Lines Matching refs:uv_stream_t
65 static void on_connection(uv_stream_t* server, int status) { in on_connection()
79 r = uv_accept(server, (uv_stream_t*)conn); in on_connection()
143 static void on_read(uv_stream_t* handle, in on_read()
184 r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_server); in on_read()
187 r = uv_listen((uv_stream_t*)&tcp_server, BACKLOG, on_connection); in on_read()
196 r = uv_write(&write_req, (uv_stream_t*)pipe, &outbuf, 1, NULL); in on_read()
213 static void on_read_listen_after_bound_twice(uv_stream_t* handle, in on_read_listen_after_bound_twice()
253 r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_server); in on_read_listen_after_bound_twice()
256 r = uv_listen((uv_stream_t*)&tcp_server, BACKLOG, on_connection); in on_read_listen_after_bound_twice()
264 r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_server2); in on_read_listen_after_bound_twice()
267 r = uv_listen((uv_stream_t*)&tcp_server2, BACKLOG, on_connection); in on_read_listen_after_bound_twice()
311 stdio[0].data.stream = (uv_stream_t*) channel; in spawn_helper()
337 static void on_tcp_read(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in on_tcp_read()
350 static void on_read_connection(uv_stream_t* handle, in on_read_connection()
390 r = uv_accept(handle, (uv_stream_t*)&tcp_connection); in on_read_connection()
398 r = uv_write(&write_req, (uv_stream_t*)&tcp_connection, &outbuf, 1, in on_read_connection()
402 r = uv_read_start((uv_stream_t*)&tcp_connection, on_read_alloc, on_tcp_read); in on_read_connection()
409 static void on_read_send_zero(uv_stream_t* handle, in on_read_send_zero()
422 uv_read_start((uv_stream_t*)&channel, on_alloc, read_cb); in run_ipc_test()
488 r = uv_listen((uv_stream_t*)&server, SOMAXCONN, NULL); in TEST_IMPL()
513 r = uv_listen((uv_stream_t*)&server, SOMAXCONN, NULL); in TEST_IMPL()
570 static void on_tcp_child_process_read(uv_stream_t* tcp, in on_tcp_child_process_read()
609 static void ipc_on_connection(uv_stream_t* server, int status) { in ipc_on_connection()
624 r = uv_accept(server, (uv_stream_t*)&conn.conn); in ipc_on_connection()
630 r = uv_write2(&conn_notify_req, (uv_stream_t*)&channel, &buf, 1, in ipc_on_connection()
644 static void ipc_on_connection_tcp_conn(uv_stream_t* server, int status) { in ipc_on_connection_tcp_conn()
658 r = uv_accept(server, (uv_stream_t*)conn); in ipc_on_connection_tcp_conn()
663 r = uv_write2(&conn_notify_req, (uv_stream_t*)&channel, &buf, 1, in ipc_on_connection_tcp_conn()
664 (uv_stream_t*)conn, NULL); in ipc_on_connection_tcp_conn()
667 r = uv_read_start((uv_stream_t*) conn, in ipc_on_connection_tcp_conn()
692 ASSERT_EQ(1, uv_is_readable((uv_stream_t*) &channel)); in ipc_helper()
693 ASSERT_EQ(1, uv_is_writable((uv_stream_t*) &channel)); in ipc_helper()
703 r = uv_listen((uv_stream_t*)&tcp_server, BACKLOG, ipc_on_connection); in ipc_helper()
708 r = uv_write2(&write_req, (uv_stream_t*)&channel, &buf, 1, in ipc_helper()
709 (uv_stream_t*)&tcp_server, NULL); in ipc_helper()
713 r = uv_listen((uv_stream_t*)&tcp_server, BACKLOG, ipc_on_connection); in ipc_helper()
743 ASSERT_EQ(1, uv_is_readable((uv_stream_t*) &channel)); in ipc_helper_tcp_connection()
744 ASSERT_EQ(1, uv_is_writable((uv_stream_t*) &channel)); in ipc_helper_tcp_connection()
755 r = uv_listen((uv_stream_t*)&tcp_server, BACKLOG, ipc_on_connection_tcp_conn); in ipc_helper_tcp_connection()
797 ASSERT_EQ(1, uv_is_readable((uv_stream_t*) &channel)); in ipc_helper_bind_twice()
798 ASSERT_EQ(1, uv_is_writable((uv_stream_t*) &channel)); in ipc_helper_bind_twice()
813 r = uv_write2(&write_req, (uv_stream_t*)&channel, &buf, 1, in ipc_helper_bind_twice()
814 (uv_stream_t*)&tcp_server, NULL); in ipc_helper_bind_twice()
816 r = uv_write2(&write_req2, (uv_stream_t*)&channel, &buf, 1, in ipc_helper_bind_twice()
817 (uv_stream_t*)&tcp_server2, NULL); in ipc_helper_bind_twice()
838 ASSERT_EQ(1, uv_is_readable((uv_stream_t*) &channel)); in ipc_helper_send_zero()
839 ASSERT_EQ(1, uv_is_writable((uv_stream_t*) &channel)); in ipc_helper_send_zero()
843 (uv_stream_t*)&channel, in ipc_helper_send_zero()
