Searched refs:QUEUE_EMPTY (Results 1 – 21 of 21) sorted by relevance
71 while (QUEUE_EMPTY(&wq) || in worker()101 if (QUEUE_EMPTY(&slow_io_pending_wq)) in worker()112 if (!QUEUE_EMPTY(&slow_io_pending_wq)) { in worker()147 if (!QUEUE_EMPTY(&run_slow_work_message)) { in post()280 cancelled = !QUEUE_EMPTY(&w->wq) && w->work != NULL; in uv__work_cancel()312 while (!QUEUE_EMPTY(&wq)) { in uv__work_done()
39 #define QUEUE_EMPTY(q) \ macro74 if (QUEUE_EMPTY(h)) \
506 while (!QUEUE_EMPTY(&queue)) { in uv_walk()
155 if (w->pevents != 0 && QUEUE_EMPTY(&w->watcher_queue)) { in uv_loop_fork()183 assert(QUEUE_EMPTY(&loop->wq) && "thread pool work queue not empty!"); in uv__loop_close()195 assert(QUEUE_EMPTY(&loop->pending_queue)); in uv__loop_close()196 assert(QUEUE_EMPTY(&loop->watcher_queue)); in uv__loop_close()
113 while (!QUEUE_EMPTY(&queue)) { in uv__inotify_fork()134 while (!QUEUE_EMPTY(&queue)) { in uv__inotify_fork()159 if ((!w->iterating) && QUEUE_EMPTY(&w->watchers)) { in maybe_free_watcher_list()226 while (!QUEUE_EMPTY(&queue)) { in uv__inotify_read()
341 !QUEUE_EMPTY(&loop->pending_queue) || in uv__loop_alive()350 QUEUE_EMPTY(&loop->pending_queue) && in uv__backend_timeout()351 QUEUE_EMPTY(&loop->idle_handles) && in uv__backend_timeout()359 if (QUEUE_EMPTY(&loop->watcher_queue)) in uv_backend_timeout()787 if (QUEUE_EMPTY(&loop->pending_queue)) in uv__run_pending()792 while (!QUEUE_EMPTY(&pq)) { in uv__run_pending()885 if (QUEUE_EMPTY(&w->watcher_queue)) in uv__io_start()921 else if (QUEUE_EMPTY(&w->watcher_queue)) in uv__io_stop()937 if (QUEUE_EMPTY(&w->pending_queue)) in uv__io_feed()
106 while (!QUEUE_EMPTY(&handle->write_queue)) { in uv__udp_finish_close()134 while (!QUEUE_EMPTY(&handle->write_completed_queue)) { in uv__udp_run_completed()160 if (QUEUE_EMPTY(&handle->write_queue)) { in uv__udp_run_completed()324 if (QUEUE_EMPTY(&handle->write_queue)) in uv__udp_sendmmsg()401 if (!QUEUE_EMPTY(&handle->write_queue)) in uv__udp_sendmmsg()422 while (!QUEUE_EMPTY(&handle->write_queue)) { in uv__udp_sendmsg()779 if (!QUEUE_EMPTY(&handle->write_queue)) in uv__udp_send()
167 while (!QUEUE_EMPTY(&events)) { \326 if (!QUEUE_EMPTY(&head)) in uv__fsevents_event_cb()702 while (!QUEUE_EMPTY(&loop->cf_signals)) { in uv__fsevents_loop_delete()760 while (!QUEUE_EMPTY(&split_head)) { in uv__cf_loop_cb()
137 assert(QUEUE_EMPTY(&loop->watcher_queue)); in uv__io_poll()143 while (!QUEUE_EMPTY(&loop->watcher_queue)) { in uv__io_poll()
151 assert(QUEUE_EMPTY(&loop->watcher_queue)); in uv__io_poll()156 while (!QUEUE_EMPTY(&loop->watcher_queue)) { in uv__io_poll()
53 while (!QUEUE_EMPTY(&queue)) { \
432 while (!QUEUE_EMPTY(&stream->write_queue)) { in uv__stream_flush_write_queue()669 assert(QUEUE_EMPTY(&stream->write_queue)); in uv__drain()893 if (QUEUE_EMPTY(&stream->write_queue)) in uv__write()941 if (QUEUE_EMPTY(&stream->write_completed_queue)) in uv__write_callbacks()946 while (!QUEUE_EMPTY(&pq)) { in uv__write_callbacks()1342 if (QUEUE_EMPTY(&stream->write_queue)) in uv__stream_io()1385 if (error < 0 || QUEUE_EMPTY(&stream->write_queue)) { in uv__stream_connect()
170 assert(QUEUE_EMPTY(&loop->watcher_queue)); in uv__io_poll()174 while (!QUEUE_EMPTY(&loop->watcher_queue)) { in uv__io_poll()320 if (w->pevents != 0 && QUEUE_EMPTY(&w->watcher_queue)) in uv__io_poll()
150 while (!QUEUE_EMPTY(&queue)) { in uv__async_io()
158 assert(QUEUE_EMPTY(&pending)); in uv__wait_children()1079 if (QUEUE_EMPTY(&handle->loop->process_handles)) in uv__process_close()
666 assert(QUEUE_EMPTY(&loop->watcher_queue)); in uv__io_poll()670 while (!QUEUE_EMPTY(&loop->watcher_queue)) { in uv__io_poll()
153 assert(QUEUE_EMPTY(&loop->watcher_queue)); in uv__io_poll()157 while (!QUEUE_EMPTY(&loop->watcher_queue)) { in uv__io_poll()
188 while (!QUEUE_EMPTY(&global_epoll_queue)) { in child_fork()
361 assert(QUEUE_EMPTY(&loop->wq) && "thread pool work queue not empty!"); in uv__loop_close()
665 while (!QUEUE_EMPTY(&handle->pipe.conn.ipc_xfer_queue)) { in uv__pipe_endgame()1083 if (QUEUE_EMPTY(&server->pipe.conn.ipc_xfer_queue)) { in uv__pipe_accept()