| /src/sys/kern/ |
| sys_mqueue.c | 92 .fo_name = "mq",
122 mqueue_t *mq; local in function:mq_listener_cb
130 mq = arg1;
132 if (kauth_cred_geteuid(cred) == mq->mq_euid)
223 mqueue_destroy(struct mqueue *mq)
231 while ((msg = TAILQ_FIRST(&mq->mq_head[i])) != NULL) {
232 TAILQ_REMOVE(&mq->mq_head[i], msg, msg_queue);
237 if (mq->mq_name) {
238 kmem_free(mq->mq_name, MQ_NAMELEN);
240 seldestroy(&mq->mq_rsel)
256 mqueue_t *mq; local in function:mqueue_lookup
279 mqueue_t *mq; local in function:mqueue_get
325 struct mqueue *mq = fp->f_mqueue; local in function:mq_stat_fop
346 struct mqueue *mq = fp->f_mqueue; local in function:mq_poll_fop
375 mqueue_t *mq = fp->f_mqueue; local in function:mq_close_fop
418 mqueue_t *mq; local in function:mqueue_create
482 struct mqueue *mq, *mq_new = NULL; local in function:mq_handle_open
633 struct mqueue *mq; local in function:mq_recv1
787 struct mqueue *mq; local in function:mq_send1
959 struct mqueue *mq; local in function:sys_mq_notify
1006 struct mqueue *mq; local in function:sys_mq_getattr
1030 struct mqueue *mq; local in function:sys_mq_setattr
1077 mqueue_t *mq; local in function:sys_mq_unlink
1203 struct mqueue *mq; local in function:mqueue_print_list
[all...] |
| /src/sys/compat/linux/common/ |
| linux_mqueue.c | 192 struct mqueue *mq; local in function:linux_sys_mq_notify
207 error = mqueue_get((mqd_t)SCARG(uap, mqdes), 0, &mq);
212 if (mq->mq_notify_proc == NULL) {
213 memcpy(&mq->mq_sig_notify, &sig,
215 mq->mq_notify_proc = l->l_proc;
222 mq->mq_notify_proc = NULL;
224 mutex_exit(&mq->mq_mtx);
242 struct mqueue *mq; local in function:linux_sys_mq_getattr
245 error = mqueue_get((mqd_t)SCARG(uap, mqdes), 0, &mq);
248 memcpy(&attr, &mq->mq_attrib, sizeof(struct mq_attr))
268 struct mqueue *mq; local in function:linux_sys_mq_setattr
[all...] |
| /src/lib/libc/compat/sys/ |
| compat_mqueue.c | 63 mq_timedreceive(mqd_t mq, char * __restrict name, size_t len,
72 return __mq_timedreceive50(mq, name, len, buf, tsp);
76 mq_timedsend(mqd_t mq, const char *name, size_t len,
85 return __mq_timedsend50(mq, name, len, buf, tsp);
|
| /src/sys/compat/netbsd32/ |
| netbsd32_mqueue.c | 108 struct mqueue *mq; local in function:netbsd32_mq_getattr
113 error = mqueue_get(SCARG(uap, mqdes), 0, &mq);
117 memcpy(&attr, &mq->mq_attrib, sizeof(struct mq_attr));
118 mutex_exit(&mq->mq_mtx);
133 struct mqueue *mq; local in function:netbsd32_mq_setattr
144 error = mqueue_get(SCARG(uap, mqdes), 0, &mq);
150 memcpy(&attr, &mq->mq_attrib, sizeof(struct mq_attr));
154 mq->mq_attrib.mq_flags |= O_NONBLOCK;
156 mq->mq_attrib.mq_flags &= ~O_NONBLOCK;
158 mutex_exit(&mq->mq_mtx)
183 struct mqueue *mq; local in function:netbsd32_mq_notify
[all...] |
| /src/sys/external/gpl2/dts/dist/arch/riscv/boot/dts/allwinner/ |
| Makefile | 9 dtb-$(CONFIG_ARCH_SUNXI) += sun20i-d1-mangopi-mq-pro.dtb
11 dtb-$(CONFIG_ARCH_SUNXI) += sun20i-d1s-mangopi-mq.dtb
|
| sun20i-d1s-mangopi-mq.dts | 13 model = "MangoPi MQ";
14 compatible = "widora,mangopi-mq", "allwinner,sun20i-d1s";
|
| sun20i-d1-mangopi-mq-pro.dts | 13 model = "MangoPi MQ Pro";
14 compatible = "widora,mangopi-mq-pro", "allwinner,sun20i-d1";
|
| /src/lib/librt/ |
| Makefile | 16 mq.3 mq_close.3 mq_getattr.3 mq_notify.3 mq_open.3 mq_receive.3 \
22 MLINKS+= mq.3 mqueue.3
|
| /src/tests/lib/libpthread/ |
| t_compat_cancel.c | 151 mqd_t mq; local in function:cancelpoint_compat50_mq_timedreceive
155 RL(mq = mq_open("mq", O_RDWR|O_CREAT, 0666, NULL));
157 RL(mq_timedreceive(mq, buf, sizeof(buf), NULL, &t));
163 mqd_t mq; local in function:cancelpoint_compat50_mq_timedsend
167 RL(mq = mq_open("mq", O_RDWR|O_CREAT, 0666, NULL));
169 RL(mq_timedsend(mq, buf, sizeof(buf), 0, &t));
|
| t_cancellation.c | 344 mqd_t mq; local in function:cancelpoint_mq_receive
347 RL(mq = mq_open("mq", O_RDWR|O_CREAT, 0666, NULL));
349 RL(mq_receive(mq, buf, sizeof(buf), NULL));
355 mqd_t mq; local in function:cancelpoint_mq_send
358 RL(mq = mq_open("mq", O_RDWR|O_CREAT, 0666, NULL));
360 RL(mq_send(mq, buf, sizeof(buf), 0));
366 mqd_t mq; local in function:cancelpoint_mq_timedreceive
370 RL(mq = mq_open("mq", O_RDWR|O_CREAT, 0666, NULL))
378 mqd_t mq; local in function:cancelpoint_mq_timedsend
[all...] |
| /src/sys/arch/powerpc/include/ |
| frame.h | 80 int mq; member in struct:utrapframe
172 int mq; member in struct:utrapframe32
|
| db_machdep.h | 57 u_int32_t mq; member in struct:powerpc_saved_state
|
| /src/usr.bin/fstat/ |
| misc.c | 204 struct mqueue mq; local in function:p_mqueue
206 if (!KVM_READ(f->f_data, &mq, sizeof(mq))) {
210 (void)printf("* mqueue \"%s\"", mq.mq_name);
|
| /src/sys/arch/powerpc/powerpc/ |
| compat_13_machdep.c | 106 tf->tf_mq = sc.sc_frame.mq;
|
| compat_16_machdep.c | 140 utf->mq = tf->tf_mq;
264 tf->tf_mq = utf->mq;
|
| db_trace.c | 118 { "mq", (long *)&ddb_regs.mq, FCN_NULL, NULL },
314 (*pr)(" mq=%#x", R(&tf->tf_mq));
|
| db_interface.c | 242 DDB_REGS->mq = tf->tf_mq;
283 tf->tf_mq = DDB_REGS->mq;
|
| /src/sys/nfs/ |
| nfs_subs.c | 808 nfsm_uiotombuf(struct uio *uiop, struct mbuf **mq, int siz, char **bpos)
827 mp = mp2 = *mq;
878 *mq = mp;
|
| /src/sys/dev/pci/ |
| if_vioif.c | 108 "b\x16" "MQ\0" \
2488 struct virtio_net_ctrl_mq *mq = sc->sc_ctrlq.ctrlq_mq; local in function:vioif_ctrl_mq_vq_pairs_set
2500 mq->virtqueue_pairs = virtio_rw16(sc->sc_virtio, nvq_pairs);
2502 specs[0].buf = mq;
2503 specs[0].bufsize = sizeof(*mq);
|
| if_mcx.c | 6933 struct mcx_cq_entry *cqe, struct mcx_mbufq *mq,
6994 MBUFQ_ENQUEUE(mq, m);
7056 struct mcx_mbufq mq; local in function:mcx_process_cq
7060 MBUFQ_INIT(&mq);
7079 rxfree += mcx_process_rx(sc, rx, cqe, &mq, c);
7102 while (MBUFQ_FIRST(&mq) != NULL) {
7103 MBUFQ_DEQUEUE(&mq, m);
|
