Server: parallel op sending try lock

2025-10-29 04:57:48 +01:00 · 2025-03-31 16:35:13 +02:00
parent 06335b4b99
commit cb909478dc
1 changed files with 5 additions and 1 deletions
--- a/dhfs-parent/server/src/main/java/com/usatiuk/dhfs/repository/invalidation/InvalidationQueueService.java
+++ b/dhfs-parent/server/src/main/java/com/usatiuk/dhfs/repository/invalidation/InvalidationQueueService.java
@@ -122,7 +122,11 @@ public class InvalidationQueueService {
                            continue;
                        }

-                        try (var lock = _locker.lock(e)) {
+                        try (var lock = _locker.tryLock(e)) {
+                            if (lock == null) {
+                                pushInvalidationToOne(e);
+                                continue;
+                            }
                            opPusher.doPush(e);
                            success++;
                        } catch (Exception ex) {