GG-19492 Add debug output for o.a.i.internal.processors.cache.persist…

…ence.GridCacheOffheapManager#restorePartitionStates method.
gridgain · Jul 4, 2019 · 621f6af · 621f6af
1 parent e74ae12
commit 621f6af
Showing 1 changed file with 13 additions and 3 deletions.
diff --git a/...java/org/apache/ignite/internal/processors/cache/persistence/GridCacheOffheapManager.java b/...java/org/apache/ignite/internal/processors/cache/persistence/GridCacheOffheapManager.java
@@ -490,6 +490,8 @@ else if (needSnapshot)
         for (int p = 0; p < grp.affinity().partitions(); p++) {
             Integer recoverState = partitionRecoveryStates.get(new GroupPartitionId(grp.groupId(), p));
 
+            long startTime = U.currentTimeMillis();
+
             if (ctx.pageStore().exists(grp.groupId(), p)) {
                 ctx.pageStore().ensure(grp.groupId(), p);
 
@@ -534,7 +536,8 @@ else if (needSnapshot)
                                 if (log.isDebugEnabled())
                                     log.debug("Restored partition state (from WAL) " +
                                         "[grp=" + grp.cacheOrGroupName() + ", p=" + p + ", state=" + part.state() +
-                                        ", updCntr=" + part.initialUpdateCounter() + "]");
+                                        ", updCntr=" + part.initialUpdateCounter() +
+                                        ", size=" + part.fullSize() + "]");
                             }
                             else {
                                 int stateId = (int) io.getPartitionState(pageAddr);
@@ -544,7 +547,8 @@ else if (needSnapshot)
                                 if (log.isDebugEnabled())
                                     log.debug("Restored partition state (from page memory) " +
                                         "[grp=" + grp.cacheOrGroupName() + ", p=" + p + ", state=" + part.state() +
-                                        ", updCntr=" + part.initialUpdateCounter() + ", stateId=" + stateId + "]");
+                                        ", updCntr=" + part.initialUpdateCounter() + ", stateId=" + stateId +
+                                        ", size=" + part.fullSize() + "]");
                             }
                         }
                         finally {
@@ -569,13 +573,19 @@ else if (recoverState != null) { // Pre-create partition if having valid state.
                 if (log.isDebugEnabled())
                     log.debug("Restored partition state (from WAL) " +
                         "[grp=" + grp.cacheOrGroupName() + ", p=" + p + ", state=" + part.state() +
-                        ", updCntr=" + part.initialUpdateCounter() + "]");
+                        ", updCntr=" + part.initialUpdateCounter() +
+                        ", size=" + part.fullSize() + "]");
             }
             else {
                 if (log.isDebugEnabled())
                     log.debug("Skipping partition on recovery (no page store OR wal state) " +
                         "[grp=" + grp.cacheOrGroupName() + ", p=" + p + "]");
             }
+
+            if (log.isDebugEnabled())
+                log.debug("Finished restoring partition state " +
+                    "[grp=" + grp.cacheOrGroupName() + ", p=" + p +
+                    ", time=" + (U.currentTimeMillis() - startTime) + " ms]");
         }
 
         partitionStatesRestored = true;