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 07:46:54 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1924 3ae3beace -> ca0d256df


Ignite 1924


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

Branch: refs/heads/ignite-1924
Commit: ca0d256df7ba1ac1509b5a9ff2f9ca1794098bc4
Parents: 3ae3bea
Author: Anton Vinogradov <av@apache.org>
Authored: Wed Nov 25 10:46:42 2015 +0300
Committer: Anton Vinogradov <av@apache.org>
Committed: Wed Nov 25 10:46:42 2015 +0300

----------------------------------------------------------------------
 .../ignite/spi/communication/tcp/TcpCommunicationSpi.java    | 8 ++++++++
 1 file changed, 8 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/ca0d256d/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
index 68e2f43..6ea2847 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
@@ -62,7 +62,10 @@ import org.apache.ignite.internal.IgniteClientDisconnectedCheckedException;
 import org.apache.ignite.internal.IgniteInternalFuture;
 import org.apache.ignite.internal.IgniteInterruptedCheckedException;
 import org.apache.ignite.internal.cluster.ClusterTopologyCheckedException;
+import org.apache.ignite.internal.managers.communication.GridIoManager;
+import org.apache.ignite.internal.managers.communication.GridIoMessage;
 import org.apache.ignite.internal.managers.eventstorage.GridLocalEventListener;
+import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemandMessage;
 import org.apache.ignite.internal.util.GridConcurrentFactory;
 import org.apache.ignite.internal.util.GridSpinReadWriteLock;
 import org.apache.ignite.internal.util.future.GridFutureAdapter;
@@ -1934,6 +1937,11 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
 
                     retry = client.sendMessage(nodeId, msg, ackC);
 
+                    if (msg instanceof GridIoMessage && ((GridIoMessage)msg).message()
instanceof GridDhtPartitionDemandMessage)
+                    {
+                        U.log(log, "B1>> " + msg);
+                    }
+
                     client.release();
 
                     client = null;


Mime
View raw message