Home
last modified time | relevance | path

Searched refs:worker_thread (Results 1 – 25 of 60) sorted by relevance

123

/external/bluetooth/bluedroid/hci/src/
Dbt_hci_bdroid.c87 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/
Daudiomonitor.cc47 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()
Dmediamonitor.h45 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()
Dmediamonitor.cc41 MediaMonitor::MediaMonitor(rtc::Thread* worker_thread, in MediaMonitor() argument
43 : worker_thread_(worker_thread), in MediaMonitor()
Dtypingmonitor.cc37 rtc::Thread* worker_thread, in TypingMonitor() argument
40 worker_thread_(worker_thread), in TypingMonitor()
Dchannel.cc283 worker_thread(), in StartConnectionMonitor()
1010 ASSERT(worker_thread() == rtc::Thread::Current()); in AddRecvStream_w()
1018 ASSERT(worker_thread() == rtc::Thread::Current()); in RemoveRecvStream_w()
1308 worker_thread()->PostDelayed(kEarlyMediaTimeout, this, in SetEarlyMedia()
1312 worker_thread()->Clear(this, MSG_EARLYMEDIATIMEOUT); in SetEarlyMedia()
1352 media_monitor_.reset(new VoiceMediaMonitor(media_channel(), worker_thread(), in StartMediaMonitor()
1386 typing_monitor_.reset(new TypingMonitor(this, worker_thread(), settings)); in StartTypingMonitor()
1458 ASSERT(worker_thread() == rtc::Thread::Current()); in SetLocalContent_w()
1496 ASSERT(worker_thread() == rtc::Thread::Current()); in SetRemoteContent_w()
1547 ASSERT(worker_thread() == rtc::Thread::Current()); in SetRingbackTone_w()
[all …]
Dchannelmanager.cc80 ChannelManager::ChannelManager(rtc::Thread* worker_thread) { in ChannelManager() argument
85 worker_thread); in ChannelManager()
93 rtc::Thread* worker_thread) { in ChannelManager() argument
94 Construct(me, dme, dm, cm, worker_thread); in ChannelManager()
99 rtc::Thread* worker_thread) { in ChannelManager() argument
104 worker_thread); in ChannelManager()
111 rtc::Thread* worker_thread) { in Construct() argument
118 worker_thread_ = worker_thread; in Construct()
Dtypingmonitor.h62 TypingMonitor(VoiceChannel* channel, rtc::Thread* worker_thread,
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/
Dtransport.cc140 rtc::Thread* worker_thread, in Transport() argument
145 worker_thread_(worker_thread), in Transport()
188 ASSERT(worker_thread()->IsCurrent()); in GetRemoteCertificate_w()
220 ASSERT(worker_thread()->IsCurrent()); in CreateChannel_w()
296 ASSERT(worker_thread()->IsCurrent()); in DestroyChannel_w()
330 ASSERT(worker_thread()->IsCurrent()); in ConnectChannels_w()
369 worker_thread()->Clear(this); in DestroyAllChannels()
375 ASSERT(worker_thread()->IsCurrent()); in DestroyAllChannels_w()
400 ASSERT(worker_thread()->IsCurrent()); in ResetChannels_w()
417 worker_thread()->Post(this, MSG_ONSIGNALINGREADY, NULL); in OnSignalingReady()
[all …]
Drawtransport.cc44 rtc::Thread* worker_thread, in RawTransport() argument
47 : Transport(signaling_thread, worker_thread, in RawTransport()
123 worker_thread(), in CreateTransportChannel()
Drawtransportchannel.cc57 rtc::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()
Dfakesession.h335 rtc::Thread* worker_thread,
338 : Transport(signaling_thread, worker_thread,
442 FakeSession(rtc::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()
Dsessionmanager.h56 rtc::Thread *worker_thread = NULL);
60 rtc::Thread *worker_thread() const { return worker_thread_; } in worker_thread() function
Ddtlstransport.h47 rtc::Thread* worker_thread, in DtlsTransport() argument
51 : Base(signaling_thread, worker_thread, content_name, allocator), in DtlsTransport()
/external/chromium_org/base/task/
Dcancelable_task_tracker_unittest.cc84 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/
Dportallocatorfactory.cc42 rtc::Thread* worker_thread) { in Create() argument
44 new rtc::RefCountedObject<PortAllocatorFactory>(worker_thread); in Create()
48 PortAllocatorFactory::PortAllocatorFactory(rtc::Thread* worker_thread) in PortAllocatorFactory() argument
50 socket_factory_(new rtc::BasicPacketSocketFactory(worker_thread)) { in PortAllocatorFactory()
Dpeerconnectionfactory.cc128 rtc::Thread* worker_thread, in CreatePeerConnectionFactory() argument
134 new rtc::RefCountedObject<PeerConnectionFactory>(worker_thread, in CreatePeerConnectionFactory()
156 rtc::Thread* worker_thread, in PeerConnectionFactory() argument
163 worker_thread_(worker_thread), in PeerConnectionFactory()
167 ASSERT(worker_thread != NULL); in PeerConnectionFactory()
377 rtc::Thread* PeerConnectionFactory::worker_thread() { in worker_thread() function in webrtc::PeerConnectionFactory
Dportallocatorfactory.h53 rtc::Thread* worker_thread);
60 explicit PortAllocatorFactory(rtc::Thread* worker_thread);
Dpeerconnectionfactory.h79 virtual rtc::Thread* worker_thread();
85 rtc::Thread* worker_thread,
/external/chromium_org/third_party/libjingle/source/talk/p2p/client/
Dfakeportallocator.h46 FakePortAllocatorSession(rtc::Thread* worker_thread, in FakePortAllocatorSession() argument
54 worker_thread_(worker_thread), in FakePortAllocatorSession()
111 FakePortAllocator(rtc::Thread* worker_thread, in FakePortAllocator() argument
113 : worker_thread_(worker_thread), factory_(factory) { in FakePortAllocator()
Dsocketmonitor.cc42 rtc::Thread* worker_thread, in SocketMonitor() argument
45 channel_thread_ = worker_thread; in SocketMonitor()
/external/chromium_org/third_party/libjingle/source/talk/media/base/
Dmediaengine.h72 virtual bool Init(rtc::Thread* worker_thread) = 0;
180 virtual bool Init(rtc::Thread* worker_thread) { in Init() argument
181 if (!voice_.Init(worker_thread)) in Init()
183 if (!video_.Init(worker_thread)) { in Init()
294 bool Init(rtc::Thread* worker_thread) { return true; } in Init() argument
339 bool Init(rtc::Thread* worker_thread) { return true; } in Init() argument
/external/valgrind/main/helgrind/tests/
Dtc03_re_excl.c16 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/webrtc/
Dwebrtcvideoengine.h107 bool Init(rtc::Thread* worker_thread);
155 rtc::Thread* worker_thread() { return worker_thread_; } in worker_thread() function
416 rtc::MessageQueue* worker_thread() { return engine_->worker_thread(); } in worker_thread() function
Dwebrtcmediaengine.h100 virtual bool Init(rtc::Thread* worker_thread) OVERRIDE { in Init() argument
101 return delegate_->Init(worker_thread); in Init()

123