1 /* 2 * Tests for util/qemu-sockets.c 3 * 4 * Copyright 2018 Red Hat, Inc. 5 * 6 * This program is free software; you can redistribute it and/or modify 7 * it under the terms of the GNU General Public License as published by 8 * the Free Software Foundation; either version 2 of the License, or 9 * (at your option) any later version. 10 * 11 * This program is distributed in the hope that it will be useful, 12 * but WITHOUT ANY WARRANTY; without even the implied warranty of 13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 14 * GNU General Public License for more details. 15 * 16 * You should have received a copy of the GNU General Public License 17 * along with this library; if not, see <http://www.gnu.org/licenses/>. 18 * 19 */ 20 21 #include "qemu/osdep.h" 22 #include "qemu-common.h" 23 #include "qemu/sockets.h" 24 #include "qapi/error.h" 25 #include "socket-helpers.h" 26 #include "monitor/monitor.h" 27 28 static void test_fd_is_socket_bad(void) 29 { 30 char *tmp = g_strdup("qemu-test-util-sockets-XXXXXX"); 31 int fd = mkstemp(tmp); 32 if (fd != 0) { 33 unlink(tmp); 34 } 35 g_free(tmp); 36 37 g_assert(fd >= 0); 38 39 g_assert(!fd_is_socket(fd)); 40 close(fd); 41 } 42 43 static void test_fd_is_socket_good(void) 44 { 45 int fd = qemu_socket(PF_INET, SOCK_STREAM, 0); 46 47 g_assert(fd >= 0); 48 49 g_assert(fd_is_socket(fd)); 50 close(fd); 51 } 52 53 static int mon_fd = -1; 54 static const char *mon_fdname; 55 __thread Monitor *cur_mon; 56 57 int monitor_get_fd(Monitor *mon, const char *fdname, Error **errp) 58 { 59 g_assert(cur_mon); 60 g_assert(mon == cur_mon); 61 if (mon_fd == -1 || !g_str_equal(mon_fdname, fdname)) { 62 error_setg(errp, "No fd named %s", fdname); 63 return -1; 64 } 65 return dup(mon_fd); 66 } 67 68 /* 69 * Syms of stubs in libqemuutil.a are discarded at .o file 70 * granularity. To replace monitor_get_fd() and monitor_cur(), we 71 * must ensure that we also replace any other symbol that is used in 72 * the binary and would be taken from the same stub object file, 73 * otherwise we get duplicate syms at link time. 74 */ 75 Monitor *monitor_cur(void) { return cur_mon; } 76 Monitor *monitor_set_cur(Coroutine *co, Monitor *mon) { abort(); } 77 int monitor_vprintf(Monitor *mon, const char *fmt, va_list ap) { abort(); } 78 79 #ifndef _WIN32 80 static void test_socket_fd_pass_name_good(void) 81 { 82 SocketAddress addr; 83 int fd; 84 85 cur_mon = g_malloc(1); /* Fake a monitor */ 86 mon_fdname = "myfd"; 87 mon_fd = qemu_socket(AF_INET, SOCK_STREAM, 0); 88 g_assert_cmpint(mon_fd, >, STDERR_FILENO); 89 90 addr.type = SOCKET_ADDRESS_TYPE_FD; 91 addr.u.fd.str = g_strdup(mon_fdname); 92 93 fd = socket_connect(&addr, &error_abort); 94 g_assert_cmpint(fd, !=, -1); 95 g_assert_cmpint(fd, !=, mon_fd); 96 close(fd); 97 98 fd = socket_listen(&addr, 1, &error_abort); 99 g_assert_cmpint(fd, !=, -1); 100 g_assert_cmpint(fd, !=, mon_fd); 101 close(fd); 102 103 g_free(addr.u.fd.str); 104 mon_fdname = NULL; 105 close(mon_fd); 106 mon_fd = -1; 107 g_free(cur_mon); 108 cur_mon = NULL; 109 } 110 111 static void test_socket_fd_pass_name_bad(void) 112 { 113 SocketAddress addr; 114 Error *err = NULL; 115 int fd; 116 117 cur_mon = g_malloc(1); /* Fake a monitor */ 118 mon_fdname = "myfd"; 119 mon_fd = dup(STDOUT_FILENO); 120 g_assert_cmpint(mon_fd, >, STDERR_FILENO); 121 122 addr.type = SOCKET_ADDRESS_TYPE_FD; 123 addr.u.fd.str = g_strdup(mon_fdname); 124 125 fd = socket_connect(&addr, &err); 126 g_assert_cmpint(fd, ==, -1); 127 error_free_or_abort(&err); 128 129 fd = socket_listen(&addr, 1, &err); 130 g_assert_cmpint(fd, ==, -1); 131 error_free_or_abort(&err); 132 133 g_free(addr.u.fd.str); 134 mon_fdname = NULL; 135 close(mon_fd); 136 mon_fd = -1; 137 g_free(cur_mon); 138 cur_mon = NULL; 139 } 140 141 static void test_socket_fd_pass_name_nomon(void) 142 { 143 SocketAddress addr; 144 Error *err = NULL; 145 int fd; 146 147 g_assert(cur_mon == NULL); 148 149 addr.type = SOCKET_ADDRESS_TYPE_FD; 150 addr.u.fd.str = g_strdup("myfd"); 151 152 fd = socket_connect(&addr, &err); 153 g_assert_cmpint(fd, ==, -1); 154 error_free_or_abort(&err); 155 156 fd = socket_listen(&addr, 1, &err); 157 g_assert_cmpint(fd, ==, -1); 158 error_free_or_abort(&err); 159 160 g_free(addr.u.fd.str); 161 } 162 163 164 static void test_socket_fd_pass_num_good(void) 165 { 166 SocketAddress addr; 167 int fd, sfd; 168 169 g_assert(cur_mon == NULL); 170 sfd = qemu_socket(AF_INET, SOCK_STREAM, 0); 171 g_assert_cmpint(sfd, >, STDERR_FILENO); 172 173 addr.type = SOCKET_ADDRESS_TYPE_FD; 174 addr.u.fd.str = g_strdup_printf("%d", sfd); 175 176 fd = socket_connect(&addr, &error_abort); 177 g_assert_cmpint(fd, ==, sfd); 178 179 fd = socket_listen(&addr, 1, &error_abort); 180 g_assert_cmpint(fd, ==, sfd); 181 182 g_free(addr.u.fd.str); 183 close(sfd); 184 } 185 186 static void test_socket_fd_pass_num_bad(void) 187 { 188 SocketAddress addr; 189 Error *err = NULL; 190 int fd, sfd; 191 192 g_assert(cur_mon == NULL); 193 sfd = dup(STDOUT_FILENO); 194 195 addr.type = SOCKET_ADDRESS_TYPE_FD; 196 addr.u.fd.str = g_strdup_printf("%d", sfd); 197 198 fd = socket_connect(&addr, &err); 199 g_assert_cmpint(fd, ==, -1); 200 error_free_or_abort(&err); 201 202 fd = socket_listen(&addr, 1, &err); 203 g_assert_cmpint(fd, ==, -1); 204 error_free_or_abort(&err); 205 206 g_free(addr.u.fd.str); 207 close(sfd); 208 } 209 210 static void test_socket_fd_pass_num_nocli(void) 211 { 212 SocketAddress addr; 213 Error *err = NULL; 214 int fd; 215 216 cur_mon = g_malloc(1); /* Fake a monitor */ 217 218 addr.type = SOCKET_ADDRESS_TYPE_FD; 219 addr.u.fd.str = g_strdup_printf("%d", STDOUT_FILENO); 220 221 fd = socket_connect(&addr, &err); 222 g_assert_cmpint(fd, ==, -1); 223 error_free_or_abort(&err); 224 225 fd = socket_listen(&addr, 1, &err); 226 g_assert_cmpint(fd, ==, -1); 227 error_free_or_abort(&err); 228 229 g_free(addr.u.fd.str); 230 } 231 #endif 232 233 #ifdef CONFIG_LINUX 234 235 #define ABSTRACT_SOCKET_VARIANTS 3 236 237 typedef struct { 238 SocketAddress *server, *client[ABSTRACT_SOCKET_VARIANTS]; 239 bool expect_connect[ABSTRACT_SOCKET_VARIANTS]; 240 } abstract_socket_matrix_row; 241 242 static gpointer unix_client_thread_func(gpointer user_data) 243 { 244 abstract_socket_matrix_row *row = user_data; 245 Error *err = NULL; 246 int i, fd; 247 248 for (i = 0; i < ABSTRACT_SOCKET_VARIANTS; i++) { 249 if (row->expect_connect[i]) { 250 fd = socket_connect(row->client[i], &error_abort); 251 g_assert_cmpint(fd, >=, 0); 252 } else { 253 fd = socket_connect(row->client[i], &err); 254 g_assert_cmpint(fd, ==, -1); 255 error_free_or_abort(&err); 256 } 257 close(fd); 258 } 259 return NULL; 260 } 261 262 static void test_socket_unix_abstract_row(abstract_socket_matrix_row *test) 263 { 264 int fd, connfd, i; 265 GThread *cli; 266 struct sockaddr_un un; 267 socklen_t len = sizeof(un); 268 269 /* Last one must connect, or else accept() below hangs */ 270 assert(test->expect_connect[ABSTRACT_SOCKET_VARIANTS - 1]); 271 272 fd = socket_listen(test->server, 1, &error_abort); 273 g_assert_cmpint(fd, >=, 0); 274 g_assert(fd_is_socket(fd)); 275 276 cli = g_thread_new("abstract_unix_client", 277 unix_client_thread_func, 278 test); 279 280 for (i = 0; i < ABSTRACT_SOCKET_VARIANTS; i++) { 281 if (test->expect_connect[i]) { 282 connfd = accept(fd, (struct sockaddr *)&un, &len); 283 g_assert_cmpint(connfd, !=, -1); 284 close(connfd); 285 } 286 } 287 288 close(fd); 289 g_thread_join(cli); 290 } 291 292 static void test_socket_unix_abstract(void) 293 { 294 SocketAddress addr, addr_tight, addr_padded; 295 abstract_socket_matrix_row matrix[ABSTRACT_SOCKET_VARIANTS] = { 296 { &addr, 297 { &addr_tight, &addr_padded, &addr }, 298 { true, false, true } }, 299 { &addr_tight, 300 { &addr_padded, &addr, &addr_tight }, 301 { false, true, true } }, 302 { &addr_padded, 303 { &addr, &addr_tight, &addr_padded }, 304 { false, false, true } } 305 }; 306 int i; 307 308 i = g_file_open_tmp("unix-XXXXXX", &addr.u.q_unix.path, NULL); 309 g_assert_true(i >= 0); 310 close(i); 311 312 addr.type = SOCKET_ADDRESS_TYPE_UNIX; 313 addr.u.q_unix.has_abstract = true; 314 addr.u.q_unix.abstract = true; 315 addr.u.q_unix.has_tight = false; 316 addr.u.q_unix.tight = false; 317 318 addr_tight = addr; 319 addr_tight.u.q_unix.has_tight = true; 320 addr_tight.u.q_unix.tight = true; 321 322 addr_padded = addr; 323 addr_padded.u.q_unix.has_tight = true; 324 addr_padded.u.q_unix.tight = false; 325 326 for (i = 0; i < ABSTRACT_SOCKET_VARIANTS; i++) { 327 test_socket_unix_abstract_row(&matrix[i]); 328 } 329 330 g_free(addr.u.q_unix.path); 331 } 332 333 #endif /* CONFIG_LINUX */ 334 335 int main(int argc, char **argv) 336 { 337 bool has_ipv4, has_ipv6; 338 339 qemu_init_main_loop(&error_abort); 340 socket_init(); 341 342 g_test_init(&argc, &argv, NULL); 343 344 /* We're creating actual IPv4/6 sockets, so we should 345 * check if the host running tests actually supports 346 * each protocol to avoid breaking tests on machines 347 * with either IPv4 or IPv6 disabled. 348 */ 349 if (socket_check_protocol_support(&has_ipv4, &has_ipv6) < 0) { 350 g_printerr("socket_check_protocol_support() failed\n"); 351 goto end; 352 } 353 354 if (has_ipv4) { 355 g_test_add_func("/util/socket/is-socket/bad", 356 test_fd_is_socket_bad); 357 g_test_add_func("/util/socket/is-socket/good", 358 test_fd_is_socket_good); 359 #ifndef _WIN32 360 g_test_add_func("/socket/fd-pass/name/good", 361 test_socket_fd_pass_name_good); 362 g_test_add_func("/socket/fd-pass/name/bad", 363 test_socket_fd_pass_name_bad); 364 g_test_add_func("/socket/fd-pass/name/nomon", 365 test_socket_fd_pass_name_nomon); 366 g_test_add_func("/socket/fd-pass/num/good", 367 test_socket_fd_pass_num_good); 368 g_test_add_func("/socket/fd-pass/num/bad", 369 test_socket_fd_pass_num_bad); 370 g_test_add_func("/socket/fd-pass/num/nocli", 371 test_socket_fd_pass_num_nocli); 372 #endif 373 } 374 375 #ifdef CONFIG_LINUX 376 g_test_add_func("/util/socket/unix-abstract", 377 test_socket_unix_abstract); 378 #endif 379 380 end: 381 return g_test_run(); 382 } 383