On Fri, Sep 05, 2025 at 05:49:34PM +0200, Laurent Vivier wrote:
Pass the virtqueue pointer to udp_vu_sock_recv() to enable proper queue selection for multiqueue support. This ensures that received packets are processed on the same virtqueue as the caller.
Signed-off-by: Laurent Vivier
Reviewed-by: David Gibson
--- udp_vu.c | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-)
diff --git a/udp_vu.c b/udp_vu.c index 2fb7b900ca31..099677f914e7 100644 --- a/udp_vu.c +++ b/udp_vu.c @@ -60,16 +60,17 @@ static size_t udp_vu_hdrlen(bool v6) /** * udp_vu_sock_recv() - Receive datagrams from socket into vhost-user buffers * @c: Execution context + * @vq: virtqueue to use to receive data * @s: Socket to receive from * @v6: Set for IPv6 connections * @dlen: Size of received data (output) * * Return: number of iov entries used to store the datagram */ -static int udp_vu_sock_recv(const struct ctx *c, int s, bool v6, ssize_t *dlen) +static int udp_vu_sock_recv(const struct ctx *c, struct vu_virtq *vq, int s, + bool v6, ssize_t *dlen) { - struct vu_dev *vdev = c->vdev; - struct vu_virtq *vq = &vdev->vq[VHOST_USER_RX_QUEUE]; + const struct vu_dev *vdev = c->vdev; int iov_cnt, idx, iov_used; struct msghdr msg = { 0 }; size_t off, hdrlen; @@ -210,7 +211,7 @@ void udp_vu_sock_to_tap(const struct ctx *c, int s, int n, flow_sidx_t tosidx) ssize_t dlen; int iov_used;
- iov_used = udp_vu_sock_recv(c, s, v6, &dlen); + iov_used = udp_vu_sock_recv(c, vq, s, v6, &dlen); if (iov_used <= 0) break;
-- 2.50.1
-- David Gibson (he or they) | I'll have my music baroque, and my code david AT gibson.dropbear.id.au | minimalist, thank you, not the other way | around. http://www.ozlabs.org/~dgibson