Lines Matching refs:uv_pipe_t
93 static void eof_timer_init(uv_pipe_t* pipe);
94 static void eof_timer_start(uv_pipe_t* pipe);
95 static void eof_timer_stop(uv_pipe_t* pipe);
97 static void eof_timer_destroy(uv_pipe_t* pipe);
114 int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) { in uv_pipe_init()
131 static void uv__pipe_connection_init(uv_pipe_t* handle) { in uv__pipe_connection_init()
197 static void close_pipe(uv_pipe_t* pipe) { in close_pipe()
395 uv_pipe_t* parent_pipe, HANDLE* child_pipe_ptr, unsigned int flags) { in uv__create_stdio_pipe_pair()
464 uv_pipe_t* handle, in uv__set_pipe_handle()
541 static int pipe_alloc_accept(uv_loop_t* loop, uv_pipe_t* handle, in pipe_alloc_accept()
575 uv_pipe_t* handle; in pipe_shutdown_thread_proc()
580 handle = (uv_pipe_t*) req->handle; in pipe_shutdown_thread_proc()
594 void uv__pipe_shutdown(uv_loop_t* loop, uv_pipe_t* handle, uv_shutdown_t *req) { in uv__pipe_shutdown()
644 void uv__pipe_endgame(uv_loop_t* loop, uv_pipe_t* handle) { in uv__pipe_endgame()
695 void uv_pipe_pending_instances(uv_pipe_t* handle, int count) { in uv_pipe_pending_instances()
704 int uv_pipe_bind(uv_pipe_t* handle, const char* name) { in uv_pipe_bind()
709 int uv_pipe_bind2(uv_pipe_t* handle, in uv_pipe_bind2()
816 uv_pipe_t* handle; in pipe_connect_thread_proc()
823 handle = (uv_pipe_t*) req->handle; in pipe_connect_thread_proc()
857 uv_pipe_t* handle, in uv_pipe_connect()
877 uv_pipe_t* handle, in uv_pipe_connect2()
1000 void uv__pipe_interrupt_read(uv_pipe_t* handle) { in uv__pipe_interrupt_read()
1047 void uv__pipe_read_stop(uv_pipe_t* handle) { in uv__pipe_read_stop()
1056 void uv__pipe_close(uv_loop_t* loop, uv_pipe_t* handle) { in uv__pipe_close()
1107 static void uv__pipe_queue_accept(uv_loop_t* loop, uv_pipe_t* handle, in uv__pipe_queue_accept()
1143 int uv__pipe_accept(uv_pipe_t* server, uv_stream_t* client) { in uv__pipe_accept()
1145 uv_pipe_t* pipe_client; in uv__pipe_accept()
1171 pipe_client = (uv_pipe_t*) client; in uv__pipe_accept()
1203 int uv__pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb) { in uv__pipe_listen()
1244 uv_pipe_t* handle = (uv_pipe_t*) req->data; in uv_pipe_zero_readfile_thread_proc()
1319 uv_pipe_t* handle = (uv_pipe_t*) req->handle; in uv_pipe_writefile_thread_proc()
1379 static void uv__pipe_queue_read(uv_loop_t* loop, uv_pipe_t* handle) { in uv__pipe_queue_read()
1443 int uv__pipe_read_start(uv_pipe_t* handle, in uv__pipe_read_start()
1470 static void uv__insert_non_overlapped_write_req(uv_pipe_t* handle, in uv__insert_non_overlapped_write_req()
1485 static uv_write_t* uv_remove_non_overlapped_write_req(uv_pipe_t* handle) { in uv_remove_non_overlapped_write_req()
1506 static void uv__queue_non_overlapped_write(uv_pipe_t* handle) { in uv__queue_non_overlapped_write()
1580 uv_pipe_t* handle, in uv__pipe_write_data()
1729 static DWORD uv__pipe_get_ipc_remote_pid(uv_pipe_t* handle) { in uv__pipe_get_ipc_remote_pid()
1748 uv_pipe_t* handle, in uv__pipe_write_ipc()
1850 uv_pipe_t* handle, in uv__pipe_write()
1866 static void uv__pipe_read_eof(uv_loop_t* loop, uv_pipe_t* handle, in uv__pipe_read_eof()
1878 static void uv__pipe_read_error(uv_loop_t* loop, uv_pipe_t* handle, int error, in uv__pipe_read_error()
1890 static void uv__pipe_read_error_or_eof(uv_loop_t* loop, uv_pipe_t* handle, in uv__pipe_read_error_or_eof()
1901 uv_pipe_t* handle, in uv__pipe_queue_ipc_xfer_info()
1921 static DWORD uv__pipe_read_exactly(uv_pipe_t* handle, void* buffer, DWORD count) { in uv__pipe_read_exactly()
1951 uv_pipe_t* handle, in uv__pipe_read_data()
2029 static int uv__pipe_read_ipc(uv_loop_t* loop, uv_pipe_t* handle) { in uv__pipe_read_ipc()
2117 uv_pipe_t* handle, in uv__process_pipe_read_req()
2175 void uv__process_pipe_write_req(uv_loop_t* loop, uv_pipe_t* handle, in uv__process_pipe_write_req()
2226 void uv__process_pipe_accept_req(uv_loop_t* loop, uv_pipe_t* handle, in uv__process_pipe_accept_req()
2261 void uv__process_pipe_connect_req(uv_loop_t* loop, uv_pipe_t* handle, in uv__process_pipe_connect_req()
2293 void uv__process_pipe_shutdown_req(uv_loop_t* loop, uv_pipe_t* handle, in uv__process_pipe_shutdown_req()
2336 static void eof_timer_init(uv_pipe_t* pipe) { in eof_timer_init()
2352 static void eof_timer_start(uv_pipe_t* pipe) { in eof_timer_start()
2361 static void eof_timer_stop(uv_pipe_t* pipe) { in eof_timer_stop()
2371 uv_pipe_t* pipe = (uv_pipe_t*) timer->data; in eof_timer_cb()
2404 static void eof_timer_destroy(uv_pipe_t* pipe) { in eof_timer_destroy()
2420 int uv_pipe_open(uv_pipe_t* pipe, uv_file file) { in uv_pipe_open()
2503 static int uv__pipe_getname(const uv_pipe_t* handle, char* buffer, size_t* size) { in uv__pipe_getname()
2534 uv__pipe_interrupt_read((uv_pipe_t*) handle); /* cast away const warning */ in uv__pipe_getname()
2597 int uv_pipe_pending_count(uv_pipe_t* handle) { in uv_pipe_pending_count()
2604 int uv_pipe_getsockname(const uv_pipe_t* handle, char* buffer, size_t* size) { in uv_pipe_getsockname()
2618 int uv_pipe_getpeername(const uv_pipe_t* handle, char* buffer, size_t* size) { in uv_pipe_getpeername()
2635 uv_handle_type uv_pipe_pending_type(uv_pipe_t* handle) { in uv_pipe_pending_type()
2644 int uv_pipe_chmod(uv_pipe_t* handle, int mode) { in uv_pipe_chmod()