| /external/tensorflow/tensorflow/python/ops/ |
| D | batch_ops_test.py | 71 worker_thread = threading.Thread(target=worker)
72 worker_thread.start()
74 worker_thread.join()
114 worker_thread = threading.Thread(target=worker)
115 worker_thread.start()
117 worker_thread.join()
150 worker_thread = threading.Thread(target=worker)
151 worker_thread.start()
153 worker_thread.join()
205 worker_thread = threading.Thread(target=worker)
[all …]
|
| /external/rust/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()
138 worker_thread.push(job_b_ref); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
153 if let Some(job) = worker_thread.take_local_job() { in join_context()
161 worker_thread.execute(job); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
181 worker_thread: &WorkerThread, in join_recover_from_panic()
185 worker_thread.wait_until(job_b_latch); in join_recover_from_panic()
|
| /external/webrtc/sdk/android/native_unittests/peerconnection/ |
| D | peer_connection_factory_unittest.cc | 37 rtc::Thread* worker_thread, in CreateTestPCF() argument
48 pcf_deps.worker_thread = worker_thread; in CreateTestPCF()
89 std::unique_ptr<rtc::Thread> worker_thread = rtc::Thread::Create(); in TEST() local
90 worker_thread->SetName("worker_thread", nullptr); in TEST()
91 RTC_CHECK(worker_thread->Start()) << "Failed to start thread"; in TEST()
98 CreateTestPCF(jni, network_thread.get(), worker_thread.get(), in TEST()
102 jni, factory, std::move(network_thread), std::move(worker_thread), in TEST()
|
| /external/rust/crates/rayon-core/src/ |
| D | registry.rs | 273 let worker_thread = WorkerThread::current(); in current() localVariable
274 if worker_thread.is_null() { in current()
277 (*worker_thread).registry.clone() in current()
287 let worker_thread = WorkerThread::current(); in current_num_threads() localVariable
288 if worker_thread.is_null() { in current_num_threads()
291 (*worker_thread).registry.num_threads() in current_num_threads()
371 let worker_thread = WorkerThread::current(); in inject_or_push() localVariable
373 if !worker_thread.is_null() && (*worker_thread).registry().id() == self.id() { in inject_or_push()
374 (*worker_thread).push(job_ref); in inject_or_push()
440 let worker_thread = WorkerThread::current(); in in_worker() localVariable
[all …]
|
| /external/pdfium/third_party/libopenjpeg20/ |
| 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/ |
| D | rng.rs | 131 worker_thread: Option<thread::JoinHandle<Worker>>, field
142 worker_thread: None, in new()
156 if let Some(worker_thread) = self.worker_thread.take() { in drop()
157 let _ = worker_thread.join(); in drop()
228 self.worker_thread = Some(join_handle); in activate()
242 if let Some(worker_thread) = self.worker_thread.take() { in reset()
243 match worker_thread.join() { in reset()
|
| D | console.rs | 312 worker_thread: Option<thread::JoinHandle<Worker>>, field
329 worker_thread: None, in new()
344 if let Some(worker_thread) = self.worker_thread.take() { in drop()
345 let _ = worker_thread.join(); in drop()
416 self.worker_thread = Some(join_handle); in activate()
429 if let Some(worker_thread) = self.worker_thread.take() { in reset()
430 match worker_thread.join() { in reset()
|
| D | tpm.rs | 167 worker_thread: Option<thread::JoinHandle<()>>, field
175 worker_thread: None, in new()
186 if let Some(worker_thread) = self.worker_thread.take() { in drop()
187 let _ = worker_thread.join(); in drop()
255 self.worker_thread = Some(join_handle); in activate()
|
| D | pmem.rs | 228 worker_thread: Option<thread::JoinHandle<()>>, field
252 worker_thread: None, in new()
270 if let Some(worker_thread) = self.worker_thread.take() { in drop()
271 let _ = worker_thread.join(); in drop()
358 self.worker_thread = Some(join_handle); in activate()
|
| D | balloon.rs | 392 worker_thread: Option<thread::JoinHandle<Tube>>, field
405 worker_thread: None, in new()
430 if let Some(worker_thread) = self.worker_thread.take() { in drop()
431 let _ = worker_thread.join(); in drop()
510 self.worker_thread = Some(join_handle); in activate()
523 if let Some(worker_thread) = self.worker_thread.take() { in reset()
524 match worker_thread.join() { in reset()
|
| /external/webrtc/pc/ |
| D | video_rtp_receiver.cc | 32 VideoRtpReceiver::VideoRtpReceiver(rtc::Thread* worker_thread, in VideoRtpReceiver() argument
35 : VideoRtpReceiver(worker_thread, in VideoRtpReceiver()
40 rtc::Thread* worker_thread, in VideoRtpReceiver() argument
43 : worker_thread_(worker_thread), in VideoRtpReceiver()
48 worker_thread, in VideoRtpReceiver()
52 worker_thread, in VideoRtpReceiver()
54 worker_thread))), in VideoRtpReceiver()
58 worker_thread, in VideoRtpReceiver()
59 new rtc::RefCountedObject<JitterBufferDelay>(worker_thread))) { in VideoRtpReceiver()
|
| D | video_track.cc | 25 rtc::Thread* worker_thread) in VideoTrack() argument
27 worker_thread_(worker_thread), in VideoTrack()
96 rtc::Thread* worker_thread) { in Create() argument
98 new rtc::RefCountedObject<VideoTrack>(id, source, worker_thread); in Create()
|
| D | rtp_sender.cc | 108 RtpSenderBase::RtpSenderBase(rtc::Thread* worker_thread, in RtpSenderBase() argument
111 : worker_thread_(worker_thread), in RtpSenderBase()
114 RTC_DCHECK(worker_thread); in RtpSenderBase()
410 rtc::Thread* worker_thread, in Create() argument
415 new rtc::RefCountedObject<AudioRtpSender>(worker_thread, id, stats, in Create()
419 AudioRtpSender::AudioRtpSender(rtc::Thread* worker_thread, in AudioRtpSender() argument
423 : RtpSenderBase(worker_thread, id, set_streams_observer), in AudioRtpSender()
558 rtc::Thread* worker_thread, in Create() argument
562 new rtc::RefCountedObject<VideoRtpSender>(worker_thread, id, in Create()
566 VideoRtpSender::VideoRtpSender(rtc::Thread* worker_thread, in VideoRtpSender() argument
[all …]
|
| D | audio_rtp_receiver.cc | 31 AudioRtpReceiver::AudioRtpReceiver(rtc::Thread* worker_thread, in AudioRtpReceiver() argument
34 : AudioRtpReceiver(worker_thread, in AudioRtpReceiver()
39 rtc::Thread* worker_thread, in AudioRtpReceiver() argument
42 : worker_thread_(worker_thread), in AudioRtpReceiver()
44 source_(new rtc::RefCountedObject<RemoteAudioSource>(worker_thread)), in AudioRtpReceiver()
52 new rtc::RefCountedObject<JitterBufferDelay>(worker_thread))) { in AudioRtpReceiver()
|
| D | channel.cc | 125 BaseChannel::BaseChannel(rtc::Thread* worker_thread, in BaseChannel() argument
133 : worker_thread_(worker_thread), in BaseChannel()
564 RTC_DCHECK(worker_thread() == rtc::Thread::Current()); in AddRecvStream_w()
569 RTC_DCHECK(worker_thread() == rtc::Thread::Current()); in RemoveRecvStream_w()
574 RTC_DCHECK(worker_thread() == rtc::Thread::Current()); in ResetUnsignaledRecvStream_w()
788 VoiceChannel::VoiceChannel(rtc::Thread* worker_thread, in VoiceChannel() argument
796 : BaseChannel(worker_thread, in VoiceChannel()
841 RTC_DCHECK_RUN_ON(worker_thread()); in SetLocalContent_w()
905 RTC_DCHECK_RUN_ON(worker_thread()); in SetRemoteContent_w()
965 VideoChannel::VideoChannel(rtc::Thread* worker_thread, in VideoChannel() argument
[all …]
|
| /external/crosvm/devices/src/virtio/vhost/user/ |
| D | net.rs | 30 worker_thread: Option<thread::JoinHandle<Worker>>, field
65 worker_thread: None, in new()
79 if let Some(worker_thread) = self.worker_thread.take() { in drop()
80 let _ = worker_thread.join(); in drop()
172 self.worker_thread = Some(join_handle); in activate()
|
| D | block.rs | 34 worker_thread: Option<thread::JoinHandle<Worker>>, field
67 worker_thread: None, in new()
81 if let Some(worker_thread) = self.worker_thread.take() { in drop()
82 let _ = worker_thread.join(); in drop()
167 self.worker_thread = Some(join_handle); in activate()
|
| D | fs.rs | 28 worker_thread: Option<thread::JoinHandle<Worker>>, field
73 worker_thread: None, in new()
166 self.worker_thread = Some(join_handle); in activate()
188 if let Some(worker_thread) = self.worker_thread.take() { in drop()
189 let _ = worker_thread.join(); in drop()
|
| /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/crosvm/devices/src/virtio/vhost/ |
| D | net.rs | 30 worker_thread: Option<thread::JoinHandle<(Worker<U>, T)>>, field
99 worker_thread: None, in new()
123 if let Some(worker_thread) = self.worker_thread.take() { in drop()
124 let _ = worker_thread.join(); in drop()
255 self.worker_thread = Some(join_handle); in activate()
277 if self.worker_thread.is_none() { in control_notify()
331 if let Some(worker_thread) = self.worker_thread.take() { in reset()
332 match worker_thread.join() { in reset()
|
| /external/crosvm/devices/src/virtio/input/ |
| D | mod.rs | 542 worker_thread: Option<thread::JoinHandle<Worker<T>>>, field
555 if let Some(worker_thread) = self.worker_thread.take() { in drop()
556 let _ = worker_thread.join(); in drop()
639 self.worker_thread = Some(join_handle); in activate()
655 if let Some(worker_thread) = self.worker_thread.take() { in reset()
656 match worker_thread.join() { in reset()
678 worker_thread: None, in new_evdev()
697 worker_thread: None, in new_single_touch()
716 worker_thread: None, in new_multi_touch()
736 worker_thread: None, in new_trackpad()
[all …]
|
| /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 | 140 std::unique_ptr<rtc::Thread> worker_thread, in NativeToScopedJavaPeerConnectionFactory() argument
144 std::move(network_thread), std::move(worker_thread), in NativeToScopedJavaPeerConnectionFactory()
152 PostJavaCallback(env, owned_factory->worker_thread(), RTC_FROM_HERE, j_pcf, in NativeToScopedJavaPeerConnectionFactory()
180 std::unique_ptr<rtc::Thread> worker_thread, in NativeToJavaPeerConnectionFactory() argument
184 jni, pcf, std::move(network_thread), std::move(worker_thread), in NativeToJavaPeerConnectionFactory()
279 std::unique_ptr<rtc::Thread> worker_thread = rtc::Thread::Create(); in CreatePeerConnectionFactoryForJava() local
280 worker_thread->SetName("worker_thread", nullptr); in CreatePeerConnectionFactoryForJava()
281 RTC_CHECK(worker_thread->Start()) << "Failed to start thread"; in CreatePeerConnectionFactoryForJava()
301 dependencies.worker_thread = worker_thread.get(); in CreatePeerConnectionFactoryForJava()
338 jni, factory, std::move(network_thread), std::move(worker_thread), in CreatePeerConnectionFactoryForJava()
[all …]
|
| /external/webrtc/rtc_base/ |
| D | rtc_certificate_generator.cc | 47 Thread* worker_thread, in RTCCertificateGenerationTask() argument
52 worker_thread_(worker_thread), in RTCCertificateGenerationTask()
135 Thread* worker_thread) in RTCCertificateGenerator() argument
136 : signaling_thread_(signaling_thread), worker_thread_(worker_thread) { in RTCCertificateGenerator()
|
| /external/webrtc/api/ |
| D | create_peerconnection_factory.cc | 31 rtc::Thread* worker_thread, in CreatePeerConnectionFactory() argument
42 dependencies.worker_thread = worker_thread; in CreatePeerConnectionFactory()
|