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。

相关文章

线上Java OOM问题定位与解决方案超详细解析

线上Java OOM问题定位与解决方案超详细解析

《线上JavaOOM问题定位与解决方案超详细解析》OOM是JVM抛出的错误,表示内存分配失败,：本文主要介绍线上JavaOOM问题定位与解决方案的相关资料,文中通过代码介绍的非常详细,需要的朋... 目录一、OOM问题核心认知1.1 OOM定义与技术定位1.2 OOM常见类型及技术特征二、OOM问题定位工具
阅读更多...
深度解析Python中递归下降解析器的原理与实现

深度解析Python中递归下降解析器的原理与实现

《深度解析Python中递归下降解析器的原理与实现》在编译器设计、配置文件处理和数据转换领域,递归下降解析器是最常用且最直观的解析技术,本文将详细介绍递归下降解析器的原理与实现,感兴趣的小伙伴可以跟随... 目录引言：解析器的核心价值一、递归下降解析器基础1.1 核心概念解析1.2 基本架构二、简单算术表达
阅读更多...
深度解析Java @Serial 注解及常见错误案例

深度解析Java @Serial 注解及常见错误案例

《深度解析Java@Serial注解及常见错误案例》Java14引入@Serial注解,用于编译时校验序列化成员,替代传统方式解决运行时错误,适用于Serializable类的方法/字段,需注意签... 目录Java @Serial 注解深度解析1. 注解本质2. 核心作用(1) 主要用途(2) 适用位置3
阅读更多...
Java MCP 的鉴权深度解析

Java MCP 的鉴权深度解析

《JavaMCP的鉴权深度解析》文章介绍JavaMCP鉴权的实现方式,指出客户端可通过queryString、header或env传递鉴权信息,服务器端支持工具单独鉴权、过滤器集中鉴权及启动时鉴权... 目录一、MCP Client 侧（负责传递，比较简单）（1）常见的 mcpServers json 配置
阅读更多...
从原理到实战解析Java Stream 的并行流性能优化

从原理到实战解析Java Stream 的并行流性能优化

《从原理到实战解析JavaStream的并行流性能优化》本文给大家介绍JavaStream的并行流性能优化：从原理到实战的全攻略,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的... 目录一、并行流的核心原理与适用场景二、性能优化的核心策略1. 合理设置并行度：打破默认阈值2. 避免装箱
阅读更多...
Maven中生命周期深度解析与实战指南

Maven中生命周期深度解析与实战指南

《Maven中生命周期深度解析与实战指南》这篇文章主要为大家详细介绍了Maven生命周期实战指南,包含核心概念、阶段详解、SpringBoot特化场景及企业级实践建议,希望对大家有一定的帮助... 目录一、Maven 生命周期哲学二、default生命周期核心阶段详解（高频使用）三、clean生命周期核心阶
阅读更多...
深入解析C++ 中std::map内存管理

深入解析C++ 中std::map内存管理

《深入解析C++中std::map内存管理》文章详解C++std::map内存管理,指出clear()仅删除元素可能不释放底层内存,建议用swap()与空map交换以彻底释放,针对指针类型需手动de... 目录1️、基本清空std::map2️、使用 swap 彻底释放内存3️、map 中存储指针类型的对象
阅读更多...
Java Scanner类解析与实战教程

Java Scanner类解析与实战教程

《JavaScanner类解析与实战教程》JavaScanner类（java.util包）是文本输入解析工具,支持基本类型和字符串读取,基于Readable接口与正则分隔符实现,适用于控制台、文件输... 目录一、核心设计与工作原理1.底层依赖2.解析机制A.核心逻辑基于分隔符（delimiter）和模式匹
阅读更多...
Java+AI驱动实现PDF文件数据提取与解析

Java+AI驱动实现PDF文件数据提取与解析

《Java+AI驱动实现PDF文件数据提取与解析》本文将和大家分享一套基于AI的体检报告智能评估方案,详细介绍从PDF上传、内容提取到AI分析、数据存储的全流程自动化实现方法,感兴趣的可以了解下... 目录一、核心流程：从上传到评估的完整链路二、第一步：解析 PDF，提取体检报告内容1. 引入依赖2. 封装
阅读更多...
深度解析Python yfinance的核心功能和高级用法

深度解析Python yfinance的核心功能和高级用法

《深度解析Pythonyfinance的核心功能和高级用法》yfinance是一个功能强大且易于使用的Python库,用于从YahooFinance获取金融数据,本教程将深入探讨yfinance的核... 目录yfinance 深度解析教程 (python)1. 简介与安装1.1 什么是 yfinance?
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2