Searched refs:write_queue (Results 1 – 5 of 5) sorted by relevance
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 …]
86 QUEUE_INIT(&stream->write_queue); in uv__stream_init()432 while (!QUEUE_EMPTY(&stream->write_queue)) { in uv__stream_flush_write_queue()433 q = QUEUE_HEAD(&stream->write_queue); in uv__stream_flush_write_queue()669 assert(QUEUE_EMPTY(&stream->write_queue)); in uv__drain()893 if (QUEUE_EMPTY(&stream->write_queue)) in uv__write()896 q = QUEUE_HEAD(&stream->write_queue); in uv__write()1342 if (QUEUE_EMPTY(&stream->write_queue)) in uv__stream_io()1385 if (error < 0 || QUEUE_EMPTY(&stream->write_queue)) { in uv__stream_connect()1482 QUEUE_INSERT_TAIL(&stream->write_queue, &req->queue); in uv_write2()
290 void* write_queue[2]; \304 void* write_queue[2]; \
591 * udp: fix write_queue cleanup on sendmmsg error (Santiago Gimeno)
70885 struct sk_buff_head write_queue; member