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 06f0f7ed91
commit 3b805cdc34
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"
if debug:
logger.out("Connecting to libvirt", state='d', prefix='vm-thread')
lv_conn = libvirt.open(libvirt_name)
if lv_conn is None:
try:
lv_conn = libvirt.open(libvirt_name)
if lv_conn is None:
raise Exception
except Exception:
logger.out('Failed to open connection to "{}"'.format(libvirt_name), state='e')
return
memalloc = 0
memprov = 0