Lines Matching refs:mqueue

161 #define VTOMQ(vp) 	((struct mqueue *)(VTON(vp)->mn_data))
163 #define FPTOMQ(fp) ((struct mqueue *)(((struct mqfs_node *) \
168 struct mqueue;
177 struct mqueue { struct
202 static SYSCTL_NODE(_kern, OID_AUTO, mqueue, CTLFLAG_RW | CTLFLAG_MPSAFE, 0, argument
256 static struct mqueue *mqueue_alloc(const struct mq_attr *attr);
257 static void mqueue_free(struct mqueue *mq);
258 static int mqueue_send(struct mqueue *mq, const char *msg_ptr,
261 static int mqueue_receive(struct mqueue *mq, char *msg_ptr,
264 static int _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg,
266 static int _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg,
268 static void mqueue_send_notification(struct mqueue *mq);
667 mqueue_zone = uma_zcreate("mqueue", sizeof(struct mqueue), in mqfs_init()
990 struct mqueue *mq; in mqfs_create()
1345 struct mqueue *mq; in mqfs_read()
1596 static struct mqueue *
1599 struct mqueue *mq; in mqueue_alloc()
1623 mqueue_free(struct mqueue *mq) in mqueue_free()
1695 mqueue_send(struct mqueue *mq, const char *msg_ptr, in mqueue_send()
1763 _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg, int timo) in _mqueue_send()
1819 mqueue_send_notification(struct mqueue *mq) in mqueue_send_notification()
1850 mqueue_receive(struct mqueue *mq, char *msg_ptr, in mqueue_receive()
1920 _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg, int timo) in _mqueue_recv()
1996 notifier_remove(struct proc *p, struct mqueue *mq, int fd) in notifier_remove()
2020 struct mqueue *mq; in kern_kmq_open()
2175 struct file **fpp, struct mqfs_node **ppn, struct mqueue **pmq) in _getmq()
2197 struct mqueue **pmq) in getmq()
2206 struct mqfs_node **ppn, struct mqueue **pmq) in getmq_read()
2215 struct mqfs_node **ppn, struct mqueue **pmq) in getmq_write()
2226 struct mqueue *mq; in kern_kmq_setattr()
2276 struct mqueue *mq; in sys_kmq_timedreceive()
2304 struct mqueue *mq; in sys_kmq_timedsend()
2333 struct mqueue *mq; in kern_kmq_notify()
2451 struct mqueue *mq; in mqueue_fdclose()
2482 struct mqueue *mq; in mq_proc_exit()
2504 struct mqueue *mq = FPTOMQ(fp); in mqf_poll()
2609 struct mqueue *mq = FPTOMQ(fp); in mqf_kqfilter()
2626 struct mqueue *mq = FPTOMQ(kn->kn_fp); in filt_mqdetach()
2639 struct mqueue *mq = FPTOMQ(kn->kn_fp); in filt_mqread()
2648 struct mqueue *mq = FPTOMQ(kn->kn_fp); in filt_mqwrite()
2800 struct mqueue *mq; in freebsd32_kmq_timedsend()
2832 struct mqueue *mq; in freebsd32_kmq_timedreceive()