mirror of https://github.com/xqemu/xqemu.git
xen: Drop net_rx_ok
Let net_rx_packet() (which checks the same conditions) drops the packet if the device is not ready. Drop net_xen_info.can_receive and update the return value for the buffer full case. We rely on the qemu_flush_queued_packets() in net_event() to wake up the peer when the buffer becomes available again. Signed-off-by: Fam Zheng <famz@redhat.com> Message-id: 1438077176-378-1-git-send-email-famz@redhat.com Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
This commit is contained in:
parent
ff1d2ac949
commit
7bba83bf80
|
@ -234,27 +234,6 @@ static void net_rx_response(struct XenNetDev *netdev,
|
||||||
|
|
||||||
#define NET_IP_ALIGN 2
|
#define NET_IP_ALIGN 2
|
||||||
|
|
||||||
static int net_rx_ok(NetClientState *nc)
|
|
||||||
{
|
|
||||||
struct XenNetDev *netdev = qemu_get_nic_opaque(nc);
|
|
||||||
RING_IDX rc, rp;
|
|
||||||
|
|
||||||
if (netdev->xendev.be_state != XenbusStateConnected) {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
rc = netdev->rx_ring.req_cons;
|
|
||||||
rp = netdev->rx_ring.sring->req_prod;
|
|
||||||
xen_rmb();
|
|
||||||
|
|
||||||
if (rc == rp || RING_REQUEST_CONS_OVERFLOW(&netdev->rx_ring, rc)) {
|
|
||||||
xen_be_printf(&netdev->xendev, 2, "%s: no rx buffers (%d/%d)\n",
|
|
||||||
__FUNCTION__, rc, rp);
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
return 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
static ssize_t net_rx_packet(NetClientState *nc, const uint8_t *buf, size_t size)
|
static ssize_t net_rx_packet(NetClientState *nc, const uint8_t *buf, size_t size)
|
||||||
{
|
{
|
||||||
struct XenNetDev *netdev = qemu_get_nic_opaque(nc);
|
struct XenNetDev *netdev = qemu_get_nic_opaque(nc);
|
||||||
|
@ -271,8 +250,7 @@ static ssize_t net_rx_packet(NetClientState *nc, const uint8_t *buf, size_t size
|
||||||
xen_rmb(); /* Ensure we see queued requests up to 'rp'. */
|
xen_rmb(); /* Ensure we see queued requests up to 'rp'. */
|
||||||
|
|
||||||
if (rc == rp || RING_REQUEST_CONS_OVERFLOW(&netdev->rx_ring, rc)) {
|
if (rc == rp || RING_REQUEST_CONS_OVERFLOW(&netdev->rx_ring, rc)) {
|
||||||
xen_be_printf(&netdev->xendev, 2, "no buffer, drop packet\n");
|
return 0;
|
||||||
return -1;
|
|
||||||
}
|
}
|
||||||
if (size > XC_PAGE_SIZE - NET_IP_ALIGN) {
|
if (size > XC_PAGE_SIZE - NET_IP_ALIGN) {
|
||||||
xen_be_printf(&netdev->xendev, 0, "packet too big (%lu > %ld)",
|
xen_be_printf(&netdev->xendev, 0, "packet too big (%lu > %ld)",
|
||||||
|
@ -304,7 +282,6 @@ static ssize_t net_rx_packet(NetClientState *nc, const uint8_t *buf, size_t size
|
||||||
static NetClientInfo net_xen_info = {
|
static NetClientInfo net_xen_info = {
|
||||||
.type = NET_CLIENT_OPTIONS_KIND_NIC,
|
.type = NET_CLIENT_OPTIONS_KIND_NIC,
|
||||||
.size = sizeof(NICState),
|
.size = sizeof(NICState),
|
||||||
.can_receive = net_rx_ok,
|
|
||||||
.receive = net_rx_packet,
|
.receive = net_rx_packet,
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue