Merge branch 'sprint-2' of
https://git-wip-us.apache.org/repos/asf/incubator-ignite into ignite-sql-tests
Conflicts:
examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java
examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/CacheStarSchemaExample.java
examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimProduct.java
examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimStore.java
examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/FactPurchase.java
modules/clients/src/test/java/org/apache/ignite/jdbc/JdbcComplexQuerySelfTest.java
modules/clients/src/test/java/org/apache/ignite/jdbc/JdbcMetadataSelfTest.java
modules/clients/src/test/java/org/apache/ignite/jdbc/JdbcPreparedStatementSelfTest.java
modules/clients/src/test/java/org/apache/ignite/jdbc/JdbcResultSetSelfTest.java
modules/clients/src/test/java/org/apache/ignite/jdbc/JdbcStatementSelfTest.java
modules/clients/src/test/resources/spring-cache.xml
modules/core/src/main/java/org/apache/ignite/cache/query/CacheContinuousQuery.java
modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
modules/core/src/main/java/org/apache/ignite/cache/query/Query.java
modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QuerySqlField.java
modules/core/src/main/java/org/apache/ignite/cache/query/annotations/QueryTextField.java
modules/core/src/main/java/org/apache/ignite/configuration/CacheConfiguration.java
modules/core/src/main/java/org/apache/ignite/configuration/CacheQueryConfiguration.java
modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
modules/core/src/main/java/org/apache/ignite/configuration/QueryConfiguration.java
modules/core/src/main/java/org/apache/ignite/events/CacheQueryExecutedEvent.java
modules/core/src/main/java/org/apache/ignite/events/CacheQueryReadEvent.java
modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
modules/core/src/main/java/org/apache/ignite/internal/cluster/IgniteClusterEx.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheProjection.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQueries.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQuery.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueriesEx.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryMetricsAdapter.java
modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryIndexing.java
modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java
modules/core/src/main/java/org/apache/ignite/resources/CacheStoreSessionResource.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffHeapSelfTest.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryEmbeddedValue.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryIndexingDisabledSelfTest.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheTestValue.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheTestValue2.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheFieldsQueryNoDataSelfTest.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheQueryIndexSelfTest.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/reducefields/GridCacheAbstractReduceFieldsQuerySelfTest.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/reducefields/GridCacheReduceFieldsQueryPartitionedSelfTest.java
modules/core/src/test/java/org/apache/ignite/loadtests/mapper/TestObject.java
modules/core/src/test/webapp/META-INF/ignite-webapp-config.xml
modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java
modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridMapQueryExecutor.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFieldsQuerySelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryTestValue.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridIndexingWithNoopSwapSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractQuerySelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCachePartitionedQueryMultiThreadedSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheQueryLoadSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheQueryMultiThreadedSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheSqlQueryMultiThreadedSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedFieldsQueryP2PDisabledSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedFieldsQueryP2PEnabledSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedFieldsQuerySelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedQueryP2PDisabledSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedQueryP2PEnabledSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedQuerySelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheAtomicFieldsQuerySelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCachePartitionedFieldsQueryP2PDisabledSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCachePartitionedQueryP2PDisabledSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheQueryNodeRestartSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/replicated/GridCacheReplicatedFieldsQueryP2PDisabledSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/replicated/GridCacheReplicatedFieldsQueryP2PEnableSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/replicated/GridCacheReplicatedFieldsQuerySelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/replicated/GridCacheReplicatedQueryP2PDisabledSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/replicated/GridCacheReplicatedQueryP2PEnabledSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/replicated/IgniteCacheReplicatedFieldsQueryP2PDisabledSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/replicated/IgniteCacheReplicatedQueryP2PDisabledSelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/replicated/IgniteCacheReplicatedQuerySelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/local/IgniteCacheLocalQuerySelfTest.java
modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/sql/GridQueryParsingTest.java
modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite.java
modules/scalar/src/main/scala/org/apache/ignite/scalar/scalar.scala
modules/visor-console/src/test/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommandSpec.scala
modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/model/Person.java
pom.xml
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/41bc7728
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/41bc7728
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/41bc7728
Branch: refs/heads/ignite-sql-tests
Commit: 41bc77289e81e9c1038c1391558ec4801b8781c5
Parents: b689abd b4cb17c
Author: S.Vladykin <[email protected]>
Authored: Fri Feb 20 02:53:55 2015 +0300
Committer: S.Vladykin <[email protected]>
Committed: Fri Feb 20 02:53:55 2015 +0300
----------------------------------------------------------------------
assembly/core-jar.xml | 49 -
assembly/dependencies-fabric.xml | 53 +-
assembly/dependencies-hadoop.xml | 42 +-
assembly/dependencies-optional-fabric.xml | 1 -
assembly/dependencies-optional-hadoop.xml | 1 -
assembly/docfiles/tools.js | 30 -
bin/include/target-classpath.bat | 4 +-
bin/include/target-classpath.sh | 10 +-
config/fabric/default-config.xml | 6 +-
config/hadoop/default-config.xml | 30 +-
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 | 10 +
examples/config/filesystem/core-site.xml | 14 +-
examples/config/filesystem/example-igfs.xml | 162 +
examples/config/filesystem/example-ignitefs.xml | 162 -
examples/config/filesystem/readme.txt | 2 +-
examples/pom-standalone.xml | 6 +
examples/pom.xml | 6 +
.../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/CacheTransactionExample.java | 6 +-
.../HibernateL2CacheExampleNodeStartup.java | 2 +-
.../datagrid/starschema/FactPurchase.java | 1 +
.../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 | 2 +-
.../ignite/examples/MessagingExample.java | 4 +-
.../examples/ScalarCacheAffinityExample1.scala | 6 +-
.../examples/ScalarCacheAffinityExample2.scala | 4 +-
.../ScalarCacheAffinitySimpleExample.scala | 10 +-
.../scalar/examples/ScalarCacheExample.scala | 51 +-
.../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 +-
.../ClientAbstractMultiNodeSelfTest.java | 6 +-
.../rest/AbstractRestProcessorSelfTest.java | 2 +-
.../ignite/jdbc/JdbcComplexQuerySelfTest.java | 2 +-
.../ignite/jdbc/JdbcMetadataSelfTest.java | 2 +-
.../jdbc/JdbcPreparedStatementSelfTest.java | 1 +
.../clients/src/test/resources/spring-cache.xml | 14 +-
.../src/test/resources/spring-server-node.xml | 44 -
.../test/resources/spring-server-ssl-node.xml | 44 +-
.../CommunicationMessageCodeGenerator.java | 782 ----
.../ignite/codegen/MessageCodeGenerator.java | 799 ++++
modules/core/licenses/sun-bcl-license.txt | 50 +
modules/core/pom.xml | 6 -
.../src/main/java/org/apache/ignite/Ignite.java | 35 +-
.../java/org/apache/ignite/IgniteCache.java | 12 +-
.../org/apache/ignite/IgniteDataLoader.java | 22 +-
.../main/java/org/apache/ignite/IgniteFs.java | 106 +-
.../apache/ignite/IgniteSystemProperties.java | 120 -
.../org/apache/ignite/IgniteTransactions.java | 89 +-
.../apache/ignite/cache/CacheAtomicityMode.java | 2 +-
.../apache/ignite/cache/CacheInterceptor.java | 1 +
.../org/apache/ignite/cache/CacheManager.java | 4 +-
.../apache/ignite/cache/CacheProjection.java | 1989 ---------
.../cache/CacheWriteSynchronizationMode.java | 4 +-
.../java/org/apache/ignite/cache/GridCache.java | 59 +-
.../eviction/igfs/CacheIgfsEvictionFilter.java | 35 +
.../CacheIgfsPerBlockLruEvictionPolicy.java | 358 ++
...acheIgfsPerBlockLruEvictionPolicyMXBean.java | 93 +
.../ignite/cache/eviction/igfs/package.html | 24 +
.../ignitefs/CacheIgniteFsEvictionFilter.java | 35 -
.../CacheIgniteFsPerBlockLruEvictionPolicy.java | 358 --
...IgniteFsPerBlockLruEvictionPolicyMXBean.java | 93 -
.../ignite/cache/eviction/ignitefs/package.html | 24 -
.../cache/query/CacheContinuousQuery.java | 284 --
.../cache/query/CacheContinuousQueryEntry.java | 49 -
.../ignite/cache/query/ContinuousQuery.java | 208 -
.../org/apache/ignite/cache/query/Query.java | 9 +
.../apache/ignite/cache/query/QueryMetrics.java | 2 +
.../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 | 29 +-
.../cache/store/jdbc/CacheJdbcBlobStore.java | 25 +-
.../apache/ignite/cluster/ClusterMetrics.java | 41 +
.../org/apache/ignite/compute/ComputeTask.java | 3 +-
.../configuration/CacheConfiguration.java | 32 +-
.../ignite/configuration/IgfsConfiguration.java | 807 ++++
.../configuration/IgniteConfiguration.java | 479 +--
.../configuration/IgniteFsConfiguration.java | 807 ----
.../configuration/QueryConfiguration.java | 3 +-
.../configuration/TransactionConfiguration.java | 22 +-
.../ignite/events/AuthenticationEvent.java | 172 -
.../ignite/events/AuthorizationEvent.java | 146 -
.../ignite/events/CacheQueryExecutedEvent.java | 9 +-
.../ignite/events/CacheQueryReadEvent.java | 9 +-
.../org/apache/ignite/events/EventType.java | 248 +-
.../org/apache/ignite/events/IgfsEvent.java | 197 +
.../org/apache/ignite/events/IgniteFsEvent.java | 197 -
.../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 -
.../ignite/internal/ClusterGroupAdapter.java | 889 ----
.../apache/ignite/internal/ClusterGroupEx.java | 44 -
.../ClusterLocalNodeMetricsMXBeanImpl.java | 10 +
.../ignite/internal/ClusterMetricsSnapshot.java | 52 +
.../internal/ClusterNodeLocalMapImpl.java | 103 -
.../apache/ignite/internal/GridComponent.java | 4 +-
.../ignite/internal/GridJobCancelRequest.java | 43 +-
.../ignite/internal/GridJobExecuteRequest.java | 154 +-
.../ignite/internal/GridJobExecuteResponse.java | 67 +-
.../ignite/internal/GridJobSiblingsRequest.java | 39 +-
.../internal/GridJobSiblingsResponse.java | 34 +-
.../ignite/internal/GridKernalContext.java | 40 +-
.../ignite/internal/GridKernalContextImpl.java | 70 +-
.../ignite/internal/GridKernalGateway.java | 7 +
.../ignite/internal/GridKernalGatewayImpl.java | 16 +
.../apache/ignite/internal/GridKillTask.java | 103 -
.../ignite/internal/GridPluginComponent.java | 2 +-
.../ignite/internal/GridTaskCancelRequest.java | 33 +-
.../ignite/internal/GridTaskSessionRequest.java | 44 +-
.../org/apache/ignite/internal/GridTopic.java | 2 +-
.../ignite/internal/IgniteClusterAsyncImpl.java | 261 --
.../ignite/internal/IgniteComponentType.java | 23 +-
.../ignite/internal/IgniteComputeImpl.java | 1 +
.../ignite/internal/IgniteEventsImpl.java | 1 +
.../org/apache/ignite/internal/IgniteEx.java | 34 +-
.../apache/ignite/internal/IgniteKernal.java | 939 +----
.../ignite/internal/IgniteMessagingImpl.java | 1 +
.../ignite/internal/IgniteNodeAttributes.java | 2 +-
.../ignite/internal/IgniteServicesImpl.java | 1 +
.../ignite/internal/IgniteTransactionsEx.java | 45 +-
.../org/apache/ignite/internal/IgnitionEx.java | 103 +-
.../internal/client/impl/GridClientImpl.java | 2 +-
.../internal/cluster/ClusterGroupAdapter.java | 866 ++++
.../ignite/internal/cluster/ClusterGroupEx.java | 44 +
.../cluster/ClusterNodeLocalMapImpl.java | 104 +
.../cluster/IgniteClusterAsyncImpl.java | 292 ++
.../internal/cluster/IgniteClusterEx.java | 27 +
.../internal/cluster/IgniteClusterImpl.java | 527 +++
.../ignite/internal/cluster/IgniteKillTask.java | 103 +
.../internal/direct/DirectByteBufferStream.java | 274 +-
.../internal/direct/DirectMessageReader.java | 23 +-
.../internal/direct/DirectMessageWriter.java | 57 +-
.../direct/DirectMessageWriterState.java | 113 +
.../internal/executor/GridExecutorService.java | 1 +
.../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 +
.../internal/managers/GridManagerAdapter.java | 2 +-
.../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 +-
.../deployment/GridDeploymentInfoBean.java | 65 +-
.../deployment/GridDeploymentManager.java | 2 +-
.../deployment/GridDeploymentRequest.java | 58 +-
.../deployment/GridDeploymentResponse.java | 43 +-
.../discovery/GridDiscoveryManager.java | 8 +-
.../eventstorage/GridEventStorageMessage.java | 88 +-
.../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/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 -
.../processors/GridProcessorAdapter.java | 2 +-
.../affinity/GridAffinityAssignmentCache.java | 43 +-
.../affinity/GridAffinityProcessor.java | 36 +-
.../processors/cache/CacheEntryEvent.java | 78 -
.../internal/processors/cache/CacheFlag.java | 8 +-
.../processors/cache/CacheMetricsImpl.java | 8 +-
.../processors/cache/CacheProjection.java | 1902 +++++++++
.../cache/CacheStoreBalancingWrapper.java | 2 +-
.../processors/cache/GridCacheAdapter.java | 981 +++--
.../cache/GridCacheAffinityManager.java | 5 +
.../cache/GridCacheConcurrentMap.java | 7 +-
.../processors/cache/GridCacheContext.java | 55 +-
.../cache/GridCacheDeploymentManager.java | 33 +-
.../processors/cache/GridCacheEntryEx.java | 21 +-
.../processors/cache/GridCacheEntryInfo.java | 9 +
.../processors/cache/GridCacheEntrySet.java | 3 +-
.../cache/GridCacheEvictionManager.java | 21 +-
.../cache/GridCacheEvictionRequest.java | 48 +-
.../cache/GridCacheEvictionResponse.java | 52 +-
.../cache/GridCacheLoaderWriterStore.java | 2 +-
.../processors/cache/GridCacheMapAdapter.java | 1 -
.../processors/cache/GridCacheMapEntry.java | 467 +--
.../processors/cache/GridCacheMessage.java | 35 +-
.../processors/cache/GridCacheMvcc.java | 8 +-
.../cache/GridCacheMvccCandidate.java | 18 -
.../processors/cache/GridCacheMvccManager.java | 15 +
.../processors/cache/GridCachePeekMode.java | 2 +-
.../processors/cache/GridCacheProcessor.java | 42 +-
.../processors/cache/GridCacheProjectionEx.java | 87 +-
.../cache/GridCacheProjectionImpl.java | 117 +-
.../processors/cache/GridCacheProxyImpl.java | 107 +-
.../processors/cache/GridCacheReturn.java | 57 +
.../cache/GridCacheSharedContext.java | 10 +-
.../processors/cache/GridCacheStoreManager.java | 88 +-
.../processors/cache/GridCacheSwapManager.java | 84 +-
.../cache/GridCacheUpdateAtomicResult.java | 29 +-
.../processors/cache/GridCacheUtils.java | 113 +-
.../processors/cache/GridCacheValueBytes.java | 36 +-
.../cache/GridCacheWriteBehindStore.java | 2 +-
.../processors/cache/IgniteCacheProxy.java | 132 +-
.../cache/affinity/GridCacheAffinityProxy.java | 2 +-
.../CacheDataStructuresManager.java | 80 +-
.../distributed/GridCacheCommittedTxInfo.java | 2 -
...idCacheOptimisticCheckPreparedTxRequest.java | 57 +-
...dCacheOptimisticCheckPreparedTxResponse.java | 47 +-
.../GridCachePerThreadTxCommitBuffer.java | 186 -
...dCachePessimisticCheckCommittedTxFuture.java | 383 --
...CachePessimisticCheckCommittedTxRequest.java | 309 --
...achePessimisticCheckCommittedTxResponse.java | 253 --
.../distributed/GridCacheTtlUpdateRequest.java | 78 +-
.../distributed/GridCacheTxCommitBuffer.java | 60 -
.../distributed/GridDistributedBaseMessage.java | 58 +-
.../GridDistributedCacheAdapter.java | 8 +-
.../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 | 92 +-
.../GridDistributedUnlockRequest.java | 43 +-
.../dht/GridDhtAffinityAssignmentRequest.java | 35 +-
.../dht/GridDhtAffinityAssignmentResponse.java | 46 +-
.../distributed/dht/GridDhtCacheAdapter.java | 75 +-
.../distributed/dht/GridDhtCacheEntry.java | 124 +-
.../cache/distributed/dht/GridDhtGetFuture.java | 38 +-
.../distributed/dht/GridDhtLockFuture.java | 158 +-
.../distributed/dht/GridDhtLockRequest.java | 127 +-
.../distributed/dht/GridDhtLockResponse.java | 66 +-
.../dht/GridDhtTransactionalCacheAdapter.java | 30 +-
.../distributed/dht/GridDhtTxFinishFuture.java | 46 +-
.../distributed/dht/GridDhtTxFinishRequest.java | 322 +-
.../dht/GridDhtTxFinishResponse.java | 37 +-
.../cache/distributed/dht/GridDhtTxLocal.java | 63 +-
.../distributed/dht/GridDhtTxLocalAdapter.java | 122 +-
.../distributed/dht/GridDhtTxPrepareFuture.java | 651 ++-
.../dht/GridDhtTxPrepareRequest.java | 150 +-
.../dht/GridDhtTxPrepareResponse.java | 73 +-
.../cache/distributed/dht/GridDhtTxRemote.java | 20 +-
.../distributed/dht/GridDhtUnlockRequest.java | 42 +-
.../dht/GridPartitionedGetFuture.java | 34 +-
.../dht/atomic/GridDhtAtomicCache.java | 196 +-
.../GridDhtAtomicDeferredUpdateResponse.java | 41 +-
.../dht/atomic/GridDhtAtomicUpdateFuture.java | 12 +-
.../dht/atomic/GridDhtAtomicUpdateRequest.java | 275 +-
.../dht/atomic/GridDhtAtomicUpdateResponse.java | 59 +-
.../dht/atomic/GridNearAtomicUpdateFuture.java | 48 +-
.../dht/atomic/GridNearAtomicUpdateRequest.java | 293 +-
.../atomic/GridNearAtomicUpdateResponse.java | 105 +-
.../dht/colocated/GridDhtColocatedCache.java | 50 +-
.../colocated/GridDhtColocatedLockFuture.java | 43 +-
.../dht/preloader/GridDhtForceKeysRequest.java | 57 +-
.../dht/preloader/GridDhtForceKeysResponse.java | 58 +-
.../GridDhtPartitionDemandMessage.java | 67 +-
.../preloader/GridDhtPartitionDemandPool.java | 6 +-
.../preloader/GridDhtPartitionExchangeId.java | 41 +-
.../dht/preloader/GridDhtPartitionFullMap.java | 2 +-
.../dht/preloader/GridDhtPartitionMap.java | 72 +-
.../GridDhtPartitionSupplyMessage.java | 73 +-
.../GridDhtPartitionsAbstractMessage.java | 32 +-
.../preloader/GridDhtPartitionsFullMessage.java | 43 +-
.../GridDhtPartitionsSingleMessage.java | 38 +-
.../GridDhtPartitionsSingleRequest.java | 26 +-
.../dht/preloader/GridDhtPreloader.java | 2 +-
.../distributed/near/GridNearAtomicCache.java | 39 +-
.../distributed/near/GridNearCacheAdapter.java | 101 +-
.../distributed/near/GridNearCacheEntry.java | 6 +-
.../distributed/near/GridNearGetFuture.java | 52 +-
.../distributed/near/GridNearGetRequest.java | 152 +-
.../distributed/near/GridNearGetResponse.java | 73 +-
.../distributed/near/GridNearLockFuture.java | 10 +-
.../distributed/near/GridNearLockRequest.java | 162 +-
.../distributed/near/GridNearLockResponse.java | 69 +-
.../near/GridNearTransactionalCache.java | 24 +-
.../near/GridNearTxFinishFuture.java | 5 +-
.../near/GridNearTxFinishRequest.java | 93 +-
.../near/GridNearTxFinishResponse.java | 48 +-
.../cache/distributed/near/GridNearTxLocal.java | 102 +-
.../near/GridNearTxPrepareFuture.java | 422 +-
.../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 | 2 +-
.../processors/cache/local/GridLocalTx.java | 8 +-
.../cache/local/GridLocalTxFuture.java | 2 +-
.../local/atomic/GridLocalAtomicCache.java | 122 +-
.../processors/cache/query/CacheQueries.java | 10 -
.../processors/cache/query/CacheQuery.java | 18 +-
.../cache/query/GridCacheQueriesEx.java | 1 +
.../cache/query/GridCacheQueriesImpl.java | 5 -
.../cache/query/GridCacheQueriesProxy.java | 13 -
.../query/GridCacheQueryFutureAdapter.java | 1 -
.../cache/query/GridCacheQueryManager.java | 2 +-
.../query/GridCacheQueryMetricsAdapter.java | 2 +-
.../cache/query/GridCacheQueryRequest.java | 140 +-
.../cache/query/GridCacheQueryResponse.java | 73 +-
.../processors/cache/query/QueryCursorImpl.java | 87 +
.../continuous/CacheContinuousQueryEntry.java | 234 ++
.../continuous/CacheContinuousQueryEvent.java | 87 +
.../CacheContinuousQueryFilterEx.java | 31 +
.../continuous/CacheContinuousQueryHandler.java | 505 +++
.../CacheContinuousQueryListener.java | 49 +
.../continuous/CacheContinuousQueryManager.java | 757 ++++
.../GridCacheContinuousQueryAdapter.java | 319 --
.../GridCacheContinuousQueryEntry.java | 344 --
.../GridCacheContinuousQueryFilterEx.java | 33 -
.../GridCacheContinuousQueryHandler.java | 573 ---
.../GridCacheContinuousQueryListener.java | 41 -
.../GridCacheContinuousQueryManager.java | 784 ----
.../cache/transactions/IgniteInternalTx.java | 17 +-
.../transactions/IgniteTransactionsImpl.java | 178 +-
.../cache/transactions/IgniteTxAdapter.java | 147 +-
.../cache/transactions/IgniteTxEntry.java | 83 +-
.../cache/transactions/IgniteTxHandler.java | 694 +---
.../transactions/IgniteTxLocalAdapter.java | 574 ++-
.../cache/transactions/IgniteTxLocalEx.java | 10 +-
.../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 +-
.../cache/version/GridCacheVersionEx.java | 2 +-
.../clock/GridClockDeltaSnapshotMessage.java | 42 +-
.../processors/clock/GridClockDeltaVersion.java | 36 +-
.../processors/closure/GridClosurePolicy.java | 4 +-
.../closure/GridClosureProcessor.java | 14 +-
.../continuous/GridContinuousMessage.java | 57 +-
.../continuous/GridContinuousProcessor.java | 2 +-
.../dataload/GridDataLoadCacheUpdaters.java | 88 -
.../dataload/GridDataLoadRequest.java | 102 +-
.../dataload/GridDataLoadResponse.java | 43 +-
.../dataload/IgniteDataLoaderImpl.java | 116 +-
.../datastructures/DataStructuresProcessor.java | 19 +-
.../datastructures/GridCacheAtomicLongImpl.java | 5 +-
.../GridCacheAtomicReferenceImpl.java | 5 +-
.../GridCacheAtomicSequenceImpl.java | 5 +-
.../GridCacheAtomicStampedImpl.java | 5 +-
.../GridCacheCountDownLatchImpl.java | 5 +-
.../datastructures/GridCacheSetImpl.java | 4 +-
.../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 | 1906 ---------
.../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 | 562 ---
.../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 | 420 --
.../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 +-
.../plugin/IgnitePluginProcessor.java | 28 +-
.../processors/query/GridQueryProcessor.java | 4 +-
.../processors/resource/GridResourceIoc.java | 48 +-
.../resource/GridResourceProcessor.java | 21 +
.../processors/rest/GridRestProcessor.java | 7 +-
.../handlers/cache/GridCacheCommandHandler.java | 10 +-
.../cache/GridCacheQueryCommandHandler.java | 10 +-
.../handlers/task/GridTaskCommandHandler.java | 4 +-
.../handlers/task/GridTaskResultRequest.java | 39 +-
.../handlers/task/GridTaskResultResponse.java | 49 +-
.../top/GridTopologyCommandHandler.java | 2 +-
.../protocols/tcp/GridTcpRestNioListener.java | 16 +-
.../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 | 79 +-
.../streamer/GridStreamerCancelRequest.java | 33 +-
.../streamer/GridStreamerContextImpl.java | 2 +-
.../streamer/GridStreamerExecutionRequest.java | 75 +-
.../streamer/GridStreamerResponse.java | 38 +-
.../processors/streamer/IgniteStreamerImpl.java | 41 +-
.../processors/task/GridTaskWorker.java | 4 +-
.../util/GridBoundedConcurrentOrderedMap.java | 20 +-
.../ignite/internal/util/GridByteArrayList.java | 36 +-
.../ignite/internal/util/GridLongList.java | 36 +-
.../ignite/internal/util/IgniteUtils.java | 32 +-
.../util/future/GridCompoundFuture.java | 2 +
.../util/future/GridCompoundIdentityFuture.java | 10 -
.../internal/util/future/GridFutureAdapter.java | 8 +-
.../util/future/GridFutureAdapterEx.java | 3 +-
.../ignite/internal/util/ipc/IpcEndpoint.java | 2 +-
.../internal/util/ipc/IpcEndpointFactory.java | 2 +-
.../internal/util/ipc/IpcToNioAdapter.java | 4 +-
.../ignite/internal/util/nio/GridNioServer.java | 32 +-
.../util/nio/GridNioSessionMetaKey.java | 5 +-
.../util/nio/GridShmemCommunicationClient.java | 4 +-
.../util/nio/GridTcpCommunicationClient.java | 4 +-
.../apache/ignite/internal/visor/VisorJob.java | 3 +-
.../internal/visor/VisorMultiNodeTask.java | 9 +-
.../ignite/internal/visor/cache/VisorCache.java | 10 +-
.../cache/VisorCacheAggregatedMetrics.java | 6 +-
.../visor/cache/VisorCacheClearTask.java | 3 +-
.../visor/cache/VisorCacheCompactTask.java | 2 +-
.../visor/cache/VisorCacheConfiguration.java | 196 +-
.../cache/VisorCacheDefaultConfiguration.java | 57 -
.../visor/cache/VisorCacheDgcConfiguration.java | 97 -
.../visor/cache/VisorCacheLoadTask.java | 43 +-
.../visor/cache/VisorCacheMetadataTask.java | 2 +-
.../internal/visor/cache/VisorCacheMetrics.java | 21 +-
.../cache/VisorCacheMetricsCollectorTask.java | 10 +-
.../visor/cache/VisorCachePreloadTask.java | 4 +-
.../cache/VisorCacheStoreConfiguration.java | 7 +-
.../visor/cache/VisorCacheSwapBackupsTask.java | 2 +-
.../cache/VisorCacheTypeFieldMetadata.java | 1 -
.../visor/cache/VisorCacheTypeMetadata.java | 12 +-
.../VisorCacheWriteBehindConfiguration.java | 6 +-
.../compute/VisorComputeCancelSessionsTask.java | 2 +-
.../compute/VisorComputeMonitoringHolder.java | 13 +-
.../compute/VisorComputeResetMetricsTask.java | 2 +-
.../VisorComputeToggleMonitoringTask.java | 4 +-
.../internal/visor/debug/VisorThreadInfo.java | 31 +-
.../visor/debug/VisorThreadLockInfo.java | 12 +-
.../visor/debug/VisorThreadMonitorInfo.java | 6 +-
.../event/VisorGridAuthenticationEvent.java | 106 -
.../event/VisorGridAuthorizationEvent.java | 89 -
.../visor/event/VisorGridDeploymentEvent.java | 10 +-
.../visor/event/VisorGridDiscoveryEvent.java | 10 +-
.../internal/visor/event/VisorGridEvent.java | 18 +-
.../visor/event/VisorGridEventsLost.java | 2 +-
.../internal/visor/event/VisorGridJobEvent.java | 30 +-
.../event/VisorGridSecuritySessionEvent.java | 12 +-
.../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 | 107 +
.../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 | 201 +
.../visor/igfs/VisorIgfsResetMetricsTask.java | 73 +
.../visor/igfs/VisorIgfsSamplingStateTask.java | 77 +
.../visor/log/VisorLogSearchResult.java | 20 +-
.../internal/visor/log/VisorLogSearchTask.java | 18 +-
.../internal/visor/misc/VisorNopTask.java | 3 +
.../visor/misc/VisorResolveHostNameTask.java | 6 +-
.../visor/node/VisorAtomicConfiguration.java | 104 +
.../visor/node/VisorBasicConfiguration.java | 11 +-
.../node/VisorCacheQueryConfiguration.java | 141 +
.../visor/node/VisorEmailConfiguration.java | 177 -
.../node/VisorExecutorServiceConfiguration.java | 86 +-
.../visor/node/VisorGgfsConfiguration.java | 574 ---
.../visor/node/VisorGridConfiguration.java | 91 +-
.../visor/node/VisorIgfsConfiguration.java | 574 +++
.../visor/node/VisorLifecycleConfiguration.java | 19 -
.../visor/node/VisorMetricsConfiguration.java | 10 +-
.../visor/node/VisorNodeDataCollectorJob.java | 80 +-
.../node/VisorNodeDataCollectorJobResult.java | 97 +-
.../visor/node/VisorNodeDataCollectorTask.java | 71 +-
.../node/VisorNodeDataCollectorTaskArg.java | 19 +-
.../node/VisorNodeDataCollectorTaskResult.java | 56 +-
.../node/VisorNodeEventsCollectorTask.java | 68 +-
.../internal/visor/node/VisorNodeGcTask.java | 2 +-
.../internal/visor/node/VisorNodePingTask.java | 2 +-
.../visor/node/VisorQueryConfiguration.java | 183 +
.../visor/node/VisorRestConfiguration.java | 6 +-
.../visor/node/VisorSpisConfiguration.java | 47 +-
.../node/VisorTransactionConfiguration.java | 158 +
.../visor/query/VisorQueryCleanupTask.java | 5 +-
.../visor/query/VisorQueryNextPageTask.java | 8 +-
.../visor/query/VisorQueryResultEx.java | 2 +-
.../internal/visor/query/VisorQueryTask.java | 58 +-
.../internal/visor/query/VisorQueryUtils.java | 18 +-
.../streamer/VisorStreamerConfiguration.java | 19 +-
.../visor/streamer/VisorStreamerMetrics.java | 6 +-
.../internal/visor/util/VisorEventMapper.java | 76 +
.../internal/visor/util/VisorMimeTypes.java | 51 +-
.../internal/visor/util/VisorTaskUtils.java | 176 +-
.../apache/ignite/lang/IgniteAsyncSupport.java | 2 +-
.../optimized/optimized-classnames.properties | 363 +-
.../mxbean/ClusterLocalNodeMetricsMXBean.java | 9 +
.../org/apache/ignite/mxbean/IgniteMXBean.java | 16 -
.../apache/ignite/plugin/ExtensionRegistry.java | 2 +-
.../apache/ignite/plugin/PluginProvider.java | 3 +-
.../communication/MessageAdapter.java | 108 +-
.../extensions/communication/MessageReader.java | 25 +-
.../extensions/communication/MessageWriter.java | 63 +-
.../plugin/security/AuthenticationContext.java | 110 +
.../security/GridSecurityCredentials.java | 5 -
.../GridSecurityCredentialsProvider.java | 5 -
.../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 | 45 +-
.../spi/discovery/DiscoverySpiDataExchange.java | 3 +-
.../DiscoverySpiNodeAuthenticator.java | 2 +-
.../discovery/tcp/TcpClientDiscoverySpi.java | 4 +-
.../spi/discovery/tcp/TcpDiscoverySpi.java | 76 +-
.../discovery/tcp/TcpDiscoverySpiAdapter.java | 2 +-
.../tcp/internal/TcpDiscoveryNodesRing.java | 2 -
.../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 | 7 +-
.../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 ++
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 +
.../ignite/IgniteCacheAffinitySelfTest.java | 8 +-
.../store/GridCacheBalancingStoreSelfTest.java | 2 +-
.../cache/store/GridGeneratingTestStore.java | 2 +-
.../IgniteCacheExpiryStoreLoadSelfTest.java | 239 ++
.../store/jdbc/CacheJdbcPojoStoreTest.java | 10 +-
...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 -
.../ignite/internal/ClusterMetricsSelfTest.java | 2 +-
.../GridJobMasterLeaveAwareSelfTest.java | 8 +-
.../internal/GridMultipleJobsSelfTest.java | 2 +-
.../internal/GridProjectionAbstractTest.java | 2 +-
.../ignite/internal/GridProjectionSelfTest.java | 2 +-
.../internal/GridReleaseTypeSelfTest.java | 35 +-
.../apache/ignite/internal/GridSelfTest.java | 15 +-
.../ignite/internal/GridStartStopSelfTest.java | 6 +-
.../GridTopologyBuildVersionSelfTest.java | 101 -
.../internal/GridUpdateNotifierSelfTest.java | 4 +
.../GridCommunicationSendMessageSelfTest.java | 13 +-
.../communication/GridIoManagerSelfTest.java | 17 +-
.../GridAffinityProcessorAbstractSelfTest.java | 7 +-
.../GridCacheAbstractFailoverSelfTest.java | 19 +-
.../cache/GridCacheAbstractFullApiSelfTest.java | 253 +-
.../cache/GridCacheAbstractMetricsSelfTest.java | 12 +-
.../cache/GridCacheAbstractSelfTest.java | 4 +-
.../cache/GridCacheAbstractTxReadTest.java | 16 +-
.../cache/GridCacheAffinityApiSelfTest.java | 18 +-
.../cache/GridCacheBasicStoreAbstractTest.java | 13 +-
.../cache/GridCacheClearLocalySelfTest.java | 2 +-
.../GridCacheConcurrentTxMultiNodeTest.java | 11 +-
...idCacheConfigurationConsistencySelfTest.java | 2 +-
.../GridCacheDaemonNodeAbstractSelfTest.java | 8 +-
.../cache/GridCacheDeploymentSelfTest.java | 45 -
.../cache/GridCacheEntryMemorySizeSelfTest.java | 4 +-
.../GridCacheExAbstractFullApiSelfTest.java | 6 +-
.../GridCacheFinishPartitionsSelfTest.java | 9 +-
...CacheFullTextQueryMultithreadedSelfTest.java | 2 +-
.../cache/GridCacheGenericTestStore.java | 2 +-
.../GridCacheGroupLockAbstractSelfTest.java | 1337 ------
...heGroupLockFailoverOptimisticTxSelfTest.java | 28 -
.../GridCacheGroupLockFailoverSelfTest.java | 533 ---
...CacheGroupLockMultiNodeAbstractSelfTest.java | 28 -
.../cache/GridCacheGroupLockPutTask.java | 161 -
.../GridCacheInterceptorAbstractSelfTest.java | 10 +-
.../processors/cache/GridCacheLeakTest.java | 2 +-
.../cache/GridCacheLifecycleAwareSelfTest.java | 2 +-
.../cache/GridCacheLuceneQueryIndexTest.java | 16 +-
.../GridCacheMarshallerTxAbstractTest.java | 6 +-
...GridCacheMixedPartitionExchangeSelfTest.java | 9 +-
.../cache/GridCacheMultiUpdateLockSelfTest.java | 9 +-
.../cache/GridCacheMvccManagerSelfTest.java | 2 +-
.../cache/GridCacheNestedTxAbstractTest.java | 10 +-
.../cache/GridCacheObjectToStringSelfTest.java | 6 +-
...CacheOffHeapMultiThreadedUpdateSelfTest.java | 17 +-
.../cache/GridCacheOffHeapSelfTest.java | 7 +-
.../GridCacheOffHeapTieredAbstractSelfTest.java | 22 +-
.../cache/GridCacheOffheapUpdateSelfTest.java | 14 +-
.../cache/GridCacheP2PUndeploySelfTest.java | 2 +-
.../cache/GridCachePartitionedWritesTest.java | 2 +-
.../GridCachePreloadingEvictionsSelfTest.java | 2 +-
.../cache/GridCacheQueryEmbeddedValue.java | 1 +
.../GridCacheQueryIndexingDisabledSelfTest.java | 1 +
.../GridCacheQueryInternalKeysSelfTest.java | 4 +-
.../GridCacheReferenceCleanupSelfTest.java | 4 +-
.../cache/GridCacheSlowTxWarnTest.java | 3 +-
.../processors/cache/GridCacheStopSelfTest.java | 2 +-
.../cache/GridCacheStorePutxSelfTest.java | 5 +-
.../cache/GridCacheSwapPreloadSelfTest.java | 5 +-
.../processors/cache/GridCacheTestEntryEx.java | 11 +-
.../processors/cache/GridCacheTestStore.java | 39 +-
.../processors/cache/GridCacheTestValue2.java | 1 +
...cheTransactionalAbstractMetricsSelfTest.java | 16 +-
.../GridCacheVariableTopologySelfTest.java | 7 +-
.../cache/GridCacheVersionMultinodeTest.java | 73 +-
.../GridCacheWriteBehindStoreAbstractTest.java | 8 +-
...BehindStorePartitionedMultiNodeSelfTest.java | 6 +-
.../IgniteCacheAbstractStopBusySelfTest.java | 381 ++
.../IgniteCacheAtomicStopBusySelfTest.java | 59 +
.../IgniteCacheContainsKeyAbstractSelfTest.java | 136 +
.../IgniteCacheEntryListenerAbstractTest.java | 106 +
.../IgniteCacheFieldsQueryNoDataSelfTest.java | 2 +
.../cache/IgniteCacheInvokeAbstractTest.java | 22 +-
.../cache/IgniteCacheQueryIndexSelfTest.java | 5 +-
...gniteCacheTransactionalStopBusySelfTest.java | 53 +
.../IgniteClientAffinityAssignmentSelfTest.java | 165 +
.../cache/IgnitePutAllLargeBatchSelfTest.java | 301 ++
...tAllUpdateNonPreloadedPartitionSelfTest.java | 129 +
.../processors/cache/IgniteTxAbstractTest.java | 26 +-
.../IgniteTxConcurrentGetAbstractTest.java | 6 +-
.../IgniteTxExceptionAbstractSelfTest.java | 72 +-
.../cache/IgniteTxMultiNodeAbstractTest.java | 22 +-
.../IgniteTxMultiThreadedAbstractTest.java | 18 +-
.../cache/IgniteTxReentryAbstractSelfTest.java | 6 +-
.../IgniteTxSingleThreadedAbstractTest.java | 4 +-
.../IgniteTxStoreExceptionAbstractSelfTest.java | 34 +-
...niteCacheContinuousExecutionContextTest.java | 34 +
...IgniteCacheIsolatedExecutionContextTest.java | 34 +
...niteCacheP2PDisableExecutionContextTest.java | 34 +
.../IgniteCachePrivateExecutionContextTest.java | 34 +
.../IgniteCacheSharedExecutionContextTest.java | 34 +
.../GridCacheQueueCleanupSelfTest.java | 8 +-
...ridCacheQueueJoinedNodeSelfAbstractTest.java | 4 +-
...GridCacheQueueMultiNodeAbstractSelfTest.java | 4 +-
.../GridCacheSequenceApiSelfAbstractTest.java | 6 +-
...dCacheSequenceMultiNodeAbstractSelfTest.java | 4 +-
.../IgniteAtomicLongApiAbstractSelfTest.java | 2 +-
.../IgniteDataStructureUniqueNameTest.java | 41 +
...idCachePartitionedNodeRestartTxSelfTest.java | 12 +-
...PartitionedQueueCreateMultiNodeSelfTest.java | 6 +-
...dCachePartitionedQueueEntryMoveSelfTest.java | 2 +-
...tractDistributedByteArrayValuesSelfTest.java | 10 +-
.../GridCacheAbstractJobExecutionTest.java | 29 +-
.../GridCacheAbstractNodeRestartSelfTest.java | 12 +-
.../GridCacheAbstractPrimarySyncSelfTest.java | 6 +-
.../GridCacheBasicOpAbstractTest.java | 9 +-
.../GridCacheClientModesAbstractSelfTest.java | 9 +-
.../GridCacheEntrySetAbstractSelfTest.java | 7 +-
.../distributed/GridCacheEventAbstractTest.java | 26 +-
...dCacheMultithreadedFailoverAbstractTest.java | 5 +-
.../GridCacheNodeFailureAbstractTest.java | 12 +-
...chePartitionedReloadAllAbstractSelfTest.java | 8 +-
.../GridCacheTransformEventSelfTest.java | 14 +-
.../IgniteCrossCacheTxStoreSelfTest.java | 20 +-
...iteTxConsistencyRestartAbstractSelfTest.java | 6 +-
...xOriginatingNodeFailureAbstractSelfTest.java | 4 +-
...cOriginatingNodeFailureAbstractSelfTest.java | 39 +-
.../IgniteTxPreloadAbstractTest.java | 6 +-
.../IgniteTxTimeoutAbstractTest.java | 12 +-
...heAbstractTransformWriteThroughSelfTest.java | 8 +-
.../dht/GridCacheAtomicNearCacheSelfTest.java | 2 -
.../dht/GridCacheColocatedDebugTest.java | 32 +-
...eColocatedOptimisticTransactionSelfTest.java | 6 +-
...ssimisticOriginatingNodeFailureSelfTest.java | 2 +-
.../dht/GridCacheDhtEntrySelfTest.java | 4 +-
...GridCacheDhtEvictionNearReadersSelfTest.java | 6 +-
.../dht/GridCacheDhtEvictionSelfTest.java | 2 +-
.../dht/GridCacheDhtInternalEntrySelfTest.java | 2 +-
.../GridCacheGroupLockColocatedSelfTest.java | 38 -
...acheGroupLockMultiNodeColocatedSelfTest.java | 29 -
...cheGroupLockPartitionedAbstractSelfTest.java | 137 -
...ockPartitionedMultiNodeAbstractSelfTest.java | 174 -
...ePartitionedNearDisabledMetricsSelfTest.java | 2 +-
...dCachePartitionedTopologyChangeSelfTest.java | 13 +-
...IgniteCacheContainsKeyColocatedSelfTest.java | 36 +
.../atomic/GridCacheAtomicPreloadSelfTest.java | 8 +-
...CacheContainsKeyColocatedAtomicSelfTest.java | 41 +
...gniteCacheContainsKeyNearAtomicSelfTest.java | 36 +
...tomicClientOnlyMultiNodeFullApiSelfTest.java | 12 +-
...AtomicPartitionedTckMetricsSelfTestImpl.java | 6 +-
...GridCacheGroupLockMultiNodeNearSelfTest.java | 30 -
.../near/GridCacheGroupLockNearSelfTest.java | 38 -
.../near/GridCacheNearMetricsSelfTest.java | 12 +-
.../near/GridCacheNearMultiGetSelfTest.java | 12 +-
.../near/GridCacheNearMultiNodeSelfTest.java | 18 +-
.../near/GridCacheNearOneNodeSelfTest.java | 10 +-
...idCacheNearOnlyMultiNodeFullApiSelfTest.java | 2 +-
.../near/GridCacheNearOnlyTopologySelfTest.java | 8 +-
.../near/GridCacheNearReadersSelfTest.java | 20 +-
.../near/GridCacheNearTxMultiNodeSelfTest.java | 14 +-
...ssimisticOriginatingNodeFailureSelfTest.java | 2 +-
...ePartitionedBasicStoreMultiNodeSelfTest.java | 18 +-
.../GridCachePartitionedEvictionSelfTest.java | 8 +-
...titionedExplicitLockNodeFailureSelfTest.java | 4 +-
...GridCachePartitionedFilteredPutSelfTest.java | 3 +-
...idCachePartitionedHitsAndMissesSelfTest.java | 177 +
...achePartitionedMultiNodeCounterSelfTest.java | 12 +-
...achePartitionedMultiNodeFullApiSelfTest.java | 2 +-
...ePartitionedMultiThreadedPutGetSelfTest.java | 8 +-
.../GridCachePartitionedNodeRestartTest.java | 2 +-
...ePartitionedOptimisticTxNodeRestartTest.java | 4 +-
...achePartitionedPreloadLifecycleSelfTest.java | 12 +-
.../GridCachePartitionedTxSalvageSelfTest.java | 12 +-
.../IgniteCacheContainsKeyNearSelfTest.java | 31 +
.../near/IgniteCacheNearReadCommittedTest.java | 68 +
...cheGroupLockMultiNodeReplicatedSelfTest.java | 45 -
.../GridCacheGroupLockReplicatedSelfTest.java | 39 -
...eReplicatedGetAndTransformStoreSelfTest.java | 8 +-
.../GridCacheReplicatedInvalidateSelfTest.java | 10 +-
...ssimisticOriginatingNodeFailureSelfTest.java | 5 +-
...CacheReplicatedPreloadLifecycleSelfTest.java | 13 +-
...heConcurrentEvictionConsistencySelfTest.java | 14 +-
.../GridCacheConcurrentEvictionsSelfTest.java | 4 +-
.../GridCacheDistributedEvictionsSelfTest.java | 4 +-
.../GridCacheEmptyEntriesAbstractSelfTest.java | 10 +-
.../eviction/GridCacheEvictionAbstractTest.java | 6 +-
.../GridCacheEvictionTouchSelfTest.java | 101 +-
.../IgniteCacheExpiryPolicyAbstractTest.java | 46 +-
.../IgniteCacheExpiryPolicyTestSuite.java | 3 +
...iteCacheNoLoadPreviousValueAbstractTest.java | 15 +-
.../IgniteCacheNoReadThroughAbstractTest.java | 14 +-
.../IgniteCacheNoWriteThroughAbstractTest.java | 18 +-
.../IgniteCacheStoreSessionAbstractTest.java | 20 +-
.../IgniteCacheTxStoreSessionTest.java | 32 +-
...dCacheAtomicLocalTckMetricsSelfTestImpl.java | 4 +-
.../GridCacheLocalByteArrayValuesSelfTest.java | 10 +-
.../local/GridCacheLocalTxTimeoutSelfTest.java | 12 +-
.../GridCacheSwapScanQueryAbstractSelfTest.java | 13 +-
...ridCacheContinuousQueryAbstractSelfTest.java | 905 +----
...dCacheContinuousQueryReplicatedSelfTest.java | 95 +-
...dCacheAbstractReduceFieldsQuerySelfTest.java | 17 +-
...cheReduceFieldsQueryPartitionedSelfTest.java | 4 +-
.../closure/GridClosureProcessorRemoteTest.java | 2 +-
.../closure/GridClosureProcessorSelfTest.java | 14 +-
.../continuous/GridEventConsumeSelfTest.java | 18 +-
.../continuous/GridMessageListenSelfTest.java | 14 +-
.../dataload/GridDataLoaderPerformanceTest.java | 17 +-
.../GridDataLoaderProcessorSelfTest.java | 154 +-
...heGgfsPerBlockLruEvictionPolicySelfTest.java | 485 ---
.../processors/fs/GridGgfsAbstractSelfTest.java | 2453 -----------
.../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 | 604 ---
.../GridGgfsPrimaryOffheapTieredSelfTest.java | 33 -
.../GridGgfsPrimaryOffheapValuesSelfTest.java | 33 -
.../processors/fs/GridGgfsPrimarySelfTest.java | 32 -
.../fs/GridGgfsProcessorSelfTest.java | 978 -----
.../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 | 878 ++++
.../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 +
.../GridServiceReassignmentSelfTest.java | 2 +-
.../internal/util/GridTestClockTimer.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 +-
.../cache/GridCacheAbstractLoadTest.java | 13 +-
...ridCacheAffinityTransactionsOffHeapTest.java | 270 --
.../cache/GridCacheDataStructuresLoadTest.java | 5 +-
.../cache/GridCacheGroupLockComparisonTest.java | 204 -
.../communication/GridTestMessage.java | 13 +-
.../GridContinuousOperationsLoadTest.java | 54 +-
.../GridCachePartitionedAtomicLongLoadTest.java | 6 +-
.../ignite/loadtests/dsi/GridDsiPerfJob.java | 3 +-
.../loadtests/hashmap/GridCacheTestContext.java | 2 +-
.../marshaller/GridMarshallerAbstractTest.java | 14 +-
.../ignite/messaging/GridMessagingSelfTest.java | 3 +-
.../p2p/GridAbstractMultinodeRedeployTest.java | 23 +-
.../spi/GridTcpSpiForwardingSelfTest.java | 4 +-
.../GridFifoQueueCollisionSpiSelfTest.java | 12 +-
.../GridPriorityQueueCollisionSpiSelfTest.java | 2 +
.../spi/communication/GridTestMessage.java | 48 +-
.../discovery/AbstractDiscoverySelfTest.java | 11 +-
...ClusterMetricsSnapshotSerializeSelfTest.java | 6 +-
.../tcp/TcpDiscoverySpiStartStopSelfTest.java | 9 +-
.../tcp/TcpDiscoverySpiWildcardSelfTest.java | 2 +-
.../inmemory/GridTestSwapSpaceSpi.java | 2 +-
.../testframework/junits/GridAbstractTest.java | 10 +-
.../ignite/testframework/junits/IgniteMock.java | 12 -
.../cache/GridAbstractCacheStoreSelfTest.java | 18 +-
.../junits/cache/TestCacheSession.java | 6 +-
.../cache/TestThreadLocalCacheSession.java | 4 +-
.../junits/common/GridCommonAbstractTest.java | 11 +-
.../junits/spi/GridSpiAbstractTest.java | 95 +-
.../ignite/testsuites/IgniteBasicTestSuite.java | 1 -
.../IgniteCacheDataStructuresSelfTestSuite.java | 3 +-
.../IgniteCacheGroupLockSelfTestSuite.java | 48 -
.../IgniteCacheMetricsSelfTestSuite.java | 21 +-
.../testsuites/IgniteCacheRestartTestSuite.java | 2 +-
.../ignite/testsuites/IgniteCacheTestSuite.java | 30 +-
.../ignite/testsuites/IgniteFsTestSuite.java | 79 -
.../ignite/testsuites/IgniteIgfsTestSuite.java | 79 +
.../webapp/META-INF/ignite-webapp-config.xml | 8 +-
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 +
.../query/h2/GridH2IndexingGeoSelfTest.java | 8 +-
modules/hadoop/pom.xml | 6 +
modules/hadoop/readme.txt | 2 +-
.../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 | 112 -
.../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 +-
.../fs/GridHadoopDistributedFileSystem.java | 2 +-
.../hadoop/fs/GridHadoopFileSystemsUtils.java | 6 +-
.../hadoop/jobtracker/GridHadoopJobTracker.java | 33 +-
.../GridHadoopDefaultMapReducePlanner.java | 28 +-
.../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 | 304 --
.../GridGgfsHadoopDualAsyncSelfTest.java | 32 -
.../GridGgfsHadoopDualSyncSelfTest.java | 32 -
...ridGgfsHadoopFileSystemAbstractSelfTest.java | 2365 -----------
.../GridGgfsHadoopFileSystemClientSelfTest.java | 199 -
...idGgfsHadoopFileSystemHandshakeSelfTest.java | 310 --
...ridGgfsHadoopFileSystemIpcCacheSelfTest.java | 207 -
.../GridGgfsHadoopFileSystemLoggerSelfTest.java | 287 --
...GgfsHadoopFileSystemLoggerStateSelfTest.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 -
.../GridGgfsNearOnlyMultiNodeSelfTest.java | 212 -
.../ignitefs/IgniteFsEventsTestSuite.java | 267 --
.../hadoop/GridHadoopAbstractSelfTest.java | 77 +-
.../hadoop/GridHadoopAbstractWordCountTest.java | 16 +-
.../hadoop/GridHadoopCommandLineTest.java | 28 +-
...idHadoopDefaultMapReducePlannerSelfTest.java | 383 +-
.../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 | 3 +-
.../hibernate/GridHibernateL2CacheSelfTest.java | 3 +-
modules/indexing/pom.xml | 6 +
.../processors/query/h2/IgniteH2Indexing.java | 117 +-
.../query/h2/opt/GridLuceneIndex.java | 13 +-
.../GridCacheAbstractFieldsQuerySelfTest.java | 1314 ++++++
.../cache/GridCacheCrossCacheQuerySelfTest.java | 17 +-
.../GridCacheCrossCacheQuerySelfTestNewApi.java | 411 ++
.../cache/GridCacheOffHeapAndSwapSelfTest.java | 6 +-
.../cache/GridCacheQueryMetricsSelfTest.java | 4 +-
.../processors/cache/GridCacheSwapSelfTest.java | 11 +-
.../cache/GridIndexingWithNoopSwapSelfTest.java | 5 +-
...hePartitionedQueryMultiThreadedSelfTest.java | 4 +-
.../cache/IgniteCacheQueryLoadSelfTest.java | 5 +-
.../IgniteCacheQueryMultiThreadedSelfTest.java | 27 +-
...gniteCacheSqlQueryMultiThreadedSelfTest.java | 4 +
...artitionedFieldsQueryP2PEnabledSelfTest.java | 34 +
...GridCachePartitionedFieldsQuerySelfTest.java | 111 +
...idCachePartitionedHitsAndMissesSelfTest.java | 176 -
...CachePartitionedQueryP2PEnabledSelfTest.java | 34 +
.../near/GridCachePartitionedQuerySelfTest.java | 479 +++
.../IgniteCacheAtomicFieldsQuerySelfTest.java | 4 +-
.../IgniteCacheQueryNodeRestartSelfTest.java | 3 +-
...eReplicatedFieldsQueryP2PEnableSelfTest.java | 34 +
.../GridCacheReplicatedFieldsQuerySelfTest.java | 157 +
...dCacheReplicatedQueryP2PEnabledSelfTest.java | 34 +
.../IgniteCacheReplicatedQuerySelfTest.java | 2 +
.../local/IgniteCacheLocalQuerySelfTest.java | 5 +-
.../query/h2/GridH2IndexRebuildTest.java | 16 +-
.../query/h2/sql/GridQueryParsingTest.java | 4 +-
.../tcp/GridOrderedMessageCancelSelfTest.java | 6 +-
.../IgniteCacheQuerySelfTestSuite.java | 2 +
.../IgniteH2IndexingSpiTestSuite.java | 2 -
.../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 +-
modules/scalar/pom.xml | 6 +
.../ignite/scalar/ScalarConversions.scala | 47 +-
.../ignite/scalar/pimps/ScalarCachePimp.scala | 662 ++-
.../pimps/ScalarCacheProjectionPimp.scala | 2004 ---------
.../scala/org/apache/ignite/scalar/scalar.scala | 27 +-
.../tests/ScalarAffinityRoutingSpec.scala | 12 +-
.../scalar/tests/ScalarCacheQueriesSpec.scala | 466 +--
.../ignite/scalar/tests/ScalarCacheSpec.scala | 10 +-
modules/spring/pom.xml | 6 +
.../org/apache/ignite/IgniteSpringBean.java | 19 +-
.../apache/ignite/cache/spring/SpringCache.java | 4 +-
.../ignite/cache/spring/SpringCacheManager.java | 5 +-
.../cache/spring/SpringDynamicCacheManager.java | 11 +-
.../resource/GridServiceInjectionSelfTest.java | 4 +-
modules/visor-console/pom.xml | 6 +
.../visor/commands/ack/VisorAckCommand.scala | 4 +-
.../commands/alert/VisorAlertCommand.scala | 94 +-
.../commands/cache/VisorCacheClearCommand.scala | 4 +-
.../commands/cache/VisorCacheCommand.scala | 18 +-
.../cache/VisorCacheCompactCommand.scala | 4 +-
.../commands/cache/VisorCacheScanCommand.scala | 4 +-
.../commands/cache/VisorCacheSwapCommand.scala | 4 +-
.../config/VisorConfigurationCommand.scala | 31 +-
.../commands/disco/VisorDiscoveryCommand.scala | 6 +-
.../commands/events/VisorEventsCommand.scala | 24 +-
.../visor/commands/gc/VisorGcCommand.scala | 4 +-
.../visor/commands/kill/VisorKillCommand.scala | 12 +-
.../visor/commands/node/VisorNodeCommand.scala | 2 +-
.../visor/commands/ping/VisorPingCommand.scala | 4 +-
.../commands/start/VisorStartCommand.scala | 4 +-
.../commands/tasks/VisorTasksCommand.scala | 12 +-
.../commands/top/VisorTopologyCommand.scala | 7 +-
.../visor/commands/vvm/VisorVvmCommand.scala | 6 +-
.../scala/org/apache/ignite/visor/visor.scala | 38 +-
.../commands/alert/VisorAlertCommandSpec.scala | 1 -
.../cache/VisorCacheClearCommandSpec.scala | 4 +-
.../commands/cache/VisorCacheCommandSpec.scala | 4 +-
.../cache/VisorCacheCompactCommandSpec.scala | 4 +-
.../config/VisorConfigurationCommandSpec.scala | 1 -
.../cswap/VisorCacheSwapCommandSpec.scala | 4 +-
.../disco/VisorDiscoveryCommandSpec.scala | 1 -
.../events/VisorEventsCommandSpec.scala | 1 -
.../visor/commands/gc/VisorGcCommandSpec.scala | 1 -
.../commands/tasks/VisorTasksCommandSpec.scala | 2 -
modules/web/pom.xml | 6 +
.../websession/IgniteWebSessionFilter.java | 6 +-
.../config/benchmark-multicast.properties | 2 +-
.../yardstick/IgniteBenchmarkArguments.java | 8 +-
.../cache/IgnitePutGetTxBenchmark.java | 2 +-
.../ignite/yardstick/cache/model/Person.java | 1 +
pom.xml | 195 +-
1412 files changed, 94317 insertions(+), 102975 deletions(-)
----------------------------------------------------------------------