Reset state with snapshots

jgroups-extras · Aug 22, 2024 · 1a907f3 · 1a907f3
1 parent feb46dc
commit 1a907f3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/src/org/jgroups/raft/blocks/CounterService.java b/src/org/jgroups/raft/blocks/CounterService.java
@@ -169,6 +169,7 @@ public void writeContentTo(DataOutput out) throws Exception {
     @Override
     public void readContentFrom(DataInput in) throws Exception {
         synchronized (counters) {
+            counters.clear();
             int size = in.readInt();
             for (int i = 0; i < size; i++) {
                 AsciiString name = Bits.readAsciiString(in);

diff --git a/src/org/jgroups/raft/blocks/ReplicatedStateMachine.java b/src/org/jgroups/raft/blocks/ReplicatedStateMachine.java
@@ -237,6 +237,7 @@ public int size() {
             tmp.put(key, val);
         }
         synchronized(map) {
+            map.clear();
             map.putAll(tmp);
         }
     }