/third_party/libuv/src/win/ |
H A D | stream.c | 40 case UV_NAMED_PIPE: in uv_listen() 59 case UV_NAMED_PIPE: in uv_accept() 80 case UV_NAMED_PIPE: in uv__read_start() 103 } else if (handle->type == UV_NAMED_PIPE) { in uv_read_stop() 131 case UV_NAMED_PIPE: in uv_write() 159 if (handle->type != UV_NAMED_PIPE || !((uv_pipe_t*) handle)->ipc) { in uv_write2() 184 case UV_NAMED_PIPE: in uv_try_write() 222 if (handle->type == UV_NAMED_PIPE) in uv_shutdown() 243 if (handle->type != UV_NAMED_PIPE) in uv_stream_set_blocking()
|
H A D | handle.c | 50 return UV_NAMED_PIPE; in uv_guess_handle() 83 case UV_NAMED_PIPE: in uv_close()
|
H A D | process-stdio.c | 239 assert(fdopt.data.stream->type == UV_NAMED_PIPE); in uv__stdio_create() 315 } else if (stream->type == UV_NAMED_PIPE && in uv__stdio_create()
|
H A D | handle-inl.h | 112 case UV_NAMED_PIPE: in uv__process_endgames()
|
H A D | pipe.c | 115 uv__stream_init(loop, (uv_stream_t*)handle, UV_NAMED_PIPE); in uv_pipe_init() 1253 assert(handle->type == UV_NAMED_PIPE); in uv_pipe_zero_readfile_thread_proc() 1324 assert(handle->type == UV_NAMED_PIPE); in uv_pipe_writefile_thread_proc() 2062 assert(handle->type == UV_NAMED_PIPE); in uv__process_pipe_read_req() 2130 assert(handle->type == UV_NAMED_PIPE); in uv__process_pipe_write_req() 2183 assert(handle->type == UV_NAMED_PIPE); in uv__process_pipe_accept_req() 2220 assert(handle->type == UV_NAMED_PIPE); in uv__process_pipe_connect_req() 2250 assert(handle->type == UV_NAMED_PIPE); in uv__process_pipe_shutdown_req() 2327 assert(pipe->type == UV_NAMED_PIPE); in eof_timer_cb()
|
H A D | req-inl.h | 123 case UV_NAMED_PIPE: \
|
/third_party/node/deps/uv/src/win/ |
H A D | stream.c | 40 case UV_NAMED_PIPE: in uv_listen() 59 case UV_NAMED_PIPE: in uv_accept() 80 case UV_NAMED_PIPE: in uv__read_start() 103 } else if (handle->type == UV_NAMED_PIPE) { in uv_read_stop() 131 case UV_NAMED_PIPE: in uv_write() 159 if (handle->type != UV_NAMED_PIPE || !((uv_pipe_t*) handle)->ipc) { in uv_write2() 184 case UV_NAMED_PIPE: in uv_try_write() 223 if (handle->type == UV_NAMED_PIPE) in uv_shutdown() 244 if (handle->type != UV_NAMED_PIPE) in uv_stream_set_blocking()
|
H A D | handle.c | 50 return UV_NAMED_PIPE; in uv_guess_handle() 83 case UV_NAMED_PIPE: in uv_close()
|
H A D | process-stdio.c | 239 assert(fdopt.data.stream->type == UV_NAMED_PIPE); in uv__stdio_create() 315 } else if (stream->type == UV_NAMED_PIPE && in uv__stdio_create()
|
H A D | pipe.c | 107 uv__stream_init(loop, (uv_stream_t*)handle, UV_NAMED_PIPE); in uv_pipe_init() 1158 assert(handle->type == UV_NAMED_PIPE); in uv_pipe_zero_readfile_thread_proc() 1229 assert(handle->type == UV_NAMED_PIPE); in uv_pipe_writefile_thread_proc() 1963 assert(handle->type == UV_NAMED_PIPE); in uv__process_pipe_read_req() 2031 assert(handle->type == UV_NAMED_PIPE); in uv__process_pipe_write_req() 2084 assert(handle->type == UV_NAMED_PIPE); in uv__process_pipe_accept_req() 2121 assert(handle->type == UV_NAMED_PIPE); in uv__process_pipe_connect_req() 2148 assert(handle->type == UV_NAMED_PIPE); in uv__process_pipe_shutdown_req() 2226 assert(pipe->type == UV_NAMED_PIPE); in eof_timer_cb()
|
H A D | handle-inl.h | 112 case UV_NAMED_PIPE: in uv__process_endgames()
|
H A D | req-inl.h | 123 case UV_NAMED_PIPE: \
|
/third_party/libuv/test/ |
H A D | test-getters-setters.c | 37 ASSERT_OK(strcmp(uv_handle_type_name(UV_NAMED_PIPE), "pipe")); in TEST_IMPL() 73 pipe = malloc(uv_handle_size(UV_NAMED_PIPE)); in TEST_IMPL() 76 ASSERT_EQ(uv_handle_get_type((uv_handle_t*)pipe), UV_NAMED_PIPE); in TEST_IMPL() local
|
H A D | test-ipc-send-recv.c | 123 if (pending == UV_NAMED_PIPE) in recv_cb() 209 ctx.expected_type = UV_NAMED_PIPE; in run_ipc_send_recv_pipe() 332 ASSERT(pending == UV_NAMED_PIPE || pending == UV_TCP); in read_cb() 334 if (pending == UV_NAMED_PIPE) in read_cb()
|
H A D | test-ping-pong.c | 321 ASSERT_EQ(uv_guess_handle((uv_file) fds[0]), UV_NAMED_PIPE); in socketpair_pinger_new() local 322 ASSERT_EQ(uv_guess_handle((uv_file) fds[1]), UV_NAMED_PIPE); in socketpair_pinger_new() local 353 ASSERT_EQ(uv_guess_handle(fds[0]), UV_NAMED_PIPE); in pipe2_pinger_new() local 354 ASSERT_EQ(uv_guess_handle(fds[1]), UV_NAMED_PIPE); in pipe2_pinger_new() local
|
H A D | benchmark-multi-accept.c | 121 else if (ipc_pipe->type == UV_NAMED_PIPE) in ipc_connection_cb() 189 else if (type == UV_NAMED_PIPE) in ipc_read_cb() 302 else if (server_handle->type == UV_NAMED_PIPE) in sv_connection_cb()
|
H A D | test-stdio-over-pipes.c | 225 ASSERT_EQ(UV_NAMED_PIPE, uv_guess_handle(0)); in stdio_over_pipes_helper() 226 ASSERT_EQ(UV_NAMED_PIPE, uv_guess_handle(1)); in stdio_over_pipes_helper()
|
H A D | test-pipe-sendmsg.c | 86 ASSERT_EQ(pending, UV_NAMED_PIPE); in read_cb()
|
/third_party/node/src/ |
H A D | node_report_utils.cc | 182 case UV_NAMED_PIPE: in WalkHandle() 215 || h->type == UV_NAMED_PIPE in WalkHandle() 229 if (h->type == UV_TCP || h->type == UV_NAMED_PIPE || h->type == UV_TTY || in WalkHandle() 253 if (h->type == UV_TCP || h->type == UV_NAMED_PIPE || h->type == UV_TTY) { in WalkHandle()
|
H A D | stream_wrap.h | 65 return stream()->type == UV_NAMED_PIPE; in is_named_pipe()
|
/third_party/libuv/src/unix/ |
H A D | stream.c | 545 case UV_NAMED_PIPE: in uv_accept() 611 case UV_NAMED_PIPE: in uv_listen() 741 case UV_NAMED_PIPE: in uv__handle_fd() 1036 is_ipc = stream->type == UV_NAMED_PIPE && ((uv_pipe_t*) stream)->ipc; in uv__read() 1089 } else if (errno == ECONNRESET && stream->type == UV_NAMED_PIPE) { in uv__read() 1158 stream->type == UV_NAMED_PIPE); in uv_shutdown() 1190 stream->type == UV_NAMED_PIPE || in uv__stream_io() 1246 assert(stream->type == UV_TCP || stream->type == UV_NAMED_PIPE); in uv__stream_connect() 1295 stream->type == UV_NAMED_PIPE || in uv__check_before_write() 1306 if (stream->type != UV_NAMED_PIPE || !((uv_pipe_ in uv__check_before_write() [all...] |
H A D | tty.c | 391 return UV_FILE; /* XXX UV_NAMED_PIPE? */ in uv_guess_handle() 394 return UV_NAMED_PIPE; in uv_guess_handle() 431 return UV_NAMED_PIPE; in uv_guess_handle() 437 return UV_NAMED_PIPE; in uv_guess_handle()
|
/third_party/node/deps/uv/src/unix/ |
H A D | stream.c | 577 case UV_NAMED_PIPE: in uv_accept() 643 case UV_NAMED_PIPE: in uv_listen() 774 case UV_NAMED_PIPE: in uv__handle_fd() 1094 is_ipc = stream->type == UV_NAMED_PIPE && ((uv_pipe_t*) stream)->ipc; in uv__read() 1147 } else if (errno == ECONNRESET && stream->type == UV_NAMED_PIPE) { in uv__read() 1224 stream->type == UV_NAMED_PIPE); in uv_shutdown() 1257 stream->type == UV_NAMED_PIPE || in uv__stream_io() 1313 assert(stream->type == UV_TCP || stream->type == UV_NAMED_PIPE); in uv__stream_connect() 1362 stream->type == UV_NAMED_PIPE || in uv__check_before_write() 1373 if (stream->type != UV_NAMED_PIPE || !((uv_pipe_ in uv__check_before_write() [all...] |
H A D | tty.c | 386 return UV_FILE; /* XXX UV_NAMED_PIPE? */ in uv_guess_handle() 389 return UV_NAMED_PIPE; in uv_guess_handle() 426 return UV_NAMED_PIPE; in uv_guess_handle() 432 return UV_NAMED_PIPE; in uv_guess_handle()
|
H A D | core.c | 122 case UV_NAMED_PIPE: in uv_close() 204 if (handle->type == UV_TCP || handle->type == UV_NAMED_PIPE) in uv__socket_sockopt() 300 case UV_NAMED_PIPE: in uv__finish_close() 773 case UV_NAMED_PIPE: in uv_fileno()
|