Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 1314718CCE for ; Thu, 18 Feb 2016 08:07:26 +0000 (UTC) Received: (qmail 6984 invoked by uid 500); 18 Feb 2016 08:07:25 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 6926 invoked by uid 500); 18 Feb 2016 08:07:25 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 6314 invoked by uid 99); 18 Feb 2016 08:07:25 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 18 Feb 2016 08:07:25 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 806EEDFF67; Thu, 18 Feb 2016 08:07:25 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sboikov@apache.org To: commits@ignite.apache.org Date: Thu, 18 Feb 2016 08:07:45 -0000 Message-Id: <6db27ecf32674fb6af775f5f3e5fbe7c@git.apache.org> In-Reply-To: <6ba01a52f6e847f5ae384abbfb7e9a1a@git.apache.org> References: <6ba01a52f6e847f5ae384abbfb7e9a1a@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [21/21] ignite git commit: Merge remote-tracking branch 'remotes/origin/master' into ignite-2407 Merge remote-tracking branch 'remotes/origin/master' into ignite-2407 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9bb1bdee Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9bb1bdee Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9bb1bdee Branch: refs/heads/ignite-2407 Commit: 9bb1bdeef50261a12a5e480d6edfa50f84c7e9bc Parents: 4a098d0 2bb4499 Author: sboikov Authored: Thu Feb 18 11:06:55 2016 +0300 Committer: sboikov Committed: Thu Feb 18 11:06:55 2016 +0300 ---------------------------------------------------------------------- .../cache/query/CacheQueryEntryEvent.java | 48 + .../ignite/internal/GridJobCancelRequest.java | 5 + .../ignite/internal/GridJobExecuteRequest.java | 5 + .../ignite/internal/GridJobExecuteResponse.java | 5 + .../ignite/internal/GridJobSiblingsRequest.java | 5 + .../internal/GridJobSiblingsResponse.java | 5 + .../ignite/internal/GridTaskCancelRequest.java | 5 + .../ignite/internal/GridTaskSessionRequest.java | 5 + .../ignite/internal/MarshallerContextImpl.java | 3 +- .../ignite/internal/binary/BinaryContext.java | 1 + .../internal/binary/BinaryEnumObjectImpl.java | 5 + .../internal/binary/BinaryObjectImpl.java | 5 + .../binary/BinaryObjectOffheapImpl.java | 5 + .../ignite/internal/binary/BinaryUtils.java | 5 +- .../checkpoint/GridCheckpointRequest.java | 5 + .../managers/communication/GridIoMessage.java | 5 + .../communication/GridIoUserMessage.java | 5 + .../deployment/GridDeploymentInfoBean.java | 5 + .../deployment/GridDeploymentRequest.java | 5 + .../deployment/GridDeploymentResponse.java | 5 + .../eventstorage/GridEventStorageMessage.java | 5 + .../affinity/AffinityTopologyVersion.java | 5 + .../cache/CacheEntryInfoCollection.java | 5 + .../cache/CacheEntryPredicateAdapter.java | 5 + .../cache/CacheEntryPredicateContainsValue.java | 8 +- .../cache/CacheEntrySerializablePredicate.java | 5 + .../cache/CacheEvictableEntryImpl.java | 2 +- .../processors/cache/CacheEvictionEntry.java | 5 + .../cache/CacheInvokeDirectResult.java | 5 + .../cache/CacheObjectByteArrayImpl.java | 5 + .../processors/cache/CacheObjectImpl.java | 5 + .../cache/GridCacheDeploymentManager.java | 8 +- .../processors/cache/GridCacheEntryInfo.java | 5 + .../processors/cache/GridCacheMessage.java | 5 + .../processors/cache/GridCacheProcessor.java | 4 +- .../processors/cache/GridCacheReturn.java | 5 + .../processors/cache/KeyCacheObjectImpl.java | 5 + .../binary/CacheObjectBinaryProcessorImpl.java | 13 +- .../CacheDataStructuresManager.java | 4 +- .../dht/atomic/GridDhtAtomicCache.java | 5 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 14 +- .../dht/atomic/GridNearAtomicUpdateRequest.java | 16 + .../dht/preloader/GridDhtPartitionDemander.java | 3 +- .../preloader/GridDhtPartitionExchangeId.java | 5 + .../distributed/near/CacheVersionedValue.java | 5 + .../cache/query/GridCacheSqlQuery.java | 5 + .../continuous/CacheContinuousQueryEntry.java | 5 + .../continuous/CacheContinuousQueryEvent.java | 17 +- .../continuous/CacheContinuousQueryHandler.java | 120 +-- .../CacheContinuousQueryListener.java | 3 +- .../continuous/CacheContinuousQueryManager.java | 65 +- .../cache/transactions/IgniteTxEntry.java | 5 + .../cache/transactions/IgniteTxKey.java | 5 + .../cache/transactions/TxEntryValueHolder.java | 5 + .../cache/version/GridCacheVersion.java | 5 + .../clock/GridClockDeltaSnapshotMessage.java | 5 + .../processors/clock/GridClockDeltaVersion.java | 5 + .../continuous/GridContinuousMessage.java | 5 + .../datastreamer/DataStreamerEntry.java | 5 + .../datastreamer/DataStreamerRequest.java | 5 + .../datastreamer/DataStreamerResponse.java | 5 + .../datastructures/DataStructuresProcessor.java | 1 + .../processors/igfs/IgfsAckMessage.java | 5 + .../internal/processors/igfs/IgfsBlockKey.java | 5 + .../processors/igfs/IgfsBlocksMessage.java | 5 + .../processors/igfs/IgfsDeleteMessage.java | 5 + .../processors/igfs/IgfsFileAffinityRange.java | 5 + .../igfs/IgfsFragmentizerRequest.java | 5 + .../igfs/IgfsFragmentizerResponse.java | 5 + .../processors/igfs/IgfsSyncMessage.java | 5 + .../platform/PlatformProcessorImpl.java | 17 +- .../callback/PlatformCallbackGateway.java | 30 + .../callback/PlatformCallbackUtils.java | 15 + .../messages/GridQueryCancelRequest.java | 5 + .../twostep/messages/GridQueryFailResponse.java | 5 + .../messages/GridQueryNextPageRequest.java | 5 + .../messages/GridQueryNextPageResponse.java | 5 + .../h2/twostep/messages/GridQueryRequest.java | 5 + .../handlers/task/GridTaskResultRequest.java | 5 + .../handlers/task/GridTaskResultResponse.java | 5 + .../service/GridServiceProcessor.java | 101 ++- .../processors/service/GridServiceProxy.java | 22 +- .../ignite/internal/util/GridByteArrayList.java | 5 + .../ignite/internal/util/GridLongList.java | 5 + .../internal/util/GridMessageCollection.java | 5 + .../internal/util/UUIDCollectionMessage.java | 5 + .../util/nio/GridNioFinishedFuture.java | 5 + .../ignite/internal/util/nio/GridNioFuture.java | 7 +- .../internal/util/nio/GridNioFutureImpl.java | 5 + .../util/nio/GridNioRecoveryDescriptor.java | 2 + .../ignite/internal/util/nio/GridNioServer.java | 7 + .../extensions/communication/Message.java | 5 + .../jobstealing/JobStealingRequest.java | 5 + .../communication/tcp/TcpCommunicationSpi.java | 15 + .../internal/GridAffinityNoCacheSelfTest.java | 5 + .../GridCommunicationSendMessageSelfTest.java | 5 + .../communication/GridIoManagerSelfTest.java | 5 + .../cache/CacheEnumOperationsAbstractTest.java | 307 +++++++ .../CacheEnumOperationsSingleNodeTest.java | 28 + .../cache/CacheEnumOperationsTest.java | 28 + .../cache/GridCacheDeploymentSelfTest.java | 78 +- .../IgniteCacheNearRestartRollbackSelfTest.java | 36 +- .../GridCacheEvictableEntryEqualsSelfTest.java | 85 ++ .../continuous/CacheContinuousBatchAckTest.java | 355 ++++++++ ...heContinuousBatchForceServerModeAckTest.java | 80 ++ ...CacheContinuousQueryCounterAbstractTest.java | 612 +++++++++++++ ...inuousQueryCounterPartitionedAtomicTest.java | 41 + ...ContinuousQueryCounterPartitionedTxTest.java | 41 + ...tinuousQueryCounterReplicatedAtomicTest.java | 41 + ...eContinuousQueryCounterReplicatedTxTest.java | 41 + .../CacheContinuousQueryLostPartitionTest.java | 4 +- ...acheContinuousQueryRandomOperationsTest.java | 896 ++++++++++++++++--- .../GridServiceSerializationSelfTest.java | 149 +++ .../communication/GridTestMessage.java | 5 + .../spi/communication/GridTestMessage.java | 5 + .../IgniteCacheEvictionSelfTestSuite.java | 4 +- .../testsuites/IgniteCacheTestSuite2.java | 4 + .../testsuites/IgniteKernalSelfTestSuite.java | 2 + .../hadoop/jobtracker/HadoopJobTracker.java | 5 +- .../processors/query/h2/IgniteH2Indexing.java | 95 +- .../h2/twostep/msg/GridH2ValueMessage.java | 5 + .../h2/GridIndexingSpiAbstractSelfTest.java | 43 +- .../IgniteCacheQuerySelfTestSuite.java | 12 + .../cpp/common/include/ignite/common/exports.h | 6 +- .../cpp/common/include/ignite/common/java.h | 21 +- modules/platforms/cpp/common/src/exports.cpp | 6 +- modules/platforms/cpp/common/src/java.cpp | 28 +- .../cpp/core-test/src/cache_query_test.cpp | 45 + .../ignite/cache/query/query_fields_row.h | 2 +- .../Apache.Ignite.Core.Tests.csproj | 2 + .../Process/IgniteProcess.cs | 16 + .../ProcessExtensions.cs | 78 ++ .../Apache.Ignite.Core.Tests/ReconnectTest.cs | 96 ++ .../Apache.Ignite.Core.csproj | 1 + .../Apache.Ignite.Core/Cluster/ICluster.cs | 14 + .../Common/ClientDisconnectedException.cs | 97 ++ .../Impl/Binary/BinaryUtils.cs | 2 +- .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 2 +- .../Impl/Compute/ComputeTaskHolder.cs | 2 +- .../Apache.Ignite.Core/Impl/ExceptionUtils.cs | 110 ++- .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 32 +- .../Apache.Ignite.Core/Impl/IgniteProxy.cs | 7 + .../Impl/Unmanaged/UnmanagedCallbackHandlers.cs | 3 + .../Impl/Unmanaged/UnmanagedCallbacks.cs | 32 +- pom.xml | 2 +- 145 files changed, 4072 insertions(+), 435 deletions(-) ----------------------------------------------------------------------