/openbsd-current/usr.sbin/unbound/dnstap/ |
H A D | 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);
|
H A D | 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 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 D | reg.h | 55 u_int32_t mq; member in struct:reg
|
H A D | cpu.h | 273 FUNC_SPR(0, mq)
|
/openbsd-current/sys/kern/ |
H A D | uipc_mbuf.c | 1652 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 D | if_oce.c | 1841 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 D | process_machdep.c | 69 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 D | ppcobsd-nat.c | 225 ppcobsd_reg_offsets.mq_offset = offsetof (struct reg, mq);
|
H A D | lynx-nat.c | 254 X (mq) /* MQ */
|
H A D | rs6000-nat.c | 641 (char *) ®s->r32.mq);
|
H A D | rs6000-tdep.c | 2237 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 D | darwin-fallback.c | 277 uint32_t mq; member in struct:gcc_mcontext32
|
/openbsd-current/sys/net/ |
H A D | if.c | 943 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 D | ip6_input.c | 1578 struct mbuf_queue *mq = xmq; local 1582 mq_delist(mq, &ml);
|
/openbsd-current/regress/usr.sbin/pkg_add/ |
H A D | Makefile | 250 @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 D | ip_input.c | 1904 struct mbuf_queue *mq = xmq; local 1909 mq_delist(mq, &ml);
|
/openbsd-current/gnu/gcc/gcc/config/h8300/ |
H A D | lib1funcs.asm | 276 divxu A1L,A3 ; mq
|
/openbsd-current/gnu/usr.bin/gcc/gcc/config/h8300/ |
H A D | lib1funcs.asm | 276 divxu A1L,A3 ; mq
|
/openbsd-current/gnu/llvm/llvm/include/llvm/BinaryFormat/ |
H A D | MachO.h | 2060 uint32_t mq; member in struct:llvm::MachO::ppc_thread_state32_t 2103 sys::swapByteOrder(x.mq);
|