Statistics
| Branch: | Revision:

root / savevm.c @ 2ada0ed7

History | View | Annotate | Download (30.9 kB)

1 a672b469 aliguori
/*
2 a672b469 aliguori
 * QEMU System Emulator
3 a672b469 aliguori
 *
4 a672b469 aliguori
 * Copyright (c) 2003-2008 Fabrice Bellard
5 a672b469 aliguori
 *
6 a672b469 aliguori
 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 a672b469 aliguori
 * of this software and associated documentation files (the "Software"), to deal
8 a672b469 aliguori
 * in the Software without restriction, including without limitation the rights
9 a672b469 aliguori
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10 a672b469 aliguori
 * copies of the Software, and to permit persons to whom the Software is
11 a672b469 aliguori
 * furnished to do so, subject to the following conditions:
12 a672b469 aliguori
 *
13 a672b469 aliguori
 * The above copyright notice and this permission notice shall be included in
14 a672b469 aliguori
 * all copies or substantial portions of the Software.
15 a672b469 aliguori
 *
16 a672b469 aliguori
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 a672b469 aliguori
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 a672b469 aliguori
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19 a672b469 aliguori
 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 a672b469 aliguori
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 a672b469 aliguori
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
22 a672b469 aliguori
 * THE SOFTWARE.
23 a672b469 aliguori
 */
24 a672b469 aliguori
#include <unistd.h>
25 a672b469 aliguori
#include <fcntl.h>
26 a672b469 aliguori
#include <signal.h>
27 a672b469 aliguori
#include <time.h>
28 a672b469 aliguori
#include <errno.h>
29 a672b469 aliguori
#include <sys/time.h>
30 a672b469 aliguori
#include <zlib.h>
31 a672b469 aliguori
32 d40cdb10 blueswir1
/* Needed early for _BSD etc. */
33 d40cdb10 blueswir1
#include "config-host.h"
34 d40cdb10 blueswir1
35 a672b469 aliguori
#ifndef _WIN32
36 a672b469 aliguori
#include <sys/times.h>
37 a672b469 aliguori
#include <sys/wait.h>
38 a672b469 aliguori
#include <termios.h>
39 a672b469 aliguori
#include <sys/mman.h>
40 a672b469 aliguori
#include <sys/ioctl.h>
41 a672b469 aliguori
#include <sys/resource.h>
42 a672b469 aliguori
#include <sys/socket.h>
43 a672b469 aliguori
#include <netinet/in.h>
44 a672b469 aliguori
#include <net/if.h>
45 a672b469 aliguori
#if defined(__NetBSD__)
46 a672b469 aliguori
#include <net/if_tap.h>
47 a672b469 aliguori
#endif
48 a672b469 aliguori
#ifdef __linux__
49 a672b469 aliguori
#include <linux/if_tun.h>
50 a672b469 aliguori
#endif
51 a672b469 aliguori
#include <arpa/inet.h>
52 a672b469 aliguori
#include <dirent.h>
53 a672b469 aliguori
#include <netdb.h>
54 a672b469 aliguori
#include <sys/select.h>
55 a672b469 aliguori
#ifdef _BSD
56 a672b469 aliguori
#include <sys/stat.h>
57 c5e97233 blueswir1
#if defined(__FreeBSD__) || defined(__DragonFly__)
58 a672b469 aliguori
#include <libutil.h>
59 a672b469 aliguori
#else
60 a672b469 aliguori
#include <util.h>
61 a672b469 aliguori
#endif
62 a672b469 aliguori
#elif defined (__GLIBC__) && defined (__FreeBSD_kernel__)
63 a672b469 aliguori
#include <freebsd/stdlib.h>
64 a672b469 aliguori
#else
65 a672b469 aliguori
#ifdef __linux__
66 a672b469 aliguori
#include <pty.h>
67 a672b469 aliguori
#include <malloc.h>
68 a672b469 aliguori
#include <linux/rtc.h>
69 a672b469 aliguori
#endif
70 a672b469 aliguori
#endif
71 a672b469 aliguori
#endif
72 a672b469 aliguori
73 a672b469 aliguori
#ifdef _WIN32
74 a672b469 aliguori
#include <malloc.h>
75 a672b469 aliguori
#include <sys/timeb.h>
76 a672b469 aliguori
#include <mmsystem.h>
77 a672b469 aliguori
#define getopt_long_only getopt_long
78 a672b469 aliguori
#define memalign(align, size) malloc(size)
79 a672b469 aliguori
#endif
80 a672b469 aliguori
81 511d2b14 blueswir1
#include "qemu-common.h"
82 511d2b14 blueswir1
#include "hw/hw.h"
83 511d2b14 blueswir1
#include "net.h"
84 511d2b14 blueswir1
#include "monitor.h"
85 511d2b14 blueswir1
#include "sysemu.h"
86 511d2b14 blueswir1
#include "qemu-timer.h"
87 511d2b14 blueswir1
#include "qemu-char.h"
88 511d2b14 blueswir1
#include "block.h"
89 511d2b14 blueswir1
#include "audio/audio.h"
90 511d2b14 blueswir1
#include "migration.h"
91 511d2b14 blueswir1
#include "qemu_socket.h"
92 511d2b14 blueswir1
93 a672b469 aliguori
/* point to the block driver where the snapshots are managed */
94 a672b469 aliguori
static BlockDriverState *bs_snapshots;
95 a672b469 aliguori
96 a672b469 aliguori
#define SELF_ANNOUNCE_ROUNDS 5
97 a672b469 aliguori
#define ETH_P_EXPERIMENTAL 0x01F1 /* just a number */
98 a672b469 aliguori
//#define ETH_P_EXPERIMENTAL 0x0012 /* make it the size of the packet */
99 a672b469 aliguori
#define EXPERIMENTAL_MAGIC 0xf1f23f4f
100 a672b469 aliguori
101 a672b469 aliguori
static int announce_self_create(uint8_t *buf, 
102 a672b469 aliguori
                                uint8_t *mac_addr)
