Home
last modified time | relevance | path

Searched refs:uv__queue_empty (Results 1 - 20 of 20) sorted by relevance

/third_party/libuv/src/unix/
H A Dloop.c165 if (w->pevents != 0 && uv__queue_empty(&w->watcher_queue)) { in uv_loop_fork()
199 assert(uv__queue_empty(&loop->wq) && "thread pool work queue not empty!"); in uv__loop_close()
212 assert(uv__queue_empty(&loop->pending_queue)); in uv__loop_close()
213 assert(uv__queue_empty(&loop->watcher_queue)); in uv__loop_close()
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()
854 if (uv__queue_empty(&stream->write_queue)) in uv__write()
905 if (uv__queue_empty(&stream->write_completed_queue)) in uv__write_callbacks()
910 while (!uv__queue_empty(&pq)) { in uv__write_callbacks()
1177 if (uv__queue_empty(&stream->write_queue)) in uv_shutdown()
1230 if (uv__queue_empty(&stream->write_queue)) in uv__stream_io()
1273 if (error < 0 || uv__queue_empty(&stream->write_queue)) { in uv__stream_connect()
H A Dcore.c385 !uv__queue_empty(&loop->pending_queue) || in uv__loop_alive()
394 uv__queue_empty(&loop->pending_queue) && in uv__backend_timeout()
395 uv__queue_empty(&loop->idle_handles) && in uv__backend_timeout()
404 if (uv__queue_empty(&loop->watcher_queue)) in uv_backend_timeout()
419 !uv__queue_empty(&loop->pending_queue) || in uv_loop_alive_taskpool()
449 uv__queue_empty(&loop->pending_queue) && in uv_run()
450 uv__queue_empty(&loop->idle_handles); in uv_run()
466 for (r = 0; r < 8 && !uv__queue_empty(&loop->pending_queue); r++) in uv_run()
861 while (!uv__queue_empty(&pq)) { in uv__run_pending()
947 if (uv__queue_empty( in uv__io_start()
[all...]
H A Dfsevents.c165 while (!uv__queue_empty(&events)) { \
324 if (!uv__queue_empty(&head)) in uv__fsevents_event_cb()
691 while (!uv__queue_empty(&loop->cf_signals)) { in uv__fsevents_loop_delete()
749 while (!uv__queue_empty(&split_head)) { in uv__cf_loop_cb()
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()
288 if (uv__queue_empty(&handle->write_queue)) in uv__udp_sendmsg()
365 if (!uv__queue_empty(&handle->write_queue)) in uv__udp_sendmsg()
374 while (!uv__queue_empty(&handle->write_queue)) { in uv__udp_sendmsg()
742 if (!uv__queue_empty(&handle->write_queue)) in uv__udp_send()
H A Dloop-watcher.c53 while (!uv__queue_empty(&queue)) { \
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 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.c158 assert(uv__queue_empty(&loop->watcher_queue)); in uv__io_poll()
165 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
H A Dasync.c138 while (!uv__queue_empty(&queue)) { in uv__async_io()
H A Dlinux.c1437 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
2407 while (!uv__queue_empty(&queue)) { in uv__inotify_fork()
2428 while (!uv__queue_empty(&queue)) { in uv__inotify_fork()
2453 if ((!w->iterating) && uv__queue_empty(&w->watchers)) { in maybe_free_watcher_list()
2521 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 Dprocess.c179 assert(uv__queue_empty(&pending)); in uv__wait_children()
1110 if (uv__queue_empty(&handle->loop->process_handles)) in uv__process_close()
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()
H A Dos390-syscalls.c188 while (!uv__queue_empty(&global_epoll_queue)) { in child_fork()
/third_party/libuv/src/
H A Dthreadpool.c78 while (uv__queue_empty(&statistic_works)) { in uv_dump_worker()
239 if (uv__queue_empty(&dump_queue)) { in uv_dump_work_queue()
356 while (uv__queue_empty(&wq) || in worker()
386 if (uv__queue_empty(&slow_io_pending_wq)) in worker()
397 if (!uv__queue_empty(&slow_io_pending_wq)) { in worker()
442 if (!uv__queue_empty(&run_slow_work_message)) { in post()
609 cancelled = !uv__queue_empty(&w->wq) && w->work != NULL; in uv__work_cancel()
617 cancelled = !uv__queue_empty(&w->wq) && w->work != NULL in uv__work_cancel()
677 if (!uv__queue_empty(&lfields->wq_sub[i])) { in uv__work_done()
686 while (!uv__queue_empty( in uv__work_done()
[all...]
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 Duv-common.c542 while (!uv__queue_empty(&queue)) { in uv_walk()
/third_party/libuv/src/win/
H A Dcore.c362 assert(uv__queue_empty(&loop->wq) && "thread pool work queue not empty!"); in uv__loop_close()
H A Dpipe.c648 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 26 milliseconds