From nobody Mon Feb 9 13:59:08 2026 Delivered-To: importer@patchew.org Received-SPF: pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) client-ip=208.118.235.17; envelope-from=qemu-devel-bounces+importer=patchew.org@nongnu.org; helo=lists.gnu.org; Authentication-Results: mx.zohomail.com; dkim=fail; spf=pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) smtp.mailfrom=qemu-devel-bounces+importer=patchew.org@nongnu.org; dmarc=fail(p=none dis=none) header.from=redhat.com Return-Path: Received: from lists.gnu.org (lists.gnu.org [208.118.235.17]) by mx.zohomail.com with SMTPS id 1539898899105334.4708309991055; Thu, 18 Oct 2018 14:41:39 -0700 (PDT) Received: from localhost ([::1]:44909 helo=lists.gnu.org) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1gDG2t-0008Ak-Tu for importer@patchew.org; Thu, 18 Oct 2018 17:41:31 -0400 Received: from eggs.gnu.org ([2001:4830:134:3::10]:48561) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1gDEyr-0008DL-R4 for qemu-devel@nongnu.org; Thu, 18 Oct 2018 16:33:21 -0400 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1gDEyk-0006jH-Et for qemu-devel@nongnu.org; Thu, 18 Oct 2018 16:33:12 -0400 Received: from mail-wr1-x441.google.com ([2a00:1450:4864:20::441]:43362) by eggs.gnu.org with esmtps (TLS1.0:RSA_AES_128_CBC_SHA1:16) (Exim 4.71) (envelope-from ) id 1gDEyi-0006ha-Tj for qemu-devel@nongnu.org; Thu, 18 Oct 2018 16:33:10 -0400 Received: by mail-wr1-x441.google.com with SMTP id n1-v6so35103031wrt.10 for ; Thu, 18 Oct 2018 13:33:08 -0700 (PDT) Received: from 640k.lan (dynamic-adsl-78-12-231-174.clienti.tiscali.it. [78.12.231.174]) by smtp.gmail.com with ESMTPSA id a12-v6sm14270952wrr.71.2018.10.18.13.33.06 (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Thu, 18 Oct 2018 13:33:06 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=sender:from:to:cc:subject:date:message-id:in-reply-to:references; bh=lXeiB6ekUojRAKLq4p+caxXDfC0SpFZfyJvsQ6gzZwU=; b=Czwm+ict6lMk3Es4dE9yye85plimZzflBpwL4y2Mlcv/iIGNNVGgqg3oOF9hIXbczB i0LuR5U2oFtbcZTPnMudccvSBLCDv6FC8Qf6x0Y8S6IFjls6uaVC1WMLK2NrXJegiTtq LeQTREYPW8EmH+YJSHu6/1Gbem2UPJs/ENLVW5nONvOHiwjAgYmL6RUmBJa1FMhtiSFN Btmy+QoTExx04P9Qt6FxqGkjOPvPyU5Q/ptKV94r82MKkcvGejKELJ+QcnsyX+gPHEaB xF6Ao4uFSd6WCn5WZqFtCXsq/TWRbh6W27pnR4QT76/kxxnhmnw37FdVhOqK9U9mHexl uVWQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:sender:from:to:cc:subject:date:message-id :in-reply-to:references; bh=lXeiB6ekUojRAKLq4p+caxXDfC0SpFZfyJvsQ6gzZwU=; b=KAV4XMZcxIVTdUsGKZtM7t9dXHz5WObwn8mHl2lW7J4TrR+W85wdn7OSIEcerxb5x8 FFp5F+ANZbANGTowihsdfx3Rx8/i7wO74x/pUPF8P3Au1oi8jFC+NUtVXz99hignoZsJ lDQRyCu2OD8gkENtplztdFaBTRyMnYLZ0l3DhV4Hiezt2Kv+5jMt5cx4HHgsnSMPO9u8 QT40vFS0k9YDoHSZwbBZMS0hCEacAxjHtRfsWIayyH6cnSwAOnIM7wf0hXIdlqnqkOiU bhHuwjvOJlwnkJ95U92vFz7VFW2/nZsJnk1VDjgawUrndqtPGbV2A0yv6miMKyLqmaEv 0xZQ== X-Gm-Message-State: ABuFfogkmol7vVJgVuEBfQAxuaLpNXmfNVIKEZHLo1voG4TopiES909e pLpIMfRyV18k/3dCCMmxOXrO7D/n X-Google-Smtp-Source: ACcGV61xuXPLYC+WMOVAtsaC7u+35fefXqxxZ9ZQA82vqOChiKGS33H/OMyhyKVuNHmA+0FBal7I3Q== X-Received: by 2002:adf:91a4:: with SMTP id 33-v6mr30398269wri.37.1539894787541; Thu, 18 Oct 2018 13:33:07 -0700 (PDT) From: Paolo Bonzini To: qemu-devel@nongnu.org Date: Thu, 18 Oct 2018 22:32:13 +0200 Message-Id: <1539894735-14232-47-git-send-email-pbonzini@redhat.com> X-Mailer: git-send-email 1.8.3.1 In-Reply-To: <1539894735-14232-1-git-send-email-pbonzini@redhat.com> References: <1539894735-14232-1-git-send-email-pbonzini@redhat.com> X-detected-operating-system: by eggs.gnu.org: Genre and OS details not recognized. X-Received-From: 2a00:1450:4864:20::441 Subject: [Qemu-devel] [PULL 46/48] hyperv_testdev: add SynIC message and event testmodes X-BeenThere: qemu-devel@nongnu.org X-Mailman-Version: 2.1.21 Precedence: list List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Cc: Roman Kagan Errors-To: qemu-devel-bounces+importer=patchew.org@nongnu.org Sender: "Qemu-devel" X-ZohoMail-DKIM: fail (Header signature does not verify) X-ZohoMail: RDMRC_1 RDKM_2 RSF_0 Z_629925259 SPT_0 Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" From: Roman Kagan Add testmodes for SynIC messages and events. The message or event connection setup / teardown is initiated by the guest via new control codes written to the test device port. Then the test connections bounce the respective operations back to the guest, i.e. the incoming messages are posted or the incoming events are signaled on the configured vCPUs. Signed-off-by: Roman Kagan Signed-off-by: Paolo Bonzini --- hw/hyperv/hyperv_testdev.c | 165 +++++++++++++++++++++++++++++++++++++++++= +++- 1 file changed, 164 insertions(+), 1 deletion(-) diff --git a/hw/hyperv/hyperv_testdev.c b/hw/hyperv/hyperv_testdev.c index fc3f6c5..4880333 100644 --- a/hw/hyperv/hyperv_testdev.c +++ b/hw/hyperv/hyperv_testdev.c @@ -12,6 +12,7 @@ */ =20 #include "qemu/osdep.h" +#include "qemu/main-loop.h" #include "qemu/queue.h" #include "hw/qdev.h" #include "hw/isa/isa.h" @@ -24,10 +25,26 @@ typedef struct TestSintRoute { HvSintRoute *sint_route; } TestSintRoute; =20 +typedef struct TestMsgConn { + QLIST_ENTRY(TestMsgConn) le; + uint8_t conn_id; + HvSintRoute *sint_route; + struct hyperv_message msg; +} TestMsgConn; + +typedef struct TestEvtConn { + QLIST_ENTRY(TestEvtConn) le; + uint8_t conn_id; + HvSintRoute *sint_route; + EventNotifier notifier; +} TestEvtConn; + struct HypervTestDev { ISADevice parent_obj; MemoryRegion sint_control; QLIST_HEAD(, TestSintRoute) sint_routes; + QLIST_HEAD(, TestMsgConn) msg_conns; + QLIST_HEAD(, TestEvtConn) evt_conns; }; typedef struct HypervTestDev HypervTestDev; =20 @@ -38,7 +55,11 @@ typedef struct HypervTestDev HypervTestDev; enum { HV_TEST_DEV_SINT_ROUTE_CREATE =3D 1, HV_TEST_DEV_SINT_ROUTE_DESTROY, - HV_TEST_DEV_SINT_ROUTE_SET_SINT + HV_TEST_DEV_SINT_ROUTE_SET_SINT, + HV_TEST_DEV_MSG_CONN_CREATE, + HV_TEST_DEV_MSG_CONN_DESTROY, + HV_TEST_DEV_EVT_CONN_CREATE, + HV_TEST_DEV_EVT_CONN_DESTROY, }; =20 static void sint_route_create(HypervTestDev *dev, @@ -93,6 +114,133 @@ static void sint_route_set_sint(HypervTestDev *dev, hyperv_sint_route_set_sint(sint_route->sint_route); } =20 +static void msg_retry(void *opaque) +{ + TestMsgConn *conn =3D opaque; + assert(!hyperv_post_msg(conn->sint_route, &conn->msg)); +} + +static void msg_cb(void *data, int status) +{ + TestMsgConn *conn =3D data; + + if (!status) { + return; + } + + assert(status =3D=3D -EAGAIN); + + aio_bh_schedule_oneshot(qemu_get_aio_context(), msg_retry, conn); +} + +static uint16_t msg_handler(const struct hyperv_post_message_input *msg, + void *data) +{ + int ret; + TestMsgConn *conn =3D data; + + /* post the same message we've got */ + conn->msg.header.message_type =3D msg->message_type; + assert(msg->payload_size < sizeof(conn->msg.payload)); + conn->msg.header.payload_size =3D msg->payload_size; + memcpy(&conn->msg.payload, msg->payload, msg->payload_size); + + ret =3D hyperv_post_msg(conn->sint_route, &conn->msg); + + switch (ret) { + case 0: + return HV_STATUS_SUCCESS; + case -EAGAIN: + return HV_STATUS_INSUFFICIENT_BUFFERS; + default: + return HV_STATUS_INVALID_HYPERCALL_INPUT; + } +} + +static void msg_conn_create(HypervTestDev *dev, uint8_t vp_index, + uint8_t sint, uint8_t conn_id) +{ + TestMsgConn *conn; + + conn =3D g_new0(TestMsgConn, 1); + assert(conn); + + conn->conn_id =3D conn_id; + + conn->sint_route =3D hyperv_sint_route_new(vp_index, sint, msg_cb, con= n); + assert(conn->sint_route); + + assert(!hyperv_set_msg_handler(conn->conn_id, msg_handler, conn)); + + QLIST_INSERT_HEAD(&dev->msg_conns, conn, le); +} + +static void msg_conn_destroy(HypervTestDev *dev, uint8_t conn_id) +{ + TestMsgConn *conn; + + QLIST_FOREACH(conn, &dev->msg_conns, le) { + if (conn->conn_id =3D=3D conn_id) { + QLIST_REMOVE(conn, le); + hyperv_set_msg_handler(conn->conn_id, NULL, NULL); + hyperv_sint_route_unref(conn->sint_route); + g_free(conn); + return; + } + } + assert(false); +} + +static void evt_conn_handler(EventNotifier *notifier) +{ + TestEvtConn *conn =3D container_of(notifier, TestEvtConn, notifier); + + event_notifier_test_and_clear(notifier); + + /* signal the same event flag we've got */ + assert(!hyperv_set_event_flag(conn->sint_route, conn->conn_id)); +} + +static void evt_conn_create(HypervTestDev *dev, uint8_t vp_index, + uint8_t sint, uint8_t conn_id) +{ + TestEvtConn *conn; + + conn =3D g_new0(TestEvtConn, 1); + assert(conn); + + conn->conn_id =3D conn_id; + + conn->sint_route =3D hyperv_sint_route_new(vp_index, sint, NULL, NULL); + assert(conn->sint_route); + + assert(!event_notifier_init(&conn->notifier, false)); + + event_notifier_set_handler(&conn->notifier, evt_conn_handler); + + assert(!hyperv_set_event_flag_handler(conn_id, &conn->notifier)); + + QLIST_INSERT_HEAD(&dev->evt_conns, conn, le); +} + +static void evt_conn_destroy(HypervTestDev *dev, uint8_t conn_id) +{ + TestEvtConn *conn; + + QLIST_FOREACH(conn, &dev->evt_conns, le) { + if (conn->conn_id =3D=3D conn_id) { + QLIST_REMOVE(conn, le); + hyperv_set_event_flag_handler(conn->conn_id, NULL); + event_notifier_set_handler(&conn->notifier, NULL); + event_notifier_cleanup(&conn->notifier); + hyperv_sint_route_unref(conn->sint_route); + g_free(conn); + return; + } + } + assert(false); +} + static uint64_t hv_test_dev_read(void *opaque, hwaddr addr, unsigned size) { return 0; @@ -105,6 +253,7 @@ static void hv_test_dev_write(void *opaque, hwaddr addr= , uint64_t data, uint8_t sint =3D data & 0xFF; uint8_t vp_index =3D (data >> 8ULL) & 0xFF; uint8_t ctl =3D (data >> 16ULL) & 0xFF; + uint8_t conn_id =3D (data >> 24ULL) & 0xFF; =20 switch (ctl) { case HV_TEST_DEV_SINT_ROUTE_CREATE: @@ -116,6 +265,18 @@ static void hv_test_dev_write(void *opaque, hwaddr add= r, uint64_t data, case HV_TEST_DEV_SINT_ROUTE_SET_SINT: sint_route_set_sint(dev, vp_index, sint); break; + case HV_TEST_DEV_MSG_CONN_CREATE: + msg_conn_create(dev, vp_index, sint, conn_id); + break; + case HV_TEST_DEV_MSG_CONN_DESTROY: + msg_conn_destroy(dev, conn_id); + break; + case HV_TEST_DEV_EVT_CONN_CREATE: + evt_conn_create(dev, vp_index, sint, conn_id); + break; + case HV_TEST_DEV_EVT_CONN_DESTROY: + evt_conn_destroy(dev, conn_id); + break; default: break; } @@ -136,6 +297,8 @@ static void hv_test_dev_realizefn(DeviceState *d, Error= **errp) MemoryRegion *io =3D isa_address_space_io(isa); =20 QLIST_INIT(&dev->sint_routes); + QLIST_INIT(&dev->msg_conns); + QLIST_INIT(&dev->evt_conns); memory_region_init_io(&dev->sint_control, OBJECT(dev), &synic_test_sint_ops, dev, "hyperv-testdev-ctl", 4); --=20 1.8.3.1