Repository: ignite Updated Branches: refs/heads/ignite-2466 [created] a4137da32
IGNITE-2466 Cleanup values in GridNearAtomicUpdateRequest. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a4137da3 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a4137da3 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a4137da3 Branch: refs/heads/ignite-2466 Commit: a4137da32f41e79f066b89f9596031ee2694acf9 Parents: cfffa2c Author: nikolay_tikhonov <[email protected]> Authored: Mon Feb 15 16:40:57 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Mon Feb 15 16:40:57 2016 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/atomic/GridDhtAtomicCache.java | 3 +++ .../distributed/dht/atomic/GridNearAtomicUpdateRequest.java | 7 +++++++ 2 files changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/a4137da3/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 fec61df..e654885 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 @@ -1459,6 +1459,9 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { res.returnValue(retVal); + if (req.writeSynchronizationMode() != FULL_ASYNC) + req.cleanup(); + if (dhtFut != null) ctx.mvcc().addAtomicFuture(dhtFut.version(), dhtFut); } http://git-wip-us.apache.org/repos/asf/ignite/blob/a4137da3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java index 1a7fa88..9abf385 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java @@ -1024,6 +1024,13 @@ public class GridNearAtomicUpdateRequest extends GridCacheMessage implements Gri return reader.afterMessageRead(GridNearAtomicUpdateRequest.class); } + /** + * Cleanup values. + */ + public void cleanup() { + vals = null; + } + /** {@inheritDoc} */ @Override public byte directType() { return 40;
