in src/main/java/com/googlesource/gerrit/plugins/multisite/forwarder/ForwardedIndexingHandler.java [61:85]
public void index(T id, Operation operation, Optional<E> event) throws IOException {
log.debug("{} {} {}", operation, id, event);
try {
Context.setForwardedEvent(true);
Lock idLock = idLocks.get(id);
idLock.lock();
try {
switch (operation) {
case INDEX:
doIndex(id, event);
break;
case DELETE:
doDelete(id, event);
break;
default:
log.error("unexpected operation: {}", operation);
break;
}
} finally {
idLock.unlock();
}
} finally {
Context.unsetForwardedEvent();
}
}