diff options
| author |  Craig Tiller <ctiller@google.com> | 2015-01-12 14:28:33 -0800 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2015-01-12 14:28:33 -0800 |
| commit | 738c334432bfe79104d4d301989fe30823364279 (patch) | |
| tree | bf2fdb45add7cebca936f30a481efda47cf8b8ef /tools/run_tests/jobset.py | |
| parent | b29797b142a016ec9821b65479309329e151f6b4 (diff) | |
Allow running tests under valgrind
Diffstat (limited to 'tools/run_tests/jobset.py')
| -rwxr-xr-x | tools/run_tests/jobset.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/tools/run_tests/jobset.py b/tools/run_tests/jobset.py index 7e1ec366f9..b7bcb7b02c 100755 --- a/tools/run_tests/jobset.py +++ b/tools/run_tests/jobset.py @@ -8,7 +8,7 @@ import tempfile import time -_MAX_JOBS = 16 * multiprocessing.cpu_count() +_MAX_JOBS = 3 def shuffle_iteratable(it): @@ -108,6 +108,7 @@ class Jobset(object): self._check_cancelled = check_cancelled self._cancelled = False self._failures = 0 + self._completed = 0 def start(self, cmdline): """Start a job. Return True on success, False on failure.""" @@ -128,9 +129,11 @@ class Jobset(object): if st == _FAILURE: self._failures += 1 dead.add(job) for job in dead: + self._completed += 1 self._running.remove(job) if dead: return - message('WAITING', '%d jobs left' % len(self._running)) + message('WAITING', '%d jobs running, %d complete' % ( + len(self._running), self._completed)) time.sleep(0.1) def cancelled(self): |