commit 53a4cd58dcc8fc3087c7df3be7cb74983d334a55
author Prakash Aswal <paswal@qti.qualcomm.com> Wed Sep 17 11:35:29 2025 +0530
committer Prakash Aswal <paswal@qti.qualcomm.com> Thu Sep 18 21:30:23 2025 -0700
tree bc5fab4ad5f92e9acd6d4e09a1b2d7f9f25e4cba
parent c0ecc03bd96e3b5f8a3007d1da6b4fc12314bc34

Give meaningful name to task for reindexing stale accounts

The toString() for tasks is displayed in the gerrit show-queue command,
so give meaningful names to the task for reindexing stale accounts.

Change-Id: I82b388740f58d9421c5002aec84e371db636e13c

src/main/java/com/googlesource/gerrit/plugins/remotegerritaccountcache/AccountCacheImpl.java

diff --git a/src/main/java/com/googlesource/gerrit/plugins/remotegerritaccountcache/AccountCacheImpl.java b/src/main/java/com/googlesource/gerrit/plugins/remotegerritaccountcache/AccountCacheImpl.java
index da4d57b..aff321b 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/remotegerritaccountcache/AccountCacheImpl.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/remotegerritaccountcache/AccountCacheImpl.java
@@ -77,6 +77,7 @@
 import java.util.Map;
 import java.util.Optional;
 import java.util.Set;
+import java.util.concurrent.Callable;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Future;
 import java.util.stream.Collectors;
@@ -284,6 +285,32 @@
       this.extIdsByAccount = configuredExternalIds.get();
     }
 
+    private class ReindexAccountIfStaleTask implements Callable<Boolean> {
+      private final Account.Id accountId;
+
+      public ReindexAccountIfStaleTask(Account.Id accountId) {
+        this.accountId = accountId;
+      }
+
+      @Override
+      public Boolean call() throws Exception {
+        try {
+          accountIndexerProvider.get().reindexIfStale(accountId);
+          logger.atInfo().log("Reindexing is done for account: %s", accountId);
+          return true;
+        } catch (Exception e) {
+          logger.atWarning().log(
+              "Reindexing for account: %s failed with error %s", accountId, e.getMessage());
+        }
+        return false;
+      }
+
+      @Override
+      public String toString() {
+        return "reindex-if-stale-account-" + accountId;
+      }
+    }
+
     @SuppressWarnings("unused")
     @Override
     public CachedAccountDetails load(CachedAccountDetails.Key key) throws Exception {
@@ -319,18 +346,7 @@
           accountsUpdateFactory.createWithServerIdent().insert(UPDATE_MESSAGE, accountId, update);
         }
         logger.atInfo().log("Account updated: %s", accountId);
-        Future<?> ignore =
-            executor.submit(
-                () -> {
-                  try {
-                    accountIndexerProvider.get().reindexIfStale(accountId);
-                    logger.atInfo().log("Reindexing is done for account: %s", accountId);
-                  } catch (Exception e) {
-                    logger.atWarning().log(
-                        "Reindexing for account: %s failed with error %s",
-                        accountId, e.getMessage());
-                  }
-                });
+        Future<?> ignore = executor.submit(new ReindexAccountIfStaleTask(accountId));
         return getAccountDetailsFromNoteDb(repo, key);
       }
     }