uv_pipe_t 198 include/uv.h typedef struct uv_pipe_s uv_pipe_t; uv_pipe_t 372 include/uv.h typedef void (*uv_read2_cb)(uv_pipe_t* pipe, ssize_t nread, uv_buf_t buf, uv_pipe_t 1084 include/uv.h UV_EXTERN int uv_pipe_init(uv_loop_t*, uv_pipe_t* handle, int ipc); uv_pipe_t 1089 include/uv.h UV_EXTERN int uv_pipe_open(uv_pipe_t*, uv_file file); uv_pipe_t 1091 include/uv.h UV_EXTERN int uv_pipe_bind(uv_pipe_t* handle, const char* name); uv_pipe_t 1093 include/uv.h UV_EXTERN void uv_pipe_connect(uv_connect_t* req, uv_pipe_t* handle, uv_pipe_t 1101 include/uv.h UV_EXTERN void uv_pipe_pending_instances(uv_pipe_t* handle, int count); uv_pipe_t 91 src/unix/core.c uv__pipe_close((uv_pipe_t*)handle); uv_pipe_t 176 src/unix/internal.h int uv_pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb); uv_pipe_t 205 src/unix/internal.h void uv__pipe_close(uv_pipe_t* handle); uv_pipe_t 35 src/unix/pipe.c int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) { uv_pipe_t 45 src/unix/pipe.c int uv_pipe_bind(uv_pipe_t* handle, const char* name) { uv_pipe_t 106 src/unix/pipe.c int uv_pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb) { uv_pipe_t 120 src/unix/pipe.c void uv__pipe_close(uv_pipe_t* handle) { uv_pipe_t 137 src/unix/pipe.c int uv_pipe_open(uv_pipe_t* handle, uv_file fd) { uv_pipe_t 153 src/unix/pipe.c uv_pipe_t* handle, uv_pipe_t 217 src/unix/pipe.c uv_pipe_t* pipe; uv_pipe_t 220 src/unix/pipe.c pipe = container_of(w, uv_pipe_t, io_watcher); uv_pipe_t 239 src/unix/pipe.c void uv_pipe_pending_instances(uv_pipe_t* handle, int count) { uv_pipe_t 242 src/unix/process.c ((uv_pipe_t*)container->data.stream)->ipc) uv_pipe_t 610 src/unix/stream.c err = uv_pipe_listen((uv_pipe_t*)stream, backlog, cb); uv_pipe_t 946 src/unix/stream.c stream->read2_cb((uv_pipe_t*) stream, status, buf, type); uv_pipe_t 1073 src/unix/stream.c stream->read2_cb((uv_pipe_t*)stream, nread, buf, uv_pipe_t 1076 src/unix/stream.c stream->read2_cb((uv_pipe_t*)stream, nread, buf, UV_UNKNOWN_HANDLE); uv_pipe_t 1224 src/unix/stream.c if (stream->type != UV_NAMED_PIPE || !((uv_pipe_t*)stream)->ipc) uv_pipe_t 112 src/win/handle-inl.h uv_pipe_endgame(loop, (uv_pipe_t*) handle); uv_pipe_t 83 src/win/handle.c uv_pipe_close(loop, (uv_pipe_t*) handle); uv_pipe_t 143 src/win/internal.h int uv_stdio_pipe_server(uv_loop_t* loop, uv_pipe_t* handle, DWORD access, uv_pipe_t 146 src/win/internal.h int uv_pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb); uv_pipe_t 147 src/win/internal.h int uv_pipe_accept(uv_pipe_t* server, uv_stream_t* client); uv_pipe_t 148 src/win/internal.h int uv_pipe_read_start(uv_pipe_t* handle, uv_alloc_cb alloc_cb, uv_pipe_t 150 src/win/internal.h int uv_pipe_read2_start(uv_pipe_t* handle, uv_alloc_cb alloc_cb, uv_pipe_t 152 src/win/internal.h int uv_pipe_write(uv_loop_t* loop, uv_write_t* req, uv_pipe_t* handle, uv_pipe_t 154 src/win/internal.h int uv_pipe_write2(uv_loop_t* loop, uv_write_t* req, uv_pipe_t* handle, uv_pipe_t 157 src/win/internal.h void uv_process_pipe_read_req(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 159 src/win/internal.h void uv_process_pipe_write_req(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 161 src/win/internal.h void uv_process_pipe_accept_req(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 163 src/win/internal.h void uv_process_pipe_connect_req(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 165 src/win/internal.h void uv_process_pipe_shutdown_req(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 168 src/win/internal.h void uv_pipe_close(uv_loop_t* loop, uv_pipe_t* handle); uv_pipe_t 169 src/win/internal.h void uv_pipe_cleanup(uv_loop_t* loop, uv_pipe_t* handle); uv_pipe_t 170 src/win/internal.h void uv_pipe_endgame(uv_loop_t* loop, uv_pipe_t* handle); uv_pipe_t 64 src/win/pipe.c static void eof_timer_init(uv_pipe_t* pipe); uv_pipe_t 65 src/win/pipe.c static void eof_timer_start(uv_pipe_t* pipe); uv_pipe_t 66 src/win/pipe.c static void eof_timer_stop(uv_pipe_t* pipe); uv_pipe_t 68 src/win/pipe.c static void eof_timer_destroy(uv_pipe_t* pipe); uv_pipe_t 77 src/win/pipe.c int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) { uv_pipe_t 96 src/win/pipe.c static void uv_pipe_connection_init(uv_pipe_t* handle) { uv_pipe_t 161 src/win/pipe.c int uv_stdio_pipe_server(uv_loop_t* loop, uv_pipe_t* handle, DWORD access, uv_pipe_t 211 src/win/pipe.c static int uv_set_pipe_handle(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 260 src/win/pipe.c uv_pipe_t* handle; uv_pipe_t 265 src/win/pipe.c handle = (uv_pipe_t*) req->handle; uv_pipe_t 279 src/win/pipe.c void uv_pipe_endgame(uv_loop_t* loop, uv_pipe_t* handle) { uv_pipe_t 389 src/win/pipe.c void uv_pipe_pending_instances(uv_pipe_t* handle, int count) { uv_pipe_t 396 src/win/pipe.c int uv_pipe_bind(uv_pipe_t* handle, const char* name) { uv_pipe_t 487 src/win/pipe.c uv_pipe_t* handle; uv_pipe_t 494 src/win/pipe.c handle = (uv_pipe_t*) req->handle; uv_pipe_t 525 src/win/pipe.c void uv_pipe_connect(uv_connect_t* req, uv_pipe_t* handle, uv_pipe_t 573 src/win/pipe.c (uv_pipe_t*) req->handle, uv_pipe_t 607 src/win/pipe.c void uv_pipe_cleanup(uv_loop_t* loop, uv_pipe_t* handle) { uv_pipe_t 639 src/win/pipe.c void uv_pipe_close(uv_loop_t* loop, uv_pipe_t* handle) { uv_pipe_t 661 src/win/pipe.c static void uv_pipe_queue_accept(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 714 src/win/pipe.c int uv_pipe_accept(uv_pipe_t* server, uv_stream_t* client) { uv_pipe_t 716 src/win/pipe.c uv_pipe_t* pipe_client; uv_pipe_t 728 src/win/pipe.c pipe_client = (uv_pipe_t*)client; uv_pipe_t 759 src/win/pipe.c int uv_pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb) { uv_pipe_t 798 src/win/pipe.c uv_pipe_t* handle = (uv_pipe_t*) req->data; uv_pipe_t 824 src/win/pipe.c uv_pipe_t* handle = (uv_pipe_t*) req->handle; uv_pipe_t 885 src/win/pipe.c static void uv_pipe_queue_read(uv_loop_t* loop, uv_pipe_t* handle) { uv_pipe_t 954 src/win/pipe.c static int uv_pipe_read_start_impl(uv_pipe_t* handle, uv_alloc_cb alloc_cb, uv_pipe_t 973 src/win/pipe.c int uv_pipe_read_start(uv_pipe_t* handle, uv_alloc_cb alloc_cb, uv_pipe_t 979 src/win/pipe.c int uv_pipe_read2_start(uv_pipe_t* handle, uv_alloc_cb alloc_cb, uv_pipe_t 985 src/win/pipe.c static void uv_insert_non_overlapped_write_req(uv_pipe_t* handle, uv_pipe_t 1000 src/win/pipe.c static uv_write_t* uv_remove_non_overlapped_write_req(uv_pipe_t* handle) { uv_pipe_t 1021 src/win/pipe.c static void uv_queue_non_overlapped_write(uv_pipe_t* handle) { uv_pipe_t 1034 src/win/pipe.c uv_pipe_t* handle, uv_buf_t bufs[], int bufcnt, uv_pipe_t 1273 src/win/pipe.c int uv_pipe_write(uv_loop_t* loop, uv_write_t* req, uv_pipe_t* handle, uv_pipe_t 1279 src/win/pipe.c int uv_pipe_write2(uv_loop_t* loop, uv_write_t* req, uv_pipe_t* handle, uv_pipe_t 1289 src/win/pipe.c static void uv_pipe_read_eof(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 1306 src/win/pipe.c static void uv_pipe_read_error(uv_loop_t* loop, uv_pipe_t* handle, int error, uv_pipe_t 1325 src/win/pipe.c static void uv_pipe_read_error_or_eof(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 1335 src/win/pipe.c void uv_process_pipe_read_req(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 1489 src/win/pipe.c void uv_process_pipe_write_req(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 1541 src/win/pipe.c void uv_process_pipe_accept_req(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 1569 src/win/pipe.c void uv_process_pipe_connect_req(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 1591 src/win/pipe.c void uv_process_pipe_shutdown_req(uv_loop_t* loop, uv_pipe_t* handle, uv_pipe_t 1617 src/win/pipe.c static void eof_timer_init(uv_pipe_t* pipe) { uv_pipe_t 1632 src/win/pipe.c static void eof_timer_start(uv_pipe_t* pipe) { uv_pipe_t 1641 src/win/pipe.c static void eof_timer_stop(uv_pipe_t* pipe) { uv_pipe_t 1651 src/win/pipe.c uv_pipe_t* pipe = (uv_pipe_t*) timer->data; uv_pipe_t 1687 src/win/pipe.c static void eof_timer_destroy(uv_pipe_t* pipe) { uv_pipe_t 1703 src/win/pipe.c int uv_pipe_open(uv_pipe_t* pipe, uv_file file) { uv_pipe_t 98 src/win/process-stdio.c uv_pipe_t* server_pipe, HANDLE* child_pipe_ptr, unsigned int flags) { uv_pipe_t 320 src/win/process-stdio.c uv_pipe_t* parent_pipe = (uv_pipe_t*) fdopt.data.stream; uv_pipe_t 401 src/win/process-stdio.c stream_handle = ((uv_pipe_t*) stream)->handle; uv_pipe_t 994 src/win/process.c ((uv_pipe_t*) fdopt->data.stream)->ipc) { uv_pipe_t 995 src/win/process.c ((uv_pipe_t*) fdopt->data.stream)->ipc_pid = info.dwProcessId; uv_pipe_t 117 src/win/req-inl.h (uv_pipe_t*) ((req)->handle_at), \ uv_pipe_t 172 src/win/req-inl.h (uv_pipe_t*) ((uv_shutdown_t*) req)->handle, uv_pipe_t 39 src/win/stream.c err = uv_pipe_listen((uv_pipe_t*)stream, backlog, cb); uv_pipe_t 58 src/win/stream.c err = uv_pipe_accept((uv_pipe_t*)server, client); uv_pipe_t 86 src/win/stream.c err = uv_pipe_read_start((uv_pipe_t*)handle, alloc_cb, read_cb); uv_pipe_t 114 src/win/stream.c err = uv_pipe_read2_start((uv_pipe_t*)handle, alloc_cb, read_cb); uv_pipe_t 157 src/win/stream.c err = uv_pipe_write(loop, req, (uv_pipe_t*) handle, bufs, bufcnt, cb); uv_pipe_t 182 src/win/stream.c err = uv_pipe_write2(loop, req, (uv_pipe_t*) handle, bufs, bufcnt, send_handle, cb); uv_pipe_t 29 test/benchmark-multi-accept.c uv_pipe_t pipe; uv_pipe_t 51 test/benchmark-multi-accept.c uv_pipe_t ipc_pipe; uv_pipe_t 62 test/benchmark-multi-accept.c uv_pipe_t ipc_pipe; uv_pipe_t 86 test/benchmark-multi-accept.c static void ipc_read2_cb(uv_pipe_t* ipc_pipe, uv_pipe_t 119 test/benchmark-multi-accept.c ASSERT(0 == uv_pipe_init(loop, (uv_pipe_t*) &pc->peer_handle, 1)); uv_pipe_t 167 test/benchmark-multi-accept.c static void ipc_read2_cb(uv_pipe_t* ipc_pipe, uv_pipe_t 180 test/benchmark-multi-accept.c ASSERT(0 == uv_pipe_init(loop, (uv_pipe_t*) ctx->server_handle, 0)); uv_pipe_t 288 test/benchmark-multi-accept.c ASSERT(0 == uv_pipe_init(server_handle->loop, (uv_pipe_t*) storage, 0)); uv_pipe_t 64 test/benchmark-pound.c uv_pipe_t stream; uv_pipe_t 223 test/benchmark-pound.c r = uv_pipe_init(loop, (uv_pipe_t*)&p->stream, 0); uv_pipe_t 226 test/benchmark-pound.c uv_pipe_connect(&((pipe_conn_rec*)p)->conn_req, (uv_pipe_t*)&p->stream, TEST_PIPENAME, connect_cb); uv_pipe_t 50 test/benchmark-pump.c static uv_pipe_t pipeServer; uv_pipe_t 77 test/benchmark-pump.c static uv_pipe_t pipe_write_handles[MAX_WRITE_HANDLES]; uv_pipe_t 231 test/benchmark-pump.c uv_pipe_t* pipe; uv_pipe_t 270 test/benchmark-pump.c stream = (uv_stream_t*)malloc(sizeof(uv_pipe_t)); uv_pipe_t 271 test/benchmark-pump.c r = uv_pipe_init(loop, (uv_pipe_t*)stream, 0); uv_pipe_t 32 test/benchmark-sizes.c LOGF("uv_pipe_t: %u bytes\n", (unsigned int) sizeof(uv_pipe_t)); uv_pipe_t 37 test/benchmark-spawn.c static uv_pipe_t out; uv_pipe_t 38 test/echo-server.c static uv_pipe_t pipeServer; uv_pipe_t 156 test/echo-server.c stream = malloc(sizeof(uv_pipe_t)); uv_pipe_t 158 test/echo-server.c r = uv_pipe_init(loop, (uv_pipe_t*)stream, 0); uv_pipe_t 29 test/test-ipc-send-recv.c void spawn_helper(uv_pipe_t* channel, uv_pipe_t 36 test/test-ipc-send-recv.c uv_pipe_t pipe; uv_pipe_t 42 test/test-ipc-send-recv.c uv_pipe_t channel; uv_pipe_t 60 test/test-ipc-send-recv.c static void recv_cb(uv_pipe_t* handle, uv_pipe_t 162 test/test-ipc-send-recv.c static void read2_cb(uv_pipe_t* handle, uv_pipe_t 28 test/test-ipc.c static uv_pipe_t channel; uv_pipe_t 41 test/test-ipc.c static uv_pipe_t channel; uv_pipe_t 135 test/test-ipc.c static void on_read(uv_pipe_t* pipe, ssize_t nread, uv_buf_t buf, uv_pipe_t 195 test/test-ipc.c void spawn_helper(uv_pipe_t* channel, uv_pipe_t 262 test/test-ipc.c static void on_read_connection(uv_pipe_t* pipe, ssize_t nread, uv_buf_t buf, uv_pipe_t 44 test/test-ping-pong.c uv_pipe_t pipe; uv_pipe_t 45 test/test-pipe-bind-error.c uv_pipe_t server1, server2; uv_pipe_t 76 test/test-pipe-bind-error.c uv_pipe_t server; uv_pipe_t 97 test/test-pipe-bind-error.c uv_pipe_t server; uv_pipe_t 119 test/test-pipe-bind-error.c uv_pipe_t server; uv_pipe_t 60 test/test-pipe-connect-error.c uv_pipe_t client; uv_pipe_t 80 test/test-pipe-connect-error.c uv_pipe_t client; uv_pipe_t 331 test/test-ref.c uv_pipe_t h; uv_pipe_t 342 test/test-ref.c uv_pipe_t h; uv_pipe_t 354 test/test-ref.c uv_pipe_t h; uv_pipe_t 368 test/test-ref.c uv_pipe_t h; uv_pipe_t 89 test/test-shutdown-close.c uv_pipe_t h; uv_pipe_t 200 test/test-spawn.c uv_pipe_t out; uv_pipe_t 286 test/test-spawn.c uv_pipe_t out; uv_pipe_t 287 test/test-spawn.c uv_pipe_t in; uv_pipe_t 329 test/test-spawn.c uv_pipe_t pipe; uv_pipe_t 411 test/test-spawn.c uv_pipe_t out; uv_pipe_t 478 test/test-spawn.c uv_pipe_t in, out, err; uv_pipe_t 537 test/test-spawn.c uv_pipe_t in, out; uv_pipe_t 618 test/test-spawn.c uv_pipe_t out; uv_pipe_t 37 test/test-stdio-over-pipes.c static uv_pipe_t in; uv_pipe_t 38 test/test-stdio-over-pipes.c static uv_pipe_t out; uv_pipe_t 161 test/test-stdio-over-pipes.c static uv_pipe_t stdin_pipe; uv_pipe_t 162 test/test-stdio-over-pipes.c static uv_pipe_t stdout_pipe;