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 <[email protected]> Authored: Mon Nov 14 14:06:36 2016 +0300 Committer: sboikov <[email protected]> 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() + ']'); }
