]> Git Repo - qemu.git/blame - block/parallels.c
qapi: Change data type of the FOO_lookup generated for enum FOO
[qemu.git] / block / parallels.c
CommitLineData
6ada7453
TS
1/*
2 * Block driver for Parallels disk image format
3 *
4 * Copyright (c) 2007 Alex Beregszaszi
cc5690f2 5 * Copyright (c) 2015 Denis V. Lunev <[email protected]>
6ada7453 6 *
cc5690f2
DL
7 * This code was originally based on comparing different disk images created
8 * by Parallels. Currently it is based on opened OpenVZ sources
9 * available at
10 * http://git.openvz.org/?p=ploop;a=summary
6ada7453
TS
11 *
12 * Permission is hereby granted, free of charge, to any person obtaining a copy
13 * of this software and associated documentation files (the "Software"), to deal
14 * in the Software without restriction, including without limitation the rights
15 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
16 * copies of the Software, and to permit persons to whom the Software is
17 * furnished to do so, subject to the following conditions:
18 *
19 * The above copyright notice and this permission notice shall be included in
20 * all copies or substantial portions of the Software.
21 *
22 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
23 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
24 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
25 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
26 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
27 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
28 * THE SOFTWARE.
29 */
80c71a24 30#include "qemu/osdep.h"
da34e65c 31#include "qapi/error.h"
faf07963 32#include "qemu-common.h"
737e150e 33#include "block/block_int.h"
8942764f 34#include "sysemu/block-backend.h"
1de7afc9 35#include "qemu/module.h"
58369e22 36#include "qemu/bswap.h"
0d31c7c2 37#include "qemu/bitmap.h"
6ada7453
TS
38
39/**************************************************************/
40
41#define HEADER_MAGIC "WithoutFreeSpace"
d25d5980 42#define HEADER_MAGIC2 "WithouFreSpacExt"
6ada7453 43#define HEADER_VERSION 2
6dd6b9f1 44#define HEADER_INUSE_MAGIC (0x746F6E59)
555a608c 45#define MAX_PARALLELS_IMAGE_FACTOR (1ull << 32)
6ada7453 46
74cf6c50
DL
47#define DEFAULT_CLUSTER_SIZE 1048576 /* 1 MiB */
48
49
6ada7453 50// always little-endian
07898904 51typedef struct ParallelsHeader {
6ada7453
TS
52 char magic[16]; // "WithoutFreeSpace"
53 uint32_t version;
54 uint32_t heads;
55 uint32_t cylinders;
56 uint32_t tracks;
369f7de9 57 uint32_t bat_entries;
8c27d54f
DL
58 uint64_t nb_sectors;
59 uint32_t inuse;
60 uint32_t data_off;
61 char padding[12];
07898904 62} QEMU_PACKED ParallelsHeader;
6ada7453 63
d6179011
DL
64
65typedef enum ParallelsPreallocMode {
66 PRL_PREALLOC_MODE_FALLOCATE = 0,
67 PRL_PREALLOC_MODE_TRUNCATE = 1,
7fb1cf16 68 PRL_PREALLOC_MODE__MAX = 2,
d6179011
DL
69} ParallelsPreallocMode;
70
f7abe0ec
MAL
71static QEnumLookup prealloc_mode_lookup = {
72 .array = (const char *const[]) {
73 "falloc",
74 "truncate",
75 NULL,
76 },
77 .size = PRL_PREALLOC_MODE__MAX
d6179011
DL
78};
79
6ada7453 80typedef struct BDRVParallelsState {
481fb9cf
DL
81 /** Locking is conservative, the lock protects
82 * - image file extending (truncate, fallocate)
83 * - any access to block allocation table
84 */
848c66e8 85 CoMutex lock;
6ada7453 86
9eae9cca
DL
87 ParallelsHeader *header;
88 uint32_t header_size;
6dd6b9f1
DL
89 bool header_unclean;
90
0d31c7c2
DL
91 unsigned long *bat_dirty_bmap;
92 unsigned int bat_dirty_block;
93
369f7de9
DL
94 uint32_t *bat_bitmap;
95 unsigned int bat_size;
6ada7453 96
19f5dc15 97 int64_t data_end;
d6179011
DL
98 uint64_t prealloc_size;
99 ParallelsPreallocMode prealloc_mode;
100
9302e863 101 unsigned int tracks;
d25d5980
DL
102
103 unsigned int off_multiplier;
6ada7453
TS
104} BDRVParallelsState;
105
555cc9d9 106
d6179011
DL
107#define PARALLELS_OPT_PREALLOC_MODE "prealloc-mode"
108#define PARALLELS_OPT_PREALLOC_SIZE "prealloc-size"
109
110static QemuOptsList parallels_runtime_opts = {
111 .name = "parallels",
112 .head = QTAILQ_HEAD_INITIALIZER(parallels_runtime_opts.head),
113 .desc = {
114 {
115 .name = PARALLELS_OPT_PREALLOC_SIZE,
116 .type = QEMU_OPT_SIZE,
117 .help = "Preallocation size on image expansion",
ff5bbe56 118 .def_value_str = "128M",
d6179011
DL
119 },
120 {
121 .name = PARALLELS_OPT_PREALLOC_MODE,
122 .type = QEMU_OPT_STRING,
123 .help = "Preallocation mode on image expansion "
124 "(allowed values: falloc, truncate)",
125 .def_value_str = "falloc",
126 },
127 { /* end of list */ },
128 },
129};
130
131
555cc9d9
DL
132static int64_t bat2sect(BDRVParallelsState *s, uint32_t idx)
133{
dd97cdc0 134 return (uint64_t)le32_to_cpu(s->bat_bitmap[idx]) * s->off_multiplier;
555cc9d9
DL
135}
136
2d68e22e
DL
137static uint32_t bat_entry_off(uint32_t idx)
138{
139 return sizeof(ParallelsHeader) + sizeof(uint32_t) * idx;
140}
141
29442569 142static int64_t seek_to_sector(BDRVParallelsState *s, int64_t sector_num)
6ada7453 143{
c34d2451 144 uint32_t index, offset;
6ada7453
TS
145
146 index = sector_num / s->tracks;
147 offset = sector_num % s->tracks;
148
9d8b88f6 149 /* not allocated */
369f7de9 150 if ((index >= s->bat_size) || (s->bat_bitmap[index] == 0)) {
f08e2f84 151 return -1;
369f7de9 152 }
555cc9d9 153 return bat2sect(s, index) + offset;
6ada7453
TS
154}
155
9de9da17
RK
156static int cluster_remainder(BDRVParallelsState *s, int64_t sector_num,
157 int nb_sectors)
158{
159 int ret = s->tracks - sector_num % s->tracks;
160 return MIN(nb_sectors, ret);
161}
162
6953d920
DL
163static int64_t block_status(BDRVParallelsState *s, int64_t sector_num,
164 int nb_sectors, int *pnum)
165{
166 int64_t start_off = -2, prev_end_off = -2;
167
168 *pnum = 0;
169 while (nb_sectors > 0 || start_off == -2) {
170 int64_t offset = seek_to_sector(s, sector_num);
171 int to_end;
172
173 if (start_off == -2) {
174 start_off = offset;
175 prev_end_off = offset;
176 } else if (offset != prev_end_off) {
177 break;
178 }
179
180 to_end = cluster_remainder(s, sector_num, nb_sectors);
181 nb_sectors -= to_end;
182 sector_num += to_end;
183 *pnum += to_end;
184
185 if (offset > 0) {
186 prev_end_off += to_end;
187 }
188 }
189 return start_off;
190}
191
ddd2ef2c
DL
192static int64_t allocate_clusters(BlockDriverState *bs, int64_t sector_num,
193 int nb_sectors, int *pnum)
5a41e1fa
DL
194{
195 BDRVParallelsState *s = bs->opaque;
d8b83e37 196 int64_t pos, space, idx, to_allocate, i, len;
5a41e1fa 197
ddd2ef2c
DL
198 pos = block_status(s, sector_num, nb_sectors, pnum);
199 if (pos > 0) {
200 return pos;
201 }
5a41e1fa 202
ddd2ef2c 203 idx = sector_num / s->tracks;
969401fe 204 to_allocate = DIV_ROUND_UP(sector_num + *pnum, s->tracks) - idx;
86d1bd70
HR
205
206 /* This function is called only by parallels_co_writev(), which will never
207 * pass a sector_num at or beyond the end of the image (because the block
208 * layer never passes such a sector_num to that function). Therefore, idx
209 * is always below s->bat_size.
210 * block_status() will limit *pnum so that sector_num + *pnum will not
211 * exceed the image end. Therefore, idx + to_allocate cannot exceed
212 * s->bat_size.
213 * Note that s->bat_size is an unsigned int, therefore idx + to_allocate
214 * will always fit into a uint32_t. */
215 assert(idx < s->bat_size && idx + to_allocate <= s->bat_size);
216
ddd2ef2c 217 space = to_allocate * s->tracks;
d8b83e37
DL
218 len = bdrv_getlength(bs->file->bs);
219 if (len < 0) {
220 return len;
221 }
222 if (s->data_end + space > (len >> BDRV_SECTOR_BITS)) {
19f5dc15 223 int ret;
ddd2ef2c 224 space += s->prealloc_size;
19f5dc15 225 if (s->prealloc_mode == PRL_PREALLOC_MODE_FALLOCATE) {
720ff280 226 ret = bdrv_pwrite_zeroes(bs->file,
74021bc4
EB
227 s->data_end << BDRV_SECTOR_BITS,
228 space << BDRV_SECTOR_BITS, 0);
19f5dc15 229 } else {
52cdbc58 230 ret = bdrv_truncate(bs->file,
ed3d2ec9 231 (s->data_end + space) << BDRV_SECTOR_BITS,
7ea37c30 232 PREALLOC_MODE_OFF, NULL);
19f5dc15
DL
233 }
234 if (ret < 0) {
235 return ret;
236 }
5a41e1fa
DL
237 }
238
ddd2ef2c
DL
239 for (i = 0; i < to_allocate; i++) {
240 s->bat_bitmap[idx + i] = cpu_to_le32(s->data_end / s->off_multiplier);
241 s->data_end += s->tracks;
242 bitmap_set(s->bat_dirty_bmap,
c9f6856d 243 bat_entry_off(idx + i) / s->bat_dirty_block, 1);
ddd2ef2c 244 }
0d31c7c2 245
ddd2ef2c 246 return bat2sect(s, idx) + sector_num % s->tracks;
5a41e1fa
DL
247}
248
0d31c7c2
DL
249
250static coroutine_fn int parallels_co_flush_to_os(BlockDriverState *bs)
251{
252 BDRVParallelsState *s = bs->opaque;
253 unsigned long size = DIV_ROUND_UP(s->header_size, s->bat_dirty_block);
254 unsigned long bit;
255
256 qemu_co_mutex_lock(&s->lock);
257
258 bit = find_first_bit(s->bat_dirty_bmap, size);
259 while (bit < size) {
260 uint32_t off = bit * s->bat_dirty_block;
261 uint32_t to_write = s->bat_dirty_block;
262 int ret;
263
264 if (off + to_write > s->header_size) {
265 to_write = s->header_size - off;
266 }
d9ca2ea2 267 ret = bdrv_pwrite(bs->file, off, (uint8_t *)s->header + off,
9a4f4c31 268 to_write);
0d31c7c2
DL
269 if (ret < 0) {
270 qemu_co_mutex_unlock(&s->lock);
271 return ret;
272 }
273 bit = find_next_bit(s->bat_dirty_bmap, size, bit + 1);
274 }
275 bitmap_zero(s->bat_dirty_bmap, size);
276
277 qemu_co_mutex_unlock(&s->lock);
278 return 0;
279}
280
281
dd3bed16 282static int64_t coroutine_fn parallels_co_get_block_status(BlockDriverState *bs,
67a0fd2a 283 int64_t sector_num, int nb_sectors, int *pnum, BlockDriverState **file)
dd3bed16
RK
284{
285 BDRVParallelsState *s = bs->opaque;
286 int64_t offset;
287
288 qemu_co_mutex_lock(&s->lock);
6953d920 289 offset = block_status(s, sector_num, nb_sectors, pnum);
dd3bed16
RK
290 qemu_co_mutex_unlock(&s->lock);
291
dd3bed16
RK
292 if (offset < 0) {
293 return 0;
294 }
295
ddf4987d 296 *file = bs->file->bs;
dd3bed16
RK
297 return (offset << BDRV_SECTOR_BITS) |
298 BDRV_BLOCK_DATA | BDRV_BLOCK_OFFSET_VALID;
299}
300
5a41e1fa
DL
301static coroutine_fn int parallels_co_writev(BlockDriverState *bs,
302 int64_t sector_num, int nb_sectors, QEMUIOVector *qiov)
303{
304 BDRVParallelsState *s = bs->opaque;
305 uint64_t bytes_done = 0;
306 QEMUIOVector hd_qiov;
307 int ret = 0;
308
309 qemu_iovec_init(&hd_qiov, qiov->niov);
310
311 while (nb_sectors > 0) {
312 int64_t position;
313 int n, nbytes;
314
315 qemu_co_mutex_lock(&s->lock);
ddd2ef2c 316 position = allocate_clusters(bs, sector_num, nb_sectors, &n);
5a41e1fa
DL
317 qemu_co_mutex_unlock(&s->lock);
318 if (position < 0) {
319 ret = (int)position;
320 break;
321 }
322
5a41e1fa
DL
323 nbytes = n << BDRV_SECTOR_BITS;
324
325 qemu_iovec_reset(&hd_qiov);
326 qemu_iovec_concat(&hd_qiov, qiov, bytes_done, nbytes);
327
25ec177d 328 ret = bdrv_co_writev(bs->file, position, n, &hd_qiov);
5a41e1fa
DL
329 if (ret < 0) {
330 break;
331 }
332
333 nb_sectors -= n;
334 sector_num += n;
335 bytes_done += nbytes;
336 }
337
338 qemu_iovec_destroy(&hd_qiov);
339 return ret;
340}
341
481fb9cf
DL
342static coroutine_fn int parallels_co_readv(BlockDriverState *bs,
343 int64_t sector_num, int nb_sectors, QEMUIOVector *qiov)
6ada7453 344{
29442569 345 BDRVParallelsState *s = bs->opaque;
481fb9cf
DL
346 uint64_t bytes_done = 0;
347 QEMUIOVector hd_qiov;
348 int ret = 0;
349
350 qemu_iovec_init(&hd_qiov, qiov->niov);
29442569 351
6ada7453 352 while (nb_sectors > 0) {
481fb9cf
DL
353 int64_t position;
354 int n, nbytes;
355
356 qemu_co_mutex_lock(&s->lock);
6953d920 357 position = block_status(s, sector_num, nb_sectors, &n);
481fb9cf
DL
358 qemu_co_mutex_unlock(&s->lock);
359
481fb9cf
DL
360 nbytes = n << BDRV_SECTOR_BITS;
361
362 if (position < 0) {
363 qemu_iovec_memset(qiov, bytes_done, 0, nbytes);
364 } else {
365 qemu_iovec_reset(&hd_qiov);
366 qemu_iovec_concat(&hd_qiov, qiov, bytes_done, nbytes);
367
28b04a8f 368 ret = bdrv_co_readv(bs->file, position, n, &hd_qiov);
29442569 369 if (ret < 0) {
481fb9cf 370 break;
29442569 371 }
9d8b88f6 372 }
481fb9cf 373
9de9da17
RK
374 nb_sectors -= n;
375 sector_num += n;
481fb9cf 376 bytes_done += nbytes;
6ada7453 377 }
6ada7453 378
481fb9cf 379 qemu_iovec_destroy(&hd_qiov);
2914caa0
PB
380 return ret;
381}
382
49ad6467
DL
383
384static int parallels_check(BlockDriverState *bs, BdrvCheckResult *res,
385 BdrvCheckMode fix)
386{
387 BDRVParallelsState *s = bs->opaque;
388 int64_t size, prev_off, high_off;
389 int ret;
390 uint32_t i;
391 bool flush_bat = false;
392 int cluster_size = s->tracks << BDRV_SECTOR_BITS;
393
9a4f4c31 394 size = bdrv_getlength(bs->file->bs);
49ad6467
DL
395 if (size < 0) {
396 res->check_errors++;
397 return size;
398 }
399
6dd6b9f1
DL
400 if (s->header_unclean) {
401 fprintf(stderr, "%s image was not closed correctly\n",
402 fix & BDRV_FIX_ERRORS ? "Repairing" : "ERROR");
403 res->corruptions++;
404 if (fix & BDRV_FIX_ERRORS) {
405 /* parallels_close will do the job right */
406 res->corruptions_fixed++;
407 s->header_unclean = false;
408 }
409 }
410
49ad6467
DL
411 res->bfi.total_clusters = s->bat_size;
412 res->bfi.compressed_clusters = 0; /* compression is not supported */
413
414 high_off = 0;
415 prev_off = 0;
416 for (i = 0; i < s->bat_size; i++) {
417 int64_t off = bat2sect(s, i) << BDRV_SECTOR_BITS;
418 if (off == 0) {
419 prev_off = 0;
420 continue;
421 }
422
423 /* cluster outside the image */
424 if (off > size) {
425 fprintf(stderr, "%s cluster %u is outside image\n",
426 fix & BDRV_FIX_ERRORS ? "Repairing" : "ERROR", i);
427 res->corruptions++;
428 if (fix & BDRV_FIX_ERRORS) {
429 prev_off = 0;
430 s->bat_bitmap[i] = 0;
431 res->corruptions_fixed++;
432 flush_bat = true;
433 continue;
434 }
435 }
436
437 res->bfi.allocated_clusters++;
438 if (off > high_off) {
439 high_off = off;
440 }
441
442 if (prev_off != 0 && (prev_off + cluster_size) != off) {
443 res->bfi.fragmented_clusters++;
444 }
445 prev_off = off;
446 }
447
448 if (flush_bat) {
d9ca2ea2 449 ret = bdrv_pwrite_sync(bs->file, 0, s->header, s->header_size);
49ad6467
DL
450 if (ret < 0) {
451 res->check_errors++;
452 return ret;
453 }
454 }
455
456 res->image_end_offset = high_off + cluster_size;
457 if (size > res->image_end_offset) {
458 int64_t count;
459 count = DIV_ROUND_UP(size - res->image_end_offset, cluster_size);
460 fprintf(stderr, "%s space leaked at the end of the image %" PRId64 "\n",
461 fix & BDRV_FIX_LEAKS ? "Repairing" : "ERROR",
462 size - res->image_end_offset);
463 res->leaks += count;
464 if (fix & BDRV_FIX_LEAKS) {
ed3d2ec9 465 Error *local_err = NULL;
7ea37c30
HR
466 ret = bdrv_truncate(bs->file, res->image_end_offset,
467 PREALLOC_MODE_OFF, &local_err);
49ad6467 468 if (ret < 0) {
ed3d2ec9 469 error_report_err(local_err);
49ad6467
DL
470 res->check_errors++;
471 return ret;
472 }
473 res->leaks_fixed += count;
474 }
475 }
476
477 return 0;
478}
479
480
74cf6c50
DL
481static int parallels_create(const char *filename, QemuOpts *opts, Error **errp)
482{
483 int64_t total_size, cl_size;
484 uint8_t tmp[BDRV_SECTOR_SIZE];
485 Error *local_err = NULL;
8942764f 486 BlockBackend *file;
369f7de9 487 uint32_t bat_entries, bat_sectors;
74cf6c50
DL
488 ParallelsHeader header;
489 int ret;
490
491 total_size = ROUND_UP(qemu_opt_get_size_del(opts, BLOCK_OPT_SIZE, 0),
492 BDRV_SECTOR_SIZE);
493 cl_size = ROUND_UP(qemu_opt_get_size_del(opts, BLOCK_OPT_CLUSTER_SIZE,
494 DEFAULT_CLUSTER_SIZE), BDRV_SECTOR_SIZE);
555a608c
KK
495 if (total_size >= MAX_PARALLELS_IMAGE_FACTOR * cl_size) {
496 error_propagate(errp, local_err);
497 return -E2BIG;
498 }
74cf6c50
DL
499
500 ret = bdrv_create_file(filename, opts, &local_err);
501 if (ret < 0) {
502 error_propagate(errp, local_err);
503 return ret;
504 }
505
efaa7c4e 506 file = blk_new_open(filename, NULL, NULL,
55880601
KW
507 BDRV_O_RDWR | BDRV_O_RESIZE | BDRV_O_PROTOCOL,
508 &local_err);
8942764f 509 if (file == NULL) {
74cf6c50 510 error_propagate(errp, local_err);
8942764f 511 return -EIO;
74cf6c50 512 }
8942764f
KW
513
514 blk_set_allow_write_beyond_eof(file, true);
515
3a691c50 516 ret = blk_truncate(file, 0, PREALLOC_MODE_OFF, errp);
74cf6c50
DL
517 if (ret < 0) {
518 goto exit;
519 }
520
369f7de9 521 bat_entries = DIV_ROUND_UP(total_size, cl_size);
2d68e22e 522 bat_sectors = DIV_ROUND_UP(bat_entry_off(bat_entries), cl_size);
369f7de9 523 bat_sectors = (bat_sectors * cl_size) >> BDRV_SECTOR_BITS;
74cf6c50
DL
524
525 memset(&header, 0, sizeof(header));
526 memcpy(header.magic, HEADER_MAGIC2, sizeof(header.magic));
527 header.version = cpu_to_le32(HEADER_VERSION);
528 /* don't care much about geometry, it is not used on image level */
529 header.heads = cpu_to_le32(16);
530 header.cylinders = cpu_to_le32(total_size / BDRV_SECTOR_SIZE / 16 / 32);
531 header.tracks = cpu_to_le32(cl_size >> BDRV_SECTOR_BITS);
369f7de9 532 header.bat_entries = cpu_to_le32(bat_entries);
74cf6c50 533 header.nb_sectors = cpu_to_le64(DIV_ROUND_UP(total_size, BDRV_SECTOR_SIZE));
369f7de9 534 header.data_off = cpu_to_le32(bat_sectors);
74cf6c50
DL
535
536 /* write all the data */
537 memset(tmp, 0, sizeof(tmp));
538 memcpy(tmp, &header, sizeof(header));
539
8341f00d 540 ret = blk_pwrite(file, 0, tmp, BDRV_SECTOR_SIZE, 0);
74cf6c50
DL
541 if (ret < 0) {
542 goto exit;
543 }
d004bd52
EB
544 ret = blk_pwrite_zeroes(file, BDRV_SECTOR_SIZE,
545 (bat_sectors - 1) << BDRV_SECTOR_BITS, 0);
74cf6c50
DL
546 if (ret < 0) {
547 goto exit;
548 }
549 ret = 0;
550
551done:
8942764f 552 blk_unref(file);
74cf6c50
DL
553 return ret;
554
555exit:
556 error_setg_errno(errp, -ret, "Failed to create Parallels image");
557 goto done;
558}
559
23d6bd3b
DL
560
561static int parallels_probe(const uint8_t *buf, int buf_size,
562 const char *filename)
563{
564 const ParallelsHeader *ph = (const void *)buf;
565
566 if (buf_size < sizeof(ParallelsHeader)) {
567 return 0;
568 }
569
570 if ((!memcmp(ph->magic, HEADER_MAGIC, 16) ||
571 !memcmp(ph->magic, HEADER_MAGIC2, 16)) &&
572 (le32_to_cpu(ph->version) == HEADER_VERSION)) {
573 return 100;
574 }
575
576 return 0;
577}
578
6dd6b9f1
DL
579static int parallels_update_header(BlockDriverState *bs)
580{
581 BDRVParallelsState *s = bs->opaque;
9a4f4c31
KW
582 unsigned size = MAX(bdrv_opt_mem_align(bs->file->bs),
583 sizeof(ParallelsHeader));
6dd6b9f1
DL
584
585 if (size > s->header_size) {
586 size = s->header_size;
587 }
d9ca2ea2 588 return bdrv_pwrite_sync(bs->file, 0, s->header, size);
6dd6b9f1
DL
589}
590
23d6bd3b
DL
591static int parallels_open(BlockDriverState *bs, QDict *options, int flags,
592 Error **errp)
593{
594 BDRVParallelsState *s = bs->opaque;
595 ParallelsHeader ph;
19f5dc15 596 int ret, size, i;
d6179011
DL
597 QemuOpts *opts = NULL;
598 Error *local_err = NULL;
599 char *buf;
23d6bd3b 600
4e4bf5c4
KW
601 bs->file = bdrv_open_child(NULL, options, "file", bs, &child_file,
602 false, errp);
603 if (!bs->file) {
604 return -EINVAL;
605 }
606
cf2ab8fc 607 ret = bdrv_pread(bs->file, 0, &ph, sizeof(ph));
23d6bd3b
DL
608 if (ret < 0) {
609 goto fail;
610 }
611
612 bs->total_sectors = le64_to_cpu(ph.nb_sectors);
613
614 if (le32_to_cpu(ph.version) != HEADER_VERSION) {
615 goto fail_format;
616 }
617 if (!memcmp(ph.magic, HEADER_MAGIC, 16)) {
618 s->off_multiplier = 1;
619 bs->total_sectors = 0xffffffff & bs->total_sectors;
620 } else if (!memcmp(ph.magic, HEADER_MAGIC2, 16)) {
621 s->off_multiplier = le32_to_cpu(ph.tracks);
622 } else {
623 goto fail_format;
624 }
625
626 s->tracks = le32_to_cpu(ph.tracks);
627 if (s->tracks == 0) {
628 error_setg(errp, "Invalid image: Zero sectors per track");
629 ret = -EINVAL;
630 goto fail;
631 }
632 if (s->tracks > INT32_MAX/513) {
633 error_setg(errp, "Invalid image: Too big cluster");
634 ret = -EFBIG;
635 goto fail;
636 }
637
638 s->bat_size = le32_to_cpu(ph.bat_entries);
639 if (s->bat_size > INT_MAX / sizeof(uint32_t)) {
640 error_setg(errp, "Catalog too large");
641 ret = -EFBIG;
642 goto fail;
643 }
644
2d68e22e 645 size = bat_entry_off(s->bat_size);
9a4f4c31
KW
646 s->header_size = ROUND_UP(size, bdrv_opt_mem_align(bs->file->bs));
647 s->header = qemu_try_blockalign(bs->file->bs, s->header_size);
23d6bd3b
DL
648 if (s->header == NULL) {
649 ret = -ENOMEM;
650 goto fail;
651 }
19f5dc15
DL
652 s->data_end = le32_to_cpu(ph.data_off);
653 if (s->data_end == 0) {
654 s->data_end = ROUND_UP(bat_entry_off(s->bat_size), BDRV_SECTOR_SIZE);
655 }
656 if (s->data_end < s->header_size) {
23d6bd3b
DL
657 /* there is not enough unused space to fit to block align between BAT
658 and actual data. We can't avoid read-modify-write... */
659 s->header_size = size;
660 }
661
cf2ab8fc 662 ret = bdrv_pread(bs->file, 0, s->header, s->header_size);
23d6bd3b
DL
663 if (ret < 0) {
664 goto fail;
665 }
666 s->bat_bitmap = (uint32_t *)(s->header + 1);
667
19f5dc15
DL
668 for (i = 0; i < s->bat_size; i++) {
669 int64_t off = bat2sect(s, i);
670 if (off >= s->data_end) {
671 s->data_end = off + s->tracks;
672 }
673 }
674
6dd6b9f1
DL
675 if (le32_to_cpu(ph.inuse) == HEADER_INUSE_MAGIC) {
676 /* Image was not closed correctly. The check is mandatory */
677 s->header_unclean = true;
678 if ((flags & BDRV_O_RDWR) && !(flags & BDRV_O_CHECK)) {
679 error_setg(errp, "parallels: Image was not closed correctly; "
680 "cannot be opened read/write");
681 ret = -EACCES;
682 goto fail;
683 }
684 }
685
d6179011
DL
686 opts = qemu_opts_create(&parallels_runtime_opts, NULL, 0, &local_err);
687 if (local_err != NULL) {
688 goto fail_options;
689 }
690
691 qemu_opts_absorb_qdict(opts, options, &local_err);
692 if (local_err != NULL) {
693 goto fail_options;
694 }
695
696 s->prealloc_size =
697 qemu_opt_get_size_del(opts, PARALLELS_OPT_PREALLOC_SIZE, 0);
698 s->prealloc_size = MAX(s->tracks, s->prealloc_size >> BDRV_SECTOR_BITS);
699 buf = qemu_opt_get_del(opts, PARALLELS_OPT_PREALLOC_MODE);
f7abe0ec 700 s->prealloc_mode = qapi_enum_parse(&prealloc_mode_lookup, buf,
06c60b6c
MA
701 PRL_PREALLOC_MODE_FALLOCATE,
702 &local_err);
d6179011
DL
703 g_free(buf);
704 if (local_err != NULL) {
705 goto fail_options;
706 }
dc62da88 707
e5e62683 708 if (!bdrv_has_zero_init(bs->file->bs)) {
d6179011
DL
709 s->prealloc_mode = PRL_PREALLOC_MODE_FALLOCATE;
710 }
711
6dd6b9f1
DL
712 if (flags & BDRV_O_RDWR) {
713 s->header->inuse = cpu_to_le32(HEADER_INUSE_MAGIC);
714 ret = parallels_update_header(bs);
715 if (ret < 0) {
716 goto fail;
717 }
718 }
719
0d31c7c2
DL
720 s->bat_dirty_block = 4 * getpagesize();
721 s->bat_dirty_bmap =
722 bitmap_new(DIV_ROUND_UP(s->header_size, s->bat_dirty_block));
723
23d6bd3b
DL
724 qemu_co_mutex_init(&s->lock);
725 return 0;
726
727fail_format:
728 error_setg(errp, "Image not in Parallels format");
729 ret = -EINVAL;
730fail:
731 qemu_vfree(s->header);
732 return ret;
d6179011
DL
733
734fail_options:
735 error_propagate(errp, local_err);
736 ret = -EINVAL;
737 goto fail;
23d6bd3b
DL
738}
739
740
6ada7453
TS
741static void parallels_close(BlockDriverState *bs)
742{
743 BDRVParallelsState *s = bs->opaque;
6dd6b9f1
DL
744
745 if (bs->open_flags & BDRV_O_RDWR) {
746 s->header->inuse = 0;
747 parallels_update_header(bs);
748 }
749
19f5dc15 750 if (bs->open_flags & BDRV_O_RDWR) {
7ea37c30
HR
751 bdrv_truncate(bs->file, s->data_end << BDRV_SECTOR_BITS,
752 PREALLOC_MODE_OFF, NULL);
19f5dc15
DL
753 }
754
0d31c7c2 755 g_free(s->bat_dirty_bmap);
9eae9cca 756 qemu_vfree(s->header);
6ada7453
TS
757}
758
74cf6c50
DL
759static QemuOptsList parallels_create_opts = {
760 .name = "parallels-create-opts",
761 .head = QTAILQ_HEAD_INITIALIZER(parallels_create_opts.head),
762 .desc = {
763 {
764 .name = BLOCK_OPT_SIZE,
765 .type = QEMU_OPT_SIZE,
766 .help = "Virtual disk size",
767 },
768 {
769 .name = BLOCK_OPT_CLUSTER_SIZE,
770 .type = QEMU_OPT_SIZE,
771 .help = "Parallels image cluster size",
772 .def_value_str = stringify(DEFAULT_CLUSTER_SIZE),
773 },
774 { /* end of list */ }
775 }
776};
777
5efa9d5a 778static BlockDriver bdrv_parallels = {
e60f469c
AJ
779 .format_name = "parallels",
780 .instance_size = sizeof(BDRVParallelsState),
781 .bdrv_probe = parallels_probe,
1dec5a70 782 .bdrv_open = parallels_open,
e60f469c 783 .bdrv_close = parallels_close,
862f215f 784 .bdrv_child_perm = bdrv_format_default_perms,
dd3bed16 785 .bdrv_co_get_block_status = parallels_co_get_block_status,
d0e61ce5 786 .bdrv_has_zero_init = bdrv_has_zero_init_1,
0d31c7c2 787 .bdrv_co_flush_to_os = parallels_co_flush_to_os,
481fb9cf 788 .bdrv_co_readv = parallels_co_readv,
5a41e1fa 789 .bdrv_co_writev = parallels_co_writev,
74cf6c50
DL
790
791 .bdrv_create = parallels_create,
49ad6467 792 .bdrv_check = parallels_check,
74cf6c50 793 .create_opts = &parallels_create_opts,
6ada7453 794};
5efa9d5a
AL
795
796static void bdrv_parallels_init(void)
797{
798 bdrv_register(&bdrv_parallels);
799}
800
801block_init(bdrv_parallels_init);
This page took 0.777017 seconds and 4 git commands to generate.