mirror/librenms-librenms
1
0
Fork 0
mirror of https://github.com/librenms/librenms.git synced 2024-10-07 16:52:45 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fixed race conditions in distributed poller setup (#11307)

Browse Source
This commit is contained in:
vsessink
2020-04-10 05:38:49 +02:00
committed by GitHub
parent e9a3317749
commit 123a669386
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
poller-wrapper.py
View File

@@ -157,20 +157,20 @@ if ('distributed_poller' in config and
import uuid
memc = memcache.Client([config['distributed_poller_memcached_host'] + ':' +
str(config['distributed_poller_memcached_port'])])
if str(memc.get(master_tag)) == config['distributed_poller_name']:
print "This system is already joined as the poller master."
sys.exit(2)
if memc_alive():
if memc.get(master_tag) is None:
distpoll = True
memc.add(nodes_tag, 0, step)
if memc.add(master_tag, config['distributed_poller_name'], 10):
print "Registered as Master"
memc.set(master_tag, config['distributed_poller_name'], 10)
memc.set(nodes_tag, 0, step)
IsNode = False
else:
print "Registered as Node joining Master %s" % memc.get(master_tag)
IsNode = True
memc.incr(nodes_tag)
distpoll = True
if str(memc.get(master_tag)) == config['distributed_poller_name']:
print "This system is already joined as the poller master."
sys.exit(2)
else:
print "Registered as Node joining Master %s" % memc.get(master_tag)
memc.incr(nodes_tag)
IsNode = True
else:
print "Could not connect to memcached, disabling distributed poller."
distpoll = False