Searched refs:mq (Results 26 - 50 of 51) sorted by relevance

123

/freebsd-11-stable/sys/netpfil/ipfw/
H A Ddn_sched_fifo.c96 dn_free_pkts(q->mq.head);
H A Ddn_sched_fq_pie.c109 struct mq mq; /* list of packets */ member in struct:fq_pie_flow
341 struct mbuf *m = q->mq.head;
345 q->mq.head = m->m_nextpkt;
747 mq_append(&q->mq, m);
764 struct mbuf *m = q->mq.head;
768 q->mq.head = m->m_nextpkt;
H A Ddn_aqm_pie.c331 struct mbuf *m = q->mq.head;
335 q->mq.head = m->m_nextpkt;
554 mq_append(&q->mq, m);
H A Ddn_sched_fq_codel.c156 struct mbuf *m = q->mq.head;
160 q->mq.head = m->m_nextpkt;
196 mq_append(&q->mq, m);
H A Ddn_sched_qfq.c529 if (cl->_q.mq.head == NULL) {
535 len = cl->_q.mq.head->m_pkthdr.len;
665 if (m != _q->mq.head) {
669 if (m != _q->mq.head)
H A Dip_dummynet.c384 if (q->mq.head)
385 dn_free_pkts(q->mq.head);
554 dn_free_pkts(dl->mq.head); /* drain delay line */
2356 if ((si->kflags & DN_ACTIVE) || si->dline.mq.head != NULL)
/freebsd-11-stable/sys/dev/ocs_fc/
H A Docs_ddump.c468 ocs_ddump_sli4_queue(textbuf, "mq", hw, hw->mq, hw->mq_count,
563 hw_mq_t *mq; local
579 mq = (hw_mq_t *) q;
580 ocs_ddump_section(textbuf, "mq", mq->instance);
581 ocs_ddump_value(textbuf, "queue-id", "%d", mq->queue->id);
582 OCS_STAT(ocs_ddump_value(textbuf, "use_count", "%d", mq->use_count));
583 ocs_ddump_endsection(textbuf, "mq", mq
[all...]
H A Dsli4.c2194 sli4_req_common_create_mq_ext_t *mq = NULL; local
2209 mq = (sli4_req_common_create_mq_ext_t *)((uint8_t *)buf + sli_config_off);
2211 mq->hdr.opcode = SLI4_OPC_COMMON_CREATE_MQ_EXT;
2212 mq->hdr.subsystem = SLI4_SUBSYSTEM_COMMON;
2213 mq->hdr.request_length = sizeof(sli4_req_common_create_mq_ext_t) -
2216 mq->num_pages = qmem->size / SLI_PAGE_SIZE;
2217 switch (mq->num_pages) {
2219 mq->ring_size = SLI4_MQE_SIZE_16;
2222 mq->ring_size = SLI4_MQE_SIZE_32;
2225 mq
2272 sli4_req_common_destroy_mq_t *mq = NULL; local
[all...]
H A Docs_hw.h944 sli4_queue_t mq[OCS_HW_MAX_NUM_MQ]; member in struct:ocs_hw_s
1250 extern void hw_del_mq(hw_mq_t *mq);
H A Docs_hw.c1267 sli_queue_free(&hw->sli, &hw->mq[i], destroy_queues, free_memory);
1432 sli_queue_reset(&hw->sli, &hw->mq[i]);
2267 if (sli_queue_write(&hw->sli, hw->mq, ctx->buf) < 0) {
2326 if (hw->mq->length && !sli_queue_is_empty(&hw->sli, hw->mq)) {
8474 CPUTRACE("mq");
8475 ocs_hw_mq_process(hw, status, hw->mq);
9105 * @param mq Pointer to the mailbox queue object.
9110 ocs_hw_mq_process(ocs_hw_t *hw, int32_t status, sli4_queue_t *mq) argument
9114 if (!sli_queue_read(&hw->sli, mq, mq
[all...]
/freebsd-11-stable/sys/netinet/
H A Digmp.c487 igmp_dispatch_queue(struct mbufq *mq, int limit, const int loop) argument
491 while ((m = mbufq_dequeue(mq)) != NULL) {
492 CTR3(KTR_IGMPV3, "%s: dispatch %p from %p", __func__, mq, m);
2341 struct mbufq *mq; local
2414 mq = &inm->inm_scq;
2415 mbufq_drain(mq);
2416 retval = igmp_v3_enqueue_group_record(mq, inm, 1,
2643 igmp_v3_enqueue_group_record(struct mbufq *mq, struct in_multi *inm, argument
2733 return (igmp_v3_enqueue_filter_change(mq, inm));
2762 m0 = mbufq_last(mq);
3005 igmp_v3_enqueue_filter_change(struct mbufq *mq, struct in_multi *inm) argument
[all...]
/freebsd-11-stable/sys/netinet6/
H A Dmld6.c421 mld_dispatch_queue(struct mbufq *mq, int limit) argument
425 while ((m = mbufq_dequeue(mq)) != NULL) {
426 CTR3(KTR_MLD, "%s: dispatch %p from %p", __func__, mq, m);
1947 struct mbufq *mq; local
2034 mq = &inm->in6m_scq;
2035 mbufq_drain(mq);
2036 retval = mld_v2_enqueue_group_record(mq, inm, 1,
2277 mld_v2_enqueue_group_record(struct mbufq *mq, struct in6_multi *inm, argument
2392 return (mld_v2_enqueue_filter_change(mq, inm));
2423 m0 = mbufq_last(mq);
2663 mld_v2_enqueue_filter_change(struct mbufq *mq, struct in6_multi *inm) argument
[all...]
/freebsd-11-stable/sys/netpfil/ipfw/nat64/
H A Dnat64_translate.c508 struct mbufq *mq, struct mbuf *m, uint32_t mtu, uint16_t ip_id,
527 if (mbufq_enqueue(mq, m) != 0) {
575 if (mbufq_enqueue(mq, m) != 0)
579 NAT64STAT_ADD(stats, ofrags, mbufq_len(mq));
586 mbufq_drain(mq);
1177 struct mbufq mq; local
1270 mbufq_init(&mq, 255);
1271 nat64_fragment6(&cfg->stats, &ip6, &mq, m, nh.nh_mtu, ip_id, ip_off);
1272 while ((m = mbufq_dequeue(&mq)) != NULL) {
1278 mbufq_drain(&mq);
507 nat64_fragment6(struct nat64_counters *stats, struct ip6_hdr *ip6, struct mbufq *mq, struct mbuf *m, uint32_t mtu, uint16_t ip_id, uint16_t ip_off) argument
[all...]
/freebsd-11-stable/lib/libthr/thread/
H A Dthr_create.c124 TAILQ_INIT(&new_thread->mq[i]);
H A Dthr_init.c420 TAILQ_INIT(&thread->mq[i]);
H A Dthr_private.h505 struct mutex_queue mq[TMQ_NITEMS]; member in struct:pthread
/freebsd-11-stable/contrib/gcc/config/rs6000/
H A Ddarwin-fallback.c277 uint32_t mq; member in struct:gcc_mcontext32
/freebsd-11-stable/sys/dev/oce/
H A Doce_mbox.c342 struct oce_mq *mq = sc->mq; local
346 mbx = RING_GET_PRODUCER_ITEM_VA(mq->ring, struct oce_mbx);
358 bus_dmamap_sync(mq->ring->dma.tag, mq->ring->dma.map,
360 RING_PUT(mq->ring, 1);
361 reg_value = (1 << 16) | mq->mq_id;
H A Doce_hw.c497 rc = oce_start_mq(sc->mq);
H A Doce_if.h858 struct oce_mq *mq; /* Mailbox queue */ member in struct:oce_softc
987 int oce_start_mq(struct oce_mq *mq);
/freebsd-11-stable/contrib/gdb/gdb/
H A Dlynx-nat.c254 X (mq) /* MQ */
H A Drs6000-nat.c611 supply_register (tdep->ppc_mq_regnum, (char *) &regs->r32.mq);
H A Drs6000-tdep.c2126 slot 70 was being used for "mq", so the next available slot (71)
2253 /* 66 */ R4(cnd), R(lr), R(cnt), R4(xer), R4(mq),
2347 /* 123 */ R(pir), R(mq), R(rtcu), R(rtcl)
/freebsd-11-stable/contrib/llvm-project/llvm/include/llvm/BinaryFormat/
H A DMachO.h1911 uint32_t mq; member in struct:llvm::MachO::ppc_thread_state32_t
1954 sys::swapByteOrder(x.mq);
/freebsd-11-stable/sys/dev/virtio/network/
H A Dif_vtnet.c3169 struct virtio_net_ctrl_mq mq; member in struct:__anon5291
3177 s.mq.virtqueue_pairs = npairs;
3183 error |= sglist_append(&sg, &s.mq, sizeof(struct virtio_net_ctrl_mq));

Completed in 439 milliseconds

123