| /base/security/device_security_level/baselib/utils/src/ |
| D | utils_work_queue.c | 51 Worker *worker = NULL; in WorkQueueThread() local
65 worker = LIST_ENTRY(queue->head.next, Worker, linkNode); in WorkQueueThread()
66 RemoveListNode(&worker->linkNode); in WorkQueueThread()
70 worker->process(worker->dataBuff, worker->dataLen); in WorkQueueThread()
71 FREE(worker); in WorkQueueThread()
77 worker = LIST_ENTRY(queue->head.next, Worker, linkNode); in WorkQueueThread()
78 RemoveListNode(&worker->linkNode); in WorkQueueThread()
80 FREE(worker); in WorkQueueThread()
161 Worker *worker = MALLOC(sizeof(Worker)); in QueueWork() local
162 if (worker == NULL) { in QueueWork()
[all …]
|
| /base/powermgr/power_manager/services/native/src/ |
| D | running_lock_inner.cpp | 61 for (auto& worker : list) { in DumpInfo() local
63 pid: %{public}d, abilityId: %{public}d", worker.use_count(), worker->GetName().c_str(), in DumpInfo()
64 worker->GetUid(), worker->GetPid(), worker->GetAbilityId()); in DumpInfo()
|
| /base/startup/init/services/param/linux/ |
| D | param_service.c | 89 static int SendResponseMsg(ParamTaskPtr worker, const ParamMessage *msg, int result) in SendResponseMsg() argument
97 ParamTaskSendMsg(worker, (ParamMessage *)response); in SendResponseMsg()
159 static int HandleParamSet(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamSet() argument
167 if (getsockopt(LE_GetSocketFd(worker), SOL_SOCKET, SO_PEERCRED, &cr, &crSize) < 0) { in HandleParamSet()
169 return SendResponseMsg(worker, msg, -1); in HandleParamSet()
171 srcLabel.sockFd = LE_GetSocketFd(worker); in HandleParamSet()
177 return SendResponseMsg(worker, msg, ret); in HandleParamSet()
230 static int HandleParamWaitAdd(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWaitAdd() argument
251 extData.stream = worker; in HandleParamWaitAdd()
284 static int HandleParamWatcherAdd(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWatcherAdd() argument
[all …]
|
| D | param_message.h | 104 int ProcessMessage(const ParamTaskPtr worker, const ParamMessage *msg);
|
| /base/powermgr/power_manager/services/native/test/unittest/src/ |
| D | running_lock_test.cpp | 92 for (auto& worker : list) { variable
94 "uid = %d, pid = %d, abilityid = %d", worker.use_count(), worker->GetName().c_str(),
95 worker->GetUid(), worker->GetPid(), worker->GetAbilityId());
104 for (auto& worker : list2) { variable
106 "uid = %d, pid = %d, abilityid = %d", worker.use_count(), worker->GetName().c_str(),
107 worker->GetUid(), worker->GetPid(), worker->GetAbilityId());
114 for (auto& worker : list2) { variable
116 "uid = %d, pid = %d, abilityid = %d", worker.use_count(), worker->GetName().c_str(),
117 worker->GetUid(), worker->GetPid(), worker->GetAbilityId());
185 std::shared_ptr<WorkTrigger> worker = std::make_shared<WorkTrigger>(1, "worker"); variable
[all …]
|
| /base/startup/init/interfaces/kits/jskits/src/ |
| D | native_parameters_watch.cpp | 461 ParamWatcherWork *worker = new ParamWatcherWork(); in WatchCallbackWork() local
462 PARAM_JS_CHECK(worker != nullptr, return, "Failed to create worker "); in WatchCallbackWork()
463 worker->watcher = watcher; in WatchCallbackWork()
464 worker->work = nullptr; in WatchCallbackWork()
465 worker->startWatch = watcher->startWatch; in WatchCallbackWork()
471 ParamWatcherWork *worker = reinterpret_cast<ParamWatcherWork *>(data); in WatchCallbackWork() local
472 … PARAM_JS_CHECK(worker != nullptr && worker->watcher != nullptr, return, "Invalid worker "); in WatchCallbackWork()
473 int status = WatchParameter(worker->watcher->keyPrefix, in WatchCallbackWork()
474 worker->startWatch ? ProcessParamChange : nullptr, worker->watcher); in WatchCallbackWork()
476 worker->startWatch ? "on" : "off", status, worker->watcher->keyPrefix); in WatchCallbackWork()
[all …]
|
| /base/startup/syspara_lite/interfaces/kits/js/src/ |
| D | native_parameters_watch.cpp | 436 ParamWatcherWork *worker = new ParamWatcherWork(); in WatchCallbackWork() local
437 PARAM_JS_CHECK(worker != nullptr, return, "Failed to create worker "); in WatchCallbackWork()
438 worker->watcher = watcher; in WatchCallbackWork()
439 worker->work = nullptr; in WatchCallbackWork()
440 worker->startWatch = watcher->startWatch; in WatchCallbackWork()
446 ParamWatcherWork *worker = (ParamWatcherWork *)data; in WatchCallbackWork() local
447 … PARAM_JS_CHECK(worker != nullptr && worker->watcher != nullptr, return, "Invalid worker "); in WatchCallbackWork()
448 int status = WatchParameter(worker->watcher->keyPrefix, in WatchCallbackWork()
449 worker->startWatch ? ProcessParamChange : nullptr, worker->watcher); in WatchCallbackWork()
451 worker->startWatch ? "on" : "off", status, worker->watcher->keyPrefix); in WatchCallbackWork()
[all …]
|
| /base/update/updateservice/frameworks/js/napi/client/ |
| D | iupdate_session.h | 32 …virtual napi_value StartWork(napi_env env, const napi_value *args, DoWorkFunction worker, void *co…
|
| D | update_session.h | 36 …napi_value StartWork(napi_env env, const napi_value *args, DoWorkFunction worker, void *context) o…
|
| D | update_session.cpp | 44 napi_value UpdateSession::StartWork(napi_env env, const napi_value *args, DoWorkFunction worker, vo… in StartWork() argument
47 doWorker_ = worker; in StartWork()
|
| /base/update/updater/services/script/threadpool/ |
| D | threadpool.cpp | 81 for (auto& worker : workers_) { in ~ThreadPool() local
82 worker.join(); in ~ThreadPool()
|