Searched refs:rx_queue (Results 1 - 9 of 9) sorted by relevance

/freebsd-13-stable/sys/dev/qlnx/qlnxe/
H A Decore_ll2.h125 struct ecore_ll2_rx_queue rx_queue; member in struct:ecore_ll2_info
H A Decore_ll2.c52 #define ECORE_LL2_RX_REGISTERED(ll2) ((ll2)->rx_queue.b_cb_registred)
338 struct ecore_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue;
374 struct ecore_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue;
425 struct ecore_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue;
477 p_rx = &p_ll2_conn->rx_queue;
542 struct ecore_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue;
834 struct ecore_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue;
1061 &p_ll2_info->rx_queue.rxq_chain, OSAL_NULL);
1068 capacity = ecore_chain_get_capacity(&p_ll2_info->rx_queue.rxq_chain);
1077 p_ll2_info->rx_queue
[all...]
/freebsd-13-stable/sys/dev/netmap/
H A Dnetmap_generic.c246 mbq_safe_purge(&kring->rx_queue);
271 mbq_safe_fini(&kring->rx_queue);
339 mbq_safe_init(&kring->rx_queue);
419 mbq_safe_fini(&kring->rx_queue);
845 } else if (unlikely(mbq_len(&kring->rx_queue) > 1024)) {
848 mbq_safe_enqueue(&kring->rx_queue, m);
942 mbq_lock(&kring->rx_queue);
944 m = mbq_peek(&kring->rx_queue);
956 mbq_dequeue(&kring->rx_queue);
973 mbq_unlock(&kring->rx_queue);
[all...]
H A Dnetmap.c964 struct mbq *q = &NMR(na, NR_RX)[i]->rx_queue;
1241 * Called under kring->rx_queue.lock on the sw rx ring.
1329 * They have been put in kring->rx_queue by netmap_transmit().
1330 * We protect access to the kring using kring->rx_queue.lock
1345 struct mbq *q = &kring->rx_queue, fq;
3926 mbq_safe_init(&NMR(na, NR_RX)[i]->rx_queue);
4018 q = &kring->rx_queue;
H A Dnetmap_kern.h416 * RX rings attached to the host stack use an mbq (rx_queue) on both
509 struct mbq rx_queue; /* intercepted rx mbufs. */ member in struct:netmap_kring
/freebsd-13-stable/sys/arm64/broadcom/genet/
H A Dif_genet.c145 struct rx_queue { struct
184 struct rx_queue rx_queue[NRXQUEUE]; member in struct:gen_softc
207 static int gen_rxintr(struct gen_softc *sc, struct rx_queue *q);
210 static int gen_newbuf_rx(struct gen_softc *sc, struct rx_queue *q, int index);
211 static int gen_mapbuf_rx(struct gen_softc *sc, struct rx_queue *q, int index,
703 struct rx_queue *q;
707 q = &sc->rx_queue[queue];
736 gen_newbuf_rx(sc, &sc->rx_queue[DEF_RXQUEUE], i);
778 sc->rx_queue[
[all...]
/freebsd-13-stable/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_proc.c129 __u32 rx_queue, tx_queue; local
134 "uid inode rx_queue tx_queue state");
146 rx_queue = rcv_nxt(sdp_sk(sk)) - sdp_sk(sk)->copied_seq;
151 rx_queue, tx_queue, sk->sk_state);
/freebsd-13-stable/sys/dev/ce/
H A Dceddk.h72 TAU32_UserRequest *rx_queue; member in struct:_ce_chan_t
H A Dceddk.c252 CE_ENQUEUE (c->rx_queue, req);
253 while (c->rx_queue) {
254 CE_DEQUEUE (c->rx_queue, req);
265 CE_ENQUEUE_HEAD (c->rx_queue, req);
379 CE_LAST_ITEM (c->rx_queue, rreq);
385 CE_FIND_ITEM (c->rx_queue, rreq, is_pending);
541 c->rx_queue = NULL;
555 CE_ENQUEUE (c->rx_queue, &c->rx_item[i].req);
567 CE_DEQUEUE (c->rx_queue, req);

Completed in 137 milliseconds