diff mbox series

[PULL,v4,34/48] vhost-user: save features of multiqueues if chardev is closed

Message ID 20200929071948.281157-35-mst@redhat.com
State New
Headers show
Series virtio,pc,acpi: fixes, tests | expand

Commit Message

Michael S. Tsirkin Sept. 29, 2020, 7:22 a.m. UTC
From: haibinzhang(张海斌) <haibinzhang@tencent.com>

Fore-commit(c6beefd674) only saves features of queue0,
this makes wrong features of other queues in multiqueues
situation.
For examples:
  qemu-system-aarch64 ... \
  -chardev socket,id=charnet0,path=/var/run/vhost_sock \
  -netdev vhost-user,chardev=charnet0,queues=2,id=hostnet0 \
  ...
There are two queues in nic assocated with one chardev.
When chardev is reconnected, it is necessary to save and
restore features of all queues.

Signed-of-by: Haibin Zhang <haibinzhang@tencent.com>
Message-Id: <46CBC206-E0CA-4249-81CD-10F75DA30441@tencent.com>
Reviewed-by: Michael S. Tsirkin <mst@redhat.com>
Signed-off-by: Michael S. Tsirkin <mst@redhat.com>
---
 net/vhost-user.c | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

Comments

Michael S. Tsirkin May 12, 2021, 7:58 a.m. UTC | #1
On Tue, Sep 29, 2020 at 03:22:25AM -0400, Michael S. Tsirkin wrote:
> From: haibinzhang(张海斌) <haibinzhang@tencent.com>

> 

> Fore-commit(c6beefd674) only saves features of queue0,

> this makes wrong features of other queues in multiqueues

> situation.

> For examples:

>   qemu-system-aarch64 ... \

>   -chardev socket,id=charnet0,path=/var/run/vhost_sock \

>   -netdev vhost-user,chardev=charnet0,queues=2,id=hostnet0 \

>   ...

> There are two queues in nic assocated with one chardev.

> When chardev is reconnected, it is necessary to save and

> restore features of all queues.

> 

> Signed-of-by: Haibin Zhang <haibinzhang@tencent.com>

> Message-Id: <46CBC206-E0CA-4249-81CD-10F75DA30441@tencent.com>

> Reviewed-by: Michael S. Tsirkin <mst@redhat.com>

> Signed-off-by: Michael S. Tsirkin <mst@redhat.com>


Cc: qemu-stable@nongnu.org

> ---

>  net/vhost-user.c | 10 +++++++---

>  1 file changed, 7 insertions(+), 3 deletions(-)

> 

> diff --git a/net/vhost-user.c b/net/vhost-user.c

> index 17532daaf3..ffbd94d944 100644

> --- a/net/vhost-user.c

> +++ b/net/vhost-user.c

> @@ -226,7 +226,7 @@ static void chr_closed_bh(void *opaque)

>      NetClientState *ncs[MAX_QUEUE_NUM];

>      NetVhostUserState *s;

>      Error *err = NULL;

> -    int queues;

> +    int queues, i;

>  

>      queues = qemu_find_net_clients_except(name, ncs,

>                                            NET_CLIENT_DRIVER_NIC,

> @@ -235,8 +235,12 @@ static void chr_closed_bh(void *opaque)

>  

>      s = DO_UPCAST(NetVhostUserState, nc, ncs[0]);

>  

> -    if (s->vhost_net) {

> -        s->acked_features = vhost_net_get_acked_features(s->vhost_net);

> +    for (i = queues -1; i >= 0; i--) {

> +        s = DO_UPCAST(NetVhostUserState, nc, ncs[i]);

> +

> +        if (s->vhost_net) {

> +            s->acked_features = vhost_net_get_acked_features(s->vhost_net);

> +        }

>      }

>  

>      qmp_set_link(name, false, &err);

> -- 

> MST

>
diff mbox series

Patch

diff --git a/net/vhost-user.c b/net/vhost-user.c
index 17532daaf3..ffbd94d944 100644
--- a/net/vhost-user.c
+++ b/net/vhost-user.c
@@ -226,7 +226,7 @@  static void chr_closed_bh(void *opaque)
     NetClientState *ncs[MAX_QUEUE_NUM];
     NetVhostUserState *s;
     Error *err = NULL;
-    int queues;
+    int queues, i;
 
     queues = qemu_find_net_clients_except(name, ncs,
                                           NET_CLIENT_DRIVER_NIC,
@@ -235,8 +235,12 @@  static void chr_closed_bh(void *opaque)
 
     s = DO_UPCAST(NetVhostUserState, nc, ncs[0]);
 
-    if (s->vhost_net) {
-        s->acked_features = vhost_net_get_acked_features(s->vhost_net);
+    for (i = queues -1; i >= 0; i--) {
+        s = DO_UPCAST(NetVhostUserState, nc, ncs[i]);
+
+        if (s->vhost_net) {
+            s->acked_features = vhost_net_get_acked_features(s->vhost_net);
+        }
     }
 
     qmp_set_link(name, false, &err);