[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-ID: <u364jxu7r6gyynkzvlt3n2jeiklgyyqyb7ws4fod7nzwfe3dru@2dkvlpwnie56>
Date: Wed, 22 Jan 2025 12:39:49 +0100
From: Stefano Garzarella <sgarzare@...hat.com>
To: Michal Luczaj <mhal@...x.co>
Cc: "David S. Miller" <davem@...emloft.net>,
Eric Dumazet <edumazet@...gle.com>, Jakub Kicinski <kuba@...nel.org>,
Paolo Abeni <pabeni@...hat.com>, Simon Horman <horms@...nel.org>,
George Zhang <georgezhang@...are.com>, Dmitry Torokhov <dtor@...are.com>, Andy King <acking@...are.com>,
netdev@...r.kernel.org
Subject: Re: [PATCH net v2 4/6] vsock/test: Introduce vsock_connect_fd()
On Tue, Jan 21, 2025 at 03:44:05PM +0100, Michal Luczaj wrote:
>Distill timeout-guarded vsock_connect_fd(). Adapt callers.
>
>Suggested-by: Stefano Garzarella <sgarzare@...hat.com>
>Signed-off-by: Michal Luczaj <mhal@...x.co>
>---
> tools/testing/vsock/util.c | 45 +++++++++++++++++----------------------------
> tools/testing/vsock/util.h | 1 +
> 2 files changed, 18 insertions(+), 28 deletions(-)
Reviewed-by: Stefano Garzarella <sgarzare@...hat.com>
>
>diff --git a/tools/testing/vsock/util.c b/tools/testing/vsock/util.c
>index 31ee1767c8b73c05cfd219c3d520a677df6e66a6..7f7e45a6596c19b09176ea2851a490cdac0f115b 100644
>--- a/tools/testing/vsock/util.c
>+++ b/tools/testing/vsock/util.c
>@@ -119,27 +119,33 @@ int vsock_bind(unsigned int cid, unsigned int port, int type)
> return fd;
> }
>
>-/* Bind to <bind_port>, connect to <cid, port> and return the file descriptor. */
>-int vsock_bind_connect(unsigned int cid, unsigned int port, unsigned int bind_port, int type)
>+int vsock_connect_fd(int fd, unsigned int cid, unsigned int port)
> {
>- struct sockaddr_vm sa_server = {
>+ struct sockaddr_vm sa = {
> .svm_family = AF_VSOCK,
> .svm_cid = cid,
> .svm_port = port,
> };
>-
>- int client_fd, ret;
>-
>- client_fd = vsock_bind(VMADDR_CID_ANY, bind_port, type);
>+ int ret;
>
> timeout_begin(TIMEOUT);
> do {
>- ret = connect(client_fd, (struct sockaddr *)&sa_server, sizeof(sa_server));
>+ ret = connect(fd, (struct sockaddr *)&sa, sizeof(sa));
> timeout_check("connect");
> } while (ret < 0 && errno == EINTR);
> timeout_end();
>
>- if (ret < 0) {
>+ return ret;
>+}
>+
>+/* Bind to <bind_port>, connect to <cid, port> and return the file descriptor. */
>+int vsock_bind_connect(unsigned int cid, unsigned int port, unsigned int bind_port, int type)
>+{
>+ int client_fd;
>+
>+ client_fd = vsock_bind(VMADDR_CID_ANY, bind_port, type);
>+
>+ if (vsock_connect_fd(client_fd, cid, port)) {
> perror("connect");
> exit(EXIT_FAILURE);
> }
>@@ -150,17 +156,6 @@ int vsock_bind_connect(unsigned int cid, unsigned int port, unsigned int bind_po
> /* Connect to <cid, port> and return the file descriptor. */
> int vsock_connect(unsigned int cid, unsigned int port, int type)
> {
>- union {
>- struct sockaddr sa;
>- struct sockaddr_vm svm;
>- } addr = {
>- .svm = {
>- .svm_family = AF_VSOCK,
>- .svm_port = port,
>- .svm_cid = cid,
>- },
>- };
>- int ret;
> int fd;
>
> control_expectln("LISTENING");
>@@ -171,20 +166,14 @@ int vsock_connect(unsigned int cid, unsigned int port, int type)
> exit(EXIT_FAILURE);
> }
>
>- timeout_begin(TIMEOUT);
>- do {
>- ret = connect(fd, &addr.sa, sizeof(addr.svm));
>- timeout_check("connect");
>- } while (ret < 0 && errno == EINTR);
>- timeout_end();
>-
>- if (ret < 0) {
>+ if (vsock_connect_fd(fd, cid, port)) {
> int old_errno = errno;
>
> close(fd);
> fd = -1;
> errno = old_errno;
> }
>+
> return fd;
> }
>
>diff --git a/tools/testing/vsock/util.h b/tools/testing/vsock/util.h
>index 7736594a15d29449d98bd1e9e19c3acd1a623443..817e11e483cd6596dd32d16061d801a66091c973 100644
>--- a/tools/testing/vsock/util.h
>+++ b/tools/testing/vsock/util.h
>@@ -39,6 +39,7 @@ struct test_case {
> void init_signals(void);
> unsigned int parse_cid(const char *str);
> unsigned int parse_port(const char *str);
>+int vsock_connect_fd(int fd, unsigned int cid, unsigned int port);
> int vsock_connect(unsigned int cid, unsigned int port, int type);
> int vsock_accept(unsigned int cid, unsigned int port,
> struct sockaddr_vm *clientaddrp, int type);
>
>--
>2.48.1
>
Powered by blists - more mailing lists