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

Properly add absent node type

This commit is contained in:
Joshua Boniface 2021-05-31 19:26:27 -04:00
parent d3b5b5236a
commit f6d0e89568
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -626,12 +626,12 @@ signal.signal(signal.SIGHUP, hup)
############################################################################### ###############################################################################
# Check if our node exists in Zookeeper, and create it if not # Check if our node exists in Zookeeper, and create it if not
if zkhandler.exists('/nodes/{}'.format(myhostname)):
logger.out("Node is " + fmt_green + "present" + fmt_end + " in Zookeeper", state='i')
if config['daemon_mode'] == 'coordinator': if config['daemon_mode'] == 'coordinator':
init_routerstate = 'secondary' init_routerstate = 'secondary'
else: else:
init_routerstate = 'client' init_routerstate = 'client'
if zkhandler.exists('/nodes/{}'.format(myhostname)):
logger.out("Node is " + fmt_green + "present" + fmt_end + " in Zookeeper", state='i')
# Update static data just in case it's changed # Update static data just in case it's changed
zkhandler.write([ zkhandler.write([
('/nodes/{}/daemonmode'.format(myhostname), config['daemon_mode']), ('/nodes/{}/daemonmode'.format(myhostname), config['daemon_mode']),
@ -651,7 +651,7 @@ else:
# Basic state information # Basic state information
('/nodes/{}/daemonmode'.format(myhostname), config['daemon_mode']), ('/nodes/{}/daemonmode'.format(myhostname), config['daemon_mode']),
('/nodes/{}/daemonstate'.format(myhostname), 'init'), ('/nodes/{}/daemonstate'.format(myhostname), 'init'),
('/nodes/{}/routerstate'.format(myhostname), 'client'), ('/nodes/{}/routerstate'.format(myhostname), init_routerstate),
('/nodes/{}/domainstate'.format(myhostname), 'flushed'), ('/nodes/{}/domainstate'.format(myhostname), 'flushed'),
('/nodes/{}/staticdata'.format(myhostname), ' '.join(staticdata)), ('/nodes/{}/staticdata'.format(myhostname), ' '.join(staticdata)),
('/nodes/{}/memtotal'.format(myhostname), '0'), ('/nodes/{}/memtotal'.format(myhostname), '0'),