Home
last modified time | relevance | path

Searched refs:task (Results 1 – 25 of 277) sorted by relevance

12345678910>>...12

/base/startup/init/services/loopevent/task/
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->flags = info->flags; in CreateTask()
46 task->taskId.fd = fd; in CreateTask()
[all …]
/base/security/device_auth/test/unittest/deviceauth/source/
Diso_auth_task_test.cpp72 TaskBase *task = CreateIsoAuthTask(nullptr, nullptr, nullptr); variable
73 EXPECT_EQ(task, nullptr);
82 task = CreateIsoAuthClientTask(inJson, outJson, &info);
83 EXPECT_EQ(task, nullptr);
87 task = CreateIsoAuthClientTask(inJson, outJson, &info);
88 EXPECT_EQ(task, nullptr);
92 task = CreateIsoAuthClientTask(inJson, outJson, &info);
93 EXPECT_EQ(task, nullptr);
97 task = CreateIsoAuthClientTask(inJson, outJson, &info);
98 EXPECT_EQ(task, nullptr);
[all …]
/base/startup/init/services/loopevent/signal/
Dle_signal.c27 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleSignalEvent_() argument
33 ssize_t s = read(GetSocketFd(task), &fdsi, sizeof(fdsi)); in HandleSignalEvent_()
35 SignalTask *sigTask = (SignalTask *)task; in HandleSignalEvent_()
44 BaseTask *task = (BaseTask *)signalHandle; in HandleSignalTaskClose_() local
45 CloseTask(loopHandle, task); in HandleSignalTaskClose_()
46 DelTask((EventLoop *)loopHandle, task); in HandleSignalTaskClose_()
47 close(task->taskId.fd); in HandleSignalTaskClose_()
59 SignalTask *task = (SignalTask *)CreateTask(loopHandle, sfd, &info, sizeof(SignalTask)); in LE_CreateSignalTask() local
60 LE_CHECK(task != NULL, return LE_NO_MEMORY, "Failed to create task"); in LE_CreateSignalTask()
61 task->base.handleEvent = HandleSignalEvent_; in LE_CreateSignalTask()
[all …]
/base/startup/init/services/loopevent/idle/
Dle_idle.c40 IdleTask *task = (IdleTask *)calloc(1, sizeof(IdleTask)); in LE_AddIdle() local
41 LE_CHECK(task != NULL, 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->node)); in LE_AddIdle()
66 IdleTask *task = (IdleTask *)idle; in LE_DelIdle() local
67 OH_ListRemove(&(task->node)); in LE_DelIdle()
[all …]
/base/request/request/services/service/request/src/manager/events/
Dstart.rs20 use crate::task::info::{ApplicationState, State};
21 use crate::task::reason::Reason;
22 use crate::task::request_task::run;
23 use crate::task::RequestTask;
29 if let Some(task) = self.get_task(uid, task_id) { in start()
30 let task_state = task.status.lock().unwrap().state; in start()
35 self.start_inner(task); in start()
50 pub(crate) fn start_inner(&mut self, task: Arc<RequestTask>) { in start_inner()
51 if !task.net_work_online() || !task.check_net_work_status() { in start_inner()
53 self.after_task_processed(&task); in start_inner()
[all …]
Ddump.rs15 use crate::task::info::{DumpAllEachInfo, DumpAllInfo, DumpOneInfo};
19 self.tasks.get(&task_id).map(|task| DumpOneInfo { in query_one_task()
20 task_id: task.conf.common_data.task_id, in query_one_task()
21 action: task.conf.common_data.action, in query_one_task()
22 state: task.status.lock().unwrap().state, in query_one_task()
23 reason: task.status.lock().unwrap().reason, in query_one_task()
24 total_size: task in query_one_task()
27 tran_size: task.progress.lock().unwrap().common_data.total_processed, in query_one_task()
28 url: task.conf.url.clone(), in query_one_task()
37 .map(|task| DumpAllEachInfo { in query_all_task()
[all …]
Dconstruct.rs21 use crate::task::config::{TaskConfig, Version};
22 use crate::task::ffi::{CTaskConfig, CTaskInfo};
23 use crate::task::info::State;
24 use crate::task::reason::Reason;
25 use crate::task::RequestTask;
53 let task = Arc::new(RequestTask::constructor( in construct_task() localVariable
65 if !self.add_task_api10(task.clone()) { in construct_task()
71 self.add_task_api9(task.clone()); in construct_task()
75 self.record_request_task(task.as_ref()); in construct_task()
85 pub(crate) fn add_task_api9(&mut self, task: Arc<RequestTask>) { in add_task_api9()
[all …]
/base/security/device_auth/services/legacy/group_manager/src/
Dgroup_manager_common.c23 static int32_t InitGroupManagerTask(GroupManagerTask *task, GMTaskParams *taskParams, TaskFunc func) in InitGroupManagerTask() argument
25 task->base.doAction = func; in InitGroupManagerTask()
26 task->base.destroy = DestroyGroupManagerTask; in InitGroupManagerTask()
27 task->osAccountId = taskParams->osAccountId; in InitGroupManagerTask()
28 task->opCode = taskParams->opCode; in InitGroupManagerTask()
29 task->reqId = taskParams->reqId; in InitGroupManagerTask()
30 task->params = taskParams->params; in InitGroupManagerTask()
31 return BindCallbackToTask(task, taskParams->params); in InitGroupManagerTask()
47 int32_t BindCallbackToTask(GroupManagerTask *task, const CJson *jsonParams) in BindCallbackToTask() argument
54 task->cb = GetGMCallbackByAppId(appId); in BindCallbackToTask()
[all …]
/base/request/request/services/service/request/src/task/
Dupload.rs17 use std::task::{Context, Poll};
26 use crate::task::info::State;
27 use crate::task::RequestTask;
34 task: Arc<RequestTask>, field
42 pub(crate) fn new(task: Arc<RequestTask>) -> Self { in new()
44 task, in new()
57 if self.task.rate_limiting.load(Ordering::Acquire) { in poll_read()
62 Clock::get_instance().register(self.task.conf.common_data.task_id, cx); in poll_read()
73 let index = self.task.progress.lock().unwrap().common_data.index; in poll_read()
74 let file = unsafe { &mut *self.task.files.0.get() } in poll_read()
[all …]
Ddownload.rs17 use std::task::{Context, Poll};
25 use crate::task::info::State;
26 use crate::task::RequestTask;
43 if self.task.rate_limiting.load(Ordering::Acquire) { in poll_download()
48 Clock::get_instance().register(self.task.conf.common_data.task_id, cx); in poll_download()
59 if self.task.range_request.load(Ordering::SeqCst) { in poll_download()
60 if self.task.range_response.load(Ordering::SeqCst) { in poll_download()
64 let begins = self.task.conf.common_data.begins; in poll_download()
65 let ends = self.task.conf.common_data.ends; in poll_download()
82 task: Arc<RequestTask>, in build_downloader()
[all …]
Doperator.rs17 use std::task::{Context, Poll};
24 use crate::task::config::Version;
25 use crate::task::info::State;
26 use crate::task::RequestTask;
33 pub(crate) task: Arc<RequestTask>, field
39 pub(crate) fn new(task: Arc<RequestTask>) -> Self { in new()
41 task, in new()
53 let state = self.task.status.lock().unwrap().state; in poll_progress_common()
55 || (self.task.conf.version == Version::API10 && !self.task.check_net_work_status()) in poll_progress_common()
61 let version = self.task.conf.version; in poll_progress_common()
[all …]
/base/security/device_auth/services/legacy/authenticators/src/account_unrelated/pake_task/standard_exchange_task/
Dstandard_client_bind_exchange_task.c33 static int ExchangeRequest(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, i… 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->taskStatus); in ExchangeConfirm()
[all …]
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, … 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->taskStatus = TASK_STATUS_SERVER_BIND_EXCHANGE_RESPONSE; in ExchangeResponse()
[all …]
/base/hiviewdfx/hiview/framework/native/unified_collection/decorator/
Dmemory_decorator.cpp26 auto task = std::bind(&MemoryCollector::CollectProcessMemory, memoryCollector_.get(), pid); in CollectProcessMemory() local
27 return Invoke(task, statInfoWrapper_, MEM_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectProcessMemory()
32 auto task = std::bind(&MemoryCollector::CollectSysMemory, memoryCollector_.get()); in CollectSysMemory() local
33 return Invoke(task, statInfoWrapper_, MEM_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectSysMemory()
38 auto task = std::bind(&MemoryCollector::CollectRawMemInfo, memoryCollector_.get()); in CollectRawMemInfo() local
39 return Invoke(task, statInfoWrapper_, MEM_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectRawMemInfo()
44 auto task = std::bind(&MemoryCollector::CollectAllProcessMemory, memoryCollector_.get()); in CollectAllProcessMemory() local
45 return Invoke(task, statInfoWrapper_, MEM_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectAllProcessMemory()
49 auto task = std::bind(&MemoryCollector::ExportAllProcessMemory, memoryCollector_.get()); in ExportAllProcessMemory() local
50 return Invoke(task, statInfoWrapper_, MEM_COLLECTOR_NAME + UC_SEPARATOR + __func__); in ExportAllProcessMemory()
[all …]
Dio_decorator.cpp26 auto task = std::bind(&IoCollector::CollectProcessIo, ioCollector_.get(), pid); in CollectProcessIo() local
27 return Invoke(task, statInfoWrapper_, IO_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectProcessIo()
32 auto task = std::bind(&IoCollector::CollectRawDiskStats, ioCollector_.get()); in CollectRawDiskStats() local
33 return Invoke(task, statInfoWrapper_, IO_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectRawDiskStats()
39 auto task = std::bind(&IoCollector::CollectDiskStats, ioCollector_.get(), filter, isUpdate); in CollectDiskStats() local
40 return Invoke(task, statInfoWrapper_, IO_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectDiskStats()
45 auto task = std::bind(&IoCollector::ExportDiskStats, ioCollector_.get(), filter); in ExportDiskStats() local
46 return Invoke(task, statInfoWrapper_, IO_COLLECTOR_NAME + UC_SEPARATOR + __func__); in ExportDiskStats()
51 auto task = std::bind(&IoCollector::CollectEMMCInfo, ioCollector_.get()); in CollectEMMCInfo() local
52 return Invoke(task, statInfoWrapper_, IO_COLLECTOR_NAME + UC_SEPARATOR + __func__); in CollectEMMCInfo()
[all …]
/base/hiviewdfx/hicollie/frameworks/native/test/unittest/common/
Dwatchdog_task_test.cpp57 WatchdogTask task("WatchdogTaskTest_001", taskFunc, 0, 0, true); variable
58 task.DoCallback();
59 EXPECT_EQ(task.flag, 0);
60 task.flag = 1;
61 task.DoCallback();
62 task.flag = 2;
63 task.DoCallback();
76 WatchdogTask task("WatchdogTaskTest_002", taskFunc, 0, 0, true); variable
77 task.Run(now);
78 EXPECT_EQ(task.GetBlockDescription(1), "Watchdog: thread(WatchdogTaskTest_002) blocked 1s");
[all …]
/base/request/request/services/service/request/src/manager/
Dmonitor.rs19 use crate::task::config::Action;
20 use crate::task::info::{ApplicationState, Mode, State};
21 use crate::task::reason::Reason;
100 Some(task) => { in update_foreground_app()
101 if task.conf.common_data.mode == Mode::FrontEnd { in update_foreground_app()
102 v.push(task.clone()) in update_foreground_app()
119 tasks.into_iter().for_each(|task| { in update_foreground_app()
120 let state = task.status.lock().unwrap().state; in update_foreground_app()
121 let reason = task.status.lock().unwrap().reason; in update_foreground_app()
124 task.resume.store(true, Ordering::SeqCst); in update_foreground_app()
[all …]
/base/startup/init/services/loopevent/timer/
Dle_timer.c41 static LE_STATUS HandleTimerEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleTimerEvent_() argument
47 (void)read(GetSocketFd(task), &repeat, sizeof(repeat)); in HandleTimerEvent_()
48 TimerTask *timer = (TimerTask *)task; in HandleTimerEvent_()
49 int fd = GetSocketFd(task); in HandleTimerEvent_()
51 uint64_t userData = *(uint64_t *)LE_GetUserData(task); in HandleTimerEvent_()
52 timer->processTimer(task, (void *)userData); in HandleTimerEvent_()
68 BaseTask *task = (BaseTask *)taskHandle; in HandleTimerClose_() local
69 CloseTask(loopHandle, task); in HandleTimerClose_()
70 DelTask((EventLoop *)loopHandle, task); in HandleTimerClose_()
71 close(task->taskId.fd); in HandleTimerClose_()
[all …]
/base/security/device_auth/deps_adapter/os_adapter/impl/src/
Dhc_task_thread.c31 HcTaskWrap task; in IMPLEMENT_HC_VECTOR() local
32 HcBool ret = thread->tasks.popFront(&thread->tasks, &task); in IMPLEMENT_HC_VECTOR()
35 return task.task; in IMPLEMENT_HC_VECTOR()
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->destroy(taskWarp->task); in Clear()
63 HcFree(taskWarp->task); in Clear()
105 HcTaskBase* task = PopTask(thread); in TaskThreadLoop() local
[all …]
/base/update/updateservice/services/firmware/upgrade/flow/src/
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()
214 FirmwareTask task; in CanInstall() local
216 firmwareTaskOperator.QueryTask(task); in CanInstall()
217 FIRMWARE_LOGI("check can install task.status:%{public}d", CAST_INT(task.status)); in CanInstall()
219 …return task.status == UpgradeStatus::DOWNLOAD_SUCCESS || task.status == UpgradeStatus::INSTALL_SUC… in CanInstall()
[all …]
/base/security/device_auth/services/legacy/authenticators/src/account_unrelated/iso_task/
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()
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 == NULL) { in CreateIsoClientTask()
105 task->taskBase.getTaskType = GetIsoClientTaskType; in CreateIsoClientTask()
106 task->taskBase.destroyTask = DestroyIsoClientTask; in CreateIsoClientTask()
[all …]
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()
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->taskBase.getTaskType = GetIsoServerTaskType; in CreateIsoServerTask()
120 task->taskBase.destroyTask = DestroyIsoServerTask; in CreateIsoServerTask()
[all …]
/base/security/device_auth/services/legacy/authenticators/src/account_unrelated/pake_task/pake_v1_task/pake_v1_protocol_task/
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()
82 task->taskStatus = TASK_STATUS_CLIENT_PAKE_REQUEST; in PakeRequest()
138 static int PakeClientConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out,… in PakeClientConfirm() argument
141 if (task->taskStatus < TASK_STATUS_CLIENT_PAKE_REQUEST) { in PakeClientConfirm()
142 LOGE("Invalid taskStatus: %d", task->taskStatus); in PakeClientConfirm()
145 if (task->taskStatus > TASK_STATUS_CLIENT_PAKE_REQUEST) { in PakeClientConfirm()
[all …]
/base/security/device_auth/services/legacy/authenticators/src/account_unrelated/
Ddas_task_main.c112 static void DestroyTaskT(Task *task) in DestroyTaskT() argument
114 if (task == NULL) { in DestroyTaskT()
119 FOR_EACH_HC_VECTOR(task->vec, index, ptr) { in DestroyTaskT()
122 DESTROY_HC_VECTOR(SubTaskVec, &(task->vec)); in DestroyTaskT()
123 HcFree(task); in DestroyTaskT()
126 static int ProcessMultiTask(Task *task, const CJson *in, CJson *out, int32_t *status) in ProcessMultiTask() argument
137 FOR_EACH_HC_VECTOR(task->vec, index, ptr) { in ProcessMultiTask()
170 static int NegotiateAndProcessTask(Task *task, const CJson *in, CJson *out, int32_t *status) in NegotiateAndProcessTask() argument
179 res = NegotiateVersion(&minVersionPeer, &curVersionPeer, &(task->versionInfo.curVersion)); in NegotiateAndProcessTask()
184 if (!IsVersionEqual(&(task->versionInfo.curVersion), &curVersionPeer)) { in NegotiateAndProcessTask()
[all …]
/base/update/updateservice/services/firmware/upgrade/data_processor/src/
Dfirmware_check_data_processor.cpp103 FirmwareTask task; in HasUndoneTask() local
104 FirmwareTaskOperator().QueryTask(task); in HasUndoneTask()
105 if (!task.isExistTask) { in HasUndoneTask()
110 FIRMWARE_LOGI("HasUndoneTask status %{public}d", task.status); in HasUndoneTask()
111 UpgradeStatus taskStatus = task.status; in HasUndoneTask()
121 FirmwareTask task; in IsUpdateOnStatus() local
122 FirmwareTaskOperator().QueryTask(task); in IsUpdateOnStatus()
123 if (!task.isExistTask) { in IsUpdateOnStatus()
128 FIRMWARE_LOGI("IsUpdateOnStatus status %{public}d", task.status); in IsUpdateOnStatus()
129 return task.status == UpgradeStatus::UPDATING; in IsUpdateOnStatus()
[all …]

12345678910>>...12