class TestShellThread(WatchableThread):
- def __init__(self, port, options, worker_number, worker_name,
+ def __init__(self, port, options, worker_number,
filename_list_queue, result_queue):
"""Initialize all the local state for this DumpRenderTree thread.
port: interface to port-specific hooks
options: command line options argument from optparse
worker_number: identifier for a particular worker thread.
- worker_name: for logging.
filename_list_queue: A thread safe Queue class that contains lists
of tuples of (filename, uri) pairs.
result_queue: A thread safe Queue class that will contain
self._port = port
self._options = options
self._worker_number = worker_number
- self._name = worker_name
+ self._name = 'worker/%d' % worker_number
self._filename_list_queue = filename_list_queue
self._result_queue = result_queue
def get_num_tests(self):
return self._num_tests
+ def name(self):
+ return self._name
+
def next_timeout(self):
"""Return the time the test is supposed to finish by."""
if self._next_timeout:
class SingleTestThread(threading.Thread):
def run(self):
- result = worker._run_single_test(driver, test_input)
+ result = worker._run_single_test(test_input, driver)
thread = SingleTestThread()
thread.start()