cerc-io/stack-orchestrator
17
1
Fork 3
Code Issues 113 Pull Requests 18 Actions Packages Projects Releases 480 Wiki Activity

Use non-blocking mutex on registry CLI with retry on error

Browse Source
This commit is contained in:
Prathamesh Musale 2024-10-28 14:32:19 +05:30
parent 5f8e809b2d
commit 59e12f0ab1
1 changed files with 20 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
stack_orchestrator/deploy/webapp/registry_mutex.py
View File

@ -1,9 +1,12 @@
import fcntl
from functools import wraps
import time
# Define default file path for the lock
DEFAULT_LOCK_FILE_PATH = "/tmp/registry_mutex_lock_file"
LOCK_RETRY_INTERVAL = 3
def registry_mutex():
def decorator(func):
@ -13,16 +16,25 @@ def registry_mutex():
if self.mutex_lock_file:
lock_file_path = self.mutex_lock_file
result = None
with open(lock_file_path, 'w') as lock_file:
while True:
try:
# Try to acquire the lock
fcntl.flock(lock_file, fcntl.LOCK_EX)
fcntl.flock(lock_file, fcntl.LOCK_EX | fcntl.LOCK_NB)
print(f"Registry lock acquired, {lock_file_path}")
# Call the actual function
result = func(self, *args, **kwargs)
finally:
break
except BlockingIOError:
# Retry on error
print(f"Not able to acquire lock on {lock_file_path}, retrying in {LOCK_RETRY_INTERVAL}s...")
time.sleep(LOCK_RETRY_INTERVAL)
# Always release the lock
fcntl.flock(lock_file, fcntl.LOCK_UN)
print(f"Registry lock released, {lock_file_path}")
return result