vmstate: port ads7846

[qemu.git] / savevm.c

diff --git a/savevm.c b/savevm.c
index fcd8db4f85b7e9a289fd021d51e7f1691916fd08..f4ff1a1db443588a6e94c756f4d193253c4761fe 100644 (file)
--- a/savevm.c
+++ b/savevm.c
@@ -78,11 +78,11 @@
 #include "sysemu.h"
 #include "qemu-timer.h"
 #include "qemu-char.h"
 #include "sysemu.h"
 #include "qemu-timer.h"
 #include "qemu-char.h"

-#include "blockdev.h"

 #include "audio/audio.h"
 #include "migration.h"
 #include "qemu_socket.h"
 #include "qemu-queue.h"
 #include "audio/audio.h"
 #include "migration.h"
 #include "qemu_socket.h"
 #include "qemu-queue.h"

+#include "cpus.h"

 
 #define SELF_ANNOUNCE_ROUNDS 5
 
 
 #define SELF_ANNOUNCE_ROUNDS 5
 


@@ -138,7 +138,7 @@ static void qemu_announce_self_once(void *opaque)
 
     if (--count) {
         /* delay 50ms, 150ms, 250ms, ... */
 
     if (--count) {
         /* delay 50ms, 150ms, 250ms, ... */

-        qemu_mod_timer(timer, qemu_get_clock(rt_clock) +
+        qemu_mod_timer(timer, qemu_get_clock_ms(rt_clock) +

                        50 + (SELF_ANNOUNCE_ROUNDS - count - 1) * 100);
     } else {
            qemu_del_timer(timer);
                        50 + (SELF_ANNOUNCE_ROUNDS - count - 1) * 100);
     } else {
            qemu_del_timer(timer);


@@ -149,7 +149,7 @@ static void qemu_announce_self_once(void *opaque)
 void qemu_announce_self(void)
 {
        static QEMUTimer *timer;
 void qemu_announce_self(void)
 {
        static QEMUTimer *timer;

-       timer = qemu_new_timer(rt_clock, qemu_announce_self_once, &timer);
+       timer = qemu_new_timer_ms(rt_clock, qemu_announce_self_once, &timer);

        qemu_announce_self_once(&timer);
 }
 
        qemu_announce_self_once(&timer);
 }
 


@@ -883,6 +883,27 @@ const VMStateInfo vmstate_info_uint32 = {
     .put  = put_uint32,
 };
 
     .put  = put_uint32,
 };
 

+/* 32 bit uint. See that the received value is the same than the one
+   in the field */
+
+static int get_uint32_equal(QEMUFile *f, void *pv, size_t size)
+{
+    uint32_t *v = pv;
+    uint32_t v2;
+    qemu_get_be32s(f, &v2);
+
+    if (*v == v2) {
+        return 0;
+    }
+    return -EINVAL;
+}
+
+const VMStateInfo vmstate_info_uint32_equal = {
+    .name = "uint32 equal",
+    .get  = get_uint32_equal,
+    .put  = put_uint32,
+};
+

 /* 64 bit unsigned int */
 
 static int get_uint64(QEMUFile *f, void *pv, size_t size)
 /* 64 bit unsigned int */
 
 static int get_uint64(QEMUFile *f, void *pv, size_t size)


@@ -987,7 +1008,7 @@ const VMStateInfo vmstate_info_buffer = {
 };
 
 /* unused buffers: space that was used for some fields that are
 };
 
 /* unused buffers: space that was used for some fields that are

-   not usefull anymore */
+   not useful anymore */

 
 static int get_unused_buffer(QEMUFile *f, void *pv, size_t size)
 {
 
 static int get_unused_buffer(QEMUFile *f, void *pv, size_t size)
 {


@@ -1309,8 +1330,12 @@ int vmstate_load_state(QEMUFile *f, const VMStateDescription *vmsd,
                 n_elems = field->num;
             } else if (field->flags & VMS_VARRAY_INT32) {
                 n_elems = *(int32_t *)(opaque+field->num_offset);
                 n_elems = field->num;
             } else if (field->flags & VMS_VARRAY_INT32) {
                 n_elems = *(int32_t *)(opaque+field->num_offset);

+            } else if (field->flags & VMS_VARRAY_UINT32) {
+                n_elems = *(uint32_t *)(opaque+field->num_offset);

             } else if (field->flags & VMS_VARRAY_UINT16) {
                 n_elems = *(uint16_t *)(opaque+field->num_offset);
             } else if (field->flags & VMS_VARRAY_UINT16) {
                 n_elems = *(uint16_t *)(opaque+field->num_offset);

+            } else if (field->flags & VMS_VARRAY_UINT8) {
+                n_elems = *(uint8_t *)(opaque+field->num_offset);

             }
             if (field->flags & VMS_POINTER) {
                 base_addr = *(void **)base_addr + field->start;
             }
             if (field->flags & VMS_POINTER) {
                 base_addr = *(void **)base_addr + field->start;


@@ -1371,6 +1396,8 @@ void vmstate_save_state(QEMUFile *f, const VMStateDescription *vmsd,
                 n_elems = *(int32_t *)(opaque+field->num_offset);
             } else if (field->flags & VMS_VARRAY_UINT16) {
                 n_elems = *(uint16_t *)(opaque+field->num_offset);
                 n_elems = *(int32_t *)(opaque+field->num_offset);
             } else if (field->flags & VMS_VARRAY_UINT16) {
                 n_elems = *(uint16_t *)(opaque+field->num_offset);

+            } else if (field->flags & VMS_VARRAY_UINT8) {
+                n_elems = *(uint8_t *)(opaque+field->num_offset);

             }
             if (field->flags & VMS_POINTER) {
                 base_addr = *(void **)base_addr + field->start;
             }
             if (field->flags & VMS_POINTER) {
                 base_addr = *(void **)base_addr + field->start;


@@ -1576,7 +1603,7 @@ static int qemu_savevm_state(Monitor *mon, QEMUFile *f)
     int ret;
 
     saved_vm_running = vm_running;
     int ret;
 
     saved_vm_running = vm_running;

-    vm_stop(0);
+    vm_stop(VMSTOP_SAVEVM);

 
     if (qemu_savevm_state_blocked(mon)) {
         ret = -EINVAL;
 
     if (qemu_savevm_state_blocked(mon)) {
         ret = -EINVAL;


@@ -1639,6 +1666,12 @@ static const VMStateDescription *vmstate_get_subsection(const VMStateSubsection
 static int vmstate_subsection_load(QEMUFile *f, const VMStateDescription *vmsd,
                                    void *opaque)
 {
 static int vmstate_subsection_load(QEMUFile *f, const VMStateDescription *vmsd,
                                    void *opaque)
 {

+    const VMStateSubsection *sub = vmsd->subsections;
+
+    if (!sub || !sub->needed) {
+        return 0;
+    }
+

     while (qemu_peek_byte(f) == QEMU_VM_SUBSECTION) {
         char idstr[256];
         int ret;
     while (qemu_peek_byte(f) == QEMU_VM_SUBSECTION) {
         char idstr[256];
         int ret;


@@ -1651,10 +1684,11 @@ static int vmstate_subsection_load(QEMUFile *f, const VMStateDescription *vmsd,
         idstr[len] = 0;
         version_id = qemu_get_be32(f);
 
         idstr[len] = 0;
         version_id = qemu_get_be32(f);
 

-        sub_vmsd = vmstate_get_subsection(vmsd->subsections, idstr);
+        sub_vmsd = vmstate_get_subsection(sub, idstr);

         if (sub_vmsd == NULL) {
             return -ENOENT;
         }
         if (sub_vmsd == NULL) {
             return -ENOENT;
         }

+        assert(!sub_vmsd->subsections);

         ret = vmstate_load_state(f, sub_vmsd, opaque, version_id);
         if (ret) {
             return ret;
         ret = vmstate_load_state(f, sub_vmsd, opaque, version_id);
         if (ret) {
             return ret;


@@ -1678,6 +1712,7 @@ static void vmstate_subsection_save(QEMUFile *f, const VMStateDescription *vmsd,
             qemu_put_byte(f, len);
             qemu_put_buffer(f, (uint8_t *)vmsd->name, len);
             qemu_put_be32(f, vmsd->version_id);
             qemu_put_byte(f, len);
             qemu_put_buffer(f, (uint8_t *)vmsd->name, len);
             qemu_put_be32(f, vmsd->version_id);

+            assert(!vmsd->subsections);

             vmstate_save_state(f, vmsd, opaque);
         }
         sub++;
             vmstate_save_state(f, vmsd, opaque);
         }
         sub++;


@@ -1897,7 +1932,7 @@ void do_savevm(Monitor *mon, const QDict *qdict)
     }
 
     saved_vm_running = vm_running;
     }
 
     saved_vm_running = vm_running;

-    vm_stop(0);
+    vm_stop(VMSTOP_SAVEVM);

 
     memset(sn, 0, sizeof(*sn));
 
 
     memset(sn, 0, sizeof(*sn));
 


@@ -1911,7 +1946,7 @@ void do_savevm(Monitor *mon, const QDict *qdict)
     sn->date_sec = tv.tv_sec;
     sn->date_nsec = tv.tv_usec * 1000;
 #endif
     sn->date_sec = tv.tv_sec;
     sn->date_nsec = tv.tv_usec * 1000;
 #endif

-    sn->vm_clock_nsec = qemu_get_clock(vm_clock);
+    sn->vm_clock_nsec = qemu_get_clock_ns(vm_clock);

 
     if (name) {
         ret = bdrv_snapshot_find(bs, old_sn, name);
 
     if (name) {
         ret = bdrv_snapshot_find(bs, old_sn, name);


@@ -1989,6 +2024,8 @@ int load_vmstate(const char *name)
     if (ret < 0) {
         return ret;
     } else if (sn.vm_state_size == 0) {
     if (ret < 0) {
         return ret;
     } else if (sn.vm_state_size == 0) {

+        error_report("This is a disk-only snapshot. Revert to it offline "
+            "using qemu-img.");

         return -EINVAL;
     }
 
         return -EINVAL;
     }