Lines Matching full:worker_thread_
174 : worker_thread_(thread),
192 ASSERT(worker_thread_ == rtc::Thread::Current());
197 ASSERT(worker_thread_ == rtc::Thread::Current());
201 worker_thread_->Clear(this); // eats any outstanding messages or packets
245 return worker_thread_->Invoke<bool>(
250 ASSERT(worker_thread_ == rtc::Thread::Current());
299 ASSERT(worker_thread_ == rtc::Thread::Current());
331 ASSERT(worker_thread_ == rtc::Thread::Current());
367 ASSERT(worker_thread_ == rtc::Thread::Current());
376 ASSERT(worker_thread_ == rtc::Thread::Current());
385 worker_thread_->Invoke<void>(Bind(
444 ASSERT(worker_thread_ == rtc::Thread::Current());
501 ASSERT(worker_thread_ == rtc::Thread::Current());
565 if (rtc::Thread::Current() != worker_thread_) {
571 worker_thread_->Post(this, message_id, data);
788 ASSERT(worker_thread_ == rtc::Thread::Current());
798 ASSERT(worker_thread_ == rtc::Thread::Current());
817 ASSERT(worker_thread_ == rtc::Thread::Current());
981 ASSERT(worker_thread_ == rtc::Thread::Current());
1077 worker_thread_->Invoke<void>(Bind(
1321 ASSERT(rtc::Thread::Current() == worker_thread_);
1323 worker_thread_->Clear(this, MSG_RTCPPACKET, &rtcp_messages);
1326 worker_thread_->Send(this, MSG_RTCPPACKET, it->pdata);
