/external/webrtc/webrtc/base/ |
worker.cc | 23 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_ != NULL) [all...] |
worker.h | 65 Thread *worker_thread_; member in class:rtc::Worker
|
sharedexclusivelock_unittest.cc | 38 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/ |
mediamonitor.cc | 43 : 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_->PostDelayed(rate_, this, MSG_MONITOR_POLL) [all...] |
channelmanager.cc | 104 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...] |
channelmanager.h | 74 rtc::Thread* worker_thread() const { return worker_thread_; } 77 worker_thread_ = thread; 223 rtc::Thread* worker_thread_; member in class:cricket::ChannelManager
|
mediamonitor.h | 59 rtc::Thread* worker_thread_; member in class:cricket::MediaMonitor
|
channel.cc | 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()) [all...] |
/external/webrtc/webrtc/p2p/client/ |
socketmonitor.cc | 28 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_->PostDelayed(rate_, this, MSG_MONITOR_POLL) [all...] |
fakeportallocator.h | 93 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
|
socketmonitor.h | 53 rtc::Thread* worker_thread_; member in class:cricket::ConnectionMonitor
|
/external/webrtc/talk/app/webrtc/ |
mediacontroller.cc | 46 : 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:__anon49513::MediaController::rtc
|
dtlsidentitystore_unittest.cc | 81 : 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();
|
peerconnectionfactory.cc | 128 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...] |
dtlsidentitystore.cc | 125 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.
|
dtlsidentitystore.h | 147 rtc::Thread* const worker_thread_; member in class:webrtc::DtlsIdentityStoreImpl::rtc
|
peerconnectionfactory.h | 111 rtc::Thread* worker_thread_; member in class:webrtc::PeerConnectionFactory
|
/external/webrtc/webrtc/p2p/base/ |
transportcontroller.cc | 44 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_->Invoke<bool> [all...] |
p2ptransportchannel.cc | 212 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_ == rtc::Thread::Current()) [all...] |
dtlstransportchannel.cc | 96 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_);
|
p2ptransportchannel.h | 187 rtc::Thread* thread() { return worker_thread_; } 269 rtc::Thread* worker_thread_; member in class:cricket::P2PTransportChannel
|
transportcontroller.h | 39 rtc::Thread* worker_thread() const { return worker_thread_; } 194 rtc::Thread* const worker_thread_ = nullptr; member in class:cricket::TransportController::rtc
|
/external/webrtc/talk/media/sctp/ |
sctpdataengine.h | 172 rtc::Thread* worker_thread() const { return worker_thread_; } 225 rtc::Thread* worker_thread_; member in class:cricket::SctpDataMediaChannel
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
grpc_server_lib.h | 159 std::unique_ptr<Thread> worker_thread_ GUARDED_BY(mu_);
|
/external/perfetto/src/traced/probes/ftrace/ |
cpu_reader.h | 198 std::thread worker_thread_; member in class:perfetto::CpuReader
|