| /external/webrtc/pc/ |
| D | channel.h | 82 BaseChannel(rtc::Thread* worker_thread,
92 rtc::Thread* worker_thread() const { return worker_thread_; } in worker_thread() function
172 RTC_RUN_ON(worker_thread()) { in set_local_content_direction()
177 RTC_RUN_ON(worker_thread()) { in local_content_direction()
182 RTC_RUN_ON(worker_thread()) { in set_remote_content_direction()
187 RTC_RUN_ON(worker_thread()) { in remote_content_direction()
199 bool enabled() const RTC_RUN_ON(worker_thread()) { return enabled_; } in enabled()
211 bool IsReadyToSendMedia_w() const RTC_RUN_ON(worker_thread());
228 void EnableMedia_w() RTC_RUN_ON(worker_thread());
229 void DisableMedia_w() RTC_RUN_ON(worker_thread());
[all …]
|
| D | peer_connection_factory.cc | 75 pc_factory->signaling_thread(), pc_factory->worker_thread(), pc_factory); in CreateModularPeerConnectionFactory()
113 worker_thread()->BlockingCall([this] { in ~PeerConnectionFactory()
114 RTC_DCHECK_RUN_ON(worker_thread()); in ~PeerConnectionFactory()
187 RTC_DCHECK_RUN_ON(worker_thread()); in StartAecDump()
193 RTC_DCHECK_RUN_ON(worker_thread()); in StopAecDump()
241 worker_thread()->BlockingCall([this] { return CreateRtcEventLog_w(); }); in CreatePeerConnectionOrError()
246 worker_thread()->BlockingCall([this, &event_log, trials, &configuration] { in CreatePeerConnectionOrError()
281 worker_thread()); in CreateVideoTrack()
282 return VideoTrackProxy::Create(signaling_thread(), worker_thread(), track); in CreateVideoTrack()
295 RTC_DCHECK_RUN_ON(worker_thread()); in CreateRtcEventLog_w()
[all …]
|
| D | video_track.cc | 26 rtc::Thread* worker_thread) in VideoTrack() argument
28 worker_thread_(worker_thread), in VideoTrack()
134 rtc::Thread* worker_thread) { in Create() argument
138 rtc::Thread::Current(), worker_thread, std::move(source)); in Create()
141 worker_thread); in Create()
|
| D | connection_context.cc | 90 worker_thread_(dependencies->worker_thread, in ConnectionContext()
115 signaling_thread_->AllowInvokesToThread(worker_thread());
123 [thread = network_thread_, worker_thread = worker_thread_.get()] { in __anon01c0b2070302()
126 if (worker_thread == thread) { in __anon01c0b2070302()
177 RTC_DCHECK_RUN_ON(worker_thread()); in ~ConnectionContext()
|
| D | connection_context.h | 74 rtc::Thread* worker_thread() { return worker_thread_.get(); } in worker_thread() function
75 const rtc::Thread* worker_thread() const { return worker_thread_.get(); } in worker_thread() function
95 RTC_DCHECK_RUN_ON(worker_thread()); in call_factory()
137 RTC_GUARDED_BY(worker_thread());
|
| D | video_track_source_proxy.cc | 22 rtc::Thread* worker_thread, in CreateVideoTrackSourceProxy() argument
25 signaling_thread, worker_thread, in CreateVideoTrackSourceProxy()
|
| D | video_rtp_receiver.cc | 26 VideoRtpReceiver::VideoRtpReceiver(rtc::Thread* worker_thread, in VideoRtpReceiver() argument
29 : VideoRtpReceiver(worker_thread, in VideoRtpReceiver()
34 rtc::Thread* worker_thread, in VideoRtpReceiver() argument
37 : worker_thread_(worker_thread), in VideoRtpReceiver()
42 worker_thread, in VideoRtpReceiver()
43 VideoTrack::Create(receiver_id, source_, worker_thread))), in VideoRtpReceiver()
|
| /external/rust/android-crates-io/crates/rayon-core/src/join/ |
| D | mod.rs | 132 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context()
139 worker_thread.push(job_b_ref); in join_context()
145 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
154 if let Some(job) = worker_thread.take_local_job() { in join_context()
162 worker_thread.execute(job); in join_context()
167 worker_thread.wait_until(&job_b.latch); in join_context()
182 worker_thread: &WorkerThread, in join_recover_from_panic()
186 worker_thread.wait_until(job_b_latch); in join_recover_from_panic()
|
| /external/tensorflow/tensorflow/python/ops/ |
| D | batch_ops_test.py | 70 worker_thread = threading.Thread(target=worker)
71 worker_thread.start()
73 worker_thread.join()
113 worker_thread = threading.Thread(target=worker)
114 worker_thread.start()
116 worker_thread.join()
149 worker_thread = threading.Thread(target=worker)
150 worker_thread.start()
152 worker_thread.join()
204 worker_thread = threading.Thread(target=worker)
[all …]
|
| /external/webrtc/sdk/android/native_unittests/peerconnection/ |
| D | peer_connection_factory_unittest.cc | 39 rtc::Thread* worker_thread, in CreateTestPCF() argument
50 pcf_deps.worker_thread = worker_thread; in CreateTestPCF()
92 std::unique_ptr<rtc::Thread> worker_thread = rtc::Thread::Create(); in TEST() local
93 worker_thread->SetName("worker_thread", nullptr); in TEST()
94 RTC_CHECK(worker_thread->Start()) << "Failed to start thread"; in TEST()
101 CreateTestPCF(jni, network_thread.get(), worker_thread.get(), in TEST()
106 std::move(worker_thread), std::move(signaling_thread)); in TEST()
|
| /external/rust/android-crates-io/crates/rayon-core/src/ |
| D | registry.rs | 295 let worker_thread = Box::into_raw(Box::new(WorkerThread::from(thread))); in new() localVariable
298 WorkerThread::set_current(worker_thread); in new()
317 let worker_thread = WorkerThread::current(); in current() localVariable
318 let registry = if worker_thread.is_null() { in current()
321 &(*worker_thread).registry in current()
332 let worker_thread = WorkerThread::current(); in current_num_threads() localVariable
333 if worker_thread.is_null() { in current_num_threads()
336 (*worker_thread).registry.num_threads() in current_num_threads()
406 let worker_thread = WorkerThread::current(); in inject_or_push() localVariable
408 if !worker_thread.is_null() && (*worker_thread).registry().id() == self.id() { in inject_or_push()
[all …]
|
| /external/crosvm/devices/src/virtio/ |
| D | rng.rs | 100 worker_thread: Option<WorkerThread<Worker>>, field
108 worker_thread: None, in new()
143 self.worker_thread = Some(WorkerThread::start("v_rng", move |kill_evt| { in activate()
155 if let Some(worker_thread) = self.worker_thread.take() { in reset()
156 let _worker = worker_thread.stop(); in reset()
162 if let Some(worker_thread) = self.worker_thread.take() { in virtio_sleep()
163 let worker = worker_thread.stop(); in virtio_sleep()
|
| D | pmem.rs | 363 worker_thread: Option<WorkerThread<(Queue, Tube)>>, field
414 worker_thread: None, in new()
493 self.worker_thread = Some(WorkerThread::start("v_pmem", move |kill_event| { in activate()
509 if let Some(worker_thread) = self.worker_thread.take() { in reset()
510 let (_queue, pmem_device_tube) = worker_thread.stop(); in reset()
517 if let Some(worker_thread) = self.worker_thread.take() { in virtio_sleep()
518 let (queue, pmem_device_tube) = worker_thread.stop(); in virtio_sleep()
|
| /external/pdfium/third_party/libopenjpeg/ |
| D | thread.c | 600 opj_worker_thread_t* worker_thread; member
622 opj_worker_thread_t* worker_thread,
658 opj_worker_thread_t* worker_thread; in opj_worker_thread_function() local
663 worker_thread = (opj_worker_thread_t*) user_data; in opj_worker_thread_function()
664 tp = worker_thread->tp; in opj_worker_thread_function()
668 opj_worker_thread_job_t* job = opj_thread_pool_get_next_job(tp, worker_thread, in opj_worker_thread_function()
759 opj_worker_thread_t* worker_thread, in opj_thread_pool_get_next_job() argument
792 if (!worker_thread->marked_as_waiting) { in opj_thread_pool_get_next_job()
795 worker_thread->marked_as_waiting = OPJ_TRUE; in opj_thread_pool_get_next_job()
808 item->worker_thread = worker_thread; in opj_thread_pool_get_next_job()
[all …]
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | mod.rs | 82 worker_thread: Option<WorkerThread<anyhow::Result<Worker>>>, field
126 if self.worker_thread.is_some() { in activate()
147 self.worker_thread = in activate()
176 if let Some(worker_thread) = self.worker_thread.take() { in reset()
177 let worker = worker_thread.stop(); in reset()
188 if let Some(worker_thread) = self.worker_thread.take() { in virtio_sleep()
193 let worker = worker_thread.stop(); in virtio_sleep()
286 worker_thread: None, in new_sound()
|
| /external/sdv/vsomeip/third_party/boost/thread/include/boost/thread/executors/ |
| D | basic_thread_pool.hpp | 84 void worker_thread() in worker_thread() function in boost::executors::basic_thread_pool
116 worker_thread(); in worker_thread1()
122 worker_thread(); in worker_thread2()
128 worker_thread(); in worker_thread3()
149 thread th (&basic_thread_pool::worker_thread, this); in basic_thread_pool()
152 threads.push_back(thread_t(&basic_thread_pool::worker_thread, this)); // do not compile in basic_thread_pool()
|
| /external/cronet/tot/base/task/ |
| D | cancelable_task_tracker_unittest.cc | 46 Thread worker_thread("worker thread"); in TEST_F() local
47 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
50 task_tracker_.PostTask(worker_thread.task_runner().get(), FROM_HERE, in TEST_F()
54 worker_thread.task_runner().get(), FROM_HERE, in TEST_F()
60 worker_thread.Stop(); in TEST_F()
126 Thread worker_thread("worker thread"); in TEST_F() local
127 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
130 worker_thread.task_runner().get(), FROM_HERE, DoNothing(), in TEST_F()
136 worker_thread.Stop(); in TEST_F()
|
| /external/libchrome/base/task/ |
| D | cancelable_task_tracker_unittest.cc | 85 Thread worker_thread("worker thread"); in TEST_F() local
86 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
88 ignore_result(task_tracker_.PostTask(worker_thread.task_runner().get(), in TEST_F()
93 worker_thread.task_runner().get(), FROM_HERE, in TEST_F()
99 worker_thread.Stop(); in TEST_F()
165 Thread worker_thread("worker thread"); in TEST_F() local
166 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
169 worker_thread.task_runner().get(), FROM_HERE, DoNothing(), in TEST_F()
175 worker_thread.Stop(); in TEST_F()
|
| /external/cronet/stable/base/task/ |
| D | cancelable_task_tracker_unittest.cc | 46 Thread worker_thread("worker thread"); in TEST_F() local
47 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
50 task_tracker_.PostTask(worker_thread.task_runner().get(), FROM_HERE, in TEST_F()
54 worker_thread.task_runner().get(), FROM_HERE, in TEST_F()
60 worker_thread.Stop(); in TEST_F()
126 Thread worker_thread("worker thread"); in TEST_F() local
127 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
130 worker_thread.task_runner().get(), FROM_HERE, DoNothing(), in TEST_F()
136 worker_thread.Stop(); in TEST_F()
|
| /external/crosvm/devices/src/virtio/vhost/ |
| D | vsock.rs | 43 worker_thread: Option<WorkerThread<Worker<VhostVsockHandle>>>, field
94 worker_thread: None, in new()
108 worker_thread: None, in new_for_testing()
238 self.worker_thread = Some(WorkerThread::start("vhost_vsock", move |kill_evt| { in activate()
251 if let Some(worker_thread) = self.worker_thread.take() { in reset()
252 let worker = worker_thread.stop(); in reset()
288 if let Some(worker_thread) = self.worker_thread.take() { in virtio_sleep()
289 let worker = worker_thread.stop(); in virtio_sleep()
|
| D | net.rs | 44 worker_thread: Option<WorkerThread<(Worker<U>, T)>>, field
109 worker_thread: None, in new()
235 self.worker_thread = Some(WorkerThread::start("vhost_net", move |kill_evt| { in activate()
271 if self.worker_thread.is_none() { in control_notify()
319 if let Some(worker_thread) = self.worker_thread.take() { in reset()
320 let (worker, tap) = worker_thread.stop(); in reset()
|
| /external/bcc/tools/ |
| D | offcputime_example.txt | 354 worker_thread
361 worker_thread
368 worker_thread
375 worker_thread
382 worker_thread
389 worker_thread
396 worker_thread
471 worker_thread
563 worker_thread
681 kworker/6:2;ret_from_fork;kthread;worker_thread;schedule 3940583
[all …]
|
| /external/webrtc/sdk/android/src/jni/pc/ |
| D | peer_connection_factory.cc | 122 std::unique_ptr<rtc::Thread> worker_thread, in NativeToScopedJavaPeerConnectionFactory() argument
126 std::move(worker_thread), std::move(signaling_thread), pcf); in NativeToScopedJavaPeerConnectionFactory()
133 PostJavaCallback(env, owned_factory->worker_thread(), j_pcf, in NativeToScopedJavaPeerConnectionFactory()
161 std::unique_ptr<rtc::Thread> worker_thread, in NativeToJavaPeerConnectionFactory() argument
165 std::move(worker_thread), std::move(signaling_thread)) in NativeToJavaPeerConnectionFactory()
259 std::unique_ptr<rtc::Thread> worker_thread = rtc::Thread::Create(); in CreatePeerConnectionFactoryForJava() local
260 worker_thread->SetName("worker_thread", nullptr); in CreatePeerConnectionFactoryForJava()
261 RTC_CHECK(worker_thread->Start()) << "Failed to start thread"; in CreatePeerConnectionFactoryForJava()
274 dependencies.worker_thread = worker_thread.get(); in CreatePeerConnectionFactoryForJava()
316 std::move(worker_thread), std::move(signaling_thread)); in CreatePeerConnectionFactoryForJava()
[all …]
|
| /external/crosvm/devices/src/virtio/input/ |
| D | mod.rs | 565 worker_thread: Option<WorkerThread<Worker<T>>>, field
626 self.worker_thread = Some(WorkerThread::start("v_input", move |kill_evt| { in activate()
641 if let Some(worker_thread) = self.worker_thread.take() { in reset()
642 let worker = worker_thread.stop(); in reset()
649 if let Some(worker_thread) = self.worker_thread.take() { in virtio_sleep()
650 let worker = worker_thread.stop(); in virtio_sleep()
697 worker_thread: None, in new_evdev()
717 worker_thread: None, in new_single_touch()
737 worker_thread: None, in new_multi_touch()
758 worker_thread: None, in new_trackpad()
[all …]
|
| /external/webrtc/api/ |
| D | create_peerconnection_factory.cc | 32 rtc::Thread* worker_thread, in CreatePeerConnectionFactory() argument
49 dependencies.worker_thread = worker_thread; in CreatePeerConnectionFactory()
|