about summary refs log tree commit diff stats
path: root/test/utils/testset.py
diff options
context:
space:
mode:
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