Home
last modified time | relevance | path

Searched refs:queueId (Results 1 - 25 of 35) sorted by relevance

12

/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_monitor.cpp80 void QueueMonitor::RegisterQueueId(uint32_t queueId, QueueHandler* queueStruct) in RegisterQueueId() argument
83 if (queueId == queuesRunningInfo_.size()) { in RegisterQueueId()
87 FFRT_LOGD("queue registration in monitor gid=%u in turn succ", queueId); in RegisterQueueId()
92 if (queueId > queuesRunningInfo_.size()) { in RegisterQueueId()
93 for (uint32_t i = queuesRunningInfo_.size(); i <= queueId; ++i) { in RegisterQueueId()
98 queuesStructInfo_[queueId] = queueStruct; in RegisterQueueId()
100 if (queuesStructInfo_[queueId] == nullptr) { in RegisterQueueId()
101 queuesStructInfo_[queueId] = queueStruct; in RegisterQueueId()
103 FFRT_LOGD("queue registration in monitor gid=%u by skip succ", queueId); in RegisterQueueId()
106 void QueueMonitor::ResetQueueInfo(uint32_t queueId) in ResetQueueInfo() argument
115 ResetQueueStruct(uint32_t queueId) ResetQueueStruct() argument
123 UpdateQueueInfo(uint32_t queueId, const uint64_t &taskId) UpdateQueueInfo() argument
136 QueryQueueStatus(uint32_t queueId) QueryQueueStatus() argument
162 ResetTaskTimestampAfterWarning(uint32_t queueId, const uint64_t &taskId) ResetTaskTimestampAfterWarning() argument
[all...]
H A Dqueue_monitor.h27 void RegisterQueueId(uint32_t queueId, QueueHandler* queueStruct);
28 void ResetQueueInfo(uint32_t queueId);
29 void ResetQueueStruct(uint32_t queueId);
30 void UpdateQueueInfo(uint32_t queueId, const uint64_t &taskId);
31 uint64_t QueryQueueStatus(uint32_t queueId);
44 void ResetTaskTimestampAfterWarning(uint32_t queueId, const uint64_t &taskId);
H A Dqueue_strategy.h31 static T* DequeBatch(const uint32_t queueId, const uint64_t now, in DequeBatch() argument
50 FFRT_LOGD("dequeue [gid=%llu -> gid=%llu], %u other tasks in [queueId=%u] ", in DequeBatch()
51 head->gid, node->gid, whenMap.size(), queueId); in DequeBatch()
55 static T* DequeSingleByPriority(const uint32_t queueId, in DequeSingleByPriority() argument
73 FFRT_LOGD("dequeue [gid=%llu], %u other tasks in [queueId=%u] ", head->gid, whenMap.size(), queueId); in DequeSingleByPriority()
77 static T* DequeSingleAgainstStarvation(const uint32_t queueId, in DequeSingleAgainstStarvation() argument
106 FFRT_LOGD("dequeue [gid=%llu], %u other tasks in [queueId=%u] ", head->gid, whenMap.size(), queueId); in DequeSingleAgainstStarvation()
H A Dbase_queue.h42 explicit BaseQueue() : queueId_(queueId++) {} in BaseQueue()
103 static std::atomic_uint32_t queueId; member in ffrt::BaseQueue
/foundation/systemabilitymgr/samgr_lite/samgr/source/
H A Dmessage.c30 static int32 SharedSend(MQueueId queueId, Exchange *exchange, int initRef);
40 exchange.id.queueId = NULL; in SAMGR_SendRequest()
42 exchange.id.queueId = SAMGR_GetCurrentQueueID(); in SAMGR_SendRequest()
46 return QUEUE_Put(identity->queueId, &exchange, 0, DONT_WAIT); in SAMGR_SendRequest()
73 if (exchange->id.queueId == NULL) { in SAMGR_SendResponse()
79 int32 ret = SharedSend(exchange->id.queueId, exchange, 1); in SAMGR_SendResponse()
87 int32 SAMGR_MsgRecv(MQueueId queueId, uint8 *interMsg, uint32 size) in SAMGR_MsgRecv() argument
89 if (queueId == NULL || interMsg == NULL || size == 0) { in SAMGR_MsgRecv()
97 return QUEUE_Pop(queueId, interMsg, 0, WAIT_FOREVER); in SAMGR_MsgRecv()
125 exchange.id.queueId in SAMGR_SendSharedRequest()
180 SharedSend(MQueueId queueId, Exchange *exchange, int initRef) SharedSend() argument
[all...]
H A Dtask_manager.c46 MQueueId queueId = (MQueueId)QUEUE_Create(name, sizeof(Exchange), config->queueSize); in SAMGR_CreateFixedTaskPool() local
47 if (queueId == NULL) { in SAMGR_CreateFixedTaskPool()
55 QUEUE_Destroy(queueId); in SAMGR_CreateFixedTaskPool()
61 taskPool->queueId = queueId; in SAMGR_CreateFixedTaskPool()
82 register ThreadId threadId = (ThreadId)THREAD_Create(TaskEntry, pool->queueId, &attr); in SAMGR_StartTaskPool()
103 QUEUE_Put(pool->queueId, &exchange, 0, DONT_WAIT); in SAMGR_ReleaseTaskPool()
H A Dservice.c71 Identity id = {impl->serviceId, INVALID_INDEX, (impl->taskPool != NULL) ? impl->taskPool->queueId : NULL}; in DEFAULT_Initialize()
120 Identity id = {service->serviceId, INVALID_INDEX, (service->taskPool != NULL) ? service->taskPool->queueId : NULL}; in DEFAULT_StopService()
153 identity.queueId = serviceImpl->taskPool->queueId; in DEFAULT_GetFeatureId()
H A Dmessage_inner.h47 int32 SAMGR_MsgRecv(MQueueId queueId, uint8 *interMsg, uint32 size);
/foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/
H A Dqueue_adapter.c46 int QUEUE_Put(MQueueId queueId, const void *element, uint8 pri, int timeout) in QUEUE_Put() argument
48 if (queueId == NULL || element == NULL || timeout > 0) { in QUEUE_Put()
51 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; in QUEUE_Put()
61 int QUEUE_Pop(MQueueId queueId, void *element, uint8 *pri, int timeout) in QUEUE_Pop() argument
63 if (queueId == NULL || element == NULL || timeout > 0) { in QUEUE_Pop()
67 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; in QUEUE_Pop()
76 int QUEUE_Destroy(MQueueId queueId) in QUEUE_Destroy() argument
78 if (queueId == NULL) { in QUEUE_Destroy()
82 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; in QUEUE_Destroy()
/foundation/systemabilitymgr/samgr_lite/samgr/adapter/cmsis/
H A Dqueue_adapter.c26 int QUEUE_Put(MQueueId queueId, const void *element, uint8 pri, int timeout) in QUEUE_Put() argument
29 osStatus_t ret = osMessageQueuePut(queueId, element, pri, waitTime); in QUEUE_Put()
36 int QUEUE_Pop(MQueueId queueId, void *element, uint8 *pri, int timeout) in QUEUE_Pop() argument
39 osStatus_t evt = osMessageQueueGet(queueId, element, pri, waitTime); in QUEUE_Pop()
46 int QUEUE_Destroy(MQueueId queueId) in QUEUE_Destroy() argument
48 osStatus_t evt = osMessageQueueDelete(queueId); in QUEUE_Destroy()
/foundation/arkui/ace_engine_lite/frameworks/native_engine/async/
H A Dmessage_queue_utils.cpp59 osMessageQueueId_t queueId = osMessageQueueNew(capacity, msgSize, nullptr); in CreateMessageQueue()
60 return static_cast<QueueHandler>(queueId); in CreateMessageQueue()
74 osMessageQueueId_t queueId = static_cast<osMessageQueueId_t>(handler); in DeleteMessageQueue()
75 if (osMessageQueueDelete(queueId) != osOK) { in DeleteMessageQueue()
96 osMessageQueueId_t queueId = static_cast<osMessageQueueId_t>(handler); in PutMessage()
97 if (osMessageQueuePut(queueId, static_cast<void *>(&msg), 0, timeOut) != osOK) { in PutMessage()
98 uint32_t msgCount = osMessageQueueGetCount(queueId); in PutMessage()
122 osMessageQueueId_t queueId = static_cast<osMessageQueueId_t>(handler); in GetMessage()
123 if (osMessageQueueGet(queueId, msgPtr, 0, timeOut) != osOK) { in GetMessage()
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/
H A Devent_handler.h65 const Event<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) in EventHandler()
67 Subscribe(event, func, queueId); in EventHandler()
85 const Event<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) in EventHandler()
87 Subscribe(event, BASE_NS::move(func), queueId); in EventHandler()
140 * @param queueId Queue id where 'func' is invoked. Fails if no such queue exists.
145 const Event<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) in Subscribe()
147 auto queue = GetTaskQueueRegistry().GetTaskQueue(queueId); in Subscribe()
150 BASE_NS::to_string(queueId).c_str()); in Subscribe()
170 bool Subscribe(const Event<EventType>& event, Func func, const BASE_NS::Uid& queueId) in Subscribe() argument
172 return Subscribe(event, MakeCallback<EventType>(BASE_NS::move(func)), queueId); in Subscribe()
64 EventHandler( const Event<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) EventHandler() argument
84 EventHandler( const Event<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) EventHandler() argument
144 Subscribe( const Event<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) Subscribe() argument
191 Subscribe(const BASE_NS::shared_ptr<IEvent>& event, Func func, const BASE_NS::Uid& queueId) Subscribe() argument
[all...]
H A Dtimer.h58 Timer(const TimeSpan& interval, Func func, TimerType type, const BASE_NS::Uid& queueId) in Timer() argument
60 Start(interval, BASE_NS::move(func), type, queueId); in Timer()
108 * @param queueId Uid of queue to which the timer task is posted to (this dictates on what thread the func is
112 bool Start(const TimeSpan& interval, Func func, TimerType type, const BASE_NS::Uid& queueId) in Start() argument
114 return Start(interval, BASE_NS::move(func), type, GetTaskQueueRegistry().GetTaskQueue(queueId)); in Start()
184 * @param queueId Uid of queue to which the timer task is posted to (this dictates on what thread the func is called).
187 inline ITaskQueue::Token SingleShotTimer(const TimeSpan& interval, Func func, const BASE_NS::Uid& queueId) in SingleShotTimer() argument
190 t.Start(interval, BASE_NS::move(func), Timer::SINGLE_SHOT, queueId); in SingleShotTimer()
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/
H A Dbtm_thread.c137 static BtmProcessingQueue *FindProcessingQueueById(uint8_t queueId) in FindProcessingQueueById() argument
145 if (queue->id == queueId) { in FindProcessingQueueById()
186 int BTM_CreateProcessingQueue(uint8_t queueId, uint16_t size) in BTM_CreateProcessingQueue() argument
191 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); in BTM_CreateProcessingQueue()
195 queue = AllocProcessingQueue(queueId, size); in BTM_CreateProcessingQueue()
203 int BTM_DeleteProcessingQueue(uint8_t queueId) in BTM_DeleteProcessingQueue() argument
210 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); in BTM_DeleteProcessingQueue()
229 int BTM_RunTaskInProcessingQueue(uint8_t queueId, void (*task)(void *context), void *context) in BTM_RunTaskInProcessingQueue() argument
231 HILOGD("%{public}d ,start process queueId is ", queueId); in BTM_RunTaskInProcessingQueue()
[all...]
H A Dbtm_thread.h43 int BTM_CreateProcessingQueue(uint8_t queueId, uint16_t size);
45 int BTM_DeleteProcessingQueue(uint8_t queueId);
47 int BTM_RunTaskInProcessingQueue(uint8_t queueId, void (*task)(void *context), void *context);
/foundation/systemabilitymgr/samgr_lite/samgr/adapter/
H A Dqueue_adapter.h29 int QUEUE_Put(MQueueId queueId, const void *element, uint8 pri, int timeout);
31 int QUEUE_Pop(MQueueId queueId, void *element, uint8 *pri, int timeout);
33 int QUEUE_Destroy(MQueueId queueId);
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/interface/
H A Dintf_task_queue_registry.h41 * @param queueId The id of the queue to get.
44 virtual ITaskQueue::Ptr GetTaskQueue(const BASE_NS::Uid& queueId) const = 0;
48 * If queue = {} this call is equivalent to calling UnregisterTaskQueue(queueId).
49 * @param queueId Id to register the queue with.
54 virtual bool RegisterTaskQueue(const ITaskQueue::Ptr& queue, const BASE_NS::Uid& queueId) = 0;
57 * @param queueId Id of the task queue to unregister.
60 virtual bool UnregisterTaskQueue(const BASE_NS::Uid& queueId) = 0;
63 * @param queueId Id of the queue to check.
66 virtual bool HasTaskQueue(const BASE_NS::Uid& queueId) const = 0;
H A Dintf_tickable_controller.h58 * @param queueId The id of the task queue. if {}, a new thread should be created for ticking.
61 virtual bool SetTickableQueueuId(const BASE_NS::Uid& queueId) = 0;
/foundation/graphic/graphic_3d/lume/metaobject/src/
H A Dstartable_object_controller.cpp284 bool StartableObjectController::HasTasks(const BASE_NS::Uid& queueId) const in HasTasks()
287 if (auto it = operations_.find(queueId); it != operations_.end()) { in HasTasks()
293 void StartableObjectController::RunTasks(const BASE_NS::Uid& queueId) in RunTasks() argument
299 if (auto it = operations_.find(queueId); it != operations_.end()) { in RunTasks()
324 bool StartableObjectController::ProcessOps(const BASE_NS::Uid& queueId) in ProcessOps() argument
326 if (!HasTasks(queueId)) { in ProcessOps()
331 auto task = [queueId, internal = IStartableObjectControllerInternal::WeakPtr { in ProcessOps()
334 me->RunTasks(queueId); in ProcessOps()
338 if (queueId != BASE_NS::Uid {} && !executingStart_) { in ProcessOps()
339 if (auto queue = GetTaskQueueRegistry().GetTaskQueue(queueId)) { in ProcessOps()
350 AddOperation(StartableOperation&& operation, const BASE_NS::Uid& queueId) AddOperation() argument
420 SetTickableQueueuId(const BASE_NS::Uid& queueId) SetTickableQueueuId() argument
[all...]
H A Dstartable_object_controller.h37 * @brief Run tasks with given queueId.
39 virtual void RunTasks(const BASE_NS::Uid& queueId) = 0;
73 bool SetTickableQueueuId(const BASE_NS::Uid& queueId) override;
86 void RunTasks(const BASE_NS::Uid& queueId) override;
103 bool HasTasks(const BASE_NS::Uid& queueId) const;
104 bool ProcessOps(const BASE_NS::Uid& queueId);
H A Dobject_registry.cpp525 ITaskQueue::Ptr ObjectRegistry::GetTaskQueue(const BASE_NS::Uid& queueId) const in GetTaskQueue()
528 if (auto queue = queues_.find(queueId); queue != queues_.end()) { in GetTaskQueue()
531 CORE_LOG_W("Cannot get task queue, task queue not registered: %s", BASE_NS::to_string(queueId).data()); in GetTaskQueue()
535 bool ObjectRegistry::RegisterTaskQueue(const ITaskQueue::Ptr& queue, const BASE_NS::Uid& queueId) in RegisterTaskQueue() argument
539 if (auto existing = queues_.find(queueId); existing != queues_.end()) { in RegisterTaskQueue()
546 queues_[queueId] = queue; in RegisterTaskQueue()
550 bool ObjectRegistry::UnregisterTaskQueue(const BASE_NS::Uid& queueId) in UnregisterTaskQueue() argument
553 if (auto existing = queues_.find(queueId); existing != queues_.end()) { in UnregisterTaskQueue()
560 bool ObjectRegistry::HasTaskQueue(const BASE_NS::Uid& queueId) const in HasTaskQueue()
563 return queues_.find(queueId) ! in HasTaskQueue()
[all...]
H A Dobject_registry.h121 ITaskQueue::Ptr GetTaskQueue(const BASE_NS::Uid& queueId) const override;
122 bool RegisterTaskQueue(const ITaskQueue::Ptr& queue, const BASE_NS::Uid& queueId) override;
123 bool UnregisterTaskQueue(const BASE_NS::Uid& queueId) override;
124 bool HasTaskQueue(const BASE_NS::Uid& queueId) const override;
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/property/
H A Dproperty_event_handler.h49 bool Subscribe(const IProperty::ConstPtr& property, const CallableTypePtr& onInvoked, const BASE_NS::Uid& queueId) in Subscribe() argument
51 return handler_.Subscribe<EventType>((property.get()->*EventFunc)(), onInvoked, queueId); in Subscribe()
61 bool Subscribe(const IProperty::ConstPtr& property, Func func, const BASE_NS::Uid& queueId) in Subscribe() argument
63 return handler_.Subscribe<EventType>((property.get()->*EventFunc)(), BASE_NS::move(func), queueId); in Subscribe()
H A Darray_property_event_handler.h60 bool Subscribe(const Property& property, Func func, const BASE_NS::Uid& queueId)
66 queueId);
/foundation/graphic/graphic_3d/lume/metaobject/test/src/api/
H A DDeferredCallbackTest.cpp184 auto queueId = interface_cast<IObjectInstance>(q)->GetInstanceId(); in HWTEST_F() local
185 META_NS::GetTaskQueueRegistry().RegisterTaskQueue(q, queueId.ToUid()); in HWTEST_F()
188 p, [&] { ++count; }, queueId.ToUid()); in HWTEST_F()
196 META_NS::GetTaskQueueRegistry().UnregisterTaskQueue(queueId.ToUid()); in HWTEST_F()

Completed in 11 milliseconds

12