diff --git a/NodeInstance.py b/NodeInstance.py index 4f2a4f87..8f412135 100644 --- a/NodeInstance.py +++ b/NodeInstance.py @@ -9,7 +9,7 @@ class NodeInstance(threading.Thread): self.zkey = '/nodes/%s' % name self.zk = zk self.name = name - self.state = 'stop' + #self.state = 'stop' self.stop_thread = threading.Event() self.node_list = node_list self.domainlist = [] diff --git a/pvcd.py b/pvcd.py index e47d65c9..50c2b259 100755 --- a/pvcd.py +++ b/pvcd.py @@ -76,12 +76,9 @@ def updatenodes(new_node_list): for node in node_list: if node in t_node: t_node[node].updatenodelist(node_list) - time.sleep(0.1) else: - print("starting" + node) t_node[node] = NodeInstance.NodeInstance(node, node_list, zk); t_node[node].start() - time.sleep(0.1) node_state = t_node[node].getstate() print(node_state)