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

Handle the starting of all daemons better

This commit is contained in:
Joshua Boniface 2019-03-17 01:45:17 -04:00
parent f38ab856c2
commit aee130f65f
1 changed files with 30 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
node-daemon/pvcd/Daemon.py
View File

@ -365,7 +365,7 @@ if enable_networking:
common.run_os_command('ip route add default via {} dev {}'.format(upstream_dev_gateway, upstream_dev)) common.run_os_command('ip route add default via {} dev {}'.format(upstream_dev_gateway, upstream_dev))
############################################################################### ###############################################################################
# PHASE 3 - Determine coordinator mode and start Zookeeper on coordinators # PHASE 3a - Determine coordinator mode
############################################################################### ###############################################################################
# What is the list of coordinator hosts # What is the list of coordinator hosts
@ -375,12 +375,37 @@ if myhostname in coordinator_nodes:
# We are indeed a coordinator host # We are indeed a coordinator host
config['daemon_mode'] = 'coordinator' config['daemon_mode'] = 'coordinator'
# Start the zookeeper service using systemctl # Start the zookeeper service using systemctl
logger.out('Node is a ' + logger.fmt_blue + 'coordinator' + logger.fmt_end +'; starting Zookeeper daemon', state='i') logger.out('Node is a ' + logger.fmt_blue + 'coordinator' + logger.fmt_end, state='i')
common.run_os_command('systemctl start zookeeper.service')
time.sleep(1)
else: else:
config['daemon_mode'] = 'hypervisor' config['daemon_mode'] = 'hypervisor'
###############################################################################
# PHASE 3b - Start system daemons
###############################################################################
if config['daemon_mode'] == 'coordinator':
logger.out('Starting Zookeeper daemon', state='i')
common.run_os_command('systemctl start zookeeper.service')
if enable_hypervisor:
logger.out('Starting Libvirt daemon', state='i')
common.run_os_command('systemctl start libvirtd.service')
if enable_networking:
if config['daemon_mode'] == 'coordinator':
logger.out('Starting MariaDB daemon', state='i')
common.run_os_command('systemctl start mariadb.service')
logger.out('Starting FRRouting daemon', state='i')
common.run_os_command('systemctl start frr.service')
if enable_storage:
if config['daemon_mode'] == 'coordinator':
logger.out('Starting Ceph monitor daemon', state='i')
common.run_os_command('systemctl start ceph-mon@{}'.format(myhostname))
logger.out('Starting Ceph manager daemon', state='i')
common.run_os_command('systemctl start ceph-mgr@{}'.format(myhostname))
time.sleep(1)
############################################################################### ###############################################################################
# PHASE 4 - Attempt to connect to the coordinators and start zookeeper client # PHASE 4 - Attempt to connect to the coordinators and start zookeeper client
############################################################################### ###############################################################################
@ -527,15 +552,10 @@ else:
zkhandler.writedata(zk_conn, { '/primary_node': myhostname }) zkhandler.writedata(zk_conn, { '/primary_node': myhostname })
############################################################################### ###############################################################################
# PHASE 7a - Ensure Libvirt is running on the local host # PHASE 7 - Ensure Libvirt is working
############################################################################### ###############################################################################
if enable_hypervisor: if enable_hypervisor:
# Start the zookeeper service using systemctl
logger.out('Starting Libvirt daemon', state='i')
common.run_os_command('systemctl start libvirtd.service')
time.sleep(1)
# Check that libvirtd is listening TCP # Check that libvirtd is listening TCP
libvirt_check_name = "qemu+tcp://127.0.0.1:16509/system" libvirt_check_name = "qemu+tcp://127.0.0.1:16509/system"
logger.out('Connecting to Libvirt daemon at {}'.format(libvirt_check_name), state='i') logger.out('Connecting to Libvirt daemon at {}'.format(libvirt_check_name), state='i')
@ -546,15 +566,6 @@ if enable_hypervisor:
logger.out('ERROR: Failed to connect to Libvirt daemon: {}'.format(e), state='e') logger.out('ERROR: Failed to connect to Libvirt daemon: {}'.format(e), state='e')
exit(1) exit(1)
###############################################################################
# PHASE 7b - Ensure Ceph is running on the local host
###############################################################################
if enable_storage:
if config['daemon_mode'] == 'coordinator':
common.run_os_command('systemctl start ceph-mon@{}'.format(myhostname))
common.run_os_command('systemctl start ceph-mgr@{}'.format(myhostname))
############################################################################### ###############################################################################
# PHASE 7c - Ensure NFT is running on the local host # PHASE 7c - Ensure NFT is running on the local host
############################################################################### ###############################################################################