Lines Matching refs:self
30 def __init__(self, max_failures):
31 super(ResultsTracker, self).__init__()
32 self._requirement = base.DROP_OUTPUT
34 self.failed = 0
35 self.remaining = 0
36 self.total = 0
37 self.max_failures = max_failures
39 def _on_next_test(self, test):
40 self.total += 1
41 self.remaining += 1
43 def _on_result_for(self, test, result):
44 self.remaining -= 1
46 self.failed += 1
47 if self.max_failures and self.failed >= self.max_failures:
49 self.stop()
53 def __init__(self):
54 super(base.TestProcObserver, self).__init__()
55 self.options = None
57 def finished(self):
60 def configure(self, options):
61 self.options = options
65 def __init__(self):
66 super(SimpleProgressIndicator, self).__init__()
67 self._requirement = base.DROP_PASS_OUTPUT
69 self._failed = []
71 def _on_result_for(self, test, result):
74 self._failed.append((test, result, False))
77 self._failed.append((test, result.results[0], True))
79 def finished(self):
83 for test, result, is_flaky in self._failed:
99 if len(self._failed) == 0:
106 print("=== %d tests failed" % len(self._failed))
115 def __init__(self):
116 super(StreamProgressIndicator, self).__init__()
117 self._requirement = base.DROP_PASS_OUTPUT
119 def _on_result_for(self, test, result):
121 self.print('PASS', test)
123 self.print("CRASH", test)
125 self.print("TIMEOUT", test)
128 self.print("UNEXPECTED PASS", test)
130 self.print("FAIL", test)
132 def print(self, prefix, test):
148 def __init__(self):
149 super(VerboseProgressIndicator, self).__init__()
150 self._last_printed_time = time.time()
152 def _print(self, text):
156 self._last_printed_time = time.time()
158 def _message(self, test, result):
167 def _on_result_for(self, test, result):
168 super(VerboseProgressIndicator, self)._on_result_for(test, result)
169 self._print(self._message(test, result))
173 def _print_processes_linux(self):
175 self._print('List of processes:')
178 self._print('pid: %d cmd: %s' % (pid, cmd))
180 def _ensure_delay(self, delay):
181 return time.time() - self._last_printed_time > delay
183 def _on_heartbeat(self):
184 if self._ensure_delay(30):
187 self._print('Still working...')
188 self._print_processes_linux()
190 def _on_event(self, event):
191 self._print(event)
192 self._print_processes_linux()
196 def _on_result_for(self, test, result):
197 super(VerboseProgressIndicator, self)._on_result_for(test, result)
198 if self.options.ci_test_completion:
199 with open(self.options.ci_test_completion, "a") as f:
200 f.write(self._message(test, result) + "\n")
201 self._output_feedback()
203 def _output_feedback(self):
207 if self._ensure_delay(60):
210 self._print(st)
214 def __init__(self):
215 super(DotsProgressIndicator, self).__init__()
216 self._count = 0
218 def _on_result_for(self, test, result):
219 super(DotsProgressIndicator, self)._on_result_for(test, result)
221 self._count += 1
222 if self._count > 1 and self._count % 50 == 1:
240 def __init__(self, templates):
241 super(CompactProgressIndicator, self).__init__()
242 self._requirement = base.DROP_PASS_OUTPUT
244 self._templates = templates
245 self._last_status_length = 0
246 self._start_time = time.time()
248 self._passed = 0
249 self._failed = 0
251 def set_test_count(self, test_count):
252 self._total = test_count
254 def _on_result_for(self, test, result):
257 self._failed += 1
259 self._passed += 1
261 self._print_progress(str(test))
267 self._clear_line(self._last_status_length)
270 self.printFormatted('stdout', stdout)
272 self.printFormatted('stderr', stderr)
273 self.printFormatted(
276 self.printFormatted(
278 self.printFormatted('failure', "--- CRASHED ---")
280 self.printFormatted('failure', "--- TIMEOUT ---")
283 self.printFormatted('failure', "--- UNEXPECTED PASS ---")
285 self.printFormatted('failure', test.expected_failure_reason)
287 self.printFormatted('failure', "--- FAILED ---")
289 def finished(self):
290 self._print_progress('Done')
293 def _print_progress(self, name):
294 self._clear_line(self._last_status_length)
295 elapsed = time.time() - self._start_time
296 if self._total:
297 progress = (self._passed + self._failed) * 100 // self._total
300 status = self._templates['status_line'] % {
301 'passed': self._passed,
303 'failed': self._failed,
308 status = self._truncateStatusLine(status, 78)
309 self._last_status_length = len(status)
313 def _truncateStatusLine(self, string, length):
319 def _clear_line(self, last_length):
324 def __init__(self):
335 super(ColorProgressIndicator, self).__init__(templates)
337 def printFormatted(self, format, string):
338 print(self._templates[format] % string)
340 def _truncateStatusLine(self, string, length):
342 return super(ColorProgressIndicator, self)._truncateStatusLine(
345 def _clear_line(self, last_length):
350 def __init__(self):
355 super(MonochromeProgressIndicator, self).__init__(templates)
357 def printFormatted(self, format, string):
360 def _clear_line(self, last_length):
365 def __init__(self, junitout, junittestsuite):
366 super(JUnitTestProgressIndicator, self).__init__()
367 self._requirement = base.DROP_PASS_STDOUT
369 self.outputter = junit_output.JUnitTestOutput(junittestsuite)
371 self.outfile = open(junitout, "wb")
373 self.outfile = sys.stdout
375 def _on_result_for(self, test, result):
391 self.outputter.HasRunTest(
397 def finished(self):
398 self.outputter.FinishAndWrite(self.outfile)
399 if self.outfile != sys.stdout:
400 self.outfile.close()
404 def __init__(self, framework_name):
405 super(JsonTestProgressIndicator, self).__init__()
410 self._requirement = base.DROP_PASS_STDOUT
412 self.framework_name = framework_name
413 self.results = []
414 self.duration_sum = 0
415 self.test_count = 0
417 def configure(self, options):
418 super(JsonTestProgressIndicator, self).configure(options)
419 self.tests = util.FixedSizeTopList(
420 self.options.slow_tests_cutoff,
423 def _on_result_for(self, test, result):
425 self.process_results(test, result.results)
427 self.process_results(test, [result])
429 def process_results(self, test, results):
434 self._buffer_slow_tests(test, result, output, run)
442 record = self._test_record(test, result, output, run)
448 self.results.append(record)
450 def _buffer_slow_tests(self, test, result, output, run):
456 record = self._test_record(test, result, output, run)
461 self.tests.add(record)
462 self.duration_sum += record['duration']
463 self.test_count += 1
465 def _test_record(self, test, result, output, run):
478 "framework_name": self.framework_name,
481 def finished(self):
483 if self.test_count:
484 duration_mean = self.duration_sum / self.test_count
487 "results": self.results,
488 "slowest_tests": self.tests.as_list(),
490 "test_total": self.test_count,
493 with open(self.options.json_test_results, "w") as f: