aboutsummaryrefslogtreecommitdiff
path: root/tests/test-util-sockets.c
diff options
context:
space:
mode:
authorMarkus Armbruster <armbru@redhat.com>2020-11-02 10:44:15 +0100
committerDaniel P. Berrangé <berrange@redhat.com>2020-11-03 13:09:28 +0000
commit89cb0bb554ee2365d948d3f593ea04f03d5bc4f8 (patch)
tree7c04e1463e35ab27399ef39e8ea71446a85d2dbc /tests/test-util-sockets.c
parent718a9be02df880ca4b4e34ce253daf2bfc5d059c (diff)
test-util-sockets: Factor out test_socket_unix_abstract_one()
Reviewed-by: Paolo Bonzini <pbonzini@redhat.com> Reviewed-by: Eric Blake <eblake@redhat.com> Signed-off-by: Markus Armbruster <armbru@redhat.com> Signed-off-by: Daniel P. Berrangé <berrange@redhat.com>
Diffstat (limited to 'tests/test-util-sockets.c')
-rw-r--r--tests/test-util-sockets.c48
1 files changed, 20 insertions, 28 deletions
diff --git a/tests/test-util-sockets.c b/tests/test-util-sockets.c
index a4792253ba..40ff893e64 100644
--- a/tests/test-util-sockets.c
+++ b/tests/test-util-sockets.c
@@ -261,6 +261,24 @@ static gpointer unix_client_thread_func(gpointer user_data)
return NULL;
}
+static void test_socket_unix_abstract_one(SocketAddress *addr)
+{
+ GThread *serv, *cli;
+
+ serv = g_thread_new("abstract_unix_server",
+ unix_server_thread_func,
+ addr);
+
+ sleep(1);
+
+ cli = g_thread_new("abstract_unix_client",
+ unix_client_thread_func,
+ addr);
+
+ g_thread_join(cli);
+ g_thread_join(serv);
+}
+
static void test_socket_unix_abstract_good(void)
{
SocketAddress addr;
@@ -272,40 +290,14 @@ static void test_socket_unix_abstract_good(void)
addr.u.q_unix.abstract = true;
/* non tight socklen serv and cli */
-
addr.u.q_unix.has_tight = false;
addr.u.q_unix.tight = false;
-
- GThread *serv = g_thread_new("abstract_unix_server",
- unix_server_thread_func,
- &addr);
-
- sleep(1);
-
- GThread *cli = g_thread_new("abstract_unix_client",
- unix_client_thread_func,
- &addr);
-
- g_thread_join(cli);
- g_thread_join(serv);
+ test_socket_unix_abstract_one(&addr);
/* tight socklen serv and cli */
-
addr.u.q_unix.has_tight = true;
addr.u.q_unix.tight = true;
-
- serv = g_thread_new("abstract_unix_server",
- unix_server_thread_func,
- &addr);
-
- sleep(1);
-
- cli = g_thread_new("abstract_unix_client",
- unix_client_thread_func,
- &addr);
-
- g_thread_join(cli);
- g_thread_join(serv);
+ test_socket_unix_abstract_one(&addr);
g_free(addr.u.q_unix.path);
}