from pool import Pool
from . import commands
+from . import perfdata
from . import utils
class Runner(object):
def __init__(self, suites, progress_indicator, context):
+ datapath = os.path.join("out", "testrunner_data")
+ self.perf_data_manager = perfdata.PerfDataManager(datapath)
+ self.perfdata = self.perf_data_manager.GetStore(context.arch, context.mode)
self.tests = [ t for s in suites for t in s.tests ]
+ for t in self.tests:
+ t.duration = self.perfdata.FetchPerfData(t) or 1.0
self._CommonInit(len(self.tests), progress_indicator, context)
def _CommonInit(self, num_tests, progress_indicator, context):
# while the queue is filled.
queue = []
queued_exception = None
- for test in self.tests:
+ for test in sorted(self.tests, key=lambda t: t.duration, reverse=True):
assert test.id >= 0
test_map[test.id] = test
try:
else:
self.succeeded += 1
self.remaining -= 1
+ try:
+ self.perfdata.UpdatePerfData(test)
+ except Exception, e:
+ print("UpdatePerfData exception: %s" % e)
+ pass # Just keep working.
self.indicator.HasRun(test, has_unexpected_output)
finally:
pool.terminate()
import time
from . import distro
-from . import perfdata
from ..local import execution
+from ..local import perfdata
from ..objects import peer
from ..objects import workpacket
from ..server import compression
self.suites = suites
num_tests = 0
datapath = os.path.join("out", "testrunner_data")
+ # TODO(machenbach): These fields should exist now in the superclass.
+ # But there is no super constructor call. Check if this is a problem.
self.perf_data_manager = perfdata.PerfDataManager(datapath)
self.perfdata = self.perf_data_manager.GetStore(context.arch, context.mode)
for s in suites: