Lines Matching refs:client
172 auto funcOnRead = [](uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) -> void { in UtForwardWaiter() argument
178 uv_close((uv_handle_t *)client, [](uv_handle_t *handle) { free(handle); }); in UtForwardWaiter()
184 uv_tcp_t *client = new uv_tcp_t(); in UtForwardWaiter() local
185 uv_tcp_init(server->loop, client); in UtForwardWaiter()
186 if (uv_accept(server, (uv_stream_t *)client) == 0) { in UtForwardWaiter()
187 uv_read_start((uv_stream_t *)client, in UtForwardWaiter()
194 uv_close((uv_handle_t *)client, [](uv_handle_t *handle) { free(handle); }); in UtForwardWaiter()
208 bool UtForwardConnect(uv_loop_t *loop, uv_tcp_t *client, uv_tcp_t *server) in UtForwardConnect() argument
228 if (uv_tcp_init(loop, client)) { in UtForwardConnect()
232 if (uv_tcp_connect(connReq, client, (const struct sockaddr *)&addr, funcConn)) { in UtForwardConnect()
245 uv_tcp_t client; in TestForwardExternThread() local
254 UtForwardConnect(&loop, &client, &server); in TestForwardExternThread()