QEMU源码全解析 —— virtio(12)

2023-12-19 08:01
文章标签 源码 解析 qemu virtio

本文主要是介绍QEMU源码全解析 —— virtio(12),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

接前一篇文章:

上一回对于virtio_device_realize函数进行了详细解析。在第2步中virtio_device_realize函数调用了具体类的realize函数,对于virtio balloon设备来说是virtio_balloon_realize函数。本回就来对于virtio_balloon_device_realize函数进行解析。

为了便于理解,再次贴出virtio_device_realize函数源码,在hw/virtio/virtio.c中,如下:

static void virtio_device_realize(DeviceState *dev, Error **errp)
{VirtIODevice *vdev = VIRTIO_DEVICE(dev);VirtioDeviceClass *vdc = VIRTIO_DEVICE_GET_CLASS(dev);Error *err = NULL;/* Devices should either use vmsd or the load/save methods */assert(!vdc->vmsd || !vdc->load);if (vdc->realize != NULL) {vdc->realize(dev, &err);if (err != NULL) {error_propagate(errp, err);return;}}virtio_bus_device_plugged(vdev, &err);if (err != NULL) {error_propagate(errp, err);vdc->unrealize(dev);return;}vdev->listener.commit = virtio_memory_listener_commit;vdev->listener.name = "virtio";memory_listener_register(&vdev->listener, vdev->dma_as);QTAILQ_INSERT_TAIL(&virtio_list, vdev, next);
}

调用具体类的realize函数的代码片段如下:

    if (vdc->realize != NULL) {vdc->realize(dev, &err);if (err != NULL) {error_propagate(errp, err);return;}}

virtio_balloon_device_realize函数在hw/virtio/virtio-balloon.c中,代码如下:

static void virtio_balloon_device_realize(DeviceState *dev, Error **errp)
{VirtIODevice *vdev = VIRTIO_DEVICE(dev);VirtIOBalloon *s = VIRTIO_BALLOON(dev);int ret;virtio_init(vdev, VIRTIO_ID_BALLOON, virtio_balloon_config_size(s));ret = qemu_add_balloon_handler(virtio_balloon_to_target,virtio_balloon_stat, s);if (ret < 0) {error_setg(errp, "Only one balloon device is supported");virtio_cleanup(vdev);return;}if (virtio_has_feature(s->host_features, VIRTIO_BALLOON_F_FREE_PAGE_HINT) &&!s->iothread) {error_setg(errp, "'free-page-hint' requires 'iothread' to be set");virtio_cleanup(vdev);return;}s->ivq = virtio_add_queue(vdev, 128, virtio_balloon_handle_output);s->dvq = virtio_add_queue(vdev, 128, virtio_balloon_handle_output);s->svq = virtio_add_queue(vdev, 128, virtio_balloon_receive_stats);if (virtio_has_feature(s->host_features, VIRTIO_BALLOON_F_FREE_PAGE_HINT)) {s->free_page_vq = virtio_add_queue(vdev, VIRTQUEUE_MAX_SIZE,virtio_balloon_handle_free_page_vq);precopy_add_notifier(&s->free_page_hint_notify);object_ref(OBJECT(s->iothread));s->free_page_bh = aio_bh_new_guarded(iothread_get_aio_context(s->iothread),virtio_ballloon_get_free_page_hints, s,&dev->mem_reentrancy_guard);}if (virtio_has_feature(s->host_features, VIRTIO_BALLOON_F_REPORTING)) {s->reporting_vq = virtio_add_queue(vdev, 32,virtio_balloon_handle_report);}reset_stats(s);
}

在同文件(hw/virtio/virtio-balloon.c)的virtio_balloon_class_init函数中,将virtio_balloon_device_realize函数(地址)赋给了vdc->realize。

static void virtio_balloon_class_init(ObjectClass *klass, void *data)
{DeviceClass *dc = DEVICE_CLASS(klass);VirtioDeviceClass *vdc = VIRTIO_DEVICE_CLASS(klass);device_class_set_props(dc, virtio_balloon_properties);dc->vmsd = &vmstate_virtio_balloon;set_bit(DEVICE_CATEGORY_MISC, dc->categories);vdc->realize = virtio_balloon_device_realize;vdc->unrealize = virtio_balloon_device_unrealize;vdc->reset = virtio_balloon_device_reset;vdc->get_config = virtio_balloon_get_config;vdc->set_config = virtio_balloon_set_config;vdc->get_features = virtio_balloon_get_features;vdc->set_status = virtio_balloon_set_status;vdc->vmsd = &vmstate_virtio_balloon_device;
}

virtio_balloon_device_realize()是virtio balloon设备的具现化函数,它用于实现TYPE_VIRTIO_BALLOON_DEVICE的具现化。

(1)virtio_balloon_device_realize函数首先调用virtio_init函数初始化virtio设备的公共部分。代码片段如下:

    virtio_init(vdev, VIRTIO_ID_BALLOON, virtio_balloon_config_size(s));

