| /src/external/bsd/jemalloc.old/dist/test/unit/ |
| mq.c | 13 mq_t mq; local
16 expect_false(mq_init(&mq), "Unexpected mq_init() failure");
17 expect_u_eq(mq_count(&mq), 0, "mq should be empty");
18 expect_ptr_null(mq_tryget(&mq),
21 mq_put(&mq, &msg);
22 expect_u_eq(mq_count(&mq), 1, "mq should contain one message");
23 expect_ptr_eq(mq_tryget(&mq), &msg, "mq_tryget() should return msg");
25 mq_put(&mq, &msg)
34 mq_t *mq = (mq_t *)arg; local
47 mq_t *mq = (mq_t *)arg; local
62 mq_t mq; local
[all...] |
| /src/external/bsd/jemalloc/dist/test/unit/ |
| mq.c | 13 mq_t mq; local
16 expect_false(mq_init(&mq), "Unexpected mq_init() failure");
17 expect_u_eq(mq_count(&mq), 0, "mq should be empty");
19 mq_tryget(&mq), "mq_tryget() should fail when the queue is empty");
21 mq_put(&mq, &msg);
22 expect_u_eq(mq_count(&mq), 1, "mq should contain one message");
23 expect_ptr_eq(mq_tryget(&mq), &msg, "mq_tryget() should return msg");
25 mq_put(&mq, &msg)
34 mq_t *mq = (mq_t *)arg; local
47 mq_t *mq = (mq_t *)arg; local
62 mq_t mq; local
[all...] |
| /src/sys/compat/linux/common/ |
| linux_mqueue.c | 192 struct mqueue *mq; local
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
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
[all...] |
| /src/sys/compat/netbsd32/ |
| netbsd32_mqueue.c | 108 struct mqueue *mq; local
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
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
[all...] |
| /src/tests/lib/libpthread/ |
| t_compat_cancel.c | 151 mqd_t mq; local
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
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
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
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
370 RL(mq = mq_open("mq", O_RDWR|O_CREAT, 0666, NULL))
378 mqd_t mq; local
[all...] |
| /src/usr.bin/fstat/ |
| misc.c | 204 struct mqueue mq; local
206 if (!KVM_READ(f->f_data, &mq, sizeof(mq))) {
210 (void)printf("* mqueue \"%s\"", mq.mq_name);
|
| /src/sys/arch/powerpc/include/ |
| db_machdep.h | 57 u_int32_t mq; member in struct:powerpc_saved_state
|
| frame.h | 80 int mq; member in struct:utrapframe
172 int mq; member in struct:utrapframe32
|
| /src/sys/kern/ |
| sys_mqueue.c | 92 .fo_name = "mq",
122 mqueue_t *mq; local
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
279 mqueue_t *mq; local
325 struct mqueue *mq = fp->f_mqueue; local
346 struct mqueue *mq = fp->f_mqueue; local
375 mqueue_t *mq = fp->f_mqueue; local
418 mqueue_t *mq; local
482 struct mqueue *mq, *mq_new = NULL; local
633 struct mqueue *mq; local
787 struct mqueue *mq; local
959 struct mqueue *mq; local
1006 struct mqueue *mq; local
1030 struct mqueue *mq; local
1077 mqueue_t *mq; local
1203 struct mqueue *mq; local
[all...] |
| /src/external/gpl3/gcc/dist/libgcc/config/rs6000/ |
| darwin-fallback.c | 284 uint32_t mq; member in struct:gcc_mcontext32
|
| /src/external/gpl3/gcc.old/dist/libgcc/config/rs6000/ |
| darwin-fallback.c | 284 uint32_t mq; member in struct:gcc_mcontext32
|
| /src/external/bsd/unbound/dist/dnstap/ |
| dtstream.c | 106 struct dt_msg_queue* mq = calloc(1, sizeof(*mq)); local
107 if(!mq) return NULL;
108 mq->maxsize = 1*1024*1024; /* set max size of buffer, per worker,
111 mq->wakeup_timer = comm_timer_create(base, mq_wakeup_cb, mq);
112 if(!mq->wakeup_timer) {
113 free(mq);
116 lock_basic_init(&mq->lock);
117 lock_protect(&mq->lock, mq, sizeof(*mq))
178 struct dt_msg_queue* mq = (struct dt_msg_queue*)arg; local
[all...] |
| /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
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
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);
|
| /src/external/gpl3/binutils/dist/gas/config/ |
| tc-tic6x.c | 1414 char *mq = q; local
1423 if (*mq == '*')
1424 mq++;
1430 skip_whitespace (mq);
1431 switch (*mq)
1434 if (mq[1] == '+')
1437 mq += 2;
1442 mq++;
1447 if (mq[1] == '-')
1450 mq += 2
[all...] |
| /src/external/gpl3/binutils.old/dist/gas/config/ |
| tc-tic6x.c | 1414 char *mq = q; local
1423 if (*mq == '*')
1424 mq++;
1430 skip_whitespace (mq);
1431 switch (*mq)
1434 if (mq[1] == '+')
1437 mq += 2;
1442 mq++;
1447 if (mq[1] == '-')
1450 mq += 2
[all...] |
| /src/external/apache2/llvm/dist/llvm/include/llvm/BinaryFormat/ |
| MachO.h | 1918 uint32_t mq; member in struct:llvm::MachO::ppc_thread_state32_t
1961 sys::swapByteOrder(x.mq);
|
