2 * Block driver for RAW files (posix)
4 * Copyright (c) 2006 Fabrice Bellard
6 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 * of this software and associated documentation files (the "Software"), to deal
8 * in the Software without restriction, including without limitation the rights
9 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10 * copies of the Software, and to permit persons to whom the Software is
11 * furnished to do so, subject to the following conditions:
13 * The above copyright notice and this permission notice shall be included in
14 * all copies or substantial portions of the Software.
16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
24 #include "qemu-common.h"
25 #include "qemu-timer.h"
26 #include "qemu-char.h"
28 #include "block_int.h"
31 #include "thread-pool.h"
35 #if defined(__APPLE__) && (__MACH__)
37 #include <sys/param.h>
38 #include <IOKit/IOKitLib.h>
39 #include <IOKit/IOBSD.h>
40 #include <IOKit/storage/IOMediaBSDClient.h>
41 #include <IOKit/storage/IOMedia.h>
42 #include <IOKit/storage/IOCDMedia.h>
43 //#include <IOKit/storage/IOCDTypes.h>
44 #include <CoreFoundation/CoreFoundation.h>
48 #define _POSIX_PTHREAD_SEMANTICS 1
52 #include <sys/types.h>
54 #include <sys/ioctl.h>
55 #include <sys/param.h>
56 #include <linux/cdrom.h>
61 #include <linux/fiemap.h>
63 #if defined (__FreeBSD__) || defined(__FreeBSD_kernel__)
69 #include <sys/ioctl.h>
70 #include <sys/disklabel.h>
75 #include <sys/ioctl.h>
76 #include <sys/disklabel.h>
82 #include <sys/ioctl.h>
83 #include <sys/diskslice.h>
90 //#define DEBUG_FLOPPY
93 #if defined(DEBUG_BLOCK)
94 #define DEBUG_BLOCK_PRINT(formatCstr, ...) do { if (qemu_log_enabled()) \
95 { qemu_log(formatCstr, ## __VA_ARGS__); qemu_log_flush(); } } while (0)
97 #define DEBUG_BLOCK_PRINT(formatCstr, ...)
100 /* OS X does not have O_DSYNC */
103 #define O_DSYNC O_SYNC
104 #elif defined(O_FSYNC)
105 #define O_DSYNC O_FSYNC
109 /* Approximate O_DIRECT with O_DSYNC if O_DIRECT isn't available */
111 #define O_DIRECT O_DSYNC
118 /* if the FD is not accessed during that time (in ns), we try to
119 reopen it to see if the disk has been changed */
120 #define FD_OPEN_TIMEOUT (1000000000)
122 #define MAX_BLOCKSIZE 4096
124 typedef struct BDRVRawState {
128 #if defined(__linux__)
129 /* linux floppy specific */
130 int64_t fd_open_time;
131 int64_t fd_error_time;
133 int fd_media_changed;
135 #ifdef CONFIG_LINUX_AIO
144 typedef struct BDRVRawReopenState {
147 #ifdef CONFIG_LINUX_AIO
150 } BDRVRawReopenState;
152 static int fd_open(BlockDriverState *bs);
153 static int64_t raw_getlength(BlockDriverState *bs);
155 typedef struct RawPosixAIOData {
156 BlockDriverState *bs;
159 struct iovec *aio_iov;
164 #define aio_ioctl_cmd aio_nbytes /* for QEMU_AIO_IOCTL */
169 #if defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
170 static int cdrom_reopen(BlockDriverState *bs);
173 #if defined(__NetBSD__)
174 static int raw_normalize_devicepath(const char **filename)
176 static char namebuf[PATH_MAX];
177 const char *dp, *fname;
181 dp = strrchr(fname, '/');
182 if (lstat(fname, &sb) < 0) {
183 fprintf(stderr, "%s: stat failed: %s\n",
184 fname, strerror(errno));
188 if (!S_ISBLK(sb.st_mode)) {
193 snprintf(namebuf, PATH_MAX, "r%s", fname);
195 snprintf(namebuf, PATH_MAX, "%.*s/r%s",
196 (int)(dp - fname), fname, dp + 1);
198 fprintf(stderr, "%s is a block device", fname);
200 fprintf(stderr, ", using %s\n", *filename);
205 static int raw_normalize_devicepath(const char **filename)
211 static void raw_parse_flags(int bdrv_flags, int *open_flags)
213 assert(open_flags != NULL);
215 *open_flags |= O_BINARY;
216 *open_flags &= ~O_ACCMODE;
217 if (bdrv_flags & BDRV_O_RDWR) {
218 *open_flags |= O_RDWR;
220 *open_flags |= O_RDONLY;
223 /* Use O_DSYNC for write-through caching, no flags for write-back caching,
224 * and O_DIRECT for no caching. */
225 if ((bdrv_flags & BDRV_O_NOCACHE)) {
226 *open_flags |= O_DIRECT;
230 #ifdef CONFIG_LINUX_AIO
231 static int raw_set_aio(void **aio_ctx, int *use_aio, int bdrv_flags)
234 assert(aio_ctx != NULL);
235 assert(use_aio != NULL);
237 * Currently Linux do AIO only for files opened with O_DIRECT
238 * specified so check NOCACHE flag too
240 if ((bdrv_flags & (BDRV_O_NOCACHE|BDRV_O_NATIVE_AIO)) ==
241 (BDRV_O_NOCACHE|BDRV_O_NATIVE_AIO)) {
243 /* if non-NULL, laio_init() has already been run */
244 if (*aio_ctx == NULL) {
245 *aio_ctx = laio_init();
262 static int raw_open_common(BlockDriverState *bs, const char *filename,
263 int bdrv_flags, int open_flags)
265 BDRVRawState *s = bs->opaque;
268 ret = raw_normalize_devicepath(&filename);
273 s->open_flags = open_flags;
274 raw_parse_flags(bdrv_flags, &s->open_flags);
277 fd = qemu_open(filename, s->open_flags, 0644);
286 #ifdef CONFIG_LINUX_AIO
287 if (raw_set_aio(&s->aio_ctx, &s->use_aio, bdrv_flags)) {
294 if (platform_test_xfs_fd(s->fd)) {
302 static int raw_open(BlockDriverState *bs, const char *filename, int flags)
304 BDRVRawState *s = bs->opaque;
306 s->type = FTYPE_FILE;
307 return raw_open_common(bs, filename, flags, 0);
310 static int raw_reopen_prepare(BDRVReopenState *state,
311 BlockReopenQueue *queue, Error **errp)
314 BDRVRawReopenState *raw_s;
317 assert(state != NULL);
318 assert(state->bs != NULL);
320 s = state->bs->opaque;
322 state->opaque = g_malloc0(sizeof(BDRVRawReopenState));
323 raw_s = state->opaque;
325 #ifdef CONFIG_LINUX_AIO
326 raw_s->use_aio = s->use_aio;
328 /* we can use s->aio_ctx instead of a copy, because the use_aio flag is
329 * valid in the 'false' condition even if aio_ctx is set, and raw_set_aio()
330 * won't override aio_ctx if aio_ctx is non-NULL */
331 if (raw_set_aio(&s->aio_ctx, &raw_s->use_aio, state->flags)) {
336 if (s->type == FTYPE_FD || s->type == FTYPE_CD) {
337 raw_s->open_flags |= O_NONBLOCK;
340 raw_parse_flags(state->flags, &raw_s->open_flags);
344 int fcntl_flags = O_APPEND | O_ASYNC | O_NONBLOCK;
346 fcntl_flags |= O_NOATIME;
349 if ((raw_s->open_flags & ~fcntl_flags) == (s->open_flags & ~fcntl_flags)) {
350 /* dup the original fd */
351 /* TODO: use qemu fcntl wrapper */
352 #ifdef F_DUPFD_CLOEXEC
353 raw_s->fd = fcntl(s->fd, F_DUPFD_CLOEXEC, 0);
355 raw_s->fd = dup(s->fd);
356 if (raw_s->fd != -1) {
357 qemu_set_cloexec(raw_s->fd);
360 if (raw_s->fd >= 0) {
361 ret = fcntl_setfl(raw_s->fd, raw_s->open_flags);
363 qemu_close(raw_s->fd);
369 /* If we cannot use fcntl, or fcntl failed, fall back to qemu_open() */
370 if (raw_s->fd == -1) {
371 assert(!(raw_s->open_flags & O_CREAT));
372 raw_s->fd = qemu_open(state->bs->filename, raw_s->open_flags);
373 if (raw_s->fd == -1) {
381 static void raw_reopen_commit(BDRVReopenState *state)
383 BDRVRawReopenState *raw_s = state->opaque;
384 BDRVRawState *s = state->bs->opaque;
386 s->open_flags = raw_s->open_flags;
390 #ifdef CONFIG_LINUX_AIO
391 s->use_aio = raw_s->use_aio;
394 g_free(state->opaque);
395 state->opaque = NULL;
399 static void raw_reopen_abort(BDRVReopenState *state)
401 BDRVRawReopenState *raw_s = state->opaque;
403 /* nothing to do if NULL, we didn't get far enough */
408 if (raw_s->fd >= 0) {
409 qemu_close(raw_s->fd);
412 g_free(state->opaque);
413 state->opaque = NULL;
417 /* XXX: use host sector size if necessary with:
418 #ifdef DIOCGSECTORSIZE
420 unsigned int sectorsize = 512;
421 if (!ioctl(fd, DIOCGSECTORSIZE, §orsize) &&
422 sectorsize > bufsize)
423 bufsize = sectorsize;
427 uint32_t blockSize = 512;
428 if ( !ioctl( fd, DKIOCGETBLOCKSIZE, &blockSize ) && blockSize > bufsize) {
435 * Check if all memory in this vector is sector aligned.
437 static int qiov_is_aligned(BlockDriverState *bs, QEMUIOVector *qiov)
441 for (i = 0; i < qiov->niov; i++) {
442 if ((uintptr_t) qiov->iov[i].iov_base % bs->buffer_alignment) {
450 static ssize_t handle_aiocb_ioctl(RawPosixAIOData *aiocb)
454 ret = ioctl(aiocb->aio_fildes, aiocb->aio_ioctl_cmd, aiocb->aio_ioctl_buf);
460 * This looks weird, but the aio code only considers a request
461 * successful if it has written the full number of bytes.
463 * Now we overload aio_nbytes as aio_ioctl_cmd for the ioctl command,
464 * so in fact we return the ioctl command here to make posix_aio_read()
467 return aiocb->aio_nbytes;
470 static ssize_t handle_aiocb_flush(RawPosixAIOData *aiocb)
474 ret = qemu_fdatasync(aiocb->aio_fildes);
483 static bool preadv_present = true;
486 qemu_preadv(int fd, const struct iovec *iov, int nr_iov, off_t offset)
488 return preadv(fd, iov, nr_iov, offset);
492 qemu_pwritev(int fd, const struct iovec *iov, int nr_iov, off_t offset)
494 return pwritev(fd, iov, nr_iov, offset);
499 static bool preadv_present = false;
502 qemu_preadv(int fd, const struct iovec *iov, int nr_iov, off_t offset)
508 qemu_pwritev(int fd, const struct iovec *iov, int nr_iov, off_t offset)
515 static ssize_t handle_aiocb_rw_vector(RawPosixAIOData *aiocb)
520 if (aiocb->aio_type & QEMU_AIO_WRITE)
521 len = qemu_pwritev(aiocb->aio_fildes,
526 len = qemu_preadv(aiocb->aio_fildes,
530 } while (len == -1 && errno == EINTR);
539 * Read/writes the data to/from a given linear buffer.
541 * Returns the number of bytes handles or -errno in case of an error. Short
542 * reads are only returned if the end of the file is reached.
544 static ssize_t handle_aiocb_rw_linear(RawPosixAIOData *aiocb, char *buf)
549 while (offset < aiocb->aio_nbytes) {
550 if (aiocb->aio_type & QEMU_AIO_WRITE) {
551 len = pwrite(aiocb->aio_fildes,
552 (const char *)buf + offset,
553 aiocb->aio_nbytes - offset,
554 aiocb->aio_offset + offset);
556 len = pread(aiocb->aio_fildes,
558 aiocb->aio_nbytes - offset,
559 aiocb->aio_offset + offset);
561 if (len == -1 && errno == EINTR) {
563 } else if (len == -1) {
566 } else if (len == 0) {
575 static ssize_t handle_aiocb_rw(RawPosixAIOData *aiocb)
580 if (!(aiocb->aio_type & QEMU_AIO_MISALIGNED)) {
582 * If there is just a single buffer, and it is properly aligned
583 * we can just use plain pread/pwrite without any problems.
585 if (aiocb->aio_niov == 1) {
586 return handle_aiocb_rw_linear(aiocb, aiocb->aio_iov->iov_base);
589 * We have more than one iovec, and all are properly aligned.
591 * Try preadv/pwritev first and fall back to linearizing the
592 * buffer if it's not supported.
594 if (preadv_present) {
595 nbytes = handle_aiocb_rw_vector(aiocb);
596 if (nbytes == aiocb->aio_nbytes ||
597 (nbytes < 0 && nbytes != -ENOSYS)) {
600 preadv_present = false;
604 * XXX(hch): short read/write. no easy way to handle the reminder
605 * using these interfaces. For now retry using plain
611 * Ok, we have to do it the hard way, copy all segments into
612 * a single aligned buffer.
614 buf = qemu_blockalign(aiocb->bs, aiocb->aio_nbytes);
615 if (aiocb->aio_type & QEMU_AIO_WRITE) {
619 for (i = 0; i < aiocb->aio_niov; ++i) {
620 memcpy(p, aiocb->aio_iov[i].iov_base, aiocb->aio_iov[i].iov_len);
621 p += aiocb->aio_iov[i].iov_len;
625 nbytes = handle_aiocb_rw_linear(aiocb, buf);
626 if (!(aiocb->aio_type & QEMU_AIO_WRITE)) {
628 size_t count = aiocb->aio_nbytes, copy;
631 for (i = 0; i < aiocb->aio_niov && count; ++i) {
633 if (copy > aiocb->aio_iov[i].iov_len) {
634 copy = aiocb->aio_iov[i].iov_len;
636 memcpy(aiocb->aio_iov[i].iov_base, p, copy);
646 static int aio_worker(void *arg)
648 RawPosixAIOData *aiocb = arg;
651 switch (aiocb->aio_type & QEMU_AIO_TYPE_MASK) {
653 ret = handle_aiocb_rw(aiocb);
654 if (ret >= 0 && ret < aiocb->aio_nbytes && aiocb->bs->growable) {
655 iov_memset(aiocb->aio_iov, aiocb->aio_niov, ret,
656 0, aiocb->aio_nbytes - ret);
658 ret = aiocb->aio_nbytes;
660 if (ret == aiocb->aio_nbytes) {
662 } else if (ret >= 0 && ret < aiocb->aio_nbytes) {
667 ret = handle_aiocb_rw(aiocb);
668 if (ret == aiocb->aio_nbytes) {
670 } else if (ret >= 0 && ret < aiocb->aio_nbytes) {
675 ret = handle_aiocb_flush(aiocb);
678 ret = handle_aiocb_ioctl(aiocb);
681 fprintf(stderr, "invalid aio request (0x%x)\n", aiocb->aio_type);
686 g_slice_free(RawPosixAIOData, aiocb);
690 static BlockDriverAIOCB *paio_submit(BlockDriverState *bs, int fd,
691 int64_t sector_num, QEMUIOVector *qiov, int nb_sectors,
692 BlockDriverCompletionFunc *cb, void *opaque, int type)
694 RawPosixAIOData *acb = g_slice_new(RawPosixAIOData);
697 acb->aio_type = type;
698 acb->aio_fildes = fd;
701 acb->aio_iov = qiov->iov;
702 acb->aio_niov = qiov->niov;
704 acb->aio_nbytes = nb_sectors * 512;
705 acb->aio_offset = sector_num * 512;
707 trace_paio_submit(acb, opaque, sector_num, nb_sectors, type);
708 return thread_pool_submit_aio(aio_worker, acb, cb, opaque);
711 static BlockDriverAIOCB *raw_aio_submit(BlockDriverState *bs,
712 int64_t sector_num, QEMUIOVector *qiov, int nb_sectors,
713 BlockDriverCompletionFunc *cb, void *opaque, int type)
715 BDRVRawState *s = bs->opaque;
721 * If O_DIRECT is used the buffer needs to be aligned on a sector
722 * boundary. Check if this is the case or tell the low-level
723 * driver that it needs to copy the buffer.
725 if ((bs->open_flags & BDRV_O_NOCACHE)) {
726 if (!qiov_is_aligned(bs, qiov)) {
727 type |= QEMU_AIO_MISALIGNED;
728 #ifdef CONFIG_LINUX_AIO
729 } else if (s->use_aio) {
730 return laio_submit(bs, s->aio_ctx, s->fd, sector_num, qiov,
731 nb_sectors, cb, opaque, type);
736 return paio_submit(bs, s->fd, sector_num, qiov, nb_sectors,
740 static BlockDriverAIOCB *raw_aio_readv(BlockDriverState *bs,
741 int64_t sector_num, QEMUIOVector *qiov, int nb_sectors,
742 BlockDriverCompletionFunc *cb, void *opaque)
744 return raw_aio_submit(bs, sector_num, qiov, nb_sectors,
745 cb, opaque, QEMU_AIO_READ);
748 static BlockDriverAIOCB *raw_aio_writev(BlockDriverState *bs,
749 int64_t sector_num, QEMUIOVector *qiov, int nb_sectors,
750 BlockDriverCompletionFunc *cb, void *opaque)
752 return raw_aio_submit(bs, sector_num, qiov, nb_sectors,
753 cb, opaque, QEMU_AIO_WRITE);
756 static BlockDriverAIOCB *raw_aio_flush(BlockDriverState *bs,
757 BlockDriverCompletionFunc *cb, void *opaque)
759 BDRVRawState *s = bs->opaque;
764 return paio_submit(bs, s->fd, 0, NULL, 0, cb, opaque, QEMU_AIO_FLUSH);
767 static void raw_close(BlockDriverState *bs)
769 BDRVRawState *s = bs->opaque;
776 static int raw_truncate(BlockDriverState *bs, int64_t offset)
778 BDRVRawState *s = bs->opaque;
781 if (fstat(s->fd, &st)) {
785 if (S_ISREG(st.st_mode)) {
786 if (ftruncate(s->fd, offset) < 0) {
789 } else if (S_ISCHR(st.st_mode) || S_ISBLK(st.st_mode)) {
790 if (offset > raw_getlength(bs)) {
801 static int64_t raw_getlength(BlockDriverState *bs)
803 BDRVRawState *s = bs->opaque;
809 if (S_ISCHR(st.st_mode) || S_ISBLK(st.st_mode)) {
812 if (ioctl(fd, DIOCGDINFO, &dl))
814 return (uint64_t)dl.d_secsize *
815 dl.d_partitions[DISKPART(st.st_rdev)].p_size;
819 #elif defined(__NetBSD__)
820 static int64_t raw_getlength(BlockDriverState *bs)
822 BDRVRawState *s = bs->opaque;
828 if (S_ISCHR(st.st_mode) || S_ISBLK(st.st_mode)) {
829 struct dkwedge_info dkw;
831 if (ioctl(fd, DIOCGWEDGEINFO, &dkw) != -1) {
832 return dkw.dkw_size * 512;
836 if (ioctl(fd, DIOCGDINFO, &dl))
838 return (uint64_t)dl.d_secsize *
839 dl.d_partitions[DISKPART(st.st_rdev)].p_size;
844 #elif defined(__sun__)
845 static int64_t raw_getlength(BlockDriverState *bs)
847 BDRVRawState *s = bs->opaque;
848 struct dk_minfo minfo;
857 * Use the DKIOCGMEDIAINFO ioctl to read the size.
859 ret = ioctl(s->fd, DKIOCGMEDIAINFO, &minfo);
861 return minfo.dki_lbsize * minfo.dki_capacity;
865 * There are reports that lseek on some devices fails, but
866 * irc discussion said that contingency on contingency was overkill.
868 return lseek(s->fd, 0, SEEK_END);
870 #elif defined(CONFIG_BSD)
871 static int64_t raw_getlength(BlockDriverState *bs)
873 BDRVRawState *s = bs->opaque;
877 #if defined (__FreeBSD__) || defined(__FreeBSD_kernel__)
886 #if defined (__FreeBSD__) || defined(__FreeBSD_kernel__)
889 if (!fstat(fd, &sb) && (S_IFCHR & sb.st_mode)) {
890 #ifdef DIOCGMEDIASIZE
891 if (ioctl(fd, DIOCGMEDIASIZE, (off_t *)&size))
892 #elif defined(DIOCGPART)
895 if (ioctl(fd, DIOCGPART, &pi) == 0)
896 size = pi.media_size;
902 #if defined(__APPLE__) && defined(__MACH__)
903 size = LONG_LONG_MAX;
905 size = lseek(fd, 0LL, SEEK_END);
907 #if defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
910 /* XXX FreeBSD acd returns UINT_MAX sectors for an empty drive */
911 if (size == 2048LL * (unsigned)-1)
913 /* XXX no disc? maybe we need to reopen... */
914 if (size <= 0 && !reopened && cdrom_reopen(bs) >= 0) {
921 size = lseek(fd, 0, SEEK_END);
926 static int64_t raw_getlength(BlockDriverState *bs)
928 BDRVRawState *s = bs->opaque;
936 return lseek(s->fd, 0, SEEK_END);
940 static int64_t raw_get_allocated_file_size(BlockDriverState *bs)
943 BDRVRawState *s = bs->opaque;
945 if (fstat(s->fd, &st) < 0) {
948 return (int64_t)st.st_blocks * 512;
951 static int raw_create(const char *filename, QEMUOptionParameter *options)
955 int64_t total_size = 0;
957 /* Read out options */
958 while (options && options->name) {
959 if (!strcmp(options->name, BLOCK_OPT_SIZE)) {
960 total_size = options->value.n / BDRV_SECTOR_SIZE;
965 fd = qemu_open(filename, O_WRONLY | O_CREAT | O_TRUNC | O_BINARY,
970 if (ftruncate(fd, total_size * BDRV_SECTOR_SIZE) != 0) {
973 if (qemu_close(fd) != 0) {
981 * Returns true iff the specified sector is present in the disk image. Drivers
982 * not implementing the functionality are assumed to not support backing files,
983 * hence all their sectors are reported as allocated.
985 * If 'sector_num' is beyond the end of the disk image the return value is 0
986 * and 'pnum' is set to 0.
988 * 'pnum' is set to the number of sectors (including and immediately following
989 * the specified sector) that are known to be in the same
990 * allocated/unallocated state.
992 * 'nb_sectors' is the max value 'pnum' should be set to. If nb_sectors goes
993 * beyond the end of the disk image it will be clamped.
995 static int coroutine_fn raw_co_is_allocated(BlockDriverState *bs,
997 int nb_sectors, int *pnum)
999 off_t start, data, hole;
1007 start = sector_num * BDRV_SECTOR_SIZE;
1009 #ifdef CONFIG_FIEMAP
1011 BDRVRawState *s = bs->opaque;
1014 struct fiemap_extent fe;
1017 f.fm.fm_start = start;
1018 f.fm.fm_length = (int64_t)nb_sectors * BDRV_SECTOR_SIZE;
1020 f.fm.fm_extent_count = 1;
1021 f.fm.fm_reserved = 0;
1022 if (ioctl(s->fd, FS_IOC_FIEMAP, &f) == -1) {
1023 /* Assume everything is allocated. */
1028 if (f.fm.fm_mapped_extents == 0) {
1029 /* No extents found, data is beyond f.fm.fm_start + f.fm.fm_length.
1030 * f.fm.fm_start + f.fm.fm_length must be clamped to the file size!
1032 off_t length = lseek(s->fd, 0, SEEK_END);
1033 hole = f.fm.fm_start;
1034 data = MIN(f.fm.fm_start + f.fm.fm_length, length);
1036 data = f.fe.fe_logical;
1037 hole = f.fe.fe_logical + f.fe.fe_length;
1040 #elif defined SEEK_HOLE && defined SEEK_DATA
1042 BDRVRawState *s = bs->opaque;
1044 hole = lseek(s->fd, start, SEEK_HOLE);
1046 /* -ENXIO indicates that sector_num was past the end of the file.
1047 * There is a virtual hole there. */
1048 assert(errno != -ENXIO);
1050 /* Most likely EINVAL. Assume everything is allocated. */
1058 /* On a hole. We need another syscall to find its end. */
1059 data = lseek(s->fd, start, SEEK_DATA);
1061 data = lseek(s->fd, 0, SEEK_END);
1069 if (data <= start) {
1070 /* On a data extent, compute sectors to the end of the extent. */
1071 *pnum = MIN(nb_sectors, (hole - start) / BDRV_SECTOR_SIZE);
1074 /* On a hole, compute sectors to the beginning of the next extent. */
1075 *pnum = MIN(nb_sectors, (data - start) / BDRV_SECTOR_SIZE);
1081 static int xfs_discard(BDRVRawState *s, int64_t sector_num, int nb_sectors)
1083 struct xfs_flock64 fl;
1085 memset(&fl, 0, sizeof(fl));
1086 fl.l_whence = SEEK_SET;
1087 fl.l_start = sector_num << 9;
1088 fl.l_len = (int64_t)nb_sectors << 9;
1090 if (xfsctl(NULL, s->fd, XFS_IOC_UNRESVSP64, &fl) < 0) {
1091 DEBUG_BLOCK_PRINT("cannot punch hole (%s)\n", strerror(errno));
1099 static coroutine_fn int raw_co_discard(BlockDriverState *bs,
1100 int64_t sector_num, int nb_sectors)
1103 BDRVRawState *s = bs->opaque;
1106 return xfs_discard(s, sector_num, nb_sectors);
1113 static QEMUOptionParameter raw_create_options[] = {
1115 .name = BLOCK_OPT_SIZE,
1117 .help = "Virtual disk size"
1122 static BlockDriver bdrv_file = {
1123 .format_name = "file",
1124 .protocol_name = "file",
1125 .instance_size = sizeof(BDRVRawState),
1126 .bdrv_probe = NULL, /* no probe for protocols */
1127 .bdrv_file_open = raw_open,
1128 .bdrv_reopen_prepare = raw_reopen_prepare,
1129 .bdrv_reopen_commit = raw_reopen_commit,
1130 .bdrv_reopen_abort = raw_reopen_abort,
1131 .bdrv_close = raw_close,
1132 .bdrv_create = raw_create,
1133 .bdrv_co_discard = raw_co_discard,
1134 .bdrv_co_is_allocated = raw_co_is_allocated,
1136 .bdrv_aio_readv = raw_aio_readv,
1137 .bdrv_aio_writev = raw_aio_writev,
1138 .bdrv_aio_flush = raw_aio_flush,
1140 .bdrv_truncate = raw_truncate,
1141 .bdrv_getlength = raw_getlength,
1142 .bdrv_get_allocated_file_size
1143 = raw_get_allocated_file_size,
1145 .create_options = raw_create_options,
1148 /***********************************************/
1151 #if defined(__APPLE__) && defined(__MACH__)
1152 static kern_return_t FindEjectableCDMedia( io_iterator_t *mediaIterator );
1153 static kern_return_t GetBSDPath( io_iterator_t mediaIterator, char *bsdPath, CFIndex maxPathSize );
1155 kern_return_t FindEjectableCDMedia( io_iterator_t *mediaIterator )
1157 kern_return_t kernResult;
1158 mach_port_t masterPort;
1159 CFMutableDictionaryRef classesToMatch;
1161 kernResult = IOMasterPort( MACH_PORT_NULL, &masterPort );
1162 if ( KERN_SUCCESS != kernResult ) {
1163 printf( "IOMasterPort returned %d\n", kernResult );
1166 classesToMatch = IOServiceMatching( kIOCDMediaClass );
1167 if ( classesToMatch == NULL ) {
1168 printf( "IOServiceMatching returned a NULL dictionary.\n" );
1170 CFDictionarySetValue( classesToMatch, CFSTR( kIOMediaEjectableKey ), kCFBooleanTrue );
1172 kernResult = IOServiceGetMatchingServices( masterPort, classesToMatch, mediaIterator );
1173 if ( KERN_SUCCESS != kernResult )
1175 printf( "IOServiceGetMatchingServices returned %d\n", kernResult );
1181 kern_return_t GetBSDPath( io_iterator_t mediaIterator, char *bsdPath, CFIndex maxPathSize )
1183 io_object_t nextMedia;
1184 kern_return_t kernResult = KERN_FAILURE;
1186 nextMedia = IOIteratorNext( mediaIterator );
1189 CFTypeRef bsdPathAsCFString;
1190 bsdPathAsCFString = IORegistryEntryCreateCFProperty( nextMedia, CFSTR( kIOBSDNameKey ), kCFAllocatorDefault, 0 );
1191 if ( bsdPathAsCFString ) {
1192 size_t devPathLength;
1193 strcpy( bsdPath, _PATH_DEV );
1194 strcat( bsdPath, "r" );
1195 devPathLength = strlen( bsdPath );
1196 if ( CFStringGetCString( bsdPathAsCFString, bsdPath + devPathLength, maxPathSize - devPathLength, kCFStringEncodingASCII ) ) {
1197 kernResult = KERN_SUCCESS;
1199 CFRelease( bsdPathAsCFString );
1201 IOObjectRelease( nextMedia );
1209 static int hdev_probe_device(const char *filename)
1213 /* allow a dedicated CD-ROM driver to match with a higher priority */
1214 if (strstart(filename, "/dev/cdrom", NULL))
1217 if (stat(filename, &st) >= 0 &&
1218 (S_ISCHR(st.st_mode) || S_ISBLK(st.st_mode))) {
1225 static int hdev_open(BlockDriverState *bs, const char *filename, int flags)
1227 BDRVRawState *s = bs->opaque;
1229 #if defined(__APPLE__) && defined(__MACH__)
1230 if (strstart(filename, "/dev/cdrom", NULL)) {
1231 kern_return_t kernResult;
1232 io_iterator_t mediaIterator;
1233 char bsdPath[ MAXPATHLEN ];
1236 kernResult = FindEjectableCDMedia( &mediaIterator );
1237 kernResult = GetBSDPath( mediaIterator, bsdPath, sizeof( bsdPath ) );
1239 if ( bsdPath[ 0 ] != '\0' ) {
1240 strcat(bsdPath,"s0");
1241 /* some CDs don't have a partition 0 */
1242 fd = qemu_open(bsdPath, O_RDONLY | O_BINARY | O_LARGEFILE);
1244 bsdPath[strlen(bsdPath)-1] = '1';
1251 if ( mediaIterator )
1252 IOObjectRelease( mediaIterator );
1256 s->type = FTYPE_FILE;
1257 #if defined(__linux__)
1259 char resolved_path[ MAXPATHLEN ], *temp;
1261 temp = realpath(filename, resolved_path);
1262 if (temp && strstart(temp, "/dev/sg", NULL)) {
1268 return raw_open_common(bs, filename, flags, 0);
1271 #if defined(__linux__)
1272 /* Note: we do not have a reliable method to detect if the floppy is
1273 present. The current method is to try to open the floppy at every
1274 I/O and to keep it opened during a few hundreds of ms. */
1275 static int fd_open(BlockDriverState *bs)
1277 BDRVRawState *s = bs->opaque;
1278 int last_media_present;
1280 if (s->type != FTYPE_FD)
1282 last_media_present = (s->fd >= 0);
1284 (get_clock() - s->fd_open_time) >= FD_OPEN_TIMEOUT) {
1288 printf("Floppy closed\n");
1292 if (s->fd_got_error &&
1293 (get_clock() - s->fd_error_time) < FD_OPEN_TIMEOUT) {
1295 printf("No floppy (open delayed)\n");
1299 s->fd = qemu_open(bs->filename, s->open_flags & ~O_NONBLOCK);
1301 s->fd_error_time = get_clock();
1302 s->fd_got_error = 1;
1303 if (last_media_present)
1304 s->fd_media_changed = 1;
1306 printf("No floppy\n");
1311 printf("Floppy opened\n");
1314 if (!last_media_present)
1315 s->fd_media_changed = 1;
1316 s->fd_open_time = get_clock();
1317 s->fd_got_error = 0;
1321 static int hdev_ioctl(BlockDriverState *bs, unsigned long int req, void *buf)
1323 BDRVRawState *s = bs->opaque;
1325 return ioctl(s->fd, req, buf);
1328 static BlockDriverAIOCB *hdev_aio_ioctl(BlockDriverState *bs,
1329 unsigned long int req, void *buf,
1330 BlockDriverCompletionFunc *cb, void *opaque)
1332 BDRVRawState *s = bs->opaque;
1333 RawPosixAIOData *acb;
1335 if (fd_open(bs) < 0)
1338 acb = g_slice_new(RawPosixAIOData);
1340 acb->aio_type = QEMU_AIO_IOCTL;
1341 acb->aio_fildes = s->fd;
1342 acb->aio_offset = 0;
1343 acb->aio_ioctl_buf = buf;
1344 acb->aio_ioctl_cmd = req;
1345 return thread_pool_submit_aio(aio_worker, acb, cb, opaque);
1348 #elif defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
1349 static int fd_open(BlockDriverState *bs)
1351 BDRVRawState *s = bs->opaque;
1353 /* this is just to ensure s->fd is sane (its called by io ops) */
1358 #else /* !linux && !FreeBSD */
1360 static int fd_open(BlockDriverState *bs)
1365 #endif /* !linux && !FreeBSD */
1367 static int hdev_create(const char *filename, QEMUOptionParameter *options)
1371 struct stat stat_buf;
1372 int64_t total_size = 0;
1374 /* Read out options */
1375 while (options && options->name) {
1376 if (!strcmp(options->name, "size")) {
1377 total_size = options->value.n / BDRV_SECTOR_SIZE;
1382 fd = qemu_open(filename, O_WRONLY | O_BINARY);
1386 if (fstat(fd, &stat_buf) < 0)
1388 else if (!S_ISBLK(stat_buf.st_mode) && !S_ISCHR(stat_buf.st_mode))
1390 else if (lseek(fd, 0, SEEK_END) < total_size * BDRV_SECTOR_SIZE)
1397 static int hdev_has_zero_init(BlockDriverState *bs)
1402 static BlockDriver bdrv_host_device = {
1403 .format_name = "host_device",
1404 .protocol_name = "host_device",
1405 .instance_size = sizeof(BDRVRawState),
1406 .bdrv_probe_device = hdev_probe_device,
1407 .bdrv_file_open = hdev_open,
1408 .bdrv_close = raw_close,
1409 .bdrv_reopen_prepare = raw_reopen_prepare,
1410 .bdrv_reopen_commit = raw_reopen_commit,
1411 .bdrv_reopen_abort = raw_reopen_abort,
1412 .bdrv_create = hdev_create,
1413 .create_options = raw_create_options,
1414 .bdrv_has_zero_init = hdev_has_zero_init,
1416 .bdrv_aio_readv = raw_aio_readv,
1417 .bdrv_aio_writev = raw_aio_writev,
1418 .bdrv_aio_flush = raw_aio_flush,
1420 .bdrv_truncate = raw_truncate,
1421 .bdrv_getlength = raw_getlength,
1422 .bdrv_get_allocated_file_size
1423 = raw_get_allocated_file_size,
1425 /* generic scsi device */
1427 .bdrv_ioctl = hdev_ioctl,
1428 .bdrv_aio_ioctl = hdev_aio_ioctl,
1433 static int floppy_open(BlockDriverState *bs, const char *filename, int flags)
1435 BDRVRawState *s = bs->opaque;
1440 /* open will not fail even if no floppy is inserted, so add O_NONBLOCK */
1441 ret = raw_open_common(bs, filename, flags, O_NONBLOCK);
1445 /* close fd so that we can reopen it as needed */
1448 s->fd_media_changed = 1;
1453 static int floppy_probe_device(const char *filename)
1457 struct floppy_struct fdparam;
1460 if (strstart(filename, "/dev/fd", NULL) &&
1461 !strstart(filename, "/dev/fdset/", NULL)) {
1465 fd = qemu_open(filename, O_RDONLY | O_NONBLOCK);
1469 ret = fstat(fd, &st);
1470 if (ret == -1 || !S_ISBLK(st.st_mode)) {
1474 /* Attempt to detect via a floppy specific ioctl */
1475 ret = ioctl(fd, FDGETPRM, &fdparam);
1486 static int floppy_is_inserted(BlockDriverState *bs)
1488 return fd_open(bs) >= 0;
1491 static int floppy_media_changed(BlockDriverState *bs)
1493 BDRVRawState *s = bs->opaque;
1497 * XXX: we do not have a true media changed indication.
1498 * It does not work if the floppy is changed without trying to read it.
1501 ret = s->fd_media_changed;
1502 s->fd_media_changed = 0;
1504 printf("Floppy changed=%d\n", ret);
1509 static void floppy_eject(BlockDriverState *bs, bool eject_flag)
1511 BDRVRawState *s = bs->opaque;
1518 fd = qemu_open(bs->filename, s->open_flags | O_NONBLOCK);
1520 if (ioctl(fd, FDEJECT, 0) < 0)
1526 static BlockDriver bdrv_host_floppy = {
1527 .format_name = "host_floppy",
1528 .protocol_name = "host_floppy",
1529 .instance_size = sizeof(BDRVRawState),
1530 .bdrv_probe_device = floppy_probe_device,
1531 .bdrv_file_open = floppy_open,
1532 .bdrv_close = raw_close,
1533 .bdrv_reopen_prepare = raw_reopen_prepare,
1534 .bdrv_reopen_commit = raw_reopen_commit,
1535 .bdrv_reopen_abort = raw_reopen_abort,
1536 .bdrv_create = hdev_create,
1537 .create_options = raw_create_options,
1538 .bdrv_has_zero_init = hdev_has_zero_init,
1540 .bdrv_aio_readv = raw_aio_readv,
1541 .bdrv_aio_writev = raw_aio_writev,
1542 .bdrv_aio_flush = raw_aio_flush,
1544 .bdrv_truncate = raw_truncate,
1545 .bdrv_getlength = raw_getlength,
1546 .bdrv_get_allocated_file_size
1547 = raw_get_allocated_file_size,
1549 /* removable device support */
1550 .bdrv_is_inserted = floppy_is_inserted,
1551 .bdrv_media_changed = floppy_media_changed,
1552 .bdrv_eject = floppy_eject,
1555 static int cdrom_open(BlockDriverState *bs, const char *filename, int flags)
1557 BDRVRawState *s = bs->opaque;
1561 /* open will not fail even if no CD is inserted, so add O_NONBLOCK */
1562 return raw_open_common(bs, filename, flags, O_NONBLOCK);
1565 static int cdrom_probe_device(const char *filename)
1571 fd = qemu_open(filename, O_RDONLY | O_NONBLOCK);
1575 ret = fstat(fd, &st);
1576 if (ret == -1 || !S_ISBLK(st.st_mode)) {
1580 /* Attempt to detect via a CDROM specific ioctl */
1581 ret = ioctl(fd, CDROM_DRIVE_STATUS, CDSL_CURRENT);
1591 static int cdrom_is_inserted(BlockDriverState *bs)
1593 BDRVRawState *s = bs->opaque;
1596 ret = ioctl(s->fd, CDROM_DRIVE_STATUS, CDSL_CURRENT);
1597 if (ret == CDS_DISC_OK)
1602 static void cdrom_eject(BlockDriverState *bs, bool eject_flag)
1604 BDRVRawState *s = bs->opaque;
1607 if (ioctl(s->fd, CDROMEJECT, NULL) < 0)
1608 perror("CDROMEJECT");
1610 if (ioctl(s->fd, CDROMCLOSETRAY, NULL) < 0)
1611 perror("CDROMEJECT");
1615 static void cdrom_lock_medium(BlockDriverState *bs, bool locked)
1617 BDRVRawState *s = bs->opaque;
1619 if (ioctl(s->fd, CDROM_LOCKDOOR, locked) < 0) {
1621 * Note: an error can happen if the distribution automatically
1624 /* perror("CDROM_LOCKDOOR"); */
1628 static BlockDriver bdrv_host_cdrom = {
1629 .format_name = "host_cdrom",
1630 .protocol_name = "host_cdrom",
1631 .instance_size = sizeof(BDRVRawState),
1632 .bdrv_probe_device = cdrom_probe_device,
1633 .bdrv_file_open = cdrom_open,
1634 .bdrv_close = raw_close,
1635 .bdrv_reopen_prepare = raw_reopen_prepare,
1636 .bdrv_reopen_commit = raw_reopen_commit,
1637 .bdrv_reopen_abort = raw_reopen_abort,
1638 .bdrv_create = hdev_create,
1639 .create_options = raw_create_options,
1640 .bdrv_has_zero_init = hdev_has_zero_init,
1642 .bdrv_aio_readv = raw_aio_readv,
1643 .bdrv_aio_writev = raw_aio_writev,
1644 .bdrv_aio_flush = raw_aio_flush,
1646 .bdrv_truncate = raw_truncate,
1647 .bdrv_getlength = raw_getlength,
1648 .bdrv_get_allocated_file_size
1649 = raw_get_allocated_file_size,
1651 /* removable device support */
1652 .bdrv_is_inserted = cdrom_is_inserted,
1653 .bdrv_eject = cdrom_eject,
1654 .bdrv_lock_medium = cdrom_lock_medium,
1656 /* generic scsi device */
1657 .bdrv_ioctl = hdev_ioctl,
1658 .bdrv_aio_ioctl = hdev_aio_ioctl,
1660 #endif /* __linux__ */
1662 #if defined (__FreeBSD__) || defined(__FreeBSD_kernel__)
1663 static int cdrom_open(BlockDriverState *bs, const char *filename, int flags)
1665 BDRVRawState *s = bs->opaque;
1670 ret = raw_open_common(bs, filename, flags, 0);
1674 /* make sure the door isn't locked at this time */
1675 ioctl(s->fd, CDIOCALLOW);
1679 static int cdrom_probe_device(const char *filename)
1681 if (strstart(filename, "/dev/cd", NULL) ||
1682 strstart(filename, "/dev/acd", NULL))
1687 static int cdrom_reopen(BlockDriverState *bs)
1689 BDRVRawState *s = bs->opaque;
1693 * Force reread of possibly changed/newly loaded disc,
1694 * FreeBSD seems to not notice sometimes...
1698 fd = qemu_open(bs->filename, s->open_flags, 0644);
1705 /* make sure the door isn't locked at this time */
1706 ioctl(s->fd, CDIOCALLOW);
1710 static int cdrom_is_inserted(BlockDriverState *bs)
1712 return raw_getlength(bs) > 0;
1715 static void cdrom_eject(BlockDriverState *bs, bool eject_flag)
1717 BDRVRawState *s = bs->opaque;
1722 (void) ioctl(s->fd, CDIOCALLOW);
1725 if (ioctl(s->fd, CDIOCEJECT) < 0)
1726 perror("CDIOCEJECT");
1728 if (ioctl(s->fd, CDIOCCLOSE) < 0)
1729 perror("CDIOCCLOSE");
1735 static void cdrom_lock_medium(BlockDriverState *bs, bool locked)
1737 BDRVRawState *s = bs->opaque;
1741 if (ioctl(s->fd, (locked ? CDIOCPREVENT : CDIOCALLOW)) < 0) {
1743 * Note: an error can happen if the distribution automatically
1746 /* perror("CDROM_LOCKDOOR"); */
1750 static BlockDriver bdrv_host_cdrom = {
1751 .format_name = "host_cdrom",
1752 .protocol_name = "host_cdrom",
1753 .instance_size = sizeof(BDRVRawState),
1754 .bdrv_probe_device = cdrom_probe_device,
1755 .bdrv_file_open = cdrom_open,
1756 .bdrv_close = raw_close,
1757 .bdrv_reopen_prepare = raw_reopen_prepare,
1758 .bdrv_reopen_commit = raw_reopen_commit,
1759 .bdrv_reopen_abort = raw_reopen_abort,
1760 .bdrv_create = hdev_create,
1761 .create_options = raw_create_options,
1762 .bdrv_has_zero_init = hdev_has_zero_init,
1764 .bdrv_aio_readv = raw_aio_readv,
1765 .bdrv_aio_writev = raw_aio_writev,
1766 .bdrv_aio_flush = raw_aio_flush,
1768 .bdrv_truncate = raw_truncate,
1769 .bdrv_getlength = raw_getlength,
1770 .bdrv_get_allocated_file_size
1771 = raw_get_allocated_file_size,
1773 /* removable device support */
1774 .bdrv_is_inserted = cdrom_is_inserted,
1775 .bdrv_eject = cdrom_eject,
1776 .bdrv_lock_medium = cdrom_lock_medium,
1778 #endif /* __FreeBSD__ */
1780 static void bdrv_file_init(void)
1783 * Register all the drivers. Note that order is important, the driver
1784 * registered last will get probed first.
1786 bdrv_register(&bdrv_file);
1787 bdrv_register(&bdrv_host_device);
1789 bdrv_register(&bdrv_host_floppy);
1790 bdrv_register(&bdrv_host_cdrom);
1792 #if defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
1793 bdrv_register(&bdrv_host_cdrom);
1797 block_init(bdrv_file_init);