Home
last modified time | relevance | path

Searched refs:worker_thread_ (Results 1 – 20 of 20) sorted by relevance

/external/chromium/third_party/libjingle/source/talk/session/phone/
Dmediamonitor.cc44 : worker_thread_(worker_thread), in MediaMonitor()
51 worker_thread_->Clear(this); in ~MediaMonitor()
58 worker_thread_->Post(this, MSG_MONITOR_START); in Start()
62 worker_thread_->Post(this, MSG_MONITOR_STOP); in Stop()
71 ASSERT(talk_base::Thread::Current() == worker_thread_); in OnMessage()
79 ASSERT(talk_base::Thread::Current() == worker_thread_); in OnMessage()
82 worker_thread_->Clear(this); in OnMessage()
87 ASSERT(talk_base::Thread::Current() == worker_thread_); in OnMessage()
100 ASSERT(talk_base::Thread::Current() == worker_thread_); in PollMediaChannel()
106 worker_thread_->PostDelayed(rate_, this, MSG_MONITOR_POLL); in PollMediaChannel()
Dchannelmanager.cc137 worker_thread_(worker_thread), in ChannelManager()
153 worker_thread_(worker_thread), in ChannelManager()
213 ASSERT(worker_thread_ != NULL); in Init()
214 if (worker_thread_ && worker_thread_->started()) { in Init()
310 worker_thread_, media_engine_.get(), media_channel, in CreateVoiceChannel_w()
359 worker_thread_, media_engine_.get(), media_channel, in CreateVideoChannel_w()
396 ASSERT(worker_thread_ == talk_base::Thread::Current()); in CreateSoundclip_w()
403 Soundclip* soundclip = new Soundclip(worker_thread_, soundclip_media); in CreateSoundclip_w()
465 ASSERT(worker_thread_ == talk_base::Thread::Current()); in SetAudioOptions_w()
486 ASSERT(worker_thread_ == talk_base::Thread::Current()); in SetOutputVolume_w()
[all …]
Dchannel.cc94 : worker_thread_(thread), in BaseChannel()
107 ASSERT(worker_thread_ == talk_base::Thread::Current()); in BaseChannel()
120 ASSERT(worker_thread_ == talk_base::Thread::Current()); in ~BaseChannel()
239 ASSERT(worker_thread_ == talk_base::Thread::Current()); in OnChannelRead()
257 if (talk_base::Thread::Current() != worker_thread_) { in SendPacket()
262 worker_thread_->Post(this, message_id, data); in SendPacket()
423 ASSERT(worker_thread_ == talk_base::Thread::Current()); in EnableMedia_w()
433 ASSERT(worker_thread_ == talk_base::Thread::Current()); in DisableMedia_w()
443 ASSERT(worker_thread_ == talk_base::Thread::Current()); in MuteMedia_w()
454 ASSERT(worker_thread_ == talk_base::Thread::Current()); in UnmuteMedia_w()
[all …]
Dsoundclip.cc53 : worker_thread_(thread), in Soundclip()
61 worker_thread_->Send(this, MSG_PLAYSOUND, &data); in PlaySound()
Dchannelmanager.h67 talk_base::Thread* worker_thread() const { return worker_thread_; } in worker_thread()
70 worker_thread_ = thread; in set_worker_thread()
193 talk_base::Thread* worker_thread_; variable
Dsoundclip.h64 talk_base::Thread* worker_thread_; variable
Dmediamonitor.h58 talk_base::Thread* worker_thread_; variable
Dchannel.h89 talk_base::Thread* worker_thread() const { return worker_thread_; } in worker_thread()
230 talk_base::Thread *worker_thread_;
/external/chromium/third_party/libjingle/source/talk/session/tunnel/
Dpseudotcpchannel.cc103 worker_thread_(NULL), in PseudoTcpChannel()
114 ASSERT(worker_thread_ == NULL); in ~PseudoTcpChannel()
130 worker_thread_ = session_->session_manager()->worker_thread(); in Connect()
175 worker_thread_->Clear(this, MSG_WK_CLOCK); in OnChannelDestroyed()
176 worker_thread_->Post(this, MSG_WK_PURGE); in OnChannelDestroyed()
194 ASSERT(worker_thread_ == NULL); in OnSessionTerminate()
320 ASSERT(worker_thread_->IsCurrent()); in OnChannelWritableState()
342 ASSERT(worker_thread_->IsCurrent()); in OnChannelRead()
360 ASSERT(worker_thread_->IsCurrent()); in OnChannelConnectionChanged()
374 worker_thread_->socketserver()->CreateSocket(SOCK_DGRAM)); in OnChannelConnectionChanged()
[all …]
Dpseudotcpchannel.h123 talk_base::Thread* signal_thread_, * worker_thread_, * stream_thread_; variable
/external/chromium/third_party/libjingle/source/talk/p2p/base/
Dp2ptransportchannel.cc169 worker_thread_(talk_base::Thread::Current()), in P2PTransportChannel()
180 ASSERT(worker_thread_ == talk_base::Thread::Current()); in ~P2PTransportChannel()
207 ASSERT(worker_thread_ == talk_base::Thread::Current()); in Connect()
218 ASSERT(worker_thread_ == talk_base::Thread::Current()); in Reset()
255 ASSERT(worker_thread_ == talk_base::Thread::Current()); in OnPortReady()
301 ASSERT(worker_thread_ == talk_base::Thread::Current()); in OnUnknownAddress()
357 ASSERT(worker_thread_ == talk_base::Thread::Current()); in OnCandidate()
372 ASSERT(worker_thread_ == talk_base::Thread::Current()); in CreateConnections()
525 worker_thread_->Post(this, MSG_SORT); in RequestSort()
534 ASSERT(worker_thread_ == talk_base::Thread::Current()); in SortConnections()
[all …]
Drawtransportchannel.cc68 worker_thread_ = raw_transport_->worker_thread(); in RawTransportChannel()
70 worker_thread_ = worker_thread; in RawTransportChannel()
230 worker_thread_->Post( in SetPort()
Dp2ptransportchannel.h139 talk_base::Thread* thread() const { return worker_thread_; } in thread()
143 talk_base::Thread *worker_thread_; variable
Dsessionmanager.h60 talk_base::Thread *worker_thread() const { return worker_thread_; } in worker_thread()
133 talk_base::Thread *worker_thread_; variable
Dtransport.h119 talk_base::Thread* worker_thread() { return worker_thread_; } in worker_thread()
255 talk_base::Thread* worker_thread_; variable
Drawtransportchannel.h94 talk_base::Thread *worker_thread_; variable
Dsessionmanager.cc46 worker_thread_ = talk_base::Thread::Current(); in SessionManager()
48 worker_thread_ = worker; in SessionManager()
Dtransport.cc86 worker_thread_(worker_thread), type_(type), allocator_(allocator), in Transport()
/external/chromium/third_party/libjingle/source/talk/examples/call/
Dcallclient.cc333 worker_thread_ = new talk_base::Thread(); in InitPhone()
337 worker_thread_->Start(); in InitPhone()
344 socket_factory_ = new talk_base::BasicPacketSocketFactory(worker_thread_); in InitPhone()
357 port_allocator_, worker_thread_); in InitPhone()
Dcallclient.h169 talk_base::Thread* worker_thread_; variable