103 a672b469 aliguori
{
104 a672b469 aliguori
    uint32_t magic = EXPERIMENTAL_MAGIC;
105 a672b469 aliguori
    uint16_t proto = htons(ETH_P_EXPERIMENTAL);
106 a672b469 aliguori
107 a672b469 aliguori
    /* FIXME: should we send a different packet (arp/rarp/ping)? */
108 a672b469 aliguori
109 a672b469 aliguori
    memset(buf, 0xff, 6);         /* h_dst */
110 a672b469 aliguori
    memcpy(buf + 6, mac_addr, 6); /* h_src */
111 a672b469 aliguori
    memcpy(buf + 12, &proto, 2);  /* h_proto */
112 a672b469 aliguori
    memcpy(buf + 14, &magic, 4);  /* magic */
113 a672b469 aliguori
114 a672b469 aliguori
    return 18; /* len */
115 a672b469 aliguori
}
116 a672b469 aliguori
117 a672b469 aliguori
void qemu_announce_self(void)
118 a672b469 aliguori
{
119 a672b469 aliguori
    int i, j, len;
120 a672b469 aliguori
    VLANState *vlan;
121 a672b469 aliguori
    VLANClientState *vc;
122 a672b469 aliguori
    uint8_t buf[256];
123 a672b469 aliguori
124 a672b469 aliguori
    for (i = 0; i < nb_nics; i++) {
125 a672b469 aliguori
        len = announce_self_create(buf, nd_table[i].macaddr);
126 a672b469 aliguori
        vlan = nd_table[i].vlan;
127 a672b469 aliguori
        for(vc = vlan->first_client; vc != NULL; vc = vc->next) {
128 a672b469 aliguori
            for (j=0; j < SELF_ANNOUNCE_ROUNDS; j++)
129 a672b469 aliguori
                vc->fd_read(vc->opaque, buf, len);
130 a672b469 aliguori
        }
131 a672b469 aliguori
    }
132 a672b469 aliguori
}
133 a672b469 aliguori
134 a672b469 aliguori
/***********************************************************/
135 a672b469 aliguori
/* savevm/loadvm support */
136 a672b469 aliguori
137 a672b469 aliguori
#define IO_BUF_SIZE 32768
138 a672b469 aliguori
139 a672b469 aliguori
struct QEMUFile {
140 a672b469 aliguori
    QEMUFilePutBufferFunc *put_buffer;
141 a672b469 aliguori
    QEMUFileGetBufferFunc *get_buffer;
142 a672b469 aliguori
    QEMUFileCloseFunc *close;
143 a672b469 aliguori
    QEMUFileRateLimit *rate_limit;
144 a672b469 aliguori
    void *opaque;
145 a672b469 aliguori
    int is_write;
146 a672b469 aliguori
147 a672b469 aliguori
    int64_t buf_offset; /* start of buffer when writing, end of buffer
148 a672b469 aliguori
                           when reading */
149 a672b469 aliguori
    int buf_index;
150 a672b469 aliguori
    int buf_size; /* 0 when writing */
151 a672b469 aliguori
    uint8_t buf[IO_BUF_SIZE];
152 a672b469 aliguori
153 a672b469 aliguori
    int has_error;
154 a672b469 aliguori
};
155 a672b469 aliguori
156 a672b469 aliguori
typedef struct QEMUFilePopen
157 a672b469 aliguori
{
158 a672b469 aliguori
    FILE *popen_file;
159 a672b469 aliguori
    QEMUFile *file;
160 a672b469 aliguori
} QEMUFilePopen;
161 a672b469 aliguori
162 a672b469 aliguori
typedef struct QEMUFileSocket
163 a672b469 aliguori
{
164 a672b469 aliguori
    int fd;
165 a672b469 aliguori
    QEMUFile *file;
166 a672b469 aliguori
} QEMUFileSocket;
167 a672b469 aliguori
168 a672b469 aliguori
static int socket_get_buffer(void *opaque, uint8_t *buf, int64_t pos, int size)
169 a672b469 aliguori
{
170 a672b469 aliguori
    QEMUFileSocket *s = opaque;
171 a672b469 aliguori
    ssize_t len;
172 a672b469 aliguori
173 a672b469 aliguori
    do {
174 a672b469 aliguori
        len = recv(s->fd, buf, size, 0);
175 a672b469 aliguori
    } while (len == -1 && socket_error() == EINTR);
176 a672b469 aliguori
177 a672b469 aliguori
    if (len == -1)
178 a672b469 aliguori
        len = -socket_error();
179 a672b469 aliguori
180 a672b469 aliguori
    return len;
181 a672b469 aliguori
}
182 a672b469 aliguori
183 a672b469 aliguori
static int socket_close(void *opaque)
184 a672b469 aliguori
{
185 a672b469 aliguori
    QEMUFileSocket *s = opaque;
186 a672b469 aliguori
    qemu_free(s);
187 a672b469 aliguori
    return 0;
188 a672b469 aliguori
}
189 a672b469 aliguori
190 a672b469 aliguori
static int popen_put_buffer(void *opaque, const uint8_t *buf, int64_t pos, int size)
191 a672b469 aliguori
{
192 a672b469 aliguori
    QEMUFilePopen *s = opaque;
193 a672b469 aliguori
    return fwrite(buf, 1, size, s->popen_file);
194 a672b469 aliguori
}
195 a672b469 aliguori
196 a672b469 aliguori
static int popen_get_buffer(void *opaque, uint8_t *buf, int64_t pos, int size)
197 a672b469 aliguori
{
198 a672b469 aliguori
    QEMUFilePopen *s = opaque;
199 a672b469 aliguori
    return fread(buf, 1, size, s->popen_file);
200 a672b469 aliguori
}
201 a672b469 aliguori
202 a672b469 aliguori
static int popen_close(void *opaque)
203 a672b469 aliguori
{
204 a672b469 aliguori
    QEMUFilePopen *s = opaque;
205 a672b469 aliguori
    pclose(s->popen_file);
206 a672b469 aliguori
    qemu_free(s);
207 a672b469 aliguori
    return 0;
208 a672b469 aliguori
}
209 a672b469 aliguori
210 a672b469 aliguori
QEMUFile *qemu_popen(FILE *popen_file, const char *mode)
211 a672b469 aliguori
{
212 a672b469 aliguori
    QEMUFilePopen *s;
213 a672b469 aliguori
214 a672b469 aliguori
    if (popen_file == NULL || mode == NULL || (mode[0] != 'r' && mode[0] != 'w') || mode[1] != 0) {
215 a672b469 aliguori
        fprintf(stderr, "qemu_popen: Argument validity check failed\n");
216 a672b469 aliguori
        return NULL;
217 a672b469 aliguori
    }
218 a672b469 aliguori
219 a672b469 aliguori
    s = qemu_mallocz(sizeof(QEMUFilePopen));
220 a672b469 aliguori
221 a672b469 aliguori
    s->popen_file = popen_file;
222 a672b469 aliguori
223 a672b469 aliguori
    if(mode[0] == 'r') {
224 a672b469 aliguori
        s->file = qemu_fopen_ops(s, NULL, popen_get_buffer, popen_close, NULL);
225 a672b469 aliguori
    } else {
226 a672b469 aliguori
        s->file = qemu_fopen_ops(s, popen_put_buffer, NULL, popen_close, NULL);
227 a672b469 aliguori
    }
228 a672b469 aliguori
    fprintf(stderr, "qemu_popen: returning result of qemu_fopen_ops\n");
229 a672b469 aliguori
    return s->file;
230 a672b469 aliguori
}
231 a672b469 aliguori
232 a672b469 aliguori
QEMUFile *qemu_popen_cmd(const char *command, const char *mode)
233 a672b469 aliguori
{
234 a672b469 aliguori
    FILE *popen_file;
235 a672b469 aliguori
236 a672b469 aliguori
    popen_file = popen(command, mode);
237 a672b469 aliguori
    if(popen_file == NULL) {
238 a672b469 aliguori
        return NULL;
239 a672b469 aliguori
    }
240 a672b469 aliguori
241 a672b469 aliguori
    return qemu_popen(popen_file, mode);
242 a672b469 aliguori
}
243 a672b469 aliguori
244 a672b469 aliguori
QEMUFile *qemu_fopen_socket(int fd)
245 a672b469 aliguori
{
246 a672b469 aliguori
    QEMUFileSocket *s = qemu_mallocz(sizeof(QEMUFileSocket));
247 a672b469 aliguori
248 a672b469 aliguori
    s->fd = fd;
249 a672b469 aliguori
    s->file = qemu_fopen_ops(s, NULL, socket_get_buffer, socket_close, NULL);
250 a672b469 aliguori
    return s->file;
251 a672b469 aliguori
}
252 a672b469 aliguori
253 a672b469 aliguori
typedef struct QEMUFileStdio
254 a672b469 aliguori
{
255 a672b469 aliguori
    FILE *outfile;
256 a672b469 aliguori
} QEMUFileStdio;
257 a672b469 aliguori
258 a672b469 aliguori
static int file_put_buffer(void *opaque, const uint8_t *buf,
259 a672b469 aliguori
                            int64_t pos, int size)
260 a672b469 aliguori
{
261 a672b469 aliguori
    QEMUFileStdio *s = opaque;
262 a672b469 aliguori
    fseek(s->outfile, pos, SEEK_SET);
263 a672b469 aliguori
    fwrite(buf, 1, size, s->outfile);
264 a672b469 aliguori
    return size;
265 a672b469 aliguori
}
266 a672b469 aliguori
267 a672b469 aliguori
static int file_get_buffer(void *opaque, uint8_t *buf, int64_t pos, int size)
268 a672b469 aliguori
{
269 a672b469 aliguori
    QEMUFileStdio *s = opaque;
270 a672b469 aliguori
    fseek(s->outfile, pos, SEEK_SET);
271 a672b469 aliguori
    return fread(buf, 1, size, s->outfile);
272 a672b469 aliguori
}
273 a672b469 aliguori
274 a672b469 aliguori
static int file_close(void *opaque)
275 a672b469 aliguori
{
276 a672b469 aliguori
    QEMUFileStdio *s = opaque;
277 a672b469 aliguori
    fclose(s->outfile);
278 a672b469 aliguori
    qemu_free(s);
279 a672b469 aliguori
    return 0;
280 a672b469 aliguori
}
281 a672b469 aliguori
282 a672b469 aliguori
QEMUFile *qemu_fopen(const char *filename, const char *mode)
283 a672b469 aliguori
{
284 a672b469 aliguori
    QEMUFileStdio *s;
285 a672b469 aliguori
286 a672b469 aliguori
    s = qemu_mallocz(sizeof(QEMUFileStdio));
287 a672b469 aliguori
288 a672b469 aliguori
    s->outfile = fopen(filename, mode);
289 a672b469 aliguori
    if (!s->outfile)
290 a672b469 aliguori
        goto fail;
291 a672b469 aliguori
292 a672b469 aliguori
    if (!strcmp(mode, "wb"))
293 a672b469 aliguori
        return qemu_fopen_ops(s, file_put_buffer, NULL, file_close, NULL);
294 a672b469 aliguori
    else if (!strcmp(mode, "rb"))
295 a672b469 aliguori
        return qemu_fopen_ops(s, NULL, file_get_buffer, file_close, NULL);
296 a672b469 aliguori
297 a672b469 aliguori
fail:
298 a672b469 aliguori
    if (s->outfile)
299 a672b469 aliguori
        fclose(s->outfile);
300 a672b469 aliguori
    qemu_free(s);
301 a672b469 aliguori
    return NULL;
302 a672b469 aliguori
}
303 a672b469 aliguori
304 a672b469 aliguori
typedef struct QEMUFileBdrv
305 a672b469 aliguori
{
306 a672b469 aliguori
    BlockDriverState *bs;
307 a672b469 aliguori
    int64_t base_offset;
308 a672b469 aliguori
} QEMUFileBdrv;
309 a672b469 aliguori
310 a672b469 aliguori
static int bdrv_put_buffer(void *opaque, const uint8_t *buf,
311 a672b469 aliguori
                           int64_t pos, int size)
