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

race fix in writeback

Browse Source
This commit is contained in:
Stepan Usatiuk
2025-02-23 18:43:08 +01:00
parent 3720280cd7
commit d7a2627c93
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
dhfs-parent/objects/src/main/java/com/usatiuk/dhfs/objects/WritebackObjectPersistentStore.java
View File

@@ -232,20 +232,20 @@ public class WritebackObjectPersistentStore {
verifyReady();
_pendingWritesVersionLock.writeLock().lock();
try {
var curPw = _pendingWrites.get();
for (var e : ((TxBundleImpl) bundle)._entries.values()) {
switch (e) {
case TxBundleImpl.CommittedEntry c -> {
curPw = curPw.plus(c.key(), new PendingWrite(c.data, bundle.getId()));
}
case TxBundleImpl.DeletedEntry d -> {
curPw = curPw.plus(d.key(), new PendingDelete(d.key, bundle.getId()));
}
default -> throw new IllegalStateException("Unexpected value: " + e);
}
}
_pendingWrites.set(curPw);
synchronized (_pendingBundles) {
var curPw = _pendingWrites.get();
for (var e : ((TxBundleImpl) bundle)._entries.values()) {
switch (e) {
case TxBundleImpl.CommittedEntry c -> {
curPw = curPw.plus(c.key(), new PendingWrite(c.data, bundle.getId()));
}
case TxBundleImpl.DeletedEntry d -> {
curPw = curPw.plus(d.key(), new PendingDelete(d.key, bundle.getId()));
}
default -> throw new IllegalStateException("Unexpected value: " + e);
}
}
_pendingWrites.set(curPw);
((TxBundleImpl) bundle).setReady();
_pendingWritesVersion.incrementAndGet();
if (_pendingBundles.peek() == bundle)