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

writeback leak fix

Browse Source
This commit is contained in:
Stepan Usatiuk
2025-01-02 22:34:56 +01:00
parent 2fe3cfc3f8
commit f93b3226d0
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
dhfs-parent/objects/src/main/java/com/usatiuk/dhfs/objects/TxWritebackImpl.java
View File

@@ -148,7 +148,7 @@ public class TxWritebackImpl implements TxWriteback {
synchronized (_pendingBundles) {
bundle._entries.values().forEach(e -> {
var cur = _pendingWrites.get(e.key());
if (cur.bundleId() == bundle.getId())
if (cur.bundleId() <= bundle.getId())
_pendingWrites.remove(e.key(), cur);
});
}
@@ -280,7 +280,7 @@ public class TxWritebackImpl implements TxWriteback {
@Override
public Optional<PendingWriteEntry> getPendingWrite(JObjectKey key) {
synchronized (_pendingWrites) {
synchronized (_pendingBundles) {
return Optional.ofNullable(_pendingWrites.get(key));
}
}