parallelvirtualcluster
/
pvc
1
0
Fork 0
Code Issues 11 Pull Requests Projects Releases 109 Wiki Activity

Rename update_zookeeper function to node_keepalive

This commit is contained in:
Joshua Boniface 2020-06-06 12:48:44 -04:00
parent ce60836c34
commit c1956072f0
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
node-daemon/pvcnoded/Daemon.py
View File

@ -80,9 +80,9 @@ def startKeepaliveTimer():
update_timer = apscheduler.schedulers.background.BackgroundScheduler() update_timer = apscheduler.schedulers.background.BackgroundScheduler()
interval = int(config['keepalive_interval']) interval = int(config['keepalive_interval'])
logger.out('Starting keepalive timer ({} second interval)'.format(interval), state='s') logger.out('Starting keepalive timer ({} second interval)'.format(interval), state='s')
update_timer.add_job(update_zookeeper, 'interval', seconds=interval) update_timer.add_job(node_keepalive, 'interval', seconds=interval)
update_timer.start() update_timer.start()
update_zookeeper() node_keepalive()
return update_timer return update_timer
def stopKeepaliveTimer(): def stopKeepaliveTimer():
@ -591,7 +591,7 @@ def cleanup():
pass pass
logger.out('Performing final keepalive update', state='s') logger.out('Performing final keepalive update', state='s')
update_zookeeper() node_keepalive()
# Set stop state in Zookeeper # Set stop state in Zookeeper
zkhandler.writedata(zk_conn, { '/nodes/{}/daemonstate'.format(myhostname): 'stop' }) zkhandler.writedata(zk_conn, { '/nodes/{}/daemonstate'.format(myhostname): 'stop' })
@ -1011,8 +1011,8 @@ if enable_storage:
# PHASE 9 - Run the daemon # PHASE 9 - Run the daemon
############################################################################### ###############################################################################
# Zookeeper keepalive update function # Keepalive update function
def update_zookeeper(): def node_keepalive():
# Set the upstream IP in Zookeeper for clients to read # Set the upstream IP in Zookeeper for clients to read
if config['enable_networking']: if config['enable_networking']:
if this_node.router_state == 'primary': if this_node.router_state == 'primary':