Searched refs:watcher_queue (Results 1 – 9 of 9) sorted by relevance
| /libuv/src/unix/ |
| H A D | loop.c | 66 uv__queue_init(&loop->watcher_queue); in uv_loop_init()
155 if (w->pevents != 0 && uv__queue_empty(&w->watcher_queue)) { in uv_loop_fork()
157 uv__queue_insert_tail(&loop->watcher_queue, &w->watcher_queue); in uv_loop_fork()
196 assert(uv__queue_empty(&loop->watcher_queue)); in uv__loop_close()
|
| H A D | posix-poll.c | 152 assert(uv__queue_empty(&loop->watcher_queue)); in uv__io_poll()
159 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
160 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
164 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
|
| H A D | sunos.c | 169 assert(uv__queue_empty(&loop->watcher_queue)); in uv__io_poll()
173 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
174 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
178 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
319 if (w->pevents != 0 && uv__queue_empty(&w->watcher_queue)) in uv__io_poll()
320 uv__queue_insert_tail(&loop->watcher_queue, &w->watcher_queue); in uv__io_poll()
|
| H A D | core.c | 403 if (uv__queue_empty(&loop->watcher_queue)) in uv_backend_timeout()
897 uv__queue_init(&w->watcher_queue); in uv__io_init()
923 if (uv__queue_empty(&w->watcher_queue)) in uv__io_start()
924 uv__queue_insert_tail(&loop->watcher_queue, &w->watcher_queue); in uv__io_start()
949 uv__queue_remove(&w->watcher_queue); in uv__io_stop()
950 uv__queue_init(&w->watcher_queue); in uv__io_stop()
959 else if (uv__queue_empty(&w->watcher_queue)) in uv__io_stop()
960 uv__queue_insert_tail(&loop->watcher_queue, &w->watcher_queue); in uv__io_stop()
|
| H A D | kqueue.c | 158 assert(uv__queue_empty(&loop->watcher_queue)); in uv__io_poll()
165 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
166 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
170 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
|
| H A D | os390.c | 832 assert(uv__queue_empty(&loop->watcher_queue)); in uv__io_poll()
838 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
841 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
844 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
|
| H A D | aix.c | 154 assert(uv__queue_empty(&loop->watcher_queue)); in uv__io_poll()
160 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
161 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
165 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
|
| H A D | linux.c | 1376 while (!uv__queue_empty(&loop->watcher_queue)) { in uv__io_poll()
1377 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
1378 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
|
| /libuv/include/uv/ |
| H A D | unix.h | 96 struct uv__queue watcher_queue; member
224 struct uv__queue watcher_queue; \
|
Completed in 45 milliseconds
