ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [44/50] ignite git commit: Added partition release future timing
Date Tue, 11 Jul 2017 09:27:43 GMT
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/master
Commit: 33ae472fc47c8983e48ac0febe22f11457c89ba1
Parents: 2ac3908
Author: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Authored: Mon Jul 10 17:18:18 2017 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@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());
 


Mime
View raw message