Home
last modified time | relevance | path

Searched refs:MQueueId (Results 1 – 9 of 9) sorted by relevance

/ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr/adapter/cmsis/
H A Dqueue_adapter.c20 MQueueId QUEUE_Create(const char *name, int size, int count) in QUEUE_Create()
23 return (MQueueId)osMessageQueueNew(count, size, &queueAttr); in QUEUE_Create()
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/systemabilitymgr/samgr_lite/samgr/adapter/
H A Dqueue_adapter.h27 MQueueId QUEUE_Create(const char *name, int size, int count);
29 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/systemabilitymgr/samgr_lite/samgr/adapter/posix/
H A Dqueue_adapter.c29 MQueueId QUEUE_Create(const char *name, int size, int count) in QUEUE_Create()
43 return (MQueueId)queue; in QUEUE_Create()
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/systemabilitymgr/samgr_lite/samgr/source/
H A Dtask_manager.c46 MQueueId queueId = (MQueueId)QUEUE_Create(name, sizeof(Exchange), config->queueSize); in SAMGR_CreateFixedTaskPool()
129 uint32 msgRcvRet = SAMGR_MsgRecv((MQueueId)argv, (uint8 *)&exchange, sizeof(Exchange)); in TaskEntry()
147 QUEUE_Destroy((MQueueId)argv); in TaskEntry()
208 MQueueId SAMGR_GetCurrentQueueID() in SAMGR_GetCurrentQueueID()
210 return (MQueueId)THREAD_GetThreadLocal(); in SAMGR_GetCurrentQueueID()
H A Dtask_manager.h39 MQueueId queueId;
51 MQueueId SAMGR_GetCurrentQueueID(void);
H A Dmessage.c30 static int32 SharedSend(MQueueId queueId, Exchange *exchange, int initRef);
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 Dmessage_inner.h47 int32 SAMGR_MsgRecv(MQueueId queueId, uint8 *interMsg, uint32 size);
/ohos5.0/foundation/systemabilitymgr/samgr_lite/interfaces/kits/samgr/
H A Dcommon.h54 typedef void *MQueueId; typedef
H A Dmessage.h83 MQueueId queueId;