Merge branch 'master' into ignite-2435
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b6ce18a7 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b6ce18a7 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b6ce18a7 Branch: refs/heads/ignite-2435 Commit: b6ce18a72fb385f8c957d86e75fa163cfb244b9d Parents: 47bc381 21bd626 Author: nikolay_tikhonov <[email protected]> Authored: Mon Apr 18 16:15:42 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Mon Apr 18 16:15:42 2016 +0300 ---------------------------------------------------------------------- .gitignore | 5 + 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 | 65 +- .../java/org/apache/ignite/IgniteQueue.java | 27 +- .../main/java/org/apache/ignite/IgniteSet.java | 26 +- .../apache/ignite/IgniteSystemProperties.java | 15 +- .../ignite/binary/BinaryBasicIdMapper.java | 167 + .../ignite/binary/BinaryBasicNameMapper.java | 141 + .../apache/ignite/binary/BinaryIdMapper.java | 19 +- .../apache/ignite/binary/BinaryNameMapper.java | 47 + .../ignite/binary/BinaryTypeConfiguration.java | 23 +- .../org/apache/ignite/cache/CacheEntry.java | 9 +- .../apache/ignite/cache/CacheInterceptor.java | 5 + .../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/BinaryConfiguration.java | 28 + .../configuration/FileSystemConfiguration.java | 96 +- .../configuration/IgniteConfiguration.java | 97 +- .../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 | 8 + .../ignite/internal/GridKernalContextImpl.java | 12 + .../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 | 51 +- .../ignite/internal/IgniteNodeAttributes.java | 6 + .../org/apache/ignite/internal/IgnitionEx.java | 10 +- .../ignite/internal/MarshallerContextImpl.java | 10 +- .../internal/binary/BinaryClassDescriptor.java | 53 +- .../ignite/internal/binary/BinaryContext.java | 418 +- .../internal/binary/BinaryEnumObjectImpl.java | 68 +- .../internal/binary/BinaryFieldAccessor.java | 46 +- .../internal/binary/BinaryInternalIdMapper.java | 161 - .../internal/binary/BinaryInternalMapper.java | 131 + .../internal/binary/BinaryMarshaller.java | 5 +- .../binary/BinaryMetadataCollector.java | 22 +- .../internal/binary/BinaryObjectImpl.java | 57 +- .../binary/BinaryObjectOffheapImpl.java | 77 +- .../internal/binary/BinaryPrimitives.java | 117 +- .../internal/binary/BinaryReaderExImpl.java | 84 +- .../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 | 64 +- .../internal/binary/GridBinaryMarshaller.java | 28 +- .../binary/builder/BinaryBuilderReader.java | 11 +- .../binary/builder/BinaryBuilderSerializer.java | 32 +- .../binary/builder/BinaryObjectBuilderImpl.java | 121 +- .../binary/builder/BinaryValueWithType.java | 3 +- .../streams/BinaryAbstractInputStream.java | 53 +- .../streams/BinaryAbstractOutputStream.java | 90 +- .../binary/streams/BinaryAbstractStream.java | 34 - .../binary/streams/BinaryHeapInputStream.java | 43 +- .../binary/streams/BinaryHeapOutputStream.java | 86 +- .../streams/BinaryMemoryAllocatorChunk.java | 9 +- .../streams/BinaryOffheapInputStream.java | 42 +- .../streams/BinaryOffheapOutputStream.java | 94 +- .../internal/direct/DirectMessageWriter.java | 2 +- .../direct/state/DirectMessageState.java | 7 +- .../stream/v1/DirectByteBufferStreamImplV1.java | 106 +- .../stream/v2/DirectByteBufferStreamImplV2.java | 353 +- .../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 ++ .../processors/cache/CacheEntryImplEx.java | 14 +- .../cache/CacheEntryInfoCollection.java | 5 + .../cache/CacheEntryPredicateAdapter.java | 8 + .../cache/CacheEntryPredicateContainsValue.java | 8 +- .../cache/CacheEntrySerializablePredicate.java | 8 +- .../cache/CacheEvictableEntryImpl.java | 8 +- .../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 + .../cache/DynamicCacheChangeRequest.java | 17 + .../cache/DynamicCacheDescriptor.java | 49 + .../processors/cache/GridCacheAdapter.java | 1025 +-- .../cache/GridCacheAffinityManager.java | 160 +- .../cache/GridCacheClearAllRunnable.java | 3 +- .../processors/cache/GridCacheContext.java | 59 +- .../cache/GridCacheDeploymentManager.java | 13 +- .../processors/cache/GridCacheEntryEx.java | 26 +- .../processors/cache/GridCacheEntryInfo.java | 5 + .../cache/GridCacheEvictionManager.java | 43 +- .../processors/cache/GridCacheIoManager.java | 29 +- .../processors/cache/GridCacheLogger.java | 3 +- .../processors/cache/GridCacheMapEntry.java | 488 +- .../processors/cache/GridCacheMessage.java | 9 +- .../cache/GridCacheMvccCandidate.java | 16 +- .../processors/cache/GridCacheMvccManager.java | 186 +- .../cache/GridCacheOffheapSwapEntry.java | 24 +- .../GridCachePartitionExchangeManager.java | 194 +- .../processors/cache/GridCachePreloader.java | 24 +- .../cache/GridCachePreloaderAdapter.java | 17 +- .../processors/cache/GridCacheProcessor.java | 296 +- .../processors/cache/GridCacheProxyImpl.java | 161 +- .../processors/cache/GridCacheReturn.java | 5 + .../cache/GridCacheSharedContext.java | 18 +- .../cache/GridCacheSwapEntryImpl.java | 61 +- .../processors/cache/GridCacheSwapManager.java | 86 +- .../processors/cache/GridCacheTtlManager.java | 75 +- .../cache/GridCacheUpdateAtomicResult.java | 4 +- .../processors/cache/GridCacheUtils.java | 209 +- .../processors/cache/IgniteCacheProxy.java | 94 +- .../processors/cache/IgniteInternalCache.java | 204 +- .../processors/cache/KeyCacheObjectImpl.java | 5 + .../cache/affinity/GridCacheAffinityImpl.java | 9 +- .../binary/CacheObjectBinaryProcessorImpl.java | 149 +- .../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 | 18 - .../dht/GridClientPartitionTopology.java | 15 +- .../dht/GridDhtAffinityAssignmentResponse.java | 199 +- .../dht/GridDhtAssignmentFetchFuture.java | 80 +- .../distributed/dht/GridDhtCacheAdapter.java | 164 +- .../distributed/dht/GridDhtCacheEntry.java | 4 +- .../distributed/dht/GridDhtEmbeddedFuture.java | 13 +- .../cache/distributed/dht/GridDhtGetFuture.java | 184 +- .../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 | 361 +- .../dht/GridDhtTransactionalCacheAdapter.java | 9 +- .../distributed/dht/GridDhtTxFinishFuture.java | 29 +- .../dht/GridDhtTxFinishResponse.java | 3 +- .../cache/distributed/dht/GridDhtTxLocal.java | 210 +- .../distributed/dht/GridDhtTxLocalAdapter.java | 4 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 73 +- .../cache/distributed/dht/GridDhtTxRemote.java | 20 +- .../dht/GridPartitionedGetFuture.java | 51 +- .../dht/GridPartitionedSingleGetFuture.java | 30 +- .../dht/atomic/GridDhtAtomicCache.java | 555 +- .../dht/atomic/GridDhtAtomicUpdateFuture.java | 89 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 40 +- .../dht/atomic/GridDhtAtomicUpdateResponse.java | 3 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 1235 ++-- .../dht/atomic/GridNearAtomicUpdateRequest.java | 19 +- .../atomic/GridNearAtomicUpdateResponse.java | 3 +- .../dht/colocated/GridDhtColocatedCache.java | 93 +- .../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 | 47 +- .../distributed/near/GridNearCacheAdapter.java | 38 +- .../distributed/near/GridNearCacheEntry.java | 123 +- .../distributed/near/GridNearGetFuture.java | 81 +- .../distributed/near/GridNearGetResponse.java | 3 +- .../distributed/near/GridNearLockFuture.java | 10 +- ...arOptimisticSerializableTxPrepareFuture.java | 11 +- .../near/GridNearOptimisticTxPrepareFuture.java | 58 +- ...ridNearOptimisticTxPrepareFutureAdapter.java | 16 +- .../GridNearPessimisticTxPrepareFuture.java | 4 +- .../near/GridNearSingleGetResponse.java | 3 +- .../near/GridNearTransactionalCache.java | 16 +- .../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 | 242 +- .../cache/query/GridCacheLocalQueryFuture.java | 7 +- .../cache/query/GridCacheQueryManager.java | 472 +- .../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 | 391 +- .../CacheContinuousQueryHandlerV2.java | 176 + .../CacheContinuousQueryListener.java | 5 +- .../continuous/CacheContinuousQueryManager.java | 406 +- .../jdbc/GridCacheQueryJdbcValidationTask.java | 3 +- .../store/GridCacheStoreManagerAdapter.java | 4 +- .../cache/transactions/IgniteInternalTx.java | 34 +- .../transactions/IgniteTransactionsImpl.java | 9 +- .../cache/transactions/IgniteTxAdapter.java | 103 +- .../cache/transactions/IgniteTxEntry.java | 45 +- .../cache/transactions/IgniteTxHandler.java | 33 +- .../IgniteTxImplicitSingleStateImpl.java | 32 +- .../cache/transactions/IgniteTxKey.java | 5 + .../transactions/IgniteTxLocalAdapter.java | 394 +- .../cache/transactions/IgniteTxLocalEx.java | 24 +- .../cache/transactions/IgniteTxManager.java | 97 +- .../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 | 12 +- .../clock/GridClockDeltaSnapshotMessage.java | 5 + .../processors/clock/GridClockDeltaVersion.java | 5 + .../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 +- .../processors/platform/PlatformIgnition.java | 6 +- .../platform/PlatformNoopProcessor.java | 29 +- .../processors/platform/PlatformProcessor.java | 45 + .../platform/PlatformProcessorImpl.java | 88 +- .../platform/cache/PlatformCache.java | 72 +- .../callback/PlatformCallbackGateway.java | 30 + .../callback/PlatformCallbackUtils.java | 16 +- .../platform/cluster/PlatformClusterGroup.java | 12 + .../platform/compute/PlatformCompute.java | 26 +- .../cpp/PlatformCppConfigurationClosure.java | 32 + .../datastreamer/PlatformDataStreamer.java | 7 +- .../datastructures/PlatformAtomicReference.java | 146 + .../datastructures/PlatformAtomicSequence.java | 122 + .../dotnet/PlatformDotNetCacheStore.java | 39 +- .../PlatformDotNetConfigurationClosure.java | 83 +- .../platform/memory/PlatformAbstractMemory.java | 6 +- .../PlatformBigEndianOutputStreamImpl.java | 14 +- .../memory/PlatformInputStreamImpl.java | 53 +- .../platform/memory/PlatformMemoryUtils.java | 108 +- .../memory/PlatformOutputStreamImpl.java | 58 +- .../platform/services/PlatformServices.java | 249 +- .../utils/PlatformConfigurationUtils.java | 717 +++ .../platform/utils/PlatformFutureUtils.java | 2 +- .../platform/utils/PlatformUtils.java | 180 +- .../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 + .../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 | 24 +- .../ignite/internal/util/GridJavaProcess.java | 3 - .../ignite/internal/util/GridLeanSet.java | 1 + .../ignite/internal/util/GridLongList.java | 5 + .../internal/util/GridMessageCollection.java | 5 + .../internal/util/GridSpinReadWriteLock.java | 10 +- .../apache/ignite/internal/util/GridUnsafe.java | 1483 ++++- .../ignite/internal/util/IgniteUtils.java | 197 +- .../util/StripedCompositeReadWriteLock.java | 174 + .../internal/util/UUIDCollectionMessage.java | 5 + .../util/future/GridCompoundFuture.java | 2 +- .../internal/util/future/GridFutureAdapter.java | 3 +- .../internal/util/io/GridUnsafeDataInput.java | 145 +- .../internal/util/io/GridUnsafeDataOutput.java | 165 +- .../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 | 79 +- .../util/offheap/unsafe/GridUnsafeMemory.java | 106 +- .../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 | 59 +- .../optimized/OptimizedMarshaller.java | 5 +- .../optimized/OptimizedMarshallerUtils.java | 47 +- .../optimized/OptimizedObjectInputStream.java | 25 +- .../optimized/OptimizedObjectOutputStream.java | 4 +- .../OptimizedObjectStreamRegistry.java | 145 +- .../PlatformDotNetCacheStoreFactoryNative.java | 58 + .../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 | 53 +- .../tcp/TcpCommunicationSpiMBean.java | 8 +- .../ignite/spi/discovery/tcp/ClientImpl.java | 35 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 216 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 28 +- .../tcp/internal/TcpDiscoveryNode.java | 41 +- .../TcpDiscoveryMulticastIpFinder.java | 13 +- .../sharedfs/TcpDiscoverySharedFsIpFinder.java | 35 +- .../TcpDiscoveryCustomEventMessage.java | 6 +- .../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 +- .../java/org/apache/ignite/GridTestIoUtils.java | 117 +- .../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 | 11 +- ...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 +- .../binary/BinaryBasicIdMapperSelfTest.java | 51 + .../binary/BinaryBasicNameMapperSelfTest.java | 50 + .../BinaryConfigurationConsistencySelfTest.java | 231 + .../internal/binary/BinaryEnumsSelfTest.java | 63 +- .../binary/BinaryFieldsOffheapSelfTest.java | 13 +- .../BinaryFooterOffsetsOffheapSelfTest.java | 13 +- .../binary/BinaryMarshallerSelfTest.java | 575 +- .../BinaryObjectBuilderAdditionalSelfTest.java | 231 +- ...naryObjectBuilderDefaultMappersSelfTest.java | 1165 ++++ .../binary/BinaryObjectBuilderSelfTest.java | 1108 ---- ...ilderSimpleNameLowerCaseMappersSelfTest.java | 41 + .../BinarySimpleNameTestPropertySelfTest.java | 94 + .../binary/GridBinaryMetaDataSelfTest.java | 371 -- .../binary/GridBinaryWildcardsSelfTest.java | 338 +- ...aultBinaryMappersBinaryMetaDataSelfTest.java | 389 ++ ...CaseBinaryMappersBinaryMetaDataSelfTest.java | 41 + .../internal/binary/TestMappedObject.java | 25 + .../mutabletest/GridBinaryTestClasses.java | 3 +- ...BuilderNonCompactDefaultMappersSelfTest.java | 30 + .../BinaryObjectBuilderNonCompactSelfTest.java | 30 - ...mpactSimpleNameLowerCaseMappersSelfTest.java | 31 + .../AbstractBinaryStreamByteOrderSelfTest.java | 464 ++ .../BinaryHeapStreamByteOrderSelfTest.java | 29 + .../BinaryOffheapStreamByteOrderSelfTest.java | 31 + ...ByteBufferStreamImplV2ByteOrderSelfTest.java | 244 + .../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 + .../cache/CacheGetEntryAbstractTest.java | 803 +++ ...GetEntryOptimisticReadCommittedSeltTest.java | 36 + ...etEntryOptimisticRepeatableReadSeltTest.java | 36 + ...eGetEntryOptimisticSerializableSeltTest.java | 36 + ...etEntryPessimisticReadCommittedSeltTest.java | 36 + ...tEntryPessimisticRepeatableReadSeltTest.java | 36 + ...GetEntryPessimisticSerializableSeltTest.java | 36 + ...erceptorPartitionCounterLocalSanityTest.java | 687 ++ ...torPartitionCounterRandomOperationsTest.java | 1054 ++++ .../CacheMetricsForClusterGroupSelfTest.java | 2 +- .../processors/cache/CacheNamesSelfTest.java | 16 +- .../CacheNamesWithSpecialCharactersTest.java | 71 + ...cheNearUpdateTopologyChangeAbstractTest.java | 2 + .../cache/CacheReadThroughRestartSelfTest.java | 45 +- .../CacheSerializableTransactionsTest.java | 142 +- .../cache/CacheSwapUnswapGetTest.java | 4 +- .../EntryVersionConsistencyReadThroughTest.java | 265 + .../cache/GridCacheAbstractFullApiSelfTest.java | 216 +- .../cache/GridCacheAbstractMetricsSelfTest.java | 124 +- .../GridCacheAbstractRemoveFailureTest.java | 10 +- .../cache/GridCacheAbstractSelfTest.java | 19 + .../cache/GridCacheConcurrentMapSelfTest.java | 13 +- .../GridCacheConditionalDeploymentSelfTest.java | 4 +- .../cache/GridCacheDeploymentSelfTest.java | 80 +- .../cache/GridCacheEntryVersionSelfTest.java | 2 +- .../GridCacheInterceptorAbstractSelfTest.java | 172 +- .../GridCacheOffHeapValuesEvictionSelfTest.java | 210 + .../GridCacheOnCopyFlagAbstractSelfTest.java | 479 +- ...ridCacheStoreManagerDeserializationTest.java | 354 ++ ...ridCacheSwapSpaceSpiConsistencySelfTest.java | 146 + ...acheTcpClientDiscoveryMultiThreadedTest.java | 2 +- .../processors/cache/GridCacheTestEntryEx.java | 12 +- ...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 | 238 +- .../GridCacheBinaryStoreAbstractSelfTest.java | 10 + ...naryStoreBinariesDefaultMappersSelfTest.java | 81 + .../GridCacheBinaryStoreBinariesSelfTest.java | 66 - ...yStoreBinariesSimpleNameMappersSelfTest.java | 40 + .../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 +- ...GridCacheDhtEvictionNearReadersSelfTest.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 | 409 +- .../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 | 67 +- ...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 ++ ...ntinuousQueryPartitionAtomicOneNodeTest.java | 37 + ...heContinuousQueryPartitionTxOneNodeTest.java | 37 + ...tinuousQueryReplicatedAtomicOneNodeTest.java | 31 + ...ontinuousQueryReplicatedOneNodeSelfTest.java | 120 - ...eContinuousQueryReplicatedTxOneNodeTest.java | 193 + ...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 + ...dUnsafeDataInputOutputByteOrderSelfTest.java | 249 + .../ignite/jvmtest/ConcurrentMapTest.java | 3 +- .../ignite/lang/GridBasicPerformanceTest.java | 11 +- .../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 + .../tcp/TcpClientDiscoverySpiSelfTest.java | 10 +- .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 43 +- .../TcpDiscoverySpiFailureTimeoutSelfTest.java | 23 +- .../spi/discovery/tcp/TestTcpDiscoverySpi.java | 5 +- .../TcpDiscoveryIpFinderAbstractSelfTest.java | 15 +- .../GridSwapSpaceSpiConsistencySelfTest.java | 131 + .../ignite/testframework/GridTestUtils.java | 5 +- .../config/GridTestProperties.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 | 73 +- .../junits/GridTestKernalContext.java | 34 +- ...IgniteCacheConfigVariationsAbstractTest.java | 583 ++ .../IgniteConfigVariationsAbstractTest.java | 420 ++ .../junits/common/GridCommonAbstractTest.java | 171 +- .../multijvm/IgniteCacheProcessProxy.java | 67 +- .../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 | 15 +- .../testsuites/IgniteBinaryBasicTestSuite.java | 101 + .../testsuites/IgniteBinaryCacheTestSuite.java | 2 + ...IgniteBinaryObjectsComputeGridTestSuite.java | 7 +- ...ctsSimpleNameMapperComputeGridTestSuite.java | 38 + .../IgniteBinaryObjectsTestSuite.java | 42 +- ...iteBinarySimpleNameMapperBasicTestSuite.java | 38 + ...rySimpleNameMapperCacheFullApiTestSuite.java | 39 + ...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 | 28 +- .../testsuites/IgniteCacheTestSuite5.java | 15 +- .../ignite/testsuites/IgniteIgfsTestSuite.java | 21 +- .../testsuites/IgniteKernalSelfTestSuite.java | 10 +- .../IgniteMarshallerSelfTestSuite.java | 12 +- .../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 + .../tests/p2p/CacheDeploymentTestEnumValue.java | 47 + .../p2p/CacheDeploymentTestStoreFactory.java | 113 + 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 +- .../hadoop/shuffle/HadoopShuffleJob.java | 5 +- .../hadoop/shuffle/HadoopShuffleMessage.java | 10 +- .../shuffle/streams/HadoopDataOutStream.java | 6 +- .../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 +- .../HadoopConcurrentHashMultimapSelftest.java | 6 +- .../collections/HadoopSkipListSelfTest.java | 5 +- .../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 | 186 +- .../IgniteBinaryCacheQueryTestSuite2.java | 39 + .../IgniteBinaryCacheQueryTestSuite3.java | 39 + .../IgniteBinaryCacheQueryTestSuite4.java | 39 + ...narySimpleNameMapperCacheQueryTestSuite.java | 38 + .../IgniteCacheQuerySelfTestSuite.java | 111 +- .../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 | 18 + .../cpp/common/include/ignite/common/java.h | 50 + .../os/linux/include/ignite/common/common.h | 20 +- .../os/win/include/ignite/common/common.h | 8 +- .../platforms/cpp/common/project/vs/module.def | 18 +- modules/platforms/cpp/common/src/exports.cpp | 64 + modules/platforms/cpp/common/src/java.cpp | 317 +- 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 | 138 +- .../Binary/BinaryBuilderSelfTest.cs | 87 +- .../Binary/BinaryBuilderSelfTestFullFooter.cs | 31 + .../Binary/BinaryCompactFooterInteropTest.cs | 129 + .../Binary/BinarySelfTest.cs | 287 +- .../Binary/BinarySelfTestFullFooter.cs | 35 + .../Binary/BinaryStructureTest.cs | 38 +- .../Cache/CacheAbstractTest.cs | 2 +- .../Cache/CacheAffinityFieldTest.cs | 199 + .../Cache/CacheAffinityTest.cs | 2 +- .../Cache/CacheConfigurationTest.cs | 530 ++ .../Cache/CacheDynamicStartTest.cs | 4 +- .../Cache/CacheTestAsyncWrapper.cs | 19 + .../Cache/Query/CacheLinqTest.cs | 1272 ++++ .../Query/CacheQueriesCodeConfigurationTest.cs | 309 + .../Cache/Query/CacheQueriesTest.cs | 15 +- .../Continuous/ContinuousQueryAbstractTest.cs | 27 +- .../Cache/Store/CacheStoreSessionTest.cs | 2 +- .../Cache/Store/CacheStoreTest.cs | 59 +- .../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 | 37 +- .../Config/Compute/compute-grid3.xml | 36 +- .../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/DataStreamerTest.cs | 4 +- .../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 | 7 +- .../Apache.Ignite.Core.Tests/ExecutableTest.cs | 89 +- .../Apache.Ignite.Core.Tests/FutureTest.cs | 1 + .../IgniteConfigurationSectionTest.cs | 69 + .../IgniteConfigurationSerializerTest.cs | 594 ++ .../IgniteConfigurationTest.cs | 390 ++ .../IgniteStartStopTest.cs | 58 +- .../Apache.Ignite.Core.Tests/JavaHomeTest.cs | 69 + .../Apache.Ignite.Core.Tests/MarshallerTest.cs | 4 +- .../Process/IgniteProcess.cs | 31 +- .../ProcessExtensions.cs | 78 + .../ProjectFilesTest.cs | 88 + .../Apache.Ignite.Core.Tests/ReconnectTest.cs | 97 + .../SerializationTest.cs | 2 +- .../Services/ServiceProxyTest.cs | 6 +- .../Services/ServicesTest.cs | 273 +- .../Services/ServicesTestFullFooter.cs | 33 + .../Apache.Ignite.Core.Tests/TestRunner.cs | 5 +- .../Apache.Ignite.Core.Tests/TestUtils.cs | 34 +- .../dotnet/Apache.Ignite.Core.Tests/app.config | 54 + .../Apache.Ignite.Core.csproj | 97 +- .../Apache.Ignite.Core.nuspec | 75 + .../Binary/BinaryConfiguration.cs | 71 +- .../Binary/BinaryReflectiveSerializer.cs | 241 + .../Binary/IBinarySerializer.cs | 6 +- .../Cache/Affinity/AffinityKey.cs | 162 + .../Affinity/AffinityKeyMappedAttribute.cs | 46 + .../Cache/CachePartialUpdateException.cs | 1 - .../Configuration/CacheAtomicWriteOrderMode.cs | 43 + .../Cache/Configuration/CacheAtomicityMode.cs | 54 + .../Cache/Configuration/CacheConfiguration.cs | 637 ++ .../Cache/Configuration/CacheMemoryMode.cs | 60 + .../Cache/Configuration/CacheMode.cs | 52 + .../Cache/Configuration/CacheRebalanceMode.cs | 51 + .../CacheWriteSynchronizationMode.cs | 45 + .../Cache/Configuration/QueryAlias.cs | 59 + .../Cache/Configuration/QueryEntity.cs | 402 ++ .../Cache/Configuration/QueryField.cs | 109 + .../Cache/Configuration/QueryIndex.cs | 137 + .../Cache/Configuration/QueryIndexField.cs | 66 + .../Cache/Configuration/QueryIndexType.cs | 40 + .../Configuration/QuerySqlFieldAttribute.cs | 60 + .../Configuration/QueryTextFieldAttribute.cs | 36 + .../dotnet/Apache.Ignite.Core/Cache/ICache.cs | 32 + .../Cache/Store/CacheStoreAdapter.cs | 1 - .../Apache.Ignite.Core/Cluster/ICluster.cs | 14 + .../Common/ClientDisconnectedException.cs | 97 + .../Apache.Ignite.Core/Common/IFactory.cs | 34 + .../Compute/ComputeTaskAdapter.cs | 1 - .../Compute/ComputeTaskSplitAdapter.cs | 1 - .../Configuration/AtomicConfiguration.cs | 58 + .../DataStructures/IAtomicReference.cs | 64 + .../DataStructures/IAtomicSequence.cs | 69 + .../Discovery/IDiscoverySpi.cs | 32 + .../Discovery/Tcp/ITcpDiscoveryIpFinder.cs | 34 + .../Multicast/TcpDiscoveryMulticastIpFinder.cs | 135 + .../Tcp/Static/TcpDiscoveryStaticIpFinder.cs | 86 + .../Discovery/Tcp/TcpDiscoveryIpFinderBase.cs | 78 + .../Discovery/Tcp/TcpDiscoverySpi.cs | 144 + .../Apache.Ignite.Core/Events/EventBase.cs | 1 - .../dotnet/Apache.Ignite.Core/IIgnite.cs | 57 +- .../Apache.Ignite.Core/IgniteConfiguration.cs | 476 +- .../IgniteConfigurationSection.cs | 80 + .../IgniteConfigurationSection.xsd | 316 + .../dotnet/Apache.Ignite.Core/Ignition.cs | 126 +- .../Apache.Ignite.Core/Impl/Binary/Binary.cs | 11 +- .../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/BinaryReaderExtensions.cs | 19 + .../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 | 115 + .../Impl/Binary/Marshaller.cs | 53 +- .../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 | 65 +- .../Apache.Ignite.Core/Impl/Cache/CacheOp.cs | 4 +- .../Impl/Cache/ICacheInternal.cs | 40 + .../Impl/Cache/Query/FieldsQueryCursor.cs | 26 +- .../Impl/Cache/Store/CacheStore.cs | 20 +- .../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 | 149 +- .../Impl/IgniteConfigurationEx.cs | 57 - .../Apache.Ignite.Core/Impl/IgniteManager.cs | 24 +- .../Apache.Ignite.Core/Impl/IgniteProxy.cs | 37 +- .../Apache.Ignite.Core/Impl/IgniteUtils.cs | 45 +- .../Impl/Memory/PlatformMemoryStream.cs | 320 +- .../Impl/Memory/PlatformRawMemory.cs | 2 +- .../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/Transactions/TransactionsImpl.cs | 2 +- .../Impl/Unmanaged/IgniteJniNativeMethods.cs | 48 +- .../Impl/Unmanaged/UnmanagedCallbackHandlers.cs | 3 + .../Impl/Unmanaged/UnmanagedCallbacks.cs | 32 +- .../Impl/Unmanaged/UnmanagedUtils.cs | 107 +- .../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 + .../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 | 11 +- .../ignite/internal/GridFactorySelfTest.java | 2 +- .../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 | 84 +- .../cache/websession/WebSessionFilter.java | 265 +- .../cache/websession/WebSessionListener.java | 66 +- .../IgniteWebSessionSelfTestSuite.java | 10 + .../internal/websession/WebSessionSelfTest.java | 332 +- modules/yardstick/.gitignore | 2 + .../config/benchmark-cache-load-win.properties | 56 + .../config/benchmark-cache-load.properties | 61 + .../config/benchmark-multicast.properties | 7 + .../yardstick/IgniteBenchmarkArguments.java | 25 +- .../org/apache/ignite/yardstick/IgniteNode.java | 5 + .../cache/IgniteCacheAbstractBenchmark.java | 54 + .../IgniteGetEntriesPutAllTxBenchmark.java | 73 + .../yardstick/cache/IgniteInvokeBenchmark.java | 65 + .../cache/IgniteInvokeTxBenchmark.java | 30 + .../cache/IgnitePutGetEntryBenchmark.java | 47 + .../cache/IgnitePutGetEntryTxBenchmark.java | 73 + .../IgniteCacheRandomOperationBenchmark.java | 767 +++ .../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 | 104 +- pom.xml | 4 +- 1274 files changed, 100121 insertions(+), 18932 deletions(-) ----------------------------------------------------------------------