virtio_init函数在hw/virtio/virtio.c中,代码如下:

void virtio_init(VirtIODevice *vdev, uint16_t device_id, size_t config_size)
{BusState *qbus = qdev_get_parent_bus(DEVICE(vdev));VirtioBusClass *k = VIRTIO_BUS_GET_CLASS(qbus);int i;int nvectors = k->query_nvectors ? k->query_nvectors(qbus->parent) : 0;if (nvectors) {vdev->vector_queues =g_malloc0(sizeof(*vdev->vector_queues) * nvectors);}vdev->start_on_kick = false;vdev->started = false;vdev->vhost_started = false;vdev->device_id = device_id;vdev->status = 0;qatomic_set(&vdev->isr, 0);vdev->queue_sel = 0;vdev->config_vector = VIRTIO_NO_VECTOR;vdev->vq = g_new0(VirtQueue, VIRTIO_QUEUE_MAX);vdev->vm_running = runstate_is_running();vdev->broken = false;for (i = 0; i < VIRTIO_QUEUE_MAX; i++) {vdev->vq[i].vector = VIRTIO_NO_VECTOR;vdev->vq[i].vdev = vdev;vdev->vq[i].queue_index = i;vdev->vq[i].host_notifier_enabled = false;}vdev->name = virtio_id_to_name(device_id);vdev->config_len = config_size;if (vdev->config_len) {vdev->config = g_malloc0(config_size);} else {vdev->config = NULL;}vdev->vmstate = qdev_add_vm_change_state_handler(DEVICE(vdev),virtio_vmstate_change, vdev);vdev->device_endian = virtio_default_endian();vdev->use_guest_notifier_mask = true;
}

virtio_init函数的工作是初始化所有virtio设备的基类TYPE_VIRTIO_DEVICE的实例VirtIODevice结构体,其对VirtIODevice的成员进行初始化。

VirtIODevice的vector_queues成员和config_vector成员与MSI中断相关;device_id、status、name成员分别表示设备的id、状态和名字;isr成员用来表示中断请求;queue_sel成员用来在进行配置队列的时候选择队列;vq成员表示的是该设备的virtio queue,这里分配了VIRTIO_QUEUE_MAX个queue,并且进行了初始化;config_len和config分别表示该virtio设备配置空间的长度和数据存放区域;use_guest_notifier_mask成员与irqfd有关。

回到virtio_balloon_device_realize函数。

(2)在virtio_init函数初始化了VirtIODevice之后,调用virtio_add_queue函数创建了3个virtqueue。代码片段如下:

    s->ivq = virtio_add_queue(vdev, 128, virtio_balloon_handle_output);s->dvq = virtio_add_queue(vdev, 128, virtio_balloon_handle_output);s->svq = virtio_add_queue(vdev, 128, virtio_balloon_receive_stats);

virtqueue是virtio设备的重要组成部分,用来与虚拟机中的操作系统进行数据传输。virtio_add_queue函数在hw/virtio/virtio.c中,代码如下:

VirtQueue *virtio_add_queue(VirtIODevice *vdev, int queue_size,VirtIOHandleOutput handle_output)
{int i;for (i = 0; i < VIRTIO_QUEUE_MAX; i++) {if (vdev->vq[i].vring.num == 0)break;}if (i == VIRTIO_QUEUE_MAX || queue_size > VIRTQUEUE_MAX_SIZE)abort();vdev->vq[i].vring.num = queue_size;vdev->vq[i].vring.num_default = queue_size;vdev->vq[i].vring.align = VIRTIO_PCI_VRING_ALIGN;vdev->vq[i].handle_output = handle_output;vdev->vq[i].used_elems = g_new0(VirtQueueElement, queue_size);return &vdev->vq[i];
}

virtio_add_queue函数是virtio框架中用来添加virtqueue的接口,其3个参数分别表示要添加的设备(VirtIODevice *vdev)、virtqueue的大小(int queue_size)以及处理函数(VirtIOHandleOutput handle_output)。

virtio_add_queue函数从VirtIODevice的vq数组成员中找到还未被使用的一个queue。一个virtqueue使用VirtQueue结构表示,这里对VirtQueue的成员进行初始化,包括这个queue的大小以及对齐等信息。最重要的是设置VirtQueue的handle_output成员,其是一个函数指针,在收到虚拟机发过来的IO请求时,会调用存放在handle_output中的回调函数。

VirtQueue结构的定义在hw/virtio/virtio.c中,如下:

