| /external/webrtc/talk/session/media/ |
| D | audiomonitor.cc | 47 voice_channel_->worker_thread()->Clear(this); in ~AudioMonitor()
55 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_START); in Start()
59 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_STOP); in Stop()
67 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
75 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
78 voice_channel_->worker_thread()->Clear(this); in OnMessage()
83 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
101 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in PollVoiceChannel()
110 voice_channel_->worker_thread()->PostDelayed(rate_, this, MSG_MONITOR_POLL); in PollVoiceChannel()
|
| D | mediamonitor.h | 45 MediaMonitor(rtc::Thread* worker_thread,
69 MediaMonitorT(MC* media_channel, rtc::Thread* worker_thread, in MediaMonitorT() argument
71 : MediaMonitor(worker_thread, monitor_thread), in MediaMonitorT()
|
| D | mediamonitor.cc | 41 MediaMonitor::MediaMonitor(rtc::Thread* worker_thread, in MediaMonitor() argument
43 : worker_thread_(worker_thread), in MediaMonitor()
|
| D | channelmanager.cc | 83 rtc::Thread* worker_thread) { in ChannelManager() argument
84 Construct(me, dme, cm, worker_thread); in ChannelManager()
88 rtc::Thread* worker_thread) { in ChannelManager() argument
92 worker_thread); in ChannelManager()
98 rtc::Thread* worker_thread) { in Construct() argument
104 worker_thread_ = worker_thread; in Construct()
|
| D | channel.cc | 430 this, worker_thread(), rtc::Thread::Current())); in StartConnectionMonitor()
843 ASSERT(worker_thread() == rtc::Thread::Current()); in SignalDtlsSetupFailure_w()
1136 ASSERT(worker_thread() == rtc::Thread::Current()); in AddRecvStream_w()
1141 ASSERT(worker_thread() == rtc::Thread::Current()); in RemoveRecvStream_w()
1375 worker_thread()->PostDelayed(kEarlyMediaTimeout, this, in SetEarlyMedia()
1379 worker_thread()->Clear(this, MSG_EARLYMEDIATIMEOUT); in SetEarlyMedia()
1415 media_monitor_.reset(new VoiceMediaMonitor(media_channel(), worker_thread(), in StartMediaMonitor()
1499 ASSERT(worker_thread() == rtc::Thread::Current()); in SetLocalContent_w()
1544 ASSERT(worker_thread() == rtc::Thread::Current()); in SetRemoteContent_w()
1683 worker_thread()->Invoke<void>(Bind( in SetRenderer()
[all …]
|
| D | channelmanager_unittest.cc | 95 EXPECT_EQ(rtc::Thread::Current(), cm_->worker_thread()); in TEST_F()
106 EXPECT_EQ(rtc::Thread::Current(), cm_->worker_thread()); in TEST_F()
108 EXPECT_EQ(&worker_, cm_->worker_thread()); in TEST_F()
|
| D | channelmanager.h | 74 rtc::Thread* worker_thread() const { return worker_thread_; } in worker_thread() function
187 rtc::Thread* worker_thread);
|
| /external/webrtc/talk/app/webrtc/ |
| D | mediacontroller.cc | 44 MediaController(rtc::Thread* worker_thread, in MediaController() argument
46 : worker_thread_(worker_thread), channel_manager_(channel_manager) { in MediaController()
47 RTC_DCHECK(nullptr != worker_thread); in MediaController()
92 rtc::Thread* worker_thread, in Create() argument
94 return new MediaController(worker_thread, channel_manager); in Create()
|
| D | peerconnectionfactory.cc | 99 rtc::Thread* worker_thread, in CreatePeerConnectionFactory() argument
105 new rtc::RefCountedObject<PeerConnectionFactory>(worker_thread, in CreatePeerConnectionFactory()
137 rtc::Thread* worker_thread, in PeerConnectionFactory() argument
145 worker_thread_(worker_thread), in PeerConnectionFactory()
149 ASSERT(worker_thread != NULL); in PeerConnectionFactory()
318 rtc::Thread* PeerConnectionFactory::worker_thread() { in worker_thread() function in webrtc::PeerConnectionFactory
|
| D | peerconnectionfactory.h | 92 virtual rtc::Thread* worker_thread();
98 rtc::Thread* worker_thread,
|
| D | mediacontroller.h | 46 rtc::Thread* worker_thread,
|
| D | dtlsidentitystore.cc | 123 rtc::Thread* worker_thread) in DtlsIdentityStoreImpl() argument
125 worker_thread_(worker_thread), in DtlsIdentityStoreImpl()
|
| D | dtlsidentitystore.h | 104 rtc::Thread* worker_thread);
|
| /external/libchrome/base/task/ |
| D | cancelable_task_tracker_unittest.cc | 84 Thread worker_thread("worker thread"); in TEST_F() local
85 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
87 ignore_result(task_tracker_.PostTask(worker_thread.task_runner().get(), in TEST_F()
92 worker_thread.task_runner().get(), FROM_HERE, in TEST_F()
98 worker_thread.Stop(); in TEST_F()
164 Thread worker_thread("worker thread"); in TEST_F() local
165 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
168 worker_thread.task_runner().get(), FROM_HERE, Bind(&DoNothing), in TEST_F()
174 worker_thread.Stop(); in TEST_F()
|
| /external/autotest/scheduler/ |
| 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/valgrind/helgrind/tests/ |
| D | tc03_re_excl.c | 16 static void* worker_thread ( void* argV ) in worker_thread() function
30 pthread_create(&thread_id, 0, worker_thread, (void*)x); in main()
|
| /external/webrtc/webrtc/p2p/client/ |
| D | fakeportallocator.h | 85 FakePortAllocatorSession(rtc::Thread* worker_thread, in FakePortAllocatorSession() argument
93 worker_thread_(worker_thread), in FakePortAllocatorSession()
143 FakePortAllocator(rtc::Thread* worker_thread, in FakePortAllocator() argument
145 : worker_thread_(worker_thread), factory_(factory) { in FakePortAllocator()
|
| D | socketmonitor.cc | 25 rtc::Thread* worker_thread, in ConnectionMonitor() argument
28 worker_thread_ = worker_thread; in ConnectionMonitor()
|
| D | socketmonitor.h | 36 rtc::Thread* worker_thread,
|
| /external/webrtc/webrtc/p2p/base/ |
| D | transportcontroller.cc | 41 rtc::Thread* worker_thread, in TransportController() argument
44 worker_thread_(worker_thread), in TransportController()
349 RTC_DCHECK(worker_thread()->IsCurrent()); in GetSslRole_w()
408 RTC_DCHECK(worker_thread()->IsCurrent()); in SetLocalTransportDescription_w()
427 RTC_DCHECK(worker_thread()->IsCurrent()); in SetRemoteTransportDescription_w()
451 RTC_DCHECK(worker_thread()->IsCurrent()); in AddRemoteCandidates_w()
465 RTC_DCHECK(worker_thread()->IsCurrent()); in ReadyForRemoteCandidates_w()
476 RTC_DCHECK(worker_thread()->IsCurrent()); in GetStats_w()
|
| D | faketransportcontroller.h | 481 explicit FakeTransportController(rtc::Thread* worker_thread) in FakeTransportController() argument
482 : TransportController(rtc::Thread::Current(), worker_thread, nullptr), in FakeTransportController()
485 FakeTransportController(rtc::Thread* worker_thread, IceRole role) in FakeTransportController() argument
486 : TransportController(rtc::Thread::Current(), worker_thread, nullptr), in FakeTransportController()
497 worker_thread()->Invoke<void>( in Connect()
|
| D | transportcontroller.h | 33 rtc::Thread* worker_thread,
39 rtc::Thread* worker_thread() const { return worker_thread_; } in worker_thread() function
|
| /external/fio/t/ |
| D | dedupe.c | 32 struct worker_thread { struct
278 static int do_work(struct worker_thread *thread, void *buf) in do_work()
313 struct worker_thread *thread = data; in thread_fn()
334 static void show_progress(struct worker_thread *threads, unsigned long total) in show_progress()
379 struct worker_thread *threads; in run_dedupe_threads()
388 threads = malloc(num_threads * sizeof(struct worker_thread)); in run_dedupe_threads()
390 memset(&threads[i], 0, sizeof(struct worker_thread)); in run_dedupe_threads()
|
| /external/webrtc/talk/media/base/ |
| D | mediaengine.h | 74 virtual bool Init(rtc::Thread* worker_thread) = 0;
143 virtual bool Init(rtc::Thread* worker_thread) { in Init() argument
144 if (!voice_.Init(worker_thread)) in Init()
|
| /external/chromium-trace/catapult/third_party/gsutil/gslib/ |
| D | command.py | 1209 worker_thread = WorkerThread(None, False)
1243 worker_thread.PerformTask(task, self)
1251 worker_thread.shared_vars_updater.Update(caller_id, self)
1647 worker_thread = WorkerThread(
1651 self.threads.append(worker_thread)
1652 worker_thread.start()
|