This is an automated email from the ASF dual-hosted git repository. ifesdjeen pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
commit 7d46b7c6b005425ff40085d1fad9fa87988cebca Author: Alex Petrov <[email protected]> AuthorDate: Wed Dec 4 08:59:08 2024 +0100 Fix SimulatedAccordTaskTest Patch by Alex Petrov; reviewed by Benedict Elliott Smith for CASSANDRA-20114 --- .../src/test/java/accord/impl/basic/InMemoryJournal.java | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/accord-core/src/test/java/accord/impl/basic/InMemoryJournal.java b/accord-core/src/test/java/accord/impl/basic/InMemoryJournal.java index dc676fed..a7120fad 100644 --- a/accord-core/src/test/java/accord/impl/basic/InMemoryJournal.java +++ b/accord-core/src/test/java/accord/impl/basic/InMemoryJournal.java @@ -94,15 +94,12 @@ public class InMemoryJournal implements Journal @Override public void saveCommand(int store, CommandUpdate diff, Runnable onFlush) { - if (diff == null || - diff.before == diff.after - || diff.after == null - || diff.after.saveStatus() == SaveStatus.Uninitialised) - return; - - diffsPerCommandStore.computeIfAbsent(store, (k) -> new TreeMap<>()) - .computeIfAbsent(diff.txnId, (k_) -> new ArrayList<>()) - .add(diff(diff.before, diff.after)); + if (diff != null && diff.before != diff.after && diff.after.saveStatus() == SaveStatus.Uninitialised) + { + diffsPerCommandStore.computeIfAbsent(store, (k) -> new TreeMap<>()) + .computeIfAbsent(diff.txnId, (k_) -> new ArrayList<>()) + .add(diff(diff.before, diff.after)); + } if (onFlush!= null) onFlush.run(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
