]>
Commit | Line | Data |
---|---|---|
1393a485 | 1 | #include "qemu/osdep.h" |
b6fcfa59 EH |
2 | #include "qemu-common.h" |
3 | #include "migration/migration.h" | |
4 | #include "migration/qemu-file.h" | |
5 | #include "migration/vmstate.h" | |
6 | #include "qemu/bitops.h" | |
6a64b644 | 7 | #include "qemu/error-report.h" |
9013dca5 | 8 | #include "trace.h" |
b6fcfa59 EH |
9 | |
10 | static void vmstate_subsection_save(QEMUFile *f, const VMStateDescription *vmsd, | |
8118f095 | 11 | void *opaque, QJSON *vmdesc); |
b6fcfa59 EH |
12 | static int vmstate_subsection_load(QEMUFile *f, const VMStateDescription *vmsd, |
13 | void *opaque); | |
14 | ||
35fc1f71 MT |
15 | static int vmstate_n_elems(void *opaque, VMStateField *field) |
16 | { | |
17 | int n_elems = 1; | |
18 | ||
19 | if (field->flags & VMS_ARRAY) { | |
20 | n_elems = field->num; | |
21 | } else if (field->flags & VMS_VARRAY_INT32) { | |
22 | n_elems = *(int32_t *)(opaque+field->num_offset); | |
23 | } else if (field->flags & VMS_VARRAY_UINT32) { | |
24 | n_elems = *(uint32_t *)(opaque+field->num_offset); | |
25 | } else if (field->flags & VMS_VARRAY_UINT16) { | |
26 | n_elems = *(uint16_t *)(opaque+field->num_offset); | |
27 | } else if (field->flags & VMS_VARRAY_UINT8) { | |
28 | n_elems = *(uint8_t *)(opaque+field->num_offset); | |
29 | } | |
30 | ||
b47d3af7 JQ |
31 | if (field->flags & VMS_MULTIPLY_ELEMENTS) { |
32 | n_elems *= field->num; | |
33 | } | |
34 | ||
023ad1a6 | 35 | trace_vmstate_n_elems(field->name, n_elems); |
35fc1f71 MT |
36 | return n_elems; |
37 | } | |
38 | ||
39 | static int vmstate_size(void *opaque, VMStateField *field) | |
40 | { | |
41 | int size = field->size; | |
42 | ||
43 | if (field->flags & VMS_VBUFFER) { | |
44 | size = *(int32_t *)(opaque+field->size_offset); | |
45 | if (field->flags & VMS_MULTIPLY) { | |
46 | size *= field->size; | |
47 | } | |
48 | } | |
49 | ||
50 | return size; | |
51 | } | |
52 | ||
f32935ea | 53 | static void *vmstate_base_addr(void *opaque, VMStateField *field, bool alloc) |
35fc1f71 MT |
54 | { |
55 | void *base_addr = opaque + field->offset; | |
56 | ||
57 | if (field->flags & VMS_POINTER) { | |
f32935ea | 58 | if (alloc && (field->flags & VMS_ALLOC)) { |
94ed706d AK |
59 | gsize size = 0; |
60 | if (field->flags & VMS_VBUFFER) { | |
61 | size = vmstate_size(opaque, field); | |
62 | } else { | |
63 | int n_elems = vmstate_n_elems(opaque, field); | |
64 | if (n_elems) { | |
65 | size = n_elems * field->size; | |
66 | } | |
67 | } | |
68 | if (size) { | |
f32935ea AK |
69 | *((void **)base_addr + field->start) = g_malloc(size); |
70 | } | |
71 | } | |
35fc1f71 MT |
72 | base_addr = *(void **)base_addr + field->start; |
73 | } | |
74 | ||
75 | return base_addr; | |
76 | } | |
77 | ||
b6fcfa59 EH |
78 | int vmstate_load_state(QEMUFile *f, const VMStateDescription *vmsd, |
79 | void *opaque, int version_id) | |
80 | { | |
81 | VMStateField *field = vmsd->fields; | |
a5df2a02 | 82 | int ret = 0; |
b6fcfa59 | 83 | |
a5df2a02 | 84 | trace_vmstate_load_state(vmsd->name, version_id); |
b6fcfa59 | 85 | if (version_id > vmsd->version_id) { |
a5df2a02 | 86 | trace_vmstate_load_state_end(vmsd->name, "too new", -EINVAL); |
b6fcfa59 EH |
87 | return -EINVAL; |
88 | } | |
b6fcfa59 | 89 | if (version_id < vmsd->minimum_version_id) { |
767adce2 PM |
90 | if (vmsd->load_state_old && |
91 | version_id >= vmsd->minimum_version_id_old) { | |
a5df2a02 DDAG |
92 | ret = vmsd->load_state_old(f, opaque, version_id); |
93 | trace_vmstate_load_state_end(vmsd->name, "old path", ret); | |
94 | return ret; | |
767adce2 | 95 | } |
a5df2a02 | 96 | trace_vmstate_load_state_end(vmsd->name, "too old", -EINVAL); |
767adce2 | 97 | return -EINVAL; |
b6fcfa59 EH |
98 | } |
99 | if (vmsd->pre_load) { | |
100 | int ret = vmsd->pre_load(opaque); | |
101 | if (ret) { | |
102 | return ret; | |
103 | } | |
104 | } | |
105 | while (field->name) { | |
a5df2a02 | 106 | trace_vmstate_load_state_field(vmsd->name, field->name); |
b6fcfa59 EH |
107 | if ((field->field_exists && |
108 | field->field_exists(opaque, version_id)) || | |
109 | (!field->field_exists && | |
110 | field->version_id <= version_id)) { | |
f32935ea | 111 | void *base_addr = vmstate_base_addr(opaque, field, true); |
35fc1f71 MT |
112 | int i, n_elems = vmstate_n_elems(opaque, field); |
113 | int size = vmstate_size(opaque, field); | |
114 | ||
b6fcfa59 EH |
115 | for (i = 0; i < n_elems; i++) { |
116 | void *addr = base_addr + size * i; | |
117 | ||
118 | if (field->flags & VMS_ARRAY_OF_POINTER) { | |
119 | addr = *(void **)addr; | |
120 | } | |
121 | if (field->flags & VMS_STRUCT) { | |
122 | ret = vmstate_load_state(f, field->vmsd, addr, | |
123 | field->vmsd->version_id); | |
124 | } else { | |
125 | ret = field->info->get(f, addr, size); | |
126 | ||
127 | } | |
13cde508 JQ |
128 | if (ret >= 0) { |
129 | ret = qemu_file_get_error(f); | |
130 | } | |
b6fcfa59 | 131 | if (ret < 0) { |
13cde508 | 132 | qemu_file_set_error(f, ret); |
a1771070 DDAG |
133 | error_report("Failed to load %s:%s", vmsd->name, |
134 | field->name); | |
9013dca5 | 135 | trace_vmstate_load_field_error(field->name, ret); |
b6fcfa59 EH |
136 | return ret; |
137 | } | |
138 | } | |
5bf81c8d | 139 | } else if (field->flags & VMS_MUST_EXIST) { |
6a64b644 DDAG |
140 | error_report("Input validation failed: %s/%s", |
141 | vmsd->name, field->name); | |
5bf81c8d | 142 | return -1; |
b6fcfa59 EH |
143 | } |
144 | field++; | |
145 | } | |
146 | ret = vmstate_subsection_load(f, vmsd, opaque); | |
147 | if (ret != 0) { | |
148 | return ret; | |
149 | } | |
150 | if (vmsd->post_load) { | |
a5df2a02 | 151 | ret = vmsd->post_load(opaque, version_id); |
b6fcfa59 | 152 | } |
a5df2a02 DDAG |
153 | trace_vmstate_load_state_end(vmsd->name, "end", ret); |
154 | return ret; | |
b6fcfa59 EH |
155 | } |
156 | ||
8118f095 AG |
157 | static int vmfield_name_num(VMStateField *start, VMStateField *search) |
158 | { | |
159 | VMStateField *field; | |
160 | int found = 0; | |
161 | ||
162 | for (field = start; field->name; field++) { | |
163 | if (!strcmp(field->name, search->name)) { | |
164 | if (field == search) { | |
165 | return found; | |
166 | } | |
167 | found++; | |
168 | } | |
169 | } | |
170 | ||
171 | return -1; | |
172 | } | |
173 | ||
174 | static bool vmfield_name_is_unique(VMStateField *start, VMStateField *search) | |
175 | { | |
176 | VMStateField *field; | |
177 | int found = 0; | |
178 | ||
179 | for (field = start; field->name; field++) { | |
180 | if (!strcmp(field->name, search->name)) { | |
181 | found++; | |
182 | /* name found more than once, so it's not unique */ | |
183 | if (found > 1) { | |
184 | return false; | |
185 | } | |
186 | } | |
187 | } | |
188 | ||
189 | return true; | |
190 | } | |
191 | ||
192 | static const char *vmfield_get_type_name(VMStateField *field) | |
193 | { | |
194 | const char *type = "unknown"; | |
195 | ||
196 | if (field->flags & VMS_STRUCT) { | |
197 | type = "struct"; | |
198 | } else if (field->info->name) { | |
199 | type = field->info->name; | |
200 | } | |
201 | ||
202 | return type; | |
203 | } | |
204 | ||
205 | static bool vmsd_can_compress(VMStateField *field) | |
206 | { | |
207 | if (field->field_exists) { | |
208 | /* Dynamically existing fields mess up compression */ | |
209 | return false; | |
210 | } | |
211 | ||
212 | if (field->flags & VMS_STRUCT) { | |
213 | VMStateField *sfield = field->vmsd->fields; | |
214 | while (sfield->name) { | |
215 | if (!vmsd_can_compress(sfield)) { | |
216 | /* Child elements can't compress, so can't we */ | |
217 | return false; | |
218 | } | |
219 | sfield++; | |
220 | } | |
221 | ||
222 | if (field->vmsd->subsections) { | |
223 | /* Subsections may come and go, better don't compress */ | |
224 | return false; | |
225 | } | |
226 | } | |
227 | ||
228 | return true; | |
229 | } | |
230 | ||
231 | static void vmsd_desc_field_start(const VMStateDescription *vmsd, QJSON *vmdesc, | |
232 | VMStateField *field, int i, int max) | |
233 | { | |
234 | char *name, *old_name; | |
235 | bool is_array = max > 1; | |
236 | bool can_compress = vmsd_can_compress(field); | |
237 | ||
238 | if (!vmdesc) { | |
239 | return; | |
240 | } | |
241 | ||
242 | name = g_strdup(field->name); | |
243 | ||
244 | /* Field name is not unique, need to make it unique */ | |
245 | if (!vmfield_name_is_unique(vmsd->fields, field)) { | |
246 | int num = vmfield_name_num(vmsd->fields, field); | |
247 | old_name = name; | |
248 | name = g_strdup_printf("%s[%d]", name, num); | |
249 | g_free(old_name); | |
250 | } | |
251 | ||
252 | json_start_object(vmdesc, NULL); | |
253 | json_prop_str(vmdesc, "name", name); | |
254 | if (is_array) { | |
255 | if (can_compress) { | |
256 | json_prop_int(vmdesc, "array_len", max); | |
257 | } else { | |
258 | json_prop_int(vmdesc, "index", i); | |
259 | } | |
260 | } | |
261 | json_prop_str(vmdesc, "type", vmfield_get_type_name(field)); | |
262 | ||
263 | if (field->flags & VMS_STRUCT) { | |
264 | json_start_object(vmdesc, "struct"); | |
265 | } | |
266 | ||
267 | g_free(name); | |
268 | } | |
269 | ||
270 | static void vmsd_desc_field_end(const VMStateDescription *vmsd, QJSON *vmdesc, | |
271 | VMStateField *field, size_t size, int i) | |
272 | { | |
273 | if (!vmdesc) { | |
274 | return; | |
275 | } | |
276 | ||
277 | if (field->flags & VMS_STRUCT) { | |
278 | /* We printed a struct in between, close its child object */ | |
279 | json_end_object(vmdesc); | |
280 | } | |
281 | ||
282 | json_prop_int(vmdesc, "size", size); | |
283 | json_end_object(vmdesc); | |
284 | } | |
285 | ||
df896152 JQ |
286 | |
287 | bool vmstate_save_needed(const VMStateDescription *vmsd, void *opaque) | |
288 | { | |
289 | if (vmsd->needed && !vmsd->needed(opaque)) { | |
290 | /* optional section not needed */ | |
291 | return false; | |
292 | } | |
293 | return true; | |
294 | } | |
295 | ||
296 | ||
b6fcfa59 | 297 | void vmstate_save_state(QEMUFile *f, const VMStateDescription *vmsd, |
8118f095 | 298 | void *opaque, QJSON *vmdesc) |
b6fcfa59 EH |
299 | { |
300 | VMStateField *field = vmsd->fields; | |
301 | ||
302 | if (vmsd->pre_save) { | |
303 | vmsd->pre_save(opaque); | |
304 | } | |
8118f095 AG |
305 | |
306 | if (vmdesc) { | |
307 | json_prop_str(vmdesc, "vmsd_name", vmsd->name); | |
308 | json_prop_int(vmdesc, "version", vmsd->version_id); | |
309 | json_start_array(vmdesc, "fields"); | |
310 | } | |
311 | ||
b6fcfa59 EH |
312 | while (field->name) { |
313 | if (!field->field_exists || | |
314 | field->field_exists(opaque, vmsd->version_id)) { | |
f32935ea | 315 | void *base_addr = vmstate_base_addr(opaque, field, false); |
35fc1f71 MT |
316 | int i, n_elems = vmstate_n_elems(opaque, field); |
317 | int size = vmstate_size(opaque, field); | |
8118f095 AG |
318 | int64_t old_offset, written_bytes; |
319 | QJSON *vmdesc_loop = vmdesc; | |
35fc1f71 | 320 | |
b6fcfa59 EH |
321 | for (i = 0; i < n_elems; i++) { |
322 | void *addr = base_addr + size * i; | |
323 | ||
8118f095 AG |
324 | vmsd_desc_field_start(vmsd, vmdesc_loop, field, i, n_elems); |
325 | old_offset = qemu_ftell_fast(f); | |
326 | ||
b6fcfa59 EH |
327 | if (field->flags & VMS_ARRAY_OF_POINTER) { |
328 | addr = *(void **)addr; | |
329 | } | |
330 | if (field->flags & VMS_STRUCT) { | |
8118f095 | 331 | vmstate_save_state(f, field->vmsd, addr, vmdesc_loop); |
b6fcfa59 EH |
332 | } else { |
333 | field->info->put(f, addr, size); | |
334 | } | |
8118f095 AG |
335 | |
336 | written_bytes = qemu_ftell_fast(f) - old_offset; | |
337 | vmsd_desc_field_end(vmsd, vmdesc_loop, field, written_bytes, i); | |
338 | ||
339 | /* Compressed arrays only care about the first element */ | |
340 | if (vmdesc_loop && vmsd_can_compress(field)) { | |
341 | vmdesc_loop = NULL; | |
342 | } | |
b6fcfa59 | 343 | } |
5bf81c8d MT |
344 | } else { |
345 | if (field->flags & VMS_MUST_EXIST) { | |
6a64b644 | 346 | error_report("Output state validation failed: %s/%s", |
5bf81c8d MT |
347 | vmsd->name, field->name); |
348 | assert(!(field->flags & VMS_MUST_EXIST)); | |
349 | } | |
b6fcfa59 EH |
350 | } |
351 | field++; | |
352 | } | |
8118f095 AG |
353 | |
354 | if (vmdesc) { | |
355 | json_end_array(vmdesc); | |
356 | } | |
357 | ||
358 | vmstate_subsection_save(f, vmsd, opaque, vmdesc); | |
b6fcfa59 EH |
359 | } |
360 | ||
361 | static const VMStateDescription * | |
5cd8cada | 362 | vmstate_get_subsection(const VMStateDescription **sub, char *idstr) |
b6fcfa59 | 363 | { |
5cd8cada JQ |
364 | while (sub && *sub && (*sub)->needed) { |
365 | if (strcmp(idstr, (*sub)->name) == 0) { | |
366 | return *sub; | |
b6fcfa59 EH |
367 | } |
368 | sub++; | |
369 | } | |
370 | return NULL; | |
371 | } | |
372 | ||
373 | static int vmstate_subsection_load(QEMUFile *f, const VMStateDescription *vmsd, | |
374 | void *opaque) | |
375 | { | |
a5df2a02 DDAG |
376 | trace_vmstate_subsection_load(vmsd->name); |
377 | ||
b6fcfa59 | 378 | while (qemu_peek_byte(f, 0) == QEMU_VM_SUBSECTION) { |
7c1e52ba | 379 | char idstr[256], *idstr_ret; |
b6fcfa59 EH |
380 | int ret; |
381 | uint8_t version_id, len, size; | |
382 | const VMStateDescription *sub_vmsd; | |
383 | ||
384 | len = qemu_peek_byte(f, 1); | |
385 | if (len < strlen(vmsd->name) + 1) { | |
386 | /* subsection name has be be "section_name/a" */ | |
023ad1a6 | 387 | trace_vmstate_subsection_load_bad(vmsd->name, "(short)", ""); |
b6fcfa59 EH |
388 | return 0; |
389 | } | |
7c1e52ba | 390 | size = qemu_peek_buffer(f, (uint8_t **)&idstr_ret, len, 2); |
b6fcfa59 | 391 | if (size != len) { |
023ad1a6 | 392 | trace_vmstate_subsection_load_bad(vmsd->name, "(peek fail)", ""); |
b6fcfa59 EH |
393 | return 0; |
394 | } | |
7c1e52ba | 395 | memcpy(idstr, idstr_ret, size); |
b6fcfa59 EH |
396 | idstr[size] = 0; |
397 | ||
398 | if (strncmp(vmsd->name, idstr, strlen(vmsd->name)) != 0) { | |
023ad1a6 DDAG |
399 | trace_vmstate_subsection_load_bad(vmsd->name, idstr, "(prefix)"); |
400 | /* it doesn't have a valid subsection name */ | |
b6fcfa59 EH |
401 | return 0; |
402 | } | |
403 | sub_vmsd = vmstate_get_subsection(vmsd->subsections, idstr); | |
404 | if (sub_vmsd == NULL) { | |
023ad1a6 | 405 | trace_vmstate_subsection_load_bad(vmsd->name, idstr, "(lookup)"); |
b6fcfa59 EH |
406 | return -ENOENT; |
407 | } | |
408 | qemu_file_skip(f, 1); /* subsection */ | |
409 | qemu_file_skip(f, 1); /* len */ | |
410 | qemu_file_skip(f, len); /* idstr */ | |
411 | version_id = qemu_get_be32(f); | |
412 | ||
413 | ret = vmstate_load_state(f, sub_vmsd, opaque, version_id); | |
414 | if (ret) { | |
023ad1a6 | 415 | trace_vmstate_subsection_load_bad(vmsd->name, idstr, "(child)"); |
b6fcfa59 EH |
416 | return ret; |
417 | } | |
418 | } | |
a5df2a02 DDAG |
419 | |
420 | trace_vmstate_subsection_load_good(vmsd->name); | |
b6fcfa59 EH |
421 | return 0; |
422 | } | |
423 | ||
424 | static void vmstate_subsection_save(QEMUFile *f, const VMStateDescription *vmsd, | |
8118f095 | 425 | void *opaque, QJSON *vmdesc) |
b6fcfa59 | 426 | { |
5cd8cada | 427 | const VMStateDescription **sub = vmsd->subsections; |
8118f095 | 428 | bool subsection_found = false; |
b6fcfa59 | 429 | |
5cd8cada JQ |
430 | while (sub && *sub && (*sub)->needed) { |
431 | if ((*sub)->needed(opaque)) { | |
432 | const VMStateDescription *vmsd = *sub; | |
b6fcfa59 EH |
433 | uint8_t len; |
434 | ||
8118f095 AG |
435 | if (vmdesc) { |
436 | /* Only create subsection array when we have any */ | |
437 | if (!subsection_found) { | |
438 | json_start_array(vmdesc, "subsections"); | |
439 | subsection_found = true; | |
440 | } | |
441 | ||
442 | json_start_object(vmdesc, NULL); | |
443 | } | |
444 | ||
b6fcfa59 EH |
445 | qemu_put_byte(f, QEMU_VM_SUBSECTION); |
446 | len = strlen(vmsd->name); | |
447 | qemu_put_byte(f, len); | |
448 | qemu_put_buffer(f, (uint8_t *)vmsd->name, len); | |
449 | qemu_put_be32(f, vmsd->version_id); | |
8118f095 AG |
450 | vmstate_save_state(f, vmsd, opaque, vmdesc); |
451 | ||
452 | if (vmdesc) { | |
453 | json_end_object(vmdesc); | |
454 | } | |
b6fcfa59 EH |
455 | } |
456 | sub++; | |
457 | } | |
8118f095 AG |
458 | |
459 | if (vmdesc && subsection_found) { | |
460 | json_end_array(vmdesc); | |
461 | } | |
b6fcfa59 EH |
462 | } |
463 | ||
464 | /* bool */ | |
465 | ||
466 | static int get_bool(QEMUFile *f, void *pv, size_t size) | |
467 | { | |
468 | bool *v = pv; | |
469 | *v = qemu_get_byte(f); | |
470 | return 0; | |
471 | } | |
472 | ||
473 | static void put_bool(QEMUFile *f, void *pv, size_t size) | |
474 | { | |
475 | bool *v = pv; | |
476 | qemu_put_byte(f, *v); | |
477 | } | |
478 | ||
479 | const VMStateInfo vmstate_info_bool = { | |
480 | .name = "bool", | |
481 | .get = get_bool, | |
482 | .put = put_bool, | |
483 | }; | |
484 | ||
485 | /* 8 bit int */ | |
486 | ||
487 | static int get_int8(QEMUFile *f, void *pv, size_t size) | |
488 | { | |
489 | int8_t *v = pv; | |
490 | qemu_get_s8s(f, v); | |
491 | return 0; | |
492 | } | |
493 | ||
494 | static void put_int8(QEMUFile *f, void *pv, size_t size) | |
495 | { | |
496 | int8_t *v = pv; | |
497 | qemu_put_s8s(f, v); | |
498 | } | |
499 | ||
500 | const VMStateInfo vmstate_info_int8 = { | |
501 | .name = "int8", | |
502 | .get = get_int8, | |
503 | .put = put_int8, | |
504 | }; | |
505 | ||
506 | /* 16 bit int */ | |
507 | ||
508 | static int get_int16(QEMUFile *f, void *pv, size_t size) | |
509 | { | |
510 | int16_t *v = pv; | |
511 | qemu_get_sbe16s(f, v); | |
512 | return 0; | |
513 | } | |
514 | ||
515 | static void put_int16(QEMUFile *f, void *pv, size_t size) | |
516 | { | |
517 | int16_t *v = pv; | |
518 | qemu_put_sbe16s(f, v); | |
519 | } | |
520 | ||
521 | const VMStateInfo vmstate_info_int16 = { | |
522 | .name = "int16", | |
523 | .get = get_int16, | |
524 | .put = put_int16, | |
525 | }; | |
526 | ||
527 | /* 32 bit int */ | |
528 | ||
529 | static int get_int32(QEMUFile *f, void *pv, size_t size) | |
530 | { | |
531 | int32_t *v = pv; | |
532 | qemu_get_sbe32s(f, v); | |
533 | return 0; | |
534 | } | |
535 | ||
536 | static void put_int32(QEMUFile *f, void *pv, size_t size) | |
537 | { | |
538 | int32_t *v = pv; | |
539 | qemu_put_sbe32s(f, v); | |
540 | } | |
541 | ||
542 | const VMStateInfo vmstate_info_int32 = { | |
543 | .name = "int32", | |
544 | .get = get_int32, | |
545 | .put = put_int32, | |
546 | }; | |
547 | ||
548 | /* 32 bit int. See that the received value is the same than the one | |
549 | in the field */ | |
550 | ||
551 | static int get_int32_equal(QEMUFile *f, void *pv, size_t size) | |
552 | { | |
553 | int32_t *v = pv; | |
554 | int32_t v2; | |
555 | qemu_get_sbe32s(f, &v2); | |
556 | ||
557 | if (*v == v2) { | |
558 | return 0; | |
559 | } | |
49228e17 | 560 | error_report("%" PRIx32 " != %" PRIx32, *v, v2); |
b6fcfa59 EH |
561 | return -EINVAL; |
562 | } | |
563 | ||
564 | const VMStateInfo vmstate_info_int32_equal = { | |
565 | .name = "int32 equal", | |
566 | .get = get_int32_equal, | |
567 | .put = put_int32, | |
568 | }; | |
569 | ||
d2ef4b61 MT |
570 | /* 32 bit int. Check that the received value is non-negative |
571 | * and less than or equal to the one in the field. | |
572 | */ | |
b6fcfa59 EH |
573 | |
574 | static int get_int32_le(QEMUFile *f, void *pv, size_t size) | |
575 | { | |
24a370ef DDAG |
576 | int32_t *cur = pv; |
577 | int32_t loaded; | |
578 | qemu_get_sbe32s(f, &loaded); | |
b6fcfa59 | 579 | |
d2ef4b61 | 580 | if (loaded >= 0 && loaded <= *cur) { |
24a370ef | 581 | *cur = loaded; |
b6fcfa59 EH |
582 | return 0; |
583 | } | |
49228e17 DDAG |
584 | error_report("Invalid value %" PRId32 |
585 | " expecting positive value <= %" PRId32, | |
586 | loaded, *cur); | |
b6fcfa59 EH |
587 | return -EINVAL; |
588 | } | |
589 | ||
590 | const VMStateInfo vmstate_info_int32_le = { | |
24a370ef | 591 | .name = "int32 le", |
b6fcfa59 EH |
592 | .get = get_int32_le, |
593 | .put = put_int32, | |
594 | }; | |
595 | ||
596 | /* 64 bit int */ | |
597 | ||
598 | static int get_int64(QEMUFile *f, void *pv, size_t size) | |
599 | { | |
600 | int64_t *v = pv; | |
601 | qemu_get_sbe64s(f, v); | |
602 | return 0; | |
603 | } | |
604 | ||
605 | static void put_int64(QEMUFile *f, void *pv, size_t size) | |
606 | { | |
607 | int64_t *v = pv; | |
608 | qemu_put_sbe64s(f, v); | |
609 | } | |
610 | ||
611 | const VMStateInfo vmstate_info_int64 = { | |
612 | .name = "int64", | |
613 | .get = get_int64, | |
614 | .put = put_int64, | |
615 | }; | |
616 | ||
617 | /* 8 bit unsigned int */ | |
618 | ||
619 | static int get_uint8(QEMUFile *f, void *pv, size_t size) | |
620 | { | |
621 | uint8_t *v = pv; | |
622 | qemu_get_8s(f, v); | |
623 | return 0; | |
624 | } | |
625 | ||
626 | static void put_uint8(QEMUFile *f, void *pv, size_t size) | |
627 | { | |
628 | uint8_t *v = pv; | |
629 | qemu_put_8s(f, v); | |
630 | } | |
631 | ||
632 | const VMStateInfo vmstate_info_uint8 = { | |
633 | .name = "uint8", | |
634 | .get = get_uint8, | |
635 | .put = put_uint8, | |
636 | }; | |
637 | ||
638 | /* 16 bit unsigned int */ | |
639 | ||
640 | static int get_uint16(QEMUFile *f, void *pv, size_t size) | |
641 | { | |
642 | uint16_t *v = pv; | |
643 | qemu_get_be16s(f, v); | |
644 | return 0; | |
645 | } | |
646 | ||
647 | static void put_uint16(QEMUFile *f, void *pv, size_t size) | |
648 | { | |
649 | uint16_t *v = pv; | |
650 | qemu_put_be16s(f, v); | |
651 | } | |
652 | ||
653 | const VMStateInfo vmstate_info_uint16 = { | |
654 | .name = "uint16", | |
655 | .get = get_uint16, | |
656 | .put = put_uint16, | |
657 | }; | |
658 | ||
659 | /* 32 bit unsigned int */ | |
660 | ||
661 | static int get_uint32(QEMUFile *f, void *pv, size_t size) | |
662 | { | |
663 | uint32_t *v = pv; | |
664 | qemu_get_be32s(f, v); | |
665 | return 0; | |
666 | } | |
667 | ||
668 | static void put_uint32(QEMUFile *f, void *pv, size_t size) | |
669 | { | |
670 | uint32_t *v = pv; | |
671 | qemu_put_be32s(f, v); | |
672 | } | |
673 | ||
674 | const VMStateInfo vmstate_info_uint32 = { | |
675 | .name = "uint32", | |
676 | .get = get_uint32, | |
677 | .put = put_uint32, | |
678 | }; | |
679 | ||
680 | /* 32 bit uint. See that the received value is the same than the one | |
681 | in the field */ | |
682 | ||
683 | static int get_uint32_equal(QEMUFile *f, void *pv, size_t size) | |
684 | { | |
685 | uint32_t *v = pv; | |
686 | uint32_t v2; | |
687 | qemu_get_be32s(f, &v2); | |
688 | ||
689 | if (*v == v2) { | |
690 | return 0; | |
691 | } | |
49228e17 | 692 | error_report("%" PRIx32 " != %" PRIx32, *v, v2); |
b6fcfa59 EH |
693 | return -EINVAL; |
694 | } | |
695 | ||
696 | const VMStateInfo vmstate_info_uint32_equal = { | |
697 | .name = "uint32 equal", | |
698 | .get = get_uint32_equal, | |
699 | .put = put_uint32, | |
700 | }; | |
701 | ||
702 | /* 64 bit unsigned int */ | |
703 | ||
704 | static int get_uint64(QEMUFile *f, void *pv, size_t size) | |
705 | { | |
706 | uint64_t *v = pv; | |
707 | qemu_get_be64s(f, v); | |
708 | return 0; | |
709 | } | |
710 | ||
711 | static void put_uint64(QEMUFile *f, void *pv, size_t size) | |
712 | { | |
713 | uint64_t *v = pv; | |
714 | qemu_put_be64s(f, v); | |
715 | } | |
716 | ||
717 | const VMStateInfo vmstate_info_uint64 = { | |
718 | .name = "uint64", | |
719 | .get = get_uint64, | |
720 | .put = put_uint64, | |
721 | }; | |
722 | ||
723 | /* 64 bit unsigned int. See that the received value is the same than the one | |
724 | in the field */ | |
725 | ||
726 | static int get_uint64_equal(QEMUFile *f, void *pv, size_t size) | |
727 | { | |
728 | uint64_t *v = pv; | |
729 | uint64_t v2; | |
730 | qemu_get_be64s(f, &v2); | |
731 | ||
732 | if (*v == v2) { | |
733 | return 0; | |
734 | } | |
49228e17 | 735 | error_report("%" PRIx64 " != %" PRIx64, *v, v2); |
b6fcfa59 EH |
736 | return -EINVAL; |
737 | } | |
738 | ||
739 | const VMStateInfo vmstate_info_uint64_equal = { | |
740 | .name = "int64 equal", | |
741 | .get = get_uint64_equal, | |
742 | .put = put_uint64, | |
743 | }; | |
744 | ||
745 | /* 8 bit int. See that the received value is the same than the one | |
746 | in the field */ | |
747 | ||
748 | static int get_uint8_equal(QEMUFile *f, void *pv, size_t size) | |
749 | { | |
750 | uint8_t *v = pv; | |
751 | uint8_t v2; | |
752 | qemu_get_8s(f, &v2); | |
753 | ||
754 | if (*v == v2) { | |
755 | return 0; | |
756 | } | |
49228e17 | 757 | error_report("%x != %x", *v, v2); |
b6fcfa59 EH |
758 | return -EINVAL; |
759 | } | |
760 | ||
761 | const VMStateInfo vmstate_info_uint8_equal = { | |
762 | .name = "uint8 equal", | |
763 | .get = get_uint8_equal, | |
764 | .put = put_uint8, | |
765 | }; | |
766 | ||
767 | /* 16 bit unsigned int int. See that the received value is the same than the one | |
768 | in the field */ | |
769 | ||
770 | static int get_uint16_equal(QEMUFile *f, void *pv, size_t size) | |
771 | { | |
772 | uint16_t *v = pv; | |
773 | uint16_t v2; | |
774 | qemu_get_be16s(f, &v2); | |
775 | ||
776 | if (*v == v2) { | |
777 | return 0; | |
778 | } | |
49228e17 | 779 | error_report("%x != %x", *v, v2); |
b6fcfa59 EH |
780 | return -EINVAL; |
781 | } | |
782 | ||
783 | const VMStateInfo vmstate_info_uint16_equal = { | |
784 | .name = "uint16 equal", | |
785 | .get = get_uint16_equal, | |
786 | .put = put_uint16, | |
787 | }; | |
788 | ||
789 | /* floating point */ | |
790 | ||
791 | static int get_float64(QEMUFile *f, void *pv, size_t size) | |
792 | { | |
793 | float64 *v = pv; | |
794 | ||
795 | *v = make_float64(qemu_get_be64(f)); | |
796 | return 0; | |
797 | } | |
798 | ||
799 | static void put_float64(QEMUFile *f, void *pv, size_t size) | |
800 | { | |
801 | uint64_t *v = pv; | |
802 | ||
803 | qemu_put_be64(f, float64_val(*v)); | |
804 | } | |
805 | ||
806 | const VMStateInfo vmstate_info_float64 = { | |
807 | .name = "float64", | |
808 | .get = get_float64, | |
809 | .put = put_float64, | |
810 | }; | |
811 | ||
55174749 JQ |
812 | /* CPU_DoubleU type */ |
813 | ||
814 | static int get_cpudouble(QEMUFile *f, void *pv, size_t size) | |
815 | { | |
816 | CPU_DoubleU *v = pv; | |
817 | qemu_get_be32s(f, &v->l.upper); | |
818 | qemu_get_be32s(f, &v->l.lower); | |
819 | return 0; | |
820 | } | |
821 | ||
822 | static void put_cpudouble(QEMUFile *f, void *pv, size_t size) | |
823 | { | |
824 | CPU_DoubleU *v = pv; | |
825 | qemu_put_be32s(f, &v->l.upper); | |
826 | qemu_put_be32s(f, &v->l.lower); | |
827 | } | |
828 | ||
829 | const VMStateInfo vmstate_info_cpudouble = { | |
830 | .name = "CPU_Double_U", | |
831 | .get = get_cpudouble, | |
832 | .put = put_cpudouble, | |
833 | }; | |
834 | ||
b6fcfa59 EH |
835 | /* uint8_t buffers */ |
836 | ||
837 | static int get_buffer(QEMUFile *f, void *pv, size_t size) | |
838 | { | |
839 | uint8_t *v = pv; | |
840 | qemu_get_buffer(f, v, size); | |
841 | return 0; | |
842 | } | |
843 | ||
844 | static void put_buffer(QEMUFile *f, void *pv, size_t size) | |
845 | { | |
846 | uint8_t *v = pv; | |
847 | qemu_put_buffer(f, v, size); | |
848 | } | |
849 | ||
850 | const VMStateInfo vmstate_info_buffer = { | |
851 | .name = "buffer", | |
852 | .get = get_buffer, | |
853 | .put = put_buffer, | |
854 | }; | |
855 | ||
856 | /* unused buffers: space that was used for some fields that are | |
857 | not useful anymore */ | |
858 | ||
859 | static int get_unused_buffer(QEMUFile *f, void *pv, size_t size) | |
860 | { | |
861 | uint8_t buf[1024]; | |
862 | int block_len; | |
863 | ||
864 | while (size > 0) { | |
865 | block_len = MIN(sizeof(buf), size); | |
866 | size -= block_len; | |
867 | qemu_get_buffer(f, buf, block_len); | |
868 | } | |
869 | return 0; | |
870 | } | |
871 | ||
872 | static void put_unused_buffer(QEMUFile *f, void *pv, size_t size) | |
873 | { | |
874 | static const uint8_t buf[1024]; | |
875 | int block_len; | |
876 | ||
877 | while (size > 0) { | |
878 | block_len = MIN(sizeof(buf), size); | |
879 | size -= block_len; | |
880 | qemu_put_buffer(f, buf, block_len); | |
881 | } | |
882 | } | |
883 | ||
884 | const VMStateInfo vmstate_info_unused_buffer = { | |
885 | .name = "unused_buffer", | |
886 | .get = get_unused_buffer, | |
887 | .put = put_unused_buffer, | |
888 | }; | |
889 | ||
890 | /* bitmaps (as defined by bitmap.h). Note that size here is the size | |
891 | * of the bitmap in bits. The on-the-wire format of a bitmap is 64 | |
892 | * bit words with the bits in big endian order. The in-memory format | |
893 | * is an array of 'unsigned long', which may be either 32 or 64 bits. | |
894 | */ | |
895 | /* This is the number of 64 bit words sent over the wire */ | |
896 | #define BITS_TO_U64S(nr) DIV_ROUND_UP(nr, 64) | |
897 | static int get_bitmap(QEMUFile *f, void *pv, size_t size) | |
898 | { | |
899 | unsigned long *bmp = pv; | |
900 | int i, idx = 0; | |
901 | for (i = 0; i < BITS_TO_U64S(size); i++) { | |
902 | uint64_t w = qemu_get_be64(f); | |
903 | bmp[idx++] = w; | |
904 | if (sizeof(unsigned long) == 4 && idx < BITS_TO_LONGS(size)) { | |
905 | bmp[idx++] = w >> 32; | |
906 | } | |
907 | } | |
908 | return 0; | |
909 | } | |
910 | ||
911 | static void put_bitmap(QEMUFile *f, void *pv, size_t size) | |
912 | { | |
913 | unsigned long *bmp = pv; | |
914 | int i, idx = 0; | |
915 | for (i = 0; i < BITS_TO_U64S(size); i++) { | |
916 | uint64_t w = bmp[idx++]; | |
917 | if (sizeof(unsigned long) == 4 && idx < BITS_TO_LONGS(size)) { | |
918 | w |= ((uint64_t)bmp[idx++]) << 32; | |
919 | } | |
920 | qemu_put_be64(f, w); | |
921 | } | |
922 | } | |
923 | ||
924 | const VMStateInfo vmstate_info_bitmap = { | |
925 | .name = "bitmap", | |
926 | .get = get_bitmap, | |
927 | .put = put_bitmap, | |
928 | }; |