stream.c - OpenGrok cross reference for /third

Lines Matching defs:loop
76 static void uv__stream_io(uv_loop_t* loop, uv__io_t* w, unsigned int events);
82 void uv__stream_init(uv_loop_t* loop,
87   uv__handle_init(loop, (uv_handle_t*)stream, type);
101   if (loop->emfile_fd == -1) {
109       loop->emfile_fd = err;
130   /* Interrupt select() loop
249   /* Invoke callback on event-loop */
251     uv__stream_io(stream->loop, &stream->io_watcher, POLLIN);
254     uv__stream_io(stream->loop, &stream->io_watcher, POLLOUT);
320    * Create fds for io watcher and to interrupt the select() loop.
346   err = uv_async_init(stream->loop, &s->async, uv__stream_osx_select_cb);
460     uv__req_unregister(stream->loop, stream->connect_req);
484 static int uv__emfile_trick(uv_loop_t* loop, int accept_fd) {
488   if (loop->emfile_fd == -1)
491   uv__close(loop->emfile_fd);
492   loop->emfile_fd = -1;
502     loop->emfile_fd = emfile_fd;
508 void uv__server_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) {
522     err = uv__emfile_trick(loop, fd);  /* Shed load. */
532     uv__io_stop(loop, &stream->io_watcher, POLLIN);
539   assert(server->loop == client->loop);
595       uv__io_start(server->loop, &server->io_watcher, POLLIN);
632     uv__io_stop(stream->loop, &stream->io_watcher, POLLOUT);
645     uv__req_unregister(stream->loop, req);
735   uv__io_feed(stream->loop, &stream->io_watcher);
830    * loop. See https://github.com/libuv/libuv/pull/482.
847   /* Prevent loop starvation when the consumer of this stream read as fast as
884     uv__io_start(stream->loop, &stream->io_watcher, POLLOUT);
895   uv__io_stop(stream->loop, &stream->io_watcher, POLLOUT);
915     uv__req_unregister(stream->loop, req);
934   uv__io_stop(stream->loop, &stream->io_watcher, POLLIN);
1031   /* Prevent loop starvation when the data comes in as fast as (or faster than)
1084           uv__io_start(stream->loop, &stream->io_watcher, POLLIN);
1099           uv__io_stop(stream->loop, &stream->io_watcher, POLLIN);
1171   uv__req_init(stream->loop, req, UV_SHUTDOWN);
1178     uv__io_feed(stream->loop, &stream->io_watcher);
1184 static void uv__stream_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) {
1271   uv__req_unregister(stream->loop, req);
1274     uv__io_stop(stream->loop, &stream->io_watcher, POLLOUT);
1350   uv__req_init(stream->loop, req, UV_WRITE);
1389     uv__io_start(stream->loop, &stream->io_watcher, POLLOUT);
1452   uv__io_start(stream->loop, &stream->io_watcher, POLLIN);
1465   uv__io_stop(stream->loop, &stream->io_watcher, POLLIN);
1507   /* Terminate select loop first */
1527   uv__io_close(handle->loop, &handle->io_watcher);