/third_party/libuv/test/ |
H A D | test-fork.c | 54 ASSERT_OK(status); in socket_cb() 69 ASSERT_OK(uv_loop_init(&loop)); in run_timer_loop_once() 73 ASSERT_OK(uv_timer_init(&loop, &timer_handle)); in run_timer_loop_once() 74 ASSERT_OK(uv_timer_start(&timer_handle, timer_cb, 1, 0)); in run_timer_loop_once() 75 ASSERT_OK(uv_run(&loop, UV_RUN_DEFAULT)); in run_timer_loop_once() 77 ASSERT_OK(uv_loop_close(&loop)); in run_timer_loop_once() 93 ASSERT_OK(WEXITSTATUS(child_stat)); in assert_wait_child() 119 ASSERT_OK(uv_loop_fork(uv_default_loop())); in TEST_IMPL() 138 ASSERT_OK(socketpair(AF_UNIX, SOCK_STREAM, 0, socket_fds)); in TEST_IMPL() 141 ASSERT_OK(uv_poll_ini in TEST_IMPL() [all...] |
H A D | test-fs-event.c | 90 ASSERT_OK(r); in create_file() 111 ASSERT_OK(r); in touch_file() 131 ASSERT_OK(status); in fs_event_cb_dir() 134 ASSERT_OK(strcmp(filename, "file1")); in fs_event_cb_dir() 138 ASSERT_OK(uv_fs_event_stop(handle)); in fs_event_cb_dir() 161 ASSERT_OK(uv_timer_start(&timer, fs_event_create_files, 100, 0)); in fs_event_create_files() 175 ASSERT_OK(r); in fs_event_unlink_files() 182 ASSERT_OK(remove(fs_event_get_filename(fs_event_removed))); in fs_event_unlink_files() 187 ASSERT_OK(uv_timer_start(&timer, fs_event_unlink_files, 1, 0)); in fs_event_unlink_files() 198 ASSERT_OK(statu in fs_event_cb_dir_multi_file() [all...] |
H A D | test-timer.c | 45 ASSERT_OK(uv_is_active(handle)); in once_close_cb() 55 ASSERT_OK(uv_is_active((uv_handle_t*) handle)); in once_cb() 69 ASSERT_OK(uv_is_active(handle)); in twice_close_cb() 78 ASSERT_OK(uv_is_active((uv_handle_t*) handle)); in twice_cb() 129 ASSERT_OK(r); in TEST_IMPL() 131 ASSERT_OK(r); in TEST_IMPL() 136 ASSERT_OK(r); in TEST_IMPL() 138 ASSERT_OK(r); in TEST_IMPL() 142 ASSERT_OK(r); in TEST_IMPL() 144 ASSERT_OK( in TEST_IMPL() [all...] |
H A D | test-threadpool-cancel.c | 80 ASSERT_OK(uv_sem_init(pause_sems + i, 0)); in saturate_threadpool() 81 ASSERT_OK(uv_queue_work(loop, pause_reqs + i, work_cb, done_cb)); in saturate_threadpool() 212 ASSERT_OK(r); in TEST_IMPL() 215 ASSERT_OK(r); in TEST_IMPL() 218 ASSERT_OK(r); in TEST_IMPL() 221 ASSERT_OK(r); in TEST_IMPL() 223 ASSERT_OK(uv_timer_init(loop, &ci.timer_handle)); in TEST_IMPL() 224 ASSERT_OK(uv_timer_start(&ci.timer_handle, timer_cb, 10, 0)); in TEST_IMPL() 225 ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT)); in TEST_IMPL() 241 ASSERT_OK( in TEST_IMPL() [all...] |
H A D | test-thread.c | 74 ASSERT_OK(r); in getaddrinfo_do() 83 ASSERT_OK(status); in getaddrinfo_cb() 97 ASSERT_OK(r); in fs_do() 118 ASSERT_OK(uv_loop_init(&loop)); in do_work() 134 ASSERT_OK(uv_run(&loop, UV_RUN_DEFAULT)); in do_work() 135 ASSERT_OK(uv_loop_close(&loop)); in do_work() 151 ASSERT_OK(r); in TEST_IMPL() 154 ASSERT_OK(r); in TEST_IMPL() 179 ASSERT_OK(r); in TEST_IMPL() 184 ASSERT_OK( in TEST_IMPL() [all...] |
H A D | test-timer-from-check.c | 35 ASSERT_OK(uv_prepare_stop(&prepare_handle)); in prepare_cb() 36 ASSERT_OK(prepare_cb_called); in prepare_cb() 38 ASSERT_OK(timer_cb_called); in prepare_cb() 44 ASSERT_OK(uv_timer_stop(&timer_handle)); in timer_cb() 47 ASSERT_OK(timer_cb_called); in timer_cb() 53 ASSERT_OK(uv_check_stop(&check_handle)); in check_cb() 54 ASSERT_OK(uv_timer_stop(&timer_handle)); /* Runs before timer_cb. */ in check_cb() 55 ASSERT_OK(uv_timer_start(&timer_handle, timer_cb, 50, 0)); in check_cb() 56 ASSERT_OK(uv_prepare_start(&prepare_handle, prepare_cb)); in check_cb() 57 ASSERT_OK(prepare_cb_calle in check_cb() [all...] |
H A D | test-tcp-close-reset.c | 65 ASSERT_OK(r); in do_write() 75 ASSERT_OK(uv_shutdown(&shutdown_req, in do_close() 81 ASSERT_OK(r); in do_close() 84 ASSERT_OK(shutdown((SOCKET)fd, SD_BOTH)); in do_close() 87 ASSERT_OK(shutdown(fd, SHUT_RDWR)); in do_close() 89 ASSERT_OK(uv_tcp_close_reset(handle, close_cb)); in do_close() 91 ASSERT_OK(uv_tcp_close_reset(handle, close_cb)); in do_close() 123 ASSERT_OK(close_cb_called); in write_cb() 161 ASSERT_OK(status); in connection_cb() 163 ASSERT_OK(uv_tcp_ini in connection_cb() [all...] |
H A D | test-fs-poll.c | 114 ASSERT_OK(memcmp(prev, &zero_statbuf, sizeof(zero_statbuf))); in poll_cb() 115 ASSERT_OK(memcmp(curr, &zero_statbuf, sizeof(zero_statbuf))); in poll_cb() 120 ASSERT_OK(status); in poll_cb() 121 ASSERT_OK(memcmp(prev, &zero_statbuf, sizeof(zero_statbuf))); in poll_cb() 123 ASSERT_OK(uv_timer_start(&timer_handle, timer_cb, 20, 0)); in poll_cb() 127 ASSERT_OK(status); in poll_cb() 130 ASSERT_OK(uv_timer_start(&timer_handle, timer_cb, 200, 0)); in poll_cb() 134 ASSERT_OK(status); in poll_cb() 143 ASSERT_OK(memcmp(curr, &zero_statbuf, sizeof(zero_statbuf))); in poll_cb() 158 ASSERT_OK(uv_timer_ini in TEST_IMPL() [all...] |
H A D | test-metrics.c | 62 ASSERT_OK(uv_loop_configure(uv_default_loop(), UV_METRICS_IDLE_TIME)); in TEST_IMPL() 63 ASSERT_OK(uv_timer_init(uv_default_loop(), &timer)); in TEST_IMPL() 64 ASSERT_OK(uv_timer_start(&timer, timer_spin_cb, timeout, 0)); in TEST_IMPL() 66 ASSERT_OK(uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL() 90 ASSERT_OK(uv_loop_init(&loop)); in metrics_routine_cb() 91 ASSERT_OK(uv_loop_configure(&loop, UV_METRICS_IDLE_TIME)); in metrics_routine_cb() 92 ASSERT_OK(uv_timer_init(&loop, &timer)); in metrics_routine_cb() 93 ASSERT_OK(uv_timer_start(&timer, timer_spin_cb, timeout, 0)); in metrics_routine_cb() 95 ASSERT_OK(uv_run(&loop, UV_RUN_DEFAULT)); in metrics_routine_cb() 107 ASSERT_OK(uv_loop_clos in metrics_routine_cb() [all...] |
H A D | test-spawn.c | 72 ASSERT_OK(term_signal); in exit_cb() 94 ASSERT_OK(exit_status); in kill_cb() 149 ASSERT_OK(status); in write_cb() 155 ASSERT_OK(status); in write_null_cb() 162 ASSERT_OK(r); in init_process_options() 195 ASSERT_OK(uv_is_active((uv_handle_t*) &process)); in TEST_IMPL() 197 ASSERT_OK(uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL() 215 ASSERT_OK(uv_is_active((uv_handle_t*) &process)); in TEST_IMPL() 216 ASSERT_OK(uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL() 227 ASSERT_OK(uv_ru in TEST_IMPL() [all...] |
H A D | test-tcp-open.c | 49 ASSERT_OK(r); in startup() 69 ASSERT_OK(r); in create_tcp_socket() 84 ASSERT_OK(r); in close_socket() 106 ASSERT_OK(status); in shutdown_cb() 118 ASSERT_OK(memcmp("PING", buf->base, nread)); in read_cb() 169 ASSERT_OK(r); in write1_cb() 180 ASSERT_OK(r); in timer_cb() 191 ASSERT_OK(status); in connect_cb() 197 ASSERT_OK(r); in connect_cb() 201 ASSERT_OK( in connect_cb() [all...] |
H A D | test-ipc-send-recv.c | 129 ASSERT_OK(r); in recv_cb() 132 ASSERT_OK(r); in recv_cb() 147 ASSERT_OK(status); in connect_cb() 155 ASSERT_OK(r); in connect_cb() 166 ASSERT_OK(r); in connect_cb() 169 ASSERT_OK(r); in connect_cb() 179 ASSERT_OK(r); in run_test() 184 ASSERT_OK(r); in run_test() 194 ASSERT_OK(r); in run_test() 200 ASSERT_OK( in run_test() [all...] |
H A D | test-ipc.c | 71 ASSERT_OK(status); in on_connection() 77 ASSERT_OK(r); in on_connection() 80 ASSERT_OK(r); in on_connection() 94 ASSERT_OK(exit_status); in exit_cb() 95 ASSERT_OK(term_signal); in exit_cb() 129 ASSERT_OK(r); in make_many_connections() 130 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in make_many_connections() 136 ASSERT_OK(r); in make_many_connections() 182 ASSERT_OK(r); in on_read() 185 ASSERT_OK( in on_read() [all...] |
H A D | test-poll-oob.c | 73 ASSERT_OK(uv_fileno((uv_handle_t*)handle, &fd)); in poll_cb() 82 ASSERT_OK(uv_poll_stop(&poll_req[0])); in poll_cb() 83 ASSERT_OK(uv_poll_start(&poll_req[0], in poll_cb() 94 ASSERT_OK(strncmp(buffer, "world", n)); in poll_cb() 100 ASSERT_OK(strncmp(buffer, "hello", n)); in poll_cb() 108 ASSERT_OK(strncmp(buffer, "world", n)); in poll_cb() 122 ASSERT_OK(strncmp(buffer, "foo", n)); in poll_cb() 138 ASSERT_OK(status); in connection_cb() 139 ASSERT_OK(uv_accept(handle, (uv_stream_t*) &peer_handle)); in connection_cb() 140 ASSERT_OK(uv_filen in connection_cb() [all...] |
H A D | test-tcp-bind-error.c | 56 ASSERT_OK(uv_tcp_init(uv_default_loop(), &conn)); in TEST_IMPL() 57 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 58 ASSERT_OK(uv_tcp_bind(&conn, (const struct sockaddr*) &addr, 0)); in TEST_IMPL() 60 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT + 1, &addr)); in TEST_IMPL() 61 ASSERT_OK(uv_tcp_connect(&req, in TEST_IMPL() 71 ASSERT_OK(uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL() 85 ASSERT_OK(uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); in TEST_IMPL() 87 ASSERT_OK(r); in TEST_IMPL() 89 ASSERT_OK(r); in TEST_IMPL() 92 ASSERT_OK( in TEST_IMPL() [all...] |
H A D | test-udp-open.c | 44 ASSERT_OK(r); in startup() 64 ASSERT_OK(r); in create_udp_socket() 79 ASSERT_OK(r); in close_socket() 116 ASSERT_OK(flags); in recv_cb() 120 ASSERT_OK(memcmp("PING", buf->base, nread)); in recv_cb() 123 ASSERT_OK(r); in recv_cb() 131 ASSERT_OK(status); in send_cb() 145 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 151 ASSERT_OK(r); in TEST_IMPL() 154 ASSERT_OK( in TEST_IMPL() [all...] |
H A D | test-signal-multiple-loops.c | 92 ASSERT_OK(uv_loop_init(&loop)); in signal_handling_worker() 97 ASSERT_OK(r); in signal_handling_worker() 99 ASSERT_OK(r); in signal_handling_worker() 101 ASSERT_OK(r); in signal_handling_worker() 103 ASSERT_OK(r); in signal_handling_worker() 108 ASSERT_OK(r); in signal_handling_worker() 110 ASSERT_OK(r); in signal_handling_worker() 120 ASSERT_OK(r); in signal_handling_worker() 125 ASSERT_OK(r); in signal_handling_worker() 127 ASSERT_OK( in signal_handling_worker() [all...] |
H A D | test-pipe-getsockname.c | 55 ASSERT_OK(status); in pipe_client_connect_cb() 59 ASSERT_OK(r); in pipe_client_connect_cb() 85 ASSERT_OK(status); in pipe_server_connection_cb() 107 ASSERT_OK(r); in TEST_IMPL() 121 ASSERT_OK(r); in TEST_IMPL() 129 ASSERT_OK(r); in TEST_IMPL() 133 ASSERT_OK(memcmp(buf, TEST_PIPENAME, len)); in TEST_IMPL() 140 ASSERT_OK(r); in TEST_IMPL() 143 ASSERT_OK(r); in TEST_IMPL() 159 ASSERT_OK( in TEST_IMPL() [all...] |
H A D | test-tcp-oob.c | 65 ASSERT_OK(uv_fileno((uv_handle_t*)handle, &fd)); in read_cb() 66 ASSERT_OK(uv_idle_start(&idle, idle_cb)); in read_cb() 79 ASSERT_OK(status); in connect_cb() 87 ASSERT_OK(status); in connection_cb() 88 ASSERT_OK(uv_accept(handle, (uv_stream_t*) &peer_handle)); in connection_cb() 89 ASSERT_OK(uv_read_start((uv_stream_t*) &peer_handle, alloc_cb, read_cb)); in connection_cb() 92 ASSERT_OK(uv_fileno((uv_handle_t*) &client_handle, &fd)); in connection_cb() 94 ASSERT_OK(uv_stream_set_blocking((uv_stream_t*) &client_handle, 1)); in connection_cb() 109 ASSERT_OK(uv_stream_set_blocking((uv_stream_t*) &client_handle, 0)); in connection_cb() 117 ASSERT_OK(uv_ip4_add in TEST_IMPL() [all...] |
H A D | test-udp-alloc-cb-fail.c | 74 ASSERT_OK(flags); in cl_recv_cb() 87 ASSERT_OK(status); in cl_send_cb() 91 ASSERT_OK(r); in cl_send_cb() 99 ASSERT_OK(status); in sv_send_cb() 129 ASSERT_OK(flags); in sv_recv_cb() 136 ASSERT_OK(r); in sv_recv_cb() 143 ASSERT_OK(r); in sv_recv_cb() 155 ASSERT_OK(uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); in TEST_IMPL() 158 ASSERT_OK(r); in TEST_IMPL() 161 ASSERT_OK( in TEST_IMPL() [all...] |
H A D | test-tcp-connect-timeout.c | 67 ASSERT_OK(uv_ip4_addr("8.8.8.8", 9999, &addr)); in TEST_IMPL() 70 ASSERT_OK(r); in TEST_IMPL() 73 ASSERT_OK(r); in TEST_IMPL() 76 ASSERT_OK(r); in TEST_IMPL() 84 ASSERT_OK(r); in TEST_IMPL() 87 ASSERT_OK(r); in TEST_IMPL() 108 ASSERT_OK(uv_os_uname(&uname)); in is_supported_system() 133 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 136 ASSERT_OK(r); in TEST_IMPL() 140 ASSERT_OK( in TEST_IMPL() [all...] |
H A D | test-tcp-create-socket-early.c | 35 ASSERT_OK(status); in on_connect() 44 ASSERT_OK(status); in on_connection() 50 ASSERT_OK(r); in on_connection() 64 ASSERT_OK(uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); in tcp_listener() 67 ASSERT_OK(r); in tcp_listener() 70 ASSERT_OK(r); in tcp_listener() 73 ASSERT_OK(r); in tcp_listener() 81 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &server_addr)); in tcp_connector() 84 ASSERT_OK(r); in tcp_connector() 90 ASSERT_OK( in tcp_connector() [all...] |
H A D | test-udp-send-and-recv.c | 68 ASSERT_OK(flags); in cl_recv_cb() 94 ASSERT_OK(status); in cl_send_cb() 98 ASSERT_OK(r); in cl_send_cb() 106 ASSERT_OK(status); in sv_send_cb() 136 ASSERT_OK(flags); in sv_recv_cb() 147 ASSERT_OK(r); in sv_recv_cb() 154 ASSERT_OK(r); in sv_recv_cb() 166 ASSERT_OK(uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); in TEST_IMPL() 169 ASSERT_OK(r); in TEST_IMPL() 172 ASSERT_OK( in TEST_IMPL() [all...] |
H A D | test-tcp-read-stop-start.c | 36 ASSERT_OK(status); in on_write_close_immediately() 43 ASSERT_OK(status); in on_write() 53 ASSERT_OK(uv_write(req, stream, &buf, 1, cb)); in do_write() 72 ASSERT_OK(uv_read_stop(stream)); in on_read1() 74 ASSERT_OK(uv_read_start(stream, on_alloc, on_read2)); in on_read1() 89 ASSERT_OK(status); in on_connection() 91 ASSERT_OK(uv_tcp_init(server->loop, &connection)); in on_connection() 93 ASSERT_OK(uv_accept(server, (uv_stream_t* )&connection)); in on_connection() 95 ASSERT_OK(uv_read_start((uv_stream_t*)&connection, on_alloc, on_read1)); in on_connection() 99 ASSERT_OK(statu in on_connect() [all...] |
H A D | test-udp-options.c | 39 ASSERT_OK(r); in udp_options_test() 44 ASSERT_OK(r); in udp_options_test() 50 ASSERT_OK(r); in udp_options_test() 57 ASSERT_OK(r); in udp_options_test() 61 ASSERT_OK(r); in udp_options_test() 74 ASSERT_OK(r); in udp_options_test() 79 ASSERT_OK(r); in udp_options_test() 88 ASSERT_OK(r); in udp_options_test() 98 ASSERT_OK(uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); in TEST_IMPL() 109 ASSERT_OK(uv_ip6_add in TEST_IMPL() [all...] |