Lines Matching refs:msg_prio
197 unsigned int msg_prio; member
259 size_t msg_len, unsigned msg_prio, int waitok,
262 size_t msg_len, unsigned *msg_prio, int waitok,
1643 mqueue_loadmsg(const char *msg_ptr, size_t msg_size, int msg_prio) in mqueue_loadmsg() argument
1658 msg->msg_prio = msg_prio; in mqueue_loadmsg()
1667 mqueue_savemsg(struct mqueue_msg *msg, char *msg_ptr, int *msg_prio) in mqueue_savemsg() argument
1673 if (error == 0 && msg_prio != NULL) in mqueue_savemsg()
1674 error = copyout(&msg->msg_prio, msg_prio, sizeof(int)); in mqueue_savemsg()
1694 size_t msg_len, unsigned msg_prio, int waitok, in mqueue_send() argument
1702 if (msg_prio >= MQ_PRIO_MAX) in mqueue_send()
1706 msg = mqueue_loadmsg(msg_ptr, msg_len, msg_prio); in mqueue_send()
1787 if (msg->msg_prio <= TAILQ_LAST(&mq->mq_msgq, msgq)->msg_prio) { in _mqueue_send()
1791 if (msg2->msg_prio < msg->msg_prio) in _mqueue_send()
1849 size_t msg_len, unsigned *msg_prio, int waitok, in mqueue_receive() argument
1905 error = mqueue_savemsg(msg, msg_ptr, msg_prio); in mqueue_receive()
2285 uap->msg_prio, waitok, abs_timeout); in sys_kmq_timedreceive()
2312 uap->msg_prio, waitok, abs_timeout); in sys_kmq_timedsend()
2810 uap->msg_prio, waitok, abs_timeout); in freebsd32_kmq_timedsend()
2841 uap->msg_prio, waitok, abs_timeout); in freebsd32_kmq_timedreceive()