• Home
  • Raw
  • Download

Lines Matching refs:uv_stream_t

47   uv_stream_t* stream;
63 static void uv__stream_connect(uv_stream_t*);
64 static void uv__write(uv_stream_t* stream);
65 static void uv__read(uv_stream_t* stream);
67 static void uv__write_callbacks(uv_stream_t* stream);
69 static void uv__drain(uv_stream_t* stream);
73 uv_stream_t* stream, in uv__stream_init()
110 static void uv__stream_osx_interrupt_select(uv_stream_t* stream) { in uv__stream_osx_interrupt_select()
137 uv_stream_t* stream; in uv__stream_osx_select()
226 uv_stream_t* stream; in uv__stream_osx_select_cb()
264 int uv__stream_try_select(uv_stream_t* stream, int* fd) { in uv__stream_try_select()
393 int uv__stream_open(uv_stream_t* stream, int fd, int flags) { in uv__stream_open()
430 void uv__stream_flush_write_queue(uv_stream_t* stream, int error) { in uv__stream_flush_write_queue()
445 void uv__stream_destroy(uv_stream_t* stream) { in uv__stream_destroy()
506 uv_stream_t* stream; in uv__server_io()
509 stream = container_of(w, uv_stream_t, io_watcher); in uv__server_io()
568 int uv_accept(uv_stream_t* server, uv_stream_t* client) { in uv_accept()
633 int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb) { in uv_listen()
658 static void uv__drain(uv_stream_t* stream) { in uv__drain()
721 static int uv__write_req_update(uv_stream_t* stream, in uv__write_req_update()
747 uv_stream_t* stream = req->handle; in uv__write_req_finish()
776 return ((uv_stream_t*) handle)->io_watcher.fd; in uv__handle_fd()
786 static int uv__try_write(uv_stream_t* stream, in uv__try_write()
789 uv_stream_t* send_handle) { in uv__try_write()
883 static void uv__write(uv_stream_t* stream) { in uv__write()
933 static void uv__write_callbacks(uv_stream_t* stream) { in uv__write_callbacks()
964 static void uv__stream_eof(uv_stream_t* stream, const uv_buf_t* buf) { in uv__stream_eof()
974 static int uv__stream_queue_fd(uv_stream_t* stream, int fd) { in uv__stream_queue_fd()
1022 static int uv__stream_recv_cmsg(uv_stream_t* stream, struct msghdr* msg) { in uv__stream_recv_cmsg()
1078 static void uv__read(uv_stream_t* stream) { in uv__read()
1221 int uv_shutdown(uv_shutdown_t* req, uv_stream_t* stream, uv_shutdown_cb cb) { in uv_shutdown()
1252 uv_stream_t* stream; in uv__stream_io()
1254 stream = container_of(w, uv_stream_t, io_watcher); in uv__stream_io()
1308 static void uv__stream_connect(uv_stream_t* stream) { in uv__stream_connect()
1357 static int uv__check_before_write(uv_stream_t* stream, in uv__check_before_write()
1359 uv_stream_t* send_handle) { in uv__check_before_write()
1396 uv_stream_t* stream, in uv_write2()
1399 uv_stream_t* send_handle, in uv_write2()
1468 uv_stream_t* handle, in uv_write()
1476 int uv_try_write(uv_stream_t* stream, in uv_try_write()
1483 int uv_try_write2(uv_stream_t* stream, in uv_try_write2()
1486 uv_stream_t* send_handle) { in uv_try_write2()
1501 int uv__read_start(uv_stream_t* stream, in uv__read_start()
1527 int uv_read_stop(uv_stream_t* stream) { in uv_read_stop()
1542 int uv_is_readable(const uv_stream_t* stream) { in uv_is_readable()
1547 int uv_is_writable(const uv_stream_t* stream) { in uv_is_writable()
1553 int uv___stream_fd(const uv_stream_t* handle) { in uv___stream_fd()
1569 void uv__stream_close(uv_stream_t* handle) { in uv__stream_close()
1624 int uv_stream_set_blocking(uv_stream_t* handle, int blocking) { in uv_stream_set_blocking()