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]; \
388 GQueue *write_queue; member467 g_queue_free_full (worker->write_queue, (GDestroyNotify) message_to_write_data_free); in _g_dbus_worker_unref()1380 send_queue = worker->write_queue; in iostream_close_cb()1381 worker->write_queue = g_queue_new (); in iostream_close_cb()1465 data = g_queue_pop_head (worker->write_queue); in continue_writing()1579 g_queue_push_tail (worker->write_queue, write_data); in schedule_writing_unlocked()1685 worker->write_queue = g_queue_new (); in _g_dbus_worker_new()1782 pending_writes = g_queue_get_length (worker->write_queue); in _g_dbus_worker_flush_sync()
591 * udp: fix write_queue cleanup on sendmmsg error (Santiago Gimeno)