Migrating to latest Atomix
Change-Id: Ie636d1b2623b7f83572dca0d70bd56734379e61a
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixLeaderElectorState.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixLeaderElectorState.java
index df04e6d..894cc79 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixLeaderElectorState.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixLeaderElectorState.java
@@ -302,8 +302,10 @@
* @return topic to leader mapping
*/
public Map<String, Leadership> allLeaderships(Commit<? extends GetAllLeaderships> commit) {
+ Map<String, Leadership> result = new HashMap<>();
try {
- return Maps.transformEntries(elections, (k, v) -> leadership(k));
+ result.putAll(Maps.transformEntries(elections, (k, v) -> leadership(k)));
+ return result;
} finally {
commit.close();
}
@@ -539,7 +541,7 @@
byte[] encodedElections = serializer.encode(elections);
writer.writeInt(encodedElections.length);
writer.write(encodedElections);
- log.info("Took state machine snapshot");
+ log.debug("Took state machine snapshot");
}
@Override
@@ -552,7 +554,7 @@
byte[] encodedElections = new byte[encodedElectionsSize];
reader.read(encodedElections);
elections = serializer.decode(encodedElections);
- log.info("Reinstated state machine from snapshot");
+ log.debug("Reinstated state machine from snapshot");
}
private AtomicLong termCounter(String topic) {