Fix failure to connect to libvirt in keepalive

This should be caught and abort the thread rather than failing and
holding up keepalives.
This commit is contained in:
Joshua Boniface 2021-09-26 20:42:01 -04:00
parent c8134d3a1c
commit 16c38da5ef
1 changed files with 6 additions and 2 deletions

View File

@ -361,9 +361,13 @@ def collect_vm_stats(logger, config, zkhandler, this_node, queue):
libvirt_name = "qemu:///system" libvirt_name = "qemu:///system"
if debug: if debug:
logger.out("Connecting to libvirt", state='d', prefix='vm-thread') logger.out("Connecting to libvirt", state='d', prefix='vm-thread')
try:
lv_conn = libvirt.open(libvirt_name) lv_conn = libvirt.open(libvirt_name)
if lv_conn is None: if lv_conn is None:
raise Exception
except Exception:
logger.out('Failed to open connection to "{}"'.format(libvirt_name), state='e') logger.out('Failed to open connection to "{}"'.format(libvirt_name), state='e')
return
memalloc = 0 memalloc = 0
memprov = 0 memprov = 0