cleanup

Author: sanderegg

packages/service-library/src/servicelib/redis/lua/acquire_fair_semaphore_v2.lua

@@ -1,14 +1,14 @@
 -- Fair distributed semaphore using token pool (BRPOP-based)
--- KEYS[1]: tokens_key (LIST of available tokens)
--- KEYS[2]: holders_key (SET of current holder instance IDs)
+-- KEYS[1]: holders_key (SET of current holder instance IDs)
+-- KEYS[2]: holder_key (individual holder TTL key for this instance)
 
--- ARGV[1]: instance_id
--- ARGV[2]: capacity (max concurrent holders)
--- ARGV[3]: ttl_seconds
+-- ARGV[1]: token (the token received from BRPOP)
+-- ARGV[2]: instance_id (the instance trying to acquire the semaphore)
+-- ARGV[3]: ttl_seconds (for the holder_key)
 --
 -- Returns: {exit_code, status, token, current_count}
--- exit_code: 0 if acquired, 255 if timeout/failed
--- status: 'acquired' or 'timeout'
+-- exit_code: 0 if acquired
+-- status: 'acquired'
 
 local holders_key = KEYS[1]
 local holder_key = KEYS[2]

packages/service-library/src/servicelib/redis/lua/register_semaphore_holder.lua

@@ -1,13 +1,11 @@
 -- Simple token initialization and management for Python BRPOP
 -- KEYS[1]: tokens_key (LIST of available tokens)
 -- KEYS[2]: holders_key (SET of current holder instance IDs)
--- KEYS[3]: holder_key (individual holder TTL key for this instance)
--- ARGV[1]: instance_id
--- ARGV[2]: capacity (max concurrent holders)
--- ARGV[3]: ttl_seconds
--- ARGV[4]: token (the token received from BRPOP)
+
+-- ARGV[1]: capacity (max concurrent holders)
+-- ARGV[2]: ttl_seconds
 --
--- Returns: {exit_code, status, current_count}
+-- Returns: {exit_code}
 -- exit_code: 0 if registered successfully
 
 local tokens_key = KEYS[1]

packages/service-library/src/servicelib/redis/lua/release_fair_semaphore_v2.lua

@@ -2,6 +2,7 @@
 -- KEYS[1]: tokens_key (LIST of available tokens)
 -- KEYS[2]: holders_key (SET of current holders)
 -- KEYS[3]: holder_key (individual holder TTL key for this instance)
+
 -- ARGV[1]: instance_id
 --
 -- Returns: {exit_code, status, current_count}