benchmark-multi-accept.c - OpenGrok cross reference for /libuv/test/benchmark-multi-accept.c

Lines Matching refs:ASSERT_OK
120     ASSERT_OK(uv_tcp_init(loop, (uv_tcp_t*) &pc->peer_handle));  in ipc_connection_cb()
122     ASSERT_OK(uv_pipe_init(loop, (uv_pipe_t*) &pc->peer_handle, 1));  in ipc_connection_cb()
126   ASSERT_OK(uv_accept(ipc_pipe, (uv_stream_t*) &pc->peer_handle));  in ipc_connection_cb()
127   ASSERT_OK(uv_write2(&pc->write_req,  in ipc_connection_cb()
156   ASSERT_OK(status);  in ipc_connect_cb()
157   ASSERT_OK(uv_read_start((uv_stream_t*) &ctx->ipc_pipe,  in ipc_connect_cb()
188     ASSERT_OK(uv_tcp_init(loop, (uv_tcp_t*) ctx->server_handle));  in ipc_read_cb()
190     ASSERT_OK(uv_pipe_init(loop, (uv_pipe_t*) ctx->server_handle, 0));  in ipc_read_cb()
194   ASSERT_OK(uv_accept(handle, ctx->server_handle));  in ipc_read_cb()
214     ASSERT_OK(uv_tcp_init(loop, (uv_tcp_t*) &ctx.server_handle));  in send_listen_handles()
215     ASSERT_OK(uv_tcp_bind((uv_tcp_t*) &ctx.server_handle,  in send_listen_handles()
226   ASSERT_OK(uv_pipe_init(loop, &ctx.ipc_pipe, 0));  in send_listen_handles()
227   ASSERT_OK(uv_pipe_bind(&ctx.ipc_pipe, IPC_PIPE_NAME));  in send_listen_handles()
228   ASSERT_OK(uv_listen((uv_stream_t*) &ctx.ipc_pipe, 128, ipc_connection_cb));  in send_listen_handles()
233   ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT));  in send_listen_handles()
235   ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT));  in send_listen_handles()
248   ASSERT_OK(uv_pipe_init(loop, &ctx.ipc_pipe, 1));  in get_listen_handle()
253   ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT));  in get_listen_handle()
262   ASSERT_OK(uv_loop_init(&loop));  in server_cb()
264   ASSERT_OK(uv_async_init(&loop, &ctx->async_handle, sv_async_cb));  in server_cb()
273   ASSERT_OK(uv_listen((uv_stream_t*) &ctx->server_handle,  in server_cb()
276   ASSERT_OK(uv_run(&loop, UV_RUN_DEFAULT));  in server_cb()
295   ASSERT_OK(status);  in sv_connection_cb()
301     ASSERT_OK(uv_tcp_init(server_handle->loop, (uv_tcp_t*) storage));  in sv_connection_cb()
303     ASSERT_OK(uv_pipe_init(server_handle->loop, (uv_pipe_t*) storage, 0));  in sv_connection_cb()
307   ASSERT_OK(uv_accept(server_handle, (uv_stream_t*) storage));  in sv_connection_cb()
308   ASSERT_OK(uv_read_start((uv_stream_t*) storage, sv_alloc_cb, sv_read_cb));  in sv_connection_cb()
333   ASSERT_OK(status);  in cl_connect_cb()
354   ASSERT_OK(uv_tcp_init(handle->loop, (uv_tcp_t*) &ctx->client_handle));  in cl_close_cb()
355   ASSERT_OK(uv_tcp_connect(&ctx->connect_req,  in cl_close_cb()
370   ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &listen_addr));  in test_tcp()
384     ASSERT_OK(uv_sem_init(&ctx->semaphore, 0));  in test_tcp()
385     ASSERT_OK(uv_thread_create(&ctx->thread_id, server_cb, ctx));  in test_tcp()
395     ASSERT_OK(uv_tcp_init(loop, handle));  in test_tcp()
396     ASSERT_OK(uv_tcp_connect(&ctx->connect_req,  in test_tcp()
400     ASSERT_OK(uv_idle_init(loop, &ctx->idle_handle));  in test_tcp()
405     ASSERT_OK(uv_run(loop, UV_RUN_DEFAULT));  in test_tcp()
413     ASSERT_OK(uv_thread_join(&ctx->thread_id));  in test_tcp()