Evidence of duplicate acquires. Try to eliminate

CDLUC3 · Feb 5, 2025 · 8307d5d · 8307d5d
1 parent ba0ed10
commit 8307d5d
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/main/java/org/cdlib/mrt/zk/QueueItem.java b/src/main/java/org/cdlib/mrt/zk/QueueItem.java
@@ -280,8 +280,10 @@ public void setStatusTrigger(ZooKeeper client) throws MerrittZKNodeInvalid, Keep
   public boolean lock(ZooKeeper client) throws InterruptedException {
     String statpath = makePath(ZKKey.LOCK);
     try {
-      QueueItemHelper.createEphemeral(client, statpath, QueueItemHelper.empty);
-      return true;  
+      if (! QueueItemHelper.createEphemeral(client, statpath, QueueItemHelper.empty).isEmpty()) 
+      	return true;  
+      else 
+	return false;
     } catch(KeeperException e) {
       return false;
     }