Lines Matching refs:msg_prio
194 unsigned int msg_prio; member
256 size_t msg_len, unsigned msg_prio, int waitok,
259 size_t msg_len, unsigned *msg_prio, int waitok,
1635 mqueue_loadmsg(const char *msg_ptr, size_t msg_size, int msg_prio) in mqueue_loadmsg() argument
1650 msg->msg_prio = msg_prio; in mqueue_loadmsg()
1659 mqueue_savemsg(struct mqueue_msg *msg, char *msg_ptr, int *msg_prio) in mqueue_savemsg() argument
1665 if (error == 0 && msg_prio != NULL) in mqueue_savemsg()
1666 error = copyout(&msg->msg_prio, msg_prio, sizeof(int)); in mqueue_savemsg()
1686 size_t msg_len, unsigned msg_prio, int waitok, in mqueue_send() argument
1694 if (msg_prio >= MQ_PRIO_MAX) in mqueue_send()
1698 msg = mqueue_loadmsg(msg_ptr, msg_len, msg_prio); in mqueue_send()
1779 if (msg->msg_prio <= TAILQ_LAST(&mq->mq_msgq, msgq)->msg_prio) { in _mqueue_send()
1783 if (msg2->msg_prio < msg->msg_prio) in _mqueue_send()
1841 size_t msg_len, unsigned *msg_prio, int waitok, in mqueue_receive() argument
1897 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()
2812 uap->msg_prio, waitok, abs_timeout); in freebsd32_kmq_timedsend()
2843 uap->msg_prio, waitok, abs_timeout); in freebsd32_kmq_timedreceive()