Lines Matching refs:ASSERT_OK
86 ASSERT_OK(status); in pinger_after_write()
115 ASSERT_OK(uv_write(req, stream, bufs, nbufs, pinger_after_write)); in pinger_write_ping()
191 ASSERT_OK(uv_write(req, stream, &writebuf, 1, pinger_after_write)); in ponger_read_cb()
200 ASSERT_OK(status); in pinger_on_connect()
204 ASSERT_OK(uv_is_closing((uv_handle_t *) req->handle)); in pinger_on_connect()
208 ASSERT_OK(uv_read_start((uv_stream_t*) req->handle, in pinger_on_connect()
221 ASSERT_OK(uv_ip6_addr("::1", TEST_PORT, &server_addr)); in tcp_pinger_v6_new()
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()
252 ASSERT_OK(uv_ip4_addr("127.0.0.1", TEST_PORT, &server_addr)); in tcp_pinger_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()
318 ASSERT_OK(uv_socketpair(SOCK_STREAM, 0, fds, UV_NONBLOCK_PIPE, UV_NONBLOCK_PIPE)); in socketpair_pinger_new()
325 ASSERT_OK(uv_tcp_init(uv_default_loop(), &pinger->stream.tcp)); in socketpair_pinger_new()
327 ASSERT_OK(uv_tcp_open(&pinger->stream.tcp, fds[1])); in socketpair_pinger_new()
332 ASSERT_OK(uv_tcp_init(uv_default_loop(), ponger)); in socketpair_pinger_new()
333 ASSERT_OK(uv_tcp_open(ponger, fds[0])); in socketpair_pinger_new()
337 ASSERT_OK(uv_read_start((uv_stream_t*) &pinger->stream.tcp, in socketpair_pinger_new()
340 ASSERT_OK(uv_read_start((uv_stream_t*) ponger, in socketpair_pinger_new()
352 ASSERT_OK(uv_pipe(fds, UV_NONBLOCK_PIPE, UV_NONBLOCK_PIPE)); in pipe2_pinger_new()
358 ASSERT_OK(uv_pipe_init(uv_default_loop(), ponger, 0)); in pipe2_pinger_new()
359 ASSERT_OK(uv_pipe_open(ponger, fds[0])); in pipe2_pinger_new()
367 ASSERT_OK(uv_pipe_init(uv_default_loop(), &pinger->stream.pipe, 0)); in pipe2_pinger_new()
368 ASSERT_OK(uv_pipe_open(&pinger->stream.pipe, fds[1])); in pipe2_pinger_new()
374 ASSERT_OK(uv_read_start((uv_stream_t*) ponger, alloc_cb, pinger_read_cb)); in pipe2_pinger_new()