Home
last modified time | relevance | path

Searched refs:queueId (Results 1 – 25 of 46) sorted by relevance

12

/ohos5.0/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_monitor.cpp71 if (queueId == queuesRunningInfo_.size()) { in RegisterQueueId()
80 if (queueId > queuesRunningInfo_.size()) { in RegisterQueueId()
86 queuesStructInfo_[queueId] = queueStruct; in RegisterQueueId()
88 if (queuesStructInfo_[queueId] == nullptr) { in RegisterQueueId()
89 queuesStructInfo_[queueId] = queueStruct; in RegisterQueueId()
94 void QueueMonitor::ResetQueueInfo(uint32_t queueId) in ResetQueueInfo() argument
100 lastReportedTask_[queueId] = INVALID_TASK_ID; in ResetQueueInfo()
103 void QueueMonitor::ResetQueueStruct(uint32_t queueId) in ResetQueueStruct() argument
108 queuesStructInfo_[queueId] = nullptr; in ResetQueueStruct()
117 queuesRunningInfo_[queueId] = {taskId, now}; in UpdateQueueInfo()
[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
51 head->gid, node->gid, whenMap.size(), queueId); in DequeBatch()
55 static T* DequeSingleByPriority(const uint32_t queueId, in DequeSingleByPriority() argument
73 …RT_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 …RT_LOGD("dequeue [gid=%llu], %u other tasks in [queueId=%u] ", head->gid, whenMap.size(), queueId); in DequeSingleAgainstStarvation()
H A Dbase_queue.h41 explicit BaseQueue() : queueId_(queueId++) {} in BaseQueue()
100 static std::atomic_uint32_t queueId;
H A Dconcurrent_queue.cpp92 uint32_t queueId = queueId_; in Pull() local
94 FFRT_LOGD("concurrency[%d] - 1 [queueId=%u] switch into inactive", oldValue, queueId); in Pull()
/ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr/source/
H A Dmessage.c40 exchange.id.queueId = NULL; in SAMGR_SendRequest()
42 exchange.id.queueId = SAMGR_GetCurrentQueueID(); in SAMGR_SendRequest()
73 if (exchange->id.queueId == NULL) { in SAMGR_SendResponse()
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 = NULL; in SAMGR_SendSharedRequest()
154 exchange.id.queueId = NULL; in SAMGR_SendSharedDirectRequest()
155 int32 err = SharedSend(id->queueId, &exchange, 0); in SAMGR_SendSharedDirectRequest()
175 exchange->id.queueId = id->queueId; in SAMGR_SendResponseByIdentity()
185 return QUEUE_Put(queueId, exchange, 0, DONT_WAIT); in SharedSend()
[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 …y id = {impl->serviceId, INVALID_INDEX, (impl->taskPool != NULL) ? impl->taskPool->queueId : NULL}; in DEFAULT_Initialize()
120 …ervice->serviceId, INVALID_INDEX, (service->taskPool != NULL) ? service->taskPool->queueId : NULL}; in DEFAULT_StopService()
153 identity.queueId = serviceImpl->taskPool->queueId; in DEFAULT_GetFeatureId()
/ohos5.0/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()
/ohos5.0/foundation/arkui/ace_engine_lite/frameworks/native_engine/async/
H A Dmessage_queue_utils.cpp59 osMessageQueueId_t queueId = osMessageQueueNew(capacity, msgSize, nullptr); in CreateMessageQueue() local
60 return static_cast<QueueHandler>(queueId); in CreateMessageQueue()
74 osMessageQueueId_t queueId = static_cast<osMessageQueueId_t>(handler); in DeleteMessageQueue() local
75 if (osMessageQueueDelete(queueId) != osOK) { in DeleteMessageQueue()
96 osMessageQueueId_t queueId = static_cast<osMessageQueueId_t>(handler); in PutMessage() local
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() local
123 if (osMessageQueueGet(queueId, msgPtr, 0, timeOut) != osOK) { in GetMessage()
/ohos5.0/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()
234 BtmProcessingQueue *queue = FindProcessingQueueById(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);
/ohos5.0/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()
/ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/
H A Devent_handler.h65 …t<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) in META_BEGIN_NAMESPACE()
67 Subscribe(event, func, queueId); in META_BEGIN_NAMESPACE()
85 …t<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) in META_BEGIN_NAMESPACE()
87 Subscribe(event, BASE_NS::move(func), queueId); in META_BEGIN_NAMESPACE()
145 …t<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) in META_BEGIN_NAMESPACE()
147 auto queue = GetTaskQueueRegistry().GetTaskQueue(queueId); in META_BEGIN_NAMESPACE()
150 BASE_NS::to_string(queueId).c_str()); in META_BEGIN_NAMESPACE()
170 bool Subscribe(const Event<EventType>& event, Func func, const BASE_NS::Uid& queueId) in META_BEGIN_NAMESPACE()
172 return Subscribe(event, MakeCallback<EventType>(BASE_NS::move(func)), queueId); in META_BEGIN_NAMESPACE()
191 bool Subscribe(const BASE_NS::shared_ptr<IEvent>& event, Func func, const BASE_NS::Uid& queueId) in META_BEGIN_NAMESPACE()
[all …]
H A Dtimer.h58 Timer(const TimeSpan& interval, Func func, TimerType type, const BASE_NS::Uid& queueId) in META_BEGIN_NAMESPACE()
60 Start(interval, BASE_NS::move(func), type, queueId); in META_BEGIN_NAMESPACE()
112 bool Start(const TimeSpan& interval, Func func, TimerType type, const BASE_NS::Uid& queueId) in META_BEGIN_NAMESPACE()
114 … return Start(interval, BASE_NS::move(func), type, GetTaskQueueRegistry().GetTaskQueue(queueId)); in META_BEGIN_NAMESPACE()
187 …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()
/ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/src/
H A Dstartable_object_controller.cpp287 if (auto it = operations_.find(queueId); it != operations_.end()) { in HasTasks()
293 void StartableObjectController::RunTasks(const BASE_NS::Uid& queueId) in RunTasks() argument
324 bool StartableObjectController::ProcessOps(const BASE_NS::Uid& queueId) in ProcessOps() argument
326 if (!HasTasks(queueId)) { 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()
359 auto& ops = operations_[queueId]; in AddOperation()
370 return ProcessOps(queueId); in AddOperation()
422 if (queueId != tickQueueId_) { in SetTickableQueueuId()
[all …]
H A Dstartable_object_controller.h39 virtual void RunTasks(const BASE_NS::Uid& queueId) = 0; in META_BEGIN_NAMESPACE()
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).dat… 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) != queues_.end(); in HasTaskQueue()
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;
/ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/include/meta/interface/
H A Dintf_task_queue_registry.h44 virtual ITaskQueue::Ptr GetTaskQueue(const BASE_NS::Uid& queueId) const = 0;
54 virtual bool RegisterTaskQueue(const ITaskQueue::Ptr& queue, const BASE_NS::Uid& queueId) = 0;
60 virtual bool UnregisterTaskQueue(const BASE_NS::Uid& queueId) = 0;
66 virtual bool HasTaskQueue(const BASE_NS::Uid& queueId) const = 0;
/ohos5.0/base/telephony/core_service/utils/common/src/
H A Dtel_event_queue.cpp119 void TelEventQueue::SubmitInner(int32_t queueId) in SubmitInner() argument
135 SubmitToFFRT(queueId, handleTime, delayTime); in SubmitInner()
146 void TelEventQueue::SubmitToFFRT(int32_t queueId, AppExecFwk::InnerEvent::TimePoint handleTime, int… in SubmitToFFRT() argument
149 if (queueId != queueId_.load()) { in SubmitToFFRT()
156 [this, queueId = queueId]() { in SubmitToFFRT()
158 auto event = PopEvent(queueId, isNeedSubmit); in SubmitToFFRT()
172 SubmitInner(queueId); in SubmitToFFRT()
230 AppExecFwk::InnerEvent::Pointer TelEventQueue::PopEvent(int32_t queueId, bool &isNeedSubmit) in PopEvent() argument
233 if (IsEmpty() || queueId != queueId_.load()) { in PopEvent()
/ohos5.0/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);
/ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/property/
H A Dproperty_event_handler.h49 …const IProperty::ConstPtr& property, const CallableTypePtr& onInvoked, const BASE_NS::Uid& queueId) in META_BEGIN_NAMESPACE()
51 return handler_.Subscribe<EventType>((property.get()->*EventFunc)(), onInvoked, queueId); in META_BEGIN_NAMESPACE()
61 bool Subscribe(const IProperty::ConstPtr& property, Func func, const BASE_NS::Uid& queueId) in META_BEGIN_NAMESPACE()
63 …return handler_.Subscribe<EventType>((property.get()->*EventFunc)(), BASE_NS::move(func), queueId); in META_BEGIN_NAMESPACE()
H A Darray_property_event_handler.h60 bool Subscribe(const Property& property, Func func, const BASE_NS::Uid& queueId) in META_BEGIN_NAMESPACE()
66 queueId); in META_BEGIN_NAMESPACE()
/ohos5.0/base/telephony/core_service/utils/common/include/
H A Dtel_event_queue.h42 AppExecFwk::InnerEvent::Pointer PopEvent(int32_t queueId, bool &isNeedSubmit);
43 void SubmitInner(int32_t queueId);
49 …void SubmitToFFRT(int32_t queueId, AppExecFwk::InnerEvent::TimePoint handleTime, int64_t delayTime…

12