| /ohos5.0/foundation/arkui/ace_engine_lite/frameworks/native_engine/async/ |
| H A D | message_queue_utils.cpp | 59 osMessageQueueId_t queueId = osMessageQueueNew(capacity, msgSize, nullptr); in CreateMessageQueue() local
74 osMessageQueueId_t queueId = static_cast<osMessageQueueId_t>(handler); in DeleteMessageQueue() local
96 osMessageQueueId_t queueId = static_cast<osMessageQueueId_t>(handler); in PutMessage() local
122 osMessageQueueId_t queueId = static_cast<osMessageQueueId_t>(handler); in GetMessage() local
|
| /ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr/adapter/cmsis/ |
| H A D | queue_adapter.c | 26 int QUEUE_Put(MQueueId queueId, const void *element, uint8 pri, int timeout) in QUEUE_Put()
36 int QUEUE_Pop(MQueueId queueId, void *element, uint8 *pri, int timeout) in QUEUE_Pop()
46 int QUEUE_Destroy(MQueueId queueId) in QUEUE_Destroy()
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/queue/ |
| H A D | queue_monitor.cpp | 68 void QueueMonitor::RegisterQueueId(uint32_t queueId, QueueHandler* queueStruct) in RegisterQueueId()
94 void QueueMonitor::ResetQueueInfo(uint32_t queueId) in ResetQueueInfo()
103 void QueueMonitor::ResetQueueStruct(uint32_t queueId) in ResetQueueStruct()
111 void QueueMonitor::UpdateQueueInfo(uint32_t queueId, const uint64_t &taskId) in UpdateQueueInfo()
123 uint64_t QueueMonitor::QueryQueueStatus(uint32_t queueId) in QueryQueueStatus()
145 void QueueMonitor::ResetTaskTimestampAfterWarning(uint32_t queueId, const uint64_t &taskId) in ResetTaskTimestampAfterWarning()
|
| H A D | queue_strategy.h | 31 static T* DequeBatch(const uint32_t queueId, const uint64_t now, in DequeBatch()
55 static T* DequeSingleByPriority(const uint32_t queueId, in DequeSingleByPriority()
77 static T* DequeSingleAgainstStarvation(const uint32_t queueId, in DequeSingleAgainstStarvation()
|
| H A D | concurrent_queue.cpp | 92 uint32_t queueId = queueId_; in Pull() local
|
| H A D | base_queue.cpp | 50 std::atomic_uint32_t BaseQueue::queueId(1); member in ffrt::BaseQueue
|
| /ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| H A D | queue_adapter.c | 46 int QUEUE_Put(MQueueId queueId, const void *element, uint8 pri, int timeout) in QUEUE_Put()
61 int QUEUE_Pop(MQueueId queueId, void *element, uint8 *pri, int timeout) in QUEUE_Pop()
76 int QUEUE_Destroy(MQueueId queueId) in QUEUE_Destroy()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/ |
| H A D | btm_thread.c | 137 static BtmProcessingQueue *FindProcessingQueueById(uint8_t queueId) in FindProcessingQueueById()
186 int BTM_CreateProcessingQueue(uint8_t queueId, uint16_t size) in BTM_CreateProcessingQueue()
203 int BTM_DeleteProcessingQueue(uint8_t queueId) in BTM_DeleteProcessingQueue()
229 int BTM_RunTaskInProcessingQueue(uint8_t queueId, void (*task)(void *context), void *context) in BTM_RunTaskInProcessingQueue()
|
| /ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr/source/ |
| H A D | message.c | 87 int32 SAMGR_MsgRecv(MQueueId queueId, uint8 *interMsg, uint32 size) in SAMGR_MsgRecv()
180 static int32 SharedSend(MQueueId queueId, Exchange *exchange, int initRef) in SharedSend()
|
| H A D | task_manager.h | 39 MQueueId queueId; member
|
| H A D | task_manager.c | 46 MQueueId queueId = (MQueueId)QUEUE_Create(name, sizeof(Exchange), config->queueSize); in SAMGR_CreateFixedTaskPool() local
|
| /ohos5.0/base/telephony/core_service/utils/common/src/ |
| H A D | tel_event_queue.cpp | 119 void TelEventQueue::SubmitInner(int32_t queueId) in SubmitInner()
146 void TelEventQueue::SubmitToFFRT(int32_t queueId, AppExecFwk::InnerEvent::TimePoint handleTime, int… in SubmitToFFRT()
230 AppExecFwk::InnerEvent::Pointer TelEventQueue::PopEvent(int32_t queueId, bool &isNeedSubmit) in PopEvent()
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/src/ |
| H A D | startable_object_controller.cpp | 293 void StartableObjectController::RunTasks(const BASE_NS::Uid& queueId) in RunTasks()
324 bool StartableObjectController::ProcessOps(const BASE_NS::Uid& queueId) in ProcessOps()
350 …tartableObjectController::AddOperation(StartableOperation&& operation, const BASE_NS::Uid& queueId) in AddOperation()
420 bool StartableObjectController::SetTickableQueueuId(const BASE_NS::Uid& queueId) in SetTickableQueueuId()
|
| H A D | object_registry.cpp | 535 bool ObjectRegistry::RegisterTaskQueue(const ITaskQueue::Ptr& queue, const BASE_NS::Uid& queueId) in RegisterTaskQueue()
550 bool ObjectRegistry::UnregisterTaskQueue(const BASE_NS::Uid& queueId) in UnregisterTaskQueue()
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/ |
| H A D | timer.h | 187 …ITaskQueue::Token SingleShotTimer(const TimeSpan& interval, Func func, const BASE_NS::Uid& queueId) in SingleShotTimer()
|
| /ohos5.0/foundation/systemabilitymgr/samgr_lite/interfaces/kits/samgr/ |
| H A D | message.h | 83 MQueueId queueId; member
|