Repository: ignite
Updated Branches:
  refs/heads/master b7fcbb05e -> 9249efda5


IGNITE-8658 Add info message for complete partition exchange

Signed-off-by: Andrey Gura <[email protected]>


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

Branch: refs/heads/master
Commit: 9249efda531390c73e28672304bd34588ffb5d42
Parents: b7fcbb0
Author: mcherkasov <[email protected]>
Authored: Fri Jun 1 17:09:14 2018 +0300
Committer: Andrey Gura <[email protected]>
Committed: Fri Jun 1 17:09:14 2018 +0300

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


http://git-wip-us.apache.org/repos/asf/ignite/blob/9249efda/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 b47084a..c391403 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
@@ -1772,6 +1772,9 @@ public class GridDhtPartitionsExchangeFuture extends 
GridDhtTopologyFutureAdapte
             if (log.isDebugEnabled())
                 log.debug("Completed partition exchange [localNode=" + 
cctx.localNodeId() + ", exchange= " + this +
                     ", durationFromInit=" + (U.currentTimeMillis() - initTs) + 
']');
+            else if(log.isInfoEnabled())
+                log.info("Completed partition exchange [localNode=" + 
cctx.localNodeId() + ", exchange=" + shortInfo() +
+                     ", topVer=" + topologyVersion() + ", durationFromInit=" + 
(U.currentTimeMillis() - initTs) + ']');
 
             initFut.onDone(err == null);
 

Reply via email to