ignite-1540 Handle error in GridDhtAtomicUpdateFuture.onDone
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1056a31f Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1056a31f Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1056a31f Branch: refs/heads/ignite-1093-2 Commit: 1056a31fc72ea25c8790e37f2621f3d6e1908c89 Parents: ece3400 Author: sboikov <[email protected]> Authored: Thu Sep 24 15:52:17 2015 +0300 Committer: sboikov <[email protected]> Committed: Thu Sep 24 15:52:17 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/1056a31f/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 0cbad48..35b8e27 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 @@ -311,6 +311,11 @@ public class GridDhtAtomicUpdateFuture extends GridFutureAdapter<Void> if (super.onDone(res, err)) { cctx.mvcc().removeAtomicFuture(version()); + if (err != null) { + for (KeyCacheObject key : keys) + updateRes.addFailedKey(key, err); + } + if (updateReq.writeSynchronizationMode() == FULL_SYNC) completionCb.apply(updateReq, updateRes);
