Merge branch 'ignite-3477-master' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-3477-debug
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3c5f3422 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3c5f3422 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3c5f3422 Branch: refs/heads/ignite-3477-debug Commit: 3c5f34223428bfe49d417ccf49169e2ce736e102 Parents: a0b6940 50f9f16 Author: Alexey Goncharuk <[email protected]> Authored: Wed Apr 12 10:26:09 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Wed Apr 12 10:26:09 2017 +0300 ---------------------------------------------------------------------- DEVNOTES.txt | 3 - assembly/dependencies-fabric-lgpl.xml | 3 - assembly/dependencies-fabric.xml | 4 +- assembly/dependencies-schema-import.xml | 57 - assembly/libs/README.txt | 1 + assembly/release-base.xml | 2 - assembly/release-fabric-base.xml | 15 +- assembly/release-schema-import.xml | 50 - bin/ignite-schema-import.bat | 110 - bin/ignite-schema-import.sh | 87 - examples/README-LGPL.txt | 4 +- examples/README.txt | 2 - examples/pom-standalone-lgpl.xml | 1 - examples/pom-standalone.xml | 1 - examples/pom.xml | 1 - examples/schema-import/README.txt | 38 - examples/schema-import/bin/db-init.sql | 28 - examples/schema-import/bin/h2-server.bat | 80 - examples/schema-import/bin/h2-server.sh | 66 - .../schema-import/bin/schema-import.properties | 28 - examples/schema-import/pom-standalone.xml | 90 - examples/schema-import/pom.xml | 101 - .../org/apache/ignite/schema/CacheConfig.java | 36 - .../java/org/apache/ignite/schema/Demo.java | 134 -- .../java/org/apache/ignite/schema/DemoNode.java | 38 - .../ignite/schema/H2DataSourceFactory.java | 35 - .../java/org/apache/ignite/schema/Person.java | 44 - .../org/apache/ignite/schema/PersonKey.java | 37 - .../benchmarks/jmh/tree/BPlusTreeBenchmark.java | 2 + .../internal/jdbc2/JdbcConnectionSelfTest.java | 34 + .../JettyRestProcessorAbstractSelfTest.java | 3 +- .../src/test/resources/spring-server-node.xml | 71 +- .../test/resources/spring-server-ssl-node.xml | 69 +- .../src/main/java/org/apache/ignite/Ignite.java | 8 + .../java/org/apache/ignite/IgniteBinary.java | 35 +- .../org/apache/ignite/IgniteFileSystem.java | 26 +- .../org/apache/ignite/IgniteJdbcDriver.java | 11 +- .../java/org/apache/ignite/MemoryMetrics.java | 95 + .../binary/BinaryAbstractIdentityResolver.java | 53 - .../binary/BinaryArrayIdentityResolver.java | 224 -- .../binary/BinaryFieldIdentityResolver.java | 307 --- .../ignite/binary/BinaryIdentityResolver.java | 42 - .../ignite/binary/BinaryTypeConfiguration.java | 25 - .../apache/ignite/cache/CacheMemoryMode.java | 63 - .../org/apache/ignite/cache/CacheMetrics.java | 70 - .../org/apache/ignite/cache/CachePeekMode.java | 5 +- .../ignite/cache/CacheTypeFieldMetadata.java | 149 -- .../apache/ignite/cache/CacheTypeMetadata.java | 379 ---- .../org/apache/ignite/cache/QueryEntity.java | 3 + .../affinity/fair/FairAffinityFunction.java | 1159 ---------- .../cache/affinity/fair/package-info.java | 21 - .../store/jdbc/CacheAbstractJdbcStore.java | 55 - .../configuration/CacheConfiguration.java | 344 +-- .../configuration/CollectionConfiguration.java | 16 - .../configuration/DataPageEvictionMode.java | 44 + .../configuration/FileSystemConfiguration.java | 6 +- .../configuration/IgniteConfiguration.java | 34 +- .../configuration/MemoryConfiguration.java | 22 +- .../MemoryPolicyConfiguration.java | 88 +- .../configuration/NearCacheConfiguration.java | 57 +- .../ignite/internal/GridKernalContext.java | 7 + .../ignite/internal/GridKernalContextImpl.java | 11 + .../ignite/internal/IgniteEventsImpl.java | 8 +- .../apache/ignite/internal/IgniteKernal.java | 12 +- .../org/apache/ignite/internal/IgnitionEx.java | 22 +- .../ignite/internal/MarshallerContextImpl.java | 20 +- .../binary/BinaryAbstractIdentityResolver.java | 56 + .../binary/BinaryArrayIdentityResolver.java | 222 ++ .../ignite/internal/binary/BinaryContext.java | 4 +- .../internal/binary/BinaryIdentityResolver.java | 43 + .../internal/binary/BinaryObjectExImpl.java | 1 - .../internal/binary/BinaryWriterExImpl.java | 1 - .../binary/builder/BinaryObjectBuilderImpl.java | 36 +- .../ignite/internal/jdbc2/JdbcConnection.java | 50 +- .../managers/communication/GridIoManager.java | 2 + .../communication/GridIoMessageFactory.java | 20 +- .../managers/communication/GridIoPolicy.java | 5 +- .../eventstorage/GridEventStorageManager.java | 12 +- .../apache/ignite/internal/pagemem/Page.java | 84 - .../ignite/internal/pagemem/PageMemory.java | 20 +- .../ignite/internal/pagemem/PageSupport.java | 114 + .../pagemem/impl/PageMemoryNoStoreImpl.java | 182 +- .../internal/pagemem/impl/PageNoStoreImpl.java | 141 -- .../cache/CacheClusterMetricsMXBeanImpl.java | 50 - .../processors/cache/CacheEvictionManager.java | 15 - .../cache/CacheLocalMetricsMXBeanImpl.java | 50 - .../processors/cache/CacheMetricsImpl.java | 134 +- .../processors/cache/CacheMetricsSnapshot.java | 120 - .../cache/CacheOffheapEvictionManager.java | 22 +- .../processors/cache/GridCacheAdapter.java | 101 +- .../processors/cache/GridCacheAtomicFuture.java | 2 +- .../processors/cache/GridCacheAttributes.java | 14 - .../cache/GridCacheConcurrentMap.java | 7 +- .../cache/GridCacheConcurrentMapImpl.java | 221 +- .../processors/cache/GridCacheContext.java | 2 - .../processors/cache/GridCacheEntryEx.java | 5 +- .../cache/GridCacheEvictionManager.java | 1757 +-------------- .../cache/GridCacheEvictionRequest.java | 248 -- .../cache/GridCacheEvictionResponse.java | 225 -- .../processors/cache/GridCacheIoManager.java | 14 - .../cache/GridCacheLocalConcurrentMap.java | 54 + .../processors/cache/GridCacheMapEntry.java | 46 +- .../processors/cache/GridCacheMvccManager.java | 84 +- .../GridCachePartitionExchangeManager.java | 6 +- .../processors/cache/GridCachePreloader.java | 4 +- .../cache/GridCachePreloaderAdapter.java | 4 +- .../processors/cache/GridCacheProcessor.java | 49 +- .../processors/cache/GridCacheUtils.java | 8 - .../cache/GridDeferredAckMessageSender.java | 11 +- .../processors/cache/GridNoStorageCacheMap.java | 1 + .../cache/IgniteCacheOffheapManagerImpl.java | 103 +- .../processors/cache/database/CacheDataRow.java | 5 + .../cache/database/CacheDataRowAdapter.java | 138 +- .../cache/database/DataStructure.java | 243 +- .../IgniteCacheDatabaseSharedManager.java | 212 +- .../cache/database/IgniteMemoryPoolMetrics.java | 33 - .../cache/database/MemoryMetricsImpl.java | 314 +++ .../processors/cache/database/MemoryPolicy.java | 35 +- .../processors/cache/database/RowStore.java | 10 - .../evict/FairFifoPageEvictionTracker.java | 74 + .../database/evict/NoOpPageEvictionTracker.java | 50 + .../evict/PageAbstractEvictionTracker.java | 243 ++ .../database/evict/PageEvictionTracker.java | 52 + .../evict/Random2LruPageEvictionTracker.java | 180 ++ .../evict/RandomLruPageEvictionTracker.java | 157 ++ .../cache/database/freelist/FreeListImpl.java | 232 +- .../cache/database/freelist/PagesList.java | 637 +++--- .../cache/database/tree/BPlusTree.java | 979 ++++---- .../cache/database/tree/io/DataPageIO.java | 110 +- .../cache/database/tree/io/PageIO.java | 3 +- .../database/tree/reuse/ReuseListImpl.java | 2 +- .../cache/database/tree/util/PageHandler.java | 381 +++- .../database/tree/util/PageLockListener.java | 42 +- .../GridDistributedCacheAdapter.java | 6 + .../dht/GridCachePartitionedConcurrentMap.java | 15 +- .../distributed/dht/GridDhtCacheAdapter.java | 29 +- .../distributed/dht/GridDhtLocalPartition.java | 318 +-- .../dht/GridDhtPartitionTopologyImpl.java | 2 +- .../GridDhtAtomicAbstractUpdateFuture.java | 4 +- .../dht/atomic/GridDhtAtomicCache.java | 57 +- .../GridNearAtomicAbstractUpdateFuture.java | 2 +- .../GridNearAtomicSingleUpdateFuture.java | 21 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 23 +- .../dht/preloader/GridDhtPartitionDemander.java | 2 +- .../dht/preloader/GridDhtPartitionMap.java | 13 +- .../dht/preloader/GridDhtPartitionSupplier.java | 8 +- .../GridDhtPartitionSupplyMessage.java | 103 +- .../GridDhtPartitionSupplyMessageV2.java | 422 ---- .../dht/preloader/GridDhtPreloader.java | 6 +- .../distributed/near/GridNearCacheAdapter.java | 21 +- .../cache/distributed/near/GridNearTxLocal.java | 2 + .../distributed/near/GridNearTxRemote.java | 4 +- .../local/atomic/GridLocalAtomicCache.java | 6 +- .../cache/transactions/IgniteTxHandler.java | 2 +- .../cache/transactions/IgniteTxManager.java | 2 +- .../cache/version/GridCacheVersionManager.java | 3 + .../cacheobject/IgniteCacheObjectProcessor.java | 7 - .../IgniteCacheObjectProcessorImpl.java | 16 - .../clock/GridClockDeltaSnapshot.java | 2 +- .../continuous/GridContinuousProcessor.java | 3 +- .../datastructures/DataStructuresProcessor.java | 1 - .../internal/processors/igfs/IgfsAsyncImpl.java | 8 +- .../internal/processors/igfs/IgfsImpl.java | 20 +- .../platform/cache/PlatformCache.java | 10 - .../utils/PlatformConfigurationUtils.java | 148 +- .../internal/processors/pool/PoolProcessor.java | 10 +- .../processors/query/GridQueryProcessor.java | 10 - .../internal/processors/query/QueryUtils.java | 328 +-- .../processors/service/GridServiceProxy.java | 10 + .../task/GridTaskThreadContextKey.java | 7 +- .../processors/task/GridTaskWorker.java | 16 +- .../org/apache/ignite/internal/util/F0.java | 196 +- .../apache/ignite/internal/util/IgniteTree.java | 14 + .../ignite/internal/util/lang/GridFunc.java | 620 +---- .../visor/cache/VisorCacheConfiguration.java | 3 +- .../cache/VisorCacheEvictionConfiguration.java | 55 - .../cache/VisorCacheQueryConfiguration.java | 1 - .../cache/VisorCacheTypeFieldMetadata.java | 14 +- .../visor/cache/VisorCacheTypeMetadata.java | 91 +- .../visor/igfs/VisorIgfsFormatTask.java | 2 +- .../visor/node/VisorIgfsConfiguration.java | 2 +- .../visor/node/VisorMemoryConfiguration.java | 1 - .../ignite/mxbean/CacheMetricsMXBean.java | 40 - .../ignite/mxbean/MemoryMetricsMXBean.java | 89 + .../ignite/spi/collision/CollisionSpi.java | 11 +- .../communication/tcp/TcpCommunicationSpi.java | 4 +- .../deployment/local/LocalDeploymentSpi.java | 5 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 3 +- .../spi/eventstorage/NoopEventStorageSpi.java | 53 + .../resources/META-INF/classnames.properties | 2 - .../core/src/test/config/spring-multicache.xml | 16 + .../test/config/store/jdbc/ignite-jdbc-type.xml | 279 +++ .../config/store/jdbc/ignite-type-metadata.xml | 276 --- .../config/websession/example-cache-client.xml | 4 + .../GridCacheAffinityBackupsSelfTest.java | 20 +- .../ignite/IgniteCacheAffinitySelfTest.java | 12 +- .../affinity/AffinityClientNodeSelfTest.java | 15 +- .../affinity/AffinityHistoryCleanupTest.java | 3 +- .../fair/FairAffinityDynamicCacheSelfTest.java | 86 - ...airAffinityFunctionBackupFilterSelfTest.java | 44 - ...ffinityFunctionExcludeNeighborsSelfTest.java | 31 - .../fair/FairAffinityFunctionNodesSelfTest.java | 247 -- .../fair/FairAffinityFunctionSelfTest.java | 31 - .../affinity/fair/FairAffinityNodesRestart.java | 130 -- .../local/LocalAffinityFunctionTest.java | 4 +- ...eJdbcStoreAbstractMultithreadedSelfTest.java | 71 +- .../cache/store/jdbc/model/Organization.java | 2 - .../cache/store/jdbc/model/OrganizationKey.java | 2 - .../ignite/cache/store/jdbc/model/Person.java | 2 - .../store/jdbc/model/PersonComplexKey.java | 4 +- .../cache/store/jdbc/model/PersonKey.java | 2 - .../ignite/custom/DummyEventFilterFactory.java | 47 + .../ignite/igfs/IgfsEventsAbstractSelfTest.java | 2 +- .../igfs/IgfsFragmentizerAbstractSelfTest.java | 2 +- .../ignite/igfs/IgfsFragmentizerSelfTest.java | 2 +- .../internal/ClusterNodeMetricsSelfTest.java | 46 +- .../GridEventStorageDefaultExceptionTest.java | 94 + .../MarshallerContextLockingSelfTest.java | 33 +- .../BinaryArrayIdentityResolverSelfTest.java | 4 - .../BinaryFieldIdentityResolverSelfTest.java | 333 --- ...ryIdentityResolverConfigurationSelfTest.java | 138 -- .../BinaryObjectBuilderAdditionalSelfTest.java | 1 - ...naryObjectBuilderDefaultMappersSelfTest.java | 1 - .../pagemem/impl/PageMemoryNoLoadSelfTest.java | 119 +- .../BinaryObjectOffHeapUnswapTemporaryTest.java | 365 --- .../cache/CacheClientStoreSelfTest.java | 4 + .../cache/CacheConfigurationLeakTest.java | 4 +- .../cache/CacheDeferredDeleteQueueTest.java | 2 +- ...cheDhtLocalPartitionAfterRemoveSelfTest.java | 2 +- .../cache/CacheEnumOperationsAbstractTest.java | 52 +- ...CacheExchangeMessageDuplicatedStateTest.java | 33 - .../cache/CacheGetEntryAbstractTest.java | 2 + ...erceptorPartitionCounterLocalSanityTest.java | 25 +- ...torPartitionCounterRandomOperationsTest.java | 111 - .../cache/CacheNearReaderUpdateTest.java | 12 - .../cache/CacheOffheapMapEntrySelfTest.java | 42 +- .../CachePutEventListenerErrorSelfTest.java | 41 +- .../CacheSerializableTransactionsTest.java | 54 +- .../cache/CacheStopAndDestroySelfTest.java | 48 +- .../cache/CacheSwapUnswapGetTest.java | 310 --- .../cache/ClusterStateAbstractTest.java | 15 +- .../cache/CrossCacheTxRandomOperationsTest.java | 36 +- ...idAbstractCacheInterceptorRebalanceTest.java | 6 - ...ridCacheAbstractByteArrayValuesSelfTest.java | 6 - .../cache/GridCacheAbstractFullApiSelfTest.java | 184 +- .../GridCacheAbstractLocalStoreSelfTest.java | 13 - .../GridCacheAbstractRemoveFailureTest.java | 26 +- .../cache/GridCacheAbstractSelfTest.java | 21 +- .../cache/GridCacheClearSelfTest.java | 113 +- .../GridCacheConcurrentTxMultiNodeTest.java | 2 +- .../GridCacheConditionalDeploymentSelfTest.java | 19 +- ...idCacheConfigurationConsistencySelfTest.java | 41 +- .../GridCacheDeploymentOffHeapSelfTest.java | 41 - ...ridCacheDeploymentOffHeapValuesSelfTest.java | 41 - .../GridCacheEvictionEventAbstractTest.java | 5 +- ...heInterceptorAtomicOffheapRebalanceTest.java | 30 - ...GridCacheInterceptorAtomicRebalanceTest.java | 6 - ...ceptorTransactionalOffheapRebalanceTest.java | 35 - ...heInterceptorTransactionalRebalanceTest.java | 6 - .../cache/GridCacheLifecycleAwareSelfTest.java | 1 + .../cache/GridCacheMemoryModeSelfTest.java | 285 --- .../cache/GridCacheObjectToStringSelfTest.java | 1 + ...HeapMultiThreadedUpdateAbstractSelfTest.java | 3 - .../GridCacheOffHeapTieredAbstractSelfTest.java | 679 ------ .../GridCacheOffHeapTieredAtomicSelfTest.java | 32 - ...heOffHeapTieredEvictionAbstractSelfTest.java | 364 --- ...acheOffHeapTieredEvictionAtomicSelfTest.java | 32 - .../GridCacheOffHeapTieredEvictionSelfTest.java | 33 - .../cache/GridCacheOffHeapTieredSelfTest.java | 33 - .../cache/GridCacheOffheapUpdateSelfTest.java | 3 - .../cache/GridCachePartitionedGetSelfTest.java | 1 - ...chePartitionedOffHeapLocalStoreSelfTest.java | 44 - .../GridCachePreloadingEvictionsSelfTest.java | 7 +- .../cache/GridCachePutAllFailoverSelfTest.java | 58 - .../cache/GridCacheReloadSelfTest.java | 4 +- .../cache/GridCacheSwapPreloadSelfTest.java | 1 - .../processors/cache/GridCacheTestEntryEx.java | 2 +- .../GridCacheTtlManagerEvictionSelfTest.java | 26 +- .../GridCacheValueBytesPreloadingSelfTest.java | 44 - .../GridCacheVersionTopologyChangeTest.java | 5 - .../processors/cache/H2CacheStoreStrategy.java | 2 +- .../cache/IgniteCacheAbstractTest.java | 6 +- ...IgniteCacheAtomicPutAllFailoverSelfTest.java | 5 - .../IgniteCacheConfigVariationsFullApiTest.java | 189 +- .../IgniteCacheEntryListenerAbstractTest.java | 11 - ...cheEntryListenerAtomicOffheapTieredTest.java | 32 - ...cheEntryListenerAtomicOffheapValuesTest.java | 32 - ...niteCacheEntryListenerExpiredEventsTest.java | 26 +- ...teCacheEntryListenerTxOffheapTieredTest.java | 32 - ...teCacheEntryListenerTxOffheapValuesTest.java | 32 - ...niteCacheExpireAndUpdateConsistencyTest.java | 35 +- .../IgniteCacheInterceptorSelfTestSuite.java | 2 - ...gniteCacheInvokeReadThroughAbstractTest.java | 4 - ...iteCacheInvokeReadThroughSingleNodeTest.java | 32 +- .../cache/IgniteCacheInvokeReadThroughTest.java | 92 +- ...gniteCacheLoadRebalanceEvictionSelfTest.java | 3 +- ...gniteCacheP2pUnmarshallingNearErrorTest.java | 4 +- .../cache/IgniteCachePeekModesAbstractTest.java | 117 +- .../IgniteCacheReadThroughEvictionSelfTest.java | 10 +- .../IgniteCacheStoreValueAbstractTest.java | 5 - .../IgniteCacheTopologySafeGetSelfTest.java | 2 +- .../cache/IgniteCacheTxNearPeekModesTest.java | 5 +- .../cache/IgniteCacheTxPeekModesTest.java | 5 +- .../IgniteClientAffinityAssignmentSelfTest.java | 20 +- ...eDynamicCacheStartNoExchangeTimeoutTest.java | 3 - .../cache/OffHeapTieredTransactionSelfTest.java | 134 -- ...heapCacheMetricsForClusterGroupSelfTest.java | 3 - ...ryDuplicateIndexObjectsAbstractSelfTest.java | 161 -- .../GridCacheBinaryObjectsAbstractSelfTest.java | 84 +- ...ateIndexObjectPartitionedAtomicSelfTest.java | 38 - ...xObjectPartitionedTransactionalSelfTest.java | 41 - ...AtomicNearDisabledOffheapTieredSelfTest.java | 29 - ...ObjectsAtomicNearDisabledOnheapSelfTest.java | 25 + ...inaryObjectsAtomicOffheapTieredSelfTest.java | 29 - ...dCacheBinaryObjectsAtomicOnheapSelfTest.java | 25 + ...tionedNearDisabledOffheapTieredSelfTest.java | 30 - ...tsPartitionedNearDisabledOnheapSelfTest.java | 25 + ...ObjectsPartitionedOffheapTieredSelfTest.java | 30 - ...eBinaryObjectsPartitionedOnheapSelfTest.java | 25 + .../dht/GridCacheMemoryModeBinarySelfTest.java | 36 - ...dCacheOffHeapTieredAtomicBinarySelfTest.java | 48 - .../GridCacheOffHeapTieredBinarySelfTest.java | 48 - ...fHeapTieredEvictionAtomicBinarySelfTest.java | 96 - ...acheOffHeapTieredEvictionBinarySelfTest.java | 96 - ...BinaryObjectsLocalOffheapTieredSelfTest.java | 29 - ...idCacheBinaryObjectsLocalOnheapSelfTest.java | 26 + .../GridCacheQueueCleanupSelfTest.java | 7 - ...dCacheQueueMultiNodeConsistencySelfTest.java | 7 - .../IgniteCollectionAbstractTest.java | 7 - .../IgniteDataStructureUniqueNameTest.java | 7 - .../GridCacheLocalAtomicOffheapSetSelfTest.java | 32 - .../GridCacheLocalAtomicQueueApiSelfTest.java | 6 - .../local/GridCacheLocalAtomicSetSelfTest.java | 7 - .../GridCacheLocalOffheapQueueApiSelfTest.java | 31 - .../local/GridCacheLocalQueueApiSelfTest.java | 7 - .../local/GridCacheLocalSetSelfTest.java | 7 - ...artitionedAtomicOffheapQueueApiSelfTest.java | 32 - ...omicOffheapQueueCreateMultiNodeSelfTest.java | 32 - ...onedAtomicOffheapQueueMultiNodeSelfTest.java | 32 - ...dCachePartitionedAtomicQueueApiSelfTest.java | 7 - ...ionedAtomicQueueCreateMultiNodeSelfTest.java | 7 - ...micQueueFailoverDataConsistencySelfTest.java | 7 - ...PartitionedAtomicQueueMultiNodeSelfTest.java | 7 - ...itionedAtomicQueueRotativeMultiNodeTest.java | 7 - ...chePartitionedAtomicSetFailoverSelfTest.java | 7 - ...rtitionedDataStructuresFailoverSelfTest.java | 7 - ...artitionedOffHeapValuesQueueApiSelfTest.java | 35 - ...achePartitionedOffHeapValuesSetSelfTest.java | 32 - ...edOffheapDataStructuresFailoverSelfTest.java | 33 - ...hePartitionedOffheapSetFailoverSelfTest.java | 32 - .../GridCachePartitionedQueueApiSelfTest.java | 7 - ...PartitionedQueueCreateMultiNodeSelfTest.java | 7 - ...dCachePartitionedQueueEntryMoveSelfTest.java | 7 - ...nedQueueFailoverDataConsistencySelfTest.java | 7 - ...CachePartitionedQueueJoinedNodeSelfTest.java | 7 - ...dCachePartitionedQueueMultiNodeSelfTest.java | 7 - ...hePartitionedQueueRotativeMultiNodeTest.java | 7 - ...GridCachePartitionedSetFailoverSelfTest.java | 7 - .../GridCachePartitionedSetSelfTest.java | 7 - .../IgnitePartitionedQueueNoBackupsTest.java | 7 - ...eplicatedDataStructuresFailoverSelfTest.java | 7 - .../GridCacheReplicatedQueueApiSelfTest.java | 7 - ...idCacheReplicatedQueueMultiNodeSelfTest.java | 7 - ...cheReplicatedQueueRotativeMultiNodeTest.java | 7 - .../GridCacheReplicatedSetSelfTest.java | 7 - ...eLateAffinityAssignmentFairAffinityTest.java | 32 - .../CacheLateAffinityAssignmentTest.java | 6 +- ...tractDistributedByteArrayValuesSelfTest.java | 120 +- .../GridCacheAbstractNodeRestartSelfTest.java | 116 +- ...tractPartitionedByteArrayValuesSelfTest.java | 33 - ...heExpiredEntriesPreloadAbstractSelfTest.java | 122 - .../IgniteCacheAtomicNodeRestartTest.java | 5 - ...teCacheClientNodePartitionsExchangeTest.java | 18 +- .../IgniteCacheNearOffheapGetSelfTest.java | 136 -- .../IgniteCacheReadFromBackupTest.java | 6 +- .../IgniteCacheTxFairAffinityNodeJoinTest.java | 35 - .../IgniteCacheTxIteratorSelfTest.java | 34 +- ...arDisabledFairAffinityPutGetRestartTest.java | 35 - ...tPartitionedOnlyByteArrayValuesSelfTest.java | 55 +- ...acheAtomicExpiredEntriesPreloadSelfTest.java | 46 - ...eColocatedOptimisticTransactionSelfTest.java | 1 - .../dht/GridCacheDhtEntrySelfTest.java | 4 +- ...GridCacheDhtEvictionNearReadersSelfTest.java | 6 +- .../dht/GridCacheDhtEvictionSelfTest.java | 356 --- ...idCacheDhtExpiredEntriesPreloadSelfTest.java | 39 - .../dht/GridCacheDhtPreloadOffHeapSelfTest.java | 38 - .../dht/GridCacheDhtPreloadOnheapSelfTest.java | 26 + .../dht/GridCacheDhtPreloadSelfTest.java | 38 +- ...icOffHeapTieredMultiNodeFullApiSelfTest.java | 43 - ...NearDisabledAtomicOnheapFullApiSelfTest.java | 38 + ...ledAtomicOnheapMultiNodeFullApiSelfTest.java | 38 + ...ledFairAffinityMultiNodeFullApiSelfTest.java | 36 - ...ionedNearDisabledOffHeapFullApiSelfTest.java | 33 - ...DisabledOffHeapMultiNodeFullApiSelfTest.java | 33 - ...abledOffHeapTieredAtomicFullApiSelfTest.java | 57 - ...earDisabledOffHeapTieredFullApiSelfTest.java | 33 - ...edOffHeapTieredMultiNodeFullApiSelfTest.java | 33 - ...tionedNearDisabledOnheapFullApiSelfTest.java | 27 + ...rDisabledOnheapMultiNodeFullApiSelfTest.java | 27 + .../dht/IgniteCacheConcurrentPutGetRemove.java | 27 +- .../IgniteCacheCrossCacheTxFailoverTest.java | 46 +- .../dht/IgniteCacheMultiTxLockSelfTest.java | 1 + .../IgniteCachePutRetryAbstractSelfTest.java | 53 +- .../dht/IgniteCachePutRetryAtomicSelfTest.java | 2 +- ...gniteCachePutRetryTransactionalSelfTest.java | 28 +- .../AtomicPutAllChangingTopologyTest.java | 4 +- ...eAtomicInvalidPartitionHandlingSelfTest.java | 65 +- .../atomic/IgniteCacheAtomicProtocolTest.java | 3 +- ...nlyFairAffinityMultiNodeFullApiSelfTest.java | 36 - ...tomicClientOnlyMultiNodeFullApiSelfTest.java | 113 +- ...micFairAffinityMultiNodeFullApiSelfTest.java | 35 - ...ledFairAffinityMultiNodeFullApiSelfTest.java | 36 - ...eAtomicNearOnlyMultiNodeFullApiSelfTest.java | 52 - .../GridCacheAtomicOffHeapFullApiSelfTest.java | 67 - ...heAtomicOffHeapMultiNodeFullApiSelfTest.java | 68 - ...CacheAtomicOffHeapTieredFullApiSelfTest.java | 32 - ...icOffHeapTieredMultiNodeFullApiSelfTest.java | 33 - .../GridCacheAtomicOnheapFullApiSelfTest.java | 28 + ...cheAtomicOnheapMultiNodeFullApiSelfTest.java | 26 + ...derFairAffinityMultiNodeFullApiSelfTest.java | 36 - ...PrimaryWriteOrderOffHeapFullApiSelfTest.java | 32 - ...yWriteOrderOffHeapTieredFullApiSelfTest.java | 33 - ...cPrimaryWriteOrderOnheapFullApiSelfTest.java | 28 + ...riteOrderOnheapMultiNodeFullApiSelfTest.java | 29 + ...ityOrderOffHeapMultiNodeFullApiSelfTest.java | 33 - ...erOffHeapTieredMultiNodeFullApiSelfTest.java | 33 - ...dCacheNearExpiredEntriesPreloadSelfTest.java | 33 - ...nlyFairAffinityMultiNodeFullApiSelfTest.java | 35 - .../near/GridCacheNearReadersSelfTest.java | 7 +- ...ePartitionedAtomicOnheapFullApiSelfTest.java | 38 + ...nedAtomicOnheapMultiNodeFullApiSelfTest.java | 38 + .../GridCachePartitionedEvictionSelfTest.java | 1 + .../GridCachePartitionedFullApiSelfTest.java | 2 - ...achePartitionedMultiNodeFullApiSelfTest.java | 43 - ...ePartitionedMultiThreadedPutGetSelfTest.java | 2 +- ...dCachePartitionedOffHeapFullApiSelfTest.java | 32 - ...titionedOffHeapMultiNodeFullApiSelfTest.java | 32 - ...PartitionedOffHeapTieredFullApiSelfTest.java | 32 - ...edOffHeapTieredMultiNodeFullApiSelfTest.java | 74 - ...idCachePartitionedOnheapFullApiSelfTest.java | 26 + ...rtitionedOnheapMultiNodeFullApiSelfTest.java | 26 + .../GridNearOffheapCacheStoreUpdateTest.java | 35 - ...eRebalancingUnmarshallingFailedSelfTest.java | 6 +- ...xcludeNeighborsMultiNodeFullApiSelfTest.java | 36 - ...tedFairAffinityMultiNodeFullApiSelfTest.java | 35 - ...stractReplicatedByteArrayValuesSelfTest.java | 29 - ...nedFairAffinityMultiNodeFullApiSelfTest.java | 37 - .../GridCacheReplicatedEvictionSelfTest.java | 135 -- ...idCacheReplicatedOffHeapFullApiSelfTest.java | 32 - ...plicatedOffHeapMultiNodeFullApiSelfTest.java | 32 - ...eReplicatedOffHeapTieredFullApiSelfTest.java | 33 - ...edOffHeapTieredMultiNodeFullApiSelfTest.java | 33 - ...ridCacheReplicatedOnheapFullApiSelfTest.java | 26 + ...eplicatedOnheapMultiNodeFullApiSelfTest.java | 26 + ...idCacheReplicatedPreloadOffHeapSelfTest.java | 37 - .../cache/eviction/EvictionAbstractTest.java | 37 +- .../GridCacheBatchEvictUnswapSelfTest.java | 199 -- ...heConcurrentEvictionConsistencySelfTest.java | 6 +- .../GridCacheConcurrentEvictionsSelfTest.java | 1 + .../GridCacheDistributedEvictionsSelfTest.java | 235 -- .../GridCacheEmptyEntriesAbstractSelfTest.java | 4 +- .../GridCacheEvictableEntryEqualsSelfTest.java | 1 + .../GridCacheEvictionFilterSelfTest.java | 2 +- .../GridCacheEvictionLockUnlockSelfTest.java | 1 + .../GridCacheEvictionTouchSelfTest.java | 12 +- ...cheSynchronousEvictionsFailoverSelfTest.java | 166 -- .../lru/LruNearEvictionPolicySelfTest.java | 28 - .../LruNearOnlyNearEvictionPolicySelfTest.java | 55 - .../paged/PageEvictionAbstractTest.java | 124 + .../paged/PageEvictionMultinodeTest.java | 110 + .../paged/PageEvictionReadThroughTest.java | 140 ++ .../paged/PageEvictionTouchOrderTest.java | 109 + .../paged/PageEvictionWithRebalanceTest.java | 81 + .../Random2LruPageEvictionMultinodeTest.java | 30 + ...Random2LruPageEvictionWithRebalanceTest.java | 30 + .../RandomLruPageEvictionMultinodeTest.java | 30 + .../RandomLruPageEvictionWithRebalanceTest.java | 30 + .../cache/eviction/paged/TestObject.java | 78 + .../SortedEvictionPolicyPerformanceTest.java | 2 +- ...CacheAtomicLocalOffheapExpiryPolicyTest.java | 30 - ...eCacheAtomicLocalOnheapExpiryPolicyTest.java | 26 + ...gniteCacheAtomicOffheapExpiryPolicyTest.java | 30 - ...IgniteCacheAtomicOnheapExpiryPolicyTest.java | 26 + ...rimaryWriteOrderOffheapExpiryPolicyTest.java | 31 - ...teOrderWithStoreOffheapExpiryPolicyTest.java | 31 - ...AtomicReplicatedOffheapExpiryPolicyTest.java | 30 - ...eAtomicWithStoreOffheapExpiryPolicyTest.java | 30 - .../IgniteCacheExpiryPolicyAbstractTest.java | 13 - .../IgniteCacheExpiryPolicyTestSuite.java | 13 - ...eCacheExpiryPolicyWithStoreAbstractTest.java | 3 - ...niteCacheTxLocalOffheapExpiryPolicyTest.java | 30 - .../IgniteCacheTxOffheapExpiryPolicyTest.java | 30 - ...acheTxReplicatedOffheapExpiryPolicyTest.java | 30 - ...CacheTxWithStoreOffheapExpiryPolicyTest.java | 30 - ...dCacheLocalAtomicOffHeapFullApiSelfTest.java | 42 - ...LocalAtomicOffHeapTieredFullApiSelfTest.java | 32 - .../GridCacheLocalByteArrayValuesSelfTest.java | 64 +- .../GridCacheLocalOffHeapFullApiSelfTest.java | 30 - ...dCacheLocalOffHeapTieredFullApiSelfTest.java | 32 - ...LocalCacheOffHeapAndSwapMetricsSelfTest.java | 627 ------ ...OnlyFairAffinityMultiJvmFullApiSelfTest.java | 31 - ...omicFairAffinityMultiJvmFullApiSelfTest.java | 31 - ...bledFairAffinityMultiJvmFullApiSelfTest.java | 36 - ...cheAtomicOffHeapMultiJvmFullApiSelfTest.java | 31 - ...micOffHeapTieredMultiJvmFullApiSelfTest.java | 36 - ...acheAtomicOnheapMultiJvmFullApiSelfTest.java | 28 + ...rderFairAffinityMultiJvmFullApiSelfTest.java | 31 - ...WriteOrderOnheapMultiJvmFullApiSelfTest.java | 29 + ...rityOrderOffHeapMultiJvmFullApiSelfTest.java | 31 - ...derOffHeapTieredMultiJvmFullApiSelfTest.java | 36 - ...OnlyFairAffinityMultiJvmFullApiSelfTest.java | 31 - ...onedFairAffinityMultiJvmFullApiSelfTest.java | 31 - ...micOffHeapTieredMultiJvmFullApiSelfTest.java | 36 - ...bledAtomicOnheapMultiJvmFullApiSelfTest.java | 28 + ...bledFairAffinityMultiJvmFullApiSelfTest.java | 31 - ...rDisabledOffHeapMultiJvmFullApiSelfTest.java | 31 - ...ledOffHeapTieredMultiJvmFullApiSelfTest.java | 36 - ...arDisabledOnheapMultiJvmFullApiSelfTest.java | 28 + ...rtitionedOffHeapMultiJvmFullApiSelfTest.java | 31 - ...nedOffHeapTieredMultiJvmFullApiSelfTest.java | 36 - ...artitionedOnheapMultiJvmFullApiSelfTest.java | 28 + ...eplicatedOffHeapMultiJvmFullApiSelfTest.java | 31 - ...tedOffHeapTieredMultiJvmFullApiSelfTest.java | 36 - ...ReplicatedOnheapMultiJvmFullApiSelfTest.java | 28 + .../GridCacheSwapScanQueryAbstractSelfTest.java | 450 ---- .../query/GridCacheSwapScanQuerySelfTest.java | 25 - .../IgniteCacheQueryCacheDestroySelfTest.java | 2 - .../continuous/CacheContinuousBatchAckTest.java | 73 +- ...eContinuousQueryAsyncFilterListenerTest.java | 170 +- ...acheContinuousQueryExecuteInPrimaryTest.java | 2 - ...usQueryFactoryFilterRandomOperationTest.java | 2 - ...ContinuousQueryFailoverAbstractSelfTest.java | 10 - ...tomicPrimaryWriteOrderOffheapTieredTest.java | 33 - ...tinuousQueryFailoverTxOffheapTieredTest.java | 32 - .../CacheContinuousQueryOperationP2PTest.java | 31 +- .../CacheContinuousQueryOrderingEventTest.java | 127 +- ...acheContinuousQueryRandomOperationsTest.java | 246 -- ...CacheKeepBinaryIterationNearEnabledTest.java | 6 +- ...acheKeepBinaryIterationStoreEnabledTest.java | 6 +- .../CacheKeepBinaryIterationTest.java | 105 +- .../ContinuousQueryPeerClassLoadingTest.java | 142 ++ ...ridCacheContinuousQueryAbstractSelfTest.java | 10 - ...eContinuousQueryAtomicOffheapTieredTest.java | 32 - ...eContinuousQueryAtomicOffheapValuesTest.java | 32 - ...CacheContinuousQueryTxOffheapTieredTest.java | 32 - ...CacheContinuousQueryTxOffheapValuesTest.java | 32 - .../IgniteCacheContinuousQueryClientTest.java | 23 +- ...edEntryPartitionedAtomicOffHeapSelfTest.java | 35 - ...PartitionedTransactionalOffHeapSelfTest.java | 36 - ...nedEntryReplicatedAtomicOffHeapSelfTest.java | 35 - ...yReplicatedTransactionalOffHeapSelfTest.java | 36 - .../database/BPlusTreeReuseSelfTest.java | 29 +- .../processors/database/BPlusTreeSelfTest.java | 123 +- .../database/FreeListImplSelfTest.java | 16 +- .../database/MemoryMetricsSelfTest.java | 313 +++ .../database/MetadataStorageSelfTest.java | 3 +- .../DataStreamProcessorSelfTest.java | 2 - ...faultIgfsSecondaryFileSystemTestAdapter.java | 2 +- .../igfs/IgfsAbstractBaseSelfTest.java | 20 +- .../processors/igfs/IgfsAbstractSelfTest.java | 15 +- .../IgfsAtomicPrimaryOffheapTieredSelfTest.java | 39 - .../IgfsAtomicPrimaryOffheapValuesSelfTest.java | 39 - ...sCachePerBlockLruEvictionPolicySelfTest.java | 3 +- .../processors/igfs/IgfsIgniteMock.java | 8 + .../processors/igfs/IgfsMaxSizeSelfTest.java | 1 - .../igfs/IgfsMetaManagerSelfTest.java | 2 +- .../processors/igfs/IgfsMetricsSelfTest.java | 2 +- .../internal/processors/igfs/IgfsMock.java | 4 +- .../igfs/IgfsPrimaryOffheapTieredSelfTest.java | 33 - .../igfs/IgfsPrimaryOffheapValuesSelfTest.java | 33 - .../processors/igfs/IgfsProcessorSelfTest.java | 8 +- .../processors/igfs/IgfsStreamsSelfTest.java | 2 +- .../processors/igfs/IgfsTaskSelfTest.java | 2 +- .../IgfsAbstractRecordResolverSelfTest.java | 2 +- .../loadtests/GridCacheMultiNodeLoadTest.java | 1 + .../GridCachePartitionedAtomicLongLoadTest.java | 2 +- .../marshaller/MarshallerContextSelfTest.java | 80 +- .../platform/PlatformCacheWriteMetricsTask.java | 126 +- .../ignite/platform/PlatformStopIgniteTask.java | 11 +- .../services/ServiceThreadPoolSelfTest.java | 133 ++ ...gniteClientReconnectMassiveShutdownTest.java | 3 - .../ignite/testframework/GridTestUtils.java | 113 - .../configvariations/ConfigVariations.java | 28 +- .../testframework/junits/GridAbstractTest.java | 56 +- .../junits/GridTestKernalContext.java | 1 + ...IgniteCacheConfigVariationsAbstractTest.java | 38 +- .../ignite/testframework/junits/IgniteMock.java | 6 + .../junits/common/GridCommonAbstractTest.java | 10 +- .../junits/multijvm/IgniteProcessProxy.java | 6 + .../ConfigVariationsTestSuiteBuilderTest.java | 4 +- .../ignite/testsuites/IgniteBasicTestSuite.java | 4 +- .../testsuites/IgniteBinaryCacheTestSuite.java | 19 - .../IgniteBinaryObjectsTestSuite.java | 17 - .../IgniteCacheDataStructuresSelfTestSuite.java | 18 - .../IgniteCacheEvictionSelfTestSuite.java | 21 +- .../IgniteCacheFailoverTestSuite.java | 4 - ...IgniteCacheFullApiMultiJvmSelfTestSuite.java | 54 +- .../IgniteCacheFullApiSelfTestSuite.java | 102 +- .../IgniteCacheMetricsSelfTestSuite.java | 2 - .../ignite/testsuites/IgniteCacheTestSuite.java | 36 +- .../testsuites/IgniteCacheTestSuite2.java | 37 +- .../testsuites/IgniteCacheTestSuite3.java | 14 +- .../testsuites/IgniteCacheTestSuite4.java | 9 - .../testsuites/IgniteCacheTestSuite5.java | 10 - .../testsuites/IgniteComputeGridTestSuite.java | 2 + .../ignite/testsuites/IgniteIgfsTestSuite.java | 9 - .../testsuites/IgniteKernalSelfTestSuite.java | 2 + .../hadoop/impl/v2/HadoopV2Context.java | 6 +- .../impl/HadoopAbstractMapReduceTest.java | 1 - .../impl/HadoopTaskExecutionSelfTest.java | 2 +- ...opClientProtocolMultipleServersSelfTest.java | 2 +- .../client/HadoopClientProtocolSelfTest.java | 2 +- .../igfs/HadoopFIleSystemFactorySelfTest.java | 1 - .../igfs/HadoopIgfsDualAbstractSelfTest.java | 1 - .../hadoop/impl/igfs/IgfsEventsTestSuite.java | 2 +- .../HibernateAccessStrategyAdapter.java | 8 +- .../cache/hibernate/HibernateCacheProxy.java | 811 +++++++ .../hibernate/HibernateCollectionRegion.java | 3 +- .../cache/hibernate/HibernateEntityRegion.java | 3 +- .../hibernate/HibernateGeneralDataRegion.java | 3 +- .../hibernate/HibernateKeyTransformer.java | 28 + .../cache/hibernate/HibernateKeyWrapper.java | 72 + .../hibernate/HibernateNaturalIdRegion.java | 3 +- .../HibernateNonStrictAccessStrategy.java | 5 +- .../hibernate/HibernateQueryResultsRegion.java | 3 +- .../HibernateReadOnlyAccessStrategy.java | 3 +- .../HibernateReadWriteAccessStrategy.java | 3 +- .../ignite/cache/hibernate/HibernateRegion.java | 6 +- .../cache/hibernate/HibernateRegionFactory.java | 30 +- .../hibernate/HibernateTimestampsRegion.java | 3 +- .../HibernateTransactionalAccessStrategy.java | 2 +- .../HibernateTransactionalDataRegion.java | 3 +- .../hibernate/HibernateL2CacheSelfTest.java | 2 +- .../IgniteBinaryHibernateTestSuite.java | 37 + modules/hibernate5/README.txt | 48 + modules/hibernate5/licenses/apache-2.0.txt | 202 ++ modules/hibernate5/pom.xml | 146 ++ .../HibernateAbstractRegionAccessStrategy.java | 99 + .../HibernateAccessStrategyAdapter.java | 379 ++++ .../cache/hibernate/HibernateCacheProxy.java | 811 +++++++ .../hibernate/HibernateCollectionRegion.java | 114 + .../cache/hibernate/HibernateEntityRegion.java | 129 ++ .../hibernate/HibernateGeneralDataRegion.java | 72 + .../hibernate/HibernateKeyTransformer.java | 28 + .../cache/hibernate/HibernateKeyWrapper.java | 108 + .../hibernate/HibernateNaturalIdRegion.java | 113 + .../HibernateNonStrictAccessStrategy.java | 222 ++ .../hibernate/HibernateQueryResultsRegion.java | 70 + .../HibernateReadOnlyAccessStrategy.java | 107 + .../HibernateReadWriteAccessStrategy.java | 328 +++ .../ignite/cache/hibernate/HibernateRegion.java | 99 + .../cache/hibernate/HibernateRegionFactory.java | 255 +++ .../hibernate/HibernateTimestampsRegion.java | 39 + .../HibernateTransactionalAccessStrategy.java | 141 ++ .../HibernateTransactionalDataRegion.java | 107 + .../ignite/cache/hibernate/package-info.java | 24 + .../hibernate/CacheHibernateBlobStore.java | 542 +++++ .../CacheHibernateBlobStoreEntry.hbm.xml | 31 + .../hibernate/CacheHibernateBlobStoreEntry.java | 89 + .../CacheHibernateBlobStoreFactory.java | 235 ++ .../CacheHibernateStoreSessionListener.java | 223 ++ .../cache/store/hibernate/package-info.java | 22 + .../src/test/config/factory-cache.xml | 59 + .../src/test/config/factory-cache1.xml | 61 + .../config/factory-incorrect-store-cache.xml | 56 + .../HibernateL2CacheConfigurationSelfTest.java | 409 ++++ .../hibernate/HibernateL2CacheSelfTest.java | 1948 ++++++++++++++++ .../HibernateL2CacheTransactionalSelfTest.java | 154 ++ ...nateL2CacheTransactionalUseSyncSelfTest.java | 31 + .../CacheHibernateBlobStoreNodeRestartTest.java | 54 + .../CacheHibernateBlobStoreSelfTest.java | 113 + .../CacheHibernateStoreFactorySelfTest.java | 326 +++ ...heHibernateStoreSessionListenerSelfTest.java | 241 ++ .../cache/store/hibernate/hibernate.cfg.xml | 42 + .../cache/store/hibernate/package-info.java | 22 + .../IgniteBinaryHibernate5TestSuite.java | 37 + .../testsuites/IgniteHibernate5TestSuite.java | 57 + .../processors/query/h2/IgniteH2Indexing.java | 23 +- .../processors/query/h2/database/H2Tree.java | 14 +- .../query/h2/database/H2TreeIndex.java | 16 +- .../processors/query/h2/opt/GridH2Row.java | 5 + .../processors/query/h2/opt/GridH2Table.java | 15 +- .../query/h2/opt/GridH2TreeIndex.java | 29 +- .../query/h2/sql/GridSqlOperationType.java | 23 +- .../query/h2/sql/GridSqlQueryParser.java | 19 +- .../cache/BinarySerializationQuerySelfTest.java | 30 +- .../cache/CacheIndexStreamerTest.java | 3 - .../cache/CacheIndexingOffheapCleanupTest.java | 157 -- .../CacheOffheapBatchIndexingBaseTest.java | 6 +- .../CacheOffheapBatchIndexingMultiTypeTest.java | 17 +- ...CacheOffheapBatchIndexingSingleTypeTest.java | 20 +- .../CacheOperationsWithExpirationTest.java | 68 +- .../cache/CacheQueryEvictDataLostTest.java | 120 + .../CacheQueryOffheapEvictDataLostTest.java | 136 -- .../CacheRandomOperationsMultithreadedTest.java | 64 +- .../ClientReconnectAfterClusterRestartTest.java | 16 +- ...ryDuplicateIndexObjectsAbstractSelfTest.java | 159 ++ .../cache/GridCacheOffHeapAndSwapSelfTest.java | 453 ---- .../cache/GridCacheOffHeapSelfTest.java | 1 - .../GridCacheOffheapIndexEntryEvictTest.java | 4 - .../cache/GridCacheOffheapIndexGetSelfTest.java | 8 - .../cache/GridCacheQuerySimpleBenchmark.java | 3 - .../cache/GridIndexingWithNoopSwapSelfTest.java | 3 +- ...aryObjectQueryArgumentsOffheapLocalTest.java | 28 - ...teBinaryObjectQueryArgumentsOffheapTest.java | 30 - .../IgniteBinaryObjectQueryArgumentsTest.java | 11 - ...niteCacheAbstractInsertSqlQuerySelfTest.java | 129 -- ...CacheDistributedJoinQueryConditionsTest.java | 16 - .../IgniteCacheInsertSqlQuerySelfTest.java | 40 - .../cache/IgniteCacheMergeSqlQuerySelfTest.java | 38 - .../IgniteCacheObjectKeyIndexingSelfTest.java | 124 + .../cache/IgniteCacheOffheapEvictQueryTest.java | 6 - .../cache/IgniteCacheOffheapIndexScanTest.java | 3 - ...CacheOffheapTieredMultithreadedSelfTest.java | 301 --- .../cache/IgniteCacheQueriesLoadTest1.java | 2 - ...QueryMultiThreadedOffHeapTieredSelfTest.java | 38 - .../IgniteCacheQueryMultiThreadedSelfTest.java | 24 +- ...QueryOffheapEvictsMultiThreadedSelfTest.java | 28 - ...eCacheQueryOffheapMultiThreadedSelfTest.java | 28 - .../cache/IgniteCrossCachesJoinsQueryTest.java | 16 - .../cache/IncorrectCacheTypeMetadataTest.java | 76 - .../cache/IncorrectQueryEntityTest.java | 3 + ...ateIndexObjectPartitionedAtomicSelfTest.java | 38 + ...xObjectPartitionedTransactionalSelfTest.java | 41 + ...QueryNodeRestartDistributedJoinSelfTest.java | 50 +- .../cache/ttl/CacheTtlAbstractSelfTest.java | 9 +- .../ttl/CacheTtlAtomicAbstractSelfTest.java | 29 + .../cache/ttl/CacheTtlAtomicLocalSelfTest.java | 34 + .../ttl/CacheTtlAtomicPartitionedSelfTest.java | 34 + .../ttl/CacheTtlOffheapAbstractSelfTest.java | 29 - .../CacheTtlOffheapAtomicAbstractSelfTest.java | 29 - .../ttl/CacheTtlOffheapAtomicLocalSelfTest.java | 34 - ...acheTtlOffheapAtomicPartitionedSelfTest.java | 34 - ...TtlOffheapTransactionalAbstractSelfTest.java | 29 - ...cheTtlOffheapTransactionalLocalSelfTest.java | 34 - ...OffheapTransactionalPartitionedSelfTest.java | 34 - .../ttl/CacheTtlOnheapAbstractSelfTest.java | 29 - .../CacheTtlOnheapAtomicAbstractSelfTest.java | 29 - .../ttl/CacheTtlOnheapAtomicLocalSelfTest.java | 34 - ...CacheTtlOnheapAtomicPartitionedSelfTest.java | 34 - ...eTtlOnheapTransactionalAbstractSelfTest.java | 29 - ...acheTtlOnheapTransactionalLocalSelfTest.java | 34 - ...lOnheapTransactionalPartitionedSelfTest.java | 34 - .../CacheTtlTransactionalAbstractSelfTest.java | 29 + .../ttl/CacheTtlTransactionalLocalSelfTest.java | 34 + ...acheTtlTransactionalPartitionedSelfTest.java | 34 + .../query/IgniteSqlSegmentedIndexSelfTest.java | 3 +- .../query/IgniteSqlSplitterSelfTest.java | 43 + .../query/h2/IgniteSqlQueryMinMaxTest.java | 376 ++++ .../h2/database/InlineIndexHelperTest.java | 48 +- .../query/h2/opt/GridH2TableSelfTest.java | 52 + .../query/h2/sql/GridQueryParsingTest.java | 27 +- .../IgniteBinaryCacheQueryTestSuite.java | 4 +- .../IgniteCacheQuerySelfTestSuite.java | 15 +- .../IgniteCacheQuerySelfTestSuite2.java | 15 +- .../IgniteCacheQuerySelfTestSuite3.java | 10 +- .../IgniteCacheQuerySelfTestSuite4.java | 4 - .../IgniteCacheWithIndexingTestSuite.java | 28 +- modules/log4j2/pom.xml | 4 +- .../ignite/logger/log4j2/Log4J2Logger.java | 23 +- modules/platforms/cpp/binary/Makefile.am | 1 - .../platforms/cpp/binary/include/Makefile.am | 3 - .../binary/binary_array_identity_resolver.h | 64 - .../include/ignite/binary/binary_containers.h | 2 +- .../ignite/binary/binary_identity_resolver.h | 61 - .../include/ignite/binary/binary_object.h | 12 +- .../include/ignite/binary/binary_raw_writer.h | 4 +- .../binary/include/ignite/binary/binary_type.h | 10 - .../include/ignite/binary/binary_writer.h | 4 +- .../ignite/impl/binary/binary_reader_impl.h | 6 +- .../ignite/impl/binary/binary_type_impl.h | 149 -- .../include/ignite/impl/binary/binary_utils.h | 12 +- .../ignite/impl/binary/binary_writer_impl.h | 12 +- .../cpp/binary/project/vs/binary.vcxproj | 4 - .../binary/project/vs/binary.vcxproj.filters | 12 - .../binary/binary_array_identity_resolver.cpp | 42 - .../cpp/core-test/config/cache-identity-32.xml | 50 + .../core-test/config/cache-identity-default.xml | 154 ++ .../cpp/core-test/config/cache-identity.xml | 124 +- .../core-test/config/cache-query-default.xml | 70 +- .../cpp/core-test/config/cache-store-32.xml | 50 + .../core-test/config/cache-store-default.xml | 71 + .../cpp/core-test/config/cache-store.xml | 41 +- .../cpp/core-test/config/cache-test-default.xml | 1 + .../cpp/core-test/config/cache-test.xml | 2 +- .../core-test/include/ignite/binary_test_defs.h | 25 - .../cpp/core-test/include/ignite/complex_type.h | 2 - .../cpp/core-test/include/ignite/test_type.h | 1 - .../cpp/core-test/include/ignite/test_utils.h | 11 + .../cpp/core-test/project/vs/core-test.vcxproj | 8 + .../project/vs/core-test.vcxproj.filters | 12 + .../src/binary_identity_resolver_test.cpp | 262 +-- .../cpp/core-test/src/binary_object_test.cpp | 8 + .../src/binary_reader_writer_raw_test.cpp | 12 +- .../core-test/src/binary_reader_writer_test.cpp | 12 +- .../cpp/core-test/src/cache_invoke_test.cpp | 7 +- .../cpp/core-test/src/cache_query_test.cpp | 227 +- .../cpp/core-test/src/cache_store_test.cpp | 11 +- .../platforms/cpp/core-test/src/cache_test.cpp | 207 +- .../cpp/core-test/src/cluster_test.cpp | 8 +- .../cpp/core-test/src/continuous_query_test.cpp | 22 +- .../cpp/core-test/src/ignition_test.cpp | 12 +- .../cpp/core/include/ignite/cache/cache.h | 161 ++ .../cpp/core/include/ignite/cache/cache_entry.h | 15 + .../include/ignite/cache/query/query_cursor.h | 28 +- .../platforms/cpp/core/include/ignite/ignite.h | 18 +- .../cpp/core/include/ignite/ignition.h | 14 +- .../ignite/impl/cache/query/query_impl.h | 7 + .../cpp/core/include/ignite/impl/helpers.h | 57 + .../core/include/ignite/impl/module_manager.h | 26 + .../cpp/core/include/ignite/impl/operations.h | 136 +- .../platforms/cpp/core/project/vs/core.vcxproj | 1 + .../cpp/core/project/vs/core.vcxproj.filters | 3 + modules/platforms/cpp/core/src/ignition.cpp | 62 +- .../core/src/impl/cache/query/query_impl.cpp | 39 +- .../cpp/core/src/impl/ignite_environment.cpp | 2 +- .../examples/include/ignite/examples/person.h | 1 - .../cpp/odbc-test/include/complex_type.h | 2 - .../platforms/cpp/odbc-test/include/test_type.h | 1 - .../ExpiryCacheHolderTest.cs | 12 +- .../Binary/BinaryDynamicRegistrationTest.cs | 50 +- .../Binary/BinaryEqualityComparerTest.cs | 217 +- .../BinaryConfigurationTest.cs | 43 + .../Affinity/AffinityFunctionSpringTest.cs | 6 +- .../Cache/Affinity/AffinityFunctionTest.cs | 92 +- .../Cache/CacheAbstractTest.cs | 18 +- .../Cache/CacheConfigurationTest.cs | 32 +- .../Cache/CacheMetricsTest.cs | 86 +- .../Cache/CacheTestAsyncWrapper.cs | 12 +- .../Cache/Query/CacheDmlQueriesTest.cs | 13 +- .../Cache/Query/CacheLinqTest.cs | 36 +- .../Cache/Store/CacheStoreTest.cs | 2 +- .../Compute/AbstractTaskTest.cs | 28 +- .../Compute/MixedClusterTest.cs | 33 +- .../Config/Cache/Affinity/affinity-function.xml | 4 +- .../Config/cache-query-continuous.xml | 118 +- .../Apache.Ignite.Core.Tests/DeploymentTest.cs | 10 + .../Apache.Ignite.Core.Tests/EventsTest.cs | 63 +- .../Examples/ExamplesTest.cs | 22 +- .../Apache.Ignite.Core.Tests/ExecutableTest.cs | 5 +- .../IgniteConfigurationSectionTest.cs | 7 +- .../IgniteConfigurationSerializerTest.cs | 32 +- .../IgniteConfigurationTest.cs | 24 +- .../Plugin/PluginTest.cs | 16 +- .../Apache.Ignite.Core.csproj | 10 +- .../Binary/BinaryArrayEqualityComparer.cs | 160 -- .../Binary/BinaryTypeConfiguration.cs | 13 - .../Cache/Affinity/Fair/FairAffinityFunction.cs | 32 - .../Cache/Affinity/Fair/Package-Info.cs | 26 - .../Cache/Affinity/IAffinityFunction.cs | 3 +- .../Cache/Configuration/CacheConfiguration.cs | 104 +- .../dotnet/Apache.Ignite.Core/Cache/ICache.cs | 16 +- .../Cache/ICacheEntryProcessorResult.cs | 12 +- .../Apache.Ignite.Core/Cache/ICacheMetrics.cs | 80 - .../Events/IEventStorageSpi.cs | 33 + .../Events/MemoryEventStorageSpi.cs | 100 + .../Events/NoopEventStorageSpi.cs | 27 + .../Apache.Ignite.Core/IgniteConfiguration.cs | 91 +- .../IgniteConfigurationSection.xsd | 65 +- .../dotnet/Apache.Ignite.Core/Ignition.cs | 28 +- .../Impl/Binary/BinaryArrayEqualityComparer.cs | 159 ++ .../Binary/BinaryEqualityComparerSerializer.cs | 100 +- .../Impl/Binary/BinaryFieldEqualityComparer.cs | 138 -- .../Impl/Binary/BinaryFullTypeDescriptor.cs | 20 - .../Impl/Binary/BinaryObject.cs | 2 +- .../Impl/Binary/BinaryObjectBuilder.cs | 7 +- .../Binary/BinarySurrogateTypeDescriptor.cs | 6 - .../Impl/Binary/BinaryUtils.cs | 10 - .../Impl/Binary/BinaryWriter.cs | 6 +- .../Impl/Binary/IBinaryEqualityComparer.cs | 63 - .../Impl/Binary/IBinaryTypeDescriptor.cs | 5 - .../Impl/Binary/Marshaller.cs | 51 +- .../Affinity/AffinityFunctionSerializer.cs | 18 +- .../Impl/Cache/CacheEntryProcessorResult.cs | 27 +- .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 28 +- .../Impl/Cache/CacheMetricsImpl.cs | 70 - .../Impl/Common/IgniteHome.cs | 21 +- .../Apache.Ignite.Core/Impl/PlatformTarget.cs | 17 +- .../Plugin/IPluginConfiguration.cs | 4 +- .../Impl/DbCache.cs | 2 +- .../Impl/CacheQueryExpressionVisitor.cs | 14 +- .../Apache.Ignite.Linq/Impl/CacheQueryParser.cs | 25 +- .../Apache.Ignite.Linq/Impl/MethodVisitor.cs | 72 +- .../examples/Apache.Ignite.Examples/App.config | 4 +- .../Datagrid/MultiTieredCacheExample.cs | 4 +- .../Datagrid/PutGetExample.cs | 13 +- .../Misc/ClientReconnectExample.cs | 38 +- modules/schema-import-db/README.txt | 4 - modules/schema-import-db/pom.xml | 55 - .../apache/ignite/schema/parser/DbColumn.java | 88 - .../ignite/schema/parser/DbMetadataReader.java | 147 -- .../apache/ignite/schema/parser/DbTable.java | 82 - .../parser/dialect/DB2MetadataDialect.java | 33 - .../parser/dialect/DatabaseMetadataDialect.java | 102 - .../parser/dialect/JdbcMetadataDialect.java | 199 -- .../parser/dialect/MySQLMetadataDialect.java | 82 - .../parser/dialect/OracleMetadataDialect.java | 360 --- modules/schema-import/README.txt | 216 -- modules/schema-import/pom.xml | 119 - .../main/java/media/data_connection_48x48.png | Bin 4443 -> 0 bytes .../src/main/java/media/error_48x48.png | Bin 4349 -> 0 bytes .../src/main/java/media/ignite_128x128.png | Bin 4917 -> 0 bytes .../src/main/java/media/ignite_16x16.png | Bin 608 -> 0 bytes .../src/main/java/media/ignite_24x24.png | Bin 930 -> 0 bytes .../src/main/java/media/ignite_32x32.png | Bin 1203 -> 0 bytes .../src/main/java/media/ignite_48x48.png | Bin 1868 -> 0 bytes .../src/main/java/media/ignite_64x64.png | Bin 2453 -> 0 bytes .../src/main/java/media/information_48x48.png | Bin 4102 -> 0 bytes .../src/main/java/media/question_48x48.png | Bin 3857 -> 0 bytes .../src/main/java/media/sign_warning_48x48.png | Bin 2988 -> 0 bytes .../schema-import/src/main/java/media/style.css | 134 -- .../src/main/java/media/text_tree_48x48.png | Bin 2567 -> 0 bytes .../ignite/schema/generator/CodeGenerator.java | 831 ------- .../ignite/schema/generator/GeneratorUtils.java | 70 - .../ignite/schema/generator/XmlGenerator.java | 446 ---- .../ignite/schema/model/PojoDescriptor.java | 497 ---- .../apache/ignite/schema/model/PojoField.java | 461 ---- .../ignite/schema/model/SchemaDescriptor.java | 62 - .../schema/parser/DatabaseMetadataParser.java | 115 - .../ignite/schema/ui/ConfirmCallable.java | 83 - .../org/apache/ignite/schema/ui/Controls.java | 697 ------ .../org/apache/ignite/schema/ui/GridPaneEx.java | 180 -- .../org/apache/ignite/schema/ui/MessageBox.java | 274 --- .../apache/ignite/schema/ui/ModalDialog.java | 50 - .../ignite/schema/ui/SchemaImportApp.java | 2115 ------------------ .../ignite/schema/ui/TextColumnValidator.java | 32 - .../schema/test/AbstractSchemaImportTest.java | 181 -- .../test/generator/CodeGeneratorTest.java | 81 - .../schema/test/generator/XmlGeneratorTest.java | 42 - .../ignite/schema/test/model/CacheConfig.txt | 409 ---- .../apache/ignite/schema/test/model/Objects.txt | 531 ----- .../ignite/schema/test/model/ObjectsKey.txt | 96 - .../ignite/schema/test/model/Primitives.txt | 535 ----- .../ignite/schema/test/model/PrimitivesKey.txt | 96 - .../org/apache/ignite/schema/test/model/Tst.txt | 535 ----- .../apache/ignite/schema/test/model/TstKey.txt | 96 - .../schema/test/model/ignite-type-metadata.xml | 666 ------ .../test/parser/DbMetadataParserTest.java | 134 -- .../testsuites/IgniteSchemaImportTestSuite.java | 42 - modules/spring/pom.xml | 6 + .../org/apache/ignite/IgniteSpringBean.java | 7 + .../apache/ignite/cache/spring/SpringCache.java | 4 +- .../ignite/cache/spring/SpringCacheTest.java | 177 ++ .../ignite/internal/GridFactorySelfTest.java | 3 + .../IgniteExcludeInConfigurationTest.java | 14 +- .../org/apache/ignite/spring/sprint-exclude.xml | 19 +- .../testsuites/IgniteSpringTestSuite.java | 3 + .../ant/beautifier/GridJavadocAntTask.java | 18 +- .../commands/cache/VisorCacheCommand.scala | 5 - .../modules/configuration/Version.service.js | 2 +- .../states/configuration/clusters/general.pug | 2 +- modules/web-console/web-agent/README.txt | 2 +- modules/web-console/web-agent/pom.xml | 12 - .../ignite/console/agent/db/DbColumn.java | 88 + .../console/agent/db/DbMetadataReader.java | 142 ++ .../apache/ignite/console/agent/db/DbTable.java | 82 + .../agent/db/dialect/DB2MetadataDialect.java | 33 + .../db/dialect/DatabaseMetadataDialect.java | 102 + .../agent/db/dialect/JdbcMetadataDialect.java | 199 ++ .../agent/db/dialect/MySQLMetadataDialect.java | 82 + .../agent/db/dialect/OracleMetadataDialect.java | 359 +++ .../agent/handlers/DatabaseListener.java | 20 +- modules/yardstick/README.txt | 2 - .../config/benchmark-atomic-win.properties | 8 +- .../config/benchmark-atomic.properties | 15 +- .../config/benchmark-cache-load.properties | 7 +- .../config/benchmark-client-mode.properties | 9 - .../config/benchmark-compute.properties | 13 +- .../config/benchmark-failover.properties | 4 +- .../config/benchmark-multicast.properties | 13 +- .../config/benchmark-put-indexed-val.properties | 9 +- .../config/benchmark-query-win.properties | 5 +- .../yardstick/config/benchmark-query.properties | 16 +- .../config/benchmark-remote-sample.properties | 5 +- .../config/benchmark-sample.properties | 5 +- .../config/benchmark-sql-dml.properties | 19 +- .../yardstick/config/benchmark-store.properties | 30 +- .../config/benchmark-tx-win.properties | 6 +- .../yardstick/config/benchmark-tx.properties | 15 +- modules/yardstick/config/benchmark.properties | 11 +- modules/yardstick/config/ignite-base-config.xml | 63 - .../config/ignite-base-load-config.xml | 63 - .../config/ignite-cache-load-config.xml | 5 - .../config/ignite-failover-base-config.xml | 37 - .../ignite-int-max-values-offheap-config.xml | 88 - .../ignite-int-max-values-swap-config.xml | 93 - .../test-max-int-values-offheap.properties | 62 - .../test-max-int-values-onheap.properties | 5 +- .../config/test-max-int-values-swap.properties | 61 - .../yardstick/IgniteBenchmarkArguments.java | 29 - .../org/apache/ignite/yardstick/IgniteNode.java | 10 - .../cache/IgniteGetOffHeapBenchmark.java | 32 - .../cache/IgniteGetOffHeapValuesBenchmark.java | 32 - .../cache/IgnitePutGetOffHeapBenchmark.java | 32 - .../IgnitePutGetOffHeapValuesBenchmark.java | 32 - .../cache/IgnitePutGetTxOffHeapBenchmark.java | 32 - .../IgnitePutGetTxOffHeapValuesBenchmark.java | 32 - .../cache/IgnitePutOffHeapBenchmark.java | 32 - .../cache/IgnitePutOffHeapValuesBenchmark.java | 32 - .../IgnitePutRandomValueSizeBenchmark.java | 2 +- .../cache/IgnitePutTxOffHeapBenchmark.java | 32 - .../IgnitePutTxOffHeapValuesBenchmark.java | 32 - .../IgniteSqlQueryJoinOffHeapBenchmark.java | 32 - .../cache/IgniteSqlQueryOffHeapBenchmark.java | 32 - .../IgniteSqlQueryPutOffHeapBenchmark.java | 32 - .../dml/IgniteSqlDeleteFilteredBenchmark.java | 5 +- .../dml/IgniteSqlUpdateFilteredBenchmark.java | 5 +- ...IgniteAtomicOffHeapInvokeRetryBenchmark.java | 31 - .../IgniteAtomicOffHeapRetriesBenchmark.java | 31 - ...ransactionalOffHeapInvokeRetryBenchmark.java | 33 - ...ransactionalOffHeapWriteInvokeBenchmark.java | 37 - ...eTransactionalOffHeapWriteReadBenchmark.java | 32 - .../IgniteCacheRandomOperationBenchmark.java | 32 +- pom.xml | 122 +- 1014 files changed, 23892 insertions(+), 42621 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3c5f3422/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3c5f3422/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3c5f3422/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/H2CacheStoreStrategy.java ---------------------------------------------------------------------- diff --cc modules/core/src/test/java/org/apache/ignite/internal/processors/cache/H2CacheStoreStrategy.java index 6261366,0167b7d..72b049b --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/H2CacheStoreStrategy.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/H2CacheStoreStrategy.java @@@ -282,11 -263,9 +282,11 @@@ public class H2CacheStoreStrategy imple /** * @return Connection pool */ - static JdbcConnectionPool createDataSource() { - JdbcConnectionPool pool = JdbcConnectionPool.create("jdbc:h2:tcp://localhost/mem:TestDb;LOCK_MODE=0", "sa", ""); + static JdbcConnectionPool createDataSource(int port) { + JdbcConnectionPool pool = JdbcConnectionPool.create("jdbc:h2:tcp://localhost:" + port + + "/mem:TestDb;LOCK_MODE=0", "sa", ""); + - pool.setMaxConnections(100); + pool.setMaxConnections(Integer.getInteger("H2_JDBC_CONNECTIONS", 100)); return pool; }