struct VirtQueue
{VRing vring;VirtQueueElement *used_elems;/* Next head to pop */uint16_t last_avail_idx;bool last_avail_wrap_counter;/* Last avail_idx read from VQ. */uint16_t shadow_avail_idx;bool shadow_avail_wrap_counter;uint16_t used_idx;bool used_wrap_counter;/* Last used index value we have signalled on */uint16_t signalled_used;/* Last used index value we have signalled on */bool signalled_used_valid;/* Notification enabled? */bool notification;uint16_t queue_index;unsigned int inuse;uint16_t vector;VirtIOHandleOutput handle_output;VirtIODevice *vdev;EventNotifier guest_notifier;EventNotifier host_notifier;bool host_notifier_enabled;QLIST_ENTRY(VirtQueue) node;
};

欲知后事如何,且看下回分解。

这篇关于QEMU源码全解析 —— virtio(12)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/511453

相关文章

网页解析 lxml 库--实战

lxml库使用流程 lxml 是 Python 的第三方解析库,完全使用 Python 语言编写,它对 XPath表达式提供了良好的支 持,因此能够了高效地解析 HTML/XML 文档。本节讲解如何通过 lxml 库解析 HTML 文档。 pip install lxml lxm| 库提供了一个 etree 模块,该模块专门用来解析 HTML/XML 文档,下面来介绍一下 lxml 库

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来,一站式有声阅读平台听书系统 🌟&nbsp;开篇:遇见未来,从“智听”开始 在这个快节奏的时代,你是否渴望在忙碌的间隙,找到一片属于自己的宁静角落?是否梦想着能随时随地,沉浸在知识的海洋,或是故事的奇幻世界里?今天,就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统,它正悄悄改变着我们的阅读方式,让未来触手可及! 📚&nbsp;第一站:海量资源,应有尽有 走进“智听

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

Java ArrayList扩容机制 (源码解读)

结论:初始长度为10,若所需长度小于1.5倍原长度,则按照1.5倍扩容。若不够用则按照所需长度扩容。 一. 明确类内部重要变量含义         1:数组默认长度         2:这是一个共享的空数组实例,用于明确创建长度为0时的ArrayList ,比如通过 new ArrayList<>(0),ArrayList 内部的数组 elementData 会指向这个 EMPTY_EL

如何在Visual Studio中调试.NET源码

今天偶然在看别人代码时,发现在他的代码里使用了Any判断List<T>是否为空。 我一般的做法是先判断是否为null,再判断Count。 看了一下Count的源码如下: 1 [__DynamicallyInvokable]2 public int Count3 {4 [__DynamicallyInvokable]5 get

工厂ERP管理系统实现源码(JAVA)

工厂进销存管理系统是一个集采购管理、仓库管理、生产管理和销售管理于一体的综合解决方案。该系统旨在帮助企业优化流程、提高效率、降低成本,并实时掌握各环节的运营状况。 在采购管理方面,系统能够处理采购订单、供应商管理和采购入库等流程,确保采购过程的透明和高效。仓库管理方面,实现库存的精准管理,包括入库、出库、盘点等操作,确保库存数据的准确性和实时性。 生产管理模块则涵盖了生产计划制定、物料需求计划、

OWASP十大安全漏洞解析

OWASP(开放式Web应用程序安全项目)发布的“十大安全漏洞”列表是Web应用程序安全领域的权威指南,它总结了Web应用程序中最常见、最危险的安全隐患。以下是对OWASP十大安全漏洞的详细解析: 1. 注入漏洞(Injection) 描述:攻击者通过在应用程序的输入数据中插入恶意代码,从而控制应用程序的行为。常见的注入类型包括SQL注入、OS命令注入、LDAP注入等。 影响:可能导致数据泄

从状态管理到性能优化:全面解析 Android Compose

文章目录 引言一、Android Compose基本概念1.1 什么是Android Compose?1.2 Compose的优势1.3 如何在项目中使用Compose 二、Compose中的状态管理2.1 状态管理的重要性2.2 Compose中的状态和数据流2.3 使用State和MutableState处理状态2.4 通过ViewModel进行状态管理 三、Compose中的列表和滚动

Spring 源码解读:自定义实现Bean定义的注册与解析

引言 在Spring框架中,Bean的注册与解析是整个依赖注入流程的核心步骤。通过Bean定义,Spring容器知道如何创建、配置和管理每个Bean实例。本篇文章将通过实现一个简化版的Bean定义注册与解析机制,帮助你理解Spring框架背后的设计逻辑。我们还将对比Spring中的BeanDefinition和BeanDefinitionRegistry,以全面掌握Bean注册和解析的核心原理。

CSP 2023 提高级第一轮 CSP-S 2023初试题 完善程序第二题解析 未完

一、题目阅读 (最大值之和)给定整数序列 a0,⋯,an−1,求该序列所有非空连续子序列的最大值之和。上述参数满足 1≤n≤105 和 1≤ai≤108。 一个序列的非空连续子序列可以用两个下标 ll 和 rr(其中0≤l≤r<n0≤l≤r<n)表示,对应的序列为 al,al+1,⋯,ar​。两个非空连续子序列不同,当且仅当下标不同。 例如,当原序列为 [1,2,1,2] 时,要计算子序列 [