Repository: ignite Updated Branches: refs/heads/ignite-no-deferred-res [created] 9f0d4988a
Check whether deferred update response affects performance. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9f0d4988 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9f0d4988 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9f0d4988 Branch: refs/heads/ignite-no-deferred-res Commit: 9f0d4988a776afc1d556985d6162d0ab76ba99f3 Parents: ef2007d Author: Alexey Goncharuk <alexey.goncha...@gmail.com> Authored: Wed Nov 25 16:15:04 2015 +0300 Committer: Alexey Goncharuk <alexey.goncha...@gmail.com> Committed: Wed Nov 25 16:15:04 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/atomic/GridDhtAtomicCache.java | 4 ++-- .../cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java | 3 ++- 2 files changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/9f0d4988/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java index cd76a56..c6fdf14 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java @@ -1311,7 +1311,7 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { res.returnValue(retVal); - if (dhtFut != null) + if (dhtFut != null && ctx.config().getWriteSynchronizationMode() == FULL_SYNC) ctx.mvcc().addAtomicFuture(dhtFut.version(), dhtFut); } else @@ -2701,7 +2701,7 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { ctx.io().send(nodeId, res, ctx.ioPolicy()); else { // No failed keys and sync mode is not FULL_SYNC, thus sending deferred response. - sendDeferredUpdateResponse(nodeId, req.futureVersion()); + //sendDeferredUpdateResponse(nodeId, req.futureVersion()); } } catch (ClusterTopologyCheckedException ignored) { http://git-wip-us.apache.org/repos/asf/ignite/blob/9f0d4988/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java index e31af19..2269110 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java @@ -349,7 +349,8 @@ public class GridDhtAtomicUpdateFuture extends GridFutureAdapter<Void> /** {@inheritDoc} */ @Override public boolean onDone(@Nullable Void res, @Nullable Throwable err) { if (super.onDone(res, err)) { - cctx.mvcc().removeAtomicFuture(version()); + if (cctx.config().getWriteSynchronizationMode() == FULL_SYNC) + cctx.mvcc().removeAtomicFuture(version()); if (err != null) { if (!mappings.isEmpty()) {