From patchwork Tue Oct 5 20:35:57 2010 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Alex Williamson X-Patchwork-Id: 66860 Return-Path: X-Original-To: incoming@patchwork.ozlabs.org Delivered-To: patchwork-incoming@bilbo.ozlabs.org Received: from lists.gnu.org (lists.gnu.org [199.232.76.165]) (using TLSv1 with cipher DHE-RSA-AES256-SHA (256/256 bits)) (Client did not present a certificate) by ozlabs.org (Postfix) with ESMTPS id 21987B70DB for ; Wed, 6 Oct 2010 07:38:18 +1100 (EST) Received: from localhost ([127.0.0.1]:45492 helo=lists.gnu.org) by lists.gnu.org with esmtp (Exim 4.43) id 1P3EGX-0001Fi-RT for incoming@patchwork.ozlabs.org; Tue, 05 Oct 2010 16:37:37 -0400 Received: from [140.186.70.92] (port=59955 helo=eggs.gnu.org) by lists.gnu.org with esmtp (Exim 4.43) id 1P3EF5-0001Ct-DT for qemu-devel@nongnu.org; Tue, 05 Oct 2010 16:36:09 -0400 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1P3EF2-00078D-G2 for qemu-devel@nongnu.org; Tue, 05 Oct 2010 16:36:05 -0400 Received: from mx1.redhat.com ([209.132.183.28]:62957) by eggs.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1P3EF2-000789-89 for qemu-devel@nongnu.org; Tue, 05 Oct 2010 16:36:04 -0400 Received: from int-mx08.intmail.prod.int.phx2.redhat.com (int-mx08.intmail.prod.int.phx2.redhat.com [10.5.11.21]) by mx1.redhat.com (8.13.8/8.13.8) with ESMTP id o95KZwh5002380 (version=TLSv1/SSLv3 cipher=DHE-RSA-AES256-SHA bits=256 verify=OK); Tue, 5 Oct 2010 16:35:58 -0400 Received: from s20.home (ovpn01.gateway.prod.ext.phx2.redhat.com [10.5.9.1]) by int-mx08.intmail.prod.int.phx2.redhat.com (8.13.8/8.13.8) with ESMTP id o95KZvrj031997; Tue, 5 Oct 2010 16:35:58 -0400 From: Alex Williamson To: qemu-devel@nongnu.org Date: Tue, 05 Oct 2010 14:35:57 -0600 Message-ID: <20101005203557.12739.25596.stgit@s20.home> In-Reply-To: <20101005202556.12739.14080.stgit@s20.home> References: <20101005202556.12739.14080.stgit@s20.home> User-Agent: StGIT/0.14.3 MIME-Version: 1.0 X-Scanned-By: MIMEDefang 2.67 on 10.5.11.21 X-detected-operating-system: by eggs.gnu.org: Genre and OS details not recognized. Cc: alex.williamson@redhat.com, cam@cs.ualberta.ca, quintela@redhat.com Subject: [Qemu-devel] [RFC PATCH 5/5] virtio: Allow virtio_save() errors X-BeenThere: qemu-devel@nongnu.org X-Mailman-Version: 2.1.5 Precedence: list List-Id: qemu-devel.nongnu.org List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Sender: qemu-devel-bounces+incoming=patchwork.ozlabs.org@nongnu.org Errors-To: qemu-devel-bounces+incoming=patchwork.ozlabs.org@nongnu.org Carry pci_device_save() error through to virtio_save(). Signed-off-by: Alex Williamson --- hw/virtio-balloon.c | 5 ++++- hw/virtio-blk.c | 5 ++++- hw/virtio-net.c | 5 ++++- hw/virtio-pci.c | 9 +++++++-- hw/virtio-serial-bus.c | 5 ++++- hw/virtio.c | 13 +++++++++---- hw/virtio.h | 4 ++-- 7 files changed, 34 insertions(+), 12 deletions(-) diff --git a/hw/virtio-balloon.c b/hw/virtio-balloon.c index 719e72c..43616ba 100644 --- a/hw/virtio-balloon.c +++ b/hw/virtio-balloon.c @@ -230,8 +230,11 @@ static void virtio_balloon_to_target(void *opaque, ram_addr_t target, static int virtio_balloon_save(QEMUFile *f, void *opaque) { VirtIOBalloon *s = opaque; + int ret; - virtio_save(&s->vdev, f); + if ((ret = virtio_save(&s->vdev, f))) { + return ret; + } qemu_put_be32(f, s->num_pages); qemu_put_be32(f, s->actual); diff --git a/hw/virtio-blk.c b/hw/virtio-blk.c index 3770901..b0fd3d6 100644 --- a/hw/virtio-blk.c +++ b/hw/virtio-blk.c @@ -464,8 +464,11 @@ static int virtio_blk_save(QEMUFile *f, void *opaque) { VirtIOBlock *s = opaque; VirtIOBlockReq *req = s->rq; + int ret; - virtio_save(&s->vdev, f); + if ((ret = virtio_save(&s->vdev, f))) { + return ret; + } while (req) { qemu_put_sbyte(f, 1); diff --git a/hw/virtio-net.c b/hw/virtio-net.c index 1b683d9..1cb201d 100644 --- a/hw/virtio-net.c +++ b/hw/virtio-net.c @@ -782,6 +782,7 @@ static void virtio_net_tx_bh(void *opaque) static int virtio_net_save(QEMUFile *f, void *opaque) { VirtIONet *n = opaque; + int ret; if (n->vhost_started) { /* TODO: should we really stop the backend? @@ -789,7 +790,9 @@ static int virtio_net_save(QEMUFile *f, void *opaque) vhost_net_stop(tap_get_vhost_net(n->nic->nc.peer), &n->vdev); n->vhost_started = 0; } - virtio_save(&n->vdev, f); + if ((ret = virtio_save(&n->vdev, f))) { + return ret; + } qemu_put_buffer(f, n->mac, ETH_ALEN); qemu_put_be32(f, n->tx_waiting); diff --git a/hw/virtio-pci.c b/hw/virtio-pci.c index 86e6b0a..0cbfc68 100644 --- a/hw/virtio-pci.c +++ b/hw/virtio-pci.c @@ -121,13 +121,18 @@ static void virtio_pci_notify(void *opaque, uint16_t vector) qemu_set_irq(proxy->pci_dev.irq[0], proxy->vdev->isr & 1); } -static void virtio_pci_save_config(void * opaque, QEMUFile *f) +static int virtio_pci_save_config(void * opaque, QEMUFile *f) { VirtIOPCIProxy *proxy = opaque; - pci_device_save(&proxy->pci_dev, f); + int ret; + + if ((ret = pci_device_save(&proxy->pci_dev, f))) { + return ret; + } msix_save(&proxy->pci_dev, f); if (msix_present(&proxy->pci_dev)) qemu_put_be16(f, proxy->vdev->config_vector); + return 0; } static void virtio_pci_save_queue(void * opaque, int n, QEMUFile *f) diff --git a/hw/virtio-serial-bus.c b/hw/virtio-serial-bus.c index 7f00fcf..5f8ab61 100644 --- a/hw/virtio-serial-bus.c +++ b/hw/virtio-serial-bus.c @@ -459,9 +459,12 @@ static int virtio_serial_save(QEMUFile *f, void *opaque) VirtIOSerialPort *port; uint32_t nr_active_ports; unsigned int i; + int ret; /* The virtio device */ - virtio_save(&s->vdev, f); + if ((ret = virtio_save(&s->vdev, f))) { + return ret; + } /* The config space */ qemu_put_be16s(f, &s->config.cols); diff --git a/hw/virtio.c b/hw/virtio.c index fbef788..6e5b997 100644 --- a/hw/virtio.c +++ b/hw/virtio.c @@ -640,12 +640,15 @@ void virtio_notify_config(VirtIODevice *vdev) virtio_notify_vector(vdev, vdev->config_vector); } -void virtio_save(VirtIODevice *vdev, QEMUFile *f) +int virtio_save(VirtIODevice *vdev, QEMUFile *f) { - int i; + int i, ret; - if (vdev->binding->save_config) - vdev->binding->save_config(vdev->binding_opaque, f); + if (vdev->binding->save_config) { + if ((ret = vdev->binding->save_config(vdev->binding_opaque, f))) { + return ret; + } + } qemu_put_8s(f, &vdev->status); qemu_put_8s(f, &vdev->isr); @@ -671,6 +674,8 @@ void virtio_save(VirtIODevice *vdev, QEMUFile *f) if (vdev->binding->save_queue) vdev->binding->save_queue(vdev->binding_opaque, i, f); } + + return 0; } int virtio_load(VirtIODevice *vdev, QEMUFile *f) diff --git a/hw/virtio.h b/hw/virtio.h index 96514e6..5c5da3a 100644 --- a/hw/virtio.h +++ b/hw/virtio.h @@ -88,7 +88,7 @@ typedef struct VirtQueueElement typedef struct { void (*notify)(void * opaque, uint16_t vector); - void (*save_config)(void * opaque, QEMUFile *f); + int (*save_config)(void * opaque, QEMUFile *f); void (*save_queue)(void * opaque, int n, QEMUFile *f); int (*load_config)(void * opaque, QEMUFile *f); int (*load_queue)(void * opaque, int n, QEMUFile *f); @@ -150,7 +150,7 @@ int virtqueue_avail_bytes(VirtQueue *vq, int in_bytes, int out_bytes); void virtio_notify(VirtIODevice *vdev, VirtQueue *vq); -void virtio_save(VirtIODevice *vdev, QEMUFile *f); +int virtio_save(VirtIODevice *vdev, QEMUFile *f); int virtio_load(VirtIODevice *vdev, QEMUFile *f);