Searched refs:write_queue (Results 1 – 9 of 9) sorted by relevance
| /third_party/node/deps/uv/src/unix/ |
| D | udp.c | 106 while (!QUEUE_EMPTY(&handle->write_queue)) { in uv__udp_finish_close()
107 q = QUEUE_HEAD(&handle->write_queue); in uv__udp_finish_close()
160 if (QUEUE_EMPTY(&handle->write_queue)) { in uv__udp_run_completed()
324 if (QUEUE_EMPTY(&handle->write_queue)) in uv__udp_sendmmsg()
328 for (pkts = 0, q = QUEUE_HEAD(&handle->write_queue); in uv__udp_sendmmsg()
329 pkts < UV__MMSG_MAXWIDTH && q != &handle->write_queue; in uv__udp_sendmmsg()
364 for (i = 0, q = QUEUE_HEAD(&handle->write_queue); in uv__udp_sendmmsg()
365 i < pkts && q != &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()
[all …]
|
| D | stream.c | 87 QUEUE_INIT(&stream->write_queue); in uv__stream_init()
433 while (!QUEUE_EMPTY(&stream->write_queue)) { in uv__stream_flush_write_queue()
434 q = QUEUE_HEAD(&stream->write_queue); in uv__stream_flush_write_queue()
662 assert(QUEUE_EMPTY(&stream->write_queue)); in uv__drain()
891 if (QUEUE_EMPTY(&stream->write_queue)) in uv__write()
894 q = QUEUE_HEAD(&stream->write_queue); in uv__write()
1244 if (QUEUE_EMPTY(&stream->write_queue)) in uv_shutdown()
1297 if (QUEUE_EMPTY(&stream->write_queue)) in uv__stream_io()
1340 if (error < 0 || QUEUE_EMPTY(&stream->write_queue)) { in uv__stream_connect()
1437 QUEUE_INSERT_TAIL(&stream->write_queue, &req->queue); in uv_write2()
|
| /third_party/libuv/src/unix/ |
| D | udp.c | 106 while (!QUEUE_EMPTY(&handle->write_queue)) { in uv__udp_finish_close()
107 q = QUEUE_HEAD(&handle->write_queue); in uv__udp_finish_close()
160 if (QUEUE_EMPTY(&handle->write_queue)) { in uv__udp_run_completed()
324 if (QUEUE_EMPTY(&handle->write_queue)) in uv__udp_sendmmsg()
328 for (pkts = 0, q = QUEUE_HEAD(&handle->write_queue); in uv__udp_sendmmsg()
329 pkts < UV__MMSG_MAXWIDTH && q != &handle->write_queue; in uv__udp_sendmmsg()
364 for (i = 0, q = QUEUE_HEAD(&handle->write_queue); in uv__udp_sendmmsg()
365 i < pkts && q != &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()
[all …]
|
| D | stream.c | 87 QUEUE_INIT(&stream->write_queue); in uv__stream_init()
433 while (!QUEUE_EMPTY(&stream->write_queue)) { in uv__stream_flush_write_queue()
434 q = QUEUE_HEAD(&stream->write_queue); in uv__stream_flush_write_queue()
662 assert(QUEUE_EMPTY(&stream->write_queue)); in uv__drain()
891 if (QUEUE_EMPTY(&stream->write_queue)) in uv__write()
894 q = QUEUE_HEAD(&stream->write_queue); in uv__write()
1244 if (QUEUE_EMPTY(&stream->write_queue)) in uv_shutdown()
1297 if (QUEUE_EMPTY(&stream->write_queue)) in uv__stream_io()
1340 if (error < 0 || QUEUE_EMPTY(&stream->write_queue)) { in uv__stream_connect()
1437 QUEUE_INSERT_TAIL(&stream->write_queue, &req->queue); in uv_write2()
|
| /third_party/node/deps/uv/include/uv/ |
| D | unix.h | 290 void* write_queue[2]; \
304 void* write_queue[2]; \
|
| /third_party/libuv/include/uv/ |
| D | unix.h | 291 void* write_queue[2]; \
305 void* write_queue[2]; \
|
| /third_party/node/deps/uv/ |
| D | ChangeLog | 719 * udp: fix write_queue cleanup on sendmmsg error (Santiago Gimeno)
|
| /third_party/libuv/ |
| D | ChangeLog | 719 * udp: fix write_queue cleanup on sendmmsg error (Santiago Gimeno)
|
| /third_party/libbpf/.github/actions/build-selftests/ |
| D | vmlinux.h | 70885 struct sk_buff_head write_queue; member
|