| /ohos5.0/drivers/hdf_core/framework/utils/src/ |
| H A D | hdf_thread_ex.c | 13 void HdfThreadStart(struct HdfThread *thread) in HdfThreadStart()
27 void HdfThreadStop(struct HdfThread *thread) in HdfThreadStop()
36 bool HdfThreadIsRunning(struct HdfThread *thread) in HdfThreadIsRunning()
46 struct HdfThread *thread = (struct HdfThread *)argv; in HdfThreadMain() local
57 void HdfThreadConstruct(struct HdfThread *thread) in HdfThreadConstruct()
69 void HdfThreadDestruct(struct HdfThread *thread) in HdfThreadDestruct()
78 struct HdfThread *thread = (struct HdfThread *)OsalMemCalloc(sizeof(struct HdfThread)); in HdfThreadNewInstance() local
85 void HdfThreadFreeInstance(struct HdfThread *thread) in HdfThreadFreeInstance()
|
| /ohos5.0/base/security/device_auth/deps_adapter/os_adapter/impl/src/linux/ |
| H A D | hc_thread.c | 28 HcThread* thread = (HcThread*)args; in StaticThreadFunc() local
53 int Start(struct HcThreadT *thread) in Start()
85 void Join(struct HcThreadT *thread) in Join()
97 void BizWait(struct HcThreadT *thread) in BizWait()
105 void BizNotify(struct HcThreadT *thread) in BizNotify()
113 int32_t InitThread(HcThread *thread, ThreadFunc func, size_t stackSize, const char *threadName) in InitThread()
151 void DestroyThread(HcThread *thread) in DestroyThread()
|
| /ohos5.0/base/security/device_auth/deps_adapter/os_adapter/impl/src/liteos/ |
| H A D | hc_thread.c | 24 HcThread *thread = (HcThread*)args; in StaticThreadFunc() local
46 int Start(struct HcThreadT *thread) in Start()
78 void Join(struct HcThreadT *thread) in Join()
96 void BizWait(struct HcThreadT *thread) in BizWait()
104 void BizNotify(struct HcThreadT *thread) in BizNotify()
112 int32_t InitThread(HcThread *thread, ThreadFunc func, size_t stackSize, const char *threadName) in InitThread()
151 void DestroyThread(HcThread *thread) in DestroyThread()
|
| /ohos5.0/base/security/device_auth/deps_adapter/os_adapter/impl/src/ |
| H A D | hc_task_thread.c | 40 static void PushTask(struct HcTaskThreadT* thread, HcTaskBase* task) in PushTask()
54 static void Clear(struct HcTaskThreadT* thread) in Clear()
69 static void StopAndClear(struct HcTaskThreadT* thread) in StopAndClear()
80 static int32_t StartTaskThread(struct HcTaskThreadT* thread) in StartTaskThread()
96 HcTaskThread* thread = (HcTaskThread*)args; in TaskThreadLoop() local
121 int32_t InitHcTaskThread(HcTaskThread* thread, size_t stackSize, const char* threadName) in InitHcTaskThread()
144 void DestroyHcTaskThread(HcTaskThread* thread) in DestroyHcTaskThread()
|
| /ohos5.0/foundation/ability/ability_runtime/test/unittest/appkit/child_main_thread_test/ |
| H A D | child_main_thread_test.cpp | 74 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
91 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
109 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
129 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
163 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
198 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
217 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
|
| /ohos5.0/foundation/communication/dsoftbus/tests/adapter/unittest/ |
| H A D | softbus_thread_test.cpp | 468 SoftBusThread thread = 0; variable
483 SoftBusThread thread = 0; variable
502 SoftBusThread thread = 0; variable
522 SoftBusThread thread = 0; variable
541 SoftBusThread thread = 0; variable
560 SoftBusThread thread = 0; variable
579 SoftBusThread thread = 0; variable
598 SoftBusThread thread = 0; variable
618 SoftBusThread thread = 0; variable
635 SoftBusThread thread = 0; variable
[all …]
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/ |
| H A D | thread_linux.c | 44 Thread *thread; member
69 Thread *thread = startPromise->thread; in ThreadStartFunc() local
99 int32_t ThreadIsSelf(const Thread *thread) in ThreadIsSelf()
109 static void ThreadStop(Thread *thread) in ThreadStop()
125 Thread *thread = (Thread *)calloc(1, (sizeof(Thread))); in ThreadCreate() local
177 void ThreadDelete(Thread *thread) in ThreadDelete()
191 void ThreadPostTask(Thread *thread, TaskFunc func, void *context) in ThreadPostTask()
205 Reactor *ThreadGetReactor(const Thread *thread) in ThreadGetReactor()
|
| /ohos5.0/foundation/ai/ai_engine/services/common/platform/threadpool/source/ |
| H A D | thread_pool.cpp | 69 std::shared_ptr<Thread> thread; in Pop() local
87 void ThreadPool::Push(std::shared_ptr<Thread> &thread) in Push()
111 for (auto &thread : busyThreads_) { in StopThreads() local
125 for (auto &thread : busyThreads_) { in StopThreads() local
142 for (auto &thread : busyThreads_) { in StopThreads() local
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/liteos/osal/src/ |
| H A D | osal_thread.c | 59 int32_t OsalThreadCreate(struct OsalThread *thread, OsalThreadEntry threadEntry, void *entryPara) in OsalThreadCreate()
84 int32_t OsalThreadBind(struct OsalThread *thread, unsigned int cpuID) in OsalThreadBind()
97 int32_t OsalThreadStart(struct OsalThread *thread, const struct OsalThreadParam *param) in OsalThreadStart()
149 static bool OsalCheckPara(struct OsalThread *thread) in OsalCheckPara()
171 int32_t OsalThreadSuspend(struct OsalThread *thread) in OsalThreadSuspend()
191 int32_t OsalThreadDestroy(struct OsalThread *thread) in OsalThreadDestroy()
207 int32_t OsalThreadResume(struct OsalThread *thread) in OsalThreadResume()
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/liteos_m/osal/src/ |
| H A D | osal_thread.c | 59 int32_t OsalThreadCreate(struct OsalThread *thread, OsalThreadEntry threadEntry, void *entryPara) in OsalThreadCreate()
84 int32_t OsalThreadBind(struct OsalThread *thread, unsigned int cpuID) in OsalThreadBind()
97 int32_t OsalThreadStart(struct OsalThread *thread, const struct OsalThreadParam *param) in OsalThreadStart()
142 static bool OsalCheckPara(struct OsalThread *thread) in OsalCheckPara()
164 int32_t OsalThreadSuspend(struct OsalThread *thread) in OsalThreadSuspend()
184 int32_t OsalThreadDestroy(struct OsalThread *thread) in OsalThreadDestroy()
200 int32_t OsalThreadResume(struct OsalThread *thread) in OsalThreadResume()
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/uniproton/osal/src/ |
| H A D | osal_thread.c | 59 int32_t OsalThreadCreate(struct OsalThread *thread, OsalThreadEntry threadEntry, void *entryPara) in OsalThreadCreate()
84 int32_t OsalThreadBind(struct OsalThread *thread, unsigned int cpuID) in OsalThreadBind()
97 int32_t OsalThreadStart(struct OsalThread *thread, const struct OsalThreadParam *param) in OsalThreadStart()
150 static bool OsalCheckPara(struct OsalThread *thread) in OsalCheckPara()
172 int32_t OsalThreadSuspend(struct OsalThread *thread) in OsalThreadSuspend()
192 int32_t OsalThreadDestroy(struct OsalThread *thread) in OsalThreadDestroy()
208 int32_t OsalThreadResume(struct OsalThread *thread) in OsalThreadResume()
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/linux/osal/src/ |
| H A D | osal_thread.c | 63 int32_t OsalThreadCreate(struct OsalThread *thread, OsalThreadEntry thread_entry, void *entry_para) in OsalThreadCreate()
88 int32_t OsalThreadBind(struct OsalThread *thread, unsigned int cpu_id) in OsalThreadBind()
102 int32_t OsalThreadStart(struct OsalThread *thread, const struct OsalThreadParam *param) in OsalThreadStart()
152 int32_t OsalThreadSuspend(struct OsalThread *thread) in OsalThreadSuspend()
159 int32_t OsalThreadDestroy(struct OsalThread *thread) in OsalThreadDestroy()
173 int32_t OsalThreadResume(struct OsalThread *thread) in OsalThreadResume()
|
| /ohos5.0/foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/ |
| H A D | thread.h | 23 thread() noexcept in thread() function
29 explicit thread(const char* name, qos qos_, Fn&& fn, Args&&... args) in thread() function
42 explicit thread(qos qos_, Fn&& fn, Args&&... args) in thread() function
71 thread(thread&& th) noexcept in thread() function
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/eu/ |
| H A D | worker_manager.cpp | 24 for (auto& thread : tgwrap.threads) { in JoinRtg() local
50 for (auto& thread : tgwrap.threads) { in JoinTG() local
74 for (auto& thread : groupCtl[qos].threads) { in LeaveTG() local
|
| H A D | cpuworker_manager.cpp | 95 CPUEUTask* CPUWorkerManager::PickUpTaskFromGlobalQueue(WorkerThread* thread) in PickUpTaskFromGlobalQueue()
108 CPUEUTask* CPUWorkerManager::PickUpTaskFromLocalQueue(WorkerThread* thread) in PickUpTaskFromLocalQueue()
119 CPUEUTask* CPUWorkerManager::PickUpTaskBatch(WorkerThread* thread) in PickUpTaskBatch()
161 unsigned int CPUWorkerManager::StealTaskBatch(WorkerThread* thread) in StealTaskBatch()
190 PollerRet CPUWorkerManager::TryPoll(const WorkerThread* thread, int timeout) in TryPoll()
219 void CPUWorkerManager::NotifyTaskPicked(const WorkerThread* thread) in NotifyTaskPicked()
224 void CPUWorkerManager::WorkerRetired(WorkerThread* thread) in WorkerRetired()
304 bool CPUWorkerManager::IsExceedRunningThreshold(const WorkerThread* thread) in IsExceedRunningThreshold()
|
| H A D | scpuworker_manager.cpp | 79 void SCPUWorkerManager::WorkerRetiredSimplified(WorkerThread* thread) in WorkerRetiredSimplified()
152 WorkerAction SCPUWorkerManager::WorkerIdleAction(const WorkerThread* thread) in WorkerIdleAction()
198 void SCPUWorkerManager::WorkerPrepare(WorkerThread* thread) in WorkerPrepare()
|
| /ohos5.0/drivers/hdf_core/framework/core/adapter/syscall/src/ |
| H A D | hdf_syscall_adapter.c | 137 static int32_t HdfDevEventReadAndDispatch(struct HdfDevListenerThread *thread, int32_t fd) in HdfDevEventReadAndDispatch()
190 static int32_t AssignPfds(struct HdfDevListenerThread *thread, struct pollfd **pfds, uint16_t *pfdS… in AssignPfds()
242 struct HdfDevListenerThread *thread = (struct HdfDevListenerThread *)para; in HdfDevEventListenTask() local
332 static int32_t HdfDevListenerThreadDoInit(struct HdfDevListenerThread *thread) in HdfDevListenerThreadDoInit()
355 static int32_t HdfDevListenerThreadInit(struct HdfDevListenerThread *thread) in HdfDevListenerThreadInit()
427 static int32_t HdfListenThreadInitPollFds(struct HdfDevListenerThread *thread) in HdfListenThreadInitPollFds()
445 static int32_t HdfDevListenerThreadStart(struct HdfDevListenerThread *thread) in HdfDevListenerThreadStart()
492 struct HdfDevListenerThread *thread = OsalMemCalloc(sizeof(struct HdfDevListenerThread)); in HdfDevListenerThreadObtain() local
618 static void HdfDevListenerThreadFree(struct HdfDevListenerThread *thread) in HdfDevListenerThreadFree()
626 static void HdfDevListenerThreadDestroy(struct HdfDevListenerThread *thread) in HdfDevListenerThreadDestroy()
[all …]
|
| /ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | thread.cpp | 40 Thread* thread = reinterpret_cast<Thread*>(this); in Start() local
53 Thread* thread = reinterpret_cast<Thread*>(arg); in Start() local
|
| /ohos5.0/base/update/updater/services/applypatch/ |
| H A D | update_progress.cpp | 43 void SetProgressExitFlag(pthread_t &thread) in SetProgressExitFlag()
75 int CreateProgressThread(Uscript::UScriptEnv *env, pthread_t &thread) in CreateProgressThread()
|
| /ohos5.0/base/hiviewdfx/faultloggerd/test/unittest/process_dump/ |
| H A D | process_dump_test.cpp | 164 auto thread = DfxThread::Create(pid, tid, tid); variable
178 std::shared_ptr<DfxThread> thread = std::make_shared<DfxThread>(pid, tid, tid); variable
196 std::shared_ptr<DfxThread> thread = DfxThread::Create(pid, tid, tid); variable
228 std::shared_ptr<DfxThread> thread = DfxThread::Create(pid, tid, tid); variable
287 std::shared_ptr<DfxThread> thread = DfxThread::Create(pid, tid, tid); variable
|
| /ohos5.0/base/hiviewdfx/faultloggerd/tools/process_dump/ |
| H A D | printer.cpp | 169 void Printer::PrintThreadHeaderByConfig(std::shared_ptr<DfxThread> thread, bool isKeyThread) in PrintThreadHeaderByConfig()
206 void Printer::PrintThreadBacktraceByConfig(std::shared_ptr<DfxThread> thread, bool isKeyThread) in PrintThreadBacktraceByConfig()
241 void Printer::PrintThreadRegsByConfig(std::shared_ptr<DfxThread> thread) in PrintThreadRegsByConfig()
265 …intThreadFaultStackByConfig(std::shared_ptr<DfxProcess> process, std::shared_ptr<DfxThread> thread, in PrintThreadFaultStackByConfig()
|
| H A D | dfx_unwind_remote.cpp | 54 void GetThreadKernelStack(std::shared_ptr<DfxThread> thread) in GetThreadKernelStack()
185 for (auto &thread : process->GetOtherThreads()) { in UnwindOtherThread() local
246 for (auto &thread : process->GetOtherThreads()) { in InitOtherThreadRegs() local
|
| /ohos5.0/drivers/hdf_core/adapter/uhdf2/host/src/ |
| H A D | hdf_device_thread.c | 94 struct DeviceThread *thread = in DeviceThreadNewInstance() local
102 void DeviceThreadFreeInstance(struct DeviceThread *thread) in DeviceThreadFreeInstance()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | block_on.rs | 24 let thread = unsafe { Arc::from_raw(ptr.cast::<Parker>()) }; in clone() localVariable
34 let thread = unsafe { Arc::from_raw(ptr.cast::<Parker>()) }; in wake() localVariable
39 let thread = unsafe { Arc::from_raw(ptr.cast::<Parker>()) }; in wake_by_ref() localVariable
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/ |
| H A D | rs_profiler_beta_recorder.cpp | 65 std::thread thread([]() { in LaunchBetaRecordNotificationThread() local
79 std::thread thread([]() { in LaunchBetaRecordMetricsUpdateThread() local
101 std::thread thread([fileDataCopy{std::move(fileData)}, path]() { in WriteBetaRecordFileThread() local
116 std::thread thread([]() { in RenameAndSendFilenameThread() local
|