Lines Matching refs:taskId
43 static constexpr char TASKID_STR[] = "taskId";
61 void StoreTask(uint64_t taskId, Task* task);
62 void RemoveTask(uint64_t taskId);
63 Task* GetTask(uint64_t taskId);
64 void EnqueueTaskId(uint64_t taskId, Priority priority = Priority::DEFAULT);
65 void EraseWaitingTaskId(uint64_t taskId, Priority priority);
67 void CancelTask(napi_env env, uint64_t taskId);
101 std::shared_ptr<CallbackInfo> GetCallbackInfo(uint64_t taskId);
102 void RegisterCallback(napi_env env, uint64_t taskId, std::shared_ptr<CallbackInfo> callbackInfo);
103 void IncreaseRefCount(uint64_t taskId);
104 void DecreaseRefCount(napi_env env, uint64_t taskId);
110 bool IsDependendByTaskId(uint64_t taskId);
112 void NotifyDependencyTaskInfo(uint64_t taskId);
113 void RemoveDependencyById(uint64_t dependentTaskId, uint64_t taskId);
114 bool StoreTaskDependency(uint64_t taskId, std::set<uint64_t> taskIdSet);
115 bool RemoveTaskDependency(uint64_t taskId, uint64_t dependentId);
116 bool CheckCircularDependency(std::set<uint64_t> dependentIdSet, std::set<uint64_t> idSet, uint64_t taskId);
117 void EnqueuePendingTaskInfo(uint64_t taskId, Priority priority);
118 std::pair<uint64_t, Priority> DequeuePendingTaskInfo(uint64_t taskId);
119 void RemovePendingTaskInfo(uint64_t taskId);
120 void StoreDependentTaskInfo(std::set<uint64_t> dependTaskIdSet, uint64_t taskId);
121 void RemoveDependentTaskInfo(uint64_t dependentTaskId, uint64_t taskId);
122 std::string GetTaskDependInfoToString(uint64_t taskId);
127 void StoreTaskDuration(uint64_t taskId, uint64_t totalDuration, uint64_t cpuDuration);
128 uint64_t GetTaskDuration(uint64_t taskId, std::string durationType);
129 void RemoveTaskDuration(uint64_t taskId);
130 void StoreLongTaskInfo(uint64_t taskId, Worker* worker);
131 void RemoveLongTaskInfo(uint64_t taskId);
132 void TerminateTask(uint64_t taskId);
133 Worker* GetLongTaskInfo(uint64_t taskId);
148 bool CheckTask(uint64_t taskId);
179 // <taskId, Task>
183 // <taskId, <dependent taskId1, dependent taskId2, ...>>, update when removeDependency or executeTask
187 // <dependent taskId, <taskId1, taskId2, ...>>, update when removeDependency or executeTask
251 void AddTask(uint64_t groupId, napi_ref taskRef, uint64_t taskId);
256 void CancelGroupTask(napi_env env, uint64_t taskId, TaskGroup* group);