[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH v6 16/17] hub: add the support for hub own flow cont
From: |
zwu . kernel |
Subject: |
[Qemu-devel] [PATCH v6 16/17] hub: add the support for hub own flow control |
Date: |
Wed, 20 Jun 2012 17:42:20 +0800 |
From: Zhi Yong Wu <address@hidden>
Only when all other hub port's *peer* .can_receive() all return 1,
the source hub port .can_receive() return 1.
Reviewed-off-by: Paolo Bonzini <address@hidden>
Signed-off-by: Zhi Yong Wu <address@hidden>
---
net/hub.c | 27 ++++++++++++++++++++++++---
1 files changed, 24 insertions(+), 3 deletions(-)
diff --git a/net/hub.c b/net/hub.c
index 230d86a..efd90b5 100644
--- a/net/hub.c
+++ b/net/hub.c
@@ -15,6 +15,7 @@
#include "monitor.h"
#include "net.h"
#include "hub.h"
+#include "iov.h"
/*
* A hub broadcasts incoming packets to all its ports except the source port.
@@ -59,16 +60,16 @@ static ssize_t net_hub_receive_iov(NetHub *hub, NetHubPort
*source_port,
const struct iovec *iov, int iovcnt)
{
NetHubPort *port;
- ssize_t ret = 0;
+ ssize_t len = iov_size(iov, iovcnt);
QLIST_FOREACH(port, &hub->ports, next) {
if (port == source_port) {
continue;
}
- ret = qemu_sendv_packet(&port->nc, iov, iovcnt);
+ qemu_sendv_packet(&port->nc, iov, iovcnt);
}
- return ret;
+ return len;
}
static NetHub *net_hub_new(unsigned int id)
@@ -85,6 +86,25 @@ static NetHub *net_hub_new(unsigned int id)
return hub;
}
+static int net_hub_port_can_receive(NetClientState *nc)
+{
+ NetHubPort *port;
+ NetHubPort *src_port = DO_UPCAST(NetHubPort, nc, nc);
+ NetHub *hub = src_port->hub;
+
+ QLIST_FOREACH(port, &hub->ports, next) {
+ if (port == src_port) {
+ continue;
+ }
+
+ if (!qemu_can_send_packet(&port->nc)) {
+ return 0;
+ }
+ }
+
+ return 1;
+}
+
static ssize_t net_hub_port_receive(NetClientState *nc,
const uint8_t *buf, size_t len)
{
@@ -111,6 +131,7 @@ static void net_hub_port_cleanup(NetClientState *nc)
static NetClientInfo net_hub_port_info = {
.type = NET_CLIENT_TYPE_HUB,
.size = sizeof(NetHubPort),
+ .can_receive = net_hub_port_can_receive,
.receive = net_hub_port_receive,
.receive_iov = net_hub_port_receive_iov,
.cleanup = net_hub_port_cleanup,
--
1.7.6
- [Qemu-devel] [PATCH v6 00/17] hub-based networking patchset, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 02/17] net: Use hubs for the vlan feature, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 04/17] hub: Check that hubs are configured correctly, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 03/17] net: Look up 'vlan' net clients using hubs, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 06/17] net: Remove vlan qdev property, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 11/17] net: Rename vc local variables to nc, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 17/17] net: roll back qdev_prop_vlan, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 14/17] net: cleanup deliver/deliver_iov func pointers, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 16/17] hub: add the support for hub own flow control,
zwu . kernel <=
- [Qemu-devel] [PATCH v6 01/17] net: Add a hub net client, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 08/17] net: Remove VLANState, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 12/17] net: Rename qemu_del_vlan_client() to qemu_del_net_client(), zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 07/17] net: Remove vlan code from net.c, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 13/17] net: Make "info network" output more readable info, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 10/17] net: Rename VLANClientState to NetClientState, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 05/17] net: Drop vlan argument to qemu_new_net_client(), zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 09/17] net: Rename non_vlan_clients to net_clients, zwu . kernel, 2012/06/20
- [Qemu-devel] [PATCH v6 15/17] net: determine if packets can be sent before net queue deliver packets, zwu . kernel, 2012/06/20
- Re: [Qemu-devel] [PATCH v6 00/17] hub-based networking patchset, Stefan Hajnoczi, 2012/06/21