Lines Matching refs:personal

287     /* find the personal and remove */
305 /* free the personal */
312 STATIC struct mqpersonal *MqGetPrivDataBuff(mqd_t personal)
314 INT32 sysFd = (INT32)personal;
350 STATIC VOID MqFreeSysFd(mqd_t personal)
352 INT32 sysFd = (INT32)personal;
367 /* Get the personal sysFd and reset personal fd -1 */
561 /* there are no more mq sysFd to use, close the personal */
572 int mq_close(mqd_t personal)
579 /* Get the personal sysFd and reset personal fd -1 */
580 privateMqPersonal = MqGetPrivDataBuff(personal);
599 MqFreeSysFd(personal);
606 int OsMqGetAttr(mqd_t personal, struct mq_attr *mqAttr)
612 privateMqPersonal = MqGetPrivDataBuff(personal);
639 int OsMqSetAttr(mqd_t personal, const struct mq_attr *mqSetAttr, struct mq_attr *mqOldAttr)
644 privateMqPersonal = MqGetPrivDataBuff(personal);
663 (VOID)OsMqGetAttr(personal, mqOldAttr);
733 STATIC INLINE BOOL MqParamCheck(mqd_t personal, const char *msg, size_t msgLen)
735 if (personal < 0) {
785 int mq_timedsend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio,
793 OS_MQ_GOTO_ERROUT_IF(!MqParamCheck(personal, msg, msgLen), errno);
797 privateMqPersonal = MqGetPrivDataBuff(personal);
827 ssize_t mq_timedreceive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio,
836 if (!MqParamCheck(personal, msg, msgLen)) {
845 privateMqPersonal = MqGetPrivDataBuff(personal);
884 int mq_send(mqd_t personal, const char *msg_ptr, size_t msg_len, unsigned int msg_prio)
886 return mq_timedsend(personal, msg_ptr, msg_len, msg_prio, NULL);
889 ssize_t mq_receive(mqd_t personal, char *msg_ptr, size_t msg_len, unsigned int *msg_prio)
891 return mq_timedreceive(personal, msg_ptr, msg_len, msg_prio, NULL);
894 STATIC INLINE BOOL MqNotifyParamCheck(mqd_t personal, const struct sigevent *sigev)
896 if (personal < 0) {
917 int OsMqNotify(mqd_t personal, const struct sigevent *sigev)
923 if (!MqNotifyParamCheck(personal, sigev)) {
928 privateMqPersonal = MqGetPrivDataBuff(personal);