Re: [PATCH v4 2/3] tests/util-sockets: add abstract unix socket cases

2020-05-15 Thread Daniel P . Berrangé
On Fri, May 15, 2020 at 12:32:34PM +0800, xiaoqiang zhao wrote:
> add cases to test tight and non-tight for abstract address type
> 
> Signed-off-by: xiaoqiang zhao 
> ---
>  tests/test-util-sockets.c | 91 +++
>  1 file changed, 91 insertions(+)
> 
> diff --git a/tests/test-util-sockets.c b/tests/test-util-sockets.c
> index 5fd947c7bf..c21a90634a 100644
> --- a/tests/test-util-sockets.c
> +++ b/tests/test-util-sockets.c
> @@ -227,6 +227,92 @@ static void test_socket_fd_pass_num_nocli(void)
>  g_free(addr.u.fd.str);
>  }
>  
> +static gchar *abstract_sock_name;
> +
> +static gpointer unix_server_thread_func(gpointer user_data)
> +{
> +SocketAddress addr;
> +Error *err = NULL;
> +int fd = -1;
> +int connfd = -1;
> +struct sockaddr_un un;
> +socklen_t len = sizeof(un);
> +
> +addr.type = SOCKET_ADDRESS_TYPE_UNIX;
> +addr.u.q_unix.path = abstract_sock_name;
> +addr.u.q_unix.tight = user_data != NULL;
> +addr.u.q_unix.abstract = true;
> +
> +fd = socket_listen(, 1, );
> +g_assert_cmpint(fd, >=, 0);
> +g_assert(fd_is_socket(fd));
> +
> +connfd = accept(fd, (struct sockaddr *), );
> +g_assert_cmpint(connfd, !=, -1);
> +
> +close(fd);
> +
> +return NULL;
> +}
> +
> +static gpointer unix_client_thread_func(gpointer user_data)
> +{
> +SocketAddress addr;
> +Error *err = NULL;
> +int fd = -1;
> +
> +addr.type = SOCKET_ADDRESS_TYPE_UNIX;
> +addr.u.q_unix.path = abstract_sock_name;
> +addr.u.q_unix.tight = user_data != NULL;
> +addr.u.q_unix.abstract = true;
> +
> +fd = socket_connect(, );
> +
> +g_assert_cmpint(fd, >=, 0);
> +
> +close(fd);
> +
> +return NULL;
> +}
> +
> +static void test_socket_unix_abstract_good(void)
> +{
> +

Extra blank line

> +GRand *r = g_rand_new();
> +
> +abstract_sock_name = g_strdup_printf("unix-%d-%d", getpid(),
> +g_rand_int_range(r, 100, 1000));

This g_rand_int_range should be indented more 

> +
> +/* non tight socklen serv and cli */
> +GThread *serv = g_thread_new("abstract_unix_server",
> + unix_server_thread_func,
> + NULL);
> +
> +sleep(1);
> +
> +GThread *cli = g_thread_new("abstruct_unix_client",

s/abstruct/abstract/

> +unix_client_thread_func,
> +NULL);
> +
> +g_thread_join(cli);
> +g_thread_join(serv);
> +
> +/* tight socklen serv and cli */
> +serv = g_thread_new("abstract_unix_server",
> +unix_server_thread_func,
> +(gpointer)1);
> +
> +sleep(1);
> +
> +cli = g_thread_new("abstruct_unix_client",

s/abstruct/abstract/

> +   unix_client_thread_func,
> +   (gpointer)1);
> +
> +g_thread_join(cli);
> +g_thread_join(serv);
> +
> +g_free(abstract_sock_name);
> +}

Everything above here needs to be wrapped in ifdef __linux__ otherwise
the compiler is liable to complain about unused static functions

>  
>  int main(int argc, char **argv)
>  {
> @@ -265,6 +351,11 @@ int main(int argc, char **argv)
>  test_socket_fd_pass_num_nocli);
>  }
>  
> +#ifdef __linux__
> +g_test_add_func("/util/socket/unix-abstract/good",
> +test_socket_unix_abstract_good);

