| /external/webrtc/talk/session/media/ |
| audiomonitor.cc | 47 voice_channel_->worker_thread()->Clear(this);
55 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_START);
59 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_STOP);
67 assert(rtc::Thread::Current() == voice_channel_->worker_thread());
75 assert(rtc::Thread::Current() == voice_channel_->worker_thread());
78 voice_channel_->worker_thread()->Clear(this);
83 assert(rtc::Thread::Current() == voice_channel_->worker_thread());
101 assert(rtc::Thread::Current() == voice_channel_->worker_thread());
110 voice_channel_->worker_thread()->PostDelayed(rate_, this, MSG_MONITOR_POLL);
|
| mediamonitor.h | 45 MediaMonitor(rtc::Thread* worker_thread,
69 MediaMonitorT(MC* media_channel, rtc::Thread* worker_thread,
71 : MediaMonitor(worker_thread, monitor_thread),
|
| mediamonitor.cc | 41 MediaMonitor::MediaMonitor(rtc::Thread* worker_thread,
43 : worker_thread_(worker_thread),
|
| /system/bt/osi/test/ |
| future_test.cc | 41 thread_t* worker_thread = thread_new("worker thread"); local
42 thread_post(worker_thread, post_to_future, future);
46 thread_free(worker_thread);
|
| /external/valgrind/helgrind/tests/ |
| tc03_re_excl.c | 16 static void* worker_thread ( void* argV ) function
30 pthread_create(&thread_id, 0, worker_thread, (void*)x);
|
| /external/webrtc/talk/app/webrtc/ |
| mediacontroller.cc | 44 MediaController(rtc::Thread* worker_thread,
46 : worker_thread_(worker_thread), channel_manager_(channel_manager) {
47 RTC_DCHECK(nullptr != worker_thread);
92 rtc::Thread* worker_thread,
94 return new MediaController(worker_thread, channel_manager);
|
| mediacontroller.h | 46 rtc::Thread* worker_thread,
|
| peerconnectionfactory.cc | 99 rtc::Thread* worker_thread,
105 new rtc::RefCountedObject<PeerConnectionFactory>(worker_thread,
137 rtc::Thread* worker_thread,
145 worker_thread_(worker_thread),
149 ASSERT(worker_thread != NULL);
318 rtc::Thread* PeerConnectionFactory::worker_thread() { function in class:webrtc::PeerConnectionFactory
|
| peerconnectionfactory.h | 92 virtual rtc::Thread* worker_thread();
98 rtc::Thread* worker_thread,
|
| /external/tensorflow/tensorflow/contrib/batching/python/ops/ |
| batch_ops_test.py | 55 worker_thread = threading.Thread(target=worker)
56 worker_thread.start()
58 worker_thread.join()
96 worker_thread = threading.Thread(target=worker)
97 worker_thread.start()
99 worker_thread.join()
130 worker_thread = threading.Thread(target=worker)
131 worker_thread.start()
133 worker_thread.join()
181 worker_thread = threading.Thread(target=worker
[all...] |
| /external/autotest/scheduler/ |
| thread_lib.py | 154 worker_thread = ExceptionRememberingThread(
161 self.drone_threads[drone] = worker_thread
163 worker_thread.setName('%s.%s' %
165 worker_thread.daemon = True
166 worker_thread.start()
|
| /external/pdfium/third_party/libopenjpeg20/ |
| thread.c | 600 opj_worker_thread_t* worker_thread; member in struct:opj_worker_thread_list_t
622 opj_worker_thread_t* worker_thread,
658 opj_worker_thread_t* worker_thread; local
663 worker_thread = (opj_worker_thread_t*) user_data;
664 tp = worker_thread->tp;
668 opj_worker_thread_job_t* job = opj_thread_pool_get_next_job(tp, worker_thread,
757 opj_worker_thread_t* worker_thread,
790 if (!worker_thread->marked_as_waiting) {
793 worker_thread->marked_as_waiting = OPJ_TRUE;
806 item->worker_thread = worker_thread
865 opj_worker_thread_t* worker_thread; local
[all...] |
| /device/generic/car/emulator/audio/driver/ |
| audio_hw.h | 59 pthread_t worker_thread; // Constant after init member in struct:generic_stream_out
85 pthread_t worker_thread; // Constant after init member in struct:generic_stream_in
|
| /external/webrtc/webrtc/p2p/client/ |
| socketmonitor.cc | 25 rtc::Thread* worker_thread,
28 worker_thread_ = worker_thread;
|
| fakeportallocator.h | 85 FakePortAllocatorSession(rtc::Thread* worker_thread,
93 worker_thread_(worker_thread),
143 FakePortAllocator(rtc::Thread* worker_thread,
145 : worker_thread_(worker_thread), factory_(factory) {
|
| socketmonitor.h | 36 rtc::Thread* worker_thread,
|
| /external/libchrome/base/task/ |
| cancelable_task_tracker_unittest.cc | 85 Thread worker_thread("worker thread");
86 ASSERT_TRUE(worker_thread.Start());
88 ignore_result(task_tracker_.PostTask(worker_thread.task_runner().get(),
93 worker_thread.task_runner().get(), FROM_HERE,
99 worker_thread.Stop();
165 Thread worker_thread("worker thread");
166 ASSERT_TRUE(worker_thread.Start());
169 worker_thread.task_runner().get(), FROM_HERE, Bind(&DoNothing),
175 worker_thread.Stop();
|
| /external/webrtc/talk/media/base/ |
| mediaengine.h | 74 virtual bool Init(rtc::Thread* worker_thread) = 0;
143 virtual bool Init(rtc::Thread* worker_thread) {
144 if (!voice_.Init(worker_thread))
|
| /system/bt/btif/src/ |
| btif_a2dp_sink.cc | 77 thread_t* worker_thread; member in struct:__anon1742
143 btif_a2dp_sink_cb.worker_thread = thread_new("btif_a2dp_sink_worker_thread");
144 if (btif_a2dp_sink_cb.worker_thread == NULL) {
157 thread_get_reactor(btif_a2dp_sink_cb.worker_thread),
161 thread_post(btif_a2dp_sink_cb.worker_thread, btif_a2dp_sink_init_delayed,
175 thread_post(btif_a2dp_sink_cb.worker_thread, btif_a2dp_sink_startup_delayed,
189 thread_post(btif_a2dp_sink_cb.worker_thread,
229 thread_post(btif_a2dp_sink_cb.worker_thread,
242 thread_post(btif_a2dp_sink_cb.worker_thread, btif_a2dp_sink_shutdown_delayed,
257 thread_t* worker_thread; local
[all...] |
| /external/ltp/testcases/realtime/func/pi-tests/ |
| sbrk_mutex.c | 78 void *worker_thread(void *arg) function
136 create_fifo_thread(worker_thread, (void *)t,
|
| /hardware/qcom/display/msm8909/sdm/include/utils/ |
| sync_task.h | 59 std::thread worker_thread(SyncTaskThread, this);
60 worker_thread_.swap(worker_thread);
|
| /hardware/qcom/display/msm8909w_3100/sdm/include/utils/ |
| sync_task.h | 59 std::thread worker_thread(SyncTaskThread, this);
60 worker_thread_.swap(worker_thread);
|
| /hardware/qcom/display/msm8998/sdm/include/utils/ |
| sync_task.h | 59 std::thread worker_thread(SyncTaskThread, this);
60 worker_thread_.swap(worker_thread);
|
| /external/fio/t/ |
| dedupe.c | 32 struct worker_thread { struct
278 static int do_work(struct worker_thread *thread, void *buf)
313 struct worker_thread *thread = data;
334 static void show_progress(struct worker_thread *threads, unsigned long total)
379 struct worker_thread *threads;
388 threads = malloc(num_threads * sizeof(struct worker_thread));
390 memset(&threads[i], 0, sizeof(struct worker_thread));
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| grpc_worker_service.cc | 78 for (auto& worker_thread : threads_) {
79 worker_thread->Shutdown();
110 for (auto& worker_thread : threads_) {
111 worker_thread->Start();
113 for (auto& worker_thread : threads_) {
114 worker_thread->Join();
|
