Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 26) sorted by relevance

12

/libuv/src/unix/
H A Dasync.c155 uv__queue_remove(&handle->queue); in uv__async_close()
163 struct uv__queue queue; local
193 while (!uv__queue_empty(&queue)) {
194 q = uv__queue_head(&queue);
195 h = uv__queue_data(q, uv_async_t, queue);
327 struct uv__queue queue; local
338 while (!uv__queue_empty(&queue)) {
339 q = uv__queue_head(&queue);
361 struct uv__queue queue; local
369 while (!uv__queue_empty(&queue)) {
[all …]
H A Dloop-watcher.c35 uv__queue_insert_head(&handle->loop->name##_handles, &handle->queue); \
43 uv__queue_remove(&handle->queue); \
50 struct uv__queue queue; \
52 uv__queue_move(&loop->name##_handles, &queue); \
53 while (!uv__queue_empty(&queue)) { \
54 q = uv__queue_head(&queue); \
55 h = uv__queue_data(q, uv_##name##_t, queue); \
H A Dudp.c74 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()
326 uv__queue_remove(&req->queue); in uv__udp_sendmsg_one()
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()
394 uv__queue_remove(&req->queue); in uv__udp_sendmsg_many()
407 req = uv__queue_data(q, uv_udp_send_t, queue); in uv__udp_sendmsg_many()
415 uv__queue_remove(&req->queue); in uv__udp_sendmsg_many()
435 req = uv__queue_data(q, uv_udp_send_t, queue); in uv__udp_sendmsg()
[all …]
H A Dprocess.c117 process = uv__queue_data(q, uv_process_t, queue); in uv__wait_children()
149 uv__queue_remove(&process->queue); in uv__wait_children()
150 uv__queue_insert_tail(&pending, &process->queue); in uv__wait_children()
156 process = uv__queue_data(q, uv_process_t, queue); in uv__wait_children()
159 uv__queue_remove(&process->queue); in uv__wait_children()
160 uv__queue_init(&process->queue); in uv__wait_children()
979 uv__queue_init(&process->queue); in uv_spawn()
1042 uv__queue_insert_tail(&loop->process_handles, &process->queue); in uv_spawn()
1104 uv__queue_remove(&handle->queue); in uv__process_close()
H A Dstream.c447 req = uv__queue_data(q, uv_write_t, queue); in uv__stream_flush_write_queue()
450 uv__queue_insert_tail(&stream->write_completed_queue, &req->queue); in uv__stream_flush_write_queue()
718 uv__queue_remove(&req->queue); in uv__write_req_finish()
735 uv__queue_insert_tail(&stream->write_completed_queue, &req->queue); in uv__write_req_finish()
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()
1360 uv__queue_init(&req->queue); in uv_write2()
1375 uv__queue_insert_tail(&stream->write_queue, &req->queue); in uv_write2()
H A Dlinux.c2467 struct uv__queue queue; in uv__inotify_fork() local
2489 uv__queue_move(&watcher_list->watchers, &queue); in uv__inotify_fork()
2490 while (!uv__queue_empty(&queue)) { in uv__inotify_fork()
2491 q = uv__queue_head(&queue); in uv__inotify_fork()
2510 uv__queue_move(&tmp_watcher_list.watchers, &queue); in uv__inotify_fork()
2511 while (!uv__queue_empty(&queue)) { in uv__inotify_fork()
2512 q = uv__queue_head(&queue); in uv__inotify_fork()
2551 struct uv__queue queue; in uv__inotify_read() local
2603 uv__queue_move(&w->watchers, &queue); in uv__inotify_read()
2604 while (!uv__queue_empty(&queue)) { in uv__inotify_read()
[all …]
H A Dpipe.c245 uv__queue_init(&req->queue); in uv_pipe_connect()
338 uv__queue_init(&req->queue); in uv_pipe_connect2()
H A Dtcp.c340 uv__queue_init(&req->queue); in uv__tcp_connect()
H A Dkqueue.c342 process = uv__queue_data(q, uv_process_t, queue); in uv__io_poll()
/libuv/include/uv/
H A Dunix.h260 struct uv__queue queue; \
268 struct uv__queue queue; \
273 struct uv__queue queue; \
314 struct uv__queue queue; \
318 struct uv__queue queue; \
322 struct uv__queue queue; \
326 struct uv__queue queue; \
333 struct uv__queue queue; \
358 struct uv__queue queue; \
H A Dwin.h555 struct uv__queue queue; \
/libuv/docs/code/multi-echo-server/
H A Dworker.c9 uv_pipe_t queue; variable
84 uv_pipe_init(loop, &queue, 1 /* ipc */); in main()
85 uv_pipe_open(&queue, 0); in main()
86 uv_read_start((uv_stream_t*)&queue, alloc_buffer, on_new_connection); in main()
/libuv/src/
H A Dtimer.c63 uv__queue_init(&handle->node.queue); in uv_timer_init()
105 uv__queue_remove(&handle->node.queue); in uv_timer_stop()
108 uv__queue_init(&handle->node.queue); in uv_timer_stop()
183 uv__queue_insert_tail(&ready_queue, &handle->node.queue); in uv__run_timers()
190 handle = container_of(queue_node, uv_timer_t, node.queue); in uv__run_timers()
H A Duv-common.c536 struct uv__queue queue; in uv_walk() local
540 uv__queue_move(&loop->handle_queue, &queue); in uv_walk()
541 while (!uv__queue_empty(&queue)) { in uv_walk()
542 q = uv__queue_head(&queue); in uv_walk()
/libuv/docs/code/
H A DCMakeLists.txt34 queue-cancel
35 queue-work
/libuv/docs/src/guide/
H A Dthreads.rst181 .. _libuv-work-queue:
188 libuv work queue
212 .. rubric:: queue-work/main.c - lazy fibonacci
213 .. literalinclude:: ../../code/queue-work/main.c
226 .. rubric:: queue-work/main.c
227 .. literalinclude:: ../../code/queue-work/main.c
254 .. rubric:: queue-cancel/main.c
255 .. literalinclude:: ../../code/queue-cancel/main.c
263 .. rubric:: queue-cancel/main.c
264 .. literalinclude:: ../../code/queue-cancel/main.c
[all …]
H A Dutilities.rst110 and the user will face an unresponsive application. In such a case queue up and
120 Here we initialize the idle watcher and queue it up along with the actual
167 Here we create the baton and queue the task.
291 wants in its main thread. libcurl keeps queueing messages into its own queue
H A Dprocesses.rst351 ``queue`` is the pipe connected to the master process on the other end, along
371 here. Fetch the file descriptor (``client``) from ``queue``. From this point
H A Dnetworking.rst56 arguments is the backlog queue -- the maximum length of queued connections.
/libuv/
H A DMakefile.am37 src/queue.h \
244 test/test-queue-foreach-delete.c \
292 test/test-tcp-write-queue-order.c \
H A DCMakeLists.txt506 test/benchmark-queue-work.c
617 test/test-queue-foreach-delete.c
663 test/test-tcp-write-queue-order.c
H A DChangeLog332 * unix,win: reset the timer queue on stop (Santiago Gimeno)
1615 * zos: explicitly mark message queue events (Irek Fakhrutdinov)
2604 * zos: write-protect message queue (jBarz)
2730 * zos,doc: add system V message queue note (jBarz)
3399 * test: fix flaky tcp-write-queue-order (Santiago Gimeno)
4282 * threadpool: send signal only when queue is empty (chenttuuvv)
4771 * unix: fix processing process handles queue (Saúl Ibarra Corretgé)
5465 * queue: strengthen type checks (Ben Noordhuis)
5976 * src: make queue.h c++ compatible (Ben Noordhuis)
5978 * unix: s/ngx-queue.h/queue.h/ in checksparse.sh (Ben Noordhuis)
[all …]
/libuv/docs/src/
H A Dstream.rst117 connections the kernel might queue, same as :man:`listen(2)`. When a new
202 Same as :c:func:`uv_write`, but won't queue a write request if it can't be
H A Ddesign.rst132 libuv currently uses a global thread pool on which all loops can queue work. 3 types of
H A Dudp.rst145 Number of send requests currently in the queue awaiting to be processed.
414 Same as :c:func:`uv_udp_send`, but won't queue a send request if it can't

Completed in 61 milliseconds

12