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,
1642 mqueue_loadmsg(const char *msg_ptr, size_t msg_size, int msg_prio) in mqueue_loadmsg() argument
1657 msg->msg_prio = msg_prio; in mqueue_loadmsg()
1666 mqueue_savemsg(struct mqueue_msg *msg, char *msg_ptr, int *msg_prio) in mqueue_savemsg() argument
1672 if (error == 0 && msg_prio != NULL) in mqueue_savemsg()
1673 error = copyout(&msg->msg_prio, msg_prio, sizeof(int)); in mqueue_savemsg()
1693 size_t msg_len, unsigned msg_prio, int waitok, in mqueue_send() argument
1701 if (msg_prio >= MQ_PRIO_MAX) in mqueue_send()
1705 msg = mqueue_loadmsg(msg_ptr, msg_len, msg_prio); in mqueue_send()
1786 if (msg->msg_prio <= TAILQ_LAST(&mq->mq_msgq, msgq)->msg_prio) { in _mqueue_send()
1790 if (msg2->msg_prio < msg->msg_prio) in _mqueue_send()
1848 size_t msg_len, unsigned *msg_prio, int waitok, in mqueue_receive() argument
1904 error = mqueue_savemsg(msg, msg_ptr, msg_prio); in mqueue_receive()
2292 uap->msg_prio, waitok, abs_timeout); in sys_kmq_timedreceive()
2319 uap->msg_prio, waitok, abs_timeout); in sys_kmq_timedsend()
2819 uap->msg_prio, waitok, abs_timeout); in freebsd32_kmq_timedsend()
2850 uap->msg_prio, waitok, abs_timeout); in freebsd32_kmq_timedreceive()