# IGNITE-223 Merge commit.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/831f4efc Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/831f4efc Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/831f4efc Branch: refs/heads/ignite-223 Commit: 831f4efc0797c91d702f0c297debbc75696d8a5d Parents: 76b3c47 81cce4c Author: sevdokimov <sevdoki...@gridgain.com> Authored: Wed Feb 18 13:36:49 2015 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Wed Feb 18 13:36:49 2015 +0300 ---------------------------------------------------------------------- assembly/core-jar.xml | 49 - assembly/dependencies-fabric.xml | 53 +- assembly/dependencies-hadoop.xml | 42 +- assembly/dependencies-optional-fabric.xml | 2 +- assembly/dependencies-optional-hadoop.xml | 3 +- assembly/dependencies-schema-load.xml | 2 +- assembly/dependencies-visor-trial.xml | 80 - assembly/docfiles/tools.js | 30 - assembly/release-base-fabric.xml | 83 - assembly/release-base.xml | 2 + assembly/release-fabric.xml | 59 +- assembly/release-scala.xml | 50 + bin/include/target-classpath.bat | 4 +- bin/include/target-classpath.sh | 10 +- config/fabric/default-config.xml | 6 +- config/hadoop/default-config.xml | 36 +- config/ignite-log4j.xml | 2 +- config/router/default-router.xml | 2 +- docs/core-site.ignite.xml | 26 +- docs/hadoop_readme.md | 8 +- docs/ignite_readme.md | 12 +- docs/ignite_readme.pdf | Bin 76810 -> 77136 bytes docs/release_notes.md | 16 + docs/release_notes.pdf | Bin 59911 -> 33174 bytes examples/config/example-cache.xml | 12 +- examples/config/filesystem/core-site.xml | 14 +- examples/config/filesystem/example-igfs.xml | 165 + examples/config/filesystem/example-ignitefs.xml | 165 - examples/config/filesystem/readme.txt | 2 +- examples/pom-standalone.xml | 115 +- examples/pom.xml | 83 +- .../apache/ignite/examples/ExamplesUtils.java | 2 +- .../computegrid/ComputeBroadcastExample.java | 2 +- .../ComputeClusterGroupsExample.java | 93 + .../computegrid/ComputeProjectionExample.java | 93 - .../examples/datagrid/CacheAffinityExample.java | 4 +- .../datagrid/CacheContinuousQueryExample.java | 69 +- .../datagrid/CacheDataLoaderExample.java | 3 +- .../datagrid/CachePopularNumbersExample.java | 31 +- .../examples/datagrid/CacheQueryExample.java | 232 +- .../datagrid/CacheTransactionExample.java | 6 +- .../HibernateL2CacheExampleNodeStartup.java | 3 +- .../starschema/CacheStarSchemaExample.java | 52 +- .../datagrid/starschema/DimProduct.java | 6 +- .../examples/datagrid/starschema/DimStore.java | 6 +- .../datagrid/starschema/FactPurchase.java | 10 +- .../datagrid/store/CacheStoreExample.java | 2 +- .../store/dummy/CacheDummyPersonStore.java | 19 +- .../hibernate/CacheHibernatePersonStore.java | 36 +- .../store/jdbc/CacheJdbcPersonStore.java | 25 +- .../IgniteAtomicSequenceExample.java | 35 +- .../datastructures/IgniteQueueExample.java | 4 +- .../ignite/examples/igfs/IgfsExample.java | 278 ++ .../examples/igfs/IgfsMapReduceExample.java | 249 ++ .../ignite/examples/igfs/IgfsNodeStartup.java | 41 + .../apache/ignite/examples/igfs/package.html | 24 + .../examples/ignitefs/IgniteFsExample.java | 278 -- .../ignitefs/IgniteFsMapReduceExample.java | 249 -- .../examples/ignitefs/IgniteFsNodeStartup.java | 41 - .../ignite/examples/ignitefs/package.html | 24 - .../examples/messaging/MessagingExample.java | 14 +- .../client/memcache/MemcacheRestExample.java | 3 +- .../MemcacheRestExampleNodeStartup.java | 4 +- .../ignite/examples/MessagingExample.java | 6 +- .../examples/ScalarCacheAffinityExample1.scala | 8 +- .../examples/ScalarCacheAffinityExample2.scala | 4 +- .../ScalarCacheAffinitySimpleExample.scala | 10 +- .../scalar/examples/ScalarCacheExample.scala | 50 +- .../ScalarCachePopularNumbersExample.scala | 13 +- .../examples/ScalarCacheQueryExample.scala | 48 +- .../scalar/examples/ScalarClosureExample.scala | 4 +- .../examples/ScalarContinuationExample.scala | 4 +- .../examples/ScalarSnowflakeSchemaExample.scala | 37 +- .../ComputeClusterGroupsExampleSelfTest.java | 39 + .../ignite/examples/IgfsExamplesSelfTest.java | 51 + .../examples/IgniteFsExamplesSelfTest.java | 51 - .../examples/ProjectionExampleSelfTest.java | 39 - .../testsuites/IgniteExamplesSelfTestSuite.java | 4 +- .../config/grid-client-spring-config.xml | 6 +- .../ClientAbstractMultiThreadedSelfTest.java | 615 --- .../client/ClientDefaultCacheSelfTest.java | 220 - .../ignite/client/ClientGetAffinityTask.java | 64 - .../apache/ignite/client/ClientHttpTask.java | 58 - .../apache/ignite/client/ClientNodeStartup.java | 57 - .../client/ClientReconnectionSelfTest.java | 235 -- .../ignite/client/ClientSslNodeStartup.java | 59 - .../ignite/client/ClientStartNodeTask.java | 179 - .../ignite/client/ClientStopNodeTask.java | 127 - .../ignite/client/ClientStringLengthTask.java | 71 - .../client/ClientTcpMultiThreadedSelfTest.java | 45 - .../ClientTcpSslAuthenticationSelfTest.java | 265 -- .../ClientTcpSslMultiThreadedSelfTest.java | 46 - .../org/apache/ignite/client/ClientTcpTask.java | 71 - ...skExecutionAfterTopologyRestartSelfTest.java | 75 - .../ignite/client/ClientTestRestServer.java | 281 -- .../client/ClientTopologyCacheSelfTest.java | 288 -- .../org/apache/ignite/client/HashMapStore.java | 53 - .../org/apache/ignite/client/SleepTestTask.java | 66 - .../client/TaskSingleJobSplitAdapter.java | 70 - .../client/impl/ClientCacheFlagsCodecTest.java | 83 - .../client/impl/ClientComputeImplSelfTest.java | 167 - .../client/impl/ClientDataImplSelfTest.java | 268 -- .../impl/ClientFutureAdapterSelfTest.java | 115 - .../impl/ClientPartitionAffinitySelfTest.java | 406 -- .../ClientPropertiesConfigurationSelfTest.java | 232 -- .../ClientAbstractConnectivitySelfTest.java | 303 -- .../ClientAbstractMultiNodeSelfTest.java | 834 ---- .../integration/ClientAbstractSelfTest.java | 1601 -------- .../integration/ClientPreferDirectSelfTest.java | 192 - .../ClientTcpConnectivitySelfTest.java | 75 - .../ClientTcpDirectMultiNodeSelfTest.java | 55 - .../integration/ClientTcpDirectSelfTest.java | 58 - .../integration/ClientTcpMultiNodeSelfTest.java | 35 - .../client/integration/ClientTcpSelfTest.java | 46 - .../ClientTcpSslDirectMultiNodeSelfTest.java | 62 - .../integration/ClientTcpSslDirectSelfTest.java | 59 - .../ClientTcpSslMultiNodeSelfTest.java | 42 - .../integration/ClientTcpSslSelfTest.java | 47 - .../ClientTcpUnreachableMultiNodeSelfTest.java | 134 - .../ignite/client/integration/package.html | 24 - .../client/router/ClientFailedInitSelfTest.java | 275 -- .../client/router/RouterFactorySelfTest.java | 107 - .../router/TcpRouterAbstractSelfTest.java | 125 - .../router/TcpRouterMultiNodeSelfTest.java | 110 - .../ignite/client/router/TcpRouterSelfTest.java | 35 - .../client/router/TcpSslRouterSelfTest.java | 48 - .../apache/ignite/client/router/package.html | 24 - .../testsuites/IgniteRouterTestSuite.java | 41 - .../client/suite/IgniteClientTestSuite.java | 118 - .../ignite/client/util/ClientByteUtilsTest.java | 172 - .../util/ClientConsistentHashSelfTest.java | 281 -- .../client/util/ClientJavaHasherSelfTest.java | 84 - .../internal/TaskEventSubjectIdSelfTest.java | 4 +- .../ClientAbstractMultiThreadedSelfTest.java | 598 +++ .../client/ClientDefaultCacheSelfTest.java | 220 + .../internal/client/ClientGetAffinityTask.java | 64 + .../ignite/internal/client/ClientHttpTask.java | 58 + .../internal/client/ClientNodeStartup.java | 57 + .../client/ClientReconnectionSelfTest.java | 233 ++ .../internal/client/ClientSslNodeStartup.java | 59 + .../internal/client/ClientStartNodeTask.java | 179 + .../internal/client/ClientStopNodeTask.java | 127 + .../internal/client/ClientStringLengthTask.java | 71 + .../client/ClientTcpMultiThreadedSelfTest.java | 45 + .../ClientTcpSslAuthenticationSelfTest.java | 265 ++ .../ClientTcpSslMultiThreadedSelfTest.java | 46 + .../ignite/internal/client/ClientTcpTask.java | 71 + ...skExecutionAfterTopologyRestartSelfTest.java | 75 + .../internal/client/ClientTestRestServer.java | 281 ++ .../client/ClientTopologyCacheSelfTest.java | 288 ++ .../ignite/internal/client/HashMapStore.java | 53 + .../ignite/internal/client/SleepTestTask.java | 66 + .../client/TaskSingleJobSplitAdapter.java | 70 + .../client/impl/ClientCacheFlagsCodecTest.java | 83 + .../client/impl/ClientComputeImplSelfTest.java | 167 + .../client/impl/ClientDataImplSelfTest.java | 268 ++ .../impl/ClientFutureAdapterSelfTest.java | 115 + .../impl/ClientPartitionAffinitySelfTest.java | 406 ++ .../ClientPropertiesConfigurationSelfTest.java | 232 ++ .../ClientAbstractConnectivitySelfTest.java | 303 ++ .../ClientAbstractMultiNodeSelfTest.java | 828 ++++ .../integration/ClientAbstractSelfTest.java | 1483 +++++++ .../integration/ClientPreferDirectSelfTest.java | 192 + .../ClientTcpConnectivitySelfTest.java | 75 + .../ClientTcpDirectMultiNodeSelfTest.java | 55 + .../integration/ClientTcpDirectSelfTest.java | 58 + .../integration/ClientTcpMultiNodeSelfTest.java | 35 + .../client/integration/ClientTcpSelfTest.java | 46 + .../ClientTcpSslDirectMultiNodeSelfTest.java | 62 + .../integration/ClientTcpSslDirectSelfTest.java | 59 + .../ClientTcpSslMultiNodeSelfTest.java | 42 + .../integration/ClientTcpSslSelfTest.java | 47 + .../ClientTcpUnreachableMultiNodeSelfTest.java | 134 + .../client/router/ClientFailedInitSelfTest.java | 275 ++ .../client/router/RouterFactorySelfTest.java | 107 + .../router/TcpRouterAbstractSelfTest.java | 125 + .../router/TcpRouterMultiNodeSelfTest.java | 110 + .../client/router/TcpRouterSelfTest.java | 35 + .../client/router/TcpSslRouterSelfTest.java | 48 + .../client/suite/IgniteClientTestSuite.java | 118 + .../client/util/ClientByteUtilsTest.java | 172 + .../util/ClientConsistentHashSelfTest.java | 281 ++ .../client/util/ClientJavaHasherSelfTest.java | 84 + .../rest/AbstractRestProcessorSelfTest.java | 9 +- .../rest/ClientMemcachedProtocolSelfTest.java | 4 +- .../rest/JettyRestProcessorSignedSelfTest.java | 4 +- .../rest/RestBinaryProtocolSelfTest.java | 265 +- .../rest/RestMemcacheProtocolSelfTest.java | 88 +- .../rest/RestProcessorMultiStartSelfTest.java | 2 +- .../rest/RestProcessorStartSelfTest.java | 10 +- .../processors/rest/RestProcessorTest.java | 10 +- .../rest/TaskCommandHandlerSelfTest.java | 12 +- .../processors/rest/TestBinaryClient.java | 23 +- .../protocols/tcp/TcpRestParserSelfTest.java | 4 +- .../ignite/jdbc/JdbcComplexQuerySelfTest.java | 22 +- .../ignite/jdbc/JdbcConnectionSelfTest.java | 8 +- .../ignite/jdbc/JdbcEmptyCacheSelfTest.java | 2 +- .../ignite/jdbc/JdbcLocalCachesSelfTest.java | 16 +- .../ignite/jdbc/JdbcMetadataSelfTest.java | 20 +- .../jdbc/JdbcPreparedStatementSelfTest.java | 38 +- .../ignite/jdbc/JdbcResultSetSelfTest.java | 44 +- .../ignite/jdbc/JdbcStatementSelfTest.java | 16 +- .../loadtests/client/ClientCacheBenchmark.java | 2 +- .../client/ClientMarshallerBenchmarkTest.java | 6 +- .../loadtests/client/ClientTcpSslLoadTest.java | 8 +- modules/clients/src/test/keystore/generate.sh | 25 +- .../clients/src/test/resources/spring-cache.xml | 19 +- .../src/test/resources/spring-router-ssl.xml | 4 +- .../src/test/resources/spring-router.xml | 2 +- .../src/test/resources/spring-server-node.xml | 152 +- .../test/resources/spring-server-ssl-node.xml | 158 +- .../CommunicationMessageCodeGenerator.java | 212 +- modules/core/licenses/sun-bcl-license.txt | 50 + modules/core/pom.xml | 87 +- .../src/main/java/org/apache/ignite/Ignite.java | 55 +- .../java/org/apache/ignite/IgniteCache.java | 123 +- .../org/apache/ignite/IgniteCountDownLatch.java | 2 - .../org/apache/ignite/IgniteDataLoader.java | 22 +- .../main/java/org/apache/ignite/IgniteFs.java | 106 +- .../java/org/apache/ignite/IgniteServices.java | 2 +- .../apache/ignite/IgniteSystemProperties.java | 120 - .../org/apache/ignite/IgniteTransactions.java | 89 +- .../main/java/org/apache/ignite/Ignition.java | 6 - .../apache/ignite/cache/CacheAtomicityMode.java | 2 +- .../org/apache/ignite/cache/CacheEntry.java | 623 --- .../apache/ignite/cache/CacheInterceptor.java | 1 + .../org/apache/ignite/cache/CacheManager.java | 51 +- .../java/org/apache/ignite/cache/CacheName.java | 41 - .../apache/ignite/cache/CacheProjection.java | 1987 --------- .../ignite/cache/CacheTypeFieldMetadata.java | 2 +- .../cache/CacheWriteSynchronizationMode.java | 4 +- .../java/org/apache/ignite/cache/GridCache.java | 14 +- .../ignite/cache/cloner/CacheBasicCloner.java | 34 - .../apache/ignite/cache/cloner/CacheCloner.java | 57 - .../ignite/cache/cloner/CacheDeepCloner.java | 87 - .../org/apache/ignite/cache/cloner/package.html | 24 - .../cache/eviction/CacheEvictionFilter.java | 8 +- .../cache/eviction/CacheEvictionPolicy.java | 10 +- .../ignite/cache/eviction/EvictableEntry.java | 67 +- .../eviction/fifo/CacheFifoEvictionPolicy.java | 48 +- .../fifo/CacheFifoEvictionPolicyMBean.java | 8 - .../eviction/igfs/CacheIgfsEvictionFilter.java | 35 + .../CacheIgfsPerBlockLruEvictionPolicy.java | 358 ++ ...acheIgfsPerBlockLruEvictionPolicyMXBean.java | 93 + .../ignite/cache/eviction/igfs/package.html | 24 + .../ignitefs/CacheIgniteFsEvictionFilter.java | 34 - .../CacheIgniteFsPerBlockLruEvictionPolicy.java | 353 -- ...IgniteFsPerBlockLruEvictionPolicyMXBean.java | 93 - .../ignite/cache/eviction/ignitefs/package.html | 24 - .../eviction/lru/CacheLruEvictionPolicy.java | 32 +- .../lru/CacheLruEvictionPolicyMBean.java | 8 - .../random/CacheRandomEvictionPolicy.java | 33 +- .../cache/query/CacheContinuousQuery.java | 284 -- .../cache/query/CacheContinuousQueryEntry.java | 49 - .../apache/ignite/cache/query/CacheQueries.java | 152 - .../apache/ignite/cache/query/CacheQuery.java | 294 -- .../cache/query/CacheQueryConfiguration.java | 180 - .../ignite/cache/query/CacheQueryFuture.java | 66 - .../cache/query/CacheQueryGroupIndex.java | 49 - .../ignite/cache/query/CacheQueryMetrics.java | 60 - .../ignite/cache/query/CacheQuerySqlField.java | 123 - .../cache/query/CacheQuerySqlFunction.java | 67 - .../ignite/cache/query/CacheQueryTextField.java | 33 - .../ignite/cache/query/CacheQueryType.java | 47 - .../cache/query/CacheQueryTypeResolver.java | 32 - .../ignite/cache/query/ContinuousQuery.java | 314 ++ .../org/apache/ignite/cache/query/Query.java | 143 + .../cache/query/QueryAffinityPredicate.java | 135 - .../cache/query/QueryContinuousPredicate.java | 215 - .../apache/ignite/cache/query/QueryCursor.java | 22 +- .../apache/ignite/cache/query/QueryMetrics.java | 62 + .../ignite/cache/query/QueryPredicate.java | 76 - .../apache/ignite/cache/query/QueryReducer.java | 30 - .../ignite/cache/query/QuerySqlPredicate.java | 118 - .../ignite/cache/query/QueryTextPredicate.java | 90 - .../ignite/cache/query/QueryTypeResolver.java | 32 + .../apache/ignite/cache/query/ScanQuery.java | 76 + .../org/apache/ignite/cache/query/SpiQuery.java | 64 + .../ignite/cache/query/SqlFieldsQuery.java | 98 + .../org/apache/ignite/cache/query/SqlQuery.java | 142 + .../apache/ignite/cache/query/TextQuery.java | 119 + .../cache/query/annotations/QuerySqlField.java | 8 +- .../query/annotations/QuerySqlFunction.java | 4 +- .../cache/query/annotations/QueryTextField.java | 8 +- .../cache/store/CacheLoadOnlyStoreAdapter.java | 2 +- .../apache/ignite/cache/store/CacheStore.java | 35 +- .../ignite/cache/store/CacheStoreAdapter.java | 2 +- .../ignite/cache/store/CacheStoreSession.java | 22 +- .../store/jdbc/CacheAbstractJdbcStore.java | 127 +- .../cache/store/jdbc/CacheJdbcBlobStore.java | 25 +- .../cache/store/jdbc/CacheJdbcPojoStore.java | 8 +- .../org/apache/ignite/client/GridClient.java | 148 - .../GridClientAuthenticationException.java | 35 - .../ignite/client/GridClientCacheFlag.java | 65 - .../ignite/client/GridClientCacheMode.java | 32 - .../client/GridClientClosedException.java | 35 - .../apache/ignite/client/GridClientCompute.java | 476 --- .../ignite/client/GridClientConfiguration.java | 845 ---- .../apache/ignite/client/GridClientData.java | 443 -- .../ignite/client/GridClientDataAffinity.java | 39 - .../client/GridClientDataConfiguration.java | 118 - .../ignite/client/GridClientDataMetrics.java | 77 - .../client/GridClientDisconnectedException.java | 36 - .../ignite/client/GridClientException.java | 111 - .../apache/ignite/client/GridClientFactory.java | 138 - .../apache/ignite/client/GridClientFuture.java | 68 - .../ignite/client/GridClientFutureListener.java | 30 - .../GridClientFutureTimeoutException.java | 45 - .../client/GridClientHandshakeException.java | 48 - .../apache/ignite/client/GridClientNode.java | 128 - .../ignite/client/GridClientNodeMetrics.java | 524 --- .../client/GridClientPartitionAffinity.java | 369 -- .../ignite/client/GridClientPredicate.java | 38 - .../ignite/client/GridClientProtocol.java | 26 - .../client/GridClientTopologyListener.java | 41 - .../client/GridServerUnreachableException.java | 45 - .../balancer/GridClientBalancerAdapter.java | 76 - .../client/balancer/GridClientLoadBalancer.java | 44 - .../balancer/GridClientRandomBalancer.java | 75 - .../balancer/GridClientRoundRobinBalancer.java | 111 - .../apache/ignite/client/balancer/package.html | 24 - .../impl/GridClientAbstractProjection.java | 458 --- .../client/impl/GridClientAndPredicate.java | 52 - .../client/impl/GridClientComputeImpl.java | 293 -- .../ignite/client/impl/GridClientDataImpl.java | 389 -- .../impl/GridClientDataMetricsAdapter.java | 160 - .../client/impl/GridClientFutureAdapter.java | 349 -- .../client/impl/GridClientFutureCallback.java | 35 - .../ignite/client/impl/GridClientImpl.java | 527 --- .../ignite/client/impl/GridClientNodeImpl.java | 396 -- .../impl/GridClientNodeMetricsAdapter.java | 990 ----- .../client/impl/GridClientThreadFactory.java | 62 - .../impl/connection/GridClientConnection.java | 531 --- .../GridClientConnectionCloseReason.java | 32 - .../connection/GridClientConnectionManager.java | 71 - .../GridClientConnectionManagerAdapter.java | 644 --- .../GridClientConnectionManagerOsImpl.java | 48 - .../GridClientConnectionResetException.java | 48 - .../connection/GridClientNioTcpConnection.java | 1075 ----- .../impl/connection/GridClientTopology.java | 450 --- .../GridConnectionIdleClosedException.java | 36 - .../org/apache/ignite/client/impl/package.html | 24 - .../client/marshaller/GridClientMarshaller.java | 45 - .../marshaller/jdk/GridClientJdkMarshaller.java | 68 - .../ignite/client/marshaller/jdk/package.html | 24 - .../GridClientOptimizedMarshaller.java | 103 - .../client/marshaller/optimized/package.html | 24 - .../ignite/client/marshaller/package.html | 24 - .../java/org/apache/ignite/client/package.html | 24 - .../ignite/client/router/GridRouterFactory.java | 126 - .../ignite/client/router/GridTcpRouter.java | 76 - .../router/GridTcpRouterConfiguration.java | 306 -- .../client/router/GridTcpRouterMBean.java | 88 - .../router/impl/GridRouterClientImpl.java | 200 - .../impl/GridRouterCommandLineStartup.java | 169 - .../client/router/impl/GridTcpRouterImpl.java | 348 -- .../impl/GridTcpRouterNioListenerAdapter.java | 203 - .../impl/GridTcpRouterNioListenerOsImpl.java | 38 - .../router/impl/GridTcpRouterNioParser.java | 115 - .../ignite/client/router/impl/package.html | 24 - .../apache/ignite/client/router/package.html | 24 - .../client/ssl/GridSslBasicContextFactory.java | 438 -- .../client/ssl/GridSslContextFactory.java | 36 - .../org/apache/ignite/client/ssl/package.html | 24 - .../client/util/GridClientConsistentHash.java | 440 -- .../client/util/GridClientStripedLock.java | 135 - .../ignite/client/util/GridClientUtils.java | 171 - .../client/util/GridConcurrentHashSet.java | 113 - .../org/apache/ignite/client/util/package.html | 24 - .../apache/ignite/cluster/ClusterMetrics.java | 41 + .../ignite/compute/ComputeJobContext.java | 20 - .../org/apache/ignite/compute/ComputeTask.java | 3 +- .../configuration/AtomicConfiguration.java | 2 +- .../configuration/CacheConfiguration.java | 71 +- .../configuration/CacheQueryConfiguration.java | 182 + .../ClientConnectionConfiguration.java | 541 --- .../configuration/ClientMessageInterceptor.java | 45 - .../configuration/ConnectorConfiguration.java | 518 +++ .../ConnectorMessageInterceptor.java | 45 + .../ignite/configuration/IgfsConfiguration.java | 807 ++++ .../configuration/IgniteConfiguration.java | 1087 +---- .../configuration/IgniteFsConfiguration.java | 807 ---- .../configuration/QueryConfiguration.java | 3 +- .../configuration/TransactionConfiguration.java | 22 +- .../ignite/events/AuthenticationEvent.java | 172 - .../ignite/events/AuthorizationEvent.java | 146 - .../org/apache/ignite/events/CacheEvent.java | 2 +- .../ignite/events/CacheQueryExecutedEvent.java | 9 +- .../ignite/events/CacheQueryReadEvent.java | 9 +- .../apache/ignite/events/CheckpointEvent.java | 2 +- .../apache/ignite/events/DeploymentEvent.java | 2 +- .../org/apache/ignite/events/EventType.java | 293 +- .../org/apache/ignite/events/IgfsEvent.java | 197 + .../org/apache/ignite/events/IgniteFsEvent.java | 197 - .../java/org/apache/ignite/events/JobEvent.java | 2 +- .../org/apache/ignite/events/LicenseEvent.java | 116 - .../ignite/events/SecureSessionEvent.java | 154 - .../main/java/org/apache/ignite/igfs/Igfs.java | 216 + .../apache/ignite/igfs/IgfsBlockLocation.java | 63 + .../IgfsConcurrentModificationException.java | 36 + .../ignite/igfs/IgfsCorruptedFileException.java | 50 + .../org/apache/ignite/igfs/IgfsException.java | 57 + .../java/org/apache/ignite/igfs/IgfsFile.java | 120 + .../ignite/igfs/IgfsFileNotFoundException.java | 44 + .../igfs/IgfsGroupDataBlocksKeyMapper.java | 101 + .../org/apache/ignite/igfs/IgfsInputStream.java | 80 + .../igfs/IgfsInvalidHdfsVersionException.java | 42 + .../ignite/igfs/IgfsInvalidPathException.java | 57 + .../org/apache/ignite/igfs/IgfsMetrics.java | 159 + .../java/org/apache/ignite/igfs/IgfsMode.java | 80 + .../ignite/igfs/IgfsOutOfSpaceException.java | 58 + .../apache/ignite/igfs/IgfsOutputStream.java | 35 + .../igfs/IgfsParentNotDirectoryException.java | 50 + .../java/org/apache/ignite/igfs/IgfsPath.java | 262 ++ .../igfs/IgfsPathAlreadyExistsException.java | 50 + .../org/apache/ignite/igfs/IgfsPathSummary.java | 138 + .../java/org/apache/ignite/igfs/IgfsReader.java | 38 + .../ignite/igfs/mapreduce/IgfsFileRange.java | 80 + .../mapreduce/IgfsInputStreamJobAdapter.java | 52 + .../apache/ignite/igfs/mapreduce/IgfsJob.java | 69 + .../ignite/igfs/mapreduce/IgfsJobAdapter.java | 28 + .../igfs/mapreduce/IgfsRangeInputStream.java | 197 + .../igfs/mapreduce/IgfsRecordResolver.java | 56 + .../apache/ignite/igfs/mapreduce/IgfsTask.java | 172 + .../ignite/igfs/mapreduce/IgfsTaskArgs.java | 82 + .../igfs/mapreduce/IgfsTaskNoReduceAdapter.java | 42 + .../apache/ignite/igfs/mapreduce/package.html | 24 + .../IgfsByteDelimiterRecordResolver.java | 347 ++ .../records/IgfsFixedLengthRecordResolver.java | 86 + .../records/IgfsNewLineRecordResolver.java | 66 + .../IgfsStringDelimiterRecordResolver.java | 84 + .../ignite/igfs/mapreduce/records/package.html | 24 + .../java/org/apache/ignite/igfs/package.html | 24 + .../ignite/ignitefs/IgniteFsBlockLocation.java | 63 - ...IgniteFsConcurrentModificationException.java | 36 - .../IgniteFsCorruptedFileException.java | 50 - .../ignite/ignitefs/IgniteFsException.java | 57 - .../apache/ignite/ignitefs/IgniteFsFile.java | 120 - .../ignitefs/IgniteFsFileNotFoundException.java | 44 - .../ignite/ignitefs/IgniteFsFileSystem.java | 216 - .../IgniteFsGroupDataBlocksKeyMapper.java | 101 - .../ignite/ignitefs/IgniteFsInputStream.java | 80 - .../IgniteFsInvalidHdfsVersionException.java | 42 - .../ignitefs/IgniteFsInvalidPathException.java | 57 - .../apache/ignite/ignitefs/IgniteFsMetrics.java | 159 - .../apache/ignite/ignitefs/IgniteFsMode.java | 80 - .../ignitefs/IgniteFsOutOfSpaceException.java | 58 - .../ignite/ignitefs/IgniteFsOutputStream.java | 35 - .../IgniteFsParentNotDirectoryException.java | 50 - .../apache/ignite/ignitefs/IgniteFsPath.java | 262 -- .../IgniteFsPathAlreadyExistsException.java | 50 - .../ignite/ignitefs/IgniteFsPathSummary.java | 138 - .../apache/ignite/ignitefs/IgniteFsReader.java | 38 - .../ignitefs/mapreduce/IgniteFsFileRange.java | 80 - .../IgniteFsInputStreamJobAdapter.java | 52 - .../ignite/ignitefs/mapreduce/IgniteFsJob.java | 69 - .../ignitefs/mapreduce/IgniteFsJobAdapter.java | 28 - .../mapreduce/IgniteFsRangeInputStream.java | 197 - .../mapreduce/IgniteFsRecordResolver.java | 56 - .../ignite/ignitefs/mapreduce/IgniteFsTask.java | 172 - .../ignitefs/mapreduce/IgniteFsTaskArgs.java | 82 - .../mapreduce/IgniteFsTaskNoReduceAdapter.java | 42 - .../ignite/ignitefs/mapreduce/package.html | 24 - .../IgniteFsByteDelimiterRecordResolver.java | 347 -- .../IgniteFsFixedLengthRecordResolver.java | 86 - .../records/IgniteFsNewLineRecordResolver.java | 66 - .../IgniteFsStringDelimiterRecordResolver.java | 84 - .../ignitefs/mapreduce/records/package.html | 24 - .../org/apache/ignite/ignitefs/package.html | 24 - .../ClusterLocalNodeMetricsMXBeanImpl.java | 10 + .../ignite/internal/ClusterMetricsSnapshot.java | 131 +- .../ignite/internal/GridJobCancelRequest.java | 43 +- .../ignite/internal/GridJobContextImpl.java | 23 - .../ignite/internal/GridJobExecuteRequest.java | 154 +- .../ignite/internal/GridJobExecuteResponse.java | 67 +- .../ignite/internal/GridJobSiblingsRequest.java | 39 +- .../internal/GridJobSiblingsResponse.java | 34 +- .../ignite/internal/GridKernalContext.java | 68 +- .../ignite/internal/GridKernalContextImpl.java | 117 +- .../ignite/internal/GridKernalGateway.java | 7 + .../ignite/internal/GridKernalGatewayImpl.java | 16 + .../apache/ignite/internal/GridProductImpl.java | 191 - .../apache/ignite/internal/GridProperties.java | 2 +- .../ignite/internal/GridTaskCancelRequest.java | 33 +- .../ignite/internal/GridTaskSessionRequest.java | 44 +- .../org/apache/ignite/internal/GridTopic.java | 2 +- .../ignite/internal/GridUpdateNotifier.java | 15 - .../ignite/internal/IgniteComponentType.java | 23 +- .../org/apache/ignite/internal/IgniteEx.java | 30 +- .../apache/ignite/internal/IgniteKernal.java | 622 +-- .../ignite/internal/IgniteNodeAttributes.java | 2 +- .../ignite/internal/IgniteTransactionsEx.java | 45 +- .../ignite/internal/IgniteVersionUtils.java | 78 + .../org/apache/ignite/internal/IgnitionEx.java | 120 +- .../ignite/internal/client/GridClient.java | 146 + .../GridClientAuthenticationException.java | 35 + .../internal/client/GridClientCacheFlag.java | 65 + .../internal/client/GridClientCacheMode.java | 32 + .../client/GridClientClosedException.java | 35 + .../internal/client/GridClientCompute.java | 419 ++ .../client/GridClientConfiguration.java | 844 ++++ .../ignite/internal/client/GridClientData.java | 443 ++ .../internal/client/GridClientDataAffinity.java | 39 + .../client/GridClientDataConfiguration.java | 118 + .../internal/client/GridClientDataMetrics.java | 77 + .../client/GridClientDisconnectedException.java | 36 + .../internal/client/GridClientException.java | 111 + .../internal/client/GridClientFactory.java | 138 + .../internal/client/GridClientFuture.java | 68 + .../client/GridClientFutureListener.java | 30 + .../GridClientFutureTimeoutException.java | 45 + .../client/GridClientHandshakeException.java | 48 + .../ignite/internal/client/GridClientNode.java | 128 + .../internal/client/GridClientNodeMetrics.java | 524 +++ .../client/GridClientPartitionAffinity.java | 369 ++ .../internal/client/GridClientPredicate.java | 38 + .../internal/client/GridClientProtocol.java | 26 + .../client/GridClientTopologyListener.java | 41 + .../client/GridServerUnreachableException.java | 45 + .../balancer/GridClientBalancerAdapter.java | 76 + .../client/balancer/GridClientLoadBalancer.java | 44 + .../balancer/GridClientRandomBalancer.java | 75 + .../balancer/GridClientRoundRobinBalancer.java | 111 + .../impl/GridClientAbstractProjection.java | 458 +++ .../client/impl/GridClientAndPredicate.java | 52 + .../client/impl/GridClientComputeImpl.java | 263 ++ .../client/impl/GridClientDataImpl.java | 389 ++ .../impl/GridClientDataMetricsAdapter.java | 160 + .../client/impl/GridClientFutureAdapter.java | 349 ++ .../client/impl/GridClientFutureCallback.java | 35 + .../internal/client/impl/GridClientImpl.java | 527 +++ .../client/impl/GridClientNodeImpl.java | 396 ++ .../impl/GridClientNodeMetricsAdapter.java | 990 +++++ .../client/impl/GridClientThreadFactory.java | 62 + .../impl/connection/GridClientConnection.java | 515 +++ .../GridClientConnectionCloseReason.java | 32 + .../connection/GridClientConnectionManager.java | 71 + .../GridClientConnectionManagerAdapter.java | 644 +++ .../GridClientConnectionManagerOsImpl.java | 48 + .../GridClientConnectionResetException.java | 48 + .../connection/GridClientNioTcpConnection.java | 1063 +++++ .../impl/connection/GridClientTopology.java | 450 +++ .../GridConnectionIdleClosedException.java | 36 + .../client/marshaller/GridClientMarshaller.java | 45 + .../marshaller/jdk/GridClientJdkMarshaller.java | 68 + .../GridClientOptimizedMarshaller.java | 103 + .../client/router/GridRouterFactory.java | 126 + .../internal/client/router/GridTcpRouter.java | 74 + .../router/GridTcpRouterConfiguration.java | 306 ++ .../client/router/GridTcpRouterMBean.java | 88 + .../router/impl/GridRouterClientImpl.java | 200 + .../impl/GridRouterCommandLineStartup.java | 169 + .../client/router/impl/GridTcpRouterImpl.java | 348 ++ .../impl/GridTcpRouterNioListenerAdapter.java | 203 + .../impl/GridTcpRouterNioListenerOsImpl.java | 38 + .../router/impl/GridTcpRouterNioParser.java | 115 + .../client/ssl/GridSslBasicContextFactory.java | 438 ++ .../client/ssl/GridSslContextFactory.java | 36 + .../client/util/GridClientConsistentHash.java | 440 ++ .../client/util/GridClientStripedLock.java | 135 + .../internal/client/util/GridClientUtils.java | 171 + .../client/util/GridConcurrentHashSet.java | 113 + .../internal/direct/DirectByteBufferStream.java | 274 +- .../internal/direct/DirectMessageReader.java | 23 +- .../internal/direct/DirectMessageWriter.java | 57 +- .../direct/DirectMessageWriterState.java | 113 + .../fs/common/GridGgfsControlResponse.java | 633 --- .../fs/common/GridGgfsDataInputStream.java | 40 - .../fs/common/GridGgfsDataOutputStream.java | 43 - .../fs/common/GridGgfsHandshakeRequest.java | 93 - .../internal/fs/common/GridGgfsIpcCommand.java | 98 - .../internal/fs/common/GridGgfsLogger.java | 767 ---- .../internal/fs/common/GridGgfsMarshaller.java | 374 -- .../internal/fs/common/GridGgfsMessage.java | 41 - .../fs/common/GridGgfsPathControlRequest.java | 238 -- .../fs/common/GridGgfsStatusRequest.java | 35 - .../fs/common/GridGgfsStreamControlRequest.java | 101 - .../ignite/internal/fs/common/package.html | 24 - .../igfs/common/IgfsControlResponse.java | 633 +++ .../igfs/common/IgfsDataInputStream.java | 40 + .../igfs/common/IgfsDataOutputStream.java | 43 + .../igfs/common/IgfsHandshakeRequest.java | 93 + .../internal/igfs/common/IgfsIpcCommand.java | 98 + .../ignite/internal/igfs/common/IgfsLogger.java | 767 ++++ .../internal/igfs/common/IgfsMarshaller.java | 374 ++ .../internal/igfs/common/IgfsMessage.java | 41 + .../igfs/common/IgfsPathControlRequest.java | 238 ++ .../internal/igfs/common/IgfsStatusRequest.java | 35 + .../igfs/common/IgfsStreamControlRequest.java | 101 + .../ignite/internal/igfs/common/package.html | 24 + .../ignite/internal/jdbc/JdbcConnection.java | 2 +- .../internal/jdbc/JdbcDatabaseMetadata.java | 2 +- .../ignite/internal/jdbc/JdbcResultSet.java | 2 +- .../ignite/internal/jdbc/JdbcStatement.java | 2 +- .../internal/managers/GridManagerAdapter.java | 14 +- .../managers/GridNoopManagerAdapter.java | 93 - .../checkpoint/GridCheckpointRequest.java | 43 +- .../managers/communication/GridIoManager.java | 6 +- .../managers/communication/GridIoMessage.java | 73 +- .../communication/GridIoMessageFactory.java | 28 +- .../communication/GridIoUserMessage.java | 78 +- .../managers/deployment/GridDeployment.java | 3 - .../deployment/GridDeploymentInfoBean.java | 65 +- .../deployment/GridDeploymentManager.java | 5 +- .../GridDeploymentPerLoaderStore.java | 3 - .../GridDeploymentPerVersionStore.java | 7 +- .../deployment/GridDeploymentRequest.java | 58 +- .../deployment/GridDeploymentResponse.java | 43 +- .../discovery/GridDiscoveryManager.java | 4 +- .../eventstorage/GridEventStorageMessage.java | 88 +- .../managers/indexing/GridIndexingManager.java | 4 +- .../loadbalancer/GridLoadBalancerManager.java | 57 - .../securesession/GridSecureSession.java | 54 - .../securesession/GridSecureSessionManager.java | 54 - .../os/GridOsSecureSessionManager.java | 56 - .../managers/securesession/os/package.html | 24 - .../managers/securesession/package.html | 24 - .../security/GridAllowAllPermissionSet.java | 55 - .../managers/security/GridSecurityContext.java | 248 -- .../managers/security/GridSecurityImpl.java | 95 - .../managers/security/GridSecurityManager.java | 93 - .../security/GridSecuritySubjectAdapter.java | 131 - .../security/os/GridOsSecurityManager.java | 97 - .../internal/managers/security/os/package.html | 24 - .../internal/managers/security/package.html | 24 - .../affinity/GridAffinityAssignmentCache.java | 43 +- .../affinity/GridAffinityProcessor.java | 36 +- .../processors/cache/CacheEntryEvent.java | 75 - .../processors/cache/CacheEntryImpl.java | 8 +- .../processors/cache/CacheEntryImpl0.java | 6 +- .../internal/processors/cache/CacheFlag.java | 8 +- .../processors/cache/CacheInvokeEntry.java | 42 +- .../processors/cache/CacheMetricsImpl.java | 8 +- .../processors/cache/CacheProjection.java | 1925 +++++++++ .../cache/CacheStoreBalancingWrapper.java | 2 +- .../cache/CacheVersionedEntryImpl.java | 53 + .../cache/CacheWeakQueryIteratorsHolder.java | 2 +- .../processors/cache/EvictableEntryImpl.java | 188 + .../processors/cache/GridCacheAdapter.java | 1193 +++--- .../cache/GridCacheAffinityManager.java | 7 +- .../processors/cache/GridCacheAttributes.java | 13 - .../cache/GridCacheConcurrentMap.java | 116 +- .../processors/cache/GridCacheContext.java | 104 +- .../cache/GridCacheDeploymentManager.java | 55 +- .../processors/cache/GridCacheEntryEx.java | 79 +- .../processors/cache/GridCacheEntryImpl.java | 729 ---- .../processors/cache/GridCacheEntryInfo.java | 9 + .../processors/cache/GridCacheEntrySet.java | 34 +- .../cache/GridCacheEvictionEntry.java | 494 --- .../cache/GridCacheEvictionManager.java | 46 +- .../cache/GridCacheEvictionRequest.java | 48 +- .../cache/GridCacheEvictionResponse.java | 52 +- .../cache/GridCacheFilterEvaluationEntry.java | 400 -- .../processors/cache/GridCacheIoManager.java | 74 +- .../processors/cache/GridCacheIterator.java | 33 +- .../processors/cache/GridCacheKeySet.java | 30 +- .../cache/GridCacheLoaderWriterStore.java | 2 +- .../processors/cache/GridCacheMapAdapter.java | 71 +- .../processors/cache/GridCacheMapEntry.java | 841 ++-- .../processors/cache/GridCacheMessage.java | 55 +- .../processors/cache/GridCacheMvcc.java | 8 +- .../cache/GridCacheMvccCandidate.java | 18 - .../processors/cache/GridCacheMvccManager.java | 15 + .../GridCachePartitionExchangeManager.java | 5 +- .../processors/cache/GridCachePeekMode.java | 6 +- .../processors/cache/GridCacheProcessor.java | 58 +- .../processors/cache/GridCacheProjectionEx.java | 65 +- .../cache/GridCacheProjectionImpl.java | 223 +- .../processors/cache/GridCacheProxyImpl.java | 185 +- .../processors/cache/GridCacheReturn.java | 57 + .../cache/GridCacheSharedContext.java | 10 +- .../processors/cache/GridCacheStoreManager.java | 143 +- .../processors/cache/GridCacheSwapManager.java | 9 +- .../cache/GridCacheUpdateAtomicResult.java | 29 +- .../processors/cache/GridCacheUtils.java | 168 +- .../processors/cache/GridCacheValueBytes.java | 36 +- .../cache/GridCacheValueCollection.java | 29 +- .../cache/GridCacheWriteBehindStore.java | 19 +- .../cache/IgniteCacheExpiryPolicy.java | 6 + .../processors/cache/IgniteCacheProxy.java | 443 +- .../cache/affinity/GridCacheAffinityProxy.java | 2 +- .../CacheDataStructuresManager.java | 80 +- .../distributed/GridCacheCommittedTxInfo.java | 2 - ...ridCacheOptimisticCheckPreparedTxFuture.java | 8 +- ...idCacheOptimisticCheckPreparedTxRequest.java | 77 +- ...dCacheOptimisticCheckPreparedTxResponse.java | 47 +- .../GridCachePerThreadTxCommitBuffer.java | 186 - ...dCachePessimisticCheckCommittedTxFuture.java | 383 -- ...CachePessimisticCheckCommittedTxRequest.java | 282 -- ...achePessimisticCheckCommittedTxResponse.java | 226 -- .../distributed/GridCacheTtlUpdateRequest.java | 80 +- .../distributed/GridCacheTxCommitBuffer.java | 60 - .../distributed/GridDistributedBaseMessage.java | 58 +- .../GridDistributedCacheAdapter.java | 14 +- .../distributed/GridDistributedCacheEntry.java | 3 - .../distributed/GridDistributedLockRequest.java | 279 +- .../GridDistributedLockResponse.java | 54 +- .../GridDistributedTxFinishRequest.java | 237 +- .../GridDistributedTxFinishResponse.java | 43 +- .../distributed/GridDistributedTxMapping.java | 6 +- .../GridDistributedTxPrepareRequest.java | 191 +- .../GridDistributedTxPrepareResponse.java | 45 +- .../GridDistributedTxRemoteAdapter.java | 96 +- .../GridDistributedUnlockRequest.java | 43 +- .../GridPartitionedCacheEntryImpl.java | 423 -- .../IgniteExternalizableExpiryPolicy.java | 14 +- .../dht/GridDhtAffinityAssignmentRequest.java | 35 +- .../dht/GridDhtAffinityAssignmentResponse.java | 46 +- .../distributed/dht/GridDhtCacheAdapter.java | 105 +- .../distributed/dht/GridDhtCacheEntry.java | 28 +- .../distributed/dht/GridDhtCacheEntryImpl.java | 172 - .../cache/distributed/dht/GridDhtGetFuture.java | 38 +- .../distributed/dht/GridDhtLockFuture.java | 167 +- .../distributed/dht/GridDhtLockRequest.java | 127 +- .../distributed/dht/GridDhtLockResponse.java | 66 +- .../dht/GridDhtTransactionalCacheAdapter.java | 54 +- .../distributed/dht/GridDhtTxFinishFuture.java | 50 +- .../distributed/dht/GridDhtTxFinishRequest.java | 322 +- .../dht/GridDhtTxFinishResponse.java | 37 +- .../cache/distributed/dht/GridDhtTxLocal.java | 65 +- .../distributed/dht/GridDhtTxLocalAdapter.java | 125 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 655 ++- .../dht/GridDhtTxPrepareRequest.java | 150 +- .../dht/GridDhtTxPrepareResponse.java | 73 +- .../cache/distributed/dht/GridDhtTxRemote.java | 20 +- .../distributed/dht/GridDhtUnlockRequest.java | 42 +- .../dht/GridPartitionedGetFuture.java | 28 +- .../dht/atomic/GridDhtAtomicCache.java | 273 +- .../dht/atomic/GridDhtAtomicCacheEntry.java | 23 - .../GridDhtAtomicDeferredUpdateResponse.java | 41 +- .../dht/atomic/GridDhtAtomicUpdateFuture.java | 14 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 179 +- .../dht/atomic/GridDhtAtomicUpdateResponse.java | 59 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 9 +- .../dht/atomic/GridNearAtomicUpdateRequest.java | 176 +- .../atomic/GridNearAtomicUpdateResponse.java | 105 +- .../dht/colocated/GridDhtColocatedCache.java | 93 +- .../colocated/GridDhtColocatedCacheEntry.java | 15 - .../colocated/GridDhtColocatedLockFuture.java | 54 +- .../colocated/GridDhtDetachedCacheEntry.java | 3 - .../dht/preloader/GridDhtForceKeysFuture.java | 2 +- .../dht/preloader/GridDhtForceKeysRequest.java | 57 +- .../dht/preloader/GridDhtForceKeysResponse.java | 58 +- .../GridDhtPartitionDemandMessage.java | 67 +- .../preloader/GridDhtPartitionDemandPool.java | 8 +- .../preloader/GridDhtPartitionExchangeId.java | 41 +- .../dht/preloader/GridDhtPartitionFullMap.java | 2 +- .../dht/preloader/GridDhtPartitionMap.java | 98 +- .../GridDhtPartitionSupplyMessage.java | 73 +- .../preloader/GridDhtPartitionSupplyPool.java | 20 +- .../GridDhtPartitionsAbstractMessage.java | 32 +- .../GridDhtPartitionsExchangeFuture.java | 8 +- .../preloader/GridDhtPartitionsFullMessage.java | 90 +- .../GridDhtPartitionsSingleMessage.java | 38 +- .../GridDhtPartitionsSingleRequest.java | 26 +- .../dht/preloader/GridDhtPreloader.java | 22 +- .../distributed/near/GridNearAtomicCache.java | 60 +- .../distributed/near/GridNearCacheAdapter.java | 190 +- .../distributed/near/GridNearCacheEntry.java | 21 +- .../distributed/near/GridNearGetFuture.java | 39 +- .../distributed/near/GridNearGetRequest.java | 152 +- .../distributed/near/GridNearGetResponse.java | 73 +- .../distributed/near/GridNearLockFuture.java | 23 +- .../distributed/near/GridNearLockRequest.java | 170 +- .../distributed/near/GridNearLockResponse.java | 69 +- .../near/GridNearTransactionalCache.java | 40 +- .../near/GridNearTxFinishFuture.java | 13 +- .../near/GridNearTxFinishRequest.java | 93 +- .../near/GridNearTxFinishResponse.java | 48 +- .../cache/distributed/near/GridNearTxLocal.java | 121 +- .../near/GridNearTxPrepareFuture.java | 425 +- .../near/GridNearTxPrepareRequest.java | 165 +- .../near/GridNearTxPrepareResponse.java | 170 +- .../distributed/near/GridNearTxRemote.java | 8 +- .../distributed/near/GridNearUnlockRequest.java | 26 +- .../processors/cache/dr/GridCacheDrInfo.java | 5 +- .../processors/cache/local/GridLocalCache.java | 12 +- .../cache/local/GridLocalCacheEntry.java | 3 - .../cache/local/GridLocalLockFuture.java | 6 +- .../processors/cache/local/GridLocalTx.java | 8 +- .../cache/local/GridLocalTxFuture.java | 2 +- .../local/atomic/GridLocalAtomicCache.java | 101 +- .../processors/cache/query/CacheQueries.java | 143 + .../processors/cache/query/CacheQuery.java | 296 ++ .../cache/query/CacheQueryFuture.java | 66 + .../processors/cache/query/CacheQueryType.java | 47 + .../query/GridCacheDistributedQueryFuture.java | 2 +- .../query/GridCacheDistributedQueryManager.java | 11 +- .../cache/query/GridCacheLocalQueryFuture.java | 6 +- .../cache/query/GridCacheLocalQueryManager.java | 1 - .../cache/query/GridCacheQueriesEx.java | 1 - .../cache/query/GridCacheQueriesImpl.java | 15 +- .../cache/query/GridCacheQueriesProxy.java | 15 +- .../cache/query/GridCacheQueryAdapter.java | 11 +- .../cache/query/GridCacheQueryErrorFuture.java | 1 - .../query/GridCacheQueryFutureAdapter.java | 1 - .../cache/query/GridCacheQueryInfo.java | 8 +- .../cache/query/GridCacheQueryManager.java | 450 +-- .../query/GridCacheQueryMetricsAdapter.java | 4 +- .../cache/query/GridCacheQueryRequest.java | 148 +- .../cache/query/GridCacheQueryResponse.java | 73 +- .../cache/query/GridCacheQueryType.java | 4 +- .../cache/query/GridCacheSqlMetadata.java | 2 +- .../processors/cache/query/QueryCursorImpl.java | 87 + .../continuous/CacheContinuousQueryEntry.java | 234 ++ .../continuous/CacheContinuousQueryEvent.java | 87 + .../CacheContinuousQueryFilterEx.java | 31 + .../continuous/CacheContinuousQueryHandler.java | 502 +++ .../CacheContinuousQueryListener.java | 49 + .../continuous/CacheContinuousQueryManager.java | 757 ++++ .../GridCacheContinuousQueryAdapter.java | 318 -- .../GridCacheContinuousQueryEntry.java | 766 ---- .../GridCacheContinuousQueryFilterEx.java | 33 - .../GridCacheContinuousQueryHandler.java | 568 --- .../GridCacheContinuousQueryListener.java | 41 - .../GridCacheContinuousQueryManager.java | 784 ---- .../query/jdbc/GridCacheQueryJdbcTask.java | 1 - .../jdbc/GridCacheQueryJdbcValidationTask.java | 5 - .../cache/transactions/IgniteInternalTx.java | 27 +- .../transactions/IgniteTransactionsImpl.java | 178 +- .../cache/transactions/IgniteTxAdapter.java | 165 +- .../cache/transactions/IgniteTxEntry.java | 85 +- .../cache/transactions/IgniteTxHandler.java | 695 +--- .../transactions/IgniteTxLocalAdapter.java | 588 +-- .../cache/transactions/IgniteTxLocalEx.java | 16 +- .../cache/transactions/IgniteTxManager.java | 240 +- .../transactions/IgniteTxMetricsAdapter.java | 119 - .../cache/transactions/IgniteTxProxy.java | 27 - .../cache/transactions/IgniteTxProxyImpl.java | 338 -- .../transactions/TransactionMetricsAdapter.java | 119 + .../cache/transactions/TransactionProxy.java | 27 + .../transactions/TransactionProxyImpl.java | 345 ++ .../cache/version/GridCacheVersion.java | 50 +- .../GridCacheVersionConflictContext.java | 4 +- .../cache/version/GridCacheVersionEx.java | 2 +- .../clock/GridClockDeltaSnapshotMessage.java | 42 +- .../processors/clock/GridClockDeltaVersion.java | 36 +- .../processors/closure/GridClosurePolicy.java | 4 +- .../closure/GridClosureProcessor.java | 300 +- .../continuous/GridContinuousMessage.java | 57 +- .../dataload/GridDataLoadCacheUpdaters.java | 88 - .../dataload/GridDataLoadRequest.java | 102 +- .../dataload/GridDataLoadResponse.java | 43 +- .../dataload/IgniteDataLoaderImpl.java | 112 +- .../datastructures/DataStructuresProcessor.java | 19 +- .../datastructures/GridCacheAtomicLongImpl.java | 5 +- .../GridCacheAtomicReferenceImpl.java | 5 +- .../GridCacheAtomicSequenceImpl.java | 5 +- .../GridCacheAtomicStampedImpl.java | 5 +- .../GridCacheCountDownLatchImpl.java | 5 +- .../datastructures/GridCacheSetImpl.java | 1 - .../GridTransactionalCacheQueueImpl.java | 8 +- .../dr/GridDrDataLoadCacheUpdater.java | 4 +- .../processors/email/GridEmailHolder.java | 111 - .../email/IgniteEmailProcessorAdapter.java | 84 - .../email/IgniteNoopEmailProcessor.java | 55 - .../internal/processors/email/package.html | 24 - .../processors/fs/GridGgfsAckMessage.java | 208 - .../processors/fs/GridGgfsAsyncImpl.java | 316 -- .../processors/fs/GridGgfsAttributes.java | 186 - .../processors/fs/GridGgfsBlockKey.java | 275 -- .../fs/GridGgfsBlockLocationImpl.java | 258 -- .../processors/fs/GridGgfsBlocksMessage.java | 188 - .../processors/fs/GridGgfsClientSession.java | 75 - .../fs/GridGgfsCommunicationMessage.java | 75 - .../internal/processors/fs/GridGgfsContext.java | 205 - .../processors/fs/GridGgfsDataManager.java | 1910 --------- .../processors/fs/GridGgfsDeleteMessage.java | 202 - .../processors/fs/GridGgfsDeleteWorker.java | 345 -- .../fs/GridGgfsDirectoryNotEmptyException.java | 44 - .../internal/processors/fs/GridGgfsEx.java | 143 - .../fs/GridGgfsFileAffinityRange.java | 394 -- .../processors/fs/GridGgfsFileInfo.java | 569 --- .../internal/processors/fs/GridGgfsFileMap.java | 361 -- .../processors/fs/GridGgfsFileWorker.java | 182 - .../processors/fs/GridGgfsFileWorkerBatch.java | 236 -- .../processors/fs/GridGgfsFileWorkerTask.java | 32 - .../fs/GridGgfsFragmentizerManager.java | 831 ---- .../fs/GridGgfsFragmentizerRequest.java | 168 - .../fs/GridGgfsFragmentizerResponse.java | 129 - .../fs/GridGgfsHandshakeResponse.java | 122 - .../internal/processors/fs/GridGgfsImpl.java | 2224 ---------- .../fs/GridGgfsInputStreamAdapter.java | 49 - .../fs/GridGgfsInputStreamDescriptor.java | 78 - .../processors/fs/GridGgfsInputStreamImpl.java | 533 --- .../fs/GridGgfsInvalidRangeException.java | 43 - .../processors/fs/GridGgfsIpcHandler.java | 573 --- .../internal/processors/fs/GridGgfsJobImpl.java | 117 - .../processors/fs/GridGgfsListingEntry.java | 197 - .../processors/fs/GridGgfsLocalMetrics.java | 212 - .../internal/processors/fs/GridGgfsManager.java | 155 - .../processors/fs/GridGgfsMetaManager.java | 3027 -------------- .../processors/fs/GridGgfsModeResolver.java | 177 - .../internal/processors/fs/GridGgfsPaths.java | 124 - .../processors/fs/GridGgfsSamplingKey.java | 83 - .../GridGgfsSecondaryInputStreamDescriptor.java | 59 - ...GridGgfsSecondaryOutputStreamDescriptor.java | 74 - .../internal/processors/fs/GridGgfsServer.java | 427 -- .../processors/fs/GridGgfsServerHandler.java | 57 - .../processors/fs/GridGgfsServerManager.java | 211 - .../internal/processors/fs/GridGgfsStatus.java | 76 - .../processors/fs/GridGgfsSyncMessage.java | 161 - .../internal/processors/fs/GridGgfsThread.java | 82 - .../processors/fs/IgniteFsFileImpl.java | 245 -- .../internal/processors/fs/IgniteFsHelper.java | 49 - .../processors/fs/IgniteFsHelperImpl.java | 54 - .../processors/fs/IgniteFsMetricsAdapter.java | 239 -- .../processors/fs/IgniteFsNoopHelper.java | 41 - .../processors/fs/IgniteFsNoopProcessor.java | 71 - .../fs/IgniteFsOutputStreamAdapter.java | 263 -- .../processors/fs/IgniteFsOutputStreamImpl.java | 505 --- .../processors/fs/IgniteFsProcessor.java | 425 -- .../processors/fs/IgniteFsProcessorAdapter.java | 80 - .../processors/fs/IgniteFsTaskArgsImpl.java | 135 - .../ignite/internal/processors/fs/package.html | 24 - .../processors/hadoop/GridHadoopJobId.java | 3 +- .../processors/igfs/IgfsAckMessage.java | 184 + .../internal/processors/igfs/IgfsAsyncImpl.java | 316 ++ .../processors/igfs/IgfsAttributes.java | 186 + .../internal/processors/igfs/IgfsBlockKey.java | 252 ++ .../processors/igfs/IgfsBlockLocationImpl.java | 258 ++ .../processors/igfs/IgfsBlocksMessage.java | 165 + .../processors/igfs/IgfsClientSession.java | 75 + .../igfs/IgfsCommunicationMessage.java | 71 + .../internal/processors/igfs/IgfsContext.java | 205 + .../processors/igfs/IgfsDataManager.java | 1907 +++++++++ .../processors/igfs/IgfsDeleteMessage.java | 179 + .../processors/igfs/IgfsDeleteWorker.java | 345 ++ .../igfs/IgfsDirectoryNotEmptyException.java | 44 + .../ignite/internal/processors/igfs/IgfsEx.java | 143 + .../processors/igfs/IgfsFileAffinityRange.java | 371 ++ .../internal/processors/igfs/IgfsFileImpl.java | 245 ++ .../internal/processors/igfs/IgfsFileInfo.java | 569 +++ .../internal/processors/igfs/IgfsFileMap.java | 361 ++ .../processors/igfs/IgfsFileWorker.java | 182 + .../processors/igfs/IgfsFileWorkerBatch.java | 236 ++ .../processors/igfs/IgfsFileWorkerTask.java | 32 + .../igfs/IgfsFragmentizerManager.java | 831 ++++ .../igfs/IgfsFragmentizerRequest.java | 146 + .../igfs/IgfsFragmentizerResponse.java | 108 + .../processors/igfs/IgfsHandshakeResponse.java | 122 + .../internal/processors/igfs/IgfsHelper.java | 49 + .../processors/igfs/IgfsHelperImpl.java | 54 + .../internal/processors/igfs/IgfsImpl.java | 2224 ++++++++++ .../processors/igfs/IgfsInputStreamAdapter.java | 49 + .../igfs/IgfsInputStreamDescriptor.java | 78 + .../processors/igfs/IgfsInputStreamImpl.java | 533 +++ .../igfs/IgfsInvalidRangeException.java | 43 + .../processors/igfs/IgfsIpcHandler.java | 562 +++ .../internal/processors/igfs/IgfsJobImpl.java | 117 + .../processors/igfs/IgfsListingEntry.java | 197 + .../processors/igfs/IgfsLocalMetrics.java | 212 + .../internal/processors/igfs/IgfsManager.java | 155 + .../processors/igfs/IgfsMetaManager.java | 3027 ++++++++++++++ .../processors/igfs/IgfsMetricsAdapter.java | 239 ++ .../processors/igfs/IgfsModeResolver.java | 177 + .../processors/igfs/IgfsNoopHelper.java | 41 + .../processors/igfs/IgfsNoopProcessor.java | 71 + .../igfs/IgfsOutputStreamAdapter.java | 263 ++ .../processors/igfs/IgfsOutputStreamImpl.java | 505 +++ .../internal/processors/igfs/IgfsPaths.java | 124 + .../internal/processors/igfs/IgfsProcessor.java | 420 ++ .../processors/igfs/IgfsProcessorAdapter.java | 80 + .../processors/igfs/IgfsSamplingKey.java | 83 + .../IgfsSecondaryInputStreamDescriptor.java | 59 + .../IgfsSecondaryOutputStreamDescriptor.java | 74 + .../internal/processors/igfs/IgfsServer.java | 427 ++ .../processors/igfs/IgfsServerHandler.java | 57 + .../processors/igfs/IgfsServerManager.java | 211 + .../internal/processors/igfs/IgfsStatus.java | 76 + .../processors/igfs/IgfsSyncMessage.java | 139 + .../processors/igfs/IgfsTaskArgsImpl.java | 135 + .../internal/processors/igfs/IgfsThread.java | 82 + .../internal/processors/igfs/package.html | 24 + .../internal/processors/job/GridJobWorker.java | 4 +- .../license/GridLicenseProcessor.java | 69 - .../license/GridLicenseSubsystem.java | 53 - .../license/GridLicenseUseRegistry.java | 90 - .../license/os/GridOsLicenseProcessor.java | 66 - .../internal/processors/license/os/package.html | 24 - .../internal/processors/license/package.html | 24 - .../portable/GridPortableProcessor.java | 14 +- .../portable/os/GridOsPortableProcessor.java | 12 +- .../processors/query/GridQueryIndexing.java | 15 +- .../processors/query/GridQueryProcessor.java | 157 +- .../processors/resource/GridResourceIoc.java | 48 +- .../resource/GridResourceProcessor.java | 21 + .../processors/rest/GridRestProcessor.java | 37 +- .../client/message/GridClientLogRequest.java | 118 - .../handlers/cache/GridCacheCommandHandler.java | 21 +- .../cache/GridCacheQueryCommandHandler.java | 7 +- .../handlers/log/GridLogCommandHandler.java | 306 -- .../processors/rest/handlers/log/package.html | 24 - .../handlers/task/GridTaskResultRequest.java | 39 +- .../handlers/task/GridTaskResultResponse.java | 49 +- .../version/GridVersionCommandHandler.java | 4 +- .../rest/protocols/GridRestProtocolAdapter.java | 8 +- .../protocols/tcp/GridTcpRestNioListener.java | 31 +- .../rest/protocols/tcp/GridTcpRestParser.java | 8 +- .../rest/protocols/tcp/GridTcpRestProtocol.java | 40 +- .../securesession/GridSecureSession.java | 60 + .../GridSecureSessionProcessor.java | 59 + .../os/GridOsSecureSessionProcessor.java | 61 + .../security/GridSecurityContext.java | 251 ++ .../security/GridSecurityProcessor.java | 97 + .../security/os/GridOsSecurityProcessor.java | 218 + .../service/GridServiceProcessor.java | 102 +- .../streamer/GridStreamProcessor.java | 5 - .../streamer/GridStreamerCancelRequest.java | 33 +- .../streamer/GridStreamerExecutionRequest.java | 75 +- .../streamer/GridStreamerResponse.java | 38 +- .../processors/streamer/IgniteStreamerImpl.java | 41 +- .../processors/task/GridTaskWorker.java | 4 +- .../ignite/internal/product/IgniteProduct.java | 67 - .../internal/product/IgniteProductLicense.java | 183 - .../product/IgniteProductLicenseException.java | 70 - .../apache/ignite/internal/product/package.html | 24 - .../util/GridBoundedConcurrentOrderedMap.java | 20 +- .../ignite/internal/util/GridByteArrayList.java | 36 +- .../ignite/internal/util/GridLongList.java | 36 +- .../ignite/internal/util/IgniteUtils.java | 67 +- .../util/future/GridCompoundFuture.java | 2 + .../util/future/GridCompoundIdentityFuture.java | 10 - .../ignite/internal/util/ipc/IpcEndpoint.java | 2 +- .../internal/util/ipc/IpcEndpointFactory.java | 2 +- .../internal/util/ipc/IpcToNioAdapter.java | 4 +- .../ipc/shmem/IpcSharedMemoryNativeLoader.java | 5 +- .../shmem/IpcSharedMemoryServerEndpoint.java | 7 +- .../ignite/internal/util/lang/GridFunc.java | 410 +- .../util/lang/GridMetadataAwareAdapter.java | 3 - .../ignite/internal/util/nio/GridNioServer.java | 36 +- .../util/nio/GridNioSessionMetaKey.java | 5 +- .../util/nio/GridShmemCommunicationClient.java | 4 +- .../util/nio/GridTcpCommunicationClient.java | 4 +- .../ignite/internal/util/typedef/PCE.java | 11 +- .../apache/ignite/internal/visor/VisorJob.java | 11 +- .../internal/visor/VisorMultiNodeTask.java | 9 +- .../ignite/internal/visor/cache/VisorCache.java | 24 +- .../cache/VisorCacheAggregatedMetrics.java | 6 +- .../visor/cache/VisorCacheClearTask.java | 140 +- .../visor/cache/VisorCacheCompactTask.java | 2 +- .../visor/cache/VisorCacheConfiguration.java | 316 +- .../cache/VisorCacheDefaultConfiguration.java | 57 - .../visor/cache/VisorCacheDgcConfiguration.java | 97 - .../visor/cache/VisorCacheLoadTask.java | 35 +- .../visor/cache/VisorCacheMetadataTask.java | 2 +- .../internal/visor/cache/VisorCacheMetrics.java | 18 +- .../cache/VisorCacheMetricsCollectorTask.java | 10 +- .../visor/cache/VisorCachePreloadTask.java | 2 +- .../visor/cache/VisorCacheQueryMetrics.java | 2 +- .../visor/cache/VisorCacheResetMetricsTask.java | 2 +- .../cache/VisorCacheStoreConfiguration.java | 7 +- .../visor/cache/VisorCacheSwapBackupsTask.java | 19 +- .../cache/VisorCacheTypeFieldMetadata.java | 115 + .../visor/cache/VisorCacheTypeMetadata.java | 320 ++ .../VisorCacheWriteBehindConfiguration.java | 6 +- .../compute/VisorComputeCancelSessionsTask.java | 4 +- .../compute/VisorComputeMonitoringHolder.java | 23 +- .../compute/VisorComputeResetMetricsTask.java | 2 +- .../VisorComputeToggleMonitoringTask.java | 10 +- .../internal/visor/debug/VisorThreadInfo.java | 17 +- .../visor/debug/VisorThreadLockInfo.java | 12 +- .../visor/debug/VisorThreadMonitorInfo.java | 6 +- .../event/VisorGridAuthenticationEvent.java | 12 +- .../event/VisorGridAuthorizationEvent.java | 12 +- .../visor/event/VisorGridDeploymentEvent.java | 10 +- .../visor/event/VisorGridDiscoveryEvent.java | 10 +- .../internal/visor/event/VisorGridEvent.java | 18 +- .../internal/visor/event/VisorGridJobEvent.java | 30 +- .../visor/event/VisorGridLicenseEvent.java | 74 - .../event/VisorGridSecuritySessionEvent.java | 10 +- .../visor/event/VisorGridTaskEvent.java | 30 +- .../internal/visor/file/VisorFileBlock.java | 10 +- .../internal/visor/file/VisorFileBlockTask.java | 10 +- .../ignite/internal/visor/ggfs/VisorGgfs.java | 113 - .../internal/visor/ggfs/VisorGgfsEndpoint.java | 106 - .../visor/ggfs/VisorGgfsFormatTask.java | 70 - .../internal/visor/ggfs/VisorGgfsMetrics.java | 350 -- .../internal/visor/ggfs/VisorGgfsProfiler.java | 88 - .../visor/ggfs/VisorGgfsProfilerClearTask.java | 114 - .../visor/ggfs/VisorGgfsProfilerEntry.java | 238 -- .../visor/ggfs/VisorGgfsProfilerTask.java | 507 --- .../VisorGgfsProfilerUniformityCounters.java | 197 - .../visor/ggfs/VisorGgfsResetMetricsTask.java | 73 - .../visor/ggfs/VisorGgfsSamplingStateTask.java | 77 - .../ignite/internal/visor/igfs/VisorIgfs.java | 112 + .../internal/visor/igfs/VisorIgfsEndpoint.java | 106 + .../visor/igfs/VisorIgfsFormatTask.java | 70 + .../internal/visor/igfs/VisorIgfsMetrics.java | 350 ++ .../internal/visor/igfs/VisorIgfsProfiler.java | 88 + .../visor/igfs/VisorIgfsProfilerClearTask.java | 114 + .../visor/igfs/VisorIgfsProfilerEntry.java | 238 ++ .../visor/igfs/VisorIgfsProfilerTask.java | 519 +++ .../VisorIgfsProfilerUniformityCounters.java | 204 + .../visor/igfs/VisorIgfsResetMetricsTask.java | 73 + .../visor/igfs/VisorIgfsSamplingStateTask.java | 77 + .../visor/log/VisorLogSearchResult.java | 20 +- .../internal/visor/log/VisorLogSearchTask.java | 10 +- .../internal/visor/misc/VisorAckTask.java | 2 +- .../visor/misc/VisorLatestVersionTask.java | 2 +- .../internal/visor/misc/VisorNopTask.java | 3 + .../visor/node/VisorAtomicConfiguration.java | 104 + .../visor/node/VisorBasicConfiguration.java | 29 +- .../visor/node/VisorEmailConfiguration.java | 177 - .../node/VisorExecutorServiceConfiguration.java | 89 +- .../visor/node/VisorGgfsConfiguration.java | 574 --- .../visor/node/VisorGridConfiguration.java | 85 +- .../visor/node/VisorIgfsConfiguration.java | 574 +++ .../visor/node/VisorLifecycleConfiguration.java | 19 - .../visor/node/VisorMetricsConfiguration.java | 10 +- .../VisorNodeConfigurationCollectorJob.java | 2 +- .../visor/node/VisorNodeDataCollectorJob.java | 115 +- .../node/VisorNodeDataCollectorJobResult.java | 97 +- .../visor/node/VisorNodeDataCollectorTask.java | 72 +- .../node/VisorNodeDataCollectorTaskArg.java | 19 +- .../node/VisorNodeDataCollectorTaskResult.java | 56 +- .../node/VisorNodeEventsCollectorTask.java | 85 +- .../internal/visor/node/VisorNodeGcTask.java | 2 +- .../internal/visor/node/VisorNodePingTask.java | 2 +- .../visor/node/VisorRestConfiguration.java | 19 +- .../visor/node/VisorSpisConfiguration.java | 45 +- .../node/VisorTransactionConfiguration.java | 158 + .../visor/query/VisorQueryCleanupTask.java | 4 +- .../visor/query/VisorQueryNextPageTask.java | 4 +- .../internal/visor/query/VisorQueryTask.java | 65 +- .../internal/visor/query/VisorQueryUtils.java | 2 +- .../streamer/VisorStreamerConfiguration.java | 19 +- .../visor/streamer/VisorStreamerMetrics.java | 6 +- .../streamer/VisorStreamerMetricsResetTask.java | 4 +- .../visor/streamer/VisorStreamerResetTask.java | 4 +- .../internal/visor/util/VisorEventMapper.java | 73 + .../internal/visor/util/VisorMimeTypes.java | 51 +- .../internal/visor/util/VisorTaskUtils.java | 186 +- .../apache/ignite/lang/IgniteAsyncSupport.java | 2 +- .../org/apache/ignite/lang/IgniteFuture.java | 1 - .../ignite/lang/IgniteProductVersion.java | 12 +- .../apache/ignite/logger/java/JavaLogger.java | 3 - .../optimized/OptimizedClassDescriptor.java | 2 +- .../optimized/optimized-classnames.properties | 377 +- .../mxbean/ClusterLocalNodeMetricsMXBean.java | 9 + .../org/apache/ignite/mxbean/IgniteMXBean.java | 24 - .../communication/MessageAdapter.java | 108 +- .../extensions/communication/MessageReader.java | 25 +- .../extensions/communication/MessageWriter.java | 63 +- .../plugin/security/AuthenticationContext.java | 110 + .../ignite/plugin/security/GridSecurity.java | 97 - .../security/GridSecurityCredentials.java | 5 - .../GridSecurityCredentialsProvider.java | 5 - .../plugin/security/GridSecuritySubject.java | 1 - .../resources/CacheStoreSessionResource.java | 41 + .../apache/ignite/resources/package-info.java | 22 + .../org/apache/ignite/resources/package.html | 25 - .../org/apache/ignite/spi/IgniteSpiAdapter.java | 19 +- .../AuthenticationAclProvider.java | 41 - .../authentication/AuthenticationContext.java | 56 - .../AuthenticationContextAdapter.java | 112 - .../spi/authentication/AuthenticationSpi.java | 90 - .../noop/NoopAuthenticationSpi.java | 127 - .../noop/NoopAuthenticationSpiMBean.java | 29 - .../ignite/spi/authentication/noop/package.html | 24 - .../ignite/spi/authentication/package.html | 24 - .../fifoqueue/FifoQueueCollisionSpi.java | 6 +- .../jobstealing/JobStealingRequest.java | 33 +- .../PriorityQueueCollisionSpi.java | 6 +- .../communication/tcp/TcpCommunicationSpi.java | 48 +- .../DiscoverySpiNodeAuthenticator.java | 2 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 72 +- .../discovery/tcp/TcpDiscoverySpiAdapter.java | 2 +- .../tcp/internal/TcpDiscoveryNodesRing.java | 2 - .../spi/indexing/GridIndexingQueryFilter.java | 34 - .../ignite/spi/indexing/GridIndexingSpi.java | 112 - .../spi/indexing/GridNoopIndexingSpi.java | 66 - .../spi/indexing/IndexingQueryFilter.java | 34 + .../apache/ignite/spi/indexing/IndexingSpi.java | 113 + .../spi/indexing/noop/NoopIndexingSpi.java | 68 + .../spi/securesession/SecureSessionSpi.java | 92 - .../noop/NoopSecureSessionSpi.java | 123 - .../noop/NoopSecureSessionSpiMBean.java | 29 - .../ignite/spi/securesession/noop/package.html | 24 - .../ignite/spi/securesession/package.html | 24 - .../spi/swapspace/noop/NoopSwapSpaceSpi.java | 2 +- .../ignite/startup/BasicWarmupClosure.java | 9 +- .../startup/cmdline/CommandLineStartup.java | 8 +- .../ignite/streamer/StreamerConfiguration.java | 50 +- .../apache/ignite/transactions/IgniteTx.java | 275 -- .../transactions/IgniteTxConcurrency.java | 45 - .../IgniteTxHeuristicException.java | 51 - .../ignite/transactions/IgniteTxIsolation.java | 49 - .../ignite/transactions/IgniteTxMetrics.java | 53 - .../IgniteTxOptimisticException.java | 47 - .../transactions/IgniteTxRollbackException.java | 47 - .../ignite/transactions/IgniteTxState.java | 65 - .../transactions/IgniteTxSynchronization.java | 45 - .../transactions/IgniteTxTimeoutException.java | 47 - .../apache/ignite/transactions/Transaction.java | 276 ++ .../transactions/TransactionConcurrency.java | 45 + .../TransactionHeuristicException.java | 51 + .../transactions/TransactionIsolation.java | 49 + .../ignite/transactions/TransactionMetrics.java | 53 + .../TransactionOptimisticException.java | 47 + .../TransactionRollbackException.java | 47 + .../ignite/transactions/TransactionState.java | 65 + .../TransactionSynchronization.java | 45 + .../TransactionTimeoutException.java | 47 + .../org/jdk8/backport/ConcurrentHashMap8.java | 3825 ++++++++++++++++++ .../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 ++ .../META-INF/licenses/gnu-gplv2ce-license.txt | 349 ++ .../core/src/main/resources/ignite.properties | 1 + .../spring-cache-client-benchmark-1.xml | 6 +- .../spring-cache-client-benchmark-2.xml | 6 +- .../spring-cache-client-benchmark-3.xml | 6 +- .../test/config/default-spring-url-testing.xml | 2 + modules/core/src/test/config/example-cache.xml | 2 + modules/core/src/test/config/ggfs-loopback.xml | 167 - modules/core/src/test/config/ggfs-shmem.xml | 167 - .../hadoop/core-site-loopback-secondary.xml | 16 +- .../test/config/hadoop/core-site-loopback.xml | 12 +- .../test/config/hadoop/core-site-secondary.xml | 12 +- .../core/src/test/config/hadoop/core-site.xml | 10 +- modules/core/src/test/config/igfs-loopback.xml | 167 + modules/core/src/test/config/igfs-shmem.xml | 167 + .../src/test/config/io-manager-benchmark.xml | 1 + .../src/test/config/job-loadtest/client.xml | 2 + .../src/test/config/job-loadtest/server.xml | 2 + modules/core/src/test/config/jobs-load-base.xml | 2 + .../src/test/config/load/cache-benchmark.xml | 2 + .../test/config/load/cache-client-benchmark.xml | 2 + .../core/src/test/config/load/dsi-load-base.xml | 2 + .../src/test/config/load/merge-sort-base.xml | 2 + .../test/config/loaders/grid-cfg-2-grids.xml | 4 + .../core/src/test/config/loaders/grid-cfg.xml | 5 + .../config/spring-cache-put-remove-load.xml | 2 + .../src/test/config/spring-start-nodes-attr.xml | 2 + .../core/src/test/config/spring-start-nodes.xml | 2 + .../config/streamer/spring-streamer-base.xml | 2 + modules/core/src/test/config/tests.properties | 6 +- .../test/config/websession/spring-cache-1.xml | 2 + .../test/config/websession/spring-cache-2.xml | 2 + .../test/config/websession/spring-cache-3.xml | 2 + .../org/apache/ignite/GridTestJobContext.java | 10 - .../apache/ignite/GridTestStoreNodeStartup.java | 4 +- .../ignite/IgniteCacheAffinitySelfTest.java | 8 +- ...CachePartitionFairAffinityNodesSelfTest.java | 4 +- .../store/GridCacheBalancingStoreSelfTest.java | 2 +- .../cache/store/GridGeneratingTestStore.java | 2 +- .../store/jdbc/CacheJdbcPojoStoreTest.java | 18 +- ...eJdbcStoreAbstractMultithreadedSelfTest.java | 2 +- ...CacheJdbcBlobStoreMultithreadedSelfTest.java | 2 +- .../ignite/igfs/IgfsEventsAbstractSelfTest.java | 848 ++++ .../igfs/IgfsFragmentizerAbstractSelfTest.java | 168 + .../ignite/igfs/IgfsFragmentizerSelfTest.java | 268 ++ .../igfs/IgfsFragmentizerTopologySelfTest.java | 49 + .../apache/ignite/igfs/IgfsPathSelfTest.java | 162 + .../ignite/igfs/IgfsTestInputGenerator.java | 51 + .../GridGgfsEventsAbstractSelfTest.java | 848 ---- .../GridGgfsFragmentizerAbstractSelfTest.java | 168 - .../ignitefs/GridGgfsFragmentizerSelfTest.java | 268 -- .../GridGgfsFragmentizerTopologySelfTest.java | 49 - .../ignite/ignitefs/GridGgfsPathSelfTest.java | 162 - .../ignitefs/GridGgfsTestInputGenerator.java | 51 - .../internal/ClusterNodeMetricsSelfTest.java | 15 + .../internal/GridDiscoveryEventSelfTest.java | 2 + .../GridJobMasterLeaveAwareSelfTest.java | 6 +- .../internal/GridLifecycleAwareSelfTest.java | 18 +- .../ignite/internal/GridProjectionSelfTest.java | 2 +- .../internal/GridReleaseTypeSelfTest.java | 35 +- .../ignite/internal/GridStartStopSelfTest.java | 16 +- .../GridTopologyBuildVersionSelfTest.java | 101 - .../internal/GridUpdateNotifierSelfTest.java | 4 + .../ignite/internal/GridVersionSelfTest.java | 7 +- .../IgniteComputeTopologyExceptionTest.java | 112 + .../checkpoint/GridCheckpointTaskSelfTest.java | 4 +- .../GridCommunicationSendMessageSelfTest.java | 13 +- .../communication/GridIoManagerSelfTest.java | 17 +- .../GridDeploymentMessageCountSelfTest.java | 7 +- .../GridDiscoveryManagerAliveCacheSelfTest.java | 2 +- .../discovery/GridDiscoveryManagerSelfTest.java | 31 + .../GridAffinityProcessorAbstractSelfTest.java | 8 +- .../GridCacheAbstractFailoverSelfTest.java | 19 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 512 +-- .../cache/GridCacheAbstractMetricsSelfTest.java | 359 +- .../GridCacheAbstractRemoveFailureTest.java | 11 +- .../cache/GridCacheAbstractSelfTest.java | 62 +- .../cache/GridCacheAbstractTxReadTest.java | 17 +- .../cache/GridCacheAffinityApiSelfTest.java | 14 +- .../cache/GridCacheAffinityRoutingSelfTest.java | 424 +- .../cache/GridCacheAlwaysEvictionPolicy.java | 3 +- .../GridCacheAsyncOperationsLimitSelfTest.java | 6 +- .../cache/GridCacheBasicApiAbstractTest.java | 8 +- .../cache/GridCacheBasicStoreAbstractTest.java | 15 +- .../cache/GridCacheClearAllSelfTest.java | 301 +- .../cache/GridCacheClearLocalySelfTest.java | 336 ++ .../cache/GridCacheConcurrentMapSelfTest.java | 88 +- .../cache/GridCacheConcurrentMapTest.java | 15 +- .../GridCacheConcurrentTxMultiNodeTest.java | 50 +- ...idCacheConfigurationConsistencySelfTest.java | 20 +- .../GridCacheDaemonNodeAbstractSelfTest.java | 14 +- .../cache/GridCacheDeploymentSelfTest.java | 72 +- .../cache/GridCacheEntryMemorySizeSelfTest.java | 74 +- .../cache/GridCacheEntryVersionSelfTest.java | 6 +- .../GridCacheEvictionEventAbstractTest.java | 5 +- .../GridCacheExAbstractFullApiSelfTest.java | 6 +- .../GridCacheFieldsQueryNoDataSelfTest.java | 6 +- .../GridCacheFinishPartitionsSelfTest.java | 15 +- ...CacheFullTextQueryMultithreadedSelfTest.java | 7 +- .../cache/GridCacheGenericTestStore.java | 2 +- .../cache/GridCacheGlobalClearAllSelfTest.java | 167 - .../GridCacheGroupLockAbstractSelfTest.java | 1332 ------ ...heGroupLockFailoverOptimisticTxSelfTest.java | 28 - .../GridCacheGroupLockFailoverSelfTest.java | 532 --- ...CacheGroupLockMultiNodeAbstractSelfTest.java | 28 - .../cache/GridCacheGroupLockPutTask.java | 162 - .../GridCacheInterceptorAbstractSelfTest.java | 12 +- .../cache/GridCacheKeyCheckSelfTest.java | 7 +- .../processors/cache/GridCacheLeakTest.java | 5 +- .../cache/GridCacheLifecycleAwareSelfTest.java | 29 +- .../cache/GridCacheLuceneQueryIndexTest.java | 23 +- .../GridCacheMarshallerTxAbstractTest.java | 20 +- .../cache/GridCacheMemoryModeSelfTest.java | 2 +- ...GridCacheMixedPartitionExchangeSelfTest.java | 10 +- .../cache/GridCacheMultiUpdateLockSelfTest.java | 15 +- ...ridCacheMultinodeUpdateAbstractSelfTest.java | 2 +- .../cache/GridCacheMvccManagerSelfTest.java | 4 +- .../cache/GridCacheMvccPartitionedSelfTest.java | 2 +- .../cache/GridCacheNestedTxAbstractTest.java | 17 +- .../cache/GridCacheObjectToStringSelfTest.java | 21 +- ...HeapMultiThreadedUpdateAbstractSelfTest.java | 75 +- ...CacheOffHeapMultiThreadedUpdateSelfTest.java | 89 +- .../cache/GridCacheOffHeapSelfTest.java | 48 +- .../processors/cache/GridCacheOffHeapTest.java | 5 +- .../GridCacheOffHeapTieredAbstractSelfTest.java | 99 +- ...heOffHeapTieredEvictionAbstractSelfTest.java | 23 +- .../cache/GridCacheOffheapUpdateSelfTest.java | 32 +- .../GridCacheOrderedPreloadingSelfTest.java | 2 +- .../cache/GridCacheP2PUndeploySelfTest.java | 17 +- .../cache/GridCachePartitionedGetSelfTest.java | 28 +- .../cache/GridCachePartitionedWritesTest.java | 2 +- .../GridCachePreloadingEvictionsSelfTest.java | 23 +- .../cache/GridCachePutAllFailoverSelfTest.java | 11 +- .../cache/GridCacheQueryEmbeddedValue.java | 10 +- .../cache/GridCacheQueryIndexSelfTest.java | 10 +- .../GridCacheQueryIndexingDisabledSelfTest.java | 2 +- .../GridCacheQueryInternalKeysSelfTest.java | 4 +- .../GridCacheReferenceCleanupSelfTest.java | 37 +- .../cache/GridCacheReloadSelfTest.java | 4 +- ...ridCacheReplicatedSynchronousCommitTest.java | 6 +- .../cache/GridCacheSlowTxWarnTest.java | 7 +- .../processors/cache/GridCacheStopSelfTest.java | 9 +- .../cache/GridCacheStorePutxSelfTest.java | 5 +- .../cache/GridCacheStoreValueBytesSelfTest.java | 4 +- .../cache/GridCacheSwapPreloadSelfTest.java | 26 +- .../processors/cache/GridCacheTestEntryEx.java | 62 +- .../processors/cache/GridCacheTestStore.java | 39 +- .../processors/cache/GridCacheTestValue.java | 4 +- .../processors/cache/GridCacheTestValue2.java | 4 +- ...cheTransactionalAbstractMetricsSelfTest.java | 25 +- .../GridCacheValueBytesPreloadingSelfTest.java | 10 +- ...idCacheValueConsistencyAbstractSelfTest.java | 7 +- .../GridCacheVariableTopologySelfTest.java | 11 +- .../cache/GridCacheVersionMultinodeTest.java | 208 + .../GridCacheWriteBehindStoreAbstractTest.java | 8 +- ...BehindStorePartitionedMultiNodeSelfTest.java | 15 +- .../IgniteCacheAbstractStopBusySelfTest.java | 381 ++ .../IgniteCacheAtomicStopBusySelfTest.java | 59 + .../IgniteCacheContainsKeyAbstractSelfTest.java | 136 + .../IgniteCacheEntryListenerAbstractTest.java | 107 +- .../cache/IgniteCacheInvokeAbstractTest.java | 26 +- ...gniteCacheTransactionalStopBusySelfTest.java | 53 + .../IgniteClientAffinityAssignmentSelfTest.java | 165 + .../cache/IgnitePutAllLargeBatchSelfTest.java | 301 ++ ...tAllUpdateNonPreloadedPartitionSelfTest.java | 129 + .../processors/cache/IgniteTxAbstractTest.java | 55 +- .../IgniteTxConcurrentGetAbstractTest.java | 10 +- .../IgniteTxExceptionAbstractSelfTest.java | 117 +- .../cache/IgniteTxMultiNodeAbstractTest.java | 87 +- .../IgniteTxMultiThreadedAbstractTest.java | 21 +- .../cache/IgniteTxReentryAbstractSelfTest.java | 9 +- .../IgniteTxSingleThreadedAbstractTest.java | 4 +- .../IgniteTxStoreExceptionAbstractSelfTest.java | 76 +- ...IgniteCacheAbstractExecutionContextTest.java | 96 + .../IgniteCacheAtomicExecutionContextTest.java | 49 + ...niteCacheContinuousExecutionContextTest.java | 34 + ...IgniteCacheIsolatedExecutionContextTest.java | 34 + ...niteCacheP2PDisableExecutionContextTest.java | 34 + ...iteCachePartitionedExecutionContextTest.java | 49 + .../IgniteCachePrivateExecutionContextTest.java | 34 + ...niteCacheReplicatedExecutionContextTest.java | 49 + .../IgniteCacheSharedExecutionContextTest.java | 34 + .../IgniteCacheTxExecutionContextTest.java | 49 + ...eAbstractDataStructuresFailoverSelfTest.java | 26 +- .../GridCacheQueueCleanupSelfTest.java | 8 +- ...GridCacheQueueMultiNodeAbstractSelfTest.java | 1 + ...dCacheQueueMultiNodeConsistencySelfTest.java | 2 +- .../GridCacheSequenceApiSelfAbstractTest.java | 15 +- .../IgniteAtomicLongApiAbstractSelfTest.java | 2 +- .../IgniteDataStructureUniqueNameTest.java | 41 + ...idCachePartitionedNodeRestartTxSelfTest.java | 36 +- ...PartitionedQueueCreateMultiNodeSelfTest.java | 12 +- ...dCachePartitionedQueueEntryMoveSelfTest.java | 2 +- ...tractDistributedByteArrayValuesSelfTest.java | 58 +- .../GridCacheAbstractJobExecutionTest.java | 29 +- .../GridCacheAbstractNodeRestartSelfTest.java | 50 +- .../GridCacheAbstractPrimarySyncSelfTest.java | 11 +- .../GridCacheAtomicTimeoutSelfTest.java | 45 +- .../GridCacheBasicOpAbstractTest.java | 81 +- .../GridCacheClientModesAbstractSelfTest.java | 37 +- .../GridCacheEntrySetAbstractSelfTest.java | 21 +- ...acheEntrySetIterationPreloadingSelfTest.java | 8 +- .../distributed/GridCacheEventAbstractTest.java | 151 +- ...heExpiredEntriesPreloadAbstractSelfTest.java | 1 - .../distributed/GridCacheLockAbstractTest.java | 2 +- .../distributed/GridCacheMixedModeSelfTest.java | 5 +- .../GridCacheMultiNodeAbstractTest.java | 190 +- .../GridCacheMultiNodeLockAbstractTest.java | 33 +- ...dCacheMultithreadedFailoverAbstractTest.java | 28 +- .../GridCacheNodeFailureAbstractTest.java | 25 +- ...dCachePartitionedAffinityFilterSelfTest.java | 5 +- ...chePartitionedReloadAllAbstractSelfTest.java | 17 +- .../GridCachePreloadEventsAbstractSelfTest.java | 4 +- .../GridCachePreloadLifecycleAbstractTest.java | 1 + ...GridCachePreloadRestartAbstractSelfTest.java | 22 +- .../GridCacheTransformEventSelfTest.java | 20 +- .../IgniteCrossCacheTxStoreSelfTest.java | 46 +- ...iteTxConsistencyRestartAbstractSelfTest.java | 20 +- ...xOriginatingNodeFailureAbstractSelfTest.java | 14 +- ...cOriginatingNodeFailureAbstractSelfTest.java | 63 +- .../IgniteTxPreloadAbstractTest.java | 6 +- .../IgniteTxTimeoutAbstractTest.java | 23 +- ...tPartitionedOnlyByteArrayValuesSelfTest.java | 25 +- ...heAbstractTransformWriteThroughSelfTest.java | 8 +- .../dht/GridCacheAtomicNearCacheSelfTest.java | 42 +- .../dht/GridCacheColocatedDebugTest.java | 142 +- ...eColocatedOptimisticTransactionSelfTest.java | 21 +- ...ssimisticOriginatingNodeFailureSelfTest.java | 2 +- .../dht/GridCacheDhtEntrySelfTest.java | 48 +- ...GridCacheDhtEvictionNearReadersSelfTest.java | 6 +- .../dht/GridCacheDhtEvictionSelfTest.java | 11 +- .../GridCacheDhtEvictionsDisabledSelfTest.java | 4 +- .../dht/GridCacheDhtInternalEntrySelfTest.java | 23 +- .../dht/GridCacheDhtMappingSelfTest.java | 2 +- .../dht/GridCacheDhtMultiBackupTest.java | 7 +- .../dht/GridCacheDhtPreloadBigDataSelfTest.java | 14 +- .../dht/GridCacheDhtPreloadDelayedSelfTest.java | 42 +- .../GridCacheDhtPreloadDisabledSelfTest.java | 8 +- .../GridCacheDhtPreloadMessageCountTest.java | 14 +- .../dht/GridCacheDhtPreloadPutGetSelfTest.java | 56 +- .../dht/GridCacheDhtPreloadUnloadSelfTest.java | 22 +- .../GridCacheGroupLockColocatedSelfTest.java | 38 - ...acheGroupLockMultiNodeColocatedSelfTest.java | 29 - ...cheGroupLockPartitionedAbstractSelfTest.java | 136 - ...ockPartitionedMultiNodeAbstractSelfTest.java | 173 - ...ePartitionedNearDisabledMetricsSelfTest.java | 13 +- ...idCachePartitionedPreloadEventsSelfTest.java | 6 +- ...dCachePartitionedTopologyChangeSelfTest.java | 54 +- ...ridCachePartitionedUnloadEventsSelfTest.java | 8 +- ...IgniteCacheContainsKeyColocatedSelfTest.java | 36 + .../dht/IgniteTxReentryColocatedSelfTest.java | 5 +- ...eAtomicInvalidPartitionHandlingSelfTest.java | 7 +- .../atomic/GridCacheAtomicPreloadSelfTest.java | 22 +- ...GridCacheValueConsistencyAtomicSelfTest.java | 4 +- ...CacheContainsKeyColocatedAtomicSelfTest.java | 41 + ...gniteCacheContainsKeyNearAtomicSelfTest.java | 36 + ...unctionExcludeNeighborsAbstractSelfTest.java | 12 +- ...tomicClientOnlyMultiNodeFullApiSelfTest.java | 22 +- ...eAtomicNearOnlyMultiNodeFullApiSelfTest.java | 4 +- ...AtomicPartitionedTckMetricsSelfTestImpl.java | 6 +- .../near/GridCacheGetStoreErrorSelfTest.java | 9 +- ...GridCacheGroupLockMultiNodeNearSelfTest.java | 30 - .../near/GridCacheGroupLockNearSelfTest.java | 38 - .../near/GridCacheNearEvictionSelfTest.java | 20 +- .../near/GridCacheNearMetricsSelfTest.java | 201 +- .../near/GridCacheNearMultiGetSelfTest.java | 23 +- .../near/GridCacheNearMultiNodeSelfTest.java | 22 +- .../near/GridCacheNearOneNodeSelfTest.java | 10 +- ...idCacheNearOnlyMultiNodeFullApiSelfTest.java | 144 +- .../near/GridCacheNearOnlySelfTest.java | 11 +- .../near/GridCacheNearOnlyTopologySelfTest.java | 29 +- .../GridCacheNearPartitionedClearSelfTest.java | 19 +- .../GridCacheNearReaderPreloadSelfTest.java | 28 +- .../near/GridCacheNearReadersSelfTest.java | 16 +- .../near/GridCacheNearTxMultiNodeSelfTest.java | 31 +- ...ssimisticOriginatingNodeFailureSelfTest.java | 2 +- ...AffinityExcludeNeighborsPerformanceTest.java | 2 +- .../GridCachePartitionedAffinitySelfTest.java | 11 +- ...ePartitionedBasicStoreMultiNodeSelfTest.java | 6 +- .../GridCachePartitionedEvictionSelfTest.java | 8 +- ...GridCachePartitionedFilteredPutSelfTest.java | 3 +- .../GridCachePartitionedFullApiSelfTest.java | 172 +- ...idCachePartitionedHitsAndMissesSelfTest.java | 177 + .../GridCachePartitionedLoadCacheSelfTest.java | 10 +- ...achePartitionedMultiNodeCounterSelfTest.java | 52 +- ...achePartitionedMultiNodeFullApiSelfTest.java | 90 +- ...ePartitionedMultiThreadedPutGetSelfTest.java | 20 +- .../GridCachePartitionedNodeRestartTest.java | 2 +- ...ePartitionedOptimisticTxNodeRestartTest.java | 4 +- ...achePartitionedPreloadLifecycleSelfTest.java | 81 +- ...hePartitionedQueryMultiThreadedSelfTest.java | 17 +- .../GridCachePartitionedStorePutSelfTest.java | 20 +- .../GridCachePartitionedTxSalvageSelfTest.java | 12 +- .../near/GridCachePutArrayValueSelfTest.java | 14 +- ...idCacheRendezvousAffinityClientSelfTest.java | 5 +- .../IgniteCacheContainsKeyNearSelfTest.java | 31 + .../near/IgniteCacheNearReadCommittedTest.java | 68 + .../near/IgniteTxReentryNearSelfTest.java | 5 +- ...cheGroupLockMultiNodeReplicatedSelfTest.java | 45 - .../GridCacheGroupLockReplicatedSelfTest.java | 39 - .../GridCacheReplicatedEvictionSelfTest.java | 2 +- ...ReplicatedFullApiMultithreadedSelfTest1.java | 36 +- ...eReplicatedGetAndTransformStoreSelfTest.java | 8 +- .../GridCacheReplicatedInvalidateSelfTest.java | 10 +- ...ssimisticOriginatingNodeFailureSelfTest.java | 5 +- ...idCacheReplicatedUnswapAdvancedSelfTest.java | 13 +- .../GridCacheSyncReplicatedPreloadSelfTest.java | 17 +- ...CacheReplicatedPreloadLifecycleSelfTest.java | 95 +- .../GridCacheReplicatedPreloadSelfTest.java | 51 +- ...GridCacheReplicatedPreloadUndeploysTest.java | 4 +- .../GridCacheBatchEvictUnswapSelfTest.java | 10 +- ...heConcurrentEvictionConsistencySelfTest.java | 34 +- .../GridCacheConcurrentEvictionsSelfTest.java | 10 +- .../GridCacheDistributedEvictionsSelfTest.java | 20 +- .../GridCacheEmptyEntriesAbstractSelfTest.java | 58 +- .../eviction/GridCacheEvictionAbstractTest.java | 73 +- .../GridCacheEvictionFilterSelfTest.java | 29 +- .../GridCacheEvictionLockUnlockSelfTest.java | 2 +- .../GridCacheEvictionTouchSelfTest.java | 125 +- .../cache/eviction/GridCacheMockEntry.java | 287 +- .../GridCacheFifoEvictionPolicySelfTest.java | 14 +- .../lru/GridCacheLruEvictionPolicySelfTest.java | 15 +- .../GridCacheLruNearEvictionPolicySelfTest.java | 2 +- ...heNearOnlyLruNearEvictionPolicySelfTest.java | 2 +- .../GridCacheRandomEvictionPolicySelfTest.java | 25 +- ...iteCacheAtomicExpiryPolicyWithStoreTest.java | 49 + .../IgniteCacheExpiryPolicyAbstractTest.java | 218 +- .../IgniteCacheExpiryPolicyTestSuite.java | 3 + ...eCacheExpiryPolicyWithStoreAbstractTest.java | 236 ++ .../IgniteCacheTxExpiryPolicyWithStoreTest.java | 43 + ...iteCacheNoLoadPreviousValueAbstractTest.java | 16 +- .../IgniteCacheNoReadThroughAbstractTest.java | 15 +- .../IgniteCacheNoWriteThroughAbstractTest.java | 19 +- .../IgniteCacheStoreSessionAbstractTest.java | 30 +- .../IgniteCacheTxStoreSessionTest.java | 32 +- ...dCacheAtomicLocalTckMetricsSelfTestImpl.java | 4 +- .../GridCacheLocalByteArrayValuesSelfTest.java | 33 +- .../local/GridCacheLocalLoadAllSelfTest.java | 2 +- .../local/GridCacheLocalTxTimeoutSelfTest.java | 30 +- .../GridCacheSwapScanQueryAbstractSelfTest.java | 57 +- ...ridCacheContinuousQueryAbstractSelfTest.java | 945 +---- ...dCacheContinuousQueryReplicatedSelfTest.java | 95 +- ...dCacheAbstractReduceFieldsQuerySelfTest.java | 29 +- ...cheReduceFieldsQueryPartitionedSelfTest.java | 5 +- .../dataload/GridDataLoaderImplSelfTest.java | 2 +- .../dataload/GridDataLoaderPerformanceTest.java | 19 +- .../GridDataLoaderProcessorSelfTest.java | 180 +- ...heGgfsPerBlockLruEvictionPolicySelfTest.java | 483 --- .../processors/fs/GridGgfsAbstractSelfTest.java | 2452 ----------- .../fs/GridGgfsAttributesSelfTest.java | 75 - .../processors/fs/GridGgfsCacheSelfTest.java | 133 - .../fs/GridGgfsCommonAbstractTest.java | 67 - .../fs/GridGgfsDataManagerSelfTest.java | 600 --- .../fs/GridGgfsDualAbstractSelfTest.java | 1601 -------- .../fs/GridGgfsDualAsyncSelfTest.java | 32 - .../processors/fs/GridGgfsDualSyncSelfTest.java | 32 - .../processors/fs/GridGgfsFileInfoSelfTest.java | 88 - .../processors/fs/GridGgfsFileMapSelfTest.java | 337 -- ...GgfsGroupDataBlockKeyMapperHashSelfTest.java | 136 - .../fs/GridGgfsMetaManagerSelfTest.java | 475 --- .../processors/fs/GridGgfsMetricsSelfTest.java | 536 --- .../fs/GridGgfsModeResolverSelfTest.java | 77 - .../processors/fs/GridGgfsModesSelfTest.java | 602 --- .../GridGgfsPrimaryOffheapTieredSelfTest.java | 33 - .../GridGgfsPrimaryOffheapValuesSelfTest.java | 33 - .../processors/fs/GridGgfsPrimarySelfTest.java | 32 - .../fs/GridGgfsProcessorSelfTest.java | 977 ----- .../fs/GridGgfsProcessorValidationSelfTest.java | 535 --- ...IpcEndpointRegistrationAbstractSelfTest.java | 185 - ...dpointRegistrationOnLinuxAndMacSelfTest.java | 50 - ...pcEndpointRegistrationOnWindowsSelfTest.java | 53 - .../processors/fs/GridGgfsSizeSelfTest.java | 875 ---- .../processors/fs/GridGgfsStreamsSelfTest.java | 472 --- .../processors/fs/GridGgfsTaskSelfTest.java | 311 -- .../processors/fs/GridGgfsTestInputStream.java | 66 - .../ignite/internal/processors/fs/package.html | 24 - .../GridGgfsAbstractRecordResolverSelfTest.java | 186 - ...GgfsByteDelimiterRecordResolverSelfTest.java | 335 -- ...idGgfsFixedLengthRecordResolverSelfTest.java | 147 - ...sNewLineDelimiterRecordResolverSelfTest.java | 129 - ...fsStringDelimiterRecordResolverSelfTest.java | 137 - ...heIgfsPerBlockLruEvictionPolicySelfTest.java | 485 +++ .../processors/igfs/IgfsAbstractSelfTest.java | 2453 +++++++++++ .../processors/igfs/IgfsAttributesSelfTest.java | 75 + .../processors/igfs/IgfsCacheSelfTest.java | 134 + .../processors/igfs/IgfsCommonAbstractTest.java | 67 + .../igfs/IgfsDataManagerSelfTest.java | 600 +++ .../igfs/IgfsDualAbstractSelfTest.java | 1601 ++++++++ .../processors/igfs/IgfsDualAsyncSelfTest.java | 32 + .../processors/igfs/IgfsDualSyncSelfTest.java | 32 + .../processors/igfs/IgfsFileInfoSelfTest.java | 88 + .../processors/igfs/IgfsFileMapSelfTest.java | 337 ++ ...IgfsGroupDataBlockKeyMapperHashSelfTest.java | 136 + .../igfs/IgfsMetaManagerSelfTest.java | 475 +++ .../processors/igfs/IgfsMetricsSelfTest.java | 536 +++ .../igfs/IgfsModeResolverSelfTest.java | 77 + .../processors/igfs/IgfsModesSelfTest.java | 604 +++ .../igfs/IgfsPrimaryOffheapTieredSelfTest.java | 33 + .../igfs/IgfsPrimaryOffheapValuesSelfTest.java | 33 + .../processors/igfs/IgfsPrimarySelfTest.java | 32 + .../processors/igfs/IgfsProcessorSelfTest.java | 978 +++++ .../igfs/IgfsProcessorValidationSelfTest.java | 535 +++ ...IpcEndpointRegistrationAbstractSelfTest.java | 185 + ...dpointRegistrationOnLinuxAndMacSelfTest.java | 50 + ...pcEndpointRegistrationOnWindowsSelfTest.java | 53 + .../processors/igfs/IgfsSizeSelfTest.java | 875 ++++ .../processors/igfs/IgfsStreamsSelfTest.java | 472 +++ .../processors/igfs/IgfsTaskSelfTest.java | 311 ++ .../processors/igfs/IgfsTestInputStream.java | 66 + .../internal/processors/igfs/package.html | 24 + .../IgfsAbstractRecordResolverSelfTest.java | 186 + ...IgfsByteDelimiterRecordResolverSelfTest.java | 335 ++ .../IgfsFixedLengthRecordResolverSelfTest.java | 147 + ...sNewLineDelimiterRecordResolverSelfTest.java | 129 + ...fsStringDelimiterRecordResolverSelfTest.java | 137 + .../cache/GridCacheCommandHandlerSelfTest.java | 6 +- .../GridServiceProcessorAbstractSelfTest.java | 10 +- .../GridServiceProcessorMultiNodeSelfTest.java | 2 +- .../product/GridProductVersionSelfTest.java | 36 +- ...dStartupWithUndefinedIgniteHomeSelfTest.java | 105 - .../internal/util/GridTestClockTimer.java | 2 - .../util/future/GridFinishedFutureSelfTest.java | 2 +- .../IpcServerEndpointDeserializerSelfTest.java | 4 +- .../ipc/shmem/GgfsSharedMemoryTestClient.java | 76 - .../ipc/shmem/GgfsSharedMemoryTestServer.java | 71 - .../ipc/shmem/IgfsSharedMemoryTestClient.java | 76 + .../ipc/shmem/IgfsSharedMemoryTestServer.java | 71 + .../IpcSharedMemoryCrashDetectionSelfTest.java | 24 +- .../ipc/shmem/IpcSharedMemoryNodeStartup.java | 12 +- .../apache/ignite/lang/GridFuncSelfTest.java | 3254 --------------- .../loadtests/GridCacheMultiNodeLoadTest.java | 2 - .../cache/GridCacheAbstractLoadTest.java | 21 +- ...ridCacheAffinityTransactionsOffHeapTest.java | 258 -- .../loadtests/cache/GridCacheBenchmark.java | 6 +- .../cache/GridCacheDataStructuresLoadTest.java | 7 +- .../cache/GridCacheGroupLockComparisonTest.java | 203 - .../loadtests/cache/GridCacheLoadTest.java | 26 +- .../cache/GridCachePutRemoveLoadTest.java | 8 +- .../cache/GridCacheSingleNodeLoadTest.java | 6 +- .../loadtests/cache/GridCacheSwapLoadTest.java | 10 +- .../capacity/GridCapacityLoadTest.java | 2 +- .../colocation/GridTestCacheStore.java | 7 +- .../loadtests/colocation/GridTestMain.java | 12 +- .../GridTcpCommunicationBenchmark.java | 2 +- .../communication/GridTestMessage.java | 13 +- .../GridContinuousOperationsLoadTest.java | 54 +- .../GridCachePartitionedAtomicLongLoadTest.java | 8 +- .../ignite/loadtests/dsi/GridDsiClient.java | 4 +- .../ignite/loadtests/dsi/GridDsiPerfJob.java | 25 +- .../cacheget/GridBenchmarkCacheGetLoadTest.java | 1 - .../loadtests/hashmap/GridCacheTestContext.java | 4 +- .../mapper/GridContinuousMapperTask1.java | 3 +- .../mapper/GridContinuousMapperTask2.java | 3 +- .../ignite/loadtests/mapper/TestObject.java | 6 +- .../swap/GridSwapEvictAllBenchmark.java | 10 +- .../marshaller/GridMarshallerAbstractTest.java | 81 +- .../marshaller/GridMarshallerResourceBean.java | 2 +- .../marshaller/GridMarshallerTestBean.java | 2 +- .../p2p/GridAbstractMultinodeRedeployTest.java | 27 +- .../spi/GridTcpSpiForwardingSelfTest.java | 1 + .../CacheCheckpointSpiSecondCacheSelfTest.java | 14 +- .../GridFifoQueueCollisionSpiSelfTest.java | 12 +- .../GridPriorityQueueCollisionSpiSelfTest.java | 2 + .../spi/communication/GridTestMessage.java | 48 +- .../discovery/AbstractDiscoverySelfTest.java | 7 +- ...ClusterMetricsSnapshotSerializeSelfTest.java | 6 +- .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 2 + .../tcp/TcpDiscoverySnapshotHistoryTest.java | 1 + .../tcp/TcpDiscoverySpiStartStopSelfTest.java | 7 +- .../GridCacheStoreValueBytesTest.java | 16 +- .../ignite/testframework/GridTestUtils.java | 19 +- .../testframework/junits/GridAbstractTest.java | 12 +- .../junits/GridTestKernalContext.java | 3 +- .../ignite/testframework/junits/IgniteMock.java | 20 +- .../cache/GridAbstractCacheStoreSelfTest.java | 18 +- .../junits/cache/TestCacheSession.java | 6 +- .../cache/TestThreadLocalCacheSession.java | 4 +- .../GridAbstractLifecycleAwareSelfTest.java | 6 +- .../junits/common/GridCommonAbstractTest.java | 73 +- .../junits/logger/GridTestLog4jLogger.java | 3 - .../junits/spi/GridSpiAbstractTest.java | 93 +- .../ignite/testsuites/IgniteBasicTestSuite.java | 1 - .../IgniteCacheDataStructuresSelfTestSuite.java | 3 +- .../IgniteCacheGroupLockSelfTestSuite.java | 48 - .../IgniteCacheMetricsSelfTestSuite.java | 21 +- .../testsuites/IgniteCacheRestartTestSuite.java | 2 +- .../ignite/testsuites/IgniteCacheTestSuite.java | 40 +- .../testsuites/IgniteComputeGridTestSuite.java | 1 + .../ignite/testsuites/IgniteFsTestSuite.java | 79 - .../ignite/testsuites/IgniteIgfsTestSuite.java | 79 + .../testsuites/IgniteKernalSelfTestSuite.java | 1 - .../testsuites/IgniteLangSelfTestSuite.java | 2 - .../core/src/test/webapp/META-INF/gg-config.xml | 345 -- .../webapp/META-INF/ignite-webapp-config.xml | 349 ++ modules/core/src/test/webapp/WEB-INF/web.xml | 6 +- modules/email/licenses/apache-2.0.txt | 202 - modules/email/pom.xml | 51 - modules/email/readme.txt | 34 - .../processors/email/IgniteEmailProcessor.java | 296 -- modules/extdata/p2p/pom.xml | 6 + .../tests/p2p/CacheDeploymentTestValue.java | 2 +- .../query/h2/GridH2IndexingGeoSelfTest.java | 15 +- modules/hadoop/pom.xml | 6 + modules/hadoop/readme.txt | 2 +- .../client/hadoop/GridHadoopClientProtocol.java | 2 +- .../GridHadoopClientProtocolProvider.java | 6 +- .../igfs/hadoop/IgfsHadoopParameters.java | 94 + .../org/apache/ignite/igfs/hadoop/package.html | 24 + .../igfs/hadoop/v1/IgfsHadoopFileSystem.java | 1253 ++++++ .../apache/ignite/igfs/hadoop/v1/package.html | 24 + .../igfs/hadoop/v2/IgfsHadoopFileSystem.java | 1007 +++++ .../apache/ignite/igfs/hadoop/v2/package.html | 24 + .../java/org/apache/ignite/igfs/package.html | 24 + .../hadoop/GridGgfsHadoopParameters.java | 94 - .../apache/ignite/ignitefs/hadoop/package.html | 24 - .../hadoop/v1/GridGgfsHadoopFileSystem.java | 1253 ------ .../ignite/ignitefs/hadoop/v1/package.html | 24 - .../hadoop/v2/GridGgfsHadoopFileSystem.java | 1007 ----- .../ignite/ignitefs/hadoop/v2/package.html | 24 - .../org/apache/ignite/ignitefs/package.html | 24 - .../internal/fs/hadoop/GridGgfsHadoop.java | 198 - .../GridGgfsHadoopCommunicationException.java | 57 - .../fs/hadoop/GridGgfsHadoopEndpoint.java | 210 - .../internal/fs/hadoop/GridGgfsHadoopEx.java | 88 - .../fs/hadoop/GridGgfsHadoopFSProperties.java | 88 - .../hadoop/GridGgfsHadoopFileSystemWrapper.java | 413 -- .../fs/hadoop/GridGgfsHadoopFuture.java | 94 - .../fs/hadoop/GridGgfsHadoopInProc.java | 409 -- .../fs/hadoop/GridGgfsHadoopInputStream.java | 626 --- .../internal/fs/hadoop/GridGgfsHadoopIo.java | 76 - .../internal/fs/hadoop/GridGgfsHadoopIpcIo.java | 599 --- .../fs/hadoop/GridGgfsHadoopIpcIoListener.java | 36 - .../fs/hadoop/GridGgfsHadoopJclLogger.java | 115 - .../fs/hadoop/GridGgfsHadoopOutProc.java | 466 --- .../fs/hadoop/GridGgfsHadoopOutputStream.java | 201 - .../hadoop/GridGgfsHadoopProxyInputStream.java | 335 -- .../hadoop/GridGgfsHadoopProxyOutputStream.java | 165 - .../fs/hadoop/GridGgfsHadoopReader.java | 104 - .../fs/hadoop/GridGgfsHadoopStreamDelegate.java | 96 - .../GridGgfsHadoopStreamEventListener.java | 39 - .../internal/fs/hadoop/GridGgfsHadoopUtils.java | 131 - .../fs/hadoop/GridGgfsHadoopWrapper.java | 511 --- .../ignite/internal/fs/hadoop/package.html | 24 - .../org/apache/ignite/internal/fs/package.html | 24 - .../ignite/internal/igfs/hadoop/IgfsHadoop.java | 198 + .../IgfsHadoopCommunicationException.java | 57 + .../igfs/hadoop/IgfsHadoopEndpoint.java | 210 + .../internal/igfs/hadoop/IgfsHadoopEx.java | 88 + .../igfs/hadoop/IgfsHadoopFSProperties.java | 88 + .../hadoop/IgfsHadoopFileSystemWrapper.java | 413 ++ .../internal/igfs/hadoop/IgfsHadoopFuture.java | 94 + .../internal/igfs/hadoop/IgfsHadoopInProc.java | 409 ++ .../igfs/hadoop/IgfsHadoopInputStream.java | 626 +++ .../internal/igfs/hadoop/IgfsHadoopIo.java | 76 + .../internal/igfs/hadoop/IgfsHadoopIpcIo.java | 599 +++ .../igfs/hadoop/IgfsHadoopIpcIoListener.java | 36 + .../igfs/hadoop/IgfsHadoopJclLogger.java | 112 + .../internal/igfs/hadoop/IgfsHadoopOutProc.java | 466 +++ .../igfs/hadoop/IgfsHadoopOutputStream.java | 201 + .../igfs/hadoop/IgfsHadoopProxyInputStream.java | 335 ++ .../hadoop/IgfsHadoopProxyOutputStream.java | 165 + .../internal/igfs/hadoop/IgfsHadoopReader.java | 104 + .../igfs/hadoop/IgfsHadoopStreamDelegate.java | 96 + .../hadoop/IgfsHadoopStreamEventListener.java | 39 + .../internal/igfs/hadoop/IgfsHadoopUtils.java | 131 + .../internal/igfs/hadoop/IgfsHadoopWrapper.java | 511 +++ .../ignite/internal/igfs/hadoop/package.html | 24 + .../apache/ignite/internal/igfs/package.html | 24 + .../hadoop/GridHadoopClassLoader.java | 10 +- .../processors/hadoop/GridHadoopSetup.java | 4 +- .../fs/GridHadoopDistributedFileSystem.java | 2 +- .../hadoop/fs/GridHadoopFileSystemsUtils.java | 6 +- .../hadoop/jobtracker/GridHadoopJobTracker.java | 33 +- .../GridHadoopDefaultMapReducePlanner.java | 28 +- .../GridHadoopExternalCommunication.java | 3 +- .../hadoop/v2/GridHadoopV2TaskContext.java | 4 +- .../GridHadoopClientProtocolSelfTest.java | 40 +- .../apache/ignite/igfs/IgfsEventsTestSuite.java | 267 ++ .../IgfsHadoop20FileSystemAbstractSelfTest.java | 1967 +++++++++ ...doop20FileSystemLoopbackPrimarySelfTest.java | 74 + ...sHadoop20FileSystemShmemPrimarySelfTest.java | 74 + .../igfs/IgfsHadoopDualAbstractSelfTest.java | 304 ++ .../igfs/IgfsHadoopDualAsyncSelfTest.java | 32 + .../ignite/igfs/IgfsHadoopDualSyncSelfTest.java | 32 + .../IgfsHadoopFileSystemAbstractSelfTest.java | 2365 +++++++++++ .../IgfsHadoopFileSystemClientSelfTest.java | 199 + .../IgfsHadoopFileSystemHandshakeSelfTest.java | 311 ++ .../IgfsHadoopFileSystemIpcCacheSelfTest.java | 207 + .../IgfsHadoopFileSystemLoggerSelfTest.java | 287 ++ ...IgfsHadoopFileSystemLoggerStateSelfTest.java | 325 ++ ...adoopFileSystemLoopbackAbstractSelfTest.java | 46 + ...SystemLoopbackEmbeddedDualAsyncSelfTest.java | 33 + ...eSystemLoopbackEmbeddedDualSyncSelfTest.java | 33 + ...leSystemLoopbackEmbeddedPrimarySelfTest.java | 33 + ...SystemLoopbackEmbeddedSecondarySelfTest.java | 34 + ...SystemLoopbackExternalDualAsyncSelfTest.java | 33 + ...eSystemLoopbackExternalDualSyncSelfTest.java | 33 + ...leSystemLoopbackExternalPrimarySelfTest.java | 33 + ...SystemLoopbackExternalSecondarySelfTest.java | 34 + ...fsHadoopFileSystemSecondaryModeSelfTest.java | 319 ++ ...fsHadoopFileSystemShmemAbstractSelfTest.java | 88 + ...ileSystemShmemEmbeddedDualAsyncSelfTest.java | 33 + ...FileSystemShmemEmbeddedDualSyncSelfTest.java | 33 + ...pFileSystemShmemEmbeddedPrimarySelfTest.java | 33 + ...ileSystemShmemEmbeddedSecondarySelfTest.java | 33 + ...ileSystemShmemExternalDualAsyncSelfTest.java | 33 + ...FileSystemShmemExternalDualSyncSelfTest.java | 33 + ...pFileSystemShmemExternalPrimarySelfTest.java | 33 + ...ileSystemShmemExternalSecondarySelfTest.java | 33 + .../java/org/apache/ignite/igfs/IgfsLoad.java | 549 +++ .../igfs/IgfsNearOnlyMultiNodeSelfTest.java | 212 + .../ignite/ignitefs/GridFileSystemLoad.java | 549 --- ...dGgfsHadoop20FileSystemAbstractSelfTest.java | 1967 --------- ...doop20FileSystemLoopbackPrimarySelfTest.java | 74 - ...sHadoop20FileSystemShmemPrimarySelfTest.java | 74 - .../GridGgfsHadoopDualAbstractSelfTest.java | 303 -- .../GridGgfsHadoopDualAsyncSelfTest.java | 32 - .../GridGgfsHadoopDualSyncSelfTest.java | 32 - ...ridGgfsHadoopFileSystemAbstractSelfTest.java | 2365 ----------- .../GridGgfsHadoopFileSystemClientSelfTest.java | 199 - ...idGgfsHadoopFileSystemHandshakeSelfTest.java | 309 -- ...ridGgfsHadoopFileSystemIpcCacheSelfTest.java | 207 - .../GridGgfsHadoopFileSystemLoggerSelfTest.java | 287 -- ...GgfsHadoopFileSystemLoggerStateSelfTest.java | 324 -- ...adoopFileSystemLoopbackAbstractSelfTest.java | 46 - ...SystemLoopbackEmbeddedDualAsyncSelfTest.java | 33 - ...eSystemLoopbackEmbeddedDualSyncSelfTest.java | 33 - ...leSystemLoopbackEmbeddedPrimarySelfTest.java | 33 - ...SystemLoopbackEmbeddedSecondarySelfTest.java | 34 - ...SystemLoopbackExternalDualAsyncSelfTest.java | 33 - ...eSystemLoopbackExternalDualSyncSelfTest.java | 33 - ...leSystemLoopbackExternalPrimarySelfTest.java | 33 - ...SystemLoopbackExternalSecondarySelfTest.java | 34 - ...fsHadoopFileSystemSecondaryModeSelfTest.java | 319 -- ...fsHadoopFileSystemShmemAbstractSelfTest.java | 88 - ...ileSystemShmemEmbeddedDualAsyncSelfTest.java | 33 - ...FileSystemShmemEmbeddedDualSyncSelfTest.java | 33 - ...pFileSystemShmemEmbeddedPrimarySelfTest.java | 33 - ...ileSystemShmemEmbeddedSecondarySelfTest.java | 33 - ...ileSystemShmemExternalDualAsyncSelfTest.java | 33 - ...FileSystemShmemExternalDualSyncSelfTest.java | 33 - ...pFileSystemShmemExternalPrimarySelfTest.java | 33 - ...ileSystemShmemExternalSecondarySelfTest.java | 33 - .../GridGgfsNearOnlyMultiNodeSelfTest.java | 212 - .../ignitefs/IgniteFsEventsTestSuite.java | 267 -- .../hadoop/GridHadoopAbstractSelfTest.java | 83 +- .../hadoop/GridHadoopAbstractWordCountTest.java | 16 +- .../hadoop/GridHadoopCommandLineTest.java | 28 +- ...idHadoopDefaultMapReducePlannerSelfTest.java | 166 +- .../hadoop/GridHadoopFileSystemsTest.java | 8 +- .../hadoop/GridHadoopGroupingTest.java | 2 +- .../hadoop/GridHadoopJobTrackerSelfTest.java | 6 +- .../GridHadoopMapReduceEmbeddedSelfTest.java | 14 +- .../hadoop/GridHadoopMapReduceTest.java | 20 +- .../hadoop/GridHadoopSortingTest.java | 14 +- .../processors/hadoop/GridHadoopStartup.java | 7 +- .../hadoop/GridHadoopTaskExecutionSelfTest.java | 38 +- .../hadoop/GridHadoopTasksAllVersionsTest.java | 34 +- ...GridHadoopExternalTaskExecutionSelfTest.java | 16 +- .../loadtests/ggfs/GridGgfsNodeStartup.java | 49 - .../ggfs/GridGgfsPerformanceBenchmark.java | 274 -- .../ignite/loadtests/igfs/IgfsNodeStartup.java | 49 + .../igfs/IgfsPerformanceBenchmark.java | 274 ++ .../IgniteFsLinuxAndMacOSTestSuite.java | 63 - .../testsuites/IgniteHadoopTestSuite.java | 36 +- .../IgniteIgfsLinuxAndMacOSTestSuite.java | 63 + modules/hibernate/pom.xml | 6 + .../GridHibernateAccessStrategyAdapter.java | 5 +- .../GridHibernateReadWriteAccessStrategy.java | 8 +- .../hibernate/GridHibernateRegionFactory.java | 7 +- .../hibernate/CacheHibernateBlobStore.java | 35 +- ...idHibernateL2CacheConfigurationSelfTest.java | 39 +- .../hibernate/GridHibernateL2CacheSelfTest.java | 3 +- modules/indexing/pom.xml | 6 + .../processors/query/h2/IgniteH2Indexing.java | 132 +- .../query/h2/opt/GridH2IndexBase.java | 6 +- .../query/h2/opt/GridH2TreeIndex.java | 2 +- .../query/h2/opt/GridLuceneIndex.java | 15 +- .../query/h2/twostep/GridMapQueryExecutor.java | 2 +- .../GridCacheAbstractFieldsQuerySelfTest.java | 64 +- .../cache/GridCacheAbstractQuerySelfTest.java | 119 +- .../cache/GridCacheCrossCacheQuerySelfTest.java | 40 +- .../GridCacheCrossCacheQuerySelfTestNewApi.java | 411 ++ .../cache/GridCacheOffHeapAndSwapSelfTest.java | 23 +- .../cache/GridCacheQueryLoadSelfTest.java | 79 +- .../cache/GridCacheQueryMetricsSelfTest.java | 5 +- .../GridCacheQueryMultiThreadedSelfTest.java | 34 +- .../cache/GridCacheQueryTestValue.java | 20 +- ...idCacheReduceQueryMultithreadedSelfTest.java | 2 +- .../GridCacheSqlQueryMultiThreadedSelfTest.java | 8 +- .../processors/cache/GridCacheSwapSelfTest.java | 48 +- .../cache/GridIndexingWithNoopSwapSelfTest.java | 5 +- .../GridCacheAtomicFieldsQuerySelfTest.java | 5 +- ...rtitionedFieldsQueryP2PDisabledSelfTest.java | 34 - ...artitionedFieldsQueryP2PEnabledSelfTest.java | 34 + ...GridCachePartitionedFieldsQuerySelfTest.java | 5 +- ...idCachePartitionedHitsAndMissesSelfTest.java | 177 - ...achePartitionedQueryP2PDisabledSelfTest.java | 34 - ...CachePartitionedQueryP2PEnabledSelfTest.java | 34 + .../near/GridCachePartitionedQuerySelfTest.java | 32 +- .../near/GridCacheQueryNodeRestartSelfTest.java | 4 +- ...eplicatedFieldsQueryP2PDisabledSelfTest.java | 34 - ...eReplicatedFieldsQueryP2PEnableSelfTest.java | 34 + .../GridCacheReplicatedFieldsQuerySelfTest.java | 6 +- ...CacheReplicatedQueryP2PDisabledSelfTest.java | 34 - ...dCacheReplicatedQueryP2PEnabledSelfTest.java | 34 + .../GridCacheReplicatedQuerySelfTest.java | 20 +- .../local/GridCacheLocalQuerySelfTest.java | 7 +- .../query/h2/GridH2IndexRebuildTest.java | 41 +- .../query/h2/sql/GridQueryParsingTest.java | 19 +- .../loadtests/h2indexing/GridTestEntity.java | 6 +- .../tcp/GridOrderedMessageCancelSelfTest.java | 3 +- .../IgniteCacheQuerySelfTestSuite.java | 9 +- .../IgniteH2IndexingSpiTestSuite.java | 2 - .../ignite/logger/jcl/IgniteJclLogger.java | 3 - .../jdk8-backport/licenses/sun-bcl-license.txt | 50 - modules/jdk8-backport/pom.xml | 36 - .../org/jdk8/backport/ConcurrentHashMap8.java | 3825 ------------------ .../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 -- .../META-INF/licenses/gnu-gplv2ce-license.txt | 349 -- modules/jta/pom.xml | 6 + .../cache/jta/GridCacheXAResource.java | 4 +- .../processors/cache/GridCacheJtaSelfTest.java | 6 +- .../IgniteLog4jDailyRollingFileAppender.java | 77 - ...IgniteLog4jExternallyRolledFileAppender.java | 63 - .../logger/log4j/IgniteLog4jFileAppender.java | 107 - .../logger/log4j/IgniteLog4jFileAware.java | 32 - .../logger/log4j/IgniteLog4jNodeIdFilePath.java | 64 - .../log4j/IgniteLog4jRollingFileAppender.java | 90 - .../log4j/Log4JDailyRollingFileAppender.java | 77 + .../Log4JExternallyRolledFileAppender.java | 63 + .../ignite/logger/log4j/Log4JFileAppender.java | 107 + .../apache/ignite/logger/log4j/Log4JLogger.java | 12 +- .../ignite/logger/log4j/Log4jFileAware.java | 32 + .../logger/log4j/Log4jNodeIdFilePath.java | 64 + .../logger/log4j/Log4jRollingFileAppender.java | 90 + .../log4j/GridLog4jCorrectFileNameTest.java | 13 +- .../http/jetty/GridJettyRestHandler.java | 2 +- .../http/jetty/GridJettyRestProtocol.java | 6 +- modules/scalar/pom.xml | 21 +- .../ignite/scalar/ScalarConversions.scala | 45 +- .../ignite/scalar/pimps/ScalarCachePimp.scala | 662 ++- .../pimps/ScalarCacheProjectionPimp.scala | 2002 --------- .../scala/org/apache/ignite/scalar/scalar.scala | 35 +- .../tests/ScalarAffinityRoutingSpec.scala | 12 +- .../tests/ScalarCacheProjectionSpec.scala | 39 - .../scalar/tests/ScalarCacheQueriesSpec.scala | 466 +-- .../ignite/scalar/tests/ScalarCacheSpec.scala | 10 +- .../processors/schedule/ScheduleFutureImpl.java | 3 - .../schema-load/src/main/java/media/style.css | 5 + .../apache/ignite/schema/model/PojoField.java | 6 +- .../org/apache/ignite/schema/ui/MessageBox.java | 8 +- .../apache/ignite/schema/ui/SchemaLoadApp.java | 88 +- .../ignite/logger/slf4j/GridSlf4jLogger.java | 3 - modules/spring/pom.xml | 6 + .../org/apache/ignite/IgniteSpringBean.java | 31 +- .../apache/ignite/cache/spring/SpringCache.java | 2 +- .../ignite/cache/spring/SpringCacheManager.java | 5 +- .../cache/spring/SpringDynamicCacheManager.java | 22 +- .../ignite/internal/GridFactorySelfTest.java | 9 + .../GridSpringBeanSerializationSelfTest.java | 2 + .../p2p/GridP2PUserVersionChangeSelfTest.java | 23 +- .../spring/GridSpringCacheManagerSelfTest.java | 23 +- .../GridSpringDynamicCacheManagerSelfTest.java | 11 +- .../optimized/OptimizedClassNamesGenerator.java | 2 +- modules/visor-console/pom.xml | 21 +- .../ignite/visor/commands/VisorConsole.scala | 27 +- .../visor/commands/ack/VisorAckCommand.scala | 4 +- .../commands/alert/VisorAlertCommand.scala | 97 +- .../commands/cache/VisorCacheClearCommand.scala | 17 +- .../commands/cache/VisorCacheCommand.scala | 33 +- .../cache/VisorCacheCompactCommand.scala | 4 +- .../commands/cache/VisorCacheScanCommand.scala | 8 +- .../commands/cache/VisorCacheSwapCommand.scala | 4 +- .../config/VisorConfigurationCommand.scala | 43 +- .../commands/deploy/VisorDeployCommand.scala | 11 +- .../commands/disco/VisorDiscoveryCommand.scala | 27 +- .../commands/events/VisorEventsCommand.scala | 39 +- .../visor/commands/gc/VisorGcCommand.scala | 6 +- .../visor/commands/kill/VisorKillCommand.scala | 10 +- .../visor/commands/node/VisorNodeCommand.scala | 18 +- .../visor/commands/ping/VisorPingCommand.scala | 4 +- .../commands/start/VisorStartCommand.scala | 13 +- .../commands/tasks/VisorTasksCommand.scala | 38 +- .../commands/top/VisorTopologyCommand.scala | 29 +- .../visor/commands/vvm/VisorVvmCommand.scala | 28 +- .../scala/org/apache/ignite/visor/visor.scala | 86 +- .../commands/alert/VisorAlertCommandSpec.scala | 1 - .../cache/VisorCacheClearCommandSpec.scala | 20 +- .../commands/cache/VisorCacheCommandSpec.scala | 85 +- .../cache/VisorCacheCompactCommandSpec.scala | 12 +- .../config/VisorConfigurationCommandSpec.scala | 1 - .../cswap/VisorCacheSwapCommandSpec.scala | 8 +- .../disco/VisorDiscoveryCommandSpec.scala | 1 - .../events/VisorEventsCommandSpec.scala | 1 - .../visor/commands/gc/VisorGcCommandSpec.scala | 1 - .../commands/tasks/VisorTasksCommandSpec.scala | 4 +- modules/web/pom.xml | 6 + .../ignite/cache/websession/GridWebSession.java | 286 -- .../cache/websession/GridWebSessionFilter.java | 466 --- .../websession/GridWebSessionListener.java | 196 - .../cache/websession/IgniteWebSession.java | 286 ++ .../websession/IgniteWebSessionFilter.java | 466 +++ .../websession/IgniteWebSessionListener.java | 196 + .../internal/websession/WebSessionSelfTest.java | 12 +- .../websession/WebSessionServerStart.java | 2 +- .../internal/websession/WebSessionTest.java | 2 +- .../config/benchmark-multicast.properties | 2 +- modules/yardstick/config/ignite-base-config.xml | 2 + .../yardstick/config/ignite-store-config.xml | 2 + .../yardstick/IgniteBenchmarkArguments.java | 8 +- .../org/apache/ignite/yardstick/IgniteNode.java | 8 +- .../cache/IgnitePutGetTxBenchmark.java | 2 +- .../cache/IgniteSqlQueryBenchmark.java | 20 +- .../cache/IgniteSqlQueryJoinBenchmark.java | 24 +- .../cache/IgniteSqlQueryPutBenchmark.java | 20 +- .../yardstick/cache/model/Organization.java | 6 +- .../ignite/yardstick/cache/model/Person.java | 12 +- pom.xml | 539 ++- 2033 files changed, 124932 insertions(+), 145471 deletions(-) ----------------------------------------------------------------------
