Home
last modified time | relevance | path

Searched refs:uv__queue_head (Results 1 – 19 of 19) sorted by relevance

/libuv/src/
H A Dthreadpool.c72 (uv__queue_head(&wq) == &run_slow_work_message && in worker()
80 q = uv__queue_head(&wq); in worker()
107 q = uv__queue_head(&slow_io_pending_wq); in worker()
324 q = uv__queue_head(&wq); in uv__work_done()
H A Dqueue.h36 static inline struct uv__queue* uv__queue_head(const struct uv__queue* q) { in uv__queue_head() function
H A Dtimer.c187 queue_node = uv__queue_head(&ready_queue); in uv__run_timers()
H A Duv-common.c542 q = uv__queue_head(&queue); in uv_walk()
/libuv/src/unix/
H A Dasync.c162 q = uv__queue_head(&queue); in uv__async_io()
256 q = uv__queue_head(&queue); in uv__async_stop()
287 q = uv__queue_head(&queue); in uv__async_fork()
H A Dudp.c71 q = uv__queue_head(&handle->write_queue); in uv__udp_finish_close()
99 q = uv__queue_head(&handle->write_completed_queue); in uv__udp_run_completed()
333 q = uv__queue_head(&handle->write_queue); in uv__udp_sendmsg_one()
349 for (pkts = 0, q = uv__queue_head(&handle->write_queue); in uv__udp_sendmsg_many()
351 ++pkts, q = uv__queue_head(q)) { in uv__udp_sendmsg_many()
389 for (i = 0, q = uv__queue_head(&handle->write_queue); in uv__udp_sendmsg_many()
391 ++i, q = uv__queue_head(&handle->write_queue)) { in uv__udp_sendmsg_many()
404 for (i = 0, q = uv__queue_head(&handle->write_queue); in uv__udp_sendmsg_many()
406 ++i, q = uv__queue_head(&handle->write_queue)) { in uv__udp_sendmsg_many()
434 q = uv__queue_head(&handle->write_queue); in uv__udp_sendmsg()
H A Dloop-watcher.c54 q = uv__queue_head(&queue); \
H A Dfsevents.c166 q = uv__queue_head(&events); \
688 q = uv__queue_head(&loop->cf_signals); in uv__fsevents_loop_delete()
746 item = uv__queue_head(&split_head); in uv__cf_loop_cb()
H A Dposix-poll.c160 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
H A Dprocess.c115 q = uv__queue_head(h); in uv__wait_children()
154 q = uv__queue_head(h); in uv__wait_children()
H A Dstream.c444 q = uv__queue_head(&stream->write_queue); in uv__stream_flush_write_queue()
858 q = uv__queue_head(&stream->write_queue); in uv__write()
913 q = uv__queue_head(&pq); in uv__write_callbacks()
H A Dos390-syscalls.c190 q = uv__queue_head(&global_epoll_queue); in child_fork()
H A Dlinux.c1406 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
2491 q = uv__queue_head(&queue); in uv__inotify_fork()
2512 q = uv__queue_head(&queue); in uv__inotify_fork()
2605 q = uv__queue_head(&queue); in uv__inotify_read()
H A Dkqueue.c199 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
H A Dsunos.c174 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
H A Dos390.c841 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
H A Daix.c161 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
H A Dcore.c848 q = uv__queue_head(&pq); in uv__run_pending()
/libuv/src/win/
H A Dpipe.c657 q = uv__queue_head(&handle->pipe.conn.ipc_xfer_queue); in uv__pipe_endgame()
1157 q = uv__queue_head(&server->pipe.conn.ipc_xfer_queue); in uv__pipe_accept()

Completed in 85 milliseconds