Searched refs:worker_thread (Results 1 - 25 of 82) sorted by relevance

1234

/external/chromium/third_party/libjingle/source/talk/session/phone/
H A Daudiomonitor.cc47 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);
H A Dmediamonitor.h44 MediaMonitor(talk_base::Thread* worker_thread,
68 MediaMonitorT(MC* media_channel, talk_base::Thread* worker_thread, argument
70 : MediaMonitor(worker_thread, monitor_thread),
H A Dmediamonitor.cc42 MediaMonitor::MediaMonitor(talk_base::Thread* worker_thread, argument
44 : worker_thread_(worker_thread),
/external/chromium_org/third_party/libjingle/source/talk/session/media/
H A Daudiomonitor.cc47 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);
H A Dmediamonitor.h44 MediaMonitor(talk_base::Thread* worker_thread,
68 MediaMonitorT(MC* media_channel, talk_base::Thread* worker_thread, argument
70 : MediaMonitor(worker_thread, monitor_thread),
H A Dmediamonitor.cc41 MediaMonitor::MediaMonitor(talk_base::Thread* worker_thread, argument
43 : worker_thread_(worker_thread),
H A Dtypingmonitor.h62 TypingMonitor(VoiceChannel* channel, talk_base::Thread* worker_thread,
H A Dtypingmonitor.cc37 talk_base::Thread* worker_thread,
40 worker_thread_(worker_thread),
88 * be called on the worker_thread.
36 TypingMonitor(VoiceChannel* channel, talk_base::Thread* worker_thread, const TypingMonitorOptions& settings) argument
/external/valgrind/main/helgrind/tests/
H A Dtc03_re_excl.c16 static void* worker_thread ( void* argV ) function
30 pthread_create(&thread_id, 0, worker_thread, (void*)x);
/external/chromium_org/content/worker/
H A Dwebsharedworker_stub.cc14 #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);
45 WorkerThread* worker_thread = WorkerThread::current(); local
46 DCHECK(worker_thread);
47 worker_thread->RemoveWorkerStub(this);
48 worker_thread->RemoveRoute(route_id_);
/external/chromium_org/third_party/libjingle/source/talk/app/webrtc/
H A Dportallocatorfactory.h53 talk_base::Thread* worker_thread);
60 explicit PortAllocatorFactory(talk_base::Thread* worker_thread);
H A Dportallocatorfactory.cc44 talk_base::Thread* worker_thread) {
46 new talk_base::RefCountedObject<PortAllocatorFactory>(worker_thread);
50 PortAllocatorFactory::PortAllocatorFactory(talk_base::Thread* worker_thread) argument
52 socket_factory_(new talk_base::BasicPacketSocketFactory(worker_thread)) {
43 Create( talk_base::Thread* worker_thread) argument
/external/chromium/third_party/libjingle/source/talk/p2p/base/
H A Dtransport.cc82 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()
81 Transport(talk_base::Thread* signaling_thread, talk_base::Thread* worker_thread, const std::string& type, PortAllocator* allocator) argument
[all...]
H A Drawtransport.cc44 talk_base::Thread* worker_thread,
46 : Transport(signaling_thread, worker_thread,
120 worker_thread(),
43 RawTransport(talk_base::Thread* signaling_thread, talk_base::Thread* worker_thread, PortAllocator* allocator) argument
H A Drawtransport.h43 talk_base::Thread* worker_thread,
H A Drawtransportchannel.cc57 talk_base::Thread *worker_thread,
67 if (worker_thread == NULL)
68 worker_thread_ = raw_transport_->worker_thread();
70 worker_thread_ = worker_thread;
54 RawTransportChannel(const std::string &name, const std::string &content_type, RawTransport* transport, talk_base::Thread *worker_thread, PortAllocator *allocator) argument
/external/chromium_org/chrome/test/functional/media/
H A Dmedia_seek_perf.py20 import worker_thread namespace
43 class SeekWorkerThread(worker_thread.WorkerThread):
111 if worker_thread.RunWorkerThreads(self, SeekWorkerThread, tasks,
H A Dmedia_constrained_network_perf.py31 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,
/external/chromium_org/third_party/libjingle/source/talk/p2p/client/
H A Dfakeportallocator.h23 FakePortAllocatorSession(talk_base::Thread* worker_thread, argument
31 worker_thread_(worker_thread),
80 FakePortAllocator(talk_base::Thread* worker_thread, argument
82 : worker_thread_(worker_thread), factory_(factory) {
H A Dsocketmonitor.cc42 talk_base::Thread* worker_thread,
45 channel_thread_ = worker_thread;
41 SocketMonitor(TransportChannel* channel, talk_base::Thread* worker_thread, talk_base::Thread* monitor_thread) argument
H A Dsocketmonitor.h44 talk_base::Thread* worker_thread,
/external/chromium_org/chrome/common/
H A Dcancelable_task_tracker_unittest.cc87 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();
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/
H A Drawtransport.cc44 talk_base::Thread* worker_thread,
47 : Transport(signaling_thread, worker_thread,
123 worker_thread(),
43 RawTransport(talk_base::Thread* signaling_thread, talk_base::Thread* worker_thread, const std::string& content_name, PortAllocator* allocator) argument
H A Drawtransport.h43 talk_base::Thread* worker_thread,
H A Drawtransportchannel.cc57 talk_base::Thread *worker_thread,
67 if (worker_thread == NULL)
68 worker_thread_ = raw_transport_->worker_thread();
70 worker_thread_ = worker_thread;
54 RawTransportChannel(const std::string& content_name, int component, RawTransport* transport, talk_base::Thread *worker_thread, PortAllocator *allocator) argument

Completed in 724 milliseconds

1234