Home
last modified time | relevance | path

Searched refs:task (Results 1 - 25 of 344) sorted by relevance

12345678910>>...14

/base/startup/init/services/loopevent/signal/
H A Dle_signal.c28 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleSignalEvent_() argument
34 ssize_t s = read(GetSocketFd(task), &fdsi, sizeof(fdsi)); in HandleSignalEvent_()
36 SignalTask *sigTask = (SignalTask *)task; in HandleSignalEvent_()
45 BaseTask *task = (BaseTask *)signalHandle; in HandleSignalTaskClose_() local
46 DelTask((EventLoop *)loopHandle, task); in HandleSignalTaskClose_()
47 CloseTask(loopHandle, task); in HandleSignalTaskClose_()
48 close(task->taskId.fd); in HandleSignalTaskClose_()
65 static void DumpSignalTaskInfo_(const TaskHandle task) in DumpSignalTaskInfo_() argument
67 INIT_CHECK(task != NULL, return); in DumpSignalTaskInfo_()
68 BaseTask *baseTask = (BaseTask *)task; in DumpSignalTaskInfo_()
86 SignalTask *task = (SignalTask *)CreateTask(loopHandle, sfd, &info, sizeof(SignalTask)); LE_CreateSignalTask() local
102 SignalTask *task = (SignalTask *)signalHandle; LE_AddSignal() local
124 SignalTask *task = (SignalTask *)signalHandle; LE_RemoveSignal() local
[all...]
/base/security/device_auth/test/fuzztest/authenticators/account_related/auth/isoauthtask_fuzzer/
H A Disoauthtask_fuzzer.cpp70 TaskBase *task = CreateIsoAuthServerTask(inJson, outJson, &info); in CreateServerTask() local
73 return task; in CreateServerTask()
95 TaskBase *task = CreateIsoAuthClientTask(inJson, outJson, &info); in CreateClientTask() local
98 return task; in CreateClientTask()
106 TaskBase *task = CreateIsoAuthTask(nullptr, nullptr, nullptr); in IsoAuthTaskTest01() local
110 task = CreateIsoAuthClientTask(inJson, outJson, &info); in IsoAuthTaskTest01()
113 task = CreateIsoAuthClientTask(inJson, outJson, &info); in IsoAuthTaskTest01()
116 task = CreateIsoAuthClientTask(inJson, outJson, &info); in IsoAuthTaskTest01()
119 task = CreateIsoAuthClientTask(inJson, outJson, &info); in IsoAuthTaskTest01()
122 task in IsoAuthTaskTest01()
201 TaskBase *task = CreateIsoAuthServerTask(nullptr, outJson, &info); IsoAuthTaskTest05() local
216 TaskBase *task = CreateServerTask(); IsoAuthTaskTest06() local
232 TaskBase *task = CreateServerTask(); IsoAuthTaskTest07() local
252 TaskBase *task = CreateServerTask(); IsoAuthTaskTest08() local
268 TaskBase *task = CreateServerTask(); IsoAuthTaskTest09() local
287 TaskBase *task = CreateServerTask(); IsoAuthTaskTest10() local
307 TaskBase *task = CreateServerTask(); IsoAuthTaskTest11() local
325 TaskBase *task = CreateServerTask(); IsoAuthTaskTest12() local
343 TaskBase *task = CreateServerTask(); IsoAuthTaskTest13() local
361 TaskBase *task = CreateServerTask(); IsoAuthTaskTest14() local
379 TaskBase *task = CreateServerTask(); IsoAuthTaskTest15() local
397 TaskBase *task = CreateServerTask(); IsoAuthTaskTest16() local
416 TaskBase *task = CreateServerTask(); IsoAuthTaskTest17() local
431 TaskBase *task = CreateIsoAuthClientTask(nullptr, outJson, &info); IsoAuthTaskTest18() local
447 TaskBase *task = CreateClientTask(); IsoAuthTaskTest19() local
466 TaskBase *task = CreateClientTask(); IsoAuthTaskTest20() local
483 TaskBase *task = CreateClientTask(); IsoAuthTaskTest21() local
500 TaskBase *task = CreateClientTask(); IsoAuthTaskTest22() local
517 TaskBase *task = CreateClientTask(); IsoAuthTaskTest23() local
529 TaskBase *task = CreateClientTask(); IsoAuthTaskTest24() local
547 TaskBase *task = CreateClientTask(); IsoAuthTaskTest25() local
569 TaskBase *task = CreateClientTask(); IsoAuthTaskTest26() local
589 TaskBase *task = CreateClientTask(); IsoAuthTaskTest04() local
610 TaskBase *task = CreateClientTask(); IsoAuthTaskTest27() local
632 TaskBase *task = CreateClientTask(); IsoAuthTaskTest28() local
654 TaskBase *task = CreateClientTask(); IsoAuthTaskTest29() local
678 TaskBase *task = CreateClientTask(); IsoAuthTaskTest30() local
701 TaskBase *task = CreateClientTask(); IsoAuthTaskTest31() local
725 TaskBase *task = CreateClientTask(); IsoAuthTaskTest32() local
743 TaskBase *task = CreateClientTask(); IsoAuthTaskTest33() local
761 TaskBase *task = CreateClientTask(); IsoAuthTaskTest34() local
779 TaskBase *task = CreateClientTask(); IsoAuthTaskTest35() local
798 TaskBase *task = CreateClientTask(); IsoAuthTaskTest36() local
816 TaskBase *task = CreateClientTask(); IsoAuthTaskTest37() local
835 TaskBase *task = CreateClientTask(); IsoAuthTaskTest38() local
[all...]
/base/hiviewdfx/hiview/framework/native/unified_collection/decorator/
H A Dmemory_decorator.cpp26 auto task = [this, &pid] { return memoryCollector_->CollectProcessMemory(pid); }; in CollectProcessMemory() local
27 return Invoke(task, statInfoWrapper_, MEM_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectProcessMemory()
32 auto task = [this] { return memoryCollector_->CollectSysMemory(); }; in CollectSysMemory() local
33 return Invoke(task, statInfoWrapper_, MEM_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectSysMemory()
38 auto task = [this] { return memoryCollector_->CollectRawMemInfo(); }; in CollectRawMemInfo() local
39 return Invoke(task, statInfoWrapper_, MEM_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectRawMemInfo()
44 auto task = [this] { return memoryCollector_->ExportMemView(); }; in ExportMemView() local
45 return Invoke(task, statInfoWrapper_, MEM_COLLECTOR_NAME + UC_SEPARATOR + __func__); in ExportMemView()
50 auto task = [this] { return memoryCollector_->CollectAllProcessMemory(); }; in CollectAllProcessMemory() local
51 return Invoke(task, statInfoWrapper in CollectAllProcessMemory()
55 auto task = [this] { return memoryCollector_->ExportAllProcessMemory(); }; ExportAllProcessMemory() local
61 auto task = [this] { return memoryCollector_->CollectRawSlabInfo(); }; CollectRawSlabInfo() local
67 auto task = [this] { return memoryCollector_->CollectRawPageTypeInfo(); }; CollectRawPageTypeInfo() local
73 auto task = [this] { return memoryCollector_->CollectRawDMA(); }; CollectRawDMA() local
79 auto task = [this] { return memoryCollector_->CollectAllAIProcess(); }; CollectAllAIProcess() local
85 auto task = [this] { return memoryCollector_->ExportAllAIProcess(); }; ExportAllAIProcess() local
91 auto task = [this, &pid] { return memoryCollector_->CollectRawSmaps(pid); }; CollectRawSmaps() local
97 auto task = [this, &pid] { return memoryCollector_->CollectHprof(pid); }; CollectHprof() local
103 auto task = [this, &pid] { return memoryCollector_->CollectProcessVss(pid); }; CollectProcessVss() local
109 auto task = [this] { return memoryCollector_->CollectMemoryLimit(); }; CollectMemoryLimit() local
115 auto task = [this] { return memoryCollector_->CollectDdrFreq(); }; CollectDdrFreq() local
[all...]
H A Dio_decorator.cpp26 auto task = [this, &pid] { return ioCollector_->CollectProcessIo(pid); }; in CollectProcessIo() local
27 return Invoke(task, statInfoWrapper_, IO_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectProcessIo()
32 auto task = [this] { return ioCollector_->CollectRawDiskStats(); }; in CollectRawDiskStats() local
33 return Invoke(task, statInfoWrapper_, IO_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectRawDiskStats()
39 auto task = [this, &filter, &isUpdate] { return ioCollector_->CollectDiskStats(filter, isUpdate); }; in CollectDiskStats() local
40 return Invoke(task, statInfoWrapper_, IO_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectDiskStats()
45 auto task = [this, &filter] { return ioCollector_->ExportDiskStats(filter); }; in ExportDiskStats() local
46 return Invoke(task, statInfoWrapper_, IO_COLLECTOR_NAME + UC_SEPARATOR + __func__); in ExportDiskStats()
51 auto task = [this] { return ioCollector_->CollectEMMCInfo(); }; in CollectEMMCInfo() local
52 return Invoke(task, statInfoWrapper in CollectEMMCInfo()
57 auto task = [this] { return ioCollector_->ExportEMMCInfo(); }; ExportEMMCInfo() local
63 auto task = [this, &isUpdate] { return ioCollector_->CollectAllProcIoStats(isUpdate); }; CollectAllProcIoStats() local
69 auto task = [this] { return ioCollector_->ExportAllProcIoStats(); }; ExportAllProcIoStats() local
75 auto task = [this] { return ioCollector_->CollectSysIoStats(); }; CollectSysIoStats() local
81 auto task = [this] { return ioCollector_->ExportSysIoStats(); }; ExportSysIoStats() local
[all...]
/base/hiviewdfx/hicollie/frameworks/native/test/unittest/common/
H A Dwatchdog_task_test.cpp57 WatchdogTask task("WatchdogTaskTest_001", taskFunc, 0, 0, true); in HWTEST_F()
58 task.DoCallback(); in HWTEST_F()
59 EXPECT_EQ(task.flag, 0); in HWTEST_F()
60 task.flag = 1; in HWTEST_F()
61 task.DoCallback(); in HWTEST_F()
62 task.flag = 2; in HWTEST_F()
63 task.DoCallback(); in HWTEST_F()
76 WatchdogTask task("WatchdogTaskTest_002", taskFunc, 0, 0, true); in HWTEST_F()
77 task.Run(now); in HWTEST_F()
78 EXPECT_EQ(task in HWTEST_F()
[all...]
/base/startup/appspawn/test/moduletest/threadpool/
H A Dthread_manager.c59 ListNode node; // 保存sub task到对应的task，方便管理
61 TaskNode *task; member
106 static int AddExecutor(ThreadManager *mgr, const TaskNode *task) in AddExecutor() argument
108 ListNode *node = task->executorList.next; in AddExecutor()
109 while (node != &task->executorList) { in AddExecutor()
111 APPSPAWN_LOGV("AddExecutor task: %{public}u executorCount: %{public}u executor: %{public}u", in AddExecutor()
112 task->taskId, mgr->executorCount, executor->task->taskId); in AddExecutor()
134 APPSPAWN_LOGV("RunExecutor task in RunExecutor()
148 TaskNode *task = ListEntry(node, TaskNode, node); TaskCompareTaskId() local
164 DeleteTask(TaskNode *task) DeleteTask() argument
179 TaskNode *task = NULL; PopTask() local
191 PushTask(ThreadManager *mgr, TaskNode *task, ListNode *queue) PushTask() argument
199 SafeRemoveTask(ThreadManager *mgr, TaskNode *task) SafeRemoveTask() argument
226 TaskNode *task = PopTask(mgr, &mgr->waitingTaskQueue); ExecuteTask() local
239 TaskNode *task = PopTask(mgr, &mgr->executingTaskQueue); CheckTaskComplete() local
261 TaskNode *task = ListEntry(node, TaskNode, node); TaskQueueDestroyProc() local
342 TaskNode *task = (TaskNode *)malloc(sizeof(TaskNode)); ThreadMgrAddTask() local
369 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); ThreadMgrAddExecutor() local
388 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); ThreadMgrCancelTask() local
413 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); TaskSyncExecute() local
442 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); TaskExecute() local
[all...]
/base/startup/init/services/loopevent/task/
H A Dle_task.c22 int CheckTaskFlags(const BaseTask *task, uint32_t flags) in CheckTaskFlags() argument
24 if (task == NULL) { in CheckTaskFlags()
27 return ((task->flags & flags) == flags); in CheckTaskFlags()
30 int GetSocketFd(const TaskHandle task) in GetSocketFd() argument
32 BaseTask *stream = (BaseTask *)task; in GetSocketFd()
41 BaseTask *task = (BaseTask *)calloc(1, size + info->userDataSize); in CreateTask() local
42 LE_CHECK(task != NULL, return NULL, "Failed to alloc for task"); in CreateTask()
43 HASHMAPInitNode(&task->hashNode); in CreateTask()
45 task in CreateTask()
56 CloseTask(const LoopHandle loopHandle, BaseTask *task) CloseTask() argument
86 IsBufferEmpty(StreamTask *task) IsBufferEmpty() argument
94 GetFirstBuffer(StreamTask *task) GetFirstBuffer() argument
106 AddBuffer(StreamTask *task, LE_Buffer *buffer) AddBuffer() argument
113 GetNextBuffer(StreamTask *task, const LE_Buffer *next) GetNextBuffer() argument
130 FreeBuffer(const LoopHandle loop, StreamTask *task, LE_Buffer *buffer) FreeBuffer() argument
198 BaseTask *task = (BaseTask *)taskHandle; LE_CloseTask() local
[all...]
/base/startup/init/services/loopevent/idle/
H A Dle_idle.c40 IdleTask *task = (IdleTask *)calloc(1, sizeof(IdleTask)); in LE_AddIdle() local
41 LE_CHECK(task != NULL, in LE_AddIdle()
42 return LE_NO_MEMORY, "Failed to create task"); in LE_AddIdle()
44 task->loop = (EventLoop *)loopHandle; in LE_AddIdle()
45 task->processIdle = processIdle; in LE_AddIdle()
46 task->context = context; in LE_AddIdle()
47 task->repeat = repeat; in LE_AddIdle()
49 *idle = (IdleHandle)task; in LE_AddIdle()
53 OH_ListAddTail(&(task->loop->idleList), &(task in LE_AddIdle()
66 IdleTask *task = (IdleTask *)idle; LE_DelIdle() local
86 IdleTask *task = (IdleTask *)node; IdleListTraversalProc() local
[all...]
/base/security/device_auth/test/unittest/deviceauth/source/
H A Diso_auth_task_test.cpp72 TaskBase *task = CreateIsoAuthTask(nullptr, nullptr, nullptr); in HWTEST_F() local
73 EXPECT_EQ(task, nullptr); in HWTEST_F()
82 task = CreateIsoAuthClientTask(inJson, outJson, &info); in HWTEST_F()
83 EXPECT_EQ(task, nullptr); in HWTEST_F()
87 task = CreateIsoAuthClientTask(inJson, outJson, &info); in HWTEST_F()
88 EXPECT_EQ(task, nullptr); in HWTEST_F()
92 task = CreateIsoAuthClientTask(inJson, outJson, &info); in HWTEST_F()
93 EXPECT_EQ(task, nullptr); in HWTEST_F()
97 task = CreateIsoAuthClientTask(inJson, outJson, &info); in HWTEST_F()
98 EXPECT_EQ(task, nullpt in HWTEST_F()
225 TaskBase *task = CreateIsoAuthServerTask(inJson, outJson, &info); CreateServerTask() local
239 TaskBase *task = CreateIsoAuthServerTask(nullptr, outJson, &info); HWTEST_F() local
263 TaskBase *task = CreateServerTask(); HWTEST_F() local
288 TaskBase *task = CreateServerTask(); HWTEST_F() local
315 TaskBase *task = CreateServerTask(); HWTEST_F() local
339 TaskBase *task = CreateServerTask(); HWTEST_F() local
364 TaskBase *task = CreateServerTask(); HWTEST_F() local
390 TaskBase *task = CreateServerTask(); HWTEST_F() local
414 TaskBase *task = CreateServerTask(); HWTEST_F() local
438 TaskBase *task = CreateServerTask(); HWTEST_F() local
462 TaskBase *task = CreateServerTask(); HWTEST_F() local
486 TaskBase *task = CreateServerTask(); HWTEST_F() local
510 TaskBase *task = CreateServerTask(); HWTEST_F() local
535 TaskBase *task = CreateServerTask(); HWTEST_F() local
554 TaskBase *task = CreateIsoAuthClientTask(nullptr, outJson, &info); HWTEST_F() local
592 TaskBase *task = CreateIsoAuthClientTask(inJson, outJson, &info); CreateClientTask() local
603 TaskBase *task = CreateClientTask(); HWTEST_F() local
627 TaskBase *task = CreateClientTask(); HWTEST_F() local
649 TaskBase *task = CreateClientTask(); HWTEST_F() local
671 TaskBase *task = CreateClientTask(); HWTEST_F() local
693 TaskBase *task = CreateClientTask(); HWTEST_F() local
709 TaskBase *task = CreateClientTask(); HWTEST_F() local
733 TaskBase *task = CreateClientTask(); HWTEST_F() local
761 TaskBase *task = CreateClientTask(); HWTEST_F() local
787 TaskBase *task = CreateClientTask(); HWTEST_F() local
814 TaskBase *task = CreateClientTask(); HWTEST_F() local
842 TaskBase *task = CreateClientTask(); HWTEST_F() local
870 TaskBase *task = CreateClientTask(); HWTEST_F() local
900 TaskBase *task = CreateClientTask(); HWTEST_F() local
929 TaskBase *task = CreateClientTask(); HWTEST_F() local
959 TaskBase *task = CreateClientTask(); HWTEST_F() local
983 TaskBase *task = CreateClientTask(); HWTEST_F() local
1007 TaskBase *task = CreateClientTask(); HWTEST_F() local
1031 TaskBase *task = CreateClientTask(); HWTEST_F() local
1055 TaskBase *task = CreateClientTask(); HWTEST_F() local
1079 TaskBase *task = CreateClientTask(); HWTEST_F() local
1104 TaskBase *task = CreateClientTask(); HWTEST_F() local
[all...]
/base/security/device_auth/services/legacy/authenticators/src/account_unrelated/pake_task/standard_exchange_task/
H A Dstandard_client_bind_exchange_task.c33 static int ExchangeRequest(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, int *status) in ExchangeRequest() argument
36 if (task->taskStatus != TASK_STATUS_CLIENT_BIND_EXCHANGE_BEGIN) { in ExchangeRequest()
37 LOGI("The message is repeated, ignore it, status: %d", task->taskStatus); in ExchangeRequest()
41 StandardBindExchangeClientTask *realTask = (StandardBindExchangeClientTask *)task; in ExchangeRequest()
71 task->taskStatus = TASK_STATUS_CLIENT_BIND_EXCHANGE_REQUEST; in ExchangeRequest()
79 static int ExchangeConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, int *status) in ExchangeConfirm() argument
81 if (task->taskStatus < TASK_STATUS_CLIENT_BIND_EXCHANGE_REQUEST) { in ExchangeConfirm()
82 LOGE("Invalid taskStatus: %d", task->taskStatus); in ExchangeConfirm()
85 if (task->taskStatus > TASK_STATUS_CLIENT_BIND_EXCHANGE_REQUEST) { in ExchangeConfirm()
86 LOGI("The message is repeated, ignore it, status: %d", task in ExchangeConfirm()
114 Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, int *status) Process() argument
148 DestroyStandardBindExchangeClientTask(struct AsyBaseCurTaskT *task) DestroyStandardBindExchangeClientTask() argument
161 StandardBindExchangeClientTask *task = CreateStandardBindExchangeClientTask() local
[all...]
H A Dstandard_server_bind_exchange_task.c33 static int ExchangeStart(AsyBaseCurTask *task, PakeParams *params, CJson *out, int *status) in ExchangeStart() argument
36 if (task->taskStatus != TASK_STATUS_SERVER_BIND_EXCHANGE_BEGIN) { in ExchangeStart()
37 LOGI("The message is repeated, ignore it, status: %d", task->taskStatus); in ExchangeStart()
60 task->taskStatus = TASK_STATUS_SERVER_BIND_EXCHANGE_START; in ExchangeStart()
65 static int ExchangeResponse(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, int *status) in ExchangeResponse() argument
71 if (task->taskStatus < TASK_STATUS_SERVER_BIND_EXCHANGE_START) { in ExchangeResponse()
74 if (task->taskStatus > TASK_STATUS_SERVER_BIND_EXCHANGE_START) { in ExchangeResponse()
75 LOGI("The message is repeated, ignore it, status: %d", task->taskStatus); in ExchangeResponse()
80 StandardBindExchangeServerTask *realTask = (StandardBindExchangeServerTask *)task; in ExchangeResponse()
118 task in ExchangeResponse()
126 Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, int *status) Process() argument
160 DestroyStandardBindExchangeServerTask(struct AsyBaseCurTaskT *task) DestroyStandardBindExchangeServerTask() argument
173 StandardBindExchangeServerTask *task = CreateStandardBindExchangeServerTask() local
[all...]
/base/request/request/services/src/manage/events/
H A Ddump.rs15 use crate::task::info::{DumpAllEachInfo, DumpAllInfo, DumpOneInfo};
21 .find(|task| task.task_id() == task_id)
22 .map(|task| {
23 let status = task.status.lock().unwrap();
25 task_id: task.conf.common_data.task_id,
26 action: task.conf.common_data.action,
38 .map(|task| {
39 let status = task.status.lock().unwrap();
41 task_id: task
[all...]
/base/security/device_auth/deps_adapter/os_adapter/impl/src/
H A Dhc_task_thread.c31 HcTaskWrap task; in PopTask() local
32 HcBool ret = thread->tasks.popFront(&thread->tasks, &task); in PopTask()
35 return task.task; in PopTask()
40 static void PushTask(struct HcTaskThreadT* thread, HcTaskBase* task) in PushTask() argument
42 if (thread == NULL || task == NULL) { in PushTask()
48 taskWarp.task = task; in PushTask()
60 if (taskWarp->task->destroy) { in Clear()
61 taskWarp->task in Clear()
105 HcTaskBase* task = PopTask(thread); TaskThreadLoop() local
[all...]
/base/request/request/services/src/manage/scheduler/qos/
H A Dmod.rs24 use crate::task::config::Action;
40 pub(crate) fn start_task(&mut self, uid: u64, task: TaskQosInfo) {
42 self.apps.insert_task(uid, task);
82 for (i, task) in self.apps.iter().enumerate().flat_map(|(i, app)| { in reschedule_inner()
88 if task.action() != action { in reschedule_inner()
92 qos_vec.push(QosDirection::new(task.uid(), task.task_id(), m1_speed)); in reschedule_inner()
94 qos_vec.push(QosDirection::new(task.uid(), task.task_id(), m2_speed)); in reschedule_inner()
110 // Each app will take turns taking one task t in reschedule_inner()
[all...]
/base/update/updateservice/services/firmware/upgrade/data_processor/src/
H A Dfirmware_check_data_processor.cpp102 FirmwareTask task; in HasUndoneTask() local
103 FirmwareTaskOperator().QueryTask(task); in HasUndoneTask()
104 if (!task.isExistTask) { in HasUndoneTask()
105 FIRMWARE_LOGI("HasUndoneTask no task"); in HasUndoneTask()
109 FIRMWARE_LOGI("HasUndoneTask status %{public}d", task.status); in HasUndoneTask()
110 UpgradeStatus taskStatus = task.status; in HasUndoneTask()
120 FirmwareTask task; in IsUpdateOnStatus() local
121 FirmwareTaskOperator().QueryTask(task); in IsUpdateOnStatus()
122 if (!task.isExistTask) { in IsUpdateOnStatus()
123 FIRMWARE_LOGI("IsUpdateOnStatus no task"); in IsUpdateOnStatus()
146 FirmwareTask task; HandleNewVersion() local
189 FirmwareTask task; UpdateFirmwareComponent() local
207 FirmwareTask task; HandleNoNewVersion() local
[all...]
/base/security/device_auth/services/legacy/authenticators/src/account_unrelated/pake_task/pake_v1_task/pake_v1_protocol_task/
H A Dpake_v1_client_protocol_task.c37 static void DestroyPakeV1ProtocolClientTask(struct AsyBaseCurTaskT *task) in DestroyPakeV1ProtocolClientTask() argument
39 HcFree(task); in DestroyPakeV1ProtocolClientTask()
42 static int PakeRequest(AsyBaseCurTask *task, PakeParams *params, CJson *out, int *status) in PakeRequest() argument
44 if (task->taskStatus != TASK_STATUS_CLIENT_PAKE_BEGIN) { in PakeRequest()
45 LOGI("The message is repeated, ignore it, status: %d", task->taskStatus); in PakeRequest()
86 task->taskStatus = TASK_STATUS_CLIENT_PAKE_REQUEST; in PakeRequest()
147 static int PakeClientConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, int *status) in PakeClientConfirm() argument
150 if (task->taskStatus < TASK_STATUS_CLIENT_PAKE_REQUEST) { in PakeClientConfirm()
151 LOGE("Invalid taskStatus: %d", task->taskStatus); in PakeClientConfirm()
154 if (task in PakeClientConfirm()
191 PakeClientVerifyConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, int *status) PakeClientVerifyConfirm() argument
222 Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, int *status) Process() argument
260 PakeV1ProtocolClientTask *task = (PakeV1ProtocolClientTask *)HcMalloc(sizeof(PakeV1ProtocolClientTask), 0); CreatePakeV1ProtocolClientTask() local
[all...]
/base/request/request/services/src/manage/scheduler/queue/
H A Drunning_task.rs23 use crate::task::config::Action;
24 use crate::task::download::download;
25 use crate::task::reason::Reason;
26 use crate::task::request_task::RequestTask;
27 use crate::task::upload::upload;
30 task: Arc<RequestTask>,
32 // `_keeper` is never used when executing the task.
37 pub(crate) fn new(task: Arc<RequestTask>, tx: TaskManagerTx, keeper: SAKeeper) -> Self {
39 task,
48 download(self.task
[all...]
/base/security/device_auth/services/legacy/authenticators/src/account_unrelated/iso_task/
H A Diso_server_task.c23 static int GetIsoServerTaskType(const struct SubTaskBaseT *task) in GetIsoServerTaskType() argument
25 IsoServerTask *realTask = (IsoServerTask *)task; in GetIsoServerTaskType()
33 static void DestroyIsoServerTask(struct SubTaskBaseT *task) in DestroyIsoServerTask() argument
35 IsoServerTask *innerTask = (IsoServerTask *)task; in DestroyIsoServerTask()
81 LOGD("Authenticate task end."); in CreateNextTask()
92 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int32_t *status) in Process() argument
94 IsoServerTask *realTask = (IsoServerTask *)task; in Process()
113 IsoServerTask *task = (IsoServerTask *)HcMalloc(sizeof(IsoServerTask), 0); in CreateIsoServerTask() local
114 if (task == NULL) { in CreateIsoServerTask()
119 task in CreateIsoServerTask()
[all...]
H A Diso_client_task.c23 static int GetIsoClientTaskType(const struct SubTaskBaseT *task) in GetIsoClientTaskType() argument
25 IsoClientTask *realTask = (IsoClientTask *)task; in GetIsoClientTaskType()
33 static void DestroyIsoClientTask(struct SubTaskBaseT *task) in DestroyIsoClientTask() argument
35 IsoClientTask *innerTask = (IsoClientTask *)task; in DestroyIsoClientTask()
52 LOGI("Bind exchange task end successfully."); in CreateNextTask()
69 LOGI("Authenticate task end successfully."); in CreateNextTask()
79 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int32_t *status) in Process() argument
81 IsoClientTask *realTask = (IsoClientTask *)task; in Process()
99 IsoClientTask *task = (IsoClientTask *)HcMalloc(sizeof(IsoClientTask), 0); in CreateIsoClientTask() local
100 if (task in CreateIsoClientTask()
[all...]
/base/security/device_auth/services/legacy/authenticators/src/account_unrelated/pake_task/pake_v1_task/
H A Dpake_v1_server_task.c25 static int GetPakeV1ServerTaskType(const struct SubTaskBaseT *task) in GetPakeV1ServerTaskType() argument
27 PakeV1ServerTask *realTask = (PakeV1ServerTask *)task; in GetPakeV1ServerTaskType()
35 static void DestroyPakeV1ServerTask(struct SubTaskBaseT *task) in DestroyPakeV1ServerTask() argument
37 PakeV1ServerTask *innerTask = (PakeV1ServerTask *)task; in DestroyPakeV1ServerTask()
83 LOGE("Create and process next task failed, opcode: %d, res: %d.", realTask->params.opCode, res); in CreateNextTask()
94 LOGI("End server task successfully, opcode: %d.", realTask->params.opCode); in CreateNextTask()
98 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int *status) in Process() argument
100 PakeV1ServerTask *realTask = (PakeV1ServerTask *)task; in Process()
121 PakeV1ServerTask *task = (PakeV1ServerTask *)HcMalloc(sizeof(PakeV1ServerTask), 0); in CreatePakeV1ServerTask() local
122 if (task in CreatePakeV1ServerTask()
[all...]
H A Dpake_v1_client_task.c25 static int GetPakeV1ClientTaskType(const struct SubTaskBaseT *task) in GetPakeV1ClientTaskType() argument
27 PakeV1ClientTask *realTask = (PakeV1ClientTask *)task; in GetPakeV1ClientTaskType()
35 static void DestroyPakeV1ClientTask(struct SubTaskBaseT *task) in DestroyPakeV1ClientTask() argument
37 PakeV1ClientTask *innerTask = (PakeV1ClientTask *)task; in DestroyPakeV1ClientTask()
83 LOGE("Create and process next task failed, opcode: %d, res: %d.", realTask->params.opCode, res); in CreateNextTask()
94 LOGI("End client task successfully, opcode: %d.", realTask->params.opCode); in CreateNextTask()
98 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int *status) in Process() argument
100 PakeV1ClientTask *realTask = (PakeV1ClientTask *)task; in Process()
121 PakeV1ClientTask *task = (PakeV1ClientTask *)HcMalloc(sizeof(PakeV1ClientTask), 0); in CreatePakeV1ClientTask() local
122 if (task in CreatePakeV1ClientTask()
[all...]
/base/hiviewdfx/hiview/plugins/performance/executor/
H A DThrTaskContainer.cpp36 void ThrTaskContainer::PostTask(ITask* task) in PostTask() argument
38 if (task == nullptr) { in PostTask()
39 throw std::invalid_argument("null task"); in PostTask()
43 tasks.push_back(task); in PostTask()
54 for (auto& task: tasks) { in IsTaskOverLimit()
55 delete task; in IsTaskOverLimit()
56 task = nullptr; in IsTaskOverLimit()
71 ITask* task = tasks.front(); in Entry() local
72 if (task == nullptr) { in Entry()
73 HIVIEW_LOGE("Entry task i in Entry()
[all...]
/base/update/updateservice/services/firmware/upgrade/flow/include/
H A Dfirmware_manager.h60 void HandleBootInstallOnStatusProcess(FirmwareTask &task);
61 void HandleBootApplyOnStatusProcess(const FirmwareTask &task);
62 void HandleBootUpdateOnStatusProcess(const FirmwareTask &task);
63 void HandleBootDownloadOnStatusProcess(FirmwareTask &task);
64 void HandleBootDownloadPauseStatusProcess(FirmwareTask &task);
65 void HandleBootDownloadedStatusProcess(FirmwareTask &task);
66 void HandleBootUpdateSuccess(const FirmwareTask &task, const std::map<std::string, UpdateResult> &resultMap);
67 void HandleBootUpdateFail(const FirmwareTask &task, const std::map<std::string, UpdateResult> &resultMap);
68 void DoAutoDownload(const FirmwareTask &task);
70 void HandleResumeDownload(FirmwareTask &task);
[all...]
/base/request/request/services/src/task/
H A Ddownload.rs18 use std::task::{Context, Poll};
28 use crate::task::info::State;
29 use crate::task::request_task::RequestTask;
58 task: Arc<RequestTask>,
62 let task_operator = TaskOperator::new(task, abort_flag);
72 pub(crate) async fn download(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) {
73 task.tries.store(0, Ordering::SeqCst);
75 if let Err(e) = download_inner(task.clone(), abort_flag.clone()).await {
83 *task.running_result.lock().unwrap() = Some(Err(Reason::NetworkOffline));
87 *task
[all...]
/base/update/updateservice/services/firmware/upgrade/flow/src/
H A Dfirmware_manager.cpp135 FirmwareTask task; in IsIdle() local
136 FirmwareTaskOperator().QueryTask(task); in IsIdle()
137 bool isIdle = !task.isExistTask; in IsIdle()
156 FirmwareTask task; in DoCancelDownload() local
157 FirmwareTaskOperator().QueryTask(task); in DoCancelDownload()
158 if (!task.isExistTask) { in DoCancelDownload()
159 FIRMWARE_LOGI("DoCancelDownload no task"); in DoCancelDownload()
160 businessError.Build(CallResult::FAIL, "no download task to cancel!"); in DoCancelDownload()
161 businessError.AddErrorMessage(CAST_INT(DUPDATE_ERR_DOWNLOAD_COMMON_ERROR), "no download task to cancel!"); in DoCancelDownload()
215 FirmwareTask task; in CanInstall() local
248 FirmwareTask task; DoAutoDownloadSwitchChanged() local
268 FirmwareTask task; DoClearError() local
301 FirmwareTask task; HandleBootComplete() local
326 FirmwareTask task; HandleNetChanged() local
351 HandleBootUpdateOnStatusProcess(const FirmwareTask &task) HandleBootUpdateOnStatusProcess() argument
370 HandleBootUpdateSuccess(const FirmwareTask &task, const std::map<std::string, UpdateResult> &resultMap) HandleBootUpdateSuccess() argument
398 HandleBootUpdateFail(const FirmwareTask &task, const std::map<std::string, UpdateResult> &resultMap) HandleBootUpdateFail() argument
432 HandleBootInstallOnStatusProcess(FirmwareTask &task) HandleBootInstallOnStatusProcess() argument
452 HandleBootDownloadOnStatusProcess(FirmwareTask &task) HandleBootDownloadOnStatusProcess() argument
459 HandleBootDownloadPauseStatusProcess(FirmwareTask &task) HandleBootDownloadPauseStatusProcess() argument
464 HandleResumeDownload(FirmwareTask &task) HandleResumeDownload() argument
469 HandleBootDownloadedStatusProcess(FirmwareTask &task) HandleBootDownloadedStatusProcess() argument
474 DoAutoDownload(const FirmwareTask &task) DoAutoDownload() argument
[all...]

Completed in 14 milliseconds

12345678910>>...14