Merge remote-tracking branch 'remotes/origin/ignite-45' into ignite-45-gridcache
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/22d766ef Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/22d766ef Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/22d766ef Branch: refs/heads/ignite-45-gridcache Commit: 22d766ef6495099df0c1ee9fba9edf488a0ad798 Parents: 299c5d1 c1d5326 Author: ivasilinets <[email protected]> Authored: Mon Mar 23 18:14:16 2015 +0300 Committer: ivasilinets <[email protected]> Committed: Mon Mar 23 18:14:16 2015 +0300 ---------------------------------------------------------------------- DEVNOTES.txt | 8 +- LICENSE.txt | 55 +- NOTICE.txt | 19 +- assembly/dependencies-fabric.xml | 4 +- assembly/dependencies-hadoop.xml | 6 +- assembly/dependencies-optional-fabric.xml | 2 +- assembly/dependencies-optional-hadoop.xml | 2 +- assembly/libs/README.txt | 120 + assembly/libs/readme.txt | 120 - assembly/release-fabric.xml | 2 + 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 | 120 +- examples/config/example-streamer.xml | 293 -- examples/config/filesystem/README.txt | 8 + 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 | 20 +- examples/pom.xml | 75 + examples/rest/http-rest-example.php | 15 +- examples/rest/memcache-rest-example.php | 92 - examples/schema-import/README.txt | 40 + 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/db-demo-script.bat | 99 - examples/schema-import/db-demo-server.bat | 97 - examples/schema-import/db-demo-wizard.bat | 89 - examples/schema-import/db-demo.bat | 93 - examples/schema-import/demo.sql | 10 - examples/schema-import/pom.xml | 91 + .../org/apache/ignite/schema/CacheConfig.java | 38 + .../java/org/apache/ignite/schema/Demo.java | 68 + .../java/org/apache/ignite/schema/Person.java | 33 + .../org/apache/ignite/schema/PersonKey.java | 31 + .../apache/ignite/examples/ExamplesUtils.java | 63 +- .../computegrid/ComputeAsyncExample.java | 74 + .../ComputeClusterGroupsExample.java | 93 - .../ComputeExecutorServiceExample.java | 71 - .../computegrid/ComputeRunnableExample.java | 15 +- .../computegrid/ComputeScheduleExample.java | 81 - .../cluster/ClusterGroupExample.java | 93 + .../computegrid/cluster/package-info.java | 22 + .../computegrid/failover/package-info.java | 2 +- .../computegrid/montecarlo/package-info.java | 2 +- .../examples/computegrid/package-info.java | 2 +- .../examples/datagrid/CacheApiExample.java | 25 +- .../examples/datagrid/CacheAsyncApiExample.java | 86 + .../datagrid/CacheContinuousQueryExample.java | 2 +- .../datagrid/CacheDataStreamerExample.java | 19 +- .../datagrid/CachePopularNumbersExample.java | 172 - .../examples/datagrid/CacheQueryExample.java | 55 +- .../hibernate/HibernateL2CacheExample.java | 135 +- .../HibernateL2CacheExampleNodeStartup.java | 97 - .../datagrid/hibernate/package-info.java | 2 +- .../ignite/examples/datagrid/package-info.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 | 11 +- .../store/dummy/CacheDummyStoreExample.java | 130 + .../datagrid/store/dummy/package-info.java | 2 +- .../hibernate/CacheHibernatePersonStore.java | 48 +- .../hibernate/CacheHibernateStoreExample.java | 130 + .../datagrid/store/hibernate/Person.hbm.xml | 2 +- .../datagrid/store/hibernate/package-info.java | 2 +- .../store/jdbc/CacheJdbcPersonStore.java | 4 +- .../store/jdbc/CacheJdbcPojoPersonStore.java | 82 - .../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 +- .../IgniteExecutorServiceExample.java | 71 + .../datastructures/IgniteSetExample.java | 1 - .../examples/datastructures/package-info.java | 2 +- .../ignite/examples/events/package-info.java | 2 +- .../ignite/examples/igfs/package-info.java | 2 +- .../messaging/MessagingPingPongExample.java | 48 +- .../ignite/examples/messaging/package-info.java | 2 +- .../misc/client/memcache/package-info.java | 2 +- .../examples/misc/client/package-info.java | 2 +- .../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 + .../examples/misc/springbean/package-info.java | 2 +- .../apache/ignite/examples/package-info.java | 2 +- .../examples/servicegrid/ServicesExample.java | 17 +- .../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 + .../ignite/examples/java8/ComputeExample.java | 56 - .../examples/java8/ExampleNodeStartup.java | 35 - .../ignite/examples/java8/ExamplesUtils.java | 129 - .../ignite/examples/java8/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 | 64 + .../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 | 100 + .../java8/streaming/numbers/CacheConfig.java | 10 +- .../streaming/numbers/QueryPopularNumbers.java | 45 +- .../streaming/numbers/StreamRandomNumbers.java | 41 +- .../examples/java8/streaming/package-info.java | 22 + .../ScalarCachePopularNumbersExample.scala | 2 +- .../examples/ScalarCacheQueryExample.scala | 5 +- .../examples/ScalarSnowflakeSchemaExample.scala | 7 +- .../ignite/examples/BasicExamplesSelfTest.java | 3 +- .../CacheExamplesMultiNodeSelfTest.java | 10 - .../ignite/examples/CacheExamplesSelfTest.java | 20 +- ...heStoreLoadDataExampleMultiNodeSelfTest.java | 39 - .../examples/ClusterGroupExampleSelfTest.java | 39 + .../ComputeClusterGroupsExampleSelfTest.java | 39 - ...ibernateL2CacheExampleMultiNodeSelfTest.java | 2 +- .../examples/MessagingExamplesSelfTest.java | 3 +- .../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 + 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 - .../integration/ClientAbstractSelfTest.java | 34 +- .../JettyRestProcessorAbstractSelfTest.java | 4 +- .../rest/RestBinaryProtocolSelfTest.java | 2 +- .../rest/TaskCommandHandlerSelfTest.java | 4 +- .../core/licenses/pcollections-mit-license.txt | 19 - modules/core/pom.xml | 1 - .../src/main/java/org/apache/ignite/Ignite.java | 82 +- .../java/org/apache/ignite/IgniteCache.java | 34 +- .../org/apache/ignite/IgniteDataStreamer.java | 41 +- .../org/apache/ignite/IgniteJdbcDriver.java | 10 - .../apache/ignite/IgniteSystemProperties.java | 7 + .../main/java/org/apache/ignite/Ignition.java | 2 +- .../CacheEntryEventSerializableFilter.java | 28 + .../ignite/cache/CacheExistsException.java | 52 + .../org/apache/ignite/cache/CacheManager.java | 27 +- .../cache/CacheServerNotFoundException.java | 49 + .../ignite/cache/CacheTypeFieldMetadata.java | 7 +- .../apache/ignite/cache/CacheTypeMetadata.java | 12 +- .../eviction/fifo/CacheFifoEvictionPolicy.java | 4 +- .../CacheIgfsPerBlockLruEvictionPolicy.java | 7 +- .../eviction/lru/CacheLruEvictionPolicy.java | 4 +- .../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 | 24 +- .../org/apache/ignite/cache/query/SqlQuery.java | 21 +- .../apache/ignite/cache/query/TextQuery.java | 35 +- .../cache/store/CacheLoadOnlyStoreAdapter.java | 2 +- .../apache/ignite/cache/store/CacheStore.java | 2 +- .../ignite/cache/store/CacheStoreAdapter.java | 2 +- .../ignite/cache/store/CacheStoreSession.java | 2 +- .../store/jdbc/CacheAbstractJdbcStore.java | 75 +- .../cache/store/jdbc/CacheJdbcBlobStore.java | 9 +- .../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/compute/ComputeJob.java | 3 +- .../ignite/compute/ComputeJobAdapter.java | 2 +- .../configuration/CacheConfiguration.java | 5 + .../configuration/NearCacheConfiguration.java | 23 - .../ignite/events/CacheQueryExecutedEvent.java | 8 +- .../ignite/events/CacheQueryReadEvent.java | 10 +- .../org/apache/ignite/events/EventType.java | 11 +- .../apache/ignite/internal/IgniteKernal.java | 161 +- .../org/apache/ignite/internal/IgnitionEx.java | 37 +- .../internal/MarshallerContextAdapter.java | 2 +- .../router/impl/GridRouterClientImpl.java | 2 +- .../cluster/ClusterNodeLocalMapImpl.java | 2 +- .../ClusterTopologyServerNotFoundException.java | 40 + .../ignite/internal/igfs/common/IgfsLogger.java | 2 +- .../checkpoint/GridCheckpointManager.java | 4 +- .../managers/communication/GridIoManager.java | 4 +- .../communication/GridIoMessageFactory.java | 2 +- .../managers/deployment/GridDeployment.java | 2 +- .../deployment/GridDeploymentClassLoader.java | 2 +- .../deployment/GridDeploymentLocalStore.java | 2 +- .../GridDeploymentPerVersionStore.java | 2 +- .../discovery/GridDiscoveryManager.java | 8 +- .../eventstorage/GridEventStorageManager.java | 2 +- .../affinity/GridAffinityAssignmentCache.java | 2 +- .../affinity/GridAffinityProcessor.java | 94 +- .../processors/affinity/GridAffinityUtils.java | 2 + .../cache/CacheStoreBalancingWrapper.java | 6 +- .../cache/CacheWeakQueryIteratorsHolder.java | 2 +- .../cache/DynamicCacheChangeRequest.java | 44 +- .../processors/cache/GridCacheAdapter.java | 8 +- .../cache/GridCacheAtomicVersionComparator.java | 21 +- .../cache/GridCacheConcurrentMap.java | 11 +- .../processors/cache/GridCacheContext.java | 47 +- .../cache/GridCacheDeploymentManager.java | 2 +- .../GridCacheEntryInfoCollectSwapListener.java | 2 +- .../cache/GridCacheEvictionManager.java | 6 +- .../processors/cache/GridCacheGateway.java | 114 +- .../processors/cache/GridCacheIoManager.java | 2 +- .../cache/GridCacheLoaderWriterStore.java | 2 +- .../processors/cache/GridCacheMapEntry.java | 47 +- .../processors/cache/GridCacheMvccManager.java | 5 +- .../GridCachePartitionExchangeManager.java | 11 +- .../processors/cache/GridCacheProcessor.java | 257 +- .../processors/cache/GridCacheStoreManager.java | 2 +- .../processors/cache/GridCacheSwapManager.java | 2 +- .../processors/cache/GridCacheUtils.java | 11 +- .../cache/GridCacheWriteBehindStore.java | 4 +- .../cache/IgniteCacheExistsException.java | 52 - .../processors/cache/IgniteCacheProxy.java | 147 +- .../CacheDataStructuresManager.java | 4 +- .../distributed/GridCacheTxFinishSync.java | 2 +- .../distributed/dht/GridDhtCacheAdapter.java | 2 +- .../distributed/dht/GridDhtCacheEntry.java | 4 +- .../distributed/dht/GridDhtLocalPartition.java | 5 +- .../distributed/dht/GridDhtLockFuture.java | 2 +- .../dht/GridDhtPartitionTopologyImpl.java | 2 +- .../distributed/dht/GridDhtTxLocalAdapter.java | 2 +- .../cache/distributed/dht/GridDhtTxRemote.java | 2 +- .../dht/atomic/GridDhtAtomicCache.java | 2 +- .../dht/atomic/GridDhtAtomicUpdateFuture.java | 2 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 11 +- .../colocated/GridDhtColocatedLockFuture.java | 5 +- .../GridDhtPartitionsExchangeFuture.java | 91 +- .../dht/preloader/GridDhtPreloader.java | 2 +- .../distributed/near/GridNearAtomicCache.java | 2 + .../distributed/near/GridNearLockFuture.java | 4 +- .../cache/distributed/near/GridNearTxLocal.java | 3 +- .../near/GridNearTxPrepareFuture.java | 2 +- .../local/atomic/GridLocalAtomicCache.java | 5 - .../query/GridCacheDistributedQueryManager.java | 2 +- .../cache/query/GridCacheQueriesImpl.java | 2 +- .../cache/query/GridCacheQueryManager.java | 2 +- .../cache/query/GridCacheTwoStepQuery.java | 20 + .../CacheContinuousQueryFilterEx.java | 4 +- .../continuous/CacheContinuousQueryHandler.java | 12 +- .../continuous/CacheContinuousQueryManager.java | 30 +- .../query/jdbc/GridCacheQueryJdbcTask.java | 2 +- .../cache/transactions/IgniteTxManager.java | 2 +- .../transactions/TransactionProxyImpl.java | 17 - .../GridCacheVersionConflictResolver.java | 2 +- .../processors/clock/GridClockServer.java | 2 +- .../clock/GridClockSyncProcessor.java | 2 +- .../continuous/GridContinuousProcessor.java | 2 +- .../datastreamer/DataStreamerImpl.java | 96 +- .../datastreamer/DataStreamerUpdateJob.java | 1 + .../datastructures/DataStructuresProcessor.java | 2 +- .../dr/IgniteDrDataStreamerCacheUpdater.java | 5 +- .../processors/igfs/IgfsClientSession.java | 2 +- .../processors/igfs/IgfsDataManager.java | 2 +- .../internal/processors/igfs/IgfsImpl.java | 2 +- .../processors/igfs/IgfsLocalMetrics.java | 30 +- .../internal/processors/igfs/IgfsProcessor.java | 2 +- .../internal/processors/igfs/IgfsServer.java | 6 +- .../processors/igfs/IgfsServerManager.java | 4 +- .../processors/job/GridJobProcessor.java | 15 +- .../jobmetrics/GridJobMetricsProcessor.java | 2 +- .../offheap/GridOffHeapProcessor.java | 2 +- .../query/GridQueryCacheObjectsIterator.java | 70 + .../processors/query/GridQueryIndexing.java | 20 +- .../processors/query/GridQueryProcessor.java | 66 +- .../processors/resource/GridResourceIoc.java | 2 +- .../processors/rest/GridRestProcessor.java | 4 +- .../handlers/cache/GridCacheCommandHandler.java | 2 - .../handlers/task/GridTaskCommandHandler.java | 2 +- .../service/GridServiceProcessor.java | 33 +- .../processors/service/GridServiceProxy.java | 2 +- .../session/GridTaskSessionProcessor.java | 2 +- .../spring/IgniteSpringProcessor.java | 12 + .../processors/task/GridTaskProcessor.java | 4 +- .../processors/task/GridTaskWorker.java | 2 +- .../timeout/GridTimeoutProcessor.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 | 65 +- .../util/future/GridCompoundFuture.java | 2 +- .../internal/util/future/IgniteFutureImpl.java | 5 - .../ignite/internal/util/lang/GridFunc.java | 2 +- .../ignite/internal/util/nio/GridNioServer.java | 2 +- .../util/nio/GridSelectorNioSessionImpl.java | 2 +- .../offheap/unsafe/GridOffHeapSnapTreeMap.java | 2 +- .../util/offheap/unsafe/GridUnsafeMap.java | 8 +- .../unsafe/GridUnsafePartitionedMap.java | 4 +- .../ignite/internal/util/worker/GridWorker.java | 14 +- .../org/apache/ignite/lang/IgniteFuture.java | 31 +- .../jdk/JdkMarshallerObjectInputStream.java | 4 +- .../optimized/OptimizedClassDescriptor.java | 268 +- .../optimized/OptimizedMarshaller.java | 2 +- .../optimized/OptimizedMarshallerUtils.java | 2 - .../optimized/OptimizedObjectInputStream.java | 93 +- .../optimized/OptimizedObjectOutputStream.java | 64 +- .../jobstealing/JobStealingCollisionSpi.java | 2 +- .../communication/tcp/TcpCommunicationSpi.java | 11 +- .../deployment/local/LocalDeploymentSpi.java | 2 +- .../discovery/tcp/TcpClientDiscoverySpi.java | 2 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 2 +- .../tcp/internal/TcpDiscoveryStatistics.java | 2 +- .../memory/MemoryEventStorageSpi.java | 2 +- .../adaptive/AdaptiveLoadBalancingSpi.java | 2 +- .../roundrobin/RoundRobinLoadBalancingSpi.java | 2 +- .../WeightedRandomLoadBalancingSpi.java | 2 +- .../spi/swapspace/file/FileSwapSpaceSpi.java | 2 +- .../apache/ignite/stream/StreamTransformer.java | 26 +- .../org/apache/ignite/stream/StreamVisitor.java | 53 + .../apache/ignite/transactions/Transaction.java | 29 - .../org/jdk8/backport/ConcurrentHashMap8.java | 3823 ------------------ .../jdk8/backport/ConcurrentLinkedDeque8.java | 1983 --------- .../jdk8/backport/ConcurrentLinkedHashMap.java | 2170 ---------- .../main/java/org/jdk8/backport/LongAdder.java | 235 -- .../main/java/org/jdk8/backport/Striped64.java | 370 -- .../org/jdk8/backport/ThreadLocalRandom8.java | 231 -- .../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 | 6 +- .../resources/META-INF/licenses/apache-2.0.txt | 202 - .../META-INF/licenses/gnu-gplv2ce-license.txt | 349 -- .../resources/META-INF/licenses/snaptree.txt | 35 - modules/core/src/test/config/example-cache.xml | 1 - .../store/GridCacheBalancingStoreSelfTest.java | 2 +- .../cache/store/GridGeneratingTestStore.java | 2 +- .../IgniteCacheExpiryStoreLoadSelfTest.java | 2 +- ...eJdbcStoreAbstractMultithreadedSelfTest.java | 2 +- ...CacheJdbcBlobStoreMultithreadedSelfTest.java | 8 +- .../GridProjectionForCachesSelfTest.java | 15 +- .../GridDeploymentMessageCountSelfTest.java | 2 +- .../discovery/GridDiscoveryManagerSelfTest.java | 8 +- .../GridAffinityProcessorAbstractSelfTest.java | 2 +- .../GridCacheAbstractLocalStoreSelfTest.java | 2 +- .../GridCacheAbstractRemoveFailureTest.java | 3 +- .../cache/GridCacheAbstractSelfTest.java | 2 +- .../cache/GridCacheClearLocallySelfTest.java | 6 +- ...idCacheConfigurationConsistencySelfTest.java | 2 +- .../cache/GridCacheGenericTestStore.java | 2 +- .../GridCacheInterceptorAbstractSelfTest.java | 2 +- .../cache/GridCacheLifecycleAwareSelfTest.java | 2 +- ...heOffHeapTieredEvictionAbstractSelfTest.java | 9 +- .../GridCacheOnCopyFlagAbstractSelfTest.java | 2 +- ...ridCacheReplicatedSynchronousCommitTest.java | 2 +- .../cache/GridCacheStorePutxSelfTest.java | 2 +- .../processors/cache/GridCacheTestStore.java | 2 +- .../GridCacheWriteBehindStoreSelfTest.java | 2 +- .../cache/IgniteCacheAbstractTest.java | 2 +- .../cache/IgniteCacheDynamicStopSelfTest.java | 130 + .../IgniteCacheEntryListenerAbstractTest.java | 13 +- .../cache/IgniteDynamicCacheStartSelfTest.java | 431 +- .../IgniteTxStoreExceptionAbstractSelfTest.java | 2 +- ...titionedAtomicSequenceMultiThreadedTest.java | 48 +- .../GridCacheClientModesAbstractSelfTest.java | 6 +- ...chePartitionedReloadAllAbstractSelfTest.java | 3 +- .../IgniteCrossCacheTxStoreSelfTest.java | 6 +- .../dht/GridCacheGlobalLoadTest.java | 2 +- ...eAtomicInvalidPartitionHandlingSelfTest.java | 11 +- ...GridCacheValueConsistencyAtomicSelfTest.java | 2 +- ...idCacheNearOnlyMultiNodeFullApiSelfTest.java | 2 +- .../near/GridCacheNearOnlyTopologySelfTest.java | 8 +- ...heNearOnlyLruNearEvictionPolicySelfTest.java | 2 +- .../IgniteCacheExpiryPolicyAbstractTest.java | 79 +- ...eCacheExpiryPolicyWithStoreAbstractTest.java | 40 +- .../IgniteCacheLoadAllAbstractTest.java | 2 +- .../IgniteCacheLoaderWriterAbstractTest.java | 2 +- .../IgniteCacheStoreSessionAbstractTest.java | 21 +- ...acheStoreSessionWriteBehindAbstractTest.java | 2 +- .../IgniteCacheTxStoreSessionTest.java | 14 +- ...ridCacheContinuousQueryAbstractSelfTest.java | 45 +- .../DataStreamProcessorSelfTest.java | 2 +- .../IgniteDataStreamerPerformanceTest.java | 4 +- .../processors/igfs/IgfsCacheSelfTest.java | 15 +- .../processors/igfs/IgfsSizeSelfTest.java | 4 +- .../processors/service/DummyService.java | 2 +- .../internal/util/GridTestClockTimer.java | 11 + .../util/future/GridCompoundFutureSelfTest.java | 3 +- .../future/GridFutureListenPerformanceTest.java | 4 +- .../util/future/GridFutureQueueTest.java | 2 +- .../ipc/shmem/IpcSharedMemorySpaceSelfTest.java | 2 +- .../offheap/GridOffHeapMapAbstractSelfTest.java | 3 +- ...idOffHeapPartitionedMapAbstractSelfTest.java | 2 +- ...apPartitionedMapPerformanceAbstractTest.java | 2 +- .../unsafe/GridUnsafeMemorySelfTest.java | 11 +- .../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 | 11 +- .../lang/utils/GridCircularBufferSelfTest.java | 2 +- .../utils/GridConcurrentHashMapSelfTest.java | 4 +- .../GridConcurrentLinkedHashMapSelfTest.java | 2 +- ...idFileSwapSpaceSpiMultithreadedLoadTest.java | 2 +- .../colocation/GridTestCacheStore.java | 5 +- .../communication/GridIoManagerBenchmark.java | 4 +- .../communication/GridIoManagerBenchmark0.java | 9 +- .../GridTcpCommunicationBenchmark.java | 6 +- .../GridContinuousOperationsLoadTest.java | 7 +- .../ignite/loadtests/dsi/GridDsiPerfJob.java | 2 +- ...dBoundedConcurrentLinkedHashSetLoadTest.java | 8 +- .../job/GridJobExecutionLoadTestClient.java | 4 +- ...GridJobExecutionLoadTestClientSemaphore.java | 4 +- ...JobExecutionSingleNodeSemaphoreLoadTest.java | 6 +- .../GridConcurrentLinkedHashMapBenchmark.java | 6 +- ...apPartitionedMapPerformanceAbstractTest.java | 2 +- .../marshaller/MarshallerContextTestImpl.java | 2 +- ...arshallerSerialPersistentFieldsSelfTest.java | 110 + .../OptimizedObjectStreamSelfTest.java | 16 +- .../tcp/GridTcpCommunicationSpiLanTest.java | 2 +- ...cpCommunicationSpiMultithreadedSelfTest.java | 2 +- .../file/GridFileSwapSpaceSpiSelfTest.java | 3 +- .../inmemory/GridTestSwapSpaceSpi.java | 2 +- .../testframework/junits/GridAbstractTest.java | 4 +- .../ignite/testframework/junits/IgniteMock.java | 42 +- .../cache/GridAbstractCacheStoreSelfTest.java | 34 +- .../IgniteCacheFailoverTestSuite.java | 2 +- .../ignite/testsuites/IgniteCacheTestSuite.java | 5 +- .../IgniteMarshallerSelfTestSuite.java | 1 + ...dConcurrentLinkedDequeMultiThreadedTest.java | 6 +- .../util/GridConcurrentLinkedDequeSelfTest.java | 6 +- ...rrentLinkedHashMapMultiThreadedSelfTest.java | 4 +- modules/core/src/test/webapp/WEB-INF/web.xml | 4 +- modules/geospatial/README.txt | 33 + modules/geospatial/readme.txt | 33 - modules/hadoop/README.txt | 33 + modules/hadoop/readme.txt | 33 - .../processors/hadoop/HadoopClassLoader.java | 2 +- .../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 | 6 +- .../hadoop/v1/HadoopV1ReduceTask.java | 5 +- .../processors/hadoop/v2/HadoopV2Job.java | 2 +- .../hadoop/v2/HadoopV2ReduceTask.java | 5 +- .../HadoopIgfs20FileSystemAbstractSelfTest.java | 4 +- .../igfs/IgfsNearOnlyMultiNodeSelfTest.java | 12 +- .../IgniteHadoopFileSystemAbstractSelfTest.java | 2 +- .../hadoop/HadoopCommandLineTest.java | 2 +- .../processors/hadoop/HadoopMapReduceTest.java | 24 +- .../processors/hadoop/HadoopSharedMap.java | 2 +- .../taskexecutor/HadoopExecutorServiceTest.java | 7 +- modules/hibernate/README.txt | 33 + modules/hibernate/readme.txt | 33 - .../cache/hibernate/HibernateRegionFactory.java | 15 +- .../hibernate/CacheHibernateBlobStore.java | 6 +- modules/indexing/README.txt | 33 + modules/indexing/readme.txt | 33 - .../processors/query/h2/IgniteH2Indexing.java | 34 +- .../processors/query/h2/opt/GridH2Table.java | 2 +- .../query/h2/opt/GridLuceneIndex.java | 8 +- .../query/h2/sql/GridSqlQueryParser.java | 4 +- .../query/h2/twostep/GridMapQueryExecutor.java | 2 +- .../query/h2/twostep/GridMergeIndex.java | 2 +- .../h2/twostep/GridReduceQueryExecutor.java | 15 +- .../cache/GridCacheCrossCacheQuerySelfTest.java | 6 +- .../cache/GridCacheOffHeapAndSwapSelfTest.java | 66 +- .../GridCacheQueryIndexDisabledSelfTest.java | 16 +- .../cache/GridCacheQuerySimpleBenchmark.java | 9 +- .../processors/cache/GridCacheSwapSelfTest.java | 2 +- .../IgniteCacheAbstractFieldsQuerySelfTest.java | 36 +- .../cache/IgniteCacheAbstractQuerySelfTest.java | 89 +- ...gniteCacheSqlQueryMultiThreadedSelfTest.java | 4 +- .../IgniteCacheAtomicFieldsQuerySelfTest.java | 2 +- .../IgniteCachePartitionedQuerySelfTest.java | 8 +- ...gniteCacheReplicatedFieldsQuerySelfTest.java | 2 +- .../IgniteCacheReplicatedQuerySelfTest.java | 16 +- .../local/IgniteCacheLocalQuerySelfTest.java | 7 +- modules/jcl/README.txt | 33 + modules/jcl/readme.txt | 33 - modules/jta/README.txt | 32 + modules/jta/readme.txt | 32 - 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 +- modules/schedule/README.txt | 32 + modules/schedule/readme.txt | 32 - .../processors/schedule/ScheduleFutureImpl.java | 11 - modules/schema-import/README.txt | 214 + modules/schema-import/pom.xml | 11 +- modules/schema-import/readme.txt | 214 - .../ignite/schema/generator/CodeGenerator.java | 556 +++ .../ignite/schema/generator/PojoGenerator.java | 414 -- .../schema/generator/SnippetGenerator.java | 144 - .../ignite/schema/generator/XmlGenerator.java | 14 +- .../org/apache/ignite/schema/ui/MessageBox.java | 2 +- .../ignite/schema/ui/SchemaImportApp.java | 90 +- .../schema/test/AbstractSchemaImportTest.java | 19 +- .../test/generator/CodeGeneratorTest.java | 70 + .../test/generator/PojoGeneratorTest.java | 70 - .../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 | 60 +- .../apache/ignite/cache/spring/SpringCache.java | 142 +- .../ignite/cache/spring/SpringCacheManager.java | 105 +- .../cache/spring/SpringDynamicCacheManager.java | 339 -- .../spring/IgniteSpringProcessorImpl.java | 100 +- .../ignite/internal/GridFactorySelfTest.java | 40 + .../internal/IgniteDynamicCacheConfigTest.java | 242 ++ .../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 + .../spring/GridSpringCacheManagerSelfTest.java | 107 +- .../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 - modules/urideploy/README.txt | 33 + modules/urideploy/readme.txt | 33 - .../licenses/jcraft-revised-bsd.txt | 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 + .../cache/IgniteSqlQueryJoinBenchmark.java | 2 +- pom.xml | 36 +- 626 files changed, 22010 insertions(+), 18031 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/22d766ef/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheClientModesAbstractSelfTest.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/22d766ef/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/22d766ef/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheSwapSelfTest.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/22d766ef/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractQuerySelfTest.java ----------------------------------------------------------------------
