Searched refs:worker_thread_ (Results 1 - 25 of 30) sorted by relevance

12

/external/webrtc/webrtc/base/
H A Dworker.cc23 Worker::Worker() : worker_thread_(NULL) {}
29 ASSERT(!worker_thread_);
34 if (worker_thread_) {
35 if (worker_thread_ == me) {
44 worker_thread_ = me;
50 if (!worker_thread_) {
53 } else if (worker_thread_ != rtc::Thread::Current()) {
59 worker_thread_->Clear(this, MSG_HAVEWORK);
60 worker_thread_ = NULL;
65 ASSERT(worker_thread_ !
[all...]
H A Dworker.h65 Thread *worker_thread_; member in class:rtc::Worker
H A Dsharedexclusivelock_unittest.cc38 worker_thread_.reset(new Thread());
39 worker_thread_->Start();
45 scoped_ptr<Thread> worker_thread_; member in class:rtc::SharedExclusiveTask
59 worker_thread_->Post(this, kMsgRead, new TypedMessageData<int*>(value));
64 ASSERT(rtc::Thread::Current() == worker_thread_.get());
92 worker_thread_->Post(this, kMsgWrite, new TypedMessageData<int>(value));
97 ASSERT(rtc::Thread::Current() == worker_thread_.get());
/external/webrtc/talk/session/media/
H A Dmediamonitor.cc43 : worker_thread_(worker_thread),
50 worker_thread_->Clear(this);
57 worker_thread_->Post(this, MSG_MONITOR_START);
61 worker_thread_->Post(this, MSG_MONITOR_STOP);
70 ASSERT(rtc::Thread::Current() == worker_thread_);
78 ASSERT(rtc::Thread::Current() == worker_thread_);
81 worker_thread_->Clear(this);
86 ASSERT(rtc::Thread::Current() == worker_thread_);
99 ASSERT(rtc::Thread::Current() == worker_thread_);
105 worker_thread_
[all...]
H A Dchannelmanager.cc104 worker_thread_ = worker_thread;
126 worker_thread_->Invoke<void>(Bind(
190 ASSERT(worker_thread_ != NULL);
191 if (!worker_thread_) {
194 if (worker_thread_ != rtc::Thread::Current()) {
196 worker_thread_->Invoke<bool>(rtc::Bind(
197 &rtc::Thread::SetAllowBlockingCalls, worker_thread_, false));
200 initialized_ = worker_thread_->Invoke<bool>(Bind(
219 ASSERT(worker_thread_ == rtc::Thread::Current());
220 return (media_engine_->Init(worker_thread_));
[all...]
H A Dchannelmanager.h74 rtc::Thread* worker_thread() const { return worker_thread_; }
77 worker_thread_ = thread;
223 rtc::Thread* worker_thread_; member in class:cricket::ChannelManager
H A Dmediamonitor.h59 rtc::Thread* worker_thread_; member in class:cricket::MediaMonitor
H A Dchannel.cc174 : 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_
[all...]
H A Dchannel.h96 rtc::Thread* worker_thread() const { return worker_thread_; }
304 return worker_thread_->Invoke<bool>(functor);
308 rtc::Thread* worker_thread_; member in class:cricket::BaseChannel
/external/webrtc/webrtc/p2p/client/
H A Dsocketmonitor.cc28 worker_thread_ = worker_thread;
34 worker_thread_->Clear(this);
42 worker_thread_->Post(this, MSG_MONITOR_START);
46 worker_thread_->Post(this, MSG_MONITOR_STOP);
53 ASSERT(rtc::Thread::Current() == worker_thread_);
61 ASSERT(rtc::Thread::Current() == worker_thread_);
64 worker_thread_->Clear(this);
69 ASSERT(rtc::Thread::Current() == worker_thread_);
85 ASSERT(rtc::Thread::Current() == worker_thread_);
93 worker_thread_
[all...]
H A Dfakeportallocator.h93 worker_thread_(worker_thread),
104 port_.reset(TestUDPPort::Create(worker_thread_, factory_, &network_,
133 rtc::Thread* worker_thread_; member in class:cricket::FakePortAllocatorSession
145 : worker_thread_(worker_thread), factory_(factory) {
148 worker_thread_));
174 worker_thread_, factory_, content_name, component, ice_ufrag, ice_pwd);
178 rtc::Thread* worker_thread_; member in class:cricket::FakePortAllocator
H A Dsocketmonitor.h53 rtc::Thread* worker_thread_; member in class:cricket::ConnectionMonitor
/external/webrtc/talk/app/webrtc/
H A Dmediacontroller.cc46 : worker_thread_(worker_thread), channel_manager_(channel_manager) {
48 worker_thread_->Invoke<void>(
53 worker_thread_->Invoke<void>(rtc::Bind(&MediaController::Destruct_w, this));
57 RTC_DCHECK(worker_thread_->IsCurrent());
67 RTC_DCHECK(worker_thread_->IsCurrent());
77 RTC_DCHECK(worker_thread_->IsCurrent());
81 rtc::Thread* const worker_thread_; member in class:__anon25906::MediaController::rtc
H A Ddtlsidentitystore_unittest.cc81 : worker_thread_(new rtc::Thread()),
83 worker_thread_.get())),
86 RTC_CHECK(worker_thread_->Start());
97 rtc::scoped_ptr<rtc::Thread> worker_thread_; member in class:DtlsIdentityStoreTest
139 worker_thread_->Stop();
149 worker_thread_->Stop();
H A Dpeerconnectionfactory.cc128 worker_thread_(new rtc::Thread) {
133 worker_thread_->Start();
145 worker_thread_(worker_thread),
160 // Make sure |worker_thread_| and |signaling_thread_| outlive
170 delete worker_thread_;
184 new rtc::BasicPacketSocketFactory(worker_thread_));
192 worker_thread_->Invoke<cricket::MediaEngineInterface*>(rtc::Bind(
196 new cricket::ChannelManager(media_engine, worker_thread_));
204 signaling_thread_, worker_thread_);
308 return MediaControllerInterface::Create(worker_thread_,
[all...]
H A Ddtlsidentitystore.cc125 worker_thread_(worker_thread),
130 if (worker_thread_ != signaling_thread_) {
205 worker_thread_->Post(task, MSG_GENERATE_IDENTITY, msg);
240 if (worker_thread_ != signaling_thread_ && // Only do in background thread.
H A Ddtlsidentitystore.h147 rtc::Thread* const worker_thread_; member in class:webrtc::DtlsIdentityStoreImpl::rtc
H A Dpeerconnectionfactory.h111 rtc::Thread* worker_thread_; member in class:webrtc::PeerConnectionFactory
/external/webrtc/webrtc/p2p/base/
H A Dtransportcontroller.cc44 worker_thread_(worker_thread),
48 worker_thread_->Invoke<void>(
55 return worker_thread_->Invoke<bool>(rtc::Bind(
60 worker_thread_->Invoke<void>(
65 worker_thread_->Invoke<void>(
71 return worker_thread_->Invoke<bool>(rtc::Bind(
77 return worker_thread_->Invoke<bool>(rtc::Bind(
84 return worker_thread_->Invoke<bool>(
92 return worker_thread_->Invoke<bool>(
102 return worker_thread_
[all...]
H A Dp2ptransportchannel.cc212 worker_thread_(rtc::Thread::Current()),
234 ASSERT(worker_thread_ == rtc::Thread::Current());
243 ASSERT(worker_thread_ == rtc::Thread::Current());
278 ASSERT(worker_thread_ == rtc::Thread::Current());
289 ASSERT(worker_thread_ == rtc::Thread::Current());
339 ASSERT(worker_thread_ == rtc::Thread::Current());
348 ASSERT(worker_thread_ == rtc::Thread::Current());
401 ASSERT(worker_thread_ == rtc::Thread::Current());
432 ASSERT(worker_thread_ == rtc::Thread::Current());
476 ASSERT(worker_thread_
[all...]
H A Ddtlstransportchannel.cc96 worker_thread_(rtc::Thread::Current()),
398 ASSERT(rtc::Thread::Current() == worker_thread_);
438 ASSERT(rtc::Thread::Current() == worker_thread_);
452 ASSERT(rtc::Thread::Current() == worker_thread_);
517 ASSERT(rtc::Thread::Current() == worker_thread_);
530 ASSERT(rtc::Thread::Current() == worker_thread_);
H A Dp2ptransportchannel.h187 rtc::Thread* thread() { return worker_thread_; }
269 rtc::Thread* worker_thread_; member in class:cricket::P2PTransportChannel
H A Dtransportcontroller.h39 rtc::Thread* worker_thread() const { return worker_thread_; }
194 rtc::Thread* const worker_thread_ = nullptr; member in class:cricket::TransportController::rtc
H A Dtransportcontroller_unittest.cc61 if (!worker_thread_) {
62 worker_thread_.reset(new rtc::Thread());
63 worker_thread_->Start();
66 new TransportControllerForTest(worker_thread_.get()));
103 worker_thread_->Invoke<void>(rtc::Bind(
180 rtc::scoped_ptr<rtc::Thread> worker_thread_; // Not used for most tests. member in class:TransportControllerTest
/external/webrtc/talk/media/sctp/
H A Dsctpdataengine.h172 rtc::Thread* worker_thread() const { return worker_thread_; }
225 rtc::Thread* worker_thread_; member in class:cricket::SctpDataMediaChannel

Completed in 303 milliseconds

12