| /third_party/rust/crates/env_logger/tests/ |
| H A D | log_tls_dtors.rs | 8 use std::thread;
19 // Use multiple thread local values to increase the chance that our TLS in run()
48 // Run on a separate thread because TLS values on the main thread in main()
50 // https://doc.rust-lang.org/std/thread/struct.LocalKey.html#platform-specific-behavior in main()
51 thread::spawn(run).join().unwrap(); in main()
|
| /third_party/python/Python/ |
| H A D | thread_pthread_stubs.h | 83 pthread_create(pthread_t *restrict thread, in pthread_create() argument
92 pthread_detach(pthread_t thread) in pthread_detach() argument
|
| /third_party/python/Include/internal/ |
| H A D | pycore_pystate.h | 14 /* Check if the current thread is the main thread.
19 unsigned long thread = PyThread_get_thread_ident(); in _Py_IsMainThread() local
20 return (thread == _PyRuntime.main_thread); in _Py_IsMainThread()
48 /* Only handle signals on the main thread of the main interpreter. */
56 /* Only execute pending calls on the main thread. */
64 /* Variable and macro for in-line access to current thread
73 /* Get the current Python thread state.
|
| /third_party/skia/third_party/externals/swiftshader/src/Vulkan/ |
| H A D | VkQueue.hpp | 22 #include <thread>
102 std::thread queueThread;
|
| /third_party/skia/third_party/externals/swiftshader/third_party/subzero/src/ |
| H A D | IceBrowserCompileServer.h | 24 #include <thread>
56 /// Creates the streams + context and starts the compile thread, handing off
67 /// Wait for the compile thread to complete then reset the state.
105 std::thread CompileThread;
|
| /third_party/python/Include/cpython/ |
| H A D | pthread_stubs.h | 65 PyAPI_FUNC(int) pthread_create(pthread_t *restrict thread,
69 PyAPI_FUNC(int) pthread_detach(pthread_t thread); variable
|
| /third_party/rust/crates/regex/examples/ |
| H A D | shootout-regex-dna-bytes.rs | 10 use std::thread;
42 let future = thread::spawn(move || variant.find_iter(&seq).count()); in main()
|
| /kernel/linux/linux-6.6/tools/perf/ |
| H A D | builtin-report.c | 42 #include "util/thread.h"
297 thread__set_lbr_stitch_enable(al.thread, true); in process_sample_event()
819 struct thread *thread; member
826 struct thread *parent_thread, *thread = task->thread; in tasks_list() local
834 if (thread__ppid(thread) == -1) in tasks_list()
837 parent_thread = machine__find_thread(machine, -1, thread__ppid(thread)); in tasks_list()
872 struct thread *threa in task__print_level() local
[all...] |
| /kernel/linux/linux-5.10/fs/hfsplus/ |
| H A D | catalog.c | 59 /* Generates key for catalog thread record. */
183 entry->thread.reserved = 0; in hfsplus_fill_cat_thread()
184 entry->thread.parentID = cpu_to_be32(parentid); in hfsplus_fill_cat_thread()
185 err = hfsplus_asc2uni(sb, &entry->thread.nodeName, HFSPLUS_MAX_STRLEN, in hfsplus_fill_cat_thread()
190 return 10 + be16_to_cpu(entry->thread.nodeName.length) * 2; in hfsplus_fill_cat_thread()
208 pr_err("found bad thread record in catalog\n"); in hfsplus_find_cat()
212 if (be16_to_cpu(tmp.thread.nodeName.length) > 255) { in hfsplus_find_cat()
218 be32_to_cpu(tmp.thread.parentID), in hfsplus_find_cat()
219 &tmp.thread.nodeName); in hfsplus_find_cat()
516 /* remove old thread entr in hfsplus_rename_cat()
[all...] |
| /kernel/linux/linux-6.6/fs/hfsplus/ |
| H A D | catalog.c | 59 /* Generates key for catalog thread record. */
183 entry->thread.reserved = 0; in hfsplus_fill_cat_thread()
184 entry->thread.parentID = cpu_to_be32(parentid); in hfsplus_fill_cat_thread()
185 err = hfsplus_asc2uni(sb, &entry->thread.nodeName, HFSPLUS_MAX_STRLEN, in hfsplus_fill_cat_thread()
190 return 10 + be16_to_cpu(entry->thread.nodeName.length) * 2; in hfsplus_fill_cat_thread()
208 pr_err("found bad thread record in catalog\n"); in hfsplus_find_cat()
212 if (be16_to_cpu(tmp.thread.nodeName.length) > 255) { in hfsplus_find_cat()
218 be32_to_cpu(tmp.thread.parentID), in hfsplus_find_cat()
219 &tmp.thread.nodeName); in hfsplus_find_cat()
516 /* remove old thread entr in hfsplus_rename_cat()
[all...] |
| /third_party/alsa-utils/alsaloop/ |
| H A D | alsaloop.c | 41 pthread_t thread; member
63 static void my_exit(struct loopback_thread *thread, int exitcode) in my_exit() argument
67 for (i = 0; i < thread->loopbacks_count; i++) in my_exit()
68 pcmjob_done(thread->loopbacks[i]); in my_exit()
69 if (thread->threaded) { in my_exit()
70 thread->exitcode = exitcode; in my_exit()
196 "-T,--thread thread number (-1 = create unique)\n" in help()
384 {"thread", 1, NULL, 'T'}, in parse_config()
627 loop->thread in parse_config()
728 struct loopback_thread *thread = _data; thread_job1() local
802 thread_job(struct loopback_thread *thread) thread_job() argument
814 struct loopback_thread *thread; send_to_all() local
833 struct loopback_thread *thread; signal_handler_state() local
[all...] |
| /third_party/skia/tests/ |
| H A D | StringTest.cpp | 15 #include <thread>
279 std::thread threads[5]; in DEF_TEST()
280 for (auto& thread : threads) { in DEF_TEST()
281 thread = std::thread([&] { in DEF_TEST()
286 for (auto& thread : threads) { in DEF_TEST()
287 thread.join(); in DEF_TEST()
|
| /third_party/skia/third_party/externals/dng_sdk/source/ |
| H A D | dng_pthread.cpp | 215 // between pthreads thread funcs and Windows C lib thread funcs
310 int dng_pthread_create(dng_pthread_t *thread, const pthread_attr_t *attrs, void * (*func)(void *), void *arg) in dng_pthread_create() argument
342 // If there is a handle open on the thread, its ID should not be reused so assert that an insertion was made. in dng_pthread_create()
349 *thread = (dng_pthread_t)threadID; in dng_pthread_create()
360 int dng_pthread_detach(dng_pthread_t thread) in dng_pthread_detach() argument
368 ThreadMapType::iterator iter = primaryHandleMap.find(thread); in dng_pthread_detach()
374 // A join is waiting on the thread. in dng_pthread_detach()
393 int dng_pthread_join(dng_pthread_t thread, void **result) in dng_pthread_join() argument
404 iter = primaryHandleMap.find(thread); in dng_pthread_join()
[all...] |
| /kernel/linux/linux-5.10/arch/arm64/kernel/ |
| H A D | signal.c | 174 ¤t->thread.uw.fpsimd_state; in preserve_fpsimd_context()
230 unsigned int vl = current->thread.sve_vl; in preserve_sve_context()
252 current->thread.sve_state, in preserve_sve_context()
269 if (sve.vl != current->thread.sve_vl) in restore_sve_fpsimd_context()
284 * thread.sve_state with preemption enabled, so protection is in restore_sve_fpsimd_context()
290 /* From now, fpsimd_thread_switch() won't touch thread.sve_state */ in restore_sve_fpsimd_context()
293 err = __copy_from_user(current->thread.sve_state, in restore_sve_fpsimd_context()
583 if (add_all || current->thread.fault_code) { in setup_sigframe_layout()
597 vl = current->thread.sve_vl; in setup_sigframe_layout()
628 __put_user_error(current->thread in setup_sigframe()
[all...] |
| /kernel/linux/linux-5.10/arch/m68k/kernel/ |
| H A D | signal.c | 261 memcpy(current->thread.fpcntl, sc->sc_fpcntl, 12); in restore_fpu_state()
262 memcpy(current->thread.fp, sc->sc_fpregs, 24); in restore_fpu_state()
340 if (__copy_from_user(current->thread.fpcntl, in rt_restore_fpu_state()
344 if (__copy_from_user(current->thread.fp, in rt_restore_fpu_state()
433 memcpy(sc->sc_fpcntl, current->thread.fpcntl, 12); in save_fpu_state()
434 memcpy(sc->sc_fpregs, current->thread.fp, 24); in save_fpu_state()
491 current->thread.fpcntl, 12); in rt_save_fpu_state()
494 current->thread.fp, 96); in rt_save_fpu_state()
1119 current->thread.esp0 = (unsigned long) regs; in do_signal()
|
| /kernel/linux/linux-5.10/tools/perf/util/ |
| H A D | arm-spe.c | 27 #include "thread.h"
28 #include "thread-stack.h"
86 struct thread *thread; member
496 thread__zput(speq->thread); in arm_spe_set_pid_tid_cpu()
500 if ((!speq->thread) && (speq->tid != -1)) { in arm_spe_set_pid_tid_cpu()
501 speq->thread = machine__find_thread(spe->machine, -1, in arm_spe_set_pid_tid_cpu()
505 if (speq->thread) { in arm_spe_set_pid_tid_cpu()
506 speq->pid = speq->thread->pid_; in arm_spe_set_pid_tid_cpu()
508 speq->cpu = speq->thread in arm_spe_set_pid_tid_cpu()
[all...] |
| /kernel/linux/linux-6.6/drivers/tty/ |
| H A D | mips_ejtag_fdc.c | 95 * This protects between user context and kernel thread.
127 * @thread: KThread for writing out data to FDC.
150 struct task_struct *thread; member
477 * mips_ejtag_fdc_put() - Kernel thread to write out channel data to FDC.
480 * This kernel thread runs while @priv->xmit_total != 0, and round robins the
736 * writer thread to drain the buffer. in mips_ejtag_fdc_tty_port_shutdown()
959 * Bind the writer thread to the right CPU so it can't migrate. in mips_ejtag_fdc_tty_probe()
963 priv->thread = kthread_run_on_cpu(mips_ejtag_fdc_put, priv, in mips_ejtag_fdc_tty_probe()
965 if (IS_ERR(priv->thread)) { in mips_ejtag_fdc_tty_probe()
966 ret = PTR_ERR(priv->thread); in mips_ejtag_fdc_tty_probe()
[all...] |
| /kernel/linux/linux-5.10/arch/xtensa/kernel/ |
| H A D | asm-offsets.c | 77 DEFINE(TASK_THREAD, offsetof (struct task_struct, thread)); in main()
93 DEFINE(THREAD_RA, offsetof (struct task_struct, thread.ra)); in main()
94 DEFINE(THREAD_SP, offsetof (struct task_struct, thread.sp)); in main()
112 thread.current_ds)); in main()
|
| /kernel/linux/linux-5.10/arch/nds32/kernel/ |
| H A D | traps.c | 146 base_reg = (unsigned long *)(tsk->thread.cpu_context.sp); in show_stack()
151 base_reg = (unsigned long *)(tsk->thread.cpu_context.fp); in show_stack()
263 tsk->thread.trap_no = ENTRY_DEBUG_RELATED; in send_sigtrap()
264 tsk->thread.error_code = error_code; in send_sigtrap()
|
| /kernel/linux/linux-5.10/arch/s390/lib/ |
| H A D | uaccess.c | 45 current->thread.mm_segment = fs; in set_fs()
69 old_fs = current->thread.mm_segment; in enable_sacf_uaccess()
74 current->thread.mm_segment |= 1; in enable_sacf_uaccess()
96 current->thread.mm_segment = old_fs; in disable_sacf_uaccess()
|
| /kernel/linux/linux-5.10/drivers/firmware/psci/ |
| H A D | psci_checker.c | 282 /* Wait for the main thread to give the start signal. */ in suspend_test_thread()
388 struct task_struct *thread; in suspend_tests() local
399 thread = kthread_create_on_cpu(suspend_test_thread, in suspend_tests()
402 if (IS_ERR(thread)) in suspend_tests()
405 threads[nb_threads++] = thread; in suspend_tests()
416 * Wake up the suspend threads. To avoid the main thread being preempted in suspend_tests()
|
| /kernel/linux/linux-6.6/arch/riscv/kernel/ |
| H A D | ptrace.c | 57 struct __riscv_d_ext_state *fstate = &target->thread.fstate; in riscv_fpr_get()
73 struct __riscv_d_ext_state *fstate = &target->thread.fstate; in riscv_fpr_set()
92 struct __riscv_v_ext_state *vstate = &target->thread.vstate; in riscv_vr_get()
124 struct __riscv_v_ext_state *vstate = &target->thread.vstate; in riscv_vr_set()
|
| /kernel/linux/linux-5.10/drivers/infiniband/hw/hfi1/ |
| H A D | msix.c | 105 * @thread: IRQ thread handler (could be NULL)
118 irq_handler_t handler, irq_handler_t thread, in msix_request_irq()
141 ret = pci_request_irq(dd->pcidev, nr, handler, thread, arg, name); in msix_request_irq()
171 irq_handler_t thread, in msix_request_rcd_irq_common()
174 int nr = msix_request_irq(rcd->dd, rcd, handler, thread, in msix_request_rcd_irq_common()
117 msix_request_irq(struct hfi1_devdata *dd, void *arg, irq_handler_t handler, irq_handler_t thread, enum irq_type type, const char *name) msix_request_irq() argument
169 msix_request_rcd_irq_common(struct hfi1_ctxtdata *rcd, irq_handler_t handler, irq_handler_t thread, const char *name) msix_request_rcd_irq_common() argument
|
| /kernel/linux/linux-6.6/drivers/firmware/psci/ |
| H A D | psci_checker.c | 282 /* Wait for the main thread to give the start signal. */ in suspend_test_thread()
388 struct task_struct *thread; in suspend_tests() local
399 thread = kthread_create_on_cpu(suspend_test_thread, in suspend_tests()
402 if (IS_ERR(thread)) in suspend_tests()
405 threads[nb_threads++] = thread; in suspend_tests()
416 * Wake up the suspend threads. To avoid the main thread being preempted in suspend_tests()
|
| /kernel/linux/linux-6.6/drivers/infiniband/hw/hfi1/ |
| H A D | msix.c | 62 * @thread: IRQ thread handler (could be NULL)
75 irq_handler_t handler, irq_handler_t thread, in msix_request_irq()
98 ret = pci_request_irq(dd->pcidev, nr, handler, thread, arg, name); in msix_request_irq()
128 irq_handler_t thread, in msix_request_rcd_irq_common()
131 int nr = msix_request_irq(rcd->dd, rcd, handler, thread, in msix_request_rcd_irq_common()
74 msix_request_irq(struct hfi1_devdata *dd, void *arg, irq_handler_t handler, irq_handler_t thread, enum irq_type type, const char *name) msix_request_irq() argument
126 msix_request_rcd_irq_common(struct hfi1_ctxtdata *rcd, irq_handler_t handler, irq_handler_t thread, const char *name) msix_request_rcd_irq_common() argument
|