Merge remote-tracking branch 'origin/sprint-2' into sprint-2
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/de13f57c Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/de13f57c Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/de13f57c Branch: refs/heads/ignite-573 Commit: de13f57c0d2b55629374b0f0ca239631d14864ff Parents: fe92bfd c867849 Author: nikolay_tikhonov <ntikho...@gridgain.com> Authored: Wed Mar 25 16:06:40 2015 +0300 Committer: nikolay_tikhonov <ntikho...@gridgain.com> Committed: Wed Mar 25 16:06:40 2015 +0300 ---------------------------------------------------------------------- DEVNOTES.txt | 9 +- LICENSE.txt | 55 +- NOTICE.txt | 17 +- assembly/dependencies-fabric.xml | 4 +- assembly/dependencies-hadoop.xml | 6 +- assembly/dependencies-optional-fabric.xml | 3 +- assembly/dependencies-optional-hadoop.xml | 3 +- assembly/libs/README.txt | 120 + assembly/libs/readme.txt | 120 - assembly/release-fabric.xml | 3 + bin/ignite-schema-import.bat | 59 +- bin/ignite-schema-import.sh | 33 +- bin/ignitevisorcmd.sh | 2 +- config/fabric/default-config.xml | 50 +- examples/README.txt | 25 + examples/config/example-cache.xml | 125 +- examples/config/example-compute.xml | 70 - examples/config/example-ignite.xml | 83 + examples/config/example-streamer.xml | 293 -- examples/config/filesystem/README.txt | 8 + examples/config/filesystem/example-igfs.xml | 3 +- examples/config/filesystem/readme.txt | 8 - examples/config/hibernate/README.txt | 8 + .../hibernate/example-hibernate-L2-cache.xml | 3 - examples/config/hibernate/readme.txt | 8 - examples/config/servlet/README.txt | 8 + examples/config/servlet/WEB-INF/web.xml | 2 +- examples/config/servlet/readme.txt | 8 - examples/config/store/example-database.script | 27 - examples/memcached/memcached-example.php | 93 + examples/pom-standalone.xml | 22 +- examples/pom.xml | 75 + examples/rest/http-rest-example.php | 15 +- examples/rest/memcache-rest-example.php | 92 - examples/schema-import/README.txt | 38 + examples/schema-import/bin/db-init.sql | 10 + 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.xml | 91 + .../org/apache/ignite/schema/CacheConfig.java | 38 + .../java/org/apache/ignite/schema/Demo.java | 145 + .../java/org/apache/ignite/schema/DemoNode.java | 37 + .../java/org/apache/ignite/schema/Person.java | 45 + .../org/apache/ignite/schema/PersonKey.java | 38 + .../ignite/examples/ComputeNodeStartup.java | 35 - .../ignite/examples/ExampleNodeStartup.java | 35 + .../apache/ignite/examples/ExamplesUtils.java | 63 +- .../computegrid/ComputeAsyncExample.java | 74 + .../computegrid/ComputeBroadcastExample.java | 8 +- .../computegrid/ComputeCallableExample.java | 8 +- .../computegrid/ComputeClosureExample.java | 8 +- .../ComputeClusterGroupsExample.java | 93 - .../ComputeContinuousMapperExample.java | 8 +- .../ComputeExecutorServiceExample.java | 71 - .../ComputeFibonacciContinuationExample.java | 8 +- .../computegrid/ComputeReducerExample.java | 8 +- .../computegrid/ComputeRunnableExample.java | 23 +- .../computegrid/ComputeScheduleExample.java | 81 - .../computegrid/ComputeTaskMapExample.java | 8 +- .../computegrid/ComputeTaskSplitExample.java | 8 +- .../cluster/ClusterGroupExample.java | 93 + .../computegrid/cluster/package-info.java | 22 + .../failover/ComputeFailoverExample.java | 1 - .../computegrid/failover/package-info.java | 2 +- .../montecarlo/CreditRiskExample.java | 8 +- .../computegrid/montecarlo/package-info.java | 2 +- .../examples/computegrid/package-info.java | 2 +- .../examples/datagrid/CacheAffinityExample.java | 37 +- .../examples/datagrid/CacheApiExample.java | 55 +- .../examples/datagrid/CacheAsyncApiExample.java | 86 + .../datagrid/CacheContinuousQueryExample.java | 101 +- .../datagrid/CacheDataStreamerExample.java | 47 +- .../examples/datagrid/CacheEventsExample.java | 77 +- .../examples/datagrid/CacheNodeStartup.java | 35 - .../datagrid/CachePopularNumbersExample.java | 161 - .../examples/datagrid/CachePutGetExample.java | 42 +- .../examples/datagrid/CacheQueryExample.java | 258 +- .../datagrid/CacheTransactionExample.java | 59 +- .../hibernate/HibernateL2CacheExample.java | 135 +- .../HibernateL2CacheExampleNodeStartup.java | 97 - .../datagrid/hibernate/package-info.java | 2 +- .../ignite/examples/datagrid/package-info.java | 2 +- .../starschema/CacheStarSchemaExample.java | 85 +- .../datagrid/starschema/DimProduct.java | 1 - .../examples/datagrid/starschema/DimStore.java | 1 - .../datagrid/starschema/FactPurchase.java | 2 - .../datagrid/starschema/package-info.java | 2 +- .../store/CacheNodeWithStoreStartup.java | 145 - .../datagrid/store/CacheStoreExample.java | 107 - .../store/CacheStoreLoadDataExample.java | 67 - .../ignite/examples/datagrid/store/Person.java | 155 + .../store/auto/CacheAutoStoreExample.java | 86 + .../auto/CacheAutoStoreLoadDataExample.java | 78 + .../datagrid/store/auto/CacheConfig.java | 80 + .../datagrid/store/auto/DbH2ServerStartup.java | 78 + .../datagrid/store/auto/package-info.java | 22 + .../store/dummy/CacheDummyPersonStore.java | 12 +- .../store/dummy/CacheDummyStoreExample.java | 130 + .../datagrid/store/dummy/package-info.java | 2 +- .../hibernate/CacheHibernatePersonStore.java | 42 +- .../hibernate/CacheHibernateStoreExample.java | 130 + .../datagrid/store/hibernate/Person.hbm.xml | 2 +- .../datagrid/store/hibernate/package-info.java | 2 +- .../store/jdbc/CacheJdbcPersonStore.java | 2 +- .../store/jdbc/CacheJdbcPojoPersonStore.java | 85 - .../store/jdbc/CacheJdbcStoreExample.java | 130 + .../datagrid/store/jdbc/package-info.java | 2 +- .../examples/datagrid/store/model/Person.java | 155 - .../examples/datagrid/store/package-info.java | 2 +- .../datastructures/IgniteAtomicLongExample.java | 10 +- .../IgniteAtomicReferenceExample.java | 10 +- .../IgniteAtomicSequenceExample.java | 10 +- .../IgniteAtomicStampedExample.java | 10 +- .../IgniteCountDownLatchExample.java | 10 +- .../IgniteExecutorServiceExample.java | 71 + .../datastructures/IgniteQueueExample.java | 33 +- .../datastructures/IgniteSetExample.java | 33 +- .../examples/datastructures/package-info.java | 2 +- .../ignite/examples/events/EventsExample.java | 10 +- .../ignite/examples/events/package-info.java | 2 +- .../ignite/examples/igfs/package-info.java | 2 +- .../examples/messaging/MessagingExample.java | 8 +- .../messaging/MessagingPingPongExample.java | 56 +- .../MessagingPingPongListenActorExample.java | 8 +- .../ignite/examples/messaging/package-info.java | 2 +- .../client/memcache/MemcacheRestExample.java | 2 +- .../misc/client/memcache/package-info.java | 2 +- .../examples/misc/client/package-info.java | 2 +- .../misc/deployment/DeploymentExample.java | 8 +- .../examples/misc/deployment/package-info.java | 2 +- .../examples/misc/lifecycle/package-info.java | 2 +- .../ignite/examples/misc/package-info.java | 2 +- .../misc/schedule/ComputeScheduleExample.java | 81 + .../examples/misc/schedule/package-info.java | 22 + .../misc/springbean/SpringBeanExample.java | 6 +- .../examples/misc/springbean/package-info.java | 2 +- .../apache/ignite/examples/package-info.java | 2 +- .../examples/servicegrid/ServicesExample.java | 21 +- .../servicegrid/SimpleMapServiceImpl.java | 32 +- .../examples/servicegrid/package-info.java | 22 + .../streaming/marketdata/CacheConfig.java | 44 + .../streaming/marketdata/Instrument.java | 106 + .../marketdata/QueryTopInstruments.java | 73 + .../streaming/marketdata/StreamMarketData.java | 103 + .../examples/streaming/numbers/CacheConfig.java | 46 + .../streaming/numbers/QueryPopularNumbers.java | 74 + .../streaming/numbers/StreamRandomNumbers.java | 78 + .../ignite/examples/streaming/package-info.java | 22 + .../apache/ignite/examples/ComputeExample.java | 57 - .../ignite/examples/MessagingExample.java | 162 - .../java8/cluster/ClusterGroupExample.java | 82 + .../examples/java8/cluster/package-info.java | 22 + .../java8/computegrid/ComputeAsyncExample.java | 71 + .../computegrid/ComputeBroadcastExample.java | 101 + .../computegrid/ComputeCallableExample.java | 73 + .../computegrid/ComputeClosureExample.java | 69 + .../computegrid/ComputeRunnableExample.java | 63 + .../java8/computegrid/package-info.java | 22 + .../java8/datagrid/CacheAffinityExample.java | 131 + .../java8/datagrid/CacheApiExample.java | 103 + .../java8/datagrid/CacheAsyncApiExample.java | 82 + .../examples/java8/datagrid/package-info.java | 22 + .../IgniteExecutorServiceExample.java | 69 + .../java8/datastructures/package-info.java | 22 + .../examples/java8/events/EventsExample.java | 132 + .../examples/java8/events/package-info.java | 22 + .../java8/messaging/MessagingExample.java | 163 + .../messaging/MessagingPingPongExample.java | 111 + .../examples/java8/messaging/package-info.java | 22 + .../misc/schedule/ComputeScheduleExample.java | 66 + .../java8/misc/schedule/package-info.java | 22 + .../ignite/examples/java8/package-info.java | 23 + .../java8/streaming/marketdata/CacheConfig.java | 44 + .../java8/streaming/marketdata/Instrument.java | 106 + .../marketdata/QueryTopInstruments.java | 73 + .../streaming/marketdata/StreamMarketData.java | 101 + .../java8/streaming/numbers/CacheConfig.java | 46 + .../streaming/numbers/QueryPopularNumbers.java | 74 + .../streaming/numbers/StreamRandomNumbers.java | 74 + .../examples/java8/streaming/package-info.java | 22 + .../examples/ScalarCacheAffinityExample.scala | 115 + .../examples/ScalarCacheAffinityExample1.scala | 121 - .../examples/ScalarCacheAffinityExample2.scala | 116 - .../ScalarCacheAffinitySimpleExample.scala | 83 - .../scalar/examples/ScalarCacheExample.scala | 29 +- .../ScalarCachePopularNumbersExample.scala | 94 +- .../examples/ScalarCacheQueryExample.scala | 45 +- .../scalar/examples/ScalarClosureExample.scala | 9 +- .../examples/ScalarContinuationExample.scala | 11 +- .../examples/ScalarCreditRiskExample.scala | 9 +- .../scalar/examples/ScalarJvmCloudExample.scala | 2 +- .../examples/ScalarPiCalculationExample.scala | 55 - .../scalar/examples/ScalarPingPongExample.scala | 9 +- .../scalar/examples/ScalarPrimeExample.scala | 8 +- .../scalar/examples/ScalarScheduleExample.scala | 9 +- .../examples/ScalarSnowflakeSchemaExample.scala | 86 +- .../scalar/examples/ScalarTaskExample.scala | 9 +- .../examples/ScalarWorldShortestMapReduce.scala | 9 +- .../ignite/examples/BasicExamplesSelfTest.java | 3 +- .../CacheExamplesMultiNodeSelfTest.java | 12 +- .../ignite/examples/CacheExamplesSelfTest.java | 20 +- ...heStoreLoadDataExampleMultiNodeSelfTest.java | 39 - .../examples/ClusterGroupExampleSelfTest.java | 39 + .../ComputeClusterGroupsExampleSelfTest.java | 39 - ...ibernateL2CacheExampleMultiNodeSelfTest.java | 2 +- .../examples/MessagingExamplesSelfTest.java | 5 +- .../testsuites/IgniteExamplesSelfTestSuite.java | 3 +- .../BasicExamplesMultiNodeSelfTest.java | 28 + .../java8/examples/BasicExamplesSelfTest.java | 83 + .../CacheExamplesMultiNodeSelfTest.java | 38 + .../java8/examples/CacheExamplesSelfTest.java | 141 + .../examples/CheckpointExamplesSelfTest.java | 45 + .../examples/ClusterGroupExampleSelfTest.java | 39 + .../ContinuationExamplesMultiNodeSelfTest.java | 28 + .../examples/ContinuationExamplesSelfTest.java | 33 + ...ntinuousMapperExamplesMultiNodeSelfTest.java | 28 + .../ContinuousMapperExamplesSelfTest.java | 33 + .../DeploymentExamplesMultiNodeSelfTest.java | 30 + .../examples/DeploymentExamplesSelfTest.java | 33 + .../EventsExamplesMultiNodeSelfTest.java | 28 + .../java8/examples/EventsExamplesSelfTest.java | 33 + ...ibernateL2CacheExampleMultiNodeSelfTest.java | 29 + .../HibernateL2CacheExampleSelfTest.java | 33 + .../java8/examples/IgfsExamplesSelfTest.java | 51 + .../examples/LifecycleExamplesSelfTest.java | 33 + .../MemcacheRestExamplesMultiNodeSelfTest.java | 31 + .../examples/MemcacheRestExamplesSelfTest.java | 41 + .../examples/MessagingExamplesSelfTest.java | 53 + .../MonteCarloExamplesMultiNodeSelfTest.java | 28 + .../examples/MonteCarloExamplesSelfTest.java | 74 + .../examples/SpringBeanExamplesSelfTest.java | 33 + .../examples/TaskExamplesMultiNodeSelfTest.java | 28 + .../java8/examples/TaskExamplesSelfTest.java | 40 + .../IgniteExamplesJ8SelfTestSuite.java | 73 + .../tests/examples/ScalarExamplesSelfTest.scala | 17 +- ipc/README.txt | 4 + ipc/readme.txt | 4 - ipc/shmem/README.txt | 37 + ipc/shmem/readme.txt | 37 - modules/aop/README.txt | 33 + modules/aop/readme.txt | 33 - modules/aws/README.txt | 32 + modules/aws/readme.txt | 32 - .../ClientAbstractMultiThreadedSelfTest.java | 194 +- .../client/ClientDefaultCacheSelfTest.java | 48 - .../client/ClientTopologyCacheSelfTest.java | 288 -- .../ClientAbstractMultiNodeSelfTest.java | 284 +- .../integration/ClientAbstractSelfTest.java | 835 +--- .../client/suite/IgniteClientTestSuite.java | 2 - .../rest/AbstractRestProcessorSelfTest.java | 2 +- .../JettyRestProcessorAbstractSelfTest.java | 9 +- .../rest/RestBinaryProtocolSelfTest.java | 74 +- .../rest/RestMemcacheProtocolSelfTest.java | 80 +- .../processors/rest/RestProcessorTest.java | 3 +- .../rest/TaskCommandHandlerSelfTest.java | 4 +- .../ignite/jdbc/JdbcComplexQuerySelfTest.java | 17 +- .../ignite/jdbc/JdbcLocalCachesSelfTest.java | 4 +- .../ignite/jdbc/JdbcMetadataSelfTest.java | 15 +- .../jdbc/JdbcPreparedStatementSelfTest.java | 2 +- .../ignite/jdbc/JdbcResultSetSelfTest.java | 2 +- .../ignite/jdbc/JdbcStatementSelfTest.java | 2 +- .../loadtests/client/ClientTcpSslLoadTest.java | 4 +- .../clients/src/test/resources/spring-cache.xml | 4 +- .../src/test/resources/spring-server-node.xml | 6 +- .../test/resources/spring-server-ssl-node.xml | 6 +- .../ignite/codegen/MessageCodeGenerator.java | 3 + .../core/licenses/pcollections-mit-license.txt | 19 - modules/core/pom.xml | 1 - .../src/main/java/org/apache/ignite/Ignite.java | 76 +- .../java/org/apache/ignite/IgniteCache.java | 38 +- .../java/org/apache/ignite/IgniteCluster.java | 4 +- .../org/apache/ignite/IgniteDataStreamer.java | 91 +- .../org/apache/ignite/IgniteJdbcDriver.java | 13 +- .../apache/ignite/IgniteSystemProperties.java | 12 + .../main/java/org/apache/ignite/Ignition.java | 58 +- .../ignite/cache/CacheDistributionMode.java | 69 - .../CacheEntryEventSerializableFilter.java | 28 + .../ignite/cache/CacheExistsException.java | 52 + .../apache/ignite/cache/CacheInterceptor.java | 5 +- .../ignite/cache/CacheInterceptorAdapter.java | 3 + .../org/apache/ignite/cache/CacheManager.java | 406 +- .../apache/ignite/cache/CacheMemoryMode.java | 6 +- .../java/org/apache/ignite/cache/CacheMode.java | 8 +- .../apache/ignite/cache/CacheRebalanceMode.java | 3 +- .../cache/CacheServerNotFoundException.java | 49 + .../ignite/cache/CacheTypeFieldMetadata.java | 7 +- .../apache/ignite/cache/CacheTypeMetadata.java | 6 +- .../apache/ignite/cache/CachingProvider.java | 155 +- .../apache/ignite/cache/affinity/Affinity.java | 246 ++ .../affinity/AffinityCentralizedFunction.java | 31 + .../ignite/cache/affinity/AffinityFunction.java | 110 + .../cache/affinity/AffinityFunctionContext.java | 72 + .../ignite/cache/affinity/AffinityKey.java | 189 + .../cache/affinity/AffinityKeyMapped.java | 110 + .../cache/affinity/AffinityKeyMapper.java | 62 + .../AffinityNodeAddressHashResolver.java | 39 + .../affinity/AffinityNodeHashResolver.java | 43 + .../affinity/AffinityNodeIdHashResolver.java | 40 + .../ignite/cache/affinity/CacheAffinity.java | 256 -- .../cache/affinity/CacheAffinityFunction.java | 110 - .../affinity/CacheAffinityFunctionContext.java | 71 - .../ignite/cache/affinity/CacheAffinityKey.java | 189 - .../cache/affinity/CacheAffinityKeyMapped.java | 110 - .../cache/affinity/CacheAffinityKeyMapper.java | 62 - .../CacheAffinityNodeAddressHashResolver.java | 39 - .../affinity/CacheAffinityNodeHashResolver.java | 43 - .../CacheAffinityNodeIdHashResolver.java | 40 - .../CacheCentralizedAffinityFunction.java | 31 - .../fair/CachePartitionFairAffinity.java | 804 ---- .../affinity/fair/FairAffinityFunction.java | 777 ++++ .../CacheRendezvousAffinityFunction.java | 501 --- .../rendezvous/RendezvousAffinityFunction.java | 500 +++ .../cache/eviction/CacheEvictionFilter.java | 40 - .../cache/eviction/CacheEvictionPolicy.java | 50 - .../ignite/cache/eviction/EvictableEntry.java | 2 +- .../ignite/cache/eviction/EvictionFilter.java | 43 + .../ignite/cache/eviction/EvictionPolicy.java | 54 + .../eviction/fifo/CacheFifoEvictionPolicy.java | 178 - .../fifo/CacheFifoEvictionPolicyMBean.java | 50 - .../cache/eviction/fifo/FifoEvictionPolicy.java | 191 + .../eviction/fifo/FifoEvictionPolicyMBean.java | 50 + .../eviction/igfs/CacheIgfsEvictionFilter.java | 35 - .../CacheIgfsPerBlockLruEvictionPolicy.java | 358 -- ...acheIgfsPerBlockLruEvictionPolicyMXBean.java | 93 - .../cache/eviction/igfs/IgfsEvictionFilter.java | 38 + .../igfs/IgfsPerBlockLruEvictionPolicy.java | 376 ++ .../IgfsPerBlockLruEvictionPolicyMXBean.java | 93 + .../eviction/lru/CacheLruEvictionPolicy.java | 185 - .../lru/CacheLruEvictionPolicyMBean.java | 50 - .../cache/eviction/lru/LruEvictionPolicy.java | 198 + .../eviction/lru/LruEvictionPolicyMBean.java | 50 + .../random/CacheRandomEvictionPolicy.java | 101 - .../random/CacheRandomEvictionPolicyMBean.java | 42 - .../eviction/random/RandomEvictionPolicy.java | 114 + .../random/RandomEvictionPolicyMBean.java | 42 + .../ignite/cache/query/ContinuousQuery.java | 104 +- .../org/apache/ignite/cache/query/Query.java | 41 +- .../apache/ignite/cache/query/ScanQuery.java | 28 +- .../org/apache/ignite/cache/query/SpiQuery.java | 17 +- .../ignite/cache/query/SqlFieldsQuery.java | 17 +- .../org/apache/ignite/cache/query/SqlQuery.java | 21 +- .../apache/ignite/cache/query/TextQuery.java | 21 +- .../cache/query/annotations/package-info.java | 22 + .../store/jdbc/CacheAbstractJdbcStore.java | 85 +- .../cache/store/jdbc/CacheJdbcBlobStore.java | 6 +- .../cache/store/jdbc/CacheJdbcPojoStore.java | 4 +- .../store/jdbc/dialect/BasicJdbcDialect.java | 6 +- .../cache/store/jdbc/dialect/DB2Dialect.java | 2 +- .../cache/store/jdbc/dialect/JdbcDialect.java | 2 +- .../store/jdbc/dialect/SQLServerDialect.java | 2 +- .../org/apache/ignite/cluster/ClusterGroup.java | 40 +- .../org/apache/ignite/cluster/package-info.java | 22 + .../org/apache/ignite/compute/ComputeJob.java | 3 +- .../ignite/compute/ComputeJobAdapter.java | 2 +- .../configuration/CacheConfiguration.java | 204 +- .../configuration/IgniteConfiguration.java | 168 +- .../configuration/IgniteReflectionFactory.java | 216 + .../configuration/NearCacheConfiguration.java | 95 + .../ignite/configuration/package-info.java | 22 + .../ignite/events/CacheQueryExecutedEvent.java | 8 +- .../ignite/events/CacheQueryReadEvent.java | 10 +- .../org/apache/ignite/events/EventType.java | 35 + .../apache/ignite/internal/GridComponent.java | 9 +- .../internal/GridEventConsumeHandler.java | 18 +- .../ignite/internal/GridKernalContextImpl.java | 14 +- .../ignite/internal/GridKernalGateway.java | 5 + .../ignite/internal/GridKernalGatewayImpl.java | 8 + .../apache/ignite/internal/GridKernalState.java | 2 +- .../internal/GridMessageListenHandler.java | 9 +- .../internal/GridNodeOrderComparator.java | 10 + .../ignite/internal/GridPluginComponent.java | 2 +- .../ignite/internal/IgniteComponentType.java | 4 +- .../apache/ignite/internal/IgniteKernal.java | 176 +- .../ignite/internal/IgniteNodeAttributes.java | 2 +- .../org/apache/ignite/internal/IgnitionEx.java | 274 +- .../internal/MarshallerContextAdapter.java | 2 +- .../ignite/internal/MarshallerContextImpl.java | 9 +- .../client/GridClientPartitionAffinity.java | 8 +- .../router/impl/GridRouterClientImpl.java | 2 +- .../impl/GridRouterCommandLineStartup.java | 4 +- .../internal/cluster/ClusterGroupAdapter.java | 94 +- .../ignite/internal/cluster/ClusterGroupEx.java | 6 +- .../cluster/ClusterNodeLocalMapImpl.java | 2 +- .../ClusterTopologyServerNotFoundException.java | 40 + .../cluster/IgniteClusterAsyncImpl.java | 10 + .../internal/cluster/IgniteClusterImpl.java | 4 +- .../internal/events/DiscoveryCustomEvent.java | 18 + .../ignite/internal/igfs/common/IgfsLogger.java | 2 +- .../internal/managers/GridManagerAdapter.java | 2 +- .../checkpoint/GridCheckpointManager.java | 4 +- .../managers/communication/GridIoManager.java | 11 +- .../communication/GridIoMessageFactory.java | 8 +- .../managers/deployment/GridDeployment.java | 2 +- .../deployment/GridDeploymentClassLoader.java | 2 +- .../deployment/GridDeploymentLocalStore.java | 2 +- .../GridDeploymentPerVersionStore.java | 2 +- .../discovery/GridDiscoveryManager.java | 550 ++- .../eventstorage/GridEventStorageManager.java | 5 +- .../processors/GridProcessorAdapter.java | 2 +- .../affinity/AffinityTopologyVersion.java | 204 + .../affinity/GridAffinityAssignment.java | 12 +- .../affinity/GridAffinityAssignmentCache.java | 124 +- .../GridAffinityFunctionContextImpl.java | 83 + .../affinity/GridAffinityProcessor.java | 150 +- .../processors/affinity/GridAffinityUtils.java | 19 +- .../GridCacheAffinityFunctionContextImpl.java | 83 - .../processors/cache/CacheDistributionMode.java | 67 + .../cache/CacheEntryPredicateAdapter.java | 20 +- .../cache/CacheEntryPredicateContainsValue.java | 6 + .../cache/CacheEvictableEntryImpl.java | 197 + .../processors/cache/CacheObjectContext.java | 6 +- .../processors/cache/CacheProjection.java | 6 +- .../cache/CacheStoreBalancingWrapper.java | 2 +- .../cache/CacheWeakQueryIteratorsHolder.java | 2 +- .../cache/DynamicCacheChangeBatch.java | 75 + .../cache/DynamicCacheChangeRequest.java | 193 + .../cache/DynamicCacheDescriptor.java | 171 + .../processors/cache/EvictableEntryImpl.java | 197 - .../internal/processors/cache/GridCache.java | 14 +- .../processors/cache/GridCacheAdapter.java | 112 +- .../cache/GridCacheAffinityManager.java | 72 +- .../processors/cache/GridCacheAtomicFuture.java | 4 +- .../cache/GridCacheAtomicVersionComparator.java | 21 +- .../processors/cache/GridCacheAttributes.java | 358 +- .../cache/GridCacheClearAllRunnable.java | 6 +- .../cache/GridCacheConcurrentMap.java | 31 +- .../processors/cache/GridCacheContext.java | 113 +- .../GridCacheDefaultAffinityKeyMapper.java | 16 +- .../cache/GridCacheDeploymentManager.java | 19 +- .../processors/cache/GridCacheEntryEx.java | 11 +- .../GridCacheEntryInfoCollectSwapListener.java | 2 +- .../processors/cache/GridCacheEntrySet.java | 2 +- .../processors/cache/GridCacheEventManager.java | 26 +- .../cache/GridCacheEvictionManager.java | 55 +- .../cache/GridCacheEvictionRequest.java | 14 +- .../cache/GridCacheExplicitLockSpan.java | 20 +- .../processors/cache/GridCacheGateway.java | 118 +- .../processors/cache/GridCacheIoManager.java | 27 +- .../processors/cache/GridCacheIterator.java | 2 +- .../processors/cache/GridCacheKeySet.java | 2 +- .../cache/GridCacheLoaderWriterStore.java | 6 +- .../GridCacheLoaderWriterStoreFactory.java | 59 + .../processors/cache/GridCacheMapEntry.java | 55 +- .../cache/GridCacheMapEntryFactory.java | 3 +- .../processors/cache/GridCacheMessage.java | 5 +- .../cache/GridCacheMvccCandidate.java | 7 +- .../processors/cache/GridCacheMvccManager.java | 59 +- .../GridCachePartitionExchangeManager.java | 274 +- .../processors/cache/GridCachePreloader.java | 3 +- .../cache/GridCachePreloaderAdapter.java | 5 +- .../processors/cache/GridCacheProcessor.java | 2176 ++++++---- .../processors/cache/GridCacheProxyImpl.java | 16 +- .../cache/GridCacheSharedContext.java | 39 +- .../processors/cache/GridCacheStoreManager.java | 139 +- .../processors/cache/GridCacheSwapManager.java | 15 +- .../cache/GridCacheTryPutFailedException.java | 28 + .../processors/cache/GridCacheTtlManager.java | 12 +- .../processors/cache/GridCacheUtils.java | 169 +- .../cache/GridCacheValueCollection.java | 2 +- .../cache/GridCacheWriteBehindStore.java | 49 +- .../processors/cache/IgniteCacheProxy.java | 279 +- .../cache/affinity/GridCacheAffinityImpl.java | 13 +- .../cache/affinity/GridCacheAffinityProxy.java | 6 +- .../CacheDataStructuresManager.java | 21 +- .../distributed/GridCacheTtlUpdateRequest.java | 12 +- .../distributed/GridCacheTxFinishSync.java | 2 +- .../GridDistributedCacheAdapter.java | 41 +- .../GridDistributedTxRemoteAdapter.java | 3 +- .../dht/GridClientPartitionTopology.java | 103 +- .../dht/GridDhtAffinityAssignmentRequest.java | 12 +- .../dht/GridDhtAffinityAssignmentResponse.java | 13 +- .../dht/GridDhtAssignmentFetchFuture.java | 19 +- .../distributed/dht/GridDhtCacheAdapter.java | 84 +- .../distributed/dht/GridDhtCacheEntry.java | 17 +- .../cache/distributed/dht/GridDhtGetFuture.java | 7 +- .../distributed/dht/GridDhtLocalPartition.java | 9 +- .../distributed/dht/GridDhtLockFuture.java | 69 +- .../distributed/dht/GridDhtLockRequest.java | 11 +- .../dht/GridDhtPartitionTopology.java | 27 +- .../dht/GridDhtPartitionTopologyImpl.java | 101 +- .../distributed/dht/GridDhtTopologyFuture.java | 10 +- .../dht/GridDhtTransactionalCacheAdapter.java | 20 +- .../distributed/dht/GridDhtTxFinishRequest.java | 11 +- .../cache/distributed/dht/GridDhtTxLocal.java | 5 +- .../distributed/dht/GridDhtTxLocalAdapter.java | 13 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 12 +- .../dht/GridDhtTxPrepareRequest.java | 11 +- .../cache/distributed/dht/GridDhtTxRemote.java | 9 +- .../distributed/dht/GridNoStorageCacheMap.java | 6 +- .../dht/GridPartitionedGetFuture.java | 49 +- .../dht/atomic/GridDhtAtomicCache.java | 109 +- .../dht/atomic/GridDhtAtomicCacheEntry.java | 3 +- .../dht/atomic/GridDhtAtomicUpdateFuture.java | 9 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 11 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 87 +- .../dht/atomic/GridNearAtomicUpdateRequest.java | 11 +- .../dht/colocated/GridDhtColocatedCache.java | 36 +- .../colocated/GridDhtColocatedCacheEntry.java | 7 +- .../colocated/GridDhtColocatedLockFuture.java | 107 +- .../dht/preloader/GridDhtForceKeysFuture.java | 9 +- .../dht/preloader/GridDhtForceKeysRequest.java | 12 +- .../GridDhtPartitionDemandMessage.java | 12 +- .../preloader/GridDhtPartitionDemandPool.java | 48 +- .../preloader/GridDhtPartitionExchangeId.java | 28 +- .../dht/preloader/GridDhtPartitionFullMap.java | 8 +- .../dht/preloader/GridDhtPartitionMap.java | 2 +- .../GridDhtPartitionsExchangeFuture.java | 235 +- .../preloader/GridDhtPartitionsFullMessage.java | 18 +- .../dht/preloader/GridDhtPreloader.java | 19 +- .../preloader/GridDhtPreloaderAssignments.java | 9 +- .../distributed/near/GridNearAtomicCache.java | 7 +- .../distributed/near/GridNearCacheAdapter.java | 66 +- .../distributed/near/GridNearCacheEntry.java | 96 +- .../distributed/near/GridNearGetFuture.java | 61 +- .../distributed/near/GridNearGetRequest.java | 12 +- .../distributed/near/GridNearGetResponse.java | 12 +- .../distributed/near/GridNearLockFuture.java | 91 +- .../distributed/near/GridNearLockRequest.java | 53 +- .../near/GridNearTransactionalCache.java | 13 +- .../near/GridNearTxFinishFuture.java | 3 +- .../near/GridNearTxFinishRequest.java | 11 +- .../cache/distributed/near/GridNearTxLocal.java | 40 +- .../near/GridNearTxPrepareFuture.java | 52 +- .../near/GridNearTxPrepareRequest.java | 11 +- .../distributed/near/GridNearTxRemote.java | 3 +- .../processors/cache/dr/GridCacheDrManager.java | 3 +- .../cache/dr/os/GridOsCacheDrManager.java | 3 +- .../processors/cache/local/GridLocalCache.java | 18 +- .../local/atomic/GridLocalAtomicCache.java | 17 +- .../processors/cache/query/CacheQuery.java | 3 +- .../query/GridCacheDistributedQueryManager.java | 28 +- .../cache/query/GridCacheQueryAdapter.java | 9 +- .../cache/query/GridCacheQueryManager.java | 39 +- .../CacheContinuousQueryFilterEx.java | 4 +- .../continuous/CacheContinuousQueryHandler.java | 42 +- .../continuous/CacheContinuousQueryManager.java | 61 +- .../jdbc/GridCacheQueryJdbcMetadataTask.java | 11 +- .../query/jdbc/GridCacheQueryJdbcTask.java | 16 +- .../jdbc/GridCacheQueryJdbcValidationTask.java | 7 +- .../cache/transactions/IgniteInternalTx.java | 10 +- .../cache/transactions/IgniteTxAdapter.java | 38 +- .../transactions/IgniteTxLocalAdapter.java | 17 +- .../cache/transactions/IgniteTxManager.java | 12 +- .../version/GridCacheRawVersionedEntry.java | 7 +- .../cache/version/GridCacheVersion.java | 19 +- .../GridCacheVersionConflictResolver.java | 2 +- .../cache/version/GridCacheVersionManager.java | 22 +- .../cacheobject/IgniteCacheObjectProcessor.java | 4 +- .../IgniteCacheObjectProcessorImpl.java | 13 +- .../processors/clock/GridClockDeltaVersion.java | 10 +- .../continuous/GridContinuousHandler.java | 15 +- .../continuous/GridContinuousProcessor.java | 81 +- .../datastreamer/DataStreamProcessor.java | 3 +- .../datastreamer/DataStreamerCacheUpdaters.java | 25 +- .../datastreamer/DataStreamerImpl.java | 131 +- .../datastreamer/DataStreamerRequest.java | 2 +- .../datastreamer/DataStreamerUpdateJob.java | 18 +- .../datastructures/DataStructuresProcessor.java | 4 +- .../GridCacheInternalKeyImpl.java | 2 +- .../datastructures/GridCacheQueueAdapter.java | 2 +- .../datastructures/GridCacheSetImpl.java | 5 +- .../dr/IgniteDrDataStreamerCacheUpdater.java | 14 +- .../processors/igfs/IgfsClientSession.java | 2 +- .../processors/igfs/IgfsDataManager.java | 69 +- .../ignite/internal/processors/igfs/IgfsEx.java | 3 + .../processors/igfs/IgfsFileWorker.java | 2 - .../processors/igfs/IgfsHelperImpl.java | 16 +- .../internal/processors/igfs/IgfsImpl.java | 10 +- .../processors/igfs/IgfsLocalMetrics.java | 30 +- .../processors/igfs/IgfsMetaManager.java | 46 +- .../internal/processors/igfs/IgfsProcessor.java | 52 +- .../internal/processors/igfs/IgfsServer.java | 2 +- .../processors/job/GridJobProcessor.java | 14 +- .../jobmetrics/GridJobMetricsProcessor.java | 2 +- .../offheap/GridOffHeapProcessor.java | 2 +- .../plugin/IgnitePluginProcessor.java | 2 +- .../processors/query/GridQueryIndexing.java | 9 +- .../processors/query/GridQueryProcessor.java | 57 +- .../processors/resource/GridResourceIoc.java | 2 +- .../processors/rest/GridRestProcessor.java | 4 +- .../handlers/cache/GridCacheCommandHandler.java | 4 +- .../cache/GridCacheQueryCommandHandler.java | 6 +- .../handlers/task/GridTaskCommandHandler.java | 2 +- .../service/GridServiceProcessor.java | 36 +- .../processors/service/GridServiceProxy.java | 2 +- .../session/GridTaskSessionProcessor.java | 2 +- .../spring/IgniteSpringProcessor.java | 73 - .../processors/task/GridTaskProcessor.java | 11 +- .../processors/task/GridTaskWorker.java | 2 +- .../internal/util/GridAnnotationsCache.java | 2 +- .../GridBoundedConcurrentLinkedHashMap.java | 4 +- .../GridBoundedConcurrentLinkedHashSet.java | 6 +- .../internal/util/GridClassLoaderCache.java | 2 +- .../internal/util/GridConcurrentFactory.java | 2 +- .../internal/util/GridConcurrentHashSet.java | 2 +- .../util/GridConcurrentLinkedHashSet.java | 4 +- .../ignite/internal/util/GridEnumCache.java | 2 +- .../internal/util/GridExecutionStatistics.java | 2 +- .../ignite/internal/util/GridKeyLock.java | 2 +- .../ignite/internal/util/GridLogThrottle.java | 2 +- .../internal/util/GridSynchronizedMap.java | 2 +- .../ignite/internal/util/IgniteUtils.java | 202 +- .../util/future/GridCompoundFuture.java | 2 +- .../shmem/IpcSharedMemoryServerEndpoint.java | 90 +- .../ignite/internal/util/lang/GridFunc.java | 4 +- .../ignite/internal/util/nio/GridNioServer.java | 122 +- .../util/nio/GridSelectorNioSessionImpl.java | 2 +- .../util/nodestart/IgniteSshHelper.java | 34 + .../util/nodestart/IgniteSshProcessor.java | 34 - .../offheap/unsafe/GridOffHeapSnapTreeMap.java | 2 +- .../util/offheap/unsafe/GridUnsafeMap.java | 8 +- .../unsafe/GridUnsafePartitionedMap.java | 4 +- .../util/spring/IgniteSpringHelper.java | 95 + .../ignite/internal/util/worker/GridWorker.java | 12 - .../ignite/internal/visor/cache/VisorCache.java | 17 +- .../cache/VisorCacheAffinityConfiguration.java | 6 +- .../visor/cache/VisorCacheClearTask.java | 2 +- .../visor/cache/VisorCacheConfiguration.java | 19 +- .../cache/VisorCacheEvictionConfiguration.java | 13 +- .../visor/cache/VisorCacheLoadTask.java | 2 +- .../cache/VisorCacheNearConfiguration.java | 6 +- .../cache/VisorCachePreloadConfiguration.java | 114 - .../visor/cache/VisorCachePreloadTask.java | 82 - .../cache/VisorCacheRebalanceConfiguration.java | 114 + .../visor/cache/VisorCacheRebalanceTask.java | 82 + .../visor/cache/VisorCacheSwapBackupsTask.java | 2 +- .../visor/node/VisorIgfsConfiguration.java | 11 + .../visor/node/VisorNodeDataCollectorJob.java | 11 +- .../internal/visor/util/VisorTaskUtils.java | 14 +- .../ignite/lang/IgniteProductVersion.java | 28 +- .../java/org/apache/ignite/lang/IgniteUuid.java | 7 +- .../apache/ignite/lifecycle/package-info.java | 22 + .../jdk/JdkMarshallerObjectInputStream.java | 4 +- .../optimized/OptimizedMarshaller.java | 2 +- .../optimized/OptimizedMarshallerUtils.java | 2 - .../org/apache/ignite/plugin/package-info.java | 22 + .../jobstealing/JobStealingCollisionSpi.java | 4 +- .../communication/tcp/TcpCommunicationSpi.java | 10 +- .../deployment/local/LocalDeploymentSpi.java | 2 +- .../spi/discovery/DiscoverySpiDataExchange.java | 8 +- .../spi/discovery/DiscoverySpiListener.java | 3 +- .../discovery/tcp/TcpClientDiscoverySpi.java | 21 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 120 +- .../tcp/internal/TcpDiscoveryNode.java | 10 +- .../tcp/internal/TcpDiscoveryStatistics.java | 2 +- .../TcpDiscoveryCustomEventMessage.java | 1 + .../messages/TcpDiscoveryNodeAddedMessage.java | 26 +- .../memory/MemoryEventStorageSpi.java | 2 +- .../adaptive/AdaptiveLoadBalancingSpi.java | 2 +- .../roundrobin/RoundRobinLoadBalancingSpi.java | 2 +- .../WeightedRandomLoadBalancingSpi.java | 2 +- .../spi/swapspace/file/FileSwapSpaceSpi.java | 2 +- .../ignite/startup/BasicWarmupClosure.java | 11 +- .../apache/ignite/stream/StreamReceiver.java | 42 + .../apache/ignite/stream/StreamTransformer.java | 53 + .../org/apache/ignite/stream/StreamVisitor.java | 53 + .../org/apache/ignite/stream/package-info.java | 21 + .../apache/ignite/transactions/Transaction.java | 1 - .../ignite/transactions/package-info.java | 22 + .../org/jdk8/backport/ConcurrentHashMap8.java | 3793 ----------------- .../jdk8/backport/ConcurrentLinkedDeque8.java | 1953 --------- .../jdk8/backport/ConcurrentLinkedHashMap.java | 2140 ---------- .../main/java/org/jdk8/backport/LongAdder.java | 205 - .../main/java/org/jdk8/backport/Striped64.java | 345 -- .../org/jdk8/backport/ThreadLocalRandom8.java | 201 - .../org/jetbrains/annotations/package-info.java | 27 + .../java/org/jsr166/ConcurrentHashMap8.java | 3794 ++++++++++++++++++ .../java/org/jsr166/ConcurrentLinkedDeque8.java | 1954 +++++++++ .../org/jsr166/ConcurrentLinkedHashMap.java | 2141 ++++++++++ .../src/main/java/org/jsr166/LongAdder8.java | 206 + .../src/main/java/org/jsr166/Striped64_8.java | 346 ++ .../java/org/jsr166/ThreadLocalRandom8.java | 202 + .../src/main/java/org/jsr166/package-info.java | 10 + .../resources/META-INF/classnames.properties | 79 +- .../resources/META-INF/licenses/apache-2.0.txt | 202 - .../META-INF/licenses/gnu-gplv2ce-license.txt | 349 -- .../resources/META-INF/licenses/snaptree.txt | 35 - .../core/src/main/resources/ignite.properties | 2 +- .../spring-cache-client-benchmark-1.xml | 4 +- .../spring-cache-client-benchmark-2.xml | 4 +- .../spring-cache-client-benchmark-3.xml | 4 +- .../core/src/test/config/discovery-stress.xml | 3 +- modules/core/src/test/config/example-cache.xml | 6 +- .../core/src/test/config/examples.properties | 14 +- modules/core/src/test/config/igfs-loopback.xml | 1 - modules/core/src/test/config/igfs-shmem.xml | 1 - .../src/test/config/load/cache-benchmark.xml | 2 - .../test/config/load/cache-client-benchmark.xml | 13 - .../config/load/dsi-49-server-production.xml | 6 +- .../src/test/config/load/dsi-load-server.xml | 7 +- .../core/src/test/config/spring-cache-swap.xml | 2 +- .../src/test/config/spring-cache-teststore.xml | 2 +- .../core/src/test/config/spring-multicache.xml | 16 +- .../core/src/test/config/store/jdbc/Ignite.xml | 268 -- .../config/store/jdbc/ignite-type-metadata.xml | 268 ++ .../test/config/websession/example-cache.xml | 8 +- .../test/config/websession/spring-cache-1.xml | 4 - .../test/config/websession/spring-cache-2.xml | 4 - .../test/config/websession/spring-cache-3.xml | 4 - .../GridCacheAffinityBackupsSelfTest.java | 8 +- .../apache/ignite/GridTestStoreNodeStartup.java | 2 +- .../ignite/IgniteCacheAffinitySelfTest.java | 28 +- ...CachePartitionFairAffinityNodesSelfTest.java | 242 -- .../GridCachePartitionFairAffinitySelfTest.java | 261 -- .../GridFairAffinityFunctionNodesSelfTest.java | 242 ++ .../fair/GridFairAffinityFunctionSelfTest.java | 264 ++ .../GridCacheLoadOnlyStoreAdapterSelfTest.java | 2 +- .../IgniteCacheExpiryStoreLoadSelfTest.java | 6 +- .../store/jdbc/CacheJdbcPojoStoreTest.java | 2 +- ...eJdbcStoreAbstractMultithreadedSelfTest.java | 20 +- ...CacheJdbcBlobStoreMultithreadedSelfTest.java | 75 +- .../ignite/igfs/IgfsEventsAbstractSelfTest.java | 3 +- .../igfs/IgfsFragmentizerAbstractSelfTest.java | 2 +- .../ignite/internal/GridAffinityMappedTest.java | 4 +- .../internal/GridAffinityP2PSelfTest.java | 4 +- .../ignite/internal/GridAffinitySelfTest.java | 2 +- .../ignite/internal/GridDiscoverySelfTest.java | 3 +- .../GridJobMasterLeaveAwareSelfTest.java | 6 +- .../internal/GridMultipleJobsSelfTest.java | 2 +- .../GridProjectionForCachesSelfTest.java | 63 +- .../ignite/internal/GridProjectionSelfTest.java | 36 +- .../ignite/internal/GridStartStopSelfTest.java | 4 +- .../internal/GridUpdateNotifierSelfTest.java | 2 + .../checkpoint/GridCheckpointTaskSelfTest.java | 4 +- .../GridDeploymentMessageCountSelfTest.java | 8 +- .../GridDiscoveryManagerAliveCacheSelfTest.java | 12 +- .../discovery/GridDiscoveryManagerSelfTest.java | 124 +- .../GridCacheTxLoadFromStoreOnLockSelfTest.java | 152 + .../GridAffinityProcessorAbstractSelfTest.java | 18 +- ...GridAffinityProcessorRendezvousSelfTest.java | 4 +- ...cheNearUpdateTopologyChangeAbstractTest.java | 140 + .../GridCacheAbstractFailoverSelfTest.java | 2 +- .../cache/GridCacheAbstractFlagsTest.java | 7 +- ...cheAbstractFullApiMultithreadedSelfTest.java | 2 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 186 +- .../GridCacheAbstractLocalStoreSelfTest.java | 21 +- .../cache/GridCacheAbstractMetricsSelfTest.java | 80 +- .../GridCacheAbstractRemoveFailureTest.java | 15 +- .../cache/GridCacheAbstractSelfTest.java | 34 +- ...acheAbstractUsersAffinityMapperSelfTest.java | 12 +- .../cache/GridCacheAffinityApiSelfTest.java | 56 +- .../cache/GridCacheAffinityMapperSelfTest.java | 14 +- .../cache/GridCacheAffinityRoutingSelfTest.java | 6 +- .../cache/GridCacheAlwaysEvictionPolicy.java | 14 +- .../GridCacheAtomicMessageCountSelfTest.java | 30 +- ...dCacheAtomicUsersAffinityMapperSelfTest.java | 5 +- .../cache/GridCacheBasicApiAbstractTest.java | 31 +- .../cache/GridCacheBasicStoreAbstractTest.java | 12 +- ...acheBasicStoreMultithreadedAbstractTest.java | 2 +- .../cache/GridCacheClearAllSelfTest.java | 45 +- .../cache/GridCacheClearLocallySelfTest.java | 378 ++ .../cache/GridCacheClearLocalySelfTest.java | 335 -- ...dCacheColocatedTxStoreExceptionSelfTest.java | 6 +- .../cache/GridCacheConcurrentMapSelfTest.java | 10 +- .../cache/GridCacheConcurrentMapTest.java | 6 +- .../GridCacheConcurrentTxMultiNodeTest.java | 36 +- ...idCacheConfigurationConsistencySelfTest.java | 270 +- ...ridCacheConfigurationValidationSelfTest.java | 39 +- .../GridCacheDaemonNodeAbstractSelfTest.java | 7 +- .../GridCacheDeploymentOffHeapSelfTest.java | 3 +- .../cache/GridCacheDeploymentSelfTest.java | 21 +- .../cache/GridCacheEntryMemorySizeSelfTest.java | 7 +- .../cache/GridCacheEntryVersionSelfTest.java | 4 +- .../GridCacheEvictionEventAbstractTest.java | 10 +- .../GridCacheExAbstractFullApiSelfTest.java | 6 +- .../GridCacheFinishPartitionsSelfTest.java | 30 +- ...CacheFullTextQueryMultithreadedSelfTest.java | 2 +- ...idCacheGetAndTransformStoreAbstractTest.java | 11 +- .../cache/GridCacheIncrementTransformTest.java | 4 +- .../GridCacheInterceptorAbstractSelfTest.java | 355 +- ...cheInterceptorAtomicNearEnabledSelfTest.java | 11 +- ...erceptorAtomicPrimaryWriteOrderSelfTest.java | 8 +- .../GridCacheInterceptorAtomicSelfTest.java | 8 +- ...GridCacheInterceptorNearEnabledSelfTest.java | 7 +- .../cache/GridCacheInterceptorSelfTest.java | 8 +- .../cache/GridCacheIteratorPerformanceTest.java | 6 +- .../GridCacheKeyCheckNearEnabledSelfTest.java | 6 +- .../cache/GridCacheKeyCheckSelfTest.java | 13 +- .../processors/cache/GridCacheLeakTest.java | 7 +- .../cache/GridCacheLifecycleAwareSelfTest.java | 43 +- .../cache/GridCacheLuceneQueryIndexTest.java | 17 +- .../GridCacheMarshallerTxAbstractTest.java | 10 +- .../GridCacheMarshallingNodeJoinSelfTest.java | 170 + .../cache/GridCacheMemoryModeSelfTest.java | 5 +- ...GridCacheMixedPartitionExchangeSelfTest.java | 45 +- .../cache/GridCacheMultiUpdateLockSelfTest.java | 14 +- ...ridCacheMultinodeUpdateAbstractSelfTest.java | 24 +- ...ultinodeUpdateAtomicNearEnabledSelfTest.java | 6 +- .../GridCacheMultinodeUpdateAtomicSelfTest.java | 6 +- ...CacheMultinodeUpdateNearEnabledSelfTest.java | 6 +- .../cache/GridCacheMultinodeUpdateSelfTest.java | 6 +- .../cache/GridCacheMvccManagerSelfTest.java | 2 +- .../cache/GridCacheMvccPartitionedSelfTest.java | 2 - .../cache/GridCacheNestedTxAbstractTest.java | 12 +- .../cache/GridCacheObjectToStringSelfTest.java | 23 +- ...HeapMultiThreadedUpdateAbstractSelfTest.java | 17 +- ...CacheOffHeapMultiThreadedUpdateSelfTest.java | 14 +- .../cache/GridCacheOffHeapSelfTest.java | 9 +- .../processors/cache/GridCacheOffHeapTest.java | 5 +- .../GridCacheOffHeapTieredAbstractSelfTest.java | 45 +- ...heOffHeapTieredEvictionAbstractSelfTest.java | 17 +- .../cache/GridCacheOffheapUpdateSelfTest.java | 10 +- .../GridCacheOnCopyFlagAbstractSelfTest.java | 18 +- .../GridCacheOrderedPreloadingSelfTest.java | 2 +- .../cache/GridCacheP2PUndeploySelfTest.java | 9 +- .../GridCachePartitionedAffinitySpreadTest.java | 4 +- .../cache/GridCachePartitionedGetSelfTest.java | 12 +- .../GridCachePartitionedLocalStoreSelfTest.java | 6 +- ...chePartitionedOffHeapLocalStoreSelfTest.java | 6 +- ...hePartitionedProjectionAffinitySelfTest.java | 2 - .../cache/GridCachePartitionedWritesTest.java | 6 +- .../GridCachePreloadingEvictionsSelfTest.java | 13 +- .../cache/GridCachePutAllFailoverSelfTest.java | 9 +- .../processors/cache/GridCachePutAllTask.java | 2 +- .../GridCacheQueryInternalKeysSelfTest.java | 2 +- .../GridCacheReferenceCleanupSelfTest.java | 13 +- .../cache/GridCacheReloadSelfTest.java | 10 +- .../GridCacheReplicatedLocalStoreSelfTest.java | 6 +- ...ridCacheReplicatedSynchronousCommitTest.java | 8 +- ...CacheReplicatedTxStoreExceptionSelfTest.java | 6 +- ...heReplicatedUsersAffinityMapperSelfTest.java | 5 +- .../GridCacheReturnValueTransferSelfTest.java | 13 +- .../cache/GridCacheSlowTxWarnTest.java | 2 +- .../processors/cache/GridCacheStopSelfTest.java | 2 +- .../cache/GridCacheStorePutxSelfTest.java | 2 +- .../cache/GridCacheStoreValueBytesSelfTest.java | 3 +- .../cache/GridCacheSwapPreloadSelfTest.java | 25 +- .../cache/GridCacheSwapReloadSelfTest.java | 2 +- .../processors/cache/GridCacheTestEntryEx.java | 27 +- ...cheTransactionalAbstractMetricsSelfTest.java | 8 +- .../cache/GridCacheTtlManagerLoadTest.java | 2 +- .../cache/GridCacheTtlManagerSelfTest.java | 6 +- ...ridCacheTxPartitionedLocalStoreSelfTest.java | 6 +- .../GridCacheTxUsersAffinityMapperSelfTest.java | 5 +- .../GridCacheValueBytesPreloadingSelfTest.java | 13 +- ...idCacheValueConsistencyAbstractSelfTest.java | 40 +- ...istencyTransactionalNearEnabledSelfTest.java | 6 +- .../GridCacheVariableTopologySelfTest.java | 2 +- .../cache/GridCacheVersionMultinodeTest.java | 13 +- .../GridCacheWriteBehindStoreAbstractTest.java | 4 +- ...BehindStorePartitionedMultiNodeSelfTest.java | 12 +- .../GridCacheWriteBehindStoreSelfTest.java | 2 +- .../IgniteCacheAbstractStopBusySelfTest.java | 13 +- .../cache/IgniteCacheAbstractTest.java | 28 +- .../cache/IgniteCacheAtomicInvokeTest.java | 6 +- .../cache/IgniteCacheAtomicLocalInvokeTest.java | 6 +- ...niteCacheAtomicLocalWithStoreInvokeTest.java | 6 +- .../IgniteCacheAtomicNearEnabledInvokeTest.java | 8 +- .../IgniteCacheAtomicNearPeekModesTest.java | 28 + ...eCacheAtomicPrimaryWriteOrderInvokeTest.java | 6 +- ...micPrimaryWriteOrderWithStoreInvokeTest.java | 6 +- ...niteCacheCopyOnReadDisabledAbstractTest.java | 2 +- .../cache/IgniteCacheDynamicStopSelfTest.java | 130 + .../IgniteCacheEntryListenerAbstractTest.java | 204 +- ...IgniteCacheEntryListenerAtomicLocalTest.java | 6 +- .../IgniteCacheEntryListenerAtomicTest.java | 6 +- .../IgniteCacheEntryListenerTxLocalTest.java | 6 +- .../cache/IgniteCacheEntryListenerTxTest.java | 6 +- .../cache/IgniteCacheInvokeReadThroughTest.java | 11 +- .../cache/IgniteCachePeekModesAbstractTest.java | 42 +- .../cache/IgniteCacheStartStopLoadTest.java | 135 + .../cache/IgniteCacheTxInvokeTest.java | 6 +- .../cache/IgniteCacheTxLocalInvokeTest.java | 6 +- .../IgniteCacheTxNearEnabledInvokeTest.java | 8 +- .../cache/IgniteCacheTxNearPeekModesTest.java | 28 + .../cache/IgniteCacheTxPreloadNoWriteTest.java | 8 +- .../cache/IgniteCachingProviderSelfTest.java | 4 +- .../IgniteClientAffinityAssignmentSelfTest.java | 15 +- .../cache/IgniteDynamicCacheStartSelfTest.java | 972 +++++ .../cache/IgnitePutAllLargeBatchSelfTest.java | 11 +- ...tAllUpdateNonPreloadedPartitionSelfTest.java | 6 +- .../cache/IgniteStaticCacheStartSelfTest.java | 98 + .../processors/cache/IgniteTxAbstractTest.java | 4 +- .../IgniteTxConcurrentGetAbstractTest.java | 4 +- .../IgniteTxExceptionAbstractSelfTest.java | 32 +- .../cache/IgniteTxMultiNodeAbstractTest.java | 58 +- .../IgniteTxMultiThreadedAbstractTest.java | 2 +- .../cache/IgniteTxReentryAbstractSelfTest.java | 7 +- .../IgniteTxStoreExceptionAbstractSelfTest.java | 50 +- ...IgniteCacheAbstractExecutionContextTest.java | 14 +- .../IgniteCacheAtomicExecutionContextTest.java | 6 +- ...iteCachePartitionedExecutionContextTest.java | 6 +- ...niteCacheReplicatedExecutionContextTest.java | 6 +- .../IgniteCacheTxExecutionContextTest.java | 6 +- ...eAbstractDataStructuresFailoverSelfTest.java | 2 +- ...actQueueFailoverDataConsistencySelfTest.java | 4 +- ...CacheAtomicReferenceApiSelfAbstractTest.java | 2 +- ...idCacheAtomicStampedApiSelfAbstractTest.java | 2 +- .../GridCacheSequenceApiSelfAbstractTest.java | 2 +- .../GridCacheSetAbstractSelfTest.java | 10 +- .../IgniteAtomicLongApiAbstractSelfTest.java | 4 +- .../IgniteCollectionAbstractTest.java | 4 +- ...titionedAtomicSequenceMultiThreadedTest.java | 48 +- ...GridCachePartitionedNodeRestartSelfTest.java | 2 +- ...idCachePartitionedNodeRestartTxSelfTest.java | 26 +- ...PartitionedQueueCreateMultiNodeSelfTest.java | 2 +- ...dCachePartitionedQueueEntryMoveSelfTest.java | 9 +- ...CacheAtomicNearUpdateTopologyChangeTest.java | 39 + .../CacheTxNearUpdateTopologyChangeTest.java | 33 + ...tractDistributedByteArrayValuesSelfTest.java | 6 +- .../GridCacheAbstractJobExecutionTest.java | 38 +- .../GridCacheAbstractNodeRestartSelfTest.java | 10 +- ...tractPartitionedByteArrayValuesSelfTest.java | 9 +- .../GridCacheAbstractPrimarySyncSelfTest.java | 7 +- .../GridCacheAtomicTimeoutSelfTest.java | 17 +- .../GridCacheBasicOpAbstractTest.java | 26 +- .../GridCacheClientModesAbstractSelfTest.java | 34 +- .../GridCacheEntrySetAbstractSelfTest.java | 2 +- ...acheEntrySetIterationPreloadingSelfTest.java | 4 +- .../distributed/GridCacheEventAbstractTest.java | 8 +- ...heExpiredEntriesPreloadAbstractSelfTest.java | 2 +- ...GridCacheLoadingConcurrentGridStartTest.java | 6 +- .../distributed/GridCacheLockAbstractTest.java | 6 +- .../distributed/GridCacheMixedModeSelfTest.java | 8 +- .../GridCacheModuloAffinityFunction.java | 4 +- .../GridCacheMultiNodeAbstractTest.java | 10 +- .../GridCacheMultiNodeLockAbstractTest.java | 14 +- ...dCacheMultithreadedFailoverAbstractTest.java | 25 +- .../GridCacheNodeFailureAbstractTest.java | 6 +- ...dCachePartitionedAffinityFilterSelfTest.java | 10 +- ...chePartitionedReloadAllAbstractSelfTest.java | 17 +- .../GridCachePreloadEventsAbstractSelfTest.java | 7 +- ...GridCachePreloadRestartAbstractSelfTest.java | 12 +- .../GridCacheTransformEventSelfTest.java | 7 +- .../IgniteCacheSystemTransactionsSelfTest.java | 2 +- .../IgniteCrossCacheTxStoreSelfTest.java | 93 +- ...iteTxConsistencyRestartAbstractSelfTest.java | 8 +- ...xOriginatingNodeFailureAbstractSelfTest.java | 8 +- ...cOriginatingNodeFailureAbstractSelfTest.java | 16 +- .../IgniteTxTimeoutAbstractTest.java | 2 +- ...tPartitionedOnlyByteArrayValuesSelfTest.java | 12 +- ...heAbstractTransformWriteThroughSelfTest.java | 8 +- ...acheAtomicExpiredEntriesPreloadSelfTest.java | 6 +- .../dht/GridCacheAtomicFullApiSelfTest.java | 5 +- .../dht/GridCacheAtomicNearCacheSelfTest.java | 86 +- ...idCacheAtomicNearEnabledFullApiSelfTest.java | 8 +- ...EnabledPrimaryWriteOrderFullApiSelfTest.java | 8 +- .../dht/GridCacheClientOnlySelfTest.java | 8 +- .../dht/GridCacheColocatedDebugTest.java | 116 +- .../dht/GridCacheColocatedFailoverSelfTest.java | 6 +- ...eColocatedOptimisticTransactionSelfTest.java | 6 +- .../GridCacheColocatedPrimarySyncSelfTest.java | 8 +- .../GridCacheColocatedTxExceptionSelfTest.java | 6 +- ...ssimisticOriginatingNodeFailureSelfTest.java | 6 +- ...dCacheColocatedTxSingleThreadedSelfTest.java | 2 +- .../GridCacheDhtAtomicRemoveFailureTest.java | 3 +- .../dht/GridCacheDhtEntrySelfTest.java | 8 +- .../dht/GridCacheDhtEntrySetSelfTest.java | 3 +- ...GridCacheDhtEvictionNearReadersSelfTest.java | 22 +- .../dht/GridCacheDhtEvictionSelfTest.java | 23 +- .../GridCacheDhtEvictionsDisabledSelfTest.java | 5 +- ...idCacheDhtExpiredEntriesPreloadSelfTest.java | 6 +- .../dht/GridCacheDhtInternalEntrySelfTest.java | 36 +- .../dht/GridCacheDhtMappingSelfTest.java | 4 +- .../dht/GridCacheDhtMultiBackupTest.java | 4 +- .../dht/GridCacheDhtPreloadBigDataSelfTest.java | 12 +- .../dht/GridCacheDhtPreloadDelayedSelfTest.java | 26 +- .../GridCacheDhtPreloadDisabledSelfTest.java | 15 +- .../GridCacheDhtPreloadMessageCountTest.java | 8 +- ...ridCacheDhtPreloadMultiThreadedSelfTest.java | 2 +- .../dht/GridCacheDhtPreloadPutGetSelfTest.java | 4 +- .../dht/GridCacheDhtPreloadSelfTest.java | 26 +- .../GridCacheDhtPreloadStartStopSelfTest.java | 10 +- .../dht/GridCacheDhtPreloadUnloadSelfTest.java | 26 +- .../dht/GridCacheDhtRemoveFailureTest.java | 3 +- .../distributed/dht/GridCacheDhtTestUtils.java | 12 +- .../dht/GridCacheDhtTxPreloadSelfTest.java | 3 +- .../dht/GridCacheGlobalLoadTest.java | 14 +- ...ePartitionedNearDisabledFullApiSelfTest.java | 8 +- ...ePartitionedNearDisabledMetricsSelfTest.java | 13 +- ...nedNearDisabledMultiNodeFullApiSelfTest.java | 8 +- ...bledMultiNodeP2PDisabledFullApiSelfTest.java | 8 +- ...isabledTxOriginatingNodeFailureSelfTest.java | 6 +- ...idCachePartitionedPreloadEventsSelfTest.java | 18 +- ...dCachePartitionedTopologyChangeSelfTest.java | 21 +- ...itionedTxOriginatingNodeFailureSelfTest.java | 5 - ...ridCachePartitionedUnloadEventsSelfTest.java | 10 +- ...IgniteCacheContainsKeyColocatedSelfTest.java | 5 +- ...teTxConsistencyColocatedRestartSelfTest.java | 5 +- .../dht/IgniteTxReentryColocatedSelfTest.java | 2 +- ...eAtomicInvalidPartitionHandlingSelfTest.java | 60 +- .../atomic/GridCacheAtomicPreloadSelfTest.java | 9 +- ...tomicPrimaryWriteOrderRemoveFailureTest.java | 56 + .../GridCacheAtomicRemoveFailureTest.java | 56 + ...lueConsistencyAtomicNearEnabledSelfTest.java | 14 +- ...micPrimaryWriteOrderNearEnabledSelfTest.java | 6 +- ...GridCacheValueConsistencyAtomicSelfTest.java | 6 +- ...CacheContainsKeyColocatedAtomicSelfTest.java | 5 +- ...tNearPartitionedByteArrayValuesSelfTest.java | 8 +- ...unctionExcludeNeighborsAbstractSelfTest.java | 6 +- ...tomicClientOnlyMultiNodeFullApiSelfTest.java | 19 +- ...GridCacheAtomicMultiNodeFullApiSelfTest.java | 5 +- ...omicMultiNodeP2PDisabledFullApiSelfTest.java | 5 +- ...omicNearEnabledMultiNodeFullApiSelfTest.java | 8 +- ...imaryWriteOrderMultiNodeFullApiSelfTest.java | 8 +- ...eAtomicNearOnlyMultiNodeFullApiSelfTest.java | 14 +- .../GridCacheAtomicNearRemoveFailureTest.java | 3 +- .../GridCacheAtomicOffHeapFullApiSelfTest.java | 5 +- ...heAtomicOffHeapMultiNodeFullApiSelfTest.java | 5 +- ...AtomicPartitionedTckMetricsSelfTestImpl.java | 8 +- ...cPrimaryWriteOrderNearRemoveFailureTest.java | 3 +- .../near/GridCacheExNearFullApiSelfTest.java | 6 +- .../near/GridCacheGetStoreErrorSelfTest.java | 41 +- .../GridCacheNearEvictionEventSelfTest.java | 5 - .../near/GridCacheNearEvictionSelfTest.java | 13 +- ...dCacheNearExpiredEntriesPreloadSelfTest.java | 6 - .../near/GridCacheNearJobExecutionSelfTest.java | 3 +- .../near/GridCacheNearMetricsSelfTest.java | 30 +- .../near/GridCacheNearMultiGetSelfTest.java | 8 +- .../near/GridCacheNearMultiNodeSelfTest.java | 27 +- .../near/GridCacheNearOneNodeSelfTest.java | 4 +- ...idCacheNearOnlyMultiNodeFullApiSelfTest.java | 48 +- .../near/GridCacheNearOnlySelfTest.java | 7 - .../near/GridCacheNearOnlyTopologySelfTest.java | 40 +- .../GridCacheNearPartitionedClearSelfTest.java | 9 +- .../near/GridCacheNearPrimarySyncSelfTest.java | 8 +- .../GridCacheNearReaderPreloadSelfTest.java | 11 +- .../near/GridCacheNearReadersSelfTest.java | 34 +- .../near/GridCacheNearRemoveFailureTest.java | 3 +- .../near/GridCacheNearTxMultiNodeSelfTest.java | 15 +- ...ssimisticOriginatingNodeFailureSelfTest.java | 6 - .../near/GridCacheNearTxPreloadSelfTest.java | 3 +- ...AffinityExcludeNeighborsPerformanceTest.java | 10 +- ...rtitionedAffinityHashIdResolverSelfTest.java | 20 +- .../GridCachePartitionedAffinitySelfTest.java | 12 +- .../near/GridCachePartitionedBasicApiTest.java | 3 +- ...ePartitionedBasicStoreMultiNodeSelfTest.java | 6 +- ...ionedClientOnlyNoPrimaryFullApiSelfTest.java | 15 +- .../near/GridCachePartitionedEventSelfTest.java | 3 +- .../GridCachePartitionedEvictionSelfTest.java | 8 +- ...titionedExplicitLockNodeFailureSelfTest.java | 3 +- ...GridCachePartitionedFilteredPutSelfTest.java | 3 +- .../GridCachePartitionedFullApiSelfTest.java | 3 +- ...idCachePartitionedHitsAndMissesSelfTest.java | 12 +- .../GridCachePartitionedLoadCacheSelfTest.java | 5 +- ...achePartitionedMultiNodeCounterSelfTest.java | 25 +- ...achePartitionedMultiNodeFullApiSelfTest.java | 44 +- ...idCachePartitionedMultiNodeLockSelfTest.java | 3 +- .../GridCachePartitionedMultiNodeSelfTest.java | 2 - ...ePartitionedMultiThreadedPutGetSelfTest.java | 15 +- ...NearDisabledBasicStoreMultiNodeSelfTest.java | 4 +- ...itionedNearOnlyNoPrimaryFullApiSelfTest.java | 6 +- ...GridCachePartitionedNodeFailureSelfTest.java | 2 - .../GridCachePartitionedNodeRestartTest.java | 5 +- ...ePartitionedOptimisticTxNodeRestartTest.java | 2 +- ...achePartitionedPreloadLifecycleSelfTest.java | 14 +- .../GridCachePartitionedStorePutSelfTest.java | 9 +- .../GridCachePartitionedTxSalvageSelfTest.java | 5 +- ...achePartitionedTxSingleThreadedSelfTest.java | 1 - .../near/GridCachePutArrayValueSelfTest.java | 2 +- ...idCacheRendezvousAffinityClientSelfTest.java | 10 +- ...ffinityFunctionExcludeNeighborsSelfTest.java | 4 +- .../near/GridPartitionedBackupLoadSelfTest.java | 5 +- .../near/IgniteCacheNearReadCommittedTest.java | 9 +- .../near/IgniteTxReentryNearSelfTest.java | 2 +- ...stractReplicatedByteArrayValuesSelfTest.java | 1 - .../GridCacheReplicatedEvictionSelfTest.java | 5 +- .../GridCacheReplicatedFullApiSelfTest.java | 5 +- ...dezvousAffinityMultiNodeFullApiSelfTest.java | 4 +- .../GridCacheReplicatedTxExceptionSelfTest.java | 6 +- ...ssimisticOriginatingNodeFailureSelfTest.java | 7 +- ...idCacheReplicatedUnswapAdvancedSelfTest.java | 4 +- .../GridCacheSyncReplicatedPreloadSelfTest.java | 7 +- ...CacheReplicatedPreloadLifecycleSelfTest.java | 15 +- .../GridCacheReplicatedPreloadSelfTest.java | 36 +- ...GridCacheReplicatedPreloadUndeploysTest.java | 4 +- .../GridCacheBatchEvictUnswapSelfTest.java | 11 +- ...heConcurrentEvictionConsistencySelfTest.java | 29 +- .../GridCacheConcurrentEvictionsSelfTest.java | 18 +- .../GridCacheDistributedEvictionsSelfTest.java | 48 +- .../GridCacheEmptyEntriesAbstractSelfTest.java | 17 +- .../eviction/GridCacheEvictionAbstractTest.java | 32 +- .../GridCacheEvictionFilterSelfTest.java | 25 +- .../GridCacheEvictionLockUnlockSelfTest.java | 12 +- .../GridCacheEvictionTouchSelfTest.java | 35 +- .../cache/eviction/GridCacheMockEntry.java | 3 +- ...cheSynchronousEvictionsFailoverSelfTest.java | 9 +- .../GridCacheFifoEvictionPolicySelfTest.java | 20 +- .../lru/GridCacheLruEvictionPolicySelfTest.java | 22 +- .../GridCacheLruNearEvictionPolicySelfTest.java | 9 +- ...heNearOnlyLruNearEvictionPolicySelfTest.java | 13 +- .../GridCacheRandomEvictionPolicySelfTest.java | 28 +- .../IgniteCacheAtomicExpiryPolicyTest.java | 6 +- .../IgniteCacheAtomicLocalExpiryPolicyTest.java | 6 +- ...maryWriteOrderWithStoreExpiryPolicyTest.java | 6 +- ...iteCacheAtomicWithStoreExpiryPolicyTest.java | 6 +- .../IgniteCacheExpiryPolicyAbstractTest.java | 26 +- ...eCacheExpiryPolicyWithStoreAbstractTest.java | 50 +- .../expiry/IgniteCacheTxExpiryPolicyTest.java | 6 +- .../IgniteCacheTxLocalExpiryPolicyTest.java | 6 +- .../IgniteCacheTxWithStoreExpiryPolicyTest.java | 6 +- .../IgniteCacheAtomicLoadAllTest.java | 6 +- .../IgniteCacheAtomicLoaderWriterTest.java | 6 +- .../IgniteCacheAtomicLocalLoadAllTest.java | 6 +- ...CacheAtomicLocalNoLoadPreviousValueTest.java | 6 +- ...IgniteCacheAtomicLocalNoReadThroughTest.java | 6 +- ...gniteCacheAtomicLocalNoWriteThroughTest.java | 6 +- ...tomicNearEnabledNoLoadPreviousValueTest.java | 8 +- ...CacheAtomicNearEnabledNoReadThroughTest.java | 8 +- ...acheAtomicNearEnabledNoWriteThroughTest.java | 8 +- ...gniteCacheAtomicNoLoadPreviousValueTest.java | 6 +- .../IgniteCacheAtomicNoReadThroughTest.java | 6 +- .../IgniteCacheAtomicNoWriteThroughTest.java | 6 +- .../IgniteCacheAtomicStoreSessionTest.java | 6 +- .../IgniteCacheLoadAllAbstractTest.java | 111 +- .../IgniteCacheLoaderWriterAbstractTest.java | 14 +- ...iteCacheNoLoadPreviousValueAbstractTest.java | 5 +- .../IgniteCacheNoReadThroughAbstractTest.java | 63 +- .../IgniteCacheNoWriteThroughAbstractTest.java | 8 +- .../IgniteCacheStoreSessionAbstractTest.java | 15 +- ...acheStoreSessionWriteBehindAbstractTest.java | 14 +- .../integration/IgniteCacheTxLoadAllTest.java | 6 +- .../IgniteCacheTxLoaderWriterTest.java | 6 +- .../IgniteCacheTxLocalLoadAllTest.java | 6 +- ...niteCacheTxLocalNoLoadPreviousValueTest.java | 6 +- .../IgniteCacheTxLocalNoReadThroughTest.java | 6 +- .../IgniteCacheTxLocalNoWriteThroughTest.java | 6 +- ...cheTxNearEnabledNoLoadPreviousValueTest.java | 8 +- ...niteCacheTxNearEnabledNoReadThroughTest.java | 8 +- ...iteCacheTxNearEnabledNoWriteThroughTest.java | 8 +- .../IgniteCacheTxNoLoadPreviousValueTest.java | 6 +- .../IgniteCacheTxNoReadThroughTest.java | 6 +- .../IgniteCacheTxNoWriteThroughTest.java | 6 +- .../IgniteCacheTxStoreSessionTest.java | 12 +- ...dCacheAtomicLocalMetricsNoStoreSelfTest.java | 13 +- ...dCacheAtomicLocalTckMetricsSelfTestImpl.java | 8 +- .../GridCacheLocalByteArrayValuesSelfTest.java | 5 +- .../local/GridCacheLocalLoadAllSelfTest.java | 5 +- .../cache/local/GridCacheLocalLockSelfTest.java | 6 +- .../GridCacheLocalMultithreadedSelfTest.java | 2 +- .../local/GridCacheLocalTxTimeoutSelfTest.java | 2 +- .../GridCacheSwapScanQueryAbstractSelfTest.java | 12 +- ...ridCacheContinuousQueryAbstractSelfTest.java | 115 +- ...ontinuousQueryAtomicNearEnabledSelfTest.java | 8 +- .../GridCacheContinuousQueryAtomicSelfTest.java | 6 +- ...eContinuousQueryPartitionedOnlySelfTest.java | 6 +- ...dCacheContinuousQueryReplicatedSelfTest.java | 8 +- .../DataStreamProcessorSelfTest.java | 49 +- .../datastreamer/DataStreamerImplSelfTest.java | 2 +- .../IgniteDataStreamerPerformanceTest.java | 9 +- .../processors/igfs/IgfsAbstractSelfTest.java | 2 +- ...sCachePerBlockLruEvictionPolicySelfTest.java | 12 +- .../processors/igfs/IgfsCacheSelfTest.java | 23 +- .../igfs/IgfsDataManagerSelfTest.java | 2 +- .../igfs/IgfsMetaManagerSelfTest.java | 3 +- .../processors/igfs/IgfsMetricsSelfTest.java | 8 +- .../processors/igfs/IgfsModesSelfTest.java | 4 +- .../processors/igfs/IgfsProcessorSelfTest.java | 2 +- .../processors/igfs/IgfsSizeSelfTest.java | 8 +- .../processors/igfs/IgfsStreamsSelfTest.java | 2 +- .../processors/igfs/IgfsTaskSelfTest.java | 4 +- .../IgfsAbstractRecordResolverSelfTest.java | 3 +- .../processors/service/DummyService.java | 2 +- .../GridServiceProcessorAbstractSelfTest.java | 4 +- .../GridServiceProcessorMultiNodeSelfTest.java | 2 +- .../internal/util/GridTestClockTimer.java | 11 + .../util/future/GridCompoundFutureSelfTest.java | 3 +- .../future/GridFutureListenPerformanceTest.java | 4 +- .../util/future/GridFutureQueueTest.java | 2 +- .../IpcSharedMemoryCrashDetectionSelfTest.java | 24 +- .../ipc/shmem/IpcSharedMemoryNodeStartup.java | 3 +- .../ipc/shmem/IpcSharedMemorySpaceSelfTest.java | 2 +- .../offheap/GridOffHeapMapAbstractSelfTest.java | 3 +- ...idOffHeapPartitionedMapAbstractSelfTest.java | 4 +- ...apPartitionedMapPerformanceAbstractTest.java | 4 +- .../unsafe/GridUnsafeMemorySelfTest.java | 10 +- ...GridUnsafePartitionedMapPerformanceTest.java | 2 +- .../ignite/jvmtest/BlockingQueueTest.java | 4 +- .../ignite/jvmtest/ConcurrentMapTest.java | 2 +- .../ignite/lang/GridBasicPerformanceTest.java | 2 +- .../lang/GridFutureListenPerformanceTest.java | 4 +- .../lang/GridMetadataAwareAdapterSelfTest.java | 14 +- .../GridCircularBufferPerformanceTest.java | 10 +- .../lang/utils/GridCircularBufferSelfTest.java | 2 +- .../utils/GridConcurrentHashMapSelfTest.java | 4 +- .../GridConcurrentLinkedHashMapSelfTest.java | 2 +- ...idFileSwapSpaceSpiMultithreadedLoadTest.java | 2 +- .../loadtests/GridCacheLoadPopulationTask.java | 2 +- .../loadtests/GridCacheMultiNodeLoadTest.java | 5 +- .../cache/GridCacheAbstractLoadTest.java | 2 +- .../loadtests/cache/GridCacheBenchmark.java | 3 +- .../cache/GridCacheDataStructuresLoadTest.java | 2 +- .../loadtests/cache/GridCacheLoadTest.java | 5 +- .../cache/GridCachePutRemoveLoadTest.java | 373 -- .../cache/GridCacheSingleNodeLoadTest.java | 182 - .../loadtests/cache/GridCacheSwapLoadTest.java | 7 +- .../GridCacheWriteBehindStoreLoadTest.java | 2 +- .../capacity/GridCapacityLoadTest.java | 3 +- .../capacity/spring-capacity-cache.xml | 4 +- .../colocation/GridTestCacheStore.java | 7 +- .../loadtests/colocation/GridTestKey.java | 2 +- .../colocation/GridTestLifecycleBean.java | 2 +- .../loadtests/colocation/GridTestMain.java | 6 +- .../loadtests/colocation/spring-colocation.xml | 4 +- .../communication/GridIoManagerBenchmark.java | 4 +- .../communication/GridIoManagerBenchmark0.java | 8 +- .../GridTcpCommunicationBenchmark.java | 6 +- .../GridContinuousOperationsLoadTest.java | 9 +- .../GridCachePartitionedAtomicLongLoadTest.java | 7 +- .../ignite/loadtests/dsi/GridDsiClient.java | 4 +- .../ignite/loadtests/dsi/GridDsiPerfJob.java | 10 +- .../ignite/loadtests/dsi/GridDsiRequest.java | 2 +- .../ignite/loadtests/dsi/GridDsiResponse.java | 4 +- .../ignite/loadtests/dsi/GridDsiSession.java | 2 +- .../cacheget/GridBenchmarkCacheGetLoadTest.java | 2 +- ...dBoundedConcurrentLinkedHashSetLoadTest.java | 8 +- .../loadtests/hashmap/GridCacheTestContext.java | 1 + .../job/GridJobExecutionLoadTestClient.java | 4 +- ...GridJobExecutionLoadTestClientSemaphore.java | 4 +- ...JobExecutionSingleNodeSemaphoreLoadTest.java | 6 +- .../GridConcurrentLinkedHashMapBenchmark.java | 6 +- .../mapper/GridContinuousMapperTask1.java | 2 +- .../mapper/GridContinuousMapperTask2.java | 2 +- ...apPartitionedMapPerformanceAbstractTest.java | 4 +- ...GridUnsafePartitionedMapPerformanceTest.java | 2 +- .../swap/GridSwapEvictAllBenchmark.java | 6 +- .../marshaller/GridMarshallerAbstractTest.java | 6 +- .../marshaller/MarshallerContextTestImpl.java | 2 +- .../OptimizedMarshallerNodeFailoverTest.java | 6 +- .../OptimizedObjectStreamSelfTest.java | 16 +- .../CacheCheckpointSpiSecondCacheSelfTest.java | 4 +- .../tcp/GridCacheDhtLockBackupSelfTest.java | 4 +- .../tcp/GridTcpCommunicationSpiLanTest.java | 2 +- ...cpCommunicationSpiMultithreadedSelfTest.java | 2 +- .../discovery/AbstractDiscoverySelfTest.java | 2 +- .../tcp/TcpDiscoverySpiStartStopSelfTest.java | 2 +- .../file/GridFileSwapSpaceSpiSelfTest.java | 3 +- .../inmemory/GridTestSwapSpaceSpi.java | 2 +- .../GridCacheStoreValueBytesNode.java | 132 - .../GridCacheStoreValueBytesTest.java | 343 -- .../ignite/testframework/GridTestUtils.java | 29 +- .../testframework/junits/GridAbstractTest.java | 146 +- .../ignite/testframework/junits/IgniteMock.java | 40 +- .../junits/common/GridAbstractExamplesTest.java | 2 +- .../GridAbstractLifecycleAwareSelfTest.java | 7 + .../junits/common/GridCommonAbstractTest.java | 95 +- .../junits/spi/GridSpiAbstractTest.java | 5 +- .../IgniteCacheFailoverTestSuite.java | 12 +- .../ignite/testsuites/IgniteCacheTestSuite.java | 18 +- ...dConcurrentLinkedDequeMultiThreadedTest.java | 6 +- .../util/GridConcurrentLinkedDequeSelfTest.java | 6 +- ...rrentLinkedHashMapMultiThreadedSelfTest.java | 4 +- .../webapp/META-INF/ignite-webapp-config.xml | 7 +- modules/core/src/test/webapp/WEB-INF/web.xml | 4 +- .../tests/p2p/CacheDeploymentTestTask1.java | 2 +- .../tests/p2p/CacheDeploymentTestTask3.java | 2 +- .../tests/p2p/GridExternalAffinityFunction.java | 6 +- .../p2p/GridExternalAffinityKeyMapper.java | 2 +- .../p2p/GridP2PContinuousDeploymentTask1.java | 2 +- modules/geospatial/README.txt | 33 + modules/geospatial/readme.txt | 33 - .../query/h2/GridH2IndexingGeoSelfTest.java | 8 +- modules/hadoop/README.txt | 33 + modules/hadoop/readme.txt | 33 - .../fs/IgniteHadoopIgfsSecondaryFileSystem.java | 26 +- .../hadoop/fs/v1/IgniteHadoopFileSystem.java | 4 +- .../hadoop/fs/v2/IgniteHadoopFileSystem.java | 4 +- .../processors/hadoop/HadoopClassLoader.java | 2 +- .../processors/hadoop/HadoopContext.java | 4 +- .../internal/processors/hadoop/HadoopSetup.java | 8 +- .../hadoop/SecondaryFileSystemProvider.java | 31 +- .../hadoop/counter/HadoopCountersImpl.java | 2 +- .../processors/hadoop/igfs/HadoopIgfsIpcIo.java | 2 +- .../hadoop/igfs/HadoopIgfsOutProc.java | 2 +- .../hadoop/jobtracker/HadoopJobTracker.java | 2 +- .../taskexecutor/HadoopExecutorService.java | 2 +- .../external/HadoopExternalTaskExecutor.java | 2 +- .../HadoopExternalCommunication.java | 2 +- .../hadoop/v1/HadoopV1ReduceTask.java | 5 +- .../processors/hadoop/v2/HadoopV2Job.java | 2 +- .../hadoop/v2/HadoopV2ReduceTask.java | 5 +- .../HadoopIgfs20FileSystemAbstractSelfTest.java | 8 +- .../igfs/HadoopIgfsDualAbstractSelfTest.java | 2 +- ...oopSecondaryFileSystemConfigurationTest.java | 8 +- .../igfs/IgfsNearOnlyMultiNodeSelfTest.java | 19 +- .../IgniteHadoopFileSystemAbstractSelfTest.java | 6 +- .../IgniteHadoopFileSystemClientSelfTest.java | 3 +- ...IgniteHadoopFileSystemHandshakeSelfTest.java | 3 +- .../IgniteHadoopFileSystemIpcCacheSelfTest.java | 2 +- ...niteHadoopFileSystemLoggerStateSelfTest.java | 2 +- ...teHadoopFileSystemSecondaryModeSelfTest.java | 4 +- .../hadoop/HadoopCommandLineTest.java | 2 +- .../processors/hadoop/HadoopMapReduceTest.java | 24 +- .../processors/hadoop/HadoopSharedMap.java | 2 +- .../taskexecutor/HadoopExecutorServiceTest.java | 6 +- modules/hibernate/README.txt | 33 + modules/hibernate/readme.txt | 33 - .../HibernateAccessStrategyAdapter.java | 2 +- .../cache/hibernate/HibernateRegionFactory.java | 21 +- .../HibernateL2CacheConfigurationSelfTest.java | 14 +- .../hibernate/HibernateL2CacheSelfTest.java | 10 +- .../HibernateL2CacheTransactionalSelfTest.java | 3 +- modules/indexing/README.txt | 33 + modules/indexing/readme.txt | 33 - .../processors/query/h2/IgniteH2Indexing.java | 36 +- .../processors/query/h2/opt/GridH2Table.java | 2 +- .../query/h2/opt/GridLuceneIndex.java | 7 +- .../query/h2/sql/GridSqlQueryParser.java | 5 +- .../query/h2/twostep/GridMapQueryExecutor.java | 2 +- .../query/h2/twostep/GridMergeIndex.java | 2 +- .../h2/twostep/GridReduceQueryExecutor.java | 2 +- .../GridCacheAbstractFieldsQuerySelfTest.java | 82 +- .../cache/GridCacheCrossCacheQuerySelfTest.java | 23 +- .../cache/GridCacheOffHeapAndSwapSelfTest.java | 72 +- .../GridCacheQueryIndexDisabledSelfTest.java | 16 +- .../cache/GridCacheQuerySimpleBenchmark.java | 10 +- .../processors/cache/GridCacheSwapSelfTest.java | 13 +- .../cache/GridIndexingWithNoopSwapSelfTest.java | 7 +- .../IgniteCacheAbstractFieldsQuerySelfTest.java | 92 +- .../cache/IgniteCacheAbstractQuerySelfTest.java | 184 +- .../IgniteCacheFieldsQueryNoDataSelfTest.java | 2 +- ...hePartitionedQueryMultiThreadedSelfTest.java | 8 +- .../cache/IgniteCacheQueryIndexSelfTest.java | 4 +- .../cache/IgniteCacheQueryLoadSelfTest.java | 16 +- .../IgniteCacheQueryMultiThreadedSelfTest.java | 35 +- ...gniteCacheSqlQueryMultiThreadedSelfTest.java | 11 +- ...GridCachePartitionedFieldsQuerySelfTest.java | 15 +- .../IgniteCacheAtomicFieldsQuerySelfTest.java | 8 +- ...cheAtomicNearEnabledFieldsQuerySelfTest.java | 8 +- ...niteCacheAtomicNearEnabledQuerySelfTest.java | 3 +- .../near/IgniteCacheAtomicQuerySelfTest.java | 3 +- ...niteCachePartitionedFieldsQuerySelfTest.java | 7 +- .../IgniteCachePartitionedQuerySelfTest.java | 12 +- .../IgniteCacheQueryNodeRestartSelfTest.java | 6 +- .../GridCacheReplicatedFieldsQuerySelfTest.java | 4 +- ...gniteCacheReplicatedFieldsQuerySelfTest.java | 4 +- .../IgniteCacheReplicatedQuerySelfTest.java | 28 +- .../local/IgniteCacheLocalQuerySelfTest.java | 9 +- ...dCacheAbstractReduceFieldsQuerySelfTest.java | 37 +- ...ridCacheReduceFieldsQueryAtomicSelfTest.java | 6 +- ...cheReduceFieldsQueryPartitionedSelfTest.java | 2 +- .../query/h2/GridH2IndexRebuildTest.java | 17 +- .../query/h2/sql/GridQueryParsingTest.java | 4 +- modules/jcl/README.txt | 33 + modules/jcl/readme.txt | 33 - modules/jta/README.txt | 32 + modules/jta/readme.txt | 32 - .../processors/cache/GridCacheJtaSelfTest.java | 2 +- .../GridTmLookupLifecycleAwareSelfTest.java | 12 +- modules/log4j/README.txt | 32 + modules/log4j/readme.txt | 32 - modules/rest-http/README.txt | 33 + modules/rest-http/readme.txt | 33 - .../http/jetty/GridJettyRestHandler.java | 5 +- modules/scalar/README.txt | 32 + modules/scalar/readme.txt | 32 - .../ignite/scalar/pimps/ScalarCachePimp.scala | 4 +- .../scala/org/apache/ignite/scalar/scalar.scala | 25 +- .../scalar/src/test/resources/spring-cache.xml | 6 +- .../test/resources/spring-ping-pong-partner.xml | 2 +- modules/schedule/README.txt | 32 + modules/schedule/readme.txt | 32 - modules/schema-import/README.txt | 214 + modules/schema-import/pom.xml | 11 +- modules/schema-import/readme.txt | 214 - .../ignite/schema/generator/CodeGenerator.java | 659 +++ .../ignite/schema/generator/PojoGenerator.java | 414 -- .../schema/generator/SnippetGenerator.java | 144 - .../ignite/schema/generator/XmlGenerator.java | 26 +- .../apache/ignite/schema/model/IndexItem.java | 16 +- .../ignite/schema/model/PojoDescriptor.java | 16 +- .../ignite/schema/ui/ConfirmCallable.java | 2 +- .../org/apache/ignite/schema/ui/MessageBox.java | 23 +- .../ignite/schema/ui/SchemaImportApp.java | 230 +- .../schema/test/AbstractSchemaImportTest.java | 19 +- .../test/generator/CodeGeneratorTest.java | 70 + .../test/generator/PojoGeneratorTest.java | 70 - .../schema/test/generator/XmlGeneratorTest.java | 2 +- .../apache/ignite/schema/test/model/Ignite.xml | 390 -- .../schema/test/model/ignite-type-metadata.xml | 362 ++ .../testsuites/IgniteSchemaImportTestSuite.java | 2 +- modules/slf4j/README.txt | 32 + modules/slf4j/readme.txt | 32 - modules/spring/README.txt | 33 + modules/spring/readme.txt | 33 - .../org/apache/ignite/IgniteSpringBean.java | 56 +- .../apache/ignite/cache/spring/SpringCache.java | 142 +- .../ignite/cache/spring/SpringCacheManager.java | 105 +- .../cache/spring/SpringDynamicCacheManager.java | 339 -- .../spring/IgniteSpringProcessorImpl.java | 268 -- .../util/spring/IgniteSpringHelperImpl.java | 301 ++ .../ignite/internal/GridFactorySelfTest.java | 64 + .../internal/IgniteDynamicCacheConfigTest.java | 244 ++ .../apache/ignite/internal/TestNodeFilter.java | 36 + .../java/org/apache/ignite/internal/cache.xml | 58 + .../apache/ignite/internal/filtered-cache.xml | 62 + .../apache/ignite/internal/invalid-cache.xml | 78 + .../p2p/GridP2PUserVersionChangeSelfTest.java | 6 +- .../spring/GridSpringCacheManagerSelfTest.java | 123 +- .../GridSpringDynamicCacheManagerSelfTest.java | 219 - .../GridSpringDynamicCacheTestService.java | 34 +- .../org/apache/ignite/spring/spring-caching.xml | 10 + .../ignite/spring/spring-dynamic-caching.xml | 43 - .../testsuites/IgniteSpringTestSuite.java | 3 +- modules/ssh/README.txt | 32 + modules/ssh/licenses/jcraft-revised-bsd.txt | 4 +- modules/ssh/readme.txt | 32 - .../util/nodestart/IgniteSshHelperImpl.java | 28 + .../util/nodestart/IgniteSshProcessorImpl.java | 28 - modules/urideploy/README.txt | 33 + modules/urideploy/readme.txt | 33 - .../licenses/jcraft-revised-bsd.txt | 4 +- .../ignite/visor/commands/VisorConsole.scala | 6 +- .../commands/cache/VisorCacheCommand.scala | 17 +- .../visor/commands/logo_ignite_128x128.png | Bin 18667 -> 0 bytes .../ignite/visor/commands/logo_ignite_48x48.png | Bin 16572 -> 0 bytes .../scala/org/apache/ignite/visor/visor.scala | 6 +- .../cache/VisorCacheClearCommandSpec.scala | 8 +- .../commands/cache/VisorCacheCommandSpec.scala | 4 +- .../cswap/VisorCacheSwapCommandSpec.scala | 4 +- modules/web/README.txt | 34 + modules/web/readme.txt | 34 - .../cache/websession/IgniteWebSession.java | 286 -- .../websession/IgniteWebSessionFilter.java | 466 --- .../websession/IgniteWebSessionListener.java | 196 - .../ignite/cache/websession/WebSession.java | 286 ++ .../cache/websession/WebSessionFilter.java | 467 +++ .../cache/websession/WebSessionListener.java | 196 + .../IgniteServletContextListenerStartup.java | 181 - .../startup/servlet/IgniteServletStartup.java | 187 - .../servlet/ServletContextListenerStartup.java | 181 + .../ignite/startup/servlet/ServletStartup.java | 187 + .../internal/websession/WebSessionSelfTest.java | 2 +- .../yardstick/IgniteAbstractBenchmark.java | 2 +- .../yardstick/IgniteBenchmarkArguments.java | 1 + .../org/apache/ignite/yardstick/IgniteNode.java | 10 +- .../yardstick/cache/IgniteGetBenchmark.java | 2 +- .../cache/IgniteGetOffHeapBenchmark.java | 2 +- .../cache/IgniteGetOffHeapValuesBenchmark.java | 2 +- .../yardstick/cache/IgnitePutBenchmark.java | 2 +- .../yardstick/cache/IgnitePutGetBenchmark.java | 2 +- .../cache/IgnitePutGetOffHeapBenchmark.java | 2 +- .../IgnitePutGetOffHeapValuesBenchmark.java | 2 +- .../cache/IgnitePutGetTxBenchmark.java | 2 +- .../cache/IgnitePutGetTxOffHeapBenchmark.java | 2 +- .../IgnitePutGetTxOffHeapValuesBenchmark.java | 2 +- .../cache/IgnitePutOffHeapBenchmark.java | 2 +- .../cache/IgnitePutOffHeapValuesBenchmark.java | 2 +- .../yardstick/cache/IgnitePutTxBenchmark.java | 2 +- .../cache/IgnitePutTxOffHeapBenchmark.java | 2 +- .../IgnitePutTxOffHeapValuesBenchmark.java | 2 +- .../cache/IgniteSqlQueryBenchmark.java | 2 +- .../cache/IgniteSqlQueryJoinBenchmark.java | 4 +- .../IgniteSqlQueryJoinOffHeapBenchmark.java | 2 +- .../cache/IgniteSqlQueryOffHeapBenchmark.java | 2 +- .../cache/IgniteSqlQueryPutBenchmark.java | 2 +- .../IgniteSqlQueryPutOffHeapBenchmark.java | 2 +- .../store/jdbc/IgniteJdbcStoreGetBenchmark.java | 2 +- .../jdbc/IgniteJdbcStoreGetTxBenchmark.java | 2 +- .../store/jdbc/IgniteJdbcStorePutBenchmark.java | 2 +- .../jdbc/IgniteJdbcStorePutGetBenchmark.java | 2 +- .../jdbc/IgniteJdbcStorePutGetTxBenchmark.java | 2 +- .../jdbc/IgniteJdbcStorePutTxBenchmark.java | 2 +- pom.xml | 42 +- 1455 files changed, 41507 insertions(+), 33711 deletions(-) ----------------------------------------------------------------------
