Added partition release future timing
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/33ae472f Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/33ae472f Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/33ae472f Branch: refs/heads/ignite-2.1 Commit: 33ae472fc47c8983e48ac0febe22f11457c89ba1 Parents: 2ac3908 Author: Alexey Goncharuk <alexey.goncha...@gmail.com> Authored: Mon Jul 10 17:18:18 2017 +0300 Committer: Alexey Goncharuk <alexey.goncha...@gmail.com> Committed: Mon Jul 10 17:18:37 2017 +0300 ---------------------------------------------------------------------- .../dht/preloader/GridDhtPartitionsExchangeFuture.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/33ae472f/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 21a3a13..5760f87 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 @@ -1042,6 +1042,8 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte int dumpCnt = 0; + long waitStart = U.currentTimeMillis(); + long nextDumpTime = 0; long futTimeout = 2 * cctx.gridConfig().getNetworkTimeout(); @@ -1062,8 +1064,11 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte } } - if (log.isDebugEnabled()) - log.debug("After waiting for partition release future: " + this); + long waitEnd = U.currentTimeMillis(); + + if (log.isInfoEnabled()) + log.info("Finished waiting for partition release future [topVer=" + exchangeId().topologyVersion() + + ", waitTime=" + (waitEnd - waitStart) + "ms]"); IgniteInternalFuture<?> locksFut = cctx.mvcc().finishLocks(exchId.topologyVersion());