samples: drivers: virtualization: add vhost sample

Add vhost sample

Signed-off-by: TOKITA Hiroshi <[email protected]>

Author: soburi

samples/drivers/virtualization/vhost/CMakeLists.txt

@@ -0,0 +1,8 @@
+# SPDX-License-Identifier: Apache-2.0
+
+cmake_minimum_required(VERSION 3.20.0)
+
+find_package(Zephyr REQUIRED HINTS $ENV{ZEPHYR_BASE})
+project(vhost)
+
+target_sources(app PRIVATE src/main.c)

samples/drivers/virtualization/vhost/README.rst

@@ -0,0 +1,22 @@
+.. zephyr:code-sample:: vhost
+   :name: Vhost sample application
+
+Overview
+********
+
+A simple sample that can be used with any :ref:`supported board <boards>` and
+prints "Hello World" to the console.
+
+Building and Running
+********************
+
+This application can be built and executed on QEMU as follows:
+
+.. zephyr-app-commands::
+   :zephyr-app: samples/drivers/virtualization/vhost
+   :host-os: unix
+   :board: xenvm
+   :goals: run
+   :compact:
+
+To build for another board, change "qemu_x86" above to that board's name.

samples/drivers/virtualization/vhost/boards/xenvm.overlay

@@ -0,0 +1,16 @@
+/*
+ * Copyright (c) 2025 TOKITA Hiroshi
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+/ {
+	vhost: xen-vhost-mmio {
+		compatible = "xen,vhost-mmio";
+		device-id = <4>;
+		vendor-id = <0x7a707972>; /* "zphy" */
+		num-queues = <2>;
+		queue-size-max= <16>;
+		base = <0x2000000>;
+	};
+};

samples/drivers/virtualization/vhost/boards/xenvm_xenvm_gicv3.overlay

@@ -0,0 +1,7 @@
+/*
+ * Copyright (c) 2025 TOKITA Hiroshi
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+#include "xenvm.overlay"

samples/drivers/virtualization/vhost/prj.conf

@@ -0,0 +1,4 @@
+CONFIG_VHOST=y
+CONFIG_LOG=y
+CONFIG_HEAP_MEM_POOL_SIZE=1048576
+CONFIG_LOG_MODE_IMMEDIATE=y

samples/drivers/virtualization/vhost/sample.yaml

@@ -0,0 +1,14 @@
+sample:
+  description: VHost sample application
+  name: vhost
+common:
+  integration_platforms:
+    - xenvm
+  harness: console
+  harness_config:
+    type: one_line
+    regex:
+      - "Hello World! (.*)"
+tests:
+  sample.virtualization.vhost:
+    tags: introduction

samples/drivers/virtualization/vhost/src/main.c

@@ -0,0 +1,104 @@
+/*
+ * Copyright (c) 2025 TOKITA Hiroshi
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+#include <zephyr/drivers/vhost.h>
+#include <zephyr/drivers/vhost/vringh.h>
+#include <zephyr/logging/log.h>
+
+LOG_MODULE_REGISTER(vhost);
+
+struct vhost_iovec riovec[16];
+struct vhost_iovec wiovec[16];
+
+struct vringh_iov riov = {
+	.iov = riovec,
+	.max_num = 16,
+};
+
+struct vringh_iov wiov = {
+	.iov = wiovec,
+	.max_num = 16,
+};
+
+struct vringh vrh_inst;
+
+void vringh_handler(struct vringh *vrh)
+{
+	LOG_DBG("%s: queue_id=%lu", __func__, vrh->queue_id);
+	uint16_t head;
+
+	while (true) {
+		int ret = vringh_getdesc(vrh, &riov, &wiov, &head);
+
+		if (ret < 0) {
+			LOG_ERR("vringh_getdesc failed: %d", ret);
+			return;
+		}
+
+		if (ret == 0) {
+			return;
+		}
+
+		/* Process writable iovecs */
+		for (uint32_t s = 0; s < wiov.used; s++) {
+			uint8_t *dst = wiov.iov[s].iov_base;
+			uint32_t len = wiov.iov[s].iov_len;
+
+			LOG_DBG("%s: addr=%p len=%u", __func__, dst, len);
+
+			for (uint32_t i = 0; i < len; i++) {
+				sys_write8(i, (mem_addr_t)&dst[i]);
+			}
+		}
+
+		barrier_dmem_fence_full();
+
+		uint32_t total_len = 0;
+		for (uint32_t i = 0; i < wiov.used; i++) {
+			total_len += wiov.iov[i].iov_len;
+		}
+
+		vringh_complete(vrh, head, total_len);
+
+		if (vringh_need_notify(vrh) > 0) {
+			vringh_notify(vrh);
+		}
+
+		/* Reset iovecs for next iteration */
+		vringh_iov_reset(&riov);
+		vringh_iov_reset(&wiov);
+	}
+}
+
+void queue_ready_handler(const struct device *dev, uint16_t qid, void *data)
+{
+	LOG_DBG("%s(dev=%p, qid=%u, data=%p)", __func__, dev, qid, data);
+
+	/* Initialize iovecs before descriptor processing */
+	vringh_iov_init(&riov, riov.iov, riov.max_num);
+	vringh_iov_init(&wiov, wiov.iov, wiov.max_num);
+
+	int err = vringh_init_device(&vrh_inst, dev, qid, vringh_handler);
+	if (err) {
+		LOG_ERR("vringh_init_device failed: %d", err);
+		return;
+	}
+}
+
+int main(void)
+{
+	const struct device *device = DEVICE_DT_GET(DT_NODELABEL(vhost));
+
+	if (!device_is_ready(device)) {
+		LOG_ERR("VHost device not ready");
+		return -ENODEV;
+	}
+
+	vhost_set_ready_callback(device, queue_ready_handler, (void *)device);
+
+	k_sleep(K_FOREVER);
+	return 0;
+}