Merge remote-tracking branch 'remotes/origin/ignite-1.5' into ignite-sql-opt
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1be4732b Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1be4732b Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1be4732b Branch: refs/heads/ignite-sql-opt Commit: 1be4732b0f5ffdcac9abc140a20054c7cfaa68b1 Parents: 8030bbd 15877a8 Author: sboikov <sboi...@gridgain.com> Authored: Mon Nov 23 09:29:09 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Mon Nov 23 09:29:09 2015 +0300 ---------------------------------------------------------------------- .gitignore | 6 + assembly/release-fabric-base.xml | 94 + .../config/binary/example-ignite-binary.xml | 44 + examples/config/example-default.xml | 76 + examples/config/example-ignite.xml | 56 +- .../apache/ignite/examples/binary/Address.java | 72 + .../apache/ignite/examples/binary/Employee.java | 93 + .../ignite/examples/binary/EmployeeKey.java | 90 + .../binary/ExampleBinaryNodeStartup.java | 36 + .../ignite/examples/binary/Organization.java | 93 + .../examples/binary/OrganizationType.java | 32 + ...ComputeClientBinaryTaskExecutionExample.java | 153 + .../binary/computegrid/ComputeClientTask.java | 116 + .../binary/computegrid/package-info.java | 21 + .../CacheClientBinaryPutGetExample.java | 230 ++ .../datagrid/CacheClientBinaryQueryExample.java | 330 ++ .../examples/binary/datagrid/package-info.java | 21 + .../ignite/examples/binary/package-info.java | 21 + .../datastructures/IgniteSemaphoreExample.java | 168 + .../CacheClientPortableExampleTest.java | 46 + .../ignite/examples/CacheExamplesSelfTest.java | 10 +- .../ComputeClientPortableExampleTest.java | 37 + .../testsuites/IgniteExamplesSelfTestSuite.java | 6 + .../stream/camel/IgniteCamelStreamerTest.java | 16 +- .../camel/IgniteCamelStreamerTestSuite.java | 1 - .../ignite/codegen/MessageCodeGenerator.java | 11 +- modules/core/pom.xml | 21 + ...processors.platform.PlatformBootstrapFactory | 2 + .../src/main/java/org/apache/ignite/Ignite.java | 24 + .../java/org/apache/ignite/IgniteBinary.java | 357 ++ .../java/org/apache/ignite/IgniteCache.java | 41 + .../org/apache/ignite/IgniteDataStreamer.java | 16 + .../java/org/apache/ignite/IgniteSemaphore.java | 312 ++ .../org/apache/ignite/binary/BinaryField.java | 46 + .../apache/ignite/binary/BinaryIdMapper.java | 54 + .../binary/BinaryInvalidTypeException.java | 58 + .../org/apache/ignite/binary/BinaryObject.java | 149 + .../ignite/binary/BinaryObjectBuilder.java | 135 + .../ignite/binary/BinaryObjectException.java | 57 + .../apache/ignite/binary/BinaryRawReader.java | 240 ++ .../apache/ignite/binary/BinaryRawWriter.java | 225 ++ .../org/apache/ignite/binary/BinaryReader.java | 290 ++ .../apache/ignite/binary/BinarySerializer.java | 47 + .../org/apache/ignite/binary/BinaryType.java | 68 + .../ignite/binary/BinaryTypeConfiguration.java | 112 + .../org/apache/ignite/binary/BinaryWriter.java | 273 ++ .../org/apache/ignite/binary/Binarylizable.java | 48 + .../org/apache/ignite/binary/package-info.java | 22 + .../ignite/cache/CacheKeyConfiguration.java | 92 + .../apache/ignite/cache/CacheTypeMetadata.java | 67 +- .../org/apache/ignite/cache/QueryEntity.java | 217 ++ .../org/apache/ignite/cache/QueryIndex.java | 192 + .../org/apache/ignite/cache/QueryIndexType.java | 38 + .../configuration/BinaryConfiguration.java | 139 + .../configuration/CacheConfiguration.java | 692 +++- .../configuration/IgniteConfiguration.java | 75 +- .../configuration/PlatformConfiguration.java | 25 + .../apache/ignite/events/DiscoveryEvent.java | 6 +- .../ignite/internal/GridKernalContextImpl.java | 4 +- .../org/apache/ignite/internal/IgniteEx.java | 9 - .../apache/ignite/internal/IgniteKernal.java | 60 +- .../ignite/internal/IgniteNodeAttributes.java | 6 + .../internal/MarshallerContextAdapter.java | 4 +- .../internal/client/GridClientCompute.java | 2 +- .../impl/connection/GridClientConnection.java | 2 +- .../GridClientConnectionManagerAdapter.java | 2 +- .../connection/GridClientNioTcpConnection.java | 6 +- .../internal/direct/DirectByteBufferStream.java | 1499 ------- .../internal/direct/DirectMessageReader.java | 144 +- .../internal/direct/DirectMessageWriter.java | 65 +- .../direct/DirectMessageWriterState.java | 123 - .../direct/state/DirectMessageState.java | 98 + .../direct/state/DirectMessageStateItem.java | 28 + .../direct/stream/DirectByteBufferStream.java | 316 ++ .../stream/v1/DirectByteBufferStreamImplV1.java | 1360 +++++++ .../stream/v2/DirectByteBufferStreamImplV2.java | 1583 ++++++++ .../managers/communication/GridIoManager.java | 64 +- .../communication/GridIoMessageFactory.java | 4 +- .../swapspace/GridSwapSpaceManager.java | 34 - .../portable/BinaryCachingMetadataHandler.java | 70 + .../internal/portable/BinaryEnumCache.java | 69 + .../internal/portable/BinaryFieldAccessor.java | 805 ++++ .../internal/portable/BinaryFieldImpl.java | 116 + .../portable/BinaryInternalIdMapper.java | 161 + .../internal/portable/BinaryMetadata.java | 166 + .../portable/BinaryMetadataCollector.java | 277 ++ .../portable/BinaryMetadataHandler.java | 44 + .../portable/BinaryNoopMetadataHandler.java | 53 + .../internal/portable/BinaryObjectEx.java | 245 ++ .../internal/portable/BinaryObjectImpl.java | 581 +++ .../portable/BinaryObjectOffheapImpl.java | 436 +++ .../internal/portable/BinaryRawReaderEx.java | 33 + .../internal/portable/BinaryRawWriterEx.java | 60 + .../internal/portable/BinaryReaderExImpl.java | 2748 +++++++++++++ .../internal/portable/BinaryReaderHandles.java | 108 + .../portable/BinaryThreadLocalContext.java | 69 + .../internal/portable/BinaryTypeImpl.java | 81 + .../internal/portable/BinaryWriteMode.java | 178 + .../internal/portable/BinaryWriterExImpl.java | 1817 +++++++++ .../internal/portable/BinaryWriterHandles.java | 101 + .../portable/BinaryWriterSchemaHolder.java | 148 + .../portable/GridPortableMarshaller.java | 67 +- .../portable/PortableClassDescriptor.java | 1003 ++--- .../internal/portable/PortableContext.java | 542 +-- .../portable/PortableMetaDataCollector.java | 258 -- .../portable/PortableMetaDataHandler.java | 44 - .../internal/portable/PortableMetaDataImpl.java | 150 - .../internal/portable/PortableObjectEx.java | 214 - .../internal/portable/PortableObjectImpl.java | 391 -- .../portable/PortableObjectOffheapImpl.java | 243 -- .../portable/PortablePositionReadable.java | 47 + .../internal/portable/PortablePrimitives.java | 779 +--- .../internal/portable/PortableRawReaderEx.java | 33 - .../internal/portable/PortableRawWriterEx.java | 60 - .../portable/PortableReaderContext.java | 82 - .../internal/portable/PortableReaderExImpl.java | 3157 --------------- .../internal/portable/PortableSchema.java | 466 +++ .../portable/PortableSchemaRegistry.java | 172 + .../PortableThreadLocalMemoryAllocator.java | 162 - .../ignite/internal/portable/PortableUtils.java | 651 +++- .../internal/portable/PortableWriterExImpl.java | 1854 --------- .../internal/portable/api/IgnitePortables.java | 362 -- .../internal/portable/api/PortableBuilder.java | 136 - .../portable/api/PortableException.java | 57 - .../internal/portable/api/PortableIdMapper.java | 54 - .../api/PortableInvalidClassException.java | 58 - .../portable/api/PortableMarshalAware.java | 48 - .../portable/api/PortableMarshaller.java | 357 -- .../internal/portable/api/PortableMetadata.java | 60 - .../internal/portable/api/PortableObject.java | 152 - .../portable/api/PortableProtocolVersion.java | 41 - .../portable/api/PortableRawReader.java | 234 -- .../portable/api/PortableRawWriter.java | 219 -- .../internal/portable/api/PortableReader.java | 284 -- .../portable/api/PortableSerializer.java | 47 - .../portable/api/PortableTypeConfiguration.java | 195 - .../internal/portable/api/PortableWriter.java | 266 -- .../builder/BinaryObjectBuilderImpl.java | 577 +++ .../portable/builder/PortableBuilderEnum.java | 8 +- .../portable/builder/PortableBuilderImpl.java | 533 --- .../portable/builder/PortableBuilderReader.java | 214 +- .../PortableBuilderSerializationAware.java | 2 +- .../builder/PortableBuilderSerializer.java | 36 +- .../builder/PortableEnumArrayLazyValue.java | 12 +- .../portable/builder/PortableLazyArrayList.java | 8 +- .../builder/PortableLazyLinkedList.java | 8 +- .../portable/builder/PortableLazyMap.java | 8 +- .../portable/builder/PortableLazyMapEntry.java | 2 +- .../portable/builder/PortableLazySet.java | 8 +- .../builder/PortableModifiableLazyValue.java | 2 +- .../builder/PortableObjectArrayLazyValue.java | 8 +- .../builder/PortablePlainLazyValue.java | 2 +- .../builder/PortablePlainPortableObject.java | 22 +- .../portable/builder/PortableValueWithType.java | 13 +- .../streams/PortableAbstractInputStream.java | 48 +- .../streams/PortableAbstractOutputStream.java | 44 +- .../streams/PortableHeapInputStream.java | 34 +- .../streams/PortableHeapOutputStream.java | 106 +- .../portable/streams/PortableInputStream.java | 12 +- .../streams/PortableMemoryAllocator.java | 67 +- .../streams/PortableMemoryAllocatorChunk.java | 117 + .../streams/PortableOffheapInputStream.java | 17 +- .../streams/PortableOffheapOutputStream.java | 59 +- .../portable/streams/PortableOutputStream.java | 94 + .../streams/PortableSimpleMemoryAllocator.java | 66 - .../affinity/GridAffinityAssignmentCache.java | 3 +- .../affinity/GridAffinityProcessor.java | 5 +- .../processors/cache/CacheInvokeEntry.java | 11 +- .../processors/cache/CacheLazyEntry.java | 23 +- .../internal/processors/cache/CacheObject.java | 11 +- .../processors/cache/CacheObjectAdapter.java | 2 +- .../cache/CacheObjectByteArrayImpl.java | 7 +- .../processors/cache/CacheObjectContext.java | 128 +- .../processors/cache/CacheObjectImpl.java | 5 + .../processors/cache/CacheOperationContext.java | 22 +- .../processors/cache/GridCacheAdapter.java | 98 +- .../cache/GridCacheConcurrentMap.java | 10 +- .../processors/cache/GridCacheContext.java | 14 +- .../processors/cache/GridCacheEntryEx.java | 15 +- .../processors/cache/GridCacheEventManager.java | 31 +- .../cache/GridCacheEvictionManager.java | 5 +- .../processors/cache/GridCacheMapEntry.java | 157 +- .../processors/cache/GridCacheMvccManager.java | 29 +- .../GridCachePartitionExchangeManager.java | 34 +- .../processors/cache/GridCacheProcessor.java | 7 + .../processors/cache/GridCacheProxyImpl.java | 4 +- .../processors/cache/GridCacheReturn.java | 27 +- .../processors/cache/GridCacheSwapManager.java | 37 +- .../processors/cache/GridCacheUtils.java | 42 +- .../processors/cache/IgniteCacheProxy.java | 11 +- .../processors/cache/IgniteInternalCache.java | 6 +- .../processors/cache/KeyCacheObjectImpl.java | 5 + .../CacheDataStructuresManager.java | 6 +- .../GridDistributedCacheAdapter.java | 40 +- .../distributed/GridDistributedCacheEntry.java | 9 +- .../distributed/GridDistributedLockRequest.java | 17 + .../GridDistributedTxPrepareRequest.java | 3 +- .../GridDistributedTxRemoteAdapter.java | 3 + .../GridFutureRemapTimeoutObject.java | 72 - .../dht/GridClientPartitionTopology.java | 38 +- .../distributed/dht/GridDhtCacheEntry.java | 5 +- .../distributed/dht/GridDhtLocalPartition.java | 3 +- .../distributed/dht/GridDhtLockFuture.java | 11 +- .../distributed/dht/GridDhtLockRequest.java | 3 + .../dht/GridDhtPartitionTopology.java | 12 +- .../dht/GridDhtPartitionTopologyImpl.java | 45 +- .../dht/GridDhtTransactionalCacheAdapter.java | 21 +- .../distributed/dht/GridDhtTxLocalAdapter.java | 17 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 16 +- .../cache/distributed/dht/GridDhtTxRemote.java | 12 +- .../dht/GridPartitionedGetFuture.java | 36 +- .../dht/GridPartitionedSingleGetFuture.java | 14 +- .../dht/atomic/GridDhtAtomicCache.java | 74 +- .../dht/atomic/GridDhtAtomicUpdateFuture.java | 6 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 42 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 15 +- .../dht/atomic/GridNearAtomicUpdateRequest.java | 68 +- .../atomic/GridNearAtomicUpdateResponse.java | 5 +- .../dht/colocated/GridDhtColocatedCache.java | 31 +- .../colocated/GridDhtColocatedLockFuture.java | 15 +- .../dht/preloader/GridDhtForceKeysFuture.java | 2 +- .../dht/preloader/GridDhtPartitionDemander.java | 2 +- .../dht/preloader/GridDhtPartitionFullMap.java | 41 +- .../dht/preloader/GridDhtPartitionMap.java | 148 +- .../dht/preloader/GridDhtPartitionMap2.java | 306 ++ .../GridDhtPartitionsExchangeFuture.java | 24 +- .../GridDhtPartitionsSingleMessage.java | 6 +- .../distributed/near/GridNearAtomicCache.java | 4 + .../distributed/near/GridNearCacheAdapter.java | 1 - .../distributed/near/GridNearCacheEntry.java | 17 +- .../distributed/near/GridNearGetFuture.java | 85 +- .../distributed/near/GridNearLockFuture.java | 16 +- .../distributed/near/GridNearLockRequest.java | 2 + ...arOptimisticSerializableTxPrepareFuture.java | 3 - .../near/GridNearOptimisticTxPrepareFuture.java | 1 - .../near/GridNearTransactionalCache.java | 8 +- .../near/GridNearTxFinishFuture.java | 4 - .../cache/distributed/near/GridNearTxLocal.java | 9 +- .../distributed/near/GridNearTxRemote.java | 13 +- .../processors/cache/local/GridLocalCache.java | 1 - .../cache/local/GridLocalCacheEntry.java | 16 +- .../cache/local/GridLocalLockFuture.java | 5 +- .../local/atomic/GridLocalAtomicCache.java | 108 +- .../CacheDefaultPortableAffinityKeyMapper.java | 8 +- .../portable/CacheObjectBinaryProcessor.java | 97 + .../CacheObjectBinaryProcessorImpl.java | 848 ++++ .../portable/CacheObjectPortableContext.java | 133 - .../portable/CacheObjectPortableProcessor.java | 103 - .../CacheObjectPortableProcessorImpl.java | 1035 ----- .../cache/portable/IgniteBinaryImpl.java | 165 + .../cache/portable/IgnitePortablesImpl.java | 177 - .../cache/portable/PortableMetaDataKey.java | 82 - .../cache/portable/PortableMetadataKey.java | 82 + .../cache/query/GridCacheQueryManager.java | 298 +- .../cache/query/GridCacheQueryRequest.java | 4 +- .../continuous/CacheContinuousQueryEvent.java | 10 +- .../cache/store/CacheOsStoreManager.java | 4 +- .../store/GridCacheStoreManagerAdapter.java | 47 +- .../cache/transactions/IgniteInternalTx.java | 1 - .../transactions/IgniteTransactionsImpl.java | 10 +- .../cache/transactions/IgniteTxAdapter.java | 6 +- .../cache/transactions/IgniteTxEntry.java | 57 +- .../IgniteTxImplicitSingleStateImpl.java | 29 +- .../transactions/IgniteTxLocalAdapter.java | 146 +- .../cache/transactions/IgniteTxLocalEx.java | 1 + .../cache/transactions/IgniteTxManager.java | 3 +- .../IgniteTxRemoteSingleStateImpl.java | 19 +- .../cache/transactions/IgniteTxStateImpl.java | 1 - .../cacheobject/IgniteCacheObjectProcessor.java | 6 + .../IgniteCacheObjectProcessorImpl.java | 9 + .../processors/cacheobject/NoOpBinary.java | 75 + .../continuous/GridContinuousProcessor.java | 6 +- .../datastreamer/DataStreamProcessor.java | 1 + .../datastreamer/DataStreamerEntry.java | 6 +- .../datastreamer/DataStreamerImpl.java | 16 +- .../datastreamer/DataStreamerRequest.java | 58 +- .../datastreamer/DataStreamerUpdateJob.java | 10 +- .../datastructures/DataStructuresProcessor.java | 240 +- .../GridAtomicCacheQueueImpl.java | 126 +- .../datastructures/GridCacheAtomicLongImpl.java | 26 +- .../GridCacheAtomicReferenceImpl.java | 10 +- .../GridCacheCountDownLatchImpl.java | 15 +- .../datastructures/GridCacheQueueAdapter.java | 32 +- .../datastructures/GridCacheSemaphoreEx.java | 47 + .../datastructures/GridCacheSemaphoreImpl.java | 763 ++++ .../datastructures/GridCacheSemaphoreState.java | 144 + .../GridTransactionalCacheQueueImpl.java | 193 +- .../processors/hadoop/HadoopJobProperty.java | 2 +- .../platform/PlatformAbstractBootstrap.java | 48 + .../PlatformAbstractConfigurationClosure.java | 61 + .../platform/PlatformAbstractPredicate.java | 67 + .../platform/PlatformAbstractTarget.java | 320 ++ .../processors/platform/PlatformBootstrap.java | 35 + .../platform/PlatformBootstrapFactory.java | 37 + .../platform/PlatformConfiguration.java | 25 - .../platform/PlatformConfigurationEx.java | 48 + .../processors/platform/PlatformContext.java | 26 +- .../platform/PlatformContextImpl.java | 616 +++ .../platform/PlatformExtendedException.java | 4 +- .../processors/platform/PlatformIgnition.java | 189 + .../platform/PlatformNoopProcessor.java | 6 + .../processors/platform/PlatformProcessor.java | 11 + .../platform/PlatformProcessorImpl.java | 374 ++ .../platform/cache/PlatformCache.java | 1090 ++++++ .../cache/PlatformCacheEntryFilterImpl.java | 106 + .../cache/PlatformCacheEntryProcessorImpl.java | 220 ++ .../platform/cache/PlatformCacheIterator.java | 72 + .../PlatformCachePartialUpdateException.java | 59 + .../cache/affinity/PlatformAffinity.java | 297 ++ .../query/PlatformAbstractQueryCursor.java | 192 + .../query/PlatformContinuousQueryImpl.java | 235 ++ .../PlatformContinuousQueryRemoteFilter.java | 188 + .../cache/query/PlatformFieldsQueryCursor.java | 49 + .../cache/query/PlatformQueryCursor.java | 45 + .../cache/store/PlatformCacheStoreCallback.java | 61 + .../platform/cluster/PlatformClusterGroup.java | 335 ++ .../cluster/PlatformClusterNodeFilterImpl.java | 78 + .../platform/compute/PlatformAbstractJob.java | 156 + .../platform/compute/PlatformAbstractTask.java | 206 + .../PlatformBalancingMultiClosureTask.java | 83 + ...tformBalancingSingleClosureAffinityTask.java | 88 + .../PlatformBalancingSingleClosureTask.java | 81 + .../PlatformBroadcastingMultiClosureTask.java | 87 + .../PlatformBroadcastingSingleClosureTask.java | 84 + .../platform/compute/PlatformClosureJob.java | 104 + .../platform/compute/PlatformCompute.java | 332 ++ .../platform/compute/PlatformFullJob.java | 220 ++ .../platform/compute/PlatformFullTask.java | 192 + .../platform/cpp/PlatformCppBootstrap.java | 31 + .../cpp/PlatformCppBootstrapFactory.java | 39 + .../cpp/PlatformCppConfigurationClosure.java | 114 + .../cpp/PlatformCppConfigurationEx.java | 82 + .../datastreamer/PlatformDataStreamer.java | 227 ++ .../PlatformStreamReceiverImpl.java | 119 + .../datastructures/PlatformAtomicLong.java | 149 + .../dotnet/PlatformDotNetBootstrap.java | 31 + .../dotnet/PlatformDotNetBootstrapFactory.java | 39 + .../dotnet/PlatformDotNetCacheStore.java | 484 +++ .../dotnet/PlatformDotNetConfiguration.java | 119 - .../PlatformDotNetConfigurationClosure.java | 258 ++ .../dotnet/PlatformDotNetConfigurationEx.java | 91 + .../PlatformDotNetPortableConfiguration.java | 228 -- ...PlatformDotNetPortableTypeConfiguration.java | 248 -- .../platform/dotnet/PlatformDotNetService.java | 27 + .../dotnet/PlatformDotNetServiceImpl.java | 47 + .../events/PlatformEventFilterListenerImpl.java | 186 + .../platform/events/PlatformEvents.java | 396 ++ .../lifecycle/PlatformLifecycleBean.java | 75 + .../platform/memory/PlatformAbstractMemory.java | 121 + .../PlatformBigEndianInputStreamImpl.java | 136 + .../PlatformBigEndianOutputStreamImpl.java | 196 + .../platform/memory/PlatformExternalMemory.java | 55 + .../memory/PlatformInputStreamImpl.java | 351 ++ .../memory/PlatformMemoryManagerImpl.java | 85 + .../platform/memory/PlatformMemoryPool.java | 140 + .../platform/memory/PlatformMemoryUtils.java | 467 +++ .../memory/PlatformOutputStreamImpl.java | 342 ++ .../platform/memory/PlatformPooledMemory.java | 64 + .../platform/memory/PlatformUnpooledMemory.java | 51 + .../messaging/PlatformMessageFilterImpl.java | 110 + .../messaging/PlatformMessageLocalFilter.java | 102 + .../platform/messaging/PlatformMessaging.java | 166 + .../services/PlatformAbstractService.java | 230 ++ .../platform/services/PlatformServices.java | 275 ++ .../transactions/PlatformTransactions.java | 259 ++ .../platform/utils/PlatformFutureUtils.java | 397 ++ .../platform/utils/PlatformReaderBiClosure.java | 34 + .../platform/utils/PlatformReaderClosure.java | 34 + .../platform/utils/PlatformUtils.java | 809 ++++ .../platform/utils/PlatformWriterBiClosure.java | 34 + .../platform/utils/PlatformWriterClosure.java | 33 + .../processors/query/GridQueryIndexing.java | 18 +- .../processors/query/GridQueryProcessor.java | 674 ++-- .../client/message/GridClientTaskRequest.java | 6 +- .../ignite/internal/util/GridEnumCache.java | 56 - .../ignite/internal/util/IgniteUtils.java | 65 +- .../internal/util/ipc/IpcToNioAdapter.java | 14 +- .../util/nio/GridCommunicationClient.java | 4 +- .../internal/util/nio/GridDirectParser.java | 37 +- .../util/nio/GridNioMessageReaderFactory.java | 37 + .../util/nio/GridNioMessageWriterFactory.java | 35 + .../ignite/internal/util/nio/GridNioServer.java | 51 +- .../util/nio/GridShmemCommunicationClient.java | 12 +- .../ignite/internal/visor/cache/VisorCache.java | 6 +- .../marshaller/portable/BinaryMarshaller.java | 146 + .../marshaller/portable/package-info.java | 22 + .../platform/cpp/PlatformCppConfiguration.java | 47 + .../ignite/platform/cpp/package-info.java | 22 + .../PlatformDotNetBinaryConfiguration.java | 170 + .../PlatformDotNetBinaryTypeConfiguration.java | 171 + .../dotnet/PlatformDotNetCacheStoreFactory.java | 117 + .../dotnet/PlatformDotNetConfiguration.java | 97 + .../dotnet/PlatformDotNetLifecycleBean.java | 86 + .../ignite/platform/dotnet/package-info.java | 22 + .../apache/ignite/platform/package-info.java | 22 + .../communication/MessageFormatter.java | 15 +- .../extensions/communication/MessageReader.java | 26 +- .../org/apache/ignite/spi/IgniteSpiAdapter.java | 6 +- .../communication/tcp/TcpCommunicationSpi.java | 80 +- .../ignite/spi/discovery/DiscoverySpi.java | 2 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 87 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 2 + .../apache/ignite/spi/swapspace/SwapKey.java | 9 +- .../org/apache/ignite/stream/StreamAdapter.java | 1 - .../apache/ignite/stream/StreamTransformer.java | 9 +- .../resources/META-INF/classnames.properties | 269 +- .../IgniteClientReconnectAtomicsTest.java | 44 +- .../portable/BinaryFieldsAbstractSelfTest.java | 719 ++++ .../portable/BinaryFieldsHeapSelfTest.java | 32 + .../portable/BinaryFieldsOffheapSelfTest.java | 61 + .../BinaryFooterOffsetsAbstractSelfTest.java | 206 + .../BinaryFooterOffsetsHeapSelfTest.java | 32 + .../BinaryFooterOffsetsOffheapSelfTest.java | 61 + .../portable/BinaryMarshallerSelfTest.java | 3671 ++++++++++++++++++ .../BinaryObjectBuilderAdditionalSelfTest.java | 1292 ++++++ .../portable/BinaryObjectBuilderSelfTest.java | 1069 +++++ .../GridPortableAffinityKeySelfTest.java | 225 ++ ...idPortableMarshallerCtxDisabledSelfTest.java | 248 ++ .../portable/GridPortableMetaDataSelfTest.java | 372 ++ .../portable/GridPortableWildcardsSelfTest.java | 465 +++ .../portable/TestCachingMetadataHandler.java | 45 + .../GridBinaryMarshalerAwareTestClass.java | 67 + .../mutabletest/GridPortableTestClasses.java | 443 +++ .../portable/mutabletest/package-info.java | 22 + .../BinaryFieldsHeapNonCompactSelfTest.java | 30 + .../BinaryFieldsOffheapNonCompactSelfTest.java | 30 + ...naryFooterOffsetsHeapNonCompactSelfTest.java | 30 + ...yFooterOffsetsOffheapNonCompactSelfTest.java | 30 + .../BinaryMarshallerNonCompactSelfTest.java | 30 + ...jectBuilderAdditionalNonCompactSelfTest.java | 30 + .../BinaryObjectBuilderNonCompactSelfTest.java | 30 + .../ignite/internal/portable/package-info.java | 22 + .../portable/test/GridPortableTestClass1.java | 28 + .../portable/test/GridPortableTestClass2.java | 24 + .../internal/portable/test/package-info.java | 22 + .../test/subpackage/GridPortableTestClass3.java | 24 + .../portable/test/subpackage/package-info.java | 22 + .../cache/CacheNearReaderUpdateTest.java | 62 +- .../cache/GridCacheAbstractSelfTest.java | 9 +- ...heOffHeapTieredEvictionAbstractSelfTest.java | 2 +- .../processors/cache/GridCacheTestEntryEx.java | 13 +- .../cache/IgniteCachePeekModesAbstractTest.java | 30 +- ...IgniteCacheAbstractExecutionContextTest.java | 5 + ...eAbstractDataStructuresFailoverSelfTest.java | 1065 +++-- .../IgniteClientDataStructuresAbstractTest.java | 59 +- .../IgniteDataStructureUniqueNameTest.java | 14 +- .../IgniteSemaphoreAbstractSelfTest.java | 411 ++ .../local/IgniteLocalSemaphoreSelfTest.java | 98 + ...rtitionedDataStructuresFailoverSelfTest.java | 7 +- ...edOffheapDataStructuresFailoverSelfTest.java | 12 +- .../IgnitePartitionedSemaphoreSelfTest.java | 33 + ...eplicatedDataStructuresFailoverSelfTest.java | 7 +- .../IgniteReplicatedSemaphoreSelfTest.java | 33 + ...tractDistributedByteArrayValuesSelfTest.java | 4 + .../dht/GridCacheDhtPreloadDelayedSelfTest.java | 12 +- .../dht/GridCacheDhtPreloadSelfTest.java | 4 +- .../distributed/dht/GridCacheDhtTestUtils.java | 8 +- ...gniteAtomicLongChangingTopologySelfTest.java | 2 + ...cingDelayedPartitionMapExchangeSelfTest.java | 178 + ...naryObjectsAbstractDataStreamerSelfTest.java | 192 + ...aryObjectsAbstractMultiThreadedSelfTest.java | 233 ++ .../GridCacheBinaryObjectsAbstractSelfTest.java | 981 +++++ ...ntNodeBinaryObjectMetadataMultinodeTest.java | 295 ++ ...CacheClientNodeBinaryObjectMetadataTest.java | 221 ++ .../GridCachePortableStoreAbstractSelfTest.java | 300 ++ .../GridCachePortableStoreObjectsSelfTest.java | 55 + ...GridCachePortableStorePortablesSelfTest.java | 66 + ...ridPortableCacheEntryMemorySizeSelfTest.java | 48 + ...leDuplicateIndexObjectsAbstractSelfTest.java | 161 + .../DataStreamProcessorPortableSelfTest.java | 71 + .../GridDataStreamerImplSelfTest.java | 345 ++ ...ridCacheAffinityRoutingPortableSelfTest.java | 54 + ...lyPortableDataStreamerMultiNodeSelfTest.java | 29 + ...rtableDataStreamerMultithreadedSelfTest.java | 47 + ...artitionedOnlyPortableMultiNodeSelfTest.java | 28 + ...tionedOnlyPortableMultithreadedSelfTest.java | 47 + ...AtomicNearDisabledOffheapTieredSelfTest.java | 29 + ...BinaryObjectsAtomicNearDisabledSelfTest.java | 51 + ...inaryObjectsAtomicOffheapTieredSelfTest.java | 29 + .../GridCacheBinaryObjectsAtomicSelfTest.java | 51 + ...tionedNearDisabledOffheapTieredSelfTest.java | 30 + ...yObjectsPartitionedNearDisabledSelfTest.java | 51 + ...ObjectsPartitionedOffheapTieredSelfTest.java | 30 + ...idCacheBinaryObjectsPartitionedSelfTest.java | 51 + .../GridCacheMemoryModePortableSelfTest.java | 36 + ...acheOffHeapTieredAtomicPortableSelfTest.java | 48 + ...eapTieredEvictionAtomicPortableSelfTest.java | 96 + ...heOffHeapTieredEvictionPortableSelfTest.java | 96 + .../GridCacheOffHeapTieredPortableSelfTest.java | 48 + ...ateIndexObjectPartitionedAtomicSelfTest.java | 38 + ...xObjectPartitionedTransactionalSelfTest.java | 41 + ...sNearPartitionedByteArrayValuesSelfTest.java | 41 + ...sPartitionedOnlyByteArrayValuesSelfTest.java | 42 + ...ridCacheBinaryObjectsReplicatedSelfTest.java | 51 + ...idCacheBinaryObjectsAtomicLocalSelfTest.java | 32 + ...BinaryObjectsLocalOffheapTieredSelfTest.java | 29 + .../GridCacheBinaryObjectsLocalSelfTest.java | 51 + .../CacheVersionedEntryAbstractTest.java | 2 +- .../continuous/GridEventConsumeSelfTest.java | 111 +- .../DataStreamProcessorSelfTest.java | 8 + .../cache/GridCacheDataStructuresLoadTest.java | 283 +- .../loadtests/hashmap/GridHashMapLoadTest.java | 3 +- .../platform/PlatformComputeBinarizable.java | 42 + .../PlatformComputeBinarizableArgTask.java | 119 + .../platform/PlatformComputeBroadcastTask.java | 73 + .../platform/PlatformComputeDecimalTask.java | 106 + .../platform/PlatformComputeEchoTask.java | 188 + .../ignite/platform/PlatformComputeEnum.java | 28 + .../PlatformComputeJavaBinarizable.java | 39 + .../platform/PlatformEventsWriteEventTask.java | 144 + .../ignite/platform/PlatformMaxMemoryTask.java | 57 + .../ignite/platform/PlatformMinMemoryTask.java | 57 + .../lifecycle/PlatformJavaLifecycleBean.java | 47 + .../lifecycle/PlatformJavaLifecycleTask.java | 65 + ...GridTcpCommunicationSpiRecoverySelfTest.java | 4 +- ...lientDiscoverySpiFailureTimeoutSelfTest.java | 4 +- .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 90 +- .../file/GridFileSwapSpaceSpiSelfTest.java | 11 +- .../testframework/GridSpiTestContext.java | 12 +- .../testframework/junits/GridAbstractTest.java | 10 +- .../ignite/testframework/junits/IgniteMock.java | 16 + .../multijvm/IgniteCacheProcessProxy.java | 7 +- .../junits/multijvm/IgniteProcessProxy.java | 11 +- .../testsuites/IgniteCacheTestSuite3.java | 2 + .../IgnitePortableCacheFullApiTestSuite.java | 37 + .../IgnitePortableCacheTestSuite.java | 103 + .../IgnitePortableObjectsTestSuite.java | 110 + .../ignite/portable/test1/1.1/test1-1.1.jar | Bin 0 -> 2548 bytes .../ignite/portable/test1/1.1/test1-1.1.pom | 9 + .../portable/test1/maven-metadata-local.xml | 12 + .../ignite/portable/test2/1.1/test2-1.1.jar | Bin 0 -> 1361 bytes .../ignite/portable/test2/1.1/test2-1.1.pom | 9 + .../portable/test2/maven-metadata-local.xml | 12 + .../HadoopDefaultMapReducePlannerSelfTest.java | 6 - .../processors/query/h2/IgniteH2Indexing.java | 25 +- .../query/h2/opt/GridH2ValueCacheObject.java | 8 +- .../query/h2/opt/GridLuceneIndex.java | 4 +- .../h2/twostep/GridReduceQueryExecutor.java | 4 +- .../IgniteCacheAbstractFieldsQuerySelfTest.java | 3 +- ...CacheOffheapTieredMultithreadedSelfTest.java | 25 +- ...niteCacheP2pUnmarshallingQueryErrorTest.java | 22 +- ...hePartitionedQueryMultiThreadedSelfTest.java | 22 +- .../query/IgniteSqlSplitterSelfTest.java | 54 + .../h2/GridIndexingSpiAbstractSelfTest.java | 7 +- .../IgnitePortableCacheQueryTestSuite.java | 117 + modules/platform/licenses/apache-2.0.txt | 202 - modules/platform/pom.xml | 80 - modules/platform/src/main/cpp/README.txt | 103 - .../platform/src/main/cpp/common/Makefile.am | 45 - .../platform/src/main/cpp/common/configure.ac | 62 - .../src/main/cpp/common/ignite-common.pc.in | 9 - .../src/main/cpp/common/include/Makefile.am | 22 - .../common/include/ignite/common/concurrent.h | 210 - .../cpp/common/include/ignite/common/exports.h | 145 - .../cpp/common/include/ignite/common/java.h | 652 ---- .../cpp/common/os/linux/include/Makefile.am | 21 - .../os/linux/include/ignite/common/common.h | 81 - .../linux/include/ignite/common/concurrent_os.h | 394 -- .../src/main/cpp/common/os/linux/src/common.cpp | 59 - .../cpp/common/os/linux/src/concurrent_os.cpp | 175 - .../os/win/include/ignite/common/common.h | 56 - .../win/include/ignite/common/concurrent_os.h | 406 -- .../src/main/cpp/common/os/win/src/common.cpp | 65 - .../cpp/common/os/win/src/concurrent_os.cpp | 151 - .../src/main/cpp/common/project/README.TXT | 1 - .../src/main/cpp/common/project/vs/README.TXT | 1 - .../main/cpp/common/project/vs/common.vcxproj | 202 - .../common/project/vs/common.vcxproj.filters | 54 - .../src/main/cpp/common/project/vs/module.def | 99 - .../src/main/cpp/common/project/vs/targetver.h | 25 - .../src/main/cpp/common/src/concurrent.cpp | 94 - .../src/main/cpp/common/src/exports.cpp | 413 -- .../platform/src/main/cpp/common/src/java.cpp | 2205 ----------- .../platform/src/main/cpp/core-test/Makefile.am | 49 - .../main/cpp/core-test/config/cache-query.xml | 91 - .../main/cpp/core-test/config/cache-test.xml | 129 - .../src/main/cpp/core-test/configure.ac | 62 - .../src/main/cpp/core-test/include/Makefile.am | 22 - .../include/ignite/portable_test_defs.h | 320 -- .../include/ignite/portable_test_utils.h | 516 --- .../cpp/core-test/include/teamcity_messages.h | 55 - .../src/main/cpp/core-test/project/README.TXT | 1 - .../main/cpp/core-test/project/vs/README.TXT | 1 - .../cpp/core-test/project/vs/core-test.vcxproj | 174 - .../project/vs/core-test.vcxproj.filters | 68 - .../main/cpp/core-test/src/cache_query_test.cpp | 656 ---- .../src/main/cpp/core-test/src/cache_test.cpp | 486 --- .../main/cpp/core-test/src/concurrent_test.cpp | 186 - .../cpp/core-test/src/handle_registry_test.cpp | 176 - .../main/cpp/core-test/src/ignition_test.cpp | 102 - .../src/portable_reader_writer_raw_test.cpp | 1532 -------- .../src/portable_reader_writer_test.cpp | 1951 ---------- .../cpp/core-test/src/portable_session_test.cpp | 257 -- .../cpp/core-test/src/portable_test_defs.cpp | 65 - .../main/cpp/core-test/src/teamcity_boost.cpp | 159 - .../cpp/core-test/src/teamcity_messages.cpp | 150 - modules/platform/src/main/cpp/core/Makefile.am | 66 - modules/platform/src/main/cpp/core/configure.ac | 62 - modules/platform/src/main/cpp/core/ignite.pc.in | 9 - .../src/main/cpp/core/include/Makefile.am | 61 - .../main/cpp/core/include/ignite/cache/cache.h | 1153 ------ .../cpp/core/include/ignite/cache/cache_entry.h | 118 - .../core/include/ignite/cache/cache_peek_mode.h | 71 - .../cpp/core/include/ignite/cache/query/query.h | 27 - .../include/ignite/cache/query/query_argument.h | 125 - .../include/ignite/cache/query/query_cursor.h | 191 - .../include/ignite/cache/query/query_scan.h | 151 - .../core/include/ignite/cache/query/query_sql.h | 253 -- .../include/ignite/cache/query/query_text.h | 159 - .../src/main/cpp/core/include/ignite/guid.h | 112 - .../src/main/cpp/core/include/ignite/ignite.h | 154 - .../core/include/ignite/ignite_configuration.h | 92 - .../main/cpp/core/include/ignite/ignite_error.h | 260 -- .../src/main/cpp/core/include/ignite/ignition.h | 195 - .../core/include/ignite/impl/cache/cache_impl.h | 418 -- .../ignite/impl/cache/query/query_impl.h | 115 - .../core/include/ignite/impl/handle_registry.h | 202 - .../include/ignite/impl/ignite_environment.h | 130 - .../cpp/core/include/ignite/impl/ignite_impl.h | 146 - .../core/include/ignite/impl/interop/interop.h | 25 - .../ignite/impl/interop/interop_input_stream.h | 234 -- .../ignite/impl/interop/interop_memory.h | 280 -- .../ignite/impl/interop/interop_output_stream.h | 234 -- .../cpp/core/include/ignite/impl/operations.h | 452 --- .../ignite/impl/portable/portable_common.h | 146 - .../ignite/impl/portable/portable_id_resolver.h | 106 - .../impl/portable/portable_metadata_handler.h | 102 - .../impl/portable/portable_metadata_manager.h | 120 - .../impl/portable/portable_metadata_snapshot.h | 122 - .../impl/portable/portable_metadata_updater.h | 53 - .../portable/portable_metadata_updater_impl.h | 65 - .../ignite/impl/portable/portable_reader_impl.h | 1130 ------ .../ignite/impl/portable/portable_utils.h | 344 -- .../ignite/impl/portable/portable_writer_impl.h | 859 ---- .../cpp/core/include/ignite/portable/portable.h | 29 - .../include/ignite/portable/portable_consts.h | 106 - .../ignite/portable/portable_containers.h | 525 --- .../ignite/portable/portable_raw_reader.h | 324 -- .../ignite/portable/portable_raw_writer.h | 300 -- .../include/ignite/portable/portable_reader.h | 355 -- .../include/ignite/portable/portable_type.h | 293 -- .../include/ignite/portable/portable_writer.h | 335 -- .../main/cpp/core/os/linux/include/Makefile.am | 20 - .../core/os/linux/include/ignite/impl/utils.h | 155 - .../main/cpp/core/os/linux/src/impl/utils.cpp | 439 --- .../cpp/core/os/win/include/ignite/impl/utils.h | 155 - .../src/main/cpp/core/os/win/src/impl/utils.cpp | 453 --- .../src/main/cpp/core/project/README.TXT | 1 - .../src/main/cpp/core/project/vs/README.TXT | 1 - .../src/main/cpp/core/project/vs/core.vcxproj | 272 -- .../cpp/core/project/vs/core.vcxproj.filters | 246 -- modules/platform/src/main/cpp/core/src/guid.cpp | 65 - .../platform/src/main/cpp/core/src/ignite.cpp | 43 - .../src/main/cpp/core/src/ignite_error.cpp | 222 -- .../platform/src/main/cpp/core/src/ignition.cpp | 468 --- .../main/cpp/core/src/impl/cache/cache_impl.cpp | 388 -- .../core/src/impl/cache/query/query_impl.cpp | 193 - .../main/cpp/core/src/impl/handle_registry.cpp | 234 -- .../cpp/core/src/impl/ignite_environment.cpp | 167 - .../src/main/cpp/core/src/impl/ignite_impl.cpp | 42 - .../src/impl/interop/interop_input_stream.cpp | 215 - .../core/src/impl/interop/interop_memory.cpp | 182 - .../src/impl/interop/interop_output_stream.cpp | 215 - .../impl/portable/portable_metadata_handler.cpp | 78 - .../impl/portable/portable_metadata_manager.cpp | 201 - .../portable/portable_metadata_snapshot.cpp | 70 - .../impl/portable/portable_metadata_updater.cpp | 32 - .../portable/portable_metadata_updater_impl.cpp | 94 - .../src/impl/portable/portable_reader_impl.cpp | 683 ---- .../core/src/impl/portable/portable_utils.cpp | 214 - .../src/impl/portable/portable_writer_impl.cpp | 600 --- .../core/src/portable/portable_containers.cpp | 76 - .../core/src/portable/portable_raw_reader.cpp | 135 - .../core/src/portable/portable_raw_writer.cpp | 147 - .../cpp/core/src/portable/portable_reader.cpp | 142 - .../cpp/core/src/portable/portable_type.cpp | 51 - .../cpp/core/src/portable/portable_writer.cpp | 154 - .../platform/src/main/cpp/project/vs/ignite.sln | 48 - .../Apache.Ignite.Core.csproj | 376 -- .../Cache/CacheAtomicUpdateTimeoutException.cs | 67 - .../Cache/CacheEntryProcessorException.cs | 79 - .../Apache.Ignite.Core/Cache/CacheException.cs | 68 - .../Cache/CachePartialUpdateException.cs | 119 - .../Apache.Ignite.Core/Cache/CachePeekMode.cs | 68 - .../Cache/Event/CacheEntryEventType.cs | 41 - .../Cache/Event/ICacheEntryEvent.cs | 40 - .../Cache/Event/ICacheEntryEventFilter.cs | 31 - .../Cache/Event/ICacheEntryEventListener.cs | 33 - .../Cache/Expiry/ExpiryPolicy.cs | 89 - .../Cache/Expiry/IExpiryPolicy.cs | 59 - .../dotnet/Apache.Ignite.Core/Cache/ICache.cs | 542 --- .../Apache.Ignite.Core/Cache/ICacheAffinity.cs | 161 - .../Apache.Ignite.Core/Cache/ICacheEntry.cs | 37 - .../Cache/ICacheEntryFilter.cs | 34 - .../Cache/ICacheEntryProcessor.cs | 45 - .../Cache/ICacheEntryProcessorResult.cs | 40 - .../Apache.Ignite.Core/Cache/ICacheLock.cs | 58 - .../Apache.Ignite.Core/Cache/ICacheMetrics.cs | 486 --- .../Cache/IMutableCacheEntry.cs | 47 - .../Cache/Query/Continuous/ContinuousQuery.cs | 170 - .../Query/Continuous/IContinuousQueryHandle.cs | 51 - .../Cache/Query/IQueryCursor.cs | 40 - .../Apache.Ignite.Core/Cache/Query/QueryBase.cs | 82 - .../Apache.Ignite.Core/Cache/Query/ScanQuery.cs | 77 - .../Cache/Query/SqlFieldsQuery.cs | 81 - .../Apache.Ignite.Core/Cache/Query/SqlQuery.cs | 119 - .../Apache.Ignite.Core/Cache/Query/TextQuery.cs | 104 - .../Store/CacheParallelLoadStoreAdapter.cs | 205 - .../Cache/Store/CacheStoreAdapter.cs | 146 - .../Cache/Store/CacheStoreException.cs | 66 - .../Cache/Store/ICacheStore.cs | 184 - .../Cache/Store/ICacheStoreSession.cs | 42 - .../Cluster/ClusterGroupEmptyException.cs | 70 - .../Cluster/ClusterTopologyException.cs | 69 - .../Apache.Ignite.Core/Cluster/ICluster.cs | 80 - .../Apache.Ignite.Core/Cluster/IClusterGroup.cs | 229 -- .../Cluster/IClusterMetrics.cs | 515 --- .../Apache.Ignite.Core/Cluster/IClusterNode.cs | 138 - .../Cluster/IClusterNodeFilter.cs | 32 - .../Common/AsyncSupportedAttribute.cs | 33 - .../Apache.Ignite.Core/Common/IAsyncSupport.cs | 52 - .../dotnet/Apache.Ignite.Core/Common/IFuture.cs | 115 - .../Common/IgniteException.cs | 66 - .../Apache.Ignite.Core/Common/IgniteGuid.cs | 138 - .../ComputeExecutionRejectedException.cs | 69 - .../Compute/ComputeJobAdapter.cs | 122 - .../Compute/ComputeJobFailoverException.cs | 72 - .../Compute/ComputeJobResultPolicy.cs | 45 - .../Compute/ComputeTaskAdapter.cs | 93 - .../Compute/ComputeTaskCancelledException.cs | 69 - .../ComputeTaskNoResultCacheAttribute.cs | 35 - .../Compute/ComputeTaskSplitAdapter.cs | 95 - .../Compute/ComputeTaskTimeoutException.cs | 67 - .../Compute/ComputeUserUndeclaredException.cs | 70 - .../Apache.Ignite.Core/Compute/ICompute.cs | 274 -- .../Apache.Ignite.Core/Compute/IComputeFunc.cs | 55 - .../Apache.Ignite.Core/Compute/IComputeJob.cs | 58 - .../Compute/IComputeJobResult.cs | 73 - .../Compute/IComputeReducer.cs | 39 - .../Apache.Ignite.Core/Compute/IComputeTask.cs | 132 - .../Datastream/IDataStreamer.cs | 206 - .../Datastream/IStreamReceiver.cs | 38 - .../Datastream/StreamTransformer.cs | 73 - .../Datastream/StreamVisitor.cs | 55 - .../Apache.Ignite.Core/Events/CacheEvent.cs | 176 - .../Events/CacheQueryExecutedEvent.cs | 97 - .../Events/CacheQueryReadEvent.cs | 134 - .../Events/CacheRebalancingEvent.cs | 98 - .../Events/CheckpointEvent.cs | 50 - .../Apache.Ignite.Core/Events/DiscoveryEvent.cs | 80 - .../Apache.Ignite.Core/Events/EventBase.cs | 160 - .../Apache.Ignite.Core/Events/EventReader.cs | 72 - .../Apache.Ignite.Core/Events/EventType.cs | 514 --- .../dotnet/Apache.Ignite.Core/Events/IEvent.cs | 74 - .../Apache.Ignite.Core/Events/IEventFilter.cs | 36 - .../dotnet/Apache.Ignite.Core/Events/IEvents.cs | 182 - .../Apache.Ignite.Core/Events/JobEvent.cs | 100 - .../Apache.Ignite.Core/Events/SwapSpaceEvent.cs | 50 - .../Apache.Ignite.Core/Events/TaskEvent.cs | 91 - .../main/dotnet/Apache.Ignite.Core/IIgnite.cs | 168 - .../Apache.Ignite.Core/IgniteConfiguration.cs | 140 - .../main/dotnet/Apache.Ignite.Core/Ignition.cs | 657 ---- .../Impl/Cache/CacheAffinityImpl.cs | 275 -- .../Apache.Ignite.Core/Impl/Cache/CacheEntry.cs | 126 - .../Impl/Cache/CacheEntryFilterHolder.cs | 147 - .../Impl/Cache/CacheEntryProcessorHolder.cs | 145 - .../Impl/Cache/CacheEntryProcessorResult.cs | 65 - .../Cache/CacheEntryProcessorResultHolder.cs | 127 - .../Impl/Cache/CacheEnumerable.cs | 82 - .../Impl/Cache/CacheEnumerator.cs | 117 - .../Impl/Cache/CacheEnumeratorProxy.cs | 156 - .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 940 ----- .../Apache.Ignite.Core/Impl/Cache/CacheLock.cs | 171 - .../Impl/Cache/CacheMetricsImpl.cs | 248 -- .../Apache.Ignite.Core/Impl/Cache/CacheOp.cs | 63 - .../Impl/Cache/CacheProxyImpl.cs | 499 --- .../Impl/Cache/Event/CacheEntryCreateEvent.cs | 74 - .../Impl/Cache/Event/CacheEntryRemoveEvent.cs | 74 - .../Impl/Cache/Event/CacheEntryUpdateEvent.cs | 79 - .../Impl/Cache/MutableCacheEntry.cs | 163 - .../Impl/Cache/Query/AbstractQueryCursor.cs | 264 -- .../Query/Continuous/ContinuousQueryFilter.cs | 125 - .../Continuous/ContinuousQueryFilterHolder.cs | 118 - .../Continuous/ContinuousQueryHandleImpl.cs | 216 -- .../Query/Continuous/ContinuousQueryUtils.cs | 115 - .../Impl/Cache/Query/FieldsQueryCursor.cs | 54 - .../Impl/Cache/Query/QueryCursor.cs | 50 - .../Impl/Cache/Store/CacheStore.cs | 263 -- .../Impl/Cache/Store/CacheStoreSession.cs | 53 - .../Impl/Cache/Store/CacheStoreSessionProxy.cs | 63 - .../Impl/Cluster/ClusterGroupImpl.cs | 577 --- .../Impl/Cluster/ClusterMetricsImpl.cs | 292 -- .../Impl/Cluster/ClusterNodeImpl.cs | 221 -- .../Impl/Cluster/IClusterGroupEx.cs | 35 - .../Impl/Collections/CollectionExtensions.cs | 45 - .../Impl/Collections/MultiValueDictionary.cs | 143 - .../Impl/Collections/ReadOnlyCollection.cs | 102 - .../Impl/Collections/ReadOnlyDictionary.cs | 149 - .../Impl/Common/AsyncResult.cs | 71 - .../Impl/Common/CompletedAsyncResult.cs | 70 - .../Common/CopyOnWriteConcurrentDictionary.cs | 70 - .../Impl/Common/DelegateConverter.cs | 253 -- .../Impl/Common/DelegateTypeDescriptor.cs | 314 -- .../Apache.Ignite.Core/Impl/Common/Future.cs | 286 -- .../Impl/Common/FutureConverter.cs | 62 - .../Impl/Common/FutureType.cs | 52 - .../Impl/Common/IFutureConverter.cs | 34 - .../Impl/Common/IFutureInternal.cs | 46 - .../Impl/Common/IgniteArgumentCheck.cs | 76 - .../Impl/Common/LoadedAssembliesResolver.cs | 96 - .../Impl/Common/PortableResultWrapper.cs | 68 - .../Impl/Common/TypeCaster.cs | 72 - .../Closure/ComputeAbstractClosureTask.cs | 101 - .../Impl/Compute/Closure/ComputeActionJob.cs | 83 - .../Impl/Compute/Closure/ComputeFuncJob.cs | 89 - .../Compute/Closure/ComputeMultiClosureTask.cs | 56 - .../Impl/Compute/Closure/ComputeOutFuncJob.cs | 76 - .../Closure/ComputeReducingClosureTask.cs | 61 - .../Compute/Closure/ComputeSingleClosureTask.cs | 48 - .../Compute/Closure/IComputeResourceInjector.cs | 31 - .../Apache.Ignite.Core/Impl/Compute/Compute.cs | 213 - .../Impl/Compute/ComputeAsync.cs | 261 -- .../Impl/Compute/ComputeFunc.cs | 119 - .../Impl/Compute/ComputeImpl.cs | 645 --- .../Impl/Compute/ComputeJob.cs | 163 - .../Impl/Compute/ComputeJobHolder.cs | 246 -- .../Compute/ComputeJobResultGenericWrapper.cs | 70 - .../Impl/Compute/ComputeJobResultImpl.cs | 96 - .../Impl/Compute/ComputeOutFunc.cs | 123 - .../Impl/Compute/ComputeTaskHolder.cs | 484 --- .../Impl/Datastream/DataStreamerBatch.cs | 269 -- .../Impl/Datastream/DataStreamerEntry.cs | 64 - .../Impl/Datastream/DataStreamerImpl.cs | 832 ---- .../Impl/Datastream/DataStreamerRemoveEntry.cs | 48 - .../Impl/Datastream/StreamReceiverHolder.cs | 144 - .../Apache.Ignite.Core/Impl/Events/Events.cs | 498 --- .../Impl/Events/EventsAsync.cs | 158 - .../Impl/Events/RemoteListenEventFilter.cs | 85 - .../Apache.Ignite.Core/Impl/ExceptionUtils.cs | 204 - .../Apache.Ignite.Core/Impl/Handle/Handle.cs | 69 - .../Impl/Handle/HandleRegistry.cs | 340 -- .../Apache.Ignite.Core/Impl/Handle/IHandle.cs | 35 - .../Apache.Ignite.Core/Impl/IInteropCallback.cs | 34 - .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 549 --- .../Impl/IgniteConfigurationEx.cs | 57 - .../Apache.Ignite.Core/Impl/IgniteManager.cs | 490 --- .../Apache.Ignite.Core/Impl/IgniteProxy.cs | 351 -- .../Apache.Ignite.Core/Impl/IgniteUtils.cs | 438 --- .../Impl/Interop/InteropDotNetConfiguration.cs | 62 - .../InteropDotNetPortableConfiguration.cs | 127 - .../InteropDotNetPortableTypeConfiguration.cs | 151 - .../Impl/InteropExceptionHolder.cs | 85 - .../Impl/LifecycleBeanHolder.cs | 66 - .../Impl/Memory/IPlatformMemory.cs | 65 - .../Impl/Memory/InteropExternalMemory.cs | 46 - .../Impl/Memory/InteropMemoryUtils.cs | 38 - .../Memory/PlatformBigEndianMemoryStream.cs | 483 --- .../Impl/Memory/PlatformMemory.cs | 78 - .../Impl/Memory/PlatformMemoryManager.cs | 107 - .../Impl/Memory/PlatformMemoryPool.cs | 106 - .../Impl/Memory/PlatformMemoryStream.cs | 677 ---- .../Impl/Memory/PlatformMemoryUtils.cs | 463 --- .../Impl/Memory/PlatformPooledMemory.cs | 70 - .../Impl/Memory/PlatformRawMemory.cs | 89 - .../Impl/Memory/PlatformUnpooledMemory.cs | 52 - .../Impl/Messaging/MessageFilterHolder.cs | 179 - .../Impl/Messaging/Messaging.cs | 262 -- .../Impl/Messaging/MessagingAsync.cs | 68 - .../Apache.Ignite.Core/Impl/NativeMethods.cs | 47 - .../Apache.Ignite.Core/Impl/PlatformTarget.cs | 715 ---- .../Portable/IPortableSystemTypeSerializer.cs | 34 - .../Impl/Portable/IPortableTypeDescriptor.cs | 124 - .../Impl/Portable/IPortableWriteAware.cs | 34 - .../Impl/Portable/Io/IPortableStream.cs | 320 -- .../Impl/Portable/Io/PortableAbstractStream.cs | 1298 ------- .../Impl/Portable/Io/PortableHeapStream.cs | 447 --- .../Impl/Portable/Io/PortableStreamAdapter.cs | 114 - .../Metadata/IPortableMetadataHandler.cs | 41 - .../Metadata/PortableHashsetMetadataHandler.cs | 69 - .../Portable/Metadata/PortableMetadataHolder.cs | 149 - .../Portable/Metadata/PortableMetadataImpl.cs | 200 - .../Impl/Portable/PortableBuilderField.cs | 73 - .../Impl/Portable/PortableBuilderImpl.cs | 923 ----- .../Impl/Portable/PortableCollectionInfo.cs | 251 -- .../Impl/Portable/PortableFullTypeDescriptor.cs | 203 - .../Impl/Portable/PortableHandleDictionary.cs | 187 - .../Portable/PortableMarshalAwareSerializer.cs | 45 - .../Impl/Portable/PortableMarshaller.cs | 603 --- .../Impl/Portable/PortableMode.cs | 40 - .../Impl/Portable/PortableObjectHandle.cs | 59 - .../PortableOrSerializableObjectHolder.cs | 66 - .../Portable/PortableReaderHandleDictionary.cs | 42 - .../Impl/Portable/PortableReaderImpl.cs | 1013 ----- .../Impl/Portable/PortableReflectiveRoutines.cs | 483 --- .../Portable/PortableReflectiveSerializer.cs | 218 -- .../Portable/PortableSurrogateTypeDescriptor.cs | 133 - .../Impl/Portable/PortableSystemHandlers.cs | 1336 ------- .../Portable/PortableSystemTypeSerializer.cs | 62 - .../Impl/Portable/PortableUserObject.cs | 385 -- .../Impl/Portable/PortableUtils.cs | 2039 ---------- .../Impl/Portable/PortableWriterImpl.cs | 1305 ------- .../Impl/Portable/PortablesImpl.cs | 205 - .../Impl/Portable/SerializableObjectHolder.cs | 66 - .../Impl/Portable/TypeResolver.cs | 227 -- .../Impl/Resource/IResourceInjector.cs | 27 - .../Impl/Resource/ResourceFieldInjector.cs | 47 - .../Impl/Resource/ResourceMethodInjector.cs | 48 - .../Impl/Resource/ResourceProcessor.cs | 105 - .../Impl/Resource/ResourcePropertyInjector.cs | 47 - .../Impl/Resource/ResourceTypeDescriptor.cs | 291 -- .../Impl/Services/ServiceContext.cs | 60 - .../Impl/Services/ServiceDescriptor.cs | 106 - .../Impl/Services/ServiceProxy.cs | 71 - .../Impl/Services/ServiceProxyInvoker.cs | 136 - .../Impl/Services/ServiceProxySerializer.cs | 140 - .../Impl/Services/Services.cs | 316 -- .../Impl/Services/ServicesAsync.cs | 89 - .../Impl/Transactions/AsyncTransaction.cs | 78 - .../Impl/Transactions/Transaction.cs | 155 - .../Impl/Transactions/TransactionImpl.cs | 489 --- .../Impl/Transactions/TransactionMetricsImpl.cs | 62 - .../Impl/Transactions/TransactionsImpl.cs | 201 - .../Impl/Unmanaged/IUnmanagedTarget.cs | 42 - .../Impl/Unmanaged/UnmanagedCallbackHandlers.cs | 99 - .../Impl/Unmanaged/UnmanagedCallbacks.cs | 1154 ------ .../Impl/Unmanaged/UnmanagedContext.cs | 53 - .../Unmanaged/UnmanagedNonReleaseableTarget.cs | 68 - .../Impl/Unmanaged/UnmanagedTarget.cs | 77 - .../Impl/Unmanaged/UnmanagedUtils.cs | 1263 ------ .../Lifecycle/ILifecycleBean.cs | 64 - .../Lifecycle/LifecycleEventType.cs | 49 - .../Messaging/IMessageFilter.cs | 35 - .../Apache.Ignite.Core/Messaging/IMessaging.cs | 105 - .../Portable/IPortableBuilder.cs | 78 - .../Portable/IPortableIdMapper.cs | 40 - .../Portable/IPortableMarshalAware.cs | 39 - .../Portable/IPortableMetadata.cs | 61 - .../Portable/IPortableNameMapper.cs | 39 - .../Portable/IPortableObject.cs | 44 - .../Portable/IPortableRawReader.cs | 264 -- .../Portable/IPortableRawWriter.cs | 221 -- .../Portable/IPortableReader.cs | 340 -- .../Portable/IPortableSerializer.cs | 39 - .../Portable/IPortableWriter.cs | 259 -- .../Apache.Ignite.Core/Portable/IPortables.cs | 120 - .../Portable/PortableConfiguration.cs | 122 - .../Portable/PortableException.cs | 64 - .../Portable/PortableTypeConfiguration.cs | 162 - .../Portable/PortableTypeNames.cs | 115 - .../Properties/AssemblyInfo.cs | 46 - .../Resource/InstanceResourceAttribute.cs | 35 - .../Resource/StoreSessionResourceAttribute.cs | 32 - .../Apache.Ignite.Core/Services/IService.cs | 51 - .../Services/IServiceContext.cs | 69 - .../Services/IServiceDescriptor.cs | 96 - .../Apache.Ignite.Core/Services/IServices.cs | 181 - .../Services/ServiceConfiguration.cs | 62 - .../Services/ServiceInvocationException.cs | 101 - .../Transactions/ITransaction.cs | 230 -- .../Transactions/ITransactionMetrics.cs | 47 - .../Transactions/ITransactions.cs | 73 - .../Transactions/TransactionConcurrency.cs | 36 - .../TransactionHeuristicException.cs | 72 - .../Transactions/TransactionIsolation.cs | 41 - .../TransactionOptimisticException.cs | 69 - .../TransactionRollbackException.cs | 68 - .../Transactions/TransactionState.cs | 70 - .../Transactions/TransactionTimeoutException.cs | 69 - .../platform/src/main/dotnet/Apache.Ignite.sln | 68 - .../main/dotnet/Apache.Ignite.sln.DotSettings | 4 - .../dotnet/Apache.Ignite/Apache.Ignite.csproj | 76 - .../src/main/dotnet/Apache.Ignite/App.config | 56 - .../Config/AppSettingsConfigurator.cs | 113 - .../Apache.Ignite/Config/ArgsConfigurator.cs | 164 - .../Apache.Ignite/Config/ConfigValueParser.cs | 42 - .../Apache.Ignite/Config/IConfigurator.cs | 34 - .../main/dotnet/Apache.Ignite/IgniteRunner.cs | 171 - .../Apache.Ignite/Properties/AssemblyInfo.cs | 35 - .../Apache.Ignite/Service/IgniteService.cs | 219 -- .../Apache.Ignite/Service/NativeMethods.cs | 57 - .../Apache.Ignite/Service/ServiceDescription.cs | 32 - ...processors.platform.PlatformBootstrapFactory | 2 - .../platform/PlatformAbstractBootstrap.java | 48 - .../PlatformAbstractConfigurationClosure.java | 61 - .../platform/PlatformAbstractPredicate.java | 67 - .../platform/PlatformAbstractTarget.java | 320 -- .../processors/platform/PlatformBootstrap.java | 35 - .../platform/PlatformBootstrapFactory.java | 37 - .../platform/PlatformConfigurationEx.java | 48 - .../platform/PlatformContextImpl.java | 621 --- .../processors/platform/PlatformIgnition.java | 189 - .../platform/PlatformProcessorImpl.java | 359 -- .../platform/cache/PlatformCache.java | 1090 ------ .../cache/PlatformCacheEntryFilterImpl.java | 106 - .../cache/PlatformCacheEntryProcessorImpl.java | 220 -- .../platform/cache/PlatformCacheIterator.java | 72 - .../PlatformCachePartialUpdateException.java | 59 - .../cache/affinity/PlatformAffinity.java | 296 -- .../query/PlatformAbstractQueryCursor.java | 192 - .../query/PlatformContinuousQueryImpl.java | 235 -- .../PlatformContinuousQueryRemoteFilter.java | 188 - .../cache/query/PlatformFieldsQueryCursor.java | 49 - .../cache/query/PlatformQueryCursor.java | 45 - .../cache/store/PlatformCacheStoreCallback.java | 61 - .../platform/cluster/PlatformClusterGroup.java | 335 -- .../cluster/PlatformClusterNodeFilterImpl.java | 78 - .../platform/compute/PlatformAbstractJob.java | 156 - .../platform/compute/PlatformAbstractTask.java | 206 - .../PlatformBalancingMultiClosureTask.java | 83 - ...tformBalancingSingleClosureAffinityTask.java | 88 - .../PlatformBalancingSingleClosureTask.java | 81 - .../PlatformBroadcastingMultiClosureTask.java | 87 - .../PlatformBroadcastingSingleClosureTask.java | 84 - .../platform/compute/PlatformClosureJob.java | 104 - .../platform/compute/PlatformCompute.java | 332 -- .../platform/compute/PlatformFullJob.java | 220 -- .../platform/compute/PlatformFullTask.java | 192 - .../platform/cpp/PlatformCppBootstrap.java | 31 - .../cpp/PlatformCppBootstrapFactory.java | 39 - .../cpp/PlatformCppConfigurationClosure.java | 99 - .../cpp/PlatformCppConfigurationEx.java | 82 - .../datastreamer/PlatformDataStreamer.java | 226 -- .../PlatformStreamReceiverImpl.java | 119 - .../dotnet/PlatformDotNetBootstrap.java | 31 - .../dotnet/PlatformDotNetBootstrapFactory.java | 39 - .../dotnet/PlatformDotNetCacheStore.java | 497 --- .../PlatformDotNetConfigurationClosure.java | 254 -- .../dotnet/PlatformDotNetConfigurationEx.java | 90 - .../platform/dotnet/PlatformDotNetService.java | 27 - .../dotnet/PlatformDotNetServiceImpl.java | 47 - .../events/PlatformEventFilterListenerImpl.java | 163 - .../platform/events/PlatformEvents.java | 396 -- .../lifecycle/PlatformLifecycleBean.java | 75 - .../platform/memory/PlatformAbstractMemory.java | 121 - .../PlatformBigEndianInputStreamImpl.java | 126 - .../PlatformBigEndianOutputStreamImpl.java | 161 - .../platform/memory/PlatformExternalMemory.java | 55 - .../memory/PlatformInputStreamImpl.java | 331 -- .../memory/PlatformMemoryManagerImpl.java | 85 - .../platform/memory/PlatformMemoryPool.java | 140 - .../platform/memory/PlatformMemoryUtils.java | 467 --- .../memory/PlatformOutputStreamImpl.java | 267 -- .../platform/memory/PlatformPooledMemory.java | 64 - .../platform/memory/PlatformUnpooledMemory.java | 51 - .../messaging/PlatformMessageFilterImpl.java | 110 - .../messaging/PlatformMessageLocalFilter.java | 102 - .../platform/messaging/PlatformMessaging.java | 166 - .../services/PlatformAbstractService.java | 230 -- .../platform/services/PlatformServices.java | 275 -- .../transactions/PlatformTransactions.java | 259 -- .../platform/utils/PlatformFutureUtils.java | 397 -- .../platform/utils/PlatformReaderBiClosure.java | 34 - .../platform/utils/PlatformReaderClosure.java | 34 - .../platform/utils/PlatformUtils.java | 768 ---- .../platform/utils/PlatformWriterBiClosure.java | 34 - .../platform/utils/PlatformWriterClosure.java | 33 - .../platform/cpp/PlatformCppConfiguration.java | 47 - .../ignite/platform/cpp/package-info.java | 22 - .../dotnet/PlatformDotNetCacheStoreFactory.java | 139 - .../dotnet/PlatformDotNetLifecycleBean.java | 109 - .../ignite/platform/dotnet/package-info.java | 22 - .../apache/ignite/platform/package-info.java | 22 - .../Apache.Ignite.Core.Tests.TestDll.csproj | 52 - .../Properties/AssemblyInfo.cs | 49 - .../TestClass.cs | 35 - .../Apache.Ignite.Core.Tests.csproj | 225 -- .../Cache/CacheAbstractTest.cs | 3252 ---------------- .../Cache/CacheAffinityTest.cs | 139 - .../Cache/CacheDynamicStartTest.cs | 281 -- .../Cache/CacheEntryTest.cs | 69 - .../Cache/CacheForkedTest.cs | 81 - .../Cache/CacheLocalAtomicTest.cs | 57 - .../Cache/CacheLocalTest.cs | 56 - .../CachePartitionedAtomicNearEnabledTest.cs | 50 - .../Cache/CachePartitionedAtomicTest.cs | 50 - .../Cache/CachePartitionedNearEnabledTest.cs | 50 - .../Cache/CachePartitionedTest.cs | 50 - .../Cache/CacheReplicatedAtomicTest.cs | 60 - .../Cache/CacheReplicatedTest.cs | 60 - .../Cache/CacheTestAsyncWrapper.cs | 436 --- .../Cache/Query/CacheQueriesTest.cs | 928 ----- .../Continuous/ContinuousQueryAbstractTest.cs | 1181 ------ .../ContinuousQueryAtomicBackupTest.cs | 33 - .../ContinuousQueryAtomicNoBackupTest.cs | 34 - .../ContinuousQueryNoBackupAbstractTest.cs | 72 - .../ContinuousQueryTransactionalBackupTest.cs | 34 - .../ContinuousQueryTransactionalNoBackupTest.cs | 33 - .../Cache/Store/CacheParallelLoadStoreTest.cs | 110 - .../Cache/Store/CacheStoreSessionTest.cs | 285 -- .../Cache/Store/CacheStoreTest.cs | 510 --- .../Cache/Store/CacheTestParallelLoadStore.cs | 91 - .../Cache/Store/CacheTestStore.cs | 155 - .../Compute/AbstractTaskTest.cs | 217 -- .../Compute/ClosureTaskTest.cs | 390 -- .../Compute/ComputeApiTest.cs | 1281 ------ .../Compute/ComputeMultithreadedTest.cs | 269 -- .../Compute/FailoverTaskSelfTest.cs | 246 -- .../Forked/ForkedPortableClosureTaskTest.cs | 30 - .../Compute/Forked/ForkedResourceTaskTest.cs | 33 - .../Forked/ForkedSerializableClosureTaskTest.cs | 33 - .../Compute/Forked/ForkedTaskAdapterTest.cs | 30 - .../Compute/IgniteExceptionTaskSelfTest.cs | 753 ---- .../Compute/PortableClosureTaskTest.cs | 217 -- .../Compute/PortableTaskTest.cs | 253 -- .../Compute/ResourceTaskTest.cs | 568 --- .../Compute/SerializableClosureTaskTest.cs | 217 -- .../Compute/TaskAdapterTest.cs | 274 -- .../Compute/TaskResultTest.cs | 437 --- .../Config/Apache.Ignite.exe.config.test | 41 - .../Config/Cache/Store/cache-store-session.xml | 80 - .../Config/Compute/compute-grid1.xml | 90 - .../Config/Compute/compute-grid2.xml | 63 - .../Config/Compute/compute-grid3.xml | 52 - .../Config/Compute/compute-standalone.xml | 87 - .../Config/Dynamic/dynamic-client.xml | 51 - .../Config/Dynamic/dynamic-data-no-cfg.xml | 47 - .../Config/Dynamic/dynamic-data.xml | 65 - .../Config/Lifecycle/lifecycle-beans.xml | 66 - .../Config/Lifecycle/lifecycle-no-beans.xml | 44 - .../Config/cache-portables.xml | 78 - .../Config/cache-query-continuous.xml | 171 - .../Config/cache-query.xml | 100 - .../Config/marshaller-default.xml | 43 - .../Config/marshaller-invalid.xml | 46 - .../Config/marshaller-portable.xml | 43 - .../native-client-test-cache-affinity.xml | 70 - .../native-client-test-cache-parallel-store.xml | 69 - .../Config/native-client-test-cache-store.xml | 125 - .../Config/native-client-test-cache.xml | 194 - .../Config/portable.xml | 56 - .../Config/start-test-grid1.xml | 54 - .../Config/start-test-grid2.xml | 45 - .../Config/start-test-grid3.xml | 43 - .../Dataload/DataStreamerTest.cs | 592 --- .../Apache.Ignite.Core.Tests/EventsTest.cs | 961 ----- .../Apache.Ignite.Core.Tests/ExceptionsTest.cs | 352 -- .../Apache.Ignite.Core.Tests/ExecutableTest.cs | 443 --- .../Apache.Ignite.Core.Tests/FutureTest.cs | 278 -- .../IgniteManagerTest.cs | 51 - .../IgniteStartStopTest.cs | 422 -- .../Apache.Ignite.Core.Tests/LifecycleTest.cs | 288 -- .../Apache.Ignite.Core.Tests/LoadDllTest.cs | 243 -- .../Apache.Ignite.Core.Tests/MarshallerTest.cs | 71 - .../Memory/InteropMemoryTest.cs | 213 - .../Apache.Ignite.Core.Tests/MessagingTest.cs | 646 --- .../Portable/PortableApiSelfTest.cs | 1787 --------- .../Portable/PortableSelfTest.cs | 2078 ---------- .../PortableConfigurationTest.cs | 173 - .../Process/IIgniteProcessOutputReader.cs | 35 - .../Process/IgniteProcess.cs | 283 -- .../Process/IgniteProcessConsoleOutputReader.cs | 40 - .../Properties/AssemblyInfo.cs | 35 - .../Query/ImplicitPortablePerson.cs | 46 - .../Query/NoDefPortablePerson.cs | 35 - .../Query/PortablePerson.cs | 69 - .../SerializationTest.cs | 240 -- .../Services/ServiceProxyTest.cs | 741 ---- .../Services/ServicesAsyncWrapper.cs | 174 - .../Services/ServicesTest.cs | 823 ---- .../Services/ServicesTestAsync.cs | 33 - .../Apache.Ignite.Core.Tests/TestRunner.cs | 71 - .../Apache.Ignite.Core.Tests/TestUtils.cs | 292 -- .../TypeResolverTest.cs | 107 - .../platform/PlatformComputeBroadcastTask.java | 73 - .../platform/PlatformComputeDecimalTask.java | 106 - .../platform/PlatformComputeEchoTask.java | 188 - .../ignite/platform/PlatformComputeEnum.java | 28 - .../platform/PlatformComputeJavaPortable.java | 39 - .../platform/PlatformComputePortable.java | 42 - .../PlatformComputePortableArgTask.java | 121 - .../platform/PlatformEventsWriteEventTask.java | 146 - .../ignite/platform/PlatformMaxMemoryTask.java | 57 - .../ignite/platform/PlatformMinMemoryTask.java | 57 - .../lifecycle/PlatformJavaLifecycleBean.java | 47 - .../lifecycle/PlatformJavaLifecycleTask.java | 65 - modules/platforms/cpp/README.txt | 101 + modules/platforms/cpp/common/Makefile.am | 45 + modules/platforms/cpp/common/configure.ac | 62 + .../platforms/cpp/common/ignite-common.pc.in | 9 + .../platforms/cpp/common/include/Makefile.am | 26 + .../common/include/ignite/common/concurrent.h | 237 ++ .../cpp/common/include/ignite/common/exports.h | 158 + .../cpp/common/include/ignite/common/java.h | 679 ++++ .../cpp/common/include/ignite/common/utils.h | 81 + .../cpp/common/os/linux/include/Makefile.am | 24 + .../os/linux/include/ignite/common/common.h | 81 + .../linux/include/ignite/common/concurrent_os.h | 394 ++ .../cpp/common/os/linux/src/common.cpp | 59 + .../cpp/common/os/linux/src/concurrent_os.cpp | 175 + .../os/win/include/ignite/common/common.h | 56 + .../win/include/ignite/common/concurrent_os.h | 406 ++ .../platforms/cpp/common/os/win/src/common.cpp | 65 + .../cpp/common/os/win/src/concurrent_os.cpp | 151 + modules/platforms/cpp/common/project/README.TXT | 1 + .../platforms/cpp/common/project/vs/README.TXT | 1 + .../cpp/common/project/vs/common.vcxproj | 203 + .../common/project/vs/common.vcxproj.filters | 57 + .../platforms/cpp/common/project/vs/module.def | 111 + .../platforms/cpp/common/project/vs/targetver.h | 25 + modules/platforms/cpp/common/src/concurrent.cpp | 94 + modules/platforms/cpp/common/src/exports.cpp | 461 +++ modules/platforms/cpp/common/src/java.cpp | 2416 ++++++++++++ modules/platforms/cpp/core-test/Makefile.am | 49 + .../cpp/core-test/config/cache-query.xml | 91 + .../cpp/core-test/config/cache-test.xml | 129 + modules/platforms/cpp/core-test/configure.ac | 62 + .../platforms/cpp/core-test/include/Makefile.am | 22 + .../core-test/include/ignite/binary_test_defs.h | 320 ++ .../include/ignite/binary_test_utils.h | 516 +++ .../cpp/core-test/include/teamcity_messages.h | 55 + .../platforms/cpp/core-test/project/README.TXT | 1 + .../cpp/core-test/project/vs/README.TXT | 1 + .../cpp/core-test/project/vs/core-test.vcxproj | 174 + .../project/vs/core-test.vcxproj.filters | 68 + .../src/binary_reader_writer_raw_test.cpp | 1593 ++++++++ .../core-test/src/binary_reader_writer_test.cpp | 2373 +++++++++++ .../cpp/core-test/src/binary_session_test.cpp | 257 ++ .../cpp/core-test/src/binary_test_defs.cpp | 65 + .../cpp/core-test/src/cache_query_test.cpp | 841 ++++ .../platforms/cpp/core-test/src/cache_test.cpp | 479 +++ .../cpp/core-test/src/concurrent_test.cpp | 186 + .../cpp/core-test/src/handle_registry_test.cpp | 176 + .../cpp/core-test/src/ignition_test.cpp | 95 + .../cpp/core-test/src/teamcity_boost.cpp | 159 + .../cpp/core-test/src/teamcity_messages.cpp | 150 + modules/platforms/cpp/core/Makefile.am | 67 + modules/platforms/cpp/core/configure.ac | 62 + modules/platforms/cpp/core/ignite.pc.in | 9 + modules/platforms/cpp/core/include/Makefile.am | 69 + .../cpp/core/include/ignite/binary/binary.h | 29 + .../core/include/ignite/binary/binary_consts.h | 106 + .../include/ignite/binary/binary_containers.h | 525 +++ .../include/ignite/binary/binary_raw_reader.h | 350 ++ .../include/ignite/binary/binary_raw_writer.h | 326 ++ .../core/include/ignite/binary/binary_reader.h | 384 ++ .../core/include/ignite/binary/binary_type.h | 293 ++ .../core/include/ignite/binary/binary_writer.h | 362 ++ .../cpp/core/include/ignite/cache/cache.h | 1196 ++++++ .../cpp/core/include/ignite/cache/cache_entry.h | 118 + .../core/include/ignite/cache/cache_peek_mode.h | 71 + .../cpp/core/include/ignite/cache/query/query.h | 28 + .../include/ignite/cache/query/query_argument.h | 125 + .../include/ignite/cache/query/query_cursor.h | 200 + .../ignite/cache/query/query_fields_cursor.h | 153 + .../ignite/cache/query/query_fields_row.h | 154 + .../include/ignite/cache/query/query_scan.h | 151 + .../core/include/ignite/cache/query/query_sql.h | 243 ++ .../ignite/cache/query/query_sql_fields.h | 210 + .../include/ignite/cache/query/query_text.h | 160 + .../platforms/cpp/core/include/ignite/guid.h | 112 + .../platforms/cpp/core/include/ignite/ignite.h | 166 + .../core/include/ignite/ignite_configuration.h | 66 + .../cpp/core/include/ignite/ignite_error.h | 260 ++ .../cpp/core/include/ignite/ignition.h | 195 + .../include/ignite/impl/binary/binary_common.h | 188 + .../ignite/impl/binary/binary_id_resolver.h | 106 + .../ignite/impl/binary/binary_reader_impl.h | 1309 +++++++ .../include/ignite/impl/binary/binary_schema.h | 136 + .../ignite/impl/binary/binary_type_handler.h | 102 + .../ignite/impl/binary/binary_type_manager.h | 120 + .../ignite/impl/binary/binary_type_snapshot.h | 122 + .../ignite/impl/binary/binary_type_updater.h | 53 + .../impl/binary/binary_type_updater_impl.h | 65 + .../include/ignite/impl/binary/binary_utils.h | 344 ++ .../ignite/impl/binary/binary_writer_impl.h | 913 +++++ .../core/include/ignite/impl/cache/cache_impl.h | 428 ++ .../impl/cache/query/query_fields_row_impl.h | 174 + .../ignite/impl/cache/query/query_impl.h | 125 + .../core/include/ignite/impl/handle_registry.h | 202 + .../include/ignite/impl/ignite_environment.h | 130 + .../cpp/core/include/ignite/impl/ignite_impl.h | 165 + .../core/include/ignite/impl/interop/interop.h | 25 + .../ignite/impl/interop/interop_input_stream.h | 250 ++ .../ignite/impl/interop/interop_memory.h | 280 ++ .../ignite/impl/interop/interop_output_stream.h | 250 ++ .../interop/interop_stream_position_guard.h | 79 + .../cpp/core/include/ignite/impl/operations.h | 452 +++ .../cpp/core/os/linux/include/Makefile.am | 23 + .../core/os/linux/include/ignite/impl/utils.h | 155 + .../cpp/core/os/linux/src/impl/utils.cpp | 439 +++ .../cpp/core/os/win/include/ignite/impl/utils.h | 155 + .../cpp/core/os/win/src/impl/utils.cpp | 453 +++ modules/platforms/cpp/core/project/README.TXT | 1 + .../platforms/cpp/core/project/vs/README.TXT | 1 + .../platforms/cpp/core/project/vs/core.vcxproj | 279 ++ .../cpp/core/project/vs/core.vcxproj.filters | 267 ++ .../cpp/core/src/binary/binary_containers.cpp | 76 + .../cpp/core/src/binary/binary_raw_reader.cpp | 145 + .../cpp/core/src/binary/binary_raw_writer.cpp | 147 + .../cpp/core/src/binary/binary_reader.cpp | 152 + .../cpp/core/src/binary/binary_type.cpp | 51 + .../cpp/core/src/binary/binary_writer.cpp | 154 + modules/platforms/cpp/core/src/guid.cpp | 65 + modules/platforms/cpp/core/src/ignite.cpp | 43 + modules/platforms/cpp/core/src/ignite_error.cpp | 222 ++ modules/platforms/cpp/core/src/ignition.cpp | 470 +++ .../core/src/impl/binary/binary_reader_impl.cpp | 760 ++++ .../cpp/core/src/impl/binary/binary_schema.cpp | 135 + .../src/impl/binary/binary_type_handler.cpp | 78 + .../src/impl/binary/binary_type_manager.cpp | 201 + .../src/impl/binary/binary_type_snapshot.cpp | 70 + .../src/impl/binary/binary_type_updater.cpp | 32 + .../impl/binary/binary_type_updater_impl.cpp | 94 + .../cpp/core/src/impl/binary/binary_utils.cpp | 211 + .../core/src/impl/binary/binary_writer_impl.cpp | 623 +++ .../cpp/core/src/impl/cache/cache_impl.cpp | 393 ++ .../core/src/impl/cache/query/query_impl.cpp | 228 ++ .../cpp/core/src/impl/handle_registry.cpp | 234 ++ .../cpp/core/src/impl/ignite_environment.cpp | 167 + .../platforms/cpp/core/src/impl/ignite_impl.cpp | 47 + .../src/impl/interop/interop_input_stream.cpp | 235 ++ .../core/src/impl/interop/interop_memory.cpp | 182 + .../src/impl/interop/interop_output_stream.cpp | 233 ++ modules/platforms/cpp/examples/Makefile.am | 39 + modules/platforms/cpp/examples/README.txt | 42 + .../cpp/examples/config/example-cache.xml | 77 + modules/platforms/cpp/examples/configure.ac | 38 + .../platforms/cpp/examples/include/Makefile.am | 21 + .../examples/include/ignite/examples/address.h | 109 + .../include/ignite/examples/organization.h | 111 + .../cpp/examples/project/vs/ignite-examples.sln | 19 + .../examples/project/vs/ignite-examples.vcxproj | 107 + .../project/vs/ignite-examples.vcxproj.filters | 30 + .../cpp/examples/src/putgetexample.cpp | 126 + modules/platforms/cpp/ignite/Makefile.am | 39 + modules/platforms/cpp/ignite/configure.ac | 62 + modules/platforms/cpp/ignite/project/README.TXT | 1 + .../platforms/cpp/ignite/project/vs/README.TXT | 1 + .../cpp/ignite/project/vs/ignite.vcxproj | 167 + .../ignite/project/vs/ignite.vcxproj.filters | 25 + modules/platforms/cpp/ignite/src/ignite.cpp | 225 ++ modules/platforms/cpp/project/vs/ignite.sln | 58 + modules/platforms/cpp/project/vs/ignite.slnrel | 33 + .../platforms/cpp/project/vs/ignite_x86.slnrel | 33 + .../Apache.Ignite.Benchmarks.csproj | 92 + .../Apache.Ignite.Benchmarks.snk | Bin 0 -> 596 bytes .../dotnet/Apache.Ignite.Benchmarks/App.config | 24 + .../Apache.Ignite.Benchmarks/BenchmarkBase.cs | 931 +++++ .../BenchmarkOperationDescriptor.cs | 68 + .../Apache.Ignite.Benchmarks/BenchmarkRunner.cs | 94 + .../Apache.Ignite.Benchmarks/BenchmarkState.cs | 106 + .../Apache.Ignite.Benchmarks/BenchmarkUtils.cs | 236 ++ .../Binary/BinarizableReadBenchmark.cs | 125 + .../Binary/BinarizableWriteBenchmark.cs | 135 + .../Config/benchmark.xml | 57 + .../Interop/ClosureBenchmark.cs | 66 + .../Interop/GetAsyncBenchmark.cs | 62 + .../Interop/GetBenchmark.cs | 62 + .../Interop/PlatformBenchmarkBase.cs | 121 + .../Interop/PutAsyncBenchmark.cs | 58 + .../Interop/PutBenchmark.cs | 58 + .../Interop/TaskBenchmark.cs | 100 + .../Interop/TxBenchmark.cs | 65 + .../Apache.Ignite.Benchmarks/Model/Address.cs | 80 + .../Apache.Ignite.Benchmarks/Model/Company.cs | 89 + .../Model/Department.cs | 40 + .../Apache.Ignite.Benchmarks/Model/Employee.cs | 136 + .../Apache.Ignite.Benchmarks/Model/Sex.cs | 31 + .../Apache.Ignite.Benchmarks/Model/TestModel.cs | 111 + .../Properties/AssemblyInfo.cs | 35 + .../Result/BenchmarkConsoleResultWriter.cs | 68 + .../Result/BenchmarkFileResultWriter.cs | 323 ++ .../Result/IBenchmarkResultWriter.cs | 55 + .../Apache.Ignite.Core.Tests.TestDll.csproj | 61 + .../Apache.Ignite.Core.Tests.TestDll.snk | Bin 0 -> 596 bytes .../Properties/AssemblyInfo.cs | 49 + .../TestClass.cs | 35 + .../Apache.Ignite.Core.Tests.csproj | 259 ++ .../Apache.Ignite.Core.Tests.nunit | 7 + .../Apache.Ignite.Core.Tests.snk | Bin 0 -> 596 bytes .../Binary/BinaryBuilderSelfTest.cs | 1721 ++++++++ .../Binary/BinarySelfTest.cs | 2157 ++++++++++ .../Binary/BinaryStructureTest.cs | 250 ++ .../BinaryConfigurationTest.cs | 173 + .../Cache/CacheAbstractTest.cs | 3265 ++++++++++++++++ .../Cache/CacheAffinityTest.cs | 139 + .../Cache/CacheDynamicStartTest.cs | 282 ++ .../Cache/CacheEntryTest.cs | 69 + .../Cache/CacheForkedTest.cs | 81 + .../Cache/CacheLocalAtomicTest.cs | 57 + .../Cache/CacheLocalTest.cs | 56 + .../CachePartitionedAtomicNearEnabledTest.cs | 50 + .../Cache/CachePartitionedAtomicTest.cs | 50 + .../Cache/CachePartitionedNearEnabledTest.cs | 50 + .../Cache/CachePartitionedTest.cs | 50 + .../Cache/CacheReplicatedAtomicTest.cs | 60 + .../Cache/CacheReplicatedTest.cs | 60 + .../Cache/CacheTestAsyncWrapper.cs | 575 +++ .../Cache/Query/CacheQueriesTest.cs | 935 +++++ .../Continuous/ContinuousQueryAbstractTest.cs | 1238 ++++++ .../ContinuousQueryAtomicBackupTest.cs | 33 + .../ContinuousQueryAtomicNoBackupTest.cs | 34 + .../ContinuousQueryNoBackupAbstractTest.cs | 72 + .../ContinuousQueryTransactionalBackupTest.cs | 34 + .../ContinuousQueryTransactionalNoBackupTest.cs | 33 + .../Cache/Store/CacheParallelLoadStoreTest.cs | 110 + .../Cache/Store/CacheStoreSessionTest.cs | 285 ++ .../Cache/Store/CacheStoreTest.cs | 536 +++ .../Cache/Store/CacheTestParallelLoadStore.cs | 91 + .../Cache/Store/CacheTestStore.cs | 155 + .../Compute/AbstractTaskTest.cs | 217 ++ .../Compute/BinarizableClosureTaskTest.cs | 185 + .../Compute/BinarizableTaskTest.cs | 269 ++ .../Compute/ClosureTaskTest.cs | 390 ++ .../Compute/ComputeApiTest.cs | 1303 +++++++ .../Compute/ComputeMultithreadedTest.cs | 269 ++ .../Compute/FailoverTaskSelfTest.cs | 246 ++ .../Forked/ForkedBinarizableClosureTaskTest.cs | 30 + .../Compute/Forked/ForkedResourceTaskTest.cs | 30 + .../Forked/ForkedSerializableClosureTaskTest.cs | 30 + .../Compute/Forked/ForkedTaskAdapterTest.cs | 30 + .../Compute/IgniteExceptionTaskSelfTest.cs | 754 ++++ .../Compute/ResourceTaskTest.cs | 568 +++ .../Compute/SerializableClosureTaskTest.cs | 217 ++ .../Compute/TaskAdapterTest.cs | 274 ++ .../Compute/TaskResultTest.cs | 437 +++ .../Config/Apache.Ignite.exe.config.test | 41 + .../Config/Cache/Store/cache-store-session.xml | 79 + .../Config/Compute/compute-grid1.xml | 95 + .../Config/Compute/compute-grid2.xml | 63 + .../Config/Compute/compute-grid3.xml | 52 + .../Config/Compute/compute-standalone.xml | 87 + .../Config/Dynamic/dynamic-client.xml | 51 + .../Config/Dynamic/dynamic-data-no-cfg.xml | 47 + .../Config/Dynamic/dynamic-data.xml | 65 + .../Config/Lifecycle/lifecycle-beans.xml | 66 + .../Config/Lifecycle/lifecycle-no-beans.xml | 44 + .../Apache.Ignite.Core.Tests/Config/binary.xml | 56 + .../Config/cache-binarizables.xml | 78 + .../Config/cache-query-continuous.xml | 171 + .../Config/cache-query.xml | 100 + .../Config/marshaller-default.xml | 43 + .../Config/marshaller-explicit.xml | 53 + .../Config/marshaller-invalid.xml | 46 + .../native-client-test-cache-affinity.xml | 70 + .../native-client-test-cache-parallel-store.xml | 68 + .../Config/native-client-test-cache-store.xml | 121 + .../Config/native-client-test-cache.xml | 143 + .../Config/start-test-grid1.xml | 54 + .../Config/start-test-grid2.xml | 45 + .../Config/start-test-grid3.xml | 43 + .../DataStructures/AtomicLongTest.cs | 138 + .../Dataload/DataStreamerTest.cs | 592 +++ .../Apache.Ignite.Core.Tests/EventsTest.cs | 956 +++++ .../Examples/Example.cs | 126 + .../Examples/ExamplesTest.cs | 156 + .../Examples/PathUtil.cs | 50 + .../Examples/ProjectFilesTest.cs | 49 + .../Apache.Ignite.Core.Tests/ExceptionsTest.cs | 365 ++ .../Apache.Ignite.Core.Tests/ExecutableTest.cs | 443 +++ .../Apache.Ignite.Core.Tests/FutureTest.cs | 188 + .../IgniteManagerTest.cs | 51 + .../IgniteStartStopTest.cs | 426 ++ .../Apache.Ignite.Core.Tests/IgniteTestBase.cs | 200 + .../Apache.Ignite.Core.Tests/LifecycleTest.cs | 289 ++ .../Apache.Ignite.Core.Tests/LoadDllTest.cs | 243 ++ .../Apache.Ignite.Core.Tests/MarshallerTest.cs | 71 + .../Memory/InteropMemoryTest.cs | 200 + .../Apache.Ignite.Core.Tests/MessagingTest.cs | 644 +++ .../Process/IIgniteProcessOutputReader.cs | 35 + .../Process/IgniteProcess.cs | 283 ++ .../Process/IgniteProcessConsoleOutputReader.cs | 40 + .../Properties/AssemblyInfo.cs | 35 + .../Query/BinarizablePerson.cs | 69 + .../Query/ImplicitBinarizablePerson.cs | 46 + .../Query/NoDefBinarizablePerson.cs | 35 + .../SerializationTest.cs | 240 ++ .../Services/ServiceProxyTest.cs | 741 ++++ .../Services/ServicesAsyncWrapper.cs | 182 + .../Services/ServicesTest.cs | 823 ++++ .../Services/ServicesTestAsync.cs | 33 + .../Apache.Ignite.Core.Tests/TestRunner.cs | 71 + .../Apache.Ignite.Core.Tests/TestUtils.cs | 306 ++ .../TypeResolverTest.cs | 107 + .../Apache.Ignite.Core.csproj | 381 ++ .../Apache.Ignite.Core/Apache.Ignite.Core.snk | Bin 0 -> 596 bytes .../Binary/BinaryConfiguration.cs | 90 + .../Binary/BinaryObjectException.cs | 64 + .../Binary/BinaryTypeConfiguration.cs | 116 + .../Binary/BinaryTypeNames.cs | 121 + .../Apache.Ignite.Core/Binary/IBinarizable.cs | 39 + .../Binary/IBinaryIdMapper.cs | 40 + .../Binary/IBinaryNameMapper.cs | 39 + .../Apache.Ignite.Core/Binary/IBinaryObject.cs | 60 + .../Binary/IBinaryObjectBuilder.cs | 310 ++ .../Binary/IBinaryRawReader.cs | 223 ++ .../Binary/IBinaryRawWriter.cs | 220 ++ .../Apache.Ignite.Core/Binary/IBinaryReader.cs | 279 ++ .../Binary/IBinarySerializer.cs | 39 + .../Apache.Ignite.Core/Binary/IBinaryType.cs | 52 + .../Apache.Ignite.Core/Binary/IBinaryWriter.cs | 256 ++ .../Apache.Ignite.Core/Binary/IIgniteBinary.cs | 120 + .../Cache/CacheAtomicUpdateTimeoutException.cs | 67 + .../Cache/CacheEntryProcessorException.cs | 79 + .../Apache.Ignite.Core/Cache/CacheException.cs | 68 + .../Cache/CachePartialUpdateException.cs | 119 + .../Apache.Ignite.Core/Cache/CachePeekMode.cs | 68 + .../Apache.Ignite.Core/Cache/CacheResult.cs | 98 + .../Cache/Event/CacheEntryEventType.cs | 41 + .../Cache/Event/ICacheEntryEvent.cs | 45 + .../Cache/Event/ICacheEntryEventFilter.cs | 31 + .../Cache/Event/ICacheEntryEventListener.cs | 33 + .../Cache/Expiry/ExpiryPolicy.cs | 89 + .../Cache/Expiry/IExpiryPolicy.cs | 63 + .../dotnet/Apache.Ignite.Core/Cache/ICache.cs | 844 ++++ .../Apache.Ignite.Core/Cache/ICacheAffinity.cs | 158 + .../Apache.Ignite.Core/Cache/ICacheEntry.cs | 37 + .../Cache/ICacheEntryFilter.cs | 34 + .../Cache/ICacheEntryProcessor.cs | 45 + .../Cache/ICacheEntryProcessorResult.cs | 40 + .../Apache.Ignite.Core/Cache/ICacheLock.cs | 58 + .../Apache.Ignite.Core/Cache/ICacheMetrics.cs | 486 +++ .../Cache/IMutableCacheEntry.cs | 47 + .../Cache/Query/Continuous/ContinuousQuery.cs | 170 + .../Query/Continuous/IContinuousQueryHandle.cs | 47 + .../Cache/Query/IQueryCursor.cs | 44 + .../Apache.Ignite.Core/Cache/Query/QueryBase.cs | 82 + .../Apache.Ignite.Core/Cache/Query/ScanQuery.cs | 76 + .../Cache/Query/SqlFieldsQuery.cs | 81 + .../Apache.Ignite.Core/Cache/Query/SqlQuery.cs | 120 + .../Apache.Ignite.Core/Cache/Query/TextQuery.cs | 104 + .../Store/CacheParallelLoadStoreAdapter.cs | 207 + .../Cache/Store/CacheStoreAdapter.cs | 146 + .../Cache/Store/CacheStoreException.cs | 66 + .../Cache/Store/ICacheStore.cs | 184 + .../Cache/Store/ICacheStoreSession.cs | 42 + .../Cluster/ClusterGroupEmptyException.cs | 70 + .../Cluster/ClusterTopologyException.cs | 69 + .../Apache.Ignite.Core/Cluster/ICluster.cs | 79 + .../Apache.Ignite.Core/Cluster/IClusterGroup.cs | 235 ++ .../Cluster/IClusterMetrics.cs | 347 ++ .../Apache.Ignite.Core/Cluster/IClusterNode.cs | 135 + .../Cluster/IClusterNodeFilter.cs | 32 + .../Common/IgniteException.cs | 66 + .../Apache.Ignite.Core/Common/IgniteGuid.cs | 132 + .../ComputeExecutionRejectedException.cs | 69 + .../Compute/ComputeJobAdapter.cs | 122 + .../Compute/ComputeJobFailoverException.cs | 72 + .../Compute/ComputeJobResultPolicy.cs | 45 + .../Compute/ComputeTaskAdapter.cs | 95 + .../Compute/ComputeTaskCancelledException.cs | 69 + .../ComputeTaskNoResultCacheAttribute.cs | 35 + .../Compute/ComputeTaskSplitAdapter.cs | 95 + .../Compute/ComputeTaskTimeoutException.cs | 67 + .../Compute/ComputeUserUndeclaredException.cs | 70 + .../Apache.Ignite.Core/Compute/ICompute.cs | 431 ++ .../Apache.Ignite.Core/Compute/IComputeFunc.cs | 55 + .../Apache.Ignite.Core/Compute/IComputeJob.cs | 59 + .../Compute/IComputeJobResult.cs | 66 + .../Compute/IComputeReducer.cs | 41 + .../Apache.Ignite.Core/Compute/IComputeTask.cs | 132 + .../DataStructures/IAtomicLong.cs | 84 + .../Datastream/IDataStreamer.cs | 206 + .../Datastream/IStreamReceiver.cs | 38 + .../Datastream/StreamTransformer.cs | 73 + .../Datastream/StreamVisitor.cs | 55 + .../Apache.Ignite.Core/Events/CacheEvent.cs | 178 + .../Events/CacheQueryExecutedEvent.cs | 99 + .../Events/CacheQueryReadEvent.cs | 136 + .../Events/CacheRebalancingEvent.cs | 100 + .../Events/CheckpointEvent.cs | 51 + .../Apache.Ignite.Core/Events/DiscoveryEvent.cs | 82 + .../Apache.Ignite.Core/Events/EventBase.cs | 167 + .../Apache.Ignite.Core/Events/EventReader.cs | 72 + .../Apache.Ignite.Core/Events/EventType.cs | 595 +++ .../dotnet/Apache.Ignite.Core/Events/IEvent.cs | 74 + .../Apache.Ignite.Core/Events/IEventFilter.cs | 33 + .../Apache.Ignite.Core/Events/IEventListener.cs | 34 + .../dotnet/Apache.Ignite.Core/Events/IEvents.cs | 259 ++ .../Apache.Ignite.Core/Events/JobEvent.cs | 102 + .../Apache.Ignite.Core/Events/SwapSpaceEvent.cs | 51 + .../Apache.Ignite.Core/Events/TaskEvent.cs | 93 + .../Apache.Ignite.Core/GlobalSuppressions.cs | Bin 0 -> 1908 bytes .../dotnet/Apache.Ignite.Core/IIgnite.cs | 168 + .../Apache.Ignite.Core/IgniteConfiguration.cs | 143 + .../dotnet/Apache.Ignite.Core/Ignition.cs | 627 +++ .../Impl/Binary/BinarizableSerializer.cs | 45 + .../Impl/Binary/BinaryBuilderField.cs | 89 + .../Impl/Binary/BinaryFullTypeDescriptor.cs | 210 + .../Impl/Binary/BinaryHandleDictionary.cs | 188 + .../Impl/Binary/BinaryMode.cs | 42 + .../Impl/Binary/BinaryObject.cs | 354 ++ .../Impl/Binary/BinaryObjectBuilder.cs | 1137 ++++++ .../Impl/Binary/BinaryObjectHandle.cs | 59 + .../Impl/Binary/BinaryObjectHeader.cs | 496 +++ .../Impl/Binary/BinaryObjectSchema.cs | 98 + .../Impl/Binary/BinaryObjectSchemaField.cs | 48 + .../Impl/Binary/BinaryObjectSchemaHolder.cs | 107 + .../Impl/Binary/BinaryReader.cs | 965 +++++ .../Impl/Binary/BinaryReaderExtensions.cs | 52 + .../Impl/Binary/BinaryReaderHandleDictionary.cs | 42 + .../Impl/Binary/BinaryReflectiveActions.cs | 440 +++ .../Impl/Binary/BinaryReflectiveSerializer.cs | 218 ++ .../Binary/BinarySurrogateTypeDescriptor.cs | 162 + .../Impl/Binary/BinarySystemHandlers.cs | 832 ++++ .../Impl/Binary/BinarySystemTypeSerializer.cs | 62 + .../Impl/Binary/BinaryUtils.cs | 1823 +++++++++ .../Impl/Binary/BinaryWriter.cs | 1428 +++++++ .../Impl/Binary/DateTimeHolder.cs | 68 + .../Impl/Binary/IBinarySystemTypeSerializer.cs | 34 + .../Impl/Binary/IBinaryTypeDescriptor.cs | 133 + .../Impl/Binary/IBinaryWriteAware.cs | 34 + .../Impl/Binary/IgniteBinary.cs | 192 + .../Impl/Binary/Io/BinaryHeapStream.cs | 452 +++ .../Impl/Binary/Io/BinaryStreamAdapter.cs | 114 + .../Impl/Binary/Io/BinaryStreamBase.cs | 1253 ++++++ .../Impl/Binary/Io/IBinaryStream.cs | 322 ++ .../Impl/Binary/Marshaller.cs | 537 +++ .../Impl/Binary/Metadata/BinaryType.cs | 200 + .../Binary/Metadata/BinaryTypeHashsetHandler.cs | 69 + .../Impl/Binary/Metadata/BinaryTypeHolder.cs | 147 + .../Impl/Binary/Metadata/IBinaryTypeHandler.cs | 41 + .../Impl/Binary/SerializableObjectHolder.cs | 73 + .../Impl/Binary/Structure/BinaryStructure.cs | 332 ++ .../Binary/Structure/BinaryStructureEntry.cs | 128 + .../Structure/BinaryStructureJumpTable.cs | 118 + .../Binary/Structure/BinaryStructureTracker.cs | 140 + .../Binary/Structure/BinaryStructureUpdate.cs | 84 + .../Impl/Binary/TypeResolver.cs | 231 ++ .../Impl/Cache/CacheAffinityImpl.cs | 275 ++ .../Apache.Ignite.Core/Impl/Cache/CacheEntry.cs | 127 + .../Impl/Cache/CacheEntryFilterHolder.cs | 132 + .../Impl/Cache/CacheEntryProcessorHolder.cs | 144 + .../Impl/Cache/CacheEntryProcessorResult.cs | 65 + .../Cache/CacheEntryProcessorResultHolder.cs | 128 + .../Impl/Cache/CacheEnumerable.cs | 82 + .../Impl/Cache/CacheEnumerator.cs | 117 + .../Impl/Cache/CacheEnumeratorProxy.cs | 159 + .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 1255 ++++++ .../Apache.Ignite.Core/Impl/Cache/CacheLock.cs | 171 + .../Impl/Cache/CacheMetricsImpl.cs | 248 ++ .../Apache.Ignite.Core/Impl/Cache/CacheOp.cs | 64 + .../Impl/Cache/Event/CacheEntryCreateEvent.cs | 80 + .../Impl/Cache/Event/CacheEntryRemoveEvent.cs | 80 + .../Impl/Cache/Event/CacheEntryUpdateEvent.cs | 85 + .../Impl/Cache/MutableCacheEntry.cs | 163 + .../Impl/Cache/Query/AbstractQueryCursor.cs | 264 ++ .../Query/Continuous/ContinuousQueryFilter.cs | 125 + .../Continuous/ContinuousQueryFilterHolder.cs | 86 + .../Continuous/ContinuousQueryHandleImpl.cs | 213 + .../Query/Continuous/ContinuousQueryUtils.cs | 96 + .../Impl/Cache/Query/FieldsQueryCursor.cs | 54 + .../Impl/Cache/Query/QueryCursor.cs | 50 + .../Impl/Cache/Store/CacheStore.cs | 263 ++ .../Impl/Cache/Store/CacheStoreSession.cs | 53 + .../Impl/Cache/Store/CacheStoreSessionProxy.cs | 63 + .../Impl/Cluster/ClusterGroupImpl.cs | 574 +++ .../Impl/Cluster/ClusterMetricsImpl.cs | 294 ++ .../Impl/Cluster/ClusterNodeImpl.cs | 222 ++ .../Impl/Cluster/IClusterGroupEx.cs | 35 + .../Impl/Collections/CollectionExtensions.cs | 45 + .../Impl/Collections/MultiValueDictionary.cs | 145 + .../Impl/Collections/ReadOnlyCollection.cs | 102 + .../Impl/Collections/ReadOnlyDictionary.cs | 149 + .../Apache.Ignite.Core/Impl/Common/Classpath.cs | 159 + .../Common/CopyOnWriteConcurrentDictionary.cs | 72 + .../Impl/Common/DelegateConverter.cs | 269 ++ .../Impl/Common/DelegateTypeDescriptor.cs | 340 ++ .../Apache.Ignite.Core/Impl/Common/Fnv1Hash.cs | 57 + .../Apache.Ignite.Core/Impl/Common/Future.cs | 128 + .../Impl/Common/FutureConverter.cs | 62 + .../Impl/Common/FutureType.cs | 55 + .../Impl/Common/IFutureConverter.cs | 35 + .../Impl/Common/IFutureInternal.cs | 46 + .../Impl/Common/IgniteArgumentCheck.cs | 77 + .../Impl/Common/IgniteHome.cs | 97 + .../Impl/Common/LoadedAssembliesResolver.cs | 96 + .../Impl/Common/ResizeableArray.cs | 64 + .../Impl/Common/TypeCaster.cs | 79 + .../Closure/ComputeAbstractClosureTask.cs | 101 + .../Impl/Compute/Closure/ComputeActionJob.cs | 82 + .../Impl/Compute/Closure/ComputeFuncJob.cs | 86 + .../Compute/Closure/ComputeMultiClosureTask.cs | 56 + .../Impl/Compute/Closure/ComputeOutFuncJob.cs | 75 + .../Closure/ComputeReducingClosureTask.cs | 61 + .../Compute/Closure/ComputeSingleClosureTask.cs | 48 + .../Compute/Closure/IComputeResourceInjector.cs | 31 + .../Apache.Ignite.Core/Impl/Compute/Compute.cs | 300 ++ .../Impl/Compute/ComputeFunc.cs | 118 + .../Impl/Compute/ComputeImpl.cs | 660 ++++ .../Impl/Compute/ComputeJob.cs | 162 + .../Impl/Compute/ComputeJobHolder.cs | 245 ++ .../Compute/ComputeJobResultGenericWrapper.cs | 73 + .../Impl/Compute/ComputeJobResultImpl.cs | 99 + .../Impl/Compute/ComputeOutFunc.cs | 122 + .../Impl/Compute/ComputeTaskHolder.cs | 505 +++ .../Impl/DataStructures/AtomicLong.cs | 102 + .../Impl/Datastream/DataStreamerBatch.cs | 270 ++ .../Impl/Datastream/DataStreamerEntry.cs | 64 + .../Impl/Datastream/DataStreamerImpl.cs | 840 ++++ .../Impl/Datastream/DataStreamerRemoveEntry.cs | 48 + .../Impl/Datastream/StreamReceiverHolder.cs | 144 + .../Apache.Ignite.Core/Impl/Events/Events.cs | 648 ++++ .../Impl/Events/RemoteListenEventFilter.cs | 84 + .../Apache.Ignite.Core/Impl/ExceptionUtils.cs | 206 + .../Apache.Ignite.Core/Impl/Handle/Handle.cs | 69 + .../Impl/Handle/HandleRegistry.cs | 343 ++ .../Apache.Ignite.Core/Impl/Handle/IHandle.cs | 35 + .../Apache.Ignite.Core/Impl/IInteropCallback.cs | 34 + .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 529 +++ .../Impl/IgniteConfigurationEx.cs | 57 + .../Apache.Ignite.Core/Impl/IgniteManager.cs | 286 ++ .../Apache.Ignite.Core/Impl/IgniteProxy.cs | 343 ++ .../Apache.Ignite.Core/Impl/IgniteUtils.cs | 418 ++ .../Impl/InteropExceptionHolder.cs | 85 + .../Impl/LifecycleBeanHolder.cs | 66 + .../Impl/Memory/IPlatformMemory.cs | 65 + .../Impl/Memory/InteropExternalMemory.cs | 46 + .../Impl/Memory/InteropMemoryUtils.cs | 38 + .../Memory/PlatformBigEndianMemoryStream.cs | 483 +++ .../Impl/Memory/PlatformMemory.cs | 78 + .../Impl/Memory/PlatformMemoryManager.cs | 107 + .../Impl/Memory/PlatformMemoryPool.cs | 106 + .../Impl/Memory/PlatformMemoryStream.cs | 727 ++++ .../Impl/Memory/PlatformMemoryUtils.cs | 465 +++ .../Impl/Memory/PlatformPooledMemory.cs | 66 + .../Impl/Memory/PlatformRawMemory.cs | 89 + .../Impl/Memory/PlatformUnpooledMemory.cs | 52 + .../Impl/Messaging/MessageListenerHolder.cs | 177 + .../Impl/Messaging/Messaging.cs | 289 ++ .../Apache.Ignite.Core/Impl/NativeMethods.cs | 47 + .../Apache.Ignite.Core/Impl/PlatformTarget.cs | 737 ++++ .../Impl/Resource/IResourceInjector.cs | 27 + .../Impl/Resource/ResourceFieldInjector.cs | 47 + .../Impl/Resource/ResourceMethodInjector.cs | 48 + .../Impl/Resource/ResourceProcessor.cs | 105 + .../Impl/Resource/ResourcePropertyInjector.cs | 47 + .../Impl/Resource/ResourceTypeDescriptor.cs | 291 ++ .../Impl/Services/ServiceContext.cs | 60 + .../Impl/Services/ServiceDescriptor.cs | 106 + .../Impl/Services/ServiceProxy.cs | 71 + .../Impl/Services/ServiceProxyInvoker.cs | 141 + .../Impl/Services/ServiceProxySerializer.cs | 140 + .../Impl/Services/Services.cs | 372 ++ .../Impl/Transactions/Transaction.cs | 146 + .../Impl/Transactions/TransactionImpl.cs | 482 +++ .../Impl/Transactions/TransactionMetricsImpl.cs | 68 + .../Impl/Transactions/TransactionsImpl.cs | 201 + .../Impl/Unmanaged/IUnmanagedTarget.cs | 42 + .../Impl/Unmanaged/UnmanagedCallbackHandlers.cs | 99 + .../Impl/Unmanaged/UnmanagedCallbacks.cs | 1164 ++++++ .../Impl/Unmanaged/UnmanagedContext.cs | 53 + .../Unmanaged/UnmanagedNonReleaseableTarget.cs | 70 + .../Impl/Unmanaged/UnmanagedTarget.cs | 77 + .../Impl/Unmanaged/UnmanagedUtils.cs | 1371 +++++++ .../Lifecycle/ILifecycleBean.cs | 64 + .../Lifecycle/LifecycleEventType.cs | 49 + .../Messaging/IMessageListener.cs | 38 + .../Apache.Ignite.Core/Messaging/IMessaging.cs | 128 + .../Properties/AssemblyInfo.cs | 46 + .../Resource/InstanceResourceAttribute.cs | 35 + .../Resource/StoreSessionResourceAttribute.cs | 32 + .../Apache.Ignite.Core/Services/IService.cs | 51 + .../Services/IServiceContext.cs | 69 + .../Services/IServiceDescriptor.cs | 96 + .../Apache.Ignite.Core/Services/IServices.cs | 256 ++ .../Services/ServiceConfiguration.cs | 62 + .../Services/ServiceInvocationException.cs | 101 + .../Transactions/ITransaction.cs | 238 ++ .../Transactions/ITransactionMetrics.cs | 47 + .../Transactions/ITransactions.cs | 76 + .../Transactions/TransactionConcurrency.cs | 36 + .../TransactionHeuristicException.cs | 72 + .../Transactions/TransactionIsolation.cs | 41 + .../TransactionOptimisticException.cs | 69 + .../TransactionRollbackException.cs | 68 + .../Transactions/TransactionState.cs | 70 + .../Transactions/TransactionTimeoutException.cs | 69 + modules/platforms/dotnet/Apache.Ignite.FxCop | 117 + modules/platforms/dotnet/Apache.Ignite.sln | 111 + .../dotnet/Apache.Ignite.sln.DotSettings | 4 + modules/platforms/dotnet/Apache.Ignite.slnrel | 43 + .../dotnet/Apache.Ignite/Apache.Ignite.csproj | 83 + .../dotnet/Apache.Ignite/Apache.Ignite.snk | Bin 0 -> 596 bytes .../platforms/dotnet/Apache.Ignite/App.config | 56 + .../Config/AppSettingsConfigurator.cs | 113 + .../Apache.Ignite/Config/ArgsConfigurator.cs | 164 + .../Apache.Ignite/Config/ConfigValueParser.cs | 42 + .../Apache.Ignite/Config/IConfigurator.cs | 34 + .../dotnet/Apache.Ignite/IgniteRunner.cs | 171 + .../Apache.Ignite/Properties/AssemblyInfo.cs | 35 + .../Apache.Ignite/Service/IgniteService.cs | 219 ++ .../Apache.Ignite/Service/NativeMethods.cs | 57 + .../Apache.Ignite/Service/ServiceDescription.cs | 32 + .../platforms/dotnet/Apache.Ignite_x86.slnrel | 43 + modules/platforms/dotnet/README.txt | 24 + .../dotnet/examples/Apache.Ignite.Examples.sln | 38 + .../Apache.Ignite.Examples.csproj | 88 + .../Apache.Ignite.Examples.snk | Bin 0 -> 596 bytes .../examples/Apache.Ignite.Examples/App.config | 24 + .../Compute/ClosureExample.cs | 84 + .../Compute/TaskExample.cs | 141 + .../Datagrid/ContinuousQueryExample.cs | 103 + .../Datagrid/CrossPlatformExample.cs | 205 + .../Datagrid/DataStreamerExample.cs | 102 + .../Datagrid/PutGetExample.cs | 219 ++ .../Datagrid/QueryExample.cs | 227 ++ .../Datagrid/StoreExample.cs | 115 + .../Datagrid/TransactionExample.cs | 105 + .../Events/EventsExample.cs | 104 + .../Messaging/MessagingExample.cs | 112 + .../Misc/LifecycleExample.cs | 109 + .../Properties/AssemblyInfo.cs | 35 + .../Services/IMapService.cs | 56 + .../Services/ServicesExample.cs | 77 + .../Apache.Ignite.ExamplesDll.csproj | 82 + .../Apache.Ignite.ExamplesDll.snk | Bin 0 -> 596 bytes .../Apache.Ignite.ExamplesDll/Binary/Account.cs | 60 + .../Apache.Ignite.ExamplesDll/Binary/Address.cs | 81 + .../Binary/Employee.cs | 93 + .../Binary/EmployeeKey.cs | 86 + .../Binary/Organization.cs | 84 + .../Binary/OrganizationType.cs | 43 + .../Compute/AverageSalaryJob.cs | 66 + .../Compute/AverageSalaryTask.cs | 85 + .../Compute/CharacterCountClosure.cs | 43 + .../Compute/CharacterCountReducer.cs | 51 + .../Datagrid/ContinuousQueryFilter.cs | 50 + .../Datagrid/EmployeeStore.cs | 122 + .../Datagrid/EmployeeStorePredicate.cs | 41 + .../Events/LocalListener.cs | 54 + .../Messaging/LocalListener.cs | 59 + .../Messaging/RemoteOrderedListener.cs | 54 + .../Messaging/RemoteUnorderedListener.cs | 54 + .../Messaging/Topic.cs | 28 + .../Properties/AssemblyInfo.cs | 35 + .../Services/MapService.cs | 119 + .../examples/Config/example-cache-query.xml | 111 + .../examples/Config/example-cache-store.xml | 59 + .../dotnet/examples/Config/example-cache.xml | 80 + .../dotnet/examples/Config/example-compute.xml | 70 + modules/platforms/dotnet/examples/README.txt | 14 + modules/platforms/licenses/apache-2.0.txt | 202 + .../org/apache/ignite/IgniteSpringBean.java | 19 + .../spring/IgniteTransactionHolder.java | 97 + .../spring/SpringTransactionManager.java | 522 +++ .../transactions/spring/package-info.java | 22 + .../test/java/config/spring-transactions.xml | 36 + .../testsuites/IgniteSpringTestSuite.java | 5 +- .../GridSpringTransactionManagerSelfTest.java | 165 + .../spring/GridSpringTransactionService.java | 68 + modules/yardstick/config/ignite-base-config.xml | 37 +- .../cache/IgniteSqlQueryPutBenchmark.java | 5 + .../cache/WaitMapExchangeFinishCallable.java | 4 +- .../IgniteFailoverAbstractBenchmark.java | 4 +- .../yardstick/cache/model/Organization.java | 19 +- .../ignite/yardstick/cache/model/Person.java | 24 +- .../ignite/yardstick/cache/model/SampleKey.java | 16 +- .../yardstick/cache/model/SampleValue.java | 16 +- parent/pom.xml | 38 +- pom.xml | 11 - 1851 files changed, 182942 insertions(+), 143568 deletions(-) ----------------------------------------------------------------------