Lines Matching refs:pipe
110 uv_pipe_init(ctxClient->thisClass->loopTask, &ctxClient->pipe, 0);
111 client = (uv_stream_t *)&ctxClient->pipe;
127 ctx->pipe.data = ctx;
205 Base::TryCloseHandle((uv_handle_t *)&ctx->pipe, true, funcHandleClose);
425 bool HdcForwardBase::LocalAbstractConnect(uv_pipe_t *pipe, string &sNodeCfg)
450 if (uv_pipe_open(pipe, s)) {
465 ctxPoint->pipe.data = ctxPoint;
466 uv_pipe_init(loopTask, &ctxPoint->pipe, 0);
471 if (uv_pipe_bind(&ctxPoint->pipe, sNodeCfg.c_str())) {
472 ctxPoint->lastError = "Unix pipe bind failed";
475 if (uv_listen((uv_stream_t *)&ctxPoint->pipe, UV_LISTEN_LBACKOG, ListenCallback)) {
476 ctxPoint->lastError = "Unix pipe listen failed";
481 bool abstractRet = LocalAbstractConnect(&ctxPoint->pipe, sNodeCfg);
494 uv_pipe_connect(connect, &ctxPoint->pipe, sNodeCfg.c_str(), ConnectTarget);
682 uv_read_start((uv_stream_t *)&ctx->pipe, AllocForwardBuf, ReadForwardBuf);
769 nRet = Base::SendToStreamEx((uv_stream_t *)&ctx->pipe, pDynBuf, size, nullptr,