Home
last modified time | relevance | path

Searched defs:worker_thread (Results 1 – 25 of 94) sorted by relevance

1234

/aosp_15_r20/external/rust/android-crates-io/crates/rayon-core/src/
Dregistry.rs295 let worker_thread = Box::into_raw(Box::new(WorkerThread::from(thread))); in new() localVariable
317 let worker_thread = WorkerThread::current(); in current() localVariable
332 let worker_thread = WorkerThread::current(); in current_num_threads() localVariable
406 let worker_thread = WorkerThread::current(); in inject_or_push() localVariable
493 let worker_thread = WorkerThread::current(); in in_worker() localVariable
520 let worker_thread = WorkerThread::current(); in in_worker_cold() localVariable
545 let worker_thread = WorkerThread::current(); in in_worker_cross() localVariable
905 let worker_thread = &WorkerThread::from(thread); in main_loop() localVariable
/aosp_15_r20/external/webrtc/pc/
H A Drtp_sender.cc150 RtpSenderBase::RtpSenderBase(rtc::Thread* worker_thread, in RtpSenderBase()
599 rtc::Thread* worker_thread, in Create()
607 AudioRtpSender::AudioRtpSender(rtc::Thread* worker_thread, in AudioRtpSender()
752 rtc::Thread* worker_thread, in Create()
759 VideoRtpSender::VideoRtpSender(rtc::Thread* worker_thread, in VideoRtpSender()
H A Dconnection_context.h74 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
H A Dvideo_track.cc26 rtc::Thread* worker_thread) in VideoTrack()
134 rtc::Thread* worker_thread) { in Create()
H A Dchannel.cc113 BaseChannel::BaseChannel(rtc::Thread* worker_thread, in BaseChannel()
814 VoiceChannel::VoiceChannel(rtc::Thread* worker_thread, in VoiceChannel()
937 VideoChannel::VideoChannel(rtc::Thread* worker_thread, in VideoChannel()
H A Daudio_rtp_receiver.cc27 rtc::Thread* worker_thread, in AudioRtpReceiver()
39 rtc::Thread* worker_thread, in AudioRtpReceiver()
H A Dvideo_rtp_receiver.cc26 VideoRtpReceiver::VideoRtpReceiver(rtc::Thread* worker_thread, in VideoRtpReceiver()
34 rtc::Thread* worker_thread, in VideoRtpReceiver()
H A Dvideo_track_source_proxy.cc22 rtc::Thread* worker_thread, in CreateVideoTrackSourceProxy()
/aosp_15_r20/external/webrtc/sdk/android/native_unittests/peerconnection/
H A Dpeer_connection_factory_unittest.cc39 rtc::Thread* worker_thread, in CreateTestPCF()
92 std::unique_ptr<rtc::Thread> worker_thread = rtc::Thread::Create(); in TEST() local
/aosp_15_r20/external/webrtc/pc/test/
H A Dfake_peer_connection_for_stats.h85 VoiceChannelForTesting(rtc::Thread* worker_thread, in VoiceChannelForTesting()
114 VideoChannelForTesting(rtc::Thread* worker_thread, in VideoChannelForTesting()
350 rtc::Thread* worker_thread() const override { return worker_thread_; } in worker_thread() function
/aosp_15_r20/external/pdfium/third_party/libopenjpeg/
H A Dthread.c600 opj_worker_thread_t* worker_thread; member
658 opj_worker_thread_t* worker_thread; in opj_worker_thread_function() local
759 opj_worker_thread_t* worker_thread, in opj_thread_pool_get_next_job()
867 opj_worker_thread_t* worker_thread; in opj_thread_pool_submit_job() local
/aosp_15_r20/external/webrtc/sdk/android/src/jni/pc/
H A Dpeer_connection_factory.cc122 std::unique_ptr<rtc::Thread> worker_thread, in NativeToScopedJavaPeerConnectionFactory()
161 std::unique_ptr<rtc::Thread> worker_thread, in NativeToJavaPeerConnectionFactory()
259 std::unique_ptr<rtc::Thread> worker_thread = rtc::Thread::Create(); in CreatePeerConnectionFactoryForJava() local
H A Downed_factory_and_threads.cc21 std::unique_ptr<rtc::Thread> worker_thread, in OwnedFactoryAndThreads()
H A Downed_factory_and_threads.h45 rtc::Thread* worker_thread() { return worker_thread_.get(); } in worker_thread() function
H A Dvideo.cc46 rtc::Thread* worker_thread, in CreateVideoSource()
/aosp_15_r20/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
H A Dgrpc_worker_service.cc393 for (auto& worker_thread : threads_) { in Shutdown() local
401 for (auto& worker_thread : threads_) { in HandleRPCsLoop() local
404 for (auto& worker_thread : threads_) { in HandleRPCsLoop() local
/aosp_15_r20/external/cronet/base/task/
H A Dcancelable_task_tracker_unittest.cc46 Thread worker_thread("worker thread"); in TEST_F() local
126 Thread worker_thread("worker thread"); in TEST_F() local
/aosp_15_r20/external/libchrome/base/task/
H A Dcancelable_task_tracker_unittest.cc85 Thread worker_thread("worker thread"); in TEST_F() local
165 Thread worker_thread("worker thread"); in TEST_F() local
/aosp_15_r20/packages/modules/DnsResolver/doh/tests/doh_frontend/src/
Ddns_https_frontend.rs76 worker_thread: Option<JoinHandle<Result<()>>>, field
278 async fn worker_thread(params: WorkerParams) -> Result<()> { in worker_thread() function
/aosp_15_r20/device/generic/car/emulator/audio/driver/
Daudio_hw.h76 pthread_t worker_thread; // Constant after init member
108 pthread_t worker_thread; // Constant after init member
/aosp_15_r20/external/webrtc/call/
H A Ddegraded_call.cc132 webrtc::TaskQueueBase* worker_thread, in ThreadedPacketReceiver()
355 TaskQueueBase* DegradedCall::worker_thread() const { in worker_thread() function in webrtc::DegradedCall
/aosp_15_r20/external/crosvm/devices/src/virtio/console/
H A Dworker.rs299 worker_thread: WorkerThread<Vec<WorkerPort>>, field
309 let worker_thread = WorkerThread::start("v_console", move |kill_evt| { in new() localVariable
/aosp_15_r20/external/sdv/vsomeip/third_party/boost/exception/example/
Dcloning_2.cpp15 worker_thread( boost::exception_ptr & error ) in worker_thread() function
/aosp_15_r20/external/webrtc/sdk/android/native_api/peerconnection/
H A Dpeer_connection_factory.cc26 std::unique_ptr<rtc::Thread> worker_thread, in NativeToJavaPeerConnectionFactory()
/aosp_15_r20/packages/modules/Bluetooth/system/osi/test/
Dfuture_test.cc42 MessageLoopThread worker_thread("worker_thread"); in TEST_F() local

1234