Home
last modified time | relevance | path

Searched defs:queueId (Results 1 – 9 of 9) sorted by relevance

/foundation/arkui/ace_engine_lite/frameworks/native_engine/async/
Dmessage_queue_utils.cpp59 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
/foundation/systemabilitymgr/samgr_lite/samgr/adapter/cmsis/
Dqueue_adapter.c26 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()
/foundation/resourceschedule/ffrt/src/queue/
Dqueue_monitor.cpp59 void QueueMonitor::RegisterQueueId(uint32_t queueId) in RegisterQueueId()
78 void QueueMonitor::ResetQueueInfo(uint32_t queueId) in ResetQueueInfo()
86 void QueueMonitor::UpdateQueueInfo(uint32_t queueId, const uint64_t &taskId) in UpdateQueueInfo()
111 void QueueMonitor::ResetTaskTimestampAfterWarning(uint32_t queueId, const uint64_t &taskId) in ResetTaskTimestampAfterWarning()
/foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/
Dqueue_adapter.c46 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()
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/
Dbtm_thread.c137 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()
/foundation/systemabilitymgr/samgr_lite/samgr/source/
Dmessage.c87 int32 SAMGR_MsgRecv(MQueueId queueId, uint8 *interMsg, uint32 size) in SAMGR_MsgRecv()
180 static int32 SharedSend(MQueueId queueId, Exchange *exchange, int initRef) in SharedSend()
Dtask_manager.h39 MQueueId queueId; member
Dtask_manager.c46 MQueueId queueId = (MQueueId)QUEUE_Create(name, sizeof(Exchange), config->queueSize); in SAMGR_CreateFixedTaskPool() local
/foundation/systemabilitymgr/samgr_lite/interfaces/kits/samgr/
Dmessage.h83 MQueueId queueId; member