| /external/autotest/frontend/ |
| H A D | thread_local.py | 1 import threading namespace
3 _store = threading.local()
|
| /external/autotest/site_utils/rpm_control_system/ |
| H A D | test_client.py | 5 import threading namespace
24 threading.Thread(target=queue_request,
26 threading.Thread(target=queue_request,
28 threading.Thread(target=queue_request,
30 threading.Thread(target=queue_request,
32 threading.Thread(target=queue_request,
|
| H A D | rpm_integration_test.py | 2 import threading namespace
57 threading.Thread(target=rpm.queue_request,
59 threading.Thread(target=rpm.queue_request,
78 threading.Thread(target=rpm.queue_request,
80 threading.Thread(target=rpm.queue_request,
86 # threading.Thread(target=rpm2.queue_request,
88 # threading.Thread(target=rpm2.queue_request,
90 # threading.Thread(target=rpm2.queue_request,
131 threading.Thread(target=poe_controller.queue_request,
133 threading
[all...] |
| /external/chromium-trace/catapult/telemetry/third_party/webpagereplay/ |
| H A D | daemonserver.py | 16 import threading namespace
30 thread = threading.Thread(target=self.serve_forever)
|
| H A D | httpproxy_test.py | 20 import threading namespace
100 t = threading.Thread(
104 initial_thread_count = threading.activeCount()
116 util.WaitFor(lambda: threading.activeCount() == initial_thread_count, 2)
127 t = threading.Thread(
131 initial_thread_count = threading.activeCount()
154 threading.activeCount(), initial_thread_count + request_count)
159 util.WaitFor(lambda: threading.activeCount() == initial_thread_count, 1)
168 t = threading.Thread(
|
| /external/chromium-trace/catapult/devil/devil/utils/lazy/ |
| H A D | weak_constant.py | 5 import threading namespace
18 self._lock = threading.Lock()
|
| /external/autotest/site_utils/ |
| H A D | stats_poller.py | 7 import threading namespace
25 threads.append(threading.Thread(target=f, args=(sam,)))
29 threads.append(threading.Thread(target=f, args=(drone,)))
33 threads.append(threading.Thread(target=f, args=(devserver,)))
36 threads.append(threading.Thread(target=f))
45 while threading.active_count() > 0:
|
| H A D | metadata_reporter.py | 14 import threading namespace
40 _report_lock = threading.Lock()
41 _abort = threading.Event()
42 _queue_full = threading.Event()
151 reporting_thread = threading.Thread(target=_run)
|
| /external/mesa3d/src/gallium/auxiliary/util/ |
| H A D | u_slab.h | 69 enum util_slab_threading threading; member in struct:util_slab_mempool
77 enum util_slab_threading threading);
82 enum util_slab_threading threading);
|
| H A D | u_slab.c | 124 enum util_slab_threading threading)
126 pool->threading = threading;
128 if (threading) {
140 enum util_slab_threading threading)
156 util_slab_set_thread_safety(pool, threading);
123 util_slab_set_thread_safety(struct util_slab_mempool *pool, enum util_slab_threading threading) argument
137 util_slab_create(struct util_slab_mempool *pool, unsigned item_size, unsigned num_blocks, enum util_slab_threading threading) argument
|
| /external/chromium-trace/catapult/third_party/Paste/paste/util/ |
| H A D | threadinglocal.py | 9 import threading namespace
16 local = threading.local
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/oauth2client/tests/ |
| H A D | test_tools.py | 6 import threading namespace
18 t = threading.Thread(target = httpd.handle_request)
|
| /external/mesa3d/scons/ |
| H A D | fixes.py | 6 import threading namespace
9 spawn_lock = threading.Lock()
|
| /external/autotest/server/cros/ |
| H A D | stress_unittest.py | 5 import threading namespace
27 event = threading.Event()
43 event = threading.Event()
57 event = threading.Event()
68 event = threading.Event()
87 start_event = threading.Event()
88 ran_event = threading.Event()
|
| /external/autotest/client/cros/ |
| H A D | dark_resume_listener.py | 6 import threading namespace
41 thread = threading.Thread(None, loop_runner)
|
| /external/chromium-trace/catapult/devil/devil/android/ |
| H A D | device_temp_file.py | 11 import threading namespace
48 threading.Thread(
|
| /external/chromium-trace/catapult/third_party/gsutil/gslib/ |
| H A D | parallelism_framework_util.py | 19 import threading namespace
39 self.lock = threading.Lock()
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/oauth2client/oauth2client/ |
| H A D | keyring_storage.py | 22 import threading namespace
61 self._lock = threading.Lock()
|
| /external/google-benchmark/ |
| H A D | mingw.py | 80 threading = arch.setdefault(value[2].strip(), {})
81 exceptions = threading.setdefault(value[3].strip(), {})
172 def root(location = None, arch = None, version = None, threading = None,
180 if not (arch and version and threading and exceptions and revision):
191 if not threading:
194 threading = 'posix'
196 threading = 'win32'
198 threading = keys[0]
200 keys = versions[version][arch][threading].keys()
208 revision = max(versions[version][arch][threading][exception
[all...] |
| /external/autotest/client/common_lib/ |
| H A D | decorators_unittest.py | 7 import threading namespace
29 self.lock = threading.RLock()
37 threads = [threading.Thread(target=thread_body,
|
| /external/chromium-trace/catapult/telemetry/telemetry/internal/backends/chrome_inspector/ |
| H A D | websocket_unittest.py | 9 import threading namespace
43 threading.Thread(target=httpd.handle_request).start()
51 threading.Thread(target=httpd.handle_request).start()
|
| /external/chromium-trace/catapult/third_party/coverage/coverage/ |
| H A D | collector.py | 91 self.threading = None
107 # It's important to import threading only if we need it. If
110 import threading namespace
111 self.threading = threading
205 if hasattr(tracer, 'threading'):
206 tracer.threading = self.threading
216 # execution begins. Ironically, the only support the threading module has
268 # Install our installation tracer in threading, t
[all...] |
| /external/parameter-framework/upstream/tools/clientSimulator/clientsimulator/testGenerator/ |
| H A D | SubprocessLogger.py | 29 import threading namespace
36 class StreamLoggerThread(threading.Thread):
84 class SubprocessLoggerThread(threading.Thread):
89 __closeEvent = threading.Event()
205 return [t for t in threading.enumerate() if isinstance(t, cls)]
|
| /external/chromium-trace/catapult/common/py_trace_event/py_trace_event/trace_event_impl/ |
| H A D | log.py | 9 import threading namespace
14 _lock = threading.Lock()
21 _tls = threading.local() # tls used to detect forking/etc
85 tid = threading.current_thread().ident
89 "pid": os.getpid(), "tid": threading.current_thread().ident,
153 tid = threading.current_thread().ident
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/httplib2/python2/httplib2/test/ |
| H A D | miniserver.py | 6 import threading namespace
32 self.__is_shut_down = threading.Event()
98 threading.Thread(target=httpd.serve_forever).start()
|