This is indented a little too much

> +#endif
> +
>  end:
>  return g_test_run();
>  }
> -- 
> 2.17.1
> 

Regards,
Daniel
-- 
|: https://berrange.com  -o-https://www.flickr.com/photos/dberrange :|
|: https://libvirt.org -o-https://fstop138.berrange.com :|
|: https://entangle-photo.org-o-https://www.instagram.com/dberrange :|




[PATCH v4 2/3] tests/util-sockets: add abstract unix socket cases

2020-05-14 Thread xiaoqiang zhao
add cases to test tight and non-tight for abstract address type

Signed-off-by: xiaoqiang zhao 
---
 tests/test-util-sockets.c | 91 +++
 1 file changed, 91 insertions(+)

diff --git a/tests/test-util-sockets.c b/tests/test-util-sockets.c
index 5fd947c7bf..c21a90634a 100644
--- a/tests/test-util-sockets.c
+++ b/tests/test-util-sockets.c
@@ -227,6 +227,92 @@ static void test_socket_fd_pass_num_nocli(void)
 g_free(addr.u.fd.str);
 }
 
+static gchar *abstract_sock_name;
+
+static gpointer unix_server_thread_func(gpointer user_data)
+{
+SocketAddress addr;
+Error *err = NULL;
+int fd = -1;
+int connfd = -1;
+struct sockaddr_un un;
+socklen_t len = sizeof(un);
+
+addr.type = SOCKET_ADDRESS_TYPE_UNIX;
+addr.u.q_unix.path = abstract_sock_name;
+addr.u.q_unix.tight = user_data != NULL;
+addr.u.q_unix.abstract = true;
+
+fd = socket_listen(, 1, );
+g_assert_cmpint(fd, >=, 0);
+g_assert(fd_is_socket(fd));
+
+connfd = accept(fd, (struct sockaddr *), );
+g_assert_cmpint(connfd, !=, -1);
+
+close(fd);
+
+return NULL;
+}
+
+static gpointer unix_client_thread_func(gpointer user_data)
+{
+SocketAddress addr;
+Error *err = NULL;
+int fd = -1;
+
+addr.type = SOCKET_ADDRESS_TYPE_UNIX;
+addr.u.q_unix.path = abstract_sock_name;
+addr.u.q_unix.tight = user_data != NULL;
+addr.u.q_unix.abstract = true;
+
+fd = socket_connect(, );
+
+g_assert_cmpint(fd, >=, 0);
+
+close(fd);
+
+return NULL;
+}
+
+static void test_socket_unix_abstract_good(void)
+{
+
+GRand *r = g_rand_new();
+
+abstract_sock_name = g_strdup_printf("unix-%d-%d", getpid(),
+g_rand_int_range(r, 100, 1000));
+
+/* non tight socklen serv and cli */
+GThread *serv = g_thread_new("abstract_unix_server",
+ unix_server_thread_func,
+ NULL);
+
+sleep(1);
+
+GThread *cli = g_thread_new("abstruct_unix_client",
+unix_client_thread_func,
+NULL);
+
+g_thread_join(cli);
+g_thread_join(serv);
+
+/* tight socklen serv and cli */
+serv = g_thread_new("abstract_unix_server",
+unix_server_thread_func,
+(gpointer)1);
+
+sleep(1);
+
+cli = g_thread_new("abstruct_unix_client",
+   unix_client_thread_func,
+   (gpointer)1);
+
+g_thread_join(cli);
+g_thread_join(serv);
+
+g_free(abstract_sock_name);
+}
 
 int main(int argc, char **argv)
 {
@@ -265,6 +351,11 @@ int main(int argc, char **argv)
 test_socket_fd_pass_num_nocli);
 }
 
+#ifdef __linux__
+g_test_add_func("/util/socket/unix-abstract/good",
+test_socket_unix_abstract_good);
+#endif
+
 end:
 return g_test_run();
 }
-- 
2.17.1