/test/xts/acts/multimedia/media/media_cpp_standard/videoDecEncNdk/src/ |
H A D | VDecEncNdkSample.cpp | 258 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 D | ADecEncNdkSample.cpp | 192 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 D | gtest-port.cc | 308 // 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 D | gtest-port.cc | 349 // 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 D | test_environment.cc | 466 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 D | gtest-port.cc | 314 // 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 D | rbug_core.c | 53 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 D | generated_message_util.cc | 40 // 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 D | ipu3-css.c | 1070 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 D | ipu3-css.c | 1057 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
|
/third_party/pulseaudio/src/modules/bluetooth/ |
H A D | module-bluez5-device.c | 47 #include <pulsecore/thread.h> 48 #include <pulsecore/thread-mq.h> 132 pa_thread *thread; member 184 /* Run from main thread */ 225 /* Run from main thread */ 253 /* Run from main thread */ 333 /* Run from IO thread */ 363 /* Run from IO thread */ 429 /* Run from IO thread */ 501 /* Run from IO thread */ [all...] |
/kernel/linux/linux-5.10/arch/ia64/kernel/ |
H A D | unaligned.c | 530 * (1) save f32-f127 to thread.fph and update the values there in setfpreg() 538 current->thread.fph[fph_index(regs, regnum)] = *fpval; in setfpreg() 592 * to current->thread.fph to get access to it. See discussion in setfpreg() in getfpreg() 597 *fpval = current->thread.fph[fph_index(regs, regnum)]; in getfpreg() 1087 * destination (pt_regs, switch_stack or thread structure). in emulate_load_floatpair() 1183 * destination (pt_regs, switch_stack or thread structure). in emulate_load_float() 1323 if ((current->thread.flags & IA64_THREAD_UAC_SIGBUS) != 0) in ia64_handle_unaligned() 1327 !(current->thread.flags & IA64_THREAD_UAC_NOPRINT) && in ia64_handle_unaligned()
|
/kernel/linux/linux-5.10/arch/powerpc/mm/book3s64/ |
H A D | hash_utils.c | 1705 trap = current->thread.regs ? TRAP(current->thread.regs) : 0UL; in update_mmu_cache() 1731 if (local && cpu_has_feature(CPU_FTR_TM) && current->thread.regs && in tm_flush_hash_page() 1732 MSR_TM_ACTIVE(current->thread.regs->msr)) { in tm_flush_hash_page()
|
/kernel/linux/linux-6.6/arch/mips/kernel/ |
H A D | unaligned.c | 446 res = fpu_emulator_cop1Handler(regs, ¤t->thread.fpu, 1, in emulate_load_store_insn() 478 fpr = ¤t->thread.fpu.fpr[wd]; in emulate_load_store_insn() 967 res = fpu_emulator_cop1Handler(regs, ¤t->thread.fpu, 1, in emulate_load_store_microMIPS() 1534 current->thread.cp0_baduaddr = regs->cp0_badvaddr; in do_ade()
|
/kernel/linux/linux-6.6/arch/ia64/kernel/ |
H A D | unaligned.c | 530 * (1) save f32-f127 to thread.fph and update the values there in setfpreg() 538 current->thread.fph[fph_index(regs, regnum)] = *fpval; in setfpreg() 592 * to current->thread.fph to get access to it. See discussion in setfpreg() in getfpreg() 597 *fpval = current->thread.fph[fph_index(regs, regnum)]; in getfpreg() 1104 * destination (pt_regs, switch_stack or thread structure). in emulate_load_floatpair() 1201 * destination (pt_regs, switch_stack or thread structure). in emulate_load_float() 1342 if ((current->thread.flags & IA64_THREAD_UAC_SIGBUS) != 0) in ia64_handle_unaligned() 1346 !(current->thread.flags & IA64_THREAD_UAC_NOPRINT) && in ia64_handle_unaligned()
|
/third_party/libunwind/libunwind/doc/ |
H A D | libunwind.tex | 194 select, e.g., the thread within a process that is to be unwound. 240 All \Prog{libunwind} routines are thread-safe. What this means is 242 However, any given cursor may be accessed by only one thread at 245 To ensure thread-safety, some \Prog{libunwind} routines may have to
|
/third_party/skia/third_party/externals/swiftshader/third_party/subzero/src/ |
H A D | IceGlobalContext.cpp | 222 for (std::thread &Worker : TranslationThreads) { in waitForWorkerThreads() 230 for (std::thread &Worker : EmitterThreads) { in waitForWorkerThreads() 295 // By default, wake up the main parser thread when the OptQ gets half empty. 324 // Create a new ThreadContext for the current thread. No need to in GlobalContext() 401 // numbers so that the emitter thread will emit subsequent functions. in translateFunctions() 422 // stats have been fully collected into this thread's TLS. in translateFunctions() 668 // TODO(stichnot): Consider adding thread-local caches of constant pool entries 925 TranslationThreads.push_back(std::thread( in startWorkerThreads() 933 std::thread(&GlobalContext::emitterWrapper, this, WorkerTLS)); in startWorkerThreads() 1016 // Temporarily override the thread in dumpLocalTimers() [all...] |
/third_party/python/Modules/ |
H A D | timemodule.c | 27 # include <sys/thread.h> 369 Return the clk_id of a thread's CPU time clock."); 1406 HANDLE thread; local 1412 thread = GetCurrentThread(); 1413 ok = GetThreadTimes(thread, &creation_time, &exit_time, 2208 // A value of zero causes the thread to relinquish the remainder of its 2209 // time slice to any other thread that is ready to run. If there are no 2211 // the thread continues execution. 2240 // Only the main thread can be interrupted by SIGINT. 2241 // Signal handlers are only executed in the main thread [all...] |
/third_party/skia/third_party/externals/abseil-cpp/absl/time/internal/cctz/src/ |
H A D | time_zone_lookup_test.cc | 21 #include <thread> 690 std::vector<std::thread> threads; in TEST() 698 for (auto& thread : threads) { in TEST() 699 thread.join(); in TEST()
|
/kernel/linux/linux-5.10/drivers/char/ipmi/ |
H A D | ipmi_ssif.c | 267 struct task_struct *thread; member 1282 if (ssif_info->thread) { in shutdown_ssif() 1284 kthread_stop(ssif_info->thread); in shutdown_ssif() 1882 ssif_info->thread = kthread_run(ipmi_ssif_thread, ssif_info, in ssif_probe() 1884 if (IS_ERR(ssif_info->thread)) { in ssif_probe() 1885 rv = PTR_ERR(ssif_info->thread); in ssif_probe() 1887 "Could not start kernel thread: error %d\n", in ssif_probe()
|
/kernel/linux/linux-5.10/drivers/scsi/aacraid/ |
H A D | linit.c | 1525 kthread_stop(aac->thread); in __aac_shutdown() 1526 aac->thread = NULL; in __aac_shutdown() 1701 aac->thread = kthread_run(aac_command_thread, aac, AAC_DRIVERNAME); in aac_probe_one() 1702 if (IS_ERR(aac->thread)) { in aac_probe_one() 1703 printk(KERN_ERR "aacraid: Unable to create command thread.\n"); in aac_probe_one() 1704 error = PTR_ERR(aac->thread); in aac_probe_one() 1705 aac->thread = NULL; in aac_probe_one()
|
/kernel/linux/linux-6.6/drivers/char/ipmi/ |
H A D | ipmi_ssif.c | 261 struct task_struct *thread; member 1273 if (ssif_info->thread) { in shutdown_ssif() 1275 kthread_stop(ssif_info->thread); in shutdown_ssif() 1868 ssif_info->thread = kthread_run(ipmi_ssif_thread, ssif_info, in ssif_probe() 1870 if (IS_ERR(ssif_info->thread)) { in ssif_probe() 1871 rv = PTR_ERR(ssif_info->thread); in ssif_probe() 1873 "Could not start kernel thread: error %d\n", in ssif_probe()
|
/kernel/linux/linux-6.6/tools/perf/ |
H A D | builtin-kwork.c | 18 #include "util/thread.h" 592 struct thread *thread; in timehist_save_callchain() local 599 /* want main thread for process - has maps */ in timehist_save_callchain() 600 thread = machine__findnew_thread(machine, sample->pid, sample->pid); in timehist_save_callchain() 601 if (thread == NULL) { in timehist_save_callchain() 602 pr_debug("Failed to get thread for pid %d\n", sample->pid); in timehist_save_callchain() 608 if (thread__resolve_callchain(thread, cursor, evsel, sample, in timehist_save_callchain() 632 thread__put(thread); in timehist_save_callchain()
|
/kernel/linux/linux-6.6/drivers/scsi/aacraid/ |
H A D | linit.c | 1529 kthread_stop(aac->thread); in __aac_shutdown() 1530 aac->thread = NULL; in __aac_shutdown() 1705 aac->thread = kthread_run(aac_command_thread, aac, AAC_DRIVERNAME); in aac_probe_one() 1706 if (IS_ERR(aac->thread)) { in aac_probe_one() 1707 printk(KERN_ERR "aacraid: Unable to create command thread.\n"); in aac_probe_one() 1708 error = PTR_ERR(aac->thread); in aac_probe_one() 1709 aac->thread = NULL; in aac_probe_one()
|
/third_party/pulseaudio/src/modules/oss/ |
H A D | module-oss.c | 55 #include <pulsecore/thread.h> 64 #include <pulsecore/thread-mq.h> 106 pa_thread *thread; member 670 /* Called from the IO thread. */ 758 /* Called from the IO thread. */ 1488 if (!(u->thread = pa_thread_new("oss", thread_func, u))) { in pa__init() 1489 pa_log("Failed to create thread."); in pa__init() 1550 if (u->thread) { in pa__done() 1553 pa_thread_free(u->thread); in pa__done()
|