xref: /qemu/block/parallels.c (revision 67a0fd2a)
1019d6b8fSAnthony Liguori /*
2019d6b8fSAnthony Liguori  * Block driver for Parallels disk image format
3019d6b8fSAnthony Liguori  *
4019d6b8fSAnthony Liguori  * Copyright (c) 2007 Alex Beregszaszi
5cc5690f2SDenis V. Lunev  * Copyright (c) 2015 Denis V. Lunev <den@openvz.org>
6019d6b8fSAnthony Liguori  *
7cc5690f2SDenis V. Lunev  * This code was originally based on comparing different disk images created
8cc5690f2SDenis V. Lunev  * by Parallels. Currently it is based on opened OpenVZ sources
9cc5690f2SDenis V. Lunev  * available at
10cc5690f2SDenis V. Lunev  *     http://git.openvz.org/?p=ploop;a=summary
11019d6b8fSAnthony Liguori  *
12019d6b8fSAnthony Liguori  * Permission is hereby granted, free of charge, to any person obtaining a copy
13019d6b8fSAnthony Liguori  * of this software and associated documentation files (the "Software"), to deal
14019d6b8fSAnthony Liguori  * in the Software without restriction, including without limitation the rights
15019d6b8fSAnthony Liguori  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
16019d6b8fSAnthony Liguori  * copies of the Software, and to permit persons to whom the Software is
17019d6b8fSAnthony Liguori  * furnished to do so, subject to the following conditions:
18019d6b8fSAnthony Liguori  *
19019d6b8fSAnthony Liguori  * The above copyright notice and this permission notice shall be included in
20019d6b8fSAnthony Liguori  * all copies or substantial portions of the Software.
21019d6b8fSAnthony Liguori  *
22019d6b8fSAnthony Liguori  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
23019d6b8fSAnthony Liguori  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
24019d6b8fSAnthony Liguori  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
25019d6b8fSAnthony Liguori  * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
26019d6b8fSAnthony Liguori  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
27019d6b8fSAnthony Liguori  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
28019d6b8fSAnthony Liguori  * THE SOFTWARE.
29019d6b8fSAnthony Liguori  */
3080c71a24SPeter Maydell #include "qemu/osdep.h"
31019d6b8fSAnthony Liguori #include "qemu-common.h"
32737e150eSPaolo Bonzini #include "block/block_int.h"
331de7afc9SPaolo Bonzini #include "qemu/module.h"
340d31c7c2SDenis V. Lunev #include "qemu/bitmap.h"
35d6179011SDenis V. Lunev #include "qapi/util.h"
36019d6b8fSAnthony Liguori 
37019d6b8fSAnthony Liguori /**************************************************************/
38019d6b8fSAnthony Liguori 
39019d6b8fSAnthony Liguori #define HEADER_MAGIC "WithoutFreeSpace"
40d25d5980SDenis V. Lunev #define HEADER_MAGIC2 "WithouFreSpacExt"
41019d6b8fSAnthony Liguori #define HEADER_VERSION 2
426dd6b9f1SDenis V. Lunev #define HEADER_INUSE_MAGIC  (0x746F6E59)
43019d6b8fSAnthony Liguori 
4474cf6c50SDenis V. Lunev #define DEFAULT_CLUSTER_SIZE 1048576        /* 1 MiB */
4574cf6c50SDenis V. Lunev 
4674cf6c50SDenis V. Lunev 
47019d6b8fSAnthony Liguori // always little-endian
4807898904SDenis V. Lunev typedef struct ParallelsHeader {
49019d6b8fSAnthony Liguori     char magic[16]; // "WithoutFreeSpace"
50019d6b8fSAnthony Liguori     uint32_t version;
51019d6b8fSAnthony Liguori     uint32_t heads;
52019d6b8fSAnthony Liguori     uint32_t cylinders;
53019d6b8fSAnthony Liguori     uint32_t tracks;
54369f7de9SDenis V. Lunev     uint32_t bat_entries;
558c27d54fSDenis V. Lunev     uint64_t nb_sectors;
568c27d54fSDenis V. Lunev     uint32_t inuse;
578c27d54fSDenis V. Lunev     uint32_t data_off;
588c27d54fSDenis V. Lunev     char padding[12];
5907898904SDenis V. Lunev } QEMU_PACKED ParallelsHeader;
60019d6b8fSAnthony Liguori 
61d6179011SDenis V. Lunev 
62d6179011SDenis V. Lunev typedef enum ParallelsPreallocMode {
63d6179011SDenis V. Lunev     PRL_PREALLOC_MODE_FALLOCATE = 0,
64d6179011SDenis V. Lunev     PRL_PREALLOC_MODE_TRUNCATE = 1,
657fb1cf16SEric Blake     PRL_PREALLOC_MODE__MAX = 2,
66d6179011SDenis V. Lunev } ParallelsPreallocMode;
67d6179011SDenis V. Lunev 
68d6179011SDenis V. Lunev static const char *prealloc_mode_lookup[] = {
69d6179011SDenis V. Lunev     "falloc",
70d6179011SDenis V. Lunev     "truncate",
71d6179011SDenis V. Lunev     NULL,
72d6179011SDenis V. Lunev };
73d6179011SDenis V. Lunev 
74d6179011SDenis V. Lunev 
75019d6b8fSAnthony Liguori typedef struct BDRVParallelsState {
76481fb9cfSDenis V. Lunev     /** Locking is conservative, the lock protects
77481fb9cfSDenis V. Lunev      *   - image file extending (truncate, fallocate)
78481fb9cfSDenis V. Lunev      *   - any access to block allocation table
79481fb9cfSDenis V. Lunev      */
80848c66e8SPaolo Bonzini     CoMutex lock;
81019d6b8fSAnthony Liguori 
829eae9ccaSDenis V. Lunev     ParallelsHeader *header;
839eae9ccaSDenis V. Lunev     uint32_t header_size;
846dd6b9f1SDenis V. Lunev     bool header_unclean;
856dd6b9f1SDenis V. Lunev 
860d31c7c2SDenis V. Lunev     unsigned long *bat_dirty_bmap;
870d31c7c2SDenis V. Lunev     unsigned int  bat_dirty_block;
880d31c7c2SDenis V. Lunev 
89369f7de9SDenis V. Lunev     uint32_t *bat_bitmap;
90369f7de9SDenis V. Lunev     unsigned int bat_size;
91019d6b8fSAnthony Liguori 
9219f5dc15SDenis V. Lunev     int64_t  data_end;
93d6179011SDenis V. Lunev     uint64_t prealloc_size;
94d6179011SDenis V. Lunev     ParallelsPreallocMode prealloc_mode;
95d6179011SDenis V. Lunev 
969302e863SKevin Wolf     unsigned int tracks;
97d25d5980SDenis V. Lunev 
98d25d5980SDenis V. Lunev     unsigned int off_multiplier;
99019d6b8fSAnthony Liguori } BDRVParallelsState;
100019d6b8fSAnthony Liguori 
101555cc9d9SDenis V. Lunev 
102d6179011SDenis V. Lunev #define PARALLELS_OPT_PREALLOC_MODE     "prealloc-mode"
103d6179011SDenis V. Lunev #define PARALLELS_OPT_PREALLOC_SIZE     "prealloc-size"
104d6179011SDenis V. Lunev 
105d6179011SDenis V. Lunev static QemuOptsList parallels_runtime_opts = {
106d6179011SDenis V. Lunev     .name = "parallels",
107d6179011SDenis V. Lunev     .head = QTAILQ_HEAD_INITIALIZER(parallels_runtime_opts.head),
108d6179011SDenis V. Lunev     .desc = {
109d6179011SDenis V. Lunev         {
110d6179011SDenis V. Lunev             .name = PARALLELS_OPT_PREALLOC_SIZE,
111d6179011SDenis V. Lunev             .type = QEMU_OPT_SIZE,
112d6179011SDenis V. Lunev             .help = "Preallocation size on image expansion",
113d6179011SDenis V. Lunev             .def_value_str = "128MiB",
114d6179011SDenis V. Lunev         },
115d6179011SDenis V. Lunev         {
116d6179011SDenis V. Lunev             .name = PARALLELS_OPT_PREALLOC_MODE,
117d6179011SDenis V. Lunev             .type = QEMU_OPT_STRING,
118d6179011SDenis V. Lunev             .help = "Preallocation mode on image expansion "
119d6179011SDenis V. Lunev                     "(allowed values: falloc, truncate)",
120d6179011SDenis V. Lunev             .def_value_str = "falloc",
121d6179011SDenis V. Lunev         },
122d6179011SDenis V. Lunev         { /* end of list */ },
123d6179011SDenis V. Lunev     },
124d6179011SDenis V. Lunev };
125d6179011SDenis V. Lunev 
126d6179011SDenis V. Lunev 
127555cc9d9SDenis V. Lunev static int64_t bat2sect(BDRVParallelsState *s, uint32_t idx)
128555cc9d9SDenis V. Lunev {
129dd97cdc0SDenis V. Lunev     return (uint64_t)le32_to_cpu(s->bat_bitmap[idx]) * s->off_multiplier;
130555cc9d9SDenis V. Lunev }
131555cc9d9SDenis V. Lunev 
1322d68e22eSDenis V. Lunev static uint32_t bat_entry_off(uint32_t idx)
1332d68e22eSDenis V. Lunev {
1342d68e22eSDenis V. Lunev     return sizeof(ParallelsHeader) + sizeof(uint32_t) * idx;
1352d68e22eSDenis V. Lunev }
1362d68e22eSDenis V. Lunev 
13729442569SRoman Kagan static int64_t seek_to_sector(BDRVParallelsState *s, int64_t sector_num)
138019d6b8fSAnthony Liguori {
139c34d2451SDavid Woodhouse     uint32_t index, offset;
140019d6b8fSAnthony Liguori 
141019d6b8fSAnthony Liguori     index = sector_num / s->tracks;
142019d6b8fSAnthony Liguori     offset = sector_num % s->tracks;
143019d6b8fSAnthony Liguori 
1449d8b88f6SChristoph Hellwig     /* not allocated */
145369f7de9SDenis V. Lunev     if ((index >= s->bat_size) || (s->bat_bitmap[index] == 0)) {
146019d6b8fSAnthony Liguori         return -1;
147369f7de9SDenis V. Lunev     }
148555cc9d9SDenis V. Lunev     return bat2sect(s, index) + offset;
149019d6b8fSAnthony Liguori }
150019d6b8fSAnthony Liguori 
1519de9da17SRoman Kagan static int cluster_remainder(BDRVParallelsState *s, int64_t sector_num,
1529de9da17SRoman Kagan         int nb_sectors)
1539de9da17SRoman Kagan {
1549de9da17SRoman Kagan     int ret = s->tracks - sector_num % s->tracks;
1559de9da17SRoman Kagan     return MIN(nb_sectors, ret);
1569de9da17SRoman Kagan }
1579de9da17SRoman Kagan 
1586953d920SDenis V. Lunev static int64_t block_status(BDRVParallelsState *s, int64_t sector_num,
1596953d920SDenis V. Lunev                             int nb_sectors, int *pnum)
1606953d920SDenis V. Lunev {
1616953d920SDenis V. Lunev     int64_t start_off = -2, prev_end_off = -2;
1626953d920SDenis V. Lunev 
1636953d920SDenis V. Lunev     *pnum = 0;
1646953d920SDenis V. Lunev     while (nb_sectors > 0 || start_off == -2) {
1656953d920SDenis V. Lunev         int64_t offset = seek_to_sector(s, sector_num);
1666953d920SDenis V. Lunev         int to_end;
1676953d920SDenis V. Lunev 
1686953d920SDenis V. Lunev         if (start_off == -2) {
1696953d920SDenis V. Lunev             start_off = offset;
1706953d920SDenis V. Lunev             prev_end_off = offset;
1716953d920SDenis V. Lunev         } else if (offset != prev_end_off) {
1726953d920SDenis V. Lunev             break;
1736953d920SDenis V. Lunev         }
1746953d920SDenis V. Lunev 
1756953d920SDenis V. Lunev         to_end = cluster_remainder(s, sector_num, nb_sectors);
1766953d920SDenis V. Lunev         nb_sectors -= to_end;
1776953d920SDenis V. Lunev         sector_num += to_end;
1786953d920SDenis V. Lunev         *pnum += to_end;
1796953d920SDenis V. Lunev 
1806953d920SDenis V. Lunev         if (offset > 0) {
1816953d920SDenis V. Lunev             prev_end_off += to_end;
1826953d920SDenis V. Lunev         }
1836953d920SDenis V. Lunev     }
1846953d920SDenis V. Lunev     return start_off;
1856953d920SDenis V. Lunev }
1866953d920SDenis V. Lunev 
187ddd2ef2cSDenis V. Lunev static int64_t allocate_clusters(BlockDriverState *bs, int64_t sector_num,
188ddd2ef2cSDenis V. Lunev                                  int nb_sectors, int *pnum)
1895a41e1faSDenis V. Lunev {
1905a41e1faSDenis V. Lunev     BDRVParallelsState *s = bs->opaque;
191ddd2ef2cSDenis V. Lunev     uint32_t idx, to_allocate, i;
192ddd2ef2cSDenis V. Lunev     int64_t pos, space;
193ddd2ef2cSDenis V. Lunev 
194ddd2ef2cSDenis V. Lunev     pos = block_status(s, sector_num, nb_sectors, pnum);
195ddd2ef2cSDenis V. Lunev     if (pos > 0) {
196ddd2ef2cSDenis V. Lunev         return pos;
197ddd2ef2cSDenis V. Lunev     }
1985a41e1faSDenis V. Lunev 
1995a41e1faSDenis V. Lunev     idx = sector_num / s->tracks;
200369f7de9SDenis V. Lunev     if (idx >= s->bat_size) {
2015a41e1faSDenis V. Lunev         return -EINVAL;
2025a41e1faSDenis V. Lunev     }
2035a41e1faSDenis V. Lunev 
204ddd2ef2cSDenis V. Lunev     to_allocate = (sector_num + *pnum + s->tracks - 1) / s->tracks - idx;
205ddd2ef2cSDenis V. Lunev     space = to_allocate * s->tracks;
2069a4f4c31SKevin Wolf     if (s->data_end + space > bdrv_getlength(bs->file->bs) >> BDRV_SECTOR_BITS) {
20719f5dc15SDenis V. Lunev         int ret;
208ddd2ef2cSDenis V. Lunev         space += s->prealloc_size;
20919f5dc15SDenis V. Lunev         if (s->prealloc_mode == PRL_PREALLOC_MODE_FALLOCATE) {
2109a4f4c31SKevin Wolf             ret = bdrv_write_zeroes(bs->file->bs, s->data_end, space, 0);
2115a41e1faSDenis V. Lunev         } else {
2129a4f4c31SKevin Wolf             ret = bdrv_truncate(bs->file->bs,
213ddd2ef2cSDenis V. Lunev                                 (s->data_end + space) << BDRV_SECTOR_BITS);
2145a41e1faSDenis V. Lunev         }
2155a41e1faSDenis V. Lunev         if (ret < 0) {
2165a41e1faSDenis V. Lunev             return ret;
2175a41e1faSDenis V. Lunev         }
21819f5dc15SDenis V. Lunev     }
219ddd2ef2cSDenis V. Lunev 
220ddd2ef2cSDenis V. Lunev     for (i = 0; i < to_allocate; i++) {
221ddd2ef2cSDenis V. Lunev         s->bat_bitmap[idx + i] = cpu_to_le32(s->data_end / s->off_multiplier);
22219f5dc15SDenis V. Lunev         s->data_end += s->tracks;
223ddd2ef2cSDenis V. Lunev         bitmap_set(s->bat_dirty_bmap,
224c9f6856dSVladimir Sementsov-Ogievskiy                    bat_entry_off(idx + i) / s->bat_dirty_block, 1);
225ddd2ef2cSDenis V. Lunev     }
2265a41e1faSDenis V. Lunev 
227ddd2ef2cSDenis V. Lunev     return bat2sect(s, idx) + sector_num % s->tracks;
2285a41e1faSDenis V. Lunev }
2295a41e1faSDenis V. Lunev 
2300d31c7c2SDenis V. Lunev 
2310d31c7c2SDenis V. Lunev static coroutine_fn int parallels_co_flush_to_os(BlockDriverState *bs)
2320d31c7c2SDenis V. Lunev {
2330d31c7c2SDenis V. Lunev     BDRVParallelsState *s = bs->opaque;
2340d31c7c2SDenis V. Lunev     unsigned long size = DIV_ROUND_UP(s->header_size, s->bat_dirty_block);
2350d31c7c2SDenis V. Lunev     unsigned long bit;
2360d31c7c2SDenis V. Lunev 
2370d31c7c2SDenis V. Lunev     qemu_co_mutex_lock(&s->lock);
2380d31c7c2SDenis V. Lunev 
2390d31c7c2SDenis V. Lunev     bit = find_first_bit(s->bat_dirty_bmap, size);
2400d31c7c2SDenis V. Lunev     while (bit < size) {
2410d31c7c2SDenis V. Lunev         uint32_t off = bit * s->bat_dirty_block;
2420d31c7c2SDenis V. Lunev         uint32_t to_write = s->bat_dirty_block;
2430d31c7c2SDenis V. Lunev         int ret;
2440d31c7c2SDenis V. Lunev 
2450d31c7c2SDenis V. Lunev         if (off + to_write > s->header_size) {
2460d31c7c2SDenis V. Lunev             to_write = s->header_size - off;
2470d31c7c2SDenis V. Lunev         }
2489a4f4c31SKevin Wolf         ret = bdrv_pwrite(bs->file->bs, off, (uint8_t *)s->header + off,
2499a4f4c31SKevin Wolf                           to_write);
2500d31c7c2SDenis V. Lunev         if (ret < 0) {
2510d31c7c2SDenis V. Lunev             qemu_co_mutex_unlock(&s->lock);
2520d31c7c2SDenis V. Lunev             return ret;
2530d31c7c2SDenis V. Lunev         }
2540d31c7c2SDenis V. Lunev         bit = find_next_bit(s->bat_dirty_bmap, size, bit + 1);
2550d31c7c2SDenis V. Lunev     }
2560d31c7c2SDenis V. Lunev     bitmap_zero(s->bat_dirty_bmap, size);
2570d31c7c2SDenis V. Lunev 
2580d31c7c2SDenis V. Lunev     qemu_co_mutex_unlock(&s->lock);
2590d31c7c2SDenis V. Lunev     return 0;
2600d31c7c2SDenis V. Lunev }
2610d31c7c2SDenis V. Lunev 
2620d31c7c2SDenis V. Lunev 
263dd3bed16SRoman Kagan static int64_t coroutine_fn parallels_co_get_block_status(BlockDriverState *bs,
264*67a0fd2aSFam Zheng         int64_t sector_num, int nb_sectors, int *pnum, BlockDriverState **file)
265dd3bed16SRoman Kagan {
266dd3bed16SRoman Kagan     BDRVParallelsState *s = bs->opaque;
267dd3bed16SRoman Kagan     int64_t offset;
268dd3bed16SRoman Kagan 
269dd3bed16SRoman Kagan     qemu_co_mutex_lock(&s->lock);
2706953d920SDenis V. Lunev     offset = block_status(s, sector_num, nb_sectors, pnum);
271dd3bed16SRoman Kagan     qemu_co_mutex_unlock(&s->lock);
272dd3bed16SRoman Kagan 
273dd3bed16SRoman Kagan     if (offset < 0) {
274dd3bed16SRoman Kagan         return 0;
275dd3bed16SRoman Kagan     }
276dd3bed16SRoman Kagan 
277dd3bed16SRoman Kagan     return (offset << BDRV_SECTOR_BITS) |
278dd3bed16SRoman Kagan         BDRV_BLOCK_DATA | BDRV_BLOCK_OFFSET_VALID;
279dd3bed16SRoman Kagan }
280dd3bed16SRoman Kagan 
2815a41e1faSDenis V. Lunev static coroutine_fn int parallels_co_writev(BlockDriverState *bs,
2825a41e1faSDenis V. Lunev         int64_t sector_num, int nb_sectors, QEMUIOVector *qiov)
2835a41e1faSDenis V. Lunev {
2845a41e1faSDenis V. Lunev     BDRVParallelsState *s = bs->opaque;
2855a41e1faSDenis V. Lunev     uint64_t bytes_done = 0;
2865a41e1faSDenis V. Lunev     QEMUIOVector hd_qiov;
2875a41e1faSDenis V. Lunev     int ret = 0;
2885a41e1faSDenis V. Lunev 
2895a41e1faSDenis V. Lunev     qemu_iovec_init(&hd_qiov, qiov->niov);
2905a41e1faSDenis V. Lunev 
2915a41e1faSDenis V. Lunev     while (nb_sectors > 0) {
2925a41e1faSDenis V. Lunev         int64_t position;
2935a41e1faSDenis V. Lunev         int n, nbytes;
2945a41e1faSDenis V. Lunev 
2955a41e1faSDenis V. Lunev         qemu_co_mutex_lock(&s->lock);
296ddd2ef2cSDenis V. Lunev         position = allocate_clusters(bs, sector_num, nb_sectors, &n);
2975a41e1faSDenis V. Lunev         qemu_co_mutex_unlock(&s->lock);
2985a41e1faSDenis V. Lunev         if (position < 0) {
2995a41e1faSDenis V. Lunev             ret = (int)position;
3005a41e1faSDenis V. Lunev             break;
3015a41e1faSDenis V. Lunev         }
3025a41e1faSDenis V. Lunev 
3035a41e1faSDenis V. Lunev         nbytes = n << BDRV_SECTOR_BITS;
3045a41e1faSDenis V. Lunev 
3055a41e1faSDenis V. Lunev         qemu_iovec_reset(&hd_qiov);
3065a41e1faSDenis V. Lunev         qemu_iovec_concat(&hd_qiov, qiov, bytes_done, nbytes);
3075a41e1faSDenis V. Lunev 
3089a4f4c31SKevin Wolf         ret = bdrv_co_writev(bs->file->bs, position, n, &hd_qiov);
3095a41e1faSDenis V. Lunev         if (ret < 0) {
3105a41e1faSDenis V. Lunev             break;
3115a41e1faSDenis V. Lunev         }
3125a41e1faSDenis V. Lunev 
3135a41e1faSDenis V. Lunev         nb_sectors -= n;
3145a41e1faSDenis V. Lunev         sector_num += n;
3155a41e1faSDenis V. Lunev         bytes_done += nbytes;
3165a41e1faSDenis V. Lunev     }
3175a41e1faSDenis V. Lunev 
3185a41e1faSDenis V. Lunev     qemu_iovec_destroy(&hd_qiov);
3195a41e1faSDenis V. Lunev     return ret;
3205a41e1faSDenis V. Lunev }
3215a41e1faSDenis V. Lunev 
322481fb9cfSDenis V. Lunev static coroutine_fn int parallels_co_readv(BlockDriverState *bs,
323481fb9cfSDenis V. Lunev         int64_t sector_num, int nb_sectors, QEMUIOVector *qiov)
324019d6b8fSAnthony Liguori {
32529442569SRoman Kagan     BDRVParallelsState *s = bs->opaque;
326481fb9cfSDenis V. Lunev     uint64_t bytes_done = 0;
327481fb9cfSDenis V. Lunev     QEMUIOVector hd_qiov;
328481fb9cfSDenis V. Lunev     int ret = 0;
329481fb9cfSDenis V. Lunev 
330481fb9cfSDenis V. Lunev     qemu_iovec_init(&hd_qiov, qiov->niov);
33129442569SRoman Kagan 
332019d6b8fSAnthony Liguori     while (nb_sectors > 0) {
333481fb9cfSDenis V. Lunev         int64_t position;
334481fb9cfSDenis V. Lunev         int n, nbytes;
335481fb9cfSDenis V. Lunev 
336481fb9cfSDenis V. Lunev         qemu_co_mutex_lock(&s->lock);
3376953d920SDenis V. Lunev         position = block_status(s, sector_num, nb_sectors, &n);
338481fb9cfSDenis V. Lunev         qemu_co_mutex_unlock(&s->lock);
339481fb9cfSDenis V. Lunev 
340481fb9cfSDenis V. Lunev         nbytes = n << BDRV_SECTOR_BITS;
341481fb9cfSDenis V. Lunev 
342481fb9cfSDenis V. Lunev         if (position < 0) {
343481fb9cfSDenis V. Lunev             qemu_iovec_memset(qiov, bytes_done, 0, nbytes);
3449d8b88f6SChristoph Hellwig         } else {
345481fb9cfSDenis V. Lunev             qemu_iovec_reset(&hd_qiov);
346481fb9cfSDenis V. Lunev             qemu_iovec_concat(&hd_qiov, qiov, bytes_done, nbytes);
347481fb9cfSDenis V. Lunev 
3489a4f4c31SKevin Wolf             ret = bdrv_co_readv(bs->file->bs, position, n, &hd_qiov);
349481fb9cfSDenis V. Lunev             if (ret < 0) {
350481fb9cfSDenis V. Lunev                 break;
3519d8b88f6SChristoph Hellwig             }
352019d6b8fSAnthony Liguori         }
353019d6b8fSAnthony Liguori 
354481fb9cfSDenis V. Lunev         nb_sectors -= n;
355481fb9cfSDenis V. Lunev         sector_num += n;
356481fb9cfSDenis V. Lunev         bytes_done += nbytes;
357481fb9cfSDenis V. Lunev     }
358481fb9cfSDenis V. Lunev 
359481fb9cfSDenis V. Lunev     qemu_iovec_destroy(&hd_qiov);
3602914caa0SPaolo Bonzini     return ret;
3612914caa0SPaolo Bonzini }
3622914caa0SPaolo Bonzini 
36349ad6467SDenis V. Lunev 
36449ad6467SDenis V. Lunev static int parallels_check(BlockDriverState *bs, BdrvCheckResult *res,
36549ad6467SDenis V. Lunev                            BdrvCheckMode fix)
36649ad6467SDenis V. Lunev {
36749ad6467SDenis V. Lunev     BDRVParallelsState *s = bs->opaque;
36849ad6467SDenis V. Lunev     int64_t size, prev_off, high_off;
36949ad6467SDenis V. Lunev     int ret;
37049ad6467SDenis V. Lunev     uint32_t i;
37149ad6467SDenis V. Lunev     bool flush_bat = false;
37249ad6467SDenis V. Lunev     int cluster_size = s->tracks << BDRV_SECTOR_BITS;
37349ad6467SDenis V. Lunev 
3749a4f4c31SKevin Wolf     size = bdrv_getlength(bs->file->bs);
37549ad6467SDenis V. Lunev     if (size < 0) {
37649ad6467SDenis V. Lunev         res->check_errors++;
37749ad6467SDenis V. Lunev         return size;
37849ad6467SDenis V. Lunev     }
37949ad6467SDenis V. Lunev 
3806dd6b9f1SDenis V. Lunev     if (s->header_unclean) {
3816dd6b9f1SDenis V. Lunev         fprintf(stderr, "%s image was not closed correctly\n",
3826dd6b9f1SDenis V. Lunev                 fix & BDRV_FIX_ERRORS ? "Repairing" : "ERROR");
3836dd6b9f1SDenis V. Lunev         res->corruptions++;
3846dd6b9f1SDenis V. Lunev         if (fix & BDRV_FIX_ERRORS) {
3856dd6b9f1SDenis V. Lunev             /* parallels_close will do the job right */
3866dd6b9f1SDenis V. Lunev             res->corruptions_fixed++;
3876dd6b9f1SDenis V. Lunev             s->header_unclean = false;
3886dd6b9f1SDenis V. Lunev         }
3896dd6b9f1SDenis V. Lunev     }
3906dd6b9f1SDenis V. Lunev 
39149ad6467SDenis V. Lunev     res->bfi.total_clusters = s->bat_size;
39249ad6467SDenis V. Lunev     res->bfi.compressed_clusters = 0; /* compression is not supported */
39349ad6467SDenis V. Lunev 
39449ad6467SDenis V. Lunev     high_off = 0;
39549ad6467SDenis V. Lunev     prev_off = 0;
39649ad6467SDenis V. Lunev     for (i = 0; i < s->bat_size; i++) {
39749ad6467SDenis V. Lunev         int64_t off = bat2sect(s, i) << BDRV_SECTOR_BITS;
39849ad6467SDenis V. Lunev         if (off == 0) {
39949ad6467SDenis V. Lunev             prev_off = 0;
40049ad6467SDenis V. Lunev             continue;
40149ad6467SDenis V. Lunev         }
40249ad6467SDenis V. Lunev 
40349ad6467SDenis V. Lunev         /* cluster outside the image */
40449ad6467SDenis V. Lunev         if (off > size) {
40549ad6467SDenis V. Lunev             fprintf(stderr, "%s cluster %u is outside image\n",
40649ad6467SDenis V. Lunev                     fix & BDRV_FIX_ERRORS ? "Repairing" : "ERROR", i);
40749ad6467SDenis V. Lunev             res->corruptions++;
40849ad6467SDenis V. Lunev             if (fix & BDRV_FIX_ERRORS) {
40949ad6467SDenis V. Lunev                 prev_off = 0;
41049ad6467SDenis V. Lunev                 s->bat_bitmap[i] = 0;
41149ad6467SDenis V. Lunev                 res->corruptions_fixed++;
41249ad6467SDenis V. Lunev                 flush_bat = true;
41349ad6467SDenis V. Lunev                 continue;
41449ad6467SDenis V. Lunev             }
41549ad6467SDenis V. Lunev         }
41649ad6467SDenis V. Lunev 
41749ad6467SDenis V. Lunev         res->bfi.allocated_clusters++;
41849ad6467SDenis V. Lunev         if (off > high_off) {
41949ad6467SDenis V. Lunev             high_off = off;
42049ad6467SDenis V. Lunev         }
42149ad6467SDenis V. Lunev 
42249ad6467SDenis V. Lunev         if (prev_off != 0 && (prev_off + cluster_size) != off) {
42349ad6467SDenis V. Lunev             res->bfi.fragmented_clusters++;
42449ad6467SDenis V. Lunev         }
42549ad6467SDenis V. Lunev         prev_off = off;
42649ad6467SDenis V. Lunev     }
42749ad6467SDenis V. Lunev 
42849ad6467SDenis V. Lunev     if (flush_bat) {
4299a4f4c31SKevin Wolf         ret = bdrv_pwrite_sync(bs->file->bs, 0, s->header, s->header_size);
43049ad6467SDenis V. Lunev         if (ret < 0) {
43149ad6467SDenis V. Lunev             res->check_errors++;
43249ad6467SDenis V. Lunev             return ret;
43349ad6467SDenis V. Lunev         }
43449ad6467SDenis V. Lunev     }
43549ad6467SDenis V. Lunev 
43649ad6467SDenis V. Lunev     res->image_end_offset = high_off + cluster_size;
43749ad6467SDenis V. Lunev     if (size > res->image_end_offset) {
43849ad6467SDenis V. Lunev         int64_t count;
43949ad6467SDenis V. Lunev         count = DIV_ROUND_UP(size - res->image_end_offset, cluster_size);
44049ad6467SDenis V. Lunev         fprintf(stderr, "%s space leaked at the end of the image %" PRId64 "\n",
44149ad6467SDenis V. Lunev                 fix & BDRV_FIX_LEAKS ? "Repairing" : "ERROR",
44249ad6467SDenis V. Lunev                 size - res->image_end_offset);
44349ad6467SDenis V. Lunev         res->leaks += count;
44449ad6467SDenis V. Lunev         if (fix & BDRV_FIX_LEAKS) {
4459a4f4c31SKevin Wolf             ret = bdrv_truncate(bs->file->bs, res->image_end_offset);
44649ad6467SDenis V. Lunev             if (ret < 0) {
44749ad6467SDenis V. Lunev                 res->check_errors++;
44849ad6467SDenis V. Lunev                 return ret;
44949ad6467SDenis V. Lunev             }
45049ad6467SDenis V. Lunev             res->leaks_fixed += count;
45149ad6467SDenis V. Lunev         }
45249ad6467SDenis V. Lunev     }
45349ad6467SDenis V. Lunev 
45449ad6467SDenis V. Lunev     return 0;
45549ad6467SDenis V. Lunev }
45649ad6467SDenis V. Lunev 
45749ad6467SDenis V. Lunev 
45874cf6c50SDenis V. Lunev static int parallels_create(const char *filename, QemuOpts *opts, Error **errp)
45974cf6c50SDenis V. Lunev {
46074cf6c50SDenis V. Lunev     int64_t total_size, cl_size;
46174cf6c50SDenis V. Lunev     uint8_t tmp[BDRV_SECTOR_SIZE];
46274cf6c50SDenis V. Lunev     Error *local_err = NULL;
46374cf6c50SDenis V. Lunev     BlockDriverState *file;
464369f7de9SDenis V. Lunev     uint32_t bat_entries, bat_sectors;
46574cf6c50SDenis V. Lunev     ParallelsHeader header;
46674cf6c50SDenis V. Lunev     int ret;
46774cf6c50SDenis V. Lunev 
46874cf6c50SDenis V. Lunev     total_size = ROUND_UP(qemu_opt_get_size_del(opts, BLOCK_OPT_SIZE, 0),
46974cf6c50SDenis V. Lunev                           BDRV_SECTOR_SIZE);
47074cf6c50SDenis V. Lunev     cl_size = ROUND_UP(qemu_opt_get_size_del(opts, BLOCK_OPT_CLUSTER_SIZE,
47174cf6c50SDenis V. Lunev                           DEFAULT_CLUSTER_SIZE), BDRV_SECTOR_SIZE);
47274cf6c50SDenis V. Lunev 
47374cf6c50SDenis V. Lunev     ret = bdrv_create_file(filename, opts, &local_err);
47474cf6c50SDenis V. Lunev     if (ret < 0) {
47574cf6c50SDenis V. Lunev         error_propagate(errp, local_err);
47674cf6c50SDenis V. Lunev         return ret;
47774cf6c50SDenis V. Lunev     }
47874cf6c50SDenis V. Lunev 
47974cf6c50SDenis V. Lunev     file = NULL;
48074cf6c50SDenis V. Lunev     ret = bdrv_open(&file, filename, NULL, NULL,
4816ebf9aa2SMax Reitz                     BDRV_O_RDWR | BDRV_O_PROTOCOL, &local_err);
48274cf6c50SDenis V. Lunev     if (ret < 0) {
48374cf6c50SDenis V. Lunev         error_propagate(errp, local_err);
48474cf6c50SDenis V. Lunev         return ret;
48574cf6c50SDenis V. Lunev     }
48674cf6c50SDenis V. Lunev     ret = bdrv_truncate(file, 0);
48774cf6c50SDenis V. Lunev     if (ret < 0) {
48874cf6c50SDenis V. Lunev         goto exit;
48974cf6c50SDenis V. Lunev     }
49074cf6c50SDenis V. Lunev 
491369f7de9SDenis V. Lunev     bat_entries = DIV_ROUND_UP(total_size, cl_size);
4922d68e22eSDenis V. Lunev     bat_sectors = DIV_ROUND_UP(bat_entry_off(bat_entries), cl_size);
493369f7de9SDenis V. Lunev     bat_sectors = (bat_sectors *  cl_size) >> BDRV_SECTOR_BITS;
49474cf6c50SDenis V. Lunev 
49574cf6c50SDenis V. Lunev     memset(&header, 0, sizeof(header));
49674cf6c50SDenis V. Lunev     memcpy(header.magic, HEADER_MAGIC2, sizeof(header.magic));
49774cf6c50SDenis V. Lunev     header.version = cpu_to_le32(HEADER_VERSION);
49874cf6c50SDenis V. Lunev     /* don't care much about geometry, it is not used on image level */
49974cf6c50SDenis V. Lunev     header.heads = cpu_to_le32(16);
50074cf6c50SDenis V. Lunev     header.cylinders = cpu_to_le32(total_size / BDRV_SECTOR_SIZE / 16 / 32);
50174cf6c50SDenis V. Lunev     header.tracks = cpu_to_le32(cl_size >> BDRV_SECTOR_BITS);
502369f7de9SDenis V. Lunev     header.bat_entries = cpu_to_le32(bat_entries);
50374cf6c50SDenis V. Lunev     header.nb_sectors = cpu_to_le64(DIV_ROUND_UP(total_size, BDRV_SECTOR_SIZE));
504369f7de9SDenis V. Lunev     header.data_off = cpu_to_le32(bat_sectors);
50574cf6c50SDenis V. Lunev 
50674cf6c50SDenis V. Lunev     /* write all the data */
50774cf6c50SDenis V. Lunev     memset(tmp, 0, sizeof(tmp));
50874cf6c50SDenis V. Lunev     memcpy(tmp, &header, sizeof(header));
50974cf6c50SDenis V. Lunev 
51074cf6c50SDenis V. Lunev     ret = bdrv_pwrite(file, 0, tmp, BDRV_SECTOR_SIZE);
51174cf6c50SDenis V. Lunev     if (ret < 0) {
51274cf6c50SDenis V. Lunev         goto exit;
51374cf6c50SDenis V. Lunev     }
514369f7de9SDenis V. Lunev     ret = bdrv_write_zeroes(file, 1, bat_sectors - 1, 0);
51574cf6c50SDenis V. Lunev     if (ret < 0) {
51674cf6c50SDenis V. Lunev         goto exit;
51774cf6c50SDenis V. Lunev     }
51874cf6c50SDenis V. Lunev     ret = 0;
51974cf6c50SDenis V. Lunev 
52074cf6c50SDenis V. Lunev done:
52174cf6c50SDenis V. Lunev     bdrv_unref(file);
52274cf6c50SDenis V. Lunev     return ret;
52374cf6c50SDenis V. Lunev 
52474cf6c50SDenis V. Lunev exit:
52574cf6c50SDenis V. Lunev     error_setg_errno(errp, -ret, "Failed to create Parallels image");
52674cf6c50SDenis V. Lunev     goto done;
52774cf6c50SDenis V. Lunev }
52874cf6c50SDenis V. Lunev 
52923d6bd3bSDenis V. Lunev 
53023d6bd3bSDenis V. Lunev static int parallels_probe(const uint8_t *buf, int buf_size,
53123d6bd3bSDenis V. Lunev                            const char *filename)
53223d6bd3bSDenis V. Lunev {
53323d6bd3bSDenis V. Lunev     const ParallelsHeader *ph = (const void *)buf;
53423d6bd3bSDenis V. Lunev 
53523d6bd3bSDenis V. Lunev     if (buf_size < sizeof(ParallelsHeader)) {
53623d6bd3bSDenis V. Lunev         return 0;
53723d6bd3bSDenis V. Lunev     }
53823d6bd3bSDenis V. Lunev 
53923d6bd3bSDenis V. Lunev     if ((!memcmp(ph->magic, HEADER_MAGIC, 16) ||
54023d6bd3bSDenis V. Lunev            !memcmp(ph->magic, HEADER_MAGIC2, 16)) &&
54123d6bd3bSDenis V. Lunev            (le32_to_cpu(ph->version) == HEADER_VERSION)) {
54223d6bd3bSDenis V. Lunev         return 100;
54323d6bd3bSDenis V. Lunev     }
54423d6bd3bSDenis V. Lunev 
54523d6bd3bSDenis V. Lunev     return 0;
54623d6bd3bSDenis V. Lunev }
54723d6bd3bSDenis V. Lunev 
5486dd6b9f1SDenis V. Lunev static int parallels_update_header(BlockDriverState *bs)
5496dd6b9f1SDenis V. Lunev {
5506dd6b9f1SDenis V. Lunev     BDRVParallelsState *s = bs->opaque;
5519a4f4c31SKevin Wolf     unsigned size = MAX(bdrv_opt_mem_align(bs->file->bs),
5529a4f4c31SKevin Wolf                         sizeof(ParallelsHeader));
5536dd6b9f1SDenis V. Lunev 
5546dd6b9f1SDenis V. Lunev     if (size > s->header_size) {
5556dd6b9f1SDenis V. Lunev         size = s->header_size;
5566dd6b9f1SDenis V. Lunev     }
5579a4f4c31SKevin Wolf     return bdrv_pwrite_sync(bs->file->bs, 0, s->header, size);
5586dd6b9f1SDenis V. Lunev }
5596dd6b9f1SDenis V. Lunev 
56023d6bd3bSDenis V. Lunev static int parallels_open(BlockDriverState *bs, QDict *options, int flags,
56123d6bd3bSDenis V. Lunev                           Error **errp)
56223d6bd3bSDenis V. Lunev {
56323d6bd3bSDenis V. Lunev     BDRVParallelsState *s = bs->opaque;
56423d6bd3bSDenis V. Lunev     ParallelsHeader ph;
56519f5dc15SDenis V. Lunev     int ret, size, i;
566d6179011SDenis V. Lunev     QemuOpts *opts = NULL;
567d6179011SDenis V. Lunev     Error *local_err = NULL;
568d6179011SDenis V. Lunev     char *buf;
56923d6bd3bSDenis V. Lunev 
5709a4f4c31SKevin Wolf     ret = bdrv_pread(bs->file->bs, 0, &ph, sizeof(ph));
57123d6bd3bSDenis V. Lunev     if (ret < 0) {
57223d6bd3bSDenis V. Lunev         goto fail;
57323d6bd3bSDenis V. Lunev     }
57423d6bd3bSDenis V. Lunev 
57523d6bd3bSDenis V. Lunev     bs->total_sectors = le64_to_cpu(ph.nb_sectors);
57623d6bd3bSDenis V. Lunev 
57723d6bd3bSDenis V. Lunev     if (le32_to_cpu(ph.version) != HEADER_VERSION) {
57823d6bd3bSDenis V. Lunev         goto fail_format;
57923d6bd3bSDenis V. Lunev     }
58023d6bd3bSDenis V. Lunev     if (!memcmp(ph.magic, HEADER_MAGIC, 16)) {
58123d6bd3bSDenis V. Lunev         s->off_multiplier = 1;
58223d6bd3bSDenis V. Lunev         bs->total_sectors = 0xffffffff & bs->total_sectors;
58323d6bd3bSDenis V. Lunev     } else if (!memcmp(ph.magic, HEADER_MAGIC2, 16)) {
58423d6bd3bSDenis V. Lunev         s->off_multiplier = le32_to_cpu(ph.tracks);
58523d6bd3bSDenis V. Lunev     } else {
58623d6bd3bSDenis V. Lunev         goto fail_format;
58723d6bd3bSDenis V. Lunev     }
58823d6bd3bSDenis V. Lunev 
58923d6bd3bSDenis V. Lunev     s->tracks = le32_to_cpu(ph.tracks);
59023d6bd3bSDenis V. Lunev     if (s->tracks == 0) {
59123d6bd3bSDenis V. Lunev         error_setg(errp, "Invalid image: Zero sectors per track");
59223d6bd3bSDenis V. Lunev         ret = -EINVAL;
59323d6bd3bSDenis V. Lunev         goto fail;
59423d6bd3bSDenis V. Lunev     }
59523d6bd3bSDenis V. Lunev     if (s->tracks > INT32_MAX/513) {
59623d6bd3bSDenis V. Lunev         error_setg(errp, "Invalid image: Too big cluster");
59723d6bd3bSDenis V. Lunev         ret = -EFBIG;
59823d6bd3bSDenis V. Lunev         goto fail;
59923d6bd3bSDenis V. Lunev     }
60023d6bd3bSDenis V. Lunev 
60123d6bd3bSDenis V. Lunev     s->bat_size = le32_to_cpu(ph.bat_entries);
60223d6bd3bSDenis V. Lunev     if (s->bat_size > INT_MAX / sizeof(uint32_t)) {
60323d6bd3bSDenis V. Lunev         error_setg(errp, "Catalog too large");
60423d6bd3bSDenis V. Lunev         ret = -EFBIG;
60523d6bd3bSDenis V. Lunev         goto fail;
60623d6bd3bSDenis V. Lunev     }
60723d6bd3bSDenis V. Lunev 
6082d68e22eSDenis V. Lunev     size = bat_entry_off(s->bat_size);
6099a4f4c31SKevin Wolf     s->header_size = ROUND_UP(size, bdrv_opt_mem_align(bs->file->bs));
6109a4f4c31SKevin Wolf     s->header = qemu_try_blockalign(bs->file->bs, s->header_size);
61123d6bd3bSDenis V. Lunev     if (s->header == NULL) {
61223d6bd3bSDenis V. Lunev         ret = -ENOMEM;
61323d6bd3bSDenis V. Lunev         goto fail;
61423d6bd3bSDenis V. Lunev     }
61519f5dc15SDenis V. Lunev     s->data_end = le32_to_cpu(ph.data_off);
61619f5dc15SDenis V. Lunev     if (s->data_end == 0) {
61719f5dc15SDenis V. Lunev         s->data_end = ROUND_UP(bat_entry_off(s->bat_size), BDRV_SECTOR_SIZE);
61819f5dc15SDenis V. Lunev     }
61919f5dc15SDenis V. Lunev     if (s->data_end < s->header_size) {
62023d6bd3bSDenis V. Lunev         /* there is not enough unused space to fit to block align between BAT
62123d6bd3bSDenis V. Lunev            and actual data. We can't avoid read-modify-write... */
62223d6bd3bSDenis V. Lunev         s->header_size = size;
62323d6bd3bSDenis V. Lunev     }
62423d6bd3bSDenis V. Lunev 
6259a4f4c31SKevin Wolf     ret = bdrv_pread(bs->file->bs, 0, s->header, s->header_size);
62623d6bd3bSDenis V. Lunev     if (ret < 0) {
62723d6bd3bSDenis V. Lunev         goto fail;
62823d6bd3bSDenis V. Lunev     }
62923d6bd3bSDenis V. Lunev     s->bat_bitmap = (uint32_t *)(s->header + 1);
63023d6bd3bSDenis V. Lunev 
63119f5dc15SDenis V. Lunev     for (i = 0; i < s->bat_size; i++) {
63219f5dc15SDenis V. Lunev         int64_t off = bat2sect(s, i);
63319f5dc15SDenis V. Lunev         if (off >= s->data_end) {
63419f5dc15SDenis V. Lunev             s->data_end = off + s->tracks;
63519f5dc15SDenis V. Lunev         }
63619f5dc15SDenis V. Lunev     }
63719f5dc15SDenis V. Lunev 
6386dd6b9f1SDenis V. Lunev     if (le32_to_cpu(ph.inuse) == HEADER_INUSE_MAGIC) {
6396dd6b9f1SDenis V. Lunev         /* Image was not closed correctly. The check is mandatory */
6406dd6b9f1SDenis V. Lunev         s->header_unclean = true;
6416dd6b9f1SDenis V. Lunev         if ((flags & BDRV_O_RDWR) && !(flags & BDRV_O_CHECK)) {
6426dd6b9f1SDenis V. Lunev             error_setg(errp, "parallels: Image was not closed correctly; "
6436dd6b9f1SDenis V. Lunev                        "cannot be opened read/write");
6446dd6b9f1SDenis V. Lunev             ret = -EACCES;
6456dd6b9f1SDenis V. Lunev             goto fail;
6466dd6b9f1SDenis V. Lunev         }
6476dd6b9f1SDenis V. Lunev     }
6486dd6b9f1SDenis V. Lunev 
649d6179011SDenis V. Lunev     opts = qemu_opts_create(&parallels_runtime_opts, NULL, 0, &local_err);
650d6179011SDenis V. Lunev     if (local_err != NULL) {
651d6179011SDenis V. Lunev         goto fail_options;
652d6179011SDenis V. Lunev     }
653d6179011SDenis V. Lunev 
654d6179011SDenis V. Lunev     qemu_opts_absorb_qdict(opts, options, &local_err);
655d6179011SDenis V. Lunev     if (local_err != NULL) {
656d6179011SDenis V. Lunev         goto fail_options;
657d6179011SDenis V. Lunev     }
658d6179011SDenis V. Lunev 
659d6179011SDenis V. Lunev     s->prealloc_size =
660d6179011SDenis V. Lunev         qemu_opt_get_size_del(opts, PARALLELS_OPT_PREALLOC_SIZE, 0);
661d6179011SDenis V. Lunev     s->prealloc_size = MAX(s->tracks, s->prealloc_size >> BDRV_SECTOR_BITS);
662d6179011SDenis V. Lunev     buf = qemu_opt_get_del(opts, PARALLELS_OPT_PREALLOC_MODE);
663d6179011SDenis V. Lunev     s->prealloc_mode = qapi_enum_parse(prealloc_mode_lookup, buf,
6647fb1cf16SEric Blake             PRL_PREALLOC_MODE__MAX, PRL_PREALLOC_MODE_FALLOCATE, &local_err);
665d6179011SDenis V. Lunev     g_free(buf);
666d6179011SDenis V. Lunev     if (local_err != NULL) {
667d6179011SDenis V. Lunev         goto fail_options;
668d6179011SDenis V. Lunev     }
6699a4f4c31SKevin Wolf     if (!bdrv_has_zero_init(bs->file->bs) ||
6709a4f4c31SKevin Wolf             bdrv_truncate(bs->file->bs, bdrv_getlength(bs->file->bs)) != 0) {
671d6179011SDenis V. Lunev         s->prealloc_mode = PRL_PREALLOC_MODE_FALLOCATE;
672d6179011SDenis V. Lunev     }
673d6179011SDenis V. Lunev 
6746dd6b9f1SDenis V. Lunev     if (flags & BDRV_O_RDWR) {
6756dd6b9f1SDenis V. Lunev         s->header->inuse = cpu_to_le32(HEADER_INUSE_MAGIC);
6766dd6b9f1SDenis V. Lunev         ret = parallels_update_header(bs);
6776dd6b9f1SDenis V. Lunev         if (ret < 0) {
6786dd6b9f1SDenis V. Lunev             goto fail;
6796dd6b9f1SDenis V. Lunev         }
6806dd6b9f1SDenis V. Lunev     }
6816dd6b9f1SDenis V. Lunev 
6820d31c7c2SDenis V. Lunev     s->bat_dirty_block = 4 * getpagesize();
6830d31c7c2SDenis V. Lunev     s->bat_dirty_bmap =
6840d31c7c2SDenis V. Lunev         bitmap_new(DIV_ROUND_UP(s->header_size, s->bat_dirty_block));
6850d31c7c2SDenis V. Lunev 
68623d6bd3bSDenis V. Lunev     qemu_co_mutex_init(&s->lock);
68723d6bd3bSDenis V. Lunev     return 0;
68823d6bd3bSDenis V. Lunev 
68923d6bd3bSDenis V. Lunev fail_format:
69023d6bd3bSDenis V. Lunev     error_setg(errp, "Image not in Parallels format");
69123d6bd3bSDenis V. Lunev     ret = -EINVAL;
69223d6bd3bSDenis V. Lunev fail:
69323d6bd3bSDenis V. Lunev     qemu_vfree(s->header);
69423d6bd3bSDenis V. Lunev     return ret;
695d6179011SDenis V. Lunev 
696d6179011SDenis V. Lunev fail_options:
697d6179011SDenis V. Lunev     error_propagate(errp, local_err);
698d6179011SDenis V. Lunev     ret = -EINVAL;
699d6179011SDenis V. Lunev     goto fail;
70023d6bd3bSDenis V. Lunev }
70123d6bd3bSDenis V. Lunev 
70223d6bd3bSDenis V. Lunev 
703019d6b8fSAnthony Liguori static void parallels_close(BlockDriverState *bs)
704019d6b8fSAnthony Liguori {
705019d6b8fSAnthony Liguori     BDRVParallelsState *s = bs->opaque;
7066dd6b9f1SDenis V. Lunev 
7076dd6b9f1SDenis V. Lunev     if (bs->open_flags & BDRV_O_RDWR) {
7086dd6b9f1SDenis V. Lunev         s->header->inuse = 0;
7096dd6b9f1SDenis V. Lunev         parallels_update_header(bs);
7106dd6b9f1SDenis V. Lunev     }
7116dd6b9f1SDenis V. Lunev 
71219f5dc15SDenis V. Lunev     if (bs->open_flags & BDRV_O_RDWR) {
7139a4f4c31SKevin Wolf         bdrv_truncate(bs->file->bs, s->data_end << BDRV_SECTOR_BITS);
71419f5dc15SDenis V. Lunev     }
71519f5dc15SDenis V. Lunev 
7160d31c7c2SDenis V. Lunev     g_free(s->bat_dirty_bmap);
7179eae9ccaSDenis V. Lunev     qemu_vfree(s->header);
718019d6b8fSAnthony Liguori }
719019d6b8fSAnthony Liguori 
72074cf6c50SDenis V. Lunev static QemuOptsList parallels_create_opts = {
72174cf6c50SDenis V. Lunev     .name = "parallels-create-opts",
72274cf6c50SDenis V. Lunev     .head = QTAILQ_HEAD_INITIALIZER(parallels_create_opts.head),
72374cf6c50SDenis V. Lunev     .desc = {
72474cf6c50SDenis V. Lunev         {
72574cf6c50SDenis V. Lunev             .name = BLOCK_OPT_SIZE,
72674cf6c50SDenis V. Lunev             .type = QEMU_OPT_SIZE,
72774cf6c50SDenis V. Lunev             .help = "Virtual disk size",
72874cf6c50SDenis V. Lunev         },
72974cf6c50SDenis V. Lunev         {
73074cf6c50SDenis V. Lunev             .name = BLOCK_OPT_CLUSTER_SIZE,
73174cf6c50SDenis V. Lunev             .type = QEMU_OPT_SIZE,
73274cf6c50SDenis V. Lunev             .help = "Parallels image cluster size",
73374cf6c50SDenis V. Lunev             .def_value_str = stringify(DEFAULT_CLUSTER_SIZE),
73474cf6c50SDenis V. Lunev         },
73574cf6c50SDenis V. Lunev         { /* end of list */ }
73674cf6c50SDenis V. Lunev     }
73774cf6c50SDenis V. Lunev };
73874cf6c50SDenis V. Lunev 
739019d6b8fSAnthony Liguori static BlockDriver bdrv_parallels = {
740019d6b8fSAnthony Liguori     .format_name	= "parallels",
741019d6b8fSAnthony Liguori     .instance_size	= sizeof(BDRVParallelsState),
742019d6b8fSAnthony Liguori     .bdrv_probe		= parallels_probe,
7431dec5a70SChristoph Hellwig     .bdrv_open		= parallels_open,
744019d6b8fSAnthony Liguori     .bdrv_close		= parallels_close,
745dd3bed16SRoman Kagan     .bdrv_co_get_block_status = parallels_co_get_block_status,
746d0e61ce5SDenis V. Lunev     .bdrv_has_zero_init       = bdrv_has_zero_init_1,
7470d31c7c2SDenis V. Lunev     .bdrv_co_flush_to_os      = parallels_co_flush_to_os,
748481fb9cfSDenis V. Lunev     .bdrv_co_readv  = parallels_co_readv,
7495a41e1faSDenis V. Lunev     .bdrv_co_writev = parallels_co_writev,
75074cf6c50SDenis V. Lunev 
75174cf6c50SDenis V. Lunev     .bdrv_create    = parallels_create,
75249ad6467SDenis V. Lunev     .bdrv_check     = parallels_check,
75374cf6c50SDenis V. Lunev     .create_opts    = &parallels_create_opts,
754019d6b8fSAnthony Liguori };
755019d6b8fSAnthony Liguori 
756019d6b8fSAnthony Liguori static void bdrv_parallels_init(void)
757019d6b8fSAnthony Liguori {
758019d6b8fSAnthony Liguori     bdrv_register(&bdrv_parallels);
759019d6b8fSAnthony Liguori }
760019d6b8fSAnthony Liguori 
761019d6b8fSAnthony Liguori block_init(bdrv_parallels_init);
762