sys/kern/uipc_mqueue.c

31  * 1) A mqueue filesystem can be mounted, each message queue appears
42  *    use the IPC facility without having to mount mqueue file system.
67 #include <sys/mqueue.h>
149 #define VTOMQ(vp) 	((struct mqueue *)(VTON(vp)->mn_data))
151 #define	FPTOMQ(fp)	((struct mqueue *)(((struct mqfs_node *) \
156 struct mqueue;
165 struct mqueue {
190 static SYSCTL_NODE(_kern, OID_AUTO, mqueue, CTLFLAG_RW, 0,
209 static MALLOC_DEFINE(M_MQUEUEDATA, "mqdata", "mqueue data");
242 static struct mqueue	*mqueue_alloc(const struct mq_attr *attr);
243 static void	mqueue_free(struct mqueue *mq);
244 static int	mqueue_send(struct mqueue *mq, const char *msg_ptr,
247 static int	mqueue_receive(struct mqueue *mq, char *msg_ptr,
250 static int	_mqueue_send(struct mqueue *mq, struct mqueue_msg *msg,
252 static int	_mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg,
254 static void	mqueue_send_notification(struct mqueue *mq);
590 	vfs_mountedfrom(mp, "mqueue");
649 	mqueue_zone = uma_zcreate("mqueue", sizeof(struct mqueue),
741 	error = getnewvnode("mqueue", mp, &mqfs_vnodeops, &newvpp);
964 	struct mqueue *mq;
1321 	struct mqueue *mq;
1528 static struct mqueue *
1531 	struct mqueue *mq;
1544 	mtx_init(&mq->mq_mutex, "mqueue lock", NULL, MTX_DEF);
1555 mqueue_free(struct mqueue *mq)
1627 mqueue_send(struct mqueue *mq, const char *msg_ptr,
1696 _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg, int timo)
1752 mqueue_send_notification(struct mqueue *mq)
1783 mqueue_receive(struct mqueue *mq, char *msg_ptr,
1854 _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg, int timo)
1930 notifier_remove(struct proc *p, struct mqueue *mq, int fd)
1954 	struct mqueue *mq;
2096        struct file **fpp, struct mqfs_node **ppn, struct mqueue **pmq)
2118 	struct mqueue **pmq)
2128 	 struct mqfs_node **ppn, struct mqueue **pmq)
2138 	struct mqfs_node **ppn, struct mqueue **pmq)
2150 	struct mqueue *mq;
2199 	struct mqueue *mq;
2225 	struct mqueue *mq;
2255 	struct mqueue *mq;
2374 	struct mqueue *mq;
2402 	struct mqueue *mq;
2453 	struct mqueue *mq = FPTOMQ(fp);
2558 	struct mqueue *mq = FPTOMQ(fp);
2575 	struct mqueue *mq = FPTOMQ(kn->kn_fp);
2588 	struct mqueue *mq = FPTOMQ(kn->kn_fp);
2597 	struct mqueue *mq = FPTOMQ(kn->kn_fp);
2739 	struct mqueue *mq;
2769 	struct mqueue *mq;