Searched refs:incoming_queue (Results 1 – 7 of 7) sorted by relevance
| /qemu/net/ |
| H A D | filter-buffer.c | 26 NetQueue *incoming_queue; member
35 if (!qemu_net_queue_flush(s->incoming_queue)) { in filter_buffer_flush()
37 qemu_net_queue_purge(s->incoming_queue, nf->netdev); in filter_buffer_flush()
82 qemu_net_queue_append_iov(s->incoming_queue, sender, flags, in filter_buffer_receive_iov()
96 if (s->incoming_queue) { in filter_buffer_cleanup()
98 g_free(s->incoming_queue); in filter_buffer_cleanup()
129 s->incoming_queue = qemu_new_net_queue(qemu_netfilter_pass_to_next, nf); in filter_buffer_setup()
|
| H A D | filter-rewriter.c | 34 NetQueue *incoming_queue; member
50 if (!qemu_net_queue_flush(s->incoming_queue)) { in filter_rewriter_flush()
52 qemu_net_queue_purge(s->incoming_queue, nf->netdev); in filter_rewriter_flush()
297 qemu_net_queue_send(s->incoming_queue, sender, 0, in colo_rewriter_receive_iov()
310 qemu_net_queue_send(s->incoming_queue, sender, 0, in colo_rewriter_receive_iov()
371 if (s->incoming_queue) { in colo_rewriter_cleanup()
373 g_free(s->incoming_queue); in colo_rewriter_cleanup()
387 s->incoming_queue = qemu_new_net_queue(qemu_netfilter_pass_to_next, nf); in colo_rewriter_setup()
|
| H A D | net.c | 286 nc->incoming_queue = qemu_new_net_queue(qemu_deliver_packet_iov, nc); in qemu_net_client_setup()
395 if (nc->incoming_queue) { in qemu_free_net_client()
396 qemu_del_net_queue(nc->incoming_queue); in qemu_free_net_client()
668 qemu_net_queue_purge(nc->peer->incoming_queue, nc); in qemu_purge_queued_packets()
680 if (qemu_net_queue_flush(nc->incoming_queue)) { in qemu_flush_or_purge_queued_packets()
687 qemu_net_queue_purge(nc->incoming_queue, nc->peer); in qemu_flush_or_purge_queued_packets()
726 queue = sender->peer->incoming_queue; in qemu_send_packet_async_with_flags()
750 return qemu_net_queue_receive(nc->incoming_queue, buf, size); in qemu_receive_packet()
760 return qemu_net_queue_receive_iov(nc->incoming_queue, iov, iovcnt); in qemu_receive_packet_iov()
879 queue = sender->peer->incoming_queue; in qemu_sendv_packet_async()
|
| H A D | hub.c | 343 ret += qemu_net_queue_flush(port->nc.incoming_queue); in net_hub_flush()
|
| H A D | filter.c | 113 qemu_net_queue_send_iov(sender->peer->incoming_queue, in qemu_netfilter_pass_to_next()
|
| /qemu/include/net/ |
| H A D | net.h | 102 NetQueue *incoming_queue; member
|
| /qemu/hw/net/ |
| H A D | virtio-net.c | 295 qemu_net_queue_purge(qnc->peer->incoming_queue, qnc); in virtio_net_vhost_status()
296 qemu_net_queue_purge(qnc->incoming_queue, qnc->peer); in virtio_net_vhost_status()
|