/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());
|