Lines Matching refs:queueId
30 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 = NULL; in SAMGR_SendSharedRequest()
126 int32 err = SharedSend(identity->queueId, &exchange, 0); 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()
180 static int32 SharedSend(MQueueId queueId, Exchange *exchange, int initRef) in SharedSend() argument
185 return QUEUE_Put(queueId, exchange, 0, DONT_WAIT); in SharedSend()
201 return QUEUE_Put(queueId, exchange, 0, DONT_WAIT); in SharedSend()