self.queue = Queue.Queue()
self.jobs = []
self.total_num_tests = 0
- self.test_num = 1
+ self.starting_test_num = 0
self.check_testslist = True
self.all_tests = None
def run_tests(self, starting_test_num, total_num_tests):
self.total_num_tests = total_num_tests
- self.test_num = starting_test_num
+ self.starting_test_num = starting_test_num
num_jobs = min(self.options.num_jobs, len(self.tests))
tests_left = list(self.tests)
jobs_running -= 1
self.print_test_num(test)
res = test.test_end()
- self.test_num += 1
self.reporter.after_test(test)
if res != Result.PASSED and (self.options.forever or
self.options.fatal_error):
- return test.result, self.test_num
+ return test.result
if self.start_new_job(tests_left):
jobs_running += 1
- return Result.PASSED, self.test_num
+ return Result.PASSED
def print_test_num(self, test):
- sys.stdout.write("[%d / %d] " % (self.test_num, self.total_num_tests))
+ cur_test_num = self.starting_test_num + self.tests.index(test) + 1
+ sys.stdout.write("[%d / %d] " % (cur_test_num, self.total_num_tests))
def clean_tests(self):
for test in self.tests:
self.reporter.init_timer()
for tester in self.testers:
- res, cur_test_num = tester.run_tests(cur_test_num, total_num_tests)
+ res = tester.run_tests(cur_test_num, total_num_tests)
+ cur_test_num += len(tester.list_tests())
if res != Result.PASSED and (self.options.forever or
self.options.fatal_error):
return False