| /libuv/src/unix/ |
| H A D | stream.c | 47 uv_stream_t* stream; member
83 uv_stream_t* stream, in uv__stream_init()
147 uv_stream_t* stream; in uv__stream_osx_select() local
236 uv_stream_t* stream; in uv__stream_osx_select_cb() local
509 uv_stream_t* stream; in uv__server_io() local
715 uv_stream_t* stream = req->handle; in uv__write_req_finish() local
1190 uv_stream_t* stream; in uv__stream_io() local
1334 uv_stream_t* stream, in uv_write2()
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()
[all …]
|
| /libuv/test/ |
| H A D | test-tcp-read-stop-start.c | 48 static void do_write(uv_stream_t* stream, uv_write_cb cb) { in do_write()
64 static void on_read1(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in on_read1()
79 static void on_read2(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in on_read2()
|
| H A D | test-iouring-pollhup.c | 49 static void read_data2(uv_stream_t* stream, in read_data2()
78 static void read_data(uv_stream_t* stream, in read_data()
|
| H A D | blackhole-server.c | 42 static void connection_cb(uv_stream_t* stream, int status) { in connection_cb()
72 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb()
|
| H A D | test-ping-pong.c | 49 } stream; member
93 uv_stream_t* stream; in pinger_write_ping() local
121 static void pinger_read_cb(uv_stream_t* stream, in pinger_read_cb()
163 static void ponger_read_cb(uv_stream_t* stream, in ponger_read_cb()
|
| H A D | test-tcp-close-after-read-timeout.c | 67 static void on_client_read(uv_stream_t* stream, ssize_t nread, in on_client_read()
92 static void on_connection_read(uv_stream_t* stream, in on_connection_read()
|
| H A D | benchmark-pound.c | 48 uv_stream_t stream; member
56 uv_tcp_t stream; member
64 uv_pipe_t stream; member
138 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb()
|
| H A D | test-pipe-close-stdout-read-stdin.c | 44 void read_stdin(uv_stream_t *stream, ssize_t nread, const uv_buf_t* buf) in read_stdin()
|
| H A D | runner.c | 386 void print_tests(FILE* stream) { in print_tests()
415 void print_lines(const char* buffer, size_t size, FILE* stream) { in print_lines()
|
| H A D | test-tcp-write-fail.c | 73 uv_stream_t* stream; in connect_cb() local
|
| H A D | benchmark-pump.c | 171 static void read_cb(uv_stream_t* stream, ssize_t bytes, const uv_buf_t* buf) { in read_cb()
202 static void do_write(uv_stream_t* stream) { in do_write()
278 uv_stream_t* stream; in connection_cb() local
|
| H A D | test-osx-select.c | 40 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb()
|
| H A D | test-tcp-close-reset.c | 105 static void read_cb2(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb2()
148 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb()
|
| H A D | test-tcp-write-to-half-open-connection.c | 77 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb()
|
| H A D | test-tcp-open.c | 187 uv_stream_t* stream; in connect_cb() local
211 uv_stream_t* stream; in connect1_cb() local
|
| H A D | test-tcp-alloc-cb-fail.c | 52 static void conn_read_cb(uv_stream_t* stream, in conn_read_cb()
|
| H A D | test-tcp-close-accept.c | 87 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb()
|
| H A D | test-tcp-writealot.c | 115 uv_stream_t* stream; in connect_cb() local
|
| H A D | runner-win.c | 220 int process_copy_output(process_info_t* p, FILE* stream) { in process_copy_output()
|
| /libuv/docs/src/ |
| H A D | stream.rst | 2 .. _stream: target
|
| /libuv/src/win/ |
| H A D | stream.c | 30 int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb) { in uv_listen()
171 int uv_try_write(uv_stream_t* stream, in uv_try_write()
193 int uv_try_write2(uv_stream_t* stream, in uv_try_write2()
|
| H A D | process-stdio.c | 310 uv_stream_t* stream = fdopt.data.stream; in uv__stdio_create() local
|
| /libuv/docs/code/uvtee/ |
| H A D | main.c | 43 void read_stdin(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) { in read_stdin()
|
| /libuv/src/ |
| H A D | uv-data-getter-setters.c | 77 size_t uv_stream_get_write_queue_size(const uv_stream_t* stream) { in uv_stream_get_write_queue_size()
|
| H A D | uv-common.c | 554 static void uv__print_handles(uv_loop_t* loop, int only_active, FILE* stream) { in uv__print_handles()
589 void uv_print_all_handles(uv_loop_t* loop, FILE* stream) { in uv_print_all_handles()
594 void uv_print_active_handles(uv_loop_t* loop, FILE* stream) { in uv_print_active_handles()
895 int uv_read_start(uv_stream_t* stream, in uv_read_start()
|
