Merge pull request #9 from CDLUC3/lockLogic

More logic for acquire lock. Is it needed?
CDLUC3 · Feb 7, 2025 · 6557bf6 · 6557bf6
2 parents 2142a28 + 16d55cf
commit 6557bf6
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/org/cdlib/mrt/zk/QueueItem.java b/src/main/java/org/cdlib/mrt/zk/QueueItem.java
@@ -280,7 +280,8 @@ public void setStatusTrigger(ZooKeeper client) throws MerrittZKNodeInvalid, Keep
   public boolean lock(ZooKeeper client) throws InterruptedException {
     String statpath = makePath(ZKKey.LOCK);
     try {
-      if (! QueueItemHelper.createEphemeral(client, statpath, QueueItemHelper.empty).isEmpty()) 
+      if (client.exists(statpath, null) != null) return false;
+      if (QueueItemHelper.createEphemeral(client, statpath, QueueItemHelper.empty).equals(statpath)) 
       	return true;  
       else 
 	return false;