ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [08/20] ignite git commit: Minors.
Date Fri, 29 Apr 2016 10:55:47 GMT
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 <vozerov@gridgain.com>
Authored: Tue Apr 26 16:31:32 2016 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
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);
 


Mime
View raw message