Home
last modified time | relevance | path

Searched refs:mq (Results 1 – 25 of 60) sorted by relevance

123

/netbsd/sys/kern/
H A Dsys_mqueue.c122 mqueue_t *mq; in mq_listener_cb() local
130 mq = arg1; in mq_listener_cb()
256 mqueue_t *mq; in mqueue_lookup() local
263 return mq; in mqueue_lookup()
279 mqueue_t *mq; in mqueue_get() local
297 *mqret = mq; in mqueue_get()
469 *mqret = mq; in mqueue_create()
525 if (mq) { in mq_handle_open()
558 mq->mq_atime = mq->mq_mtime = mq->mq_btime; in mq_handle_open()
1211 mq->mq_name, mq, mq->mq_mode, in mqueue_print_list()
[all …]
/netbsd/external/bsd/jemalloc/dist/test/include/test/
H A Dmq.h43 ql_new(&mq->msgs); \
44 mq->count = 0; \
49 mtx_fini(&mq->lock); \
55 mtx_lock(&mq->lock); \
56 count = mq->count; \
57 mtx_unlock(&mq->lock); \
64 mtx_lock(&mq->lock); \
68 mq->count--; \
70 mtx_unlock(&mq->lock); \
102 mtx_lock(&mq->lock); \
[all …]
/netbsd/external/bsd/jemalloc/dist/test/unit/
H A Dmq.c13 mq_t mq; in mq_gen() local
18 assert_ptr_null(mq_tryget(&mq), in mq_gen()
21 mq_put(&mq, &msg); in mq_gen()
25 mq_put(&mq, &msg); in mq_gen()
28 mq_fini(&mq); in mq_gen()
34 mq_t *mq = (mq_t *)arg; in thd_receiver_start() local
38 mq_msg_t *msg = mq_get(mq); in thd_receiver_start()
47 mq_t *mq = (mq_t *)arg; in thd_sender_start() local
56 mq_put(mq, msg); in thd_sender_start()
62 mq_t mq; in TEST_BEGIN() local
[all …]
/netbsd/external/bsd/unbound/dist/dnstap/
H A Ddtstream.c106 struct dt_msg_queue* mq = calloc(1, sizeof(*mq)); in dt_msg_queue_create() local
111 mq->wakeup_timer = comm_timer_create(base, mq_wakeup_cb, mq); in dt_msg_queue_create()
113 free(mq); in dt_msg_queue_create()
117 lock_protect(&mq->lock, mq, sizeof(*mq)); in dt_msg_queue_create()
118 return mq; in dt_msg_queue_create()
141 if(!mq) return; in dt_msg_queue_delete()
145 free(mq); in dt_msg_queue_delete()
245 if(!mq) { in dt_msg_queue_submit()
269 (mq->cursize < mq->maxsize * 9 / 10 && in dt_msg_queue_submit()
270 mq->cursize+len >= mq->maxsize * 9 / 10)) in dt_msg_queue_submit()
[all …]
H A Ddtstream.h255 void dt_msg_queue_delete(struct dt_msg_queue* mq);
269 void dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len);
304 struct dt_msg_queue* mq);
312 struct dt_msg_queue* mq);
/netbsd/sys/compat/netbsd32/
H A Dnetbsd32_mqueue.c108 struct mqueue *mq; in netbsd32_mq_getattr() local
118 mutex_exit(&mq->mq_mtx); in netbsd32_mq_getattr()
133 struct mqueue *mq; in netbsd32_mq_setattr() local
154 mq->mq_attrib.mq_flags |= O_NONBLOCK; in netbsd32_mq_setattr()
156 mq->mq_attrib.mq_flags &= ~O_NONBLOCK; in netbsd32_mq_setattr()
158 mutex_exit(&mq->mq_mtx); in netbsd32_mq_setattr()
183 struct mqueue *mq; in netbsd32_mq_notify() local
204 if (mq->mq_notify_proc == NULL) { in netbsd32_mq_notify()
206 mq->mq_notify_proc = l->l_proc; in netbsd32_mq_notify()
213 mq->mq_notify_proc = NULL; in netbsd32_mq_notify()
[all …]
/netbsd/lib/libc/compat/sys/
H A Dcompat_mqueue.c63 mq_timedreceive(mqd_t mq, char * __restrict name, size_t len, in __weak_alias()
72 return __mq_timedreceive50(mq, name, len, buf, tsp); in __weak_alias()
76 mq_timedsend(mqd_t mq, const char *name, size_t len, in mq_timedsend() argument
85 return __mq_timedsend50(mq, name, len, buf, tsp); in mq_timedsend()
/netbsd/external/gpl3/gdb/dist/gas/config/
H A Dtc-tic6x.c1427 mq++; in tic6x_parse_operand()
1440 mq += 2; in tic6x_parse_operand()
1445 mq++; in tic6x_parse_operand()
1453 mq += 2; in tic6x_parse_operand()
1458 mq++; in tic6x_parse_operand()
1476 if (mq[0] == '+' && mq[1] == '+') in tic6x_parse_operand()
1481 else if (mq[0] == '-' && mq[1] == '-') in tic6x_parse_operand()
1508 mq++; in tic6x_parse_operand()
1514 mq++; in tic6x_parse_operand()
1553 mq++; in tic6x_parse_operand()
[all …]
/netbsd/external/gpl3/binutils/dist/gas/config/
H A Dtc-tic6x.c1425 mq++; in tic6x_parse_operand()
1438 mq += 2; in tic6x_parse_operand()
1443 mq++; in tic6x_parse_operand()
1451 mq += 2; in tic6x_parse_operand()
1456 mq++; in tic6x_parse_operand()
1474 if (mq[0] == '+' && mq[1] == '+') in tic6x_parse_operand()
1479 else if (mq[0] == '-' && mq[1] == '-') in tic6x_parse_operand()
1506 mq++; in tic6x_parse_operand()
1512 mq++; in tic6x_parse_operand()
1551 mq++; in tic6x_parse_operand()
[all …]
/netbsd/external/gpl3/binutils.old/dist/gas/config/
H A Dtc-tic6x.c1430 mq++; in tic6x_parse_operand()
1443 mq += 2; in tic6x_parse_operand()
1448 mq++; in tic6x_parse_operand()
1456 mq += 2; in tic6x_parse_operand()
1461 mq++; in tic6x_parse_operand()
1479 if (mq[0] == '+' && mq[1] == '+') in tic6x_parse_operand()
1484 else if (mq[0] == '-' && mq[1] == '-') in tic6x_parse_operand()
1511 mq++; in tic6x_parse_operand()
1517 mq++; in tic6x_parse_operand()
1556 mq++; in tic6x_parse_operand()
[all …]
/netbsd/external/gpl3/gdb.old/dist/gas/config/
H A Dtc-tic6x.c1427 mq++; in tic6x_parse_operand()
1440 mq += 2; in tic6x_parse_operand()
1445 mq++; in tic6x_parse_operand()
1453 mq += 2; in tic6x_parse_operand()
1458 mq++; in tic6x_parse_operand()
1476 if (mq[0] == '+' && mq[1] == '+') in tic6x_parse_operand()
1481 else if (mq[0] == '-' && mq[1] == '-') in tic6x_parse_operand()
1508 mq++; in tic6x_parse_operand()
1514 mq++; in tic6x_parse_operand()
1553 mq++; in tic6x_parse_operand()
[all …]
/netbsd/usr.bin/fstat/
H A Dmisc.c204 struct mqueue mq; in p_mqueue() local
206 if (!KVM_READ(f->f_data, &mq, sizeof(mq))) { in p_mqueue()
210 (void)printf("* mqueue \"%s\"", mq.mq_name); in p_mqueue()
/netbsd/lib/librt/
H A DMakefile16 mq.3 mq_close.3 mq_getattr.3 mq_notify.3 mq_open.3 mq_receive.3 \
22 MLINKS+= mq.3 mqueue.3
/netbsd/sys/arch/powerpc/include/
H A Dframe.h80 int mq; member
172 int mq; member
H A Ddb_machdep.h57 u_int32_t mq; member
/netbsd/sys/arch/powerpc/powerpc/
H A Dcompat_16_machdep.c116 utf->mq = tf->tf_mq; in sendsig_sigcontext()
240 tf->tf_mq = utf->mq; in compat_16_sys___sigreturn14()
H A Dcompat_13_machdep.c90 tf->tf_mq = sc.sc_frame.mq; in compat_13_sys_sigreturn()
H A Ddb_interface.c242 DDB_REGS->mq = tf->tf_mq; in kdb_trap()
282 tf->tf_mq = DDB_REGS->mq; in kdb_trap()
/netbsd/external/mpl/bind/dist/bin/tests/system/dnssec/signer/general/
H A DKexample.com.+008+63613.key5 …G6 /4zTjEv8JyYjGQz2k2vcoWWcD+86xD5IUqfa1pdXXUU8bdhG9DBtW/K1 mc4P6g8heU+0f++mq/L4TPlWVZUG8lVH4H8mD6…
/netbsd/external/gpl2/dtc/dist/tests/
H A Dmultilabel.dts3 m1: mq: /memreserve/ 0 0x1000;
H A Dmultilabel_merge.dts3 m1: mq: /memreserve/ 0 0x1000;
/netbsd/external/gpl3/gdb/dist/gdb/
H A Dppc-obsd-nat.c206 ppcobsd_reg_offsets.mq_offset = offsetof (struct reg, mq); in _initialize_ppcobsd_nat()
/netbsd/external/gpl3/gdb.old/dist/gdb/
H A Dppc-obsd-nat.c206 ppcobsd_reg_offsets.mq_offset = offsetof (struct reg, mq); in _initialize_ppcobsd_nat()
/netbsd/external/gpl3/binutils/dist/gprofng/src/
H A DEmsg.cc487 Emsgqueue::appendqueue (Emsgqueue* mq) in appendqueue() argument
489 Emsg *m = mq->first; in appendqueue()
/netbsd/external/mit/libcbor/dist/docs/stylesheets/
H A Dgithub-light.css84 .pl-mq /* markup.quote */ {

123