Annotation of embedaddon/istgt/src/istgt_lu_disk_vbox.c, revision 1.1.1.1
1.1 misho 1: /*
2: * Copyright (C) 2008-2012 Daisuke Aoyama <aoyama@peach.ne.jp>.
3: * All rights reserved.
4: *
5: * Redistribution and use in source and binary forms, with or without
6: * modification, are permitted provided that the following conditions
7: * are met:
8: * 1. Redistributions of source code must retain the above copyright
9: * notice, this list of conditions and the following disclaimer.
10: * 2. Redistributions in binary form must reproduce the above copyright
11: * notice, this list of conditions and the following disclaimer in the
12: * documentation and/or other materials provided with the distribution.
13: *
14: * THIS SOFTWARE IS PROVIDED BY AUTHOR AND CONTRIBUTORS ``AS IS'' AND
15: * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
16: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
17: * ARE DISCLAIMED. IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
18: * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
19: * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
20: * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
21: * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
22: * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
23: * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
24: * SUCH DAMAGE.
25: *
26: */
27:
28: #ifdef HAVE_CONFIG_H
29: #include "config.h"
30: #endif
31:
32: #include <inttypes.h>
33: #include <stdint.h>
34:
35: #include <errno.h>
36: #include <stdarg.h>
37: #include <stdio.h>
38: #include <string.h>
39: #include <pthread.h>
40:
41: #include <fcntl.h>
42: #include <unistd.h>
43:
44: #include "istgt.h"
45: #include "istgt_log.h"
46: #include "istgt_misc.h"
47: #include "istgt_lu.h"
48: #include "istgt_proto.h"
49:
50: #if !defined(__GNUC__)
51: #undef __attribute__
52: #define __attribute__(x)
53: #endif
54:
55: #ifdef USE_VBOXVD
56: #define IN_RING3
57: #include "iprt/buildconfig.h"
58: #include "VBox/vd.h"
59:
60: typedef struct istgt_lu_disk_vbox_t {
61: PVBOXHDD pDisk;
62: PVDINTERFACE pVDIfs;
63: PVDINTERFACE pVDIfsImage;
64: VDINTERFACE VDIfsDisk;
65: VDINTERFACEERROR VDIfError;
66: VDTYPE enmType;
67: RTUUID uuid;
68: } ISTGT_LU_DISK_VBOX;
69:
70: #ifndef O_ACCMODE
71: #define O_ACCMODE (O_RDONLY|O_WRONLY|O_RDWR)
72: #endif
73:
74: static void istgt_lu_disk_vbox_error(void *pvUser, int rc, const char *pszFile, unsigned iLine, const char *pszFunction, const char *pszFormat, va_list va) __attribute__((__format__(__printf__, 6, 0)));
75:
76: static void istgt_lu_disk_vbox_error(void *pvUser, int rc, const char *pszFile, unsigned iLine, const char *pszFunction, const char *pszFormat, va_list va)
77: {
78: ISTGT_LU_DISK *spec = (ISTGT_LU_DISK*)pvUser;
79: char buf[MAX_TMPBUF*2];
80:
81: vsnprintf(buf, sizeof buf, pszFormat, va);
82: ISTGT_ERRLOG("LU%d: LUN%d: rc=%d, %s:%u:%s: %s", spec->num, spec->lun,
83: rc, pszFile, iLine, pszFunction, buf);
84: }
85:
86: static int
87: istgt_lu_disk_open_vbox(ISTGT_LU_DISK *spec, int flags, int mode __attribute__((__unused__)))
88: {
89: ISTGT_LU_DISK_VBOX *exspec = (ISTGT_LU_DISK_VBOX *)spec->exspec;
90: PVDINTERFACE pIf;
91: uint32_t major, minor, build;
92: unsigned uOpenFlags;
93: int rc;
94:
95: major = RTBldCfgVersionMajor();
96: minor = RTBldCfgVersionMinor();
97: build = RTBldCfgVersionBuild();
98: if (major > 4 || (major == 4 && minor >= 2)) {
99: // VBoxDDU >= 4.2
100: if (ISTGT_VBOXINC_VERSION_MAJOR < 4 ||
101: (ISTGT_VBOXINC_VERSION_MAJOR == 4 && ISTGT_VBOXINC_VERSION_MINOR < 2)) {
102: ISTGT_ERRLOG("VBox library is newer than istgt\n");
103: return -1;
104: }
105: } else {
106: // VBoxDDU < 4.2
107: if (ISTGT_VBOXINC_VERSION_MAJOR > 4 ||
108: (ISTGT_VBOXINC_VERSION_MAJOR == 4 && ISTGT_VBOXINC_VERSION_MINOR >= 2)) {
109: ISTGT_ERRLOG("VBox library is older than istgt\n");
110: return -1;
111: }
112: if (strcasecmp(spec->disktype, "QCOW") == 0
113: || strcasecmp(spec->disktype, "QED") == 0
114: || strcasecmp(spec->disktype, "VHDX") == 0) {
115: ISTGT_ERRLOG("VD format(%s) is not supported in this version.\n",
116: spec->disktype);
117: return -1;
118: }
119: }
120:
121: if ((flags & O_ACCMODE) == O_RDONLY) {
122: uOpenFlags = VD_OPEN_FLAGS_READONLY;
123: } else if ((flags & O_ACCMODE) == O_RDWR) {
124: uOpenFlags = VD_OPEN_FLAGS_NORMAL;
125: } else {
126: ISTGT_ERRLOG("not supported mode %x\n", (flags & O_ACCMODE));
127: return -1;
128: }
129:
130: exspec->pDisk = NULL;
131: exspec->pVDIfs = NULL;
132: exspec->pVDIfsImage = NULL;
133: exspec->enmType = VDTYPE_HDD;
134:
135: #if ((ISTGT_VBOXINC_VERSION_MAJOR > 4) || (ISTGT_VBOXINC_VERSION_MAJOR == 4 && ISTGT_VBOXINC_VERSION_MINOR >= 2))
136: exspec->VDIfError.pfnError = istgt_lu_disk_vbox_error;
137: exspec->VDIfError.pfnMessage = NULL;
138: pIf = (PVDINTERFACE)&exspec->VDIfError;
139:
140: rc = VDInterfaceAdd(pIf, "VD interface error", VDINTERFACETYPE_ERROR,
141: spec, sizeof(VDINTERFACEERROR), &exspec->pVDIfs);
142: #else /* VBox < 4.2 */
143: exspec->VDIfError.cbSize = sizeof(VDINTERFACEERROR);
144: exspec->VDIfError.enmInterface = VDINTERFACETYPE_ERROR;
145: exspec->VDIfError.pfnError = istgt_lu_disk_vbox_error;
146: exspec->VDIfError.pfnMessage = NULL;
147: pIf = &exspec->VDIfsDisk;
148:
149: rc = VDInterfaceAdd(pIf, "VD interface error", VDINTERFACETYPE_ERROR,
150: &exspec->VDIfError, spec, &exspec->pVDIfs);
151: #endif /* VBox >= 4.2 */
152: if (RT_FAILURE(rc)) {
153: ISTGT_ERRLOG("VDInterfaceAdd error\n");
154: return -1;
155: }
156:
157: rc = VDCreate(exspec->pVDIfs, exspec->enmType, &exspec->pDisk);
158: if (RT_FAILURE(rc)) {
159: ISTGT_ERRLOG("VDCreate error\n");
160: VDInterfaceRemove(pIf, &exspec->pVDIfs);
161: exspec->pDisk = NULL;
162: exspec->pVDIfs = NULL;
163: exspec->pVDIfsImage = NULL;
164: return -1;
165: }
166: rc = VDOpen(exspec->pDisk, spec->disktype, spec->file, uOpenFlags,
167: exspec->pVDIfsImage);
168: if (RT_FAILURE(rc)) {
169: ISTGT_ERRLOG("VDOpen error\n");
170: VDDestroy(exspec->pDisk);
171: VDInterfaceRemove(pIf, &exspec->pVDIfs);
172: exspec->pDisk = NULL;
173: exspec->pVDIfs = NULL;
174: exspec->pVDIfsImage = NULL;
175: return -1;
176: }
177: return 0;
178: }
179:
180: static int
181: istgt_lu_disk_close_vbox(ISTGT_LU_DISK *spec)
182: {
183: ISTGT_LU_DISK_VBOX *exspec = (ISTGT_LU_DISK_VBOX *)spec->exspec;
184: PVDINTERFACE pIf;
185: bool fDelete = false;
186: int rc;
187:
188: #if ((ISTGT_VBOXINC_VERSION_MAJOR > 4) || (ISTGT_VBOXINC_VERSION_MAJOR == 4 && ISTGT_VBOXINC_VERSION_MINOR >= 2))
189: pIf = (PVDINTERFACE)&exspec->VDIfError;
190: #else /* VBox < 4.2 */
191: pIf = &exspec->VDIfsDisk;
192: #endif /* VBox >= 4.2 */
193: rc = VDClose(exspec->pDisk, fDelete);
194: if (RT_FAILURE(rc)) {
195: ISTGT_ERRLOG("VDClose error\n");
196: VDDestroy(exspec->pDisk);
197: VDInterfaceRemove(pIf, &exspec->pVDIfs);
198: exspec->pDisk = NULL;
199: exspec->pVDIfs = NULL;
200: exspec->pVDIfsImage = NULL;
201: return -1;
202: }
203: VDDestroy(exspec->pDisk);
204: VDInterfaceRemove(pIf, &exspec->pVDIfs);
205: exspec->pDisk = NULL;
206: exspec->pVDIfs = NULL;
207: exspec->pVDIfsImage = NULL;
208: return 0;
209: }
210:
211: static int64_t
212: istgt_lu_disk_seek_vbox(ISTGT_LU_DISK *spec, uint64_t offset)
213: {
214: //ISTGT_LU_DISK_VBOX *exspec = (ISTGT_LU_DISK_VBOX *)spec->exspec;
215:
216: spec->foffset = offset;
217: return 0;
218: }
219:
220: static int64_t
221: istgt_lu_disk_read_vbox(ISTGT_LU_DISK *spec, void *buf, uint64_t nbytes)
222: {
223: ISTGT_LU_DISK_VBOX *exspec = (ISTGT_LU_DISK_VBOX *)spec->exspec;
224: uint64_t offset;
225: int rc;
226:
227: offset = spec->foffset;
228: rc = VDRead(exspec->pDisk, offset, buf, (size_t)nbytes);
229: if (RT_FAILURE(rc)) {
230: ISTGT_ERRLOG("VDRead error\n");
231: return -1;
232: }
233: spec->foffset += nbytes;
234: return (int64_t)nbytes;
235: }
236:
237: static int64_t
238: istgt_lu_disk_write_vbox(ISTGT_LU_DISK *spec, const void *buf, uint64_t nbytes)
239: {
240: ISTGT_LU_DISK_VBOX *exspec = (ISTGT_LU_DISK_VBOX *)spec->exspec;
241: uint64_t offset;
242: int rc;
243:
244: offset = spec->foffset;
245: rc = VDWrite(exspec->pDisk, offset, buf, (size_t)nbytes);
246: if (RT_FAILURE(rc)) {
247: ISTGT_ERRLOG("VDWrite error\n");
248: return -1;
249: }
250: spec->foffset += nbytes;
251: return (int64_t)nbytes;
252: }
253:
254: static int64_t
255: istgt_lu_disk_sync_vbox(ISTGT_LU_DISK *spec, uint64_t offset __attribute__((__unused__)), uint64_t nbytes __attribute__((__unused__)))
256: {
257: ISTGT_LU_DISK_VBOX *exspec = (ISTGT_LU_DISK_VBOX *)spec->exspec;
258: int rc;
259:
260: rc = VDFlush(exspec->pDisk);
261: if (RT_FAILURE(rc)) {
262: ISTGT_ERRLOG("VDFlush error\n");
263: return -1;
264: }
265: return 0;
266: }
267:
268: static int
269: istgt_lu_disk_allocate_vbox(ISTGT_LU_DISK *spec __attribute__((__unused__)))
270: {
271: //ISTGT_LU_DISK_VBOX *exspec = (ISTGT_LU_DISK_VBOX *)spec->exspec;
272:
273: return 0;
274: }
275:
276: static int
277: istgt_lu_disk_setcache_vbox(ISTGT_LU_DISK *spec)
278: {
279: //ISTGT_LU_DISK_VBOX *exspec = (ISTGT_LU_DISK_VBOX *)spec->exspec;
280:
281: if (spec->read_cache) {
282: }
283: if (spec->write_cache) {
284: }
285: return 0;
286: }
287:
288: int
289: istgt_lu_disk_vbox_lun_init(ISTGT_LU_DISK *spec, ISTGT_Ptr istgt __attribute__((__unused__)), ISTGT_LU_Ptr lu)
290: {
291: ISTGT_LU_DISK_VBOX *exspec;
292: uint64_t capacity;
293: uint64_t fsize;
294: int flags;
295: int rc;
296:
297: ISTGT_TRACELOG(ISTGT_TRACE_DEBUG, "istgt_lu_disk_vbox_lun_init\n");
298:
299: ISTGT_TRACELOG(ISTGT_TRACE_DEBUG, "LU%d: LUN%d for disktype=%s\n",
300: spec->num, spec->lun, spec->disktype);
301:
302: spec->open = istgt_lu_disk_open_vbox;
303: spec->close = istgt_lu_disk_close_vbox;
304: spec->seek = istgt_lu_disk_seek_vbox;
305: spec->read = istgt_lu_disk_read_vbox;
306: spec->write = istgt_lu_disk_write_vbox;
307: spec->sync = istgt_lu_disk_sync_vbox;
308: spec->allocate = istgt_lu_disk_allocate_vbox;
309: spec->setcache = istgt_lu_disk_setcache_vbox;
310:
311: exspec = xmalloc(sizeof *exspec);
312: memset(exspec, 0, sizeof *exspec);
313: spec->exspec = exspec;
314:
315: flags = lu->readonly ? O_RDONLY : O_RDWR;
316: rc = spec->open(spec, flags, 0666);
317: if (rc < 0) {
318: ISTGT_ERRLOG("LU%d: LUN%d: open error(rc=%d)\n",
319: spec->num, spec->lun, rc);
320: return -1;
321: }
322:
323: capacity = VDGetSize(exspec->pDisk, 0);
324: fsize = VDGetFileSize(exspec->pDisk, 0);
325:
326: spec->size = capacity;
327: spec->blocklen = 512;
328: spec->blockcnt = spec->size / spec->blocklen;
329: if (spec->blockcnt == 0) {
330: ISTGT_ERRLOG("LU%d: LUN%d: size zero\n", spec->num, spec->lun);
331: spec->close(spec);
332: return -1;
333: }
334:
335: #if 0
336: ISTGT_TRACELOG(ISTGT_TRACE_DEBUG,
337: "LU%d: LUN%d file=%s, size=%"PRIu64"\n",
338: spec->num, spec->lun, spec->file, spec->size);
339: ISTGT_TRACELOG(ISTGT_TRACE_DEBUG,
340: "LU%d: LUN%d %"PRIu64" blocks, %"
341: PRIu64" bytes/block\n",
342: spec->num, spec->lun, spec->blockcnt, spec->blocklen);
343: #endif
344:
345: printf("LU%d: LUN%d file=%s, size=%"PRIu64"\n",
346: spec->num, spec->lun, spec->file, spec->size);
347: printf("LU%d: LUN%d %"PRIu64" blocks, %"PRIu64" bytes/block\n",
348: spec->num, spec->lun, spec->blockcnt, spec->blocklen);
349:
350: if (strcasecmp(spec->disktype, "VDI") == 0
351: || strcasecmp(spec->disktype, "VHD") == 0
352: || strcasecmp(spec->disktype, "VMDK") == 0) {
353: rc = VDGetUuid(exspec->pDisk, 0, &exspec->uuid);
354: if (RT_FAILURE(rc)) {
355: ISTGT_ERRLOG("LU%d: LUN%d: uuid error\n", spec->num, spec->lun);
356: spec->close(spec);
357: return -1;
358: }
359: printf("LU%d: LUN%d UUID="
360: "%8.8x-%4.4x-%4.4x-%2.2x%2.2x-%2.2x%2.2x%2.2x%2.2x%2.2x%2.2x\n",
361: spec->num, spec->lun,
362: exspec->uuid.Gen.u32TimeLow,
363: exspec->uuid.Gen.u16TimeMid,
364: exspec->uuid.Gen.u16TimeHiAndVersion,
365: exspec->uuid.Gen.u8ClockSeqHiAndReserved,
366: exspec->uuid.Gen.u8ClockSeqLow,
367: exspec->uuid.Gen.au8Node[0],
368: exspec->uuid.Gen.au8Node[1],
369: exspec->uuid.Gen.au8Node[2],
370: exspec->uuid.Gen.au8Node[3],
371: exspec->uuid.Gen.au8Node[4],
372: exspec->uuid.Gen.au8Node[5]);
373: }
374: return 0;
375: }
376:
377: int
378: istgt_lu_disk_vbox_lun_shutdown(ISTGT_LU_DISK *spec, ISTGT_Ptr istgt __attribute__((__unused__)), ISTGT_LU_Ptr lu __attribute__((__unused__)))
379: {
380: ISTGT_LU_DISK_VBOX *exspec = (ISTGT_LU_DISK_VBOX *)spec->exspec;
381: int rc;
382:
383: ISTGT_TRACELOG(ISTGT_TRACE_DEBUG, "istgt_lu_disk_vbox_lun_shutdown\n");
384:
385: ISTGT_TRACELOG(ISTGT_TRACE_DEBUG, "LU%d: LUN%d for disktype=%s\n",
386: spec->num, spec->lun, spec->disktype);
387:
388: if (!spec->lu->readonly) {
389: rc = spec->sync(spec, 0, spec->size);
390: if (rc < 0) {
391: //ISTGT_ERRLOG("LU%d: lu_disk_sync() failed\n", lu->num);
392: /* ignore error */
393: }
394: }
395: rc = spec->close(spec);
396: if (rc < 0) {
397: //ISTGT_ERRLOG("LU%d: lu_disk_close() failed\n", lu->num);
398: /* ignore error */
399: }
400:
401: xfree(exspec);
402: spec->exspec = NULL;
403: return 0;
404: }
405: #else /* USE_VBOXVD */
406: int
407: istgt_lu_disk_vbox_lun_init(ISTGT_LU_DISK *spec, ISTGT_Ptr istgt __attribute__((__unused__)), ISTGT_LU_Ptr lu __attribute__((__unused__)))
408: {
409: ISTGT_TRACELOG(ISTGT_TRACE_DEBUG, "LU%d: LUN%d unsupported virtual disk\n",
410: spec->num, spec->lun);
411: return -1;
412: }
413:
414: int
415: istgt_lu_disk_vbox_lun_shutdown(ISTGT_LU_DISK *spec, ISTGT_Ptr istgt __attribute__((__unused__)), ISTGT_LU_Ptr lu __attribute__((__unused__)))
416: {
417: ISTGT_TRACELOG(ISTGT_TRACE_DEBUG, "LU%d: LUN%d unsupported virtual disk\n",
418: spec->num, spec->lun);
419: return -1;
420: }
421: #endif /* USE_VBOXVD */
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to istgt_lu_disk_vbox.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / istgt / src