Merge pull request #8 from CDLUC3/lockLogic

Evidence of duplicate acquires. Try to eliminate
CDLUC3 · Feb 5, 2025 · 2142a28 · 2142a28
2 parents ba0ed10 + 8307d5d
commit 2142a28
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;
     }