HomeSort by relevance Sort by last modified time
    Searched refs:worker_thread_ (Results 1 - 25 of 34) sorted by null

1 2

  /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:__anon26201::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
  /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
  /system/tpm/tpm_manager/server/
tpm_manager_service.cc 39 worker_thread_.reset(new base::Thread("TpmManager Service Worker"));
40 worker_thread_->StartWithOptions(
44 worker_thread_->task_runner()->PostNonNestableTask(FROM_HERE, task);
305 worker_thread_->task_runner()->PostTaskAndReply(FROM_HERE,
tpm_manager_service.h 188 std::unique_ptr<base::Thread> worker_thread_; member in class:tpm_manager::TpmManagerService
  /system/tpm/attestation/server/
attestation_service.cc 52 worker_thread_.reset(new base::Thread("Attestation Service Worker"));
53 worker_thread_->StartWithOptions(
68 worker_thread_->task_runner()->PostTask(FROM_HERE, base::Bind(
95 worker_thread_->task_runner()->PostTaskAndReply(FROM_HERE, task, reply);
188 worker_thread_->task_runner()->PostTaskAndReply(FROM_HERE, task, reply);
232 worker_thread_->task_runner()->PostTaskAndReply(FROM_HERE, task, reply);
283 worker_thread_->task_runner()->PostTaskAndReply(FROM_HERE, task, reply);
340 worker_thread_->task_runner()->PostTaskAndReply(FROM_HERE, task, reply);
388 worker_thread_->task_runner()->PostTaskAndReply(FROM_HERE, task, reply);
425 worker_thread_->task_runner()->PostTaskAndReply(FROM_HERE, task, reply)
    [all...]

Completed in 2168 milliseconds

1 2