312 a672b469 aliguori
{
313 a672b469 aliguori
    QEMUFileBdrv *s = opaque;
314 a672b469 aliguori
    bdrv_pwrite(s->bs, s->base_offset + pos, buf, size);
315 a672b469 aliguori
    return size;
316 a672b469 aliguori
}
317 a672b469 aliguori
318 a672b469 aliguori
static int bdrv_get_buffer(void *opaque, uint8_t *buf, int64_t pos, int size)
319 a672b469 aliguori
{
320 a672b469 aliguori
    QEMUFileBdrv *s = opaque;
321 a672b469 aliguori
    return bdrv_pread(s->bs, s->base_offset + pos, buf, size);
322 a672b469 aliguori
}
323 a672b469 aliguori
324 a672b469 aliguori
static int bdrv_fclose(void *opaque)
325 a672b469 aliguori
{
326 a672b469 aliguori
    QEMUFileBdrv *s = opaque;
327 a672b469 aliguori
    qemu_free(s);
328 a672b469 aliguori
    return 0;
329 a672b469 aliguori
}
330 a672b469 aliguori
331 a672b469 aliguori
static QEMUFile *qemu_fopen_bdrv(BlockDriverState *bs, int64_t offset, int is_writable)
332 a672b469 aliguori
{
333 a672b469 aliguori
    QEMUFileBdrv *s;
334 a672b469 aliguori
335 a672b469 aliguori
    s = qemu_mallocz(sizeof(QEMUFileBdrv));
336 a672b469 aliguori
337 a672b469 aliguori
    s->bs = bs;
338 a672b469 aliguori
    s->base_offset = offset;
339 a672b469 aliguori
340 a672b469 aliguori
    if (is_writable)
341 a672b469 aliguori
        return qemu_fopen_ops(s, bdrv_put_buffer, NULL, bdrv_fclose, NULL);
342 a672b469 aliguori
343 a672b469 aliguori
    return qemu_fopen_ops(s, NULL, bdrv_get_buffer, bdrv_fclose, NULL);
344 a672b469 aliguori
}
345 a672b469 aliguori
346 a672b469 aliguori
QEMUFile *qemu_fopen_ops(void *opaque, QEMUFilePutBufferFunc *put_buffer,
347 a672b469 aliguori
                         QEMUFileGetBufferFunc *get_buffer,
348 a672b469 aliguori
                         QEMUFileCloseFunc *close,
349 a672b469 aliguori
                         QEMUFileRateLimit *rate_limit)
350 a672b469 aliguori
{
351 a672b469 aliguori
    QEMUFile *f;
352 a672b469 aliguori
353 a672b469 aliguori
    f = qemu_mallocz(sizeof(QEMUFile));
354 a672b469 aliguori
355 a672b469 aliguori
    f->opaque = opaque;
356 a672b469 aliguori
    f->put_buffer = put_buffer;
357 a672b469 aliguori
    f->get_buffer = get_buffer;
358 a672b469 aliguori
    f->close = close;
359 a672b469 aliguori
    f->rate_limit = rate_limit;
360 a672b469 aliguori
    f->is_write = 0;
361 a672b469 aliguori
362 a672b469 aliguori
    return f;
363 a672b469 aliguori
}
364 a672b469 aliguori
365 a672b469 aliguori
int qemu_file_has_error(QEMUFile *f)
366 a672b469 aliguori
{
367 a672b469 aliguori
    return f->has_error;
368 a672b469 aliguori
}
369 a672b469 aliguori
370 a672b469 aliguori
void qemu_fflush(QEMUFile *f)
371 a672b469 aliguori
{
372 a672b469 aliguori
    if (!f->put_buffer)
373 a672b469 aliguori
        return;
374 a672b469 aliguori
375 a672b469 aliguori
    if (f->is_write && f->buf_index > 0) {
376 a672b469 aliguori
        int len;
377 a672b469 aliguori
378 a672b469 aliguori
        len = f->put_buffer(f->opaque, f->buf, f->buf_offset, f->buf_index);
379 a672b469 aliguori
        if (len > 0)
380 a672b469 aliguori
            f->buf_offset += f->buf_index;
381 a672b469 aliguori
        else
382 a672b469 aliguori
            f->has_error = 1;
383 a672b469 aliguori
        f->buf_index = 0;
384 a672b469 aliguori
    }
385 a672b469 aliguori
}
386 a672b469 aliguori
387 a672b469 aliguori
static void qemu_fill_buffer(QEMUFile *f)
388 a672b469 aliguori
{
389 a672b469 aliguori
    int len;
390 a672b469 aliguori
391 a672b469 aliguori
    if (!f->get_buffer)
392 a672b469 aliguori
        return;
393 a672b469 aliguori
394 a672b469 aliguori
    if (f->is_write)
395 a672b469 aliguori
        abort();
396 a672b469 aliguori
397 a672b469 aliguori
    len = f->get_buffer(f->opaque, f->buf, f->buf_offset, IO_BUF_SIZE);
398 a672b469 aliguori
    if (len > 0) {
399 a672b469 aliguori
        f->buf_index = 0;
400 a672b469 aliguori
        f->buf_size = len;
401 a672b469 aliguori
        f->buf_offset += len;
402 a672b469 aliguori
    } else if (len != -EAGAIN)
403 a672b469 aliguori
        f->has_error = 1;
404 a672b469 aliguori
}
405 a672b469 aliguori
406 a672b469 aliguori
int qemu_fclose(QEMUFile *f)
407 a672b469 aliguori
{
408 a672b469 aliguori
    int ret = 0;
409 a672b469 aliguori
    qemu_fflush(f);
410 a672b469 aliguori
    if (f->close)
411 a672b469 aliguori
        ret = f->close(f->opaque);
412 a672b469 aliguori
    qemu_free(f);
413 a672b469 aliguori
    return ret;
414 a672b469 aliguori
}
415 a672b469 aliguori
416 a672b469 aliguori
void qemu_file_put_notify(QEMUFile *f)
417 a672b469 aliguori
{
418 a672b469 aliguori
    f->put_buffer(f->opaque, NULL, 0, 0);
419 a672b469 aliguori
}
420 a672b469 aliguori
421 a672b469 aliguori
void qemu_put_buffer(QEMUFile *f, const uint8_t *buf, int size)
422 a672b469 aliguori
{
423 a672b469 aliguori
    int l;
424 a672b469 aliguori
425 a672b469 aliguori
    if (!f->has_error && f->is_write == 0 && f->buf_index > 0) {
426 a672b469 aliguori
        fprintf(stderr,
427 a672b469 aliguori
                "Attempted to write to buffer while read buffer is not empty\n");
428 a672b469 aliguori
        abort();
429 a672b469 aliguori
    }
430 a672b469 aliguori
431 a672b469 aliguori
    while (!f->has_error && size > 0) {
432 a672b469 aliguori
        l = IO_BUF_SIZE - f->buf_index;
433 a672b469 aliguori
        if (l > size)
434 a672b469 aliguori
            l = size;
435 a672b469 aliguori
        memcpy(f->buf + f->buf_index, buf, l);
436 a672b469 aliguori
        f->is_write = 1;
437 a672b469 aliguori
        f->buf_index += l;
438 a672b469 aliguori
        buf += l;
439 a672b469 aliguori
        size -= l;
440 a672b469 aliguori
        if (f->buf_index >= IO_BUF_SIZE)
441 a672b469 aliguori
            qemu_fflush(f);
442 a672b469 aliguori
    }
443 a672b469 aliguori
}
444 a672b469 aliguori
445 a672b469 aliguori
void qemu_put_byte(QEMUFile *f, int v)
446 a672b469 aliguori
{
447 a672b469 aliguori
    if (!f->has_error && f->is_write == 0 && f->buf_index > 0) {
448 a672b469 aliguori
        fprintf(stderr,
449 a672b469 aliguori
                "Attempted to write to buffer while read buffer is not empty\n");
450 a672b469 aliguori
        abort();
451 a672b469 aliguori
    }
452 a672b469 aliguori
453 a672b469 aliguori
    f->buf[f->buf_index++] = v;
454 a672b469 aliguori
    f->is_write = 1;
455 a672b469 aliguori
    if (f->buf_index >= IO_BUF_SIZE)
456 a672b469 aliguori
        qemu_fflush(f);
457 a672b469 aliguori
}
458 a672b469 aliguori
459 a672b469 aliguori
int qemu_get_buffer(QEMUFile *f, uint8_t *buf, int size1)
460 a672b469 aliguori
{
461 a672b469 aliguori
    int size, l;
462 a672b469 aliguori
463 a672b469 aliguori
    if (f->is_write)
464 a672b469 aliguori
        abort();
465 a672b469 aliguori
466 a672b469 aliguori
    size = size1;
467 a672b469 aliguori
    while (size > 0) {
468 a672b469 aliguori
        l = f->buf_size - f->buf_index;
469 a672b469 aliguori
        if (l == 0) {
470 a672b469 aliguori
            qemu_fill_buffer(f);
471 a672b469 aliguori
            l = f->buf_size - f->buf_index;
472 a672b469 aliguori
            if (l == 0)
473 a672b469 aliguori
                break;
474 a672b469 aliguori
        }
475 a672b469 aliguori
        if (l > size)
476 a672b469 aliguori
            l = size;
477 a672b469 aliguori
        memcpy(buf, f->buf + f->buf_index, l);
478 a672b469 aliguori
        f->buf_index += l;
479 a672b469 aliguori
        buf += l;
480 a672b469 aliguori
        size -= l;
481 a672b469 aliguori
    }
482 a672b469 aliguori
    return size1 - size;
483 a672b469 aliguori
}
484 a672b469 aliguori
485 a672b469 aliguori
int qemu_get_byte(QEMUFile *f)
486 a672b469 aliguori
{
487 a672b469 aliguori
    if (f->is_write)
488 a672b469 aliguori
        abort();
489 a672b469 aliguori
490 a672b469 aliguori
    if (f->buf_index >= f->buf_size) {
491 a672b469 aliguori
        qemu_fill_buffer(f);
492 a672b469 aliguori
        if (f->buf_index >= f->buf_size)
493 a672b469 aliguori
            return 0;
494 a672b469 aliguori
    }
495 a672b469 aliguori
    return f->buf[f->buf_index++];
496 a672b469 aliguori
}
497 a672b469 aliguori
498 a672b469 aliguori
int64_t qemu_ftell(QEMUFile *f)
499 a672b469 aliguori
{
500 a672b469 aliguori
    return f->buf_offset - f->buf_size + f->buf_index;
501 a672b469 aliguori
}
502 a672b469 aliguori
503 a672b469 aliguori
int64_t qemu_fseek(QEMUFile *f, int64_t pos, int whence)
504 a672b469 aliguori
{
505 a672b469 aliguori
    if (whence == SEEK_SET) {
506 a672b469 aliguori
        /* nothing to do */
507 a672b469 aliguori
    } else if (whence == SEEK_CUR) {
508 a672b469 aliguori
        pos += qemu_ftell(f);
509 a672b469 aliguori
    } else {
510 a672b469 aliguori
        /* SEEK_END not supported */
511 a672b469 aliguori
        return -1;
512 a672b469 aliguori
    }
513 a672b469 aliguori
    if (f->put_buffer) {
514 a672b469 aliguori
        qemu_fflush(f);
515 a672b469 aliguori
        f->buf_offset = pos;
516 a672b469 aliguori
    } else {
517 a672b469 aliguori
        f->buf_offset = pos;
518 a672b469 aliguori
        f->buf_index = 0;
519 a672b469 aliguori
        f->buf_size = 0;
520 a672b469 aliguori
    }
521 a672b469 aliguori
    return pos;
522 a672b469 aliguori
}
523 a672b469 aliguori
524 a672b469 aliguori
int qemu_file_rate_limit(QEMUFile *f)
525 a672b469 aliguori
{
526 a672b469 aliguori
    if (f->rate_limit)
527 a672b469 aliguori
        return f->rate_limit(f->opaque);
528 a672b469 aliguori
529 a672b469 aliguori
    return 0;
530 a672b469 aliguori
}
531 a672b469 aliguori
532 a672b469 aliguori
void qemu_put_be16(QEMUFile *f, unsigned int v)
533 a672b469 aliguori
{
534 a672b469 aliguori
    qemu_put_byte(f, v >> 8);
535 a672b469 aliguori
    qemu_put_byte(f, v);
536 a672b469 aliguori
}
537 a672b469 aliguori
538 a672b469 aliguori
void qemu_put_be32(QEMUFile *f, unsigned int v)
539 a672b469 aliguori
{
540 a672b469 aliguori
    qemu_put_byte(f, v >> 24);
541 a672b469 aliguori
    qemu_put_byte(f, v >> 16);
542 a672b469 aliguori
    qemu_put_byte(f, v >> 8);
543 a672b469 aliguori
    qemu_put_byte(f, v);
544 a672b469 aliguori
}
545 a672b469 aliguori
546 a672b469 aliguori
void qemu_put_be64(QEMUFile *f, uint64_t v)
547 a672b469 aliguori
{
548 a672b469 aliguori
    qemu_put_be32(f, v >> 32);
549 a672b469 aliguori
    qemu_put_be32(f, v);
550 a672b469 aliguori
}
551 a672b469 aliguori
552 a672b469 aliguori
unsigned int qemu_get_be16(QEMUFile *f)
553 a672b469 aliguori
{
554 a672b469 aliguori
    unsigned int v;
555 a672b469 aliguori
    v = qemu_get_byte(f) << 8;
556 a672b469 aliguori
    v |= qemu_get_byte(f);
557 a672b469 aliguori
    return v;
558 a672b469 aliguori
}
559 a672b469 aliguori
560 a672b469 aliguori
unsigned int qemu_get_be32(QEMUFile *f)
561 a672b469 aliguori
{
562 a672b469 aliguori
    unsigned int v;
563 a672b469 aliguori
    v = qemu_get_byte(f) << 24;
564 a672b469 aliguori
    v |= qemu_get_byte(f) << 16;
565 a672b469 aliguori
    v |= qemu_get_byte(f) << 8;
566 a672b469 aliguori
    v |= qemu_get_byte(f);
567 a672b469 aliguori
    return v;
568 a672b469 aliguori
}
569 a672b469 aliguori
570 a672b469 aliguori
uint64_t qemu_get_be64(QEMUFile *f)
571 a672b469 aliguori
{
572 a672b469 aliguori
    uint64_t v;
573 a672b469 aliguori
    v = (uint64_t)qemu_get_be32(f) << 32;
574 a672b469 aliguori
    v |= qemu_get_be32(f);
575 a672b469 aliguori
    return v;
576 a672b469 aliguori
}
577 a672b469 aliguori
578 a672b469 aliguori
typedef struct SaveStateEntry {
579 a672b469 aliguori
    char idstr[256];
580 a672b469 aliguori
    int instance_id;
581 a672b469 aliguori
    int version_id;
582 a672b469 aliguori
    int section_id;
583 a672b469 aliguori
    SaveLiveStateHandler *save_live_state;
584 a672b469 aliguori
    SaveStateHandler *save_state;
585 a672b469 aliguori
    LoadStateHandler *load_state;
586 a672b469 aliguori
    void *opaque;
587 a672b469 aliguori
    struct SaveStateEntry *next;
588 a672b469 aliguori
} SaveStateEntry;
589 a672b469 aliguori
590 a672b469 aliguori
static SaveStateEntry *first_se;
591 a672b469 aliguori
592 a672b469 aliguori
/* TODO: Individual devices generally have very little idea about the rest
593 a672b469 aliguori
   of the system, so instance_id should be removed/replaced.
594 a672b469 aliguori
   Meanwhile pass -1 as instance_id if you do not already have a clearly
595 a672b469 aliguori
   distinguishing id for all instances of your device class. */
