158 #define VTOMQ(vp) 	((struct mqueue *)(VTON(vp)->mn_data))
160 #define	FPTOMQ(fp)	((struct mqueue *)(((struct mqfs_node *) \
165 struct mqueue;
174 struct mqueue {  struct
199 static SYSCTL_NODE(_kern, OID_AUTO, mqueue, CTLFLAG_RW | CTLFLAG_MPSAFE, 0,  argument
257 static struct mqueue	*mqueue_alloc(const struct mq_attr *attr);
258 static void	mqueue_free(struct mqueue *mq);
259 static int	mqueue_send(struct mqueue *mq, const char *msg_ptr,
262 static int	mqueue_receive(struct mqueue *mq, char *msg_ptr,
265 static int	_mqueue_send(struct mqueue *mq, struct mqueue_msg *msg,
267 static int	_mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg,
269 static void	mqueue_send_notification(struct mqueue *mq);
669 	mqueue_zone = uma_zcreate("mqueue", sizeof(struct mqueue),  in mqfs_init()
992 	struct mqueue *mq;  in mqfs_create()
1345 	struct mqueue *mq;  in mqfs_read()
1591 static struct mqueue *
1594 	struct mqueue *mq;  in mqueue_alloc()
1618 mqueue_free(struct mqueue *mq)  in mqueue_free()
1690 mqueue_send(struct mqueue *mq, const char *msg_ptr,  in mqueue_send()
1758 _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg, int timo)  in _mqueue_send()
1814 mqueue_send_notification(struct mqueue *mq)  in mqueue_send_notification()
1845 mqueue_receive(struct mqueue *mq, char *msg_ptr,  in mqueue_receive()
1915 _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg, int timo)  in _mqueue_recv()
1991 notifier_remove(struct proc *p, struct mqueue *mq, int fd)  in notifier_remove()
2015 	struct mqueue *mq;  in kern_kmq_open()
2181        struct file **fpp, struct mqfs_node **ppn, struct mqueue **pmq)  in _getmq()
2203 	struct mqueue **pmq)  in getmq()
2212 	 struct mqfs_node **ppn, struct mqueue **pmq)  in getmq_read()
2221 	struct mqfs_node **ppn, struct mqueue **pmq)  in getmq_write()
2232 	struct mqueue *mq;  in kern_kmq_setattr()
2283 	struct mqueue *mq;  in kern_kmq_timedreceive()
2320 	struct mqueue *mq;  in kern_kmq_timedsend()
2358 	struct mqueue *mq;  in kern_kmq_notify()
2478 	struct mqueue *mq;  in mq_proc_exit()
2500 	struct mqueue *mq = FPTOMQ(fp);  in mqf_poll()
2541 	struct mqueue *mq;  in mqf_fdclose()
2631 	struct mqueue *mq = FPTOMQ(fp);  in mqf_kqfilter()
2648 	struct mqueue *mq = FPTOMQ(kn->kn_fp);  in filt_mqdetach()
2661 	struct mqueue *mq = FPTOMQ(kn->kn_fp);  in filt_mqread()
2670 	struct mqueue *mq = FPTOMQ(kn->kn_fp);  in filt_mqwrite()