Searched refs:mq (Results 1 - 19 of 19) sorted by relevance

/openbsd-current/usr.sbin/unbound/dnstap/
H A Ddtstream.h253 * @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);
H A Ddtstream.c106 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
123 dt_msg_queue_clear(struct dt_msg_queue* mq) argument
139 dt_msg_queue_delete(struct dt_msg_queue* mq) argument
178 struct dt_msg_queue* mq = (struct dt_msg_queue*)arg; local
191 dt_msg_queue_start_timer(struct dt_msg_queue* mq, int wakeupnow) argument
230 dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len) argument
448 dt_io_thread_register_queue(struct dt_io_thread* dtio, struct dt_msg_queue* mq) argument
463 dt_io_thread_unregister_queue(struct dt_io_thread* dtio, struct dt_msg_queue* mq) argument
489 dt_msg_queue_pop(struct dt_msg_queue* mq, void** buf, size_t* len) argument
511 dtio_find_in_queue(struct dt_io_thread* dtio, struct dt_msg_queue* mq) argument
[all...]
/openbsd-current/sys/arch/powerpc/include/
H A Dreg.h55 u_int32_t mq; member in struct:reg
H A Dcpu.h273 FUNC_SPR(0, mq)
/openbsd-current/sys/kern/
H A Duipc_mbuf.c1652 mq_init(struct mbuf_queue *mq, u_int maxlen, int ipl) argument
1654 mtx_init(&mq->mq_mtx, ipl);
1655 ml_init(&mq->mq_list);
1656 mq->mq_maxlen = maxlen;
1660 mq_push(struct mbuf_queue *mq, struct mbuf *m) argument
1664 mtx_enter(&mq->mq_mtx);
1665 if (mq_len(mq) >= mq->mq_maxlen) {
1666 mq->mq_drops++;
1667 dropped = ml_dequeue(&mq
1679 mq_enqueue(struct mbuf_queue *mq, struct mbuf *m) argument
1699 mq_dequeue(struct mbuf_queue *mq) argument
1711 mq_enlist(struct mbuf_queue *mq, struct mbuf_list *ml) argument
1734 mq_delist(struct mbuf_queue *mq, struct mbuf_list *ml) argument
1743 mq_dechain(struct mbuf_queue *mq) argument
1755 mq_purge(struct mbuf_queue *mq) argument
1765 mq_hdatalen(struct mbuf_queue *mq) argument
1777 mq_set_maxlen(struct mbuf_queue *mq, u_int maxlen) argument
1785 sysctl_mq(int *name, u_int namelen, void *oldp, size_t *oldlenp, void *newp, size_t newlen, struct mbuf_queue *mq) argument
[all...]
/openbsd-current/sys/dev/pci/
H A Dif_oce.c1841 struct oce_mq *mq = (struct oce_mq *)arg; local
1842 struct oce_softc *sc = mq->sc;
1843 struct oce_cq *cq = mq->cq;
2257 struct oce_mq *mq = NULL; local
2260 /* allocate the mq */
2261 mq = malloc(sizeof(struct oce_mq), M_DEVBUF, M_NOWAIT | M_ZERO);
2262 if (!mq)
2265 mq->ring = oce_create_ring(sc, 128, sizeof(struct oce_mbx), 8);
2266 if (!mq->ring) {
2267 free(mq, M_DEVBU
2302 oce_drain_mq(struct oce_mq *mq) argument
2318 oce_destroy_mq(struct oce_mq *mq) argument
2868 struct oce_mq *mq = sc->sc_mq; local
3321 oce_new_mq(struct oce_softc *sc, struct oce_mq *mq) argument
[all...]
/openbsd-current/sys/arch/powerpc/powerpc/
H A Dprocess_machdep.c69 regs->mq = 0; /* what should this really be? */
150 /* regs->mq = 0; what should this really be? */
/openbsd-current/gnu/usr.bin/binutils/gdb/
H A Dppcobsd-nat.c225 ppcobsd_reg_offsets.mq_offset = offsetof (struct reg, mq);
H A Dlynx-nat.c254 X (mq) /* MQ */
H A Drs6000-nat.c641 (char *) &regs->r32.mq);
H A Drs6000-tdep.c2237 slot 70 was being used for "mq", so the next available slot (71)
2393 /* 66 */ R4(cnd), S(lr), S(cnt), S4(xer), S4(mq),
2492 /* 123 */ S(pir), S(mq), S(rtcu), S(rtcl)
/openbsd-current/gnu/gcc/gcc/config/rs6000/
H A Ddarwin-fallback.c277 uint32_t mq; member in struct:gcc_mcontext32
/openbsd-current/sys/net/
H A Dif.c943 if_output_mq(struct ifnet *ifp, struct mbuf_queue *mq, unsigned int *total, argument
950 mq_delist(mq, &ml);
955 if (mq_len(mq) > 0) {
957 atomic_sub_int(total, len + mq_purge(mq));
/openbsd-current/sys/netinet6/
H A Dip6_input.c1578 struct mbuf_queue *mq = xmq; local
1582 mq_delist(mq, &ml);
/openbsd-current/regress/usr.sbin/pkg_add/
H A DMakefile250 @ROOT=${D30} ${INFO_PKG} -mq|diff -u - ${.CURDIR}/list9.out
252 @ROOT=${D30} ${INFO_PKG} -mq|diff -u - ${.CURDIR}/list10.out
/openbsd-current/sys/netinet/
H A Dip_input.c1904 struct mbuf_queue *mq = xmq; local
1909 mq_delist(mq, &ml);
/openbsd-current/gnu/gcc/gcc/config/h8300/
H A Dlib1funcs.asm276 divxu A1L,A3 ; mq
/openbsd-current/gnu/usr.bin/gcc/gcc/config/h8300/
H A Dlib1funcs.asm276 divxu A1L,A3 ; mq
/openbsd-current/gnu/llvm/llvm/include/llvm/BinaryFormat/
H A DMachO.h2060 uint32_t mq; member in struct:llvm::MachO::ppc_thread_state32_t
2103 sys::swapByteOrder(x.mq);

Completed in 409 milliseconds