Lines Matching refs:pipe
70 ctx->pipe.data = ctx;
91 Base::TryCloseHandle((const uv_handle_t *)&ctxIn->pipe, [](uv_handle_t *handle) {
115 void HdcJdwp::ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf)
136 HCtxJdwp ctxJdwp = static_cast<HCtxJdwp>(pipe->data);
169 if (uv_fileno(reinterpret_cast<uv_handle_t *>(&(ctxJdwp->pipe)), &fd) < 0) {
232 uv_pipe_init(thisClass->loop, &ctxJdwp->pipe, 1);
233 if (uv_accept(server, (uv_stream_t *)&ctxJdwp->pipe) < 0) {
245 uv_read_start((uv_stream_t *)&ctxJdwp->pipe, funAlloc, ReadStream);
249 // Test uv connect(pipe): 'uv_pipe_connect'
405 if (Base::SendToStreamEx((uv_stream_t *)&ctx->pipe, (uint8_t *)&ctx->dummy, 1, (uv_stream_t *)&ctx->jvmTCP,
444 uv_stream_t *stream = (uv_stream_t *)&ctx->pipe;
626 WRITE_LOG(LOG_FATAL, "DrainAwakenPollThread: Failed to read data from awaken pipe %d", retVal);
639 WRITE_LOG(LOG_FATAL, "WakePollThread: Failed to write data into awaken pipe %d", retVal);