| /xnu-11215/bsd/net/ |
| H A D | if_utun.c | 421 if (rx_ring != NULL) { in utun_netif_sync_tx() 422 kern_channel_notify(rx_ring, 0); in utun_netif_sync_tx() 597 if (rx_ring != NULL) { in utun_netif_tx_doorbell() 598 kern_channel_notify(rx_ring, 0); in utun_netif_tx_doorbell() 629 (void) kern_channel_reclaim(rx_ring); in utun_netif_sync_rx() 640 struct kern_pbufpool *rx_pp = rx_ring->ckr_pp; in utun_netif_sync_rx() 2978 if (rx_ring != NULL) { in utun_pkt_input() 2979 kern_channel_notify(rx_ring, 0); in utun_pkt_input() 3225 if (rx_ring != NULL) { in utun_kpipe_sync_tx() 3226 kern_channel_notify(rx_ring, 0); in utun_kpipe_sync_tx() [all …]
|
| H A D | if_ipsec.c | 678 if (rx_ring != NULL) { in ipsec_kpipe_sync_tx() 679 kern_channel_notify(rx_ring, 0); in ipsec_kpipe_sync_tx() 769 (void) kern_channel_reclaim(rx_ring); in ipsec_kpipe_sync_rx() 823 struct kern_pbufpool *rx_pp = rx_ring->ckr_pp; in ipsec_kpipe_sync_rx() 1130 if (rx_ring != NULL) { in ipsec_netif_sync_tx() 1131 kern_channel_notify(rx_ring, 0); in ipsec_netif_sync_tx() 1293 if (rx_ring != NULL) { in ipsec_netif_tx_doorbell_one() 1294 kern_channel_notify(rx_ring, 0); in ipsec_netif_tx_doorbell_one() 1483 (void) kern_channel_reclaim(rx_ring); in ipsec_netif_sync_rx() 4135 if (rx_ring != NULL) { in ipsec_inject_inbound_packet() [all …]
|
| H A D | if_headless.c | 744 kern_nexus_t nexus, kern_channel_ring_t rx_ring, uint32_t flags) in headless_nx_sync_rx_null() argument 746 #pragma unused(nxprov, rx_ring, flags) in headless_nx_sync_rx_null() 758 kern_nexus_t nexus, kern_channel_ring_t rx_ring, uint32_t flags) in headless_nx_sync_rx() argument 770 kern_channel_reclaim(rx_ring); in headless_nx_sync_rx() 774 rx_ring->ckr_ring_id, flags); in headless_nx_sync_rx() 784 rx_slot = kern_channel_get_next_slot(rx_ring, NULL, NULL); in headless_nx_sync_rx() 815 kern_channel_slot_attach_packet(rx_ring, rx_slot, ph); in headless_nx_sync_rx() 819 rx_slot = kern_channel_get_next_slot(rx_ring, rx_slot, NULL); in headless_nx_sync_rx() 823 kern_channel_advance_slot(rx_ring, last_rx_slot); in headless_nx_sync_rx() 824 kern_channel_increment_ring_net_stats(rx_ring, ifp, &stats); in headless_nx_sync_rx()
|
| H A D | if_redirect.c | 751 kern_channel_ring_t rx_ring = NULL; in redirect_rx_cb() local 759 rx_ring = rd->rd_rx_ring[0]; in redirect_rx_cb() 760 if (rx_ring == NULL) { in redirect_rx_cb() 767 kr_enter(rx_ring, TRUE); in redirect_rx_cb() 768 kern_channel_reclaim(rx_ring); in redirect_rx_cb() 776 rx_slot = kern_channel_get_next_slot(rx_ring, last_rx_slot, NULL); in redirect_rx_cb() 794 err = kern_channel_slot_attach_packet(rx_ring, rx_slot, ph); in redirect_rx_cb() 801 kern_channel_advance_slot(rx_ring, last_rx_slot); in redirect_rx_cb() 802 kern_channel_increment_ring_net_stats(rx_ring, rd->rd_ifp, &stats); in redirect_rx_cb() 804 kr_exit(rx_ring); in redirect_rx_cb() [all …]
|
| H A D | if_fake.c | 1453 kern_channel_ring_t rx_ring = NULL; in feth_rx_submit() local 1459 rx_ring = dif->iff_rx_ring[0]; in feth_rx_submit() 1460 if (rx_ring == NULL) { in feth_rx_submit() 1464 kr_enter(rx_ring, TRUE); in feth_rx_submit() 1465 kern_channel_reclaim(rx_ring); in feth_rx_submit() 1466 rx_slot = kern_channel_get_next_slot(rx_ring, NULL, NULL); in feth_rx_submit() 1514 kern_channel_advance_slot(rx_ring, last_rx_slot); in feth_rx_submit() 1515 kern_channel_increment_ring_net_stats(rx_ring, dif->iff_ifp, in feth_rx_submit() 1519 if (rx_ring != NULL) { in feth_rx_submit() 1520 kr_exit(rx_ring); in feth_rx_submit() [all …]
|
| /xnu-11215/tests/skywalk/ |
| H A D | skt_filter.c | 213 channel_ring_t rx_ring; in get_packet() local 215 rx_ring = os_channel_rx_ring(ch, r); in get_packet() 216 SKTC_ASSERT_ERR(rx_ring != NULL); in get_packet() 218 rx_slot = os_channel_get_next_slot(rx_ring, last_rx_slot, &prop); in get_packet() 224 pkt = os_channel_slot_get_packet(rx_ring, rx_slot); in get_packet() 227 error = os_channel_slot_detach_packet(rx_ring, rx_slot, pkt); in get_packet() 237 error = os_channel_advance_slot(rx_ring, last_rx_slot); in get_packet()
|
| H A D | skt_netifdirect.c | 414 slot = os_channel_get_next_slot(port->rx_ring, last_slot, in skt_netif_channel_receive() 421 pkt = os_channel_slot_get_packet(port->rx_ring, slot); in skt_netif_channel_receive() 424 error = os_channel_slot_detach_packet(port->rx_ring, in skt_netif_channel_receive() 470 error = os_channel_advance_slot(port->rx_ring, last_slot); in skt_netif_channel_receive()
|
| H A D | skywalk_test_utils.c | 1672 ch_port->rx_ring = os_channel_rx_ring(ch_port->chan, ringid); in sktu_channel_port_init() 1673 assert(ch_port->rx_ring != NULL); in sktu_channel_port_init() 2063 slot = os_channel_get_next_slot(port->rx_ring, NULL, &prop); in sktu_channel_port_rx() 2071 pkt = os_channel_slot_get_packet(port->rx_ring, slot); in sktu_channel_port_rx() 2074 error = os_channel_slot_detach_packet(port->rx_ring, in sktu_channel_port_rx() 2114 error = os_channel_advance_slot(port->rx_ring, slot); in sktu_channel_port_rx()
|
| H A D | skywalk_test_utils.h | 164 channel_ring_t rx_ring; member
|
| H A D | skt_xfer.c | 1352 slot = os_channel_get_next_slot(port->rx_ring, NULL, &prop); in channel_port_receive_payload() 1358 pkt = os_channel_slot_get_packet(port->rx_ring, slot); in channel_port_receive_payload() 1361 error = os_channel_slot_detach_packet(port->rx_ring, in channel_port_receive_payload() 1385 error = os_channel_advance_slot(port->rx_ring, slot); in channel_port_receive_payload() 1423 slot = os_channel_get_next_slot(port->rx_ring, last_slot, in channel_port_receive() 1430 pkt = os_channel_slot_get_packet(port->rx_ring, slot); in channel_port_receive() 1433 error = os_channel_slot_detach_packet(port->rx_ring, in channel_port_receive() 1489 error = os_channel_advance_slot(port->rx_ring, last_slot); in channel_port_receive()
|