You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by dp...@apache.org on 2018/05/29 15:41:45 UTC
ignite git commit: IGNITE-8636 debug logging for client join
scenario. - Fixes #4087.
Repository: ignite
Updated Branches:
refs/heads/master 79ca7a25a -> 79278e074
IGNITE-8636 debug logging for client join scenario. - Fixes #4087.
Signed-off-by: Dmitriy Pavlov <dp...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/79278e07
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/79278e07
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/79278e07
Branch: refs/heads/master
Commit: 79278e074e313e9ca23b5ccc97926e1f5d5cc031
Parents: 79ca7a2
Author: Sergey Chugunov <se...@gmail.com>
Authored: Tue May 29 18:39:02 2018 +0300
Committer: Dmitriy Pavlov <dp...@apache.org>
Committed: Tue May 29 18:39:02 2018 +0300
----------------------------------------------------------------------
.../GridCachePartitionExchangeManager.java | 10 ++++++--
.../GridDhtPartitionsExchangeFuture.java | 26 +++++++++++++++++++-
2 files changed, 33 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/79278e07/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
index c3a0add..6533bbc 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
@@ -1552,8 +1552,14 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
if (updated)
scheduleResendPartitions();
}
- else
- exchangeFuture(msg.exchangeId(), null, null, null, null).onReceiveSingleMessage(node, msg);
+ else {
+ GridDhtPartitionsExchangeFuture exchFut = exchangeFuture(msg.exchangeId(), null, null, null, null);
+
+ if (log.isDebugEnabled())
+ log.debug("Notifying exchange future about single message: " + exchFut);
+
+ exchFut.onReceiveSingleMessage(node, msg);
+ }
}
finally {
leaveBusy();
http://git-wip-us.apache.org/repos/asf/ignite/blob/79278e07/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
index 317fde2..b47084a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
@@ -2092,6 +2092,9 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
if (mergedWith0 != null) {
mergedWith0.processMergedMessage(node, msg);
+ if (log.isDebugEnabled())
+ log.debug("Merged message processed, message handling finished: " + msg);
+
return;
}
@@ -2117,6 +2120,9 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
* @param msg Client's message.
*/
public void waitAndReplyToNode(final UUID nodeId, final GridDhtPartitionsSingleMessage msg) {
+ if (log.isDebugEnabled())
+ log.debug("Single message will be handled on completion of exchange future: " + this);
+
listen(new CI1<IgniteInternalFuture<AffinityTopologyVersion>>() {
@Override public void apply(IgniteInternalFuture<AffinityTopologyVersion> fut) {
if (cctx.kernalContext().isStopping())
@@ -2133,8 +2139,17 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
ClusterNode node = cctx.node(nodeId);
- if (node == null)
+ if (node == null) {
+ if (log.isDebugEnabled()) {
+ log.debug("No node found for nodeId: " +
+ nodeId +
+ ", handling of single message will be stopped: " +
+ msg
+ );
+ }
+
return;
+ }
finishState0 = new FinishState(cctx.localNodeId(),
initialVersion(),
@@ -2201,6 +2216,8 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
", allReceived=" + allReceived + ']');
}
}
+ else if (log.isDebugEnabled())
+ log.debug("Coordinator received single message it didn't expect to receive: " + msg);
break;
}
@@ -2879,6 +2896,13 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
try {
cctx.io().send(node, fullMsg, SYSTEM_POOL);
+
+ if (log.isDebugEnabled()) {
+ log.debug("Full message was sent to node: " +
+ node +
+ ", fullMsg: " + fullMsg
+ );
+ }
}
catch (ClusterTopologyCheckedException e) {
if (log.isDebugEnabled())