596 a672b469 aliguori
int register_savevm_live(const char *idstr,
597 a672b469 aliguori
                         int instance_id,
598 a672b469 aliguori
                         int version_id,
599 a672b469 aliguori
                         SaveLiveStateHandler *save_live_state,
600 a672b469 aliguori
                         SaveStateHandler *save_state,
601 a672b469 aliguori
                         LoadStateHandler *load_state,
602 a672b469 aliguori
                         void *opaque)
603 a672b469 aliguori
{
604 a672b469 aliguori
    SaveStateEntry *se, **pse;
605 a672b469 aliguori
    static int global_section_id;
606 a672b469 aliguori
607 a672b469 aliguori
    se = qemu_malloc(sizeof(SaveStateEntry));
608 a672b469 aliguori
    pstrcpy(se->idstr, sizeof(se->idstr), idstr);
609 a672b469 aliguori
    se->instance_id = (instance_id == -1) ? 0 : instance_id;
610 a672b469 aliguori
    se->version_id = version_id;
611 a672b469 aliguori
    se->section_id = global_section_id++;
612 a672b469 aliguori
    se->save_live_state = save_live_state;
613 a672b469 aliguori
    se->save_state = save_state;
614 a672b469 aliguori
    se->load_state = load_state;
615 a672b469 aliguori
    se->opaque = opaque;
616 a672b469 aliguori
    se->next = NULL;
617 a672b469 aliguori
618 a672b469 aliguori
    /* add at the end of list */
619 a672b469 aliguori
    pse = &first_se;
620 a672b469 aliguori
    while (*pse != NULL) {
621 a672b469 aliguori
        if (instance_id == -1
622 a672b469 aliguori
                && strcmp(se->idstr, (*pse)->idstr) == 0
623 a672b469 aliguori
                && se->instance_id <= (*pse)->instance_id)
624 a672b469 aliguori
            se->instance_id = (*pse)->instance_id + 1;
625 a672b469 aliguori
        pse = &(*pse)->next;
626 a672b469 aliguori
    }
627 a672b469 aliguori
    *pse = se;
628 a672b469 aliguori
    return 0;
629 a672b469 aliguori
}
630 a672b469 aliguori
631 a672b469 aliguori
int register_savevm(const char *idstr,
632 a672b469 aliguori
                    int instance_id,
633 a672b469 aliguori
                    int version_id,
634 a672b469 aliguori
                    SaveStateHandler *save_state,
635 a672b469 aliguori
                    LoadStateHandler *load_state,
636 a672b469 aliguori
                    void *opaque)
