2 * Block driver for RAW files (win32)
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 "block/block_int.h"
27 #include "qemu/module.h"
30 #include "block/thread-pool.h"
37 #define FTYPE_HARDDISK 2
39 static QEMUWin32AIOState
*aio
;
41 typedef struct RawWin32AIOData
{
44 struct iovec
*aio_iov
;
51 typedef struct BDRVRawState
{
54 char drive_path
[16]; /* format: "d:\" */
55 QEMUWin32AIOState
*aio
;
59 * Read/writes the data to/from a given linear buffer.
61 * Returns the number of bytes handles or -errno in case of an error. Short
62 * reads are only returned if the end of the file is reached.
64 static size_t handle_aiocb_rw(RawWin32AIOData
*aiocb
)
69 for (i
= 0; i
< aiocb
->aio_niov
; i
++) {
71 DWORD ret
, ret_count
, len
;
73 memset(&ov
, 0, sizeof(ov
));
74 ov
.Offset
= (aiocb
->aio_offset
+ offset
);
75 ov
.OffsetHigh
= (aiocb
->aio_offset
+ offset
) >> 32;
76 len
= aiocb
->aio_iov
[i
].iov_len
;
77 if (aiocb
->aio_type
& QEMU_AIO_WRITE
) {
78 ret
= WriteFile(aiocb
->hfile
, aiocb
->aio_iov
[i
].iov_base
,
79 len
, &ret_count
, &ov
);
81 ret
= ReadFile(aiocb
->hfile
, aiocb
->aio_iov
[i
].iov_base
,
82 len
, &ret_count
, &ov
);
87 if (ret_count
!= len
) {
97 static int aio_worker(void *arg
)
99 RawWin32AIOData
*aiocb
= arg
;
103 switch (aiocb
->aio_type
& QEMU_AIO_TYPE_MASK
) {
105 count
= handle_aiocb_rw(aiocb
);
106 if (count
< aiocb
->aio_nbytes
&& aiocb
->bs
->growable
) {
107 /* A short read means that we have reached EOF. Pad the buffer
108 * with zeros for bytes after EOF. */
109 iov_memset(aiocb
->aio_iov
, aiocb
->aio_niov
, count
,
110 0, aiocb
->aio_nbytes
- count
);
112 count
= aiocb
->aio_nbytes
;
114 if (count
== aiocb
->aio_nbytes
) {
121 count
= handle_aiocb_rw(aiocb
);
122 if (count
== aiocb
->aio_nbytes
) {
129 if (!FlushFileBuffers(aiocb
->hfile
)) {
134 fprintf(stderr
, "invalid aio request (0x%x)\n", aiocb
->aio_type
);
139 g_slice_free(RawWin32AIOData
, aiocb
);
143 static BlockDriverAIOCB
*paio_submit(BlockDriverState
*bs
, HANDLE hfile
,
144 int64_t sector_num
, QEMUIOVector
*qiov
, int nb_sectors
,
145 BlockDriverCompletionFunc
*cb
, void *opaque
, int type
)
147 RawWin32AIOData
*acb
= g_slice_new(RawWin32AIOData
);
152 acb
->aio_type
= type
;
155 acb
->aio_iov
= qiov
->iov
;
156 acb
->aio_niov
= qiov
->niov
;
158 acb
->aio_nbytes
= nb_sectors
* 512;
159 acb
->aio_offset
= sector_num
* 512;
161 trace_paio_submit(acb
, opaque
, sector_num
, nb_sectors
, type
);
162 pool
= aio_get_thread_pool(bdrv_get_aio_context(bs
));
163 return thread_pool_submit_aio(pool
, aio_worker
, acb
, cb
, opaque
);
166 int qemu_ftruncate64(int fd
, int64_t length
)
174 if ((GetVersion() & 0x80000000UL
) && (length
>> 32) != 0)
177 h
= (HANDLE
)_get_osfhandle(fd
);
179 /* get current position, ftruncate do not change position */
181 li
.LowPart
= SetFilePointer (h
, 0, &li
.HighPart
, FILE_CURRENT
);
182 if (li
.LowPart
== INVALID_SET_FILE_POINTER
&& GetLastError() != NO_ERROR
) {
187 dw
= SetFilePointer(h
, (DWORD
) length
, &high
, FILE_BEGIN
);
188 if (dw
== INVALID_SET_FILE_POINTER
&& GetLastError() != NO_ERROR
) {
191 res
= SetEndOfFile(h
);
193 /* back to old position */
194 SetFilePointer(h
, li
.LowPart
, &li
.HighPart
, FILE_BEGIN
);
198 static int set_sparse(int fd
)
201 return (int) DeviceIoControl((HANDLE
)_get_osfhandle(fd
), FSCTL_SET_SPARSE
,
202 NULL
, 0, NULL
, 0, &returned
, NULL
);
205 static void raw_probe_alignment(BlockDriverState
*bs
)
207 BDRVRawState
*s
= bs
->opaque
;
208 DWORD sectorsPerCluster
, freeClusters
, totalClusters
, count
;
212 if (s
->type
== FTYPE_CD
) {
213 bs
->request_alignment
= 2048;
216 if (s
->type
== FTYPE_HARDDISK
) {
217 status
= DeviceIoControl(s
->hfile
, IOCTL_DISK_GET_DRIVE_GEOMETRY_EX
,
218 NULL
, 0, &dg
, sizeof(dg
), &count
, NULL
);
220 bs
->request_alignment
= dg
.Geometry
.BytesPerSector
;
223 /* try GetDiskFreeSpace too */
226 if (s
->drive_path
[0]) {
227 GetDiskFreeSpace(s
->drive_path
, §orsPerCluster
,
228 &dg
.Geometry
.BytesPerSector
,
229 &freeClusters
, &totalClusters
);
230 bs
->request_alignment
= dg
.Geometry
.BytesPerSector
;
234 static void raw_parse_flags(int flags
, int *access_flags
, DWORD
*overlapped
)
236 assert(access_flags
!= NULL
);
237 assert(overlapped
!= NULL
);
239 if (flags
& BDRV_O_RDWR
) {
240 *access_flags
= GENERIC_READ
| GENERIC_WRITE
;
242 *access_flags
= GENERIC_READ
;
245 *overlapped
= FILE_ATTRIBUTE_NORMAL
;
246 if (flags
& BDRV_O_NATIVE_AIO
) {
247 *overlapped
|= FILE_FLAG_OVERLAPPED
;
249 if (flags
& BDRV_O_NOCACHE
) {
250 *overlapped
|= FILE_FLAG_NO_BUFFERING
;
254 static QemuOptsList raw_runtime_opts
= {
256 .head
= QTAILQ_HEAD_INITIALIZER(raw_runtime_opts
.head
),
260 .type
= QEMU_OPT_STRING
,
261 .help
= "File name of the image",
263 { /* end of list */ }
267 static int raw_open(BlockDriverState
*bs
, QDict
*options
, int flags
,
270 BDRVRawState
*s
= bs
->opaque
;
274 Error
*local_err
= NULL
;
275 const char *filename
;
278 s
->type
= FTYPE_FILE
;
280 opts
= qemu_opts_create(&raw_runtime_opts
, NULL
, 0, &error_abort
);
281 qemu_opts_absorb_qdict(opts
, options
, &local_err
);
282 if (error_is_set(&local_err
)) {
283 error_propagate(errp
, local_err
);
288 filename
= qemu_opt_get(opts
, "filename");
290 raw_parse_flags(flags
, &access_flags
, &overlapped
);
292 if ((flags
& BDRV_O_NATIVE_AIO
) && aio
== NULL
) {
293 aio
= win32_aio_init();
295 error_setg(errp
, "Could not initialize AIO");
301 if (filename
[0] && filename
[1] == ':') {
302 snprintf(s
->drive_path
, sizeof(s
->drive_path
), "%c:\\", filename
[0]);
303 } else if (filename
[0] == '\\' && filename
[1] == '\\') {
304 s
->drive_path
[0] = 0;
308 GetCurrentDirectory(MAX_PATH
, buf
);
309 snprintf(s
->drive_path
, sizeof(s
->drive_path
), "%c:\\", buf
[0]);
312 s
->hfile
= CreateFile(filename
, access_flags
,
313 FILE_SHARE_READ
, NULL
,
314 OPEN_EXISTING
, overlapped
, NULL
);
315 if (s
->hfile
== INVALID_HANDLE_VALUE
) {
316 int err
= GetLastError();
318 if (err
== ERROR_ACCESS_DENIED
) {
326 if (flags
& BDRV_O_NATIVE_AIO
) {
327 ret
= win32_aio_attach(aio
, s
->hfile
);
329 CloseHandle(s
->hfile
);
330 error_setg_errno(errp
, -ret
, "Could not enable AIO");
336 raw_probe_alignment(bs
);
343 static BlockDriverAIOCB
*raw_aio_readv(BlockDriverState
*bs
,
344 int64_t sector_num
, QEMUIOVector
*qiov
, int nb_sectors
,
345 BlockDriverCompletionFunc
*cb
, void *opaque
)
347 BDRVRawState
*s
= bs
->opaque
;
349 return win32_aio_submit(bs
, s
->aio
, s
->hfile
, sector_num
, qiov
,
350 nb_sectors
, cb
, opaque
, QEMU_AIO_READ
);
352 return paio_submit(bs
, s
->hfile
, sector_num
, qiov
, nb_sectors
,
353 cb
, opaque
, QEMU_AIO_READ
);
357 static BlockDriverAIOCB
*raw_aio_writev(BlockDriverState
*bs
,
358 int64_t sector_num
, QEMUIOVector
*qiov
, int nb_sectors
,
359 BlockDriverCompletionFunc
*cb
, void *opaque
)
361 BDRVRawState
*s
= bs
->opaque
;
363 return win32_aio_submit(bs
, s
->aio
, s
->hfile
, sector_num
, qiov
,
364 nb_sectors
, cb
, opaque
, QEMU_AIO_WRITE
);
366 return paio_submit(bs
, s
->hfile
, sector_num
, qiov
, nb_sectors
,
367 cb
, opaque
, QEMU_AIO_WRITE
);
371 static BlockDriverAIOCB
*raw_aio_flush(BlockDriverState
*bs
,
372 BlockDriverCompletionFunc
*cb
, void *opaque
)
374 BDRVRawState
*s
= bs
->opaque
;
375 return paio_submit(bs
, s
->hfile
, 0, NULL
, 0, cb
, opaque
, QEMU_AIO_FLUSH
);
378 static void raw_close(BlockDriverState
*bs
)
380 BDRVRawState
*s
= bs
->opaque
;
381 CloseHandle(s
->hfile
);
384 static int raw_truncate(BlockDriverState
*bs
, int64_t offset
)
386 BDRVRawState
*s
= bs
->opaque
;
394 * An error has occurred if the return value is INVALID_SET_FILE_POINTER
395 * and GetLastError doesn't return NO_ERROR.
397 dwPtrLow
= SetFilePointer(s
->hfile
, low
, &high
, FILE_BEGIN
);
398 if (dwPtrLow
== INVALID_SET_FILE_POINTER
&& GetLastError() != NO_ERROR
) {
399 fprintf(stderr
, "SetFilePointer error: %lu\n", GetLastError());
402 if (SetEndOfFile(s
->hfile
) == 0) {
403 fprintf(stderr
, "SetEndOfFile error: %lu\n", GetLastError());
409 static int64_t raw_getlength(BlockDriverState
*bs
)
411 BDRVRawState
*s
= bs
->opaque
;
413 ULARGE_INTEGER available
, total
, total_free
;
420 l
.LowPart
= GetFileSize(s
->hfile
, (PDWORD
)&l
.HighPart
);
421 if (l
.LowPart
== 0xffffffffUL
&& GetLastError() != NO_ERROR
)
425 if (!GetDiskFreeSpaceEx(s
->drive_path
, &available
, &total
, &total_free
))
427 l
.QuadPart
= total
.QuadPart
;
430 status
= DeviceIoControl(s
->hfile
, IOCTL_DISK_GET_DRIVE_GEOMETRY_EX
,
431 NULL
, 0, &dg
, sizeof(dg
), &count
, NULL
);
442 static int64_t raw_get_allocated_file_size(BlockDriverState
*bs
)
444 typedef DWORD (WINAPI
* get_compressed_t
)(const char *filename
,
446 get_compressed_t get_compressed
;
448 const char *filename
= bs
->filename
;
449 /* WinNT support GetCompressedFileSize to determine allocate size */
451 (get_compressed_t
) GetProcAddress(GetModuleHandle("kernel32"),
452 "GetCompressedFileSizeA");
453 if (get_compressed
) {
455 low
= get_compressed(filename
, &high
);
456 if (low
!= 0xFFFFFFFFlu
|| GetLastError() == NO_ERROR
) {
457 return (((int64_t) high
) << 32) + low
;
461 if (_stati64(filename
, &st
) < 0) {
467 static int raw_create(const char *filename
, QEMUOptionParameter
*options
,
471 int64_t total_size
= 0;
473 /* Read out options */
474 while (options
&& options
->name
) {
475 if (!strcmp(options
->name
, BLOCK_OPT_SIZE
)) {
476 total_size
= options
->value
.n
/ 512;
481 fd
= qemu_open(filename
, O_WRONLY
| O_CREAT
| O_TRUNC
| O_BINARY
,
484 error_setg_errno(errp
, errno
, "Could not create file");
488 ftruncate(fd
, total_size
* 512);
493 static QEMUOptionParameter raw_create_options
[] = {
495 .name
= BLOCK_OPT_SIZE
,
497 .help
= "Virtual disk size"
502 static BlockDriver bdrv_file
= {
503 .format_name
= "file",
504 .protocol_name
= "file",
505 .instance_size
= sizeof(BDRVRawState
),
506 .bdrv_needs_filename
= true,
507 .bdrv_file_open
= raw_open
,
508 .bdrv_close
= raw_close
,
509 .bdrv_create
= raw_create
,
510 .bdrv_has_zero_init
= bdrv_has_zero_init_1
,
512 .bdrv_aio_readv
= raw_aio_readv
,
513 .bdrv_aio_writev
= raw_aio_writev
,
514 .bdrv_aio_flush
= raw_aio_flush
,
516 .bdrv_truncate
= raw_truncate
,
517 .bdrv_getlength
= raw_getlength
,
518 .bdrv_get_allocated_file_size
519 = raw_get_allocated_file_size
,
521 .create_options
= raw_create_options
,
524 /***********************************************/
527 static int find_cdrom(char *cdrom_name
, int cdrom_name_size
)
529 char drives
[256], *pdrv
= drives
;
532 memset(drives
, 0, sizeof(drives
));
533 GetLogicalDriveStrings(sizeof(drives
), drives
);
534 while(pdrv
[0] != '\0') {
535 type
= GetDriveType(pdrv
);
538 snprintf(cdrom_name
, cdrom_name_size
, "\\\\.\\%c:", pdrv
[0]);
542 pdrv
+= lstrlen(pdrv
) + 1;
547 static int find_device_type(BlockDriverState
*bs
, const char *filename
)
549 BDRVRawState
*s
= bs
->opaque
;
553 if (strstart(filename
, "\\\\.\\", &p
) ||
554 strstart(filename
, "//./", &p
)) {
555 if (stristart(p
, "PhysicalDrive", NULL
))
556 return FTYPE_HARDDISK
;
557 snprintf(s
->drive_path
, sizeof(s
->drive_path
), "%c:\\", p
[0]);
558 type
= GetDriveType(s
->drive_path
);
560 case DRIVE_REMOVABLE
:
562 return FTYPE_HARDDISK
;
573 static int hdev_probe_device(const char *filename
)
575 if (strstart(filename
, "/dev/cdrom", NULL
))
577 if (is_windows_drive(filename
))
582 static int hdev_open(BlockDriverState
*bs
, QDict
*options
, int flags
,
585 BDRVRawState
*s
= bs
->opaque
;
586 int access_flags
, create_flags
;
589 char device_name
[64];
591 Error
*local_err
= NULL
;
592 const char *filename
;
594 QemuOpts
*opts
= qemu_opts_create(&raw_runtime_opts
, NULL
, 0,
596 qemu_opts_absorb_qdict(opts
, options
, &local_err
);
597 if (error_is_set(&local_err
)) {
598 error_propagate(errp
, local_err
);
603 filename
= qemu_opt_get(opts
, "filename");
605 if (strstart(filename
, "/dev/cdrom", NULL
)) {
606 if (find_cdrom(device_name
, sizeof(device_name
)) < 0) {
607 error_setg(errp
, "Could not open CD-ROM drive");
611 filename
= device_name
;
613 /* transform drive letters into device name */
614 if (((filename
[0] >= 'a' && filename
[0] <= 'z') ||
615 (filename
[0] >= 'A' && filename
[0] <= 'Z')) &&
616 filename
[1] == ':' && filename
[2] == '\0') {
617 snprintf(device_name
, sizeof(device_name
), "\\\\.\\%c:", filename
[0]);
618 filename
= device_name
;
621 s
->type
= find_device_type(bs
, filename
);
623 raw_parse_flags(flags
, &access_flags
, &overlapped
);
625 create_flags
= OPEN_EXISTING
;
627 s
->hfile
= CreateFile(filename
, access_flags
,
628 FILE_SHARE_READ
, NULL
,
629 create_flags
, overlapped
, NULL
);
630 if (s
->hfile
== INVALID_HANDLE_VALUE
) {
631 int err
= GetLastError();
633 if (err
== ERROR_ACCESS_DENIED
) {
638 error_setg_errno(errp
, -ret
, "Could not open device");
647 static BlockDriver bdrv_host_device
= {
648 .format_name
= "host_device",
649 .protocol_name
= "host_device",
650 .instance_size
= sizeof(BDRVRawState
),
651 .bdrv_needs_filename
= true,
652 .bdrv_probe_device
= hdev_probe_device
,
653 .bdrv_file_open
= hdev_open
,
654 .bdrv_close
= raw_close
,
656 .bdrv_aio_readv
= raw_aio_readv
,
657 .bdrv_aio_writev
= raw_aio_writev
,
658 .bdrv_aio_flush
= raw_aio_flush
,
660 .bdrv_getlength
= raw_getlength
,
661 .has_variable_length
= true,
663 .bdrv_get_allocated_file_size
664 = raw_get_allocated_file_size
,
667 static void bdrv_file_init(void)
669 bdrv_register(&bdrv_file
);
670 bdrv_register(&bdrv_host_device
);
673 block_init(bdrv_file_init
);