Merge remote-tracking branch 'remotes/origin/master' into ignite-9720
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a6cd973a Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a6cd973a Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a6cd973a Branch: refs/heads/ignite-9720 Commit: a6cd973a2b80d3bb1b6ead420b4d9d7d2afc9084 Parents: 28a76b3 e1f8f46 Author: sboikov <sboi...@apache.org> Authored: Mon Oct 22 18:15:20 2018 +0300 Committer: sboikov <sboi...@apache.org> Committed: Mon Oct 22 18:15:20 2018 +0300 ---------------------------------------------------------------------- .../ignite/codegen/MessageCodeGenerator.java | 6 +- .../apache/ignite/IgniteSystemProperties.java | 7 + .../apache/ignite/internal/IgniteKernal.java | 2 +- .../binary/BinaryCachingMetadataHandler.java | 25 +- .../ignite/internal/binary/BinaryContext.java | 59 +- .../internal/binary/BinaryMetadataHandler.java | 10 + .../binary/BinaryNoopMetadataHandler.java | 6 + .../binary/builder/BinaryObjectBuilderImpl.java | 2 +- .../internal/client/thin/TcpIgniteClient.java | 6 + .../communication/GridIoMessageFactory.java | 18 + .../cache/CacheAffinitySharedManager.java | 115 +- .../cache/CacheConflictResolutionManager.java | 2 +- .../processors/cache/GridCacheIoManager.java | 22 +- .../processors/cache/GridCacheMapEntry.java | 9 +- .../GridCachePartitionExchangeManager.java | 21 +- .../processors/cache/GridCacheProcessor.java | 532 ++++++-- .../cache/IgniteCacheOffheapManager.java | 6 +- .../cache/IgniteCacheOffheapManagerImpl.java | 5 + .../cache/PartitionUpdateCounter.java | 30 +- .../processors/cache/StartCacheInfo.java | 113 ++ .../binary/CacheObjectBinaryProcessorImpl.java | 5 + .../distributed/GridCacheTxRecoveryFuture.java | 11 - .../GridDistributedTxRemoteAdapter.java | 52 +- .../distributed/dht/GridDhtTxFinishFuture.java | 4 +- .../distributed/dht/GridDhtTxLocalAdapter.java | 38 - .../distributed/dht/GridDhtTxPrepareFuture.java | 2 +- .../GridDhtPartitionsExchangeFuture.java | 80 +- .../topology/GridClientPartitionTopology.java | 3 +- .../dht/topology/GridDhtLocalPartition.java | 7 + .../dht/topology/GridDhtPartitionTopology.java | 5 +- .../topology/GridDhtPartitionTopologyImpl.java | 6 +- .../processors/cache/dr/GridCacheDrManager.java | 3 +- .../cache/dr/GridOsCacheDrManager.java | 2 +- .../processors/cache/mvcc/MvccProcessor.java | 7 - .../cache/mvcc/MvccProcessorImpl.java | 217 ++- .../processors/cache/mvcc/MvccUtils.java | 6 +- .../mvcc/msg/MvccRecoveryFinishedMessage.java | 116 ++ .../PartitionCountersNeighborcastRequest.java | 145 ++ .../PartitionCountersNeighborcastResponse.java | 114 ++ .../persistence/GridCacheOffheapManager.java | 13 + .../cache/transactions/IgniteTxAdapter.java | 3 +- .../cache/transactions/IgniteTxHandler.java | 125 ++ .../cache/transactions/IgniteTxManager.java | 123 +- .../PartitionCountersNeighborcastFuture.java | 211 +++ .../cache/transactions/TxCounters.java | 3 +- .../cache/version/GridCacheVersionManager.java | 31 +- .../continuous/GridContinuousProcessor.java | 6 +- .../processors/query/GridQueryProcessor.java | 77 +- .../ignite/internal/util/IgniteUtils.java | 116 +- .../internal/util/InitializationProtector.java | 79 ++ .../ignite/internal/util/lang/GridFunc.java | 2 + .../util/lang/IgniteThrowableConsumer.java | 37 + .../util/lang/IgniteThrowableRunner.java | 30 + .../binary/TestCachingMetadataHandler.java | 6 + .../binary/BinaryMetadataUpdatesFlowTest.java | 6 + .../distributed/CacheBlockOnGetAllTest.java | 196 +++ .../CacheBlockOnReadAbstractTest.java | 1277 ++++++++++++++++++ .../cache/distributed/CacheBlockOnScanTest.java | 73 + .../distributed/CacheBlockOnSingleGetTest.java | 190 +++ .../distributed/CacheStartInParallelTest.java | 219 +++ .../IgniteCrossCacheTxStoreSelfTest.java | 44 +- ...xOriginatingNodeFailureAbstractSelfTest.java | 2 +- ...cOriginatingNodeFailureAbstractSelfTest.java | 69 +- ...itionedTxOriginatingNodeFailureSelfTest.java | 2 +- ...woBackupsPrimaryNodeFailureRecoveryTest.java | 2 +- ...ePrimaryNodeFailureRecoveryAbstractTest.java | 133 +- ...licatedTxOriginatingNodeFailureSelfTest.java | 2 +- .../cache/mvcc/CacheMvccTransactionsTest.java | 4 +- ...ContinuousQueryFailoverAbstractSelfTest.java | 2 +- .../internal/util/IgniteUtilsSelfTest.java | 74 + .../TcpCommunicationSpiFaultyClientTest.java | 37 +- .../testframework/junits/GridAbstractTest.java | 33 + ...eBlockExchangeOnReadOperationsTestSuite.java | 51 + .../testsuites/IgniteCacheTestSuite7.java | 5 +- .../IgniteCacheTxRecoverySelfTestSuite.java | 2 +- .../cache/CacheRegisterMetadataLocallyTest.java | 287 ++++ .../CacheBlockOnCreateDestoryIndexTest.java | 480 +++++++ .../distributed/CacheBlockOnSqlQueryTest.java | 131 ++ .../cache/index/AbstractSchemaSelfTest.java | 6 +- .../index/H2DynamicIndexAbstractSelfTest.java | 48 +- .../cache/mvcc/CacheMvccTxRecoveryTest.java | 654 +++++++++ ...GridIndexRebuildWithMvccEnabledSelfTest.java | 3 +- .../NonCollocatedRetryMessageSelfTest.java | 119 +- ...ockExchangeOnSqlReadOperationsTestSuite.java | 39 + .../testsuites/IgniteCacheMvccSqlTestSuite.java | 58 + .../IgniteCacheWithIndexingTestSuite.java | 2 + parent/pom.xml | 2 +- 87 files changed, 6256 insertions(+), 677 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/a6cd973a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheOffheapManager.java ----------------------------------------------------------------------