motorhead/qemu
1
0
Fork 0
mirror of https://github.com/Motorhead1991/qemu.git synced 2025-08-07 17:53:56 -06:00
Code Issues Projects Releases Packages Wiki Activity Actions

hw/net/net_tx_pkt: Automatically determine if virtio-net header is used

Browse source 
The new function qemu_get_using_vnet_hdr() allows to automatically
determine if virtio-net header is used.

Signed-off-by: Akihiko Odaki <akihiko.odaki@daynix.com>
Signed-off-by: Jason Wang <jasowang@redhat.com>
This commit is contained in:
Akihiko Odaki 2023-02-23 19:20:06 +09:00 • committed by Jason Wang
parent 481c52320a
commit 55daf493f7
4 changed files with 14 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

3
hw/net/e1000e_core.c
View file

@ -3376,8 +3376,7 @@ e1000e_core_pci_realize(E1000ECore *core,
qemu_add_vm_change_state_handler(e1000e_vm_state_change, core); qemu_add_vm_change_state_handler(e1000e_vm_state_change, core);
for (i = 0; i < E1000E_NUM_QUEUES; i++) { for (i = 0; i < E1000E_NUM_QUEUES; i++) {
net_tx_pkt_init(&core->tx[i].tx_pkt, core->owner, net_tx_pkt_init(&core->tx[i].tx_pkt, core->owner, E1000E_MAX_TX_FRAGS);
E1000E_MAX_TX_FRAGS, core->has_vnet);
} }
net_rx_pkt_init(&core->rx_pkt, core->has_vnet); net_rx_pkt_init(&core->rx_pkt, core->has_vnet);

19
hw/net/net_tx_pkt.c
View file

@ -35,7 +35,6 @@ struct NetTxPkt {
PCIDevice *pci_dev; PCIDevice *pci_dev;
struct virtio_net_hdr virt_hdr; struct virtio_net_hdr virt_hdr;
bool has_virt_hdr;
struct iovec *raw; struct iovec *raw;
uint32_t raw_frags; uint32_t raw_frags;
@ -59,7 +58,7 @@ struct NetTxPkt {
}; };
void net_tx_pkt_init(struct NetTxPkt **pkt, PCIDevice *pci_dev, void net_tx_pkt_init(struct NetTxPkt **pkt, PCIDevice *pci_dev,
uint32_t max_frags, bool has_virt_hdr) uint32_t max_frags)
{ {
struct NetTxPkt *p = g_malloc0(sizeof *p); struct NetTxPkt *p = g_malloc0(sizeof *p);
@ -71,10 +70,8 @@ void net_tx_pkt_init(struct NetTxPkt **pkt, PCIDevice *pci_dev,
p->max_payload_frags = max_frags; p->max_payload_frags = max_frags;
p->max_raw_frags = max_frags; p->max_raw_frags = max_frags;
p->has_virt_hdr = has_virt_hdr;
p->vec[NET_TX_PKT_VHDR_FRAG].iov_base = &p->virt_hdr; p->vec[NET_TX_PKT_VHDR_FRAG].iov_base = &p->virt_hdr;
p->vec[NET_TX_PKT_VHDR_FRAG].iov_len = p->vec[NET_TX_PKT_VHDR_FRAG].iov_len = sizeof p->virt_hdr;
p->has_virt_hdr ? sizeof p->virt_hdr : 0;
p->vec[NET_TX_PKT_L2HDR_FRAG].iov_base = &p->l2_hdr; p->vec[NET_TX_PKT_L2HDR_FRAG].iov_base = &p->l2_hdr;
p->vec[NET_TX_PKT_L3HDR_FRAG].iov_base = &p->l3_hdr; p->vec[NET_TX_PKT_L3HDR_FRAG].iov_base = &p->l3_hdr;
@ -617,9 +614,11 @@ static bool net_tx_pkt_do_sw_fragmentation(struct NetTxPkt *pkt,
bool net_tx_pkt_send(struct NetTxPkt *pkt, NetClientState *nc) bool net_tx_pkt_send(struct NetTxPkt *pkt, NetClientState *nc)
{ {
bool using_vnet_hdr = qemu_get_using_vnet_hdr(nc->peer);
assert(pkt); assert(pkt);
if (!pkt->has_virt_hdr && if (!using_vnet_hdr &&
pkt->virt_hdr.flags & VIRTIO_NET_HDR_F_NEEDS_CSUM) { pkt->virt_hdr.flags & VIRTIO_NET_HDR_F_NEEDS_CSUM) {
net_tx_pkt_do_sw_csum(pkt); net_tx_pkt_do_sw_csum(pkt);
} }
@ -636,11 +635,13 @@ bool net_tx_pkt_send(struct NetTxPkt *pkt, NetClientState *nc)
} }
} }
if (pkt->has_virt_hdr || if (using_vnet_hdr ||
pkt->virt_hdr.gso_type == VIRTIO_NET_HDR_GSO_NONE) { pkt->virt_hdr.gso_type == VIRTIO_NET_HDR_GSO_NONE) {
int index = using_vnet_hdr ?
NET_TX_PKT_VHDR_FRAG : NET_TX_PKT_L2HDR_FRAG;
net_tx_pkt_fix_ip6_payload_len(pkt); net_tx_pkt_fix_ip6_payload_len(pkt);
net_tx_pkt_sendv(pkt, nc, pkt->vec, net_tx_pkt_sendv(pkt, nc, pkt->vec + index,
pkt->payload_frags + NET_TX_PKT_PL_START_FRAG); pkt->payload_frags + NET_TX_PKT_PL_START_FRAG - index);
return true; return true;
} }

3
hw/net/net_tx_pkt.h
View file

@ -32,10 +32,9 @@ struct NetTxPkt;
* @pkt: packet pointer * @pkt: packet pointer
* @pci_dev: PCI device processing this packet * @pci_dev: PCI device processing this packet
* @max_frags: max tx ip fragments * @max_frags: max tx ip fragments
* @has_virt_hdr: device uses virtio header.
*/ */
void net_tx_pkt_init(struct NetTxPkt **pkt, PCIDevice *pci_dev, void net_tx_pkt_init(struct NetTxPkt **pkt, PCIDevice *pci_dev,
uint32_t max_frags, bool has_virt_hdr); uint32_t max_frags);
/** /**
* Clean all tx packet resources. * Clean all tx packet resources.

6
hw/net/vmxnet3.c
View file

@ -1521,8 +1521,7 @@ static void vmxnet3_activate_device(VMXNET3State *s)
/* Preallocate TX packet wrapper */ /* Preallocate TX packet wrapper */
VMW_CFPRN("Max TX fragments is %u", s->max_tx_frags); VMW_CFPRN("Max TX fragments is %u", s->max_tx_frags);
net_tx_pkt_init(&s->tx_pkt, PCI_DEVICE(s), net_tx_pkt_init(&s->tx_pkt, PCI_DEVICE(s), s->max_tx_frags);
s->max_tx_frags, s->peer_has_vhdr);
net_rx_pkt_init(&s->rx_pkt, s->peer_has_vhdr); net_rx_pkt_init(&s->rx_pkt, s->peer_has_vhdr);
/* Read rings memory locations for RX queues */ /* Read rings memory locations for RX queues */
@ -2402,8 +2401,7 @@ static int vmxnet3_post_load(void *opaque, int version_id)
{ {
VMXNET3State *s = opaque; VMXNET3State *s = opaque;
net_tx_pkt_init(&s->tx_pkt, PCI_DEVICE(s), net_tx_pkt_init(&s->tx_pkt, PCI_DEVICE(s), s->max_tx_frags);
s->max_tx_frags, s->peer_has_vhdr);
net_rx_pkt_init(&s->rx_pkt, s->peer_has_vhdr); net_rx_pkt_init(&s->rx_pkt, s->peer_has_vhdr);
if (s->msix_used) { if (s->msix_used) {