xref: /openbmc/qemu/block.c (revision c07a9008ac6985cd5a15909c2b9977d982defc12)
1fc01f7e7Sbellard /*
2fc01f7e7Sbellard  * QEMU System Emulator block driver
3fc01f7e7Sbellard  *
4fc01f7e7Sbellard  * Copyright (c) 2003 Fabrice Bellard
5fc01f7e7Sbellard  *
6fc01f7e7Sbellard  * Permission is hereby granted, free of charge, to any person obtaining a copy
7fc01f7e7Sbellard  * of this software and associated documentation files (the "Software"), to deal
8fc01f7e7Sbellard  * in the Software without restriction, including without limitation the rights
9fc01f7e7Sbellard  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10fc01f7e7Sbellard  * copies of the Software, and to permit persons to whom the Software is
11fc01f7e7Sbellard  * furnished to do so, subject to the following conditions:
12fc01f7e7Sbellard  *
13fc01f7e7Sbellard  * The above copyright notice and this permission notice shall be included in
14fc01f7e7Sbellard  * all copies or substantial portions of the Software.
15fc01f7e7Sbellard  *
16fc01f7e7Sbellard  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17fc01f7e7Sbellard  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18fc01f7e7Sbellard  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19fc01f7e7Sbellard  * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20fc01f7e7Sbellard  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21fc01f7e7Sbellard  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
22fc01f7e7Sbellard  * THE SOFTWARE.
23fc01f7e7Sbellard  */
243990d09aSblueswir1 #include "config-host.h"
25179a2c19Sblueswir1 #ifdef HOST_BSD
263990d09aSblueswir1 /* include native header before sys-queue.h */
273990d09aSblueswir1 #include <sys/queue.h>
283990d09aSblueswir1 #endif
293990d09aSblueswir1 
30faf07963Spbrook #include "qemu-common.h"
31376253ecSaliguori #include "monitor.h"
32ea2384d3Sbellard #include "block_int.h"
33fc01f7e7Sbellard 
34179a2c19Sblueswir1 #ifdef HOST_BSD
357674e7bfSbellard #include <sys/types.h>
367674e7bfSbellard #include <sys/stat.h>
377674e7bfSbellard #include <sys/ioctl.h>
38c5e97233Sblueswir1 #ifndef __DragonFly__
397674e7bfSbellard #include <sys/disk.h>
407674e7bfSbellard #endif
41c5e97233Sblueswir1 #endif
427674e7bfSbellard 
4349dc768dSaliguori #ifdef _WIN32
4449dc768dSaliguori #include <windows.h>
4549dc768dSaliguori #endif
4649dc768dSaliguori 
4783f64091Sbellard #define SECTOR_BITS 9
4883f64091Sbellard #define SECTOR_SIZE (1 << SECTOR_BITS)
493b0d4f61Sbellard 
50*c07a9008Saliguori static AIOPool vectored_aio_pool;
51*c07a9008Saliguori 
5290765429Sbellard typedef struct BlockDriverAIOCBSync {
5390765429Sbellard     BlockDriverAIOCB common;
5490765429Sbellard     QEMUBH *bh;
5590765429Sbellard     int ret;
5690765429Sbellard } BlockDriverAIOCBSync;
5790765429Sbellard 
58ce1a14dcSpbrook static BlockDriverAIOCB *bdrv_aio_read_em(BlockDriverState *bs,
59ce1a14dcSpbrook         int64_t sector_num, uint8_t *buf, int nb_sectors,
60ce1a14dcSpbrook         BlockDriverCompletionFunc *cb, void *opaque);
61ce1a14dcSpbrook static BlockDriverAIOCB *bdrv_aio_write_em(BlockDriverState *bs,
62ce1a14dcSpbrook         int64_t sector_num, const uint8_t *buf, int nb_sectors,
63ce1a14dcSpbrook         BlockDriverCompletionFunc *cb, void *opaque);
6483f64091Sbellard static void bdrv_aio_cancel_em(BlockDriverAIOCB *acb);
6583f64091Sbellard static int bdrv_read_em(BlockDriverState *bs, int64_t sector_num,
6683f64091Sbellard                         uint8_t *buf, int nb_sectors);
6783f64091Sbellard static int bdrv_write_em(BlockDriverState *bs, int64_t sector_num,
6883f64091Sbellard                          const uint8_t *buf, int nb_sectors);
69ec530c81Sbellard 
707ee930d0Sblueswir1 BlockDriverState *bdrv_first;
717ee930d0Sblueswir1 
72ea2384d3Sbellard static BlockDriver *first_drv;
73ea2384d3Sbellard 
7483f64091Sbellard int path_is_absolute(const char *path)
7583f64091Sbellard {
7683f64091Sbellard     const char *p;
7721664424Sbellard #ifdef _WIN32
7821664424Sbellard     /* specific case for names like: "\\.\d:" */
7921664424Sbellard     if (*path == '/' || *path == '\\')
8021664424Sbellard         return 1;
8121664424Sbellard #endif
8283f64091Sbellard     p = strchr(path, ':');
8383f64091Sbellard     if (p)
8483f64091Sbellard         p++;
8583f64091Sbellard     else
8683f64091Sbellard         p = path;
873b9f94e1Sbellard #ifdef _WIN32
883b9f94e1Sbellard     return (*p == '/' || *p == '\\');
893b9f94e1Sbellard #else
903b9f94e1Sbellard     return (*p == '/');
913b9f94e1Sbellard #endif
9283f64091Sbellard }
9383f64091Sbellard 
9483f64091Sbellard /* if filename is absolute, just copy it to dest. Otherwise, build a
9583f64091Sbellard    path to it by considering it is relative to base_path. URL are
9683f64091Sbellard    supported. */
9783f64091Sbellard void path_combine(char *dest, int dest_size,
9883f64091Sbellard                   const char *base_path,
9983f64091Sbellard                   const char *filename)
10083f64091Sbellard {
10183f64091Sbellard     const char *p, *p1;
10283f64091Sbellard     int len;
10383f64091Sbellard 
10483f64091Sbellard     if (dest_size <= 0)
10583f64091Sbellard         return;
10683f64091Sbellard     if (path_is_absolute(filename)) {
10783f64091Sbellard         pstrcpy(dest, dest_size, filename);
10883f64091Sbellard     } else {
10983f64091Sbellard         p = strchr(base_path, ':');
11083f64091Sbellard         if (p)
11183f64091Sbellard             p++;
11283f64091Sbellard         else
11383f64091Sbellard             p = base_path;
1143b9f94e1Sbellard         p1 = strrchr(base_path, '/');
1153b9f94e1Sbellard #ifdef _WIN32
1163b9f94e1Sbellard         {
1173b9f94e1Sbellard             const char *p2;
1183b9f94e1Sbellard             p2 = strrchr(base_path, '\\');
1193b9f94e1Sbellard             if (!p1 || p2 > p1)
1203b9f94e1Sbellard                 p1 = p2;
1213b9f94e1Sbellard         }
1223b9f94e1Sbellard #endif
12383f64091Sbellard         if (p1)
12483f64091Sbellard             p1++;
12583f64091Sbellard         else
12683f64091Sbellard             p1 = base_path;
12783f64091Sbellard         if (p1 > p)
12883f64091Sbellard             p = p1;
12983f64091Sbellard         len = p - base_path;
13083f64091Sbellard         if (len > dest_size - 1)
13183f64091Sbellard             len = dest_size - 1;
13283f64091Sbellard         memcpy(dest, base_path, len);
13383f64091Sbellard         dest[len] = '\0';
13483f64091Sbellard         pstrcat(dest, dest_size, filename);
13583f64091Sbellard     }
13683f64091Sbellard }
13783f64091Sbellard 
13883f64091Sbellard 
1399596ebb7Spbrook static void bdrv_register(BlockDriver *bdrv)
140ea2384d3Sbellard {
141ce1a14dcSpbrook     if (!bdrv->bdrv_aio_read) {
14283f64091Sbellard         /* add AIO emulation layer */
14383f64091Sbellard         bdrv->bdrv_aio_read = bdrv_aio_read_em;
14483f64091Sbellard         bdrv->bdrv_aio_write = bdrv_aio_write_em;
14583f64091Sbellard         bdrv->bdrv_aio_cancel = bdrv_aio_cancel_em;
14690765429Sbellard         bdrv->aiocb_size = sizeof(BlockDriverAIOCBSync);
147eda578e5Saliguori     } else if (!bdrv->bdrv_read) {
14883f64091Sbellard         /* add synchronous IO emulation layer */
14983f64091Sbellard         bdrv->bdrv_read = bdrv_read_em;
15083f64091Sbellard         bdrv->bdrv_write = bdrv_write_em;
15183f64091Sbellard     }
1526bbff9a0Saliguori     aio_pool_init(&bdrv->aio_pool, bdrv->aiocb_size, bdrv->bdrv_aio_cancel);
153ea2384d3Sbellard     bdrv->next = first_drv;
154ea2384d3Sbellard     first_drv = bdrv;
155ea2384d3Sbellard }
156b338082bSbellard 
157b338082bSbellard /* create a new block device (by default it is empty) */
158b338082bSbellard BlockDriverState *bdrv_new(const char *device_name)
159fc01f7e7Sbellard {
160b338082bSbellard     BlockDriverState **pbs, *bs;
161b338082bSbellard 
162b338082bSbellard     bs = qemu_mallocz(sizeof(BlockDriverState));
163b338082bSbellard     pstrcpy(bs->device_name, sizeof(bs->device_name), device_name);
164ea2384d3Sbellard     if (device_name[0] != '\0') {
165b338082bSbellard         /* insert at the end */
166b338082bSbellard         pbs = &bdrv_first;
167b338082bSbellard         while (*pbs != NULL)
168b338082bSbellard             pbs = &(*pbs)->next;
169b338082bSbellard         *pbs = bs;
170ea2384d3Sbellard     }
171b338082bSbellard     return bs;
172b338082bSbellard }
173b338082bSbellard 
174ea2384d3Sbellard BlockDriver *bdrv_find_format(const char *format_name)
175ea2384d3Sbellard {
176ea2384d3Sbellard     BlockDriver *drv1;
177ea2384d3Sbellard     for(drv1 = first_drv; drv1 != NULL; drv1 = drv1->next) {
178ea2384d3Sbellard         if (!strcmp(drv1->format_name, format_name))
179ea2384d3Sbellard             return drv1;
180ea2384d3Sbellard     }
181ea2384d3Sbellard     return NULL;
182ea2384d3Sbellard }
183ea2384d3Sbellard 
184ea2384d3Sbellard int bdrv_create(BlockDriver *drv,
185ea2384d3Sbellard                 const char *filename, int64_t size_in_sectors,
186ea2384d3Sbellard                 const char *backing_file, int flags)
187ea2384d3Sbellard {
188ea2384d3Sbellard     if (!drv->bdrv_create)
189ea2384d3Sbellard         return -ENOTSUP;
190ea2384d3Sbellard     return drv->bdrv_create(filename, size_in_sectors, backing_file, flags);
191ea2384d3Sbellard }
192ea2384d3Sbellard 
193d5249393Sbellard #ifdef _WIN32
19495389c86Sbellard void get_tmp_filename(char *filename, int size)
195d5249393Sbellard {
1963b9f94e1Sbellard     char temp_dir[MAX_PATH];
1973b9f94e1Sbellard 
1983b9f94e1Sbellard     GetTempPath(MAX_PATH, temp_dir);
1993b9f94e1Sbellard     GetTempFileName(temp_dir, "qem", 0, filename);
200d5249393Sbellard }
201d5249393Sbellard #else
20295389c86Sbellard void get_tmp_filename(char *filename, int size)
203ea2384d3Sbellard {
204ea2384d3Sbellard     int fd;
2057ccfb2ebSblueswir1     const char *tmpdir;
206d5249393Sbellard     /* XXX: race condition possible */
2070badc1eeSaurel32     tmpdir = getenv("TMPDIR");
2080badc1eeSaurel32     if (!tmpdir)
2090badc1eeSaurel32         tmpdir = "/tmp";
2100badc1eeSaurel32     snprintf(filename, size, "%s/vl.XXXXXX", tmpdir);
211ea2384d3Sbellard     fd = mkstemp(filename);
212ea2384d3Sbellard     close(fd);
213ea2384d3Sbellard }
214d5249393Sbellard #endif
215ea2384d3Sbellard 
21619cb3738Sbellard #ifdef _WIN32
217f45512feSbellard static int is_windows_drive_prefix(const char *filename)
218f45512feSbellard {
219f45512feSbellard     return (((filename[0] >= 'a' && filename[0] <= 'z') ||
220f45512feSbellard              (filename[0] >= 'A' && filename[0] <= 'Z')) &&
221f45512feSbellard             filename[1] == ':');
222f45512feSbellard }
223f45512feSbellard 
22419cb3738Sbellard static int is_windows_drive(const char *filename)
22519cb3738Sbellard {
226f45512feSbellard     if (is_windows_drive_prefix(filename) &&
227f45512feSbellard         filename[2] == '\0')
22819cb3738Sbellard         return 1;
22919cb3738Sbellard     if (strstart(filename, "\\\\.\\", NULL) ||
23019cb3738Sbellard         strstart(filename, "//./", NULL))
23119cb3738Sbellard         return 1;
23219cb3738Sbellard     return 0;
23319cb3738Sbellard }
23419cb3738Sbellard #endif
23519cb3738Sbellard 
23683f64091Sbellard static BlockDriver *find_protocol(const char *filename)
23783f64091Sbellard {
23883f64091Sbellard     BlockDriver *drv1;
23983f64091Sbellard     char protocol[128];
24083f64091Sbellard     int len;
24183f64091Sbellard     const char *p;
24219cb3738Sbellard 
24319cb3738Sbellard #ifdef _WIN32
244f45512feSbellard     if (is_windows_drive(filename) ||
245f45512feSbellard         is_windows_drive_prefix(filename))
24619cb3738Sbellard         return &bdrv_raw;
24719cb3738Sbellard #endif
24883f64091Sbellard     p = strchr(filename, ':');
24983f64091Sbellard     if (!p)
25083f64091Sbellard         return &bdrv_raw;
25183f64091Sbellard     len = p - filename;
25283f64091Sbellard     if (len > sizeof(protocol) - 1)
25383f64091Sbellard         len = sizeof(protocol) - 1;
25483f64091Sbellard     memcpy(protocol, filename, len);
25583f64091Sbellard     protocol[len] = '\0';
25683f64091Sbellard     for(drv1 = first_drv; drv1 != NULL; drv1 = drv1->next) {
25783f64091Sbellard         if (drv1->protocol_name &&
25883f64091Sbellard             !strcmp(drv1->protocol_name, protocol))
25983f64091Sbellard             return drv1;
26083f64091Sbellard     }
26183f64091Sbellard     return NULL;
26283f64091Sbellard }
26383f64091Sbellard 
2647674e7bfSbellard /* XXX: force raw format if block or character device ? It would
2657674e7bfSbellard    simplify the BSD case */
266ea2384d3Sbellard static BlockDriver *find_image_format(const char *filename)
267ea2384d3Sbellard {
26883f64091Sbellard     int ret, score, score_max;
269ea2384d3Sbellard     BlockDriver *drv1, *drv;
27083f64091Sbellard     uint8_t buf[2048];
27183f64091Sbellard     BlockDriverState *bs;
272ea2384d3Sbellard 
27319cb3738Sbellard     /* detect host devices. By convention, /dev/cdrom[N] is always
27419cb3738Sbellard        recognized as a host CDROM */
27519cb3738Sbellard     if (strstart(filename, "/dev/cdrom", NULL))
27619cb3738Sbellard         return &bdrv_host_device;
27719cb3738Sbellard #ifdef _WIN32
27819cb3738Sbellard     if (is_windows_drive(filename))
27919cb3738Sbellard         return &bdrv_host_device;
28019cb3738Sbellard #else
28119cb3738Sbellard     {
28219cb3738Sbellard         struct stat st;
28319cb3738Sbellard         if (stat(filename, &st) >= 0 &&
28419cb3738Sbellard             (S_ISCHR(st.st_mode) || S_ISBLK(st.st_mode))) {
28519cb3738Sbellard             return &bdrv_host_device;
28619cb3738Sbellard         }
28719cb3738Sbellard     }
28819cb3738Sbellard #endif
28919cb3738Sbellard 
29083f64091Sbellard     drv = find_protocol(filename);
29119cb3738Sbellard     /* no need to test disk image formats for vvfat */
29283f64091Sbellard     if (drv == &bdrv_vvfat)
29383f64091Sbellard         return drv;
29483f64091Sbellard 
29583f64091Sbellard     ret = bdrv_file_open(&bs, filename, BDRV_O_RDONLY);
29683f64091Sbellard     if (ret < 0)
2977674e7bfSbellard         return NULL;
29883f64091Sbellard     ret = bdrv_pread(bs, 0, buf, sizeof(buf));
29983f64091Sbellard     bdrv_delete(bs);
300ea2384d3Sbellard     if (ret < 0) {
301ea2384d3Sbellard         return NULL;
302ea2384d3Sbellard     }
303ea2384d3Sbellard 
304ea2384d3Sbellard     score_max = 0;
305ea2384d3Sbellard     for(drv1 = first_drv; drv1 != NULL; drv1 = drv1->next) {
30683f64091Sbellard         if (drv1->bdrv_probe) {
307ea2384d3Sbellard             score = drv1->bdrv_probe(buf, ret, filename);
308ea2384d3Sbellard             if (score > score_max) {
309ea2384d3Sbellard                 score_max = score;
310ea2384d3Sbellard                 drv = drv1;
311ea2384d3Sbellard             }
312ea2384d3Sbellard         }
31383f64091Sbellard     }
314ea2384d3Sbellard     return drv;
315ea2384d3Sbellard }
316ea2384d3Sbellard 
31783f64091Sbellard int bdrv_file_open(BlockDriverState **pbs, const char *filename, int flags)
318b338082bSbellard {
31983f64091Sbellard     BlockDriverState *bs;
32083f64091Sbellard     int ret;
3213b0d4f61Sbellard 
32283f64091Sbellard     bs = bdrv_new("");
32383f64091Sbellard     ret = bdrv_open2(bs, filename, flags | BDRV_O_FILE, NULL);
32483f64091Sbellard     if (ret < 0) {
32583f64091Sbellard         bdrv_delete(bs);
32683f64091Sbellard         return ret;
3273b0d4f61Sbellard     }
32871d0770cSaliguori     bs->growable = 1;
32983f64091Sbellard     *pbs = bs;
33083f64091Sbellard     return 0;
3313b0d4f61Sbellard }
3323b0d4f61Sbellard 
33383f64091Sbellard int bdrv_open(BlockDriverState *bs, const char *filename, int flags)
33483f64091Sbellard {
33583f64091Sbellard     return bdrv_open2(bs, filename, flags, NULL);
336ea2384d3Sbellard }
337ea2384d3Sbellard 
33883f64091Sbellard int bdrv_open2(BlockDriverState *bs, const char *filename, int flags,
339ea2384d3Sbellard                BlockDriver *drv)
340ea2384d3Sbellard {
34183f64091Sbellard     int ret, open_flags;
342eb5c851fSths     char tmp_filename[PATH_MAX];
343eb5c851fSths     char backing_filename[PATH_MAX];
344fc01f7e7Sbellard 
3450849bf08Sbellard     bs->read_only = 0;
346ea2384d3Sbellard     bs->is_temporary = 0;
347ea2384d3Sbellard     bs->encrypted = 0;
348c0f4ce77Saliguori     bs->valid_key = 0;
34933e3963eSbellard 
35083f64091Sbellard     if (flags & BDRV_O_SNAPSHOT) {
351ea2384d3Sbellard         BlockDriverState *bs1;
352ea2384d3Sbellard         int64_t total_size;
3537c96d46eSaliguori         int is_protocol = 0;
35433e3963eSbellard 
355ea2384d3Sbellard         /* if snapshot, we create a temporary backing file and open it
356ea2384d3Sbellard            instead of opening 'filename' directly */
357ea2384d3Sbellard 
358ea2384d3Sbellard         /* if there is a backing file, use it */
359ea2384d3Sbellard         bs1 = bdrv_new("");
36051d7c00cSaliguori         ret = bdrv_open(bs1, filename, 0);
36151d7c00cSaliguori         if (ret < 0) {
362ea2384d3Sbellard             bdrv_delete(bs1);
36351d7c00cSaliguori             return ret;
364ea2384d3Sbellard         }
36583f64091Sbellard         total_size = bdrv_getlength(bs1) >> SECTOR_BITS;
3667c96d46eSaliguori 
3677c96d46eSaliguori         if (bs1->drv && bs1->drv->protocol_name)
3687c96d46eSaliguori             is_protocol = 1;
3697c96d46eSaliguori 
370ea2384d3Sbellard         bdrv_delete(bs1);
371ea2384d3Sbellard 
372ea2384d3Sbellard         get_tmp_filename(tmp_filename, sizeof(tmp_filename));
3737c96d46eSaliguori 
3747c96d46eSaliguori         /* Real path is meaningless for protocols */
3757c96d46eSaliguori         if (is_protocol)
3767c96d46eSaliguori             snprintf(backing_filename, sizeof(backing_filename),
3777c96d46eSaliguori                      "%s", filename);
3787c96d46eSaliguori         else
379a817d936Sbellard             realpath(filename, backing_filename);
3807c96d46eSaliguori 
38151d7c00cSaliguori         ret = bdrv_create(&bdrv_qcow2, tmp_filename,
38251d7c00cSaliguori                           total_size, backing_filename, 0);
38351d7c00cSaliguori         if (ret < 0) {
38451d7c00cSaliguori             return ret;
385ea2384d3Sbellard         }
386ea2384d3Sbellard         filename = tmp_filename;
387ea2384d3Sbellard         bs->is_temporary = 1;
388ea2384d3Sbellard     }
389ea2384d3Sbellard 
390ea2384d3Sbellard     pstrcpy(bs->filename, sizeof(bs->filename), filename);
39183f64091Sbellard     if (flags & BDRV_O_FILE) {
39283f64091Sbellard         drv = find_protocol(filename);
39351d7c00cSaliguori     } else if (!drv) {
394ea2384d3Sbellard         drv = find_image_format(filename);
395ea2384d3Sbellard     }
39651d7c00cSaliguori     if (!drv) {
39751d7c00cSaliguori         ret = -ENOENT;
39851d7c00cSaliguori         goto unlink_and_fail;
39983f64091Sbellard     }
400ea2384d3Sbellard     bs->drv = drv;
401ea2384d3Sbellard     bs->opaque = qemu_mallocz(drv->instance_size);
40283f64091Sbellard     /* Note: for compatibility, we open disk image files as RDWR, and
40383f64091Sbellard        RDONLY as fallback */
40483f64091Sbellard     if (!(flags & BDRV_O_FILE))
4059f7965c7Saliguori         open_flags = BDRV_O_RDWR | (flags & BDRV_O_CACHE_MASK);
40683f64091Sbellard     else
40783f64091Sbellard         open_flags = flags & ~(BDRV_O_FILE | BDRV_O_SNAPSHOT);
40883f64091Sbellard     ret = drv->bdrv_open(bs, filename, open_flags);
409a0a83536Saurel32     if ((ret == -EACCES || ret == -EPERM) && !(flags & BDRV_O_FILE)) {
4109f7965c7Saliguori         ret = drv->bdrv_open(bs, filename, open_flags & ~BDRV_O_RDWR);
41183f64091Sbellard         bs->read_only = 1;
41283f64091Sbellard     }
413ea2384d3Sbellard     if (ret < 0) {
414ea2384d3Sbellard         qemu_free(bs->opaque);
4156b21b973Sbellard         bs->opaque = NULL;
4166b21b973Sbellard         bs->drv = NULL;
41751d7c00cSaliguori     unlink_and_fail:
41851d7c00cSaliguori         if (bs->is_temporary)
41951d7c00cSaliguori             unlink(filename);
42083f64091Sbellard         return ret;
421ea2384d3Sbellard     }
422d15a771dSbellard     if (drv->bdrv_getlength) {
423d15a771dSbellard         bs->total_sectors = bdrv_getlength(bs) >> SECTOR_BITS;
424d15a771dSbellard     }
425ea2384d3Sbellard #ifndef _WIN32
426ea2384d3Sbellard     if (bs->is_temporary) {
427ea2384d3Sbellard         unlink(filename);
42833e3963eSbellard     }
42967b915a5Sbellard #endif
43083f64091Sbellard     if (bs->backing_file[0] != '\0') {
431ea2384d3Sbellard         /* if there is a backing file, use it */
432ea2384d3Sbellard         bs->backing_hd = bdrv_new("");
43383f64091Sbellard         path_combine(backing_filename, sizeof(backing_filename),
43483f64091Sbellard                      filename, bs->backing_file);
43551d7c00cSaliguori         ret = bdrv_open(bs->backing_hd, backing_filename, open_flags);
43651d7c00cSaliguori         if (ret < 0) {
43751d7c00cSaliguori             bdrv_close(bs);
43851d7c00cSaliguori             return ret;
43951d7c00cSaliguori         }
440ea2384d3Sbellard     }
44133e3963eSbellard 
442bb5fc20fSaliguori     if (!bdrv_key_required(bs)) {
443b338082bSbellard         /* call the change callback */
44419cb3738Sbellard         bs->media_changed = 1;
445b338082bSbellard         if (bs->change_cb)
446b338082bSbellard             bs->change_cb(bs->change_opaque);
447bb5fc20fSaliguori     }
448b338082bSbellard     return 0;
449fc01f7e7Sbellard }
450fc01f7e7Sbellard 
451fc01f7e7Sbellard void bdrv_close(BlockDriverState *bs)
452fc01f7e7Sbellard {
45319cb3738Sbellard     if (bs->drv) {
454ea2384d3Sbellard         if (bs->backing_hd)
455ea2384d3Sbellard             bdrv_delete(bs->backing_hd);
456ea2384d3Sbellard         bs->drv->bdrv_close(bs);
457ea2384d3Sbellard         qemu_free(bs->opaque);
458ea2384d3Sbellard #ifdef _WIN32
459ea2384d3Sbellard         if (bs->is_temporary) {
460ea2384d3Sbellard             unlink(bs->filename);
461ea2384d3Sbellard         }
46267b915a5Sbellard #endif
463ea2384d3Sbellard         bs->opaque = NULL;
464ea2384d3Sbellard         bs->drv = NULL;
465b338082bSbellard 
466b338082bSbellard         /* call the change callback */
46719cb3738Sbellard         bs->media_changed = 1;
468b338082bSbellard         if (bs->change_cb)
469b338082bSbellard             bs->change_cb(bs->change_opaque);
470b338082bSbellard     }
471b338082bSbellard }
472b338082bSbellard 
473b338082bSbellard void bdrv_delete(BlockDriverState *bs)
474b338082bSbellard {
47534c6f050Saurel32     BlockDriverState **pbs;
47634c6f050Saurel32 
47734c6f050Saurel32     pbs = &bdrv_first;
47834c6f050Saurel32     while (*pbs != bs && *pbs != NULL)
47934c6f050Saurel32         pbs = &(*pbs)->next;
48034c6f050Saurel32     if (*pbs == bs)
48134c6f050Saurel32         *pbs = bs->next;
48234c6f050Saurel32 
483b338082bSbellard     bdrv_close(bs);
484b338082bSbellard     qemu_free(bs);
485fc01f7e7Sbellard }
486fc01f7e7Sbellard 
48733e3963eSbellard /* commit COW file into the raw image */
48833e3963eSbellard int bdrv_commit(BlockDriverState *bs)
48933e3963eSbellard {
49019cb3738Sbellard     BlockDriver *drv = bs->drv;
49183f64091Sbellard     int64_t i, total_sectors;
492ea2384d3Sbellard     int n, j;
493ea2384d3Sbellard     unsigned char sector[512];
49433e3963eSbellard 
49519cb3738Sbellard     if (!drv)
49619cb3738Sbellard         return -ENOMEDIUM;
49733e3963eSbellard 
49833e3963eSbellard     if (bs->read_only) {
499ea2384d3Sbellard 	return -EACCES;
50033e3963eSbellard     }
50133e3963eSbellard 
502ea2384d3Sbellard     if (!bs->backing_hd) {
503ea2384d3Sbellard 	return -ENOTSUP;
504ea2384d3Sbellard     }
505ea2384d3Sbellard 
50683f64091Sbellard     total_sectors = bdrv_getlength(bs) >> SECTOR_BITS;
50783f64091Sbellard     for (i = 0; i < total_sectors;) {
50819cb3738Sbellard         if (drv->bdrv_is_allocated(bs, i, 65536, &n)) {
509ea2384d3Sbellard             for(j = 0; j < n; j++) {
51033e3963eSbellard                 if (bdrv_read(bs, i, sector, 1) != 0) {
511ea2384d3Sbellard                     return -EIO;
51233e3963eSbellard                 }
51333e3963eSbellard 
514ea2384d3Sbellard                 if (bdrv_write(bs->backing_hd, i, sector, 1) != 0) {
515ea2384d3Sbellard                     return -EIO;
51633e3963eSbellard                 }
517ea2384d3Sbellard                 i++;
518ea2384d3Sbellard 	    }
519ea2384d3Sbellard 	} else {
520ea2384d3Sbellard             i += n;
52133e3963eSbellard         }
52233e3963eSbellard     }
52395389c86Sbellard 
52419cb3738Sbellard     if (drv->bdrv_make_empty)
52519cb3738Sbellard 	return drv->bdrv_make_empty(bs);
52695389c86Sbellard 
52733e3963eSbellard     return 0;
52833e3963eSbellard }
52933e3963eSbellard 
53071d0770cSaliguori static int bdrv_check_byte_request(BlockDriverState *bs, int64_t offset,
53171d0770cSaliguori                                    size_t size)
53271d0770cSaliguori {
53371d0770cSaliguori     int64_t len;
53471d0770cSaliguori 
53571d0770cSaliguori     if (!bdrv_is_inserted(bs))
53671d0770cSaliguori         return -ENOMEDIUM;
53771d0770cSaliguori 
53871d0770cSaliguori     if (bs->growable)
53971d0770cSaliguori         return 0;
54071d0770cSaliguori 
54171d0770cSaliguori     len = bdrv_getlength(bs);
54271d0770cSaliguori 
54371d0770cSaliguori     if ((offset + size) > len)
54471d0770cSaliguori         return -EIO;
54571d0770cSaliguori 
54671d0770cSaliguori     return 0;
54771d0770cSaliguori }
54871d0770cSaliguori 
54971d0770cSaliguori static int bdrv_check_request(BlockDriverState *bs, int64_t sector_num,
55071d0770cSaliguori                               int nb_sectors)
55171d0770cSaliguori {
55271d0770cSaliguori     int64_t offset;
55371d0770cSaliguori 
55471d0770cSaliguori     /* Deal with byte accesses */
55571d0770cSaliguori     if (sector_num < 0)
55671d0770cSaliguori         offset = -sector_num;
55771d0770cSaliguori     else
55871d0770cSaliguori         offset = sector_num * 512;
55971d0770cSaliguori 
56071d0770cSaliguori     return bdrv_check_byte_request(bs, offset, nb_sectors * 512);
56171d0770cSaliguori }
56271d0770cSaliguori 
56319cb3738Sbellard /* return < 0 if error. See bdrv_write() for the return codes */
564fc01f7e7Sbellard int bdrv_read(BlockDriverState *bs, int64_t sector_num,
565fc01f7e7Sbellard               uint8_t *buf, int nb_sectors)
566fc01f7e7Sbellard {
567ea2384d3Sbellard     BlockDriver *drv = bs->drv;
568fc01f7e7Sbellard 
56919cb3738Sbellard     if (!drv)
57019cb3738Sbellard         return -ENOMEDIUM;
57171d0770cSaliguori     if (bdrv_check_request(bs, sector_num, nb_sectors))
57271d0770cSaliguori         return -EIO;
573b338082bSbellard 
57483f64091Sbellard     return drv->bdrv_read(bs, sector_num, buf, nb_sectors);
57583f64091Sbellard }
576fc01f7e7Sbellard 
57719cb3738Sbellard /* Return < 0 if error. Important errors are:
57819cb3738Sbellard   -EIO         generic I/O error (may happen for all errors)
57919cb3738Sbellard   -ENOMEDIUM   No media inserted.
58019cb3738Sbellard   -EINVAL      Invalid sector number or nb_sectors
58119cb3738Sbellard   -EACCES      Trying to write a read-only device
58219cb3738Sbellard */
583fc01f7e7Sbellard int bdrv_write(BlockDriverState *bs, int64_t sector_num,
584fc01f7e7Sbellard                const uint8_t *buf, int nb_sectors)
585fc01f7e7Sbellard {
58683f64091Sbellard     BlockDriver *drv = bs->drv;
58719cb3738Sbellard     if (!bs->drv)
58819cb3738Sbellard         return -ENOMEDIUM;
5890849bf08Sbellard     if (bs->read_only)
59019cb3738Sbellard         return -EACCES;
59171d0770cSaliguori     if (bdrv_check_request(bs, sector_num, nb_sectors))
59271d0770cSaliguori         return -EIO;
59371d0770cSaliguori 
59483f64091Sbellard     return drv->bdrv_write(bs, sector_num, buf, nb_sectors);
59583f64091Sbellard }
59683f64091Sbellard 
597eda578e5Saliguori int bdrv_pread(BlockDriverState *bs, int64_t offset,
598eda578e5Saliguori                void *buf, int count1)
59983f64091Sbellard {
60083f64091Sbellard     uint8_t tmp_buf[SECTOR_SIZE];
60183f64091Sbellard     int len, nb_sectors, count;
60283f64091Sbellard     int64_t sector_num;
60383f64091Sbellard 
60483f64091Sbellard     count = count1;
60583f64091Sbellard     /* first read to align to sector start */
60683f64091Sbellard     len = (SECTOR_SIZE - offset) & (SECTOR_SIZE - 1);
60783f64091Sbellard     if (len > count)
60883f64091Sbellard         len = count;
60983f64091Sbellard     sector_num = offset >> SECTOR_BITS;
61083f64091Sbellard     if (len > 0) {
61183f64091Sbellard         if (bdrv_read(bs, sector_num, tmp_buf, 1) < 0)
61283f64091Sbellard             return -EIO;
61383f64091Sbellard         memcpy(buf, tmp_buf + (offset & (SECTOR_SIZE - 1)), len);
61483f64091Sbellard         count -= len;
61583f64091Sbellard         if (count == 0)
61683f64091Sbellard             return count1;
61783f64091Sbellard         sector_num++;
61883f64091Sbellard         buf += len;
61983f64091Sbellard     }
62083f64091Sbellard 
62183f64091Sbellard     /* read the sectors "in place" */
62283f64091Sbellard     nb_sectors = count >> SECTOR_BITS;
62383f64091Sbellard     if (nb_sectors > 0) {
62483f64091Sbellard         if (bdrv_read(bs, sector_num, buf, nb_sectors) < 0)
62583f64091Sbellard             return -EIO;
62683f64091Sbellard         sector_num += nb_sectors;
62783f64091Sbellard         len = nb_sectors << SECTOR_BITS;
62883f64091Sbellard         buf += len;
62983f64091Sbellard         count -= len;
63083f64091Sbellard     }
63183f64091Sbellard 
63283f64091Sbellard     /* add data from the last sector */
63383f64091Sbellard     if (count > 0) {
63483f64091Sbellard         if (bdrv_read(bs, sector_num, tmp_buf, 1) < 0)
63583f64091Sbellard             return -EIO;
63683f64091Sbellard         memcpy(buf, tmp_buf, count);
63783f64091Sbellard     }
63883f64091Sbellard     return count1;
63983f64091Sbellard }
64083f64091Sbellard 
641eda578e5Saliguori int bdrv_pwrite(BlockDriverState *bs, int64_t offset,
642eda578e5Saliguori                 const void *buf, int count1)
64383f64091Sbellard {
64483f64091Sbellard     uint8_t tmp_buf[SECTOR_SIZE];
64583f64091Sbellard     int len, nb_sectors, count;
64683f64091Sbellard     int64_t sector_num;
64783f64091Sbellard 
64883f64091Sbellard     count = count1;
64983f64091Sbellard     /* first write to align to sector start */
65083f64091Sbellard     len = (SECTOR_SIZE - offset) & (SECTOR_SIZE - 1);
65183f64091Sbellard     if (len > count)
65283f64091Sbellard         len = count;
65383f64091Sbellard     sector_num = offset >> SECTOR_BITS;
65483f64091Sbellard     if (len > 0) {
65583f64091Sbellard         if (bdrv_read(bs, sector_num, tmp_buf, 1) < 0)
65683f64091Sbellard             return -EIO;
65783f64091Sbellard         memcpy(tmp_buf + (offset & (SECTOR_SIZE - 1)), buf, len);
65883f64091Sbellard         if (bdrv_write(bs, sector_num, tmp_buf, 1) < 0)
65983f64091Sbellard             return -EIO;
66083f64091Sbellard         count -= len;
66183f64091Sbellard         if (count == 0)
66283f64091Sbellard             return count1;
66383f64091Sbellard         sector_num++;
66483f64091Sbellard         buf += len;
66583f64091Sbellard     }
66683f64091Sbellard 
66783f64091Sbellard     /* write the sectors "in place" */
66883f64091Sbellard     nb_sectors = count >> SECTOR_BITS;
66983f64091Sbellard     if (nb_sectors > 0) {
67083f64091Sbellard         if (bdrv_write(bs, sector_num, buf, nb_sectors) < 0)
67183f64091Sbellard             return -EIO;
67283f64091Sbellard         sector_num += nb_sectors;
67383f64091Sbellard         len = nb_sectors << SECTOR_BITS;
67483f64091Sbellard         buf += len;
67583f64091Sbellard         count -= len;
67683f64091Sbellard     }
67783f64091Sbellard 
67883f64091Sbellard     /* add data from the last sector */
67983f64091Sbellard     if (count > 0) {
68083f64091Sbellard         if (bdrv_read(bs, sector_num, tmp_buf, 1) < 0)
68183f64091Sbellard             return -EIO;
68283f64091Sbellard         memcpy(tmp_buf, buf, count);
68383f64091Sbellard         if (bdrv_write(bs, sector_num, tmp_buf, 1) < 0)
68483f64091Sbellard             return -EIO;
68583f64091Sbellard     }
68683f64091Sbellard     return count1;
68783f64091Sbellard }
68883f64091Sbellard 
68983f64091Sbellard /**
69083f64091Sbellard  * Truncate file to 'offset' bytes (needed only for file protocols)
69183f64091Sbellard  */
69283f64091Sbellard int bdrv_truncate(BlockDriverState *bs, int64_t offset)
69383f64091Sbellard {
69483f64091Sbellard     BlockDriver *drv = bs->drv;
69583f64091Sbellard     if (!drv)
69619cb3738Sbellard         return -ENOMEDIUM;
69783f64091Sbellard     if (!drv->bdrv_truncate)
69883f64091Sbellard         return -ENOTSUP;
69983f64091Sbellard     return drv->bdrv_truncate(bs, offset);
70083f64091Sbellard }
70183f64091Sbellard 
70283f64091Sbellard /**
70383f64091Sbellard  * Length of a file in bytes. Return < 0 if error or unknown.
70483f64091Sbellard  */
70583f64091Sbellard int64_t bdrv_getlength(BlockDriverState *bs)
70683f64091Sbellard {
70783f64091Sbellard     BlockDriver *drv = bs->drv;
70883f64091Sbellard     if (!drv)
70919cb3738Sbellard         return -ENOMEDIUM;
71083f64091Sbellard     if (!drv->bdrv_getlength) {
71183f64091Sbellard         /* legacy mode */
71283f64091Sbellard         return bs->total_sectors * SECTOR_SIZE;
71383f64091Sbellard     }
71483f64091Sbellard     return drv->bdrv_getlength(bs);
715fc01f7e7Sbellard }
716fc01f7e7Sbellard 
71719cb3738Sbellard /* return 0 as number of sectors if no device present or error */
71896b8f136Sths void bdrv_get_geometry(BlockDriverState *bs, uint64_t *nb_sectors_ptr)
719fc01f7e7Sbellard {
72019cb3738Sbellard     int64_t length;
72119cb3738Sbellard     length = bdrv_getlength(bs);
72219cb3738Sbellard     if (length < 0)
72319cb3738Sbellard         length = 0;
72419cb3738Sbellard     else
72519cb3738Sbellard         length = length >> SECTOR_BITS;
72619cb3738Sbellard     *nb_sectors_ptr = length;
727fc01f7e7Sbellard }
728cf98951bSbellard 
729f3d54fc4Saliguori struct partition {
730f3d54fc4Saliguori         uint8_t boot_ind;           /* 0x80 - active */
731f3d54fc4Saliguori         uint8_t head;               /* starting head */
732f3d54fc4Saliguori         uint8_t sector;             /* starting sector */
733f3d54fc4Saliguori         uint8_t cyl;                /* starting cylinder */
734f3d54fc4Saliguori         uint8_t sys_ind;            /* What partition type */
735f3d54fc4Saliguori         uint8_t end_head;           /* end head */
736f3d54fc4Saliguori         uint8_t end_sector;         /* end sector */
737f3d54fc4Saliguori         uint8_t end_cyl;            /* end cylinder */
738f3d54fc4Saliguori         uint32_t start_sect;        /* starting sector counting from 0 */
739f3d54fc4Saliguori         uint32_t nr_sects;          /* nr of sectors in partition */
740f3d54fc4Saliguori } __attribute__((packed));
741f3d54fc4Saliguori 
742f3d54fc4Saliguori /* try to guess the disk logical geometry from the MSDOS partition table. Return 0 if OK, -1 if could not guess */
743f3d54fc4Saliguori static int guess_disk_lchs(BlockDriverState *bs,
744f3d54fc4Saliguori                            int *pcylinders, int *pheads, int *psectors)
745f3d54fc4Saliguori {
746f3d54fc4Saliguori     uint8_t buf[512];
747f3d54fc4Saliguori     int ret, i, heads, sectors, cylinders;
748f3d54fc4Saliguori     struct partition *p;
749f3d54fc4Saliguori     uint32_t nr_sects;
750a38131b6Sblueswir1     uint64_t nb_sectors;
751f3d54fc4Saliguori 
752f3d54fc4Saliguori     bdrv_get_geometry(bs, &nb_sectors);
753f3d54fc4Saliguori 
754f3d54fc4Saliguori     ret = bdrv_read(bs, 0, buf, 1);
755f3d54fc4Saliguori     if (ret < 0)
756f3d54fc4Saliguori         return -1;
757f3d54fc4Saliguori     /* test msdos magic */
758f3d54fc4Saliguori     if (buf[510] != 0x55 || buf[511] != 0xaa)
759f3d54fc4Saliguori         return -1;
760f3d54fc4Saliguori     for(i = 0; i < 4; i++) {
761f3d54fc4Saliguori         p = ((struct partition *)(buf + 0x1be)) + i;
762f3d54fc4Saliguori         nr_sects = le32_to_cpu(p->nr_sects);
763f3d54fc4Saliguori         if (nr_sects && p->end_head) {
764f3d54fc4Saliguori             /* We make the assumption that the partition terminates on
765f3d54fc4Saliguori                a cylinder boundary */
766f3d54fc4Saliguori             heads = p->end_head + 1;
767f3d54fc4Saliguori             sectors = p->end_sector & 63;
768f3d54fc4Saliguori             if (sectors == 0)
769f3d54fc4Saliguori                 continue;
770f3d54fc4Saliguori             cylinders = nb_sectors / (heads * sectors);
771f3d54fc4Saliguori             if (cylinders < 1 || cylinders > 16383)
772f3d54fc4Saliguori                 continue;
773f3d54fc4Saliguori             *pheads = heads;
774f3d54fc4Saliguori             *psectors = sectors;
775f3d54fc4Saliguori             *pcylinders = cylinders;
776f3d54fc4Saliguori #if 0
777f3d54fc4Saliguori             printf("guessed geometry: LCHS=%d %d %d\n",
778f3d54fc4Saliguori                    cylinders, heads, sectors);
779f3d54fc4Saliguori #endif
780f3d54fc4Saliguori             return 0;
781f3d54fc4Saliguori         }
782f3d54fc4Saliguori     }
783f3d54fc4Saliguori     return -1;
784f3d54fc4Saliguori }
785f3d54fc4Saliguori 
786f3d54fc4Saliguori void bdrv_guess_geometry(BlockDriverState *bs, int *pcyls, int *pheads, int *psecs)
787f3d54fc4Saliguori {
788f3d54fc4Saliguori     int translation, lba_detected = 0;
789f3d54fc4Saliguori     int cylinders, heads, secs;
790a38131b6Sblueswir1     uint64_t nb_sectors;
791f3d54fc4Saliguori 
792f3d54fc4Saliguori     /* if a geometry hint is available, use it */
793f3d54fc4Saliguori     bdrv_get_geometry(bs, &nb_sectors);
794f3d54fc4Saliguori     bdrv_get_geometry_hint(bs, &cylinders, &heads, &secs);
795f3d54fc4Saliguori     translation = bdrv_get_translation_hint(bs);
796f3d54fc4Saliguori     if (cylinders != 0) {
797f3d54fc4Saliguori         *pcyls = cylinders;
798f3d54fc4Saliguori         *pheads = heads;
799f3d54fc4Saliguori         *psecs = secs;
800f3d54fc4Saliguori     } else {
801f3d54fc4Saliguori         if (guess_disk_lchs(bs, &cylinders, &heads, &secs) == 0) {
802f3d54fc4Saliguori             if (heads > 16) {
803f3d54fc4Saliguori                 /* if heads > 16, it means that a BIOS LBA
804f3d54fc4Saliguori                    translation was active, so the default
805f3d54fc4Saliguori                    hardware geometry is OK */
806f3d54fc4Saliguori                 lba_detected = 1;
807f3d54fc4Saliguori                 goto default_geometry;
808f3d54fc4Saliguori             } else {
809f3d54fc4Saliguori                 *pcyls = cylinders;
810f3d54fc4Saliguori                 *pheads = heads;
811f3d54fc4Saliguori                 *psecs = secs;
812f3d54fc4Saliguori                 /* disable any translation to be in sync with
813f3d54fc4Saliguori                    the logical geometry */
814f3d54fc4Saliguori                 if (translation == BIOS_ATA_TRANSLATION_AUTO) {
815f3d54fc4Saliguori                     bdrv_set_translation_hint(bs,
816f3d54fc4Saliguori                                               BIOS_ATA_TRANSLATION_NONE);
817f3d54fc4Saliguori                 }
818f3d54fc4Saliguori             }
819f3d54fc4Saliguori         } else {
820f3d54fc4Saliguori         default_geometry:
821f3d54fc4Saliguori             /* if no geometry, use a standard physical disk geometry */
822f3d54fc4Saliguori             cylinders = nb_sectors / (16 * 63);
823f3d54fc4Saliguori 
824f3d54fc4Saliguori             if (cylinders > 16383)
825f3d54fc4Saliguori                 cylinders = 16383;
826f3d54fc4Saliguori             else if (cylinders < 2)
827f3d54fc4Saliguori                 cylinders = 2;
828f3d54fc4Saliguori             *pcyls = cylinders;
829f3d54fc4Saliguori             *pheads = 16;
830f3d54fc4Saliguori             *psecs = 63;
831f3d54fc4Saliguori             if ((lba_detected == 1) && (translation == BIOS_ATA_TRANSLATION_AUTO)) {
832f3d54fc4Saliguori                 if ((*pcyls * *pheads) <= 131072) {
833f3d54fc4Saliguori                     bdrv_set_translation_hint(bs,
834f3d54fc4Saliguori                                               BIOS_ATA_TRANSLATION_LARGE);
835f3d54fc4Saliguori                 } else {
836f3d54fc4Saliguori                     bdrv_set_translation_hint(bs,
837f3d54fc4Saliguori                                               BIOS_ATA_TRANSLATION_LBA);
838f3d54fc4Saliguori                 }
839f3d54fc4Saliguori             }
840f3d54fc4Saliguori         }
841f3d54fc4Saliguori         bdrv_set_geometry_hint(bs, *pcyls, *pheads, *psecs);
842f3d54fc4Saliguori     }
843f3d54fc4Saliguori }
844f3d54fc4Saliguori 
845b338082bSbellard void bdrv_set_geometry_hint(BlockDriverState *bs,
846b338082bSbellard                             int cyls, int heads, int secs)
847b338082bSbellard {
848b338082bSbellard     bs->cyls = cyls;
849b338082bSbellard     bs->heads = heads;
850b338082bSbellard     bs->secs = secs;
851b338082bSbellard }
852b338082bSbellard 
853b338082bSbellard void bdrv_set_type_hint(BlockDriverState *bs, int type)
854b338082bSbellard {
855b338082bSbellard     bs->type = type;
856b338082bSbellard     bs->removable = ((type == BDRV_TYPE_CDROM ||
857b338082bSbellard                       type == BDRV_TYPE_FLOPPY));
858b338082bSbellard }
859b338082bSbellard 
86046d4767dSbellard void bdrv_set_translation_hint(BlockDriverState *bs, int translation)
86146d4767dSbellard {
86246d4767dSbellard     bs->translation = translation;
86346d4767dSbellard }
86446d4767dSbellard 
865b338082bSbellard void bdrv_get_geometry_hint(BlockDriverState *bs,
866b338082bSbellard                             int *pcyls, int *pheads, int *psecs)
867b338082bSbellard {
868b338082bSbellard     *pcyls = bs->cyls;
869b338082bSbellard     *pheads = bs->heads;
870b338082bSbellard     *psecs = bs->secs;
871b338082bSbellard }
872b338082bSbellard 
873b338082bSbellard int bdrv_get_type_hint(BlockDriverState *bs)
874b338082bSbellard {
875b338082bSbellard     return bs->type;
876b338082bSbellard }
877b338082bSbellard 
87846d4767dSbellard int bdrv_get_translation_hint(BlockDriverState *bs)
87946d4767dSbellard {
88046d4767dSbellard     return bs->translation;
88146d4767dSbellard }
88246d4767dSbellard 
883b338082bSbellard int bdrv_is_removable(BlockDriverState *bs)
884b338082bSbellard {
885b338082bSbellard     return bs->removable;
886b338082bSbellard }
887b338082bSbellard 
888b338082bSbellard int bdrv_is_read_only(BlockDriverState *bs)
889b338082bSbellard {
890b338082bSbellard     return bs->read_only;
891b338082bSbellard }
892b338082bSbellard 
893985a03b0Sths int bdrv_is_sg(BlockDriverState *bs)
894985a03b0Sths {
895985a03b0Sths     return bs->sg;
896985a03b0Sths }
897985a03b0Sths 
89819cb3738Sbellard /* XXX: no longer used */
899b338082bSbellard void bdrv_set_change_cb(BlockDriverState *bs,
900b338082bSbellard                         void (*change_cb)(void *opaque), void *opaque)
901b338082bSbellard {
902b338082bSbellard     bs->change_cb = change_cb;
903b338082bSbellard     bs->change_opaque = opaque;
904b338082bSbellard }
905b338082bSbellard 
906ea2384d3Sbellard int bdrv_is_encrypted(BlockDriverState *bs)
907ea2384d3Sbellard {
908ea2384d3Sbellard     if (bs->backing_hd && bs->backing_hd->encrypted)
909ea2384d3Sbellard         return 1;
910ea2384d3Sbellard     return bs->encrypted;
911ea2384d3Sbellard }
912ea2384d3Sbellard 
913c0f4ce77Saliguori int bdrv_key_required(BlockDriverState *bs)
914c0f4ce77Saliguori {
915c0f4ce77Saliguori     BlockDriverState *backing_hd = bs->backing_hd;
916c0f4ce77Saliguori 
917c0f4ce77Saliguori     if (backing_hd && backing_hd->encrypted && !backing_hd->valid_key)
918c0f4ce77Saliguori         return 1;
919c0f4ce77Saliguori     return (bs->encrypted && !bs->valid_key);
920c0f4ce77Saliguori }
921c0f4ce77Saliguori 
922ea2384d3Sbellard int bdrv_set_key(BlockDriverState *bs, const char *key)
923ea2384d3Sbellard {
924ea2384d3Sbellard     int ret;
925ea2384d3Sbellard     if (bs->backing_hd && bs->backing_hd->encrypted) {
926ea2384d3Sbellard         ret = bdrv_set_key(bs->backing_hd, key);
927ea2384d3Sbellard         if (ret < 0)
928ea2384d3Sbellard             return ret;
929ea2384d3Sbellard         if (!bs->encrypted)
930ea2384d3Sbellard             return 0;
931ea2384d3Sbellard     }
932ea2384d3Sbellard     if (!bs->encrypted || !bs->drv || !bs->drv->bdrv_set_key)
933ea2384d3Sbellard         return -1;
934c0f4ce77Saliguori     ret = bs->drv->bdrv_set_key(bs, key);
935bb5fc20fSaliguori     if (ret < 0) {
936bb5fc20fSaliguori         bs->valid_key = 0;
937bb5fc20fSaliguori     } else if (!bs->valid_key) {
938bb5fc20fSaliguori         bs->valid_key = 1;
939bb5fc20fSaliguori         /* call the change callback now, we skipped it on open */
940bb5fc20fSaliguori         bs->media_changed = 1;
941bb5fc20fSaliguori         if (bs->change_cb)
942bb5fc20fSaliguori             bs->change_cb(bs->change_opaque);
943bb5fc20fSaliguori     }
944c0f4ce77Saliguori     return ret;
945ea2384d3Sbellard }
946ea2384d3Sbellard 
947ea2384d3Sbellard void bdrv_get_format(BlockDriverState *bs, char *buf, int buf_size)
948ea2384d3Sbellard {
94919cb3738Sbellard     if (!bs->drv) {
950ea2384d3Sbellard         buf[0] = '\0';
951ea2384d3Sbellard     } else {
952ea2384d3Sbellard         pstrcpy(buf, buf_size, bs->drv->format_name);
953ea2384d3Sbellard     }
954ea2384d3Sbellard }
955ea2384d3Sbellard 
956ea2384d3Sbellard void bdrv_iterate_format(void (*it)(void *opaque, const char *name),
957ea2384d3Sbellard                          void *opaque)
958ea2384d3Sbellard {
959ea2384d3Sbellard     BlockDriver *drv;
960ea2384d3Sbellard 
961ea2384d3Sbellard     for (drv = first_drv; drv != NULL; drv = drv->next) {
962ea2384d3Sbellard         it(opaque, drv->format_name);
963ea2384d3Sbellard     }
964ea2384d3Sbellard }
965ea2384d3Sbellard 
966b338082bSbellard BlockDriverState *bdrv_find(const char *name)
967b338082bSbellard {
968b338082bSbellard     BlockDriverState *bs;
969b338082bSbellard 
970b338082bSbellard     for (bs = bdrv_first; bs != NULL; bs = bs->next) {
971b338082bSbellard         if (!strcmp(name, bs->device_name))
972b338082bSbellard             return bs;
973b338082bSbellard     }
974b338082bSbellard     return NULL;
975b338082bSbellard }
976b338082bSbellard 
97751de9760Saliguori void bdrv_iterate(void (*it)(void *opaque, BlockDriverState *bs), void *opaque)
97881d0912dSbellard {
97981d0912dSbellard     BlockDriverState *bs;
98081d0912dSbellard 
98181d0912dSbellard     for (bs = bdrv_first; bs != NULL; bs = bs->next) {
98251de9760Saliguori         it(opaque, bs);
98381d0912dSbellard     }
98481d0912dSbellard }
98581d0912dSbellard 
986ea2384d3Sbellard const char *bdrv_get_device_name(BlockDriverState *bs)
987ea2384d3Sbellard {
988ea2384d3Sbellard     return bs->device_name;
989ea2384d3Sbellard }
990ea2384d3Sbellard 
9917a6cba61Spbrook void bdrv_flush(BlockDriverState *bs)
9927a6cba61Spbrook {
9937a6cba61Spbrook     if (bs->drv->bdrv_flush)
9947a6cba61Spbrook         bs->drv->bdrv_flush(bs);
9957a6cba61Spbrook     if (bs->backing_hd)
9967a6cba61Spbrook         bdrv_flush(bs->backing_hd);
9977a6cba61Spbrook }
9987a6cba61Spbrook 
999c6ca28d6Saliguori void bdrv_flush_all(void)
1000c6ca28d6Saliguori {
1001c6ca28d6Saliguori     BlockDriverState *bs;
1002c6ca28d6Saliguori 
1003c6ca28d6Saliguori     for (bs = bdrv_first; bs != NULL; bs = bs->next)
1004c6ca28d6Saliguori         if (bs->drv && !bdrv_is_read_only(bs) &&
1005c6ca28d6Saliguori             (!bdrv_is_removable(bs) || bdrv_is_inserted(bs)))
1006c6ca28d6Saliguori             bdrv_flush(bs);
1007c6ca28d6Saliguori }
1008c6ca28d6Saliguori 
1009f58c7b35Sths /*
1010f58c7b35Sths  * Returns true iff the specified sector is present in the disk image. Drivers
1011f58c7b35Sths  * not implementing the functionality are assumed to not support backing files,
1012f58c7b35Sths  * hence all their sectors are reported as allocated.
1013f58c7b35Sths  *
1014f58c7b35Sths  * 'pnum' is set to the number of sectors (including and immediately following
1015f58c7b35Sths  * the specified sector) that are known to be in the same
1016f58c7b35Sths  * allocated/unallocated state.
1017f58c7b35Sths  *
1018f58c7b35Sths  * 'nb_sectors' is the max value 'pnum' should be set to.
1019f58c7b35Sths  */
1020f58c7b35Sths int bdrv_is_allocated(BlockDriverState *bs, int64_t sector_num, int nb_sectors,
1021f58c7b35Sths 	int *pnum)
1022f58c7b35Sths {
1023f58c7b35Sths     int64_t n;
1024f58c7b35Sths     if (!bs->drv->bdrv_is_allocated) {
1025f58c7b35Sths         if (sector_num >= bs->total_sectors) {
1026f58c7b35Sths             *pnum = 0;
1027f58c7b35Sths             return 0;
1028f58c7b35Sths         }
1029f58c7b35Sths         n = bs->total_sectors - sector_num;
1030f58c7b35Sths         *pnum = (n < nb_sectors) ? (n) : (nb_sectors);
1031f58c7b35Sths         return 1;
1032f58c7b35Sths     }
1033f58c7b35Sths     return bs->drv->bdrv_is_allocated(bs, sector_num, nb_sectors, pnum);
1034f58c7b35Sths }
1035f58c7b35Sths 
1036376253ecSaliguori void bdrv_info(Monitor *mon)
1037b338082bSbellard {
1038b338082bSbellard     BlockDriverState *bs;
1039b338082bSbellard 
1040b338082bSbellard     for (bs = bdrv_first; bs != NULL; bs = bs->next) {
1041376253ecSaliguori         monitor_printf(mon, "%s:", bs->device_name);
1042376253ecSaliguori         monitor_printf(mon, " type=");
1043b338082bSbellard         switch(bs->type) {
1044b338082bSbellard         case BDRV_TYPE_HD:
1045376253ecSaliguori             monitor_printf(mon, "hd");
1046b338082bSbellard             break;
1047b338082bSbellard         case BDRV_TYPE_CDROM:
1048376253ecSaliguori             monitor_printf(mon, "cdrom");
1049b338082bSbellard             break;
1050b338082bSbellard         case BDRV_TYPE_FLOPPY:
1051376253ecSaliguori             monitor_printf(mon, "floppy");
1052b338082bSbellard             break;
1053b338082bSbellard         }
1054376253ecSaliguori         monitor_printf(mon, " removable=%d", bs->removable);
1055b338082bSbellard         if (bs->removable) {
1056376253ecSaliguori             monitor_printf(mon, " locked=%d", bs->locked);
1057b338082bSbellard         }
105819cb3738Sbellard         if (bs->drv) {
1059376253ecSaliguori             monitor_printf(mon, " file=");
1060376253ecSaliguori             monitor_print_filename(mon, bs->filename);
1061fef30743Sths             if (bs->backing_file[0] != '\0') {
1062376253ecSaliguori                 monitor_printf(mon, " backing_file=");
1063376253ecSaliguori                 monitor_print_filename(mon, bs->backing_file);
1064fef30743Sths             }
1065376253ecSaliguori             monitor_printf(mon, " ro=%d", bs->read_only);
1066376253ecSaliguori             monitor_printf(mon, " drv=%s", bs->drv->format_name);
1067376253ecSaliguori             monitor_printf(mon, " encrypted=%d", bdrv_is_encrypted(bs));
1068b338082bSbellard         } else {
1069376253ecSaliguori             monitor_printf(mon, " [not inserted]");
1070b338082bSbellard         }
1071376253ecSaliguori         monitor_printf(mon, "\n");
1072b338082bSbellard     }
1073b338082bSbellard }
1074a36e69ddSths 
1075a36e69ddSths /* The "info blockstats" command. */
1076376253ecSaliguori void bdrv_info_stats(Monitor *mon)
1077a36e69ddSths {
1078a36e69ddSths     BlockDriverState *bs;
1079a36e69ddSths 
1080a36e69ddSths     for (bs = bdrv_first; bs != NULL; bs = bs->next) {
1081376253ecSaliguori         monitor_printf(mon, "%s:"
1082a36e69ddSths                        " rd_bytes=%" PRIu64
1083a36e69ddSths                        " wr_bytes=%" PRIu64
1084a36e69ddSths                        " rd_operations=%" PRIu64
1085a36e69ddSths                        " wr_operations=%" PRIu64
1086ebf53fcdSaliguori                        "\n",
1087a36e69ddSths                        bs->device_name,
1088a36e69ddSths                        bs->rd_bytes, bs->wr_bytes,
1089a36e69ddSths                        bs->rd_ops, bs->wr_ops);
1090a36e69ddSths     }
1091a36e69ddSths }
1092ea2384d3Sbellard 
1093045df330Saliguori const char *bdrv_get_encrypted_filename(BlockDriverState *bs)
1094045df330Saliguori {
1095045df330Saliguori     if (bs->backing_hd && bs->backing_hd->encrypted)
1096045df330Saliguori         return bs->backing_file;
1097045df330Saliguori     else if (bs->encrypted)
1098045df330Saliguori         return bs->filename;
1099045df330Saliguori     else
1100045df330Saliguori         return NULL;
1101045df330Saliguori }
1102045df330Saliguori 
110383f64091Sbellard void bdrv_get_backing_filename(BlockDriverState *bs,
110483f64091Sbellard                                char *filename, int filename_size)
110583f64091Sbellard {
110683f64091Sbellard     if (!bs->backing_hd) {
110783f64091Sbellard         pstrcpy(filename, filename_size, "");
110883f64091Sbellard     } else {
110983f64091Sbellard         pstrcpy(filename, filename_size, bs->backing_file);
111083f64091Sbellard     }
111183f64091Sbellard }
111283f64091Sbellard 
1113faea38e7Sbellard int bdrv_write_compressed(BlockDriverState *bs, int64_t sector_num,
1114faea38e7Sbellard                           const uint8_t *buf, int nb_sectors)
1115faea38e7Sbellard {
1116faea38e7Sbellard     BlockDriver *drv = bs->drv;
1117faea38e7Sbellard     if (!drv)
111819cb3738Sbellard         return -ENOMEDIUM;
1119faea38e7Sbellard     if (!drv->bdrv_write_compressed)
1120faea38e7Sbellard         return -ENOTSUP;
1121faea38e7Sbellard     return drv->bdrv_write_compressed(bs, sector_num, buf, nb_sectors);
1122faea38e7Sbellard }
1123faea38e7Sbellard 
1124faea38e7Sbellard int bdrv_get_info(BlockDriverState *bs, BlockDriverInfo *bdi)
1125faea38e7Sbellard {
1126faea38e7Sbellard     BlockDriver *drv = bs->drv;
1127faea38e7Sbellard     if (!drv)
112819cb3738Sbellard         return -ENOMEDIUM;
1129faea38e7Sbellard     if (!drv->bdrv_get_info)
1130faea38e7Sbellard         return -ENOTSUP;
1131faea38e7Sbellard     memset(bdi, 0, sizeof(*bdi));
1132faea38e7Sbellard     return drv->bdrv_get_info(bs, bdi);
1133faea38e7Sbellard }
1134faea38e7Sbellard 
1135faea38e7Sbellard /**************************************************************/
1136faea38e7Sbellard /* handling of snapshots */
1137faea38e7Sbellard 
1138faea38e7Sbellard int bdrv_snapshot_create(BlockDriverState *bs,
1139faea38e7Sbellard                          QEMUSnapshotInfo *sn_info)
1140faea38e7Sbellard {
1141faea38e7Sbellard     BlockDriver *drv = bs->drv;
1142faea38e7Sbellard     if (!drv)
114319cb3738Sbellard         return -ENOMEDIUM;
1144faea38e7Sbellard     if (!drv->bdrv_snapshot_create)
1145faea38e7Sbellard         return -ENOTSUP;
1146faea38e7Sbellard     return drv->bdrv_snapshot_create(bs, sn_info);
1147faea38e7Sbellard }
1148faea38e7Sbellard 
1149faea38e7Sbellard int bdrv_snapshot_goto(BlockDriverState *bs,
1150faea38e7Sbellard                        const char *snapshot_id)
1151faea38e7Sbellard {
1152faea38e7Sbellard     BlockDriver *drv = bs->drv;
1153faea38e7Sbellard     if (!drv)
115419cb3738Sbellard         return -ENOMEDIUM;
1155faea38e7Sbellard     if (!drv->bdrv_snapshot_goto)
1156faea38e7Sbellard         return -ENOTSUP;
1157faea38e7Sbellard     return drv->bdrv_snapshot_goto(bs, snapshot_id);
1158faea38e7Sbellard }
1159faea38e7Sbellard 
1160faea38e7Sbellard int bdrv_snapshot_delete(BlockDriverState *bs, const char *snapshot_id)
1161faea38e7Sbellard {
1162faea38e7Sbellard     BlockDriver *drv = bs->drv;
1163faea38e7Sbellard     if (!drv)
116419cb3738Sbellard         return -ENOMEDIUM;
1165faea38e7Sbellard     if (!drv->bdrv_snapshot_delete)
1166faea38e7Sbellard         return -ENOTSUP;
1167faea38e7Sbellard     return drv->bdrv_snapshot_delete(bs, snapshot_id);
1168faea38e7Sbellard }
1169faea38e7Sbellard 
1170faea38e7Sbellard int bdrv_snapshot_list(BlockDriverState *bs,
1171faea38e7Sbellard                        QEMUSnapshotInfo **psn_info)
1172faea38e7Sbellard {
1173faea38e7Sbellard     BlockDriver *drv = bs->drv;
1174faea38e7Sbellard     if (!drv)
117519cb3738Sbellard         return -ENOMEDIUM;
1176faea38e7Sbellard     if (!drv->bdrv_snapshot_list)
1177faea38e7Sbellard         return -ENOTSUP;
1178faea38e7Sbellard     return drv->bdrv_snapshot_list(bs, psn_info);
1179faea38e7Sbellard }
1180faea38e7Sbellard 
1181faea38e7Sbellard #define NB_SUFFIXES 4
1182faea38e7Sbellard 
1183faea38e7Sbellard char *get_human_readable_size(char *buf, int buf_size, int64_t size)
1184faea38e7Sbellard {
1185faea38e7Sbellard     static const char suffixes[NB_SUFFIXES] = "KMGT";
1186faea38e7Sbellard     int64_t base;
1187faea38e7Sbellard     int i;
1188faea38e7Sbellard 
1189faea38e7Sbellard     if (size <= 999) {
1190faea38e7Sbellard         snprintf(buf, buf_size, "%" PRId64, size);
1191faea38e7Sbellard     } else {
1192faea38e7Sbellard         base = 1024;
1193faea38e7Sbellard         for(i = 0; i < NB_SUFFIXES; i++) {
1194faea38e7Sbellard             if (size < (10 * base)) {
1195faea38e7Sbellard                 snprintf(buf, buf_size, "%0.1f%c",
1196faea38e7Sbellard                          (double)size / base,
1197faea38e7Sbellard                          suffixes[i]);
1198faea38e7Sbellard                 break;
1199faea38e7Sbellard             } else if (size < (1000 * base) || i == (NB_SUFFIXES - 1)) {
1200faea38e7Sbellard                 snprintf(buf, buf_size, "%" PRId64 "%c",
1201faea38e7Sbellard                          ((size + (base >> 1)) / base),
1202faea38e7Sbellard                          suffixes[i]);
1203faea38e7Sbellard                 break;
1204faea38e7Sbellard             }
1205faea38e7Sbellard             base = base * 1024;
1206faea38e7Sbellard         }
1207faea38e7Sbellard     }
1208faea38e7Sbellard     return buf;
1209faea38e7Sbellard }
1210faea38e7Sbellard 
1211faea38e7Sbellard char *bdrv_snapshot_dump(char *buf, int buf_size, QEMUSnapshotInfo *sn)
1212faea38e7Sbellard {
1213faea38e7Sbellard     char buf1[128], date_buf[128], clock_buf[128];
12143b9f94e1Sbellard #ifdef _WIN32
12153b9f94e1Sbellard     struct tm *ptm;
12163b9f94e1Sbellard #else
1217faea38e7Sbellard     struct tm tm;
12183b9f94e1Sbellard #endif
1219faea38e7Sbellard     time_t ti;
1220faea38e7Sbellard     int64_t secs;
1221faea38e7Sbellard 
1222faea38e7Sbellard     if (!sn) {
1223faea38e7Sbellard         snprintf(buf, buf_size,
1224faea38e7Sbellard                  "%-10s%-20s%7s%20s%15s",
1225faea38e7Sbellard                  "ID", "TAG", "VM SIZE", "DATE", "VM CLOCK");
1226faea38e7Sbellard     } else {
1227faea38e7Sbellard         ti = sn->date_sec;
12283b9f94e1Sbellard #ifdef _WIN32
12293b9f94e1Sbellard         ptm = localtime(&ti);
12303b9f94e1Sbellard         strftime(date_buf, sizeof(date_buf),
12313b9f94e1Sbellard                  "%Y-%m-%d %H:%M:%S", ptm);
12323b9f94e1Sbellard #else
1233faea38e7Sbellard         localtime_r(&ti, &tm);
1234faea38e7Sbellard         strftime(date_buf, sizeof(date_buf),
1235faea38e7Sbellard                  "%Y-%m-%d %H:%M:%S", &tm);
12363b9f94e1Sbellard #endif
1237faea38e7Sbellard         secs = sn->vm_clock_nsec / 1000000000;
1238faea38e7Sbellard         snprintf(clock_buf, sizeof(clock_buf),
1239faea38e7Sbellard                  "%02d:%02d:%02d.%03d",
1240faea38e7Sbellard                  (int)(secs / 3600),
1241faea38e7Sbellard                  (int)((secs / 60) % 60),
1242faea38e7Sbellard                  (int)(secs % 60),
1243faea38e7Sbellard                  (int)((sn->vm_clock_nsec / 1000000) % 1000));
1244faea38e7Sbellard         snprintf(buf, buf_size,
1245faea38e7Sbellard                  "%-10s%-20s%7s%20s%15s",
1246faea38e7Sbellard                  sn->id_str, sn->name,
1247faea38e7Sbellard                  get_human_readable_size(buf1, sizeof(buf1), sn->vm_state_size),
1248faea38e7Sbellard                  date_buf,
1249faea38e7Sbellard                  clock_buf);
1250faea38e7Sbellard     }
1251faea38e7Sbellard     return buf;
1252faea38e7Sbellard }
1253faea38e7Sbellard 
125483f64091Sbellard 
1255ea2384d3Sbellard /**************************************************************/
125683f64091Sbellard /* async I/Os */
1257ea2384d3Sbellard 
12583b69e4b9Saliguori typedef struct VectorTranslationState {
12593b69e4b9Saliguori     QEMUIOVector *iov;
12603b69e4b9Saliguori     uint8_t *bounce;
12613b69e4b9Saliguori     int is_write;
12623b69e4b9Saliguori     BlockDriverAIOCB *aiocb;
12633b69e4b9Saliguori     BlockDriverAIOCB *this_aiocb;
12643b69e4b9Saliguori } VectorTranslationState;
12653b69e4b9Saliguori 
1266*c07a9008Saliguori static void bdrv_aio_cancel_vector(BlockDriverAIOCB *acb)
1267*c07a9008Saliguori {
1268*c07a9008Saliguori     VectorTranslationState *s = acb->opaque;
1269*c07a9008Saliguori 
1270*c07a9008Saliguori     bdrv_aio_cancel(s->aiocb);
1271*c07a9008Saliguori }
1272*c07a9008Saliguori 
12733b69e4b9Saliguori static void bdrv_aio_rw_vector_cb(void *opaque, int ret)
12743b69e4b9Saliguori {
12753b69e4b9Saliguori     VectorTranslationState *s = opaque;
12763b69e4b9Saliguori 
12773b69e4b9Saliguori     if (!s->is_write) {
1278249aa745Saliguori         qemu_iovec_from_buffer(s->iov, s->bounce, s->iov->size);
12793b69e4b9Saliguori     }
1280d905dba4Saurel32     qemu_vfree(s->bounce);
12813b69e4b9Saliguori     s->this_aiocb->cb(s->this_aiocb->opaque, ret);
12823b69e4b9Saliguori     qemu_aio_release(s->this_aiocb);
12833b69e4b9Saliguori }
12843b69e4b9Saliguori 
12853b69e4b9Saliguori static BlockDriverAIOCB *bdrv_aio_rw_vector(BlockDriverState *bs,
12863b69e4b9Saliguori                                             int64_t sector_num,
12873b69e4b9Saliguori                                             QEMUIOVector *iov,
12883b69e4b9Saliguori                                             int nb_sectors,
12893b69e4b9Saliguori                                             BlockDriverCompletionFunc *cb,
12903b69e4b9Saliguori                                             void *opaque,
12913b69e4b9Saliguori                                             int is_write)
12923b69e4b9Saliguori 
12933b69e4b9Saliguori {
12943b69e4b9Saliguori     VectorTranslationState *s = qemu_mallocz(sizeof(*s));
1295*c07a9008Saliguori     BlockDriverAIOCB *aiocb = qemu_aio_get_pool(&vectored_aio_pool, bs,
1296*c07a9008Saliguori                                                 cb, opaque);
12973b69e4b9Saliguori 
12983b69e4b9Saliguori     s->this_aiocb = aiocb;
12993b69e4b9Saliguori     s->iov = iov;
13003b69e4b9Saliguori     s->bounce = qemu_memalign(512, nb_sectors * 512);
13013b69e4b9Saliguori     s->is_write = is_write;
13023b69e4b9Saliguori     if (is_write) {
13033b69e4b9Saliguori         qemu_iovec_to_buffer(s->iov, s->bounce);
13043b69e4b9Saliguori         s->aiocb = bdrv_aio_write(bs, sector_num, s->bounce, nb_sectors,
13053b69e4b9Saliguori                                   bdrv_aio_rw_vector_cb, s);
13063b69e4b9Saliguori     } else {
13073b69e4b9Saliguori         s->aiocb = bdrv_aio_read(bs, sector_num, s->bounce, nb_sectors,
13083b69e4b9Saliguori                                  bdrv_aio_rw_vector_cb, s);
13093b69e4b9Saliguori     }
13103b69e4b9Saliguori     return aiocb;
13113b69e4b9Saliguori }
13123b69e4b9Saliguori 
13133b69e4b9Saliguori BlockDriverAIOCB *bdrv_aio_readv(BlockDriverState *bs, int64_t sector_num,
13143b69e4b9Saliguori                                  QEMUIOVector *iov, int nb_sectors,
13153b69e4b9Saliguori                                  BlockDriverCompletionFunc *cb, void *opaque)
13163b69e4b9Saliguori {
131771d0770cSaliguori     if (bdrv_check_request(bs, sector_num, nb_sectors))
131871d0770cSaliguori         return NULL;
131971d0770cSaliguori 
13203b69e4b9Saliguori     return bdrv_aio_rw_vector(bs, sector_num, iov, nb_sectors,
13213b69e4b9Saliguori                               cb, opaque, 0);
13223b69e4b9Saliguori }
13233b69e4b9Saliguori 
13243b69e4b9Saliguori BlockDriverAIOCB *bdrv_aio_writev(BlockDriverState *bs, int64_t sector_num,
13253b69e4b9Saliguori                                   QEMUIOVector *iov, int nb_sectors,
13263b69e4b9Saliguori                                   BlockDriverCompletionFunc *cb, void *opaque)
13273b69e4b9Saliguori {
132871d0770cSaliguori     if (bdrv_check_request(bs, sector_num, nb_sectors))
132971d0770cSaliguori         return NULL;
133071d0770cSaliguori 
13313b69e4b9Saliguori     return bdrv_aio_rw_vector(bs, sector_num, iov, nb_sectors,
13323b69e4b9Saliguori                               cb, opaque, 1);
13333b69e4b9Saliguori }
13343b69e4b9Saliguori 
1335ce1a14dcSpbrook BlockDriverAIOCB *bdrv_aio_read(BlockDriverState *bs, int64_t sector_num,
133683f64091Sbellard                                 uint8_t *buf, int nb_sectors,
133783f64091Sbellard                                 BlockDriverCompletionFunc *cb, void *opaque)
1338ea2384d3Sbellard {
133983f64091Sbellard     BlockDriver *drv = bs->drv;
1340a36e69ddSths     BlockDriverAIOCB *ret;
1341ea2384d3Sbellard 
134219cb3738Sbellard     if (!drv)
1343ce1a14dcSpbrook         return NULL;
134471d0770cSaliguori     if (bdrv_check_request(bs, sector_num, nb_sectors))
134571d0770cSaliguori         return NULL;
134683f64091Sbellard 
1347a36e69ddSths     ret = drv->bdrv_aio_read(bs, sector_num, buf, nb_sectors, cb, opaque);
1348a36e69ddSths 
1349a36e69ddSths     if (ret) {
1350a36e69ddSths 	/* Update stats even though technically transfer has not happened. */
1351a36e69ddSths 	bs->rd_bytes += (unsigned) nb_sectors * SECTOR_SIZE;
1352a36e69ddSths 	bs->rd_ops ++;
1353a36e69ddSths     }
1354a36e69ddSths 
1355a36e69ddSths     return ret;
135683f64091Sbellard }
135783f64091Sbellard 
1358ce1a14dcSpbrook BlockDriverAIOCB *bdrv_aio_write(BlockDriverState *bs, int64_t sector_num,
135983f64091Sbellard                                  const uint8_t *buf, int nb_sectors,
136083f64091Sbellard                                  BlockDriverCompletionFunc *cb, void *opaque)
13617674e7bfSbellard {
136283f64091Sbellard     BlockDriver *drv = bs->drv;
1363a36e69ddSths     BlockDriverAIOCB *ret;
136483f64091Sbellard 
136519cb3738Sbellard     if (!drv)
1366ce1a14dcSpbrook         return NULL;
136783f64091Sbellard     if (bs->read_only)
1368ce1a14dcSpbrook         return NULL;
136971d0770cSaliguori     if (bdrv_check_request(bs, sector_num, nb_sectors))
137071d0770cSaliguori         return NULL;
137183f64091Sbellard 
1372a36e69ddSths     ret = drv->bdrv_aio_write(bs, sector_num, buf, nb_sectors, cb, opaque);
1373a36e69ddSths 
1374a36e69ddSths     if (ret) {
1375a36e69ddSths 	/* Update stats even though technically transfer has not happened. */
1376a36e69ddSths 	bs->wr_bytes += (unsigned) nb_sectors * SECTOR_SIZE;
1377a36e69ddSths 	bs->wr_ops ++;
1378a36e69ddSths     }
1379a36e69ddSths 
1380a36e69ddSths     return ret;
138183f64091Sbellard }
138283f64091Sbellard 
138383f64091Sbellard void bdrv_aio_cancel(BlockDriverAIOCB *acb)
138483f64091Sbellard {
13856bbff9a0Saliguori     acb->pool->cancel(acb);
138683f64091Sbellard }
138783f64091Sbellard 
138883f64091Sbellard 
138983f64091Sbellard /**************************************************************/
139083f64091Sbellard /* async block device emulation */
139183f64091Sbellard 
139283f64091Sbellard static void bdrv_aio_bh_cb(void *opaque)
1393beac80cdSbellard {
1394ce1a14dcSpbrook     BlockDriverAIOCBSync *acb = opaque;
1395ce1a14dcSpbrook     acb->common.cb(acb->common.opaque, acb->ret);
1396ce1a14dcSpbrook     qemu_aio_release(acb);
1397beac80cdSbellard }
1398beac80cdSbellard 
1399ce1a14dcSpbrook static BlockDriverAIOCB *bdrv_aio_read_em(BlockDriverState *bs,
1400ce1a14dcSpbrook         int64_t sector_num, uint8_t *buf, int nb_sectors,
1401ce1a14dcSpbrook         BlockDriverCompletionFunc *cb, void *opaque)
1402ea2384d3Sbellard {
1403ce1a14dcSpbrook     BlockDriverAIOCBSync *acb;
140483f64091Sbellard     int ret;
140583f64091Sbellard 
1406ce1a14dcSpbrook     acb = qemu_aio_get(bs, cb, opaque);
1407ce1a14dcSpbrook     if (!acb->bh)
1408ce1a14dcSpbrook         acb->bh = qemu_bh_new(bdrv_aio_bh_cb, acb);
1409ce1a14dcSpbrook     ret = bdrv_read(bs, sector_num, buf, nb_sectors);
1410ce1a14dcSpbrook     acb->ret = ret;
1411ce1a14dcSpbrook     qemu_bh_schedule(acb->bh);
1412ce1a14dcSpbrook     return &acb->common;
14137a6cba61Spbrook }
14147a6cba61Spbrook 
1415ce1a14dcSpbrook static BlockDriverAIOCB *bdrv_aio_write_em(BlockDriverState *bs,
1416ce1a14dcSpbrook         int64_t sector_num, const uint8_t *buf, int nb_sectors,
1417ce1a14dcSpbrook         BlockDriverCompletionFunc *cb, void *opaque)
141883f64091Sbellard {
1419ce1a14dcSpbrook     BlockDriverAIOCBSync *acb;
142083f64091Sbellard     int ret;
142183f64091Sbellard 
1422ce1a14dcSpbrook     acb = qemu_aio_get(bs, cb, opaque);
1423ce1a14dcSpbrook     if (!acb->bh)
1424ce1a14dcSpbrook         acb->bh = qemu_bh_new(bdrv_aio_bh_cb, acb);
1425ce1a14dcSpbrook     ret = bdrv_write(bs, sector_num, buf, nb_sectors);
1426ce1a14dcSpbrook     acb->ret = ret;
1427ce1a14dcSpbrook     qemu_bh_schedule(acb->bh);
1428ce1a14dcSpbrook     return &acb->common;
142983f64091Sbellard }
143083f64091Sbellard 
1431ce1a14dcSpbrook static void bdrv_aio_cancel_em(BlockDriverAIOCB *blockacb)
143283f64091Sbellard {
1433ce1a14dcSpbrook     BlockDriverAIOCBSync *acb = (BlockDriverAIOCBSync *)blockacb;
1434ce1a14dcSpbrook     qemu_bh_cancel(acb->bh);
1435ce1a14dcSpbrook     qemu_aio_release(acb);
143683f64091Sbellard }
143783f64091Sbellard 
143883f64091Sbellard /**************************************************************/
143983f64091Sbellard /* sync block device emulation */
144083f64091Sbellard 
144183f64091Sbellard static void bdrv_rw_em_cb(void *opaque, int ret)
144283f64091Sbellard {
144383f64091Sbellard     *(int *)opaque = ret;
144483f64091Sbellard }
144583f64091Sbellard 
144683f64091Sbellard #define NOT_DONE 0x7fffffff
144783f64091Sbellard 
144883f64091Sbellard static int bdrv_read_em(BlockDriverState *bs, int64_t sector_num,
144983f64091Sbellard                         uint8_t *buf, int nb_sectors)
145083f64091Sbellard {
1451ce1a14dcSpbrook     int async_ret;
1452ce1a14dcSpbrook     BlockDriverAIOCB *acb;
145383f64091Sbellard 
145483f64091Sbellard     async_ret = NOT_DONE;
1455ce1a14dcSpbrook     acb = bdrv_aio_read(bs, sector_num, buf, nb_sectors,
145683f64091Sbellard                         bdrv_rw_em_cb, &async_ret);
1457baf35cb9Saliguori     if (acb == NULL)
1458ce1a14dcSpbrook         return -1;
1459baf35cb9Saliguori 
146083f64091Sbellard     while (async_ret == NOT_DONE) {
146183f64091Sbellard         qemu_aio_wait();
146283f64091Sbellard     }
1463baf35cb9Saliguori 
146483f64091Sbellard     return async_ret;
146583f64091Sbellard }
146683f64091Sbellard 
146783f64091Sbellard static int bdrv_write_em(BlockDriverState *bs, int64_t sector_num,
146883f64091Sbellard                          const uint8_t *buf, int nb_sectors)
146983f64091Sbellard {
1470ce1a14dcSpbrook     int async_ret;
1471ce1a14dcSpbrook     BlockDriverAIOCB *acb;
147283f64091Sbellard 
147383f64091Sbellard     async_ret = NOT_DONE;
1474ce1a14dcSpbrook     acb = bdrv_aio_write(bs, sector_num, buf, nb_sectors,
147583f64091Sbellard                          bdrv_rw_em_cb, &async_ret);
1476baf35cb9Saliguori     if (acb == NULL)
1477ce1a14dcSpbrook         return -1;
147883f64091Sbellard     while (async_ret == NOT_DONE) {
147983f64091Sbellard         qemu_aio_wait();
148083f64091Sbellard     }
148183f64091Sbellard     return async_ret;
148283f64091Sbellard }
1483ea2384d3Sbellard 
1484ea2384d3Sbellard void bdrv_init(void)
1485ea2384d3Sbellard {
1486*c07a9008Saliguori     aio_pool_init(&vectored_aio_pool, sizeof(BlockDriverAIOCB),
1487*c07a9008Saliguori                   bdrv_aio_cancel_vector);
1488*c07a9008Saliguori 
1489ea2384d3Sbellard     bdrv_register(&bdrv_raw);
149019cb3738Sbellard     bdrv_register(&bdrv_host_device);
1491ea2384d3Sbellard #ifndef _WIN32
1492ea2384d3Sbellard     bdrv_register(&bdrv_cow);
1493ea2384d3Sbellard #endif
1494ea2384d3Sbellard     bdrv_register(&bdrv_qcow);
1495ea2384d3Sbellard     bdrv_register(&bdrv_vmdk);
14963c56521bSbellard     bdrv_register(&bdrv_cloop);
1497585d0ed9Sbellard     bdrv_register(&bdrv_dmg);
1498a8753c34Sbellard     bdrv_register(&bdrv_bochs);
14996a0f9e82Sbellard     bdrv_register(&bdrv_vpc);
1500712e7874Sbellard     bdrv_register(&bdrv_vvfat);
1501faea38e7Sbellard     bdrv_register(&bdrv_qcow2);
15026ada7453Sths     bdrv_register(&bdrv_parallels);
150375818250Sths     bdrv_register(&bdrv_nbd);
1504ea2384d3Sbellard }
1505ce1a14dcSpbrook 
15066bbff9a0Saliguori void aio_pool_init(AIOPool *pool, int aiocb_size,
15076bbff9a0Saliguori                    void (*cancel)(BlockDriverAIOCB *acb))
1508ce1a14dcSpbrook {
15096bbff9a0Saliguori     pool->aiocb_size = aiocb_size;
15106bbff9a0Saliguori     pool->cancel = cancel;
15116bbff9a0Saliguori     pool->free_aiocb = NULL;
15126bbff9a0Saliguori }
15136bbff9a0Saliguori 
15146bbff9a0Saliguori void *qemu_aio_get_pool(AIOPool *pool, BlockDriverState *bs,
15156bbff9a0Saliguori                         BlockDriverCompletionFunc *cb, void *opaque)
15166bbff9a0Saliguori {
1517ce1a14dcSpbrook     BlockDriverAIOCB *acb;
1518ce1a14dcSpbrook 
15196bbff9a0Saliguori     if (pool->free_aiocb) {
15206bbff9a0Saliguori         acb = pool->free_aiocb;
15216bbff9a0Saliguori         pool->free_aiocb = acb->next;
1522ce1a14dcSpbrook     } else {
15236bbff9a0Saliguori         acb = qemu_mallocz(pool->aiocb_size);
15246bbff9a0Saliguori         acb->pool = pool;
1525ce1a14dcSpbrook     }
1526ce1a14dcSpbrook     acb->bs = bs;
1527ce1a14dcSpbrook     acb->cb = cb;
1528ce1a14dcSpbrook     acb->opaque = opaque;
1529ce1a14dcSpbrook     return acb;
1530ce1a14dcSpbrook }
1531ce1a14dcSpbrook 
15326bbff9a0Saliguori void *qemu_aio_get(BlockDriverState *bs, BlockDriverCompletionFunc *cb,
15336bbff9a0Saliguori                    void *opaque)
15346bbff9a0Saliguori {
15356bbff9a0Saliguori     return qemu_aio_get_pool(&bs->drv->aio_pool, bs, cb, opaque);
15366bbff9a0Saliguori }
15376bbff9a0Saliguori 
1538ce1a14dcSpbrook void qemu_aio_release(void *p)
1539ce1a14dcSpbrook {
15406bbff9a0Saliguori     BlockDriverAIOCB *acb = (BlockDriverAIOCB *)p;
15416bbff9a0Saliguori     AIOPool *pool = acb->pool;
15426bbff9a0Saliguori     acb->next = pool->free_aiocb;
15436bbff9a0Saliguori     pool->free_aiocb = acb;
1544ce1a14dcSpbrook }
154519cb3738Sbellard 
154619cb3738Sbellard /**************************************************************/
154719cb3738Sbellard /* removable device support */
154819cb3738Sbellard 
154919cb3738Sbellard /**
155019cb3738Sbellard  * Return TRUE if the media is present
155119cb3738Sbellard  */
155219cb3738Sbellard int bdrv_is_inserted(BlockDriverState *bs)
155319cb3738Sbellard {
155419cb3738Sbellard     BlockDriver *drv = bs->drv;
155519cb3738Sbellard     int ret;
155619cb3738Sbellard     if (!drv)
155719cb3738Sbellard         return 0;
155819cb3738Sbellard     if (!drv->bdrv_is_inserted)
155919cb3738Sbellard         return 1;
156019cb3738Sbellard     ret = drv->bdrv_is_inserted(bs);
156119cb3738Sbellard     return ret;
156219cb3738Sbellard }
156319cb3738Sbellard 
156419cb3738Sbellard /**
156519cb3738Sbellard  * Return TRUE if the media changed since the last call to this
156619cb3738Sbellard  * function. It is currently only used for floppy disks
156719cb3738Sbellard  */
156819cb3738Sbellard int bdrv_media_changed(BlockDriverState *bs)
156919cb3738Sbellard {
157019cb3738Sbellard     BlockDriver *drv = bs->drv;
157119cb3738Sbellard     int ret;
157219cb3738Sbellard 
157319cb3738Sbellard     if (!drv || !drv->bdrv_media_changed)
157419cb3738Sbellard         ret = -ENOTSUP;
157519cb3738Sbellard     else
157619cb3738Sbellard         ret = drv->bdrv_media_changed(bs);
157719cb3738Sbellard     if (ret == -ENOTSUP)
157819cb3738Sbellard         ret = bs->media_changed;
157919cb3738Sbellard     bs->media_changed = 0;
158019cb3738Sbellard     return ret;
158119cb3738Sbellard }
158219cb3738Sbellard 
158319cb3738Sbellard /**
158419cb3738Sbellard  * If eject_flag is TRUE, eject the media. Otherwise, close the tray
158519cb3738Sbellard  */
158619cb3738Sbellard void bdrv_eject(BlockDriverState *bs, int eject_flag)
158719cb3738Sbellard {
158819cb3738Sbellard     BlockDriver *drv = bs->drv;
158919cb3738Sbellard     int ret;
159019cb3738Sbellard 
159119cb3738Sbellard     if (!drv || !drv->bdrv_eject) {
159219cb3738Sbellard         ret = -ENOTSUP;
159319cb3738Sbellard     } else {
159419cb3738Sbellard         ret = drv->bdrv_eject(bs, eject_flag);
159519cb3738Sbellard     }
159619cb3738Sbellard     if (ret == -ENOTSUP) {
159719cb3738Sbellard         if (eject_flag)
159819cb3738Sbellard             bdrv_close(bs);
159919cb3738Sbellard     }
160019cb3738Sbellard }
160119cb3738Sbellard 
160219cb3738Sbellard int bdrv_is_locked(BlockDriverState *bs)
160319cb3738Sbellard {
160419cb3738Sbellard     return bs->locked;
160519cb3738Sbellard }
160619cb3738Sbellard 
160719cb3738Sbellard /**
160819cb3738Sbellard  * Lock or unlock the media (if it is locked, the user won't be able
160919cb3738Sbellard  * to eject it manually).
161019cb3738Sbellard  */
161119cb3738Sbellard void bdrv_set_locked(BlockDriverState *bs, int locked)
161219cb3738Sbellard {
161319cb3738Sbellard     BlockDriver *drv = bs->drv;
161419cb3738Sbellard 
161519cb3738Sbellard     bs->locked = locked;
161619cb3738Sbellard     if (drv && drv->bdrv_set_locked) {
161719cb3738Sbellard         drv->bdrv_set_locked(bs, locked);
161819cb3738Sbellard     }
161919cb3738Sbellard }
1620985a03b0Sths 
1621985a03b0Sths /* needed for generic scsi interface */
1622985a03b0Sths 
1623985a03b0Sths int bdrv_ioctl(BlockDriverState *bs, unsigned long int req, void *buf)
1624985a03b0Sths {
1625985a03b0Sths     BlockDriver *drv = bs->drv;
1626985a03b0Sths 
1627985a03b0Sths     if (drv && drv->bdrv_ioctl)
1628985a03b0Sths         return drv->bdrv_ioctl(bs, req, buf);
1629985a03b0Sths     return -ENOTSUP;
1630985a03b0Sths }
16317d780669Saliguori 
16327d780669Saliguori int bdrv_sg_send_command(BlockDriverState *bs, void *buf, int count)
16337d780669Saliguori {
163404eeb8b6Saliguori     return bs->drv->bdrv_sg_send_command(bs, buf, count);
16357d780669Saliguori }
16367d780669Saliguori 
16377d780669Saliguori int bdrv_sg_recv_response(BlockDriverState *bs, void *buf, int count)
16387d780669Saliguori {
163904eeb8b6Saliguori     return bs->drv->bdrv_sg_recv_response(bs, buf, count);
16407d780669Saliguori }
16417d780669Saliguori 
16427d780669Saliguori BlockDriverAIOCB *bdrv_sg_aio_read(BlockDriverState *bs, void *buf, int count,
16437d780669Saliguori                                    BlockDriverCompletionFunc *cb, void *opaque)
16447d780669Saliguori {
164504eeb8b6Saliguori     return bs->drv->bdrv_sg_aio_read(bs, buf, count, cb, opaque);
16467d780669Saliguori }
16477d780669Saliguori 
16487d780669Saliguori BlockDriverAIOCB *bdrv_sg_aio_write(BlockDriverState *bs, void *buf, int count,
16497d780669Saliguori                                     BlockDriverCompletionFunc *cb, void *opaque)
16507d780669Saliguori {
165104eeb8b6Saliguori     return bs->drv->bdrv_sg_aio_write(bs, buf, count, cb, opaque);
16527d780669Saliguori }
1653