Searched refs:QUEUE_HEAD (Results 1 – 19 of 19) sorted by relevance
72 (QUEUE_HEAD(&wq) == &run_slow_work_message && in worker()80 q = QUEUE_HEAD(&wq); in worker()107 q = QUEUE_HEAD(&slow_io_pending_wq); in worker()313 q = QUEUE_HEAD(&wq); in uv__work_done()
42 #define QUEUE_HEAD(q) \ macro77 QUEUE* q = QUEUE_HEAD(h); \
507 q = QUEUE_HEAD(&queue); in uv_walk()
114 q = QUEUE_HEAD(&queue); in uv__inotify_fork()135 q = QUEUE_HEAD(&queue); in uv__inotify_fork()227 q = QUEUE_HEAD(&queue); in uv__inotify_read()
107 q = QUEUE_HEAD(&handle->write_queue); in uv__udp_finish_close()135 q = QUEUE_HEAD(&handle->write_completed_queue); in uv__udp_run_completed()328 for (pkts = 0, q = QUEUE_HEAD(&handle->write_queue); in uv__udp_sendmmsg()330 ++pkts, q = QUEUE_HEAD(q)) { in uv__udp_sendmmsg()364 for (i = 0, q = QUEUE_HEAD(&handle->write_queue); in uv__udp_sendmmsg()366 ++i, q = QUEUE_HEAD(&handle->write_queue)) { in uv__udp_sendmmsg()382 for (i = 0, q = QUEUE_HEAD(&handle->write_queue); in uv__udp_sendmmsg()384 ++i, q = QUEUE_HEAD(&handle->write_queue)) { in uv__udp_sendmmsg()423 q = QUEUE_HEAD(&handle->write_queue); in uv__udp_sendmsg()
54 q = QUEUE_HEAD(&queue); \
151 q = QUEUE_HEAD(&queue); in uv__async_io()
168 q = QUEUE_HEAD(&events); \703 q = QUEUE_HEAD(&loop->cf_signals); in uv__fsevents_loop_delete()761 item = QUEUE_HEAD(&split_head); in uv__cf_loop_cb()
144 q = QUEUE_HEAD(&loop->watcher_queue); in uv__io_poll()
157 q = QUEUE_HEAD(&loop->watcher_queue); in uv__io_poll()
98 q = QUEUE_HEAD(h); in uv__wait_children()136 q = QUEUE_HEAD(h); in uv__wait_children()
433 q = QUEUE_HEAD(&stream->write_queue); in uv__stream_flush_write_queue()896 q = QUEUE_HEAD(&stream->write_queue); in uv__write()948 q = QUEUE_HEAD(&pq); in uv__write_callbacks()
190 q = QUEUE_HEAD(&global_epoll_queue); in child_fork()
175 q = QUEUE_HEAD(&loop->watcher_queue); in uv__io_poll()
673 q = QUEUE_HEAD(&loop->watcher_queue); in uv__io_poll()
158 q = QUEUE_HEAD(&loop->watcher_queue); in uv__io_poll()
793 q = QUEUE_HEAD(&pq); in uv__run_pending()
669 q = QUEUE_HEAD(&handle->pipe.conn.ipc_xfer_queue); in uv__pipe_endgame()1088 q = QUEUE_HEAD(&server->pipe.conn.ipc_xfer_queue); in uv__pipe_accept()