/libuv/test/ |
H A D | test-udp-send-unreachable.c | 123 ASSERT_OK(r); in TEST_IMPL() 126 ASSERT_OK(r); in TEST_IMPL() 129 ASSERT_OK(r); in TEST_IMPL() 132 ASSERT_OK(r); in TEST_IMPL() 135 ASSERT_OK(r); in TEST_IMPL() 146 ASSERT_OK(r); in TEST_IMPL() 156 ASSERT_OK(r); in TEST_IMPL() 160 ASSERT_OK(r); in TEST_IMPL() 165 ASSERT_OK(r); in TEST_IMPL() 168 ASSERT_OK(r); in TEST_IMPL() [all …]
|
H A D | test-udp-multicast-join6.c | 109 ASSERT_OK(flags); in cl_recv_cb() 135 ASSERT_OK(r); in cl_recv_cb() 138 ASSERT_OK(r); in cl_recv_cb() 141 ASSERT_OK(r); in cl_recv_cb() 144 ASSERT_OK(r); in cl_recv_cb() 178 ASSERT_OK(r); in TEST_IMPL() 181 ASSERT_OK(r); in TEST_IMPL() 185 ASSERT_OK(r); in TEST_IMPL() 193 ASSERT_OK(r); in TEST_IMPL() 205 ASSERT_OK(r); in TEST_IMPL() [all …]
|
H A D | test-tcp-read-stop.c | 43 ASSERT_OK(uv_write(&write_req, in timer_cb() 48 ASSERT_OK(uv_read_stop((uv_stream_t*) &tcp_handle)); in timer_cb() 53 ASSERT_OK(status); in connect_cb() 54 ASSERT_OK(uv_timer_start(&timer_handle, timer_cb, 50, 0)); in connect_cb() 55 ASSERT_OK(uv_read_start((uv_stream_t*) &tcp_handle, in connect_cb() 65 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 66 ASSERT_OK(uv_timer_init(uv_default_loop(), &timer_handle)); in TEST_IMPL() 67 ASSERT_OK(uv_tcp_init(uv_default_loop(), &tcp_handle)); in TEST_IMPL() 68 ASSERT_OK(uv_tcp_connect(&connect_req, in TEST_IMPL() 72 ASSERT_OK(uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL()
|
H A D | test-semaphore.c | 43 ASSERT_OK(c->posted); in worker() 56 ASSERT_OK(uv_sem_init(&wc.sem, 0)); in TEST_IMPL() 57 ASSERT_OK(uv_mutex_init(&wc.mutex)); in TEST_IMPL() 58 ASSERT_OK(uv_thread_create(&thread, worker, &wc)); in TEST_IMPL() 66 ASSERT_OK(uv_thread_join(&thread)); in TEST_IMPL() 81 ASSERT_OK(uv_sem_init(&wc.sem, 0)); in TEST_IMPL() 82 ASSERT_OK(uv_mutex_init(&wc.mutex)); in TEST_IMPL() 87 ASSERT_OK(uv_thread_join(&thread)); in TEST_IMPL() 98 ASSERT_OK(uv_sem_init(&sem, 3)); in TEST_IMPL() 101 ASSERT_OK(uv_sem_trywait(&sem)); in TEST_IMPL() [all …]
|
H A D | test-udp-bind.c | 36 ASSERT_OK(uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); in TEST_IMPL() 41 ASSERT_OK(r); in TEST_IMPL() 44 ASSERT_OK(r); in TEST_IMPL() 47 ASSERT_OK(r); in TEST_IMPL() 56 ASSERT_OK(r); in TEST_IMPL() 69 ASSERT_OK(uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); in TEST_IMPL() 74 ASSERT_OK(r); in TEST_IMPL() 77 ASSERT_OK(r); in TEST_IMPL() 80 ASSERT_OK(r); in TEST_IMPL() 83 ASSERT_OK(r); in TEST_IMPL() [all …]
|
H A D | test-process-title-threadsafe.c | 49 ASSERT_OK(uv_get_process_title(buffer, sizeof(buffer))); in getter_thread_body() 73 ASSERT_OK(uv_set_process_title(titles[0])); in setter_thread_body() 74 ASSERT_OK(uv_set_process_title(titles[1])); in setter_thread_body() 75 ASSERT_OK(uv_set_process_title(titles[2])); in setter_thread_body() 76 ASSERT_OK(uv_set_process_title(titles[3])); in setter_thread_body() 92 ASSERT_OK(uv_set_process_title(titles[0])); in TEST_IMPL() 94 ASSERT_OK(uv_sem_init(&getter_sem, 0)); in TEST_IMPL() 95 ASSERT_OK(uv_thread_create(&getter_thread, getter_thread_body, &getter_sem)); in TEST_IMPL() 98 ASSERT_OK(uv_thread_create(&setter_threads[i], setter_thread_body, NULL)); in TEST_IMPL() 101 ASSERT_OK(uv_thread_join(&setter_threads[i])); in TEST_IMPL() [all …]
|
H A D | test-tcp-close.c | 52 ASSERT_OK(r); in connect_cb() 61 ASSERT_OK(close_cb_called); in write_cb() 75 ASSERT_OK(status); in connection_cb() 86 ASSERT_OK(r); in start_server() 89 ASSERT_OK(r); in start_server() 92 ASSERT_OK(r); in start_server() 115 ASSERT_OK(r); in TEST_IMPL() 121 ASSERT_OK(r); in TEST_IMPL() 123 ASSERT_OK(write_cb_called); in TEST_IMPL() 124 ASSERT_OK(close_cb_called); in TEST_IMPL() [all …]
|
H A D | test-udp-reuseport.c | 46 ASSERT_OK(r); in TEST_IMPL() 49 ASSERT_OK(r); in TEST_IMPL() 52 ASSERT_OK(r); in TEST_IMPL() 58 ASSERT_OK(r); in TEST_IMPL() 171 ASSERT_OK(r); in bind_socket_and_prepare_recv() 179 ASSERT_OK(r); in bind_socket_and_prepare_recv() 182 ASSERT_OK(r); in bind_socket_and_prepare_recv() 202 ASSERT_OK(r); in run_event_loop() 204 ASSERT_OK(r); in run_event_loop() 209 ASSERT_OK(r); in run_event_loop() [all …]
|
H A D | test-ping-pong.c | 86 ASSERT_OK(status); in pinger_after_write() 200 ASSERT_OK(status); in pinger_on_connect() 232 ASSERT_OK(r); in tcp_pinger_v6_new() 240 ASSERT_OK(r); in tcp_pinger_v6_new() 243 ASSERT_OK(pinger_on_connect_count); in tcp_pinger_v6_new() 263 ASSERT_OK(r); in tcp_pinger_new() 271 ASSERT_OK(r); in tcp_pinger_new() 274 ASSERT_OK(pinger_on_connect_count); in tcp_pinger_new() 292 ASSERT_OK(r); in pipe_pinger_new() 300 ASSERT_OK(pinger_on_connect_count); in pipe_pinger_new() [all …]
|
H A D | test-tcp-write-to-half-open-connection.c | 49 ASSERT_OK(status); in connection_cb() 52 ASSERT_OK(r); in connection_cb() 55 ASSERT_OK(r); in connection_cb() 58 ASSERT_OK(r); in connection_cb() 64 ASSERT_OK(r); in connection_cb() 116 ASSERT_OK(r); in TEST_IMPL() 119 ASSERT_OK(r); in TEST_IMPL() 122 ASSERT_OK(r); in TEST_IMPL() 125 ASSERT_OK(r); in TEST_IMPL() 131 ASSERT_OK(r); in TEST_IMPL() [all …]
|
H A D | test-not-readable-nor-writable-on-read-error.c | 38 ASSERT_OK(status); in write_cb() 57 ASSERT_OK(uv_is_writable(handle)); in read_cb() 58 ASSERT_OK(uv_is_readable(handle)); in read_cb() 68 ASSERT_OK(status); in connect_cb() 71 ASSERT_OK(r); in connect_cb() 81 ASSERT_OK(r); in connect_cb() 86 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &sa)); in TEST_IMPL() 87 ASSERT_OK(uv_loop_init(&loop)); in TEST_IMPL() 88 ASSERT_OK(uv_tcp_init(&loop, &tcp_client)); in TEST_IMPL() 90 ASSERT_OK(uv_tcp_connect(&connect_req, in TEST_IMPL() [all …]
|
H A D | test-thread-priority.c | 59 ASSERT_OK(uv_sem_init(&sem, 1)); in TEST_IMPL() 61 ASSERT_OK(uv_thread_create(&task_id, simple_task, NULL)); in TEST_IMPL() 62 ASSERT_OK(uv_thread_getpriority(task_id, &priority)); in TEST_IMPL() 67 ASSERT_OK(pthread_getschedparam(task_id, &policy, ¶m)); in TEST_IMPL() 78 ASSERT_OK(uv_thread_setpriority(task_id, UV_THREAD_PRIORITY_LOWEST)); in TEST_IMPL() 79 ASSERT_OK(uv_thread_getpriority(task_id, &priority)); in TEST_IMPL() 91 ASSERT_OK(uv_thread_getpriority(pthread_self(), &priority)); in TEST_IMPL() 93 ASSERT_OK(uv_thread_setpriority(pthread_self(), UV_THREAD_PRIORITY_LOWEST)); in TEST_IMPL() 94 ASSERT_OK(uv_thread_getpriority(pthread_self(), &priority)); in TEST_IMPL() 100 ASSERT_OK(uv_thread_join(&task_id)); in TEST_IMPL()
|
H A D | test-delayed-accept.c | 57 ASSERT_OK(r); in do_accept() 61 ASSERT_OK(r); in do_accept() 82 ASSERT_OK(status); in connection_cb() 89 ASSERT_OK(r); in connection_cb() 94 ASSERT_OK(r); in connection_cb() 109 ASSERT_OK(r); in start_server() 111 ASSERT_OK(r); in start_server() 114 ASSERT_OK(r); in start_server() 144 ASSERT_OK(r); in connect_cb() 163 ASSERT_OK(r); in client_connect() [all …]
|
H A D | test-udp-ipv6.c | 84 ASSERT_OK(status); in send_cb() 157 ASSERT_OK(r); in do_test() 160 ASSERT_OK(r); in do_test() 173 ASSERT_OK(r); in do_test() 176 ASSERT_OK(r); in do_test() 196 ASSERT_OK(r); in do_test() 205 ASSERT_OK(r); in do_test() 208 ASSERT_OK(r); in do_test() 211 ASSERT_OK(send_cb_called); in do_test() 212 ASSERT_OK(recv_cb_called); in do_test() [all …]
|
H A D | test-tcp-reuseport.c | 44 ASSERT_OK(r); in TEST_IMPL() 140 ASSERT_OK(r); in create_listener() 143 ASSERT_OK(r); in create_listener() 146 ASSERT_OK(r); in create_listener() 166 ASSERT_OK(r); in run_event_loop() 168 ASSERT_OK(r); in run_event_loop() 173 ASSERT_OK(r); in run_event_loop() 182 ASSERT_OK(r); in TEST_IMPL() 185 ASSERT_OK(r); in TEST_IMPL() 211 ASSERT_OK(r); in TEST_IMPL() [all …]
|
H A D | test-tcp-close-accept.c | 50 ASSERT_OK(status); in write_cb() 71 ASSERT_OK(status); in connect_cb() 93 ASSERT_OK(uv_read_stop(stream)); in read_cb() 109 ASSERT_OK(uv_tcp_init(loop, &tcp_check)); in read_cb() 110 ASSERT_OK(uv_tcp_connect(&tcp_check_req, in read_cb() 129 ASSERT_OK(uv_tcp_init(server->loop, incoming)); in connection_cb() 130 ASSERT_OK(uv_accept(server, (uv_stream_t*) incoming)); in connection_cb() 167 ASSERT_OK(uv_tcp_init(loop, &tcp_server)); in TEST_IMPL() 169 ASSERT_OK(uv_listen((uv_stream_t*) &tcp_server, in TEST_IMPL() 176 ASSERT_OK(uv_tcp_init(loop, client)); in TEST_IMPL() [all …]
|
H A D | test-eintr-handling.c | 51 ASSERT_OK(kill(getpid(), SIGUSR1)); in thread_main() 73 ASSERT_OK(uv_signal_init(loop, &signal)); in TEST_IMPL() 74 ASSERT_OK(uv_signal_start(&signal, sig_func, SIGUSR1)); in TEST_IMPL() 76 ASSERT_OK(pipe(pipe_fds)); in TEST_IMPL() 77 ASSERT_OK(uv_thread_create(&thread, thread_main, &ctx)); in TEST_IMPL() 82 ASSERT_OK(strcmp(buf, test_buf)); in TEST_IMPL() 84 ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT)); in TEST_IMPL() 86 ASSERT_OK(close(pipe_fds[0])); in TEST_IMPL() 87 ASSERT_OK(close(pipe_fds[1])); in TEST_IMPL() 90 ASSERT_OK(uv_thread_join(&thread)); in TEST_IMPL()
|
H A D | test-udp-multicast-interface.c | 68 ASSERT_OK(uv_ip4_addr("239.255.0.1", TEST_PORT, &addr)); in TEST_IMPL() 71 ASSERT_OK(r); in TEST_IMPL() 73 ASSERT_OK(uv_ip4_addr("0.0.0.0", 0, &baddr)); in TEST_IMPL() 75 ASSERT_OK(r); in TEST_IMPL() 78 ASSERT_OK(r); in TEST_IMPL() 88 ASSERT_OK(r); in TEST_IMPL() 90 ASSERT_OK(close_cb_called); in TEST_IMPL() 91 ASSERT_OK(sv_send_cb_called); in TEST_IMPL() 99 ASSERT_OK(client.send_queue_size); in TEST_IMPL() 100 ASSERT_OK(server.send_queue_size); in TEST_IMPL()
|
H A D | test-pipe-connect-multiple.c | 51 ASSERT_OK(r); in connection_cb() 54 ASSERT_OK(r); in connection_cb() 83 ASSERT_OK(r); in TEST_IMPL() 86 ASSERT_OK(r); in TEST_IMPL() 89 ASSERT_OK(r); in TEST_IMPL() 93 ASSERT_OK(r); in TEST_IMPL() 117 ASSERT_OK(r); in connection_cb2() 120 ASSERT_OK(r); in connection_cb2() 149 ASSERT_OK(r); in TEST_IMPL() 152 ASSERT_OK(r); in TEST_IMPL() [all …]
|
H A D | test-readable-on-eof.c | 38 ASSERT_OK(status); in write_cb() 62 ASSERT_OK(uv_is_readable(handle)); in read_cb() 63 ASSERT_OK(uv_is_writable(handle)); in read_cb() 66 ASSERT_OK(r); in read_cb() 75 ASSERT_OK(status); in connect_cb() 87 ASSERT_OK(r); in connect_cb() 92 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &sa)); in TEST_IMPL() 93 ASSERT_OK(uv_loop_init(&loop)); in TEST_IMPL() 94 ASSERT_OK(uv_tcp_init(&loop, &tcp_client)); in TEST_IMPL() 96 ASSERT_OK(uv_tcp_connect(&connect_req, in TEST_IMPL() [all …]
|
H A D | test-socket-buffer-size.c | 43 ASSERT_OK(uv_recv_buffer_size(handle, &value)); in check_buffer_size() 47 ASSERT_OK(uv_recv_buffer_size(handle, &value)); in check_buffer_size() 50 ASSERT_OK(uv_recv_buffer_size(handle, &value)); in check_buffer_size() 59 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 61 ASSERT_OK(uv_tcp_init(uv_default_loop(), &tcp)); in TEST_IMPL() 62 ASSERT_OK(uv_tcp_bind(&tcp, (struct sockaddr*) &addr, 0)); in TEST_IMPL() 66 ASSERT_OK(uv_udp_init(uv_default_loop(), &udp)); in TEST_IMPL() 67 ASSERT_OK(uv_udp_bind(&udp, (struct sockaddr*) &addr, 0)); in TEST_IMPL() 71 ASSERT_OK(uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL()
|
H A D | test-tcp-shutdown-after-write.c | 69 ASSERT_OK(r); in timer_cb() 72 ASSERT_OK(r); in timer_cb() 83 ASSERT_OK(status); in connect_cb() 87 ASSERT_OK(r); in connect_cb() 92 ASSERT_OK(status); in write_cb() 98 ASSERT_OK(status); in shutdown_cb() 113 ASSERT_OK(r); in TEST_IMPL() 116 ASSERT_OK(r); in TEST_IMPL() 119 ASSERT_OK(r); in TEST_IMPL() 125 ASSERT_OK(r); in TEST_IMPL() [all …]
|
H A D | test-multiple-listen.c | 41 ASSERT_OK(status); in connection_cb() 51 ASSERT_OK(uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); in start_server() 54 ASSERT_OK(r); in start_server() 57 ASSERT_OK(r); in start_server() 60 ASSERT_OK(r); in start_server() 63 ASSERT_OK(r); in start_server() 69 ASSERT_OK(status); in connect_cb() 81 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in client_connect() 85 ASSERT_OK(r); in client_connect() 91 ASSERT_OK(r); in client_connect()
|
H A D | test-close-fd.c | 58 ASSERT_OK(uv_pipe(fd, 0, 0)); in TEST_IMPL() 59 ASSERT_OK(uv_pipe_init(uv_default_loop(), &pipe_handle, 0)); in TEST_IMPL() 60 ASSERT_OK(uv_pipe_open(&pipe_handle, fd[0])); in TEST_IMPL() 68 ASSERT_OK(_close(fd[1])); in TEST_IMPL() 70 ASSERT_OK(close(fd[1])); in TEST_IMPL() 73 ASSERT_OK(uv_read_start((uv_stream_t *) &pipe_handle, alloc_cb, read_cb)); in TEST_IMPL() 74 ASSERT_OK(uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL() 76 ASSERT_OK(uv_is_active((const uv_handle_t *) &pipe_handle)); in TEST_IMPL() 77 ASSERT_OK(uv_read_start((uv_stream_t *) &pipe_handle, alloc_cb, read_cb)); in TEST_IMPL() 78 ASSERT_OK(uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL()
|
H A D | test-thread-affinity.c | 40 ASSERT_OK(r); in check_affinity() 42 ASSERT_OK(r); in check_affinity() 72 ASSERT_OK(r); in TEST_IMPL() 103 ASSERT_OK(uv_thread_create(threads + 1, in TEST_IMPL() 106 ASSERT_OK(uv_thread_create(threads + 2, in TEST_IMPL() 114 ASSERT_OK(cpumask[t1first + 2]); in TEST_IMPL() 118 ASSERT_OK(cpumask[t2first + 1]); in TEST_IMPL() 120 ASSERT_OK(cpumask[t2first + 3]); in TEST_IMPL() 128 ASSERT_OK(r); in TEST_IMPL() 132 ASSERT_OK(r); in TEST_IMPL() [all …]
|