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

Add additional start/finish debug messages

This commit is contained in:
Joshua Boniface 2020-08-17 13:11:03 -04:00
parent f9b126a106
commit b451c0e8e3
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1025,6 +1025,9 @@ if enable_storage:
# Ceph stats update function # Ceph stats update function
def collect_ceph_stats(queue): def collect_ceph_stats(queue):
if debug:
logger.out("ceph-thread: Thread starting", state='d')
# Connect to the Ceph cluster # Connect to the Ceph cluster
try: try:
ceph_conn = Rados(conffile=config['ceph_config_file'], conf=dict(keyring=config['ceph_admin_keyring'])) ceph_conn = Rados(conffile=config['ceph_config_file'], conf=dict(keyring=config['ceph_admin_keyring']))
@ -1033,6 +1036,9 @@ def collect_ceph_stats(queue):
logger.out('Failed to open connection to Ceph cluster: {}'.format(e), state='e') logger.out('Failed to open connection to Ceph cluster: {}'.format(e), state='e')
return return
if debug:
logger.out("ceph-thread: Getting health stats from monitor", state='d')
# Get Ceph cluster health for local status output # Get Ceph cluster health for local status output
command = { "prefix": "health", "format": "json" } command = { "prefix": "health", "format": "json" }
try: try:
@ -1283,6 +1289,9 @@ def collect_ceph_stats(queue):
queue.put(ceph_health) queue.put(ceph_health)
queue.put(osds_this_node) queue.put(osds_this_node)
if debug:
logger.out("ceph-thread: Thread finished", state='d')
# State table for pretty stats # State table for pretty stats
libvirt_vm_states = { libvirt_vm_states = {
0: "NOSTATE", 0: "NOSTATE",
@ -1297,6 +1306,9 @@ libvirt_vm_states = {
# VM stats update function # VM stats update function
def collect_vm_stats(queue): def collect_vm_stats(queue):
if debug:
logger.out("vm-thread: Thread starting", state='d')
# Connect to libvirt # Connect to libvirt
if debug: if debug:
logger.out("vm-thread: Connect to libvirt", state='d') logger.out("vm-thread: Connect to libvirt", state='d')
@ -1422,8 +1434,14 @@ def collect_vm_stats(queue):
queue.put(memalloc) queue.put(memalloc)
queue.put(vcpualloc) queue.put(vcpualloc)
if debug:
logger.out("vm-thread: Thread finished", state='d')
# Keepalive update function # Keepalive update function
def node_keepalive(): def node_keepalive():
if debug:
logger.out("main-thread: Keepalive starting", state='d')
# 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':
@ -1609,6 +1627,8 @@ def node_keepalive():
# Write the updated data after we start the fence thread # Write the updated data after we start the fence thread
zkhandler.writedata(zk_conn, { '/nodes/{}/daemonstate'.format(node_name): 'dead' }) zkhandler.writedata(zk_conn, { '/nodes/{}/daemonstate'.format(node_name): 'dead' })
if debug:
logger.out("main-thread: Keepalive finished", state='d')
# Start keepalive thread # Start keepalive thread
update_timer = startKeepaliveTimer() update_timer = startKeepaliveTimer()