637 a672b469 aliguori
{
638 a672b469 aliguori
    return register_savevm_live(idstr, instance_id, version_id,
639 a672b469 aliguori
                                NULL, save_state, load_state, opaque);
640 a672b469 aliguori
}
641 a672b469 aliguori
642 a672b469 aliguori
#define QEMU_VM_FILE_MAGIC           0x5145564d
643 a672b469 aliguori
#define QEMU_VM_FILE_VERSION_COMPAT  0x00000002
644 a672b469 aliguori
#define QEMU_VM_FILE_VERSION         0x00000003
645 a672b469 aliguori
646 a672b469 aliguori
#define QEMU_VM_EOF                  0x00
647 a672b469 aliguori
#define QEMU_VM_SECTION_START        0x01
648 a672b469 aliguori
#define QEMU_VM_SECTION_PART         0x02
649 a672b469 aliguori
#define QEMU_VM_SECTION_END          0x03
650 a672b469 aliguori
#define QEMU_VM_SECTION_FULL         0x04
651 a672b469 aliguori
652 a672b469 aliguori
int qemu_savevm_state_begin(QEMUFile *f)
653 a672b469 aliguori
{
654 a672b469 aliguori
    SaveStateEntry *se;
655 a672b469 aliguori
656 a672b469 aliguori
    qemu_put_be32(f, QEMU_VM_FILE_MAGIC);
657 a672b469 aliguori
    qemu_put_be32(f, QEMU_VM_FILE_VERSION);
658 a672b469 aliguori
659 a672b469 aliguori
    for (se = first_se; se != NULL; se = se->next) {
660 a672b469 aliguori
        int len;
661 a672b469 aliguori
662 a672b469 aliguori
        if (se->save_live_state == NULL)
663 a672b469 aliguori
            continue;
664 a672b469 aliguori
665 a672b469 aliguori
        /* Section type */
666 a672b469 aliguori
        qemu_put_byte(f, QEMU_VM_SECTION_START);
667 a672b469 aliguori
        qemu_put_be32(f, se->section_id);
668 a672b469 aliguori
669 a672b469 aliguori
        /* ID string */
670 a672b469 aliguori
        len = strlen(se->idstr);
671 a672b469 aliguori
        qemu_put_byte(f, len);
672 a672b469 aliguori
        qemu_put_buffer(f, (uint8_t *)se->idstr, len);
673 a672b469 aliguori
674 a672b469 aliguori
        qemu_put_be32(f, se->instance_id);
675 a672b469 aliguori
        qemu_put_be32(f, se->version_id);
676 a672b469 aliguori
677 a672b469 aliguori
        se->save_live_state(f, QEMU_VM_SECTION_START, se->opaque);
678 a672b469 aliguori
    }
679 a672b469 aliguori
680 a672b469 aliguori
    if (qemu_file_has_error(f))
681 a672b469 aliguori
        return -EIO;
682 a672b469 aliguori
683 a672b469 aliguori
    return 0;
684 a672b469 aliguori
}
685 a672b469 aliguori
686 a672b469 aliguori
int qemu_savevm_state_iterate(QEMUFile *f)
687 a672b469 aliguori
{
688 a672b469 aliguori
    SaveStateEntry *se;
689 a672b469 aliguori
    int ret = 1;
690 a672b469 aliguori
691 a672b469 aliguori
    for (se = first_se; se != NULL; se = se->next) {
692 a672b469 aliguori
        if (se->save_live_state == NULL)
693 a672b469 aliguori
            continue;
694 a672b469 aliguori
695 a672b469 aliguori
        /* Section type */
696 a672b469 aliguori
        qemu_put_byte(f, QEMU_VM_SECTION_PART);
697 a672b469 aliguori
        qemu_put_be32(f, se->section_id);
698 a672b469 aliguori
699 a672b469 aliguori
        ret &= !!se->save_live_state(f, QEMU_VM_SECTION_PART, se->opaque);
700 a672b469 aliguori
    }
701 a672b469 aliguori
702 a672b469 aliguori
    if (ret)
703 a672b469 aliguori
        return 1;
704 a672b469 aliguori
705 a672b469 aliguori
    if (qemu_file_has_error(f))
706 a672b469 aliguori
        return -EIO;
707 a672b469 aliguori
708 a672b469 aliguori
    return 0;
709 a672b469 aliguori
}
710 a672b469 aliguori
711 a672b469 aliguori
int qemu_savevm_state_complete(QEMUFile *f)
712 a672b469 aliguori
{
713 a672b469 aliguori
    SaveStateEntry *se;
714 a672b469 aliguori
715 a672b469 aliguori
    for (se = first_se; se != NULL; se = se->next) {
716 a672b469 aliguori
        if (se->save_live_state == NULL)
717 a672b469 aliguori
            continue;
718 a672b469 aliguori
719 a672b469 aliguori
        /* Section type */
720 a672b469 aliguori
        qemu_put_byte(f, QEMU_VM_SECTION_END);
721 a672b469 aliguori
        qemu_put_be32(f, se->section_id);
722 a672b469 aliguori
723 a672b469 aliguori
        se->save_live_state(f, QEMU_VM_SECTION_END, se->opaque);
724 a672b469 aliguori
    }
725 a672b469 aliguori
726 a672b469 aliguori
    for(se = first_se; se != NULL; se = se->next) {
727 a672b469 aliguori
        int len;
728 a672b469 aliguori
729 a672b469 aliguori
        if (se->save_state == NULL)
730 a672b469 aliguori
            continue;
731 a672b469 aliguori
732 a672b469 aliguori
        /* Section type */
733 a672b469 aliguori
        qemu_put_byte(f, QEMU_VM_SECTION_FULL);
734 a672b469 aliguori
        qemu_put_be32(f, se->section_id);
735 a672b469 aliguori
736 a672b469 aliguori
        /* ID string */
737 a672b469 aliguori
        len = strlen(se->idstr);
738 a672b469 aliguori
        qemu_put_byte(f, len);
739 a672b469 aliguori
        qemu_put_buffer(f, (uint8_t *)se->idstr, len);
740 a672b469 aliguori
741 a672b469 aliguori
        qemu_put_be32(f, se->instance_id);
742 a672b469 aliguori
        qemu_put_be32(f, se->version_id);
743 a672b469 aliguori
744 a672b469 aliguori
        se->save_state(f, se->opaque);
745 a672b469 aliguori
    }
746 a672b469 aliguori
747 a672b469 aliguori
    qemu_put_byte(f, QEMU_VM_EOF);
748 a672b469 aliguori
749 a672b469 aliguori
    if (qemu_file_has_error(f))
750 a672b469 aliguori
        return -EIO;
751 a672b469 aliguori
752 a672b469 aliguori
    return 0;
753 a672b469 aliguori
}
754 a672b469 aliguori
755 a672b469 aliguori
int qemu_savevm_state(QEMUFile *f)
756 a672b469 aliguori
{
757 a672b469 aliguori
    int saved_vm_running;
758 a672b469 aliguori
    int ret;
759 a672b469 aliguori
760 a672b469 aliguori
    saved_vm_running = vm_running;
761 a672b469 aliguori
    vm_stop(0);
762 a672b469 aliguori
763 a672b469 aliguori
    bdrv_flush_all();
764 a672b469 aliguori
765 a672b469 aliguori
    ret = qemu_savevm_state_begin(f);
766 a672b469 aliguori
    if (ret < 0)
767 a672b469 aliguori
        goto out;
768 a672b469 aliguori
769 a672b469 aliguori
    do {
770 a672b469 aliguori
        ret = qemu_savevm_state_iterate(f);
771 a672b469 aliguori
        if (ret < 0)
772 a672b469 aliguori
            goto out;
773 a672b469 aliguori
    } while (ret == 0);
774 a672b469 aliguori
775 a672b469 aliguori
    ret = qemu_savevm_state_complete(f);
776 a672b469 aliguori
777 a672b469 aliguori
out:
778 a672b469 aliguori
    if (qemu_file_has_error(f))
779 a672b469 aliguori
        ret = -EIO;
780 a672b469 aliguori
781 a672b469 aliguori
    if (!ret && saved_vm_running)
782 a672b469 aliguori
        vm_start();
783 a672b469 aliguori
784 a672b469 aliguori
    return ret;
785 a672b469 aliguori
}
786 a672b469 aliguori
787 a672b469 aliguori
static SaveStateEntry *find_se(const char *idstr, int instance_id)
788 a672b469 aliguori
{
789 a672b469 aliguori
    SaveStateEntry *se;
790 a672b469 aliguori
791 a672b469 aliguori
    for(se = first_se; se != NULL; se = se->next) {
792 a672b469 aliguori
        if (!strcmp(se->idstr, idstr) &&
793 a672b469 aliguori
            instance_id == se->instance_id)
794 a672b469 aliguori
            return se;
795 a672b469 aliguori
    }
796 a672b469 aliguori
    return NULL;
797 a672b469 aliguori
}
798 a672b469 aliguori
799 a672b469 aliguori
typedef struct LoadStateEntry {
800 a672b469 aliguori
    SaveStateEntry *se;
801 a672b469 aliguori
    int section_id;
802 a672b469 aliguori
    int version_id;
803 a672b469 aliguori
    struct LoadStateEntry *next;
804 a672b469 aliguori
} LoadStateEntry;
805 a672b469 aliguori
806 a672b469 aliguori
static int qemu_loadvm_state_v2(QEMUFile *f)
807 a672b469 aliguori
{
808 a672b469 aliguori
    SaveStateEntry *se;
809 a672b469 aliguori
    int len, ret, instance_id, record_len, version_id;
810 a672b469 aliguori
    int64_t total_len, end_pos, cur_pos;
811 a672b469 aliguori
    char idstr[256];
812 a672b469 aliguori
813 a672b469 aliguori
    total_len = qemu_get_be64(f);
814 a672b469 aliguori
    end_pos = total_len + qemu_ftell(f);
815 a672b469 aliguori
    for(;;) {
816 a672b469 aliguori
        if (qemu_ftell(f) >= end_pos)
817 a672b469 aliguori
            break;
818 a672b469 aliguori
        len = qemu_get_byte(f);
819 a672b469 aliguori
        qemu_get_buffer(f, (uint8_t *)idstr, len);
820 a672b469 aliguori
        idstr[len] = '\0';
821 a672b469 aliguori
        instance_id = qemu_get_be32(f);
822 a672b469 aliguori
        version_id = qemu_get_be32(f);
823 a672b469 aliguori
        record_len = qemu_get_be32(f);
824 a672b469 aliguori
        cur_pos = qemu_ftell(f);
825 a672b469 aliguori
        se = find_se(idstr, instance_id);
826 a672b469 aliguori
        if (!se) {
827 a672b469 aliguori
            fprintf(stderr, "qemu: warning: instance 0x%x of device '%s' not present in current VM\n",
828 a672b469 aliguori
                    instance_id, idstr);
829 a672b469 aliguori
        } else {
830 a672b469 aliguori
            ret = se->load_state(f, se->opaque, version_id);
831 a672b469 aliguori
            if (ret < 0) {
832 a672b469 aliguori
                fprintf(stderr, "qemu: warning: error while loading state for instance 0x%x of device '%s'\n",
833 a672b469 aliguori
                        instance_id, idstr);
834 a672b469 aliguori
            }
835 a672b469 aliguori
        }
836 a672b469 aliguori
        /* always seek to exact end of record */
837 a672b469 aliguori
        qemu_fseek(f, cur_pos + record_len, SEEK_SET);
838 a672b469 aliguori
    }
839 a672b469 aliguori
840 a672b469 aliguori
    if (qemu_file_has_error(f))
841 a672b469 aliguori
        return -EIO;
842 a672b469 aliguori
843 a672b469 aliguori
    return 0;
844 a672b469 aliguori
}
845 a672b469 aliguori
846 a672b469 aliguori
int qemu_loadvm_state(QEMUFile *f)
847 a672b469 aliguori
{
848 a672b469 aliguori
    LoadStateEntry *first_le = NULL;
849 a672b469 aliguori
    uint8_t section_type;
850 a672b469 aliguori
    unsigned int v;
851 a672b469 aliguori
    int ret;
852 a672b469 aliguori
853 a672b469 aliguori
    v = qemu_get_be32(f);
854 a672b469 aliguori
    if (v != QEMU_VM_FILE_MAGIC)
855 a672b469 aliguori
        return -EINVAL;
856 a672b469 aliguori
857 a672b469 aliguori
    v = qemu_get_be32(f);
858 a672b469 aliguori
    if (v == QEMU_VM_FILE_VERSION_COMPAT)
859 a672b469 aliguori
        return qemu_loadvm_state_v2(f);
860 a672b469 aliguori
    if (v != QEMU_VM_FILE_VERSION)
861 a672b469 aliguori
        return -ENOTSUP;
862 a672b469 aliguori
863 a672b469 aliguori
    while ((section_type = qemu_get_byte(f)) != QEMU_VM_EOF) {
864 a672b469 aliguori
        uint32_t instance_id, version_id, section_id;
865 a672b469 aliguori
        LoadStateEntry *le;
866 a672b469 aliguori
        SaveStateEntry *se;
867 a672b469 aliguori
        char idstr[257];
868 a672b469 aliguori
        int len;
869 a672b469 aliguori
870 a672b469 aliguori
        switch (section_type) {
871 a672b469 aliguori
        case QEMU_VM_SECTION_START:
872 a672b469 aliguori
        case QEMU_VM_SECTION_FULL:
873 a672b469 aliguori
            /* Read section start */
874 a672b469 aliguori
            section_id = qemu_get_be32(f);
875 a672b469 aliguori
            len = qemu_get_byte(f);
876 a672b469 aliguori
            qemu_get_buffer(f, (uint8_t *)idstr, len);
877 a672b469 aliguori
            idstr[len] = 0;
878 a672b469 aliguori
            instance_id = qemu_get_be32(f);
879 a672b469 aliguori
            version_id = qemu_get_be32(f);
880 a672b469 aliguori
881 a672b469 aliguori
            /* Find savevm section */
882 a672b469 aliguori
            se = find_se(idstr, instance_id);
883 a672b469 aliguori
            if (se == NULL) {
884 a672b469 aliguori
                fprintf(stderr, "Unknown savevm section or instance '%s' %d\n", idstr, instance_id);
885 a672b469 aliguori
                ret = -EINVAL;
886 a672b469 aliguori
                goto out;
887 a672b469 aliguori
            }
888 a672b469 aliguori
889 a672b469 aliguori
            /* Validate version */
890 a672b469 aliguori
            if (version_id > se->version_id) {
891 a672b469 aliguori
                fprintf(stderr, "savevm: unsupported version %d for '%s' v%d\n",
892 a672b469 aliguori
                        version_id, idstr, se->version_id);
893 a672b469 aliguori
                ret = -EINVAL;
894 a672b469 aliguori
                goto out;
895 a672b469 aliguori
            }
896 a672b469 aliguori
897 a672b469 aliguori
            /* Add entry */
898 a672b469 aliguori
            le = qemu_mallocz(sizeof(*le));
899 a672b469 aliguori
900 a672b469 aliguori
            le->se = se;
901 a672b469 aliguori
            le->section_id = section_id;
902 a672b469 aliguori
            le->version_id = version_id;
903 a672b469 aliguori
            le->next = first_le;
904 a672b469 aliguori
            first_le = le;
905 a672b469 aliguori
906 a672b469 aliguori
            le->se->load_state(f, le->se->opaque, le->version_id);
907 a672b469 aliguori
            break;
908 a672b469 aliguori
        case QEMU_VM_SECTION_PART:
909 a672b469 aliguori
        case QEMU_VM_SECTION_END:
910 a672b469 aliguori
            section_id = qemu_get_be32(f);
911 a672b469 aliguori
912 a672b469 aliguori
            for (le = first_le; le && le->section_id != section_id; le = le->next);
913 a672b469 aliguori
            if (le == NULL) {
914 a672b469 aliguori
                fprintf(stderr, "Unknown savevm section %d\n", section_id);
915 a672b469 aliguori
                ret = -EINVAL;
916 a672b469 aliguori
                goto out;
917 a672b469 aliguori
            }
918 a672b469 aliguori
919 a672b469 aliguori
            le->se->load_state(f, le->se->opaque, le->version_id);
920 a672b469 aliguori
            break;
921 a672b469 aliguori
        default:
922 a672b469 aliguori
            fprintf(stderr, "Unknown savevm section type %d\n", section_type);
923 a672b469 aliguori
            ret = -EINVAL;
924 a672b469 aliguori
            goto out;
925 a672b469 aliguori
        }
926 a672b469 aliguori
    }
927 a672b469 aliguori
928 a672b469 aliguori
    ret = 0;
929 a672b469 aliguori
930 a672b469 aliguori
out:
931 a672b469 aliguori
    while (first_le) {
932 a672b469 aliguori
        LoadStateEntry *le = first_le;
933 a672b469 aliguori
        first_le = first_le->next;
934 a672b469 aliguori
        qemu_free(le);
935 a672b469 aliguori
    }
936 a672b469 aliguori
937 a672b469 aliguori
    if (qemu_file_has_error(f))
938 a672b469 aliguori
        ret = -EIO;
939 a672b469 aliguori
940 a672b469 aliguori
    return ret;
941 a672b469 aliguori
}
942 a672b469 aliguori
943 a672b469 aliguori
/* device can contain snapshots */
944 a672b469 aliguori
static int bdrv_can_snapshot(BlockDriverState *bs)
945 a672b469 aliguori
{
946 a672b469 aliguori
    return (bs &&
947 a672b469 aliguori
            !bdrv_is_removable(bs) &&
948 a672b469 aliguori
            !bdrv_is_read_only(bs));
949 a672b469 aliguori
}
950 a672b469 aliguori
951 a672b469 aliguori
/* device must be snapshots in order to have a reliable snapshot */
952 a672b469 aliguori
static int bdrv_has_snapshot(BlockDriverState *bs)
953 a672b469 aliguori
{
954 a672b469 aliguori
    return (bs &&
955 a672b469 aliguori
            !bdrv_is_removable(bs) &&
956 a672b469 aliguori
            !bdrv_is_read_only(bs));
957 a672b469 aliguori
}
958 a672b469 aliguori
959 a672b469 aliguori
static BlockDriverState *get_bs_snapshots(void)
960 a672b469 aliguori
{
961 a672b469 aliguori
    BlockDriverState *bs;
962 a672b469 aliguori
    int i;
963 a672b469 aliguori
964 a672b469 aliguori
    if (bs_snapshots)
965 a672b469 aliguori
        return bs_snapshots;
966 a672b469 aliguori
    for(i = 0; i <= nb_drives; i++) {
967 a672b469 aliguori
        bs = drives_table[i].bdrv;
968 a672b469 aliguori
        if (bdrv_can_snapshot(bs))
969 a672b469 aliguori
            goto ok;
970 a672b469 aliguori
    }
971 a672b469 aliguori
    return NULL;
972 a672b469 aliguori
 ok:
973 a672b469 aliguori
    bs_snapshots = bs;
974 a672b469 aliguori
    return bs;
975 a672b469 aliguori
}
976 a672b469 aliguori
977 a672b469 aliguori
static int bdrv_snapshot_find(BlockDriverState *bs, QEMUSnapshotInfo *sn_info,
978 a672b469 aliguori
                              const char *name)
