133 #ifndef ti_ipc_MessageQ__include
134 #define ti_ipc_MessageQ__include
138 #if defined (__cplusplus)
150 #define MessageQ_S_BUSY 2
155 #define MessageQ_S_ALREADYSETUP 1
160 #define MessageQ_S_SUCCESS 0
165 #define MessageQ_E_FAIL -1
170 #define MessageQ_E_INVALIDARG -2
175 #define MessageQ_E_MEMORY -3
180 #define MessageQ_E_ALREADYEXISTS -4
185 #define MessageQ_E_NOTFOUND -5
190 #define MessageQ_E_TIMEOUT -6
195 #define MessageQ_E_INVALIDSTATE -7
200 #define MessageQ_E_OSFAILURE -8
205 #define MessageQ_E_RESOURCE -9
210 #define MessageQ_E_RESTART -10
215 #define MessageQ_E_INVALIDMSG -11
220 #define MessageQ_E_NOTOWNER -12
225 #define MessageQ_E_REMOTEACTIVE -13
230 #define MessageQ_E_INVALIDHEAPID -14
235 #define MessageQ_E_INVALIDPROCID -15
240 #define MessageQ_E_MAXREACHED -16
245 #define MessageQ_E_UNREGISTEREDHEAPID -17
250 #define MessageQ_E_CANNOTFREESTATICMSG -18
255 #define MessageQ_E_UNBLOCKED -19
265 #define MessageQ_FOREVER ~(0)
270 #define MessageQ_INVALIDMSGID 0xffff
275 #define MessageQ_INVALIDMESSAGEQ 0xffff
280 #define MessageQ_PRIORITYMASK 0x3
292 #define MessageQ_getDstQueue(msg) \
293 ((msg)->dstId == (MessageQ_QueueIndex)MessageQ_INVALIDMESSAGEQ) ? \
294 (MessageQ_QueueId)MessageQ_INVALIDMESSAGEQ : \
295 (MessageQ_QueueId)(((MessageQ_QueueId)MultiProc_self() << 16u) \
296 | (((MessageQ_Msg)(msg))->dstId))
313 #define MessageQ_getMsgId(msg) (((MessageQ_Msg) (msg))->msgId)
323 #define MessageQ_getMsgSize(msg) (((MessageQ_Msg) (msg))->msgSize)
332 #define MessageQ_getMsgPri(msg) \
333 ((((MessageQ_Msg) (msg))->flags & MessageQ_PRIORITYMASK))
345 #define MessageQ_getProcId(queueId) \
346 ((UInt16)((queueId) >> 16))
365 #define MessageQ_getReplyQueue(msg) \
366 (MessageQ_QueueId)((((MessageQ_Msg) (msg))->replyProc << 16u) \
367 | ((MessageQ_Msg)(msg))->replyId)
381 #define MessageQ_setMsgId(msg, id) ((MessageQ_Msg) (msg))->msgId = (id)
389 #define MessageQ_setMsgPri(msg, priority) \
390 (((MessageQ_Msg) (msg))->flags = ((priority) & MessageQ_PRIORITYMASK))
692 Int
MessageQ_get(MessageQ_Handle handle, MessageQ_Msg *msg, UInt timeout);
722 Int
MessageQ_put(MessageQ_QueueId queueId, MessageQ_Msg msg);
796 #if defined (__cplusplus)