From 8307d5d0d63f1d15d25f766267b8e904db360b69 Mon Sep 17 00:00:00 2001 From: mreyescdl Date: Wed, 5 Feb 2025 11:09:46 -0800 Subject: [PATCH] Evidence of duplicate acquires. Try to eliminate --- src/main/java/org/cdlib/mrt/zk/QueueItem.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/cdlib/mrt/zk/QueueItem.java b/src/main/java/org/cdlib/mrt/zk/QueueItem.java index 50ff62b..460049b 100644 --- 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; }