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);
668 	mqueue_zone = uma_zcreate("mqueue", sizeof(struct mqueue),  in mqfs_init()
991 	struct mqueue *mq;  in mqfs_create()
1344 	struct mqueue *mq;  in mqfs_read()
1590 static struct mqueue *
1593 	struct mqueue *mq;  in mqueue_alloc()
1617 mqueue_free(struct mqueue *mq)  in mqueue_free()
1689 mqueue_send(struct mqueue *mq, const char *msg_ptr,  in mqueue_send()
1757 _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg, int timo)  in _mqueue_send()
1813 mqueue_send_notification(struct mqueue *mq)  in mqueue_send_notification()
1844 mqueue_receive(struct mqueue *mq, char *msg_ptr,  in mqueue_receive()
1914 _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg, int timo)  in _mqueue_recv()
1990 notifier_remove(struct proc *p, struct mqueue *mq, int fd)  in notifier_remove()
2014 	struct mqueue *mq;  in kern_kmq_open()
2179        struct file **fpp, struct mqfs_node **ppn, struct mqueue **pmq)  in _getmq()
2201 	struct mqueue **pmq)  in getmq()
2210 	 struct mqfs_node **ppn, struct mqueue **pmq)  in getmq_read()
2219 	struct mqfs_node **ppn, struct mqueue **pmq)  in getmq_write()
2230 	struct mqueue *mq;  in kern_kmq_setattr()
2281 	struct mqueue *mq;  in kern_kmq_timedreceive()
2318 	struct mqueue *mq;  in kern_kmq_timedsend()
2356 	struct mqueue *mq;  in kern_kmq_notify()
2474 	struct mqueue *mq;  in mqueue_fdclose()
2505 	struct mqueue *mq;  in mq_proc_exit()
2527 	struct mqueue *mq = FPTOMQ(fp);  in mqf_poll()
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()