Home
last modified time | relevance | path

Searched refs:thread (Results 1851 - 1875 of 2466) sorted by relevance

1...<<71727374757677787980>>...99

/third_party/libunwind/libunwind/doc/
H A Dlibunwind-ptrace.tex99 explicit locking is used. As long as only one thread uses
101 is thread-safe.
/third_party/ltp/testcases/realtime/func/rt-migrate/
H A Drt-migrate.c30 * - If the thread is high priority, and if a CPU is available, the
31 * thread runs on that CPU.
32 * - The thread records the start time and the number of ticks in the run
314 struct thread *thr = (struct thread *)data; in start_task()
465 debug(DBG_WARN, "Warning, can't set priority of main thread!\n"); in main()
/third_party/node/deps/v8/src/base/platform/
H A Dplatform-fuchsia.cc8 #include <lib/zx/thread.h>
361 if (zx::thread::self()->get_info(ZX_INFO_THREAD_STATS, &info, sizeof(info), in GetUserTime()
/third_party/skia/third_party/externals/oboe/apps/OboeTester/app/src/main/cpp/
H A DNativeAudioContext.h23 #include <thread>
263 // stop a thread that runs in place of the callback in stopBlockingIOThread()
264 threadEnabled.store(false); // ask thread to exit its loop in stopBlockingIOThread()
331 std::thread *dataThread = nullptr;
/third_party/rust/crates/nix/src/sys/
H A Daio.rs35 ptr, thread,
206 thread::panicking() || !self.in_progress, in drop()
247 /// # use std::{thread, time};
262 /// thread::sleep(time::Duration::from_millis(10));
289 /// # use std::{thread, time};
301 /// thread::sleep(time::Duration::from_millis(10));
326 /// # use std::{thread, time};
336 /// thread::sleep(time::Duration::from_millis(10));
418 /// # use std::{thread, time};
426 /// thread
[all...]
/kernel/linux/linux-5.10/drivers/md/
H A Draid10.c284 md_wakeup_thread(mddev->thread); in reschedule_retry()
302 * Wake up any possible resync thread that waits for the device in raid_end_bio_io()
881 * thread state in flush_pending_writes()
985 /* move on if recovery thread is in wait_barrier()
988 (conf->mddev->thread->tsk == current && in wait_barrier()
1075 md_wakeup_thread(mddev->thread); in raid10_unplug()
1105 * 1. Register the new request and wait if the reconstruction thread has put
1285 md_wakeup_thread(mddev->thread); in raid10_write_one_disk()
1326 md_wakeup_thread(mddev->thread); in raid10_write_request()
1335 md_wakeup_thread(mddev->thread); in raid10_write_request()
2717 raid10d(struct md_thread *thread) raid10d() argument
[all...]
/kernel/linux/linux-6.6/arch/arm64/mm/
H A Dfault.c423 current->thread.fault_address = address; in set_thread_esr()
437 if (!is_ttbr0_addr(current->thread.fault_address)) { in set_thread_esr()
475 current->thread.fault_code = esr; in set_thread_esr()
/kernel/linux/linux-5.10/drivers/md/bcache/
H A Dwriteback.c142 * c->idle_counter is increased by writeback thread of all in idle_counter_exceeded()
707 * the writeback thread should sleep here and wait for others in bch_writeback_thread()
734 * writeback thread should stop after there is no dirty in bch_writeback_thread()
749 * BCH_DO_AUTO_GC is set, garbage collection thread in bch_writeback_thread()
974 state.infos[i].thread = in bch_sectors_dirty_init()
977 if (IS_ERR(state.infos[i].thread)) { in bch_sectors_dirty_init()
978 pr_err("fails to run thread bch_dirty_init[%d]\n", i); in bch_sectors_dirty_init()
981 kthread_stop(state.infos[i].thread); in bch_sectors_dirty_init()
/kernel/linux/linux-5.10/fs/ceph/
H A Dsuper.h798 struct task_struct *thread; member
804 .thread = current, \
830 if (ctx->thread == current) { in ceph_find_rw_context()
/kernel/linux/linux-6.6/drivers/md/bcache/
H A Dwriteback.c180 * c->idle_counter is increased by writeback thread of all in idle_counter_exceeded()
755 * the writeback thread should sleep here and wait for others in bch_writeback_thread()
782 * writeback thread should stop after there is no dirty in bch_writeback_thread()
806 * BCH_DO_AUTO_GC is set, garbage collection thread in bch_writeback_thread()
1030 state.infos[i].thread = in bch_sectors_dirty_init()
1033 if (IS_ERR(state.infos[i].thread)) { in bch_sectors_dirty_init()
1034 pr_err("fails to run thread bch_dirty_init[%d]\n", i); in bch_sectors_dirty_init()
1037 kthread_stop(state.infos[i].thread); in bch_sectors_dirty_init()
/kernel/linux/linux-6.6/tools/testing/selftests/mm/
H A Duffd-unit-tests.c300 pthread_t thread; in pagemap_test_fork() local
305 /* Prepare a thread to resolve EVENT_FORK */ in pagemap_test_fork()
307 if (pthread_create(&thread, NULL, fork_event_consumer, &args)) in pagemap_test_fork()
341 if (pthread_join(thread, NULL)) in pagemap_test_fork()
666 * feature. Using monitor thread, verify no userfault events are generated.
/test/xts/acts/ai/neural_network_runtime/v2_0/interface/src/
H A DCompileTest.cpp18 #include <thread>
851 std::thread th1(CompileModel, compilation1, m_compileParam); in HWTEST_F()
852 std::thread th2(CompileModel, compilation2, m_compileParam); in HWTEST_F()
/test/xts/acts/ai/neural_network_runtime/v1_0/interface/src/
H A DCompileTest.cpp18 #include <thread>
851 std::thread th1(CompileModel, compilation1, m_compileParam); in HWTEST_F()
852 std::thread th2(CompileModel, compilation2, m_compileParam); in HWTEST_F()
/test/xts/acts/multimedia/av_codec/vcodec/encoder/src/
H A Dvideoenc_api11_sample.cpp397 inputLoop_ = make_unique<thread>(&VEncAPI11Sample::InputFuncSurface, this); in StartVideoEncoder()
399 inputLoop_ = make_unique<thread>(&VEncAPI11Sample::InputFunc, this); in StartVideoEncoder()
407 outputLoop_ = make_unique<thread>(&VEncAPI11Sample::OutputFunc, this); in StartVideoEncoder()
H A Dvideoenc_ndk_sample.cpp366 inputLoop_ = make_unique<thread>(&VEncNdkSample::InputFuncSurface, this); in StartVideoEncoder()
368 inputLoop_ = make_unique<thread>(&VEncNdkSample::InputFunc, this); in StartVideoEncoder()
376 outputLoop_ = make_unique<thread>(&VEncNdkSample::OutputFunc, this); in StartVideoEncoder()
/test/xts/acts/multimedia/media/media_cpp_standard/videoDecEncNdk/src/
H A DVDecEncNdkSample.cpp258 inputLoopDec_ = make_unique<thread>(&VDecEncNdkSample::InputFuncDec, this); in StartDec()
262 outputLoopDec_ = make_unique<thread>(&VDecEncNdkSample::OutputFuncDec, this); in StartDec()
591 outputLoopEnc_ = make_unique<thread>(&VDecEncNdkSample::OutputFuncEnc, this); in StartEnc()
/test/xts/acts/multimedia/media/media_cpp_standard/audioDecEncNdk/src/
H A DADecEncNdkSample.cpp192 inputLoopDec_ = make_unique<thread>(&ADecEncNdkSample::InputFuncDec, this); in StartDec()
465 inputLoopEnc_ = make_unique<thread>(&ADecEncNdkSample::InputFuncEnc, this); in StartEnc()
469 outputLoopEnc_ = make_unique<thread>(&ADecEncNdkSample::OutputFuncEnc, this); in StartEnc()
/third_party/googletest/googletest/src/
H A Dgtest-port.cc308 // Static mutexes are leaked intentionally. It is not thread-safe to try in ~Mutex()
326 // caller's responsibility to ensure that the current thread holds the in Unlock()
332 // Does nothing if the current thread holds the mutex. Otherwise, crashes
337 << "The current thread is not holding the mutex @" << this; in AssertHeld()
403 // Possibly yields the rest of the thread's time slice to other in ThreadSafeLazyInit()
479 << "Failed to join the thread with error " << ::GetLastError() << "."; in Join()
482 // Maps a thread to a set of ThreadIdToThreadLocals that have values
483 // instantiated on that thread and notifies them when the thread exits. A
488 // Registers thread_local_instance as having value on the current thread
591 HANDLE thread = StartWatcherThreadFor() local
[all...]
/third_party/mesa3d/src/gtest/src/
H A Dgtest-port.cc349 // Static mutexes are leaked intentionally. It is not thread-safe to try in ~Mutex()
367 // caller's responsibility to ensure that the current thread holds the in Unlock()
373 // Does nothing if the current thread holds the mutex. Otherwise, crashes
378 << "The current thread is not holding the mutex @" << this; in AssertHeld()
446 // Possibly yields the rest of the thread's time slice to other in ThreadSafeLazyInit()
526 << "Failed to join the thread with error " << ::GetLastError() << "."; in Join()
529 // Maps a thread to a set of ThreadIdToThreadLocals that have values
530 // instantiated on that thread and notifies them when the thread exits. A
535 // Registers thread_local_instance as having value on the current thread
635 HANDLE thread = ::OpenThread(SYNCHRONIZE | THREAD_QUERY_INFORMATION, StartWatcherThreadFor() local
[all...]
/third_party/node/test/cctest/
H A Dtest_environment.cc466 uv_thread_t thread; in TEST_F() local
467 err = uv_thread_create(&thread, [](void* arg) { in TEST_F()
528 uv_thread_join(&thread); in TEST_F()
/third_party/node/deps/googletest/src/
H A Dgtest-port.cc314 // Static mutexes are leaked intentionally. It is not thread-safe to try in ~Mutex()
332 // caller's responsibility to ensure that the current thread holds the in Unlock()
338 // Does nothing if the current thread holds the mutex. Otherwise, crashes
343 << "The current thread is not holding the mutex @" << this; in AssertHeld()
409 // Possibly yields the rest of the thread's time slice to other in ThreadSafeLazyInit()
485 << "Failed to join the thread with error " << ::GetLastError() << "."; in Join()
488 // Maps a thread to a set of ThreadIdToThreadLocals that have values
489 // instantiated on that thread and notifies them when the thread exits. A
494 // Registers thread_local_instance as having value on the current thread
597 HANDLE thread = StartWatcherThreadFor() local
[all...]
/third_party/mesa3d/src/gallium/auxiliary/driver_rbug/
H A Drbug_core.c53 thrd_t thread; member
844 if (thrd_success != u_thread_create(&tr_rbug->thread, rbug_thread, tr_rbug)) { in rbug_start()
859 thrd_join(tr_rbug->thread, NULL); in rbug_stop()
/third_party/protobuf/src/google/protobuf/
H A Dgenerated_message_util.cc40 // We're only using this as a standard way for getting the thread id.
41 // We're not using any thread functionality.
42 #include <thread> // NOLINT
794 // thread that is currently initializing. in InitSCCImpl()
796 static std::atomic<std::thread::id> runner; in InitSCCImpl()
799 // This is a lightweight replacement for std::thread::id. std::thread does not in InitSCCImpl()
821 runner.store(std::thread::id{}, std::memory_order_relaxed); in InitSCCImpl()
/kernel/linux/linux-5.10/drivers/staging/media/ipu3/
H A Dipu3-css.c1070 static u8 imgu_css_queue_pos(struct imgu_css *css, int queue, int thread) in imgu_css_queue_pos() argument
1078 return queue >= 0 ? readb(&q->host2sp_bufq_info[thread][queue].end) : in imgu_css_queue_pos()
1084 int queue, int thread, u32 data) in imgu_css_queue_data()
1094 size = readb(&q->host2sp_bufq_info[thread][queue].size); in imgu_css_queue_data()
1095 start = readb(&q->host2sp_bufq_info[thread][queue].start); in imgu_css_queue_data()
1096 end = readb(&q->host2sp_bufq_info[thread][queue].end); in imgu_css_queue_data()
1111 writel(data, &q->host2sp_bufq[thread][queue][end]); in imgu_css_queue_data()
1112 writeb(end2, &q->host2sp_bufq_info[thread][queue].end); in imgu_css_queue_data()
1083 imgu_css_queue_data(struct imgu_css *css, int queue, int thread, u32 data) imgu_css_queue_data() argument
/kernel/linux/linux-6.6/drivers/staging/media/ipu3/
H A Dipu3-css.c1057 static u8 imgu_css_queue_pos(struct imgu_css *css, int queue, int thread) in imgu_css_queue_pos() argument
1065 return queue >= 0 ? readb(&q->host2sp_bufq_info[thread][queue].end) : in imgu_css_queue_pos()
1071 int queue, int thread, u32 data) in imgu_css_queue_data()
1081 size = readb(&q->host2sp_bufq_info[thread][queue].size); in imgu_css_queue_data()
1082 start = readb(&q->host2sp_bufq_info[thread][queue].start); in imgu_css_queue_data()
1083 end = readb(&q->host2sp_bufq_info[thread][queue].end); in imgu_css_queue_data()
1098 writel(data, &q->host2sp_bufq[thread][queue][end]); in imgu_css_queue_data()
1099 writeb(end2, &q->host2sp_bufq_info[thread][queue].end); in imgu_css_queue_data()
1070 imgu_css_queue_data(struct imgu_css *css, int queue, int thread, u32 data) imgu_css_queue_data() argument

Completed in 37 milliseconds

1...<<71727374757677787980>>...99