Home
last modified time | relevance | path

Searched refs:stream (Results 26 – 50 of 60) sorted by relevance

123

/libuv/src/
H A Duv-data-getter-setters.c77 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 Duv-common.h147 int uv__read_start(uv_stream_t* stream,
272 (h->stream.conn.shutdown_req != NULL)
/libuv/test/
H A Dtest-osx-select.c40 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 Dtest-tcp-write-to-half-open-connection.c32 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 Dtest-spawn.c294 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 Drunner-win.c220 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 Dtest-stdio-over-pipes.c134 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 Drunner-unix.c368 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 Dtest-tcp-alloc-cb-fail.c52 static void conn_read_cb(uv_stream_t* stream, in conn_read_cb() argument
H A Dbenchmark-spawn.c123 options.stdio[1].data.stream = (uv_stream_t*)&out; in spawn()
/libuv/docs/src/
H A Dapi.rst22 stream
H A Dtty.rst7 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 Dtty.c2185 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 Dpipe.c597 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 Dinternal.h92 uv_tcp_t* stream,
174 uv_tty_t* stream,
/libuv/src/unix/
H A Dprocess.c198 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 Dinternal.h273 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 Dnetworking.rst21 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 Dprocesses.rst196 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 Dfilesystem.rst171 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 Dmain.c33 child_stdio[1].data.stream = (uv_stream_t*) client; in invoke_cgi_script()
/libuv/docs/code/uvtee/
H A Dmain.c43 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 Dmain.c80 child_stdio[0].data.stream = (uv_stream_t*) &worker->pipe; in setup_workers()
/libuv/include/
H A Duv.h172 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 DChangeLog871 * 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 …]

Completed in 144 milliseconds

123