ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: Ignite 1924
Date Wed, 25 Nov 2015 09:21:43 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1924 732c96f9f -> 8802d6e5a


Ignite 1924


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

Branch: refs/heads/ignite-1924
Commit: 8802d6e5a41af95597eb6eef570a76dedb98ba9e
Parents: 732c96f
Author: Anton Vinogradov <av@apache.org>
Authored: Wed Nov 25 12:21:33 2015 +0300
Committer: Anton Vinogradov <av@apache.org>
Committed: Wed Nov 25 12:21:33 2015 +0300

----------------------------------------------------------------------
 .../util/nio/GridTcpNioCommunicationClient.java        | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/8802d6e5/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridTcpNioCommunicationClient.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridTcpNioCommunicationClient.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridTcpNioCommunicationClient.java
index 4022bc5..5b29573 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridTcpNioCommunicationClient.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridTcpNioCommunicationClient.java
@@ -25,6 +25,9 @@ import java.util.UUID;
 import org.apache.ignite.IgniteCheckedException;
 import org.apache.ignite.IgniteException;
 import org.apache.ignite.IgniteLogger;
+import org.apache.ignite.internal.IgniteInternalFuture;
+import org.apache.ignite.internal.managers.communication.GridIoMessage;
+import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage;
 import org.apache.ignite.internal.util.lang.IgniteInClosure2X;
 import org.apache.ignite.internal.util.typedef.internal.S;
 import org.apache.ignite.internal.util.typedef.internal.U;
@@ -104,7 +107,7 @@ public class GridTcpNioCommunicationClient extends GridAbstractCommunicationClie
     }
 
     /** {@inheritDoc} */
-    @Override public boolean sendMessage(@Nullable UUID nodeId, Message msg, IgniteInClosure<IgniteException>
closure)
+    @Override public boolean sendMessage(@Nullable UUID nodeId, final Message msg, IgniteInClosure<IgniteException>
closure)
         throws IgniteCheckedException {
         // Node ID is never provided in asynchronous send mode.
         assert nodeId == null;
@@ -114,6 +117,14 @@ public class GridTcpNioCommunicationClient extends GridAbstractCommunicationClie
 
         GridNioFuture<?> fut = ses.send(msg);
 
+        if (msg instanceof GridIoMessage && ((GridIoMessage)msg).message() instanceof
GridDhtPartitionDemandMessage) {
+            fut.listen(new IgniteInClosure<IgniteInternalFuture<?>>() {
+                @Override public void apply(IgniteInternalFuture<?> future) {
+                    U.log(log, "C1>> " + ((GridIoMessage)msg).message());
+                }
+            });
+        }
+
         if (fut.isDone()) {
             try {
                 fut.get();


Mime
View raw message