| /external/bluetooth/bluedroid/hci/src/ |
| D | bt_hci_bdroid.c | 87 thread_t *worker_thread; member
221 if (hc_cb.worker_thread) in bthc_rx_ready()
222 thread_post(hc_cb.worker_thread, event_rx, NULL); in bthc_rx_ready()
230 if (hc_cb.worker_thread) { in bthc_tx()
233 thread_post(hc_cb.worker_thread, event_tx, NULL); in bthc_tx()
242 if (hc_cb.worker_thread) in bthc_idle_timeout()
243 thread_post(hc_cb.worker_thread, event_lpm_idle_timeout, NULL); in bthc_idle_timeout()
261 thread_free(hc_cb.worker_thread); in epilog_wait_timeout()
264 hc_cb.worker_thread = NULL; in epilog_wait_timeout()
355 if (hc_cb.worker_thread) in init()
[all …]
|
| /external/chromium_org/third_party/libjingle/source/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(talk_base::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
75 assert(talk_base::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
78 voice_channel_->worker_thread()->Clear(this); in OnMessage()
83 assert(talk_base::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
101 assert(talk_base::Thread::Current() == voice_channel_->worker_thread()); in PollVoiceChannel()
110 voice_channel_->worker_thread()->PostDelayed(rate_, this, MSG_MONITOR_POLL); in PollVoiceChannel()
|
| D | mediamonitor.h | 44 MediaMonitor(talk_base::Thread* worker_thread,
68 MediaMonitorT(MC* media_channel, talk_base::Thread* worker_thread, in MediaMonitorT() argument
70 : MediaMonitor(worker_thread, monitor_thread), in MediaMonitorT()
|
| D | mediamonitor.cc | 41 MediaMonitor::MediaMonitor(talk_base::Thread* worker_thread, in MediaMonitor() argument
43 : worker_thread_(worker_thread), in MediaMonitor()
|
| D | typingmonitor.cc | 37 talk_base::Thread* worker_thread, in TypingMonitor() argument
40 worker_thread_(worker_thread), in TypingMonitor()
|
| D | channel.cc | 298 worker_thread(), in StartConnectionMonitor()
989 ASSERT(worker_thread() == talk_base::Thread::Current()); in AddRecvStream_w()
997 ASSERT(worker_thread() == talk_base::Thread::Current()); in RemoveRecvStream_w()
1302 worker_thread()->PostDelayed(kEarlyMediaTimeout, this, in SetEarlyMedia()
1306 worker_thread()->Clear(this, MSG_EARLYMEDIATIMEOUT); in SetEarlyMedia()
1346 media_monitor_.reset(new VoiceMediaMonitor(media_channel(), worker_thread(), in StartMediaMonitor()
1380 typing_monitor_.reset(new TypingMonitor(this, worker_thread(), settings)); in StartTypingMonitor()
1452 ASSERT(worker_thread() == talk_base::Thread::Current()); in SetLocalContent_w()
1490 ASSERT(worker_thread() == talk_base::Thread::Current()); in SetRemoteContent_w()
1541 ASSERT(worker_thread() == talk_base::Thread::Current()); in SetRingbackTone_w()
[all …]
|
| D | channelmanager.cc | 80 ChannelManager::ChannelManager(talk_base::Thread* worker_thread) { in ChannelManager() argument
85 worker_thread); in ChannelManager()
93 talk_base::Thread* worker_thread) { in ChannelManager() argument
94 Construct(me, dme, dm, cm, worker_thread); in ChannelManager()
99 talk_base::Thread* worker_thread) { in ChannelManager() argument
104 worker_thread); in ChannelManager()
111 talk_base::Thread* worker_thread) { in Construct() argument
118 worker_thread_ = worker_thread; in Construct()
|
| /external/chromium_org/content/worker/ |
| D | websharedworker_stub.cc | 35 WorkerThread* worker_thread = WorkerThread::current(); in WebSharedWorkerStub() local
36 DCHECK(worker_thread); in WebSharedWorkerStub()
37 worker_thread->AddWorkerStub(this); in WebSharedWorkerStub()
39 worker_thread->GetRouter()->AddRoute(route_id_, this); in WebSharedWorkerStub()
57 WorkerThread* worker_thread = WorkerThread::current(); in ~WebSharedWorkerStub() local
58 DCHECK(worker_thread); in ~WebSharedWorkerStub()
59 worker_thread->RemoveWorkerStub(this); in ~WebSharedWorkerStub()
60 worker_thread->GetRouter()->RemoveRoute(route_id_); in ~WebSharedWorkerStub()
|
| D | BUILD.gn | 15 "worker_thread.cc",
16 "worker_thread.h",
|
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| D | transport.cc | 122 talk_base::Thread* worker_thread, in Transport() argument
127 worker_thread_(worker_thread), in Transport()
170 ASSERT(worker_thread()->IsCurrent()); in GetRemoteCertificate_w()
202 ASSERT(worker_thread()->IsCurrent()); in CreateChannel_w()
278 ASSERT(worker_thread()->IsCurrent()); in DestroyChannel_w()
312 ASSERT(worker_thread()->IsCurrent()); in ConnectChannels_w()
351 worker_thread()->Clear(this); in DestroyAllChannels()
357 ASSERT(worker_thread()->IsCurrent()); in DestroyAllChannels_w()
382 ASSERT(worker_thread()->IsCurrent()); in ResetChannels_w()
399 worker_thread()->Post(this, MSG_ONSIGNALINGREADY, NULL); in OnSignalingReady()
[all …]
|
| D | rawtransport.cc | 44 talk_base::Thread* worker_thread, in RawTransport() argument
47 : Transport(signaling_thread, worker_thread, in RawTransport()
123 worker_thread(), in CreateTransportChannel()
|
| D | rawtransportchannel.cc | 57 talk_base::Thread *worker_thread, in RawTransportChannel() argument
67 if (worker_thread == NULL) in RawTransportChannel()
68 worker_thread_ = raw_transport_->worker_thread(); in RawTransportChannel()
70 worker_thread_ = worker_thread; in RawTransportChannel()
|
| D | fakesession.h | 335 talk_base::Thread* worker_thread,
338 : Transport(signaling_thread, worker_thread,
442 FakeSession(talk_base::Thread* worker_thread, bool initiator) in FakeSession() argument
444 worker_thread, in FakeSession()
492 return new FakeTransport(signaling_thread(), worker_thread(), content_name); in CreateTransport()
|
| /external/chromium_org/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.message_loop_proxy().get(), in TEST_F()
92 task_tracker_.PostTaskAndReply(worker_thread.message_loop_proxy().get(), in TEST_F()
100 worker_thread.Stop(); in TEST_F()
166 Thread worker_thread("worker thread"); in TEST_F() local
167 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
170 task_tracker_.PostTaskAndReply(worker_thread.message_loop_proxy().get(), in TEST_F()
178 worker_thread.Stop(); in TEST_F()
|
| /external/chromium_org/third_party/libjingle/source/talk/app/webrtc/ |
| D | portallocatorfactory.cc | 42 talk_base::Thread* worker_thread) { in Create() argument
44 new talk_base::RefCountedObject<PortAllocatorFactory>(worker_thread); in Create()
48 PortAllocatorFactory::PortAllocatorFactory(talk_base::Thread* worker_thread) in PortAllocatorFactory() argument
50 socket_factory_(new talk_base::BasicPacketSocketFactory(worker_thread)) { in PortAllocatorFactory()
|
| D | peerconnectionfactory.cc | 127 talk_base::Thread* worker_thread, in CreatePeerConnectionFactory() argument
133 new talk_base::RefCountedObject<PeerConnectionFactory>(worker_thread, in CreatePeerConnectionFactory()
155 talk_base::Thread* worker_thread, in PeerConnectionFactory() argument
162 worker_thread_(worker_thread), in PeerConnectionFactory()
166 ASSERT(worker_thread != NULL); in PeerConnectionFactory()
376 talk_base::Thread* PeerConnectionFactory::worker_thread() { in worker_thread() function in webrtc::PeerConnectionFactory
|
| D | portallocatorfactory.h | 53 talk_base::Thread* worker_thread);
60 explicit PortAllocatorFactory(talk_base::Thread* worker_thread);
|
| D | peerconnectionfactory.h | 79 virtual talk_base::Thread* worker_thread();
85 talk_base::Thread* worker_thread,
|
| /external/chromium_org/third_party/libjingle/source/talk/p2p/client/ |
| D | fakeportallocator.h | 23 FakePortAllocatorSession(talk_base::Thread* worker_thread, in FakePortAllocatorSession() argument
31 worker_thread_(worker_thread), in FakePortAllocatorSession()
80 FakePortAllocator(talk_base::Thread* worker_thread, in FakePortAllocator() argument
82 : worker_thread_(worker_thread), factory_(factory) { in FakePortAllocator()
|
| D | socketmonitor.cc | 42 talk_base::Thread* worker_thread, in SocketMonitor() argument
45 channel_thread_ = worker_thread; in SocketMonitor()
|
| /external/valgrind/main/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/chromium_org/third_party/libjingle/source/talk/media/base/ |
| D | mediaengine.h | 72 virtual bool Init(talk_base::Thread* worker_thread) = 0;
183 virtual bool Init(talk_base::Thread* worker_thread) { in Init() argument
184 if (!voice_.Init(worker_thread)) in Init()
186 if (!video_.Init(worker_thread)) { in Init()
304 bool Init(talk_base::Thread* worker_thread) { return true; } in Init() argument
349 bool Init(talk_base::Thread* worker_thread) { return true; } in Init() argument
|
| D | hybridvideoengine.h | 152 bool Init(talk_base::Thread* worker_thread) { in Init() argument
153 if (!video1_.Init(worker_thread)) { in Init()
157 if (!video2_.Init(worker_thread)) { in Init()
|
| /external/chromium_org/content/ |
| D | content_worker.gypi | 20 'worker/worker_thread.cc',
21 'worker/worker_thread.h',
|
| /external/chromium_org/third_party/libjingle/source/talk/media/webrtc/ |
| D | webrtcvideoengine.h | 105 bool Init(talk_base::Thread* worker_thread);
153 talk_base::Thread* worker_thread() { return worker_thread_; } in worker_thread() function
394 talk_base::MessageQueue* worker_thread() { return engine_->worker_thread(); } in worker_thread() function
|