uv_stream_t 195 include/uv.h typedef struct uv_stream_s uv_stream_t; uv_stream_t 365 include/uv.h typedef void (*uv_read_cb)(uv_stream_t* stream, ssize_t nread, uv_buf_t buf); uv_stream_t 378 include/uv.h typedef void (*uv_connection_cb)(uv_stream_t* server, int status); uv_stream_t 479 include/uv.h UV_EXTERN int uv_shutdown(uv_shutdown_t* req, uv_stream_t* handle, uv_stream_t 484 include/uv.h uv_stream_t* handle; uv_stream_t 590 include/uv.h UV_EXTERN int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb); uv_stream_t 603 include/uv.h UV_EXTERN int uv_accept(uv_stream_t* server, uv_stream_t* client); uv_stream_t 617 include/uv.h UV_EXTERN int uv_read_start(uv_stream_t*, uv_alloc_cb alloc_cb, uv_stream_t 620 include/uv.h UV_EXTERN int uv_read_stop(uv_stream_t*); uv_stream_t 626 include/uv.h UV_EXTERN int uv_read2_start(uv_stream_t*, uv_alloc_cb alloc_cb, uv_stream_t 651 include/uv.h UV_EXTERN int uv_write(uv_write_t* req, uv_stream_t* handle, uv_stream_t 661 include/uv.h UV_EXTERN int uv_write2(uv_write_t* req, uv_stream_t* handle, uv_buf_t bufs[], uv_stream_t 662 include/uv.h int bufcnt, uv_stream_t* send_handle, uv_write_cb cb); uv_stream_t 668 include/uv.h uv_stream_t* send_handle; uv_stream_t 669 include/uv.h uv_stream_t* handle; uv_stream_t 677 include/uv.h UV_EXTERN int uv_is_readable(const uv_stream_t* handle); uv_stream_t 678 include/uv.h UV_EXTERN int uv_is_writable(const uv_stream_t* handle); uv_stream_t 703 include/uv.h UV_EXTERN int uv_stream_set_blocking(uv_stream_t* handle, int blocking); uv_stream_t 778 include/uv.h uv_stream_t* handle; uv_stream_t 1367 include/uv.h uv_stream_t* stream; uv_stream_t 95 src/unix/core.c uv__stream_close((uv_stream_t*)handle); uv_stream_t 191 src/unix/core.c uv__stream_destroy((uv_stream_t*)handle); uv_stream_t 160 src/unix/internal.h void uv__stream_init(uv_loop_t* loop, uv_stream_t* stream, uv_stream_t 162 src/unix/internal.h int uv__stream_open(uv_stream_t*, int fd, int flags); uv_stream_t 163 src/unix/internal.h void uv__stream_destroy(uv_stream_t* stream); uv_stream_t 165 src/unix/internal.h int uv__stream_try_select(uv_stream_t* stream, int* fd); uv_stream_t 209 src/unix/internal.h void uv__stream_close(uv_stream_t* handle); uv_stream_t 216 src/unix/internal.h int uv___stream_fd(uv_stream_t* handle); uv_stream_t 217 src/unix/internal.h #define uv__stream_fd(handle) (uv___stream_fd((uv_stream_t*) (handle))) uv_stream_t 36 src/unix/pipe.c uv__stream_init(loop, (uv_stream_t*)handle, UV_NAMED_PIPE); uv_stream_t 133 src/unix/pipe.c uv__stream_close((uv_stream_t*)handle); uv_stream_t 141 src/unix/pipe.c err = uv__stream_try_select((uv_stream_t*) handle, &fd); uv_stream_t 146 src/unix/pipe.c return uv__stream_open((uv_stream_t*)handle, uv_stream_t 188 src/unix/pipe.c err = uv__stream_open((uv_stream_t*)handle, uv_stream_t 201 src/unix/pipe.c req->handle = (uv_stream_t*)handle; uv_stream_t 226 src/unix/pipe.c pipe->connection_cb((uv_stream_t*)pipe, -errno); uv_stream_t 231 src/unix/pipe.c pipe->connection_cb((uv_stream_t*)pipe, 0); uv_stream_t 255 src/unix/process.c uv__stream_close((uv_stream_t*)container->data.stream); uv_stream_t 47 src/unix/stream.c uv_stream_t* stream; uv_stream_t 59 src/unix/stream.c static void uv__stream_connect(uv_stream_t*); uv_stream_t 60 src/unix/stream.c static void uv__write(uv_stream_t* stream); uv_stream_t 61 src/unix/stream.c static void uv__read(uv_stream_t* stream); uv_stream_t 109 src/unix/stream.c uv_stream_t* stream, uv_stream_t 143 src/unix/stream.c uv_stream_t* stream; uv_stream_t 232 src/unix/stream.c static void uv__stream_osx_interrupt_select(uv_stream_t* stream) { uv_stream_t 253 src/unix/stream.c uv_stream_t* stream; uv_stream_t 284 src/unix/stream.c int uv__stream_try_select(uv_stream_t* stream, int* fd) { uv_stream_t 375 src/unix/stream.c int uv__stream_open(uv_stream_t* stream, int fd, int flags) { uv_stream_t 394 src/unix/stream.c void uv__stream_destroy(uv_stream_t* stream) { uv_stream_t 497 src/unix/stream.c uv_stream_t* stream; uv_stream_t 500 src/unix/stream.c stream = container_of(w, uv_stream_t, io_watcher); uv_stream_t 558 src/unix/stream.c int uv_accept(uv_stream_t* server, uv_stream_t* client) { uv_stream_t 600 src/unix/stream.c int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb) { uv_stream_t 624 src/unix/stream.c static void uv__drain(uv_stream_t* stream) { uv_stream_t 668 src/unix/stream.c uv_stream_t* stream = req->handle; uv_stream_t 697 src/unix/stream.c return ((uv_stream_t*) handle)->io_watcher.fd; uv_stream_t 720 src/unix/stream.c static void uv__write(uv_stream_t* stream) { uv_stream_t 874 src/unix/stream.c static void uv__write_callbacks(uv_stream_t* stream) { uv_stream_t 939 src/unix/stream.c static void uv__stream_read_cb(uv_stream_t* stream, uv_stream_t 950 src/unix/stream.c static void uv__stream_eof(uv_stream_t* stream, uv_buf_t buf) { uv_stream_t 959 src/unix/stream.c static void uv__read(uv_stream_t* stream) { uv_stream_t 1090 src/unix/stream.c int uv_shutdown(uv_shutdown_t* req, uv_stream_t* stream, uv_shutdown_cb cb) { uv_stream_t 1116 src/unix/stream.c uv_stream_t* stream; uv_stream_t 1118 src/unix/stream.c stream = container_of(w, uv_stream_t, io_watcher); uv_stream_t 1168 src/unix/stream.c static void uv__stream_connect(uv_stream_t* stream) { uv_stream_t 1207 src/unix/stream.c uv_stream_t* stream, uv_stream_t 1210 src/unix/stream.c uv_stream_t* send_handle, uv_stream_t 1293 src/unix/stream.c int uv_write(uv_write_t* req, uv_stream_t* stream, uv_buf_t bufs[], int bufcnt, uv_stream_t 1299 src/unix/stream.c static int uv__read_start_common(uv_stream_t* stream, uv_stream_t 1338 src/unix/stream.c int uv_read_start(uv_stream_t* stream, uv_alloc_cb alloc_cb, uv_stream_t 1344 src/unix/stream.c int uv_read2_start(uv_stream_t* stream, uv_alloc_cb alloc_cb, uv_stream_t 1350 src/unix/stream.c int uv_read_stop(uv_stream_t* stream) { uv_stream_t 1379 src/unix/stream.c int uv_is_readable(const uv_stream_t* stream) { uv_stream_t 1384 src/unix/stream.c int uv_is_writable(const uv_stream_t* stream) { uv_stream_t 1390 src/unix/stream.c int uv___stream_fd(uv_stream_t* handle) { uv_stream_t 1406 src/unix/stream.c void uv__stream_close(uv_stream_t* handle) { uv_stream_t 1444 src/unix/stream.c int uv_stream_set_blocking(uv_stream_t* handle, int blocking) { uv_stream_t 32 src/unix/tcp.c uv__stream_init(loop, (uv_stream_t*)tcp, UV_TCP); uv_stream_t 49 src/unix/tcp.c err = uv__stream_open((uv_stream_t*) handle, sockfd, flags); uv_stream_t 123 src/unix/tcp.c req->handle = (uv_stream_t*) handle; uv_stream_t 153 src/unix/tcp.c return uv__stream_open((uv_stream_t*)handle, uv_stream_t 328 src/unix/tcp.c uv__stream_close((uv_stream_t*)handle); uv_stream_t 37 src/unix/tty.c uv__stream_init(loop, (uv_stream_t*)tty, UV_TTY); uv_stream_t 41 src/unix/tty.c int err = uv__stream_try_select((uv_stream_t*) tty, &fd); uv_stream_t 49 src/unix/tty.c uv__stream_open((uv_stream_t*)tty, fd, UV_STREAM_READABLE); uv_stream_t 52 src/unix/tty.c uv__stream_open((uv_stream_t*)tty, fd, UV_STREAM_WRITABLE); uv_stream_t 147 src/win/internal.h int uv_pipe_accept(uv_pipe_t* server, uv_stream_t* client); uv_stream_t 155 src/win/internal.h uv_buf_t bufs[], int bufcnt, uv_stream_t* send_handle, uv_write_cb cb); uv_stream_t 78 src/win/pipe.c uv_stream_init(loop, (uv_stream_t*)handle, UV_NAMED_PIPE); uv_stream_t 97 src/win/pipe.c uv_connection_init((uv_stream_t*) handle); uv_stream_t 534 src/win/pipe.c req->handle = (uv_stream_t*) handle; uv_stream_t 714 src/win/pipe.c int uv_pipe_accept(uv_pipe_t* server, uv_stream_t* client) { uv_stream_t 1035 src/win/pipe.c uv_stream_t* send_handle, uv_write_cb cb) { uv_stream_t 1057 src/win/pipe.c req->handle = (uv_stream_t*) handle; uv_stream_t 1112 src/win/pipe.c ipc_header_req->handle = (uv_stream_t*) handle; uv_stream_t 1280 src/win/pipe.c uv_buf_t bufs[], int bufcnt, uv_stream_t* send_handle, uv_write_cb cb) { uv_stream_t 1296 src/win/pipe.c uv_read_stop((uv_stream_t*) handle); uv_stream_t 1301 src/win/pipe.c handle->read_cb((uv_stream_t*) handle, UV_EOF, uv_null_buf_); uv_stream_t 1312 src/win/pipe.c uv_read_stop((uv_stream_t*) handle); uv_stream_t 1320 src/win/pipe.c handle->read_cb((uv_stream_t*)handle, uv_translate_sys_error(error), buf); uv_stream_t 1437 src/win/pipe.c handle->read_cb((uv_stream_t*) handle, UV_ENOBUFS, buf); uv_stream_t 1457 src/win/pipe.c handle->read_cb((uv_stream_t*)handle, bytes, buf); uv_stream_t 1465 src/win/pipe.c handle->read_cb((uv_stream_t*)handle, bytes, buf); uv_stream_t 1553 src/win/pipe.c handle->connection_cb((uv_stream_t*)handle, 0); uv_stream_t 1679 src/win/pipe.c uv_read_stop((uv_stream_t*) pipe); uv_stream_t 393 src/win/process-stdio.c uv_stream_t* stream = fdopt.data.stream; uv_stream_t 34 src/win/stream-inl.h uv_stream_t* handle, uv_stream_t 42 src/win/stream-inl.h INLINE static void uv_connection_init(uv_stream_t* handle) { uv_stream_t 30 src/win/stream.c int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb) { uv_stream_t 49 src/win/stream.c int uv_accept(uv_stream_t* server, uv_stream_t* client) { uv_stream_t 68 src/win/stream.c int uv_read_start(uv_stream_t* handle, uv_alloc_cb alloc_cb, uv_stream_t 99 src/win/stream.c int uv_read2_start(uv_stream_t* handle, uv_alloc_cb alloc_cb, uv_stream_t 124 src/win/stream.c int uv_read_stop(uv_stream_t* handle) { uv_stream_t 142 src/win/stream.c int uv_write(uv_write_t* req, uv_stream_t* handle, uv_buf_t bufs[], int bufcnt, uv_stream_t 170 src/win/stream.c int uv_write2(uv_write_t* req, uv_stream_t* handle, uv_buf_t bufs[], int bufcnt, uv_stream_t 171 src/win/stream.c uv_stream_t* send_handle, uv_write_cb cb) { uv_stream_t 192 src/win/stream.c int uv_shutdown(uv_shutdown_t* req, uv_stream_t* handle, uv_shutdown_cb cb) { uv_stream_t 219 src/win/stream.c int uv_is_readable(const uv_stream_t* handle) { uv_stream_t 224 src/win/stream.c int uv_is_writable(const uv_stream_t* handle) { uv_stream_t 229 src/win/stream.c int uv_stream_set_blocking(uv_stream_t* handle, int blocking) { uv_stream_t 150 src/win/tcp.c uv_stream_init(loop, (uv_stream_t*) handle, UV_TCP); uv_stream_t 439 src/win/tcp.c handle->read_cb((uv_stream_t*) handle, UV_ENOBUFS, handle->read_buffer); uv_stream_t 611 src/win/tcp.c uv_connection_init((uv_stream_t*) client); uv_stream_t 704 src/win/tcp.c req->handle = (uv_stream_t*) handle; uv_stream_t 761 src/win/tcp.c req->handle = (uv_stream_t*) handle; uv_stream_t 837 src/win/tcp.c req->handle = (uv_stream_t*) handle; uv_stream_t 917 src/win/tcp.c handle->read_cb((uv_stream_t*)handle, uv_stream_t 926 src/win/tcp.c handle->read_cb((uv_stream_t*)handle, uv_stream_t 943 src/win/tcp.c handle->read_cb((uv_stream_t*)handle, UV_EOF, handle->read_buffer); uv_stream_t 967 src/win/tcp.c handle->read_cb((uv_stream_t*)handle, bytes, buf); uv_stream_t 977 src/win/tcp.c handle->read_cb((uv_stream_t*)handle, UV_EOF, buf); uv_stream_t 984 src/win/tcp.c handle->read_cb((uv_stream_t*)handle, 0, buf); uv_stream_t 996 src/win/tcp.c handle->read_cb((uv_stream_t*)handle, uv_stream_t 1068 src/win/tcp.c handle->connection_cb((uv_stream_t*)handle, uv_stream_t 1083 src/win/tcp.c handle->connection_cb((uv_stream_t*)handle, 0); uv_stream_t 1115 src/win/tcp.c uv_connection_init((uv_stream_t*)handle); uv_stream_t 1162 src/win/tcp.c uv_connection_init((uv_stream_t*)tcp); uv_stream_t 128 src/win/tty.c uv_stream_init(loop, (uv_stream_t*) tty, UV_TTY); uv_stream_t 129 src/win/tty.c uv_connection_init((uv_stream_t*) tty); uv_stream_t 487 src/win/tty.c handle->read_cb((uv_stream_t*)handle, uv_stream_t 498 src/win/tty.c handle->read_cb((uv_stream_t*)handle, uv_stream_t 519 src/win/tty.c handle->read_cb((uv_stream_t*) handle, uv_stream_t 639 src/win/tty.c handle->read_cb((uv_stream_t*) handle, uv_stream_t 689 src/win/tty.c handle->read_cb((uv_stream_t*) handle, UV_ENOBUFS, buf); uv_stream_t 699 src/win/tty.c handle->read_cb((uv_stream_t*) handle, buf_used, buf); uv_stream_t 720 src/win/tty.c handle->read_cb((uv_stream_t*) handle, buf_used, buf); uv_stream_t 756 src/win/tty.c handle->read_cb((uv_stream_t*) handle, uv_stream_t 761 src/win/tty.c handle->read_cb((uv_stream_t*) handle, 0, buf); uv_stream_t 768 src/win/tty.c handle->read_cb((uv_stream_t*) handle, bytes, buf); uv_stream_t 1752 src/win/tty.c req->handle = (uv_stream_t*) handle; uv_stream_t 61 test/benchmark-multi-accept.c uv_stream_t* server_handle; uv_stream_t 82 test/benchmark-multi-accept.c static void ipc_connection_cb(uv_stream_t* ipc_pipe, int status); uv_stream_t 93 test/benchmark-multi-accept.c static void sv_connection_cb(uv_stream_t* server_handle, int status); uv_stream_t 94 test/benchmark-multi-accept.c static void sv_read_cb(uv_stream_t* handle, ssize_t nread, uv_buf_t buf); uv_stream_t 104 test/benchmark-multi-accept.c static void ipc_connection_cb(uv_stream_t* ipc_pipe, int status) { uv_stream_t 123 test/benchmark-multi-accept.c ASSERT(0 == uv_accept(ipc_pipe, (uv_stream_t*) &pc->peer_handle)); uv_stream_t 125 test/benchmark-multi-accept.c (uv_stream_t*) &pc->peer_handle, uv_stream_t 128 test/benchmark-multi-accept.c (uv_stream_t*) &sc->server_handle, uv_stream_t 154 test/benchmark-multi-accept.c ASSERT(0 == uv_read2_start((uv_stream_t*) &ctx->ipc_pipe, uv_stream_t 184 test/benchmark-multi-accept.c ASSERT(0 == uv_accept((uv_stream_t*) &ctx->ipc_pipe, ctx->server_handle)); uv_stream_t 212 test/benchmark-multi-accept.c ASSERT(0 == uv_listen((uv_stream_t*) &ctx.ipc_pipe, 128, ipc_connection_cb)); uv_stream_t 226 test/benchmark-multi-accept.c static void get_listen_handle(uv_loop_t* loop, uv_stream_t* server_handle) { uv_stream_t 254 test/benchmark-multi-accept.c get_listen_handle(loop, (uv_stream_t*) &ctx->server_handle); uv_stream_t 258 test/benchmark-multi-accept.c ASSERT(0 == uv_listen((uv_stream_t*) &ctx->server_handle, uv_stream_t 275 test/benchmark-multi-accept.c static void sv_connection_cb(uv_stream_t* server_handle, int status) { uv_stream_t 292 test/benchmark-multi-accept.c ASSERT(0 == uv_accept(server_handle, (uv_stream_t*) storage)); uv_stream_t 293 test/benchmark-multi-accept.c ASSERT(0 == uv_read_start((uv_stream_t*) storage, sv_alloc_cb, sv_read_cb)); uv_stream_t 304 test/benchmark-multi-accept.c static void sv_read_cb(uv_stream_t* handle, ssize_t nread, uv_buf_t buf) { uv_stream_t 108 test/benchmark-ping-pongs.c if (uv_write(req, (uv_stream_t*) &pinger->tcp, &buf, 1, pinger_write_cb)) { uv_stream_t 126 test/benchmark-ping-pongs.c static void pinger_read_cb(uv_stream_t* tcp, ssize_t nread, uv_buf_t buf) { uv_stream_t 152 test/benchmark-ping-pongs.c uv_shutdown(&pinger->shutdown_req, (uv_stream_t*) tcp, pinger_shutdown_cb); uv_stream_t 48 test/benchmark-pound.c uv_stream_t stream; uv_stream_t 80 test/benchmark-pound.c static void read_cb(uv_stream_t* stream, ssize_t nread, uv_buf_t buf); uv_stream_t 138 test/benchmark-pound.c static void read_cb(uv_stream_t* stream, ssize_t nread, uv_buf_t buf) { uv_stream_t 38 test/benchmark-pump.c static void do_write(uv_stream_t*); uv_stream_t 51 test/benchmark-pump.c static uv_stream_t* server; uv_stream_t 161 test/benchmark-pump.c static void read_cb(uv_stream_t* stream, ssize_t bytes, uv_buf_t buf) { uv_stream_t 188 test/benchmark-pump.c do_write((uv_stream_t*) req->handle); uv_stream_t 192 test/benchmark-pump.c static void do_write(uv_stream_t* stream) { uv_stream_t 222 test/benchmark-pump.c do_write(type == TCP ? (uv_stream_t*)&tcp_write_handles[i] : (uv_stream_t*)&pipe_write_handles[i]); uv_stream_t 258 test/benchmark-pump.c static void connection_cb(uv_stream_t* s, int status) { uv_stream_t 259 test/benchmark-pump.c uv_stream_t* stream; uv_stream_t 266 test/benchmark-pump.c stream = (uv_stream_t*)malloc(sizeof(uv_tcp_t)); uv_stream_t 270 test/benchmark-pump.c stream = (uv_stream_t*)malloc(sizeof(uv_pipe_t)); uv_stream_t 368 test/benchmark-pump.c server = (uv_stream_t*)&tcpServer; uv_stream_t 373 test/benchmark-pump.c r = uv_listen((uv_stream_t*)&tcpServer, MAX_WRITE_HANDLES, connection_cb); uv_stream_t 389 test/benchmark-pump.c server = (uv_stream_t*)&pipeServer; uv_stream_t 394 test/benchmark-pump.c r = uv_listen((uv_stream_t*)&pipeServer, MAX_WRITE_HANDLES, connection_cb); uv_stream_t 91 test/benchmark-spawn.c static void on_read(uv_stream_t* pipe, ssize_t nread, uv_buf_t buf) { uv_stream_t 123 test/benchmark-spawn.c options.stdio[1].data.stream = (uv_stream_t*)&out; uv_stream_t 132 test/benchmark-spawn.c r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); uv_stream_t 58 test/benchmark-tcp-write-batch.c ASSERT(req->handle == (uv_stream_t*)&tcp_client); uv_stream_t 81 test/benchmark-tcp-write-batch.c ASSERT(req->handle == (uv_stream_t*)&tcp_client); uv_stream_t 35 test/blackhole-server.c static void connection_cb(uv_stream_t* stream, int status); uv_stream_t 37 test/blackhole-server.c static void read_cb(uv_stream_t* stream, ssize_t nread, uv_buf_t buf); uv_stream_t 42 test/blackhole-server.c static void connection_cb(uv_stream_t* stream, int status) { uv_stream_t 47 test/blackhole-server.c ASSERT(stream == (uv_stream_t*)&tcp_server); uv_stream_t 55 test/blackhole-server.c r = uv_accept(stream, (uv_stream_t*)&conn->handle); uv_stream_t 58 test/blackhole-server.c r = uv_read_start((uv_stream_t*)&conn->handle, alloc_cb, read_cb); uv_stream_t 69 test/blackhole-server.c static void read_cb(uv_stream_t* stream, ssize_t nread, uv_buf_t buf) { uv_stream_t 111 test/blackhole-server.c r = uv_listen((uv_stream_t*)&tcp_server, 128, connection_cb); uv_stream_t 57 test/dns-server.c static void after_read(uv_stream_t*, ssize_t nread, uv_buf_t buf); uv_stream_t 59 test/dns-server.c static void on_connection(uv_stream_t*, int status); uv_stream_t 127 test/dns-server.c static void process_req(uv_stream_t* handle, ssize_t nread, uv_buf_t buf) { uv_stream_t 226 test/dns-server.c static void after_read(uv_stream_t* handle, ssize_t nread, uv_buf_t buf) { uv_stream_t 266 test/dns-server.c static void on_connection(uv_stream_t* server, int status) { uv_stream_t 283 test/dns-server.c r = uv_accept(server, (uv_stream_t*)handle); uv_stream_t 286 test/dns-server.c r = uv_read_start((uv_stream_t*)handle, buf_alloc, after_read); uv_stream_t 309 test/dns-server.c r = uv_listen((uv_stream_t*)&server, 128, on_connection); uv_stream_t 42 test/echo-server.c static void after_read(uv_stream_t*, ssize_t nread, uv_buf_t buf); uv_stream_t 45 test/echo-server.c static void on_connection(uv_stream_t*, int status); uv_stream_t 75 test/echo-server.c static void after_read(uv_stream_t* handle, ssize_t nread, uv_buf_t buf) { uv_stream_t 138 test/echo-server.c static void on_connection(uv_stream_t* server, int status) { uv_stream_t 139 test/echo-server.c uv_stream_t* stream; uv_stream_t 232 test/echo-server.c r = uv_listen((uv_stream_t*)&tcpServer, SOMAXCONN, on_connection); uv_stream_t 265 test/echo-server.c r = uv_listen((uv_stream_t*)&tcpServer, SOMAXCONN, on_connection); uv_stream_t 324 test/echo-server.c r = uv_listen((uv_stream_t*)&pipeServer, SOMAXCONN, on_connection); uv_stream_t 72 test/test-callback-stack.c static void read_cb(uv_stream_t* tcp, ssize_t nread, uv_buf_t buf) { uv_stream_t 102 test/test-callback-stack.c if (uv_shutdown(&shutdown_req, (uv_stream_t*)tcp, shutdown_cb)) { uv_stream_t 118 test/test-callback-stack.c if (uv_read_start((uv_stream_t*)&client, alloc_cb, read_cb)) { uv_stream_t 165 test/test-callback-stack.c if (uv_write(&write_req, (uv_stream_t*)req->handle, &buf, 1, write_cb)) { uv_stream_t 70 test/test-connection-fail.c ASSERT((uv_stream_t*) &tcp == req->handle); uv_stream_t 63 test/test-delayed-accept.c r = uv_accept((uv_stream_t*)server, (uv_stream_t*)accepted_handle); uv_stream_t 81 test/test-delayed-accept.c static void connection_cb(uv_stream_t* tcp, int status) { uv_stream_t 115 test/test-delayed-accept.c r = uv_listen((uv_stream_t*)server, 128, connection_cb); uv_stream_t 120 test/test-delayed-accept.c static void read_cb(uv_stream_t* tcp, ssize_t nread, uv_buf_t buf) { uv_stream_t 145 test/test-delayed-accept.c r = uv_read_start((uv_stream_t*)(req->handle), alloc_cb, read_cb); uv_stream_t 65 test/test-getsockname.c static void after_read(uv_stream_t* handle, ssize_t nread, uv_buf_t buf) { uv_stream_t 105 test/test-getsockname.c static void on_connection(uv_stream_t* server, int status) { uv_stream_t 125 test/test-getsockname.c r = uv_accept(server, (uv_stream_t*)handle); uv_stream_t 140 test/test-getsockname.c r = uv_read_start((uv_stream_t*)handle, alloc, after_read); uv_stream_t 185 test/test-getsockname.c r = uv_listen((uv_stream_t*)&tcpServer, 128, on_connection); uv_stream_t 35 test/test-ipc-send-recv.c uv_stream_t stream; uv_stream_t 78 test/test-ipc-send-recv.c r = uv_accept((uv_stream_t*)&ctx.channel, &ctx.recv.stream); uv_stream_t 97 test/test-ipc-send-recv.c (uv_stream_t*)&ctx.channel, uv_stream_t 103 test/test-ipc-send-recv.c r = uv_read2_start((uv_stream_t*)&ctx.channel, alloc_cb, recv_cb); uv_stream_t 182 test/test-ipc-send-recv.c r = uv_accept((uv_stream_t*)handle, &ctx.recv.stream); uv_stream_t 186 test/test-ipc-send-recv.c (uv_stream_t*)&ctx.channel, uv_stream_t 206 test/test-ipc-send-recv.c ASSERT(uv_is_readable((uv_stream_t*)&ctx.channel)); uv_stream_t 207 test/test-ipc-send-recv.c ASSERT(uv_is_writable((uv_stream_t*)&ctx.channel)); uv_stream_t 210 test/test-ipc-send-recv.c r = uv_read2_start((uv_stream_t*)&ctx.channel, alloc_cb, read2_cb); uv_stream_t 63 test/test-ipc.c static void on_connection(uv_stream_t* server, int status) { uv_stream_t 70 test/test-ipc.c ASSERT((uv_stream_t*)&tcp_server == server); uv_stream_t 77 test/test-ipc.c r = uv_accept(server, (uv_stream_t*)conn); uv_stream_t 167 test/test-ipc.c r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_server); uv_stream_t 170 test/test-ipc.c r = uv_listen((uv_stream_t*)&tcp_server, 12, on_connection); uv_stream_t 179 test/test-ipc.c r = uv_write(&write_req, (uv_stream_t*)pipe, &outbuf, 1, NULL); uv_stream_t 226 test/test-ipc.c options.stdio[0].data.stream = (uv_stream_t*)channel; uv_stream_t 236 test/test-ipc.c ASSERT(req->handle == (uv_stream_t*)&tcp_connection); uv_stream_t 249 test/test-ipc.c static void on_tcp_read(uv_stream_t* tcp, ssize_t nread, uv_buf_t buf) { uv_stream_t 252 test/test-ipc.c ASSERT(tcp == (uv_stream_t*)&tcp_connection); uv_stream_t 293 test/test-ipc.c r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_connection); uv_stream_t 301 test/test-ipc.c r = uv_write(&write_req, (uv_stream_t*)&tcp_connection, &outbuf, 1, uv_stream_t 305 test/test-ipc.c r = uv_read_start((uv_stream_t*)&tcp_connection, on_read_alloc, on_tcp_read); uv_stream_t 317 test/test-ipc.c uv_read2_start((uv_stream_t*)&channel, on_alloc, read_cb); uv_stream_t 372 test/test-ipc.c r = uv_listen((uv_stream_t*)&server, SOMAXCONN, NULL); uv_stream_t 395 test/test-ipc.c r = uv_listen((uv_stream_t*)&server, SOMAXCONN, NULL); uv_stream_t 430 test/test-ipc.c static void on_tcp_child_process_read(uv_stream_t* tcp, ssize_t nread, uv_buf_t buf) { uv_stream_t 467 test/test-ipc.c static void ipc_on_connection(uv_stream_t* server, int status) { uv_stream_t 477 test/test-ipc.c ASSERT((uv_stream_t*)&tcp_server == server); uv_stream_t 482 test/test-ipc.c r = uv_accept(server, (uv_stream_t*)&conn.conn); uv_stream_t 488 test/test-ipc.c r = uv_write2(&conn_notify_req, (uv_stream_t*)&channel, &buf, 1, uv_stream_t 497 test/test-ipc.c static void ipc_on_connection_tcp_conn(uv_stream_t* server, int status) { uv_stream_t 503 test/test-ipc.c ASSERT((uv_stream_t*)&tcp_server == server); uv_stream_t 511 test/test-ipc.c r = uv_accept(server, (uv_stream_t*)conn); uv_stream_t 516 test/test-ipc.c r = uv_write2(&conn_notify_req, (uv_stream_t*)&channel, &buf, 1, uv_stream_t 517 test/test-ipc.c (uv_stream_t*)conn, NULL); uv_stream_t 520 test/test-ipc.c r = uv_read_start((uv_stream_t*)conn, on_read_alloc, on_tcp_child_process_read); uv_stream_t 542 test/test-ipc.c ASSERT(uv_is_readable((uv_stream_t*) &channel)); uv_stream_t 543 test/test-ipc.c ASSERT(uv_is_writable((uv_stream_t*) &channel)); uv_stream_t 553 test/test-ipc.c r = uv_listen((uv_stream_t*)&tcp_server, 12, ipc_on_connection); uv_stream_t 558 test/test-ipc.c r = uv_write2(&write_req, (uv_stream_t*)&channel, &buf, 1, uv_stream_t 559 test/test-ipc.c (uv_stream_t*)&tcp_server, NULL); uv_stream_t 563 test/test-ipc.c r = uv_listen((uv_stream_t*)&tcp_server, 12, ipc_on_connection); uv_stream_t 592 test/test-ipc.c ASSERT(uv_is_readable((uv_stream_t*)&channel)); uv_stream_t 593 test/test-ipc.c ASSERT(uv_is_writable((uv_stream_t*)&channel)); uv_stream_t 602 test/test-ipc.c r = uv_listen((uv_stream_t*)&tcp_server, 12, ipc_on_connection_tcp_conn); uv_stream_t 40 test/test-multiple-listen.c static void connection_cb(uv_stream_t* tcp, int status) { uv_stream_t 57 test/test-multiple-listen.c r = uv_listen((uv_stream_t*)&server, 128, connection_cb); uv_stream_t 60 test/test-multiple-listen.c r = uv_listen((uv_stream_t*)&server, 128, connection_cb); uv_stream_t 40 test/test-osx-select.c static void read_cb(uv_stream_t* stream, ssize_t nread, uv_buf_t buf) { uv_stream_t 63 test/test-osx-select.c uv_read_start((uv_stream_t*) &tty, alloc_cb, read_cb); uv_stream_t 80 test/test-ping-pong.c if (uv_write(req, (uv_stream_t*)&pinger->stream.tcp, &buf, 1, pinger_after_write)) { uv_stream_t 88 test/test-ping-pong.c static void pinger_read_cb(uv_stream_t* stream, ssize_t nread, uv_buf_t buf) { uv_stream_t 141 test/test-ping-pong.c uv_read_start((uv_stream_t*)(req->handle), alloc_cb, pinger_read_cb); uv_stream_t 58 test/test-pipe-bind-error.c r = uv_listen((uv_stream_t*)&server1, SOMAXCONN, NULL); uv_stream_t 60 test/test-pipe-bind-error.c r = uv_listen((uv_stream_t*)&server2, SOMAXCONN, NULL); uv_stream_t 125 test/test-pipe-bind-error.c r = uv_listen((uv_stream_t*)&server, SOMAXCONN, NULL); uv_stream_t 234 test/test-ref.c uv_listen((uv_stream_t*)&h, 128, (uv_connection_cb)fail_cb); uv_stream_t 246 test/test-ref.c uv_listen((uv_stream_t*)&h, 128, (uv_connection_cb)fail_cb); uv_stream_t 344 test/test-ref.c uv_listen((uv_stream_t*)&h, 128, (uv_connection_cb)fail_cb); uv_stream_t 50 test/test-shutdown-eof.c static void read_cb(uv_stream_t* t, ssize_t nread, uv_buf_t buf) { uv_stream_t 94 test/test-shutdown-eof.c uv_read_start((uv_stream_t*)&tcp, alloc_cb, read_cb); uv_stream_t 100 test/test-shutdown-eof.c uv_write(&write_req, (uv_stream_t*) &tcp, &qbuf, 1, NULL); uv_stream_t 103 test/test-shutdown-eof.c uv_shutdown(&shutdown_req, (uv_stream_t*) &tcp, shutdown_cb); uv_stream_t 129 test/test-spawn.c static void on_read(uv_stream_t* tcp, ssize_t nread, uv_buf_t buf) { uv_stream_t 209 test/test-spawn.c options.stdio[1].data.stream = (uv_stream_t*)&out; uv_stream_t 215 test/test-spawn.c r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); uv_stream_t 299 test/test-spawn.c options.stdio[0].data.stream = (uv_stream_t*)∈ uv_stream_t 301 test/test-spawn.c options.stdio[1].data.stream = (uv_stream_t*)&out; uv_stream_t 309 test/test-spawn.c r = uv_write(&write_req, (uv_stream_t*)&in, &buf, 1, write_cb); uv_stream_t 312 test/test-spawn.c r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); uv_stream_t 340 test/test-spawn.c options.stdio[3].data.stream = (uv_stream_t*)&pipe; uv_stream_t 346 test/test-spawn.c r = uv_read_start((uv_stream_t*) &pipe, on_alloc, on_read); uv_stream_t 420 test/test-spawn.c options.stdio[1].data.stream = (uv_stream_t*) &out; uv_stream_t 432 test/test-spawn.c r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); uv_stream_t 498 test/test-spawn.c options.stdio[0].data.stream = (uv_stream_t*)∈ uv_stream_t 500 test/test-spawn.c options.stdio[1].data.stream = (uv_stream_t*)&out; uv_stream_t 502 test/test-spawn.c options.stdio[2].data.stream = (uv_stream_t*)&err; uv_stream_t 509 test/test-spawn.c r = uv_write(&write, (uv_stream_t*) &in, &buf, 1, write_cb); uv_stream_t 512 test/test-spawn.c r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); uv_stream_t 515 test/test-spawn.c r = uv_read_start((uv_stream_t*) &err, on_alloc, on_read); uv_stream_t 549 test/test-spawn.c options.stdio[0].data.stream = (uv_stream_t*)∈ uv_stream_t 551 test/test-spawn.c options.stdio[1].data.stream = (uv_stream_t*)&out; uv_stream_t 563 test/test-spawn.c r = uv_write(&write_req, (uv_stream_t*)&in, &buf, 1, write_cb); uv_stream_t 566 test/test-spawn.c r = uv_read_start((uv_stream_t*)&out, on_alloc, on_read); uv_stream_t 629 test/test-spawn.c options.stdio[1].data.stream = (uv_stream_t*)&out; uv_stream_t 647 test/test-spawn.c r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); uv_stream_t 95 test/test-stdio-over-pipes.c static void on_read(uv_stream_t* tcp, ssize_t nread, uv_buf_t rdbuf) { uv_stream_t 108 test/test-stdio-over-pipes.c r = uv_write(req, (uv_stream_t*)&in, &wrbuf, 1, after_write); uv_stream_t 131 test/test-stdio-over-pipes.c options.stdio[0].data.stream = (uv_stream_t*)∈ uv_stream_t 133 test/test-stdio-over-pipes.c options.stdio[1].data.stream = (uv_stream_t*)&out; uv_stream_t 139 test/test-stdio-over-pipes.c r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); uv_stream_t 164 test/test-stdio-over-pipes.c static void on_pipe_read(uv_stream_t* tcp, ssize_t nread, uv_buf_t buf) { uv_stream_t 225 test/test-stdio-over-pipes.c r = uv_write(&write_req[i], (uv_stream_t*)&stdout_pipe, &buf[i], 1, uv_stream_t 239 test/test-stdio-over-pipes.c r = uv_read_start((uv_stream_t*)&stdin_pipe, on_read_alloc, uv_stream_t 52 test/test-tcp-bind-error.c r = uv_listen((uv_stream_t*)&server1, 128, NULL); uv_stream_t 54 test/test-tcp-bind-error.c r = uv_listen((uv_stream_t*)&server2, 128, NULL); uv_stream_t 184 test/test-tcp-bind-error.c r = uv_listen((uv_stream_t*)&server, 128, NULL); uv_stream_t 52 test/test-tcp-bind6-error.c r = uv_listen((uv_stream_t*)&server1, 128, NULL); uv_stream_t 54 test/test-tcp-bind6-error.c r = uv_listen((uv_stream_t*)&server2, 128, NULL); uv_stream_t 51 test/test-tcp-close.c r = uv_write(req, (uv_stream_t*)&tcp_handle, &buf, 1, write_cb); uv_stream_t 62 test/test-tcp-close.c ASSERT(req->handle == (uv_stream_t*)&tcp_handle); uv_stream_t 74 test/test-tcp-close.c static void connection_cb(uv_stream_t* server, int status) { uv_stream_t 88 test/test-tcp-close.c r = uv_listen((uv_stream_t*)handle, 128, connection_cb); uv_stream_t 77 test/test-tcp-connect-error-after-write.c r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); uv_stream_t 83 test/test-tcp-connect-error-after-write.c r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); uv_stream_t 96 test/test-tcp-open.c static void read_cb(uv_stream_t* tcp, ssize_t nread, uv_buf_t buf) { uv_stream_t 125 test/test-tcp-open.c uv_stream_t* stream; uv_stream_t 44 test/test-tcp-read-stop.c (uv_stream_t*) &tcp_handle, uv_stream_t 48 test/test-tcp-read-stop.c ASSERT(0 == uv_read_stop((uv_stream_t*) &tcp_handle)); uv_stream_t 55 test/test-tcp-read-stop.c ASSERT(0 == uv_read_start((uv_stream_t*) &tcp_handle, uv_stream_t 65 test/test-tcp-shutdown-after-write.c r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); uv_stream_t 68 test/test-tcp-shutdown-after-write.c r = uv_shutdown(&shutdown_req, (uv_stream_t*)&conn, shutdown_cb); uv_stream_t 73 test/test-tcp-shutdown-after-write.c static void read_cb(uv_stream_t* handle, ssize_t nread, uv_buf_t buf) { uv_stream_t 83 test/test-tcp-shutdown-after-write.c r = uv_read_start((uv_stream_t*)&conn, alloc_cb, read_cb); uv_stream_t 57 test/test-tcp-unexpected-read.c static void read_cb(uv_stream_t* handle, ssize_t nread, uv_buf_t buf) { uv_stream_t 63 test/test-tcp-unexpected-read.c ASSERT(req->handle == (uv_stream_t*) &client_handle); uv_stream_t 69 test/test-tcp-unexpected-read.c ASSERT(req->handle == (uv_stream_t*) &peer_handle); uv_stream_t 74 test/test-tcp-unexpected-read.c static void connection_cb(uv_stream_t* handle, int status) { uv_stream_t 80 test/test-tcp-unexpected-read.c ASSERT(0 == uv_accept(handle, (uv_stream_t*) &peer_handle)); uv_stream_t 81 test/test-tcp-unexpected-read.c ASSERT(0 == uv_read_start((uv_stream_t*) &peer_handle, alloc_cb, read_cb)); uv_stream_t 82 test/test-tcp-unexpected-read.c ASSERT(0 == uv_write(&write_req, (uv_stream_t*) &peer_handle, uv_stream_t 102 test/test-tcp-unexpected-read.c ASSERT(0 == uv_listen((uv_stream_t*) &server_handle, 1, connection_cb)); uv_stream_t 29 test/test-tcp-write-to-half-open-connection.c static void connection_cb(uv_stream_t* server, int status); uv_stream_t 32 test/test-tcp-write-to-half-open-connection.c static void read_cb(uv_stream_t* stream, ssize_t nread, uv_buf_t buf); uv_stream_t 44 test/test-tcp-write-to-half-open-connection.c static void connection_cb(uv_stream_t* server, int status) { uv_stream_t 48 test/test-tcp-write-to-half-open-connection.c ASSERT(server == (uv_stream_t*)&tcp_server); uv_stream_t 54 test/test-tcp-write-to-half-open-connection.c r = uv_accept(server, (uv_stream_t*)&tcp_peer); uv_stream_t 57 test/test-tcp-write-to-half-open-connection.c r = uv_read_start((uv_stream_t*)&tcp_peer, alloc_cb, read_cb); uv_stream_t 63 test/test-tcp-write-to-half-open-connection.c r = uv_write(&write_req, (uv_stream_t*)&tcp_peer, &buf, 1, write_cb); uv_stream_t 74 test/test-tcp-write-to-half-open-connection.c static void read_cb(uv_stream_t* stream, ssize_t nread, uv_buf_t buf) { uv_stream_t 115 test/test-tcp-write-to-half-open-connection.c r = uv_listen((uv_stream_t*)&tcp_server, 1, connection_cb); uv_stream_t 79 test/test-tcp-writealot.c static void read_cb(uv_stream_t* tcp, ssize_t nread, uv_buf_t buf) { uv_stream_t 110 test/test-tcp-writealot.c uv_stream_t* stream;