Home
last modified time | relevance | path

Searched refs:taskId (Results 1 – 25 of 47) sorted by relevance

12

/base/request/request/download/services/src/
Ddownload_service_manager.cpp117 uint32_t taskId = GetCurrentTaskId(); in AddTask() local
118 if (taskMap_.find(taskId) != taskMap_.end()) { in AddTask()
122 auto task = std::make_shared<DownloadServiceTask>(taskId, config); in AddTask()
129 taskMap_[taskId] = task; in AddTask()
130 MoveTaskToQueue(taskId, task); in AddTask()
131 return taskId; in AddTask()
134 void DownloadServiceManager::InstallCallback(uint32_t taskId, DownloadTaskCallback eventCb) in InstallCallback() argument
139 std::map<uint32_t, std::shared_ptr<DownloadServiceTask>>::iterator it = taskMap_.find(taskId); in InstallCallback()
150 uint32_t taskId; in ProcessTask() local
151 auto pickupTask = [this, &taskId]() -> std::shared_ptr<DownloadServiceTask> { in ProcessTask()
[all …]
Ddownload_service_ability.cpp165 int32_t taskId = -1; in Request() local
171 return taskId; in Request()
173 taskId = static_cast<int32_t>(instance->AddTask(config)); in Request()
174 if (taskId < 0) { in Request()
176 taskId, config.GetUrl().c_str()); in Request()
178 … err.errInfo = "taskId "+ std::to_string(taskId) + " is invalid, config url: " + config.GetUrl(); in Request()
179 return taskId; in Request()
181 instance->InstallCallback(taskId, NotifyHandler); in Request()
182 DOWNLOAD_HILOGI("DownloadServiceAbility Allocate Task[%{public}d] started.", taskId); in Request()
183 return taskId; in Request()
[all …]
Ddownload_background_notification.cpp28 void DownloadBackgroundNotification::PublishDownloadNotification(uint32_t taskId, pid_t uid, in PublishDownloadNotification() argument
33 DOWNLOAD_HILOGE("taskId: %{public}d, downloadTemplate is null", taskId); in PublishDownloadNotification()
44 DOWNLOAD_HILOGE("taskId: %{public}d, normalContent is null", taskId); in PublishDownloadNotification()
49 DOWNLOAD_HILOGE("taskId: %{public}d, content is null", taskId); in PublishDownloadNotification()
52 NotificationRequest req(taskId); in PublishDownloadNotification()
/base/security/device_auth/services/authenticators/src/account_related/
Daccount_multi_task_manager.c24 static bool IsManagerHasTaskId(int32_t taskId) in IsManagerHasTaskId() argument
27 if (g_taskManager.taskArray[i] != NULL && taskId == g_taskManager.taskArray[i]->taskId) { in IsManagerHasTaskId()
28 LOGD("Task already exists, taskId: %d.", taskId); in IsManagerHasTaskId()
32 LOGD("Multi auth manager do not has task id(%d).", taskId); in IsManagerHasTaskId()
45 static bool CanAddTaskInManager(int32_t taskId) in CanAddTaskInManager() argument
51 if (IsManagerHasTaskId(taskId)) { in CanAddTaskInManager()
65 if (!CanAddTaskInManager(task->taskId)) { in AddTaskToManager()
80 static AccountTask *GetTaskFromManager(int32_t taskId) in GetTaskFromManager() argument
83 … if ((g_taskManager.taskArray[i] != NULL) && (g_taskManager.taskArray[i]->taskId == taskId)) { in GetTaskFromManager()
87 LOGE("Task does not exist, taskId: %d.", taskId); in GetTaskFromManager()
[all …]
Daccount_module.c70 static int32_t CreateAccountTask(int32_t *taskId, const CJson *in, CJson *out) in CreateAccountTask() argument
72 if (taskId == NULL || in == NULL || out == NULL) { in CreateAccountTask()
90 AccountTask *newTask = CreateAccountTaskT(taskId, in, out); in CreateAccountTask()
103 static int32_t ProcessAccountTask(int32_t taskId, const CJson *in, CJson *out, int32_t *status) in ProcessAccountTask() argument
110 AccountTask *currentTask = authManager->getTaskFromManager(taskId); in ProcessAccountTask()
112 LOGE("Get task from manager failed, taskId: %d.", taskId); in ProcessAccountTask()
115 LOGD("Begin process account related task, taskId: %d.", taskId); in ProcessAccountTask()
119 static void DestroyAccountTask(int32_t taskId) in DestroyAccountTask() argument
126 LOGI("Delete taskId:%d from task manager.", taskId); in DestroyAccountTask()
127 authManager->deleteTaskFromManager(taskId); in DestroyAccountTask()
/base/request/request/download/interfaces/kits/js/napi/download_single/src/
Ddownload_manager.cpp63 int32_t taskId = proxy->Request(config, err); in EnqueueTask() local
64 if (taskId < 0) { in EnqueueTask()
69 return new DownloadTask(taskId); in EnqueueTask()
72 bool DownloadManager::Pause(uint32_t taskId) in Pause() argument
79 return proxy->Pause(taskId); in Pause()
82 bool DownloadManager::Query(uint32_t taskId, DownloadInfo &info) in Query() argument
89 return proxy->Query(taskId, info); in Query()
92 bool DownloadManager::QueryMimeType(uint32_t taskId, std::string &mimeType) in QueryMimeType() argument
99 return proxy->QueryMimeType(taskId, mimeType); in QueryMimeType()
102 bool DownloadManager::Remove(uint32_t taskId) in Remove() argument
[all …]
Ddownload_service_proxy.cpp107 int32_t taskId = reply.ReadInt32(); in Request() local
108 if (taskId < 0) { in Request()
110 error.errInfo = "taskId: " + std::to_string(taskId); in Request()
114 return taskId; in Request()
117 bool DownloadServiceProxy::Pause(uint32_t taskId) in Pause() argument
123 data.WriteUint32(taskId); in Pause()
134 bool DownloadServiceProxy::Query(uint32_t taskId, DownloadInfo &info) in Query() argument
140 data.WriteInt32(taskId); in Query()
163 bool DownloadServiceProxy::QueryMimeType(uint32_t taskId, std::string &mimeType) in QueryMimeType() argument
169 data.WriteInt32(taskId); in QueryMimeType()
[all …]
/base/request/request/download/interfaces/innerkits/include/
Ddownload_service_interface.h32 virtual bool Pause(uint32_t taskId) = 0;
33 virtual bool Query(uint32_t taskId, DownloadInfo &info) = 0;
34 virtual bool QueryMimeType(uint32_t taskId, std::string &mimeType) = 0;
35 virtual bool Remove(uint32_t taskId) = 0;
36 virtual bool Resume(uint32_t taskId) = 0;
37 …virtual bool On(uint32_t taskId, const std::string &type, const sptr<DownloadNotifyInterface> &lis…
38 virtual bool Off(uint32_t taskId, const std::string &type) = 0;
/base/request/request/download/interfaces/kits/js/napi/download_single/include/
Ddownload_service_proxy.h31 bool Pause(uint32_t taskId) override;
32 bool Query(uint32_t taskId, DownloadInfo &info) override;
33 bool QueryMimeType(uint32_t taskId, std::string &mimeType) override;
34 bool Remove(uint32_t taskId) override;
35 bool Resume(uint32_t taskId) override;
37 …bool On(uint32_t taskId, const std::string &type, const sptr<DownloadNotifyInterface> &listener) o…
38 bool Off(uint32_t taskId, const std::string &type) override;
Ddownload_manager.h48 bool Pause(uint32_t taskId);
49 bool Query(uint32_t taskId, DownloadInfo &info);
50 bool QueryMimeType(uint32_t taskId, std::string &mimeType);
51 bool Remove(uint32_t taskId);
52 bool Resume(uint32_t taskId);
54 … bool On(uint32_t taskId, const std::string &type, const sptr<DownloadNotifyInterface> &listener);
55 bool Off(uint32_t taskId, const std::string &type);
/base/request/request/download/services/include/
Ddownload_service_ability.h53 bool Pause(uint32_t taskId) override;
54 bool Query(uint32_t taskId, DownloadInfo &info) override;
55 bool QueryMimeType(uint32_t taskId, std::string &mimeType) override;
56 bool Remove(uint32_t taskId) override;
57 bool Resume(uint32_t taskId) override;
59 …bool On(uint32_t taskId, const std::string &type, const sptr<DownloadNotifyInterface> &listener) o…
60 bool Off(uint32_t taskId, const std::string &type) override;
66 …static void NotifyHandler(const std::string& type, uint32_t taskId, int64_t argv1, int64_t argv2, …
77 void AddUnregisteredNotify(uint32_t taskId, const std::string &type);
78 bool DoUnregisteredNotify(uint32_t taskId, const std::string &type);
Ddownload_service_manager.h44 void InstallCallback(uint32_t taskId, DownloadTaskCallback eventCb);
47 bool Pause(uint32_t taskId, uint32_t uid);
48 bool Resume(uint32_t taskId, uint32_t uid);
49 bool Remove(uint32_t taskId, uint32_t uid);
50 bool Query(uint32_t taskId, DownloadInfo &info);
51 bool Query(uint32_t taskId, uint32_t uid, DownloadInfo &info);
53 bool QueryMimeType(uint32_t taskId, uint32_t uid, std::string &mimeType);
72 void MoveTaskToQueue(uint32_t taskId, std::shared_ptr<DownloadServiceTask> task);
73 void PushQueue(std::queue<uint32_t> &queue, uint32_t taskId);
74 void RemoveFromQueue(std::queue<uint32_t> &queue, uint32_t taskId);
/base/startup/init/services/loopevent/loop/
Dle_loop.c24 return (int)task1->taskId.fd - (int)task2->taskId.fd; in TaskNodeCompare()
30 TaskId *taskId = (TaskId *)key; in TaskKeyCompare() local
31 return (int)task->taskId.fd - taskId->taskId.fd; in TaskKeyCompare()
37 return task->taskId.fd; in TaskGetNodeHasCode()
42 TaskId *taskId = (TaskId *)key; in TaskGetKeyHasCode() local
43 return taskId->taskId.fd; in TaskGetKeyHasCode()
123 loop->delEvent(loop, task->taskId.fd, in DelTask()
/base/security/device_auth/services/authenticators/src/account_unrelated/
Ddas_module.c68 static int CreateDasTask(int32_t *taskId, const CJson *in, CJson *out) in CreateDasTask() argument
70 if (taskId == NULL || in == NULL || out == NULL) { in CreateDasTask()
77 Task *task = CreateTaskT(taskId, in, out); in CreateDasTask()
103 static int ProcessDasTask(int32_t taskId, const CJson* in, CJson* out, int32_t *status) in ProcessDasTask() argument
114 if (taskId == temp->taskId) { in ProcessDasTask()
120 LOGE("Task doesn't exist, taskId: %d.", taskId); in ProcessDasTask()
124 static void DestroyDasTask(int taskId) in DestroyDasTask() argument
131 if (taskId == temp->taskId) { in DestroyDasTask()
/base/inputmethod/imf/services/dfx/src/
Dinputmethod_trace.cpp31 void StartAsync(uint64_t label, const std::string& value, int32_t taskId) in StartAsync() argument
33 StartAsyncTrace(label, value, taskId); in StartAsync()
36 void FinishAsync(uint64_t label, const std::string &value, int32_t taskId) in FinishAsync() argument
38 FinishAsyncTrace(label, value, taskId); in FinishAsync()
/base/hiviewdfx/hitrace/interfaces/native/innerkits/src/
Dhitrace_meter.cpp227 void StartAsyncTrace(uint64_t label, const string& value, int32_t taskId, float limit UNUSED_PARAM) in StartAsyncTrace() argument
230 AddHitraceMeterMarker(MARKER_ASYNC_BEGIN, label, traceName, std::to_string(taskId)); in StartAsyncTrace()
233 void StartAsyncTraceDebug(bool isDebug, uint64_t label, const string& value, int32_t taskId, float … in StartAsyncTraceDebug() argument
239 AddHitraceMeterMarker(MARKER_ASYNC_BEGIN, label, traceName, std::to_string(taskId)); in StartAsyncTraceDebug()
242 void StartAsyncTraceArgs(uint64_t label, int32_t taskId, const char *fmt, ...) in StartAsyncTraceArgs() argument
254 StartAsyncTrace(label, name, taskId, -1); in StartAsyncTraceArgs()
257 void StartAsyncTraceArgsDebug(bool isDebug, uint64_t label, int32_t taskId, const char *fmt, ...) in StartAsyncTraceArgsDebug() argument
272 StartAsyncTrace(label, name, taskId, -1); in StartAsyncTraceArgsDebug()
275 void FinishAsyncTrace(uint64_t label, const string& value, int32_t taskId) in FinishAsyncTrace() argument
278 AddHitraceMeterMarker(MARKER_ASYNC_END, label, traceName, std::to_string(taskId)); in FinishAsyncTrace()
[all …]
/base/security/device_auth/services/frameworks/src/module/
Ddev_auth_module_manager.c174 int32_t ProcessTask(int taskId, const CJson *in, CJson *out, int32_t *status, int moduleType) in ProcessTask() argument
190 int32_t res = module->processTask(taskId, in, out, status); in ProcessTask()
193 LOGE("Process task failed, taskId: %d, moduleType: %d, res: %d.", taskId, moduleType, res); in ProcessTask()
201 LOGI("Process task success, taskId: %d, moduleType: %d.", taskId, moduleType); in ProcessTask()
205 int32_t CreateTask(int32_t *taskId, const CJson *in, CJson *out, int moduleType) in CreateTask() argument
207 if (in == NULL || out == NULL || taskId == NULL) { in CreateTask()
220 int32_t res = module->createTask(taskId, in, out); in CreateTask()
222 LOGE("Create task failed, taskId: %d, moduleType: %d, res: %d.", *taskId, moduleType, res); in CreateTask()
225 LOGI("Create task success, taskId: %d, moduleType: %d.", *taskId, moduleType); in CreateTask()
229 void DestroyTask(int taskId, int moduleType) in DestroyTask() argument
[all …]
/base/hiviewdfx/hitrace/interfaces/native/innerkits/include/hitrace_meter/
Dhitrace_meter.h121 void StartAsyncTrace(uint64_t label, const std::string& value, int32_t taskId, float limit = -1);
122 void StartAsyncTraceDebug(bool isDebug, uint64_t label, const std::string& value, int32_t taskId, f…
123 void StartAsyncTraceArgs(uint64_t label, int32_t taskId, const char *fmt, ...);
124 void StartAsyncTraceArgsDebug(bool isDebug, uint64_t label, int32_t taskId, const char *fmt, ...);
129 void FinishAsyncTrace(uint64_t label, const std::string& value, int32_t taskId);
130 void FinishAsyncTraceDebug(bool isDebug, uint64_t label, const std::string& value, int32_t taskId);
131 void FinishAsyncTraceArgs(uint64_t label, int32_t taskId, const char *fmt, ...);
132 void FinishAsyncTraceArgsDebug(bool isDebug, uint64_t label, int32_t taskId, const char *fmt, ...);
/base/security/device_auth/services/authenticators/inc/account_related/
Daccount_multi_task_manager.h28 AccountTask *(*getTaskFromManager)(int32_t taskId);
29 void (*deleteTaskFromManager)(int32_t taskId);
Daccount_task_main.h30 int32_t taskId; member
41 AccountTask *CreateAccountTaskT(int32_t *taskId, const CJson *in, CJson *out);
/base/useriam/user_auth_framework/frameworks/native/common/dfx/src/
Diam_hitrace_helper.cpp39 static std::atomic<int32_t> taskId(0); in GetHiTraceTaskId() local
40 return taskId++; in GetHiTraceTaskId()
/base/security/device_auth/services/frameworks/inc/module/
Ddev_auth_module_manager.h44 int32_t CreateTask(int32_t *taskId, const CJson *in, CJson *out, int moduleType);
45 int32_t ProcessTask(int taskId, const CJson *in, CJson *out, int32_t *status, int moduleType);
46 void DestroyTask(int taskId, int moduleType);
/base/inputmethod/imf/services/dfx/include/
Dinputmethod_trace.h28 void StartAsync(uint64_t label, const std::string& value, int32_t taskId);
29 void FinishAsync(uint64_t label, const std::string &value, int32_t taskId);
/base/security/device_auth/services/authenticators/inc/account_unrelated/
Ddas_task_main.h27 int taskId; member
34 Task *CreateTaskT(int32_t *taskId, const CJson *in, CJson *out);
/base/hiviewdfx/hitrace/interfaces/js/kits/napi/hitracemeter/
Dnapi_hitrace_meter.cpp138 int taskId = 0; in JSTraceStart() local
139 if (!ParseInt32Param(env, argv[SECOND_ARG_INDEX], taskId)) { in JSTraceStart()
142 StartAsyncTrace(HITRACE_TAG_APP, name, taskId); in JSTraceStart()
154 int taskId = 0; in JSTraceFinish() local
155 if (!ParseInt32Param(env, nValue, taskId)) { in JSTraceFinish()
158 FinishAsyncTrace(HITRACE_TAG_APP, name, taskId); in JSTraceFinish()

12