Merge remote-tracking branch 'origin/master'
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1f064206 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1f064206 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1f064206 Branch: refs/heads/ignite-8446 Commit: 1f064206343f19dc84a9ceb66cc5544ebbe7fcae Parents: f041175 9e884e5 Author: devozerov <ppoze...@gmail.com> Authored: Tue Jul 31 17:16:36 2018 +0300 Committer: devozerov <ppoze...@gmail.com> Committed: Tue Jul 31 17:16:36 2018 +0300 ---------------------------------------------------------------------- examples/pom.xml | 21 - .../cluster/TensorFlowClusterExample.java | 118 ------ .../org/apache/ignite/cache/CacheMetrics.java | 77 ++++ .../internal/commandline/CommandHandler.java | 162 ++++--- .../commandline/cache/CacheArguments.java | 34 ++ .../cache/CacheClusterMetricsMXBeanImpl.java | 55 +++ .../cache/CacheLocalMetricsMXBeanImpl.java | 55 +++ .../processors/cache/CacheMetricsImpl.java | 206 +++++++++ .../processors/cache/CacheMetricsSnapshot.java | 157 +++++++ .../processors/cache/GridCacheAdapter.java | 67 ++- .../processors/cache/GridCacheEntryEx.java | 8 +- .../processors/cache/GridCacheMapEntry.java | 115 +++-- .../cache/GridCacheUpdateAtomicResult.java | 15 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 5 + .../GridDhtAtomicAbstractUpdateFuture.java | 8 +- .../GridDhtAtomicAbstractUpdateRequest.java | 16 +- .../dht/atomic/GridDhtAtomicCache.java | 63 ++- .../GridDhtAtomicSingleUpdateRequest.java | 11 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 5 +- .../distributed/near/GridNearAtomicCache.java | 14 +- .../local/atomic/GridLocalAtomicCache.java | 116 ++++-- .../cache/transactions/IgniteTxAdapter.java | 2 + .../cache/verify/IdleVerifyDumpResult.java | 73 ++++ .../cache/verify/IdleVerifyResultV2.java | 85 +++- .../verify/VerifyBackupPartitionsDumpTask.java | 230 ++++++++++ .../platform/cache/PlatformCache.java | 11 + .../visor/verify/VisorIdleVerifyDumpTask.java | 37 ++ .../verify/VisorIdleVerifyDumpTaskArg.java | 73 ++++ .../visor/verify/VisorIdleVerifyJob.java | 83 ++++ .../resources/META-INF/classnames.properties | 2 + .../cache/GridCacheAbstractMetricsSelfTest.java | 417 +++++++++++++++++++ .../processors/cache/GridCacheTestEntryEx.java | 8 +- .../GridCacheNearAtomicMetricsSelfTest.java | 35 ++ .../near/GridCacheNearMetricsSelfTest.java | 388 +++++++++++++++++ .../platform/PlatformCacheWriteMetricsTask.java | 55 +++ .../testframework/junits/GridAbstractTest.java | 95 +++-- .../ignite/testsuites/IgniteBasicTestSuite.java | 12 +- .../IgniteBasicWithPersistenceTestSuite.java | 67 +++ ...IgniteBinaryObjectsComputeGridTestSuite.java | 3 + .../IgniteCacheEvictionSelfTestSuite.java | 3 - .../IgniteCacheFullApiSelfTestSuite.java | 3 + .../IgniteCacheMetricsSelfTestSuite.java | 6 +- .../ignite/testsuites/IgniteCacheTestSuite.java | 8 +- .../testsuites/IgniteCacheTestSuite2.java | 5 +- .../testsuites/IgniteCacheTestSuite3.java | 7 +- .../testsuites/IgniteCacheTestSuite4.java | 5 +- .../testsuites/IgniteCacheTestSuite5.java | 6 +- .../testsuites/IgniteCacheTestSuite6.java | 28 +- .../testsuites/IgniteCacheTestSuite7.java | 53 ++- .../testsuites/IgniteComputeGridTestSuite.java | 2 - .../testsuites/IgniteKernalSelfTestSuite.java | 7 +- .../IgniteMarshallerSelfTestSuite.java | 5 +- .../testsuites/IgniteUtilSelfTestSuite.java | 7 +- .../ignite/util/GridCommandHandlerTest.java | 178 +++++++- .../GridInternalTaskUnusedWalSegmentsTest.java | 27 +- ...acheWithIndexingAndPersistenceTestSuite.java | 38 ++ .../IgniteCacheWithIndexingTestSuite.java | 6 +- .../Cache/CacheMetricsTest.cs | 11 + .../Apache.Ignite.Core/Cache/ICacheMetrics.cs | 88 ++++ .../Impl/Cache/CacheMetricsImpl.cs | 79 +++- modules/tensorflow/README.txt | 55 ++- modules/tensorflow/pom.xml | 56 ++- modules/tensorflow/src/main/assembly/zip.xml | 56 +++ .../cluster/TensorFlowClusterGateway.java | 34 +- .../TensorFlowClusterGatewayManager.java | 95 ++++- .../cluster/TensorFlowClusterMaintainer.java | 105 +++-- .../cluster/TensorFlowClusterManager.java | 268 ++++++++---- .../cluster/TensorFlowJobArchive.java | 65 +++ .../cluster/spec/TensorFlowClusterSpec.java | 39 ++ .../spec/TensorFlowServerAddressSpec.java | 14 + .../tfrunning/TensorFlowServerManager.java | 112 +---- .../TensorFlowServerScriptFormatter.java | 62 +++ .../cluster/util/ClusterPortManager.java | 168 ++++++-- .../cluster/util/TensorFlowChiefRunner.java | 80 ++++ .../cluster/util/TensorFlowClusterResolver.java | 92 ++-- .../util/TensorFlowUserScriptRunner.java | 236 +++++++++++ .../ignite/tensorflow/core/ProcessManager.java | 5 +- .../tensorflow/core/ProcessManagerWrapper.java | 5 +- .../longrunning/LongRunningProcessManager.java | 19 +- .../task/LongRunningProcessStartTask.java | 4 +- .../core/nativerunning/NativeProcess.java | 6 +- .../nativerunning/NativeProcessManager.java | 12 +- .../task/NativeProcessStartTask.java | 81 +--- .../PythonProcessBuilderSupplier.java | 57 +++ .../pythonrunning/PythonProcessManager.java | 35 +- .../core/util/AsyncNativeProcessRunner.java | 107 +++++ .../core/util/NativeProcessRunner.java | 133 ++++++ .../tensorflow/submitter/JobSubmitter.java | 35 ++ .../submitter/command/AbstractCommand.java | 55 +++ .../submitter/command/AttachCommand.java | 51 +++ .../tensorflow/submitter/command/PsCommand.java | 47 +++ .../submitter/command/RootCommand.java | 42 ++ .../submitter/command/StartCommand.java | 205 +++++++++ .../submitter/command/StopCommand.java | 50 +++ .../submitter/command/package-info.java | 22 + .../tensorflow/submitter/package-info.java | 23 + .../tensorflow/util/SerializableConsumer.java | 29 ++ .../tensorflow/util/SerializableSupplier.java | 29 ++ .../ignite/tensorflow/util/package-info.java | 22 + modules/tensorflow/src/main/sh/ignite-tf.sh | 19 + modules/tensorflow/src/main/sh/logback.xml | 36 ++ .../LongRunningProcessManagerTest.java | 10 +- 102 files changed, 5346 insertions(+), 906 deletions(-) ----------------------------------------------------------------------
