nicolas/librenms
1
0
Fork 0
mirror of https://github.com/stylersnico/librenms.git synced 2026-08-01 16:26:55 +02:00
Code Issues Packages Projects Releases Wiki Activity

index and limit

Browse Source
This commit is contained in:
Clint Armstrong
2015-08-25 11:35:22 -04:00
parent bb697a35bd
commit c9a56e248d
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
poller-service.py
+4 -5
View File
@@ -199,7 +199,8 @@ dev_query = ('SELECT device_id, status,
'AND ( last_poll_attempted < DATE_SUB(NOW(), INTERVAL {2} SECOND ) '
' OR last_poll_attempted IS NULL ) '
'{3} '
'ORDER BY next_poll asc ').format(poll_frequency,
'ORDER BY next_poll asc '
'LIMIT 5 ').format(poll_frequency,
discover_frequency,
down_retry,
poller_group)
@@ -251,11 +252,9 @@ while True:
# add queue lock, so we lock the next device against any other pollers
# if this fails, the device is locked by another poller already
if not getLock('queued.{}'.format(device_id)):
time.sleep(.5)
continue
if not lockFree('polling.{}'.format(device_id)):
releaseLock('queued.{}'.format(device_id))
time.sleep(.5)
continue
if next_poll and next_poll > datetime.now():
@@ -278,9 +277,9 @@ while True:
# If we made it this far, break out of the loop and query again.
break
# Looping with no break causes the service to be killed by init.
# This point is only reached if the query is empty, so sleep half a second before querying again.
time.sleep(.5)
# Make sure we're not holding any device queue locks in this connection before querying again.
# Make sure we're not holding any device queue locks in this connection before querying again
# by locking a different string.
getLock('unlock.{}'.format(config['distributed_poller_name']))