Lines Matching refs:conn
53 uv_tcp_t conn; member
66 uv_tcp_t* conn; in on_connection() local
74 conn = malloc(sizeof(*conn)); in on_connection()
75 ASSERT_NOT_NULL(conn); in on_connection()
76 r = uv_tcp_init(server->loop, conn); in on_connection()
79 r = uv_accept(server, (uv_stream_t*)conn); in on_connection()
82 uv_close((uv_handle_t*)conn, close_server_conn_cb); in on_connection()
120 tcp_conn* conn; in make_many_connections() local
125 conn = malloc(sizeof(*conn)); in make_many_connections()
126 ASSERT_NOT_NULL(conn); in make_many_connections()
128 r = uv_tcp_init(uv_default_loop(), &conn->conn); in make_many_connections()
132 r = uv_tcp_connect(&conn->conn_req, in make_many_connections()
133 (uv_tcp_t*) &conn->conn, in make_many_connections()
138 conn->conn.data = conn; in make_many_connections()
542 static tcp_conn conn; variable
557 ASSERT_PTR_EQ(&conn.conn, req->handle); in tcp_connection_write_cb()
593 r = uv_write(&conn.tcp_write_req, tcp, &outbuf, 1, tcp_connection_write_cb); in on_tcp_child_process_read()
621 r = uv_tcp_init(server->loop, &conn.conn); in ipc_on_connection()
624 r = uv_accept(server, (uv_stream_t*)&conn.conn); in ipc_on_connection()
627 uv_close((uv_handle_t*)&conn.conn, close_cb); in ipc_on_connection()
647 uv_tcp_t* conn; in ipc_on_connection_tcp_conn() local
652 conn = malloc(sizeof(*conn)); in ipc_on_connection_tcp_conn()
653 ASSERT_NOT_NULL(conn); in ipc_on_connection_tcp_conn()
655 r = uv_tcp_init(server->loop, conn); in ipc_on_connection_tcp_conn()
658 r = uv_accept(server, (uv_stream_t*)conn); 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()
672 uv_close((uv_handle_t*)conn, close_and_free_cb); in ipc_on_connection_tcp_conn()
759 r = uv_tcp_init(uv_default_loop(), &conn.conn); in ipc_helper_tcp_connection()
764 r = uv_tcp_connect(&conn.conn_req, in ipc_helper_tcp_connection()
765 (uv_tcp_t*) &conn.conn, in ipc_helper_tcp_connection()
