ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-4154
Date Mon, 14 Nov 2016 11:06:43 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-4154-opt2 283b23237 -> db93ec4ba


ignite-4154


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/db93ec4b
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/db93ec4b
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/db93ec4b

Branch: refs/heads/ignite-4154-opt2
Commit: db93ec4baf34d1831b198705ea6927666cf65e57
Parents: 283b232
Author: sboikov <sboikov@gridgain.com>
Authored: Mon Nov 14 14:06:36 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Mon Nov 14 14:06:36 2016 +0300

----------------------------------------------------------------------
 .../dht/preloader/GridDhtPartitionsExchangeFuture.java        | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/db93ec4b/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 468e16e..3ae7e7d 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
@@ -803,8 +803,13 @@ public class GridDhtPartitionsExchangeFuture extends GridFutureAdapter<AffinityT
             if (cctx.exchange().skipFirstExchangeMessage() && discoEvt.type() ==
EVT_NODE_JOINED && discoEvt.eventNode().isLocal())
                 skipSnd = true;
 
-            if (!skipSnd)
+            if (!skipSnd) {
+                long sendStart = System.currentTimeMillis();
+
                 sendPartitions(crd);
+
+                log.info("Send parts time [topVer=" + topologyVersion() + ", time=" + (System.currentTimeMillis()
- sendStart) + ']');
+            }
             else
                 log.info("Skip first exchange message [topVer=" + topologyVersion() + ']');
         }


Mime
View raw message