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

1 2 3 4

  /external/chromium/third_party/libjingle/source/talk/session/phone/
audiomonitor.cc 47 voice_channel_->worker_thread()->Clear(this);
55 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_START);
59 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_STOP);
67 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
75 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
78 voice_channel_->worker_thread()->Clear(this);
83 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
101 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
110 voice_channel_->worker_thread()->PostDelayed(rate_, this, MSG_MONITOR_POLL);
mediamonitor.h 44 MediaMonitor(talk_base::Thread* worker_thread,
68 MediaMonitorT(MC* media_channel, talk_base::Thread* worker_thread,
70 : MediaMonitor(worker_thread, monitor_thread),
mediamonitor.cc 42 MediaMonitor::MediaMonitor(talk_base::Thread* worker_thread,
44 : worker_thread_(worker_thread),
  /external/chromium_org/third_party/libjingle/source/talk/session/media/
audiomonitor.cc 47 voice_channel_->worker_thread()->Clear(this);
55 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_START);
59 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_STOP);
67 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
75 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
78 voice_channel_->worker_thread()->Clear(this);
83 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
101 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
110 voice_channel_->worker_thread()->PostDelayed(rate_, this, MSG_MONITOR_POLL);
mediamonitor.h 44 MediaMonitor(talk_base::Thread* worker_thread,
68 MediaMonitorT(MC* media_channel, talk_base::Thread* worker_thread,
70 : MediaMonitor(worker_thread, monitor_thread),
typingmonitor.h 62 TypingMonitor(VoiceChannel* channel, talk_base::Thread* worker_thread,
mediamonitor.cc 41 MediaMonitor::MediaMonitor(talk_base::Thread* worker_thread,
43 : worker_thread_(worker_thread),
  /external/valgrind/main/helgrind/tests/
tc03_re_excl.c 16 static void* worker_thread ( void* argV ) function
30 pthread_create(&thread_id, 0, worker_thread, (void*)x);
  /external/chromium_org/content/worker/
websharedworker_stub.cc 14 #include "content/worker/worker_thread.h"
31 WorkerThread* worker_thread = WorkerThread::current(); local
32 DCHECK(worker_thread);
33 worker_thread->AddWorkerStub(this);
35 worker_thread->AddRoute(route_id_, this);
46 WorkerThread* worker_thread = WorkerThread::current(); local
47 DCHECK(worker_thread);
48 worker_thread->RemoveWorkerStub(this);
49 worker_thread->RemoveRoute(route_id_);
  /external/chromium_org/third_party/libjingle/source/talk/app/webrtc/
portallocatorfactory.h 53 talk_base::Thread* worker_thread);
60 explicit PortAllocatorFactory(talk_base::Thread* worker_thread);
portallocatorfactory.cc 44 talk_base::Thread* worker_thread) {
46 new talk_base::RefCountedObject<PortAllocatorFactory>(worker_thread);
50 PortAllocatorFactory::PortAllocatorFactory(talk_base::Thread* worker_thread)
52 socket_factory_(new talk_base::BasicPacketSocketFactory(worker_thread)) {
  /external/chromium/third_party/libjingle/source/talk/p2p/base/
transport.cc 82 talk_base::Thread* worker_thread,
86 worker_thread_(worker_thread), type_(type), allocator_(allocator),
100 worker_thread()->Send(this, MSG_CREATECHANNEL, &msg);
106 ASSERT(worker_thread()->IsCurrent());
144 worker_thread()->Send(this, MSG_DESTROYCHANNEL, &msg);
148 ASSERT(worker_thread()->IsCurrent());
174 worker_thread()->Send(this, MSG_CONNECTCHANNELS, NULL);
178 ASSERT(worker_thread()->IsCurrent());
197 worker_thread()->Send(this, MSG_DESTROYALLCHANNELS, NULL);
198 worker_thread()->Clear(this)
    [all...]
rawtransport.cc 44 talk_base::Thread* worker_thread,
46 : Transport(signaling_thread, worker_thread,
120 worker_thread(),
p2ptransport.h 40 talk_base::Thread* worker_thread,
rawtransport.h 43 talk_base::Thread* worker_thread,
rawtransportchannel.cc 57 talk_base::Thread *worker_thread,
67 if (worker_thread == NULL)
68 worker_thread_ = raw_transport_->worker_thread();
70 worker_thread_ = worker_thread;
  /external/chromium_org/third_party/libjingle/source/talk/p2p/client/
fakeportallocator.h 23 FakePortAllocatorSession(talk_base::Thread* worker_thread,
31 worker_thread_(worker_thread),
80 FakePortAllocator(talk_base::Thread* worker_thread,
82 : worker_thread_(worker_thread), factory_(factory) {
socketmonitor.cc 42 talk_base::Thread* worker_thread,
45 channel_thread_ = worker_thread;
  /external/chromium_org/chrome/test/functional/media/
media_constrained_network_perf.py 31 import worker_thread namespace
74 class CNSWorkerThread(worker_thread.WorkerThread):
82 worker_thread.WorkerThread.__init__(self, *args, **kwargs)
188 if worker_thread.RunWorkerThreads(self, CNSWorkerThread, tasks, 1,
204 if worker_thread.RunWorkerThreads(self, CNSWorkerThread, tasks,
media_seek_perf.py 20 import worker_thread namespace
43 class SeekWorkerThread(worker_thread.WorkerThread):
111 if worker_thread.RunWorkerThreads(self, SeekWorkerThread, tasks,
  /external/chromium_org/third_party/libjingle/source/talk/p2p/base/
transport.cc 114 talk_base::Thread* worker_thread,
119 worker_thread_(worker_thread),
141 worker_thread()->Send(this, MSG_SETICEROLE, &param);
146 worker_thread()->Send(this, MSG_SETIDENTITY, &params);
152 worker_thread()->Send(this, MSG_SETLOCALDESCRIPTION, &params);
159 worker_thread()->Send(this, MSG_SETREMOTEDESCRIPTION, &params);
165 worker_thread()->Send(this, MSG_CREATECHANNEL, &params);
170 ASSERT(worker_thread()->IsCurrent());
239 worker_thread()->Send(this, MSG_DESTROYCHANNEL, &params);
243 ASSERT(worker_thread()->IsCurrent())
    [all...]
rawtransport.cc 44 talk_base::Thread* worker_thread,
47 : Transport(signaling_thread, worker_thread,
123 worker_thread(),
rawtransport.h 43 talk_base::Thread* worker_thread,
rawtransportchannel.cc 57 talk_base::Thread *worker_thread,
67 if (worker_thread == NULL)
68 worker_thread_ = raw_transport_->worker_thread();
70 worker_thread_ = worker_thread;
  /external/chromium_org/chrome/common/
cancelable_task_tracker_unittest.cc 87 base::Thread worker_thread("worker thread");
88 ASSERT_TRUE(worker_thread.Start());
90 ignore_result(task_tracker_.PostTask(worker_thread.message_loop_proxy().get(),
95 task_tracker_.PostTaskAndReply(worker_thread.message_loop_proxy().get(),
103 worker_thread.Stop();
174 base::Thread worker_thread("worker thread");
175 ASSERT_TRUE(worker_thread.Start());
178 task_tracker_.PostTaskAndReply(worker_thread.message_loop_proxy().get(),
186 worker_thread.Stop();

Completed in 1303 milliseconds

1 2 3 4