Home
last modified time | relevance | path

Searched refs:uv__queue_empty (Results 1 – 21 of 21) sorted by relevance

/libuv/src/
H A Dthreadpool.c71 while (uv__queue_empty(&wq) || in worker()
101 if (uv__queue_empty(&slow_io_pending_wq)) in worker()
112 if (!uv__queue_empty(&slow_io_pending_wq)) { in worker()
147 if (!uv__queue_empty(&run_slow_work_message)) { in post()
288 cancelled = !uv__queue_empty(&w->wq) && w->work != NULL; in uv__work_cancel()
323 while (!uv__queue_empty(&wq)) { in uv__work_done()
H A Dqueue.h32 static inline int uv__queue_empty(const struct uv__queue* q) { in uv__queue_empty() function
63 if (uv__queue_empty(h)) in uv__queue_move()
H A Dtimer.c186 while (!uv__queue_empty(&ready_queue)) { in uv__run_timers()
H A Duv-common.c541 while (!uv__queue_empty(&queue)) { in uv_walk()
/libuv/src/unix/
H A Dloop.c155 if (w->pevents != 0 && uv__queue_empty(&w->watcher_queue)) { in uv_loop_fork()
183 assert(uv__queue_empty(&loop->wq) && "thread pool work queue not empty!"); in uv__loop_close()
195 assert(uv__queue_empty(&loop->pending_queue)); in uv__loop_close()
196 assert(uv__queue_empty(&loop->watcher_queue)); in uv__loop_close()
H A Dasync.c161 while (!uv__queue_empty(&queue)) { in uv__async_io()
255 while (!uv__queue_empty(&queue)) { in uv__async_stop()
286 while (!uv__queue_empty(&queue)) { in uv__async_fork()
H A Dcore.c394 !uv__queue_empty(&loop->pending_queue) || in uv__loop_alive()
403 uv__queue_empty(&loop->pending_queue) && in uv__backend_timeout()
404 uv__queue_empty(&loop->idle_handles) && in uv__backend_timeout()
413 if (uv__queue_empty(&loop->watcher_queue)) in uv_backend_timeout()
445 uv__queue_empty(&loop->pending_queue) && in uv_run()
446 uv__queue_empty(&loop->idle_handles); in uv_run()
462 for (r = 0; r < 8 && !uv__queue_empty(&loop->pending_queue); r++) in uv_run()
847 while (!uv__queue_empty(&pq)) { in uv__run_pending()
933 if (uv__queue_empty(&w->watcher_queue)) in uv__io_start()
969 else if (uv__queue_empty(&w->watcher_queue)) in uv__io_stop()
[all …]
H A Dloop-watcher.c53 while (!uv__queue_empty(&queue)) { \
H A Dstream.c443 while (!uv__queue_empty(&stream->write_queue)) { in uv__stream_flush_write_queue()
630 assert(uv__queue_empty(&stream->write_queue)); in uv__drain()
855 if (uv__queue_empty(&stream->write_queue)) in uv__write()
906 if (uv__queue_empty(&stream->write_completed_queue)) in uv__write_callbacks()
911 while (!uv__queue_empty(&pq)) { in uv__write_callbacks()
1182 if (uv__queue_empty(&stream->write_queue)) in uv_shutdown()
1235 if (uv__queue_empty(&stream->write_queue)) in uv__stream_io()
1278 if (error < 0 || uv__queue_empty(&stream->write_queue)) { in uv__stream_connect()
H A Dudp.c70 while (!uv__queue_empty(&handle->write_queue)) { in uv__udp_finish_close()
98 while (!uv__queue_empty(&handle->write_completed_queue)) { in uv__udp_run_completed()
124 if (uv__queue_empty(&handle->write_queue)) { in uv__udp_run_completed()
330 if (uv__queue_empty(&handle->write_queue)) in uv__udp_sendmsg_one()
420 if (!uv__queue_empty(&handle->write_queue)) in uv__udp_sendmsg_many()
431 if (uv__queue_empty(&handle->write_queue)) in uv__udp_sendmsg()
777 if (!uv__queue_empty(&handle->write_queue)) in uv__udp_send()
H A Dposix-poll.c152 assert(uv__queue_empty(&loop->watcher_queue)); in uv__io_poll()
159 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
H A Dfsevents.c165 while (!uv__queue_empty(&events)) { \
320 if (!uv__queue_empty(&head)) in uv__fsevents_event_cb()
687 while (!uv__queue_empty(&loop->cf_signals)) { in uv__fsevents_loop_delete()
745 while (!uv__queue_empty(&split_head)) { in uv__cf_loop_cb()
H A Dsunos.c169 assert(uv__queue_empty(&loop->watcher_queue)); in uv__io_poll()
173 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
319 if (w->pevents != 0 && uv__queue_empty(&w->watcher_queue)) in uv__io_poll()
H A Dkqueue.c191 assert(uv__queue_empty(&loop->watcher_queue)); in uv__io_poll()
198 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
H A Dprocess.c176 assert(uv__queue_empty(&pending)); in uv__wait_children()
1107 if (uv__queue_empty(&handle->loop->process_handles)) in uv__process_close()
H A Dlinux.c1405 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
2490 while (!uv__queue_empty(&queue)) { in uv__inotify_fork()
2511 while (!uv__queue_empty(&queue)) { in uv__inotify_fork()
2536 if ((!w->iterating) && uv__queue_empty(&w->watchers)) { in maybe_free_watcher_list()
2604 while (!uv__queue_empty(&queue)) { in uv__inotify_read()
H A Dos390.c832 assert(uv__queue_empty(&loop->watcher_queue)); in uv__io_poll()
838 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
H A Dos390-syscalls.c188 while (!uv__queue_empty(&global_epoll_queue)) { in child_fork()
H A Daix.c154 assert(uv__queue_empty(&loop->watcher_queue)); in uv__io_poll()
160 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
/libuv/src/win/
H A Dcore.c361 assert(uv__queue_empty(&loop->wq) && "thread pool work queue not empty!"); in uv__loop_close()
H A Dpipe.c653 while (!uv__queue_empty(&handle->pipe.conn.ipc_xfer_queue)) { in uv__pipe_endgame()
1152 if (uv__queue_empty(&server->pipe.conn.ipc_xfer_queue)) { in uv__pipe_accept()

Completed in 60 milliseconds