Sync index between all nodes Change-Id: I79d04ca3a1b13a271089388a9140c1802c540e66
diff --git a/src/main/java/com/ericsson/gerrit/plugins/highavailability/indexsync/IndexSyncRunner.java b/src/main/java/com/ericsson/gerrit/plugins/highavailability/indexsync/IndexSyncRunner.java index 92834bd..919b139 100644 --- a/src/main/java/com/ericsson/gerrit/plugins/highavailability/indexsync/IndexSyncRunner.java +++ b/src/main/java/com/ericsson/gerrit/plugins/highavailability/indexsync/IndexSyncRunner.java
@@ -108,15 +108,17 @@ } ChangeIndexer indexer = changeIndexerFactory.create(executor, changeIndexes, false); - // NOTE: this loop will stop as soon as the initial sync is performed from one peer + boolean failed = false; for (PeerInfo peer : peers) { if (syncFrom(peer, indexer)) { - log.atFine().log("Finished indexSync"); - return true; + log.atFine().log("Finished indexSync for %s", peer.getDirectUrl()); + } else { + log.atSevere().log("Failed to sync index with %s", peer.getDirectUrl()); + failed = true; } } - return false; + return !failed; } private boolean syncFrom(PeerInfo peer, ChangeIndexer indexer) {