ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject ignite git commit: IGNITE-2466 Added onAckReceived method on Message interface.
Date Tue, 16 Feb 2016 13:50:33 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-2466 a41742229 -> 1ec5bfc79


IGNITE-2466 Added onAckReceived method on Message interface.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1ec5bfc7
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1ec5bfc7
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1ec5bfc7

Branch: refs/heads/ignite-2466
Commit: 1ec5bfc7961526fee2ac7c075bc48a49d568f97c
Parents: a417422
Author: nikolay_tikhonov <ntikhonov@gridgain.com>
Authored: Tue Feb 16 16:45:32 2016 +0300
Committer: nikolay_tikhonov <ntikhonov@gridgain.com>
Committed: Tue Feb 16 16:45:32 2016 +0300

----------------------------------------------------------------------
 .../processors/query/h2/twostep/msg/GridH2ValueMessage.java     | 5 +++++
 .../processors/query/h2/GridIndexingSpiAbstractSelfTest.java    | 5 +++++
 2 files changed, 10 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/1ec5bfc7/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2ValueMessage.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2ValueMessage.java
b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2ValueMessage.java
index a2833db..d528c47 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2ValueMessage.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2ValueMessage.java
@@ -39,6 +39,11 @@ public abstract class GridH2ValueMessage implements Message {
     public abstract Value value(GridKernalContext ctx) throws IgniteCheckedException;
 
     /** {@inheritDoc} */
+    @Override public void onAckReceived() {
+        // No-op.
+    }
+
+    /** {@inheritDoc} */
     @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) {
         return true;
     }

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ec5bfc7/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/GridIndexingSpiAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/GridIndexingSpiAbstractSelfTest.java
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/GridIndexingSpiAbstractSelfTest.java
index c027b26..dc572e2 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/GridIndexingSpiAbstractSelfTest.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/GridIndexingSpiAbstractSelfTest.java
@@ -574,6 +574,11 @@ public abstract class GridIndexingSpiAbstractSelfTest extends GridCommonAbstract
         }
 
         /** {@inheritDoc} */
+        @Override public void onAckReceived() {
+            // No-op.
+        }
+
+        /** {@inheritDoc} */
         @Nullable @Override public <T> T value(CacheObjectContext ctx, boolean cpy)
{
             return (T)val;
         }


Mime
View raw message