Minors.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f64cdcce Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f64cdcce Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f64cdcce Branch: refs/heads/ignite-2523-1 Commit: f64cdcced0b50002820e448429e6ad15f4308068 Parents: fe132a5 Author: vozerov-gridgain <[email protected]> Authored: Tue Apr 26 16:31:32 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Tue Apr 26 16:31:32 2016 +0300 ---------------------------------------------------------------------- .../dht/atomic/GridNearAtomicAbstractUpdateResponse.java | 5 +++++ .../dht/atomic/GridNearAtomicSingleUpdateResponse.java | 5 +++++ .../distributed/dht/atomic/GridNearAtomicUpdateResponse.java | 8 ++++++-- 3 files changed, 16 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/f64cdcce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateResponse.java index e945604..56bdd66 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateResponse.java @@ -198,4 +198,9 @@ public abstract class GridNearAtomicAbstractUpdateResponse extends GridCacheMess * @param e Error cause. */ public abstract void addFailedKeys(GridNearAtomicAbstractUpdateRequest req, Throwable e); + + /** + * @return {@code True} is this is a response for a single key-value pair update. + */ + public abstract boolean isSingle(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/f64cdcce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateResponse.java index 9ec6fcf..fcb7afc 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateResponse.java @@ -293,6 +293,11 @@ public class GridNearAtomicSingleUpdateResponse extends GridNearAtomicAbstractUp err.addSuppressed(e); } + /** {@inheritDoc} */ + @Override public boolean isSingle() { + return true; + } + /** {@inheritDoc} * @param ctx*/ @Override public void prepareMarshal(GridCacheSharedContext ctx) throws IgniteCheckedException { http://git-wip-us.apache.org/repos/asf/ignite/blob/f64cdcce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java index 7e27657..34d3fe3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java @@ -330,8 +330,12 @@ public class GridNearAtomicUpdateResponse extends GridNearAtomicAbstractUpdateRe err.addSuppressed(e); } - /** {@inheritDoc} - * @param ctx*/ + /** {@inheritDoc} */ + @Override public boolean isSingle() { + return false; + } + + /** {@inheritDoc} */ @Override public void prepareMarshal(GridCacheSharedContext ctx) throws IgniteCheckedException { super.prepareMarshal(ctx);
