Merge remote-tracking branch 'upstream/ignite-1.6.5' into ignite-1.6.5
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e23aba4b Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e23aba4b Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e23aba4b Branch: refs/heads/ignite-3661 Commit: e23aba4b060a9dfbee20384550a49274a479ac00 Parents: b9d9d84 0180010 Author: vozerov-gridgain <[email protected]> Authored: Tue Aug 9 14:05:17 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Tue Aug 9 14:05:17 2016 +0300 ---------------------------------------------------------------------- .../ignite/codegen/MessageCodeGenerator.java | 6 +- .../java/org/apache/ignite/IgniteCompute.java | 69 +- .../ignite/internal/GridJobExecuteRequest.java | 148 +++- .../ignite/internal/GridJobExecuteResponse.java | 42 +- .../ignite/internal/IgniteComputeImpl.java | 120 ++- .../failover/GridFailoverContextImpl.java | 27 +- .../managers/failover/GridFailoverManager.java | 17 +- .../affinity/GridAffinityProcessor.java | 18 + .../processors/cache/GridCacheSwapManager.java | 22 +- .../distributed/dht/GridDhtCacheAdapter.java | 19 +- .../distributed/dht/GridDhtLocalPartition.java | 33 +- .../cache/distributed/dht/GridReservable.java | 5 +- .../cache/query/GridCacheQueryManager.java | 10 +- .../processors/closure/AffinityTask.java | 17 +- .../closure/GridClosureProcessor.java | 142 +++- .../processors/job/GridJobProcessor.java | 139 ++- .../internal/processors/job/GridJobWorker.java | 203 +++-- .../processors/query/GridQueryProcessor.java | 22 +- .../processors/task/GridTaskWorker.java | 235 +++-- .../ignite/internal/util/IgniteUtils.java | 10 + .../ignite/spi/failover/FailoverContext.java | 15 +- .../spi/failover/always/AlwaysFailoverSpi.java | 15 +- .../GridJobMasterLeaveAwareSelfTest.java | 4 +- ...ectionLocalJobMultipleArgumentsSelfTest.java | 4 +- .../GridTaskFailoverAffinityRunTest.java | 2 +- .../IgniteComputeEmptyClusterGroupTest.java | 8 +- .../binary/GridBinaryAffinityKeySelfTest.java | 6 +- ...acheAbstractUsersAffinityMapperSelfTest.java | 2 +- ...niteDynamicCacheStartStopConcurrentTest.java | 2 +- .../spi/failover/GridFailoverTestContext.java | 6 + ...eLockPartitionOnAffinityRunAbstractTest.java | 412 +++++++++ ...PartitionOnAffinityRunAtomicCacheOpTest.java | 329 +++++++ ...niteCacheLockPartitionOnAffinityRunTest.java | 852 +++++++++++++++++++ ...LockPartitionOnAffinityRunTxCacheOpTest.java | 33 + ...titionOnAffinityRunWithCollisionSpiTest.java | 204 +++++ .../IgniteCacheAffinityRunTestSuite.java | 45 + 36 files changed, 2961 insertions(+), 282 deletions(-) ----------------------------------------------------------------------
