|
@@ -423,16 +423,27 @@ ssize_t qemu_deliver_packet_iov(NetClientState *sender,
|
|
void *opaque)
|
|
void *opaque)
|
|
{
|
|
{
|
|
NetClientState *nc = opaque;
|
|
NetClientState *nc = opaque;
|
|
|
|
+ int ret;
|
|
|
|
|
|
if (nc->link_down) {
|
|
if (nc->link_down) {
|
|
return iov_size(iov, iovcnt);
|
|
return iov_size(iov, iovcnt);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ if (nc->receive_disabled) {
|
|
|
|
+ return 0;
|
|
|
|
+ }
|
|
|
|
+
|
|
if (nc->info->receive_iov) {
|
|
if (nc->info->receive_iov) {
|
|
- return nc->info->receive_iov(nc, iov, iovcnt);
|
|
|
|
|
|
+ ret = nc->info->receive_iov(nc, iov, iovcnt);
|
|
} else {
|
|
} else {
|
|
- return nc_sendv_compat(nc, iov, iovcnt);
|
|
|
|
|
|
+ ret = nc_sendv_compat(nc, iov, iovcnt);
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ if (ret == 0) {
|
|
|
|
+ nc->receive_disabled = 1;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ return ret;
|
|
}
|
|
}
|
|
|
|
|
|
ssize_t qemu_sendv_packet_async(NetClientState *sender,
|
|
ssize_t qemu_sendv_packet_async(NetClientState *sender,
|