| /external/autotest/site_utils/ |
| log_socket_server_unittest.py | 8 import multiprocessing
46 process = multiprocessing.Process(target=self.log_call,
|
| rpc_logserver.py | 12 import multiprocessing
47 server_started = multiprocessing.Value(ctypes.c_bool, False)
48 LogServer.process = multiprocessing.Process(
|
| 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(
|
| rpc_flight_recorder.py | 9 import multiprocessing
96 pool = multiprocessing.Pool(processes=multiprocessing.cpu_count() * 4)
123 self._manager = multiprocessing.Manager()
135 self._stop_event = multiprocessing.Event()
142 self._update_shards_ps = multiprocessing.Process(
154 self._poll_rpc_server_ps = multiprocessing.Process(
|
| /external/autotest/site_utils/lxc/ |
| unittest_http.py | 7 import multiprocessing
47 p = multiprocessing.Process(target=serve)
|
| /external/autotest/site_utils/tester_feedback/ |
| service.py | 8 import multiprocessing
49 self._server_process = multiprocessing.Process(
|
| 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()
|
| query_delegate.py | 7 import multiprocessing
20 _query_count = multiprocessing.Value('d', 0)
|
| /external/python/cpython2/Doc/includes/ |
| mp_webserver.py | 6 # object. (We import `multiprocessing.reduction` to enable this pickling.)
18 from multiprocessing import Process, current_process, freeze_support
23 import multiprocessing.reduction # make sockets pickable/inheritable
|
| mp_newtype.py | 9 from multiprocessing import freeze_support
10 from multiprocessing.managers import BaseManager, BaseProxy
|
| /external/toolchain-utils/bestflags/ |
| pipeline_process_test.py | 11 import multiprocessing
60 manager = multiprocessing.Manager()
|
| pipeline_worker_test.py | 13 import multiprocessing
46 manager = multiprocessing.Manager()
52 helper_process = multiprocessing.Process(
96 manager = multiprocessing.Manager()
|
| example_algorithms.py | 16 import multiprocessing
156 manager = multiprocessing.Manager()
174 steer_process = multiprocessing.Process(
|
| /external/chromium-trace/catapult/common/py_utils/py_utils/ |
| 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/autotest/client/site_tests/power_HotCPUSuspend/ |
| power_HotCPUSuspend.py | 5 import hashlib, logging, multiprocessing, os, re, time
71 cpus = multiprocessing.cpu_count()
74 pool = multiprocessing.Pool(workers)
|
| /external/autotest/contrib/ |
| watch_expensive_rpcs.py | 18 import multiprocessing
88 queue = multiprocessing.Queue()
92 proc = multiprocessing.Process(target=pull_all_data, args=(pid, queue))
|
| /external/vixl/tools/ |
| clang_format.py | 31 import multiprocessing
64 default = multiprocessing.cpu_count(),
65 const = multiprocessing.cpu_count(),
118 # The multiprocessing map_async function does not allow passing multiple
139 pool = multiprocessing.Pool(jobs)
|
| /external/autotest/client/site_tests/power_CameraSuspend/ |
| power_CameraSuspend.py | 5 import logging, multiprocessing, os, time
46 pool = multiprocessing.Pool(processes=1)
|
| /external/deqp/scripts/ |
| launchcontrol_build.py | 27 import multiprocessing
59 threadCount = multiprocessing.cpu_count() + 1
|
| /external/skia/tools/ |
| check-headers-self-sufficient | 9 import multiprocessing
144 # ...Except use a multiprocessing pool.
149 pool = multiprocessing.Pool()
|
| /external/llvm/utils/lit/lit/ |
| run.py | 16 import multiprocessing
18 multiprocessing = None variable
118 self.queue = multiprocessing.Queue()
215 if jobs != 1 and use_processes and multiprocessing:
217 task_impl = multiprocessing.Process
218 queue_impl = multiprocessing.Queue
219 canceled_flag = multiprocessing.Value('i', 0)
222 # multiprocessing fails to initialize with certain OpenBSD and
225 self.lit_config.note('failed to initialize multiprocessing')
238 # https://docs.python.org/2/library/multiprocessing.htm
[all...] |
| /external/autotest/client/cros/cellular/mbim_compliance/ |
| 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
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_multiprocessing.py | 4 # Unit tests for the multiprocessing package
27 test_support.import_module('multiprocessing.synchronize')
29 import multiprocessing.dummy
30 import multiprocessing.connection
31 import multiprocessing.managers
32 import multiprocessing.heap
33 import multiprocessing.pool
35 from multiprocessing import util
38 from multiprocessing.sharedctypes import Value, copy
244 cpus = multiprocessing.cpu_count()
[all...] |
| /external/python/cpython2/Lib/multiprocessing/dummy/ |
| __init__.py | 2 # Support for the API of the multiprocessing package using threads
4 # multiprocessing/dummy/__init__.py
51 from multiprocessing import TimeoutError, cpu_count
52 from multiprocessing.dummy.connection import Pipe
150 from multiprocessing.pool import ThreadPool
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/multiprocessing/dummy/ |
| __init__.py | 2 # Support for the API of the multiprocessing package using threads
4 # multiprocessing/dummy/__init__.py
51 from multiprocessing import TimeoutError, cpu_count
52 from multiprocessing.dummy.connection import Pipe
150 from multiprocessing.pool import ThreadPool
|
