Lines Matching refs:pipe
103 uv_pipe_init(ctxClient->thisClass->loopTask, &ctxClient->pipe, 0); in ListenCallback()
104 client = (uv_stream_t *)&ctxClient->pipe; in ListenCallback()
120 ctx->pipe.data = ctx; in MallocContext()
195 Base::TryCloseHandle((uv_handle_t *)&ctx->pipe, true, funcHandleClose); in FreeContext()
405 bool HdcForwardBase::LocalAbstractConnect(uv_pipe_t *pipe, string &sNodeCfg) in LocalAbstractConnect() argument
428 if (uv_pipe_open(pipe, s)) { in LocalAbstractConnect()
443 ctxPoint->pipe.data = ctxPoint; in SetupFilePoint()
444 uv_pipe_init(loopTask, &ctxPoint->pipe, 0); in SetupFilePoint()
449 if (uv_pipe_bind(&ctxPoint->pipe, sNodeCfg.c_str())) { in SetupFilePoint()
453 if (uv_listen((uv_stream_t *)&ctxPoint->pipe, 4, ListenCallback)) { in SetupFilePoint()
459 bool abstractRet = LocalAbstractConnect(&ctxPoint->pipe, sNodeCfg); in SetupFilePoint()
472 uv_pipe_connect(connect, &ctxPoint->pipe, sNodeCfg.c_str(), ConnectTarget); in SetupFilePoint()
630 uv_read_start((uv_stream_t *)&ctx->pipe, AllocForwardBuf, ReadForwardBuf); in DoForwardBegin()
714 nRet = Base::SendToStreamEx((uv_stream_t *)&ctx->pipe, pDynBuf, size, nullptr, in SendForwardBuf()