| /libuv/src/unix/ |
| H A D | fsevents.c | 167 event = uv__queue_data(q, uv__fsevents_event_t, member); \
242 handle = uv__queue_data(q, uv_fs_event_t, cf_member); in uv__fsevents_event_cb()
447 curr = uv__queue_data(q, uv_fs_event_t, cf_member); in uv__fsevents_reschedule()
486 curr = uv__queue_data(q, uv_fs_event_t, cf_member); in uv__fsevents_reschedule()
689 s = uv__queue_data(q, uv__cf_loop_signal_t, member); in uv__fsevents_loop_delete()
749 s = uv__queue_data(item, uv__cf_loop_signal_t, member); in uv__cf_loop_cb()
|
| H A D | async.c | 199 h = uv__queue_data(q, uv_async_t, queue);
357 h = uv__queue_data(q, uv_async_t, queue);
388 h = uv__queue_data(q, uv_async_t, queue);
|
| H A D | loop-watcher.c | 55 h = uv__queue_data(q, uv_##name##_t, queue); \
|
| H A D | udp.c | 74 req = uv__queue_data(q, uv_udp_send_t, queue); in uv__udp_finish_close()
102 req = uv__queue_data(q, uv_udp_send_t, queue); in uv__udp_run_completed()
334 req = uv__queue_data(q, uv_udp_send_t, queue); in uv__udp_sendmsg_one()
352 req = uv__queue_data(q, uv_udp_send_t, queue); in uv__udp_sendmsg_many()
392 req = uv__queue_data(q, uv_udp_send_t, queue); in uv__udp_sendmsg_many()
407 req = uv__queue_data(q, uv_udp_send_t, queue); in uv__udp_sendmsg_many()
435 req = uv__queue_data(q, uv_udp_send_t, queue); in uv__udp_sendmsg()
|
| H A D | signal.c | 293 uv_handle_t* handle = uv__queue_data(q, uv_handle_t, handle_queue); in uv__signal_loop_fork()
318 uv_handle_t* handle = uv__queue_data(q, uv_handle_t, handle_queue); in uv__signal_loop_cleanup()
|
| H A D | os390-syscalls.c | 192 lst = uv__queue_data(q, uv__os390_epoll, member); in child_fork()
362 lst = uv__queue_data(q, uv__os390_epoll, member); in epoll_file_close()
|
| H A D | kqueue.c | 203 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
348 process = uv__queue_data(q, uv_process_t, queue); in uv__io_poll()
|
| H A D | posix-poll.c | 164 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
|
| H A D | process.c | 117 process = uv__queue_data(q, uv_process_t, queue); in uv__wait_children()
156 process = uv__queue_data(q, uv_process_t, queue); in uv__wait_children()
|
| H A D | stream.c | 447 req = uv__queue_data(q, uv_write_t, queue); in uv__stream_flush_write_queue()
859 req = uv__queue_data(q, uv_write_t, queue); in uv__write()
914 req = uv__queue_data(q, uv_write_t, queue); in uv__write_callbacks()
|
| H A D | linux.c | 1386 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
2477 handle = uv__queue_data(q, uv_fs_event_t, watchers); in uv__inotify_fork()
2499 handle = uv__queue_data(q, uv_fs_event_t, watchers); in uv__inotify_fork()
2591 h = uv__queue_data(q, uv_fs_event_t, watchers); in uv__inotify_read()
|
| H A D | sunos.c | 178 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
|
| H A D | os390.c | 844 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
|
| H A D | aix.c | 165 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
|
| H A D | core.c | 851 w = uv__queue_data(q, uv__io_t, pending_queue); in uv__run_pending()
|
| /libuv/src/ |
| H A D | queue.h | 21 #define uv__queue_data(pointer, type, field) \ macro
|
| H A D | uv-common.c | 543 h = uv__queue_data(q, uv_handle_t, handle_queue); in uv_walk()
566 h = uv__queue_data(q, uv_handle_t, handle_queue); in uv__print_handles()
862 h = uv__queue_data(q, uv_handle_t, handle_queue); in uv_loop_close()
|
| H A D | threadpool.c | 121 w = uv__queue_data(q, struct uv__work, wq); in worker()
|
| /libuv/src/win/ |
| H A D | pipe.c | 659 xfer_queue_item = uv__queue_data(q, uv__ipc_xfer_queue_item_t, member); in uv__pipe_endgame()
1160 item = uv__queue_data(q, uv__ipc_xfer_queue_item_t, member); in uv__pipe_accept()
|
