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

More fixes

This commit is contained in:
Joshua Boniface 2018-06-01 00:41:26 -04:00
parent 7bcb2e0b00
commit 9ab02318c6
2 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
NodeInstance.py
View File

@ -99,6 +99,8 @@ class NodeInstance(threading.Thread):
self.flush() self.flush()
def setup_remote_node(self): def setup_remote_node(self):
pass
@zk.DataWatch(self.zkey + '/state') @zk.DataWatch(self.zkey + '/state')
def watch_state(data, stat): def watch_state(data, stat):
self.state = data.decode('ascii') self.state = data.decode('ascii')

1
pvcd.py
View File

@ -82,6 +82,7 @@ def updatenodes(new_node_list):
t_node[node].start() t_node[node].start()
node_state = t_node[node].getstate() node_state = t_node[node].getstate()
print(node_state)
if node_state == 'start': if node_state == 'start':
active_node_list.append(t_node[node].getname()) active_node_list.append(t_node[node].getname())
elif node_state == 'flush': elif node_state == 'flush':