| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| worker.cc | 40 Worker::Worker() : worker_thread_(NULL) {}
46 ASSERT(!worker_thread_);
51 if (worker_thread_) {
52 if (worker_thread_ == me) {
61 worker_thread_ = me;
67 if (!worker_thread_) {
70 } else if (worker_thread_ != talk_base::Thread::Current()) {
76 worker_thread_->Clear(this, MSG_HAVEWORK);
77 worker_thread_ = NULL;
82 ASSERT(worker_thread_ != NULL)
[all...] |
| worker.h | 82 Thread *worker_thread_; member in class:talk_base::Worker
|
| sharedexclusivelock_unittest.cc | 55 worker_thread_.reset(new Thread());
56 worker_thread_->Start();
62 scoped_ptr<Thread> worker_thread_; member in class:talk_base::SharedExclusiveTask
76 worker_thread_->Post(this, kMsgRead, new TypedMessageData<int*>(value));
81 ASSERT(talk_base::Thread::Current() == worker_thread_.get());
109 worker_thread_->Post(this, kMsgWrite, new TypedMessageData<int>(value));
114 ASSERT(talk_base::Thread::Current() == worker_thread_.get());
|
| /external/chromium/third_party/libjingle/source/talk/session/phone/ |
| mediamonitor.cc | 44 : worker_thread_(worker_thread),
51 worker_thread_->Clear(this);
58 worker_thread_->Post(this, MSG_MONITOR_START);
62 worker_thread_->Post(this, MSG_MONITOR_STOP);
71 ASSERT(talk_base::Thread::Current() == worker_thread_);
79 ASSERT(talk_base::Thread::Current() == worker_thread_);
82 worker_thread_->Clear(this);
87 ASSERT(talk_base::Thread::Current() == worker_thread_);
100 ASSERT(talk_base::Thread::Current() == worker_thread_);
106 worker_thread_->PostDelayed(rate_, this, MSG_MONITOR_POLL)
[all...] |
| soundclip.h | 64 talk_base::Thread* worker_thread_; member in class:cricket::Soundclip
|
| soundclip.cc | 53 : worker_thread_(thread),
61 worker_thread_->Send(this, MSG_PLAYSOUND, &data);
|
| channelmanager.cc | 137 worker_thread_(worker_thread),
153 worker_thread_(worker_thread),
213 ASSERT(worker_thread_ != NULL);
214 if (worker_thread_ && worker_thread_->started()) {
310 worker_thread_, media_engine_.get(), media_channel,
359 worker_thread_, media_engine_.get(), media_channel,
396 ASSERT(worker_thread_ == talk_base::Thread::Current());
403 Soundclip* soundclip = new Soundclip(worker_thread_, soundclip_media);
465 ASSERT(worker_thread_ == talk_base::Thread::Current())
[all...] |
| /external/chromium_org/third_party/libjingle/source/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(talk_base::Thread::Current() == worker_thread_);
78 ASSERT(talk_base::Thread::Current() == worker_thread_);
81 worker_thread_->Clear(this);
86 ASSERT(talk_base::Thread::Current() == worker_thread_);
99 ASSERT(talk_base::Thread::Current() == worker_thread_);
105 worker_thread_->PostDelayed(rate_, this, MSG_MONITOR_POLL)
[all...] |
| soundclip.h | 64 talk_base::Thread* worker_thread_; member in class:cricket::Soundclip
|
| typingmonitor.cc | 40 worker_thread_(worker_thread),
56 worker_thread_->Clear(this, 0, &messages);
80 worker_thread_->PostDelayed(mute_period_, this, 0);
93 worker_thread_->Clear(this, 0, &removed);
|
| channelmanager.cc | 118 worker_thread_ = worker_thread;
219 ASSERT(worker_thread_ != NULL);
220 if (worker_thread_ && worker_thread_->started()) {
221 if (media_engine_->Init(worker_thread_)) {
294 worker_thread_->Invoke<void>(Bind(&ChannelManager::Terminate_w, this));
300 ASSERT(worker_thread_ == talk_base::Thread::Current());
318 return worker_thread_->Invoke<VoiceChannel*>(
332 worker_thread_, media_engine_.get(), media_channel,
344 worker_thread_->Invoke<void>
[all...] |
| typingmonitor.h | 75 talk_base::Thread* worker_thread_; member in class:cricket::TypingMonitor
|
| soundclip.cc | 53 : worker_thread_(thread),
61 worker_thread_->Send(this, MSG_PLAYSOUND, &data);
|
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| transportchannelproxy.cc | 47 worker_thread_ = talk_base::Thread::Current();
52 worker_thread_->Clear(this);
58 ASSERT(talk_base::Thread::Current() == worker_thread_);
101 worker_thread_->Post(this, MSG_UPDATESTATE);
107 ASSERT(talk_base::Thread::Current() == worker_thread_);
116 ASSERT(talk_base::Thread::Current() == worker_thread_);
125 ASSERT(talk_base::Thread::Current() == worker_thread_);
133 ASSERT(talk_base::Thread::Current() == worker_thread_);
141 ASSERT(talk_base::Thread::Current() == worker_thread_);
149 ASSERT(talk_base::Thread::Current() == worker_thread_);
[all...] |
| p2ptransportchannel.cc | 162 worker_thread_(talk_base::Thread::Current()),
178 ASSERT(worker_thread_ == talk_base::Thread::Current());
219 ASSERT(worker_thread_ == talk_base::Thread::Current());
230 ASSERT(worker_thread_ == talk_base::Thread::Current());
241 ASSERT(worker_thread_ == talk_base::Thread::Current());
252 ASSERT(worker_thread_ == talk_base::Thread::Current());
271 ASSERT(worker_thread_ == talk_base::Thread::Current());
295 ASSERT(worker_thread_ == talk_base::Thread::Current());
312 ASSERT(worker_thread_ == talk_base::Thread::Current());
346 ASSERT(worker_thread_ == talk_base::Thread::Current())
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/p2p/client/ |
| fakeportallocator.h | 31 worker_thread_(worker_thread),
42 port_.reset(cricket::UDPPort::Create(worker_thread_, factory_,
70 talk_base::Thread* worker_thread_; member in class:cricket::FakePortAllocatorSession
82 : worker_thread_(worker_thread), factory_(factory) {
85 worker_thread_));
96 worker_thread_, factory_, content_name, component, ice_ufrag, ice_pwd);
100 talk_base::Thread* worker_thread_; member in class:cricket::FakePortAllocator
|
| /external/chromium_org/third_party/libjingle/source/talk/examples/plus/ |
| libjingleplus.cc | 85 worker_thread_(NULL), ljp_(ljp), notify_(notify),
102 if (worker_thread_) {
103 worker_thread_->Send(this, MSG_DISCONNECT);
104 delete worker_thread_;
241 worker_thread_ = new talk_base::Thread(&pss_);
242 worker_thread_->Start();
243 worker_thread_->Send(this, MSG_START);
247 assert(talk_base::ThreadManager::CurrentThread() != worker_thread_);
248 worker_thread_->Post(this, MSG_SEND_XMPP_MESSAGE, new SendMessageData(m));
253 assert(talk_base::ThreadManager::CurrentThread() != worker_thread_);
676 talk_base::Thread *worker_thread_; member in class:LibjinglePlusWorker
[all...] |
| /external/chromium/third_party/libjingle/source/talk/session/tunnel/ |
| pseudotcpchannel.cc | 90 // worker_thread_ - created when channel_ is created, purged when channel_ is
93 // this - created in constructor, destroyed when worker_thread_ and stream_
103 worker_thread_(NULL),
114 ASSERT(worker_thread_ == NULL);
130 worker_thread_ = session_->session_manager()->worker_thread();
175 worker_thread_->Clear(this, MSG_WK_CLOCK);
176 worker_thread_->Post(this, MSG_WK_PURGE);
194 ASSERT(worker_thread_ == NULL);
320 ASSERT(worker_thread_->IsCurrent());
342 ASSERT(worker_thread_->IsCurrent())
[all...] |
| /external/chromium_org/chrome/browser/chromeos/drive/ |
| webkit_file_stream_reader_impl_unittest.cc | 38 worker_thread_.reset(new base::Thread("WebkitFileStreamReaderImplTest"));
39 ASSERT_TRUE(worker_thread_->Start());
64 scoped_ptr<base::Thread> worker_thread_; member in class:drive::internal::WebkitFileStreamReaderImplTest
76 worker_thread_->message_loop_proxy().get(),
96 worker_thread_->message_loop_proxy().get(),
117 worker_thread_->message_loop_proxy().get(),
137 worker_thread_->message_loop_proxy().get(),
156 worker_thread_->message_loop_proxy().get(),
176 worker_thread_->message_loop_proxy().get(),
196 worker_thread_->message_loop_proxy().get()
[all...] |
| local_file_reader_unittest.cc | 49 worker_thread_.reset(new base::Thread("LocalFileReaderTest"));
50 ASSERT_TRUE(worker_thread_->Start());
52 new LocalFileReader(worker_thread_->message_loop_proxy().get()));
57 scoped_ptr<base::Thread> worker_thread_; member in class:drive::util::LocalFileReaderTest
|
| drive_file_stream_reader_unittest.cc | 50 worker_thread_.reset(new base::Thread("ReaderProxyTest"));
51 ASSERT_TRUE(worker_thread_->Start());
60 scoped_ptr<base::Thread> worker_thread_; member in class:drive::internal::LocalReaderProxyTest
66 new util::LocalFileReader(worker_thread_->message_loop_proxy().get()));
87 new util::LocalFileReader(worker_thread_->message_loop_proxy().get()));
287 worker_thread_.reset(new base::Thread("DriveFileStreamReaderTest"));
288 ASSERT_TRUE(worker_thread_->Start());
313 scoped_ptr<base::Thread> worker_thread_; member in class:drive::DriveFileStreamReaderTest
325 GetFileSystemGetter(), worker_thread_->message_loop_proxy().get()));
353 GetFileSystemGetter(), worker_thread_->message_loop_proxy().get()))
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/session/tunnel/ |
| pseudotcpchannel.cc | 91 // worker_thread_ - created when channel_ is created, purged when channel_ is
94 // this - created in constructor, destroyed when worker_thread_ and stream_
104 worker_thread_(NULL),
115 ASSERT(worker_thread_ == NULL);
132 worker_thread_ = session_->session_manager()->worker_thread();
178 worker_thread_->Clear(this, MSG_WK_CLOCK);
179 worker_thread_->Post(this, MSG_WK_PURGE);
197 ASSERT(worker_thread_ == NULL);
323 ASSERT(worker_thread_->IsCurrent());
347 ASSERT(worker_thread_->IsCurrent())
[all...] |
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| p2ptransportchannel.cc | 169 worker_thread_(talk_base::Thread::Current()),
180 ASSERT(worker_thread_ == talk_base::Thread::Current());
207 ASSERT(worker_thread_ == talk_base::Thread::Current());
218 ASSERT(worker_thread_ == talk_base::Thread::Current());
255 ASSERT(worker_thread_ == talk_base::Thread::Current());
301 ASSERT(worker_thread_ == talk_base::Thread::Current());
357 ASSERT(worker_thread_ == talk_base::Thread::Current());
372 ASSERT(worker_thread_ == talk_base::Thread::Current());
525 worker_thread_->Post(this, MSG_SORT);
534 ASSERT(worker_thread_ == talk_base::Thread::Current())
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/app/webrtc/ |
| peerconnectionfactory.cc | 151 worker_thread_(new talk_base::Thread) {
154 result = worker_thread_->Start();
166 worker_thread_(worker_thread),
182 delete worker_thread_;
232 allocator_factory_ = PortAllocatorFactory::Create(worker_thread_);
247 webrtc_media_engine, device_manager, worker_thread_));
373 return worker_thread_;
|
| /external/chromium_org/chrome/browser/ |
| process_singleton_linux_unittest.cc | 90 worker_thread_->message_loop()->PostTask(
96 worker_thread_->message_loop_proxy().get()));
105 ASSERT_EQ(NULL, worker_thread_.get());
106 worker_thread_.reset(new base::Thread("BlockingThread"));
107 worker_thread_->Start();
109 worker_thread_->message_loop()->PostTask(
116 new base::ThreadTestHelper(worker_thread_->message_loop_proxy().get()));
173 worker_thread_->message_loop()->PostTask(
216 scoped_ptr<base::Thread> worker_thread_; member in class:__anon8166::ProcessSingletonLinuxTest
|
