Repository: ignite Updated Branches: refs/heads/ignite-slow-rebal 663a2d993 -> 4d61a0f0c
debug Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/4d61a0f0 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/4d61a0f0 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/4d61a0f0 Branch: refs/heads/ignite-slow-rebal Commit: 4d61a0f0c95b16f701993e5a3131ebdcf1beb67c Parents: 663a2d9 Author: Alexey Goncharuk <[email protected]> Authored: Thu Oct 1 13:07:40 2015 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Thu Oct 1 13:07:40 2015 +0300 ---------------------------------------------------------------------- .../dht/preloader/GridDhtPartitionsExchangeFuture.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/4d61a0f0/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 3cf0eb0..eaa5584 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 @@ -1196,6 +1196,8 @@ public class GridDhtPartitionsExchangeFuture extends GridFutureAdapter<AffinityT if (match) { boolean allReceived; + long start = U.currentTimeMillis(); + synchronized (rcvdIds) { if (rcvdIds.add(nodeId)) updatePartitionSingleMap(msg); @@ -1203,6 +1205,8 @@ public class GridDhtPartitionsExchangeFuture extends GridFutureAdapter<AffinityT allReceived = allReceived(); } + long end = U.currentTimeMillis(); + // If got all replies, and initialization finished, and reply has not been sent yet. if (allReceived && ready.get() && replied.compareAndSet(false, true)) { spreadPartitions(); @@ -1212,7 +1216,7 @@ public class GridDhtPartitionsExchangeFuture extends GridFutureAdapter<AffinityT else if (log.isDebugEnabled()) log.debug("Exchange future full map is not sent [allReceived=" + allReceived() + ", ready=" + ready + ", replied=" + replied.get() + ", init=" + init.get() + - ", fut=" + this + ']'); + ", fut=" + GridDhtPartitionsExchangeFuture.this + ", updateDur=" + (end - start) + ']'); } } });
