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) {
131 static void uv__pipe_connection_init(uv_pipe_t* handle) {
197 static void close_pipe(uv_pipe_t* pipe) {
390 uv_pipe_t* parent_pipe, HANDLE* child_pipe_ptr, unsigned int flags) {
459 uv_pipe_t* handle,
536 static int pipe_alloc_accept(uv_loop_t* loop, uv_pipe_t* handle,
570 uv_pipe_t* handle;
575 handle = (uv_pipe_t*) req->handle;
589 void uv__pipe_shutdown(uv_loop_t* loop, uv_pipe_t* handle, uv_shutdown_t *req) {
639 void uv__pipe_endgame(uv_loop_t* loop, uv_pipe_t* handle) {
695 void uv_pipe_pending_instances(uv_pipe_t* handle, int count) {
704 int uv_pipe_bind(uv_pipe_t* handle, const char* name) {
709 int uv_pipe_bind2(uv_pipe_t* handle,
816 uv_pipe_t* handle;
823 handle = (uv_pipe_t*) req->handle;
857 uv_pipe_t* handle,
877 uv_pipe_t* handle,
1000 void uv__pipe_interrupt_read(uv_pipe_t* handle) {
1047 void uv__pipe_read_stop(uv_pipe_t* handle) {
1054 /* Cleans up uv_pipe_t (server or connection) and all resources associated with
1056 void uv__pipe_close(uv_loop_t* loop, uv_pipe_t* handle) {
1107 static void uv__pipe_queue_accept(uv_loop_t* loop, uv_pipe_t* handle,
1143 int uv__pipe_accept(uv_pipe_t* server, uv_stream_t* client) {
1145 uv_pipe_t* pipe_client;
1171 pipe_client = (uv_pipe_t*) client;
1203 int uv__pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb) {
1244 uv_pipe_t* handle = (uv_pipe_t*) req->data;
1319 uv_pipe_t* handle = (uv_pipe_t*) req->handle;
1379 static void uv__pipe_queue_read(uv_loop_t* loop, uv_pipe_t* handle) {
1444 int uv__pipe_read_start(uv_pipe_t* handle,
1471 static void uv__insert_non_overlapped_write_req(uv_pipe_t* handle,
1486 static uv_write_t* uv_remove_non_overlapped_write_req(uv_pipe_t* handle) {
1507 static void uv__queue_non_overlapped_write(uv_pipe_t* handle) {
1581 uv_pipe_t* handle,
1730 static DWORD uv__pipe_get_ipc_remote_pid(uv_pipe_t* handle) {
1749 uv_pipe_t* handle,
1851 uv_pipe_t* handle,
1867 static void uv__pipe_read_eof(uv_loop_t* loop, uv_pipe_t* handle,
1879 static void uv__pipe_read_error(uv_loop_t* loop, uv_pipe_t* handle, int error,
1891 static void uv__pipe_read_error_or_eof(uv_loop_t* loop, uv_pipe_t* handle,
1902 uv_pipe_t* handle,
1944 uv_pipe_t* handle,
1978 static DWORD uv__pipe_read_ipc(uv_loop_t* loop, uv_pipe_t* handle) {
2060 uv_pipe_t* handle,
2126 void uv__process_pipe_write_req(uv_loop_t* loop, uv_pipe_t* handle,
2179 void uv__process_pipe_accept_req(uv_loop_t* loop, uv_pipe_t* handle,
2214 void uv__process_pipe_connect_req(uv_loop_t* loop, uv_pipe_t* handle,
2246 void uv__process_pipe_shutdown_req(uv_loop_t* loop, uv_pipe_t* handle,
2289 static void eof_timer_init(uv_pipe_t* pipe) {
2305 static void eof_timer_start(uv_pipe_t* pipe) {
2314 static void eof_timer_stop(uv_pipe_t* pipe) {
2324 uv_pipe_t* pipe = (uv_pipe_t*) timer->data;
2357 static void eof_timer_destroy(uv_pipe_t* pipe) {
2373 int uv_pipe_open(uv_pipe_t* pipe, uv_file file) {
2456 static int uv__pipe_getname(const uv_pipe_t* handle, char* buffer, size_t* size) {
2487 uv__pipe_interrupt_read((uv_pipe_t*) handle); /* cast away const warning */
2550 int uv_pipe_pending_count(uv_pipe_t* handle) {
2557 int uv_pipe_getsockname(const uv_pipe_t* handle, char* buffer, size_t* size) {
2571 int uv_pipe_getpeername(const uv_pipe_t* handle, char* buffer, size_t* size) {
2588 uv_handle_type uv_pipe_pending_type(uv_pipe_t* handle) {
2597 int uv_pipe_chmod(uv_pipe_t* handle, int mode) {