Merge branch 'stable-3.6' into stable-3.7 * stable-3.6: Do not take draft comments into account for change index up-to-date Enhance indexing logging Change-Id: I9232e99ff02682b0c0450f69e0554db8d5ce5a2a
diff --git a/src/main/java/com/googlesource/gerrit/plugins/multisite/index/ChangeCheckerImpl.java b/src/main/java/com/googlesource/gerrit/plugins/multisite/index/ChangeCheckerImpl.java index 7373bcc..063d7bf 100644 --- a/src/main/java/com/googlesource/gerrit/plugins/multisite/index/ChangeCheckerImpl.java +++ b/src/main/java/com/googlesource/gerrit/plugins/multisite/index/ChangeCheckerImpl.java
@@ -14,10 +14,7 @@ package com.googlesource.gerrit.plugins.multisite.index; -import com.google.gerrit.entities.Change; -import com.google.gerrit.entities.HumanComment; import com.google.gerrit.exceptions.StorageException; -import com.google.gerrit.server.CommentsUtil; import com.google.gerrit.server.change.ChangeFinder; import com.google.gerrit.server.config.GerritInstanceId; import com.google.gerrit.server.git.GitRepositoryManager; @@ -42,7 +39,6 @@ public class ChangeCheckerImpl implements ChangeChecker { private static final Logger log = LoggerFactory.getLogger(ChangeCheckerImpl.class); private final GitRepositoryManager gitRepoMgr; - private final CommentsUtil commentsUtil; private final OneOffRequestContext oneOffReqCtx; private final String changeId; private final ChangeFinder changeFinder; @@ -57,14 +53,12 @@ @Inject public ChangeCheckerImpl( GitRepositoryManager gitRepoMgr, - CommentsUtil commentsUtil, ChangeFinder changeFinder, OneOffRequestContext oneOffReqCtx, @GerritInstanceId String instanceId, @Assisted String changeId) { this.changeFinder = changeFinder; this.gitRepoMgr = gitRepoMgr; - this.commentsUtil = commentsUtil; this.oneOffReqCtx = oneOffReqCtx; this.changeId = changeId; this.instanceId = instanceId; @@ -177,20 +171,7 @@ } private Optional<Long> computeLastChangeTs() { - return getChangeNotes().map(notes -> getTsFromChangeAndDraftComments(notes)); - } - - private long getTsFromChangeAndDraftComments(ChangeNotes notes) { - Change change = notes.getChange(); - Timestamp changeTs = Timestamp.from(change.getLastUpdatedOn()); - try { - for (HumanComment comment : commentsUtil.draftByChange(changeNotes.get())) { - Timestamp commentTs = comment.writtenOn; - changeTs = commentTs.after(changeTs) ? commentTs : changeTs; - } - } catch (StorageException e) { - log.warn("Unable to access draft comments for change {}", change, e); - } - return changeTs.getTime() / 1000; + return getChangeNotes() + .map(notes -> Timestamp.from(notes.getChange().getLastUpdatedOn()).getTime() / 1000); } }
diff --git a/src/main/java/com/googlesource/gerrit/plugins/multisite/index/IndexEventHandler.java b/src/main/java/com/googlesource/gerrit/plugins/multisite/index/IndexEventHandler.java index ee16b07..4369619 100644 --- a/src/main/java/com/googlesource/gerrit/plugins/multisite/index/IndexEventHandler.java +++ b/src/main/java/com/googlesource/gerrit/plugins/multisite/index/IndexEventHandler.java
@@ -178,7 +178,9 @@ @Override public String toString() { - return String.format("Index change %s in target instance", changeIndexEvent.changeId); + return String.format( + "Index change %s for project %s produced by instance %s", + changeIndexEvent.changeId, changeIndexEvent.projectName, changeIndexEvent.instanceId); } } @@ -209,7 +211,9 @@ @Override public String toString() { - return String.format("Index change %s in target instance", changeIndexEvent.changeId); + return String.format( + "Index change %s for project %s produced by instance %s", + changeIndexEvent.changeId, changeIndexEvent.projectName, changeIndexEvent.instanceId); } }