HomeSort by: relevance | last modified time | path
    Searched refs:mq (Results 1 - 25 of 34) sorted by relevancy

1 2

  /src/external/bsd/jemalloc/dist/test/include/test/
mq.h 17 * bool mq_init(mq_t *mq);
18 * void mq_fini(mq_t *mq);
19 * unsigned mq_count(mq_t *mq);
20 * mq_msg_t *mq_tryget(mq_t *mq);
21 * mq_msg_t *mq_get(mq_t *mq);
22 * void mq_put(mq_t *mq, mq_msg_t *msg);
38 a_prefix##init(a_mq_type *mq) { \
40 if (mtx_init(&mq->lock)) { \
43 ql_new(&mq->msgs); \
44 mq->count = 0;
    [all...]
  /src/external/bsd/jemalloc.old/dist/test/include/test/
mq.h 17 * bool mq_init(mq_t *mq);
18 * void mq_fini(mq_t *mq);
19 * unsigned mq_count(mq_t *mq);
20 * mq_msg_t *mq_tryget(mq_t *mq);
21 * mq_msg_t *mq_get(mq_t *mq);
22 * void mq_put(mq_t *mq, mq_msg_t *msg);
38 a_prefix##init(a_mq_type *mq) { \
40 if (mtx_init(&mq->lock)) { \
43 ql_new(&mq->msgs); \
44 mq->count = 0;
    [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");
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.old/dist/test/unit/
mq.c 13 mq_t mq; local
16 assert_false(mq_init(&mq), "Unexpected mq_init() failure");
17 assert_u_eq(mq_count(&mq), 0, "mq should be empty");
18 assert_ptr_null(mq_tryget(&mq),
21 mq_put(&mq, &msg);
22 assert_u_eq(mq_count(&mq), 1, "mq should contain one message");
23 assert_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/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/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/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
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/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
  /src/external/bsd/unbound/dist/dnstap/
dtstream.h 253 * @param mq: message queue.
255 void dt_msg_queue_delete(struct dt_msg_queue* mq);
261 * @param mq: message queue.
269 void dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len);
300 * @param mq: message queue to register.
304 struct dt_msg_queue* mq);
309 * @param mq: message queue.
312 struct dt_msg_queue* mq);
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/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
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/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/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));
  /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/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/gpl3/gcc.old/dist/libphobos/libdruntime/core/sys/darwin/mach/
thread_act.d 269 uint mq; /// MQ register (601 only)
  /src/external/gpl3/binutils/dist/gprofng/src/
Emsg.cc 487 Emsgqueue::appendqueue (Emsgqueue* mq)
489 Emsg *m = mq->first;
  /src/external/gpl3/binutils.old/dist/gprofng/src/
Emsg.cc 487 Emsgqueue::appendqueue (Emsgqueue* mq)
489 Emsg *m = mq->first;

Completed in 52 milliseconds

1 2