Lines Matching refs:server
169 void UtForwardWaiter(uv_loop_t *loop, uv_tcp_t *server) in UtForwardWaiter() argument
171 auto funcOnNewConn = [](uv_stream_t *server, int status) -> void { in UtForwardWaiter() argument
185 uv_tcp_init(server->loop, client); in UtForwardWaiter()
186 if (uv_accept(server, (uv_stream_t *)client) == 0) { in UtForwardWaiter()
199 if (uv_tcp_init(loop, server) || uv_ip4_addr("127.0.0.1", utForwardTargetPort, &addr)) { in UtForwardWaiter()
202 …if (uv_tcp_bind(server, (const struct sockaddr *)&addr, 0) || uv_listen((uv_stream_t *)server, 5, … in UtForwardWaiter()
208 bool UtForwardConnect(uv_loop_t *loop, uv_tcp_t *client, uv_tcp_t *server) in UtForwardConnect() argument
211 uv_tcp_t *server = (uv_tcp_t *)req->data; in UtForwardConnect() local
218 uv_close((uv_handle_t *)server, nullptr); // notify UtForwardWaiter stop in UtForwardConnect()
226 connReq->data = server; in UtForwardConnect()
244 uv_tcp_t server; in TestForwardExternThread() local
254 UtForwardConnect(&loop, &client, &server); in TestForwardExternThread()
258 UtForwardWaiter(&loop, &server); in TestForwardExternThread()