stepus53/dhfs
1
0
Fork 0
mirror of https://github.com/usatiuk/dhfs.git synced 2025-10-28 20:47:49 +01:00
Code Issues Packages Projects Releases Wiki Activity

Server: dump op compare fix

Browse Source
This commit is contained in:
Stepan Usatiuk
2024-10-09 22:53:18 +02:00
parent 1e77b9b94d
commit aeaca7c051
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/jkleppmanntree/JKleppmannTreeManager.java
View File

@@ -14,10 +14,7 @@ import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;
import org.apache.commons.lang3.tuple.Pair;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import java.util.UUID;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Function;
@@ -125,7 +122,7 @@ public class JKleppmannTreeManager {
_persistentData.get().runWriteLockedVoid(JObjectManager.ResolutionStrategy.LOCAL_ONLY, (m, d, b, v) -> {
_persistentData.get().bumpVer();
var got = d.getQueues().get(host).pollFirstEntry().getValue();
if (jop.getOp() != got) {
if (!Objects.equals(jop.getOp(), got)) {
throw new IllegalArgumentException("Committed op push was not the oldest");
}
});