You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/12/05 14:41:38 UTC
[16/50] [abbrv] ignite git commit: added debug for hanging exchange -
10.11.2016
added debug for hanging exchange - 10.11.2016
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/4bf1c460
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/4bf1c460
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/4bf1c460
Branch: refs/heads/ignite-comm-balance-master
Commit: 4bf1c4604108679227bbcfdd755bc2b9e4fd1a08
Parents: cee9cc6
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Thu Nov 10 20:42:50 2016 +0300
Committer: Yakov Zhdanov <yz...@gridgain.com>
Committed: Thu Nov 10 20:42:50 2016 +0300
----------------------------------------------------------------------
.../main/java/org/apache/ignite/internal/IgniteKernal.java | 3 ---
.../processors/cache/GridCachePartitionExchangeManager.java | 2 --
.../dht/preloader/GridDhtPartitionsExchangeFuture.java | 8 --------
.../ignite/internal/util/future/GridFutureAdapter.java | 6 +++---
4 files changed, 3 insertions(+), 16 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/4bf1c460/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
index e256df8..4fbf4e5 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
@@ -1104,9 +1104,6 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable {
" ^-- Outbound messages queue [size=" + m.getOutboundMessagesQueueSize() + "]";
log.info(msg);
-
- // TODO
- ctx.io().dumpStats();
}
catch (IgniteClientDisconnectedException ignore) {
// No-op.
http://git-wip-us.apache.org/repos/asf/ignite/blob/4bf1c460/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 09055ed..8495425 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
@@ -1080,8 +1080,6 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
}
else {
if (msg.client()) {
- U.debug(log, ">>> Received partitions from client [node=" + node + ", msg=" + msg + ']');
-
final GridDhtPartitionsExchangeFuture exchFut = exchangeFuture(msg.exchangeId(),
null,
null,
http://git-wip-us.apache.org/repos/asf/ignite/blob/4bf1c460/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 d7a79d2..80b3768 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
@@ -955,9 +955,6 @@ public class GridDhtPartitionsExchangeFuture extends GridFutureAdapter<AffinityT
try {
cctx.io().send(node, m, SYSTEM_POOL);
-
- U.debug(log, ">>> Sent local partitions [node=" + node + ", clientOnly=" + clientOnlyExchange +
- ", m=" + m + ']');
}
catch (ClusterTopologyCheckedException e) {
if (log.isDebugEnabled())
@@ -1183,9 +1180,6 @@ public class GridDhtPartitionsExchangeFuture extends GridFutureAdapter<AffinityT
if (!centralizedAff)
sendAllPartitions(node.id(), cctx.gridConfig().getNetworkSendRetryCount());
-
- if (msg.client())
- U.debug(log, ">>> Sent all partitions to client [node=" + node + ", msg=" + msg + ']');
}
else {
initFut.listen(new CI1<IgniteInternalFuture<Boolean>>() {
@@ -1350,8 +1344,6 @@ public class GridDhtPartitionsExchangeFuture extends GridFutureAdapter<AffinityT
final UUID nodeId = node.id();
- U.debug(log, "Received partitions full map [node=" + node + ", msg=" + msg + ']');
-
if (isDone()) {
if (log.isDebugEnabled())
log.debug("Received message for finished future [msg=" + msg + ", fut=" + this + ']');
http://git-wip-us.apache.org/repos/asf/ignite/blob/4bf1c460/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java
index cad4486..2e5b1b8 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java
@@ -200,9 +200,9 @@ public class GridFutureAdapter<R> implements IgniteInternalFuture<R> {
else if (Thread.interrupted()) {
interrupted = true;
-// TODO
-// if (!ignoreInterrupts)
-// throw new IgniteInterruptedCheckedException("Thread has been interrupted.");
+
+ // TODO ignore interrupts support
+ throw new IgniteInterruptedCheckedException("Thread has been interrupted.");
}
}
}