Lines Matching refs:uv_stream_t
47 uv_stream_t* stream;
73 static void uv__stream_connect(uv_stream_t*);
74 static void uv__write(uv_stream_t* stream);
75 static void uv__read(uv_stream_t* stream);
77 static void uv__write_callbacks(uv_stream_t* stream);
79 static void uv__drain(uv_stream_t* stream);
83 uv_stream_t* stream, in uv__stream_init()
120 static void uv__stream_osx_interrupt_select(uv_stream_t* stream) { in uv__stream_osx_interrupt_select()
147 uv_stream_t* stream; in uv__stream_osx_select()
236 uv_stream_t* stream; in uv__stream_osx_select_cb()
274 int uv__stream_try_select(uv_stream_t* stream, int* fd) { in uv__stream_try_select()
403 int uv__stream_open(uv_stream_t* stream, int fd, int flags) { in uv__stream_open()
440 void uv__stream_flush_write_queue(uv_stream_t* stream, int error) { in uv__stream_flush_write_queue()
455 void uv__stream_destroy(uv_stream_t* stream) { in uv__stream_destroy()
509 uv_stream_t* stream; in uv__server_io()
513 stream = container_of(w, uv_stream_t, io_watcher); in uv__server_io()
536 int uv_accept(uv_stream_t* server, uv_stream_t* client) { in uv_accept()
601 int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb) { in uv_listen()
626 static void uv__drain(uv_stream_t* stream) { in uv__drain()
688 static int uv__write_req_update(uv_stream_t* stream, in uv__write_req_update()
715 uv_stream_t* stream = req->handle; in uv__write_req_finish()
744 return ((uv_stream_t*) handle)->io_watcher.fd; in uv__handle_fd()
754 static int uv__try_write(uv_stream_t* stream, in uv__try_write()
757 uv_stream_t* send_handle) { in uv__try_write()
840 static void uv__write(uv_stream_t* stream) { in uv__write()
901 static void uv__write_callbacks(uv_stream_t* stream) { in uv__write_callbacks()
932 static void uv__stream_eof(uv_stream_t* stream, const uv_buf_t* buf) { in uv__stream_eof()
942 static int uv__stream_queue_fd(uv_stream_t* stream, int fd) { in uv__stream_queue_fd()
981 static int uv__stream_recv_cmsg(uv_stream_t* stream, struct msghdr* msg) { in uv__stream_recv_cmsg()
1025 static void uv__read(uv_stream_t* stream) { in uv__read()
1160 int uv_shutdown(uv_shutdown_t* req, uv_stream_t* stream, uv_shutdown_cb cb) { in uv_shutdown()
1190 uv_stream_t* stream; in uv__stream_io()
1192 stream = container_of(w, uv_stream_t, io_watcher); in uv__stream_io()
1246 static void uv__stream_connect(uv_stream_t* stream) { in uv__stream_connect()
1295 static int uv__check_before_write(uv_stream_t* stream, in uv__check_before_write()
1297 uv_stream_t* send_handle) { in uv__check_before_write()
1334 uv_stream_t* stream, in uv_write2()
1337 uv_stream_t* send_handle, in uv_write2()
1406 uv_stream_t* handle, in uv_write()
1414 int uv_try_write(uv_stream_t* stream, in uv_try_write()
1421 int uv_try_write2(uv_stream_t* stream, in uv_try_write2()
1424 uv_stream_t* send_handle) { in uv_try_write2()
1439 int uv__read_start(uv_stream_t* stream, in uv__read_start()
1465 int uv_read_stop(uv_stream_t* stream) { in uv_read_stop()
1480 int uv_is_readable(const uv_stream_t* stream) { in uv_is_readable()
1485 int uv_is_writable(const uv_stream_t* stream) { in uv_is_writable()
1491 int uv___stream_fd(const uv_stream_t* handle) { in uv___stream_fd()
1507 void uv__stream_close(uv_stream_t* handle) { in uv__stream_close()
1562 int uv_stream_set_blocking(uv_stream_t* handle, int blocking) { in uv_stream_set_blocking()
