about summary refs log tree commit diff stats
path: root/test/utils/testset.py
diff options
context:
space:
mode:
authorCamille Mougey <commial@gmail.com>2016-04-06 10:02:34 +0200
committerCamille Mougey <commial@gmail.com>2016-04-06 10:02:34 +0200
commitcba4c6b1d0e937e2dc14682b4f3efc2d5d4fec72 (patch)
treeaaa33f85493afce3e7401efdd9dc2cc5404fc337 /test/utils/testset.py
parent5db3ce6a4a1bba435fd39b9700feb7cb2256663b (diff)
parente21cdd93c7352bc9d8f31d920b8b9596caaa7444 (diff)
downloadmiasm-cba4c6b1d0e937e2dc14682b4f3efc2d5d4fec72.tar.gz
miasm-cba4c6b1d0e937e2dc14682b4f3efc2d5d4fec72.zip
Merge pull request #349 from serpilliere/clean_test_output
Clean test output
Diffstat (limited to 'test/utils/testset.py')
-rw-r--r--test/utils/testset.py12
1 files changed, 11 insertions, 1 deletions
diff --git a/test/utils/testset.py b/test/utils/testset.py
index 54df732c..4336f4fa 100644
--- a/test/utils/testset.py
+++ b/test/utils/testset.py
@@ -1,34 +1,43 @@
 import os
 import subprocess
 import sys
+import time
 from multiprocessing import cpu_count, Queue, Process
+
 from test import Test
 
 
 class Message(object):
+
     "Message exchanged in the TestSet message queue"
     pass
 
 
 class MessageTaskNew(Message):
+
     "Stand for a new task"
+
     def __init__(self, task):
         self.task = task
 
 
 class MessageTaskDone(Message):
+
     "Stand for a task done"
+
     def __init__(self, task, error):
         self.task = task
         self.error = error
 
 
 class MessageClose(Message):
+
     "Close the channel"
     pass
 
 
 class TestSet(object):
+
     "Manage a set of test"
 
     def __init__(self, base_dir):
@@ -39,7 +48,7 @@ class TestSet(object):
         self.base_dir = base_dir
 
         # Init internals
-        self.task_done_cb = lambda tst, err: None # On task done callback
+        self.task_done_cb = lambda tst, err: None  # On task done callback
         self.task_new_cb = lambda tst: None       # On new task callback
         self.todo_queue = Queue()                 # Tasks to do
         self.message_queue = Queue()              # Messages with workers
@@ -136,6 +145,7 @@ class TestSet(object):
             test = todo_queue.get()
             if test is None:
                 break
+            test.start_time = time.time()
             message_queue.put(MessageTaskNew(test))
 
             # Go to the expected directory