/external/webrtc/talk/session/media/ |
H A D | 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);
|
H A D | mediamonitor.h | 45 MediaMonitor(rtc::Thread* worker_thread, 69 MediaMonitorT(MC* media_channel, rtc::Thread* worker_thread, argument 71 : MediaMonitor(worker_thread, monitor_thread),
|
H A D | mediamonitor.cc | 41 MediaMonitor::MediaMonitor(rtc::Thread* worker_thread, argument 43 : worker_thread_(worker_thread),
|
H A D | channelmanager.cc | 83 rtc::Thread* worker_thread) { 84 Construct(me, dme, cm, worker_thread); 88 rtc::Thread* worker_thread) { 92 worker_thread); 98 rtc::Thread* worker_thread) { 104 worker_thread_ = worker_thread; 80 ChannelManager(MediaEngineInterface* me, DataEngineInterface* dme, CaptureManager* cm, rtc::Thread* worker_thread) argument 87 ChannelManager(MediaEngineInterface* me, rtc::Thread* worker_thread) argument 95 Construct(MediaEngineInterface* me, DataEngineInterface* dme, CaptureManager* cm, rtc::Thread* worker_thread) argument
|
H A D | channelmanager.h | 74 rtc::Thread* worker_thread() const { return worker_thread_; } function in class:cricket::ChannelManager 187 rtc::Thread* worker_thread);
|
H A D | 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());
|
H A D | channel.cc | 430 this, worker_thread(), rtc::Thread::Current())); 843 ASSERT(worker_thread() == rtc::Thread::Current()); 1136 ASSERT(worker_thread() == rtc::Thread::Current()); 1141 ASSERT(worker_thread() == rtc::Thread::Current()); 1375 worker_thread()->PostDelayed(kEarlyMediaTimeout, this, 1379 worker_thread()->Clear(this, MSG_EARLYMEDIATIMEOUT); 1415 media_monitor_.reset(new VoiceMediaMonitor(media_channel(), worker_thread(), 1499 ASSERT(worker_thread() == rtc::Thread::Current()); 1544 ASSERT(worker_thread() == rtc::Thread::Current()); 1683 worker_thread() [all...] |
/external/valgrind/helgrind/tests/ |
H A D | 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/ |
H A D | mediacontroller.cc | 44 MediaController(rtc::Thread* worker_thread, argument 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); 91 Create( rtc::Thread* worker_thread, cricket::ChannelManager* channel_manager) argument
|
H A D | mediacontroller.h | 46 rtc::Thread* worker_thread,
|
H A D | 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 98 CreatePeerConnectionFactory( rtc::Thread* worker_thread, rtc::Thread* signaling_thread, AudioDeviceModule* default_adm, cricket::WebRtcVideoEncoderFactory* encoder_factory, cricket::WebRtcVideoDecoderFactory* decoder_factory) argument 136 PeerConnectionFactory( rtc::Thread* worker_thread, rtc::Thread* signaling_thread, AudioDeviceModule* default_adm, cricket::WebRtcVideoEncoderFactory* video_encoder_factory, cricket::WebRtcVideoDecoderFactory* video_decoder_factory) argument
|
H A D | peerconnectionfactory.h | 92 virtual rtc::Thread* worker_thread(); 98 rtc::Thread* worker_thread,
|
H A D | dtlsidentitystore.h | 104 rtc::Thread* worker_thread);
|
H A D | dtlsidentitystore.cc | 123 rtc::Thread* worker_thread) 125 worker_thread_(worker_thread), 122 DtlsIdentityStoreImpl(rtc::Thread* signaling_thread, rtc::Thread* worker_thread) argument
|
/external/webrtc/webrtc/p2p/client/ |
H A D | socketmonitor.cc | 25 rtc::Thread* worker_thread, 28 worker_thread_ = worker_thread; 24 ConnectionMonitor(ConnectionStatsGetter* stats_getter, rtc::Thread* worker_thread, rtc::Thread* monitoring_thread) argument
|
H A D | socketmonitor.h | 36 rtc::Thread* worker_thread,
|
H A D | fakeportallocator.h | 85 FakePortAllocatorSession(rtc::Thread* worker_thread, argument 93 worker_thread_(worker_thread), 143 FakePortAllocator(rtc::Thread* worker_thread, argument 145 : worker_thread_(worker_thread), factory_(factory) {
|
/external/autotest/scheduler/ |
H A D | thread_lib.py | 189 worker_thread = ExceptionRememberingThread( 196 self.drone_threads[drone] = worker_thread 198 worker_thread.setName('%s.%s' % 200 worker_thread.daemon = True 201 worker_thread.start()
|
/external/libchrome/base/task/ |
H A D | 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/ |
H A D | mediaengine.h | 74 virtual bool Init(rtc::Thread* worker_thread) = 0; 143 virtual bool Init(rtc::Thread* worker_thread) { argument 144 if (!voice_.Init(worker_thread))
|
/external/fio/t/ |
H A D | 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/webrtc/webrtc/p2p/base/ |
H A D | 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()); 40 TransportController(rtc::Thread* signaling_thread, rtc::Thread* worker_thread, PortAllocator* port_allocator) argument
|
H A D | transportcontroller.h | 33 rtc::Thread* worker_thread, 39 rtc::Thread* worker_thread() const { return worker_thread_; } function in class:cricket::TransportController
|
H A D | faketransportcontroller.h | 481 explicit FakeTransportController(rtc::Thread* worker_thread) argument 482 : TransportController(rtc::Thread::Current(), worker_thread, nullptr), 485 FakeTransportController(rtc::Thread* worker_thread, IceRole role) argument 486 : TransportController(rtc::Thread::Current(), worker_thread, nullptr), 497 worker_thread()->Invoke<void>(
|
/external/webrtc/talk/media/sctp/ |
H A D | sctpdataengine.h | 172 rtc::Thread* worker_thread() const { return worker_thread_; } function in class:cricket::SctpDataMediaChannel
|