Home
last modified time | relevance | path

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

12

/external/webrtc/webrtc/base/
Dworker.cc23 Worker::Worker() : worker_thread_(NULL) {} in Worker()
29 ASSERT(!worker_thread_); in ~Worker()
34 if (worker_thread_) { in StartWork()
35 if (worker_thread_ == me) { in StartWork()
44 worker_thread_ = me; in StartWork()
50 if (!worker_thread_) { in StopWork()
53 } else if (worker_thread_ != rtc::Thread::Current()) { in StopWork()
59 worker_thread_->Clear(this, MSG_HAVEWORK); in StopWork()
60 worker_thread_ = NULL; in StopWork()
65 ASSERT(worker_thread_ != NULL); in HaveWork()
[all …]
Dsharedexclusivelock_unittest.cc38 worker_thread_.reset(new Thread()); in SharedExclusiveTask()
39 worker_thread_->Start(); in SharedExclusiveTask()
45 scoped_ptr<Thread> worker_thread_; member in rtc::SharedExclusiveTask
59 worker_thread_->Post(this, kMsgRead, new TypedMessageData<int*>(value)); in PostRead()
64 ASSERT(rtc::Thread::Current() == worker_thread_.get()); in OnMessage()
92 worker_thread_->Post(this, kMsgWrite, new TypedMessageData<int>(value)); in PostWrite()
97 ASSERT(rtc::Thread::Current() == worker_thread_.get()); in OnMessage()
Dworker.h65 Thread *worker_thread_; variable
/external/webrtc/talk/session/media/
Dchannelmanager.cc104 worker_thread_ = worker_thread; in Construct()
126 worker_thread_->Invoke<void>(Bind( in ~ChannelManager()
190 ASSERT(worker_thread_ != NULL); in Init()
191 if (!worker_thread_) { in Init()
194 if (worker_thread_ != rtc::Thread::Current()) { in Init()
196 worker_thread_->Invoke<bool>(rtc::Bind( in Init()
197 &rtc::Thread::SetAllowBlockingCalls, worker_thread_, false)); in Init()
200 initialized_ = worker_thread_->Invoke<bool>(Bind( in Init()
219 ASSERT(worker_thread_ == rtc::Thread::Current()); in InitMediaEngine_w()
220 return (media_engine_->Init(worker_thread_)); in InitMediaEngine_w()
[all …]
Dmediamonitor.cc43 : worker_thread_(worker_thread), in MediaMonitor()
50 worker_thread_->Clear(this); in ~MediaMonitor()
57 worker_thread_->Post(this, MSG_MONITOR_START); in Start()
61 worker_thread_->Post(this, MSG_MONITOR_STOP); in Stop()
70 ASSERT(rtc::Thread::Current() == worker_thread_); in OnMessage()
78 ASSERT(rtc::Thread::Current() == worker_thread_); in OnMessage()
81 worker_thread_->Clear(this); in OnMessage()
86 ASSERT(rtc::Thread::Current() == worker_thread_); in OnMessage()
99 ASSERT(rtc::Thread::Current() == worker_thread_); in PollMediaChannel()
105 worker_thread_->PostDelayed(rate_, this, MSG_MONITOR_POLL); in PollMediaChannel()
Dchannel.cc174 : 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()
[all …]
Dchannelmanager.h74 rtc::Thread* worker_thread() const { return worker_thread_; } in worker_thread()
77 worker_thread_ = thread; in set_worker_thread()
223 rtc::Thread* worker_thread_; variable
Dmediamonitor.h59 rtc::Thread* worker_thread_; variable
Dchannel.h96 rtc::Thread* worker_thread() const { return worker_thread_; } in worker_thread()
304 return worker_thread_->Invoke<bool>(functor); in InvokeOnWorker()
308 rtc::Thread* worker_thread_;
/external/webrtc/webrtc/p2p/base/
Dtransportcontroller.cc44 worker_thread_(worker_thread), in TransportController()
48 worker_thread_->Invoke<void>( in ~TransportController()
55 return worker_thread_->Invoke<bool>(rtc::Bind( in SetSslMaxProtocolVersion()
60 worker_thread_->Invoke<void>( in SetIceConfig()
65 worker_thread_->Invoke<void>( in SetIceRole()
71 return worker_thread_->Invoke<bool>(rtc::Bind( in GetSslRole()
77 return worker_thread_->Invoke<bool>(rtc::Bind( in SetLocalCertificate()
84 return worker_thread_->Invoke<bool>( in GetLocalCertificate()
92 return worker_thread_->Invoke<bool>( in GetRemoteSSLCertificate()
102 return worker_thread_->Invoke<bool>( in SetLocalTransportDescription()
[all …]
Dp2ptransportchannel.cc212 worker_thread_(rtc::Thread::Current()), in P2PTransportChannel()
234 ASSERT(worker_thread_ == rtc::Thread::Current()); in ~P2PTransportChannel()
243 ASSERT(worker_thread_ == rtc::Thread::Current()); in AddAllocatorSession()
278 ASSERT(worker_thread_ == rtc::Thread::Current()); in SetIceRole()
289 ASSERT(worker_thread_ == rtc::Thread::Current()); in SetIceTiebreaker()
339 ASSERT(worker_thread_ == rtc::Thread::Current()); in SetIceCredentials()
348 ASSERT(worker_thread_ == rtc::Thread::Current()); in SetRemoteIceCredentials()
401 ASSERT(worker_thread_ == rtc::Thread::Current()); in Connect()
432 ASSERT(worker_thread_ == rtc::Thread::Current()); in OnPortReady()
476 ASSERT(worker_thread_ == rtc::Thread::Current()); in OnCandidatesReady()
[all …]
Ddtlstransportchannel.cc96 worker_thread_(rtc::Thread::Current()), in DtlsTransportChannelWrapper()
398 ASSERT(rtc::Thread::Current() == worker_thread_); in OnWritableState()
438 ASSERT(rtc::Thread::Current() == worker_thread_); in OnReceivingState()
452 ASSERT(rtc::Thread::Current() == worker_thread_); in OnReadPacket()
517 ASSERT(rtc::Thread::Current() == worker_thread_); in OnSentPacket()
530 ASSERT(rtc::Thread::Current() == worker_thread_); in OnDtlsEvent()
Dtransportcontroller_unittest.cc61 if (!worker_thread_) { in CreateTransportControllerWithWorkerThread()
62 worker_thread_.reset(new rtc::Thread()); in CreateTransportControllerWithWorkerThread()
63 worker_thread_->Start(); in CreateTransportControllerWithWorkerThread()
66 new TransportControllerForTest(worker_thread_.get())); in CreateTransportControllerWithWorkerThread()
103 worker_thread_->Invoke<void>(rtc::Bind( in CreateChannelsAndCompleteConnectionOnWorkerThread()
180 rtc::scoped_ptr<rtc::Thread> worker_thread_; // Not used for most tests. member in TransportControllerTest
Dtransportcontroller.h39 rtc::Thread* worker_thread() const { return worker_thread_; } in worker_thread()
194 rtc::Thread* const worker_thread_ = nullptr; variable
Dp2ptransportchannel.h187 rtc::Thread* thread() { return worker_thread_; } in thread()
269 rtc::Thread* worker_thread_; variable
/external/webrtc/webrtc/p2p/client/
Dsocketmonitor.cc28 worker_thread_ = worker_thread; in ConnectionMonitor()
34 worker_thread_->Clear(this); in ~ConnectionMonitor()
42 worker_thread_->Post(this, MSG_MONITOR_START); in Start()
46 worker_thread_->Post(this, MSG_MONITOR_STOP); in Stop()
53 ASSERT(rtc::Thread::Current() == worker_thread_); in OnMessage()
61 ASSERT(rtc::Thread::Current() == worker_thread_); in OnMessage()
64 worker_thread_->Clear(this); in OnMessage()
69 ASSERT(rtc::Thread::Current() == worker_thread_); in OnMessage()
85 ASSERT(rtc::Thread::Current() == worker_thread_); in PollConnectionStats_w()
93 worker_thread_->PostDelayed(rate_, this, MSG_MONITOR_POLL); in PollConnectionStats_w()
Dfakeportallocator.h93 worker_thread_(worker_thread), in FakePortAllocatorSession()
104 port_.reset(TestUDPPort::Create(worker_thread_, factory_, &network_, in StartGettingPorts()
133 rtc::Thread* worker_thread_;
145 : worker_thread_(worker_thread), factory_(factory) { in FakePortAllocator()
148 worker_thread_)); in FakePortAllocator()
174 worker_thread_, factory_, content_name, component, ice_ufrag, ice_pwd); in CreateSessionInternal()
178 rtc::Thread* worker_thread_;
Dsocketmonitor.h53 rtc::Thread* worker_thread_; variable
/external/webrtc/talk/app/webrtc/
Dmediacontroller.cc46 : worker_thread_(worker_thread), channel_manager_(channel_manager) { in MediaController()
48 worker_thread_->Invoke<void>( in MediaController()
53 worker_thread_->Invoke<void>(rtc::Bind(&MediaController::Destruct_w, this)); in ~MediaController()
57 RTC_DCHECK(worker_thread_->IsCurrent()); in call_w()
67 RTC_DCHECK(worker_thread_->IsCurrent()); in Construct_w()
77 RTC_DCHECK(worker_thread_->IsCurrent()); in Destruct_w()
81 rtc::Thread* const worker_thread_; member in __anonefac14ff0111::MediaController
Dpeerconnectionfactory.cc128 worker_thread_(new rtc::Thread) { in PeerConnectionFactory()
133 worker_thread_->Start(); in PeerConnectionFactory()
145 worker_thread_(worker_thread), in PeerConnectionFactory()
170 delete worker_thread_; in ~PeerConnectionFactory()
184 new rtc::BasicPacketSocketFactory(worker_thread_)); in Initialize()
192 worker_thread_->Invoke<cricket::MediaEngineInterface*>(rtc::Bind( in Initialize()
196 new cricket::ChannelManager(media_engine, worker_thread_)); in Initialize()
204 signaling_thread_, worker_thread_); in Initialize()
308 return MediaControllerInterface::Create(worker_thread_, in CreateMediaController()
320 return worker_thread_; in worker_thread()
[all …]
Ddtlsidentitystore_unittest.cc81 : worker_thread_(new rtc::Thread()), in DtlsIdentityStoreTest()
83 worker_thread_.get())), in DtlsIdentityStoreTest()
86 RTC_CHECK(worker_thread_->Start()); in DtlsIdentityStoreTest()
97 rtc::scoped_ptr<rtc::Thread> worker_thread_; member in DtlsIdentityStoreTest
139 worker_thread_->Stop(); in TEST_F()
149 worker_thread_->Stop(); in TEST_F()
Ddtlsidentitystore.cc125 worker_thread_(worker_thread), in DtlsIdentityStoreImpl()
130 if (worker_thread_ != signaling_thread_) { in DtlsIdentityStoreImpl()
205 worker_thread_->Post(task, MSG_GENERATE_IDENTITY, msg); in GenerateIdentity()
240 if (worker_thread_ != signaling_thread_ && // Only do in background thread. in OnIdentityGenerated()
Ddtlsidentitystore.h147 rtc::Thread* const worker_thread_; variable
Dpeerconnectionfactory.h111 rtc::Thread* worker_thread_; variable
/external/webrtc/talk/media/sctp/
Dsctpdataengine.h172 rtc::Thread* worker_thread() const { return worker_thread_; } in worker_thread()
225 rtc::Thread* worker_thread_; variable

12