/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() argument 78 return stream->write_queue_size; in uv_stream_get_write_queue_size()
|
H A D | uv-common.h | 147 int uv__read_start(uv_stream_t* stream, 272 (h->stream.conn.shutdown_req != NULL)
|
/libuv/test/ |
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() argument 45 uv_close((uv_handle_t*) stream, NULL); in read_cb()
|
H A D | test-tcp-write-to-half-open-connection.c | 32 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf); 77 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
|
H A D | test-spawn.c | 294 options.stdio[1].data.stream = (uv_stream_t*) &out; in TEST_IMPL() 598 options.stdio[0].data.stream = (uv_stream_t*) ∈ in TEST_IMPL() 600 options.stdio[1].data.stream = (uv_stream_t*) &out; in TEST_IMPL() 797 options.stdio[1].data.stream = (uv_stream_t*) &out; in TEST_IMPL() 877 options.stdio[0].data.stream = (uv_stream_t*) ∈ in TEST_IMPL() 879 options.stdio[1].data.stream = (uv_stream_t*) &out; in TEST_IMPL() 881 options.stdio[2].data.stream = (uv_stream_t*) &err; in TEST_IMPL() 928 options.stdio[0].data.stream = (uv_stream_t*) ∈ in TEST_IMPL() 975 options.stdio[0].data.stream = (uv_stream_t*) ∈ in TEST_IMPL() 1020 options.stdio[0].data.stream = (uv_stream_t*) ∈ in TEST_IMPL() [all …]
|
H A D | runner-win.c | 220 int process_copy_output(process_info_t* p, FILE* stream) { in process_copy_output() argument 233 print_lines(buf, r, stream); in process_copy_output()
|
H A D | test-stdio-over-pipes.c | 134 options.stdio[0].data.stream = (uv_stream_t*) ∈ in test_stdio_over_pipes() 137 options.stdio[1].data.stream = (uv_stream_t*) &out; in test_stdio_over_pipes()
|
H A D | runner-unix.c | 368 int process_copy_output(process_info_t* p, FILE* stream) { in process_copy_output() argument 380 print_lines(buf, r, stream); in process_copy_output()
|
H A D | test-tcp-alloc-cb-fail.c | 52 static void conn_read_cb(uv_stream_t* stream, in conn_read_cb() argument
|
H A D | benchmark-spawn.c | 123 options.stdio[1].data.stream = (uv_stream_t*)&out; in spawn()
|
/libuv/docs/src/ |
H A D | api.rst | 22 stream
|
H A D | tty.rst | 7 TTY handles represent a stream for the console. 69 Initialize a new TTY stream with the given file descriptor. Usually the 94 .. versionchanged:: 1.5.0: trying to initialize a TTY stream with a file
|
/libuv/src/win/ |
H A D | tty.c | 2185 handle->stream.conn.write_reqs_pending++; 2207 if (handle->stream.conn.write_reqs_pending > 0) 2230 handle->stream.conn.write_reqs_pending--; 2231 if (handle->stream.conn.write_reqs_pending == 0 && 2235 handle->stream.conn.shutdown_req); 2261 void uv__process_tty_shutdown_req(uv_loop_t* loop, uv_tty_t* stream, uv_shutdown_t* req) { argument 2262 assert(stream->stream.conn.write_reqs_pending == 0); 2265 stream->stream.conn.shutdown_req = NULL; 2266 UNREGISTER_HANDLE_REQ(loop, stream, req); 2270 if (stream->flags & UV_HANDLE_CLOSING) { [all …]
|
H A D | pipe.c | 597 assert(handle->stream.conn.write_reqs_pending == 0); in uv__pipe_shutdown() 1208 handle->stream.serv.connection_cb = cb; in uv__pipe_listen() 1229 handle->stream.serv.connection_cb = cb; in uv__pipe_listen() 1643 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data() 1649 if (handle->stream.conn.write_reqs_pending == 0) { in uv__pipe_write_data() 1691 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data() 1724 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data() 2163 handle->stream.conn.write_reqs_pending--; in uv__process_pipe_write_req() 2171 if (handle->stream.conn.write_reqs_pending == 0 && in uv__process_pipe_write_req() 2197 if (handle->stream.serv.connection_cb) { in uv__process_pipe_accept_req() [all …]
|
H A D | internal.h | 92 uv_tcp_t* stream, 174 uv_tty_t* stream,
|
/libuv/src/unix/ |
H A D | process.c | 198 assert(container->data.stream != NULL); in uv__process_init_stdio() 199 if (container->data.stream->type != UV_NAMED_PIPE) in uv__process_init_stdio() 209 fd = uv__stream_fd(container->data.stream); in uv__process_init_stdio() 245 return uv__stream_open(container->data.stream, pipefds[0], flags); in uv__process_open_stream() 251 uv__stream_close(container->data.stream); in uv__process_close_stream()
|
H A D | internal.h | 273 void uv__stream_init(uv_loop_t* loop, uv_stream_t* stream, 276 void uv__stream_destroy(uv_stream_t* stream); 278 int uv__stream_try_select(uv_stream_t* stream, int* fd);
|
/libuv/docs/src/guide/ |
H A D | networking.rst | 21 TCP is a connection oriented, stream protocol and is therefore based on the 34 5. Use :ref:`stream operations <buffers-and-streams>` to communicate with the 60 In this case we also establish interest in reading from this stream. 99 communication. Hence libuv doesn't offer a stream. Instead libuv provides 102 actual API for reading/writing is very similar to normal stream reads. To look
|
H A D | processes.rst | 196 uv_stream_t* stream; 215 If you run ``proc-stream`` you'll see that only the line "This is stderr" will 219 to ``UV_INHERIT_STREAM`` and setting ``data.stream`` to the stream in the 220 parent process, the child process can treat that stream as standard I/O. This 241 Here we simply accept the TCP connection and pass on the socket (*stream*) to 265 the ``uv_stream_t* stream`` field must be set to point to an initialized, 313 the stream API is concerned. You can test this server using `socat`_::
|
H A D | filesystem.rst | 171 The basic I/O handle in libuv is the stream (``uv_stream_t``). TCP sockets, UDP 172 sockets, and pipes for file I/O and IPC are all treated as stream subclasses. 184 The stream based functions are simpler to use than the filesystem ones and 185 libuv will automatically keep reading from a stream when ``uv_read_start()`` is 246 UV_ENOBUFS. libuv will continue to attempt to read the stream though, so you
|
/libuv/docs/code/cgi/ |
H A D | main.c | 33 child_stdio[1].data.stream = (uv_stream_t*) client; in invoke_cgi_script()
|
/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() argument
|
/libuv/docs/code/multi-echo-server/ |
H A D | main.c | 80 child_stdio[0].data.stream = (uv_stream_t*) &worker->pipe; in setup_workers()
|
/libuv/include/ |
H A D | uv.h | 172 XX(STREAM, stream) \ 324 typedef void (*uv_read_cb)(uv_stream_t* stream, 499 UV_EXTERN void uv_print_all_handles(uv_loop_t* loop, FILE* stream); 500 UV_EXTERN void uv_print_active_handles(uv_loop_t* loop, FILE* stream); 538 UV_EXTERN size_t uv_stream_get_write_queue_size(const uv_stream_t* stream); 540 UV_EXTERN int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb); 1039 uv_stream_t* stream; member
|
/libuv/ |
H A D | ChangeLog | 871 * stream: permit read after seeing EOF (Jameson Nash) 993 * stream: introduce uv_try_write2 function (twosee) 2132 * unix,stream: fix zero byte writes (Santiago Gimeno) 2275 * doc: add missing slash in stream.rst (Emil Bay) 2310 * stream: autodetect direction (Jameson Nash) 3336 * doc: fix stream typos (Pierre-Marie de Rodat) 4206 * stream: use SO_OOBINLINE on OS X (Fedor Indutny) 5153 * stream: fix uv__stream_osx_select (Fedor Indutny) 5184 * stream: introduce uv_try_write(...) (Fedor Indutny) 5815 * unix: fix stream refcounting buglet (Ben Noordhuis) [all …]
|