| /ohos5.0/foundation/resourceschedule/ffrt/src/eu/ |
| H A D | cpu_worker.cpp | 41 void CPUWorker::Run(CPUEUTask* task, CoRoutineEnv* coRoutineEnv, CPUWorker* worker) in Run()
102 void* CPUWorker::WrapDispatch(void* worker) in WrapDispatch()
109 void CPUWorker::RunTask(ffrt_executor_task_t* curtask, CPUWorker* worker) in RunTask()
116 void CPUWorker::RunTask(ffrt_executor_task_t* curtask, CPUWorker* worker, ExecuteCtx* ctx, CoRoutin… in RunTask()
145 void CPUWorker::RunTaskLifo(ffrt_executor_task_t* task, CPUWorker* worker) in RunTaskLifo()
160 void* CPUWorker::GetTask(CPUWorker* worker) in GetTask()
198 PollerRet CPUWorker::TryPoll(CPUWorker* worker, int timeout) in TryPoll()
208 bool CPUWorker::LocalEmpty(CPUWorker* worker) in LocalEmpty()
213 void CPUWorker::Dispatch(CPUWorker* worker) in Dispatch()
241 CPUWorker* worker = reinterpret_cast<CPUWorker*>(p); in WorkerLooperDefault() local
|
| H A D | cpuworker_manager.cpp | 61 auto worker = CPUManagerStrategy::CreateCPUWorker(localQos, this); in IncWorker() local
114 CPUWorker* worker = reinterpret_cast<CPUWorker*>(thread); in PickUpTaskFromLocalQueue() local
233 auto worker = std::move(groupCtl[qos].threads[thread]); in WorkerRetired() local
|
| H A D | scpuworker_manager.cpp | 89 auto worker = std::move(groupCtl[qos].threads[thread]); in WorkerRetiredSimplified() local
|
| /ohos5.0/commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| H A D | test_worker.cpp | 256 Worker* worker = nullptr; variable
278 Worker* worker = nullptr; variable
303 Worker* worker = nullptr; variable
331 Worker* worker = nullptr; variable
362 Worker* worker = nullptr; variable
391 Worker* worker = nullptr; variable
441 Worker* worker = nullptr; variable
466 Worker* worker = nullptr; variable
517 Worker* worker = nullptr; variable
552 Worker* worker = nullptr; variable
[all …]
|
| /ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | worker.cpp | 34 Worker::PriorityScope::PriorityScope(Worker* worker, Priority taskPriority) : worker_(worker) in PriorityScope()
64 Worker* worker = new Worker(env); in WorkerConstructor() local
71 auto worker = static_cast<Worker*>(req->data); in ReleaseWorkerHandles() local
137 Worker* worker = reinterpret_cast<Worker*>(req->data); in HandleDebuggerTask() local
209 auto worker = reinterpret_cast<Worker*>(const_cast<void*>(data)); in ExecuteInThread() local
338 auto worker = reinterpret_cast<Worker*>(req->data); in TriggerGCCheck() local
372 auto worker = static_cast<Worker*>(req->data); in PerformTask() local
472 Worker* worker = reinterpret_cast<Worker*>(task->worker_); in NotifyHandleTaskResult() local
508 auto worker = static_cast<Worker*>(task->worker_); in TaskResultCallback() local
|
| H A D | task_manager.cpp | 98 for (auto& worker : workers_) { in ~TaskManager() local
145 for (auto& worker : workers_) { in GetThreadInfos() local
246 auto worker = *iter; in CheckForBlockedWorkers() local
329 for (auto& worker : idleWorkers_) { in GetIdleWorkers() local
361 for (auto& worker : idleWorkers_) { in GetIdleWorkersList() local
409 auto worker = freeList_[i]; in TriggerShrink() local
443 auto worker = *iter; in TriggerShrink() local
812 for (auto& worker : workers_) { in IsChooseIdle() local
844 for (auto& worker : idleWorkers_) { in NotifyExecuteTask() local
1028 auto worker = info->worker; in GetMessageQueue() local
[all …]
|
| H A D | worker.h | 136 explicit RunningScope(Worker* worker) : worker_(worker) in RunningScope()
|
| H A D | task.h | 231 Worker* worker; member
|
| /ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | ut_worker_manager.cpp | 107 WorkerThread* worker = CPUManagerStrategy::CreateCPUWorker(QoS(2), manager); variable
127 WorkerThread* worker = new CPUWorker(QoS(2), std::move(ops)); variable
|
| /ohos5.0/base/startup/init/services/param/linux/ |
| H A D | param_service.c | 87 static int SendResponseMsg(ParamTaskPtr worker, const ParamMessage *msg, int result) in SendResponseMsg()
161 static int HandleParamSet(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamSet()
234 static int HandleParamWaitAdd(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWaitAdd()
287 static int HandleParamWatcherAdd(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWatcherAdd()
307 static int HandleParamWatcherDel(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWatcherDel()
315 static int HandleParamSave(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamSave()
333 PARAM_STATIC int ProcessMessage(const ParamTaskPtr worker, const ParamMessage *msg) in ProcessMessage()
|
| /ohos5.0/commonlibrary/ets_utils/js_concurrent_module/worker/ |
| H A D | worker.cpp | 110 Worker* worker = nullptr; in InitPort() local
235 Worker* worker = nullptr; in Constructor() local
464 Worker* worker = nullptr; in CommonPostMessage() local
500 Worker* worker = nullptr; in Terminate() local
551 Worker* worker = nullptr; in RegisterGlobalCallObject() local
574 Worker* worker = nullptr; in UnregisterGlobalCallObject() local
634 Worker* worker = nullptr; in AddListener() local
678 Worker* worker = nullptr; in RemoveListener() local
737 Worker* worker = nullptr; in DispatchEvent() local
776 Worker* worker = nullptr; in RemoveAllListener() local
[all …]
|
| /ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 197 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in CheckForBlockedWorkers() local
235 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in TriggerShrink() local
311 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in TryExpand() local
367 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in NotifyWorkerIdle() local
390 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in EnqueueTaskId() local
422 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in RestoreWorker() local
479 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in NotifyDependencyTaskInfo() local
741 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in ReleaseWorkerHandles() local
761 Worker* worker = reinterpret_cast<Worker*>(WorkerConstructor(env)); in DebuggerOnPostTask() local
904 Worker* worker = Worker::WorkerConstructor(env); in WorkerConstructor() local
[all …]
|
| /ohos5.0/foundation/multimodalinput/input/intention/common/channel/test/ |
| H A D | channel_test.cpp | 55 std::thread worker([sender = sender, count]() mutable { in __anon6484951c0202() variable
84 std::thread worker([sender = sender, count]() mutable { in __anon6484951c0302() variable
|
| /ohos5.0/base/msdp/device_status/test/unittest/intention/common/src/ |
| H A D | channel_test.cpp | 55 std::thread worker([sender = sender, count]() mutable { in __anonb4f9918d0202() variable
84 std::thread worker([sender = sender, count]() mutable { in __anonb4f9918d0302() variable
|
| /ohos5.0/base/print/print_fwk/frameworks/kits/extension/src/ |
| H A D | js_print_callback.cpp | 89 uv_work_t *worker = new (std::nothrow) uv_work_t; in BuildJsWorker() local
119 uv_work_t *worker = BuildJsWorker(jsObj, name, argv, argc, isSync); in Exec() local
143 int JsPrintCallback::UvQueueWork(uv_loop_s* loop, uv_work_t* worker) in UvQueueWork()
|
| /ohos5.0/foundation/ai/ai_engine/services/server/plugin/asr/keyword_spotting/source/ |
| H A D | kws_plugin.cpp | 43 static int32_t InitWorkplace(KWSWorkplace &worker, SlideWindowProcessorConfig &slideCfg, in InitWorkplace()
119 KWSWorkplace worker = { in Prepare() local
199 …GetNormedFeatures(const Array<uint16_t> &input, Array<int32_t> &output, const KWSWorkplace &worker) in GetNormedFeatures()
331 int32_t KWSPlugin::InitComponents(KWSWorkplace &worker) in InitComponents()
|
| /ohos5.0/foundation/ai/ai_engine/test/common/threadpool/ |
| H A D | thread_pool_test.cpp | 119 CWorker worker; variable
143 CWorker worker; variable
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/bridge/declarative_frontend/jsview/ |
| H A D | js_isolated_component.cpp | 57 Worker* worker = nullptr; in ParseWorker() local
92 Worker* worker = ParseWorker(obj->GetProperty("worker")); in Create() local
|
| H A D | js_dynamic_component.cpp | 86 Worker* worker = nullptr; in Create() local
|
| /ohos5.0/base/security/device_security_level/baselib/utils/src/ |
| H A D | utils_work_queue.c | 52 Worker *worker = NULL; in WorkQueueThread() local
225 Worker *worker = MALLOC(sizeof(Worker)); in QueueWork() local
|
| /ohos5.0/commonlibrary/ets_utils/js_util_module/util/ |
| H A D | js_base64.h | 43 napi_async_work worker = nullptr; member
55 napi_async_work worker = nullptr; member
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/util/ |
| H A D | worker_monitor.cpp | 175 WorkerThread* worker = thread.first; in CheckWorkerStatus() local
193 …id WorkerMonitor::RecordTimeoutFunctionInfo(const CoWorkerInfo& coWorkerInfo, WorkerThread* worker, in RecordTimeoutFunctionInfo()
|
| /ohos5.0/base/update/updateservice/frameworks/js/napi/session/src/ |
| H A D | napi_session.cpp | 42 napi_value NapiSession::StartWork(napi_env env, const napi_value *args, DoWorkFunction worker, void… in StartWork()
|
| /ohos5.0/base/update/updater/services/script/threadpool/ |
| H A D | threadpool.cpp | 94 for (auto& worker : workers_) { in ~ThreadPool() local
|
| /ohos5.0/base/startup/init/interfaces/kits/jskits/src/ |
| H A D | native_parameters_watch.cpp | 461 ParamWatcherWork *worker = new ParamWatcherWork(); in WatchCallbackWork() local
471 ParamWatcherWork *worker = reinterpret_cast<ParamWatcherWork *>(data); in WatchCallbackWork() local
479 ParamWatcherWork *worker = reinterpret_cast<ParamWatcherWork *>(data); in WatchCallbackWork() local
|