| /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
|
