Home
last modified time | relevance | path

Searched refs:rx_queue (Results 1 – 6 of 6) sorted by relevance

/NextBSD/sys/dev/netmap/
HDnetmap_generic.c278 mbq_safe_init(&na->rx_rings[r].rx_queue); in generic_netmap_register()
351 mbq_safe_purge(&na->rx_rings[r].rx_queue); in generic_netmap_register()
352 mbq_safe_destroy(&na->rx_rings[r].rx_queue); in generic_netmap_register()
397 mbq_safe_destroy(&na->rx_rings[r].rx_queue); in generic_netmap_register()
673 if (unlikely(mbq_len(&na->rx_rings[rr].rx_queue) > 1024)) { in generic_rx_handler()
676 mbq_safe_enqueue(&na->rx_rings[rr].rx_queue, m); in generic_rx_handler()
743 m = mbq_safe_dequeue(&kring->rx_queue); in generic_netmap_rxsync()
HDnetmap.c884 struct mbq *q = &na->rx_rings[na->num_rx_rings].rx_queue; in netmap_hw_krings_delete()
1190 struct mbq *q = &kring->rx_queue, fq; in netmap_rxsync_from_host()
2829 mbq_safe_init(&na->rx_rings[na->num_rx_rings].rx_queue); in netmap_hw_krings_create()
2903 q = &kring->rx_queue; in netmap_transmit()
HDnetmap_kern.h348 struct mbq rx_queue; /* intercepted rx mbufs. */ member
/NextBSD/sys/dev/ce/
HDceddk.c252 CE_ENQUEUE (c->rx_queue, req); in ce_on_receive()
253 while (c->rx_queue) { in ce_on_receive()
254 CE_DEQUEUE (c->rx_queue, req); in ce_on_receive()
265 CE_ENQUEUE_HEAD (c->rx_queue, req); in ce_on_receive()
379 CE_LAST_ITEM (c->rx_queue, rreq); in ce_on_config_stop()
385 CE_FIND_ITEM (c->rx_queue, rreq, is_pending); in ce_on_config_stop()
541 c->rx_queue = NULL; in ce_start_chan()
555 CE_ENQUEUE (c->rx_queue, &c->rx_item[i].req); in ce_start_chan()
567 CE_DEQUEUE (c->rx_queue, req); in ce_start_chan()
HDceddk.h72 TAU32_UserRequest *rx_queue; member
/NextBSD/sys/ofed/drivers/infiniband/ulp/sdp/
HDsdp_proc.c128 __u32 rx_queue, tx_queue; in sdp_seq_show() local
145 rx_queue = rcv_nxt(sdp_sk(sk)) - sdp_sk(sk)->copied_seq; in sdp_seq_show()
150 rx_queue, tx_queue, sk->sk_state); in sdp_seq_show()