b3477fdd01
- Removed duplication and unnecessary indirection from all suites testcfgs. - Introduced a more comprehensive context to cover both command context and other platform specific concerns. - Propagated above context to TestLoader to allow for test counting command execution on all platforms. - Wrapped original pool with another class to give it a new interface and allow injecting different implementations in the future. - Consolidated progress indicators under a single processor in the pipeline. - Consolidated result retention requirements calculation outside of pipeline chain. - Refactored LoaderProc and got it under tests. - Added some more tests for the standard runner. - Extracted BuildConfig class. Bug: v8:12785 Change-Id: I87be040e91f792a983662bb5a10d55b36a14ea7f Reviewed-on: https://chromium-review.googlesource.com/c/v8/v8/+/3701595 Reviewed-by: Michael Achenbach <machenbach@chromium.org> Commit-Queue: Liviu Rau <liviurau@chromium.org> Cr-Commit-Position: refs/heads/main@{#81770}
37 lines
991 B
Python
37 lines
991 B
Python
# Copyright 2018 the V8 project authors. All rights reserved.
|
|
# Use of this source code is governed by a BSD-style license that can be
|
|
# found in the LICENSE file.
|
|
|
|
from . import base
|
|
|
|
class LoadProc(base.TestProc):
|
|
"""First processor in the chain that passes all tests to the next processor.
|
|
"""
|
|
|
|
def __init__(self, tests, initial_batch_size=float('inf')):
|
|
super(LoadProc, self).__init__()
|
|
|
|
self.tests = tests
|
|
self.initial_batch_size = initial_batch_size
|
|
|
|
|
|
def load_initial_tests(self):
|
|
"""Send an initial batch of tests down to executor"""
|
|
if not self.initial_batch_size:
|
|
return
|
|
to_load = self.initial_batch_size
|
|
for t in self.tests:
|
|
if self._send_test(t):
|
|
to_load -= 1
|
|
if not to_load:
|
|
break
|
|
|
|
def next_test(self, test):
|
|
assert False, \
|
|
'Nothing can be connected to the LoadProc' # pragma: no cover
|
|
|
|
def result_for(self, test, result):
|
|
for t in self.tests:
|
|
if self._send_test(t):
|
|
break
|