[Author Prev][Author Next][Thread Prev][Thread Next][Author Index][Thread Index]
[tor-commits] [chutney/master] status: only look at the nodes in the current launch phase.
commit fa545464cc00ea1e9ed4a4c633273ce61652484a
Author: Nick Mathewson <nickm@xxxxxxxxxxxxxx>
Date: Wed Jun 24 10:51:52 2020 -0400
status: only look at the nodes in the current launch phase.
---
lib/chutney/TorNet.py | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/lib/chutney/TorNet.py b/lib/chutney/TorNet.py
index ff1e894..98ccc45 100644
--- a/lib/chutney/TorNet.py
+++ b/lib/chutney/TorNet.py
@@ -2260,11 +2260,13 @@ class Network(object):
"""Print how many nodes are running and how many are expected, and
return True if all nodes are running.
"""
+ cur_launch = self._dfltEnv['CUR_LAUNCH_PHASE']
statuses = [n.getController().check(listNonRunning=True)
- for n in self._nodes]
+ for n in self._nodes
+ if n._env['launch_phase'] == cur_launch]
n_ok = len([x for x in statuses if x])
print("%d/%d nodes are running" % (n_ok, len(self._nodes)))
- return n_ok == len(self._nodes)
+ return n_ok == len(statuses)
def restart(self):
"""Invoked from command line: Stop and subsequently start our
@@ -2280,7 +2282,7 @@ class Network(object):
sys.stdout.flush()
rv = all([n.getController().start() for n in self._nodes
if n._env['launch_phase'] ==
- self._dfltEnv['CUR_LAUNCH_PHASE']])
+ self._dfltEnv['CUR_LAUNCH_PHASE']])
# now print a newline unconditionally - this stops poll()ing
# output from being squashed together, at the cost of a blank
# line in wait()ing output
_______________________________________________
tor-commits mailing list
tor-commits@xxxxxxxxxxxxxxxxxxxx
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits