Merge remote-tracking branch 'remotes/origin/master' into ignite-1093
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a7ddb62c Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a7ddb62c Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a7ddb62c Branch: refs/heads/ignite-1093 Commit: a7ddb62cc70e92704c8732617edac071aa891555 Parents: 4ddb969 e4ba2eb Author: Anton Vinogradov <[email protected]> Authored: Thu Aug 27 11:52:40 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Thu Aug 27 11:52:40 2015 +0300 ---------------------------------------------------------------------- assembly/dependencies-hadoop.xml | 1 + .../ignite/codegen/MessageCodeGenerator.java | 30 +- .../internal/GridEventConsumeHandler.java | 2 +- .../ignite/internal/GridJobCancelRequest.java | 2 +- .../ignite/internal/GridJobExecuteRequest.java | 2 +- .../ignite/internal/GridJobExecuteResponse.java | 2 +- .../ignite/internal/GridJobSiblingsRequest.java | 2 +- .../internal/GridJobSiblingsResponse.java | 2 +- .../ignite/internal/GridTaskCancelRequest.java | 2 +- .../ignite/internal/GridTaskSessionRequest.java | 2 +- .../internal/direct/DirectByteBufferStream.java | 2 +- .../internal/direct/DirectMessageReader.java | 6 + .../checkpoint/GridCheckpointRequest.java | 2 +- .../managers/communication/GridIoManager.java | 2 +- .../managers/communication/GridIoMessage.java | 8 +- .../communication/GridIoUserMessage.java | 2 +- .../deployment/GridDeploymentInfoBean.java | 2 +- .../deployment/GridDeploymentRequest.java | 2 +- .../deployment/GridDeploymentResponse.java | 2 +- .../eventstorage/GridEventStorageManager.java | 2 +- .../eventstorage/GridEventStorageMessage.java | 2 +- .../platform/PlatformAwareEventFilter.java | 37 - .../platform/PlatformLocalEventListener.java | 28 - .../internal/portable/PortableContext.java | 4 - .../affinity/AffinityTopologyVersion.java | 2 +- .../cache/CacheEntryInfoCollection.java | 2 +- .../cache/CacheEntryPredicateAdapter.java | 2 +- .../cache/CacheEntryPredicateContainsValue.java | 2 +- .../cache/CacheEntrySerializablePredicate.java | 2 +- .../processors/cache/CacheEvictionEntry.java | 2 +- .../cache/CacheInvokeDirectResult.java | 2 +- .../processors/cache/CacheObjectAdapter.java | 2 +- .../cache/CacheObjectByteArrayImpl.java | 2 +- .../processors/cache/GridCacheEntryInfo.java | 2 +- .../cache/GridCacheEvictionRequest.java | 2 +- .../cache/GridCacheEvictionResponse.java | 2 +- .../processors/cache/GridCacheMessage.java | 2 +- .../processors/cache/GridCacheReturn.java | 2 +- .../distributed/GridCacheTtlUpdateRequest.java | 3 +- .../distributed/GridCacheTxRecoveryRequest.java | 2 +- .../GridCacheTxRecoveryResponse.java | 2 +- .../distributed/GridDistributedBaseMessage.java | 2 +- .../distributed/GridDistributedLockRequest.java | 2 +- .../GridDistributedLockResponse.java | 2 +- .../GridDistributedTxFinishRequest.java | 8 +- .../GridDistributedTxFinishResponse.java | 2 +- .../GridDistributedTxPrepareRequest.java | 8 +- .../GridDistributedTxPrepareResponse.java | 2 +- .../GridDistributedUnlockRequest.java | 2 +- .../dht/GridDhtAffinityAssignmentRequest.java | 2 +- .../dht/GridDhtAffinityAssignmentResponse.java | 2 +- .../distributed/dht/GridDhtLockRequest.java | 6 +- .../distributed/dht/GridDhtLockResponse.java | 2 +- .../distributed/dht/GridDhtTxFinishRequest.java | 2 +- .../dht/GridDhtTxFinishResponse.java | 2 +- .../dht/GridDhtTxPrepareRequest.java | 2 +- .../dht/GridDhtTxPrepareResponse.java | 2 +- .../distributed/dht/GridDhtUnlockRequest.java | 2 +- .../GridDhtAtomicDeferredUpdateResponse.java | 2 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 2 +- .../dht/atomic/GridDhtAtomicUpdateResponse.java | 2 +- .../dht/atomic/GridNearAtomicUpdateRequest.java | 2 +- .../atomic/GridNearAtomicUpdateResponse.java | 2 +- .../dht/preloader/GridDhtForceKeysRequest.java | 3 +- .../dht/preloader/GridDhtForceKeysResponse.java | 4 +- .../GridDhtPartitionDemandMessage.java | 2 +- .../preloader/GridDhtPartitionExchangeId.java | 2 +- .../GridDhtPartitionSupplyMessage.java | 2 +- .../GridDhtPartitionsAbstractMessage.java | 2 +- .../preloader/GridDhtPartitionsFullMessage.java | 2 +- .../GridDhtPartitionsSingleMessage.java | 2 +- .../GridDhtPartitionsSingleRequest.java | 2 +- .../distributed/near/CacheVersionedValue.java | 2 +- .../distributed/near/GridNearGetRequest.java | 2 +- .../distributed/near/GridNearGetResponse.java | 2 +- .../distributed/near/GridNearLockRequest.java | 2 +- .../distributed/near/GridNearLockResponse.java | 2 +- .../near/GridNearTxFinishRequest.java | 2 +- .../near/GridNearTxFinishResponse.java | 2 +- .../near/GridNearTxPrepareRequest.java | 2 +- .../near/GridNearTxPrepareResponse.java | 2 +- .../distributed/near/GridNearUnlockRequest.java | 2 +- .../CacheObjectPortableProcessorImpl.java | 3 +- .../cache/query/GridCacheQueryRequest.java | 2 +- .../cache/query/GridCacheQueryResponse.java | 2 +- .../cache/query/GridCacheSqlQuery.java | 9 +- .../continuous/CacheContinuousQueryEntry.java | 2 +- .../cache/transactions/IgniteTxEntry.java | 2 +- .../cache/transactions/IgniteTxKey.java | 2 +- .../cache/transactions/TxEntryValueHolder.java | 2 +- .../version/GridCacheRawVersionedEntry.java | 2 +- .../cache/version/GridCacheVersion.java | 2 +- .../cache/version/GridCacheVersionEx.java | 2 +- .../cacheobject/IgniteCacheObjectProcessor.java | 2 +- .../IgniteCacheObjectProcessorImpl.java | 2 +- .../clock/GridClockDeltaSnapshotMessage.java | 2 +- .../processors/clock/GridClockDeltaVersion.java | 2 +- .../continuous/GridContinuousMessage.java | 2 +- .../datastreamer/DataStreamerEntry.java | 2 +- .../datastreamer/DataStreamerRequest.java | 2 +- .../datastreamer/DataStreamerResponse.java | 2 +- .../processors/igfs/IgfsAckMessage.java | 2 +- .../internal/processors/igfs/IgfsBlockKey.java | 2 +- .../processors/igfs/IgfsBlocksMessage.java | 2 +- .../igfs/IgfsCommunicationMessage.java | 2 +- .../processors/igfs/IgfsDeleteMessage.java | 2 +- .../processors/igfs/IgfsFileAffinityRange.java | 9 +- .../igfs/IgfsFragmentizerRequest.java | 2 +- .../igfs/IgfsFragmentizerResponse.java | 2 +- .../internal/processors/igfs/IgfsProcessor.java | 8 - .../processors/igfs/IgfsSyncMessage.java | 2 +- .../platform/PlatformAwareEventFilter.java | 37 + .../processors/platform/PlatformContext.java | 123 +++ .../platform/PlatformLocalEventListener.java | 28 + .../platform/PlatformNoopProcessor.java | 5 + .../processors/platform/PlatformProcessor.java | 7 + .../callback/PlatformCallbackGateway.java | 869 +++++++++++++++++++ .../callback/PlatformCallbackUtils.java | 468 ++++++++++ .../platform/memory/PlatformInputStream.java | 30 + .../platform/memory/PlatformMemory.java | 77 ++ .../platform/memory/PlatformMemoryManager.java | 46 + .../platform/memory/PlatformOutputStream.java | 30 + .../processors/query/GridQueryProcessor.java | 2 +- .../messages/GridQueryCancelRequest.java | 2 +- .../twostep/messages/GridQueryFailResponse.java | 2 +- .../messages/GridQueryNextPageRequest.java | 2 +- .../messages/GridQueryNextPageResponse.java | 3 +- .../h2/twostep/messages/GridQueryRequest.java | 5 +- .../handlers/task/GridTaskResultRequest.java | 2 +- .../handlers/task/GridTaskResultResponse.java | 2 +- .../ignite/internal/util/GridByteArrayList.java | 2 +- .../ignite/internal/util/GridLongList.java | 2 +- .../internal/util/nio/GridDirectParser.java | 2 +- .../communication/MessageFormatter.java | 3 +- .../extensions/communication/MessageReader.java | 13 + .../org/apache/ignite/spi/IgniteSpiAdapter.java | 2 +- .../jobstealing/JobStealingRequest.java | 2 +- .../communication/tcp/TcpCommunicationSpi.java | 8 +- .../resources/META-INF/classnames.properties | 2 +- .../IgniteCacheManyAsyncOperationsTest.java | 107 +++ .../processors/igfs/IgfsAbstractSelfTest.java | 34 +- .../igfs/IgfsBackupFailoverSelfTest.java | 488 +++++++++++ .../igfs/IgfsBackupsDualAsyncSelfTest.java | 40 + .../igfs/IgfsBackupsDualSyncSelfTest.java | 40 + .../igfs/IgfsBackupsPrimarySelfTest.java | 40 + .../testframework/GridSpiTestContext.java | 2 +- .../ignite/testsuites/IgniteCacheTestSuite.java | 1 + .../ignite/testsuites/IgniteIgfsTestSuite.java | 7 + .../Apache.Ignite.Core.csproj | 25 + .../Common/AsyncSupportedAttribute.cs | 33 + .../Apache.Ignite.Core/Common/IAsyncSupport.cs | 52 ++ .../dotnet/Apache.Ignite.Core/Common/IFuture.cs | 115 +++ .../Common/IgniteException.cs | 66 ++ .../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 ++++++ .../Apache.Ignite.Core/Impl/Common/Future.cs | 286 ++++++ .../Impl/Common/FutureType.cs | 52 ++ .../Impl/Common/GridArgumentCheck.cs | 76 ++ .../Impl/Common/IFutureConverter.cs | 32 + .../Impl/Common/IFutureInternal.cs | 45 + .../Impl/Common/LoadedAssembliesResolver.cs | 96 ++ .../Impl/Common/TypeCaster.cs | 72 ++ .../Apache.Ignite.Core/Impl/Handle/Handle.cs | 69 ++ .../Impl/Handle/HandleRegistry.cs | 340 ++++++++ .../Apache.Ignite.Core/Impl/Handle/IHandle.cs | 35 + .../internal/platform/PlatformBootstrap.java | 36 - .../platform/PlatformBootstrapFactory.java | 37 - .../internal/platform/PlatformException.java | 71 -- .../internal/platform/PlatformIgnition.java | 187 ---- .../platform/PlatformNoCallbackException.java | 50 -- .../callback/PlatformCallbackGateway.java | 869 ------------------- .../callback/PlatformCallbackUtils.java | 468 ---------- .../platform/memory/PlatformAbstractMemory.java | 121 --- .../PlatformBigEndianInputStreamImpl.java | 126 --- .../PlatformBigEndianOutputStreamImpl.java | 162 ---- .../platform/memory/PlatformExternalMemory.java | 55 -- .../platform/memory/PlatformInputStream.java | 30 - .../memory/PlatformInputStreamImpl.java | 323 ------- .../platform/memory/PlatformMemory.java | 77 -- .../platform/memory/PlatformMemoryManager.java | 46 - .../memory/PlatformMemoryManagerImpl.java | 83 -- .../platform/memory/PlatformMemoryPool.java | 133 --- .../platform/memory/PlatformMemoryUtils.java | 468 ---------- .../platform/memory/PlatformOutputStream.java | 30 - .../memory/PlatformOutputStreamImpl.java | 259 ------ .../platform/memory/PlatformPooledMemory.java | 63 -- .../platform/memory/PlatformUnpooledMemory.java | 51 -- .../platform/PlatformAbstractBootstrap.java | 48 + .../platform/PlatformAbstractTarget.java | 276 ++++++ .../processors/platform/PlatformBootstrap.java | 36 + .../platform/PlatformBootstrapFactory.java | 37 + .../processors/platform/PlatformException.java | 71 ++ .../platform/PlatformExtendedException.java | 39 + .../processors/platform/PlatformIgnition.java | 186 ++++ .../platform/PlatformNoCallbackException.java | 50 ++ .../processors/platform/PlatformTarget.java | 76 ++ .../platform/cache/PlatformCacheIterator.java | 72 ++ .../cache/affinity/PlatformAffinity.java | 293 +++++++ .../query/PlatformAbstractQueryCursor.java | 192 ++++ .../cache/query/PlatformFieldsQueryCursor.java | 50 ++ .../cache/query/PlatformQueryCursor.java | 46 + .../cache/store/PlatformCacheStore.java | 25 + .../cache/store/PlatformCacheStoreCallback.java | 61 ++ .../lifecycle/PlatformLifecycleBean.java | 72 ++ .../platform/memory/PlatformAbstractMemory.java | 121 +++ .../PlatformBigEndianInputStreamImpl.java | 126 +++ .../PlatformBigEndianOutputStreamImpl.java | 162 ++++ .../platform/memory/PlatformExternalMemory.java | 55 ++ .../memory/PlatformInputStreamImpl.java | 323 +++++++ .../memory/PlatformMemoryManagerImpl.java | 83 ++ .../platform/memory/PlatformMemoryPool.java | 133 +++ .../platform/memory/PlatformMemoryUtils.java | 468 ++++++++++ .../memory/PlatformOutputStreamImpl.java | 259 ++++++ .../platform/memory/PlatformPooledMemory.java | 63 ++ .../platform/memory/PlatformUnpooledMemory.java | 51 ++ .../transactions/PlatformTransactions.java | 255 ++++++ .../platform/utils/PlatformFutureUtils.java | 326 +++++++ .../platform/utils/PlatformReaderBiClosure.java | 34 + .../platform/utils/PlatformReaderClosure.java | 34 + .../platform/utils/PlatformUtils.java | 663 ++++++++++++++ .../platform/utils/PlatformWriterBiClosure.java | 34 + .../platform/utils/PlatformWriterClosure.java | 33 + parent/pom.xml | 1 + 229 files changed, 9807 insertions(+), 3987 deletions(-) ----------------------------------------------------------------------
