NoteDbMigrator: log total progress of the migration every 1000 changes

Change-Id: I3cd0af886f7d8713ed370f8b9a58770e1d45b8e3

1 files changed, 7 insertions, 0 deletions

diff --git a/java/com/google/gerrit/server/notedb/rebuild/NoteDbMigrator.java b/java/com/google/gerrit/server/notedb/rebuild/NoteDbMigrator.java
index 12da1a2a7f..4f2f9ab62c 100644
--- a/java/com/google/gerrit/server/notedb/rebuild/NoteDbMigrator.java
+++ b/java/com/google/gerrit/server/notedb/rebuild/NoteDbMigrator.java
@@ -93,6 +93,7 @@ import java.util.List;
 import java.util.Optional;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicLong;
 import java.util.function.Consumer;
 import java.util.function.Predicate;
 import org.eclipse.jgit.errors.ConfigInvalidException;
@@ -443,6 +444,8 @@ public class NoteDbMigrator implements AutoCloseable {
   private final int sequenceGap;
   private final boolean autoMigrate;
 
+  private final AtomicLong globalChangeCounter = new AtomicLong();
+
   private NoteDbMigrator(
       SitePaths sitePaths,
       SchemaFactory<ReviewDb> schemaFactory,
@@ -972,6 +975,10 @@ public class NoteDbMigrator implements AutoCloseable {
             logger.atSevere().withCause(t).log("Failed to rebuild change %s", changeId);
             ok = false;
           }
+          long cnt = globalChangeCounter.incrementAndGet();
+          if (cnt % 1000 == 0) {
+            logger.atInfo().log("Total number of rebuilt changes %d", cnt);
+          }
           pm.update(1);
         }
         logger.atInfo().log(