nicolas/librenms
1
0
Fork 0
mirror of https://github.com/stylersnico/librenms.git synced 2026-07-12 16:06:25 +02:00
Code Issues Packages Projects Releases Wiki Activity

make sure to clear the thread if unsuccessful

Browse Source
This commit is contained in:
Clint Armstrong
2015-09-02 14:42:57 -04:00
parent 8d7a937e03
commit b7ecea9323
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
poller-service.py
+8 -2
View File
@@ -200,7 +200,10 @@ def getThreadQueueLock(device_id):
for thread_cursor in thread_cursors:
if not thread_cursor.in_use:
thread_cursor.in_use = 'queue.{0}'.format(device_id)
return getLock('queue.{0}'.format(device_id), thread_cursor.cursor)
if getLock('queue.{0}'.format(device_id), thread_cursor.cursor):
return True
else:
thread_cursor.in_use = False
time.sleep(.5)
@@ -210,7 +213,10 @@ def getThreadActionLock(device_id, action):
for thread_cursor in thread_cursors:
if thread_cursor.in_use == 'queue.{0}'.format(device_id):
thread_cursor.in_use = '{0}.{1}'.format(action, device_id)
return getLock('{0}.{1}'.format(action, device_id), thread_cursor.cursor)
if getLock('{0}.{1}'.format(action, device_id), thread_cursor.cursor):
return True
else:
thread_cursor.in_use = False
return False