Home
last modified time | relevance | path

Searched refs:QueueTask (Results 1 – 23 of 23) sorted by relevance

/ohos5.0/foundation/resourceschedule/ffrt/src/queue/
H A Dbase_queue.h29 class QueueTask; variable
44 virtual int Push(QueueTask* task) = 0;
45 virtual QueueTask* Pull() = 0;
50 virtual int Remove(const QueueTask* task);
84 void Stop(std::multimap<uint64_t, QueueTask*>& whenMap);
85 void Remove(std::multimap<uint64_t, QueueTask*>& whenMap);
86 int Remove(const QueueTask* task, std::multimap<uint64_t, QueueTask*>& whenMap);
87 int Remove(const char* name, std::multimap<uint64_t, QueueTask*>& whenMap);
88 bool HasTask(const char* name, std::multimap<uint64_t, QueueTask*> whenMap);
93 std::multimap<uint64_t, QueueTask*> whenMap_;
[all …]
H A Dqueue_handler.h29 class QueueTask; variable
41 int Cancel(QueueTask* task);
42 void Dispatch(QueueTask* inTask);
43 void Submit(QueueTask* task);
44 void TransferTask(QueueTask* task);
51 QueueTask* PickUpTask();
102 void SetTimeoutMonitor(QueueTask* task);
103 void RunTimeOutCallback(QueueTask* task);
109 void AddSchedDeadline(QueueTask* task);
110 void RemoveSchedDeadline(QueueTask* task);
[all …]
H A Dqueue_api.cpp31 QueueTask* cbTask = GetQueueTaskByFuncStorageOffset(p->timeoutCb_); in ResetTimeoutCb()
43 QueueTask* task = GetQueueTaskByFuncStorageOffset(f); in ffrt_queue_submit_base()
44 new (task)ffrt::QueueTask(handler, p, insertHead); in ffrt_queue_submit_base()
113 QueueTask* task = GetQueueTaskByFuncStorageOffset(f);
114 new (task)ffrt::QueueTask(nullptr);
167 QueueTask* task = ffrt_queue_submit_base(queue, f, false, false, attr);
175 QueueTask* task = ffrt_queue_submit_base(queue, f, false, true, attr);
183 QueueTask* task = ffrt_queue_submit_base(queue, f, true, false, attr);
192 QueueTask* task = ffrt_queue_submit_base(queue, f, true, true, attr);
201 QueueTask* task = static_cast<QueueTask*>(handle);
[all …]
H A Deventhandler_adapter_queue.h37 HistoryTask(uint64_t beginTime, QueueTask* task) in HistoryTask()
52 int Push(QueueTask* task) override;
53 QueueTask* Pull() override;
66 int Remove(const QueueTask* task) override in Remove()
81 void SetCurrentRunningTask(QueueTask* task);
82 void PushHistoryTask(QueueTask* task, uint64_t triggerTime, uint64_t completeTime);
H A Dbase_queue.cpp34 void ClearWhenMap(std::multimap<uint64_t, ffrt::QueueTask*>& whenMap, ffrt::condition_variable& con… in ClearWhenMap()
58 void BaseQueue::Stop(std::multimap<uint64_t, QueueTask*>& whenMap) in Stop()
70 void BaseQueue::Remove(std::multimap<uint64_t, QueueTask*>& whenMap) in Remove()
84 int BaseQueue::Remove(const char* name, std::multimap<uint64_t, QueueTask*>& whenMap) in Remove()
104 int BaseQueue::Remove(const QueueTask* task) in Remove()
110 int BaseQueue::Remove(const QueueTask* task, std::multimap<uint64_t, QueueTask*>& whenMap) in Remove()
131 bool BaseQueue::HasTask(const char* name, std::multimap<uint64_t, QueueTask*> whenMap) in HasTask()
H A Dqueue_handler.cpp113 QueueTask* QueueHandler::PickUpTask() in PickUpTask()
119 void QueueHandler::Submit(QueueTask* task) in Submit()
200 int QueueHandler::Cancel(QueueTask* task) in Cancel()
221 void QueueHandler::Dispatch(QueueTask* inTask) in Dispatch()
223 QueueTask* nextTask = nullptr; in Dispatch()
271 QueueTask* task = queue_->Pull(); in Deliver()
279 void QueueHandler::TransferTask(QueueTask* task) in TransferTask()
298 new (initTask)ffrt::QueueTask(this); in TransferInitTask()
303 void QueueHandler::SetTimeoutMonitor(QueueTask* task) in SetTimeoutMonitor()
338 void QueueHandler::RunTimeOutCallback(QueueTask* task) in RunTimeOutCallback()
[all …]
H A Deventhandler_adapter_queue.cpp63 const std::multimap<uint64_t, ffrt::QueueTask*>& whenMap, std::ostringstream& oss) in DumpUnexecutedTaskInfo()
73 std::multimap<ffrt_inner_queue_priority_t, ffrt::QueueTask*> priorityMap; in DumpUnexecutedTaskInfo()
78 auto taskDumpFun = [&](int n, ffrt::QueueTask* task) { in DumpUnexecutedTaskInfo()
108 dequeFunc_ = QueueStrategy<QueueTask>::DequeSingleAgainstStarvation; in EventHandlerAdapterQueue()
118 int EventHandlerAdapterQueue::Push(QueueTask* task) in Push()
130 std::multimap<uint64_t, QueueTask*> tmpWhenMap {{0, task}}; in Push()
143 QueueTask* EventHandlerAdapterQueue::Pull() in Pull()
196 void EventHandlerAdapterQueue::SetCurrentRunningTask(QueueTask* task) in SetCurrentRunningTask()
201 void EventHandlerAdapterQueue::PushHistoryTask(QueueTask* task, uint64_t triggerTime, uint64_t comp… in PushHistoryTask()
H A Dconcurrent_queue.h26 dequeFunc_ = QueueStrategy<QueueTask>::DequeSingleByPriority;
30 int Push(QueueTask* task) override;
31 QueueTask* Pull() override;
61 int PushDelayTaskToTimer(QueueTask* task);
H A Dserial_queue.h25 dequeFunc_ = QueueStrategy<QueueTask>::DequeBatch; in SerialQueue()
29 int Push(QueueTask* task) override;
30 QueueTask* Pull() override;
H A Deventhandler_interactive_queue.h28 int Push(QueueTask* task) override;
30 QueueTask* Pull() override in Pull()
45 int Remove(const QueueTask* task) override in Remove()
H A Dconcurrent_queue.cpp25 static_cast<QueueTask*>(task)->Execute(); in DelayTaskCb()
33 int ConcurrentQueue::Push(QueueTask* task) in Push()
70 QueueTask* ConcurrentQueue::Pull() in Pull()
134 int ConcurrentQueue::PushDelayTaskToTimer(QueueTask* task) in PushDelayTaskToTimer()
H A Dserial_queue.cpp26 int SerialQueue::Push(QueueTask* task) in Push()
59 QueueTask* SerialQueue::Pull() in Pull()
H A Deventhandler_interactive_queue.cpp25 int EventHandlerInteractiveQueue::Push(QueueTask* task) in Push()
/ohos5.0/foundation/resourceschedule/ffrt/src/tm/
H A Dqueue_task.cpp25 QueueTask::QueueTask(QueueHandler* handler, const task_attr_private* attr, bool insertHead) in QueueTask() function in ffrt::QueueTask
58 QueueTask::~QueueTask() in ~QueueTask()
63 void QueueTask::Destroy() in Destroy()
72 void QueueTask::Notify() in Notify()
82 void QueueTask::Execute() in Execute()
94 void QueueTask::Wait() in Wait()
103 void QueueTask::FreeMem() in FreeMem()
105 SimpleAllocator<QueueTask>::FreeMem(this); in FreeMem()
108 uint32_t QueueTask::GetQueueId() const in GetQueueId()
H A Dqueue_task.h26 …(reinterpret_cast<QueueTask*>(static_cast<uintptr_t>(static_cast<size_t>(reinterpret_cast<uintptr_…
27 (reinterpret_cast<size_t>(&((reinterpret_cast<QueueTask*>(0))->func_storage))))))
30 class QueueTask : public CoTask {
32 …explicit QueueTask(QueueHandler* handler, const task_attr_private* attr = nullptr, bool insertHead…
33 ~QueueTask() override;
72 inline QueueTask* GetNextTask() const in GetNextTask()
77 inline void SetNextTask(QueueTask* task) in SetNextTask()
118 QueueTask* nextTask_ = nullptr;
/ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/
H A Ddeferred_callback.h30 class QueueTask : public IntroduceInterfaces<ITaskQueueTask> {
31 …META_INTERFACE(IntroduceInterfaces<ITaskQueueTask>, QueueTask, "426c3d10-89e5-4cf7-a314-a5155ede15…
34 QueueTask(Func func) : func_(BASE_NS::move(func)) {} in QueueTask() function
83 …q->AddTask(ITaskQueueTask::Ptr(new QueueTask([control = BASE_NS::weak_ptr(control_), args...]() mu… in Invoke()
/ohos5.0/foundation/resourceschedule/ffrt/src/dfx/bbox/
H A Dbbox.cpp212 std::lock_guard lk(SimpleAllocator<QueueTask>::Instance()->lock); in SaveQueueTaskStatus()
213 auto unfreeQueueTask = SimpleAllocator<QueueTask>::getUnfreedMem(); in SaveQueueTaskStatus()
214 auto applyqueue = [&](const char* tag, const std::function<bool(QueueTask*)>& filter) { in SaveQueueTaskStatus()
215 std::vector<QueueTask*> tmp; in SaveQueueTaskStatus()
217 auto t = reinterpret_cast<QueueTask*>(task); in SaveQueueTaskStatus()
240 applyqueue("queue task blocked by synchronization primitive(mutex etc)", [](QueueTask* t) { in SaveQueueTaskStatus()
617 std::lock_guard lk(SimpleAllocator<QueueTask>::Instance()->lock); in SaveQueueTaskStatusInfo()
618 auto unfreeQueueTask = SimpleAllocator<QueueTask>::getUnfreedMem(); in SaveQueueTaskStatusInfo()
619 auto applyqueue = [&](const char* tag, const std::function<bool(QueueTask*)>& filter) { in SaveQueueTaskStatusInfo()
620 std::vector<QueueTask*> tmp; in SaveQueueTaskStatusInfo()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/eu/
H A Dco_routine.cpp236 QueueTask* sTask = reinterpret_cast<QueueTask*>(task); in CoStartEntry()
505 QueueTask* sTask = reinterpret_cast<QueueTask*>(task); in CoWake()
H A Dcpu_worker.cpp59 QueueTask* sTask = reinterpret_cast<QueueTask*>(task); in Run()
/ohos5.0/foundation/resourceschedule/ffrt/src/core/
H A Dtask.cpp275 return ffrt::SimpleAllocator<ffrt::QueueTask>::AllocMem()->func_storage;
516 return reinterpret_cast<ffrt::QueueTask*>(curTask)->GetHandler()->GetExecTaskId();
531 ffrt::QueueTask* task = reinterpret_cast<ffrt::QueueTask*>(curTask);
/ohos5.0/foundation/graphic/graphic_3d/lume/Lume_3D/src/gltf/
H A Dgltf2_importer.cpp3026 QueueTask(move(task)); in PrepareBufferTasks()
3058 QueueTask(move(task)); in PrepareSamplerTasks()
3121 QueueTask(move(task)); in QueueImage()
3184 QueueTask(move(task)); in PrepareImageTasks()
3245 QueueTask(move(task)); in PrepareImageBasedLightTasks()
3290 QueueTask(move(task)); in PrepareMaterialTasks()
3354 QueueTask(move(task)); in PrepareMeshTasks()
3379 QueueTask(move(task)); in PrepareAnimationInputTask()
3407 QueueTask(move(task)); in PrepareAnimationOutputTask()
3452 QueueTask(move(task)); in PrepareAnimationTasks()
[all …]
H A Dgltf2_importer.h140 void QueueTask(BASE_NS::unique_ptr<ImporterTask>&& task);
/ohos5.0/foundation/resourceschedule/ffrt/src/dm/
H A Dsdependence_manager.cpp37 SimpleAllocator<QueueTask>::Instance(); in SDependenceManager()