Lines Matching defs:loop
66 static void uv__stream_io(uv_loop_t* loop, uv__io_t* w, unsigned int events);
72 void uv__stream_init(uv_loop_t* loop,
77 uv__handle_init(loop, (uv_handle_t*)stream, type);
91 if (loop->emfile_fd == -1) {
99 loop->emfile_fd = err;
120 /* Interrupt select() loop
239 /* Invoke callback on event-loop */
241 uv__stream_io(stream->loop, &stream->io_watcher, POLLIN);
244 uv__stream_io(stream->loop, &stream->io_watcher, POLLOUT);
310 * Create fds for io watcher and to interrupt the select() loop.
336 err = uv_async_init(stream->loop, &s->async, uv__stream_osx_select_cb);
450 uv__req_unregister(stream->loop, stream->connect_req);
474 static int uv__emfile_trick(uv_loop_t* loop, int accept_fd) {
478 if (loop->emfile_fd == -1)
481 uv__close(loop->emfile_fd);
482 loop->emfile_fd = -1;
492 loop->emfile_fd = emfile_fd;
505 void uv__server_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) {
514 uv__io_start(stream->loop, &stream->io_watcher, POLLIN);
517 * in the loop so check it on each iteration.
536 err = uv__emfile_trick(loop, uv__stream_fd(stream));
551 uv__io_stop(loop, &stream->io_watcher, POLLIN);
571 assert(server->loop == client->loop);
627 uv__io_start(server->loop, &server->io_watcher, POLLIN);
664 uv__io_stop(stream->loop, &stream->io_watcher, POLLOUT);
678 uv__req_unregister(stream->loop, req);
768 uv__io_feed(stream->loop, &stream->io_watcher);
874 * loop. See https://github.com/libuv/libuv/pull/482.
918 uv__io_start(stream->loop, &stream->io_watcher, POLLOUT);
928 uv__io_stop(stream->loop, &stream->io_watcher, POLLOUT);
948 uv__req_unregister(stream->loop, req);
967 uv__io_stop(stream->loop, &stream->io_watcher, POLLIN);
1089 /* Prevent loop starvation when the data comes in as fast as (or faster than)
1142 uv__io_start(stream->loop, &stream->io_watcher, POLLIN);
1157 uv__io_stop(stream->loop, &stream->io_watcher, POLLIN);
1237 uv__req_init(stream->loop, req, UV_SHUTDOWN);
1245 uv__io_feed(stream->loop, &stream->io_watcher);
1251 static void uv__stream_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) {
1338 uv__req_unregister(stream->loop, req);
1341 uv__io_stop(stream->loop, &stream->io_watcher, POLLOUT);
1417 uv__req_init(stream->loop, req, UV_WRITE);
1456 uv__io_start(stream->loop, &stream->io_watcher, POLLOUT);
1519 uv__io_start(stream->loop, &stream->io_watcher, POLLIN);
1532 uv__io_stop(stream->loop, &stream->io_watcher, POLLIN);
1574 /* Terminate select loop first */
1594 uv__io_close(handle->loop, &handle->io_watcher);