Searched refs:multiprocessing (Results 1 – 25 of 93) sorted by relevance
1234
| /external/chromium-trace/catapult/third_party/coverage/coverage/ |
| D | monkey.py | 6 import multiprocessing
7 import multiprocessing.process
22 if hasattr(multiprocessing, PATCHED_MARKER):
26 klass = multiprocessing.process.BaseProcess
28 klass = multiprocessing.Process
48 multiprocessing.Process = ProcessWithCoverage
50 setattr(multiprocessing, PATCHED_MARKER, True)
|
| /external/chromium-trace/catapult/catapult_base/catapult_base/ |
| D | lock_unittest.py | 5 import multiprocessing
59 p = multiprocessing.Process(
90 p = multiprocessing.Process(
111 p = multiprocessing.Process(
129 p = multiprocessing.Process(
148 p = multiprocessing.Process(
157 p = multiprocessing.Process(
|
| /external/vixl/tools/ |
| D | threaded_tests.py | 27 import multiprocessing
63 n_tests_passed = multiprocessing.Value('i', 0)
64 n_tests_failed = multiprocessing.Value('i', 0)
113 __run_tests_lock__ = multiprocessing.Lock()
142 pool = multiprocessing.Pool(jobs)
|
| D | printer.py | 32 import multiprocessing
51 __print_lock__ = multiprocessing.Lock()
52 __last_overwritable_line_length__ = multiprocessing.Value('i', 0)
53 __last_line_type__ = multiprocessing.Value('i', LINE_TYPE_NONE)
|
| D | lint.py | 30 import multiprocessing
55 default=1, const=multiprocessing.cpu_count(),
63 __lint_results_lock__ = multiprocessing.Lock()
134 pool = multiprocessing.Pool(jobs)
|
| /external/autotest/site_utils/tester_feedback/ |
| D | request_multiplexer.py | 7 from multiprocessing import reduction
10 import multiprocessing
34 self._request_queue = multiprocessing.Queue()
134 self._request_handling_process = multiprocessing.Process(
164 reply_pipe_send, reply_pipe_recv = multiprocessing.Pipe()
|
| D | service.py | 8 import multiprocessing
49 self._server_process = multiprocessing.Process(
|
| /external/v8/tools/gcmole/ |
| D | parallel.py | 24 import multiprocessing
37 processes = multiprocessing.cpu_count()
38 pool = multiprocessing.Pool(processes=processes)
|
| /external/llvm/utils/lit/lit/ |
| D | run.py | 16 import multiprocessing
18 multiprocessing = None variable
116 self.queue = multiprocessing.Queue()
213 if jobs != 1 and use_processes and multiprocessing:
215 task_impl = multiprocessing.Process
216 queue_impl = multiprocessing.Queue
217 canceled_flag = multiprocessing.Value('i', 0)
|
| /external/chromium-trace/catapult/common/py_trace_event/py_trace_event/trace_event_impl/ |
| D | multiprocessing_shim.py | 4 import multiprocessing
9 _RealProcess = multiprocessing.Process
91 if multiprocessing.Process != ProcessShim:
92 multiprocessing.Process = ProcessShim
|
| /external/chromium-trace/catapult/third_party/typ/typ/ |
| D | pool.py | 16 import multiprocessing
63 self.requests = multiprocessing.Queue()
64 self.responses = multiprocessing.Queue()
70 w = multiprocessing.Process(target=_loop,
104 multiprocessing.queues.is_exiting = lambda: True
106 multiprocessing.util._exiting = True
|
| /external/autotest/site_utils/ |
| D | log_socket_server.py | 16 import multiprocessing
125 server_started = multiprocessing.Value(ctypes.c_bool, False)
126 port = multiprocessing.Value(ctypes.c_int, 0)
127 LogSocketServer.process = multiprocessing.Process(
|
| D | rpc_logserver.py | 12 import multiprocessing
47 server_started = multiprocessing.Value(ctypes.c_bool, False)
48 LogServer.process = multiprocessing.Process(
|
| D | test_push.py | 23 import multiprocessing
500 queue = multiprocessing.Queue()
502 push_to_prod_suite = multiprocessing.Process(
510 au_suite = multiprocessing.Process(
516 shard_suite = multiprocessing.Process(
523 asynchronous_suite = multiprocessing.Process(
|
| /external/webrtc/webrtc/tools/barcode_tools/ |
| D | helper_functions.py | 10 import multiprocessing
86 process_pool = multiprocessing.Pool(processes=multiprocessing.cpu_count())
|
| /external/autotest/client/cros/cellular/mbim_compliance/ |
| D | mbim_channel.py | 6 import multiprocessing
77 self._stop_request_event = multiprocessing.Event()
78 self._request_queue = multiprocessing.Queue()
79 self._response_queue = multiprocessing.Queue()
84 process_class = multiprocessing.Process
|
| /external/chromium-trace/catapult/telemetry/telemetry/internal/platform/profiler/ |
| D | monsoon_profiler.py | 13 import multiprocessing
73 self._is_collecting = multiprocessing.Event()
74 self._collector = multiprocessing.Process(
|
| /external/autotest/contrib/ |
| D | watch_expensive_rpcs.py | 18 import multiprocessing
88 queue = multiprocessing.Queue()
92 proc = multiprocessing.Process(target=pull_all_data, args=(pid, queue))
|
| /external/chromium-trace/catapult/catapult_base/catapult_base/refactor/ |
| D | __init__.py | 12 import multiprocessing
28 return multiprocessing.Pool().map(transform, file_paths)
|
| /external/chromium-trace/catapult/third_party/closure_linter/closure_linter/ |
| D | gjslint.py | 56 import multiprocessing
58 multiprocessing = None variable
76 platform.system() is 'Linux' and bool(multiprocessing),
105 pool = multiprocessing.Pool()
|
| /external/chromium-trace/catapult/telemetry/telemetry/internal/platform/power_monitor/ |
| D | monsoon_power_monitor.py | 7 import multiprocessing
71 self._is_collecting = multiprocessing.Event()
72 self._powermonitor_process = multiprocessing.Process(
|
| /external/autotest/client/site_tests/power_HotCPUSuspend/ |
| D | power_HotCPUSuspend.py | 5 import hashlib, logging, multiprocessing, os, re, time
71 cpus = multiprocessing.cpu_count()
74 pool = multiprocessing.Pool(workers)
|
| /external/autotest/server/ |
| D | site_server_job.py | 7 import os, logging, multiprocessing
86 test_queue = multiprocessing.JoinableQueue()
87 test_queue_lock = multiprocessing.Lock()
|
| /external/chromium-trace/catapult/experimental/buildbot/ |
| D | download.py | 7 import multiprocessing
37 process_pool = multiprocessing.Pool(4)
|
| /external/autotest/server/cros/clique_lib/ |
| D | clique_dut_log_collector.py | 6 import multiprocessing
49 task = multiprocessing.Process(
|
1234