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

net: cadence_gem: Move tx/rx packet buffert to CadenceGEMState

Browse source 
Moving this buffers to CadenceGEMState, as their size will be increased
more when JUMBO frames support is added.

Signed-off-by: Sai Pavan Boddu <sai.pavan.boddu@xilinx.com>
Reviewed-by: Edgar E. Iglesias <edgar.iglesias@xilinx.com>
Signed-off-by: Jason Wang <jasowang@redhat.com>
This commit is contained in:
Sai Pavan Boddu 2020-05-12 20:24:48 +05:30 • committed by Jason Wang
parent 68dbee3bf9
commit 24d62fd502
2 changed files with 21 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

38
hw/net/cadence_gem.c
View file

@ -928,17 +928,14 @@ static void gem_get_rx_desc(CadenceGEMState *s, int q)
*/ */
static ssize_t gem_receive(NetClientState *nc, const uint8_t *buf, size_t size) static ssize_t gem_receive(NetClientState *nc, const uint8_t *buf, size_t size)
{ {
CadenceGEMState *s; CadenceGEMState *s = qemu_get_nic_opaque(nc);
unsigned rxbufsize, bytes_to_copy; unsigned rxbufsize, bytes_to_copy;
unsigned rxbuf_offset; unsigned rxbuf_offset;
uint8_t rxbuf[2048];
uint8_t *rxbuf_ptr; uint8_t *rxbuf_ptr;
bool first_desc = true; bool first_desc = true;
int maf; int maf;
int q = 0; int q = 0;
s = qemu_get_nic_opaque(nc);
/* Is this destination MAC address "for us" ? */ /* Is this destination MAC address "for us" ? */
maf = gem_mac_address_filter(s, buf); maf = gem_mac_address_filter(s, buf);
if (maf == GEM_RX_REJECT) { if (maf == GEM_RX_REJECT) {
@ -994,19 +991,19 @@ static ssize_t gem_receive(NetClientState *nc, const uint8_t *buf, size_t size)
} else { } else {
unsigned crc_val; unsigned crc_val;
if (size > sizeof(rxbuf) - sizeof(crc_val)) { if (size > MAX_FRAME_SIZE - sizeof(crc_val)) {
size = sizeof(rxbuf) - sizeof(crc_val); size = MAX_FRAME_SIZE - sizeof(crc_val);
} }
bytes_to_copy = size; bytes_to_copy = size;
/* The application wants the FCS field, which QEMU does not provide. /* The application wants the FCS field, which QEMU does not provide.
* We must try and calculate one. * We must try and calculate one.
*/ */
memcpy(rxbuf, buf, size); memcpy(s->rx_packet, buf, size);
memset(rxbuf + size, 0, sizeof(rxbuf) - size); memset(s->rx_packet + size, 0, MAX_FRAME_SIZE - size);
rxbuf_ptr = rxbuf; rxbuf_ptr = s->rx_packet;
crc_val = cpu_to_le32(crc32(0, rxbuf, MAX(size, 60))); crc_val = cpu_to_le32(crc32(0, s->rx_packet, MAX(size, 60)));
memcpy(rxbuf + size, &crc_val, sizeof(crc_val)); memcpy(s->rx_packet + size, &crc_val, sizeof(crc_val));
bytes_to_copy += 4; bytes_to_copy += 4;
size += 4; size += 4;
@ -1152,7 +1149,6 @@ static void gem_transmit(CadenceGEMState *s)
{ {
uint32_t desc[DESC_MAX_NUM_WORDS]; uint32_t desc[DESC_MAX_NUM_WORDS];
hwaddr packet_desc_addr; hwaddr packet_desc_addr;
uint8_t tx_packet[2048];
uint8_t *p; uint8_t *p;
unsigned total_bytes; unsigned total_bytes;
int q = 0; int q = 0;
@ -1168,7 +1164,7 @@ static void gem_transmit(CadenceGEMState *s)
* Packets scattered across multiple descriptors are gathered to this * Packets scattered across multiple descriptors are gathered to this
* one contiguous buffer first. * one contiguous buffer first.
*/ */
p = tx_packet; p = s->tx_packet;
total_bytes = 0; total_bytes = 0;
for (q = s->num_priority_queues - 1; q >= 0; q--) { for (q = s->num_priority_queues - 1; q >= 0; q--) {
@ -1198,12 +1194,12 @@ static void gem_transmit(CadenceGEMState *s)
break; break;
} }
if (tx_desc_get_length(desc) > sizeof(tx_packet) - if (tx_desc_get_length(desc) > MAX_FRAME_SIZE -
(p - tx_packet)) { (p - s->tx_packet)) {
DB_PRINT("TX descriptor @ 0x%" HWADDR_PRIx \ DB_PRINT("TX descriptor @ 0x%" HWADDR_PRIx \
" too large: size 0x%x space 0x%zx\n", " too large: size 0x%x space 0x%zx\n",
packet_desc_addr, tx_desc_get_length(desc), packet_desc_addr, tx_desc_get_length(desc),
sizeof(tx_packet) - (p - tx_packet)); MAX_FRAME_SIZE - (p - s->tx_packet));
break; break;
} }
@ -1248,24 +1244,24 @@ static void gem_transmit(CadenceGEMState *s)
/* Is checksum offload enabled? */ /* Is checksum offload enabled? */
if (s->regs[GEM_DMACFG] & GEM_DMACFG_TXCSUM_OFFL) { if (s->regs[GEM_DMACFG] & GEM_DMACFG_TXCSUM_OFFL) {
net_checksum_calculate(tx_packet, total_bytes); net_checksum_calculate(s->tx_packet, total_bytes);
} }
/* Update MAC statistics */ /* Update MAC statistics */
gem_transmit_updatestats(s, tx_packet, total_bytes); gem_transmit_updatestats(s, s->tx_packet, total_bytes);
/* Send the packet somewhere */ /* Send the packet somewhere */
if (s->phy_loop || (s->regs[GEM_NWCTRL] & if (s->phy_loop || (s->regs[GEM_NWCTRL] &
GEM_NWCTRL_LOCALLOOP)) { GEM_NWCTRL_LOCALLOOP)) {
gem_receive(qemu_get_queue(s->nic), tx_packet, gem_receive(qemu_get_queue(s->nic), s->tx_packet,
total_bytes); total_bytes);
} else { } else {
qemu_send_packet(qemu_get_queue(s->nic), tx_packet, qemu_send_packet(qemu_get_queue(s->nic), s->tx_packet,
total_bytes); total_bytes);
} }
/* Prepare for next packet */ /* Prepare for next packet */
p = tx_packet; p = s->tx_packet;
total_bytes = 0; total_bytes = 0;
} }

4
include/hw/net/cadence_gem.h
View file

@ -40,6 +40,8 @@
#define MAX_TYPE1_SCREENERS 16 #define MAX_TYPE1_SCREENERS 16
#define MAX_TYPE2_SCREENERS 16 #define MAX_TYPE2_SCREENERS 16
#define MAX_FRAME_SIZE 2048
typedef struct CadenceGEMState { typedef struct CadenceGEMState {
/*< private >*/ /*< private >*/
SysBusDevice parent_obj; SysBusDevice parent_obj;
@ -80,6 +82,8 @@ typedef struct CadenceGEMState {
uint8_t can_rx_state; /* Debug only */ uint8_t can_rx_state; /* Debug only */
uint8_t tx_packet[MAX_FRAME_SIZE];
uint8_t rx_packet[MAX_FRAME_SIZE];
uint32_t rx_desc[MAX_PRIORITY_QUEUES][DESC_MAX_NUM_WORDS]; uint32_t rx_desc[MAX_PRIORITY_QUEUES][DESC_MAX_NUM_WORDS];
bool sar_active[4]; bool sar_active[4];