From 157f19154663cdd8115f1d1d7e718719296a6dd2 Mon Sep 17 00:00:00 2001 From: Renato Alves Date: Mon, 13 Jul 2015 02:13:43 +0100 Subject: [PATCH] Test: Show total time on serial and parallel tests Visible only when using run_all -l (or above) --- test/run_all | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/test/run_all b/test/run_all index abdf75aec..213f5e27c 100755 --- a/test/run_all +++ b/test/run_all @@ -19,7 +19,8 @@ os.environ["TASKD_USE_PATH"] = "1" TIMEOUT = .2 -def run_test(testqueue, outqueue): +def run_test(testqueue, outqueue, threadname): + start = time.time() while True: try: test = testqueue.get(block=True, timeout=TIMEOUT) @@ -43,6 +44,9 @@ def run_test(testqueue, outqueue): testqueue.task_done() + log.warning("Finished %s thread after %s seconds", + threadname, round(time.time() - start, 3)) + class TestRunner(object): def __init__(self): @@ -77,11 +81,11 @@ class TestRunner(object): def _prepare_threads(self): # Serial thread self.threads.append( - Thread(target=run_test, args=(self._serialq, self._outputq)) + Thread(target=run_test, args=(self._serialq, self._outputq, "Serial")) ) # Parallel threads self.threads.extend([ - Thread(target=run_test, args=(self._parallelq, self._outputq)) + Thread(target=run_test, args=(self._parallelq, self._outputq, "Parallel")) for i in range(cpu_count()) ]) log.info("Spawned %s threads to run tests", len(self.threads))