| /foundation/ai/intelligent_voice_framework/services/intell_voice_engine/server/wakeup/headset/ |
| H A D | headset_wakeup_engine_impl.cpp | 157 std::thread(&HeadsetWakeupEngineImpl::OnInitDone, this, event.result).detach(); in OnWakeupEvent()
161 std::thread(&HeadsetWakeupEngineImpl::OnWakeupRecognition, this, event.result, event.info).detach(); in OnWakeupEvent()
294 std::thread t1(std::bind(&HeadsetWakeupEngineImpl::ReadThread, this)); in StartAudioSource()
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service_base/include/transaction/ |
| H A D | rs_marshalling_helper.h | 23 #include <thread>
411 static void BeginNoSharedMem(std::thread::id tid);
413 static bool GetUseSharedMem(std::thread::id tid);
|
| /foundation/multimedia/av_codec/test/moduletest/audio_encoder/InnerAPI/ |
| H A D | InnerFuzzTest.cpp | 413 vector<thread> threadVec; in HWTEST_F()
414 threadVec.push_back(thread(inputFunc, encoderDemo)); in HWTEST_F()
415 threadVec.push_back(thread(outputFunc, encoderDemo)); in HWTEST_F()
|
| /foundation/communication/ipc/ipc/native/src/mock/include/ |
| H A D | dbinder_base_invoker_object.h | 406 ZLOGE(LOG_LABEL, "make thread message info failed, handle:%{public}u seq:%{public}" PRIu64,
in WaitForReply()
420 ZLOGE(LOG_LABEL, "sender thread wait reply message time out, "
in WaitForReply()
454 std::thread::id threadId = current->GetIdleDataThread();
in StartProcessLoop()
455 if (threadId == std::thread::id()) {
in StartProcessLoop()
459 ZLOGE(LOG_LABEL, "create IO thread failed, current socket thread num:%{public}d socketId:%{public}d",
in StartProcessLoop()
461 /* thread create too much, wait some thread be idle */
in StartProcessLoop()
464 /* no IO thread in idle state, wait a monent */
in StartProcessLoop()
466 } while ((threadId = current->GetIdleDataThread()) == std::thread in StartProcessLoop()
[all...] |
| /foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/channel/ |
| H A D | auth_negotiate_channel.cpp | 156 std::thread(&AuthNegotiateChannel::OnWaitDetectResponseTimeout, this).detach(); in SendMessageAndWaitResponse()
235 std::thread(AuthNegotiateChannel::ProcessDetectLinkRequest, channel).detach(); in OnAuthDataReceived()
238 std::thread(AuthNegotiateChannel::ProcessDetectLinkResponse, handle, msg).detach(); in OnAuthDataReceived()
|
| /foundation/deviceprofile/device_info_manager/interfaces/innerkits/core/src/ |
| H A D | distributed_device_profile_client.cpp | 24 #include <thread>
450 std::thread(&DistributedDeviceProfileClient::SendSubscribeInfosToService, this).detach(); in StartThreadSendSubscribeInfos()
467 std::thread(autoTask).detach(); in ReSubscribeDeviceProfileInited()
|
| /foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_toolkit/net_helper/ |
| H A D | http_request.cpp | 17 #include <thread>
365 std::thread getHost = std::thread(&GetHostThread, pData); in GetIPFromUrl()
|
| /kernel/linux/linux-5.10/arch/arm64/kernel/ |
| H A D | signal32.c | 97 ¤t->thread.uw.fpsimd_state; in compat_preserve_vfp_context()
388 __put_user_error(!!(current->thread.fault_code & ESR_ELx_WNR) << in compat_setup_sigframe()
390 __put_user_error(current->thread.fault_address, &sf->uc.uc_mcontext.fault_address, err); in compat_setup_sigframe()
|
| /kernel/linux/linux-5.10/arch/arm/mm/ |
| H A D | fault.c | 172 tsk->thread.address = addr; in __do_user_fault()
173 tsk->thread.error_code = fsr; in __do_user_fault()
174 tsk->thread.trap_no = 14; in __do_user_fault()
|
| /kernel/linux/linux-5.10/arch/powerpc/mm/book3s32/ |
| H A D | mmu.c | 340 if (!current->thread.regs) in update_mmu_cache()
344 if (TRAP(current->thread.regs) != 0x300 && TRAP(current->thread.regs) != 0x400) in update_mmu_cache()
|
| /kernel/linux/linux-5.10/arch/x86/include/asm/fpu/ |
| H A D | internal.h | 498 struct fpu *fpu = ¤t->thread.fpu; in __fpregs_load_activate()
524 * are saved in the current thread's FPU register state.
536 struct fpu *old_fpu = &prev->thread.fpu; in switch_fpu_prepare()
561 struct fpu *next_fpu = &next->thread.fpu; in switch_fpu_finish()
|
| /kernel/linux/linux-5.10/arch/sparc/kernel/ |
| H A D | prom_64.c | 382 int cpu, unsigned int *thread) in arch_find_n_match_cpu_physical_id()
415 if (thread) { in arch_find_n_match_cpu_physical_id()
418 /* On sparc64, the cpu thread information is obtained in arch_find_n_match_cpu_physical_id()
427 *thread = proc_id; in arch_find_n_match_cpu_physical_id()
381 arch_find_n_match_cpu_physical_id(struct device_node *cpun, int cpu, unsigned int *thread) arch_find_n_match_cpu_physical_id() argument
|
| /kernel/linux/linux-5.10/arch/x86/ia32/ |
| H A D | ia32_signal.c | 175 unsafe_put_user(current->thread.trap_nr, &sc->trapno, Efault); in __unsafe_setup_sigcontext32()
176 unsafe_put_user(current->thread.error_code, &sc->err, Efault); in __unsafe_setup_sigcontext32()
187 unsafe_put_user(current->thread.cr2, &sc->cr2, Efault); in __unsafe_setup_sigcontext32()
|
| /kernel/linux/linux-5.10/arch/arc/kernel/ |
| H A D | entry.S | 59 jl.d [r14] ; kernel thread entry point
68 ; a kernel thread which is executed via JL above but always returns
169 st r12, [r11, THREAD_FAULT_ADDR] ; thread.fault_address
|
| /kernel/linux/linux-5.10/tools/testing/selftests/x86/ |
| H A D | fsgsbase.c | 241 printf("\tother thread: ARCH_SET_GS(0x%lx)%s -- sel is 0x%hx\n", in do_remote_base()
251 * that GSBASE == 0 (i.e. thread.gsbase == 0). in load_gs()
348 * thread.gsbase == 0. in threadproc()
354 errx(1, "helper thread got bad command"); in threadproc()
425 printf("[RUN]\tARCH_SET_GS(0), clear gs, then manipulate GSBASE in a different thread\n"); in test_unexpected_base()
589 pthread_t thread; in main() local
631 if (pthread_create(&thread, 0, threadproc, 0) != 0) in main()
669 ftx = 3; /* Kill the thread. */ in main()
672 if (pthread_join(thread, NULL) != 0) in main()
|
| /kernel/linux/linux-6.6/arch/arc/kernel/ |
| H A D | ptrace.c | 98 struct callee_regs *tmp = (struct callee_regs *)tsk->thread.callee_reg; in task_callee_regs()
148 membuf_store(&to, target->thread.fault_address); // efa in genregs_get()
151 stop_pc_val = target->thread.fault_address; in genregs_get()
|
| /kernel/linux/linux-6.6/arch/arm/mm/ |
| H A D | fault.c | 200 tsk->thread.address = addr; in __do_user_fault()
201 tsk->thread.error_code = fsr; in __do_user_fault()
202 tsk->thread.trap_no = 14; in __do_user_fault()
|
| /kernel/linux/linux-6.6/arch/sparc/kernel/ |
| H A D | prom_64.c | 382 int cpu, unsigned int *thread) in arch_find_n_match_cpu_physical_id()
415 if (thread) { in arch_find_n_match_cpu_physical_id()
418 /* On sparc64, the cpu thread information is obtained in arch_find_n_match_cpu_physical_id()
427 *thread = proc_id; in arch_find_n_match_cpu_physical_id()
381 arch_find_n_match_cpu_physical_id(struct device_node *cpun, int cpu, unsigned int *thread) arch_find_n_match_cpu_physical_id() argument
|
| /kernel/linux/linux-5.10/tools/perf/bench/ |
| H A D | epoll-ctl.c | 59 /* amount of fds to monitor, per thread */
69 pthread_t thread; member
77 OPT_UINTEGER('f', "nfds", &nfds, "Specify amount of file descriptors to monitor for each thread"),
266 ret = pthread_create(&w->thread, attrp, workerfn, in do_threads()
376 printinfo("main thread: toggling done\n"); in bench_epoll_ctl()
379 ret = pthread_join(worker[i].thread, NULL); in bench_epoll_ctl()
398 printf("[thread %2d] fdmap: %p [ add: %04ld; mod: %04ld; del: %04lds ops ]\n", in bench_epoll_ctl()
402 printf("[thread %2d] fdmap: %p ... %p [ add: %04ld ops; mod: %04ld ops; del: %04ld ops ]\n", in bench_epoll_ctl()
|
| /kernel/linux/linux-5.10/tools/io_uring/ |
| H A D | io_uring-bench.c | 73 pthread_t thread; member
103 static int sq_thread_poll = 0; /* use kernel submission/poller thread */
104 static int sq_thread_cpu = -1; /* pin above thread to this CPU */
306 * Only need to call io_uring_enter if we're not using SQ thread in submitter_fn()
322 * For non SQ thread poll, we already got the events we needed in submitter_fn()
323 * through the io_uring_enter() above. For SQ thread poll, we in submitter_fn()
560 pthread_create(&s->thread, NULL, submitter_fn, s); in main()
588 pthread_join(s->thread, &ret); in main()
|
| /kernel/linux/linux-6.6/drivers/virt/acrn/ |
| H A D | ioreq.c | 167 * ioreq_task() is the execution entity of handler thread of an I/O client.
168 * The handler callback of the I/O client is called within the handler thread.
183 * clear_bit() - in handler thread (include ACRN userspace) in ioreq_task()
262 * In the default client, a user space thread waits on the in acrn_ioreq_client_wait()
408 * thread and call the handler to handle I/O requests.
442 client->thread = kthread_run(ioreq_task, client, "VM%u-%s", in acrn_ioreq_client_create()
444 if (IS_ERR(client->thread)) { in acrn_ioreq_client_create()
477 kthread_stop(client->thread); in acrn_ioreq_client_destroy()
|
| /kernel/linux/linux-6.6/tools/perf/bench/ |
| H A D | epoll-ctl.c | 59 /* amount of fds to monitor, per thread */
69 pthread_t thread; member
77 OPT_UINTEGER('f', "nfds", &nfds, "Specify amount of file descriptors to monitor for each thread"),
276 ret = pthread_create(&w->thread, attrp, workerfn, in do_threads()
389 printinfo("main thread: toggling done\n"); in bench_epoll_ctl()
392 ret = pthread_join(worker[i].thread, NULL); in bench_epoll_ctl()
411 printf("[thread %2d] fdmap: %p [ add: %04ld; mod: %04ld; del: %04lds ops ]\n", in bench_epoll_ctl()
415 printf("[thread %2d] fdmap: %p ... %p [ add: %04ld ops; mod: %04ld ops; del: %04ld ops ]\n", in bench_epoll_ctl()
|
| /kernel/linux/linux-6.6/tools/perf/util/ |
| H A D | maps.c | 9 #include "thread.h"
386 int maps__clone(struct thread *thread, struct maps *parent) in maps__clone() argument
388 struct maps *maps = thread__maps(thread); in maps__clone()
|
| /kernel/linux/linux-6.6/tools/testing/selftests/x86/ |
| H A D | amx.c | 692 pthread_t thread; member
726 * The last thread's last unlock will be for in check_tiledata()
727 * thread 0's mutex. However, thread 0 will in check_tiledata()
739 * Return this thread's finfo, which is in check_tiledata()
740 * a unique value for this thread. in check_tiledata()
764 if (pthread_create(&finfo[i].thread, NULL, check_tiledata, &finfo[i])) in create_threads()
803 * This thread wakes up thread 0 in test_context_switch()
807 * the last thread wil in test_context_switch()
[all...] |
| H A D | test_shadow_stack.c | 486 pthread_t thread; in test_userfaultfd() local
514 if (pthread_create(&thread, NULL, &uffd_thread, &uffd)) in test_userfaultfd()
520 if (pthread_join(thread, &res)) in test_userfaultfd()
|