This is an automated email from the ASF dual-hosted git repository. ifesdjeen pushed a commit to branch ex-sp-pl in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
commit a396b99393ed19b3995d0afbccf9340a3c413614 Author: Benedict Elliott Smith <[email protected]> AuthorDate: Sun Sep 29 11:57:06 2024 +0100 fix replay --- .../src/test/java/accord/impl/list/ListStore.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/accord-core/src/test/java/accord/impl/list/ListStore.java b/accord-core/src/test/java/accord/impl/list/ListStore.java index d2a071bd..3671e3b6 100644 --- a/accord-core/src/test/java/accord/impl/list/ListStore.java +++ b/accord-core/src/test/java/accord/impl/list/ListStore.java @@ -233,15 +233,15 @@ public class ListStore implements DataStore public void restoreFromSnapshot() { - if (snapshot == null) - return; - - data.putAll(snapshot.data); - addedAts.addAll(snapshot.addedAts); - removedAts.addAll(snapshot.removedAts); - purgedAts.addAll(snapshot.purgedAts); - fetchCompletes.addAll(snapshot.fetchCompletes); - pendingRemoves.addAll(snapshot.pendingRemoves); + if (snapshot != null) + { + data.putAll(snapshot.data); + addedAts.addAll(snapshot.addedAts); + removedAts.addAll(snapshot.removedAts); + purgedAts.addAll(snapshot.purgedAts); + fetchCompletes.addAll(snapshot.fetchCompletes); + pendingRemoves.addAll(snapshot.pendingRemoves); + } while (!pendingSnapshots.isEmpty()) pendingSnapshots.pollFirst().onCompletion.accept(false); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
