/libuv/test/ |
H A D | test-tcp-close-while-connecting.c | 72 ASSERT_OK(uv_ip4_addr("1.2.3.4", TEST_PORT, &addr)); in TEST_IMPL() 73 ASSERT_OK(uv_tcp_init(loop, &tcp_handle)); in TEST_IMPL() 80 ASSERT_OK(r); in TEST_IMPL() 81 ASSERT_OK(uv_timer_init(loop, &timer1_handle)); in TEST_IMPL() 82 ASSERT_OK(uv_timer_start(&timer1_handle, timer1_cb, 1, 0)); in TEST_IMPL() 83 ASSERT_OK(uv_timer_init(loop, &timer2_handle)); in TEST_IMPL() 84 ASSERT_OK(uv_timer_start(&timer2_handle, timer2_cb, 86400 * 1000, 0)); in TEST_IMPL() 85 ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT)); in TEST_IMPL()
|
H A D | benchmark-pump.c | 162 ASSERT_OK(r); in start_stats_collection() 164 ASSERT_OK(r); in start_stats_collection() 212 ASSERT_OK(r); in do_write() 295 ASSERT_OK(r); in connection_cb() 298 ASSERT_OK(r); in connection_cb() 387 ASSERT_OK(r); in HELPER_IMPL() 389 ASSERT_OK(r); in HELPER_IMPL() 391 ASSERT_OK(r); in HELPER_IMPL() 409 ASSERT_OK(r); in HELPER_IMPL() 411 ASSERT_OK(r); in HELPER_IMPL() [all …]
|
H A D | test-not-writable-after-shutdown.c | 37 ASSERT_OK(status); in connect_cb() 40 ASSERT_OK(r); in connect_cb() 42 ASSERT_OK(uv_is_writable(req->handle)); in connect_cb() 52 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 56 ASSERT_OK(r); in TEST_IMPL() 62 ASSERT_OK(r); in TEST_IMPL() 65 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-async.c | 52 ASSERT_OK(r); in thread_cb() 103 ASSERT_OK(r); in prepare_cb() 112 ASSERT_OK(r); in TEST_IMPL() 116 ASSERT_OK(r); in TEST_IMPL() 118 ASSERT_OK(r); in TEST_IMPL() 121 ASSERT_OK(r); in TEST_IMPL() 124 ASSERT_OK(r); in TEST_IMPL() 130 ASSERT_OK(uv_thread_join(&thread)); in TEST_IMPL()
|
H A D | benchmark-async.c | 46 ASSERT_OK(uv_async_send(&ctx->main_async)); in worker_async_cb() 58 ASSERT_OK(uv_async_send(&ctx->worker_async)); in main_async_cb() 69 ASSERT_OK(uv_async_send(&ctx->main_async)); in worker() 70 ASSERT_OK(uv_run(&ctx->loop, UV_RUN_DEFAULT)); in worker() 88 ASSERT_OK(uv_loop_init(&ctx->loop)); in test_async() 89 ASSERT_OK(uv_async_init(&ctx->loop, &ctx->worker_async, worker_async_cb)); in test_async() 90 ASSERT_OK(uv_async_init(uv_default_loop(), in test_async() 93 ASSERT_OK(uv_thread_create(&ctx->thread, worker, ctx)); in test_async() 98 ASSERT_OK(uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in test_async() 101 ASSERT_OK(uv_thread_join(&threads[i].thread)); in test_async()
|
H A D | test-udp-mmsg.c | 80 ASSERT_OK(nread); in recv_cb() 113 ASSERT_OK(uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); in TEST_IMPL() 115 ASSERT_OK(uv_udp_init_ex(uv_default_loop(), &recver, in TEST_IMPL() 118 ASSERT_OK(uv_udp_bind(&recver, (const struct sockaddr*) &addr, 0)); in TEST_IMPL() 120 ASSERT_OK(uv_udp_recv_start(&recver, alloc_cb, recv_cb)); in TEST_IMPL() 122 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 124 ASSERT_OK(uv_udp_init(uv_default_loop(), &sender)); in TEST_IMPL() 131 ASSERT_OK(uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL() 136 ASSERT_OK(sender.send_queue_size); in TEST_IMPL() 137 ASSERT_OK(recver.send_queue_size); in TEST_IMPL()
|
H A D | test-loop-configure.c | 27 ASSERT_OK(uv_loop_init(&loop)); in TEST_IMPL() 31 ASSERT_OK(uv_loop_configure(&loop, UV_LOOP_BLOCK_SIGNAL, SIGPROF)); in TEST_IMPL() 33 ASSERT_OK(uv_timer_init(&loop, &timer_handle)); in TEST_IMPL() 34 ASSERT_OK(uv_timer_start(&timer_handle, timer_cb, 10, 0)); in TEST_IMPL() 35 ASSERT_OK(uv_run(&loop, UV_RUN_DEFAULT)); in TEST_IMPL() 36 ASSERT_OK(uv_loop_close(&loop)); in TEST_IMPL()
|
H A D | test-udp-try-send.c | 73 ASSERT_OK(memcmp("EXIT", rcvbuf->base, nread)); in sv_recv_cb() 87 ASSERT_OK(uv_ip4_addr("0.0.0.0", TEST_PORT, &addr)); in TEST_IMPL() 90 ASSERT_OK(r); in TEST_IMPL() 93 ASSERT_OK(r); in TEST_IMPL() 96 ASSERT_OK(r); in TEST_IMPL() 98 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 101 ASSERT_OK(r); in TEST_IMPL() 116 ASSERT_OK(client.send_queue_size); in TEST_IMPL() 117 ASSERT_OK(server.send_queue_size); in TEST_IMPL()
|
H A D | test-fs-copyfile.c | 58 ASSERT_OK(r); in handle_result() 65 ASSERT_OK(r); in handle_result() 101 ASSERT_OK(r); in touch_file() 133 ASSERT_OK(r); in TEST_IMPL() 137 ASSERT_OK(r); in TEST_IMPL() 145 ASSERT_OK(r); in TEST_IMPL() 152 ASSERT_OK(r); in TEST_IMPL() 157 ASSERT_OK(r); in TEST_IMPL() 172 ASSERT_OK(r); in TEST_IMPL() 179 ASSERT_OK(r); in TEST_IMPL() [all …]
|
H A D | test-emfile.c | 62 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 63 ASSERT_OK(uv_tcp_init(loop, &server_handle)); in TEST_IMPL() 64 ASSERT_OK(uv_tcp_init(loop, &client_handle)); in TEST_IMPL() 65 ASSERT_OK(uv_tcp_bind(&server_handle, (const struct sockaddr*) &addr, 0)); in TEST_IMPL() 66 ASSERT_OK(uv_listen((uv_stream_t*) &server_handle, 8, connection_cb)); in TEST_IMPL() 90 ASSERT_OK(uv_tcp_connect(&connect_req, in TEST_IMPL() 94 ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT)); in TEST_IMPL() 119 ASSERT_OK(status); in connect_cb()
|
H A D | test-shutdown-twice.c | 41 ASSERT_OK(status); in shutdown_cb() 49 ASSERT_OK(status); in connect_cb() 52 ASSERT_OK(r); in connect_cb() 66 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 70 ASSERT_OK(r); in TEST_IMPL() 76 ASSERT_OK(r); in TEST_IMPL() 79 ASSERT_OK(r); in TEST_IMPL()
|
H A D | blackhole-server.c | 46 ASSERT_OK(status); in connection_cb() 53 ASSERT_OK(r); in connection_cb() 56 ASSERT_OK(r); in connection_cb() 59 ASSERT_OK(r); in connection_cb() 84 ASSERT_OK(r); in read_cb() 106 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in HELPER_IMPL() 109 ASSERT_OK(r); in HELPER_IMPL() 112 ASSERT_OK(r); in HELPER_IMPL() 115 ASSERT_OK(r); in HELPER_IMPL()
|
H A D | test-thread-equal.c | 34 ASSERT_OK(uv_thread_equal(&main_thread_id, &self_id)); in check_thread() 45 ASSERT_OK(uv_thread_create(threads + 0, check_thread, subthreads + 0)); in TEST_IMPL() 46 ASSERT_OK(uv_thread_create(threads + 1, check_thread, subthreads + 1)); in TEST_IMPL() 47 ASSERT_OK(uv_thread_join(threads + 0)); in TEST_IMPL() 48 ASSERT_OK(uv_thread_join(threads + 1)); in TEST_IMPL() 49 ASSERT_OK(uv_thread_equal(subthreads + 0, subthreads + 1)); in TEST_IMPL()
|
H A D | test-getnameinfo.c | 42 ASSERT_OK(status); in getnameinfo_req() 57 ASSERT_OK(r); in TEST_IMPL() 64 ASSERT_OK(r); in TEST_IMPL() 79 ASSERT_OK(uv_ip4_addr(address_ip4, port, &addr4)); in TEST_IMPL() 81 ASSERT_OK(uv_getnameinfo(uv_default_loop(), in TEST_IMPL() 103 ASSERT_OK(r); in TEST_IMPL() 110 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-pipe-server-close.c | 46 ASSERT_OK(status); in pipe_client_connect_cb() 59 ASSERT_OK(status); in pipe_server_connection_cb() 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() 88 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-poll-closesocket.c | 42 ASSERT_OK(status); in poll_cb() 46 ASSERT_OK(r); in poll_cb() 65 ASSERT_OK(r); in TEST_IMPL() 71 ASSERT_OK(r); in TEST_IMPL() 74 ASSERT_OK(r); in TEST_IMPL() 81 ASSERT_OK(r); in TEST_IMPL() 83 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-queue-foreach-delete.c | 108 ASSERT_OK(r); \ 111 ASSERT_OK(r); \ 118 ASSERT_OK(name##_cb_calls[1]); \ 143 ASSERT_OK(r); in init_and_start_fs_events() 149 ASSERT_OK(r); in init_and_start_fs_events() 159 ASSERT_OK(r); in helper_timer_cb() 160 ASSERT_OK(fs_req.result); in helper_timer_cb() 162 ASSERT_OK(strcmp(fs_req.path, watched_dir)); in helper_timer_cb() 185 ASSERT_OK(r); in TEST_IMPL() 188 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-timer-again.c | 57 ASSERT_OK(r); in repeat_1_cb() 80 ASSERT_OK(uv_is_active((uv_handle_t*) handle)); in repeat_2_cb() 103 ASSERT_OK(r); in TEST_IMPL() 110 ASSERT_OK(r); in TEST_IMPL() 112 ASSERT_OK(r); in TEST_IMPL() 113 ASSERT_OK(uv_timer_get_repeat(&repeat_1)); in TEST_IMPL() 124 ASSERT_OK(r); in TEST_IMPL() 126 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-udp-send-hang-loop.c | 49 ASSERT_OK(uv_idle_stop(handle)); in idle_cb() 64 ASSERT_OK(r); in idle_cb() 75 ASSERT_OK(uv_idle_start(&idle_handle, idle_cb)); in send_cb() 80 ASSERT_OK(uv_idle_init(uv_default_loop(), &idle_handle)); in TEST_IMPL() 85 ASSERT_OK(uv_ip4_addr("192.0.2.3", TEST_PORT, &addr)); in TEST_IMPL() 87 ASSERT_OK(uv_udp_init(uv_default_loop(), &client)); in TEST_IMPL() 91 ASSERT_OK(uv_idle_start(&idle_handle, idle_cb)); in TEST_IMPL()
|
H A D | test-tcp-write-fail.c | 44 ASSERT_OK(r); in close_socket() 50 ASSERT_OK(r); in close_socket() 77 ASSERT_OK(status); in connect_cb() 87 ASSERT_OK(r); in connect_cb() 96 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 99 ASSERT_OK(r); in TEST_IMPL() 105 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-shutdown-simultaneous.c | 48 ASSERT_OK(called_tcp_close_cb); in shutdown_cb() 62 ASSERT_OK(got_eof); in read_cb() 82 ASSERT_OK(status); in connect_cb() 86 ASSERT_OK(uv_read_start((uv_stream_t*)&tcp, alloc_cb, read_cb)); in connect_cb() 101 ASSERT_OK(called_shutdown_cb); in connect_cb() 116 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &server_addr)); in TEST_IMPL() 118 ASSERT_OK(r); in TEST_IMPL() 124 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-poll-close-doesnt-corrupt-stack.c | 62 ASSERT_OK(r); in close_socket_and_verify_stack() 82 ASSERT_OK(r); in TEST_IMPL() 88 ASSERT_OK(r); in TEST_IMPL() 91 ASSERT_OK(r); in TEST_IMPL() 98 ASSERT_OK(r); in TEST_IMPL() 100 ASSERT_OK(r); in TEST_IMPL() 107 ASSERT_OK(r); in TEST_IMPL()
|
H A D | test-tcp-connect6-error.c | 59 ASSERT_OK(r); in TEST_IMPL() 70 ASSERT_OK(connect_cb_called); in TEST_IMPL() 99 ASSERT_OK(uv_interface_addresses(&ifs, &n)); in TEST_IMPL() 110 ASSERT_OK(uv_ip6_addr("fe80::0bad:babe", 1337, &addr)); in TEST_IMPL() 111 ASSERT_OK(uv_tcp_init(uv_default_loop(), &server)); in TEST_IMPL() 119 ASSERT_OK(uv_tcp_connect(&req, in TEST_IMPL() 125 ASSERT_OK(uv_run(uv_default_loop(), UV_RUN_DEFAULT)); in TEST_IMPL()
|
H A D | test-tcp-writealot.c | 69 ASSERT_OK(status); in shutdown_cb() 74 ASSERT_OK(tcp->write_queue_size); in shutdown_cb() 119 ASSERT_OK(status); in connect_cb() 134 ASSERT_OK(r); in connect_cb() 139 ASSERT_OK(r); in connect_cb() 143 ASSERT_OK(r); in connect_cb() 157 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &addr)); in TEST_IMPL() 163 ASSERT_OK(r); in TEST_IMPL() 169 ASSERT_OK(r); in TEST_IMPL()
|
H A D | benchmark-udp-pummel.c | 99 ASSERT_OK(uv_udp_send(&s->send_req, in send_cb() 165 ASSERT_OK(uv_timer_init(loop, &timer_handle)); in pummel() 166 ASSERT_OK(uv_timer_start(&timer_handle, timeout_cb, timeout, 0)); in pummel() 175 ASSERT_OK(uv_ip4_addr("0.0.0.0", BASE_PORT + i, &addr)); in pummel() 176 ASSERT_OK(uv_udp_init(loop, &s->udp_handle)); in pummel() 177 ASSERT_OK(uv_udp_bind(&s->udp_handle, (const struct sockaddr*) &addr, 0)); in pummel() 178 ASSERT_OK(uv_udp_recv_start(&s->udp_handle, alloc_cb, recv_cb)); in pummel() 190 ASSERT_OK(uv_ip4_addr("127.0.0.1", in pummel() 193 ASSERT_OK(uv_udp_init(loop, &s->udp_handle)); in pummel() 194 ASSERT_OK(uv_udp_send(&s->send_req, in pummel() [all …]
|