979 a672b469 aliguori
{
980 a672b469 aliguori
    QEMUSnapshotInfo *sn_tab, *sn;
981 a672b469 aliguori
    int nb_sns, i, ret;
982 a672b469 aliguori
983 a672b469 aliguori
    ret = -ENOENT;
984 a672b469 aliguori
    nb_sns = bdrv_snapshot_list(bs, &sn_tab);
985 a672b469 aliguori
    if (nb_sns < 0)
986 a672b469 aliguori
        return ret;
987 a672b469 aliguori
    for(i = 0; i < nb_sns; i++) {
988 a672b469 aliguori
        sn = &sn_tab[i];
989 a672b469 aliguori
        if (!strcmp(sn->id_str, name) || !strcmp(sn->name, name)) {
990 a672b469 aliguori
            *sn_info = *sn;
991 a672b469 aliguori
            ret = 0;
992 a672b469 aliguori
            break;
993 a672b469 aliguori
        }
994 a672b469 aliguori
    }
995 a672b469 aliguori
    qemu_free(sn_tab);
996 a672b469 aliguori
    return ret;
997 a672b469 aliguori
}
998 a672b469 aliguori
999 376253ec aliguori
void do_savevm(Monitor *mon, const char *name)
1000 a672b469 aliguori
{
1001 a672b469 aliguori
    BlockDriverState *bs, *bs1;
1002 a672b469 aliguori
    QEMUSnapshotInfo sn1, *sn = &sn1, old_sn1, *old_sn = &old_sn1;
1003 a672b469 aliguori
    int must_delete, ret, i;
1004 a672b469 aliguori
    BlockDriverInfo bdi1, *bdi = &bdi1;
1005 a672b469 aliguori
    QEMUFile *f;
1006 a672b469 aliguori
    int saved_vm_running;
1007 2d22b18f aliguori
    uint32_t vm_state_size;
1008 a672b469 aliguori
#ifdef _WIN32
1009 a672b469 aliguori
    struct _timeb tb;
1010 a672b469 aliguori
#else
1011 a672b469 aliguori
    struct timeval tv;
1012 a672b469 aliguori
#endif
1013 a672b469 aliguori
1014 a672b469 aliguori
    bs = get_bs_snapshots();
1015 a672b469 aliguori
    if (!bs) {
1016 376253ec aliguori
        monitor_printf(mon, "No block device can accept snapshots\n");
1017 a672b469 aliguori
        return;
1018 a672b469 aliguori
    }
1019 a672b469 aliguori
1020 a672b469 aliguori
    /* ??? Should this occur after vm_stop?  */
1021 a672b469 aliguori
    qemu_aio_flush();
1022 a672b469 aliguori
1023 a672b469 aliguori
    saved_vm_running = vm_running;
1024 a672b469 aliguori
    vm_stop(0);
1025 a672b469 aliguori
1026 a672b469 aliguori
    must_delete = 0;
1027 a672b469 aliguori
    if (name) {
1028 a672b469 aliguori
        ret = bdrv_snapshot_find(bs, old_sn, name);
1029 a672b469 aliguori
        if (ret >= 0) {
1030 a672b469 aliguori
            must_delete = 1;
1031 a672b469 aliguori
        }
1032 a672b469 aliguori
    }
1033 a672b469 aliguori
    memset(sn, 0, sizeof(*sn));
1034 a672b469 aliguori
    if (must_delete) {
1035 a672b469 aliguori
        pstrcpy(sn->name, sizeof(sn->name), old_sn->name);
1036 a672b469 aliguori
        pstrcpy(sn->id_str, sizeof(sn->id_str), old_sn->id_str);
1037 a672b469 aliguori
    } else {
1038 a672b469 aliguori
        if (name)
1039 a672b469 aliguori
            pstrcpy(sn->name, sizeof(sn->name), name);
1040 a672b469 aliguori
    }
1041 a672b469 aliguori
1042 a672b469 aliguori
    /* fill auxiliary fields */
1043 a672b469 aliguori
#ifdef _WIN32
1044 a672b469 aliguori
    _ftime(&tb);
1045 a672b469 aliguori
    sn->date_sec = tb.time;
1046 a672b469 aliguori
    sn->date_nsec = tb.millitm * 1000000;
1047 a672b469 aliguori
#else
1048 a672b469 aliguori
    gettimeofday(&tv, NULL);
1049 a672b469 aliguori
    sn->date_sec = tv.tv_sec;
1050 a672b469 aliguori
    sn->date_nsec = tv.tv_usec * 1000;
1051 a672b469 aliguori
#endif
1052 a672b469 aliguori
    sn->vm_clock_nsec = qemu_get_clock(vm_clock);
1053 a672b469 aliguori
1054 a672b469 aliguori
    if (bdrv_get_info(bs, bdi) < 0 || bdi->vm_state_offset <= 0) {
1055 376253ec aliguori
        monitor_printf(mon, "Device %s does not support VM state snapshots\n",
1056 376253ec aliguori
                       bdrv_get_device_name(bs));
1057 a672b469 aliguori
        goto the_end;
1058 a672b469 aliguori
    }
1059 a672b469 aliguori
1060 a672b469 aliguori
    /* save the VM state */
1061 a672b469 aliguori
    f = qemu_fopen_bdrv(bs, bdi->vm_state_offset, 1);
1062 a672b469 aliguori
    if (!f) {
1063 376253ec aliguori
        monitor_printf(mon, "Could not open VM state file\n");
1064 a672b469 aliguori
        goto the_end;
1065 a672b469 aliguori
    }
1066 a672b469 aliguori
    ret = qemu_savevm_state(f);
1067 2d22b18f aliguori
    vm_state_size = qemu_ftell(f);
1068 a672b469 aliguori
    qemu_fclose(f);
1069 a672b469 aliguori
    if (ret < 0) {
1070 376253ec aliguori
        monitor_printf(mon, "Error %d while writing VM\n", ret);
1071 a672b469 aliguori
        goto the_end;
1072 a672b469 aliguori
    }
1073 a672b469 aliguori
1074 a672b469 aliguori
    /* create the snapshots */
1075 a672b469 aliguori
1076 a672b469 aliguori
    for(i = 0; i < nb_drives; i++) {
1077 a672b469 aliguori
        bs1 = drives_table[i].bdrv;
1078 a672b469 aliguori
        if (bdrv_has_snapshot(bs1)) {
1079 a672b469 aliguori
            if (must_delete) {
1080 a672b469 aliguori
                ret = bdrv_snapshot_delete(bs1, old_sn->id_str);
1081 a672b469 aliguori
                if (ret < 0) {
1082 376253ec aliguori
                    monitor_printf(mon,
1083 376253ec aliguori
                                   "Error while deleting snapshot on '%s'\n",
1084 376253ec aliguori
                                   bdrv_get_device_name(bs1));
1085 a672b469 aliguori
                }
1086 a672b469 aliguori
            }
1087 2d22b18f aliguori
            /* Write VM state size only to the image that contains the state */
1088 2d22b18f aliguori
            sn->vm_state_size = (bs == bs1 ? vm_state_size : 0);
1089 a672b469 aliguori
            ret = bdrv_snapshot_create(bs1, sn);
1090 a672b469 aliguori
            if (ret < 0) {
1091 376253ec aliguori
                monitor_printf(mon, "Error while creating snapshot on '%s'\n",
1092 376253ec aliguori
                               bdrv_get_device_name(bs1));
1093 a672b469 aliguori
            }
1094 a672b469 aliguori
        }
1095 a672b469 aliguori
    }
1096 a672b469 aliguori
1097 a672b469 aliguori
 the_end:
1098 a672b469 aliguori
    if (saved_vm_running)
1099 a672b469 aliguori
        vm_start();
1100 a672b469 aliguori
}
1101 a672b469 aliguori
1102 376253ec aliguori
void do_loadvm(Monitor *mon, const char *name)
1103 a672b469 aliguori
{
1104 a672b469 aliguori
    BlockDriverState *bs, *bs1;
1105 a672b469 aliguori
    BlockDriverInfo bdi1, *bdi = &bdi1;
1106 2d22b18f aliguori
    QEMUSnapshotInfo sn;
1107 a672b469 aliguori
    QEMUFile *f;
1108 a672b469 aliguori
    int i, ret;
1109 a672b469 aliguori
    int saved_vm_running;
1110 a672b469 aliguori
1111 a672b469 aliguori
    bs = get_bs_snapshots();
1112 a672b469 aliguori
    if (!bs) {
1113 376253ec aliguori
        monitor_printf(mon, "No block device supports snapshots\n");
1114 a672b469 aliguori
        return;
1115 a672b469 aliguori
    }
1116 a672b469 aliguori
1117 a672b469 aliguori
    /* Flush all IO requests so they don't interfere with the new state.  */
1118 a672b469 aliguori
    qemu_aio_flush();
1119 a672b469 aliguori
1120 a672b469 aliguori
    saved_vm_running = vm_running;
1121 a672b469 aliguori
    vm_stop(0);
1122 a672b469 aliguori
1123 a672b469 aliguori
    for(i = 0; i <= nb_drives; i++) {
1124 a672b469 aliguori
        bs1 = drives_table[i].bdrv;
1125 a672b469 aliguori
        if (bdrv_has_snapshot(bs1)) {
1126 a672b469 aliguori
            ret = bdrv_snapshot_goto(bs1, name);
1127 a672b469 aliguori
            if (ret < 0) {
1128 a672b469 aliguori
                if (bs != bs1)
1129 376253ec aliguori
                    monitor_printf(mon, "Warning: ");
1130 a672b469 aliguori
                switch(ret) {
1131 a672b469 aliguori
                case -ENOTSUP:
1132 376253ec aliguori
                    monitor_printf(mon,
1133 376253ec aliguori
                                   "Snapshots not supported on device '%s'\n",
1134 376253ec aliguori
                                   bdrv_get_device_name(bs1));
1135 a672b469 aliguori
                    break;
1136 a672b469 aliguori
                case -ENOENT:
1137 376253ec aliguori
                    monitor_printf(mon, "Could not find snapshot '%s' on "
1138 376253ec aliguori
                                   "device '%s'\n",
1139 376253ec aliguori
                                   name, bdrv_get_device_name(bs1));
1140 a672b469 aliguori
                    break;
1141 a672b469 aliguori
                default:
1142 376253ec aliguori
                    monitor_printf(mon, "Error %d while activating snapshot on"
1143 376253ec aliguori
                                   " '%s'\n", ret, bdrv_get_device_name(bs1));
1144 a672b469 aliguori
                    break;
1145 a672b469 aliguori
                }
1146 a672b469 aliguori
                /* fatal on snapshot block device */
1147 a672b469 aliguori
                if (bs == bs1)
1148 a672b469 aliguori
                    goto the_end;
1149 a672b469 aliguori
            }
1150 a672b469 aliguori
        }
1151 a672b469 aliguori
    }
1152 a672b469 aliguori
1153 a672b469 aliguori
    if (bdrv_get_info(bs, bdi) < 0 || bdi->vm_state_offset <= 0) {
1154 376253ec aliguori
        monitor_printf(mon, "Device %s does not support VM state snapshots\n",
1155 376253ec aliguori
                       bdrv_get_device_name(bs));
1156 a672b469 aliguori
        return;
1157 a672b469 aliguori
    }
1158 a672b469 aliguori
1159 2d22b18f aliguori
    /* Don't even try to load empty VM states */
1160 2d22b18f aliguori
    ret = bdrv_snapshot_find(bs, &sn, name);
1161 2d22b18f aliguori
    if ((ret >= 0) && (sn.vm_state_size == 0))
1162 2d22b18f aliguori
        goto the_end;
1163 2d22b18f aliguori
1164 a672b469 aliguori
    /* restore the VM state */
1165 a672b469 aliguori
    f = qemu_fopen_bdrv(bs, bdi->vm_state_offset, 0);
1166 a672b469 aliguori
    if (!f) {
1167 376253ec aliguori
        monitor_printf(mon, "Could not open VM state file\n");
1168 a672b469 aliguori
        goto the_end;
1169 a672b469 aliguori
    }
1170 a672b469 aliguori
    ret = qemu_loadvm_state(f);
1171 a672b469 aliguori
    qemu_fclose(f);
1172 a672b469 aliguori
    if (ret < 0) {
1173 376253ec aliguori
        monitor_printf(mon, "Error %d while loading VM state\n", ret);
1174 a672b469 aliguori
    }
1175 a672b469 aliguori
 the_end:
1176 a672b469 aliguori
    if (saved_vm_running)
1177 a672b469 aliguori
        vm_start();
1178 a672b469 aliguori
}
1179 a672b469 aliguori
1180 376253ec aliguori
void do_delvm(Monitor *mon, const char *name)
1181 a672b469 aliguori
{
1182 a672b469 aliguori
    BlockDriverState *bs, *bs1;
1183 a672b469 aliguori
    int i, ret;
1184 a672b469 aliguori
1185 a672b469 aliguori
    bs = get_bs_snapshots();
1186 a672b469 aliguori
    if (!bs) {
1187 376253ec aliguori
        monitor_printf(mon, "No block device supports snapshots\n");
1188 a672b469 aliguori
        return;
1189 a672b469 aliguori
    }
1190 a672b469 aliguori
1191 a672b469 aliguori
    for(i = 0; i <= nb_drives; i++) {
1192 a672b469 aliguori
        bs1 = drives_table[i].bdrv;
1193 a672b469 aliguori
        if (bdrv_has_snapshot(bs1)) {
1194 a672b469 aliguori
            ret = bdrv_snapshot_delete(bs1, name);
1195 a672b469 aliguori
            if (ret < 0) {
1196 a672b469 aliguori
                if (ret == -ENOTSUP)
1197 376253ec aliguori
                    monitor_printf(mon,
1198 376253ec aliguori
                                   "Snapshots not supported on device '%s'\n",
1199 376253ec aliguori
                                   bdrv_get_device_name(bs1));
1200 a672b469 aliguori
                else
1201 376253ec aliguori
                    monitor_printf(mon, "Error %d while deleting snapshot on "
1202 376253ec aliguori
                                   "'%s'\n", ret, bdrv_get_device_name(bs1));
1203 a672b469 aliguori
            }
1204 a672b469 aliguori
        }
1205 a672b469 aliguori
    }
1206 a672b469 aliguori
}
1207 a672b469 aliguori
1208 376253ec aliguori
void do_info_snapshots(Monitor *mon)
1209 a672b469 aliguori
{
1210 a672b469 aliguori
    BlockDriverState *bs, *bs1;
1211 a672b469 aliguori
    QEMUSnapshotInfo *sn_tab, *sn;
1212 a672b469 aliguori
    int nb_sns, i;
1213 a672b469 aliguori
    char buf[256];
1214 a672b469 aliguori
1215 a672b469 aliguori
    bs = get_bs_snapshots();
1216 a672b469 aliguori
    if (!bs) {
1217 376253ec aliguori
        monitor_printf(mon, "No available block device supports snapshots\n");
1218 a672b469 aliguori
        return;
1219 a672b469 aliguori
    }
1220 376253ec aliguori
    monitor_printf(mon, "Snapshot devices:");
1221 a672b469 aliguori
    for(i = 0; i <= nb_drives; i++) {
1222 a672b469 aliguori
        bs1 = drives_table[i].bdrv;
1223 a672b469 aliguori
        if (bdrv_has_snapshot(bs1)) {
1224 a672b469 aliguori
            if (bs == bs1)
1225 376253ec aliguori
                monitor_printf(mon, " %s", bdrv_get_device_name(bs1));
1226 a672b469 aliguori
        }
1227 a672b469 aliguori
    }
1228 376253ec aliguori
    monitor_printf(mon, "\n");
1229 a672b469 aliguori
1230 a672b469 aliguori
    nb_sns = bdrv_snapshot_list(bs, &sn_tab);
1231 a672b469 aliguori
    if (nb_sns < 0) {
1232 376253ec aliguori
        monitor_printf(mon, "bdrv_snapshot_list: error %d\n", nb_sns);
1233 a672b469 aliguori
        return;
1234 a672b469 aliguori
    }
1235 376253ec aliguori
    monitor_printf(mon, "Snapshot list (from %s):\n",
1236 376253ec aliguori
                   bdrv_get_device_name(bs));
1237 376253ec aliguori
    monitor_printf(mon, "%s\n", bdrv_snapshot_dump(buf, sizeof(buf), NULL));
1238 a672b469 aliguori
    for(i = 0; i < nb_sns; i++) {
1239 a672b469 aliguori
        sn = &sn_tab[i];
1240 376253ec aliguori
        monitor_printf(mon, "%s\n", bdrv_snapshot_dump(buf, sizeof(buf), sn));
1241 a672b469 aliguori
    }
1242 a672b469 aliguori
    qemu_free(sn_tab);
1243 a672b469 aliguori
}