Lines Matching refs:queue
65 NetQueue *queue; in qemu_new_net_queue() local
67 queue = g_new0(NetQueue, 1); in qemu_new_net_queue()
69 queue->opaque = opaque; in qemu_new_net_queue()
70 queue->nq_maxlen = 10000; in qemu_new_net_queue()
71 queue->nq_count = 0; in qemu_new_net_queue()
72 queue->deliver = deliver; in qemu_new_net_queue()
74 QTAILQ_INIT(&queue->packets); in qemu_new_net_queue()
76 queue->delivering = 0; in qemu_new_net_queue()
78 return queue; in qemu_new_net_queue()
81 void qemu_del_net_queue(NetQueue *queue) in qemu_del_net_queue() argument
85 QTAILQ_FOREACH_SAFE(packet, &queue->packets, entry, next) { in qemu_del_net_queue()
86 QTAILQ_REMOVE(&queue->packets, packet, entry); in qemu_del_net_queue()
90 g_free(queue); in qemu_del_net_queue()
93 static void qemu_net_queue_append(NetQueue *queue, in qemu_net_queue_append() argument
102 if (queue->nq_count >= queue->nq_maxlen && !sent_cb) { in qemu_net_queue_append()
112 queue->nq_count++; in qemu_net_queue_append()
113 QTAILQ_INSERT_TAIL(&queue->packets, packet, entry); in qemu_net_queue_append()
116 void qemu_net_queue_append_iov(NetQueue *queue, in qemu_net_queue_append_iov() argument
127 if (queue->nq_count >= queue->nq_maxlen && !sent_cb) { in qemu_net_queue_append_iov()
147 queue->nq_count++; in qemu_net_queue_append_iov()
148 QTAILQ_INSERT_TAIL(&queue->packets, packet, entry); in qemu_net_queue_append_iov()
151 static ssize_t qemu_net_queue_deliver(NetQueue *queue, in qemu_net_queue_deliver() argument
163 queue->delivering = 1; in qemu_net_queue_deliver()
164 ret = queue->deliver(sender, flags, &iov, 1, queue->opaque); in qemu_net_queue_deliver()
165 queue->delivering = 0; in qemu_net_queue_deliver()
170 static ssize_t qemu_net_queue_deliver_iov(NetQueue *queue, in qemu_net_queue_deliver_iov() argument
178 queue->delivering = 1; in qemu_net_queue_deliver_iov()
179 ret = queue->deliver(sender, flags, iov, iovcnt, queue->opaque); in qemu_net_queue_deliver_iov()
180 queue->delivering = 0; in qemu_net_queue_deliver_iov()
185 ssize_t qemu_net_queue_receive(NetQueue *queue, in qemu_net_queue_receive() argument
189 if (queue->delivering) { in qemu_net_queue_receive()
193 return qemu_net_queue_deliver(queue, NULL, 0, data, size); in qemu_net_queue_receive()
196 ssize_t qemu_net_queue_send(NetQueue *queue, in qemu_net_queue_send() argument
205 if (queue->delivering || !qemu_can_send_packet(sender)) { in qemu_net_queue_send()
206 qemu_net_queue_append(queue, sender, flags, data, size, sent_cb); in qemu_net_queue_send()
210 ret = qemu_net_queue_deliver(queue, sender, flags, data, size); in qemu_net_queue_send()
212 qemu_net_queue_append(queue, sender, flags, data, size, sent_cb); in qemu_net_queue_send()
216 qemu_net_queue_flush(queue); in qemu_net_queue_send()
221 ssize_t qemu_net_queue_send_iov(NetQueue *queue, in qemu_net_queue_send_iov() argument
230 if (queue->delivering || !qemu_can_send_packet(sender)) { in qemu_net_queue_send_iov()
231 qemu_net_queue_append_iov(queue, sender, flags, iov, iovcnt, sent_cb); in qemu_net_queue_send_iov()
235 ret = qemu_net_queue_deliver_iov(queue, sender, flags, iov, iovcnt); in qemu_net_queue_send_iov()
237 qemu_net_queue_append_iov(queue, sender, flags, iov, iovcnt, sent_cb); in qemu_net_queue_send_iov()
241 qemu_net_queue_flush(queue); in qemu_net_queue_send_iov()
246 void qemu_net_queue_purge(NetQueue *queue, NetClientState *from) in qemu_net_queue_purge() argument
250 QTAILQ_FOREACH_SAFE(packet, &queue->packets, entry, next) { in qemu_net_queue_purge()
252 QTAILQ_REMOVE(&queue->packets, packet, entry); in qemu_net_queue_purge()
253 queue->nq_count--; in qemu_net_queue_purge()
262 bool qemu_net_queue_flush(NetQueue *queue) in qemu_net_queue_flush() argument
264 if (queue->delivering) in qemu_net_queue_flush()
267 while (!QTAILQ_EMPTY(&queue->packets)) { in qemu_net_queue_flush()
271 packet = QTAILQ_FIRST(&queue->packets); in qemu_net_queue_flush()
272 QTAILQ_REMOVE(&queue->packets, packet, entry); in qemu_net_queue_flush()
273 queue->nq_count--; in qemu_net_queue_flush()
275 ret = qemu_net_queue_deliver(queue, in qemu_net_queue_flush()
281 queue->nq_count++; in qemu_net_queue_flush()
282 QTAILQ_INSERT_HEAD(&queue->packets, packet, entry); in qemu_net_queue_flush()