in src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/FetchRefReplicatedEventHandler.java [39:62]
public void onEvent(Event event) {
if (event instanceof FetchRefReplicatedEvent && isLocalEvent()) {
FetchRefReplicatedEvent fetchRefReplicatedEvent = (FetchRefReplicatedEvent) event;
if (!RefNames.isNoteDbMetaRef(fetchRefReplicatedEvent.getRefName())
|| !fetchRefReplicatedEvent
.getStatus()
.equals(ReplicationState.RefFetchResult.SUCCEEDED.toString())) {
return;
}
Project.NameKey projectNameKey = fetchRefReplicatedEvent.getProjectNameKey();
logger.atFine().log(
"Indexing ref '%s' for project %s",
fetchRefReplicatedEvent.getRefName(), projectNameKey.get());
Change.Id changeId = Change.Id.fromRef(fetchRefReplicatedEvent.getRefName());
if (changeId != null) {
changeIndexer.index(projectNameKey, changeId);
} else {
logger.atWarning().log(
"Couldn't get changeId from refName. Skipping indexing of change %s for project %s",
fetchRefReplicatedEvent.getRefName(), projectNameKey.get());
}
}
}