Lines Matching refs:loop
169 void UtForwardWaiter(uv_loop_t *loop, uv_tcp_t *server) in UtForwardWaiter() argument
185 uv_tcp_init(server->loop, client); in UtForwardWaiter()
199 if (uv_tcp_init(loop, server) || uv_ip4_addr("127.0.0.1", utForwardTargetPort, &addr)) { in UtForwardWaiter()
208 bool UtForwardConnect(uv_loop_t *loop, uv_tcp_t *client, uv_tcp_t *server) in UtForwardConnect() argument
217 … Base::DelayDoSimple(req->handle->loop, 3000, [=](const uint8_t flag, string &msg, const void *p) { in UtForwardConnect()
228 if (uv_tcp_init(loop, client)) { in UtForwardConnect()
243 uv_loop_t loop; in TestForwardExternThread() local
252 uv_stop(&loop); in TestForwardExternThread()
254 UtForwardConnect(&loop, &client, &server); in TestForwardExternThread()
257 uv_loop_init(&loop); in TestForwardExternThread()
258 UtForwardWaiter(&loop, &server); in TestForwardExternThread()
259 Base::DelayDoSimple(&loop, clientForwardTimeout, funcDelayCallUtForwardConnect); in TestForwardExternThread()
260 uv_run(&loop, UV_RUN_DEFAULT); in TestForwardExternThread()
261 uv_loop_close(&loop); in TestForwardExternThread()