/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
|