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

Better reporting of nodes

This commit is contained in:
Joshua Boniface 2018-05-31 23:37:48 -04:00
parent cf1d9bc327
commit 54587c1f61
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
pvcd.py
View File

@ -68,15 +68,30 @@ node_list = []
def updatenodes(new_node_list): def updatenodes(new_node_list):
global node_list global node_list
node_list = new_node_list node_list = new_node_list
active_node_list = []
flushed_node_list = []
inactive_node_list = []
print('Node list: %s' % node_list) print('Node list: %s' % node_list)
for node in node_list: for node in node_list:
if node in t_node: if node in t_node:
t_node[node].updatenodelist(node_list) t_node[node].updatenodelist(node_list)
node_status = t_node[node].getstatus()
else: else:
t_node[node] = NodeInstance.NodeInstance(node, node_list, zk); t_node[node] = NodeInstance.NodeInstance(node, node_list, zk);
if t_node[node].name == myhostname: if t_node[node].name == myhostname:
t_node[node].start() t_node[node].start()
if node_status == 'start':
active_node_list.append(t_node[node].getname())
elif node_status == 'flush':
flushed_node_list.append(t_node[node].getname())
else:
inactive_node_list.append(t_node[node].getname())
print('Active nodes: %s' % active_node_list)
print('Flushed nodes: %s' % flushed_node_list)
print('Inactive nodes: %s' % inactive_node_list)
domain_list = zk.get_children('/domains') domain_list = zk.get_children('/domains')
print('Domain list: %s' % domain_list) print('Domain list: %s' % domain_list)