Lines Matching refs:worker_thread_
174 : worker_thread_(thread), in BaseChannel()
192 ASSERT(worker_thread_ == rtc::Thread::Current()); in BaseChannel()
197 ASSERT(worker_thread_ == rtc::Thread::Current()); in ~BaseChannel()
201 worker_thread_->Clear(this); // eats any outstanding messages or packets in ~BaseChannel()
245 return worker_thread_->Invoke<bool>( in SetTransport()
250 ASSERT(worker_thread_ == rtc::Thread::Current()); in SetTransport_w()
299 ASSERT(worker_thread_ == rtc::Thread::Current()); in set_transport_channel()
331 ASSERT(worker_thread_ == rtc::Thread::Current()); in set_rtcp_transport_channel()
367 ASSERT(worker_thread_ == rtc::Thread::Current()); in ConnectToTransportChannel()
376 ASSERT(worker_thread_ == rtc::Thread::Current()); in DisconnectFromTransportChannel()
385 worker_thread_->Invoke<void>(Bind( in Enable()
444 ASSERT(worker_thread_ == rtc::Thread::Current()); in GetConnectionStats()
501 ASSERT(worker_thread_ == rtc::Thread::Current()); in OnChannelRead()
565 if (rtc::Thread::Current() != worker_thread_) { in SendPacket()
571 worker_thread_->Post(this, message_id, data); in SendPacket()
788 ASSERT(worker_thread_ == rtc::Thread::Current()); in EnableMedia_w()
798 ASSERT(worker_thread_ == rtc::Thread::Current()); in DisableMedia_w()
817 ASSERT(worker_thread_ == rtc::Thread::Current()); in ChannelWritable_w()
981 ASSERT(worker_thread_ == rtc::Thread::Current()); in ChannelNotWritable_w()
1077 worker_thread_->Invoke<void>(Bind( in ActivateRtcpMux()
1321 ASSERT(rtc::Thread::Current() == worker_thread_); in FlushRtcpMessages()
1323 worker_thread_->Clear(this, MSG_RTCPPACKET, &rtcp_messages); in FlushRtcpMessages()
1326 worker_thread_->Send(this, MSG_RTCPPACKET, it->pdata); in FlushRtcpMessages()