Searched refs:worker_thread (Results 1 - 25 of 37) sorted by relevance

12

/external/webrtc/talk/session/media/
H A Daudiomonitor.cc47 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 Dmediamonitor.h45 MediaMonitor(rtc::Thread* worker_thread,
69 MediaMonitorT(MC* media_channel, rtc::Thread* worker_thread, argument
71 : MediaMonitor(worker_thread, monitor_thread),
H A Dmediamonitor.cc41 MediaMonitor::MediaMonitor(rtc::Thread* worker_thread, argument
43 : worker_thread_(worker_thread),
H A Dchannelmanager.cc83 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 Dchannelmanager.h74 rtc::Thread* worker_thread() const { return worker_thread_; } function in class:cricket::ChannelManager
187 rtc::Thread* worker_thread);
H A Dchannelmanager_unittest.cc95 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 Dchannel.cc430 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 Dtc03_re_excl.c16 static void* worker_thread ( void* argV ) function
30 pthread_create(&thread_id, 0, worker_thread, (void*)x);
/external/webrtc/talk/app/webrtc/
H A Dmediacontroller.cc44 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 Dmediacontroller.h46 rtc::Thread* worker_thread,
H A Dpeerconnectionfactory.cc99 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 Dpeerconnectionfactory.h92 virtual rtc::Thread* worker_thread();
98 rtc::Thread* worker_thread,
H A Ddtlsidentitystore.h104 rtc::Thread* worker_thread);
H A Ddtlsidentitystore.cc123 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 Dsocketmonitor.cc25 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 Dsocketmonitor.h36 rtc::Thread* worker_thread,
H A Dfakeportallocator.h85 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 Dthread_lib.py189 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 Dcancelable_task_tracker_unittest.cc84 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 Dmediaengine.h74 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 Ddedupe.c32 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 Dtransportcontroller.cc41 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 Dtransportcontroller.h33 rtc::Thread* worker_thread,
39 rtc::Thread* worker_thread() const { return worker_thread_; } function in class:cricket::TransportController
H A Dfaketransportcontroller.h481 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 Dsctpdataengine.h172 rtc::Thread* worker_thread() const { return worker_thread_; } function in class:cricket::SctpDataMediaChannel

Completed in 1307 milliseconds

12