| /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),
|
| channelmanager.h | 74 rtc::Thread* worker_thread() const { return worker_thread_; } function in class:cricket::ChannelManager
187 rtc::Thread* worker_thread);
|
| channelmanager_unittest.cc | 95 EXPECT_EQ(rtc::Thread::Current(), cm_->worker_thread());
106 EXPECT_EQ(rtc::Thread::Current(), cm_->worker_thread());
108 EXPECT_EQ(&worker_, cm_->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);
|
| fixed_queue_test.cc | 336 thread_t* worker_thread = thread_new("test_fixed_queue_worker_thread");
337 ASSERT_TRUE(worker_thread != NULL);
339 fixed_queue_register_dequeue(queue, thread_get_reactor(worker_thread),
348 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,
|
| /cts/hostsidetests/security/securityPatch/CVE-2016-8444/ |
| poc.c | 43 void *worker_thread(void *arg) { function
73 pthread_create(&th[i], 0, worker_thread, (void *)(long)i);
|
| /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/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 | 84 Thread worker_thread("worker thread");
85 ASSERT_TRUE(worker_thread.Start());
87 ignore_result(task_tracker_.PostTask(worker_thread.task_runner().get(),
92 worker_thread.task_runner().get(), FROM_HERE,
98 worker_thread.Stop();
164 Thread worker_thread("worker thread");
165 ASSERT_TRUE(worker_thread.Start());
168 worker_thread.task_runner().get(), FROM_HERE, Bind(&DoNothing),
174 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))
|
| /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/msm8998/sdm/include/utils/ |
| sync_task.h | 59 std::thread worker_thread(SyncTaskThread, this);
60 worker_thread_.swap(worker_thread);
|
| /system/bt/btif/src/ |
| btif_a2dp_sink.cc | 83 thread_t* worker_thread; member in struct:__anon113345
147 btif_a2dp_sink_cb.worker_thread = thread_new("btif_a2dp_sink_worker_thread");
148 if (btif_a2dp_sink_cb.worker_thread == NULL) {
161 thread_get_reactor(btif_a2dp_sink_cb.worker_thread),
167 thread_post(btif_a2dp_sink_cb.worker_thread, btif_a2dp_sink_startup_delayed,
196 thread_post(btif_a2dp_sink_cb.worker_thread, btif_a2dp_sink_shutdown_delayed,
198 thread_free(btif_a2dp_sink_cb.worker_thread);
199 btif_a2dp_sink_cb.worker_thread = NULL;
297 if (btif_a2dp_sink_cb.worker_thread != NULL) {
298 thread_post(btif_a2dp_sink_cb.worker_thread,
[all...] |
| /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/ltp/testcases/realtime/func/prio-wake/ |
| prio-wake.c | 130 void *worker_thread(void *arg) function
209 create_fifo_thread(worker_thread, (void *)(intptr_t) i, prio);
|
| /external/webrtc/webrtc/p2p/base/ |
| transportcontroller.cc | 41 rtc::Thread* worker_thread,
44 worker_thread_(worker_thread),
349 RTC_DCHECK(worker_thread()->IsCurrent());
408 RTC_DCHECK(worker_thread()->IsCurrent());
427 RTC_DCHECK(worker_thread()->IsCurrent());
451 RTC_DCHECK(worker_thread()->IsCurrent());
465 RTC_DCHECK(worker_thread()->IsCurrent());
476 RTC_DCHECK(worker_thread()->IsCurrent());
|
