Home
last modified time | relevance | path

Searched refs:q (Results 1 – 23 of 23) sorted by relevance

/libuv/src/
H A Dqueue.h25 for ((q) = (h)->next; (q) != (h); (q) = (q)->next)
28 q->next = q; in uv__queue_init()
29 q->prev = q; in uv__queue_init()
33 return q == q->next; in uv__queue_empty()
56 n->next = q; in uv__queue_split()
59 q->prev = n; in uv__queue_split()
72 q->prev = h; in uv__queue_insert_head()
73 q->next->prev = q; in uv__queue_insert_head()
81 q->prev->next = q; in uv__queue_insert_tail()
86 q->prev->next = q->next; in uv__queue_remove()
[all …]
H A Dthreadpool.c59 struct uv__queue* q; in worker() local
80 q = uv__queue_head(&wq); in worker()
81 if (q == &exit_message) { in worker()
87 uv__queue_remove(q); in worker()
108 uv__queue_remove(q); in worker()
109 uv__queue_init(q); in worker()
153 q = &run_slow_work_message; in post()
156 uv__queue_insert_tail(&wq, q); in post()
311 struct uv__queue* q; in uv__work_done() local
324 q = uv__queue_head(&wq); in uv__work_done()
[all …]
H A Didna.c161 unsigned q; in uv__idna_toascii_label() local
261 for (k = 36, q = delta; /* empty */; k += 36) { in uv__idna_toascii_label()
270 if (q < t) in uv__idna_toascii_label()
277 x = q - t; in uv__idna_toascii_label()
279 q = x / y; in uv__idna_toascii_label()
287 *(*d)++ = alphabet[q]; in uv__idna_toascii_label()
H A Duv-common.c537 struct uv__queue* q; in uv_walk() local
542 q = uv__queue_head(&queue); in uv_walk()
543 h = uv__queue_data(q, uv_handle_t, handle_queue); in uv_walk()
545 uv__queue_remove(q); in uv_walk()
546 uv__queue_insert_tail(&loop->handle_queue, q); in uv_walk()
556 struct uv__queue* q; in uv__print_handles() local
565 uv__queue_foreach(q, &loop->handle_queue) { in uv__print_handles()
566 h = uv__queue_data(q, uv_handle_t, handle_queue); in uv__print_handles()
852 struct uv__queue* q; in uv_loop_close() local
861 uv__queue_foreach(q, &loop->handle_queue) { in uv_loop_close()
[all …]
/libuv/src/unix/
H A Dasync.c164 struct uv__queue* q; local
194 q = uv__queue_head(&queue);
195 h = uv__queue_data(q, uv_async_t, queue);
197 uv__queue_remove(q);
328 struct uv__queue* q; local
339 q = uv__queue_head(&queue);
340 h = uv__queue_data(q, uv_async_t, queue);
342 uv__queue_remove(q);
362 struct uv__queue* q; local
370 q = uv__queue_head(&queue);
[all …]
H A Dloop-watcher.c51 struct uv__queue* q; \
54 q = uv__queue_head(&queue); \
55 h = uv__queue_data(q, uv_##name##_t, queue); \
56 uv__queue_remove(q); \
57 uv__queue_insert_tail(&loop->name##_handles, q); \
H A Dfsevents.c227 struct uv__queue* q; in uv__fsevents_event_cb() local
241 uv__queue_foreach(q, &state->fsevent_handles) { in uv__fsevents_event_cb()
242 handle = uv__queue_data(q, uv_fs_event_t, cf_member); in uv__fsevents_event_cb()
402 struct uv__queue* q; in uv__fsevents_reschedule() local
443 q = &state->fsevent_handles; in uv__fsevents_reschedule()
445 q = uv__queue_next(q); in uv__fsevents_reschedule()
446 assert(q != &state->fsevent_handles); in uv__fsevents_reschedule()
485 uv__queue_foreach(q, &state->fsevent_handles) { in uv__fsevents_reschedule()
674 struct uv__queue* q; in uv__fsevents_loop_delete() local
688 q = uv__queue_head(&loop->cf_signals); in uv__fsevents_loop_delete()
[all …]
H A Dudp.c65 struct uv__queue* q; in uv__udp_finish_close() local
71 q = uv__queue_head(&handle->write_queue); in uv__udp_finish_close()
72 uv__queue_remove(q); in uv__udp_finish_close()
93 struct uv__queue* q; in uv__udp_run_completed() local
100 uv__queue_remove(q); in uv__udp_run_completed()
286 struct uv__queue* q; in uv__udp_sendmsg_one() local
333 q = uv__queue_head(&handle->write_queue); in uv__udp_sendmsg_one()
343 struct uv__queue* q; in uv__udp_sendmsg_many() local
351 ++pkts, q = uv__queue_head(q)) { in uv__udp_sendmsg_many()
428 struct uv__queue* q; in uv__udp_sendmsg() local
[all …]
H A Dos390-syscalls.c181 struct uv__queue* q; in child_fork() local
190 q = uv__queue_head(&global_epoll_queue); in child_fork()
191 uv__queue_remove(q); in child_fork()
192 lst = uv__queue_data(q, uv__os390_epoll, member); in child_fork()
355 struct uv__queue* q; in epoll_file_close() local
359 uv__queue_foreach(q, &global_epoll_queue) { in epoll_file_close()
362 lst = uv__queue_data(q, uv__os390_epoll, member); in epoll_file_close()
H A Dsignal.c282 struct uv__queue* q; in uv__signal_loop_fork() local
292 uv__queue_foreach(q, &loop->handle_queue) { in uv__signal_loop_fork()
293 uv_handle_t* handle = uv__queue_data(q, uv_handle_t, handle_queue); in uv__signal_loop_fork()
309 struct uv__queue* q; in uv__signal_loop_cleanup() local
317 uv__queue_foreach(q, &loop->handle_queue) { in uv__signal_loop_cleanup()
318 uv_handle_t* handle = uv__queue_data(q, uv_handle_t, handle_queue); in uv__signal_loop_cleanup()
H A Dposix-poll.c140 struct uv__queue* q; in uv__io_poll() local
160 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
161 uv__queue_remove(q); in uv__io_poll()
162 uv__queue_init(q); in uv__io_poll()
164 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
H A Dprocess.c109 struct uv__queue* q; in uv__wait_children() local
115 q = uv__queue_head(h); in uv__wait_children()
116 while (q != h) { in uv__wait_children()
117 process = uv__queue_data(q, uv_process_t, queue); in uv__wait_children()
118 q = uv__queue_next(q); in uv__wait_children()
154 q = uv__queue_head(h); in uv__wait_children()
155 while (q != h) { in uv__wait_children()
156 process = uv__queue_data(q, uv_process_t, queue); in uv__wait_children()
157 q = uv__queue_next(q); in uv__wait_children()
H A Dkqueue.c166 struct uv__queue* q; in uv__io_poll() local
193 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
194 uv__queue_remove(q); in uv__io_poll()
195 uv__queue_init(q); in uv__io_poll()
197 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
341 uv__queue_foreach(q, &loop->process_handles) { in uv__io_poll()
342 process = uv__queue_data(q, uv_process_t, queue); in uv__io_poll()
H A Dlinux.c1359 struct uv__queue* q; in uv__io_poll() local
1408 uv__queue_remove(q); in uv__io_poll()
1409 uv__queue_init(q); in uv__io_poll()
2468 struct uv__queue* q; in uv__inotify_fork() local
2491 q = uv__queue_head(&queue); in uv__inotify_fork()
2499 uv__queue_remove(q); in uv__inotify_fork()
2512 q = uv__queue_head(&queue); in uv__inotify_fork()
2513 uv__queue_remove(q); in uv__inotify_fork()
2552 struct uv__queue* q; in uv__inotify_read() local
2605 q = uv__queue_head(&queue); in uv__inotify_read()
[all …]
H A Dstream.c442 struct uv__queue* q; in uv__stream_flush_write_queue() local
444 q = uv__queue_head(&stream->write_queue); in uv__stream_flush_write_queue()
445 uv__queue_remove(q); in uv__stream_flush_write_queue()
447 req = uv__queue_data(q, uv_write_t, queue); in uv__stream_flush_write_queue()
841 struct uv__queue* q; in uv__write() local
858 q = uv__queue_head(&stream->write_queue); in uv__write()
859 req = uv__queue_data(q, uv_write_t, queue); in uv__write()
903 struct uv__queue* q; in uv__write_callbacks() local
913 q = uv__queue_head(&pq); in uv__write_callbacks()
914 req = uv__queue_data(q, uv_write_t, queue); in uv__write_callbacks()
[all …]
H A Dsunos.c151 struct uv__queue* q; in uv__io_poll() local
174 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
175 uv__queue_remove(q); in uv__io_poll()
176 uv__queue_init(q); in uv__io_poll()
178 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
H A Dos390.c820 struct uv__queue* q; in uv__io_poll() local
841 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
842 uv__queue_remove(q); in uv__io_poll()
843 uv__queue_init(q); in uv__io_poll()
844 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
H A Dcore.c368 uv_handle_t* q; in uv__run_closing_handles() local
374 q = p->next_closing; in uv__run_closing_handles()
376 p = q; in uv__run_closing_handles()
841 struct uv__queue* q; in uv__run_pending() local
848 q = uv__queue_head(&pq); in uv__run_pending()
849 uv__queue_remove(q); in uv__run_pending()
850 uv__queue_init(q); in uv__run_pending()
851 w = uv__queue_data(q, uv__io_t, pending_queue); in uv__run_pending()
H A Daix.c139 struct uv__queue* q; in uv__io_poll() local
161 q = uv__queue_head(&loop->watcher_queue); in uv__io_poll()
162 uv__queue_remove(q); in uv__io_poll()
163 uv__queue_init(q); in uv__io_poll()
165 w = uv__queue_data(q, uv__io_t, watcher_queue); in uv__io_poll()
/libuv/docs/code/multi-echo-server/
H A Dworker.c51 void on_new_connection(uv_stream_t *q, ssize_t nread, const uv_buf_t *buf) { in on_new_connection() argument
55 uv_close((uv_handle_t*) q, NULL); in on_new_connection()
59 uv_pipe_t *pipe = (uv_pipe_t*) q; in on_new_connection()
70 if (uv_accept(q, (uv_stream_t*) client) == 0) { in on_new_connection()
/libuv/docs/
H A Dmake.bat45 for /d %%i in (%BUILDDIR%\*) do rmdir /q /s %%i
46 del /q /s %BUILDDIR%\*
/libuv/src/win/
H A Dpipe.c654 struct uv__queue* q; in uv__pipe_endgame() local
657 q = uv__queue_head(&handle->pipe.conn.ipc_xfer_queue); in uv__pipe_endgame()
658 uv__queue_remove(q); in uv__pipe_endgame()
659 xfer_queue_item = uv__queue_data(q, uv__ipc_xfer_queue_item_t, member); in uv__pipe_endgame()
1147 struct uv__queue* q; in uv__pipe_accept() local
1157 q = uv__queue_head(&server->pipe.conn.ipc_xfer_queue); in uv__pipe_accept()
1158 uv__queue_remove(q); in uv__pipe_accept()
1160 item = uv__queue_data(q, uv__ipc_xfer_queue_item_t, member); in uv__pipe_accept()
/libuv/.github/workflows/
H A DCI-unix.yml170 QEMU_SRC: "http://archive.ubuntu.com/ubuntu/pool/universe/q/qemu"

Completed in 99 milliseconds