Merge remote-tracking branch 'remotes/origin/master' into ignite-db-x-10884
Conflicts:
modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
modules/core/src/main/java/org/apache/ignite/internal/GridKernalContext.java
modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictableEntryImpl.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEntryEx.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSharedContext.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTransactionalCacheAdapter.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedSingleGetFuture.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/colocated/GridDhtColocatedCache.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheTestEntryEx.java
modules/core/src/test/java/org/apache/ignite/testsuites/IgniteKernalSelfTestSuite.java
pom.xml
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1643a7cc
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1643a7cc
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1643a7cc
Branch: refs/heads/ignite-db-x-10884
Commit: 1643a7cc90fd61292c672843854ab8d547156848
Parents: f61c260 e1eb931
Author: sboikov <[email protected]>
Authored: Fri Apr 22 15:28:51 2016 +0300
Committer: sboikov <[email protected]>
Committed: Fri Apr 22 15:28:51 2016 +0300
----------------------------------------------------------------------
.gitignore | 4 +
DEVNOTES.txt | 4 +-
assembly/dependencies-fabric-lgpl.xml | 1 +
assembly/dependencies-fabric.xml | 1 +
bin/ignite.bat | 7 +-
bin/ignite.sh | 6 +-
.../store/CacheLoadOnlyStoreExample.java | 171 +
.../streaming/StreamVisitorExample.java | 31 +-
examples/src/main/resources/person.csv | 20 +
.../ignite/examples/CacheExamplesSelfTest.java | 8 +
modules/aws/pom.xml | 38 +-
.../jmh/cache/JmhCacheAbstractBenchmark.java | 3 +
.../benchmarks/jmh/cache/JmhCacheBenchmark.java | 145 +
.../jmh/cache/JmhCachePutBenchmark.java | 124 -
.../jmh/runner/JmhIdeBenchmarkRunner.java | 20 +-
.../ClientAbstractMultiNodeSelfTest.java | 8 +-
.../rest/RestBinaryProtocolSelfTest.java | 4 +-
.../rest/RestMemcacheProtocolSelfTest.java | 4 +-
.../java/org/apache/ignite/IgniteCache.java | 20 +-
.../java/org/apache/ignite/IgniteQueue.java | 27 +-
.../main/java/org/apache/ignite/IgniteSet.java | 26 +-
.../apache/ignite/IgniteSystemProperties.java | 15 +-
.../main/java/org/apache/ignite/Ignition.java | 19 +-
.../ignite/binary/BinaryBasicNameMapper.java | 2 +-
.../ignite/cache/CacheInterceptorEntry.java | 39 +
.../apache/ignite/cache/CacheMemoryMode.java | 2 +
.../ignite/cache/affinity/AffinityFunction.java | 2 +
.../cache/query/CacheQueryEntryEvent.java | 48 +
.../ignite/cache/query/ContinuousQuery.java | 35 +
.../store/jdbc/CacheAbstractJdbcStore.java | 4 +
.../cache/store/jdbc/CacheJdbcPojoStore.java | 2 +-
.../configuration/ConnectorConfiguration.java | 3 +
.../configuration/FileSystemConfiguration.java | 96 +-
.../configuration/IgniteConfiguration.java | 92 +
.../ignite/configuration/OdbcConfiguration.java | 319 +
.../configuration/TransactionConfiguration.java | 32 +
.../igfs/IgfsIpcEndpointConfiguration.java | 28 +
.../java/org/apache/ignite/igfs/IgfsPath.java | 32 +-
.../internal/GridEventConsumeHandler.java | 7 +-
.../ignite/internal/GridJobCancelRequest.java | 5 +
.../ignite/internal/GridJobExecuteRequest.java | 5 +
.../ignite/internal/GridJobExecuteResponse.java | 5 +
.../ignite/internal/GridJobSiblingsRequest.java | 5 +
.../internal/GridJobSiblingsResponse.java | 5 +
.../ignite/internal/GridKernalContext.java | 9 +
.../ignite/internal/GridKernalContextImpl.java | 13 +
.../apache/ignite/internal/GridLoggerProxy.java | 3 +-
.../internal/GridMessageListenHandler.java | 23 +-
.../ignite/internal/GridTaskCancelRequest.java | 5 +
.../ignite/internal/GridTaskSessionRequest.java | 5 +
.../ignite/internal/IgniteComputeImpl.java | 4 +-
.../apache/ignite/internal/IgniteKernal.java | 52 +-
.../ignite/internal/IgniteNodeAttributes.java | 3 +
.../org/apache/ignite/internal/IgnitionEx.java | 67 +-
.../ignite/internal/MarshallerContextImpl.java | 10 +-
.../internal/binary/BinaryClassDescriptor.java | 24 +-
.../ignite/internal/binary/BinaryContext.java | 73 +-
.../internal/binary/BinaryEnumObjectImpl.java | 55 +-
.../internal/binary/BinaryFieldAccessor.java | 1 +
.../internal/binary/BinaryObjectImpl.java | 57 +-
.../binary/BinaryObjectOffheapImpl.java | 45 +-
.../internal/binary/BinaryReaderExImpl.java | 70 +-
.../ignite/internal/binary/BinarySchema.java | 11 +-
.../ignite/internal/binary/BinaryTypeImpl.java | 8 +
.../ignite/internal/binary/BinaryUtils.java | 119 +-
.../ignite/internal/binary/BinaryWriteMode.java | 3 +
.../internal/binary/BinaryWriterExImpl.java | 34 +
.../internal/binary/GridBinaryMarshaller.java | 7 +-
.../binary/builder/BinaryBuilderReader.java | 11 +-
.../binary/builder/BinaryBuilderSerializer.java | 16 +-
.../binary/builder/BinaryObjectBuilderImpl.java | 119 +-
.../binary/builder/BinaryValueWithType.java | 3 +-
.../internal/direct/DirectMessageReader.java | 2 +-
.../internal/direct/DirectMessageWriter.java | 4 +-
.../direct/state/DirectMessageState.java | 7 +-
.../stream/v2/DirectByteBufferStreamImplV2.java | 2 +-
.../ignite/internal/jdbc/JdbcStatement.java | 9 +-
.../ignite/internal/jdbc2/JdbcStatement.java | 7 +-
.../internal/managers/GridManagerAdapter.java | 4 +-
.../checkpoint/GridCheckpointManager.java | 2 +-
.../checkpoint/GridCheckpointRequest.java | 5 +
.../managers/communication/GridIoManager.java | 256 +-
.../managers/communication/GridIoMessage.java | 5 +
.../communication/GridIoMessageFactory.java | 4 +-
.../managers/communication/GridIoPolicy.java | 3 +
.../communication/GridIoUserMessage.java | 5 +
.../deployment/GridDeploymentCommunication.java | 5 +-
.../deployment/GridDeploymentInfoBean.java | 5 +
.../deployment/GridDeploymentLocalStore.java | 2 +-
.../deployment/GridDeploymentRequest.java | 5 +
.../deployment/GridDeploymentResponse.java | 5 +
.../discovery/GridDiscoveryManager.java | 92 +-
.../eventstorage/GridEventStorageManager.java | 10 +-
.../eventstorage/GridEventStorageMessage.java | 5 +
.../affinity/AffinityTopologyVersion.java | 5 +
.../affinity/GridAffinityAssignment.java | 100 +-
.../affinity/GridAffinityAssignmentCache.java | 314 +-
.../affinity/GridAffinityProcessor.java | 8 +-
.../processors/affinity/GridAffinityUtils.java | 6 +-
.../cache/CacheAffinityChangeMessage.java | 160 +
.../cache/CacheAffinitySharedManager.java | 1795 ++++++
.../cache/CacheClusterMetricsMXBeanImpl.java | 410 ++
.../cache/CacheEntryInfoCollection.java | 5 +
.../cache/CacheEntryPredicateAdapter.java | 8 +
.../cache/CacheEntryPredicateContainsValue.java | 8 +-
.../cache/CacheEntrySerializablePredicate.java | 8 +-
.../cache/CacheEvictableEntryImpl.java | 6 +-
.../processors/cache/CacheEvictionEntry.java | 5 +
.../cache/CacheInvokeDirectResult.java | 8 +-
.../processors/cache/CacheInvokeEntry.java | 41 +-
.../processors/cache/CacheLazyEntry.java | 62 +-
.../cache/CacheLocalMetricsMXBeanImpl.java | 410 ++
.../cache/CacheMetricsMXBeanImpl.java | 410 --
.../internal/processors/cache/CacheObject.java | 3 +
.../cache/CacheObjectByteArrayImpl.java | 5 +
.../processors/cache/CacheObjectImpl.java | 5 +
.../processors/cache/CacheOperationFilter.java | 61 +
.../cache/DynamicCacheChangeRequest.java | 17 +
.../cache/DynamicCacheDescriptor.java | 49 +
.../processors/cache/GridCacheAdapter.java | 633 +-
.../cache/GridCacheAffinityManager.java | 160 +-
.../processors/cache/GridCacheAtomicFuture.java | 5 -
.../cache/GridCacheClearAllRunnable.java | 3 +-
.../processors/cache/GridCacheContext.java | 22 +-
.../cache/GridCacheDeploymentManager.java | 13 +-
.../processors/cache/GridCacheEntryEx.java | 19 +-
.../processors/cache/GridCacheEntryInfo.java | 5 +
.../cache/GridCacheEvictionManager.java | 36 +-
.../processors/cache/GridCacheIoManager.java | 29 +-
.../processors/cache/GridCacheLogger.java | 3 +-
.../processors/cache/GridCacheMapEntry.java | 425 +-
.../processors/cache/GridCacheMessage.java | 9 +-
.../cache/GridCacheMvccCandidate.java | 16 +-
.../processors/cache/GridCacheMvccManager.java | 186 +-
.../GridCachePartitionExchangeManager.java | 194 +-
.../processors/cache/GridCachePreloader.java | 24 +-
.../cache/GridCachePreloaderAdapter.java | 17 +-
.../processors/cache/GridCacheProcessor.java | 289 +-
.../processors/cache/GridCacheProxyImpl.java | 110 +-
.../processors/cache/GridCacheReturn.java | 5 +
.../cache/GridCacheSharedContext.java | 18 +-
.../processors/cache/GridCacheSwapManager.java | 41 +-
.../processors/cache/GridCacheTtlManager.java | 75 +-
.../cache/GridCacheUpdateAtomicResult.java | 4 +-
.../processors/cache/GridCacheUtils.java | 209 +-
.../processors/cache/IgniteCacheProxy.java | 43 +-
.../processors/cache/IgniteInternalCache.java | 119 +-
.../processors/cache/KeyCacheObjectImpl.java | 5 +
.../cache/affinity/GridCacheAffinityImpl.java | 9 +-
.../binary/CacheObjectBinaryProcessorImpl.java | 18 +-
.../CacheDataStructuresManager.java | 8 +-
.../distributed/GridCacheCommittedTxInfo.java | 1 +
.../GridDistributedCacheAdapter.java | 2 +-
.../GridDistributedLockResponse.java | 11 +-
.../GridDistributedTxFinishRequest.java | 2 +
.../GridDistributedTxPrepareRequest.java | 2 +-
.../GridDistributedTxPrepareResponse.java | 3 +-
.../GridDistributedTxRemoteAdapter.java | 12 +-
.../dht/CacheDistributedGetFutureAdapter.java | 3 -
.../dht/GridClientPartitionTopology.java | 15 +-
.../dht/GridDhtAffinityAssignmentResponse.java | 199 +-
.../dht/GridDhtAssignmentFetchFuture.java | 80 +-
.../distributed/dht/GridDhtCacheAdapter.java | 128 +-
.../distributed/dht/GridDhtCacheEntry.java | 2 +-
.../distributed/dht/GridDhtEmbeddedFuture.java | 13 +-
.../cache/distributed/dht/GridDhtGetFuture.java | 178 +-
.../distributed/dht/GridDhtGetSingleFuture.java | 478 ++
.../distributed/dht/GridDhtLocalPartition.java | 76 +-
.../distributed/dht/GridDhtLockFuture.java | 24 +-
.../distributed/dht/GridDhtPartitionState.java | 2 +-
.../dht/GridDhtPartitionTopology.java | 15 +-
.../dht/GridDhtPartitionTopologyImpl.java | 367 +-
.../dht/GridDhtTransactionalCacheAdapter.java | 5 +-
.../distributed/dht/GridDhtTxFinishFuture.java | 29 +-
.../dht/GridDhtTxFinishResponse.java | 3 +-
.../cache/distributed/dht/GridDhtTxLocal.java | 210 +-
.../distributed/dht/GridDhtTxLocalAdapter.java | 4 +-
.../distributed/dht/GridDhtTxPrepareFuture.java | 69 +-
.../cache/distributed/dht/GridDhtTxRemote.java | 20 +-
.../dht/GridPartitionedGetFuture.java | 8 +-
.../dht/GridPartitionedSingleGetFuture.java | 8 +-
.../dht/atomic/GridDhtAtomicCache.java | 503 +-
.../dht/atomic/GridDhtAtomicUpdateFuture.java | 94 +-
.../dht/atomic/GridDhtAtomicUpdateRequest.java | 40 +-
.../dht/atomic/GridDhtAtomicUpdateResponse.java | 3 +-
.../GridNearAtomicAbstractUpdateFuture.java | 244 +
.../GridNearAtomicSingleUpdateFuture.java | 645 ++
.../dht/atomic/GridNearAtomicUpdateFuture.java | 1392 ++---
.../dht/atomic/GridNearAtomicUpdateRequest.java | 19 +-
.../atomic/GridNearAtomicUpdateResponse.java | 3 +-
.../dht/colocated/GridDhtColocatedCache.java | 46 +-
.../colocated/GridDhtColocatedLockFuture.java | 17 +-
.../dht/preloader/GridDhtForceKeysResponse.java | 3 +-
.../GridDhtPartitionDemandMessage.java | 3 +-
.../dht/preloader/GridDhtPartitionDemander.java | 51 +-
.../preloader/GridDhtPartitionExchangeId.java | 5 +
.../dht/preloader/GridDhtPartitionMap2.java | 4 +-
.../dht/preloader/GridDhtPartitionSupplier.java | 29 +-
.../GridDhtPartitionsExchangeFuture.java | 1538 +++--
.../preloader/GridDhtPartitionsFullMessage.java | 5 +-
.../GridDhtPartitionsSingleMessage.java | 5 +-
.../dht/preloader/GridDhtPreloader.java | 119 +-
.../distributed/near/CacheVersionedValue.java | 5 +
.../distributed/near/GridNearAtomicCache.java | 41 +-
.../distributed/near/GridNearCacheAdapter.java | 32 +-
.../distributed/near/GridNearCacheEntry.java | 120 +-
.../distributed/near/GridNearGetFuture.java | 26 +-
.../distributed/near/GridNearGetResponse.java | 3 +-
.../distributed/near/GridNearLockFuture.java | 10 +-
...arOptimisticSerializableTxPrepareFuture.java | 9 +-
.../near/GridNearOptimisticTxPrepareFuture.java | 54 +-
...ridNearOptimisticTxPrepareFutureAdapter.java | 16 +-
.../GridNearPessimisticTxPrepareFuture.java | 2 +-
.../near/GridNearSingleGetResponse.java | 3 +-
.../near/GridNearTransactionalCache.java | 7 +-
.../near/GridNearTxFinishFuture.java | 123 +-
.../near/GridNearTxFinishRequest.java | 46 +-
.../near/GridNearTxFinishResponse.java | 3 +-
.../cache/distributed/near/GridNearTxLocal.java | 115 +-
.../near/GridNearTxPrepareFutureAdapter.java | 4 +-
.../distributed/near/GridNearTxRemote.java | 33 +-
.../processors/cache/dr/GridCacheDrManager.java | 8 +-
.../cache/dr/GridOsCacheDrManager.java | 5 +-
.../cache/local/GridLocalCacheEntry.java | 27 -
.../cache/local/GridLocalLockFuture.java | 15 -
.../local/atomic/GridLocalAtomicCache.java | 121 +-
.../cache/query/GridCacheLocalQueryFuture.java | 7 +-
.../cache/query/GridCacheQueryManager.java | 569 +-
.../cache/query/GridCacheQueryRequest.java | 13 +-
.../cache/query/GridCacheQueryResponse.java | 3 +-
.../cache/query/GridCacheSqlQuery.java | 11 +-
.../CacheContinuousQueryBatchAck.java | 4 +
.../continuous/CacheContinuousQueryEntry.java | 5 +
.../continuous/CacheContinuousQueryEvent.java | 17 +-
.../continuous/CacheContinuousQueryHandler.java | 384 +-
.../CacheContinuousQueryHandlerV2.java | 176 +
.../CacheContinuousQueryListener.java | 5 +-
.../continuous/CacheContinuousQueryManager.java | 406 +-
.../jdbc/GridCacheQueryJdbcValidationTask.java | 3 +-
.../store/GridCacheStoreManagerAdapter.java | 3 +-
.../cache/transactions/IgniteInternalTx.java | 34 +-
.../transactions/IgniteTransactionsImpl.java | 9 +-
.../cache/transactions/IgniteTxAdapter.java | 99 +-
.../cache/transactions/IgniteTxEntry.java | 23 +-
.../cache/transactions/IgniteTxHandler.java | 33 +-
.../IgniteTxImplicitSingleStateImpl.java | 32 +-
.../cache/transactions/IgniteTxKey.java | 5 +
.../transactions/IgniteTxLocalAdapter.java | 170 +-
.../cache/transactions/IgniteTxLocalEx.java | 21 +-
.../cache/transactions/IgniteTxManager.java | 95 +-
.../IgniteTxRemoteSingleStateImpl.java | 6 +-
.../IgniteTxRemoteStateAdapter.java | 7 +-
.../cache/transactions/IgniteTxState.java | 5 +-
.../cache/transactions/IgniteTxStateImpl.java | 28 +-
.../cache/transactions/TxEntryValueHolder.java | 5 +
.../version/GridCacheRawVersionedEntry.java | 5 +-
.../cache/version/GridCacheVersion.java | 19 +-
.../cache/version/GridCacheVersionEx.java | 9 +
.../cache/version/GridCacheVersionManager.java | 21 +-
.../IgniteCacheObjectProcessorImpl.java | 5 +-
.../clock/GridClockDeltaSnapshotMessage.java | 5 +
.../processors/clock/GridClockDeltaVersion.java | 5 +
.../processors/clock/GridClockServer.java | 3 +-
.../closure/GridClosureProcessor.java | 413 +-
.../continuous/GridContinuousHandler.java | 4 +-
.../continuous/GridContinuousMessage.java | 5 +
.../continuous/GridContinuousProcessor.java | 103 +-
.../StartRoutineAckDiscoveryMessage.java | 22 +-
.../StartRoutineDiscoveryMessage.java | 22 +-
.../datastreamer/DataStreamProcessor.java | 12 +-
.../datastreamer/DataStreamerEntry.java | 5 +
.../datastreamer/DataStreamerImpl.java | 58 +-
.../datastreamer/DataStreamerRequest.java | 5 +
.../datastreamer/DataStreamerResponse.java | 5 +
.../datastructures/DataStructuresProcessor.java | 10 +-
.../datastructures/GridCacheAtomicLongImpl.java | 3 +-
.../GridCacheAtomicReferenceImpl.java | 70 +-
.../GridCacheAtomicSequenceImpl.java | 3 +-
.../GridCacheAtomicStampedImpl.java | 3 +-
.../GridCacheCountDownLatchImpl.java | 3 +-
.../datastructures/GridCacheQueueAdapter.java | 25 +
.../datastructures/GridCacheQueueProxy.java | 17 +-
.../datastructures/GridCacheSemaphoreEx.java | 5 +
.../datastructures/GridCacheSemaphoreImpl.java | 164 +-
.../datastructures/GridCacheSetImpl.java | 38 +-
.../datastructures/GridCacheSetProxy.java | 17 +-
.../processors/hadoop/HadoopNoopProcessor.java | 24 +-
.../processors/igfs/IgfsAckMessage.java | 5 +
.../internal/processors/igfs/IgfsBlockKey.java | 35 +-
.../processors/igfs/IgfsBlocksMessage.java | 5 +
.../IgfsColocatedMetadataAffinityKeyMapper.java | 47 +
.../processors/igfs/IgfsDataManager.java | 132 +-
.../processors/igfs/IgfsDeleteMessage.java | 5 +
.../processors/igfs/IgfsDeleteWorker.java | 71 +-
.../processors/igfs/IgfsDirectoryInfo.java | 284 +
.../internal/processors/igfs/IgfsEntryInfo.java | 319 +
.../ignite/internal/processors/igfs/IgfsEx.java | 12 -
.../processors/igfs/IgfsFileAffinityRange.java | 37 +-
.../internal/processors/igfs/IgfsFileImpl.java | 67 +-
.../internal/processors/igfs/IgfsFileInfo.java | 515 +-
.../internal/processors/igfs/IgfsFileMap.java | 50 +-
.../processors/igfs/IgfsFileWorkerBatch.java | 75 +-
.../IgfsFileWorkerBatchCancelledException.java | 51 +
.../igfs/IgfsFragmentizerManager.java | 107 +-
.../igfs/IgfsFragmentizerRequest.java | 5 +
.../igfs/IgfsFragmentizerResponse.java | 5 +
.../internal/processors/igfs/IgfsImpl.java | 162 +-
.../processors/igfs/IgfsInputStreamAdapter.java | 5 +-
.../processors/igfs/IgfsInputStreamImpl.java | 34 +-
.../igfs/IgfsInvalidRangeException.java | 4 +-
.../processors/igfs/IgfsIpcHandler.java | 109 +-
.../processors/igfs/IgfsListingEntry.java | 161 +-
.../processors/igfs/IgfsMetaManager.java | 2598 ++++----
.../processors/igfs/IgfsOutputStreamImpl.java | 116 +-
.../internal/processors/igfs/IgfsPathIds.java | 315 +
.../processors/igfs/IgfsPathsCreateResult.java | 64 +
.../internal/processors/igfs/IgfsProcessor.java | 60 +-
.../IgfsSecondaryInputStreamDescriptor.java | 6 +-
.../IgfsSecondaryOutputStreamDescriptor.java | 20 +-
.../internal/processors/igfs/IgfsServer.java | 2 +-
.../processors/igfs/IgfsSyncMessage.java | 5 +
.../internal/processors/igfs/IgfsUtils.java | 542 +-
.../meta/IgfsMetaDirectoryCreateProcessor.java | 172 +
.../IgfsMetaDirectoryListingAddProcessor.java | 136 +
...IgfsMetaDirectoryListingRemoveProcessor.java | 132 +
...gfsMetaDirectoryListingReplaceProcessor.java | 130 +
.../igfs/meta/IgfsMetaFileCreateProcessor.java | 172 +
.../igfs/meta/IgfsMetaFileLockProcessor.java | 107 +
.../meta/IgfsMetaFileRangeDeleteProcessor.java | 111 +
.../meta/IgfsMetaFileRangeUpdateProcessor.java | 120 +
.../meta/IgfsMetaFileReserveSpaceProcessor.java | 120 +
.../igfs/meta/IgfsMetaFileUnlockProcessor.java | 103 +
.../meta/IgfsMetaUpdatePropertiesProcessor.java | 121 +
.../igfs/meta/IgfsMetaUpdateTimesProcessor.java | 113 +
.../internal/processors/igfs/package-info.java | 2 +-
.../processors/job/GridJobProcessor.java | 30 +-
.../internal/processors/job/GridJobWorker.java | 2 +-
.../processors/odbc/OdbcBufferedParser.java | 81 +
.../processors/odbc/OdbcColumnMeta.java | 110 +
.../processors/odbc/OdbcHandshakeRequest.java | 49 +
.../processors/odbc/OdbcHandshakeResult.java | 66 +
.../processors/odbc/OdbcMessageParser.java | 277 +
.../processors/odbc/OdbcNioListener.java | 171 +
.../processors/odbc/OdbcNioServerBuffer.java | 114 +
.../internal/processors/odbc/OdbcProcessor.java | 116 +
.../processors/odbc/OdbcQueryCloseRequest.java | 49 +
.../processors/odbc/OdbcQueryCloseResult.java | 40 +
.../odbc/OdbcQueryExecuteRequest.java | 78 +
.../processors/odbc/OdbcQueryExecuteResult.java | 54 +
.../processors/odbc/OdbcQueryFetchRequest.java | 61 +
.../processors/odbc/OdbcQueryFetchResult.java | 66 +
.../odbc/OdbcQueryGetColumnsMetaRequest.java | 74 +
.../odbc/OdbcQueryGetColumnsMetaResult.java | 42 +
.../odbc/OdbcQueryGetTablesMetaRequest.java | 85 +
.../odbc/OdbcQueryGetTablesMetaResult.java | 42 +
.../internal/processors/odbc/OdbcRequest.java | 58 +
.../processors/odbc/OdbcRequestHandler.java | 362 ++
.../internal/processors/odbc/OdbcResponse.java | 96 +
.../internal/processors/odbc/OdbcTableMeta.java | 85 +
.../internal/processors/odbc/OdbcUtils.java | 56 +
.../offheap/GridOffHeapProcessor.java | 2 +-
.../processors/platform/PlatformContext.java | 16 +
.../platform/PlatformContextImpl.java | 86 +-
.../platform/PlatformNoopProcessor.java | 14 +-
.../processors/platform/PlatformProcessor.java | 20 +
.../platform/PlatformProcessorImpl.java | 58 +-
.../platform/cache/PlatformCache.java | 56 +-
.../callback/PlatformCallbackGateway.java | 30 +
.../callback/PlatformCallbackUtils.java | 16 +-
.../platform/cluster/PlatformClusterGroup.java | 12 +
.../platform/compute/PlatformCompute.java | 26 +-
.../datastreamer/PlatformDataStreamer.java | 7 +-
.../datastructures/PlatformAtomicReference.java | 146 +
.../datastructures/PlatformAtomicSequence.java | 122 +
.../PlatformDotNetConfigurationClosure.java | 5 -
.../platform/services/PlatformServices.java | 249 +-
.../utils/PlatformConfigurationUtils.java | 102 +-
.../platform/utils/PlatformFutureUtils.java | 2 +-
.../platform/utils/PlatformUtils.java | 128 +
.../processors/plugin/CachePluginManager.java | 25 +
.../processors/query/GridQueryProcessor.java | 13 +-
.../messages/GridQueryCancelRequest.java | 5 +
.../twostep/messages/GridQueryFailResponse.java | 5 +
.../messages/GridQueryNextPageRequest.java | 5 +
.../messages/GridQueryNextPageResponse.java | 5 +
.../h2/twostep/messages/GridQueryRequest.java | 5 +
.../handlers/cache/GridCacheCommandHandler.java | 2 +-
.../handlers/log/GridLogCommandHandler.java | 32 +-
.../handlers/task/GridTaskCommandHandler.java | 8 +-
.../handlers/task/GridTaskResultRequest.java | 5 +
.../handlers/task/GridTaskResultResponse.java | 5 +
.../rest/protocols/tcp/GridTcpRestProtocol.java | 7 +-
.../service/GridServiceProcessor.java | 173 +-
.../processors/service/GridServiceProxy.java | 239 +-
.../processors/task/GridTaskProcessor.java | 5 +-
.../processors/task/GridTaskWorker.java | 9 +-
.../ignite/internal/util/GridByteArrayList.java | 5 +
.../internal/util/GridExecutionStatistics.java | 106 -
.../ignite/internal/util/GridHandleTable.java | 7 +-
.../ignite/internal/util/GridLeanSet.java | 1 +
.../ignite/internal/util/GridLongList.java | 5 +
.../internal/util/GridMessageCollection.java | 5 +
.../ignite/internal/util/IgniteUtils.java | 97 +-
.../util/StripedCompositeReadWriteLock.java | 174 +
.../internal/util/UUIDCollectionMessage.java | 5 +
.../util/future/GridCompoundFuture.java | 2 +-
.../internal/util/future/GridFutureAdapter.java | 3 +-
.../shmem/IpcSharedMemoryServerEndpoint.java | 6 +-
.../ignite/internal/util/lang/GridFunc.java | 92 +-
.../ignite/internal/util/lang/GridTuple.java | 2 -
.../ignite/internal/util/lang/GridTuple3.java | 2 -
.../ignite/internal/util/lang/GridTuple4.java | 2 -
.../ignite/internal/util/lang/GridTuple5.java | 2 -
.../ignite/internal/util/lang/GridTuple6.java | 2 -
.../ignite/internal/util/lang/GridTupleV.java | 1 +
.../internal/util/nio/GridDirectParser.java | 4 +-
.../util/nio/GridNioFinishedFuture.java | 5 +
.../ignite/internal/util/nio/GridNioFuture.java | 7 +-
.../internal/util/nio/GridNioFutureImpl.java | 5 +
.../util/nio/GridNioRecoveryDescriptor.java | 23 +-
.../ignite/internal/util/nio/GridNioServer.java | 238 +-
.../util/nio/GridSelectorNioSessionImpl.java | 2 +-
.../util/nio/SelectedSelectionKeySet.java | 132 +
.../util/offheap/unsafe/GridUnsafeMap.java | 4 +-
.../apache/ignite/internal/util/typedef/X.java | 2 +-
.../ignite/internal/visor/cache/VisorCache.java | 11 +-
.../cache/VisorCacheAggregatedMetrics.java | 113 +-
.../internal/visor/cache/VisorCacheMetrics.java | 99 +-
.../cache/VisorCacheMetricsCollectorTask.java | 21 +-
.../visor/cache/VisorCacheMetricsV2.java | 66 +
.../visor/cache/VisorCacheResetMetricsTask.java | 2 +-
.../internal/visor/cache/VisorCacheV2.java | 2 +-
.../internal/visor/cache/VisorCacheV3.java | 108 +
.../visor/igfs/VisorIgfsProfilerTask.java | 20 +-
.../visor/node/VisorNodeDataCollectorJob.java | 31 +-
.../internal/visor/util/VisorTaskUtils.java | 4 +-
.../org/apache/ignite/lang/IgniteBiTuple.java | 6 +-
.../ignite/logger/java/JavaLoggerFormatter.java | 4 +-
.../apache/ignite/marshaller/Marshaller.java | 6 +-
.../optimized/OptimizedClassDescriptor.java | 37 +-
.../optimized/OptimizedMarshallerUtils.java | 3 +
.../optimized/OptimizedObjectInputStream.java | 15 +-
.../optimized/OptimizedObjectOutputStream.java | 4 +-
.../OptimizedObjectStreamRegistry.java | 145 +-
.../ignite/plugin/CachePluginProvider.java | 11 +
.../extensions/communication/Message.java | 5 +
.../ignite/resources/JobContextResource.java | 4 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 15 +
.../ignite/spi/IgniteSpiConsistencyChecked.java | 8 +
.../jobstealing/JobStealingCollisionSpi.java | 14 +-
.../jobstealing/JobStealingRequest.java | 5 +
.../communication/tcp/TcpCommunicationSpi.java | 57 +-
.../tcp/TcpCommunicationSpiMBean.java | 8 +-
.../ignite/spi/discovery/tcp/ClientImpl.java | 33 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 249 +-
.../spi/discovery/tcp/TcpDiscoverySpi.java | 29 +-
.../tcp/internal/TcpDiscoveryNode.java | 41 +-
.../TcpDiscoveryMulticastIpFinder.java | 1 +
.../sharedfs/TcpDiscoverySharedFsIpFinder.java | 35 +-
.../TcpDiscoveryCustomEventMessage.java | 12 +-
.../apache/ignite/spi/indexing/IndexingSpi.java | 4 +-
.../spi/swapspace/file/FileSwapSpaceSpi.java | 2 +
.../spi/swapspace/noop/NoopSwapSpaceSpi.java | 2 +
.../org/apache/ignite/thread/IgniteThread.java | 34 +-
.../ignite/thread/IgniteThreadFactory.java | 7 +-
.../resources/META-INF/classnames.properties | 102 +-
.../config/websession/example-cache-base.xml | 148 +
.../config/websession/example-cache-client.xml | 33 +
.../test/config/websession/example-cache.xml | 128 +-
.../test/config/websession/example-cache2.xml | 31 +
.../GridCacheAffinityBackupsSelfTest.java | 2 +-
.../affinity/AffinityClientNodeSelfTest.java | 4 +-
.../affinity/AffinityHistoryCleanupTest.java | 414 ++
.../fair/FairAffinityFunctionNodesSelfTest.java | 2 +
.../local/LocalAffinityFunctionTest.java | 80 +
.../CacheJdbcPojoStoreAbstractSelfTest.java | 28 +-
...eJdbcStoreAbstractMultithreadedSelfTest.java | 25 +-
.../ignite/cache/store/jdbc/model/Person.java | 25 +
.../ignite/igfs/IgfsEventsAbstractSelfTest.java | 24 +-
.../igfs/IgfsFragmentizerAbstractSelfTest.java | 4 +-
.../ComputeJobCancelWithServiceSelfTest.java | 154 +
.../internal/GridAffinityNoCacheSelfTest.java | 13 +-
.../ignite/internal/GridAffinitySelfTest.java | 9 +-
...omputationBinarylizableClosuresSelfTest.java | 413 ++
.../GridMultithreadedJobStealingSelfTest.java | 3 +-
.../internal/GridNodeMetricsLogSelfTest.java | 98 +
.../GridTaskCancelSingleNodeSelfTest.java | 37 +-
.../GridTaskFailoverAffinityRunTest.java | 6 +-
.../IgniteClientReconnectAbstractTest.java | 15 +-
.../IgniteClientReconnectAtomicsTest.java | 8 +-
.../IgniteClientReconnectCollectionsTest.java | 4 +-
.../IgniteClientReconnectComputeTest.java | 6 +-
...eClientReconnectContinuousProcessorTest.java | 32 +-
.../IgniteClientReconnectFailoverTest.java | 2 +
.../IgniteClientReconnectServicesTest.java | 4 +-
.../IgniteClientReconnectStreamerTest.java | 2 +-
.../internal/TestRecordingCommunicationSpi.java | 65 +-
.../internal/binary/BinaryEnumsSelfTest.java | 51 +-
.../binary/BinaryMarshallerSelfTest.java | 50 +
.../BinaryObjectBuilderAdditionalSelfTest.java | 231 +-
...naryObjectBuilderDefaultMappersSelfTest.java | 32 +-
.../GridCommunicationSendMessageSelfTest.java | 5 +
.../communication/GridIoManagerSelfTest.java | 5 +
.../BinaryObjectOffHeapUnswapTemporaryTest.java | 362 ++
.../cache/CacheAffinityCallSelfTest.java | 45 +-
.../cache/CacheConfigurationLeakTest.java | 62 +
.../cache/CacheEntryProcessorCopySelfTest.java | 213 +
.../cache/CacheEnumOperationsAbstractTest.java | 339 +
.../CacheEnumOperationsSingleNodeTest.java | 28 +
.../cache/CacheEnumOperationsTest.java | 28 +
...erceptorPartitionCounterLocalSanityTest.java | 687 ++
...torPartitionCounterRandomOperationsTest.java | 1054 ++++
.../CacheMetricsForClusterGroupSelfTest.java | 2 +-
.../processors/cache/CacheNamesSelfTest.java | 16 +-
.../CacheNamesWithSpecialCharactersTest.java | 71 +
...cheNearUpdateTopologyChangeAbstractTest.java | 2 +
.../cache/CacheReadThroughRestartSelfTest.java | 2 +
.../cache/CacheSwapUnswapGetTest.java | 4 +-
.../EntryVersionConsistencyReadThroughTest.java | 265 +
.../cache/GridCacheAbstractFullApiSelfTest.java | 75 +-
.../cache/GridCacheAbstractMetricsSelfTest.java | 124 +-
.../GridCacheAbstractRemoveFailureTest.java | 10 +-
.../cache/GridCacheAbstractSelfTest.java | 19 +
.../cache/GridCacheDeploymentSelfTest.java | 80 +-
.../cache/GridCacheEntryVersionSelfTest.java | 2 +-
.../GridCacheOffHeapValuesEvictionSelfTest.java | 210 +
.../GridCacheOnCopyFlagAbstractSelfTest.java | 479 +-
...ridCacheStoreManagerDeserializationTest.java | 354 ++
...ridCacheSwapSpaceSpiConsistencySelfTest.java | 146 +
...acheTcpClientDiscoveryMultiThreadedTest.java | 2 +-
.../processors/cache/GridCacheTestEntryEx.java | 10 +-
...cheTransactionalAbstractMetricsSelfTest.java | 4 +-
.../GridCacheVersionTopologyChangeTest.java | 246 +
...calCacheStoreManagerDeserializationTest.java | 101 +
.../cache/IgniteCacheAbstractTest.java | 6 +
.../IgniteCacheConfigVariationsFullApiTest.java | 5851 ++++++++++++++++++
.../IgniteCacheEntryListenerAbstractTest.java | 535 +-
...cheEntryListenerAtomicOffheapTieredTest.java | 32 +
...cheEntryListenerAtomicOffheapValuesTest.java | 32 +
...niteCacheEntryListenerExpiredEventsTest.java | 202 +
...teCacheEntryListenerTxOffheapTieredTest.java | 32 +
...teCacheEntryListenerTxOffheapValuesTest.java | 32 +
.../cache/IgniteCacheEntryListenerTxTest.java | 4 -
.../IgniteCacheEntryProcessorNodeJoinTest.java | 147 +-
.../cache/IgniteCacheIncrementTxTest.java | 299 +
.../IgniteCacheInterceptorSelfTestSuite.java | 2 +
.../cache/IgniteCacheNearLockValueSelfTest.java | 2 +-
.../IgniteCacheP2pUnmarshallingErrorTest.java | 1 -
...CacheP2pUnmarshallingRebalanceErrorTest.java | 36 +-
.../IgniteCacheP2pUnmarshallingTxErrorTest.java | 2 +
.../IgniteCachePutStackOverflowSelfTest.java | 133 +
...ReadThroughEvictionOffheapTiredSelfTest.java | 30 +
.../IgniteCacheReadThroughEvictionSelfTest.java | 359 ++
.../IgniteClientAffinityAssignmentSelfTest.java | 2 +-
...niteDynamicCacheStartStopConcurrentTest.java | 6 +-
.../IgniteDynamicClientCacheStartSelfTest.java | 97 +
.../cache/IgniteTxConfigCacheSelfTest.java | 249 +
.../cache/IgniteTxReentryAbstractSelfTest.java | 2 +-
.../MarshallerCacheJobRunNodeRestartTest.java | 307 +
.../GridCacheBinaryObjectsAbstractSelfTest.java | 221 +-
.../GridDataStreamerImplSelfTest.java | 49 +-
...eAbstractDataStructuresFailoverSelfTest.java | 56 +-
.../GridCacheQueueApiSelfAbstractTest.java | 104 +-
.../GridCacheSetAbstractSelfTest.java | 103 +-
.../CacheGetInsideLockChangingTopologyTest.java | 6 +
...eLateAffinityAssignmentFairAffinityTest.java | 32 +
...ffinityAssignmentNodeJoinValidationTest.java | 134 +
.../CacheLateAffinityAssignmentTest.java | 2688 ++++++++
.../GridCacheAbstractJobExecutionTest.java | 6 +-
.../GridCacheTransformEventSelfTest.java | 2 +-
...niteCacheClientNodeChangingTopologyTest.java | 28 +-
...teCacheClientNodePartitionsExchangeTest.java | 85 +-
.../IgniteCacheClientReconnectTest.java | 2 +
.../distributed/IgniteCacheCreatePutTest.java | 137 +-
.../distributed/IgniteCacheGetRestartTest.java | 4 +
.../distributed/IgniteCacheManyClientsTest.java | 6 +
.../IgniteCacheNearRestartRollbackSelfTest.java | 290 +
.../distributed/IgniteCachePrimarySyncTest.java | 45 +-
.../IgniteCacheReadFromBackupTest.java | 12 +-
.../IgniteCacheSingleGetMessageTest.java | 8 +-
.../IgniteTxCachePrimarySyncTest.java | 1114 ++++
...teSynchronizationModesMultithreadedTest.java | 422 ++
.../IgniteTxPreloadAbstractTest.java | 2 +-
.../dht/GridCacheColocatedDebugTest.java | 2 +-
.../GridCacheDhtPreloadMessageCountTest.java | 6 +-
...ePartitionedNearDisabledMetricsSelfTest.java | 2 +-
...idCachePartitionedPreloadEventsSelfTest.java | 11 +
...ridCachePartitionedUnloadEventsSelfTest.java | 2 +
.../dht/GridCacheTxNodeFailureSelfTest.java | 10 +-
.../IgniteCachePutRetryAbstractSelfTest.java | 4 +-
...imaryWriteOrderMultiNodeFullApiSelfTest.java | 35 +
...AtomicPartitionedTckMetricsSelfTestImpl.java | 92 +-
.../near/GridCacheNearJobExecutionSelfTest.java | 2 -
.../near/GridCacheNearMetricsSelfTest.java | 152 +-
.../near/GridCacheNearMultiNodeSelfTest.java | 4 +-
.../near/GridCacheNearReadersSelfTest.java | 21 +-
.../near/GridCacheNearTxForceKeyTest.java | 6 +-
...idCachePartitionedHitsAndMissesSelfTest.java | 2 +-
...LateAffDisabledMultiNodeFullApiSelfTest.java | 34 +
...achePartitionedMultiNodeCounterSelfTest.java | 43 +-
...achePartitionedMultiNodeFullApiSelfTest.java | 2 +
...idCacheRendezvousAffinityClientSelfTest.java | 2 +
...cingDelayedPartitionMapExchangeSelfTest.java | 14 +-
.../GridCacheRebalancingSyncSelfTest.java | 245 +-
.../GridCacheReplicatedJobExecutionTest.java | 2 -
...idCacheReplicatedPreloadOffHeapSelfTest.java | 3 +-
.../GridCacheReplicatedPreloadSelfTest.java | 397 +-
.../GridCacheEvictableEntryEqualsSelfTest.java | 85 +
...CacheAtomicLocalOffheapExpiryPolicyTest.java | 30 +
...gniteCacheAtomicOffheapExpiryPolicyTest.java | 30 +
...rimaryWriteOrderOffheapExpiryPolicyTest.java | 31 +
...teOrderWithStoreOffheapExpiryPolicyTest.java | 31 +
...AtomicReplicatedOffheapExpiryPolicyTest.java | 30 +
...eAtomicWithStoreOffheapExpiryPolicyTest.java | 30 +
.../IgniteCacheExpiryPolicyAbstractTest.java | 169 +-
.../IgniteCacheExpiryPolicyTestSuite.java | 13 +
...niteCacheTxLocalOffheapExpiryPolicyTest.java | 30 +
.../IgniteCacheTxOffheapExpiryPolicyTest.java | 30 +
...acheTxReplicatedOffheapExpiryPolicyTest.java | 30 +
...CacheTxWithStoreOffheapExpiryPolicyTest.java | 30 +
...CacheLocalOffHeapAndSwapMetricsSelfTest.java | 380 +-
...dCacheAtomicLocalTckMetricsSelfTestImpl.java | 92 +-
.../continuous/CacheContinuousBatchAckTest.java | 355 ++
...heContinuousBatchForceServerModeAckTest.java | 80 +
...CacheContinuousQueryCounterAbstractTest.java | 612 ++
...inuousQueryCounterPartitionedAtomicTest.java | 41 +
...ContinuousQueryCounterPartitionedTxTest.java | 41 +
...tinuousQueryCounterReplicatedAtomicTest.java | 41 +
...eContinuousQueryCounterReplicatedTxTest.java | 41 +
...acheContinuousQueryExecuteInPrimaryTest.java | 306 +
.../CacheContinuousQueryFactoryFilterTest.java | 714 +++
...ContinuousQueryFailoverAbstractSelfTest.java | 61 +-
...tomicPrimaryWriteOrderOffheapTieredTest.java | 33 +
...tinuousQueryFailoverTxOffheapTieredTest.java | 32 +
.../CacheContinuousQueryLostPartitionTest.java | 2 +-
.../CacheContinuousQueryOperationP2PTest.java | 326 +
...acheContinuousQueryRandomOperationsTest.java | 1799 ++++++
...inuousQueryRandomOperationsTwoNodesTest.java | 28 +
...ridCacheContinuousQueryAbstractSelfTest.java | 19 +-
...eContinuousQueryAtomicOffheapTieredTest.java | 32 +
...eContinuousQueryAtomicOffheapValuesTest.java | 32 +
.../GridCacheContinuousQueryConcurrentTest.java | 466 ++
...CacheContinuousQueryTxOffheapTieredTest.java | 32 +
...CacheContinuousQueryTxOffheapValuesTest.java | 32 +
...IgniteCacheContinuousQueryReconnectTest.java | 192 +
...BehindStorePartitionedMultiNodeSelfTest.java | 11 +-
.../processors/igfs/IgfsAbstractSelfTest.java | 180 +-
...lockMessageSystemPoolStarvationSelfTest.java | 299 +
.../igfs/IgfsDataManagerSelfTest.java | 67 +-
.../igfs/IgfsDualAbstractSelfTest.java | 104 +-
.../processors/igfs/IgfsFileInfoSelfTest.java | 26 +-
.../igfs/IgfsMetaManagerSelfTest.java | 105 +-
.../igfs/IgfsPrimaryMultiNodeSelfTest.java | 28 +
.../IgfsPrimaryOptimziedMarshallerSelfTest.java | 28 +
...maryRelaxedConsistencyMultiNodeSelfTest.java | 28 +
.../IgfsPrimaryRelaxedConsistencySelfTest.java | 28 +
.../processors/igfs/IgfsProcessorSelfTest.java | 71 +-
.../igfs/IgfsProcessorValidationSelfTest.java | 43 +
.../processors/igfs/IgfsSizeSelfTest.java | 40 +-
.../processors/igfs/IgfsStartCacheTest.java | 9 +-
.../processors/igfs/IgfsStreamsSelfTest.java | 27 +-
.../handlers/log/GridLogCommandHandlerTest.java | 97 +-
...GridServiceProxyClientReconnectSelfTest.java | 124 +
.../GridServiceProxyNodeStopSelfTest.java | 105 +
.../GridServiceSerializationSelfTest.java | 149 +
.../processors/service/inner/MyService.java | 11 +
.../processors/service/inner/MyServiceImpl.java | 10 +
.../internal/util/GridHandleTableSelfTest.java | 50 +
.../ignite/jvmtest/ConcurrentMapTest.java | 3 +-
.../apache/ignite/lang/GridTupleSelfTest.java | 42 +-
.../communication/GridTestMessage.java | 5 +
.../loadtests/hashmap/GridCacheTestContext.java | 2 +
...namicProxySerializationMultiJvmSelfTest.java | 191 +
.../OptimizedMarshallerPooledSelfTest.java | 44 +
.../platform/PlatformAttributeNodeFilter.java | 31 +
.../platform/PlatformComputeEchoTask.java | 11 +-
.../platform/PlatformDeployServiceTask.java | 360 ++
.../ignite/platform/PlatformSqlQueryTask.java | 117 +
.../platform/PlatformStartIgniteTask.java | 77 +
.../ignite/platform/PlatformStopIgniteTask.java | 74 +
.../GridSessionCheckpointAbstractSelfTest.java | 6 +-
.../spi/communication/GridTestMessage.java | 5 +
.../GridTcpCommunicationSpiConfigSelfTest.java | 22 +
.../tcp/TcpClientDiscoverySpiSelfTest.java | 10 +-
.../spi/discovery/tcp/TcpDiscoverySelfTest.java | 189 +-
.../tcp/TcpDiscoverySpiConfigSelfTest.java | 22 +
.../TcpDiscoverySpiFailureTimeoutSelfTest.java | 23 +-
.../spi/discovery/tcp/TestTcpDiscoverySpi.java | 5 +-
.../TcpDiscoveryIpFinderAbstractSelfTest.java | 15 +-
.../GridSwapSpaceSpiConsistencySelfTest.java | 131 +
.../ignite/testframework/GridTestUtils.java | 5 +-
.../configvariations/CacheStartMode.java | 29 +
.../configvariations/ConfigFactory.java | 39 +
.../configvariations/ConfigParameter.java | 34 +
.../configvariations/ConfigVariations.java | 346 ++
.../ConfigVariationsFactory.java | 197 +
.../ConfigVariationsTestSuiteBuilder.java | 382 ++
.../IgniteConfigVariationsTestSuite.java | 50 +
.../configvariations/Parameters.java | 377 ++
.../configvariations/VariationsIterator.java | 174 +
.../configvariations/VariationsTestsConfig.java | 161 +
.../testframework/junits/GridAbstractTest.java | 52 +-
.../junits/GridTestKernalContext.java | 34 +-
...IgniteCacheConfigVariationsAbstractTest.java | 583 ++
.../IgniteConfigVariationsAbstractTest.java | 420 ++
.../junits/common/GridCommonAbstractTest.java | 171 +-
.../multijvm/IgniteCacheProcessProxy.java | 8 +
.../junits/multijvm/IgniteNodeRunner.java | 16 +-
.../junits/multijvm/IgniteProcessProxy.java | 19 +-
.../ConfigVariationsTestSuiteBuilderTest.java | 112 +
.../testframework/test/ParametersTest.java | 87 +
.../test/VariationsIteratorTest.java | 156 +
.../ignite/testsuites/IgniteBasicTestSuite.java | 13 +
.../testsuites/IgniteBinaryBasicTestSuite.java | 6 +
.../testsuites/IgniteBinaryCacheTestSuite.java | 2 +
...IgniteBinaryObjectsComputeGridTestSuite.java | 7 +-
.../IgniteBinaryObjectsTestSuite.java | 8 +-
...heBasicConfigVariationsFullApiTestSuite.java | 41 +
.../IgniteCacheDataStructuresSelfTestSuite.java | 10 +-
.../IgniteCacheEvictionSelfTestSuite.java | 4 +-
.../IgniteCacheFullApiSelfTestSuite.java | 6 +
.../testsuites/IgniteCacheRestartTestSuite.java | 2 +
.../ignite/testsuites/IgniteCacheTestSuite.java | 21 +
.../testsuites/IgniteCacheTestSuite2.java | 10 +
.../testsuites/IgniteCacheTestSuite3.java | 2 +
.../testsuites/IgniteCacheTestSuite4.java | 20 +-
.../testsuites/IgniteCacheTestSuite5.java | 15 +-
.../ignite/testsuites/IgniteIgfsTestSuite.java | 21 +-
.../testsuites/IgniteKernalSelfTestSuite.java | 11 +-
.../IgniteMarshallerSelfTestSuite.java | 8 +-
.../IgniteSpiSwapSpaceSelfTestSuite.java | 2 +
.../p2p/CacheDeploymentAffinityKeyMapper.java | 35 +
.../CacheDeploymentAlwaysTruePredicate2.java | 30 +
...oymentCacheEntryEventSerializableFilter.java | 32 +
.../p2p/CacheDeploymentCacheEntryListener.java | 31 +
...CacheDeploymentCachePluginConfiguration.java | 81 +
.../p2p/CacheDeploymentEntryEventFilter.java | 33 +
.../CacheDeploymentEntryEventFilterFactory.java | 31 +
.../CacheDeploymentExternalizableTestValue.java | 69 +
...heDeploymentStoreSessionListenerFactory.java | 83 +
modules/flink/README.txt | 33 +
modules/flink/licenses/apache-2.0.txt | 202 +
modules/flink/pom.xml | 167 +
.../apache/ignite/sink/flink/IgniteSink.java | 204 +
.../apache/ignite/sink/flink/package-info.java | 22 +
.../sink/flink/FlinkIgniteSinkSelfTest.java | 188 +
.../flink/FlinkIgniteSinkSelfTestSuite.java | 38 +
.../flink/src/test/resources/example-ignite.xml | 70 +
.../hadoop/fs/BasicHadoopFileSystemFactory.java | 22 +-
.../fs/CachingHadoopFileSystemFactory.java | 2 +-
.../fs/IgniteHadoopIgfsSecondaryFileSystem.java | 45 +-
.../fs/KerberosHadoopFileSystemFactory.java | 217 +
.../hadoop/fs/v1/IgniteHadoopFileSystem.java | 19 +-
.../hadoop/fs/v2/IgniteHadoopFileSystem.java | 21 +-
.../processors/hadoop/HadoopContext.java | 3 +-
.../hadoop/igfs/HadoopIgfsProperties.java | 11 +-
.../hadoop/igfs/HadoopIgfsWrapper.java | 11 +-
.../hadoop/jobtracker/HadoopJobTracker.java | 13 +-
.../child/HadoopChildProcessRunner.java | 2 +-
.../hadoop/cache/HadoopTxConfigCacheTest.java | 42 +
...KerberosHadoopFileSystemFactorySelfTest.java | 121 +
.../ignite/igfs/Hadoop1DualAbstractTest.java | 5 +-
...oopFileSystemUniversalFileSystemAdapter.java | 8 +-
.../HadoopIgfs20FileSystemAbstractSelfTest.java | 2 +
.../igfs/HadoopIgfsDualAbstractSelfTest.java | 11 +-
.../apache/ignite/igfs/IgfsEventsTestSuite.java | 16 +-
.../IgniteHadoopFileSystemAbstractSelfTest.java | 2 +
...IgniteHadoopFileSystemHandshakeSelfTest.java | 121 +-
.../IgniteHadoopFileSystemLoggerSelfTest.java | 21 +-
.../hadoop/HadoopAbstractMapReduceTest.java | 405 ++
.../processors/hadoop/HadoopErrorSimulator.java | 326 +
.../HadoopMapReduceErrorResilienceTest.java | 154 +
.../processors/hadoop/HadoopMapReduceTest.java | 379 +-
.../hadoop/HadoopNoHadoopMapReduceTest.java | 47 +
.../hadoop/HadoopSnappyFullMapReduceTest.java | 8 +
.../hadoop/examples/HadoopWordCount1Map.java | 12 +
.../hadoop/examples/HadoopWordCount1Reduce.java | 5 +
.../hadoop/examples/HadoopWordCount2.java | 2 +-
.../examples/HadoopWordCount2Combiner.java | 45 +
.../hadoop/examples/HadoopWordCount2Mapper.java | 19 +-
.../examples/HadoopWordCount2Reducer.java | 43 +-
.../testsuites/IgniteHadoopTestSuite.java | 46 +-
.../HibernateL2CacheTransactionalSelfTest.java | 9 +
...nateL2CacheTransactionalUseSyncSelfTest.java | 31 +
.../testsuites/IgniteHibernateTestSuite.java | 4 +-
.../processors/query/h2/IgniteH2Indexing.java | 65 +-
.../query/h2/opt/GridH2ValueCacheObject.java | 9 +
.../query/h2/sql/GridSqlAggregateFunction.java | 12 +-
.../query/h2/sql/GridSqlQueryParser.java | 30 +-
.../query/h2/sql/GridSqlQuerySplitter.java | 6 +-
.../processors/query/h2/sql/GridSqlSelect.java | 2 +-
.../query/h2/twostep/GridMapQueryExecutor.java | 2 +-
.../query/h2/twostep/GridMergeIndex.java | 32 +-
.../h2/twostep/GridMergeIndexUnsorted.java | 19 +-
.../query/h2/twostep/GridMergeTable.java | 16 +-
.../h2/twostep/GridReduceQueryExecutor.java | 6 +-
.../h2/twostep/msg/GridH2ValueMessage.java | 5 +
.../cache/AtomicBinaryOffheapBatchTest.java | 384 ++
.../cache/CacheQueryBuildValueTest.java | 144 +
.../cache/CacheQueryNewClientSelfTest.java | 115 +
.../CacheQueryOffheapEvictDataLostTest.java | 138 +
.../CacheRandomOperationsMultithreadedTest.java | 507 ++
.../IgniteBinaryObjectQueryArgumentsTest.java | 161 +
.../cache/IgniteCacheAbstractQuerySelfTest.java | 197 +-
.../cache/IgniteClientReconnectQueriesTest.java | 13 +-
.../near/IgniteCacheQueryNodeFailTest.java | 148 +
.../IgniteCacheQueryNodeRestartSelfTest2.java | 3 +
.../h2/GridIndexingSpiAbstractSelfTest.java | 43 +-
.../IgniteBinaryCacheQueryTestSuite.java | 1 -
.../IgniteBinaryCacheQueryTestSuite2.java | 39 +
.../IgniteBinaryCacheQueryTestSuite3.java | 39 +
.../IgniteBinaryCacheQueryTestSuite4.java | 39 +
.../IgniteCacheQuerySelfTestSuite.java | 117 +-
.../IgniteCacheQuerySelfTestSuite2.java | 109 +
.../IgniteCacheQuerySelfTestSuite3.java | 99 +
.../IgniteCacheQuerySelfTestSuite4.java | 49 +
.../IgniteCacheWithIndexingTestSuite.java | 2 +
.../processors/cache/jta/CacheJtaManager.java | 26 +-
.../processors/cache/jta/CacheJtaResource.java | 304 +
.../cache/jta/GridCacheXAResource.java | 251 -
.../cache/AbstarctCacheJtaSelfTest.java | 183 -
.../cache/AbstractCacheJtaSelfTest.java | 183 +
.../GridPartitionedCacheJtaFactorySelfTest.java | 2 +-
...rtitionedCacheJtaFactoryUseSyncSelfTest.java | 32 +
...titionedCacheJtaLookupClassNameSelfTest.java | 2 +-
...eplicatedCacheJtaFactoryUseSyncSelfTest.java | 32 +
.../ignite/testsuites/IgniteJtaTestSuite.java | 5 +
modules/kafka/README.txt | 85 +-
.../kafka/connect/IgniteSourceConnector.java | 81 +
.../kafka/connect/IgniteSourceConstants.java | 44 +
.../stream/kafka/connect/IgniteSourceTask.java | 335 +
.../serialization/CacheEventConverter.java | 66 +
.../serialization/CacheEventDeserializer.java | 54 +
.../serialization/CacheEventSerializer.java | 54 +
.../kafka/IgniteKafkaStreamerSelfTestSuite.java | 4 +-
.../kafka/KafkaIgniteStreamerSelfTest.java | 11 +-
.../ignite/stream/kafka/TestKafkaBroker.java | 27 +-
.../kafka/connect/IgniteSinkConnectorTest.java | 13 +-
.../connect/IgniteSourceConnectorMock.java | 31 +
.../connect/IgniteSourceConnectorTest.java | 327 +
.../kafka/connect/IgniteSourceTaskMock.java | 31 +
.../kafka/connect/TestCacheEventFilter.java | 31 +
.../kafka/src/test/resources/example-ignite.xml | 4 +-
.../osgi-karaf/src/main/resources/features.xml | 12 +-
.../cpp/common/include/ignite/common/exports.h | 21 +-
.../cpp/common/include/ignite/common/java.h | 53 +-
.../os/linux/include/ignite/common/common.h | 20 +-
.../os/win/include/ignite/common/common.h | 8 +-
.../platforms/cpp/common/project/vs/module.def | 15 +-
modules/platforms/cpp/common/src/exports.cpp | 58 +-
modules/platforms/cpp/common/src/java.cpp | 285 +-
modules/platforms/cpp/core-test/Makefile.am | 2 +
.../cpp/core-test/project/vs/core-test.vcxproj | 2 +
.../project/vs/core-test.vcxproj.filters | 6 +
.../cpp/core-test/src/cache_query_test.cpp | 45 +
.../platforms/cpp/core-test/src/cache_test.cpp | 12 +
.../cpp/core-test/src/ignite_error_test.cpp | 45 +
.../cpp/core-test/src/interop_memory_test.cpp | 95 +
.../ignite/cache/query/query_fields_row.h | 2 +-
.../cpp/core/include/ignite/ignite_error.h | 18 +-
.../include/ignite/impl/ignite_environment.h | 19 +-
modules/platforms/cpp/core/src/ignite_error.cpp | 32 +-
.../impl/binary/binary_type_updater_impl.cpp | 2 +
.../cpp/core/src/impl/cache/cache_impl.cpp | 2 +-
.../cpp/core/src/impl/ignite_environment.cpp | 30 +-
.../Apache.Ignite.Benchmarks.csproj | 36 +-
.../Apache.Ignite.Core.Tests.NuGet.csproj | 134 +
.../Apache.Ignite.Core.Tests.NuGet.sln | 32 +
...ache.Ignite.Core.Tests.NuGet.sln.DotSettings | 4 +
.../Apache.Ignite.Core.Tests.NuGet/CacheTest.cs | 134 +
.../ComputeTest.cs | 84 +
.../Config/ignite-config.xml | 50 +
.../Apache.Ignite.Core.Tests.NuGet/NuGet.config | 35 +
.../Properties/AssemblyInfo.cs | 35 +
.../StartupTest.cs | 66 +
.../TestRunner.cs | 70 +
.../Apache.Ignite.Core.Tests.NuGet/TestUtil.cs | 43 +
.../install-package.ps1 | 25 +
.../packages.config | 24 +
.../Apache.Ignite.Core.Tests.TestDll.csproj | 32 +-
.../Apache.Ignite.Core.Tests.csproj | 135 +-
.../Binary/BinaryBuilderSelfTest.cs | 87 +-
.../Binary/BinaryBuilderSelfTestFullFooter.cs | 31 +
.../Binary/BinaryCompactFooterInteropTest.cs | 129 +
.../Binary/BinarySelfTest.cs | 278 +-
.../Binary/BinarySelfTestFullFooter.cs | 35 +
.../Binary/BinaryStructureTest.cs | 38 +-
.../Cache/CacheAffinityFieldTest.cs | 199 +
.../Cache/CacheConfigurationTest.cs | 18 +-
.../Cache/CacheTestAsyncWrapper.cs | 12 +
.../Cache/Query/CacheLinqTest.cs | 1272 ++++
.../Query/CacheQueriesCodeConfigurationTest.cs | 20 +-
.../Cache/Query/CacheQueriesTest.cs | 13 +-
.../Continuous/ContinuousQueryAbstractTest.cs | 25 +-
.../Cache/Store/CacheStoreTest.cs | 36 +-
.../Cache/Store/CacheStoreTestCodeConfig.cs | 106 +
.../Cache/Store/CacheTestStore.cs | 2 +-
.../Compute/ComputeApiTest.cs | 62 +-
.../Compute/ComputeApiTestFullFooter.cs | 65 +
.../Compute/MixedClusterTest.cs | 183 +
.../Config/Apache.Ignite.exe.config.test2 | 58 +
.../Config/Apache.Ignite.exe.config.test3 | 34 +
.../Config/Cache/Store/cache-store-session.xml | 3 +-
.../Config/Compute/compute-grid1.xml | 24 +-
.../Config/Compute/compute-grid2.xml | 20 +-
.../Config/Compute/compute-grid3.xml | 7 +-
.../Config/Compute/compute-standalone.xml | 4 +-
.../Config/Dynamic/dynamic-client.xml | 3 +-
.../Config/Dynamic/dynamic-data-no-cfg.xml | 3 +-
.../Config/Dynamic/dynamic-data.xml | 3 +-
.../Config/Lifecycle/lifecycle-beans.xml | 3 +-
.../Config/Lifecycle/lifecycle-no-beans.xml | 3 +-
.../Apache.Ignite.Core.Tests/Config/binary.xml | 56 -
.../Config/cache-binarizables.xml | 3 +-
.../Config/cache-local-node.xml | 66 +
.../Config/cache-query-continuous.xml | 3 +-
.../Config/cache-query.xml | 5 +-
.../Config/ignite-dotnet-cfg.xml | 52 +
.../Config/marshaller-default.xml | 3 +-
.../Config/marshaller-explicit.xml | 3 +-
.../Config/marshaller-invalid.xml | 3 +-
.../native-client-test-cache-affinity.xml | 3 +-
.../native-client-test-cache-parallel-store.xml | 3 +-
.../Config/native-client-test-cache-store.xml | 3 +-
.../Config/native-client-test-cache.xml | 3 +-
.../Config/reconnect-test.xml | 43 +
.../Config/start-test-grid1.xml | 3 +-
.../Config/start-test-grid2.xml | 3 +-
.../Config/start-test-grid3.xml | 3 +-
.../DataStructures/AtomicReferenceTest.cs | 239 +
.../DataStructures/AtomicSequenceTest.cs | 131 +
.../Dataload/DataStreamerTestTopologyChange.cs | 104 +
.../Apache.Ignite.Core.Tests/DeploymentTest.cs | 180 +
.../Examples/ExamplesTest.cs | 3 +-
.../Examples/ProjectFilesTest.cs | 2 +-
.../Apache.Ignite.Core.Tests/ExceptionsTest.cs | 5 +
.../Apache.Ignite.Core.Tests/ExecutableTest.cs | 89 +-
.../Apache.Ignite.Core.Tests/FutureTest.cs | 1 +
.../IgniteConfigurationSectionTest.cs | 69 +
.../IgniteConfigurationSerializerTest.cs | 594 ++
.../IgniteConfigurationTest.cs | 55 +-
.../IgniteStartStopTest.cs | 58 +-
.../Apache.Ignite.Core.Tests/JavaHomeTest.cs | 69 +
.../Process/IgniteProcess.cs | 31 +-
.../ProcessExtensions.cs | 78 +
.../ProjectFilesTest.cs | 88 +
.../Apache.Ignite.Core.Tests/ReconnectTest.cs | 97 +
.../Services/ServiceProxyTest.cs | 6 +-
.../Services/ServicesTest.cs | 273 +-
.../Services/ServicesTestFullFooter.cs | 33 +
.../Apache.Ignite.Core.Tests/TestRunner.cs | 2 +-
.../Apache.Ignite.Core.Tests/TestUtils.cs | 34 +-
.../dotnet/Apache.Ignite.Core.Tests/app.config | 54 +
.../Apache.Ignite.Core.csproj | 68 +-
.../Apache.Ignite.Core.nuspec | 75 +
.../Binary/BinaryConfiguration.cs | 44 +-
.../Binary/BinaryReflectiveSerializer.cs | 241 +
.../Binary/IBinarySerializer.cs | 6 +-
.../Cache/Affinity/AffinityKey.cs | 162 +
.../Affinity/AffinityKeyMappedAttribute.cs | 46 +
.../Cache/CachePartialUpdateException.cs | 1 -
.../Cache/Configuration/CacheConfiguration.cs | 36 +
.../Cache/Configuration/QueryEntity.cs | 17 +-
.../Cache/Configuration/QueryField.cs | 2 +-
.../dotnet/Apache.Ignite.Core/Cache/ICache.cs | 26 +
.../Cache/Store/CacheStoreAdapter.cs | 1 -
.../Apache.Ignite.Core/Cluster/ICluster.cs | 14 +
.../Common/ClientDisconnectedException.cs | 97 +
.../Compute/ComputeTaskAdapter.cs | 1 -
.../Compute/ComputeTaskSplitAdapter.cs | 1 -
.../Configuration/AtomicConfiguration.cs | 58 +
.../DataStructures/IAtomicReference.cs | 64 +
.../DataStructures/IAtomicSequence.cs | 69 +
.../Multicast/TcpDiscoveryMulticastIpFinder.cs | 6 +-
.../Tcp/Static/TcpDiscoveryStaticIpFinder.cs | 6 +-
.../Apache.Ignite.Core/Events/EventBase.cs | 1 -
.../dotnet/Apache.Ignite.Core/IIgnite.cs | 28 +
.../Apache.Ignite.Core/IgniteConfiguration.cs | 139 +-
.../IgniteConfigurationSection.cs | 80 +
.../IgniteConfigurationSection.xsd | 316 +
.../dotnet/Apache.Ignite.Core/Ignition.cs | 97 +-
.../Apache.Ignite.Core/Impl/Binary/Binary.cs | 8 +-
.../Impl/Binary/BinaryHandleDictionary.cs | 32 +-
.../Impl/Binary/BinaryObject.cs | 9 +-
.../Impl/Binary/BinaryObjectBuilder.cs | 9 +-
.../Impl/Binary/BinaryObjectHeader.cs | 176 +-
.../Impl/Binary/BinaryObjectSchema.cs | 20 +
.../Impl/Binary/BinaryObjectSchemaHolder.cs | 18 +-
.../Impl/Binary/BinaryObjectSchemaSerializer.cs | 262 +
.../Impl/Binary/BinaryReader.cs | 109 +-
.../Impl/Binary/BinaryReaderHandleDictionary.cs | 2 +-
.../Impl/Binary/BinaryReflectiveActions.cs | 611 +-
.../Impl/Binary/BinaryReflectiveSerializer.cs | 218 -
.../Impl/Binary/BinarySystemHandlers.cs | 147 +-
.../Impl/Binary/BinaryUtils.cs | 180 +-
.../Impl/Binary/BinaryWriter.cs | 72 +-
.../Apache.Ignite.Core/Impl/Binary/JavaTypes.cs | 29 +-
.../Impl/Binary/Marshaller.cs | 45 +-
.../Impl/Binary/Metadata/BinaryType.cs | 28 +-
.../Impl/Binary/ReferenceEqualityComparer.cs | 45 +
.../Apache.Ignite.Core/Impl/Cache/CacheEntry.cs | 2 +-
.../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 56 +-
.../Apache.Ignite.Core/Impl/Cache/CacheOp.cs | 3 +-
.../Impl/Cache/ICacheInternal.cs | 40 +
.../Impl/Cache/Query/FieldsQueryCursor.cs | 26 +-
.../Impl/Cluster/ClusterGroupImpl.cs | 15 +
.../Impl/Cluster/ClusterNodeImpl.cs | 2 +-
.../Impl/Common/BooleanLowerCaseConverter.cs | 60 +
.../Apache.Ignite.Core/Impl/Common/Classpath.cs | 18 +-
.../Impl/Common/DelegateConverter.cs | 131 +-
.../Apache.Ignite.Core/Impl/Common/Future.cs | 14 +-
.../Impl/Common/FutureType.cs | 18 +-
.../Common/IgniteConfigurationXmlSerializer.cs | 472 ++
.../Impl/Common/IgniteHome.cs | 9 +-
.../Apache.Ignite.Core/Impl/Common/Logger.cs | 37 +
.../Impl/Common/ObjectStringConverter.cs | 104 +
.../Apache.Ignite.Core/Impl/Common/Platform.cs | 35 +
.../Impl/Common/TypeCaster.cs | 12 +
.../Impl/Common/TypeStringConverter.cs | 115 +
.../Closure/ComputeAbstractClosureTask.cs | 1 -
.../Impl/Compute/ComputeTaskHolder.cs | 2 +-
.../Impl/DataStructures/AtomicReference.cs | 92 +
.../Impl/DataStructures/AtomicSequence.cs | 90 +
.../Impl/Datastream/DataStreamerImpl.cs | 9 +-
.../Impl/Events/EventTypeConverter.cs | 133 +
.../Apache.Ignite.Core/Impl/ExceptionUtils.cs | 110 +-
.../Apache.Ignite.Core/Impl/Handle/Handle.cs | 8 +-
.../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 101 +-
.../Apache.Ignite.Core/Impl/IgniteManager.cs | 19 +-
.../Apache.Ignite.Core/Impl/IgniteProxy.cs | 19 +
.../Apache.Ignite.Core/Impl/IgniteUtils.cs | 43 +-
.../Impl/Memory/PlatformMemoryStream.cs | 320 +-
.../Apache.Ignite.Core/Impl/PlatformTarget.cs | 47 +-
.../Impl/Services/ServiceDescriptor.cs | 7 +-
.../Impl/Services/ServiceProxyInvoker.cs | 29 +-
.../Impl/Services/ServiceProxySerializer.cs | 63 +-
.../Impl/Services/Services.cs | 13 +-
.../Impl/Unmanaged/IgniteJniNativeMethods.cs | 37 +
.../Impl/Unmanaged/UnmanagedCallbackHandlers.cs | 3 +
.../Impl/Unmanaged/UnmanagedCallbacks.cs | 32 +-
.../Impl/Unmanaged/UnmanagedUtils.cs | 85 +-
.../dotnet/Apache.Ignite.Core/NuGet/Install.ps1 | 27 +
.../NuGet/LINQPad/ComputeExample.linq | 106 +
.../NuGet/LINQPad/PutGetExample.linq | 69 +
.../NuGet/LINQPad/QueryExample.linq | 96 +
.../Apache.Ignite.Core/NuGet/PostBuild.ps1 | 20 +
.../Apache.Ignite.Core/NuGet/Uninstall.ps1 | 21 +
.../Transactions/ITransaction.cs | 3 +-
.../Transactions/TransactionConfiguration.cs | 76 +
.../dotnet/Apache.Ignite.Core/build-common.ps1 | 64 +
.../powershell.exe.activation_config | 29 +
modules/platforms/dotnet/Apache.Ignite.FxCop | 4 +-
.../Apache.Ignite.Linq.csproj | 93 +
.../Apache.Ignite.Linq.nuspec | 63 +
.../Apache.Ignite.Linq/Apache.Ignite.Linq.snk | Bin 0 -> 596 bytes
.../Apache.Ignite.Linq/CacheExtensions.cs | 98 +
.../dotnet/Apache.Ignite.Linq/CompiledQuery.cs | 208 +
.../Apache.Ignite.Linq/ICacheQueryable.cs | 53 +
.../Apache.Ignite.Linq/Impl/AliasDictionary.cs | 102 +
.../Impl/CacheFieldsQueryExecutor.cs | 223 +
.../Impl/CacheFieldsQueryProvider.cs | 239 +
.../Impl/CacheFieldsQueryable.cs | 40 +
.../Impl/CacheQueryExpressionVisitor.cs | 506 ++
.../Impl/CacheQueryModelVisitor.cs | 509 ++
.../Apache.Ignite.Linq/Impl/CacheQueryParser.cs | 56 +
.../Apache.Ignite.Linq/Impl/CacheQueryable.cs | 43 +
.../Impl/CacheQueryableBase.cs | 122 +
.../Apache.Ignite.Linq/Impl/ExpressionWalker.cs | 172 +
.../Apache.Ignite.Linq/Impl/ICacheQueryProxy.cs | 40 +
.../Impl/ICacheQueryableInternal.cs | 54 +
.../Apache.Ignite.Linq/Impl/MethodVisitor.cs | 250 +
.../dotnet/Apache.Ignite.Linq/Impl/QueryData.cs | 92 +
.../dotnet/Apache.Ignite.Linq/Impl/SqlTypes.cs | 63 +
.../NuGet/LINQPad/QueryExample.linq | 111 +
.../Properties/AssemblyInfo.cs | 40 +
.../dotnet/Apache.Ignite.Linq/packages.config | 22 +
modules/platforms/dotnet/Apache.Ignite.sln | 163 +-
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 35 +-
.../Config/AppSettingsConfigurator.cs | 97 +-
.../Apache.Ignite/Config/ArgsConfigurator.cs | 145 +-
.../dotnet/Apache.Ignite/Config/Configurator.cs | 168 +
.../Apache.Ignite/Config/IConfigurator.cs | 34 -
.../dotnet/Apache.Ignite/IgniteRunner.cs | 24 +-
.../Apache.Ignite/Service/IgniteService.cs | 21 +-
modules/platforms/dotnet/DEVNOTES.txt | 7 +-
modules/platforms/dotnet/build.bat | 94 -
.../dotnet/examples/Apache.Ignite.Examples.sln | 24 +-
.../Apache.Ignite.Examples.csproj | 49 +-
.../Compute/ClosureExample.cs | 10 +-
.../Compute/TaskExample.cs | 13 +-
.../Datagrid/ContinuousQueryExample.cs | 15 +-
.../Datagrid/DataStreamerExample.cs | 16 +-
.../Datagrid/LinqExample.cs | 247 +
.../Datagrid/PutGetExample.cs | 15 +-
.../Datagrid/QueryExample.cs | 29 +-
.../Datagrid/StoreExample.cs | 25 +-
.../Datagrid/TransactionExample.cs | 24 +-
.../Events/EventsExample.cs | 14 +-
.../Messaging/MessagingExample.cs | 11 +-
.../Misc/LifecycleExample.cs | 3 +-
.../Services/ServicesExample.cs | 11 +-
.../Apache.Ignite.ExamplesDll.csproj | 43 +-
.../Apache.Ignite.ExamplesDll/Binary/Account.cs | 1 -
.../Apache.Ignite.ExamplesDll/Binary/Address.cs | 5 +-
.../Binary/Employee.cs | 4 +
.../Binary/EmployeeKey.cs | 6 +-
.../Binary/Organization.cs | 11 +-
.../Binary/OrganizationType.cs | 3 -
.../Datagrid/EmployeeStoreFactory.cs | 38 +
.../examples/Config/example-cache-query.xml | 118 -
.../examples/Config/example-cache-store.xml | 59 -
.../dotnet/examples/Config/example-cache.xml | 87 -
.../dotnet/examples/Config/example-compute.xml | 70 -
.../dotnet/examples/Config/examples-config.xml | 98 +
.../http/jetty/GridJettyRestProtocol.java | 4 +-
.../ignite/schema/generator/CodeGenerator.java | 84 +-
.../ignite/schema/generator/GeneratorUtils.java | 70 +
.../ignite/schema/generator/XmlGenerator.java | 62 +-
.../ignite/schema/ui/SchemaImportApp.java | 205 +-
.../schema/test/model/ignite-type-metadata.xml | 44 +-
.../org/apache/ignite/spark/IgniteContext.scala | 68 +-
.../apache/ignite/spark/JavaIgniteContext.scala | 14 +-
.../spark/JavaEmbeddedIgniteRDDSelfTest.java | 343 +
.../ignite/spark/JavaIgniteRDDSelfTest.java | 302 -
.../spark/JavaStandaloneIgniteRDDSelfTest.java | 302 +
.../ignite/testsuites/IgniteRDDTestSuite.java | 40 +
.../ignite/internal/GridFactorySelfTest.java | 87 +-
.../commands/cache/VisorCacheCommand.scala | 42 +-
.../commands/tasks/VisorTasksCommand.scala | 4 +-
.../scala/org/apache/ignite/visor/visor.scala | 4 +
modules/web/ignite-weblogic-test/pom.xml | 76 +
.../webapp/META-INF/config/default-config.xml | 37 +
.../src/main/webapp/WEB-INF/web.xml | 52 +
.../src/main/webapp/index.jsp | 36 +
.../ignite/cache/websession/WebSession.java | 91 +-
.../cache/websession/WebSessionFilter.java | 265 +-
.../cache/websession/WebSessionListener.java | 66 +-
.../IgniteWebSessionSelfTestSuite.java | 10 +
.../internal/websession/WebSessionSelfTest.java | 418 +-
modules/yardstick/.gitignore | 2 +
.../config/benchmark-cache-load-win.properties | 56 +
.../config/benchmark-cache-load.properties | 86 +
.../config/ignite-base-load-config.xml | 256 +
.../config/ignite-cache-load-config.xml | 70 +
.../yardstick/IgniteBenchmarkArguments.java | 25 +-
.../org/apache/ignite/yardstick/IgniteNode.java | 2 +
.../cache/IgniteCacheAbstractBenchmark.java | 54 +
.../yardstick/cache/IgniteInvokeBenchmark.java | 65 +
.../cache/IgniteInvokeTxBenchmark.java | 30 +
.../IgniteCacheRandomOperationBenchmark.java | 941 +++
.../yardstick/cache/load/model/ModelUtil.java | 147 +
.../cache/load/model/key/Identifier.java | 107 +
.../yardstick/cache/load/model/key/Mark.java | 108 +
.../yardstick/cache/load/model/value/Car.java | 120 +
.../yardstick/cache/load/model/value/Color.java | 50 +
.../yardstick/cache/load/model/value/Truck.java | 63 +
.../apache/ignite/yarn/ApplicationMaster.java | 30 +-
.../apache/ignite/yarn/IgniteYarnClient.java | 25 +
.../ignite/yarn/utils/IgniteYarnUtils.java | 19 +
modules/zookeeper/pom.xml | 50 +-
.../tcp/ipfinder/zk/ZookeeperIpFinderTest.java | 26 +-
parent/pom.xml | 103 +-
pom.xml | 3 +
1163 files changed, 86167 insertions(+), 15524 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/aws/pom.xml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
----------------------------------------------------------------------
diff --cc
modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
index c8dcc19,858cb71..93fc275
--- a/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
@@@ -367,9 -367,9 +367,12 @@@ public final class IgniteSystemProperti
/** JDBC driver cursor remove delay. */
public static final String IGNITE_JDBC_DRIVER_CURSOR_REMOVE_DELAY =
"IGNITE_JDBC_DRIVER_CURSOR_RMV_DELAY";
+ /** Long-long offheap map load factor. */
+ public static final String IGNITE_LONG_LONG_HASH_MAP_LOAD_FACTOR =
"IGNITE_LONG_LONG_HASH_MAP_LOAD_FACTOR";
+
+ /** Maximum number of nested listener calls before listener notification
becomes asynchronous. */
+ public static final String IGNITE_MAX_NESTED_LISTENER_CALLS =
"IGNITE_MAX_NESTED_LISTENER_CALLS";
+
/**
* Manages {@link OptimizedMarshaller} behavior of {@code
serialVersionUID} computation for
* {@link Serializable} classes.
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
----------------------------------------------------------------------
diff --cc
modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
index 2452894,e5bd05c..64cbc06
---
a/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
+++
b/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java
@@@ -438,9 -446,9 +446,12 @@@ public class IgniteConfiguration
/** */
private BinaryConfiguration binaryCfg;
+ /** */
+ private boolean lateAffAssignment = DFLT_LATE_AFF_ASSIGNMENT;
+
+ /** Database configuration. */
+ private DatabaseConfiguration dbCfg;
+
/**
* Creates valid grid configuration with all default values.
*/
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContext.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryContext.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryEnumObjectImpl.java
----------------------------------------------------------------------
diff --cc
modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryEnumObjectImpl.java
index d6e8006,e58edd2..0f46967
---
a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryEnumObjectImpl.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryEnumObjectImpl.java
@@@ -206,18 -241,8 +241,18 @@@ public class BinaryEnumObjectImpl imple
}
/** {@inheritDoc} */
+ @Override public boolean putValue(ByteBuffer buf, CacheObjectContext ctx)
throws IgniteCheckedException {
+ throw new UnsupportedOperationException("TODO implement.");
+ }
+
+ /** {@inheritDoc} */
+ @Override public int valueBytesLength(CacheObjectContext ctx) throws
IgniteCheckedException {
+ throw new UnsupportedOperationException("TODO implement.");
+ }
+
+ /** {@inheritDoc} */
@Override public byte cacheObjectType() {
- return TYPE_BINARY;
+ return TYPE_BINARY_ENUM;
}
/** {@inheritDoc} */
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectImpl.java
----------------------------------------------------------------------
diff --cc
modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectImpl.java
index 1afbeb9,0997d6f..f5c5589
---
a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectImpl.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectImpl.java
@@@ -404,125 -401,9 +420,125 @@@ public final class BinaryObjectImpl ext
}
/** {@inheritDoc} */
+ @SuppressWarnings("IfMayBeConditional")
+ @Override public boolean writeFieldByOrder(int order, ByteBuffer buf) {
+ // Calculate field position.
+ int schemaOffset = BinaryPrimitives.readInt(arr, start +
GridBinaryMarshaller.SCHEMA_OR_RAW_OFF_POS);
+
+ short flags = BinaryPrimitives.readShort(arr, start +
GridBinaryMarshaller.FLAGS_POS);
+
+ int fieldIdLen = BinaryUtils.isCompactFooter(flags) ? 0 :
BinaryUtils.FIELD_ID_LEN;
+ int fieldOffsetLen = BinaryUtils.fieldOffsetLength(flags);
+
+ int fieldOffsetPos = start + schemaOffset + order * (fieldIdLen +
fieldOffsetLen) + fieldIdLen;
+
+ int fieldPos;
+
+ if (fieldOffsetLen == BinaryUtils.OFFSET_1)
+ fieldPos = start + ((int)BinaryPrimitives.readByte(arr,
fieldOffsetPos) & 0xFF);
+ else if (fieldOffsetLen == BinaryUtils.OFFSET_2)
+ fieldPos = start + ((int)BinaryPrimitives.readShort(arr,
fieldOffsetPos) & 0xFFFF);
+ else
+ fieldPos = start + BinaryPrimitives.readInt(arr, fieldOffsetPos);
+
+ // Read header and try performing fast lookup for well-known types
(the most common types go first).
+ byte hdr = BinaryPrimitives.readByte(arr, fieldPos);
+
+ int totalLen;
+
+ switch (hdr) {
+ case GridBinaryMarshaller.NULL:
+ totalLen = 1;
+
+ break;
+
+ case GridBinaryMarshaller.INT:
+ case GridBinaryMarshaller.FLOAT:
+ totalLen = 5;
+
+ break;
+
+ case GridBinaryMarshaller.LONG:
+ case GridBinaryMarshaller.DOUBLE:
+ case GridBinaryMarshaller.DATE:
+ totalLen = 9;
+
+ break;
+
+ case GridBinaryMarshaller.BOOLEAN:
+ totalLen = 2;
+
+ break;
+
+ case GridBinaryMarshaller.SHORT:
+ totalLen = 3;
+
+ break;
+
+ case GridBinaryMarshaller.BYTE:
+ totalLen = 2;
+
+ break;
+
+ case GridBinaryMarshaller.CHAR:
+ totalLen = 3;
+
+ break;
+
+ case GridBinaryMarshaller.STRING: {
+ int dataLen = BinaryPrimitives.readInt(arr, fieldPos + 1);
+
+ totalLen = dataLen + 5;
+
+ break;
+ }
+
+ case GridBinaryMarshaller.TIMESTAMP:
+ totalLen = 13;
+
+ break;
+
+ case GridBinaryMarshaller.UUID:
+ totalLen = 17;
+
+ break;
+
+ case GridBinaryMarshaller.DECIMAL: {
+ int dataLen = BinaryPrimitives.readInt(arr, fieldPos + 5);
+
+ totalLen = dataLen + 9;
+
+ break;
+ }
+
+ case GridBinaryMarshaller.OBJ:
+ totalLen = BinaryPrimitives.readInt(arr, fieldPos +
GridBinaryMarshaller.TOTAL_LEN_POS);
+
+ break;
+
+ case GridBinaryMarshaller.OPTM_MARSH:
+ totalLen = BinaryPrimitives.readInt(arr, fieldPos + 1);
+
+ break;
+
+ default:
+ throw new UnsupportedOperationException("Failed to write
field of the given type " +
+ "(field type is not supported): " + hdr);
+
+ }
+
+ if (buf.remaining() < totalLen)
+ return false;
+
+ buf.put(arr, fieldPos, totalLen);
+
+ return true;
+ }
+
+ /** {@inheritDoc} */
@SuppressWarnings("unchecked")
@Nullable @Override protected <F> F field(BinaryReaderHandles rCtx,
String fieldName) {
- return (F)reader(rCtx).unmarshalField(fieldName);
+ return (F)reader(rCtx, false).unmarshalField(fieldName);
}
/** {@inheritDoc} */
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectOffheapImpl.java
----------------------------------------------------------------------
diff --cc
modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectOffheapImpl.java
index aed936b,c687192..b942456
---
a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectOffheapImpl.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryObjectOffheapImpl.java
@@@ -309,14 -309,9 +319,14 @@@ public class BinaryObjectOffheapImpl ex
}
/** {@inheritDoc} */
+ @Override protected boolean writeFieldByOrder(int fieldOffset, ByteBuffer
buf) {
+ return false;
+ }
+
+ /** {@inheritDoc} */
@SuppressWarnings("unchecked")
@Nullable @Override protected <F> F field(BinaryReaderHandles rCtx,
String fieldName) {
- return (F)reader(rCtx).unmarshalField(fieldName);
+ return (F)reader(rCtx, false).unmarshalField(fieldName);
}
/** {@inheritDoc} */
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/direct/stream/v2/DirectByteBufferStreamImplV2.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java
----------------------------------------------------------------------
diff --cc
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java
index 2768813,3d56ee3..57b6adf
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java
@@@ -87,6 -90,16 +90,11 @@@ public abstract class CacheEntryPredica
* @return Value.
*/
@Nullable protected CacheObject peekVisibleValue(GridCacheEntryEx entry) {
- try {
- return locked ? entry.rawGetOrUnmarshal(true) :
entry.peekVisibleValue();
- }
- catch (IgniteCheckedException e) {
- throw new IgniteException(e);
- }
+ return locked ? entry.rawGet() : entry.peekVisibleValue();
}
+
+ /** {@inheritDoc} */
+ @Override public void onAckReceived() {
+ // No-op.
+ }
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictableEntryImpl.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObject.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectByteArrayImpl.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
----------------------------------------------------------------------
diff --cc
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
index 4eb1f9b,d807e26..9b13609
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
@@@ -4486,10 -4518,10 +4394,10 @@@ public abstract class GridCacheAdapter<
try {
KeyCacheObject cacheKey = ctx.toCacheKeyObject(key);
- GridCacheEntryEx entry = ctx.isSwapOrOffheapEnabled() ?
entryEx(cacheKey) : peekEx(cacheKey);
+ GridCacheEntryEx entry = entryEx(cacheKey);
if (entry != null)
- return entry.clear(obsoleteVer, readers, null);
+ return entry.clear(obsoleteVer, readers);
}
catch (GridDhtInvalidPartitionException ignored) {
// No-op.
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheClearAllRunnable.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1643a7cc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentManager.java
----------------------------------------------------------------------
