Lines Matching refs:tcp
106 uv_tcp_init(ctxClient->thisClass->loopTask, &ctxClient->tcp); in ListenCallback()
107 client = (uv_stream_t *)&ctxClient->tcp; in ListenCallback()
126 ctx->tcp.data = ctx; in MallocContext()
199 Base::TryCloseHandle((uv_handle_t *)&ctx->tcp, true, funcHandleClose); in FreeContext()
369 ctxPoint->tcp.data = ctxPoint; in SetupTCPPoint()
370 uv_tcp_init(loopTask, &ctxPoint->tcp); in SetupTCPPoint()
374 uv_tcp_bind(&ctxPoint->tcp, (const struct sockaddr *)&addr, 0); in SetupTCPPoint()
375 if (uv_listen((uv_stream_t *)&ctxPoint->tcp, 4, ListenCallback)) { in SetupTCPPoint()
387 … uv_tcp_connect(conn, (uv_tcp_t *)&ctxPoint->tcp, (const struct sockaddr *)&addr, ConnectTarget); in SetupTCPPoint()
660 uv_tcp_nodelay((uv_tcp_t *)&ctx->tcp, 1); in DoForwardBegin()
661 uv_read_start((uv_stream_t *)&ctx->tcp, AllocForwardBuf, ReadForwardBuf); in DoForwardBegin()
665 uv_tcp_init(loopTask, &ctx->tcp); in DoForwardBegin()
666 uv_tcp_open(&ctx->tcp, fds[0]); in DoForwardBegin()
667 uv_tcp_nodelay((uv_tcp_t *)&ctx->tcp, 1); in DoForwardBegin()
668 uv_read_start((uv_stream_t *)&ctx->tcp, AllocForwardBuf, ReadForwardBuf); in DoForwardBegin()
754 nRet = Base::SendToStreamEx((uv_stream_t *)&ctx->tcp, pDynBuf, size, nullptr, in SendForwardBuf()