VirtualBox

source: vbox/trunk/src/VBox/Main/src-server/MediumImpl.cpp@ 42699

Last change on this file since 42699 was 42551, checked in by vboxsync, 12 years ago

Main: big API naming cleanup, use all caps acronyms everywhere, including SDK docs
Frontends/VBoxManage: implement guestcontrol execute for new API, disabled by default

  • Property svn:eol-style set to native
  • Property svn:keywords set to Author Date Id Revision
File size: 271.4 KB
Line 
1/* $Id: MediumImpl.cpp 42551 2012-08-02 16:44:39Z vboxsync $ */
2/** @file
3 * VirtualBox COM class implementation
4 */
5
6/*
7 * Copyright (C) 2008-2012 Oracle Corporation
8 *
9 * This file is part of VirtualBox Open Source Edition (OSE), as
10 * available from http://www.virtualbox.org. This file is free software;
11 * you can redistribute it and/or modify it under the terms of the GNU
12 * General Public License (GPL) as published by the Free Software
13 * Foundation, in version 2 as it comes in the "COPYING" file of the
14 * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
15 * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
16 */
17
18#include "MediumImpl.h"
19#include "ProgressImpl.h"
20#include "SystemPropertiesImpl.h"
21#include "VirtualBoxImpl.h"
22
23#include "AutoCaller.h"
24#include "Logging.h"
25
26#include <VBox/com/array.h>
27#include "VBox/com/MultiResult.h"
28#include "VBox/com/ErrorInfo.h"
29
30#include <VBox/err.h>
31#include <VBox/settings.h>
32
33#include <iprt/param.h>
34#include <iprt/path.h>
35#include <iprt/file.h>
36#include <iprt/tcp.h>
37#include <iprt/cpp/utils.h>
38
39#include <VBox/vd.h>
40
41#include <algorithm>
42#include <list>
43
44typedef std::list<Guid> GuidList;
45
46////////////////////////////////////////////////////////////////////////////////
47//
48// Medium data definition
49//
50////////////////////////////////////////////////////////////////////////////////
51
52/** Describes how a machine refers to this medium. */
53struct BackRef
54{
55 /** Equality predicate for stdc++. */
56 struct EqualsTo : public std::unary_function <BackRef, bool>
57 {
58 explicit EqualsTo(const Guid &aMachineId) : machineId(aMachineId) {}
59
60 bool operator()(const argument_type &aThat) const
61 {
62 return aThat.machineId == machineId;
63 }
64
65 const Guid machineId;
66 };
67
68 BackRef(const Guid &aMachineId,
69 const Guid &aSnapshotId = Guid::Empty)
70 : machineId(aMachineId),
71 fInCurState(aSnapshotId.isEmpty())
72 {
73 if (!aSnapshotId.isEmpty())
74 llSnapshotIds.push_back(aSnapshotId);
75 }
76
77 Guid machineId;
78 bool fInCurState : 1;
79 GuidList llSnapshotIds;
80};
81
82typedef std::list<BackRef> BackRefList;
83
84struct Medium::Data
85{
86 Data()
87 : pVirtualBox(NULL),
88 state(MediumState_NotCreated),
89 variant(MediumVariant_Standard),
90 size(0),
91 readers(0),
92 preLockState(MediumState_NotCreated),
93 queryInfoSem(LOCKCLASS_MEDIUMQUERY),
94 queryInfoRunning(false),
95 type(MediumType_Normal),
96 devType(DeviceType_HardDisk),
97 logicalSize(0),
98 hddOpenMode(OpenReadWrite),
99 autoReset(false),
100 hostDrive(false),
101 implicit(false),
102 uOpenFlagsDef(VD_OPEN_FLAGS_IGNORE_FLUSH),
103 numCreateDiffTasks(0),
104 vdDiskIfaces(NULL),
105 vdImageIfaces(NULL)
106 { }
107
108 /** weak VirtualBox parent */
109 VirtualBox * const pVirtualBox;
110
111 // pParent and llChildren are protected by VirtualBox::getMediaTreeLockHandle()
112 ComObjPtr<Medium> pParent;
113 MediaList llChildren; // to add a child, just call push_back; to remove a child, call child->deparent() which does a lookup
114
115 GuidList llRegistryIDs; // media registries in which this medium is listed
116
117 const Guid id;
118 Utf8Str strDescription;
119 MediumState_T state;
120 MediumVariant_T variant;
121 Utf8Str strLocationFull;
122 uint64_t size;
123 Utf8Str strLastAccessError;
124
125 BackRefList backRefs;
126
127 size_t readers;
128 MediumState_T preLockState;
129
130 /** Special synchronization for operations which must wait for
131 * Medium::queryInfo in another thread to complete. Using a SemRW is
132 * not quite ideal, but at least it is subject to the lock validator,
133 * unlike the SemEventMulti which we had here for many years. Catching
134 * possible deadlocks is more important than a tiny bit of efficiency. */
135 RWLockHandle queryInfoSem;
136 bool queryInfoRunning : 1;
137
138 const Utf8Str strFormat;
139 ComObjPtr<MediumFormat> formatObj;
140
141 MediumType_T type;
142 DeviceType_T devType;
143 uint64_t logicalSize;
144
145 HDDOpenMode hddOpenMode;
146
147 bool autoReset : 1;
148
149 /** New UUID to be set on the next Medium::queryInfo call. */
150 const Guid uuidImage;
151 /** New parent UUID to be set on the next Medium::queryInfo call. */
152 const Guid uuidParentImage;
153
154 bool hostDrive : 1;
155
156 settings::StringsMap mapProperties;
157
158 bool implicit : 1;
159
160 /** Default flags passed to VDOpen(). */
161 unsigned uOpenFlagsDef;
162
163 uint32_t numCreateDiffTasks;
164
165 Utf8Str vdError; /*< Error remembered by the VD error callback. */
166
167 VDINTERFACEERROR vdIfError;
168
169 VDINTERFACECONFIG vdIfConfig;
170
171 VDINTERFACETCPNET vdIfTcpNet;
172
173 PVDINTERFACE vdDiskIfaces;
174 PVDINTERFACE vdImageIfaces;
175};
176
177typedef struct VDSOCKETINT
178{
179 /** Socket handle. */
180 RTSOCKET hSocket;
181} VDSOCKETINT, *PVDSOCKETINT;
182
183////////////////////////////////////////////////////////////////////////////////
184//
185// Globals
186//
187////////////////////////////////////////////////////////////////////////////////
188
189/**
190 * Medium::Task class for asynchronous operations.
191 *
192 * @note Instances of this class must be created using new() because the
193 * task thread function will delete them when the task is complete.
194 *
195 * @note The constructor of this class adds a caller on the managed Medium
196 * object which is automatically released upon destruction.
197 */
198class Medium::Task
199{
200public:
201 Task(Medium *aMedium, Progress *aProgress)
202 : mVDOperationIfaces(NULL),
203 mMedium(aMedium),
204 mMediumCaller(aMedium),
205 mThread(NIL_RTTHREAD),
206 mProgress(aProgress),
207 mVirtualBoxCaller(NULL)
208 {
209 AssertReturnVoidStmt(aMedium, mRC = E_FAIL);
210 mRC = mMediumCaller.rc();
211 if (FAILED(mRC))
212 return;
213
214 /* Get strong VirtualBox reference, see below. */
215 VirtualBox *pVirtualBox = aMedium->m->pVirtualBox;
216 mVirtualBox = pVirtualBox;
217 mVirtualBoxCaller.attach(pVirtualBox);
218 mRC = mVirtualBoxCaller.rc();
219 if (FAILED(mRC))
220 return;
221
222 /* Set up a per-operation progress interface, can be used freely (for
223 * binary operations you can use it either on the source or target). */
224 mVDIfProgress.pfnProgress = vdProgressCall;
225 int vrc = VDInterfaceAdd(&mVDIfProgress.Core,
226 "Medium::Task::vdInterfaceProgress",
227 VDINTERFACETYPE_PROGRESS,
228 mProgress,
229 sizeof(VDINTERFACEPROGRESS),
230 &mVDOperationIfaces);
231 AssertRC(vrc);
232 if (RT_FAILURE(vrc))
233 mRC = E_FAIL;
234 }
235
236 // Make all destructors virtual. Just in case.
237 virtual ~Task()
238 {}
239
240 HRESULT rc() const { return mRC; }
241 bool isOk() const { return SUCCEEDED(rc()); }
242
243 static int fntMediumTask(RTTHREAD aThread, void *pvUser);
244
245 bool isAsync() { return mThread != NIL_RTTHREAD; }
246
247 PVDINTERFACE mVDOperationIfaces;
248
249 const ComObjPtr<Medium> mMedium;
250 AutoCaller mMediumCaller;
251
252 friend HRESULT Medium::runNow(Medium::Task*);
253
254protected:
255 HRESULT mRC;
256 RTTHREAD mThread;
257
258private:
259 virtual HRESULT handler() = 0;
260
261 const ComObjPtr<Progress> mProgress;
262
263 static DECLCALLBACK(int) vdProgressCall(void *pvUser, unsigned uPercent);
264
265 VDINTERFACEPROGRESS mVDIfProgress;
266
267 /* Must have a strong VirtualBox reference during a task otherwise the
268 * reference count might drop to 0 while a task is still running. This
269 * would result in weird behavior, including deadlocks due to uninit and
270 * locking order issues. The deadlock often is not detectable because the
271 * uninit uses event semaphores which sabotages deadlock detection. */
272 ComObjPtr<VirtualBox> mVirtualBox;
273 AutoCaller mVirtualBoxCaller;
274};
275
276class Medium::CreateBaseTask : public Medium::Task
277{
278public:
279 CreateBaseTask(Medium *aMedium,
280 Progress *aProgress,
281 uint64_t aSize,
282 MediumVariant_T aVariant)
283 : Medium::Task(aMedium, aProgress),
284 mSize(aSize),
285 mVariant(aVariant)
286 {}
287
288 uint64_t mSize;
289 MediumVariant_T mVariant;
290
291private:
292 virtual HRESULT handler();
293};
294
295class Medium::CreateDiffTask : public Medium::Task
296{
297public:
298 CreateDiffTask(Medium *aMedium,
299 Progress *aProgress,
300 Medium *aTarget,
301 MediumVariant_T aVariant,
302 MediumLockList *aMediumLockList,
303 bool fKeepMediumLockList = false)
304 : Medium::Task(aMedium, aProgress),
305 mpMediumLockList(aMediumLockList),
306 mTarget(aTarget),
307 mVariant(aVariant),
308 mTargetCaller(aTarget),
309 mfKeepMediumLockList(fKeepMediumLockList)
310 {
311 AssertReturnVoidStmt(aTarget != NULL, mRC = E_FAIL);
312 mRC = mTargetCaller.rc();
313 if (FAILED(mRC))
314 return;
315 }
316
317 ~CreateDiffTask()
318 {
319 if (!mfKeepMediumLockList && mpMediumLockList)
320 delete mpMediumLockList;
321 }
322
323 MediumLockList *mpMediumLockList;
324
325 const ComObjPtr<Medium> mTarget;
326 MediumVariant_T mVariant;
327
328private:
329 virtual HRESULT handler();
330
331 AutoCaller mTargetCaller;
332 bool mfKeepMediumLockList;
333};
334
335class Medium::CloneTask : public Medium::Task
336{
337public:
338 CloneTask(Medium *aMedium,
339 Progress *aProgress,
340 Medium *aTarget,
341 MediumVariant_T aVariant,
342 Medium *aParent,
343 uint32_t idxSrcImageSame,
344 uint32_t idxDstImageSame,
345 MediumLockList *aSourceMediumLockList,
346 MediumLockList *aTargetMediumLockList,
347 bool fKeepSourceMediumLockList = false,
348 bool fKeepTargetMediumLockList = false)
349 : Medium::Task(aMedium, aProgress),
350 mTarget(aTarget),
351 mParent(aParent),
352 mpSourceMediumLockList(aSourceMediumLockList),
353 mpTargetMediumLockList(aTargetMediumLockList),
354 mVariant(aVariant),
355 midxSrcImageSame(idxSrcImageSame),
356 midxDstImageSame(idxDstImageSame),
357 mTargetCaller(aTarget),
358 mParentCaller(aParent),
359 mfKeepSourceMediumLockList(fKeepSourceMediumLockList),
360 mfKeepTargetMediumLockList(fKeepTargetMediumLockList)
361 {
362 AssertReturnVoidStmt(aTarget != NULL, mRC = E_FAIL);
363 mRC = mTargetCaller.rc();
364 if (FAILED(mRC))
365 return;
366 /* aParent may be NULL */
367 mRC = mParentCaller.rc();
368 if (FAILED(mRC))
369 return;
370 AssertReturnVoidStmt(aSourceMediumLockList != NULL, mRC = E_FAIL);
371 AssertReturnVoidStmt(aTargetMediumLockList != NULL, mRC = E_FAIL);
372 }
373
374 ~CloneTask()
375 {
376 if (!mfKeepSourceMediumLockList && mpSourceMediumLockList)
377 delete mpSourceMediumLockList;
378 if (!mfKeepTargetMediumLockList && mpTargetMediumLockList)
379 delete mpTargetMediumLockList;
380 }
381
382 const ComObjPtr<Medium> mTarget;
383 const ComObjPtr<Medium> mParent;
384 MediumLockList *mpSourceMediumLockList;
385 MediumLockList *mpTargetMediumLockList;
386 MediumVariant_T mVariant;
387 uint32_t midxSrcImageSame;
388 uint32_t midxDstImageSame;
389
390private:
391 virtual HRESULT handler();
392
393 AutoCaller mTargetCaller;
394 AutoCaller mParentCaller;
395 bool mfKeepSourceMediumLockList;
396 bool mfKeepTargetMediumLockList;
397};
398
399class Medium::CompactTask : public Medium::Task
400{
401public:
402 CompactTask(Medium *aMedium,
403 Progress *aProgress,
404 MediumLockList *aMediumLockList,
405 bool fKeepMediumLockList = false)
406 : Medium::Task(aMedium, aProgress),
407 mpMediumLockList(aMediumLockList),
408 mfKeepMediumLockList(fKeepMediumLockList)
409 {
410 AssertReturnVoidStmt(aMediumLockList != NULL, mRC = E_FAIL);
411 }
412
413 ~CompactTask()
414 {
415 if (!mfKeepMediumLockList && mpMediumLockList)
416 delete mpMediumLockList;
417 }
418
419 MediumLockList *mpMediumLockList;
420
421private:
422 virtual HRESULT handler();
423
424 bool mfKeepMediumLockList;
425};
426
427class Medium::ResizeTask : public Medium::Task
428{
429public:
430 ResizeTask(Medium *aMedium,
431 uint64_t aSize,
432 Progress *aProgress,
433 MediumLockList *aMediumLockList,
434 bool fKeepMediumLockList = false)
435 : Medium::Task(aMedium, aProgress),
436 mSize(aSize),
437 mpMediumLockList(aMediumLockList),
438 mfKeepMediumLockList(fKeepMediumLockList)
439 {
440 AssertReturnVoidStmt(aMediumLockList != NULL, mRC = E_FAIL);
441 }
442
443 ~ResizeTask()
444 {
445 if (!mfKeepMediumLockList && mpMediumLockList)
446 delete mpMediumLockList;
447 }
448
449 uint64_t mSize;
450 MediumLockList *mpMediumLockList;
451
452private:
453 virtual HRESULT handler();
454
455 bool mfKeepMediumLockList;
456};
457
458class Medium::ResetTask : public Medium::Task
459{
460public:
461 ResetTask(Medium *aMedium,
462 Progress *aProgress,
463 MediumLockList *aMediumLockList,
464 bool fKeepMediumLockList = false)
465 : Medium::Task(aMedium, aProgress),
466 mpMediumLockList(aMediumLockList),
467 mfKeepMediumLockList(fKeepMediumLockList)
468 {}
469
470 ~ResetTask()
471 {
472 if (!mfKeepMediumLockList && mpMediumLockList)
473 delete mpMediumLockList;
474 }
475
476 MediumLockList *mpMediumLockList;
477
478private:
479 virtual HRESULT handler();
480
481 bool mfKeepMediumLockList;
482};
483
484class Medium::DeleteTask : public Medium::Task
485{
486public:
487 DeleteTask(Medium *aMedium,
488 Progress *aProgress,
489 MediumLockList *aMediumLockList,
490 bool fKeepMediumLockList = false)
491 : Medium::Task(aMedium, aProgress),
492 mpMediumLockList(aMediumLockList),
493 mfKeepMediumLockList(fKeepMediumLockList)
494 {}
495
496 ~DeleteTask()
497 {
498 if (!mfKeepMediumLockList && mpMediumLockList)
499 delete mpMediumLockList;
500 }
501
502 MediumLockList *mpMediumLockList;
503
504private:
505 virtual HRESULT handler();
506
507 bool mfKeepMediumLockList;
508};
509
510class Medium::MergeTask : public Medium::Task
511{
512public:
513 MergeTask(Medium *aMedium,
514 Medium *aTarget,
515 bool fMergeForward,
516 Medium *aParentForTarget,
517 const MediaList &aChildrenToReparent,
518 Progress *aProgress,
519 MediumLockList *aMediumLockList,
520 bool fKeepMediumLockList = false)
521 : Medium::Task(aMedium, aProgress),
522 mTarget(aTarget),
523 mfMergeForward(fMergeForward),
524 mParentForTarget(aParentForTarget),
525 mChildrenToReparent(aChildrenToReparent),
526 mpMediumLockList(aMediumLockList),
527 mTargetCaller(aTarget),
528 mParentForTargetCaller(aParentForTarget),
529 mfChildrenCaller(false),
530 mfKeepMediumLockList(fKeepMediumLockList)
531 {
532 AssertReturnVoidStmt(aMediumLockList != NULL, mRC = E_FAIL);
533 for (MediaList::const_iterator it = mChildrenToReparent.begin();
534 it != mChildrenToReparent.end();
535 ++it)
536 {
537 HRESULT rc2 = (*it)->addCaller();
538 if (FAILED(rc2))
539 {
540 mRC = E_FAIL;
541 for (MediaList::const_iterator it2 = mChildrenToReparent.begin();
542 it2 != it;
543 --it2)
544 {
545 (*it2)->releaseCaller();
546 }
547 return;
548 }
549 }
550 mfChildrenCaller = true;
551 }
552
553 ~MergeTask()
554 {
555 if (!mfKeepMediumLockList && mpMediumLockList)
556 delete mpMediumLockList;
557 if (mfChildrenCaller)
558 {
559 for (MediaList::const_iterator it = mChildrenToReparent.begin();
560 it != mChildrenToReparent.end();
561 ++it)
562 {
563 (*it)->releaseCaller();
564 }
565 }
566 }
567
568 const ComObjPtr<Medium> mTarget;
569 bool mfMergeForward;
570 /* When mChildrenToReparent is empty then mParentForTarget is non-null.
571 * In other words: they are used in different cases. */
572 const ComObjPtr<Medium> mParentForTarget;
573 MediaList mChildrenToReparent;
574 MediumLockList *mpMediumLockList;
575
576private:
577 virtual HRESULT handler();
578
579 AutoCaller mTargetCaller;
580 AutoCaller mParentForTargetCaller;
581 bool mfChildrenCaller;
582 bool mfKeepMediumLockList;
583};
584
585class Medium::ExportTask : public Medium::Task
586{
587public:
588 ExportTask(Medium *aMedium,
589 Progress *aProgress,
590 const char *aFilename,
591 MediumFormat *aFormat,
592 MediumVariant_T aVariant,
593 VDINTERFACEIO *aVDImageIOIf,
594 void *aVDImageIOUser,
595 MediumLockList *aSourceMediumLockList,
596 bool fKeepSourceMediumLockList = false)
597 : Medium::Task(aMedium, aProgress),
598 mpSourceMediumLockList(aSourceMediumLockList),
599 mFilename(aFilename),
600 mFormat(aFormat),
601 mVariant(aVariant),
602 mfKeepSourceMediumLockList(fKeepSourceMediumLockList)
603 {
604 AssertReturnVoidStmt(aSourceMediumLockList != NULL, mRC = E_FAIL);
605
606 mVDImageIfaces = aMedium->m->vdImageIfaces;
607 if (aVDImageIOIf)
608 {
609 int vrc = VDInterfaceAdd(&aVDImageIOIf->Core, "Medium::vdInterfaceIO",
610 VDINTERFACETYPE_IO, aVDImageIOUser,
611 sizeof(VDINTERFACEIO), &mVDImageIfaces);
612 AssertRCReturnVoidStmt(vrc, mRC = E_FAIL);
613 }
614 }
615
616 ~ExportTask()
617 {
618 if (!mfKeepSourceMediumLockList && mpSourceMediumLockList)
619 delete mpSourceMediumLockList;
620 }
621
622 MediumLockList *mpSourceMediumLockList;
623 Utf8Str mFilename;
624 ComObjPtr<MediumFormat> mFormat;
625 MediumVariant_T mVariant;
626 PVDINTERFACE mVDImageIfaces;
627
628private:
629 virtual HRESULT handler();
630
631 bool mfKeepSourceMediumLockList;
632};
633
634class Medium::ImportTask : public Medium::Task
635{
636public:
637 ImportTask(Medium *aMedium,
638 Progress *aProgress,
639 const char *aFilename,
640 MediumFormat *aFormat,
641 MediumVariant_T aVariant,
642 VDINTERFACEIO *aVDImageIOIf,
643 void *aVDImageIOUser,
644 Medium *aParent,
645 MediumLockList *aTargetMediumLockList,
646 bool fKeepTargetMediumLockList = false)
647 : Medium::Task(aMedium, aProgress),
648 mFilename(aFilename),
649 mFormat(aFormat),
650 mVariant(aVariant),
651 mParent(aParent),
652 mpTargetMediumLockList(aTargetMediumLockList),
653 mParentCaller(aParent),
654 mfKeepTargetMediumLockList(fKeepTargetMediumLockList)
655 {
656 AssertReturnVoidStmt(aTargetMediumLockList != NULL, mRC = E_FAIL);
657 /* aParent may be NULL */
658 mRC = mParentCaller.rc();
659 if (FAILED(mRC))
660 return;
661
662 mVDImageIfaces = aMedium->m->vdImageIfaces;
663 if (aVDImageIOIf)
664 {
665 int vrc = VDInterfaceAdd(&aVDImageIOIf->Core, "Medium::vdInterfaceIO",
666 VDINTERFACETYPE_IO, aVDImageIOUser,
667 sizeof(VDINTERFACEIO), &mVDImageIfaces);
668 AssertRCReturnVoidStmt(vrc, mRC = E_FAIL);
669 }
670 }
671
672 ~ImportTask()
673 {
674 if (!mfKeepTargetMediumLockList && mpTargetMediumLockList)
675 delete mpTargetMediumLockList;
676 }
677
678 Utf8Str mFilename;
679 ComObjPtr<MediumFormat> mFormat;
680 MediumVariant_T mVariant;
681 const ComObjPtr<Medium> mParent;
682 MediumLockList *mpTargetMediumLockList;
683 PVDINTERFACE mVDImageIfaces;
684
685private:
686 virtual HRESULT handler();
687
688 AutoCaller mParentCaller;
689 bool mfKeepTargetMediumLockList;
690};
691
692/**
693 * Thread function for time-consuming medium tasks.
694 *
695 * @param pvUser Pointer to the Medium::Task instance.
696 */
697/* static */
698DECLCALLBACK(int) Medium::Task::fntMediumTask(RTTHREAD aThread, void *pvUser)
699{
700 LogFlowFuncEnter();
701 AssertReturn(pvUser, (int)E_INVALIDARG);
702 Medium::Task *pTask = static_cast<Medium::Task *>(pvUser);
703
704 pTask->mThread = aThread;
705
706 HRESULT rc = pTask->handler();
707
708 /* complete the progress if run asynchronously */
709 if (pTask->isAsync())
710 {
711 if (!pTask->mProgress.isNull())
712 pTask->mProgress->notifyComplete(rc);
713 }
714
715 /* pTask is no longer needed, delete it. */
716 delete pTask;
717
718 LogFlowFunc(("rc=%Rhrc\n", rc));
719 LogFlowFuncLeave();
720
721 return (int)rc;
722}
723
724/**
725 * PFNVDPROGRESS callback handler for Task operations.
726 *
727 * @param pvUser Pointer to the Progress instance.
728 * @param uPercent Completion percentage (0-100).
729 */
730/*static*/
731DECLCALLBACK(int) Medium::Task::vdProgressCall(void *pvUser, unsigned uPercent)
732{
733 Progress *that = static_cast<Progress *>(pvUser);
734
735 if (that != NULL)
736 {
737 /* update the progress object, capping it at 99% as the final percent
738 * is used for additional operations like setting the UUIDs and similar. */
739 HRESULT rc = that->SetCurrentOperationProgress(uPercent * 99 / 100);
740 if (FAILED(rc))
741 {
742 if (rc == E_FAIL)
743 return VERR_CANCELLED;
744 else
745 return VERR_INVALID_STATE;
746 }
747 }
748
749 return VINF_SUCCESS;
750}
751
752/**
753 * Implementation code for the "create base" task.
754 */
755HRESULT Medium::CreateBaseTask::handler()
756{
757 return mMedium->taskCreateBaseHandler(*this);
758}
759
760/**
761 * Implementation code for the "create diff" task.
762 */
763HRESULT Medium::CreateDiffTask::handler()
764{
765 return mMedium->taskCreateDiffHandler(*this);
766}
767
768/**
769 * Implementation code for the "clone" task.
770 */
771HRESULT Medium::CloneTask::handler()
772{
773 return mMedium->taskCloneHandler(*this);
774}
775
776/**
777 * Implementation code for the "compact" task.
778 */
779HRESULT Medium::CompactTask::handler()
780{
781 return mMedium->taskCompactHandler(*this);
782}
783
784/**
785 * Implementation code for the "resize" task.
786 */
787HRESULT Medium::ResizeTask::handler()
788{
789 return mMedium->taskResizeHandler(*this);
790}
791
792
793/**
794 * Implementation code for the "reset" task.
795 */
796HRESULT Medium::ResetTask::handler()
797{
798 return mMedium->taskResetHandler(*this);
799}
800
801/**
802 * Implementation code for the "delete" task.
803 */
804HRESULT Medium::DeleteTask::handler()
805{
806 return mMedium->taskDeleteHandler(*this);
807}
808
809/**
810 * Implementation code for the "merge" task.
811 */
812HRESULT Medium::MergeTask::handler()
813{
814 return mMedium->taskMergeHandler(*this);
815}
816
817/**
818 * Implementation code for the "export" task.
819 */
820HRESULT Medium::ExportTask::handler()
821{
822 return mMedium->taskExportHandler(*this);
823}
824
825/**
826 * Implementation code for the "import" task.
827 */
828HRESULT Medium::ImportTask::handler()
829{
830 return mMedium->taskImportHandler(*this);
831}
832
833////////////////////////////////////////////////////////////////////////////////
834//
835// Medium constructor / destructor
836//
837////////////////////////////////////////////////////////////////////////////////
838
839DEFINE_EMPTY_CTOR_DTOR(Medium)
840
841HRESULT Medium::FinalConstruct()
842{
843 m = new Data;
844
845 /* Initialize the callbacks of the VD error interface */
846 m->vdIfError.pfnError = vdErrorCall;
847 m->vdIfError.pfnMessage = NULL;
848
849 /* Initialize the callbacks of the VD config interface */
850 m->vdIfConfig.pfnAreKeysValid = vdConfigAreKeysValid;
851 m->vdIfConfig.pfnQuerySize = vdConfigQuerySize;
852 m->vdIfConfig.pfnQuery = vdConfigQuery;
853
854 /* Initialize the callbacks of the VD TCP interface (we always use the host
855 * IP stack for now) */
856 m->vdIfTcpNet.pfnSocketCreate = vdTcpSocketCreate;
857 m->vdIfTcpNet.pfnSocketDestroy = vdTcpSocketDestroy;
858 m->vdIfTcpNet.pfnClientConnect = vdTcpClientConnect;
859 m->vdIfTcpNet.pfnClientClose = vdTcpClientClose;
860 m->vdIfTcpNet.pfnIsClientConnected = vdTcpIsClientConnected;
861 m->vdIfTcpNet.pfnSelectOne = vdTcpSelectOne;
862 m->vdIfTcpNet.pfnRead = vdTcpRead;
863 m->vdIfTcpNet.pfnWrite = vdTcpWrite;
864 m->vdIfTcpNet.pfnSgWrite = vdTcpSgWrite;
865 m->vdIfTcpNet.pfnFlush = vdTcpFlush;
866 m->vdIfTcpNet.pfnSetSendCoalescing = vdTcpSetSendCoalescing;
867 m->vdIfTcpNet.pfnGetLocalAddress = vdTcpGetLocalAddress;
868 m->vdIfTcpNet.pfnGetPeerAddress = vdTcpGetPeerAddress;
869 m->vdIfTcpNet.pfnSelectOneEx = NULL;
870 m->vdIfTcpNet.pfnPoke = NULL;
871
872 /* Initialize the per-disk interface chain (could be done more globally,
873 * but it's not wasting much time or space so it's not worth it). */
874 int vrc;
875 vrc = VDInterfaceAdd(&m->vdIfError.Core,
876 "Medium::vdInterfaceError",
877 VDINTERFACETYPE_ERROR, this,
878 sizeof(VDINTERFACEERROR), &m->vdDiskIfaces);
879 AssertRCReturn(vrc, E_FAIL);
880
881 /* Initialize the per-image interface chain */
882 vrc = VDInterfaceAdd(&m->vdIfConfig.Core,
883 "Medium::vdInterfaceConfig",
884 VDINTERFACETYPE_CONFIG, this,
885 sizeof(VDINTERFACECONFIG), &m->vdImageIfaces);
886 AssertRCReturn(vrc, E_FAIL);
887
888 vrc = VDInterfaceAdd(&m->vdIfTcpNet.Core,
889 "Medium::vdInterfaceTcpNet",
890 VDINTERFACETYPE_TCPNET, this,
891 sizeof(VDINTERFACETCPNET), &m->vdImageIfaces);
892 AssertRCReturn(vrc, E_FAIL);
893
894 return BaseFinalConstruct();
895}
896
897void Medium::FinalRelease()
898{
899 uninit();
900
901 delete m;
902
903 BaseFinalRelease();
904}
905
906/**
907 * Initializes an empty hard disk object without creating or opening an associated
908 * storage unit.
909 *
910 * This gets called by VirtualBox::CreateHardDisk() in which case uuidMachineRegistry
911 * is empty since starting with VirtualBox 4.0, we no longer add opened media to a
912 * registry automatically (this is deferred until the medium is attached to a machine).
913 *
914 * This also gets called when VirtualBox creates diff images; in this case uuidMachineRegistry
915 * is set to the registry of the parent image to make sure they all end up in the same
916 * file.
917 *
918 * For hard disks that don't have the MediumFormatCapabilities_CreateFixed or
919 * MediumFormatCapabilities_CreateDynamic capability (and therefore cannot be created or deleted
920 * with the means of VirtualBox) the associated storage unit is assumed to be
921 * ready for use so the state of the hard disk object will be set to Created.
922 *
923 * @param aVirtualBox VirtualBox object.
924 * @param aFormat
925 * @param aLocation Storage unit location.
926 * @param uuidMachineRegistry The registry to which this medium should be added (global registry UUID or machine UUID or empty if none).
927 */
928HRESULT Medium::init(VirtualBox *aVirtualBox,
929 const Utf8Str &aFormat,
930 const Utf8Str &aLocation,
931 const Guid &uuidMachineRegistry)
932{
933 AssertReturn(aVirtualBox != NULL, E_FAIL);
934 AssertReturn(!aFormat.isEmpty(), E_FAIL);
935
936 /* Enclose the state transition NotReady->InInit->Ready */
937 AutoInitSpan autoInitSpan(this);
938 AssertReturn(autoInitSpan.isOk(), E_FAIL);
939
940 HRESULT rc = S_OK;
941
942 unconst(m->pVirtualBox) = aVirtualBox;
943
944 if (!uuidMachineRegistry.isEmpty())
945 m->llRegistryIDs.push_back(uuidMachineRegistry);
946
947 /* no storage yet */
948 m->state = MediumState_NotCreated;
949
950 /* cannot be a host drive */
951 m->hostDrive = false;
952
953 /* No storage unit is created yet, no need to call Medium::queryInfo */
954
955 rc = setFormat(aFormat);
956 if (FAILED(rc)) return rc;
957
958 rc = setLocation(aLocation);
959 if (FAILED(rc)) return rc;
960
961 if (!(m->formatObj->getCapabilities() & ( MediumFormatCapabilities_CreateFixed
962 | MediumFormatCapabilities_CreateDynamic))
963 )
964 {
965 /* Storage for hard disks of this format can neither be explicitly
966 * created by VirtualBox nor deleted, so we place the hard disk to
967 * Inaccessible state here and also add it to the registry. The
968 * state means that one has to use RefreshState() to update the
969 * medium format specific fields. */
970 m->state = MediumState_Inaccessible;
971 // create new UUID
972 unconst(m->id).create();
973
974 AutoWriteLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
975 ComObjPtr<Medium> pMedium;
976 rc = m->pVirtualBox->registerMedium(this, &pMedium, DeviceType_HardDisk);
977 Assert(this == pMedium);
978 }
979
980 /* Confirm a successful initialization when it's the case */
981 if (SUCCEEDED(rc))
982 autoInitSpan.setSucceeded();
983
984 return rc;
985}
986
987/**
988 * Initializes the medium object by opening the storage unit at the specified
989 * location. The enOpenMode parameter defines whether the medium will be opened
990 * read/write or read-only.
991 *
992 * This gets called by VirtualBox::OpenMedium() and also by
993 * Machine::AttachDevice() and createImplicitDiffs() when new diff
994 * images are created.
995 *
996 * There is no registry for this case since starting with VirtualBox 4.0, we
997 * no longer add opened media to a registry automatically (this is deferred
998 * until the medium is attached to a machine).
999 *
1000 * For hard disks, the UUID, format and the parent of this medium will be
1001 * determined when reading the medium storage unit. For DVD and floppy images,
1002 * which have no UUIDs in their storage units, new UUIDs are created.
1003 * If the detected or set parent is not known to VirtualBox, then this method
1004 * will fail.
1005 *
1006 * @param aVirtualBox VirtualBox object.
1007 * @param aLocation Storage unit location.
1008 * @param enOpenMode Whether to open the medium read/write or read-only.
1009 * @param fForceNewUuid Whether a new UUID should be set to avoid duplicates.
1010 * @param aDeviceType Device type of medium.
1011 */
1012HRESULT Medium::init(VirtualBox *aVirtualBox,
1013 const Utf8Str &aLocation,
1014 HDDOpenMode enOpenMode,
1015 bool fForceNewUuid,
1016 DeviceType_T aDeviceType)
1017{
1018 AssertReturn(aVirtualBox, E_INVALIDARG);
1019 AssertReturn(!aLocation.isEmpty(), E_INVALIDARG);
1020
1021 /* Enclose the state transition NotReady->InInit->Ready */
1022 AutoInitSpan autoInitSpan(this);
1023 AssertReturn(autoInitSpan.isOk(), E_FAIL);
1024
1025 HRESULT rc = S_OK;
1026
1027 unconst(m->pVirtualBox) = aVirtualBox;
1028
1029 /* there must be a storage unit */
1030 m->state = MediumState_Created;
1031
1032 /* remember device type for correct unregistering later */
1033 m->devType = aDeviceType;
1034
1035 /* cannot be a host drive */
1036 m->hostDrive = false;
1037
1038 /* remember the open mode (defaults to ReadWrite) */
1039 m->hddOpenMode = enOpenMode;
1040
1041 if (aDeviceType == DeviceType_DVD)
1042 m->type = MediumType_Readonly;
1043 else if (aDeviceType == DeviceType_Floppy)
1044 m->type = MediumType_Writethrough;
1045
1046 rc = setLocation(aLocation);
1047 if (FAILED(rc)) return rc;
1048
1049 /* get all the information about the medium from the storage unit */
1050 if (fForceNewUuid)
1051 unconst(m->uuidImage).create();
1052
1053 rc = queryInfo(fForceNewUuid /* fSetImageId */, false /* fSetParentId */);
1054
1055 if (SUCCEEDED(rc))
1056 {
1057 /* if the storage unit is not accessible, it's not acceptable for the
1058 * newly opened media so convert this into an error */
1059 if (m->state == MediumState_Inaccessible)
1060 {
1061 Assert(!m->strLastAccessError.isEmpty());
1062 rc = setError(E_FAIL, "%s", m->strLastAccessError.c_str());
1063 }
1064 else
1065 {
1066 AssertReturn(!m->id.isEmpty(), E_FAIL);
1067
1068 /* storage format must be detected by Medium::queryInfo if the
1069 * medium is accessible */
1070 AssertReturn(!m->strFormat.isEmpty(), E_FAIL);
1071 }
1072 }
1073
1074 /* Confirm a successful initialization when it's the case */
1075 if (SUCCEEDED(rc))
1076 autoInitSpan.setSucceeded();
1077
1078 return rc;
1079}
1080
1081/**
1082 * Initializes the medium object by loading its data from the given settings
1083 * node. In this mode, the medium will always be opened read/write.
1084 *
1085 * In this case, since we're loading from a registry, uuidMachineRegistry is
1086 * always set: it's either the global registry UUID or a machine UUID when
1087 * loading from a per-machine registry.
1088 *
1089 * @param aVirtualBox VirtualBox object.
1090 * @param aParent Parent medium disk or NULL for a root (base) medium.
1091 * @param aDeviceType Device type of the medium.
1092 * @param uuidMachineRegistry The registry to which this medium should be added (global registry UUID or machine UUID).
1093 * @param aNode Configuration settings.
1094 * @param strMachineFolder The machine folder with which to resolve relative paths; if empty, then we use the VirtualBox home directory
1095 *
1096 * @note Locks the medium tree for writing.
1097 */
1098HRESULT Medium::init(VirtualBox *aVirtualBox,
1099 Medium *aParent,
1100 DeviceType_T aDeviceType,
1101 const Guid &uuidMachineRegistry,
1102 const settings::Medium &data,
1103 const Utf8Str &strMachineFolder)
1104{
1105 using namespace settings;
1106
1107 AssertReturn(aVirtualBox, E_INVALIDARG);
1108
1109 /* Enclose the state transition NotReady->InInit->Ready */
1110 AutoInitSpan autoInitSpan(this);
1111 AssertReturn(autoInitSpan.isOk(), E_FAIL);
1112
1113 HRESULT rc = S_OK;
1114
1115 unconst(m->pVirtualBox) = aVirtualBox;
1116
1117 if (!uuidMachineRegistry.isEmpty())
1118 m->llRegistryIDs.push_back(uuidMachineRegistry);
1119
1120 /* register with VirtualBox/parent early, since uninit() will
1121 * unconditionally unregister on failure */
1122 if (aParent)
1123 {
1124 // differencing medium: add to parent
1125 AutoWriteLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
1126 m->pParent = aParent;
1127 aParent->m->llChildren.push_back(this);
1128 }
1129
1130 /* see below why we don't call Medium::queryInfo (and therefore treat
1131 * the medium as inaccessible for now */
1132 m->state = MediumState_Inaccessible;
1133 m->strLastAccessError = tr("Accessibility check was not yet performed");
1134
1135 /* required */
1136 unconst(m->id) = data.uuid;
1137
1138 /* assume not a host drive */
1139 m->hostDrive = false;
1140
1141 /* optional */
1142 m->strDescription = data.strDescription;
1143
1144 /* required */
1145 if (aDeviceType == DeviceType_HardDisk)
1146 {
1147 AssertReturn(!data.strFormat.isEmpty(), E_FAIL);
1148 rc = setFormat(data.strFormat);
1149 if (FAILED(rc)) return rc;
1150 }
1151 else
1152 {
1153 /// @todo handle host drive settings here as well?
1154 if (!data.strFormat.isEmpty())
1155 rc = setFormat(data.strFormat);
1156 else
1157 rc = setFormat("RAW");
1158 if (FAILED(rc)) return rc;
1159 }
1160
1161 /* optional, only for diffs, default is false; we can only auto-reset
1162 * diff media so they must have a parent */
1163 if (aParent != NULL)
1164 m->autoReset = data.fAutoReset;
1165 else
1166 m->autoReset = false;
1167
1168 /* properties (after setting the format as it populates the map). Note that
1169 * if some properties are not supported but present in the settings file,
1170 * they will still be read and accessible (for possible backward
1171 * compatibility; we can also clean them up from the XML upon next
1172 * XML format version change if we wish) */
1173 for (settings::StringsMap::const_iterator it = data.properties.begin();
1174 it != data.properties.end();
1175 ++it)
1176 {
1177 const Utf8Str &name = it->first;
1178 const Utf8Str &value = it->second;
1179 m->mapProperties[name] = value;
1180 }
1181
1182 /* try to decrypt an optional iSCSI initiator secret */
1183 settings::StringsMap::const_iterator itCph = data.properties.find("InitiatorSecretEncrypted");
1184 if ( itCph != data.properties.end()
1185 && !itCph->second.isEmpty())
1186 {
1187 Utf8Str strPlaintext;
1188 int vrc = m->pVirtualBox->decryptSetting(&strPlaintext, itCph->second);
1189 if (RT_SUCCESS(vrc))
1190 m->mapProperties["InitiatorSecret"] = strPlaintext;
1191 }
1192
1193 Utf8Str strFull;
1194 if (m->formatObj->getCapabilities() & MediumFormatCapabilities_File)
1195 {
1196 // compose full path of the medium, if it's not fully qualified...
1197 // slightly convoluted logic here. If the caller has given us a
1198 // machine folder, then a relative path will be relative to that:
1199 if ( !strMachineFolder.isEmpty()
1200 && !RTPathStartsWithRoot(data.strLocation.c_str())
1201 )
1202 {
1203 strFull = strMachineFolder;
1204 strFull += RTPATH_SLASH;
1205 strFull += data.strLocation;
1206 }
1207 else
1208 {
1209 // Otherwise use the old VirtualBox "make absolute path" logic:
1210 rc = m->pVirtualBox->calculateFullPath(data.strLocation, strFull);
1211 if (FAILED(rc)) return rc;
1212 }
1213 }
1214 else
1215 strFull = data.strLocation;
1216
1217 rc = setLocation(strFull);
1218 if (FAILED(rc)) return rc;
1219
1220 if (aDeviceType == DeviceType_HardDisk)
1221 {
1222 /* type is only for base hard disks */
1223 if (m->pParent.isNull())
1224 m->type = data.hdType;
1225 }
1226 else if (aDeviceType == DeviceType_DVD)
1227 m->type = MediumType_Readonly;
1228 else
1229 m->type = MediumType_Writethrough;
1230
1231 /* remember device type for correct unregistering later */
1232 m->devType = aDeviceType;
1233
1234 LogFlowThisFunc(("m->strLocationFull='%s', m->strFormat=%s, m->id={%RTuuid}\n",
1235 m->strLocationFull.c_str(), m->strFormat.c_str(), m->id.raw()));
1236
1237 /* Don't call Medium::queryInfo for registered media to prevent the calling
1238 * thread (i.e. the VirtualBox server startup thread) from an unexpected
1239 * freeze but mark it as initially inaccessible instead. The vital UUID,
1240 * location and format properties are read from the registry file above; to
1241 * get the actual state and the rest of the data, the user will have to call
1242 * COMGETTER(State). */
1243
1244 AutoWriteLock treeLock(aVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
1245
1246 /* load all children */
1247 for (settings::MediaList::const_iterator it = data.llChildren.begin();
1248 it != data.llChildren.end();
1249 ++it)
1250 {
1251 const settings::Medium &med = *it;
1252
1253 ComObjPtr<Medium> pHD;
1254 pHD.createObject();
1255 rc = pHD->init(aVirtualBox,
1256 this, // parent
1257 aDeviceType,
1258 uuidMachineRegistry,
1259 med, // child data
1260 strMachineFolder);
1261 if (FAILED(rc)) break;
1262
1263 rc = m->pVirtualBox->registerMedium(pHD, &pHD, DeviceType_HardDisk);
1264 if (FAILED(rc)) break;
1265 }
1266
1267 /* Confirm a successful initialization when it's the case */
1268 if (SUCCEEDED(rc))
1269 autoInitSpan.setSucceeded();
1270
1271 return rc;
1272}
1273
1274/**
1275 * Initializes the medium object by providing the host drive information.
1276 * Not used for anything but the host floppy/host DVD case.
1277 *
1278 * There is no registry for this case.
1279 *
1280 * @param aVirtualBox VirtualBox object.
1281 * @param aDeviceType Device type of the medium.
1282 * @param aLocation Location of the host drive.
1283 * @param aDescription Comment for this host drive.
1284 *
1285 * @note Locks VirtualBox lock for writing.
1286 */
1287HRESULT Medium::init(VirtualBox *aVirtualBox,
1288 DeviceType_T aDeviceType,
1289 const Utf8Str &aLocation,
1290 const Utf8Str &aDescription /* = Utf8Str::Empty */)
1291{
1292 ComAssertRet(aDeviceType == DeviceType_DVD || aDeviceType == DeviceType_Floppy, E_INVALIDARG);
1293 ComAssertRet(!aLocation.isEmpty(), E_INVALIDARG);
1294
1295 /* Enclose the state transition NotReady->InInit->Ready */
1296 AutoInitSpan autoInitSpan(this);
1297 AssertReturn(autoInitSpan.isOk(), E_FAIL);
1298
1299 unconst(m->pVirtualBox) = aVirtualBox;
1300
1301 // We do not store host drives in VirtualBox.xml or anywhere else, so if we want
1302 // host drives to be identifiable by UUID and not give the drive a different UUID
1303 // every time VirtualBox starts, we need to fake a reproducible UUID here:
1304 RTUUID uuid;
1305 RTUuidClear(&uuid);
1306 if (aDeviceType == DeviceType_DVD)
1307 memcpy(&uuid.au8[0], "DVD", 3);
1308 else
1309 memcpy(&uuid.au8[0], "FD", 2);
1310 /* use device name, adjusted to the end of uuid, shortened if necessary */
1311 size_t lenLocation = aLocation.length();
1312 if (lenLocation > 12)
1313 memcpy(&uuid.au8[4], aLocation.c_str() + (lenLocation - 12), 12);
1314 else
1315 memcpy(&uuid.au8[4 + 12 - lenLocation], aLocation.c_str(), lenLocation);
1316 unconst(m->id) = uuid;
1317
1318 if (aDeviceType == DeviceType_DVD)
1319 m->type = MediumType_Readonly;
1320 else
1321 m->type = MediumType_Writethrough;
1322 m->devType = aDeviceType;
1323 m->state = MediumState_Created;
1324 m->hostDrive = true;
1325 HRESULT rc = setFormat("RAW");
1326 if (FAILED(rc)) return rc;
1327 rc = setLocation(aLocation);
1328 if (FAILED(rc)) return rc;
1329 m->strDescription = aDescription;
1330
1331 autoInitSpan.setSucceeded();
1332 return S_OK;
1333}
1334
1335/**
1336 * Uninitializes the instance.
1337 *
1338 * Called either from FinalRelease() or by the parent when it gets destroyed.
1339 *
1340 * @note All children of this medium get uninitialized by calling their
1341 * uninit() methods.
1342 */
1343void Medium::uninit()
1344{
1345 /* Enclose the state transition Ready->InUninit->NotReady */
1346 AutoUninitSpan autoUninitSpan(this);
1347 if (autoUninitSpan.uninitDone())
1348 return;
1349
1350 if (!m->formatObj.isNull())
1351 {
1352 /* remove the caller reference we added in setFormat() */
1353 m->formatObj->releaseCaller();
1354 m->formatObj.setNull();
1355 }
1356
1357 if (m->state == MediumState_Deleting)
1358 {
1359 /* This medium has been already deleted (directly or as part of a
1360 * merge). Reparenting has already been done. */
1361 Assert(m->pParent.isNull());
1362 }
1363 else
1364 {
1365 MediaList::iterator it;
1366 for (it = m->llChildren.begin();
1367 it != m->llChildren.end();
1368 ++it)
1369 {
1370 Medium *pChild = *it;
1371 pChild->m->pParent.setNull();
1372 pChild->uninit();
1373 }
1374 m->llChildren.clear(); // this unsets all the ComPtrs and probably calls delete
1375
1376 if (m->pParent)
1377 {
1378 // this is a differencing disk: then remove it from the parent's children list
1379 deparent();
1380 }
1381 }
1382
1383 unconst(m->pVirtualBox) = NULL;
1384}
1385
1386/**
1387 * Internal helper that removes "this" from the list of children of its
1388 * parent. Used in uninit() and other places when reparenting is necessary.
1389 *
1390 * The caller must hold the medium tree lock!
1391 */
1392void Medium::deparent()
1393{
1394 MediaList &llParent = m->pParent->m->llChildren;
1395 for (MediaList::iterator it = llParent.begin();
1396 it != llParent.end();
1397 ++it)
1398 {
1399 Medium *pParentsChild = *it;
1400 if (this == pParentsChild)
1401 {
1402 llParent.erase(it);
1403 break;
1404 }
1405 }
1406 m->pParent.setNull();
1407}
1408
1409/**
1410 * Internal helper that removes "this" from the list of children of its
1411 * parent. Used in uninit() and other places when reparenting is necessary.
1412 *
1413 * The caller must hold the medium tree lock!
1414 */
1415void Medium::setParent(const ComObjPtr<Medium> &pParent)
1416{
1417 m->pParent = pParent;
1418 if (pParent)
1419 pParent->m->llChildren.push_back(this);
1420}
1421
1422
1423////////////////////////////////////////////////////////////////////////////////
1424//
1425// IMedium public methods
1426//
1427////////////////////////////////////////////////////////////////////////////////
1428
1429STDMETHODIMP Medium::COMGETTER(Id)(BSTR *aId)
1430{
1431 CheckComArgOutPointerValid(aId);
1432
1433 AutoCaller autoCaller(this);
1434 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1435
1436 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1437
1438 m->id.toUtf16().cloneTo(aId);
1439
1440 return S_OK;
1441}
1442
1443STDMETHODIMP Medium::COMGETTER(Description)(BSTR *aDescription)
1444{
1445 CheckComArgOutPointerValid(aDescription);
1446
1447 AutoCaller autoCaller(this);
1448 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1449
1450 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1451
1452 m->strDescription.cloneTo(aDescription);
1453
1454 return S_OK;
1455}
1456
1457STDMETHODIMP Medium::COMSETTER(Description)(IN_BSTR aDescription)
1458{
1459 AutoCaller autoCaller(this);
1460 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1461
1462// AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
1463
1464 /// @todo update m->description and save the global registry (and local
1465 /// registries of portable VMs referring to this medium), this will also
1466 /// require to add the mRegistered flag to data
1467
1468 NOREF(aDescription);
1469
1470 ReturnComNotImplemented();
1471}
1472
1473STDMETHODIMP Medium::COMGETTER(State)(MediumState_T *aState)
1474{
1475 CheckComArgOutPointerValid(aState);
1476
1477 AutoCaller autoCaller(this);
1478 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1479
1480 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1481 *aState = m->state;
1482
1483 return S_OK;
1484}
1485
1486STDMETHODIMP Medium::COMGETTER(Variant)(ULONG *aVariant)
1487{
1488 CheckComArgOutPointerValid(aVariant);
1489
1490 AutoCaller autoCaller(this);
1491 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1492
1493 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1494 *aVariant = m->variant;
1495
1496 return S_OK;
1497}
1498
1499
1500STDMETHODIMP Medium::COMGETTER(Location)(BSTR *aLocation)
1501{
1502 CheckComArgOutPointerValid(aLocation);
1503
1504 AutoCaller autoCaller(this);
1505 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1506
1507 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1508
1509 m->strLocationFull.cloneTo(aLocation);
1510
1511 return S_OK;
1512}
1513
1514STDMETHODIMP Medium::COMSETTER(Location)(IN_BSTR aLocation)
1515{
1516 CheckComArgStrNotEmptyOrNull(aLocation);
1517
1518 AutoCaller autoCaller(this);
1519 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1520
1521 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
1522
1523 /// @todo NEWMEDIA for file names, add the default extension if no extension
1524 /// is present (using the information from the VD backend which also implies
1525 /// that one more parameter should be passed to setLocation() requesting
1526 /// that functionality since it is only allowed when called from this method
1527
1528 /// @todo NEWMEDIA rename the file and set m->location on success, then save
1529 /// the global registry (and local registries of portable VMs referring to
1530 /// this medium), this will also require to add the mRegistered flag to data
1531
1532 ReturnComNotImplemented();
1533}
1534
1535STDMETHODIMP Medium::COMGETTER(Name)(BSTR *aName)
1536{
1537 CheckComArgOutPointerValid(aName);
1538
1539 AutoCaller autoCaller(this);
1540 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1541
1542 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1543
1544 getName().cloneTo(aName);
1545
1546 return S_OK;
1547}
1548
1549STDMETHODIMP Medium::COMGETTER(DeviceType)(DeviceType_T *aDeviceType)
1550{
1551 CheckComArgOutPointerValid(aDeviceType);
1552
1553 AutoCaller autoCaller(this);
1554 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1555
1556 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1557
1558 *aDeviceType = m->devType;
1559
1560 return S_OK;
1561}
1562
1563STDMETHODIMP Medium::COMGETTER(HostDrive)(BOOL *aHostDrive)
1564{
1565 CheckComArgOutPointerValid(aHostDrive);
1566
1567 AutoCaller autoCaller(this);
1568 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1569
1570 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1571
1572 *aHostDrive = m->hostDrive;
1573
1574 return S_OK;
1575}
1576
1577STDMETHODIMP Medium::COMGETTER(Size)(LONG64 *aSize)
1578{
1579 CheckComArgOutPointerValid(aSize);
1580
1581 AutoCaller autoCaller(this);
1582 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1583
1584 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1585
1586 *aSize = m->size;
1587
1588 return S_OK;
1589}
1590
1591STDMETHODIMP Medium::COMGETTER(Format)(BSTR *aFormat)
1592{
1593 CheckComArgOutPointerValid(aFormat);
1594
1595 AutoCaller autoCaller(this);
1596 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1597
1598 /* no need to lock, m->strFormat is const */
1599 m->strFormat.cloneTo(aFormat);
1600
1601 return S_OK;
1602}
1603
1604STDMETHODIMP Medium::COMGETTER(MediumFormat)(IMediumFormat **aMediumFormat)
1605{
1606 CheckComArgOutPointerValid(aMediumFormat);
1607
1608 AutoCaller autoCaller(this);
1609 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1610
1611 /* no need to lock, m->formatObj is const */
1612 m->formatObj.queryInterfaceTo(aMediumFormat);
1613
1614 return S_OK;
1615}
1616
1617STDMETHODIMP Medium::COMGETTER(Type)(MediumType_T *aType)
1618{
1619 CheckComArgOutPointerValid(aType);
1620
1621 AutoCaller autoCaller(this);
1622 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1623
1624 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1625
1626 *aType = m->type;
1627
1628 return S_OK;
1629}
1630
1631STDMETHODIMP Medium::COMSETTER(Type)(MediumType_T aType)
1632{
1633 AutoCaller autoCaller(this);
1634 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1635
1636 // we access mParent and members
1637 AutoWriteLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
1638 AutoWriteLock mlock(this COMMA_LOCKVAL_SRC_POS);
1639
1640 switch (m->state)
1641 {
1642 case MediumState_Created:
1643 case MediumState_Inaccessible:
1644 break;
1645 default:
1646 return setStateError();
1647 }
1648
1649 if (m->type == aType)
1650 {
1651 /* Nothing to do */
1652 return S_OK;
1653 }
1654
1655 DeviceType_T devType = getDeviceType();
1656 // DVD media can only be readonly.
1657 if (devType == DeviceType_DVD && aType != MediumType_Readonly)
1658 return setError(VBOX_E_INVALID_OBJECT_STATE,
1659 tr("Cannot change the type of DVD medium '%s'"),
1660 m->strLocationFull.c_str());
1661 // Floppy media can only be writethrough or readonly.
1662 if ( devType == DeviceType_Floppy
1663 && aType != MediumType_Writethrough
1664 && aType != MediumType_Readonly)
1665 return setError(VBOX_E_INVALID_OBJECT_STATE,
1666 tr("Cannot change the type of floppy medium '%s'"),
1667 m->strLocationFull.c_str());
1668
1669 /* cannot change the type of a differencing medium */
1670 if (m->pParent)
1671 return setError(VBOX_E_INVALID_OBJECT_STATE,
1672 tr("Cannot change the type of medium '%s' because it is a differencing medium"),
1673 m->strLocationFull.c_str());
1674
1675 /* Cannot change the type of a medium being in use by more than one VM.
1676 * If the change is to Immutable or MultiAttach then it must not be
1677 * directly attached to any VM, otherwise the assumptions about indirect
1678 * attachment elsewhere are violated and the VM becomes inaccessible.
1679 * Attaching an immutable medium triggers the diff creation, and this is
1680 * vital for the correct operation. */
1681 if ( m->backRefs.size() > 1
1682 || ( ( aType == MediumType_Immutable
1683 || aType == MediumType_MultiAttach)
1684 && m->backRefs.size() > 0))
1685 return setError(VBOX_E_INVALID_OBJECT_STATE,
1686 tr("Cannot change the type of medium '%s' because it is attached to %d virtual machines"),
1687 m->strLocationFull.c_str(), m->backRefs.size());
1688
1689 switch (aType)
1690 {
1691 case MediumType_Normal:
1692 case MediumType_Immutable:
1693 case MediumType_MultiAttach:
1694 {
1695 /* normal can be easily converted to immutable and vice versa even
1696 * if they have children as long as they are not attached to any
1697 * machine themselves */
1698 break;
1699 }
1700 case MediumType_Writethrough:
1701 case MediumType_Shareable:
1702 case MediumType_Readonly:
1703 {
1704 /* cannot change to writethrough, shareable or readonly
1705 * if there are children */
1706 if (getChildren().size() != 0)
1707 return setError(VBOX_E_OBJECT_IN_USE,
1708 tr("Cannot change type for medium '%s' since it has %d child media"),
1709 m->strLocationFull.c_str(), getChildren().size());
1710 if (aType == MediumType_Shareable)
1711 {
1712 MediumVariant_T variant = getVariant();
1713 if (!(variant & MediumVariant_Fixed))
1714 return setError(VBOX_E_INVALID_OBJECT_STATE,
1715 tr("Cannot change type for medium '%s' to 'Shareable' since it is a dynamic medium storage unit"),
1716 m->strLocationFull.c_str());
1717 }
1718 else if (aType == MediumType_Readonly && devType == DeviceType_HardDisk)
1719 {
1720 // Readonly hard disks are not allowed, this medium type is reserved for
1721 // DVDs and floppy images at the moment. Later we might allow readonly hard
1722 // disks, but that's extremely unusual and many guest OSes will have trouble.
1723 return setError(VBOX_E_INVALID_OBJECT_STATE,
1724 tr("Cannot change type for medium '%s' to 'Readonly' since it is a hard disk"),
1725 m->strLocationFull.c_str());
1726 }
1727 break;
1728 }
1729 default:
1730 AssertFailedReturn(E_FAIL);
1731 }
1732
1733 if (aType == MediumType_MultiAttach)
1734 {
1735 // This type is new with VirtualBox 4.0 and therefore requires settings
1736 // version 1.11 in the settings backend. Unfortunately it is not enough to do
1737 // the usual routine in MachineConfigFile::bumpSettingsVersionIfNeeded() for
1738 // two reasons: The medium type is a property of the media registry tree, which
1739 // can reside in the global config file (for pre-4.0 media); we would therefore
1740 // possibly need to bump the global config version. We don't want to do that though
1741 // because that might make downgrading to pre-4.0 impossible.
1742 // As a result, we can only use these two new types if the medium is NOT in the
1743 // global registry:
1744 const Guid &uuidGlobalRegistry = m->pVirtualBox->getGlobalRegistryId();
1745 if (isInRegistry(uuidGlobalRegistry))
1746 return setError(VBOX_E_INVALID_OBJECT_STATE,
1747 tr("Cannot change type for medium '%s': the media type 'MultiAttach' can only be used "
1748 "on media registered with a machine that was created with VirtualBox 4.0 or later"),
1749 m->strLocationFull.c_str());
1750 }
1751
1752 m->type = aType;
1753
1754 // save the settings
1755 mlock.release();
1756 treeLock.release();
1757 markRegistriesModified();
1758 m->pVirtualBox->saveModifiedRegistries();
1759
1760 return S_OK;
1761}
1762
1763STDMETHODIMP Medium::COMGETTER(AllowedTypes)(ComSafeArrayOut(MediumType_T, aAllowedTypes))
1764{
1765 CheckComArgOutSafeArrayPointerValid(aAllowedTypes);
1766 NOREF(aAllowedTypes);
1767#ifndef RT_OS_WINDOWS
1768 NOREF(aAllowedTypesSize);
1769#endif
1770
1771 AutoCaller autoCaller(this);
1772 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1773
1774 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1775
1776 ReturnComNotImplemented();
1777}
1778
1779STDMETHODIMP Medium::COMGETTER(Parent)(IMedium **aParent)
1780{
1781 CheckComArgOutPointerValid(aParent);
1782
1783 AutoCaller autoCaller(this);
1784 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1785
1786 /* we access mParent */
1787 AutoReadLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
1788
1789 m->pParent.queryInterfaceTo(aParent);
1790
1791 return S_OK;
1792}
1793
1794STDMETHODIMP Medium::COMGETTER(Children)(ComSafeArrayOut(IMedium *, aChildren))
1795{
1796 CheckComArgOutSafeArrayPointerValid(aChildren);
1797
1798 AutoCaller autoCaller(this);
1799 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1800
1801 /* we access children */
1802 AutoReadLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
1803
1804 SafeIfaceArray<IMedium> children(this->getChildren());
1805 children.detachTo(ComSafeArrayOutArg(aChildren));
1806
1807 return S_OK;
1808}
1809
1810STDMETHODIMP Medium::COMGETTER(Base)(IMedium **aBase)
1811{
1812 CheckComArgOutPointerValid(aBase);
1813
1814 /* base() will do callers/locking */
1815
1816 getBase().queryInterfaceTo(aBase);
1817
1818 return S_OK;
1819}
1820
1821STDMETHODIMP Medium::COMGETTER(ReadOnly)(BOOL *aReadOnly)
1822{
1823 CheckComArgOutPointerValid(aReadOnly);
1824
1825 AutoCaller autoCaller(this);
1826 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1827
1828 /* isReadOnly() will do locking */
1829
1830 *aReadOnly = isReadOnly();
1831
1832 return S_OK;
1833}
1834
1835STDMETHODIMP Medium::COMGETTER(LogicalSize)(LONG64 *aLogicalSize)
1836{
1837 CheckComArgOutPointerValid(aLogicalSize);
1838
1839 {
1840 AutoCaller autoCaller(this);
1841 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1842
1843 /* we access mParent */
1844 AutoReadLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
1845
1846 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1847
1848 if (m->pParent.isNull())
1849 {
1850 *aLogicalSize = m->logicalSize;
1851
1852 return S_OK;
1853 }
1854 }
1855
1856 /* We assume that some backend may decide to return a meaningless value in
1857 * response to VDGetSize() for differencing media and therefore always
1858 * ask the base medium ourselves. */
1859
1860 /* base() will do callers/locking */
1861
1862 return getBase()->COMGETTER(LogicalSize)(aLogicalSize);
1863}
1864
1865STDMETHODIMP Medium::COMGETTER(AutoReset)(BOOL *aAutoReset)
1866{
1867 CheckComArgOutPointerValid(aAutoReset);
1868
1869 AutoCaller autoCaller(this);
1870 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1871
1872 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1873
1874 if (m->pParent.isNull())
1875 *aAutoReset = FALSE;
1876 else
1877 *aAutoReset = m->autoReset;
1878
1879 return S_OK;
1880}
1881
1882STDMETHODIMP Medium::COMSETTER(AutoReset)(BOOL aAutoReset)
1883{
1884 AutoCaller autoCaller(this);
1885 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1886
1887 AutoWriteLock mlock(this COMMA_LOCKVAL_SRC_POS);
1888
1889 if (m->pParent.isNull())
1890 return setError(VBOX_E_NOT_SUPPORTED,
1891 tr("Medium '%s' is not differencing"),
1892 m->strLocationFull.c_str());
1893
1894 if (m->autoReset != !!aAutoReset)
1895 {
1896 m->autoReset = !!aAutoReset;
1897
1898 // save the settings
1899 mlock.release();
1900 markRegistriesModified();
1901 m->pVirtualBox->saveModifiedRegistries();
1902 }
1903
1904 return S_OK;
1905}
1906
1907STDMETHODIMP Medium::COMGETTER(LastAccessError)(BSTR *aLastAccessError)
1908{
1909 CheckComArgOutPointerValid(aLastAccessError);
1910
1911 AutoCaller autoCaller(this);
1912 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1913
1914 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1915
1916 m->strLastAccessError.cloneTo(aLastAccessError);
1917
1918 return S_OK;
1919}
1920
1921STDMETHODIMP Medium::COMGETTER(MachineIds)(ComSafeArrayOut(BSTR,aMachineIds))
1922{
1923 CheckComArgOutSafeArrayPointerValid(aMachineIds);
1924
1925 AutoCaller autoCaller(this);
1926 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1927
1928 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
1929
1930 com::SafeArray<BSTR> machineIds;
1931
1932 if (m->backRefs.size() != 0)
1933 {
1934 machineIds.reset(m->backRefs.size());
1935
1936 size_t i = 0;
1937 for (BackRefList::const_iterator it = m->backRefs.begin();
1938 it != m->backRefs.end(); ++it, ++i)
1939 {
1940 it->machineId.toUtf16().detachTo(&machineIds[i]);
1941 }
1942 }
1943
1944 machineIds.detachTo(ComSafeArrayOutArg(aMachineIds));
1945
1946 return S_OK;
1947}
1948
1949STDMETHODIMP Medium::SetIds(BOOL aSetImageId,
1950 IN_BSTR aImageId,
1951 BOOL aSetParentId,
1952 IN_BSTR aParentId)
1953{
1954 AutoCaller autoCaller(this);
1955 if (FAILED(autoCaller.rc())) return autoCaller.rc();
1956
1957 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
1958
1959 switch (m->state)
1960 {
1961 case MediumState_Created:
1962 break;
1963 default:
1964 return setStateError();
1965 }
1966
1967 Guid imageId, parentId;
1968 if (aSetImageId)
1969 {
1970 if (Bstr(aImageId).isEmpty())
1971 imageId.create();
1972 else
1973 {
1974 imageId = Guid(aImageId);
1975 if (imageId.isEmpty())
1976 return setError(E_INVALIDARG, tr("Argument %s is empty"), "aImageId");
1977 }
1978 }
1979 if (aSetParentId)
1980 {
1981 if (Bstr(aParentId).isEmpty())
1982 parentId.create();
1983 else
1984 parentId = Guid(aParentId);
1985 }
1986
1987 unconst(m->uuidImage) = imageId;
1988 unconst(m->uuidParentImage) = parentId;
1989
1990 // must not hold any locks before calling Medium::queryInfo
1991 alock.release();
1992
1993 HRESULT rc = queryInfo(!!aSetImageId /* fSetImageId */,
1994 !!aSetParentId /* fSetParentId */);
1995
1996 return rc;
1997}
1998
1999STDMETHODIMP Medium::RefreshState(MediumState_T *aState)
2000{
2001 CheckComArgOutPointerValid(aState);
2002
2003 AutoCaller autoCaller(this);
2004 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2005
2006 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
2007
2008 HRESULT rc = S_OK;
2009
2010 switch (m->state)
2011 {
2012 case MediumState_Created:
2013 case MediumState_Inaccessible:
2014 case MediumState_LockedRead:
2015 {
2016 // must not hold any locks before calling Medium::queryInfo
2017 alock.release();
2018
2019 rc = queryInfo(false /* fSetImageId */, false /* fSetParentId */);
2020
2021 alock.acquire();
2022 break;
2023 }
2024 default:
2025 break;
2026 }
2027
2028 *aState = m->state;
2029
2030 return rc;
2031}
2032
2033STDMETHODIMP Medium::GetSnapshotIds(IN_BSTR aMachineId,
2034 ComSafeArrayOut(BSTR, aSnapshotIds))
2035{
2036 CheckComArgExpr(aMachineId, Guid(aMachineId).isEmpty() == false);
2037 CheckComArgOutSafeArrayPointerValid(aSnapshotIds);
2038
2039 AutoCaller autoCaller(this);
2040 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2041
2042 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
2043
2044 com::SafeArray<BSTR> snapshotIds;
2045
2046 Guid id(aMachineId);
2047 for (BackRefList::const_iterator it = m->backRefs.begin();
2048 it != m->backRefs.end(); ++it)
2049 {
2050 if (it->machineId == id)
2051 {
2052 size_t size = it->llSnapshotIds.size();
2053
2054 /* if the medium is attached to the machine in the current state, we
2055 * return its ID as the first element of the array */
2056 if (it->fInCurState)
2057 ++size;
2058
2059 if (size > 0)
2060 {
2061 snapshotIds.reset(size);
2062
2063 size_t j = 0;
2064 if (it->fInCurState)
2065 it->machineId.toUtf16().detachTo(&snapshotIds[j++]);
2066
2067 for (GuidList::const_iterator jt = it->llSnapshotIds.begin();
2068 jt != it->llSnapshotIds.end();
2069 ++jt, ++j)
2070 {
2071 (*jt).toUtf16().detachTo(&snapshotIds[j]);
2072 }
2073 }
2074
2075 break;
2076 }
2077 }
2078
2079 snapshotIds.detachTo(ComSafeArrayOutArg(aSnapshotIds));
2080
2081 return S_OK;
2082}
2083
2084/**
2085 * @note @a aState may be NULL if the state value is not needed (only for
2086 * in-process calls).
2087 */
2088STDMETHODIMP Medium::LockRead(MediumState_T *aState)
2089{
2090 AutoCaller autoCaller(this);
2091 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2092
2093 /* Must not hold the object lock, as we need control over it below. */
2094 Assert(!isWriteLockOnCurrentThread());
2095 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
2096
2097 /* Wait for a concurrently running Medium::queryInfo to complete. */
2098 if (m->queryInfoRunning)
2099 {
2100 /* Must not hold the media tree lock, as Medium::queryInfo needs this
2101 * lock and thus we would run into a deadlock here. */
2102 Assert(!m->pVirtualBox->getMediaTreeLockHandle().isWriteLockOnCurrentThread());
2103 while (m->queryInfoRunning)
2104 {
2105 alock.release();
2106 {
2107 AutoReadLock qlock(m->queryInfoSem COMMA_LOCKVAL_SRC_POS);
2108 }
2109 alock.acquire();
2110 }
2111 }
2112
2113 /* return the current state before */
2114 if (aState)
2115 *aState = m->state;
2116
2117 HRESULT rc = S_OK;
2118
2119 switch (m->state)
2120 {
2121 case MediumState_Created:
2122 case MediumState_Inaccessible:
2123 case MediumState_LockedRead:
2124 {
2125 ++m->readers;
2126
2127 ComAssertMsgBreak(m->readers != 0, ("Counter overflow"), rc = E_FAIL);
2128
2129 /* Remember pre-lock state */
2130 if (m->state != MediumState_LockedRead)
2131 m->preLockState = m->state;
2132
2133 LogFlowThisFunc(("Okay - prev state=%d readers=%d\n", m->state, m->readers));
2134 m->state = MediumState_LockedRead;
2135
2136 break;
2137 }
2138 default:
2139 {
2140 LogFlowThisFunc(("Failing - state=%d\n", m->state));
2141 rc = setStateError();
2142 break;
2143 }
2144 }
2145
2146 return rc;
2147}
2148
2149/**
2150 * @note @a aState may be NULL if the state value is not needed (only for
2151 * in-process calls).
2152 */
2153STDMETHODIMP Medium::UnlockRead(MediumState_T *aState)
2154{
2155 AutoCaller autoCaller(this);
2156 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2157
2158 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
2159
2160 HRESULT rc = S_OK;
2161
2162 switch (m->state)
2163 {
2164 case MediumState_LockedRead:
2165 {
2166 ComAssertMsgBreak(m->readers != 0, ("Counter underflow"), rc = E_FAIL);
2167 --m->readers;
2168
2169 /* Reset the state after the last reader */
2170 if (m->readers == 0)
2171 {
2172 m->state = m->preLockState;
2173 /* There are cases where we inject the deleting state into
2174 * a medium locked for reading. Make sure #unmarkForDeletion()
2175 * gets the right state afterwards. */
2176 if (m->preLockState == MediumState_Deleting)
2177 m->preLockState = MediumState_Created;
2178 }
2179
2180 LogFlowThisFunc(("new state=%d\n", m->state));
2181 break;
2182 }
2183 default:
2184 {
2185 LogFlowThisFunc(("Failing - state=%d\n", m->state));
2186 rc = setError(VBOX_E_INVALID_OBJECT_STATE,
2187 tr("Medium '%s' is not locked for reading"),
2188 m->strLocationFull.c_str());
2189 break;
2190 }
2191 }
2192
2193 /* return the current state after */
2194 if (aState)
2195 *aState = m->state;
2196
2197 return rc;
2198}
2199
2200/**
2201 * @note @a aState may be NULL if the state value is not needed (only for
2202 * in-process calls).
2203 */
2204STDMETHODIMP Medium::LockWrite(MediumState_T *aState)
2205{
2206 AutoCaller autoCaller(this);
2207 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2208
2209 /* Must not hold the object lock, as we need control over it below. */
2210 Assert(!isWriteLockOnCurrentThread());
2211 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
2212
2213 /* Wait for a concurrently running Medium::queryInfo to complete. */
2214 if (m->queryInfoRunning)
2215 {
2216 /* Must not hold the media tree lock, as Medium::queryInfo needs this
2217 * lock and thus we would run into a deadlock here. */
2218 Assert(!m->pVirtualBox->getMediaTreeLockHandle().isWriteLockOnCurrentThread());
2219 while (m->queryInfoRunning)
2220 {
2221 alock.release();
2222 {
2223 AutoReadLock qlock(m->queryInfoSem COMMA_LOCKVAL_SRC_POS);
2224 }
2225 alock.acquire();
2226 }
2227 }
2228
2229 /* return the current state before */
2230 if (aState)
2231 *aState = m->state;
2232
2233 HRESULT rc = S_OK;
2234
2235 switch (m->state)
2236 {
2237 case MediumState_Created:
2238 case MediumState_Inaccessible:
2239 {
2240 m->preLockState = m->state;
2241
2242 LogFlowThisFunc(("Okay - prev state=%d locationFull=%s\n", m->state, getLocationFull().c_str()));
2243 m->state = MediumState_LockedWrite;
2244 break;
2245 }
2246 default:
2247 {
2248 LogFlowThisFunc(("Failing - state=%d locationFull=%s\n", m->state, getLocationFull().c_str()));
2249 rc = setStateError();
2250 break;
2251 }
2252 }
2253
2254 return rc;
2255}
2256
2257/**
2258 * @note @a aState may be NULL if the state value is not needed (only for
2259 * in-process calls).
2260 */
2261STDMETHODIMP Medium::UnlockWrite(MediumState_T *aState)
2262{
2263 AutoCaller autoCaller(this);
2264 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2265
2266 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
2267
2268 HRESULT rc = S_OK;
2269
2270 switch (m->state)
2271 {
2272 case MediumState_LockedWrite:
2273 {
2274 m->state = m->preLockState;
2275 /* There are cases where we inject the deleting state into
2276 * a medium locked for writing. Make sure #unmarkForDeletion()
2277 * gets the right state afterwards. */
2278 if (m->preLockState == MediumState_Deleting)
2279 m->preLockState = MediumState_Created;
2280 LogFlowThisFunc(("new state=%d locationFull=%s\n", m->state, getLocationFull().c_str()));
2281 break;
2282 }
2283 default:
2284 {
2285 LogFlowThisFunc(("Failing - state=%d locationFull=%s\n", m->state, getLocationFull().c_str()));
2286 rc = setError(VBOX_E_INVALID_OBJECT_STATE,
2287 tr("Medium '%s' is not locked for writing"),
2288 m->strLocationFull.c_str());
2289 break;
2290 }
2291 }
2292
2293 /* return the current state after */
2294 if (aState)
2295 *aState = m->state;
2296
2297 return rc;
2298}
2299
2300STDMETHODIMP Medium::Close()
2301{
2302 AutoCaller autoCaller(this);
2303 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2304
2305 // make a copy of VirtualBox pointer which gets nulled by uninit()
2306 ComObjPtr<VirtualBox> pVirtualBox(m->pVirtualBox);
2307
2308 MultiResult mrc = close(autoCaller);
2309
2310 pVirtualBox->saveModifiedRegistries();
2311
2312 return mrc;
2313}
2314
2315STDMETHODIMP Medium::GetProperty(IN_BSTR aName, BSTR *aValue)
2316{
2317 CheckComArgStrNotEmptyOrNull(aName);
2318 CheckComArgOutPointerValid(aValue);
2319
2320 AutoCaller autoCaller(this);
2321 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2322
2323 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
2324
2325 settings::StringsMap::const_iterator it = m->mapProperties.find(Utf8Str(aName));
2326 if (it == m->mapProperties.end())
2327 return setError(VBOX_E_OBJECT_NOT_FOUND,
2328 tr("Property '%ls' does not exist"), aName);
2329
2330 it->second.cloneTo(aValue);
2331
2332 return S_OK;
2333}
2334
2335STDMETHODIMP Medium::SetProperty(IN_BSTR aName, IN_BSTR aValue)
2336{
2337 CheckComArgStrNotEmptyOrNull(aName);
2338
2339 AutoCaller autoCaller(this);
2340 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2341
2342 AutoWriteLock mlock(this COMMA_LOCKVAL_SRC_POS);
2343
2344 switch (m->state)
2345 {
2346 case MediumState_Created:
2347 case MediumState_Inaccessible:
2348 break;
2349 default:
2350 return setStateError();
2351 }
2352
2353 settings::StringsMap::iterator it = m->mapProperties.find(Utf8Str(aName));
2354 if (it == m->mapProperties.end())
2355 return setError(VBOX_E_OBJECT_NOT_FOUND,
2356 tr("Property '%ls' does not exist"),
2357 aName);
2358
2359 it->second = aValue;
2360
2361 // save the settings
2362 mlock.release();
2363 markRegistriesModified();
2364 m->pVirtualBox->saveModifiedRegistries();
2365
2366 return S_OK;
2367}
2368
2369STDMETHODIMP Medium::GetProperties(IN_BSTR aNames,
2370 ComSafeArrayOut(BSTR, aReturnNames),
2371 ComSafeArrayOut(BSTR, aReturnValues))
2372{
2373 CheckComArgOutSafeArrayPointerValid(aReturnNames);
2374 CheckComArgOutSafeArrayPointerValid(aReturnValues);
2375
2376 AutoCaller autoCaller(this);
2377 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2378
2379 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
2380
2381 /// @todo make use of aNames according to the documentation
2382 NOREF(aNames);
2383
2384 com::SafeArray<BSTR> names(m->mapProperties.size());
2385 com::SafeArray<BSTR> values(m->mapProperties.size());
2386 size_t i = 0;
2387
2388 for (settings::StringsMap::const_iterator it = m->mapProperties.begin();
2389 it != m->mapProperties.end();
2390 ++it)
2391 {
2392 it->first.cloneTo(&names[i]);
2393 it->second.cloneTo(&values[i]);
2394 ++i;
2395 }
2396
2397 names.detachTo(ComSafeArrayOutArg(aReturnNames));
2398 values.detachTo(ComSafeArrayOutArg(aReturnValues));
2399
2400 return S_OK;
2401}
2402
2403STDMETHODIMP Medium::SetProperties(ComSafeArrayIn(IN_BSTR, aNames),
2404 ComSafeArrayIn(IN_BSTR, aValues))
2405{
2406 CheckComArgSafeArrayNotNull(aNames);
2407 CheckComArgSafeArrayNotNull(aValues);
2408
2409 AutoCaller autoCaller(this);
2410 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2411
2412 AutoWriteLock mlock(this COMMA_LOCKVAL_SRC_POS);
2413
2414 com::SafeArray<IN_BSTR> names(ComSafeArrayInArg(aNames));
2415 com::SafeArray<IN_BSTR> values(ComSafeArrayInArg(aValues));
2416
2417 /* first pass: validate names */
2418 for (size_t i = 0;
2419 i < names.size();
2420 ++i)
2421 {
2422 if (m->mapProperties.find(Utf8Str(names[i])) == m->mapProperties.end())
2423 return setError(VBOX_E_OBJECT_NOT_FOUND,
2424 tr("Property '%ls' does not exist"), names[i]);
2425 }
2426
2427 /* second pass: assign */
2428 for (size_t i = 0;
2429 i < names.size();
2430 ++i)
2431 {
2432 settings::StringsMap::iterator it = m->mapProperties.find(Utf8Str(names[i]));
2433 AssertReturn(it != m->mapProperties.end(), E_FAIL);
2434
2435 it->second = Utf8Str(values[i]);
2436 }
2437
2438 // save the settings
2439 mlock.release();
2440 markRegistriesModified();
2441 m->pVirtualBox->saveModifiedRegistries();
2442
2443 return S_OK;
2444}
2445
2446STDMETHODIMP Medium::CreateBaseStorage(LONG64 aLogicalSize,
2447 ULONG aVariant,
2448 IProgress **aProgress)
2449{
2450 CheckComArgOutPointerValid(aProgress);
2451 if (aLogicalSize < 0)
2452 return setError(E_INVALIDARG, tr("The medium size argument (%lld) is negative"), aLogicalSize);
2453
2454 AutoCaller autoCaller(this);
2455 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2456
2457 HRESULT rc = S_OK;
2458 ComObjPtr <Progress> pProgress;
2459 Medium::Task *pTask = NULL;
2460
2461 try
2462 {
2463 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
2464
2465 aVariant = (MediumVariant_T)((unsigned)aVariant & (unsigned)~MediumVariant_Diff);
2466 if ( !(aVariant & MediumVariant_Fixed)
2467 && !(m->formatObj->getCapabilities() & MediumFormatCapabilities_CreateDynamic))
2468 throw setError(VBOX_E_NOT_SUPPORTED,
2469 tr("Medium format '%s' does not support dynamic storage creation"),
2470 m->strFormat.c_str());
2471 if ( (aVariant & MediumVariant_Fixed)
2472 && !(m->formatObj->getCapabilities() & MediumFormatCapabilities_CreateDynamic))
2473 throw setError(VBOX_E_NOT_SUPPORTED,
2474 tr("Medium format '%s' does not support fixed storage creation"),
2475 m->strFormat.c_str());
2476
2477 if (m->state != MediumState_NotCreated)
2478 throw setStateError();
2479
2480 pProgress.createObject();
2481 rc = pProgress->init(m->pVirtualBox,
2482 static_cast<IMedium*>(this),
2483 (aVariant & MediumVariant_Fixed)
2484 ? BstrFmt(tr("Creating fixed medium storage unit '%s'"), m->strLocationFull.c_str()).raw()
2485 : BstrFmt(tr("Creating dynamic medium storage unit '%s'"), m->strLocationFull.c_str()).raw(),
2486 TRUE /* aCancelable */);
2487 if (FAILED(rc))
2488 throw rc;
2489
2490 /* setup task object to carry out the operation asynchronously */
2491 pTask = new Medium::CreateBaseTask(this, pProgress, aLogicalSize,
2492 (MediumVariant_T)aVariant);
2493 rc = pTask->rc();
2494 AssertComRC(rc);
2495 if (FAILED(rc))
2496 throw rc;
2497
2498 m->state = MediumState_Creating;
2499 }
2500 catch (HRESULT aRC) { rc = aRC; }
2501
2502 if (SUCCEEDED(rc))
2503 {
2504 rc = startThread(pTask);
2505
2506 if (SUCCEEDED(rc))
2507 pProgress.queryInterfaceTo(aProgress);
2508 }
2509 else if (pTask != NULL)
2510 delete pTask;
2511
2512 return rc;
2513}
2514
2515STDMETHODIMP Medium::DeleteStorage(IProgress **aProgress)
2516{
2517 CheckComArgOutPointerValid(aProgress);
2518
2519 AutoCaller autoCaller(this);
2520 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2521
2522 ComObjPtr<Progress> pProgress;
2523
2524 MultiResult mrc = deleteStorage(&pProgress,
2525 false /* aWait */);
2526 /* Must save the registries in any case, since an entry was removed. */
2527 m->pVirtualBox->saveModifiedRegistries();
2528
2529 if (SUCCEEDED(mrc))
2530 pProgress.queryInterfaceTo(aProgress);
2531
2532 return mrc;
2533}
2534
2535STDMETHODIMP Medium::CreateDiffStorage(IMedium *aTarget,
2536 ULONG aVariant,
2537 IProgress **aProgress)
2538{
2539 CheckComArgNotNull(aTarget);
2540 CheckComArgOutPointerValid(aProgress);
2541
2542 AutoCaller autoCaller(this);
2543 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2544
2545 ComObjPtr<Medium> diff = static_cast<Medium*>(aTarget);
2546
2547 // locking: we need the tree lock first because we access parent pointers
2548 AutoMultiWriteLock3 alock(&m->pVirtualBox->getMediaTreeLockHandle(),
2549 this->lockHandle(), diff->lockHandle() COMMA_LOCKVAL_SRC_POS);
2550
2551 if (m->type == MediumType_Writethrough)
2552 return setError(VBOX_E_INVALID_OBJECT_STATE,
2553 tr("Medium type of '%s' is Writethrough"),
2554 m->strLocationFull.c_str());
2555 else if (m->type == MediumType_Shareable)
2556 return setError(VBOX_E_INVALID_OBJECT_STATE,
2557 tr("Medium type of '%s' is Shareable"),
2558 m->strLocationFull.c_str());
2559 else if (m->type == MediumType_Readonly)
2560 return setError(VBOX_E_INVALID_OBJECT_STATE,
2561 tr("Medium type of '%s' is Readonly"),
2562 m->strLocationFull.c_str());
2563
2564 /* Apply the normal locking logic to the entire chain. */
2565 MediumLockList *pMediumLockList(new MediumLockList());
2566 alock.release();
2567 HRESULT rc = diff->createMediumLockList(true /* fFailIfInaccessible */,
2568 true /* fMediumLockWrite */,
2569 this,
2570 *pMediumLockList);
2571 alock.acquire();
2572 if (FAILED(rc))
2573 {
2574 delete pMediumLockList;
2575 return rc;
2576 }
2577
2578 alock.release();
2579 rc = pMediumLockList->Lock();
2580 alock.acquire();
2581 if (FAILED(rc))
2582 {
2583 delete pMediumLockList;
2584
2585 return setError(rc, tr("Could not lock medium when creating diff '%s'"),
2586 diff->getLocationFull().c_str());
2587 }
2588
2589 Guid parentMachineRegistry;
2590 if (getFirstRegistryMachineId(parentMachineRegistry))
2591 {
2592 /* since this medium has been just created it isn't associated yet */
2593 diff->m->llRegistryIDs.push_back(parentMachineRegistry);
2594 alock.release();
2595 diff->markRegistriesModified();
2596 alock.acquire();
2597 }
2598
2599 alock.release();
2600
2601 ComObjPtr <Progress> pProgress;
2602
2603 rc = createDiffStorage(diff, (MediumVariant_T)aVariant, pMediumLockList,
2604 &pProgress, false /* aWait */);
2605 if (FAILED(rc))
2606 delete pMediumLockList;
2607 else
2608 pProgress.queryInterfaceTo(aProgress);
2609
2610 return rc;
2611}
2612
2613STDMETHODIMP Medium::MergeTo(IMedium *aTarget, IProgress **aProgress)
2614{
2615 CheckComArgNotNull(aTarget);
2616 CheckComArgOutPointerValid(aProgress);
2617 ComAssertRet(aTarget != this, E_INVALIDARG);
2618
2619 AutoCaller autoCaller(this);
2620 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2621
2622 ComObjPtr<Medium> pTarget = static_cast<Medium*>(aTarget);
2623
2624 bool fMergeForward = false;
2625 ComObjPtr<Medium> pParentForTarget;
2626 MediaList childrenToReparent;
2627 MediumLockList *pMediumLockList = NULL;
2628
2629 HRESULT rc = S_OK;
2630
2631 rc = prepareMergeTo(pTarget, NULL, NULL, true, fMergeForward,
2632 pParentForTarget, childrenToReparent, pMediumLockList);
2633 if (FAILED(rc)) return rc;
2634
2635 ComObjPtr <Progress> pProgress;
2636
2637 rc = mergeTo(pTarget, fMergeForward, pParentForTarget, childrenToReparent,
2638 pMediumLockList, &pProgress, false /* aWait */);
2639 if (FAILED(rc))
2640 cancelMergeTo(childrenToReparent, pMediumLockList);
2641 else
2642 pProgress.queryInterfaceTo(aProgress);
2643
2644 return rc;
2645}
2646
2647STDMETHODIMP Medium::CloneToBase(IMedium *aTarget,
2648 ULONG aVariant,
2649 IProgress **aProgress)
2650{
2651 int rc = S_OK;
2652 CheckComArgNotNull(aTarget);
2653 CheckComArgOutPointerValid(aProgress);
2654 rc = CloneTo(aTarget, aVariant, NULL, aProgress);
2655 return rc;
2656}
2657
2658STDMETHODIMP Medium::CloneTo(IMedium *aTarget,
2659 ULONG aVariant,
2660 IMedium *aParent,
2661 IProgress **aProgress)
2662{
2663 CheckComArgNotNull(aTarget);
2664 CheckComArgOutPointerValid(aProgress);
2665 ComAssertRet(aTarget != this, E_INVALIDARG);
2666
2667 AutoCaller autoCaller(this);
2668 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2669
2670 ComObjPtr<Medium> pTarget = static_cast<Medium*>(aTarget);
2671 ComObjPtr<Medium> pParent;
2672 if (aParent)
2673 pParent = static_cast<Medium*>(aParent);
2674
2675 HRESULT rc = S_OK;
2676 ComObjPtr<Progress> pProgress;
2677 Medium::Task *pTask = NULL;
2678
2679 try
2680 {
2681 // locking: we need the tree lock first because we access parent pointers
2682 // and we need to write-lock the media involved
2683 uint32_t cHandles = 3;
2684 LockHandle* pHandles[4] = { &m->pVirtualBox->getMediaTreeLockHandle(),
2685 this->lockHandle(),
2686 pTarget->lockHandle() };
2687 /* Only add parent to the lock if it is not null */
2688 if (!pParent.isNull())
2689 pHandles[cHandles++] = pParent->lockHandle();
2690 AutoWriteLock alock(cHandles,
2691 pHandles
2692 COMMA_LOCKVAL_SRC_POS);
2693
2694 if ( pTarget->m->state != MediumState_NotCreated
2695 && pTarget->m->state != MediumState_Created)
2696 throw pTarget->setStateError();
2697
2698 /* Build the source lock list. */
2699 MediumLockList *pSourceMediumLockList(new MediumLockList());
2700 alock.release();
2701 rc = createMediumLockList(true /* fFailIfInaccessible */,
2702 false /* fMediumLockWrite */,
2703 NULL,
2704 *pSourceMediumLockList);
2705 alock.acquire();
2706 if (FAILED(rc))
2707 {
2708 delete pSourceMediumLockList;
2709 throw rc;
2710 }
2711
2712 /* Build the target lock list (including the to-be parent chain). */
2713 MediumLockList *pTargetMediumLockList(new MediumLockList());
2714 alock.release();
2715 rc = pTarget->createMediumLockList(true /* fFailIfInaccessible */,
2716 true /* fMediumLockWrite */,
2717 pParent,
2718 *pTargetMediumLockList);
2719 alock.acquire();
2720 if (FAILED(rc))
2721 {
2722 delete pSourceMediumLockList;
2723 delete pTargetMediumLockList;
2724 throw rc;
2725 }
2726
2727 alock.release();
2728 rc = pSourceMediumLockList->Lock();
2729 alock.acquire();
2730 if (FAILED(rc))
2731 {
2732 delete pSourceMediumLockList;
2733 delete pTargetMediumLockList;
2734 throw setError(rc,
2735 tr("Failed to lock source media '%s'"),
2736 getLocationFull().c_str());
2737 }
2738 alock.release();
2739 rc = pTargetMediumLockList->Lock();
2740 alock.acquire();
2741 if (FAILED(rc))
2742 {
2743 delete pSourceMediumLockList;
2744 delete pTargetMediumLockList;
2745 throw setError(rc,
2746 tr("Failed to lock target media '%s'"),
2747 pTarget->getLocationFull().c_str());
2748 }
2749
2750 pProgress.createObject();
2751 rc = pProgress->init(m->pVirtualBox,
2752 static_cast <IMedium *>(this),
2753 BstrFmt(tr("Creating clone medium '%s'"), pTarget->m->strLocationFull.c_str()).raw(),
2754 TRUE /* aCancelable */);
2755 if (FAILED(rc))
2756 {
2757 delete pSourceMediumLockList;
2758 delete pTargetMediumLockList;
2759 throw rc;
2760 }
2761
2762 /* setup task object to carry out the operation asynchronously */
2763 pTask = new Medium::CloneTask(this, pProgress, pTarget,
2764 (MediumVariant_T)aVariant,
2765 pParent, UINT32_MAX, UINT32_MAX,
2766 pSourceMediumLockList, pTargetMediumLockList);
2767 rc = pTask->rc();
2768 AssertComRC(rc);
2769 if (FAILED(rc))
2770 throw rc;
2771
2772 if (pTarget->m->state == MediumState_NotCreated)
2773 pTarget->m->state = MediumState_Creating;
2774 }
2775 catch (HRESULT aRC) { rc = aRC; }
2776
2777 if (SUCCEEDED(rc))
2778 {
2779 rc = startThread(pTask);
2780
2781 if (SUCCEEDED(rc))
2782 pProgress.queryInterfaceTo(aProgress);
2783 }
2784 else if (pTask != NULL)
2785 delete pTask;
2786
2787 return rc;
2788}
2789
2790STDMETHODIMP Medium::Compact(IProgress **aProgress)
2791{
2792 CheckComArgOutPointerValid(aProgress);
2793
2794 AutoCaller autoCaller(this);
2795 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2796
2797 HRESULT rc = S_OK;
2798 ComObjPtr <Progress> pProgress;
2799 Medium::Task *pTask = NULL;
2800
2801 try
2802 {
2803 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
2804
2805 /* Build the medium lock list. */
2806 MediumLockList *pMediumLockList(new MediumLockList());
2807 alock.release();
2808 rc = createMediumLockList(true /* fFailIfInaccessible */ ,
2809 true /* fMediumLockWrite */,
2810 NULL,
2811 *pMediumLockList);
2812 alock.acquire();
2813 if (FAILED(rc))
2814 {
2815 delete pMediumLockList;
2816 throw rc;
2817 }
2818
2819 alock.release();
2820 rc = pMediumLockList->Lock();
2821 alock.acquire();
2822 if (FAILED(rc))
2823 {
2824 delete pMediumLockList;
2825 throw setError(rc,
2826 tr("Failed to lock media when compacting '%s'"),
2827 getLocationFull().c_str());
2828 }
2829
2830 pProgress.createObject();
2831 rc = pProgress->init(m->pVirtualBox,
2832 static_cast <IMedium *>(this),
2833 BstrFmt(tr("Compacting medium '%s'"), m->strLocationFull.c_str()).raw(),
2834 TRUE /* aCancelable */);
2835 if (FAILED(rc))
2836 {
2837 delete pMediumLockList;
2838 throw rc;
2839 }
2840
2841 /* setup task object to carry out the operation asynchronously */
2842 pTask = new Medium::CompactTask(this, pProgress, pMediumLockList);
2843 rc = pTask->rc();
2844 AssertComRC(rc);
2845 if (FAILED(rc))
2846 throw rc;
2847 }
2848 catch (HRESULT aRC) { rc = aRC; }
2849
2850 if (SUCCEEDED(rc))
2851 {
2852 rc = startThread(pTask);
2853
2854 if (SUCCEEDED(rc))
2855 pProgress.queryInterfaceTo(aProgress);
2856 }
2857 else if (pTask != NULL)
2858 delete pTask;
2859
2860 return rc;
2861}
2862
2863STDMETHODIMP Medium::Resize(LONG64 aLogicalSize, IProgress **aProgress)
2864{
2865 CheckComArgOutPointerValid(aProgress);
2866
2867 AutoCaller autoCaller(this);
2868 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2869
2870 HRESULT rc = S_OK;
2871 ComObjPtr <Progress> pProgress;
2872 Medium::Task *pTask = NULL;
2873
2874 try
2875 {
2876 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
2877
2878 /* Build the medium lock list. */
2879 MediumLockList *pMediumLockList(new MediumLockList());
2880 alock.release();
2881 rc = createMediumLockList(true /* fFailIfInaccessible */ ,
2882 true /* fMediumLockWrite */,
2883 NULL,
2884 *pMediumLockList);
2885 alock.acquire();
2886 if (FAILED(rc))
2887 {
2888 delete pMediumLockList;
2889 throw rc;
2890 }
2891
2892 alock.release();
2893 rc = pMediumLockList->Lock();
2894 alock.acquire();
2895 if (FAILED(rc))
2896 {
2897 delete pMediumLockList;
2898 throw setError(rc,
2899 tr("Failed to lock media when compacting '%s'"),
2900 getLocationFull().c_str());
2901 }
2902
2903 pProgress.createObject();
2904 rc = pProgress->init(m->pVirtualBox,
2905 static_cast <IMedium *>(this),
2906 BstrFmt(tr("Compacting medium '%s'"), m->strLocationFull.c_str()).raw(),
2907 TRUE /* aCancelable */);
2908 if (FAILED(rc))
2909 {
2910 delete pMediumLockList;
2911 throw rc;
2912 }
2913
2914 /* setup task object to carry out the operation asynchronously */
2915 pTask = new Medium::ResizeTask(this, aLogicalSize, pProgress, pMediumLockList);
2916 rc = pTask->rc();
2917 AssertComRC(rc);
2918 if (FAILED(rc))
2919 throw rc;
2920 }
2921 catch (HRESULT aRC) { rc = aRC; }
2922
2923 if (SUCCEEDED(rc))
2924 {
2925 rc = startThread(pTask);
2926
2927 if (SUCCEEDED(rc))
2928 pProgress.queryInterfaceTo(aProgress);
2929 }
2930 else if (pTask != NULL)
2931 delete pTask;
2932
2933 return rc;
2934}
2935
2936STDMETHODIMP Medium::Reset(IProgress **aProgress)
2937{
2938 CheckComArgOutPointerValid(aProgress);
2939
2940 AutoCaller autoCaller(this);
2941 if (FAILED(autoCaller.rc())) return autoCaller.rc();
2942
2943 HRESULT rc = S_OK;
2944 ComObjPtr <Progress> pProgress;
2945 Medium::Task *pTask = NULL;
2946
2947 try
2948 {
2949 /* canClose() needs the tree lock */
2950 AutoMultiWriteLock2 multilock(&m->pVirtualBox->getMediaTreeLockHandle(),
2951 this->lockHandle()
2952 COMMA_LOCKVAL_SRC_POS);
2953
2954 LogFlowThisFunc(("ENTER for medium %s\n", m->strLocationFull.c_str()));
2955
2956 if (m->pParent.isNull())
2957 throw setError(VBOX_E_NOT_SUPPORTED,
2958 tr("Medium type of '%s' is not differencing"),
2959 m->strLocationFull.c_str());
2960
2961 rc = canClose();
2962 if (FAILED(rc))
2963 throw rc;
2964
2965 /* Build the medium lock list. */
2966 MediumLockList *pMediumLockList(new MediumLockList());
2967 multilock.release();
2968 rc = createMediumLockList(true /* fFailIfInaccessible */,
2969 true /* fMediumLockWrite */,
2970 NULL,
2971 *pMediumLockList);
2972 multilock.acquire();
2973 if (FAILED(rc))
2974 {
2975 delete pMediumLockList;
2976 throw rc;
2977 }
2978
2979 multilock.release();
2980 rc = pMediumLockList->Lock();
2981 multilock.acquire();
2982 if (FAILED(rc))
2983 {
2984 delete pMediumLockList;
2985 throw setError(rc,
2986 tr("Failed to lock media when resetting '%s'"),
2987 getLocationFull().c_str());
2988 }
2989
2990 pProgress.createObject();
2991 rc = pProgress->init(m->pVirtualBox,
2992 static_cast<IMedium*>(this),
2993 BstrFmt(tr("Resetting differencing medium '%s'"), m->strLocationFull.c_str()).raw(),
2994 FALSE /* aCancelable */);
2995 if (FAILED(rc))
2996 throw rc;
2997
2998 /* setup task object to carry out the operation asynchronously */
2999 pTask = new Medium::ResetTask(this, pProgress, pMediumLockList);
3000 rc = pTask->rc();
3001 AssertComRC(rc);
3002 if (FAILED(rc))
3003 throw rc;
3004 }
3005 catch (HRESULT aRC) { rc = aRC; }
3006
3007 if (SUCCEEDED(rc))
3008 {
3009 rc = startThread(pTask);
3010
3011 if (SUCCEEDED(rc))
3012 pProgress.queryInterfaceTo(aProgress);
3013 }
3014 else
3015 {
3016 /* Note: on success, the task will unlock this */
3017 {
3018 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
3019 HRESULT rc2 = UnlockWrite(NULL);
3020 AssertComRC(rc2);
3021 }
3022 if (pTask != NULL)
3023 delete pTask;
3024 }
3025
3026 LogFlowThisFunc(("LEAVE, rc=%Rhrc\n", rc));
3027
3028 return rc;
3029}
3030
3031////////////////////////////////////////////////////////////////////////////////
3032//
3033// Medium public internal methods
3034//
3035////////////////////////////////////////////////////////////////////////////////
3036
3037/**
3038 * Internal method to return the medium's parent medium. Must have caller + locking!
3039 * @return
3040 */
3041const ComObjPtr<Medium>& Medium::getParent() const
3042{
3043 return m->pParent;
3044}
3045
3046/**
3047 * Internal method to return the medium's list of child media. Must have caller + locking!
3048 * @return
3049 */
3050const MediaList& Medium::getChildren() const
3051{
3052 return m->llChildren;
3053}
3054
3055/**
3056 * Internal method to return the medium's GUID. Must have caller + locking!
3057 * @return
3058 */
3059const Guid& Medium::getId() const
3060{
3061 return m->id;
3062}
3063
3064/**
3065 * Internal method to return the medium's state. Must have caller + locking!
3066 * @return
3067 */
3068MediumState_T Medium::getState() const
3069{
3070 return m->state;
3071}
3072
3073/**
3074 * Internal method to return the medium's variant. Must have caller + locking!
3075 * @return
3076 */
3077MediumVariant_T Medium::getVariant() const
3078{
3079 return m->variant;
3080}
3081
3082/**
3083 * Internal method which returns true if this medium represents a host drive.
3084 * @return
3085 */
3086bool Medium::isHostDrive() const
3087{
3088 return m->hostDrive;
3089}
3090
3091/**
3092 * Internal method to return the medium's full location. Must have caller + locking!
3093 * @return
3094 */
3095const Utf8Str& Medium::getLocationFull() const
3096{
3097 return m->strLocationFull;
3098}
3099
3100/**
3101 * Internal method to return the medium's format string. Must have caller + locking!
3102 * @return
3103 */
3104const Utf8Str& Medium::getFormat() const
3105{
3106 return m->strFormat;
3107}
3108
3109/**
3110 * Internal method to return the medium's format object. Must have caller + locking!
3111 * @return
3112 */
3113const ComObjPtr<MediumFormat>& Medium::getMediumFormat() const
3114{
3115 return m->formatObj;
3116}
3117
3118/**
3119 * Internal method that returns true if the medium is represented by a file on the host disk
3120 * (and not iSCSI or something).
3121 * @return
3122 */
3123bool Medium::isMediumFormatFile() const
3124{
3125 if ( m->formatObj
3126 && (m->formatObj->getCapabilities() & MediumFormatCapabilities_File)
3127 )
3128 return true;
3129 return false;
3130}
3131
3132/**
3133 * Internal method to return the medium's size. Must have caller + locking!
3134 * @return
3135 */
3136uint64_t Medium::getSize() const
3137{
3138 return m->size;
3139}
3140
3141/**
3142 * Returns the medium device type. Must have caller + locking!
3143 * @return
3144 */
3145DeviceType_T Medium::getDeviceType() const
3146{
3147 return m->devType;
3148}
3149
3150/**
3151 * Returns the medium type. Must have caller + locking!
3152 * @return
3153 */
3154MediumType_T Medium::getType() const
3155{
3156 return m->type;
3157}
3158
3159/**
3160 * Returns a short version of the location attribute.
3161 *
3162 * @note Must be called from under this object's read or write lock.
3163 */
3164Utf8Str Medium::getName()
3165{
3166 Utf8Str name = RTPathFilename(m->strLocationFull.c_str());
3167 return name;
3168}
3169
3170/**
3171 * This adds the given UUID to the list of media registries in which this
3172 * medium should be registered. The UUID can either be a machine UUID,
3173 * to add a machine registry, or the global registry UUID as returned by
3174 * VirtualBox::getGlobalRegistryId().
3175 *
3176 * Note that for hard disks, this method does nothing if the medium is
3177 * already in another registry to avoid having hard disks in more than
3178 * one registry, which causes trouble with keeping diff images in sync.
3179 * See getFirstRegistryMachineId() for details.
3180 *
3181 * If fRecurse == true, then the media tree lock must be held for reading.
3182 *
3183 * @param id
3184 * @param fRecurse If true, recurses into child media to make sure the whole tree has registries in sync.
3185 * @return true if the registry was added; false if the given id was already on the list.
3186 */
3187bool Medium::addRegistry(const Guid& id, bool fRecurse)
3188{
3189 AutoCaller autoCaller(this);
3190 if (FAILED(autoCaller.rc()))
3191 return false;
3192 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
3193
3194 bool fAdd = true;
3195
3196 // hard disks cannot be in more than one registry
3197 if ( m->devType == DeviceType_HardDisk
3198 && m->llRegistryIDs.size() > 0)
3199 fAdd = false;
3200
3201 // no need to add the UUID twice
3202 if (fAdd)
3203 {
3204 for (GuidList::const_iterator it = m->llRegistryIDs.begin();
3205 it != m->llRegistryIDs.end();
3206 ++it)
3207 {
3208 if ((*it) == id)
3209 {
3210 fAdd = false;
3211 break;
3212 }
3213 }
3214 }
3215
3216 if (fAdd)
3217 m->llRegistryIDs.push_back(id);
3218
3219 if (fRecurse)
3220 {
3221 // Get private list of children and release medium lock straight away.
3222 MediaList llChildren(m->llChildren);
3223 alock.release();
3224
3225 for (MediaList::iterator it = llChildren.begin();
3226 it != llChildren.end();
3227 ++it)
3228 {
3229 Medium *pChild = *it;
3230 fAdd |= pChild->addRegistry(id, true);
3231 }
3232 }
3233
3234 return fAdd;
3235}
3236
3237/**
3238 * Removes the given UUID from the list of media registry UUIDs. Returns true
3239 * if found or false if not.
3240 *
3241 * If fRecurse == true, then the media tree lock must be held for reading.
3242 *
3243 * @param id
3244 * @param fRecurse If true, recurses into child media to make sure the whole tree has registries in sync.
3245 * @return
3246 */
3247bool Medium::removeRegistry(const Guid& id, bool fRecurse)
3248{
3249 AutoCaller autoCaller(this);
3250 if (FAILED(autoCaller.rc()))
3251 return false;
3252 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
3253
3254 bool fRemove = false;
3255
3256 for (GuidList::iterator it = m->llRegistryIDs.begin();
3257 it != m->llRegistryIDs.end();
3258 ++it)
3259 {
3260 if ((*it) == id)
3261 {
3262 m->llRegistryIDs.erase(it);
3263 fRemove = true;
3264 break;
3265 }
3266 }
3267
3268 if (fRecurse)
3269 {
3270 // Get private list of children and release medium lock straight away.
3271 MediaList llChildren(m->llChildren);
3272 alock.release();
3273
3274 for (MediaList::iterator it = llChildren.begin();
3275 it != llChildren.end();
3276 ++it)
3277 {
3278 Medium *pChild = *it;
3279 fRemove |= pChild->removeRegistry(id, true);
3280 }
3281 }
3282
3283 return fRemove;
3284}
3285
3286/**
3287 * Returns true if id is in the list of media registries for this medium.
3288 *
3289 * Must have caller + read locking!
3290 *
3291 * @param id
3292 * @return
3293 */
3294bool Medium::isInRegistry(const Guid& id)
3295{
3296 for (GuidList::const_iterator it = m->llRegistryIDs.begin();
3297 it != m->llRegistryIDs.end();
3298 ++it)
3299 {
3300 if (*it == id)
3301 return true;
3302 }
3303
3304 return false;
3305}
3306
3307/**
3308 * Internal method to return the medium's first registry machine (i.e. the machine in whose
3309 * machine XML this medium is listed).
3310 *
3311 * Every attached medium must now (4.0) reside in at least one media registry, which is identified
3312 * by a UUID. This is either a machine UUID if the machine is from 4.0 or newer, in which case
3313 * machines have their own media registries, or it is the pseudo-UUID of the VirtualBox
3314 * object if the machine is old and still needs the global registry in VirtualBox.xml.
3315 *
3316 * By definition, hard disks may only be in one media registry, in which all its children
3317 * will be stored as well. Otherwise we run into problems with having keep multiple registries
3318 * in sync. (This is the "cloned VM" case in which VM1 may link to the disks of VM2; in this
3319 * case, only VM2's registry is used for the disk in question.)
3320 *
3321 * If there is no medium registry, particularly if the medium has not been attached yet, this
3322 * does not modify uuid and returns false.
3323 *
3324 * ISOs and RAWs, by contrast, can be in more than one repository to make things easier for
3325 * the user.
3326 *
3327 * Must have caller + locking!
3328 *
3329 * @param uuid Receives first registry machine UUID, if available.
3330 * @return true if uuid was set.
3331 */
3332bool Medium::getFirstRegistryMachineId(Guid &uuid) const
3333{
3334 if (m->llRegistryIDs.size())
3335 {
3336 uuid = m->llRegistryIDs.front();
3337 return true;
3338 }
3339 return false;
3340}
3341
3342/**
3343 * Marks all the registries in which this medium is registered as modified.
3344 */
3345void Medium::markRegistriesModified()
3346{
3347 AutoCaller autoCaller(this);
3348 if (FAILED(autoCaller.rc())) return;
3349
3350 // Get local copy, as keeping the lock over VirtualBox::markRegistryModified
3351 // causes trouble with the lock order
3352 GuidList llRegistryIDs;
3353 {
3354 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
3355 llRegistryIDs = m->llRegistryIDs;
3356 }
3357
3358 for (GuidList::const_iterator it = llRegistryIDs.begin();
3359 it != llRegistryIDs.end();
3360 ++it)
3361 {
3362 m->pVirtualBox->markRegistryModified(*it);
3363 }
3364}
3365
3366/**
3367 * Adds the given machine and optionally the snapshot to the list of the objects
3368 * this medium is attached to.
3369 *
3370 * @param aMachineId Machine ID.
3371 * @param aSnapshotId Snapshot ID; when non-empty, adds a snapshot attachment.
3372 */
3373HRESULT Medium::addBackReference(const Guid &aMachineId,
3374 const Guid &aSnapshotId /*= Guid::Empty*/)
3375{
3376 AssertReturn(!aMachineId.isEmpty(), E_FAIL);
3377
3378 LogFlowThisFunc(("ENTER, aMachineId: {%RTuuid}, aSnapshotId: {%RTuuid}\n", aMachineId.raw(), aSnapshotId.raw()));
3379
3380 AutoCaller autoCaller(this);
3381 AssertComRCReturnRC(autoCaller.rc());
3382
3383 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
3384
3385 switch (m->state)
3386 {
3387 case MediumState_Created:
3388 case MediumState_Inaccessible:
3389 case MediumState_LockedRead:
3390 case MediumState_LockedWrite:
3391 break;
3392
3393 default:
3394 return setStateError();
3395 }
3396
3397 if (m->numCreateDiffTasks > 0)
3398 return setError(VBOX_E_OBJECT_IN_USE,
3399 tr("Cannot attach medium '%s' {%RTuuid}: %u differencing child media are being created"),
3400 m->strLocationFull.c_str(),
3401 m->id.raw(),
3402 m->numCreateDiffTasks);
3403
3404 BackRefList::iterator it = std::find_if(m->backRefs.begin(),
3405 m->backRefs.end(),
3406 BackRef::EqualsTo(aMachineId));
3407 if (it == m->backRefs.end())
3408 {
3409 BackRef ref(aMachineId, aSnapshotId);
3410 m->backRefs.push_back(ref);
3411
3412 return S_OK;
3413 }
3414
3415 // if the caller has not supplied a snapshot ID, then we're attaching
3416 // to a machine a medium which represents the machine's current state,
3417 // so set the flag
3418 if (aSnapshotId.isEmpty())
3419 {
3420 /* sanity: no duplicate attachments */
3421 if (it->fInCurState)
3422 return setError(VBOX_E_OBJECT_IN_USE,
3423 tr("Cannot attach medium '%s' {%RTuuid}: medium is already associated with the current state of machine uuid {%RTuuid}!"),
3424 m->strLocationFull.c_str(),
3425 m->id.raw(),
3426 aMachineId.raw());
3427 it->fInCurState = true;
3428
3429 return S_OK;
3430 }
3431
3432 // otherwise: a snapshot medium is being attached
3433
3434 /* sanity: no duplicate attachments */
3435 for (GuidList::const_iterator jt = it->llSnapshotIds.begin();
3436 jt != it->llSnapshotIds.end();
3437 ++jt)
3438 {
3439 const Guid &idOldSnapshot = *jt;
3440
3441 if (idOldSnapshot == aSnapshotId)
3442 {
3443#ifdef DEBUG
3444 dumpBackRefs();
3445#endif
3446 return setError(VBOX_E_OBJECT_IN_USE,
3447 tr("Cannot attach medium '%s' {%RTuuid} from snapshot '%RTuuid': medium is already in use by this snapshot!"),
3448 m->strLocationFull.c_str(),
3449 m->id.raw(),
3450 aSnapshotId.raw());
3451 }
3452 }
3453
3454 it->llSnapshotIds.push_back(aSnapshotId);
3455 it->fInCurState = false;
3456
3457 LogFlowThisFuncLeave();
3458
3459 return S_OK;
3460}
3461
3462/**
3463 * Removes the given machine and optionally the snapshot from the list of the
3464 * objects this medium is attached to.
3465 *
3466 * @param aMachineId Machine ID.
3467 * @param aSnapshotId Snapshot ID; when non-empty, removes the snapshot
3468 * attachment.
3469 */
3470HRESULT Medium::removeBackReference(const Guid &aMachineId,
3471 const Guid &aSnapshotId /*= Guid::Empty*/)
3472{
3473 AssertReturn(!aMachineId.isEmpty(), E_FAIL);
3474
3475 AutoCaller autoCaller(this);
3476 AssertComRCReturnRC(autoCaller.rc());
3477
3478 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
3479
3480 BackRefList::iterator it =
3481 std::find_if(m->backRefs.begin(), m->backRefs.end(),
3482 BackRef::EqualsTo(aMachineId));
3483 AssertReturn(it != m->backRefs.end(), E_FAIL);
3484
3485 if (aSnapshotId.isEmpty())
3486 {
3487 /* remove the current state attachment */
3488 it->fInCurState = false;
3489 }
3490 else
3491 {
3492 /* remove the snapshot attachment */
3493 GuidList::iterator jt = std::find(it->llSnapshotIds.begin(),
3494 it->llSnapshotIds.end(),
3495 aSnapshotId);
3496
3497 AssertReturn(jt != it->llSnapshotIds.end(), E_FAIL);
3498 it->llSnapshotIds.erase(jt);
3499 }
3500
3501 /* if the backref becomes empty, remove it */
3502 if (it->fInCurState == false && it->llSnapshotIds.size() == 0)
3503 m->backRefs.erase(it);
3504
3505 return S_OK;
3506}
3507
3508/**
3509 * Internal method to return the medium's list of backrefs. Must have caller + locking!
3510 * @return
3511 */
3512const Guid* Medium::getFirstMachineBackrefId() const
3513{
3514 if (!m->backRefs.size())
3515 return NULL;
3516
3517 return &m->backRefs.front().machineId;
3518}
3519
3520/**
3521 * Internal method which returns a machine that either this medium or one of its children
3522 * is attached to. This is used for finding a replacement media registry when an existing
3523 * media registry is about to be deleted in VirtualBox::unregisterMachine().
3524 *
3525 * Must have caller + locking, *and* caller must hold the media tree lock!
3526 * @return
3527 */
3528const Guid* Medium::getAnyMachineBackref() const
3529{
3530 if (m->backRefs.size())
3531 return &m->backRefs.front().machineId;
3532
3533 for (MediaList::iterator it = m->llChildren.begin();
3534 it != m->llChildren.end();
3535 ++it)
3536 {
3537 Medium *pChild = *it;
3538 // recurse for this child
3539 const Guid* puuid;
3540 if ((puuid = pChild->getAnyMachineBackref()))
3541 return puuid;
3542 }
3543
3544 return NULL;
3545}
3546
3547const Guid* Medium::getFirstMachineBackrefSnapshotId() const
3548{
3549 if (!m->backRefs.size())
3550 return NULL;
3551
3552 const BackRef &ref = m->backRefs.front();
3553 if (!ref.llSnapshotIds.size())
3554 return NULL;
3555
3556 return &ref.llSnapshotIds.front();
3557}
3558
3559size_t Medium::getMachineBackRefCount() const
3560{
3561 return m->backRefs.size();
3562}
3563
3564#ifdef DEBUG
3565/**
3566 * Debugging helper that gets called after VirtualBox initialization that writes all
3567 * machine backreferences to the debug log.
3568 */
3569void Medium::dumpBackRefs()
3570{
3571 AutoCaller autoCaller(this);
3572 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
3573
3574 LogFlowThisFunc(("Dumping backrefs for medium '%s':\n", m->strLocationFull.c_str()));
3575
3576 for (BackRefList::iterator it2 = m->backRefs.begin();
3577 it2 != m->backRefs.end();
3578 ++it2)
3579 {
3580 const BackRef &ref = *it2;
3581 LogFlowThisFunc((" Backref from machine {%RTuuid} (fInCurState: %d)\n", ref.machineId.raw(), ref.fInCurState));
3582
3583 for (GuidList::const_iterator jt2 = it2->llSnapshotIds.begin();
3584 jt2 != it2->llSnapshotIds.end();
3585 ++jt2)
3586 {
3587 const Guid &id = *jt2;
3588 LogFlowThisFunc((" Backref from snapshot {%RTuuid}\n", id.raw()));
3589 }
3590 }
3591}
3592#endif
3593
3594/**
3595 * Checks if the given change of \a aOldPath to \a aNewPath affects the location
3596 * of this media and updates it if necessary to reflect the new location.
3597 *
3598 * @param aOldPath Old path (full).
3599 * @param aNewPath New path (full).
3600 *
3601 * @note Locks this object for writing.
3602 */
3603HRESULT Medium::updatePath(const Utf8Str &strOldPath, const Utf8Str &strNewPath)
3604{
3605 AssertReturn(!strOldPath.isEmpty(), E_FAIL);
3606 AssertReturn(!strNewPath.isEmpty(), E_FAIL);
3607
3608 AutoCaller autoCaller(this);
3609 if (FAILED(autoCaller.rc())) return autoCaller.rc();
3610
3611 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
3612
3613 LogFlowThisFunc(("locationFull.before='%s'\n", m->strLocationFull.c_str()));
3614
3615 const char *pcszMediumPath = m->strLocationFull.c_str();
3616
3617 if (RTPathStartsWith(pcszMediumPath, strOldPath.c_str()))
3618 {
3619 Utf8Str newPath(strNewPath);
3620 newPath.append(pcszMediumPath + strOldPath.length());
3621 unconst(m->strLocationFull) = newPath;
3622
3623 LogFlowThisFunc(("locationFull.after='%s'\n", m->strLocationFull.c_str()));
3624 // we changed something
3625 return S_OK;
3626 }
3627
3628 // no change was necessary, signal error which the caller needs to interpret
3629 return VBOX_E_FILE_ERROR;
3630}
3631
3632/**
3633 * Returns the base medium of the media chain this medium is part of.
3634 *
3635 * The base medium is found by walking up the parent-child relationship axis.
3636 * If the medium doesn't have a parent (i.e. it's a base medium), it
3637 * returns itself in response to this method.
3638 *
3639 * @param aLevel Where to store the number of ancestors of this medium
3640 * (zero for the base), may be @c NULL.
3641 *
3642 * @note Locks medium tree for reading.
3643 */
3644ComObjPtr<Medium> Medium::getBase(uint32_t *aLevel /*= NULL*/)
3645{
3646 ComObjPtr<Medium> pBase;
3647 uint32_t level;
3648
3649 AutoCaller autoCaller(this);
3650 AssertReturn(autoCaller.isOk(), pBase);
3651
3652 /* we access mParent */
3653 AutoReadLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
3654
3655 pBase = this;
3656 level = 0;
3657
3658 if (m->pParent)
3659 {
3660 for (;;)
3661 {
3662 AutoCaller baseCaller(pBase);
3663 AssertReturn(baseCaller.isOk(), pBase);
3664
3665 if (pBase->m->pParent.isNull())
3666 break;
3667
3668 pBase = pBase->m->pParent;
3669 ++level;
3670 }
3671 }
3672
3673 if (aLevel != NULL)
3674 *aLevel = level;
3675
3676 return pBase;
3677}
3678
3679/**
3680 * Returns @c true if this medium cannot be modified because it has
3681 * dependents (children) or is part of the snapshot. Related to the medium
3682 * type and posterity, not to the current media state.
3683 *
3684 * @note Locks this object and medium tree for reading.
3685 */
3686bool Medium::isReadOnly()
3687{
3688 AutoCaller autoCaller(this);
3689 AssertComRCReturn(autoCaller.rc(), false);
3690
3691 /* we access children */
3692 AutoReadLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
3693
3694 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
3695
3696 switch (m->type)
3697 {
3698 case MediumType_Normal:
3699 {
3700 if (getChildren().size() != 0)
3701 return true;
3702
3703 for (BackRefList::const_iterator it = m->backRefs.begin();
3704 it != m->backRefs.end(); ++it)
3705 if (it->llSnapshotIds.size() != 0)
3706 return true;
3707
3708 if (m->variant & MediumVariant_VmdkStreamOptimized)
3709 return true;
3710
3711 return false;
3712 }
3713 case MediumType_Immutable:
3714 case MediumType_MultiAttach:
3715 return true;
3716 case MediumType_Writethrough:
3717 case MediumType_Shareable:
3718 case MediumType_Readonly: /* explicit readonly media has no diffs */
3719 return false;
3720 default:
3721 break;
3722 }
3723
3724 AssertFailedReturn(false);
3725}
3726
3727/**
3728 * Internal method to return the medium's size. Must have caller + locking!
3729 * @return
3730 */
3731void Medium::updateId(const Guid &id)
3732{
3733 unconst(m->id) = id;
3734}
3735
3736/**
3737 * Saves medium data by appending a new child node to the given
3738 * parent XML settings node.
3739 *
3740 * @param data Settings struct to be updated.
3741 * @param strHardDiskFolder Folder for which paths should be relative.
3742 *
3743 * @note Locks this object, medium tree and children for reading.
3744 */
3745HRESULT Medium::saveSettings(settings::Medium &data,
3746 const Utf8Str &strHardDiskFolder)
3747{
3748 AutoCaller autoCaller(this);
3749 if (FAILED(autoCaller.rc())) return autoCaller.rc();
3750
3751 /* we access mParent */
3752 AutoReadLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
3753
3754 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
3755
3756 data.uuid = m->id;
3757
3758 // make path relative if needed
3759 if ( !strHardDiskFolder.isEmpty()
3760 && RTPathStartsWith(m->strLocationFull.c_str(), strHardDiskFolder.c_str())
3761 )
3762 data.strLocation = m->strLocationFull.substr(strHardDiskFolder.length() + 1);
3763 else
3764 data.strLocation = m->strLocationFull;
3765 data.strFormat = m->strFormat;
3766
3767 /* optional, only for diffs, default is false */
3768 if (m->pParent)
3769 data.fAutoReset = m->autoReset;
3770 else
3771 data.fAutoReset = false;
3772
3773 /* optional */
3774 data.strDescription = m->strDescription;
3775
3776 /* optional properties */
3777 data.properties.clear();
3778
3779 /* handle iSCSI initiator secrets transparently */
3780 bool fHaveInitiatorSecretEncrypted = false;
3781 Utf8Str strCiphertext;
3782 settings::StringsMap::const_iterator itPln = m->mapProperties.find("InitiatorSecret");
3783 if ( itPln != m->mapProperties.end()
3784 && !itPln->second.isEmpty())
3785 {
3786 /* Encrypt the plain secret. If that does not work (i.e. no or wrong settings key
3787 * specified), just use the encrypted secret (if there is any). */
3788 int rc = m->pVirtualBox->encryptSetting(itPln->second, &strCiphertext);
3789 if (RT_SUCCESS(rc))
3790 fHaveInitiatorSecretEncrypted = true;
3791 }
3792 for (settings::StringsMap::const_iterator it = m->mapProperties.begin();
3793 it != m->mapProperties.end();
3794 ++it)
3795 {
3796 /* only save properties that have non-default values */
3797 if (!it->second.isEmpty())
3798 {
3799 const Utf8Str &name = it->first;
3800 const Utf8Str &value = it->second;
3801 /* do NOT store the plain InitiatorSecret */
3802 if ( !fHaveInitiatorSecretEncrypted
3803 || !name.equals("InitiatorSecret"))
3804 data.properties[name] = value;
3805 }
3806 }
3807 if (fHaveInitiatorSecretEncrypted)
3808 data.properties["InitiatorSecretEncrypted"] = strCiphertext;
3809
3810 /* only for base media */
3811 if (m->pParent.isNull())
3812 data.hdType = m->type;
3813
3814 /* save all children */
3815 for (MediaList::const_iterator it = getChildren().begin();
3816 it != getChildren().end();
3817 ++it)
3818 {
3819 settings::Medium med;
3820 HRESULT rc = (*it)->saveSettings(med, strHardDiskFolder);
3821 AssertComRCReturnRC(rc);
3822 data.llChildren.push_back(med);
3823 }
3824
3825 return S_OK;
3826}
3827
3828/**
3829 * Constructs a medium lock list for this medium. The lock is not taken.
3830 *
3831 * @note Caller MUST NOT hold the media tree or medium lock.
3832 *
3833 * @param fFailIfInaccessible If true, this fails with an error if a medium is inaccessible. If false,
3834 * inaccessible media are silently skipped and not locked (i.e. their state remains "Inaccessible");
3835 * this is necessary for a VM's removable media VM startup for which we do not want to fail.
3836 * @param fMediumLockWrite Whether to associate a write lock with this medium.
3837 * @param pToBeParent Medium which will become the parent of this medium.
3838 * @param mediumLockList Where to store the resulting list.
3839 */
3840HRESULT Medium::createMediumLockList(bool fFailIfInaccessible,
3841 bool fMediumLockWrite,
3842 Medium *pToBeParent,
3843 MediumLockList &mediumLockList)
3844{
3845 Assert(!m->pVirtualBox->getMediaTreeLockHandle().isWriteLockOnCurrentThread());
3846 Assert(!isWriteLockOnCurrentThread());
3847
3848 AutoCaller autoCaller(this);
3849 if (FAILED(autoCaller.rc())) return autoCaller.rc();
3850
3851 HRESULT rc = S_OK;
3852
3853 /* paranoid sanity checking if the medium has a to-be parent medium */
3854 if (pToBeParent)
3855 {
3856 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
3857 ComAssertRet(getParent().isNull(), E_FAIL);
3858 ComAssertRet(getChildren().size() == 0, E_FAIL);
3859 }
3860
3861 ErrorInfoKeeper eik;
3862 MultiResult mrc(S_OK);
3863
3864 ComObjPtr<Medium> pMedium = this;
3865 while (!pMedium.isNull())
3866 {
3867 AutoReadLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
3868
3869 /* Accessibility check must be first, otherwise locking interferes
3870 * with getting the medium state. Lock lists are not created for
3871 * fun, and thus getting the medium status is no luxury. */
3872 MediumState_T mediumState = pMedium->getState();
3873 if (mediumState == MediumState_Inaccessible)
3874 {
3875 alock.release();
3876 rc = pMedium->queryInfo(false /* fSetImageId */, false /* fSetParentId */);
3877 alock.acquire();
3878 if (FAILED(rc)) return rc;
3879
3880 mediumState = pMedium->getState();
3881 if (mediumState == MediumState_Inaccessible)
3882 {
3883 // ignore inaccessible ISO media and silently return S_OK,
3884 // otherwise VM startup (esp. restore) may fail without good reason
3885 if (!fFailIfInaccessible)
3886 return S_OK;
3887
3888 // otherwise report an error
3889 Bstr error;
3890 rc = pMedium->COMGETTER(LastAccessError)(error.asOutParam());
3891 if (FAILED(rc)) return rc;
3892
3893 /* collect multiple errors */
3894 eik.restore();
3895 Assert(!error.isEmpty());
3896 mrc = setError(E_FAIL,
3897 "%ls",
3898 error.raw());
3899 // error message will be something like
3900 // "Could not open the medium ... VD: error VERR_FILE_NOT_FOUND opening image file ... (VERR_FILE_NOT_FOUND).
3901 eik.fetch();
3902 }
3903 }
3904
3905 if (pMedium == this)
3906 mediumLockList.Prepend(pMedium, fMediumLockWrite);
3907 else
3908 mediumLockList.Prepend(pMedium, false);
3909
3910 pMedium = pMedium->getParent();
3911 if (pMedium.isNull() && pToBeParent)
3912 {
3913 pMedium = pToBeParent;
3914 pToBeParent = NULL;
3915 }
3916 }
3917
3918 return mrc;
3919}
3920
3921/**
3922 * Creates a new differencing storage unit using the format of the given target
3923 * medium and the location. Note that @c aTarget must be NotCreated.
3924 *
3925 * The @a aMediumLockList parameter contains the associated medium lock list,
3926 * which must be in locked state. If @a aWait is @c true then the caller is
3927 * responsible for unlocking.
3928 *
3929 * If @a aProgress is not NULL but the object it points to is @c null then a
3930 * new progress object will be created and assigned to @a *aProgress on
3931 * success, otherwise the existing progress object is used. If @a aProgress is
3932 * NULL, then no progress object is created/used at all.
3933 *
3934 * When @a aWait is @c false, this method will create a thread to perform the
3935 * create operation asynchronously and will return immediately. Otherwise, it
3936 * will perform the operation on the calling thread and will not return to the
3937 * caller until the operation is completed. Note that @a aProgress cannot be
3938 * NULL when @a aWait is @c false (this method will assert in this case).
3939 *
3940 * @param aTarget Target medium.
3941 * @param aVariant Precise medium variant to create.
3942 * @param aMediumLockList List of media which should be locked.
3943 * @param aProgress Where to find/store a Progress object to track
3944 * operation completion.
3945 * @param aWait @c true if this method should block instead of
3946 * creating an asynchronous thread.
3947 *
3948 * @note Locks this object and @a aTarget for writing.
3949 */
3950HRESULT Medium::createDiffStorage(ComObjPtr<Medium> &aTarget,
3951 MediumVariant_T aVariant,
3952 MediumLockList *aMediumLockList,
3953 ComObjPtr<Progress> *aProgress,
3954 bool aWait)
3955{
3956 AssertReturn(!aTarget.isNull(), E_FAIL);
3957 AssertReturn(aMediumLockList, E_FAIL);
3958 AssertReturn(aProgress != NULL || aWait == true, E_FAIL);
3959
3960 AutoCaller autoCaller(this);
3961 if (FAILED(autoCaller.rc())) return autoCaller.rc();
3962
3963 AutoCaller targetCaller(aTarget);
3964 if (FAILED(targetCaller.rc())) return targetCaller.rc();
3965
3966 HRESULT rc = S_OK;
3967 ComObjPtr<Progress> pProgress;
3968 Medium::Task *pTask = NULL;
3969
3970 try
3971 {
3972 AutoMultiWriteLock2 alock(this, aTarget COMMA_LOCKVAL_SRC_POS);
3973
3974 ComAssertThrow( m->type != MediumType_Writethrough
3975 && m->type != MediumType_Shareable
3976 && m->type != MediumType_Readonly, E_FAIL);
3977 ComAssertThrow(m->state == MediumState_LockedRead, E_FAIL);
3978
3979 if (aTarget->m->state != MediumState_NotCreated)
3980 throw aTarget->setStateError();
3981
3982 /* Check that the medium is not attached to the current state of
3983 * any VM referring to it. */
3984 for (BackRefList::const_iterator it = m->backRefs.begin();
3985 it != m->backRefs.end();
3986 ++it)
3987 {
3988 if (it->fInCurState)
3989 {
3990 /* Note: when a VM snapshot is being taken, all normal media
3991 * attached to the VM in the current state will be, as an
3992 * exception, also associated with the snapshot which is about
3993 * to create (see SnapshotMachine::init()) before deassociating
3994 * them from the current state (which takes place only on
3995 * success in Machine::fixupHardDisks()), so that the size of
3996 * snapshotIds will be 1 in this case. The extra condition is
3997 * used to filter out this legal situation. */
3998 if (it->llSnapshotIds.size() == 0)
3999 throw setError(VBOX_E_INVALID_OBJECT_STATE,
4000 tr("Medium '%s' is attached to a virtual machine with UUID {%RTuuid}. No differencing media based on it may be created until it is detached"),
4001 m->strLocationFull.c_str(), it->machineId.raw());
4002
4003 Assert(it->llSnapshotIds.size() == 1);
4004 }
4005 }
4006
4007 if (aProgress != NULL)
4008 {
4009 /* use the existing progress object... */
4010 pProgress = *aProgress;
4011
4012 /* ...but create a new one if it is null */
4013 if (pProgress.isNull())
4014 {
4015 pProgress.createObject();
4016 rc = pProgress->init(m->pVirtualBox,
4017 static_cast<IMedium*>(this),
4018 BstrFmt(tr("Creating differencing medium storage unit '%s'"), aTarget->m->strLocationFull.c_str()).raw(),
4019 TRUE /* aCancelable */);
4020 if (FAILED(rc))
4021 throw rc;
4022 }
4023 }
4024
4025 /* setup task object to carry out the operation sync/async */
4026 pTask = new Medium::CreateDiffTask(this, pProgress, aTarget, aVariant,
4027 aMediumLockList,
4028 aWait /* fKeepMediumLockList */);
4029 rc = pTask->rc();
4030 AssertComRC(rc);
4031 if (FAILED(rc))
4032 throw rc;
4033
4034 /* register a task (it will deregister itself when done) */
4035 ++m->numCreateDiffTasks;
4036 Assert(m->numCreateDiffTasks != 0); /* overflow? */
4037
4038 aTarget->m->state = MediumState_Creating;
4039 }
4040 catch (HRESULT aRC) { rc = aRC; }
4041
4042 if (SUCCEEDED(rc))
4043 {
4044 if (aWait)
4045 rc = runNow(pTask);
4046 else
4047 rc = startThread(pTask);
4048
4049 if (SUCCEEDED(rc) && aProgress != NULL)
4050 *aProgress = pProgress;
4051 }
4052 else if (pTask != NULL)
4053 delete pTask;
4054
4055 return rc;
4056}
4057
4058/**
4059 * Returns a preferred format for differencing media.
4060 */
4061Utf8Str Medium::getPreferredDiffFormat()
4062{
4063 AutoCaller autoCaller(this);
4064 AssertComRCReturn(autoCaller.rc(), Utf8Str::Empty);
4065
4066 /* check that our own format supports diffs */
4067 if (!(m->formatObj->getCapabilities() & MediumFormatCapabilities_Differencing))
4068 {
4069 /* use the default format if not */
4070 Utf8Str tmp;
4071 m->pVirtualBox->getDefaultHardDiskFormat(tmp);
4072 return tmp;
4073 }
4074
4075 /* m->strFormat is const, no need to lock */
4076 return m->strFormat;
4077}
4078
4079/**
4080 * Implementation for the public Medium::Close() with the exception of calling
4081 * VirtualBox::saveRegistries(), in case someone wants to call this for several
4082 * media.
4083 *
4084 * After this returns with success, uninit() has been called on the medium, and
4085 * the object is no longer usable ("not ready" state).
4086 *
4087 * @param autoCaller AutoCaller instance which must have been created on the caller's stack for this medium. This gets released here
4088 * upon which the Medium instance gets uninitialized.
4089 * @return
4090 */
4091HRESULT Medium::close(AutoCaller &autoCaller)
4092{
4093 // we're accessing parent/child and backrefs, so lock the tree first, then ourselves
4094 AutoMultiWriteLock2 multilock(&m->pVirtualBox->getMediaTreeLockHandle(),
4095 this->lockHandle()
4096 COMMA_LOCKVAL_SRC_POS);
4097
4098 LogFlowFunc(("ENTER for %s\n", getLocationFull().c_str()));
4099
4100 bool wasCreated = true;
4101
4102 switch (m->state)
4103 {
4104 case MediumState_NotCreated:
4105 wasCreated = false;
4106 break;
4107 case MediumState_Created:
4108 case MediumState_Inaccessible:
4109 break;
4110 default:
4111 return setStateError();
4112 }
4113
4114 if (m->backRefs.size() != 0)
4115 return setError(VBOX_E_OBJECT_IN_USE,
4116 tr("Medium '%s' cannot be closed because it is still attached to %d virtual machines"),
4117 m->strLocationFull.c_str(), m->backRefs.size());
4118
4119 // perform extra media-dependent close checks
4120 HRESULT rc = canClose();
4121 if (FAILED(rc)) return rc;
4122
4123 if (wasCreated)
4124 {
4125 // remove from the list of known media before performing actual
4126 // uninitialization (to keep the media registry consistent on
4127 // failure to do so)
4128 rc = unregisterWithVirtualBox();
4129 if (FAILED(rc)) return rc;
4130
4131 multilock.release();
4132 markRegistriesModified();
4133 m->pVirtualBox->saveModifiedRegistries();
4134 multilock.acquire();
4135 }
4136
4137 // release the AutoCaller, as otherwise uninit() will simply hang
4138 autoCaller.release();
4139
4140 // Keep the locks held until after uninit, as otherwise the consistency
4141 // of the medium tree cannot be guaranteed.
4142 uninit();
4143
4144 LogFlowFuncLeave();
4145
4146 return rc;
4147}
4148
4149/**
4150 * Deletes the medium storage unit.
4151 *
4152 * If @a aProgress is not NULL but the object it points to is @c null then a new
4153 * progress object will be created and assigned to @a *aProgress on success,
4154 * otherwise the existing progress object is used. If Progress is NULL, then no
4155 * progress object is created/used at all.
4156 *
4157 * When @a aWait is @c false, this method will create a thread to perform the
4158 * delete operation asynchronously and will return immediately. Otherwise, it
4159 * will perform the operation on the calling thread and will not return to the
4160 * caller until the operation is completed. Note that @a aProgress cannot be
4161 * NULL when @a aWait is @c false (this method will assert in this case).
4162 *
4163 * @param aProgress Where to find/store a Progress object to track operation
4164 * completion.
4165 * @param aWait @c true if this method should block instead of creating
4166 * an asynchronous thread.
4167 *
4168 * @note Locks mVirtualBox and this object for writing. Locks medium tree for
4169 * writing.
4170 */
4171HRESULT Medium::deleteStorage(ComObjPtr<Progress> *aProgress,
4172 bool aWait)
4173{
4174 AssertReturn(aProgress != NULL || aWait == true, E_FAIL);
4175
4176 AutoCaller autoCaller(this);
4177 if (FAILED(autoCaller.rc())) return autoCaller.rc();
4178
4179 HRESULT rc = S_OK;
4180 ComObjPtr<Progress> pProgress;
4181 Medium::Task *pTask = NULL;
4182
4183 try
4184 {
4185 /* we're accessing the media tree, and canClose() needs it too */
4186 AutoMultiWriteLock2 multilock(&m->pVirtualBox->getMediaTreeLockHandle(),
4187 this->lockHandle()
4188 COMMA_LOCKVAL_SRC_POS);
4189 LogFlowThisFunc(("aWait=%RTbool locationFull=%s\n", aWait, getLocationFull().c_str() ));
4190
4191 if ( !(m->formatObj->getCapabilities() & ( MediumFormatCapabilities_CreateDynamic
4192 | MediumFormatCapabilities_CreateFixed)))
4193 throw setError(VBOX_E_NOT_SUPPORTED,
4194 tr("Medium format '%s' does not support storage deletion"),
4195 m->strFormat.c_str());
4196
4197 /* Note that we are fine with Inaccessible state too: a) for symmetry
4198 * with create calls and b) because it doesn't really harm to try, if
4199 * it is really inaccessible, the delete operation will fail anyway.
4200 * Accepting Inaccessible state is especially important because all
4201 * registered media are initially Inaccessible upon VBoxSVC startup
4202 * until COMGETTER(RefreshState) is called. Accept Deleting state
4203 * because some callers need to put the medium in this state early
4204 * to prevent races. */
4205 switch (m->state)
4206 {
4207 case MediumState_Created:
4208 case MediumState_Deleting:
4209 case MediumState_Inaccessible:
4210 break;
4211 default:
4212 throw setStateError();
4213 }
4214
4215 if (m->backRefs.size() != 0)
4216 {
4217 Utf8Str strMachines;
4218 for (BackRefList::const_iterator it = m->backRefs.begin();
4219 it != m->backRefs.end();
4220 ++it)
4221 {
4222 const BackRef &b = *it;
4223 if (strMachines.length())
4224 strMachines.append(", ");
4225 strMachines.append(b.machineId.toString().c_str());
4226 }
4227#ifdef DEBUG
4228 dumpBackRefs();
4229#endif
4230 throw setError(VBOX_E_OBJECT_IN_USE,
4231 tr("Cannot delete storage: medium '%s' is still attached to the following %d virtual machine(s): %s"),
4232 m->strLocationFull.c_str(),
4233 m->backRefs.size(),
4234 strMachines.c_str());
4235 }
4236
4237 rc = canClose();
4238 if (FAILED(rc))
4239 throw rc;
4240
4241 /* go to Deleting state, so that the medium is not actually locked */
4242 if (m->state != MediumState_Deleting)
4243 {
4244 rc = markForDeletion();
4245 if (FAILED(rc))
4246 throw rc;
4247 }
4248
4249 /* Build the medium lock list. */
4250 MediumLockList *pMediumLockList(new MediumLockList());
4251 multilock.release();
4252 rc = createMediumLockList(true /* fFailIfInaccessible */,
4253 true /* fMediumLockWrite */,
4254 NULL,
4255 *pMediumLockList);
4256 multilock.acquire();
4257 if (FAILED(rc))
4258 {
4259 delete pMediumLockList;
4260 throw rc;
4261 }
4262
4263 multilock.release();
4264 rc = pMediumLockList->Lock();
4265 multilock.acquire();
4266 if (FAILED(rc))
4267 {
4268 delete pMediumLockList;
4269 throw setError(rc,
4270 tr("Failed to lock media when deleting '%s'"),
4271 getLocationFull().c_str());
4272 }
4273
4274 /* try to remove from the list of known media before performing
4275 * actual deletion (we favor the consistency of the media registry
4276 * which would have been broken if unregisterWithVirtualBox() failed
4277 * after we successfully deleted the storage) */
4278 rc = unregisterWithVirtualBox();
4279 if (FAILED(rc))
4280 throw rc;
4281 // no longer need lock
4282 multilock.release();
4283 markRegistriesModified();
4284
4285 if (aProgress != NULL)
4286 {
4287 /* use the existing progress object... */
4288 pProgress = *aProgress;
4289
4290 /* ...but create a new one if it is null */
4291 if (pProgress.isNull())
4292 {
4293 pProgress.createObject();
4294 rc = pProgress->init(m->pVirtualBox,
4295 static_cast<IMedium*>(this),
4296 BstrFmt(tr("Deleting medium storage unit '%s'"), m->strLocationFull.c_str()).raw(),
4297 FALSE /* aCancelable */);
4298 if (FAILED(rc))
4299 throw rc;
4300 }
4301 }
4302
4303 /* setup task object to carry out the operation sync/async */
4304 pTask = new Medium::DeleteTask(this, pProgress, pMediumLockList);
4305 rc = pTask->rc();
4306 AssertComRC(rc);
4307 if (FAILED(rc))
4308 throw rc;
4309 }
4310 catch (HRESULT aRC) { rc = aRC; }
4311
4312 if (SUCCEEDED(rc))
4313 {
4314 if (aWait)
4315 rc = runNow(pTask);
4316 else
4317 rc = startThread(pTask);
4318
4319 if (SUCCEEDED(rc) && aProgress != NULL)
4320 *aProgress = pProgress;
4321
4322 }
4323 else
4324 {
4325 if (pTask)
4326 delete pTask;
4327
4328 /* Undo deleting state if necessary. */
4329 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
4330 /* Make sure that any error signalled by unmarkForDeletion() is not
4331 * ending up in the error list (if the caller uses MultiResult). It
4332 * usually is spurious, as in most cases the medium hasn't been marked
4333 * for deletion when the error was thrown above. */
4334 ErrorInfoKeeper eik;
4335 unmarkForDeletion();
4336 }
4337
4338 return rc;
4339}
4340
4341/**
4342 * Mark a medium for deletion.
4343 *
4344 * @note Caller must hold the write lock on this medium!
4345 */
4346HRESULT Medium::markForDeletion()
4347{
4348 ComAssertRet(isWriteLockOnCurrentThread(), E_FAIL);
4349 switch (m->state)
4350 {
4351 case MediumState_Created:
4352 case MediumState_Inaccessible:
4353 m->preLockState = m->state;
4354 m->state = MediumState_Deleting;
4355 return S_OK;
4356 default:
4357 return setStateError();
4358 }
4359}
4360
4361/**
4362 * Removes the "mark for deletion".
4363 *
4364 * @note Caller must hold the write lock on this medium!
4365 */
4366HRESULT Medium::unmarkForDeletion()
4367{
4368 ComAssertRet(isWriteLockOnCurrentThread(), E_FAIL);
4369 switch (m->state)
4370 {
4371 case MediumState_Deleting:
4372 m->state = m->preLockState;
4373 return S_OK;
4374 default:
4375 return setStateError();
4376 }
4377}
4378
4379/**
4380 * Mark a medium for deletion which is in locked state.
4381 *
4382 * @note Caller must hold the write lock on this medium!
4383 */
4384HRESULT Medium::markLockedForDeletion()
4385{
4386 ComAssertRet(isWriteLockOnCurrentThread(), E_FAIL);
4387 if ( ( m->state == MediumState_LockedRead
4388 || m->state == MediumState_LockedWrite)
4389 && m->preLockState == MediumState_Created)
4390 {
4391 m->preLockState = MediumState_Deleting;
4392 return S_OK;
4393 }
4394 else
4395 return setStateError();
4396}
4397
4398/**
4399 * Removes the "mark for deletion" for a medium in locked state.
4400 *
4401 * @note Caller must hold the write lock on this medium!
4402 */
4403HRESULT Medium::unmarkLockedForDeletion()
4404{
4405 ComAssertRet(isWriteLockOnCurrentThread(), E_FAIL);
4406 if ( ( m->state == MediumState_LockedRead
4407 || m->state == MediumState_LockedWrite)
4408 && m->preLockState == MediumState_Deleting)
4409 {
4410 m->preLockState = MediumState_Created;
4411 return S_OK;
4412 }
4413 else
4414 return setStateError();
4415}
4416
4417/**
4418 * Prepares this (source) medium, target medium and all intermediate media
4419 * for the merge operation.
4420 *
4421 * This method is to be called prior to calling the #mergeTo() to perform
4422 * necessary consistency checks and place involved media to appropriate
4423 * states. If #mergeTo() is not called or fails, the state modifications
4424 * performed by this method must be undone by #cancelMergeTo().
4425 *
4426 * See #mergeTo() for more information about merging.
4427 *
4428 * @param pTarget Target medium.
4429 * @param aMachineId Allowed machine attachment. NULL means do not check.
4430 * @param aSnapshotId Allowed snapshot attachment. NULL or empty UUID means
4431 * do not check.
4432 * @param fLockMedia Flag whether to lock the medium lock list or not.
4433 * If set to false and the medium lock list locking fails
4434 * later you must call #cancelMergeTo().
4435 * @param fMergeForward Resulting merge direction (out).
4436 * @param pParentForTarget New parent for target medium after merge (out).
4437 * @param aChildrenToReparent List of children of the source which will have
4438 * to be reparented to the target after merge (out).
4439 * @param aMediumLockList Medium locking information (out).
4440 *
4441 * @note Locks medium tree for reading. Locks this object, aTarget and all
4442 * intermediate media for writing.
4443 */
4444HRESULT Medium::prepareMergeTo(const ComObjPtr<Medium> &pTarget,
4445 const Guid *aMachineId,
4446 const Guid *aSnapshotId,
4447 bool fLockMedia,
4448 bool &fMergeForward,
4449 ComObjPtr<Medium> &pParentForTarget,
4450 MediaList &aChildrenToReparent,
4451 MediumLockList * &aMediumLockList)
4452{
4453 AssertReturn(pTarget != NULL, E_FAIL);
4454 AssertReturn(pTarget != this, E_FAIL);
4455
4456 AutoCaller autoCaller(this);
4457 AssertComRCReturnRC(autoCaller.rc());
4458
4459 AutoCaller targetCaller(pTarget);
4460 AssertComRCReturnRC(targetCaller.rc());
4461
4462 HRESULT rc = S_OK;
4463 fMergeForward = false;
4464 pParentForTarget.setNull();
4465 aChildrenToReparent.clear();
4466 Assert(aMediumLockList == NULL);
4467 aMediumLockList = NULL;
4468
4469 try
4470 {
4471 // locking: we need the tree lock first because we access parent pointers
4472 AutoWriteLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
4473
4474 /* more sanity checking and figuring out the merge direction */
4475 ComObjPtr<Medium> pMedium = getParent();
4476 while (!pMedium.isNull() && pMedium != pTarget)
4477 pMedium = pMedium->getParent();
4478 if (pMedium == pTarget)
4479 fMergeForward = false;
4480 else
4481 {
4482 pMedium = pTarget->getParent();
4483 while (!pMedium.isNull() && pMedium != this)
4484 pMedium = pMedium->getParent();
4485 if (pMedium == this)
4486 fMergeForward = true;
4487 else
4488 {
4489 Utf8Str tgtLoc;
4490 {
4491 AutoReadLock alock(pTarget COMMA_LOCKVAL_SRC_POS);
4492 tgtLoc = pTarget->getLocationFull();
4493 }
4494
4495 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
4496 throw setError(VBOX_E_INVALID_OBJECT_STATE,
4497 tr("Media '%s' and '%s' are unrelated"),
4498 m->strLocationFull.c_str(), tgtLoc.c_str());
4499 }
4500 }
4501
4502 /* Build the lock list. */
4503 aMediumLockList = new MediumLockList();
4504 treeLock.release();
4505 if (fMergeForward)
4506 rc = pTarget->createMediumLockList(true /* fFailIfInaccessible */,
4507 true /* fMediumLockWrite */,
4508 NULL,
4509 *aMediumLockList);
4510 else
4511 rc = createMediumLockList(true /* fFailIfInaccessible */,
4512 false /* fMediumLockWrite */,
4513 NULL,
4514 *aMediumLockList);
4515 treeLock.acquire();
4516 if (FAILED(rc))
4517 throw rc;
4518
4519 /* Sanity checking, must be after lock list creation as it depends on
4520 * valid medium states. The medium objects must be accessible. Only
4521 * do this if immediate locking is requested, otherwise it fails when
4522 * we construct a medium lock list for an already running VM. Snapshot
4523 * deletion uses this to simplify its life. */
4524 if (fLockMedia)
4525 {
4526 {
4527 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
4528 if (m->state != MediumState_Created)
4529 throw setStateError();
4530 }
4531 {
4532 AutoReadLock alock(pTarget COMMA_LOCKVAL_SRC_POS);
4533 if (pTarget->m->state != MediumState_Created)
4534 throw pTarget->setStateError();
4535 }
4536 }
4537
4538 /* check medium attachment and other sanity conditions */
4539 if (fMergeForward)
4540 {
4541 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
4542 if (getChildren().size() > 1)
4543 {
4544 throw setError(VBOX_E_INVALID_OBJECT_STATE,
4545 tr("Medium '%s' involved in the merge operation has more than one child medium (%d)"),
4546 m->strLocationFull.c_str(), getChildren().size());
4547 }
4548 /* One backreference is only allowed if the machine ID is not empty
4549 * and it matches the machine the medium is attached to (including
4550 * the snapshot ID if not empty). */
4551 if ( m->backRefs.size() != 0
4552 && ( !aMachineId
4553 || m->backRefs.size() != 1
4554 || aMachineId->isEmpty()
4555 || *getFirstMachineBackrefId() != *aMachineId
4556 || ( (!aSnapshotId || !aSnapshotId->isEmpty())
4557 && *getFirstMachineBackrefSnapshotId() != *aSnapshotId)))
4558 throw setError(VBOX_E_OBJECT_IN_USE,
4559 tr("Medium '%s' is attached to %d virtual machines"),
4560 m->strLocationFull.c_str(), m->backRefs.size());
4561 if (m->type == MediumType_Immutable)
4562 throw setError(VBOX_E_INVALID_OBJECT_STATE,
4563 tr("Medium '%s' is immutable"),
4564 m->strLocationFull.c_str());
4565 if (m->type == MediumType_MultiAttach)
4566 throw setError(VBOX_E_INVALID_OBJECT_STATE,
4567 tr("Medium '%s' is multi-attach"),
4568 m->strLocationFull.c_str());
4569 }
4570 else
4571 {
4572 AutoReadLock alock(pTarget COMMA_LOCKVAL_SRC_POS);
4573 if (pTarget->getChildren().size() > 1)
4574 {
4575 throw setError(VBOX_E_OBJECT_IN_USE,
4576 tr("Medium '%s' involved in the merge operation has more than one child medium (%d)"),
4577 pTarget->m->strLocationFull.c_str(),
4578 pTarget->getChildren().size());
4579 }
4580 if (pTarget->m->type == MediumType_Immutable)
4581 throw setError(VBOX_E_INVALID_OBJECT_STATE,
4582 tr("Medium '%s' is immutable"),
4583 pTarget->m->strLocationFull.c_str());
4584 if (pTarget->m->type == MediumType_MultiAttach)
4585 throw setError(VBOX_E_INVALID_OBJECT_STATE,
4586 tr("Medium '%s' is multi-attach"),
4587 pTarget->m->strLocationFull.c_str());
4588 }
4589 ComObjPtr<Medium> pLast(fMergeForward ? (Medium *)pTarget : this);
4590 ComObjPtr<Medium> pLastIntermediate = pLast->getParent();
4591 for (pLast = pLastIntermediate;
4592 !pLast.isNull() && pLast != pTarget && pLast != this;
4593 pLast = pLast->getParent())
4594 {
4595 AutoReadLock alock(pLast COMMA_LOCKVAL_SRC_POS);
4596 if (pLast->getChildren().size() > 1)
4597 {
4598 throw setError(VBOX_E_OBJECT_IN_USE,
4599 tr("Medium '%s' involved in the merge operation has more than one child medium (%d)"),
4600 pLast->m->strLocationFull.c_str(),
4601 pLast->getChildren().size());
4602 }
4603 if (pLast->m->backRefs.size() != 0)
4604 throw setError(VBOX_E_OBJECT_IN_USE,
4605 tr("Medium '%s' is attached to %d virtual machines"),
4606 pLast->m->strLocationFull.c_str(),
4607 pLast->m->backRefs.size());
4608
4609 }
4610
4611 /* Update medium states appropriately */
4612 {
4613 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
4614
4615 if (m->state == MediumState_Created)
4616 {
4617 rc = markForDeletion();
4618 if (FAILED(rc))
4619 throw rc;
4620 }
4621 else
4622 {
4623 if (fLockMedia)
4624 throw setStateError();
4625 else if ( m->state == MediumState_LockedWrite
4626 || m->state == MediumState_LockedRead)
4627 {
4628 /* Either mark it for deletion in locked state or allow
4629 * others to have done so. */
4630 if (m->preLockState == MediumState_Created)
4631 markLockedForDeletion();
4632 else if (m->preLockState != MediumState_Deleting)
4633 throw setStateError();
4634 }
4635 else
4636 throw setStateError();
4637 }
4638 }
4639
4640 if (fMergeForward)
4641 {
4642 /* we will need parent to reparent target */
4643 pParentForTarget = getParent();
4644 }
4645 else
4646 {
4647 /* we will need to reparent children of the source */
4648 for (MediaList::const_iterator it = getChildren().begin();
4649 it != getChildren().end();
4650 ++it)
4651 {
4652 pMedium = *it;
4653 if (fLockMedia)
4654 {
4655 rc = pMedium->LockWrite(NULL);
4656 if (FAILED(rc))
4657 throw rc;
4658 }
4659
4660 aChildrenToReparent.push_back(pMedium);
4661 }
4662 }
4663 for (pLast = pLastIntermediate;
4664 !pLast.isNull() && pLast != pTarget && pLast != this;
4665 pLast = pLast->getParent())
4666 {
4667 AutoWriteLock alock(pLast COMMA_LOCKVAL_SRC_POS);
4668 if (pLast->m->state == MediumState_Created)
4669 {
4670 rc = pLast->markForDeletion();
4671 if (FAILED(rc))
4672 throw rc;
4673 }
4674 else
4675 throw pLast->setStateError();
4676 }
4677
4678 /* Tweak the lock list in the backward merge case, as the target
4679 * isn't marked to be locked for writing yet. */
4680 if (!fMergeForward)
4681 {
4682 MediumLockList::Base::iterator lockListBegin =
4683 aMediumLockList->GetBegin();
4684 MediumLockList::Base::iterator lockListEnd =
4685 aMediumLockList->GetEnd();
4686 lockListEnd--;
4687 for (MediumLockList::Base::iterator it = lockListBegin;
4688 it != lockListEnd;
4689 ++it)
4690 {
4691 MediumLock &mediumLock = *it;
4692 if (mediumLock.GetMedium() == pTarget)
4693 {
4694 HRESULT rc2 = mediumLock.UpdateLock(true);
4695 AssertComRC(rc2);
4696 break;
4697 }
4698 }
4699 }
4700
4701 if (fLockMedia)
4702 {
4703 treeLock.release();
4704 rc = aMediumLockList->Lock();
4705 treeLock.acquire();
4706 if (FAILED(rc))
4707 {
4708 AutoReadLock alock(pTarget COMMA_LOCKVAL_SRC_POS);
4709 throw setError(rc,
4710 tr("Failed to lock media when merging to '%s'"),
4711 pTarget->getLocationFull().c_str());
4712 }
4713 }
4714 }
4715 catch (HRESULT aRC) { rc = aRC; }
4716
4717 if (FAILED(rc))
4718 {
4719 delete aMediumLockList;
4720 aMediumLockList = NULL;
4721 }
4722
4723 return rc;
4724}
4725
4726/**
4727 * Merges this medium to the specified medium which must be either its
4728 * direct ancestor or descendant.
4729 *
4730 * Given this medium is SOURCE and the specified medium is TARGET, we will
4731 * get two variants of the merge operation:
4732 *
4733 * forward merge
4734 * ------------------------->
4735 * [Extra] <- SOURCE <- Intermediate <- TARGET
4736 * Any Del Del LockWr
4737 *
4738 *
4739 * backward merge
4740 * <-------------------------
4741 * TARGET <- Intermediate <- SOURCE <- [Extra]
4742 * LockWr Del Del LockWr
4743 *
4744 * Each diagram shows the involved media on the media chain where
4745 * SOURCE and TARGET belong. Under each medium there is a state value which
4746 * the medium must have at a time of the mergeTo() call.
4747 *
4748 * The media in the square braces may be absent (e.g. when the forward
4749 * operation takes place and SOURCE is the base medium, or when the backward
4750 * merge operation takes place and TARGET is the last child in the chain) but if
4751 * they present they are involved too as shown.
4752 *
4753 * Neither the source medium nor intermediate media may be attached to
4754 * any VM directly or in the snapshot, otherwise this method will assert.
4755 *
4756 * The #prepareMergeTo() method must be called prior to this method to place all
4757 * involved to necessary states and perform other consistency checks.
4758 *
4759 * If @a aWait is @c true then this method will perform the operation on the
4760 * calling thread and will not return to the caller until the operation is
4761 * completed. When this method succeeds, all intermediate medium objects in
4762 * the chain will be uninitialized, the state of the target medium (and all
4763 * involved extra media) will be restored. @a aMediumLockList will not be
4764 * deleted, whether the operation is successful or not. The caller has to do
4765 * this if appropriate. Note that this (source) medium is not uninitialized
4766 * because of possible AutoCaller instances held by the caller of this method
4767 * on the current thread. It's therefore the responsibility of the caller to
4768 * call Medium::uninit() after releasing all callers.
4769 *
4770 * If @a aWait is @c false then this method will create a thread to perform the
4771 * operation asynchronously and will return immediately. If the operation
4772 * succeeds, the thread will uninitialize the source medium object and all
4773 * intermediate medium objects in the chain, reset the state of the target
4774 * medium (and all involved extra media) and delete @a aMediumLockList.
4775 * If the operation fails, the thread will only reset the states of all
4776 * involved media and delete @a aMediumLockList.
4777 *
4778 * When this method fails (regardless of the @a aWait mode), it is a caller's
4779 * responsibility to undo state changes and delete @a aMediumLockList using
4780 * #cancelMergeTo().
4781 *
4782 * If @a aProgress is not NULL but the object it points to is @c null then a new
4783 * progress object will be created and assigned to @a *aProgress on success,
4784 * otherwise the existing progress object is used. If Progress is NULL, then no
4785 * progress object is created/used at all. Note that @a aProgress cannot be
4786 * NULL when @a aWait is @c false (this method will assert in this case).
4787 *
4788 * @param pTarget Target medium.
4789 * @param fMergeForward Merge direction.
4790 * @param pParentForTarget New parent for target medium after merge.
4791 * @param aChildrenToReparent List of children of the source which will have
4792 * to be reparented to the target after merge.
4793 * @param aMediumLockList Medium locking information.
4794 * @param aProgress Where to find/store a Progress object to track operation
4795 * completion.
4796 * @param aWait @c true if this method should block instead of creating
4797 * an asynchronous thread.
4798 *
4799 * @note Locks the tree lock for writing. Locks the media from the chain
4800 * for writing.
4801 */
4802HRESULT Medium::mergeTo(const ComObjPtr<Medium> &pTarget,
4803 bool fMergeForward,
4804 const ComObjPtr<Medium> &pParentForTarget,
4805 const MediaList &aChildrenToReparent,
4806 MediumLockList *aMediumLockList,
4807 ComObjPtr <Progress> *aProgress,
4808 bool aWait)
4809{
4810 AssertReturn(pTarget != NULL, E_FAIL);
4811 AssertReturn(pTarget != this, E_FAIL);
4812 AssertReturn(aMediumLockList != NULL, E_FAIL);
4813 AssertReturn(aProgress != NULL || aWait == true, E_FAIL);
4814
4815 AutoCaller autoCaller(this);
4816 if (FAILED(autoCaller.rc())) return autoCaller.rc();
4817
4818 AutoCaller targetCaller(pTarget);
4819 AssertComRCReturnRC(targetCaller.rc());
4820
4821 HRESULT rc = S_OK;
4822 ComObjPtr <Progress> pProgress;
4823 Medium::Task *pTask = NULL;
4824
4825 try
4826 {
4827 if (aProgress != NULL)
4828 {
4829 /* use the existing progress object... */
4830 pProgress = *aProgress;
4831
4832 /* ...but create a new one if it is null */
4833 if (pProgress.isNull())
4834 {
4835 Utf8Str tgtName;
4836 {
4837 AutoReadLock alock(pTarget COMMA_LOCKVAL_SRC_POS);
4838 tgtName = pTarget->getName();
4839 }
4840
4841 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
4842
4843 pProgress.createObject();
4844 rc = pProgress->init(m->pVirtualBox,
4845 static_cast<IMedium*>(this),
4846 BstrFmt(tr("Merging medium '%s' to '%s'"),
4847 getName().c_str(),
4848 tgtName.c_str()).raw(),
4849 TRUE /* aCancelable */);
4850 if (FAILED(rc))
4851 throw rc;
4852 }
4853 }
4854
4855 /* setup task object to carry out the operation sync/async */
4856 pTask = new Medium::MergeTask(this, pTarget, fMergeForward,
4857 pParentForTarget, aChildrenToReparent,
4858 pProgress, aMediumLockList,
4859 aWait /* fKeepMediumLockList */);
4860 rc = pTask->rc();
4861 AssertComRC(rc);
4862 if (FAILED(rc))
4863 throw rc;
4864 }
4865 catch (HRESULT aRC) { rc = aRC; }
4866
4867 if (SUCCEEDED(rc))
4868 {
4869 if (aWait)
4870 rc = runNow(pTask);
4871 else
4872 rc = startThread(pTask);
4873
4874 if (SUCCEEDED(rc) && aProgress != NULL)
4875 *aProgress = pProgress;
4876 }
4877 else if (pTask != NULL)
4878 delete pTask;
4879
4880 return rc;
4881}
4882
4883/**
4884 * Undoes what #prepareMergeTo() did. Must be called if #mergeTo() is not
4885 * called or fails. Frees memory occupied by @a aMediumLockList and unlocks
4886 * the medium objects in @a aChildrenToReparent.
4887 *
4888 * @param aChildrenToReparent List of children of the source which will have
4889 * to be reparented to the target after merge.
4890 * @param aMediumLockList Medium locking information.
4891 *
4892 * @note Locks the media from the chain for writing.
4893 */
4894void Medium::cancelMergeTo(const MediaList &aChildrenToReparent,
4895 MediumLockList *aMediumLockList)
4896{
4897 AutoCaller autoCaller(this);
4898 AssertComRCReturnVoid(autoCaller.rc());
4899
4900 AssertReturnVoid(aMediumLockList != NULL);
4901
4902 /* Revert media marked for deletion to previous state. */
4903 HRESULT rc;
4904 MediumLockList::Base::const_iterator mediumListBegin =
4905 aMediumLockList->GetBegin();
4906 MediumLockList::Base::const_iterator mediumListEnd =
4907 aMediumLockList->GetEnd();
4908 for (MediumLockList::Base::const_iterator it = mediumListBegin;
4909 it != mediumListEnd;
4910 ++it)
4911 {
4912 const MediumLock &mediumLock = *it;
4913 const ComObjPtr<Medium> &pMedium = mediumLock.GetMedium();
4914 AutoWriteLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
4915
4916 if (pMedium->m->state == MediumState_Deleting)
4917 {
4918 rc = pMedium->unmarkForDeletion();
4919 AssertComRC(rc);
4920 }
4921 }
4922
4923 /* the destructor will do the work */
4924 delete aMediumLockList;
4925
4926 /* unlock the children which had to be reparented */
4927 for (MediaList::const_iterator it = aChildrenToReparent.begin();
4928 it != aChildrenToReparent.end();
4929 ++it)
4930 {
4931 const ComObjPtr<Medium> &pMedium = *it;
4932
4933 AutoWriteLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
4934 pMedium->UnlockWrite(NULL);
4935 }
4936}
4937
4938/**
4939 * Fix the parent UUID of all children to point to this medium as their
4940 * parent.
4941 */
4942HRESULT Medium::fixParentUuidOfChildren(const MediaList &childrenToReparent)
4943{
4944 Assert(!isWriteLockOnCurrentThread());
4945 Assert(!m->pVirtualBox->getMediaTreeLockHandle().isWriteLockOnCurrentThread());
4946 MediumLockList mediumLockList;
4947 HRESULT rc = createMediumLockList(true /* fFailIfInaccessible */,
4948 false /* fMediumLockWrite */,
4949 this,
4950 mediumLockList);
4951 AssertComRCReturnRC(rc);
4952
4953 try
4954 {
4955 PVBOXHDD hdd;
4956 int vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
4957 ComAssertRCThrow(vrc, E_FAIL);
4958
4959 try
4960 {
4961 MediumLockList::Base::iterator lockListBegin =
4962 mediumLockList.GetBegin();
4963 MediumLockList::Base::iterator lockListEnd =
4964 mediumLockList.GetEnd();
4965 for (MediumLockList::Base::iterator it = lockListBegin;
4966 it != lockListEnd;
4967 ++it)
4968 {
4969 MediumLock &mediumLock = *it;
4970 const ComObjPtr<Medium> &pMedium = mediumLock.GetMedium();
4971 AutoReadLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
4972
4973 // open the medium
4974 vrc = VDOpen(hdd,
4975 pMedium->m->strFormat.c_str(),
4976 pMedium->m->strLocationFull.c_str(),
4977 VD_OPEN_FLAGS_READONLY | m->uOpenFlagsDef,
4978 pMedium->m->vdImageIfaces);
4979 if (RT_FAILURE(vrc))
4980 throw vrc;
4981 }
4982
4983 for (MediaList::const_iterator it = childrenToReparent.begin();
4984 it != childrenToReparent.end();
4985 ++it)
4986 {
4987 /* VD_OPEN_FLAGS_INFO since UUID is wrong yet */
4988 vrc = VDOpen(hdd,
4989 (*it)->m->strFormat.c_str(),
4990 (*it)->m->strLocationFull.c_str(),
4991 VD_OPEN_FLAGS_INFO | m->uOpenFlagsDef,
4992 (*it)->m->vdImageIfaces);
4993 if (RT_FAILURE(vrc))
4994 throw vrc;
4995
4996 vrc = VDSetParentUuid(hdd, VD_LAST_IMAGE, m->id.raw());
4997 if (RT_FAILURE(vrc))
4998 throw vrc;
4999
5000 vrc = VDClose(hdd, false /* fDelete */);
5001 if (RT_FAILURE(vrc))
5002 throw vrc;
5003
5004 (*it)->UnlockWrite(NULL);
5005 }
5006 }
5007 catch (HRESULT aRC) { rc = aRC; }
5008 catch (int aVRC)
5009 {
5010 rc = setError(E_FAIL,
5011 tr("Could not update medium UUID references to parent '%s' (%s)"),
5012 m->strLocationFull.c_str(),
5013 vdError(aVRC).c_str());
5014 }
5015
5016 VDDestroy(hdd);
5017 }
5018 catch (HRESULT aRC) { rc = aRC; }
5019
5020 return rc;
5021}
5022
5023/**
5024 * Used by IAppliance to export disk images.
5025 *
5026 * @param aFilename Filename to create (UTF8).
5027 * @param aFormat Medium format for creating @a aFilename.
5028 * @param aVariant Which exact image format variant to use
5029 * for the destination image.
5030 * @param aVDImageIOCallbacks Pointer to the callback table for a
5031 * VDINTERFACEIO interface. May be NULL.
5032 * @param aVDImageIOUser Opaque data for the callbacks.
5033 * @param aProgress Progress object to use.
5034 * @return
5035 * @note The source format is defined by the Medium instance.
5036 */
5037HRESULT Medium::exportFile(const char *aFilename,
5038 const ComObjPtr<MediumFormat> &aFormat,
5039 MediumVariant_T aVariant,
5040 PVDINTERFACEIO aVDImageIOIf, void *aVDImageIOUser,
5041 const ComObjPtr<Progress> &aProgress)
5042{
5043 AssertPtrReturn(aFilename, E_INVALIDARG);
5044 AssertReturn(!aFormat.isNull(), E_INVALIDARG);
5045 AssertReturn(!aProgress.isNull(), E_INVALIDARG);
5046
5047 AutoCaller autoCaller(this);
5048 if (FAILED(autoCaller.rc())) return autoCaller.rc();
5049
5050 HRESULT rc = S_OK;
5051 Medium::Task *pTask = NULL;
5052
5053 try
5054 {
5055 // This needs no extra locks besides what is done in the called methods.
5056
5057 /* Build the source lock list. */
5058 MediumLockList *pSourceMediumLockList(new MediumLockList());
5059 rc = createMediumLockList(true /* fFailIfInaccessible */,
5060 false /* fMediumLockWrite */,
5061 NULL,
5062 *pSourceMediumLockList);
5063 if (FAILED(rc))
5064 {
5065 delete pSourceMediumLockList;
5066 throw rc;
5067 }
5068
5069 rc = pSourceMediumLockList->Lock();
5070 if (FAILED(rc))
5071 {
5072 delete pSourceMediumLockList;
5073 throw setError(rc,
5074 tr("Failed to lock source media '%s'"),
5075 getLocationFull().c_str());
5076 }
5077
5078 /* setup task object to carry out the operation asynchronously */
5079 pTask = new Medium::ExportTask(this, aProgress, aFilename, aFormat,
5080 aVariant, aVDImageIOIf,
5081 aVDImageIOUser, pSourceMediumLockList);
5082 rc = pTask->rc();
5083 AssertComRC(rc);
5084 if (FAILED(rc))
5085 throw rc;
5086 }
5087 catch (HRESULT aRC) { rc = aRC; }
5088
5089 if (SUCCEEDED(rc))
5090 rc = startThread(pTask);
5091 else if (pTask != NULL)
5092 delete pTask;
5093
5094 return rc;
5095}
5096
5097/**
5098 * Used by IAppliance to import disk images.
5099 *
5100 * @param aFilename Filename to read (UTF8).
5101 * @param aFormat Medium format for reading @a aFilename.
5102 * @param aVariant Which exact image format variant to use
5103 * for the destination image.
5104 * @param aVDImageIOCallbacks Pointer to the callback table for a
5105 * VDINTERFACEIO interface. May be NULL.
5106 * @param aVDImageIOUser Opaque data for the callbacks.
5107 * @param aParent Parent medium. May be NULL.
5108 * @param aProgress Progress object to use.
5109 * @return
5110 * @note The destination format is defined by the Medium instance.
5111 */
5112HRESULT Medium::importFile(const char *aFilename,
5113 const ComObjPtr<MediumFormat> &aFormat,
5114 MediumVariant_T aVariant,
5115 PVDINTERFACEIO aVDImageIOIf, void *aVDImageIOUser,
5116 const ComObjPtr<Medium> &aParent,
5117 const ComObjPtr<Progress> &aProgress)
5118{
5119 AssertPtrReturn(aFilename, E_INVALIDARG);
5120 AssertReturn(!aFormat.isNull(), E_INVALIDARG);
5121 AssertReturn(!aProgress.isNull(), E_INVALIDARG);
5122
5123 AutoCaller autoCaller(this);
5124 if (FAILED(autoCaller.rc())) return autoCaller.rc();
5125
5126 HRESULT rc = S_OK;
5127 Medium::Task *pTask = NULL;
5128
5129 try
5130 {
5131 // locking: we need the tree lock first because we access parent pointers
5132 // and we need to write-lock the media involved
5133 uint32_t cHandles = 2;
5134 LockHandle* pHandles[3] = { &m->pVirtualBox->getMediaTreeLockHandle(),
5135 this->lockHandle() };
5136 /* Only add parent to the lock if it is not null */
5137 if (!aParent.isNull())
5138 pHandles[cHandles++] = aParent->lockHandle();
5139 AutoWriteLock alock(cHandles,
5140 pHandles
5141 COMMA_LOCKVAL_SRC_POS);
5142
5143 if ( m->state != MediumState_NotCreated
5144 && m->state != MediumState_Created)
5145 throw setStateError();
5146
5147 /* Build the target lock list. */
5148 MediumLockList *pTargetMediumLockList(new MediumLockList());
5149 alock.release();
5150 rc = createMediumLockList(true /* fFailIfInaccessible */,
5151 true /* fMediumLockWrite */,
5152 aParent,
5153 *pTargetMediumLockList);
5154 alock.acquire();
5155 if (FAILED(rc))
5156 {
5157 delete pTargetMediumLockList;
5158 throw rc;
5159 }
5160
5161 alock.release();
5162 rc = pTargetMediumLockList->Lock();
5163 alock.acquire();
5164 if (FAILED(rc))
5165 {
5166 delete pTargetMediumLockList;
5167 throw setError(rc,
5168 tr("Failed to lock target media '%s'"),
5169 getLocationFull().c_str());
5170 }
5171
5172 /* setup task object to carry out the operation asynchronously */
5173 pTask = new Medium::ImportTask(this, aProgress, aFilename, aFormat,
5174 aVariant, aVDImageIOIf,
5175 aVDImageIOUser, aParent,
5176 pTargetMediumLockList);
5177 rc = pTask->rc();
5178 AssertComRC(rc);
5179 if (FAILED(rc))
5180 throw rc;
5181
5182 if (m->state == MediumState_NotCreated)
5183 m->state = MediumState_Creating;
5184 }
5185 catch (HRESULT aRC) { rc = aRC; }
5186
5187 if (SUCCEEDED(rc))
5188 rc = startThread(pTask);
5189 else if (pTask != NULL)
5190 delete pTask;
5191
5192 return rc;
5193}
5194
5195/**
5196 * Internal version of the public CloneTo API which allows to enable certain
5197 * optimizations to improve speed during VM cloning.
5198 *
5199 * @param aTarget Target medium
5200 * @param aVariant Which exact image format variant to use
5201 * for the destination image.
5202 * @param aParent Parent medium. May be NULL.
5203 * @param aProgress Progress object to use.
5204 * @param idxSrcImageSame The last image in the source chain which has the
5205 * same content as the given image in the destination
5206 * chain. Use UINT32_MAX to disable this optimization.
5207 * @param idxDstImageSame The last image in the destination chain which has the
5208 * same content as the given image in the source chain.
5209 * Use UINT32_MAX to disable this optimization.
5210 * @return
5211 */
5212HRESULT Medium::cloneToEx(const ComObjPtr<Medium> &aTarget, ULONG aVariant,
5213 const ComObjPtr<Medium> &aParent, IProgress **aProgress,
5214 uint32_t idxSrcImageSame, uint32_t idxDstImageSame)
5215{
5216 CheckComArgNotNull(aTarget);
5217 CheckComArgOutPointerValid(aProgress);
5218 ComAssertRet(aTarget != this, E_INVALIDARG);
5219
5220 AutoCaller autoCaller(this);
5221 if (FAILED(autoCaller.rc())) return autoCaller.rc();
5222
5223 HRESULT rc = S_OK;
5224 ComObjPtr<Progress> pProgress;
5225 Medium::Task *pTask = NULL;
5226
5227 try
5228 {
5229 // locking: we need the tree lock first because we access parent pointers
5230 // and we need to write-lock the media involved
5231 uint32_t cHandles = 3;
5232 LockHandle* pHandles[4] = { &m->pVirtualBox->getMediaTreeLockHandle(),
5233 this->lockHandle(),
5234 aTarget->lockHandle() };
5235 /* Only add parent to the lock if it is not null */
5236 if (!aParent.isNull())
5237 pHandles[cHandles++] = aParent->lockHandle();
5238 AutoWriteLock alock(cHandles,
5239 pHandles
5240 COMMA_LOCKVAL_SRC_POS);
5241
5242 if ( aTarget->m->state != MediumState_NotCreated
5243 && aTarget->m->state != MediumState_Created)
5244 throw aTarget->setStateError();
5245
5246 /* Build the source lock list. */
5247 MediumLockList *pSourceMediumLockList(new MediumLockList());
5248 alock.release();
5249 rc = createMediumLockList(true /* fFailIfInaccessible */,
5250 false /* fMediumLockWrite */,
5251 NULL,
5252 *pSourceMediumLockList);
5253 alock.acquire();
5254 if (FAILED(rc))
5255 {
5256 delete pSourceMediumLockList;
5257 throw rc;
5258 }
5259
5260 /* Build the target lock list (including the to-be parent chain). */
5261 MediumLockList *pTargetMediumLockList(new MediumLockList());
5262 alock.release();
5263 rc = aTarget->createMediumLockList(true /* fFailIfInaccessible */,
5264 true /* fMediumLockWrite */,
5265 aParent,
5266 *pTargetMediumLockList);
5267 alock.acquire();
5268 if (FAILED(rc))
5269 {
5270 delete pSourceMediumLockList;
5271 delete pTargetMediumLockList;
5272 throw rc;
5273 }
5274
5275 alock.release();
5276 rc = pSourceMediumLockList->Lock();
5277 alock.acquire();
5278 if (FAILED(rc))
5279 {
5280 delete pSourceMediumLockList;
5281 delete pTargetMediumLockList;
5282 throw setError(rc,
5283 tr("Failed to lock source media '%s'"),
5284 getLocationFull().c_str());
5285 }
5286 alock.release();
5287 rc = pTargetMediumLockList->Lock();
5288 alock.acquire();
5289 if (FAILED(rc))
5290 {
5291 delete pSourceMediumLockList;
5292 delete pTargetMediumLockList;
5293 throw setError(rc,
5294 tr("Failed to lock target media '%s'"),
5295 aTarget->getLocationFull().c_str());
5296 }
5297
5298 pProgress.createObject();
5299 rc = pProgress->init(m->pVirtualBox,
5300 static_cast <IMedium *>(this),
5301 BstrFmt(tr("Creating clone medium '%s'"), aTarget->m->strLocationFull.c_str()).raw(),
5302 TRUE /* aCancelable */);
5303 if (FAILED(rc))
5304 {
5305 delete pSourceMediumLockList;
5306 delete pTargetMediumLockList;
5307 throw rc;
5308 }
5309
5310 /* setup task object to carry out the operation asynchronously */
5311 pTask = new Medium::CloneTask(this, pProgress, aTarget,
5312 (MediumVariant_T)aVariant,
5313 aParent, idxSrcImageSame,
5314 idxDstImageSame, pSourceMediumLockList,
5315 pTargetMediumLockList);
5316 rc = pTask->rc();
5317 AssertComRC(rc);
5318 if (FAILED(rc))
5319 throw rc;
5320
5321 if (aTarget->m->state == MediumState_NotCreated)
5322 aTarget->m->state = MediumState_Creating;
5323 }
5324 catch (HRESULT aRC) { rc = aRC; }
5325
5326 if (SUCCEEDED(rc))
5327 {
5328 rc = startThread(pTask);
5329
5330 if (SUCCEEDED(rc))
5331 pProgress.queryInterfaceTo(aProgress);
5332 }
5333 else if (pTask != NULL)
5334 delete pTask;
5335
5336 return rc;
5337}
5338
5339////////////////////////////////////////////////////////////////////////////////
5340//
5341// Private methods
5342//
5343////////////////////////////////////////////////////////////////////////////////
5344
5345/**
5346 * Queries information from the medium.
5347 *
5348 * As a result of this call, the accessibility state and data members such as
5349 * size and description will be updated with the current information.
5350 *
5351 * @note This method may block during a system I/O call that checks storage
5352 * accessibility.
5353 *
5354 * @note Caller MUST NOT hold the media tree or medium lock.
5355 *
5356 * @note Locks mParent for reading. Locks this object for writing.
5357 *
5358 * @param fSetImageId Whether to reset the UUID contained in the image file to the UUID in the medium instance data (see SetIDs())
5359 * @param fSetParentId Whether to reset the parent UUID contained in the image file to the parent UUID in the medium instance data (see SetIDs())
5360 * @return
5361 */
5362HRESULT Medium::queryInfo(bool fSetImageId, bool fSetParentId)
5363{
5364 Assert(!isWriteLockOnCurrentThread());
5365 AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
5366
5367 if ( m->state != MediumState_Created
5368 && m->state != MediumState_Inaccessible
5369 && m->state != MediumState_LockedRead)
5370 return E_FAIL;
5371
5372 HRESULT rc = S_OK;
5373
5374 int vrc = VINF_SUCCESS;
5375
5376 /* check if a blocking queryInfo() call is in progress on some other thread,
5377 * and wait for it to finish if so instead of querying data ourselves */
5378 if (m->queryInfoRunning)
5379 {
5380 Assert( m->state == MediumState_LockedRead
5381 || m->state == MediumState_LockedWrite);
5382
5383 while (m->queryInfoRunning)
5384 {
5385 alock.release();
5386 {
5387 AutoReadLock qlock(m->queryInfoSem COMMA_LOCKVAL_SRC_POS);
5388 }
5389 alock.acquire();
5390 }
5391
5392 return S_OK;
5393 }
5394
5395 bool success = false;
5396 Utf8Str lastAccessError;
5397
5398 /* are we dealing with a new medium constructed using the existing
5399 * location? */
5400 bool isImport = m->id.isEmpty();
5401 unsigned uOpenFlags = VD_OPEN_FLAGS_INFO;
5402
5403 /* Note that we don't use VD_OPEN_FLAGS_READONLY when opening new
5404 * media because that would prevent necessary modifications
5405 * when opening media of some third-party formats for the first
5406 * time in VirtualBox (such as VMDK for which VDOpen() needs to
5407 * generate an UUID if it is missing) */
5408 if ( m->hddOpenMode == OpenReadOnly
5409 || m->type == MediumType_Readonly
5410 || (!isImport && !fSetImageId && !fSetParentId)
5411 )
5412 uOpenFlags |= VD_OPEN_FLAGS_READONLY;
5413
5414 /* Open shareable medium with the appropriate flags */
5415 if (m->type == MediumType_Shareable)
5416 uOpenFlags |= VD_OPEN_FLAGS_SHAREABLE;
5417
5418 /* Lock the medium, which makes the behavior much more consistent */
5419 alock.release();
5420 if (uOpenFlags & (VD_OPEN_FLAGS_READONLY | VD_OPEN_FLAGS_SHAREABLE))
5421 rc = LockRead(NULL);
5422 else
5423 rc = LockWrite(NULL);
5424 if (FAILED(rc)) return rc;
5425 alock.acquire();
5426
5427 /* Copies of the input state fields which are not read-only,
5428 * as we're dropping the lock. CAUTION: be extremely careful what
5429 * you do with the contents of this medium object, as you will
5430 * create races if there are concurrent changes. */
5431 Utf8Str format(m->strFormat);
5432 Utf8Str location(m->strLocationFull);
5433 ComObjPtr<MediumFormat> formatObj = m->formatObj;
5434
5435 /* "Output" values which can't be set because the lock isn't held
5436 * at the time the values are determined. */
5437 Guid mediumId = m->id;
5438 uint64_t mediumSize = 0;
5439 uint64_t mediumLogicalSize = 0;
5440
5441 /* Flag whether a base image has a non-zero parent UUID and thus
5442 * need repairing after it was closed again. */
5443 bool fRepairImageZeroParentUuid = false;
5444
5445 /* release the object lock before a lengthy operation, and take the
5446 * opportunity to have a media tree lock, too, which isn't held initially */
5447 m->queryInfoRunning = true;
5448 alock.release();
5449 Assert(!isWriteLockOnCurrentThread());
5450 Assert(!m->pVirtualBox->getMediaTreeLockHandle().isWriteLockOnCurrentThread());
5451 AutoWriteLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
5452 treeLock.release();
5453
5454 /* Note that taking the queryInfoSem after leaving the object lock above
5455 * can lead to short spinning of the loops waiting for queryInfo() to
5456 * complete. This is unavoidable since the other order causes a lock order
5457 * violation: here it would be requesting the object lock (at the beginning
5458 * of the method), then queryInfoSem, and below the other way round. */
5459 AutoWriteLock qlock(m->queryInfoSem COMMA_LOCKVAL_SRC_POS);
5460
5461 try
5462 {
5463 /* skip accessibility checks for host drives */
5464 if (m->hostDrive)
5465 {
5466 success = true;
5467 throw S_OK;
5468 }
5469
5470 PVBOXHDD hdd;
5471 vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
5472 ComAssertRCThrow(vrc, E_FAIL);
5473
5474 try
5475 {
5476 /** @todo This kind of opening of media is assuming that diff
5477 * media can be opened as base media. Should be documented that
5478 * it must work for all medium format backends. */
5479 vrc = VDOpen(hdd,
5480 format.c_str(),
5481 location.c_str(),
5482 uOpenFlags | m->uOpenFlagsDef,
5483 m->vdImageIfaces);
5484 if (RT_FAILURE(vrc))
5485 {
5486 lastAccessError = Utf8StrFmt(tr("Could not open the medium '%s'%s"),
5487 location.c_str(), vdError(vrc).c_str());
5488 throw S_OK;
5489 }
5490
5491 if (formatObj->getCapabilities() & MediumFormatCapabilities_Uuid)
5492 {
5493 /* Modify the UUIDs if necessary. The associated fields are
5494 * not modified by other code, so no need to copy. */
5495 if (fSetImageId)
5496 {
5497 alock.acquire();
5498 vrc = VDSetUuid(hdd, 0, m->uuidImage.raw());
5499 alock.release();
5500 ComAssertRCThrow(vrc, E_FAIL);
5501 mediumId = m->uuidImage;
5502 }
5503 if (fSetParentId)
5504 {
5505 alock.acquire();
5506 vrc = VDSetParentUuid(hdd, 0, m->uuidParentImage.raw());
5507 alock.release();
5508 ComAssertRCThrow(vrc, E_FAIL);
5509 }
5510 /* zap the information, these are no long-term members */
5511 alock.acquire();
5512 unconst(m->uuidImage).clear();
5513 unconst(m->uuidParentImage).clear();
5514 alock.release();
5515
5516 /* check the UUID */
5517 RTUUID uuid;
5518 vrc = VDGetUuid(hdd, 0, &uuid);
5519 ComAssertRCThrow(vrc, E_FAIL);
5520
5521 if (isImport)
5522 {
5523 mediumId = uuid;
5524
5525 if (mediumId.isEmpty() && (m->hddOpenMode == OpenReadOnly))
5526 // only when importing a VDMK that has no UUID, create one in memory
5527 mediumId.create();
5528 }
5529 else
5530 {
5531 Assert(!mediumId.isEmpty());
5532
5533 if (mediumId != uuid)
5534 {
5535 /** @todo r=klaus this always refers to VirtualBox.xml as the medium registry, even for new VMs */
5536 lastAccessError = Utf8StrFmt(
5537 tr("UUID {%RTuuid} of the medium '%s' does not match the value {%RTuuid} stored in the media registry ('%s')"),
5538 &uuid,
5539 location.c_str(),
5540 mediumId.raw(),
5541 m->pVirtualBox->settingsFilePath().c_str());
5542 throw S_OK;
5543 }
5544 }
5545 }
5546 else
5547 {
5548 /* the backend does not support storing UUIDs within the
5549 * underlying storage so use what we store in XML */
5550
5551 if (fSetImageId)
5552 {
5553 /* set the UUID if an API client wants to change it */
5554 alock.acquire();
5555 mediumId = m->uuidImage;
5556 alock.release();
5557 }
5558 else if (isImport)
5559 {
5560 /* generate an UUID for an imported UUID-less medium */
5561 mediumId.create();
5562 }
5563 }
5564
5565 /* get the medium variant */
5566 unsigned uImageFlags;
5567 vrc = VDGetImageFlags(hdd, 0, &uImageFlags);
5568 ComAssertRCThrow(vrc, E_FAIL);
5569 alock.acquire();
5570 m->variant = (MediumVariant_T)uImageFlags;
5571 alock.release();
5572
5573 /* check/get the parent uuid and update corresponding state */
5574 if (uImageFlags & VD_IMAGE_FLAGS_DIFF)
5575 {
5576 RTUUID parentId;
5577 vrc = VDGetParentUuid(hdd, 0, &parentId);
5578 ComAssertRCThrow(vrc, E_FAIL);
5579
5580 /* streamOptimized VMDK images are only accepted as base
5581 * images, as this allows automatic repair of OVF appliances.
5582 * Since such images don't support random writes they will not
5583 * be created for diff images. Only an overly smart user might
5584 * manually create this case. Too bad for him. */
5585 if ( isImport
5586 && !(uImageFlags & VD_VMDK_IMAGE_FLAGS_STREAM_OPTIMIZED))
5587 {
5588 /* the parent must be known to us. Note that we freely
5589 * call locking methods of mVirtualBox and parent, as all
5590 * relevant locks must be already held. There may be no
5591 * concurrent access to the just opened medium on other
5592 * threads yet (and init() will fail if this method reports
5593 * MediumState_Inaccessible) */
5594
5595 Guid id = parentId;
5596 ComObjPtr<Medium> pParent;
5597 rc = m->pVirtualBox->findHardDiskById(id, false /* aSetError */, &pParent);
5598 if (FAILED(rc))
5599 {
5600 lastAccessError = Utf8StrFmt(
5601 tr("Parent medium with UUID {%RTuuid} of the medium '%s' is not found in the media registry ('%s')"),
5602 &parentId, location.c_str(),
5603 m->pVirtualBox->settingsFilePath().c_str());
5604 throw S_OK;
5605 }
5606
5607 /* we set mParent & children() */
5608 treeLock.acquire();
5609
5610 Assert(m->pParent.isNull());
5611 m->pParent = pParent;
5612 m->pParent->m->llChildren.push_back(this);
5613
5614 treeLock.release();
5615 }
5616 else
5617 {
5618 /* we access mParent */
5619 treeLock.acquire();
5620
5621 /* check that parent UUIDs match. Note that there's no need
5622 * for the parent's AutoCaller (our lifetime is bound to
5623 * it) */
5624
5625 if (m->pParent.isNull())
5626 {
5627 /* Due to a bug in VDCopy() in VirtualBox 3.0.0-3.0.14
5628 * and 3.1.0-3.1.8 there are base images out there
5629 * which have a non-zero parent UUID. No point in
5630 * complaining about them, instead automatically
5631 * repair the problem. Later we can bring back the
5632 * error message, but we should wait until really
5633 * most users have repaired their images, either with
5634 * VBoxFixHdd or this way. */
5635#if 1
5636 fRepairImageZeroParentUuid = true;
5637#else /* 0 */
5638 lastAccessError = Utf8StrFmt(
5639 tr("Medium type of '%s' is differencing but it is not associated with any parent medium in the media registry ('%s')"),
5640 location.c_str(),
5641 m->pVirtualBox->settingsFilePath().c_str());
5642 treeLock.release();
5643 throw S_OK;
5644#endif /* 0 */
5645 }
5646
5647 {
5648 AutoReadLock parentLock(m->pParent COMMA_LOCKVAL_SRC_POS);
5649 if ( !fRepairImageZeroParentUuid
5650 && m->pParent->getState() != MediumState_Inaccessible
5651 && m->pParent->getId() != parentId)
5652 {
5653 /** @todo r=klaus this always refers to VirtualBox.xml as the medium registry, even for new VMs */
5654 lastAccessError = Utf8StrFmt(
5655 tr("Parent UUID {%RTuuid} of the medium '%s' does not match UUID {%RTuuid} of its parent medium stored in the media registry ('%s')"),
5656 &parentId, location.c_str(),
5657 m->pParent->getId().raw(),
5658 m->pVirtualBox->settingsFilePath().c_str());
5659 parentLock.release();
5660 treeLock.release();
5661 throw S_OK;
5662 }
5663 }
5664
5665 /// @todo NEWMEDIA what to do if the parent is not
5666 /// accessible while the diff is? Probably nothing. The
5667 /// real code will detect the mismatch anyway.
5668
5669 treeLock.release();
5670 }
5671 }
5672
5673 mediumSize = VDGetFileSize(hdd, 0);
5674 mediumLogicalSize = VDGetSize(hdd, 0);
5675
5676 success = true;
5677 }
5678 catch (HRESULT aRC)
5679 {
5680 rc = aRC;
5681 }
5682
5683 vrc = VDDestroy(hdd);
5684 if (RT_FAILURE(vrc))
5685 {
5686 lastAccessError = Utf8StrFmt(tr("Could not update and close the medium '%s'%s"),
5687 location.c_str(), vdError(vrc).c_str());
5688 success = false;
5689 throw S_OK;
5690 }
5691 }
5692 catch (HRESULT aRC)
5693 {
5694 rc = aRC;
5695 }
5696
5697 treeLock.acquire();
5698 alock.acquire();
5699
5700 if (isImport || fSetImageId)
5701 unconst(m->id) = mediumId;
5702
5703 if (success)
5704 {
5705 m->size = mediumSize;
5706 m->logicalSize = mediumLogicalSize;
5707 m->strLastAccessError.setNull();
5708 }
5709 else
5710 {
5711 m->strLastAccessError = lastAccessError;
5712 LogWarningFunc(("'%s' is not accessible (error='%s', rc=%Rhrc, vrc=%Rrc)\n",
5713 location.c_str(), m->strLastAccessError.c_str(),
5714 rc, vrc));
5715 }
5716
5717 /* unblock anyone waiting for the queryInfo results */
5718 qlock.release();
5719 m->queryInfoRunning = false;
5720
5721 /* Set the proper state according to the result of the check */
5722 if (success)
5723 m->preLockState = MediumState_Created;
5724 else
5725 m->preLockState = MediumState_Inaccessible;
5726
5727 HRESULT rc2;
5728 if (uOpenFlags & (VD_OPEN_FLAGS_READONLY | VD_OPEN_FLAGS_SHAREABLE))
5729 rc2 = UnlockRead(NULL);
5730 else
5731 rc2 = UnlockWrite(NULL);
5732 if (SUCCEEDED(rc) && FAILED(rc2))
5733 rc = rc2;
5734 if (FAILED(rc)) return rc;
5735
5736 /* If this is a base image which incorrectly has a parent UUID set,
5737 * repair the image now by zeroing the parent UUID. This is only done
5738 * when we have structural information from a config file, on import
5739 * this is not possible. If someone would accidentally call openMedium
5740 * with a diff image before the base is registered this would destroy
5741 * the diff. Not acceptable. */
5742 if (fRepairImageZeroParentUuid)
5743 {
5744 rc = LockWrite(NULL);
5745 if (FAILED(rc)) return rc;
5746
5747 alock.release();
5748
5749 try
5750 {
5751 PVBOXHDD hdd;
5752 vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
5753 ComAssertRCThrow(vrc, E_FAIL);
5754
5755 try
5756 {
5757 vrc = VDOpen(hdd,
5758 format.c_str(),
5759 location.c_str(),
5760 (uOpenFlags & ~VD_OPEN_FLAGS_READONLY) | m->uOpenFlagsDef,
5761 m->vdImageIfaces);
5762 if (RT_FAILURE(vrc))
5763 throw S_OK;
5764
5765 RTUUID zeroParentUuid;
5766 RTUuidClear(&zeroParentUuid);
5767 vrc = VDSetParentUuid(hdd, 0, &zeroParentUuid);
5768 ComAssertRCThrow(vrc, E_FAIL);
5769 }
5770 catch (HRESULT aRC)
5771 {
5772 rc = aRC;
5773 }
5774
5775 VDDestroy(hdd);
5776 }
5777 catch (HRESULT aRC)
5778 {
5779 rc = aRC;
5780 }
5781
5782 rc = UnlockWrite(NULL);
5783 if (SUCCEEDED(rc) && FAILED(rc2))
5784 rc = rc2;
5785 if (FAILED(rc)) return rc;
5786 }
5787
5788 return rc;
5789}
5790
5791/**
5792 * Performs extra checks if the medium can be closed and returns S_OK in
5793 * this case. Otherwise, returns a respective error message. Called by
5794 * Close() under the medium tree lock and the medium lock.
5795 *
5796 * @note Also reused by Medium::Reset().
5797 *
5798 * @note Caller must hold the media tree write lock!
5799 */
5800HRESULT Medium::canClose()
5801{
5802 Assert(m->pVirtualBox->getMediaTreeLockHandle().isWriteLockOnCurrentThread());
5803
5804 if (getChildren().size() != 0)
5805 return setError(VBOX_E_OBJECT_IN_USE,
5806 tr("Cannot close medium '%s' because it has %d child media"),
5807 m->strLocationFull.c_str(), getChildren().size());
5808
5809 return S_OK;
5810}
5811
5812/**
5813 * Unregisters this medium with mVirtualBox. Called by close() under the medium tree lock.
5814 *
5815 * @note Caller must have locked the media tree lock for writing!
5816 */
5817HRESULT Medium::unregisterWithVirtualBox()
5818{
5819 /* Note that we need to de-associate ourselves from the parent to let
5820 * unregisterMedium() properly save the registry */
5821
5822 /* we modify mParent and access children */
5823 Assert(m->pVirtualBox->getMediaTreeLockHandle().isWriteLockOnCurrentThread());
5824
5825 Medium *pParentBackup = m->pParent;
5826 AssertReturn(getChildren().size() == 0, E_FAIL);
5827 if (m->pParent)
5828 deparent();
5829
5830 HRESULT rc = m->pVirtualBox->unregisterMedium(this);
5831 if (FAILED(rc))
5832 {
5833 if (pParentBackup)
5834 {
5835 // re-associate with the parent as we are still relatives in the registry
5836 m->pParent = pParentBackup;
5837 m->pParent->m->llChildren.push_back(this);
5838 }
5839 }
5840
5841 return rc;
5842}
5843
5844/**
5845 * Like SetProperty but do not trigger a settings store. Only for internal use!
5846 */
5847HRESULT Medium::setPropertyDirect(const Utf8Str &aName, const Utf8Str &aValue)
5848{
5849 AutoCaller autoCaller(this);
5850 if (FAILED(autoCaller.rc())) return autoCaller.rc();
5851
5852 AutoWriteLock mlock(this COMMA_LOCKVAL_SRC_POS);
5853
5854 switch (m->state)
5855 {
5856 case MediumState_Created:
5857 case MediumState_Inaccessible:
5858 break;
5859 default:
5860 return setStateError();
5861 }
5862
5863 m->mapProperties[aName] = aValue;
5864
5865 return S_OK;
5866}
5867
5868/**
5869 * Sets the extended error info according to the current media state.
5870 *
5871 * @note Must be called from under this object's write or read lock.
5872 */
5873HRESULT Medium::setStateError()
5874{
5875 HRESULT rc = E_FAIL;
5876
5877 switch (m->state)
5878 {
5879 case MediumState_NotCreated:
5880 {
5881 rc = setError(VBOX_E_INVALID_OBJECT_STATE,
5882 tr("Storage for the medium '%s' is not created"),
5883 m->strLocationFull.c_str());
5884 break;
5885 }
5886 case MediumState_Created:
5887 {
5888 rc = setError(VBOX_E_INVALID_OBJECT_STATE,
5889 tr("Storage for the medium '%s' is already created"),
5890 m->strLocationFull.c_str());
5891 break;
5892 }
5893 case MediumState_LockedRead:
5894 {
5895 rc = setError(VBOX_E_INVALID_OBJECT_STATE,
5896 tr("Medium '%s' is locked for reading by another task"),
5897 m->strLocationFull.c_str());
5898 break;
5899 }
5900 case MediumState_LockedWrite:
5901 {
5902 rc = setError(VBOX_E_INVALID_OBJECT_STATE,
5903 tr("Medium '%s' is locked for writing by another task"),
5904 m->strLocationFull.c_str());
5905 break;
5906 }
5907 case MediumState_Inaccessible:
5908 {
5909 /* be in sync with Console::powerUpThread() */
5910 if (!m->strLastAccessError.isEmpty())
5911 rc = setError(VBOX_E_INVALID_OBJECT_STATE,
5912 tr("Medium '%s' is not accessible. %s"),
5913 m->strLocationFull.c_str(), m->strLastAccessError.c_str());
5914 else
5915 rc = setError(VBOX_E_INVALID_OBJECT_STATE,
5916 tr("Medium '%s' is not accessible"),
5917 m->strLocationFull.c_str());
5918 break;
5919 }
5920 case MediumState_Creating:
5921 {
5922 rc = setError(VBOX_E_INVALID_OBJECT_STATE,
5923 tr("Storage for the medium '%s' is being created"),
5924 m->strLocationFull.c_str());
5925 break;
5926 }
5927 case MediumState_Deleting:
5928 {
5929 rc = setError(VBOX_E_INVALID_OBJECT_STATE,
5930 tr("Storage for the medium '%s' is being deleted"),
5931 m->strLocationFull.c_str());
5932 break;
5933 }
5934 default:
5935 {
5936 AssertFailed();
5937 break;
5938 }
5939 }
5940
5941 return rc;
5942}
5943
5944/**
5945 * Sets the value of m->strLocationFull. The given location must be a fully
5946 * qualified path; relative paths are not supported here.
5947 *
5948 * As a special exception, if the specified location is a file path that ends with '/'
5949 * then the file name part will be generated by this method automatically in the format
5950 * '{<uuid>}.<ext>' where <uuid> is a fresh UUID that this method will generate
5951 * and assign to this medium, and <ext> is the default extension for this
5952 * medium's storage format. Note that this procedure requires the media state to
5953 * be NotCreated and will return a failure otherwise.
5954 *
5955 * @param aLocation Location of the storage unit. If the location is a FS-path,
5956 * then it can be relative to the VirtualBox home directory.
5957 * @param aFormat Optional fallback format if it is an import and the format
5958 * cannot be determined.
5959 *
5960 * @note Must be called from under this object's write lock.
5961 */
5962HRESULT Medium::setLocation(const Utf8Str &aLocation,
5963 const Utf8Str &aFormat /* = Utf8Str::Empty */)
5964{
5965 AssertReturn(!aLocation.isEmpty(), E_FAIL);
5966
5967 AutoCaller autoCaller(this);
5968 AssertComRCReturnRC(autoCaller.rc());
5969
5970 /* formatObj may be null only when initializing from an existing path and
5971 * no format is known yet */
5972 AssertReturn( (!m->strFormat.isEmpty() && !m->formatObj.isNull())
5973 || ( autoCaller.state() == InInit
5974 && m->state != MediumState_NotCreated
5975 && m->id.isEmpty()
5976 && m->strFormat.isEmpty()
5977 && m->formatObj.isNull()),
5978 E_FAIL);
5979
5980 /* are we dealing with a new medium constructed using the existing
5981 * location? */
5982 bool isImport = m->strFormat.isEmpty();
5983
5984 if ( isImport
5985 || ( (m->formatObj->getCapabilities() & MediumFormatCapabilities_File)
5986 && !m->hostDrive))
5987 {
5988 Guid id;
5989
5990 Utf8Str locationFull(aLocation);
5991
5992 if (m->state == MediumState_NotCreated)
5993 {
5994 /* must be a file (formatObj must be already known) */
5995 Assert(m->formatObj->getCapabilities() & MediumFormatCapabilities_File);
5996
5997 if (RTPathFilename(aLocation.c_str()) == NULL)
5998 {
5999 /* no file name is given (either an empty string or ends with a
6000 * slash), generate a new UUID + file name if the state allows
6001 * this */
6002
6003 ComAssertMsgRet(!m->formatObj->getFileExtensions().empty(),
6004 ("Must be at least one extension if it is MediumFormatCapabilities_File\n"),
6005 E_FAIL);
6006
6007 Utf8Str strExt = m->formatObj->getFileExtensions().front();
6008 ComAssertMsgRet(!strExt.isEmpty(),
6009 ("Default extension must not be empty\n"),
6010 E_FAIL);
6011
6012 id.create();
6013
6014 locationFull = Utf8StrFmt("%s{%RTuuid}.%s",
6015 aLocation.c_str(), id.raw(), strExt.c_str());
6016 }
6017 }
6018
6019 // we must always have full paths now (if it refers to a file)
6020 if ( ( m->formatObj.isNull()
6021 || m->formatObj->getCapabilities() & MediumFormatCapabilities_File)
6022 && !RTPathStartsWithRoot(locationFull.c_str()))
6023 return setError(VBOX_E_FILE_ERROR,
6024 tr("The given path '%s' is not fully qualified"),
6025 locationFull.c_str());
6026
6027 /* detect the backend from the storage unit if importing */
6028 if (isImport)
6029 {
6030 VDTYPE enmType = VDTYPE_INVALID;
6031 char *backendName = NULL;
6032
6033 int vrc = VINF_SUCCESS;
6034
6035 /* is it a file? */
6036 {
6037 RTFILE file;
6038 vrc = RTFileOpen(&file, locationFull.c_str(), RTFILE_O_READ | RTFILE_O_OPEN | RTFILE_O_DENY_NONE);
6039 if (RT_SUCCESS(vrc))
6040 RTFileClose(file);
6041 }
6042 if (RT_SUCCESS(vrc))
6043 {
6044 vrc = VDGetFormat(NULL /* pVDIfsDisk */, NULL /* pVDIfsImage */,
6045 locationFull.c_str(), &backendName, &enmType);
6046 }
6047 else if ( vrc != VERR_FILE_NOT_FOUND
6048 && vrc != VERR_PATH_NOT_FOUND
6049 && vrc != VERR_ACCESS_DENIED
6050 && locationFull != aLocation)
6051 {
6052 /* assume it's not a file, restore the original location */
6053 locationFull = aLocation;
6054 vrc = VDGetFormat(NULL /* pVDIfsDisk */, NULL /* pVDIfsImage */,
6055 locationFull.c_str(), &backendName, &enmType);
6056 }
6057
6058 if (RT_FAILURE(vrc))
6059 {
6060 if (vrc == VERR_ACCESS_DENIED)
6061 return setError(VBOX_E_FILE_ERROR,
6062 tr("Permission problem accessing the file for the medium '%s' (%Rrc)"),
6063 locationFull.c_str(), vrc);
6064 else if (vrc == VERR_FILE_NOT_FOUND || vrc == VERR_PATH_NOT_FOUND)
6065 return setError(VBOX_E_FILE_ERROR,
6066 tr("Could not find file for the medium '%s' (%Rrc)"),
6067 locationFull.c_str(), vrc);
6068 else if (aFormat.isEmpty())
6069 return setError(VBOX_E_IPRT_ERROR,
6070 tr("Could not get the storage format of the medium '%s' (%Rrc)"),
6071 locationFull.c_str(), vrc);
6072 else
6073 {
6074 HRESULT rc = setFormat(aFormat);
6075 /* setFormat() must not fail since we've just used the backend so
6076 * the format object must be there */
6077 AssertComRCReturnRC(rc);
6078 }
6079 }
6080 else if ( enmType == VDTYPE_INVALID
6081 || m->devType != convertToDeviceType(enmType))
6082 {
6083 /*
6084 * The user tried to use a image as a device which is not supported
6085 * by the backend.
6086 */
6087 return setError(E_FAIL,
6088 tr("The medium '%s' can't be used as the requested device type"),
6089 locationFull.c_str());
6090 }
6091 else
6092 {
6093 ComAssertRet(backendName != NULL && *backendName != '\0', E_FAIL);
6094
6095 HRESULT rc = setFormat(backendName);
6096 RTStrFree(backendName);
6097
6098 /* setFormat() must not fail since we've just used the backend so
6099 * the format object must be there */
6100 AssertComRCReturnRC(rc);
6101 }
6102 }
6103
6104 m->strLocationFull = locationFull;
6105
6106 /* is it still a file? */
6107 if ( (m->formatObj->getCapabilities() & MediumFormatCapabilities_File)
6108 && (m->state == MediumState_NotCreated)
6109 )
6110 /* assign a new UUID (this UUID will be used when calling
6111 * VDCreateBase/VDCreateDiff as a wanted UUID). Note that we
6112 * also do that if we didn't generate it to make sure it is
6113 * either generated by us or reset to null */
6114 unconst(m->id) = id;
6115 }
6116 else
6117 m->strLocationFull = aLocation;
6118
6119 return S_OK;
6120}
6121
6122/**
6123 * Checks that the format ID is valid and sets it on success.
6124 *
6125 * Note that this method will caller-reference the format object on success!
6126 * This reference must be released somewhere to let the MediumFormat object be
6127 * uninitialized.
6128 *
6129 * @note Must be called from under this object's write lock.
6130 */
6131HRESULT Medium::setFormat(const Utf8Str &aFormat)
6132{
6133 /* get the format object first */
6134 {
6135 SystemProperties *pSysProps = m->pVirtualBox->getSystemProperties();
6136 AutoReadLock propsLock(pSysProps COMMA_LOCKVAL_SRC_POS);
6137
6138 unconst(m->formatObj) = pSysProps->mediumFormat(aFormat);
6139 if (m->formatObj.isNull())
6140 return setError(E_INVALIDARG,
6141 tr("Invalid medium storage format '%s'"),
6142 aFormat.c_str());
6143
6144 /* reference the format permanently to prevent its unexpected
6145 * uninitialization */
6146 HRESULT rc = m->formatObj->addCaller();
6147 AssertComRCReturnRC(rc);
6148
6149 /* get properties (preinsert them as keys in the map). Note that the
6150 * map doesn't grow over the object life time since the set of
6151 * properties is meant to be constant. */
6152
6153 Assert(m->mapProperties.empty());
6154
6155 for (MediumFormat::PropertyList::const_iterator it = m->formatObj->getProperties().begin();
6156 it != m->formatObj->getProperties().end();
6157 ++it)
6158 {
6159 m->mapProperties.insert(std::make_pair(it->strName, Utf8Str::Empty));
6160 }
6161 }
6162
6163 unconst(m->strFormat) = aFormat;
6164
6165 return S_OK;
6166}
6167
6168/**
6169 * Converts the Medium device type to the VD type.
6170 */
6171VDTYPE Medium::convertDeviceType()
6172{
6173 VDTYPE enmType;
6174
6175 switch (m->devType)
6176 {
6177 case DeviceType_HardDisk:
6178 enmType = VDTYPE_HDD;
6179 break;
6180 case DeviceType_DVD:
6181 enmType = VDTYPE_DVD;
6182 break;
6183 case DeviceType_Floppy:
6184 enmType = VDTYPE_FLOPPY;
6185 break;
6186 default:
6187 ComAssertFailedRet(VDTYPE_INVALID);
6188 }
6189
6190 return enmType;
6191}
6192
6193/**
6194 * Converts from the VD type to the medium type.
6195 */
6196DeviceType_T Medium::convertToDeviceType(VDTYPE enmType)
6197{
6198 DeviceType_T devType;
6199
6200 switch (enmType)
6201 {
6202 case VDTYPE_HDD:
6203 devType = DeviceType_HardDisk;
6204 break;
6205 case VDTYPE_DVD:
6206 devType = DeviceType_DVD;
6207 break;
6208 case VDTYPE_FLOPPY:
6209 devType = DeviceType_Floppy;
6210 break;
6211 default:
6212 ComAssertFailedRet(DeviceType_Null);
6213 }
6214
6215 return devType;
6216}
6217
6218/**
6219 * Returns the last error message collected by the vdErrorCall callback and
6220 * resets it.
6221 *
6222 * The error message is returned prepended with a dot and a space, like this:
6223 * <code>
6224 * ". <error_text> (%Rrc)"
6225 * </code>
6226 * to make it easily appendable to a more general error message. The @c %Rrc
6227 * format string is given @a aVRC as an argument.
6228 *
6229 * If there is no last error message collected by vdErrorCall or if it is a
6230 * null or empty string, then this function returns the following text:
6231 * <code>
6232 * " (%Rrc)"
6233 * </code>
6234 *
6235 * @note Doesn't do any object locking; it is assumed that the caller makes sure
6236 * the callback isn't called by more than one thread at a time.
6237 *
6238 * @param aVRC VBox error code to use when no error message is provided.
6239 */
6240Utf8Str Medium::vdError(int aVRC)
6241{
6242 Utf8Str error;
6243
6244 if (m->vdError.isEmpty())
6245 error = Utf8StrFmt(" (%Rrc)", aVRC);
6246 else
6247 error = Utf8StrFmt(".\n%s", m->vdError.c_str());
6248
6249 m->vdError.setNull();
6250
6251 return error;
6252}
6253
6254/**
6255 * Error message callback.
6256 *
6257 * Puts the reported error message to the m->vdError field.
6258 *
6259 * @note Doesn't do any object locking; it is assumed that the caller makes sure
6260 * the callback isn't called by more than one thread at a time.
6261 *
6262 * @param pvUser The opaque data passed on container creation.
6263 * @param rc The VBox error code.
6264 * @param RT_SRC_POS_DECL Use RT_SRC_POS.
6265 * @param pszFormat Error message format string.
6266 * @param va Error message arguments.
6267 */
6268/*static*/
6269DECLCALLBACK(void) Medium::vdErrorCall(void *pvUser, int rc, RT_SRC_POS_DECL,
6270 const char *pszFormat, va_list va)
6271{
6272 NOREF(pszFile); NOREF(iLine); NOREF(pszFunction); /* RT_SRC_POS_DECL */
6273
6274 Medium *that = static_cast<Medium*>(pvUser);
6275 AssertReturnVoid(that != NULL);
6276
6277 if (that->m->vdError.isEmpty())
6278 that->m->vdError =
6279 Utf8StrFmt("%s (%Rrc)", Utf8Str(pszFormat, va).c_str(), rc);
6280 else
6281 that->m->vdError =
6282 Utf8StrFmt("%s.\n%s (%Rrc)", that->m->vdError.c_str(),
6283 Utf8Str(pszFormat, va).c_str(), rc);
6284}
6285
6286/* static */
6287DECLCALLBACK(bool) Medium::vdConfigAreKeysValid(void *pvUser,
6288 const char * /* pszzValid */)
6289{
6290 Medium *that = static_cast<Medium*>(pvUser);
6291 AssertReturn(that != NULL, false);
6292
6293 /* we always return true since the only keys we have are those found in
6294 * VDBACKENDINFO */
6295 return true;
6296}
6297
6298/* static */
6299DECLCALLBACK(int) Medium::vdConfigQuerySize(void *pvUser,
6300 const char *pszName,
6301 size_t *pcbValue)
6302{
6303 AssertReturn(VALID_PTR(pcbValue), VERR_INVALID_POINTER);
6304
6305 Medium *that = static_cast<Medium*>(pvUser);
6306 AssertReturn(that != NULL, VERR_GENERAL_FAILURE);
6307
6308 settings::StringsMap::const_iterator it = that->m->mapProperties.find(Utf8Str(pszName));
6309 if (it == that->m->mapProperties.end())
6310 return VERR_CFGM_VALUE_NOT_FOUND;
6311
6312 /* we interpret null values as "no value" in Medium */
6313 if (it->second.isEmpty())
6314 return VERR_CFGM_VALUE_NOT_FOUND;
6315
6316 *pcbValue = it->second.length() + 1 /* include terminator */;
6317
6318 return VINF_SUCCESS;
6319}
6320
6321/* static */
6322DECLCALLBACK(int) Medium::vdConfigQuery(void *pvUser,
6323 const char *pszName,
6324 char *pszValue,
6325 size_t cchValue)
6326{
6327 AssertReturn(VALID_PTR(pszValue), VERR_INVALID_POINTER);
6328
6329 Medium *that = static_cast<Medium*>(pvUser);
6330 AssertReturn(that != NULL, VERR_GENERAL_FAILURE);
6331
6332 settings::StringsMap::const_iterator it = that->m->mapProperties.find(Utf8Str(pszName));
6333 if (it == that->m->mapProperties.end())
6334 return VERR_CFGM_VALUE_NOT_FOUND;
6335
6336 /* we interpret null values as "no value" in Medium */
6337 if (it->second.isEmpty())
6338 return VERR_CFGM_VALUE_NOT_FOUND;
6339
6340 const Utf8Str &value = it->second;
6341 if (value.length() >= cchValue)
6342 return VERR_CFGM_NOT_ENOUGH_SPACE;
6343
6344 memcpy(pszValue, value.c_str(), value.length() + 1);
6345
6346 return VINF_SUCCESS;
6347}
6348
6349DECLCALLBACK(int) Medium::vdTcpSocketCreate(uint32_t fFlags, PVDSOCKET pSock)
6350{
6351 PVDSOCKETINT pSocketInt = NULL;
6352
6353 if ((fFlags & VD_INTERFACETCPNET_CONNECT_EXTENDED_SELECT) != 0)
6354 return VERR_NOT_SUPPORTED;
6355
6356 pSocketInt = (PVDSOCKETINT)RTMemAllocZ(sizeof(VDSOCKETINT));
6357 if (!pSocketInt)
6358 return VERR_NO_MEMORY;
6359
6360 pSocketInt->hSocket = NIL_RTSOCKET;
6361 *pSock = pSocketInt;
6362 return VINF_SUCCESS;
6363}
6364
6365DECLCALLBACK(int) Medium::vdTcpSocketDestroy(VDSOCKET Sock)
6366{
6367 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6368
6369 if (pSocketInt->hSocket != NIL_RTSOCKET)
6370 RTTcpClientCloseEx(pSocketInt->hSocket, false /*fGracefulShutdown*/);
6371
6372 RTMemFree(pSocketInt);
6373
6374 return VINF_SUCCESS;
6375}
6376
6377DECLCALLBACK(int) Medium::vdTcpClientConnect(VDSOCKET Sock, const char *pszAddress, uint32_t uPort)
6378{
6379 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6380
6381 return RTTcpClientConnect(pszAddress, uPort, &pSocketInt->hSocket);
6382}
6383
6384DECLCALLBACK(int) Medium::vdTcpClientClose(VDSOCKET Sock)
6385{
6386 int rc = VINF_SUCCESS;
6387 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6388
6389 rc = RTTcpClientCloseEx(pSocketInt->hSocket, false /*fGracefulShutdown*/);
6390 pSocketInt->hSocket = NIL_RTSOCKET;
6391 return rc;
6392}
6393
6394DECLCALLBACK(bool) Medium::vdTcpIsClientConnected(VDSOCKET Sock)
6395{
6396 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6397 return pSocketInt->hSocket != NIL_RTSOCKET;
6398}
6399
6400DECLCALLBACK(int) Medium::vdTcpSelectOne(VDSOCKET Sock, RTMSINTERVAL cMillies)
6401{
6402 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6403 return RTTcpSelectOne(pSocketInt->hSocket, cMillies);
6404}
6405
6406DECLCALLBACK(int) Medium::vdTcpRead(VDSOCKET Sock, void *pvBuffer, size_t cbBuffer, size_t *pcbRead)
6407{
6408 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6409 return RTTcpRead(pSocketInt->hSocket, pvBuffer, cbBuffer, pcbRead);
6410}
6411
6412DECLCALLBACK(int) Medium::vdTcpWrite(VDSOCKET Sock, const void *pvBuffer, size_t cbBuffer)
6413{
6414 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6415 return RTTcpWrite(pSocketInt->hSocket, pvBuffer, cbBuffer);
6416}
6417
6418DECLCALLBACK(int) Medium::vdTcpSgWrite(VDSOCKET Sock, PCRTSGBUF pSgBuf)
6419{
6420 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6421 return RTTcpSgWrite(pSocketInt->hSocket, pSgBuf);
6422}
6423
6424DECLCALLBACK(int) Medium::vdTcpFlush(VDSOCKET Sock)
6425{
6426 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6427 return RTTcpFlush(pSocketInt->hSocket);
6428}
6429
6430DECLCALLBACK(int) Medium::vdTcpSetSendCoalescing(VDSOCKET Sock, bool fEnable)
6431{
6432 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6433 return RTTcpSetSendCoalescing(pSocketInt->hSocket, fEnable);
6434}
6435
6436DECLCALLBACK(int) Medium::vdTcpGetLocalAddress(VDSOCKET Sock, PRTNETADDR pAddr)
6437{
6438 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6439 return RTTcpGetLocalAddress(pSocketInt->hSocket, pAddr);
6440}
6441
6442DECLCALLBACK(int) Medium::vdTcpGetPeerAddress(VDSOCKET Sock, PRTNETADDR pAddr)
6443{
6444 PVDSOCKETINT pSocketInt = (PVDSOCKETINT)Sock;
6445 return RTTcpGetPeerAddress(pSocketInt->hSocket, pAddr);
6446}
6447
6448/**
6449 * Starts a new thread driven by the appropriate Medium::Task::handler() method.
6450 *
6451 * @note When the task is executed by this method, IProgress::notifyComplete()
6452 * is automatically called for the progress object associated with this
6453 * task when the task is finished to signal the operation completion for
6454 * other threads asynchronously waiting for it.
6455 */
6456HRESULT Medium::startThread(Medium::Task *pTask)
6457{
6458#ifdef VBOX_WITH_MAIN_LOCK_VALIDATION
6459 /* Extreme paranoia: The calling thread should not hold the medium
6460 * tree lock or any medium lock. Since there is no separate lock class
6461 * for medium objects be even more strict: no other object locks. */
6462 Assert(!AutoLockHoldsLocksInClass(LOCKCLASS_LISTOFMEDIA));
6463 Assert(!AutoLockHoldsLocksInClass(getLockingClass()));
6464#endif
6465
6466 /// @todo use a more descriptive task name
6467 int vrc = RTThreadCreate(NULL, Medium::Task::fntMediumTask, pTask,
6468 0, RTTHREADTYPE_MAIN_HEAVY_WORKER, 0,
6469 "Medium::Task");
6470 if (RT_FAILURE(vrc))
6471 {
6472 delete pTask;
6473 return setError(E_FAIL, "Could not create Medium::Task thread (%Rrc)\n", vrc);
6474 }
6475
6476 return S_OK;
6477}
6478
6479/**
6480 * Runs Medium::Task::handler() on the current thread instead of creating
6481 * a new one.
6482 *
6483 * This call implies that it is made on another temporary thread created for
6484 * some asynchronous task. Avoid calling it from a normal thread since the task
6485 * operations are potentially lengthy and will block the calling thread in this
6486 * case.
6487 *
6488 * @note When the task is executed by this method, IProgress::notifyComplete()
6489 * is not called for the progress object associated with this task when
6490 * the task is finished. Instead, the result of the operation is returned
6491 * by this method directly and it's the caller's responsibility to
6492 * complete the progress object in this case.
6493 */
6494HRESULT Medium::runNow(Medium::Task *pTask)
6495{
6496#ifdef VBOX_WITH_MAIN_LOCK_VALIDATION
6497 /* Extreme paranoia: The calling thread should not hold the medium
6498 * tree lock or any medium lock. Since there is no separate lock class
6499 * for medium objects be even more strict: no other object locks. */
6500 Assert(!AutoLockHoldsLocksInClass(LOCKCLASS_LISTOFMEDIA));
6501 Assert(!AutoLockHoldsLocksInClass(getLockingClass()));
6502#endif
6503
6504 /* NIL_RTTHREAD indicates synchronous call. */
6505 return (HRESULT)Medium::Task::fntMediumTask(NIL_RTTHREAD, pTask);
6506}
6507
6508/**
6509 * Implementation code for the "create base" task.
6510 *
6511 * This only gets started from Medium::CreateBaseStorage() and always runs
6512 * asynchronously. As a result, we always save the VirtualBox.xml file when
6513 * we're done here.
6514 *
6515 * @param task
6516 * @return
6517 */
6518HRESULT Medium::taskCreateBaseHandler(Medium::CreateBaseTask &task)
6519{
6520 HRESULT rc = S_OK;
6521
6522 /* these parameters we need after creation */
6523 uint64_t size = 0, logicalSize = 0;
6524 MediumVariant_T variant = MediumVariant_Standard;
6525 bool fGenerateUuid = false;
6526
6527 try
6528 {
6529 AutoWriteLock thisLock(this COMMA_LOCKVAL_SRC_POS);
6530
6531 /* The object may request a specific UUID (through a special form of
6532 * the setLocation() argument). Otherwise we have to generate it */
6533 Guid id = m->id;
6534 fGenerateUuid = id.isEmpty();
6535 if (fGenerateUuid)
6536 {
6537 id.create();
6538 /* VirtualBox::registerMedium() will need UUID */
6539 unconst(m->id) = id;
6540 }
6541
6542 Utf8Str format(m->strFormat);
6543 Utf8Str location(m->strLocationFull);
6544 uint64_t capabilities = m->formatObj->getCapabilities();
6545 ComAssertThrow(capabilities & ( MediumFormatCapabilities_CreateFixed
6546 | MediumFormatCapabilities_CreateDynamic), E_FAIL);
6547 Assert(m->state == MediumState_Creating);
6548
6549 PVBOXHDD hdd;
6550 int vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
6551 ComAssertRCThrow(vrc, E_FAIL);
6552
6553 /* unlock before the potentially lengthy operation */
6554 thisLock.release();
6555
6556 try
6557 {
6558 /* ensure the directory exists */
6559 if (capabilities & MediumFormatCapabilities_File)
6560 {
6561 rc = VirtualBox::ensureFilePathExists(location, !(task.mVariant & MediumVariant_NoCreateDir) /* fCreate */);
6562 if (FAILED(rc))
6563 throw rc;
6564 }
6565
6566 VDGEOMETRY geo = { 0, 0, 0 }; /* auto-detect */
6567
6568 vrc = VDCreateBase(hdd,
6569 format.c_str(),
6570 location.c_str(),
6571 task.mSize,
6572 task.mVariant & ~MediumVariant_NoCreateDir,
6573 NULL,
6574 &geo,
6575 &geo,
6576 id.raw(),
6577 VD_OPEN_FLAGS_NORMAL | m->uOpenFlagsDef,
6578 m->vdImageIfaces,
6579 task.mVDOperationIfaces);
6580 if (RT_FAILURE(vrc))
6581 throw setError(VBOX_E_FILE_ERROR,
6582 tr("Could not create the medium storage unit '%s'%s"),
6583 location.c_str(), vdError(vrc).c_str());
6584
6585 size = VDGetFileSize(hdd, 0);
6586 logicalSize = VDGetSize(hdd, 0);
6587 unsigned uImageFlags;
6588 vrc = VDGetImageFlags(hdd, 0, &uImageFlags);
6589 if (RT_SUCCESS(vrc))
6590 variant = (MediumVariant_T)uImageFlags;
6591 }
6592 catch (HRESULT aRC) { rc = aRC; }
6593
6594 VDDestroy(hdd);
6595 }
6596 catch (HRESULT aRC) { rc = aRC; }
6597
6598 if (SUCCEEDED(rc))
6599 {
6600 /* register with mVirtualBox as the last step and move to
6601 * Created state only on success (leaving an orphan file is
6602 * better than breaking media registry consistency) */
6603 AutoWriteLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
6604 ComObjPtr<Medium> pMedium;
6605 rc = m->pVirtualBox->registerMedium(this, &pMedium, DeviceType_HardDisk);
6606 Assert(this == pMedium);
6607 }
6608
6609 // re-acquire the lock before changing state
6610 AutoWriteLock thisLock(this COMMA_LOCKVAL_SRC_POS);
6611
6612 if (SUCCEEDED(rc))
6613 {
6614 m->state = MediumState_Created;
6615
6616 m->size = size;
6617 m->logicalSize = logicalSize;
6618 m->variant = variant;
6619
6620 thisLock.release();
6621 markRegistriesModified();
6622 if (task.isAsync())
6623 {
6624 // in asynchronous mode, save settings now
6625 m->pVirtualBox->saveModifiedRegistries();
6626 }
6627 }
6628 else
6629 {
6630 /* back to NotCreated on failure */
6631 m->state = MediumState_NotCreated;
6632
6633 /* reset UUID to prevent it from being reused next time */
6634 if (fGenerateUuid)
6635 unconst(m->id).clear();
6636 }
6637
6638 return rc;
6639}
6640
6641/**
6642 * Implementation code for the "create diff" task.
6643 *
6644 * This task always gets started from Medium::createDiffStorage() and can run
6645 * synchronously or asynchronously depending on the "wait" parameter passed to
6646 * that function. If we run synchronously, the caller expects the medium
6647 * registry modification to be set before returning; otherwise (in asynchronous
6648 * mode), we save the settings ourselves.
6649 *
6650 * @param task
6651 * @return
6652 */
6653HRESULT Medium::taskCreateDiffHandler(Medium::CreateDiffTask &task)
6654{
6655 HRESULT rcTmp = S_OK;
6656
6657 const ComObjPtr<Medium> &pTarget = task.mTarget;
6658
6659 uint64_t size = 0, logicalSize = 0;
6660 MediumVariant_T variant = MediumVariant_Standard;
6661 bool fGenerateUuid = false;
6662
6663 try
6664 {
6665 /* Lock both in {parent,child} order. */
6666 AutoMultiWriteLock2 mediaLock(this, pTarget COMMA_LOCKVAL_SRC_POS);
6667
6668 /* The object may request a specific UUID (through a special form of
6669 * the setLocation() argument). Otherwise we have to generate it */
6670 Guid targetId = pTarget->m->id;
6671 fGenerateUuid = targetId.isEmpty();
6672 if (fGenerateUuid)
6673 {
6674 targetId.create();
6675 /* VirtualBox::registerMedium() will need UUID */
6676 unconst(pTarget->m->id) = targetId;
6677 }
6678
6679 Guid id = m->id;
6680
6681 Utf8Str targetFormat(pTarget->m->strFormat);
6682 Utf8Str targetLocation(pTarget->m->strLocationFull);
6683 uint64_t capabilities = pTarget->m->formatObj->getCapabilities();
6684 ComAssertThrow(capabilities & MediumFormatCapabilities_CreateDynamic, E_FAIL);
6685
6686 Assert(pTarget->m->state == MediumState_Creating);
6687 Assert(m->state == MediumState_LockedRead);
6688
6689 PVBOXHDD hdd;
6690 int vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
6691 ComAssertRCThrow(vrc, E_FAIL);
6692
6693 /* the two media are now protected by their non-default states;
6694 * unlock the media before the potentially lengthy operation */
6695 mediaLock.release();
6696
6697 try
6698 {
6699 /* Open all media in the target chain but the last. */
6700 MediumLockList::Base::const_iterator targetListBegin =
6701 task.mpMediumLockList->GetBegin();
6702 MediumLockList::Base::const_iterator targetListEnd =
6703 task.mpMediumLockList->GetEnd();
6704 for (MediumLockList::Base::const_iterator it = targetListBegin;
6705 it != targetListEnd;
6706 ++it)
6707 {
6708 const MediumLock &mediumLock = *it;
6709 const ComObjPtr<Medium> &pMedium = mediumLock.GetMedium();
6710
6711 AutoReadLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
6712
6713 /* Skip over the target diff medium */
6714 if (pMedium->m->state == MediumState_Creating)
6715 continue;
6716
6717 /* sanity check */
6718 Assert(pMedium->m->state == MediumState_LockedRead);
6719
6720 /* Open all media in appropriate mode. */
6721 vrc = VDOpen(hdd,
6722 pMedium->m->strFormat.c_str(),
6723 pMedium->m->strLocationFull.c_str(),
6724 VD_OPEN_FLAGS_READONLY | m->uOpenFlagsDef,
6725 pMedium->m->vdImageIfaces);
6726 if (RT_FAILURE(vrc))
6727 throw setError(VBOX_E_FILE_ERROR,
6728 tr("Could not open the medium storage unit '%s'%s"),
6729 pMedium->m->strLocationFull.c_str(),
6730 vdError(vrc).c_str());
6731 }
6732
6733 /* ensure the target directory exists */
6734 if (capabilities & MediumFormatCapabilities_File)
6735 {
6736 HRESULT rc = VirtualBox::ensureFilePathExists(targetLocation, !(task.mVariant & MediumVariant_NoCreateDir) /* fCreate */);
6737 if (FAILED(rc))
6738 throw rc;
6739 }
6740
6741 vrc = VDCreateDiff(hdd,
6742 targetFormat.c_str(),
6743 targetLocation.c_str(),
6744 (task.mVariant & ~MediumVariant_NoCreateDir) | VD_IMAGE_FLAGS_DIFF,
6745 NULL,
6746 targetId.raw(),
6747 id.raw(),
6748 VD_OPEN_FLAGS_NORMAL | m->uOpenFlagsDef,
6749 pTarget->m->vdImageIfaces,
6750 task.mVDOperationIfaces);
6751 if (RT_FAILURE(vrc))
6752 throw setError(VBOX_E_FILE_ERROR,
6753 tr("Could not create the differencing medium storage unit '%s'%s"),
6754 targetLocation.c_str(), vdError(vrc).c_str());
6755
6756 size = VDGetFileSize(hdd, VD_LAST_IMAGE);
6757 logicalSize = VDGetSize(hdd, VD_LAST_IMAGE);
6758 unsigned uImageFlags;
6759 vrc = VDGetImageFlags(hdd, 0, &uImageFlags);
6760 if (RT_SUCCESS(vrc))
6761 variant = (MediumVariant_T)uImageFlags;
6762 }
6763 catch (HRESULT aRC) { rcTmp = aRC; }
6764
6765 VDDestroy(hdd);
6766 }
6767 catch (HRESULT aRC) { rcTmp = aRC; }
6768
6769 MultiResult mrc(rcTmp);
6770
6771 if (SUCCEEDED(mrc))
6772 {
6773 AutoWriteLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
6774
6775 Assert(pTarget->m->pParent.isNull());
6776
6777 /* associate the child with the parent */
6778 pTarget->m->pParent = this;
6779 m->llChildren.push_back(pTarget);
6780
6781 /** @todo r=klaus neither target nor base() are locked,
6782 * potential race! */
6783 /* diffs for immutable media are auto-reset by default */
6784 pTarget->m->autoReset = (getBase()->m->type == MediumType_Immutable);
6785
6786 /* register with mVirtualBox as the last step and move to
6787 * Created state only on success (leaving an orphan file is
6788 * better than breaking media registry consistency) */
6789 ComObjPtr<Medium> pMedium;
6790 mrc = m->pVirtualBox->registerMedium(pTarget, &pMedium, DeviceType_HardDisk);
6791 Assert(pTarget == pMedium);
6792
6793 if (FAILED(mrc))
6794 /* break the parent association on failure to register */
6795 deparent();
6796 }
6797
6798 AutoMultiWriteLock2 mediaLock(this, pTarget COMMA_LOCKVAL_SRC_POS);
6799
6800 if (SUCCEEDED(mrc))
6801 {
6802 pTarget->m->state = MediumState_Created;
6803
6804 pTarget->m->size = size;
6805 pTarget->m->logicalSize = logicalSize;
6806 pTarget->m->variant = variant;
6807 }
6808 else
6809 {
6810 /* back to NotCreated on failure */
6811 pTarget->m->state = MediumState_NotCreated;
6812
6813 pTarget->m->autoReset = false;
6814
6815 /* reset UUID to prevent it from being reused next time */
6816 if (fGenerateUuid)
6817 unconst(pTarget->m->id).clear();
6818 }
6819
6820 // deregister the task registered in createDiffStorage()
6821 Assert(m->numCreateDiffTasks != 0);
6822 --m->numCreateDiffTasks;
6823
6824 mediaLock.release();
6825 markRegistriesModified();
6826 if (task.isAsync())
6827 {
6828 // in asynchronous mode, save settings now
6829 m->pVirtualBox->saveModifiedRegistries();
6830 }
6831
6832 /* Note that in sync mode, it's the caller's responsibility to
6833 * unlock the medium. */
6834
6835 return mrc;
6836}
6837
6838/**
6839 * Implementation code for the "merge" task.
6840 *
6841 * This task always gets started from Medium::mergeTo() and can run
6842 * synchronously or asynchronously depending on the "wait" parameter passed to
6843 * that function. If we run synchronously, the caller expects the medium
6844 * registry modification to be set before returning; otherwise (in asynchronous
6845 * mode), we save the settings ourselves.
6846 *
6847 * @param task
6848 * @return
6849 */
6850HRESULT Medium::taskMergeHandler(Medium::MergeTask &task)
6851{
6852 HRESULT rcTmp = S_OK;
6853
6854 const ComObjPtr<Medium> &pTarget = task.mTarget;
6855
6856 try
6857 {
6858 PVBOXHDD hdd;
6859 int vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
6860 ComAssertRCThrow(vrc, E_FAIL);
6861
6862 try
6863 {
6864 // Similar code appears in SessionMachine::onlineMergeMedium, so
6865 // if you make any changes below check whether they are applicable
6866 // in that context as well.
6867
6868 unsigned uTargetIdx = VD_LAST_IMAGE;
6869 unsigned uSourceIdx = VD_LAST_IMAGE;
6870 /* Open all media in the chain. */
6871 MediumLockList::Base::iterator lockListBegin =
6872 task.mpMediumLockList->GetBegin();
6873 MediumLockList::Base::iterator lockListEnd =
6874 task.mpMediumLockList->GetEnd();
6875 unsigned i = 0;
6876 for (MediumLockList::Base::iterator it = lockListBegin;
6877 it != lockListEnd;
6878 ++it)
6879 {
6880 MediumLock &mediumLock = *it;
6881 const ComObjPtr<Medium> &pMedium = mediumLock.GetMedium();
6882
6883 if (pMedium == this)
6884 uSourceIdx = i;
6885 else if (pMedium == pTarget)
6886 uTargetIdx = i;
6887
6888 AutoReadLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
6889
6890 /*
6891 * complex sanity (sane complexity)
6892 *
6893 * The current medium must be in the Deleting (medium is merged)
6894 * or LockedRead (parent medium) state if it is not the target.
6895 * If it is the target it must be in the LockedWrite state.
6896 */
6897 Assert( ( pMedium != pTarget
6898 && ( pMedium->m->state == MediumState_Deleting
6899 || pMedium->m->state == MediumState_LockedRead))
6900 || ( pMedium == pTarget
6901 && pMedium->m->state == MediumState_LockedWrite));
6902
6903 /*
6904 * Medium must be the target, in the LockedRead state
6905 * or Deleting state where it is not allowed to be attached
6906 * to a virtual machine.
6907 */
6908 Assert( pMedium == pTarget
6909 || pMedium->m->state == MediumState_LockedRead
6910 || ( pMedium->m->backRefs.size() == 0
6911 && pMedium->m->state == MediumState_Deleting));
6912 /* The source medium must be in Deleting state. */
6913 Assert( pMedium != this
6914 || pMedium->m->state == MediumState_Deleting);
6915
6916 unsigned uOpenFlags = VD_OPEN_FLAGS_NORMAL;
6917
6918 if ( pMedium->m->state == MediumState_LockedRead
6919 || pMedium->m->state == MediumState_Deleting)
6920 uOpenFlags = VD_OPEN_FLAGS_READONLY;
6921 if (pMedium->m->type == MediumType_Shareable)
6922 uOpenFlags |= VD_OPEN_FLAGS_SHAREABLE;
6923
6924 /* Open the medium */
6925 vrc = VDOpen(hdd,
6926 pMedium->m->strFormat.c_str(),
6927 pMedium->m->strLocationFull.c_str(),
6928 uOpenFlags | m->uOpenFlagsDef,
6929 pMedium->m->vdImageIfaces);
6930 if (RT_FAILURE(vrc))
6931 throw vrc;
6932
6933 i++;
6934 }
6935
6936 ComAssertThrow( uSourceIdx != VD_LAST_IMAGE
6937 && uTargetIdx != VD_LAST_IMAGE, E_FAIL);
6938
6939 vrc = VDMerge(hdd, uSourceIdx, uTargetIdx,
6940 task.mVDOperationIfaces);
6941 if (RT_FAILURE(vrc))
6942 throw vrc;
6943
6944 /* update parent UUIDs */
6945 if (!task.mfMergeForward)
6946 {
6947 /* we need to update UUIDs of all source's children
6948 * which cannot be part of the container at once so
6949 * add each one in there individually */
6950 if (task.mChildrenToReparent.size() > 0)
6951 {
6952 for (MediaList::const_iterator it = task.mChildrenToReparent.begin();
6953 it != task.mChildrenToReparent.end();
6954 ++it)
6955 {
6956 /* VD_OPEN_FLAGS_INFO since UUID is wrong yet */
6957 vrc = VDOpen(hdd,
6958 (*it)->m->strFormat.c_str(),
6959 (*it)->m->strLocationFull.c_str(),
6960 VD_OPEN_FLAGS_INFO | m->uOpenFlagsDef,
6961 (*it)->m->vdImageIfaces);
6962 if (RT_FAILURE(vrc))
6963 throw vrc;
6964
6965 vrc = VDSetParentUuid(hdd, VD_LAST_IMAGE,
6966 pTarget->m->id.raw());
6967 if (RT_FAILURE(vrc))
6968 throw vrc;
6969
6970 vrc = VDClose(hdd, false /* fDelete */);
6971 if (RT_FAILURE(vrc))
6972 throw vrc;
6973
6974 (*it)->UnlockWrite(NULL);
6975 }
6976 }
6977 }
6978 }
6979 catch (HRESULT aRC) { rcTmp = aRC; }
6980 catch (int aVRC)
6981 {
6982 rcTmp = setError(VBOX_E_FILE_ERROR,
6983 tr("Could not merge the medium '%s' to '%s'%s"),
6984 m->strLocationFull.c_str(),
6985 pTarget->m->strLocationFull.c_str(),
6986 vdError(aVRC).c_str());
6987 }
6988
6989 VDDestroy(hdd);
6990 }
6991 catch (HRESULT aRC) { rcTmp = aRC; }
6992
6993 ErrorInfoKeeper eik;
6994 MultiResult mrc(rcTmp);
6995 HRESULT rc2;
6996
6997 if (SUCCEEDED(mrc))
6998 {
6999 /* all media but the target were successfully deleted by
7000 * VDMerge; reparent the last one and uninitialize deleted media. */
7001
7002 AutoWriteLock treeLock(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
7003
7004 if (task.mfMergeForward)
7005 {
7006 /* first, unregister the target since it may become a base
7007 * medium which needs re-registration */
7008 rc2 = m->pVirtualBox->unregisterMedium(pTarget);
7009 AssertComRC(rc2);
7010
7011 /* then, reparent it and disconnect the deleted branch at
7012 * both ends (chain->parent() is source's parent) */
7013 pTarget->deparent();
7014 pTarget->m->pParent = task.mParentForTarget;
7015 if (pTarget->m->pParent)
7016 {
7017 pTarget->m->pParent->m->llChildren.push_back(pTarget);
7018 deparent();
7019 }
7020
7021 /* then, register again */
7022 ComObjPtr<Medium> pMedium;
7023 rc2 = m->pVirtualBox->registerMedium(pTarget, &pMedium,
7024 DeviceType_HardDisk);
7025 AssertComRC(rc2);
7026 }
7027 else
7028 {
7029 Assert(pTarget->getChildren().size() == 1);
7030 Medium *targetChild = pTarget->getChildren().front();
7031
7032 /* disconnect the deleted branch at the elder end */
7033 targetChild->deparent();
7034
7035 /* reparent source's children and disconnect the deleted
7036 * branch at the younger end */
7037 if (task.mChildrenToReparent.size() > 0)
7038 {
7039 /* obey {parent,child} lock order */
7040 AutoWriteLock sourceLock(this COMMA_LOCKVAL_SRC_POS);
7041
7042 for (MediaList::const_iterator it = task.mChildrenToReparent.begin();
7043 it != task.mChildrenToReparent.end();
7044 it++)
7045 {
7046 Medium *pMedium = *it;
7047 AutoWriteLock childLock(pMedium COMMA_LOCKVAL_SRC_POS);
7048
7049 pMedium->deparent(); // removes pMedium from source
7050 pMedium->setParent(pTarget);
7051 }
7052 }
7053 }
7054
7055 /* unregister and uninitialize all media removed by the merge */
7056 MediumLockList::Base::iterator lockListBegin =
7057 task.mpMediumLockList->GetBegin();
7058 MediumLockList::Base::iterator lockListEnd =
7059 task.mpMediumLockList->GetEnd();
7060 for (MediumLockList::Base::iterator it = lockListBegin;
7061 it != lockListEnd;
7062 )
7063 {
7064 MediumLock &mediumLock = *it;
7065 /* Create a real copy of the medium pointer, as the medium
7066 * lock deletion below would invalidate the referenced object. */
7067 const ComObjPtr<Medium> pMedium = mediumLock.GetMedium();
7068
7069 /* The target and all media not merged (readonly) are skipped */
7070 if ( pMedium == pTarget
7071 || pMedium->m->state == MediumState_LockedRead)
7072 {
7073 ++it;
7074 continue;
7075 }
7076
7077 rc2 = pMedium->m->pVirtualBox->unregisterMedium(pMedium);
7078 AssertComRC(rc2);
7079
7080 /* now, uninitialize the deleted medium (note that
7081 * due to the Deleting state, uninit() will not touch
7082 * the parent-child relationship so we need to
7083 * uninitialize each disk individually) */
7084
7085 /* note that the operation initiator medium (which is
7086 * normally also the source medium) is a special case
7087 * -- there is one more caller added by Task to it which
7088 * we must release. Also, if we are in sync mode, the
7089 * caller may still hold an AutoCaller instance for it
7090 * and therefore we cannot uninit() it (it's therefore
7091 * the caller's responsibility) */
7092 if (pMedium == this)
7093 {
7094 Assert(getChildren().size() == 0);
7095 Assert(m->backRefs.size() == 0);
7096 task.mMediumCaller.release();
7097 }
7098
7099 /* Delete the medium lock list entry, which also releases the
7100 * caller added by MergeChain before uninit() and updates the
7101 * iterator to point to the right place. */
7102 rc2 = task.mpMediumLockList->RemoveByIterator(it);
7103 AssertComRC(rc2);
7104
7105 if (task.isAsync() || pMedium != this)
7106 pMedium->uninit();
7107 }
7108 }
7109
7110 markRegistriesModified();
7111 if (task.isAsync())
7112 {
7113 // in asynchronous mode, save settings now
7114 eik.restore();
7115 m->pVirtualBox->saveModifiedRegistries();
7116 eik.fetch();
7117 }
7118
7119 if (FAILED(mrc))
7120 {
7121 /* Here we come if either VDMerge() failed (in which case we
7122 * assume that it tried to do everything to make a further
7123 * retry possible -- e.g. not deleted intermediate media
7124 * and so on) or VirtualBox::saveRegistries() failed (where we
7125 * should have the original tree but with intermediate storage
7126 * units deleted by VDMerge()). We have to only restore states
7127 * (through the MergeChain dtor) unless we are run synchronously
7128 * in which case it's the responsibility of the caller as stated
7129 * in the mergeTo() docs. The latter also implies that we
7130 * don't own the merge chain, so release it in this case. */
7131 if (task.isAsync())
7132 {
7133 Assert(task.mChildrenToReparent.size() == 0);
7134 cancelMergeTo(task.mChildrenToReparent, task.mpMediumLockList);
7135 }
7136 }
7137
7138 return mrc;
7139}
7140
7141/**
7142 * Implementation code for the "clone" task.
7143 *
7144 * This only gets started from Medium::CloneTo() and always runs asynchronously.
7145 * As a result, we always save the VirtualBox.xml file when we're done here.
7146 *
7147 * @param task
7148 * @return
7149 */
7150HRESULT Medium::taskCloneHandler(Medium::CloneTask &task)
7151{
7152 HRESULT rcTmp = S_OK;
7153
7154 const ComObjPtr<Medium> &pTarget = task.mTarget;
7155 const ComObjPtr<Medium> &pParent = task.mParent;
7156
7157 bool fCreatingTarget = false;
7158
7159 uint64_t size = 0, logicalSize = 0;
7160 MediumVariant_T variant = MediumVariant_Standard;
7161 bool fGenerateUuid = false;
7162
7163 try
7164 {
7165 /* Lock all in {parent,child} order. The lock is also used as a
7166 * signal from the task initiator (which releases it only after
7167 * RTThreadCreate()) that we can start the job. */
7168 AutoMultiWriteLock3 thisLock(this, pTarget, pParent COMMA_LOCKVAL_SRC_POS);
7169
7170 fCreatingTarget = pTarget->m->state == MediumState_Creating;
7171
7172 /* The object may request a specific UUID (through a special form of
7173 * the setLocation() argument). Otherwise we have to generate it */
7174 Guid targetId = pTarget->m->id;
7175 fGenerateUuid = targetId.isEmpty();
7176 if (fGenerateUuid)
7177 {
7178 targetId.create();
7179 /* VirtualBox::registerMedium() will need UUID */
7180 unconst(pTarget->m->id) = targetId;
7181 }
7182
7183 PVBOXHDD hdd;
7184 int vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
7185 ComAssertRCThrow(vrc, E_FAIL);
7186
7187 try
7188 {
7189 /* Open all media in the source chain. */
7190 MediumLockList::Base::const_iterator sourceListBegin =
7191 task.mpSourceMediumLockList->GetBegin();
7192 MediumLockList::Base::const_iterator sourceListEnd =
7193 task.mpSourceMediumLockList->GetEnd();
7194 for (MediumLockList::Base::const_iterator it = sourceListBegin;
7195 it != sourceListEnd;
7196 ++it)
7197 {
7198 const MediumLock &mediumLock = *it;
7199 const ComObjPtr<Medium> &pMedium = mediumLock.GetMedium();
7200 AutoReadLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
7201
7202 /* sanity check */
7203 Assert(pMedium->m->state == MediumState_LockedRead);
7204
7205 /** Open all media in read-only mode. */
7206 vrc = VDOpen(hdd,
7207 pMedium->m->strFormat.c_str(),
7208 pMedium->m->strLocationFull.c_str(),
7209 VD_OPEN_FLAGS_READONLY | m->uOpenFlagsDef,
7210 pMedium->m->vdImageIfaces);
7211 if (RT_FAILURE(vrc))
7212 throw setError(VBOX_E_FILE_ERROR,
7213 tr("Could not open the medium storage unit '%s'%s"),
7214 pMedium->m->strLocationFull.c_str(),
7215 vdError(vrc).c_str());
7216 }
7217
7218 Utf8Str targetFormat(pTarget->m->strFormat);
7219 Utf8Str targetLocation(pTarget->m->strLocationFull);
7220 uint64_t capabilities = pTarget->m->formatObj->getCapabilities();
7221
7222 Assert( pTarget->m->state == MediumState_Creating
7223 || pTarget->m->state == MediumState_LockedWrite);
7224 Assert(m->state == MediumState_LockedRead);
7225 Assert( pParent.isNull()
7226 || pParent->m->state == MediumState_LockedRead);
7227
7228 /* unlock before the potentially lengthy operation */
7229 thisLock.release();
7230
7231 /* ensure the target directory exists */
7232 if (capabilities & MediumFormatCapabilities_File)
7233 {
7234 HRESULT rc = VirtualBox::ensureFilePathExists(targetLocation, !(task.mVariant & MediumVariant_NoCreateDir) /* fCreate */);
7235 if (FAILED(rc))
7236 throw rc;
7237 }
7238
7239 PVBOXHDD targetHdd;
7240 vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &targetHdd);
7241 ComAssertRCThrow(vrc, E_FAIL);
7242
7243 try
7244 {
7245 /* Open all media in the target chain. */
7246 MediumLockList::Base::const_iterator targetListBegin =
7247 task.mpTargetMediumLockList->GetBegin();
7248 MediumLockList::Base::const_iterator targetListEnd =
7249 task.mpTargetMediumLockList->GetEnd();
7250 for (MediumLockList::Base::const_iterator it = targetListBegin;
7251 it != targetListEnd;
7252 ++it)
7253 {
7254 const MediumLock &mediumLock = *it;
7255 const ComObjPtr<Medium> &pMedium = mediumLock.GetMedium();
7256
7257 /* If the target medium is not created yet there's no
7258 * reason to open it. */
7259 if (pMedium == pTarget && fCreatingTarget)
7260 continue;
7261
7262 AutoReadLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
7263
7264 /* sanity check */
7265 Assert( pMedium->m->state == MediumState_LockedRead
7266 || pMedium->m->state == MediumState_LockedWrite);
7267
7268 unsigned uOpenFlags = VD_OPEN_FLAGS_NORMAL;
7269 if (pMedium->m->state != MediumState_LockedWrite)
7270 uOpenFlags = VD_OPEN_FLAGS_READONLY;
7271 if (pMedium->m->type == MediumType_Shareable)
7272 uOpenFlags |= VD_OPEN_FLAGS_SHAREABLE;
7273
7274 /* Open all media in appropriate mode. */
7275 vrc = VDOpen(targetHdd,
7276 pMedium->m->strFormat.c_str(),
7277 pMedium->m->strLocationFull.c_str(),
7278 uOpenFlags | m->uOpenFlagsDef,
7279 pMedium->m->vdImageIfaces);
7280 if (RT_FAILURE(vrc))
7281 throw setError(VBOX_E_FILE_ERROR,
7282 tr("Could not open the medium storage unit '%s'%s"),
7283 pMedium->m->strLocationFull.c_str(),
7284 vdError(vrc).c_str());
7285 }
7286
7287 /** @todo r=klaus target isn't locked, race getting the state */
7288 if (task.midxSrcImageSame == UINT32_MAX)
7289 {
7290 vrc = VDCopy(hdd,
7291 VD_LAST_IMAGE,
7292 targetHdd,
7293 targetFormat.c_str(),
7294 (fCreatingTarget) ? targetLocation.c_str() : (char *)NULL,
7295 false /* fMoveByRename */,
7296 0 /* cbSize */,
7297 task.mVariant & ~MediumVariant_NoCreateDir,
7298 targetId.raw(),
7299 VD_OPEN_FLAGS_NORMAL | m->uOpenFlagsDef,
7300 NULL /* pVDIfsOperation */,
7301 pTarget->m->vdImageIfaces,
7302 task.mVDOperationIfaces);
7303 }
7304 else
7305 {
7306 vrc = VDCopyEx(hdd,
7307 VD_LAST_IMAGE,
7308 targetHdd,
7309 targetFormat.c_str(),
7310 (fCreatingTarget) ? targetLocation.c_str() : (char *)NULL,
7311 false /* fMoveByRename */,
7312 0 /* cbSize */,
7313 task.midxSrcImageSame,
7314 task.midxDstImageSame,
7315 task.mVariant & ~MediumVariant_NoCreateDir,
7316 targetId.raw(),
7317 VD_OPEN_FLAGS_NORMAL | m->uOpenFlagsDef,
7318 NULL /* pVDIfsOperation */,
7319 pTarget->m->vdImageIfaces,
7320 task.mVDOperationIfaces);
7321 }
7322 if (RT_FAILURE(vrc))
7323 throw setError(VBOX_E_FILE_ERROR,
7324 tr("Could not create the clone medium '%s'%s"),
7325 targetLocation.c_str(), vdError(vrc).c_str());
7326
7327 size = VDGetFileSize(targetHdd, VD_LAST_IMAGE);
7328 logicalSize = VDGetSize(targetHdd, VD_LAST_IMAGE);
7329 unsigned uImageFlags;
7330 vrc = VDGetImageFlags(targetHdd, 0, &uImageFlags);
7331 if (RT_SUCCESS(vrc))
7332 variant = (MediumVariant_T)uImageFlags;
7333 }
7334 catch (HRESULT aRC) { rcTmp = aRC; }
7335
7336 VDDestroy(targetHdd);
7337 }
7338 catch (HRESULT aRC) { rcTmp = aRC; }
7339
7340 VDDestroy(hdd);
7341 }
7342 catch (HRESULT aRC) { rcTmp = aRC; }
7343
7344 ErrorInfoKeeper eik;
7345 MultiResult mrc(rcTmp);
7346
7347 /* Only do the parent changes for newly created media. */
7348 if (SUCCEEDED(mrc) && fCreatingTarget)
7349 {
7350 /* we set mParent & children() */
7351 AutoWriteLock alock2(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
7352
7353 Assert(pTarget->m->pParent.isNull());
7354
7355 if (pParent)
7356 {
7357 /* associate the clone with the parent and deassociate
7358 * from VirtualBox */
7359 pTarget->m->pParent = pParent;
7360 pParent->m->llChildren.push_back(pTarget);
7361
7362 /* register with mVirtualBox as the last step and move to
7363 * Created state only on success (leaving an orphan file is
7364 * better than breaking media registry consistency) */
7365 eik.restore();
7366 ComObjPtr<Medium> pMedium;
7367 mrc = pParent->m->pVirtualBox->registerMedium(pTarget, &pMedium,
7368 DeviceType_HardDisk);
7369 Assert(pTarget == pMedium);
7370 eik.fetch();
7371
7372 if (FAILED(mrc))
7373 /* break parent association on failure to register */
7374 pTarget->deparent(); // removes target from parent
7375 }
7376 else
7377 {
7378 /* just register */
7379 eik.restore();
7380 ComObjPtr<Medium> pMedium;
7381 mrc = m->pVirtualBox->registerMedium(pTarget, &pMedium,
7382 DeviceType_HardDisk);
7383 Assert(pTarget == pMedium);
7384 eik.fetch();
7385 }
7386 }
7387
7388 if (fCreatingTarget)
7389 {
7390 AutoWriteLock mLock(pTarget COMMA_LOCKVAL_SRC_POS);
7391
7392 if (SUCCEEDED(mrc))
7393 {
7394 pTarget->m->state = MediumState_Created;
7395
7396 pTarget->m->size = size;
7397 pTarget->m->logicalSize = logicalSize;
7398 pTarget->m->variant = variant;
7399 }
7400 else
7401 {
7402 /* back to NotCreated on failure */
7403 pTarget->m->state = MediumState_NotCreated;
7404
7405 /* reset UUID to prevent it from being reused next time */
7406 if (fGenerateUuid)
7407 unconst(pTarget->m->id).clear();
7408 }
7409 }
7410
7411 // now, at the end of this task (always asynchronous), save the settings
7412 if (SUCCEEDED(mrc))
7413 {
7414 // save the settings
7415 markRegistriesModified();
7416 /* collect multiple errors */
7417 eik.restore();
7418 m->pVirtualBox->saveModifiedRegistries();
7419 eik.fetch();
7420 }
7421
7422 /* Everything is explicitly unlocked when the task exits,
7423 * as the task destruction also destroys the source chain. */
7424
7425 /* Make sure the source chain is released early. It could happen
7426 * that we get a deadlock in Appliance::Import when Medium::Close
7427 * is called & the source chain is released at the same time. */
7428 task.mpSourceMediumLockList->Clear();
7429
7430 return mrc;
7431}
7432
7433/**
7434 * Implementation code for the "delete" task.
7435 *
7436 * This task always gets started from Medium::deleteStorage() and can run
7437 * synchronously or asynchronously depending on the "wait" parameter passed to
7438 * that function.
7439 *
7440 * @param task
7441 * @return
7442 */
7443HRESULT Medium::taskDeleteHandler(Medium::DeleteTask &task)
7444{
7445 NOREF(task);
7446 HRESULT rc = S_OK;
7447
7448 try
7449 {
7450 /* The lock is also used as a signal from the task initiator (which
7451 * releases it only after RTThreadCreate()) that we can start the job */
7452 AutoWriteLock thisLock(this COMMA_LOCKVAL_SRC_POS);
7453
7454 PVBOXHDD hdd;
7455 int vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
7456 ComAssertRCThrow(vrc, E_FAIL);
7457
7458 Utf8Str format(m->strFormat);
7459 Utf8Str location(m->strLocationFull);
7460
7461 /* unlock before the potentially lengthy operation */
7462 Assert(m->state == MediumState_Deleting);
7463 thisLock.release();
7464
7465 try
7466 {
7467 vrc = VDOpen(hdd,
7468 format.c_str(),
7469 location.c_str(),
7470 VD_OPEN_FLAGS_READONLY | VD_OPEN_FLAGS_INFO | m->uOpenFlagsDef,
7471 m->vdImageIfaces);
7472 if (RT_SUCCESS(vrc))
7473 vrc = VDClose(hdd, true /* fDelete */);
7474
7475 if (RT_FAILURE(vrc))
7476 throw setError(VBOX_E_FILE_ERROR,
7477 tr("Could not delete the medium storage unit '%s'%s"),
7478 location.c_str(), vdError(vrc).c_str());
7479
7480 }
7481 catch (HRESULT aRC) { rc = aRC; }
7482
7483 VDDestroy(hdd);
7484 }
7485 catch (HRESULT aRC) { rc = aRC; }
7486
7487 AutoWriteLock thisLock(this COMMA_LOCKVAL_SRC_POS);
7488
7489 /* go to the NotCreated state even on failure since the storage
7490 * may have been already partially deleted and cannot be used any
7491 * more. One will be able to manually re-open the storage if really
7492 * needed to re-register it. */
7493 m->state = MediumState_NotCreated;
7494
7495 /* Reset UUID to prevent Create* from reusing it again */
7496 unconst(m->id).clear();
7497
7498 return rc;
7499}
7500
7501/**
7502 * Implementation code for the "reset" task.
7503 *
7504 * This always gets started asynchronously from Medium::Reset().
7505 *
7506 * @param task
7507 * @return
7508 */
7509HRESULT Medium::taskResetHandler(Medium::ResetTask &task)
7510{
7511 HRESULT rc = S_OK;
7512
7513 uint64_t size = 0, logicalSize = 0;
7514 MediumVariant_T variant = MediumVariant_Standard;
7515
7516 try
7517 {
7518 /* The lock is also used as a signal from the task initiator (which
7519 * releases it only after RTThreadCreate()) that we can start the job */
7520 AutoWriteLock thisLock(this COMMA_LOCKVAL_SRC_POS);
7521
7522 /// @todo Below we use a pair of delete/create operations to reset
7523 /// the diff contents but the most efficient way will of course be
7524 /// to add a VDResetDiff() API call
7525
7526 PVBOXHDD hdd;
7527 int vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
7528 ComAssertRCThrow(vrc, E_FAIL);
7529
7530 Guid id = m->id;
7531 Utf8Str format(m->strFormat);
7532 Utf8Str location(m->strLocationFull);
7533
7534 Medium *pParent = m->pParent;
7535 Guid parentId = pParent->m->id;
7536 Utf8Str parentFormat(pParent->m->strFormat);
7537 Utf8Str parentLocation(pParent->m->strLocationFull);
7538
7539 Assert(m->state == MediumState_LockedWrite);
7540
7541 /* unlock before the potentially lengthy operation */
7542 thisLock.release();
7543
7544 try
7545 {
7546 /* Open all media in the target chain but the last. */
7547 MediumLockList::Base::const_iterator targetListBegin =
7548 task.mpMediumLockList->GetBegin();
7549 MediumLockList::Base::const_iterator targetListEnd =
7550 task.mpMediumLockList->GetEnd();
7551 for (MediumLockList::Base::const_iterator it = targetListBegin;
7552 it != targetListEnd;
7553 ++it)
7554 {
7555 const MediumLock &mediumLock = *it;
7556 const ComObjPtr<Medium> &pMedium = mediumLock.GetMedium();
7557
7558 AutoReadLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
7559
7560 /* sanity check, "this" is checked above */
7561 Assert( pMedium == this
7562 || pMedium->m->state == MediumState_LockedRead);
7563
7564 /* Open all media in appropriate mode. */
7565 vrc = VDOpen(hdd,
7566 pMedium->m->strFormat.c_str(),
7567 pMedium->m->strLocationFull.c_str(),
7568 VD_OPEN_FLAGS_READONLY | m->uOpenFlagsDef,
7569 pMedium->m->vdImageIfaces);
7570 if (RT_FAILURE(vrc))
7571 throw setError(VBOX_E_FILE_ERROR,
7572 tr("Could not open the medium storage unit '%s'%s"),
7573 pMedium->m->strLocationFull.c_str(),
7574 vdError(vrc).c_str());
7575
7576 /* Done when we hit the media which should be reset */
7577 if (pMedium == this)
7578 break;
7579 }
7580
7581 /* first, delete the storage unit */
7582 vrc = VDClose(hdd, true /* fDelete */);
7583 if (RT_FAILURE(vrc))
7584 throw setError(VBOX_E_FILE_ERROR,
7585 tr("Could not delete the medium storage unit '%s'%s"),
7586 location.c_str(), vdError(vrc).c_str());
7587
7588 /* next, create it again */
7589 vrc = VDOpen(hdd,
7590 parentFormat.c_str(),
7591 parentLocation.c_str(),
7592 VD_OPEN_FLAGS_READONLY | VD_OPEN_FLAGS_INFO | m->uOpenFlagsDef,
7593 m->vdImageIfaces);
7594 if (RT_FAILURE(vrc))
7595 throw setError(VBOX_E_FILE_ERROR,
7596 tr("Could not open the medium storage unit '%s'%s"),
7597 parentLocation.c_str(), vdError(vrc).c_str());
7598
7599 vrc = VDCreateDiff(hdd,
7600 format.c_str(),
7601 location.c_str(),
7602 /// @todo use the same medium variant as before
7603 VD_IMAGE_FLAGS_NONE,
7604 NULL,
7605 id.raw(),
7606 parentId.raw(),
7607 VD_OPEN_FLAGS_NORMAL,
7608 m->vdImageIfaces,
7609 task.mVDOperationIfaces);
7610 if (RT_FAILURE(vrc))
7611 throw setError(VBOX_E_FILE_ERROR,
7612 tr("Could not create the differencing medium storage unit '%s'%s"),
7613 location.c_str(), vdError(vrc).c_str());
7614
7615 size = VDGetFileSize(hdd, VD_LAST_IMAGE);
7616 logicalSize = VDGetSize(hdd, VD_LAST_IMAGE);
7617 unsigned uImageFlags;
7618 vrc = VDGetImageFlags(hdd, 0, &uImageFlags);
7619 if (RT_SUCCESS(vrc))
7620 variant = (MediumVariant_T)uImageFlags;
7621 }
7622 catch (HRESULT aRC) { rc = aRC; }
7623
7624 VDDestroy(hdd);
7625 }
7626 catch (HRESULT aRC) { rc = aRC; }
7627
7628 AutoWriteLock thisLock(this COMMA_LOCKVAL_SRC_POS);
7629
7630 m->size = size;
7631 m->logicalSize = logicalSize;
7632 m->variant = variant;
7633
7634 if (task.isAsync())
7635 {
7636 /* unlock ourselves when done */
7637 HRESULT rc2 = UnlockWrite(NULL);
7638 AssertComRC(rc2);
7639 }
7640
7641 /* Note that in sync mode, it's the caller's responsibility to
7642 * unlock the medium. */
7643
7644 return rc;
7645}
7646
7647/**
7648 * Implementation code for the "compact" task.
7649 *
7650 * @param task
7651 * @return
7652 */
7653HRESULT Medium::taskCompactHandler(Medium::CompactTask &task)
7654{
7655 HRESULT rc = S_OK;
7656
7657 /* Lock all in {parent,child} order. The lock is also used as a
7658 * signal from the task initiator (which releases it only after
7659 * RTThreadCreate()) that we can start the job. */
7660 AutoWriteLock thisLock(this COMMA_LOCKVAL_SRC_POS);
7661
7662 try
7663 {
7664 PVBOXHDD hdd;
7665 int vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
7666 ComAssertRCThrow(vrc, E_FAIL);
7667
7668 try
7669 {
7670 /* Open all media in the chain. */
7671 MediumLockList::Base::const_iterator mediumListBegin =
7672 task.mpMediumLockList->GetBegin();
7673 MediumLockList::Base::const_iterator mediumListEnd =
7674 task.mpMediumLockList->GetEnd();
7675 MediumLockList::Base::const_iterator mediumListLast =
7676 mediumListEnd;
7677 mediumListLast--;
7678 for (MediumLockList::Base::const_iterator it = mediumListBegin;
7679 it != mediumListEnd;
7680 ++it)
7681 {
7682 const MediumLock &mediumLock = *it;
7683 const ComObjPtr<Medium> &pMedium = mediumLock.GetMedium();
7684 AutoReadLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
7685
7686 /* sanity check */
7687 if (it == mediumListLast)
7688 Assert(pMedium->m->state == MediumState_LockedWrite);
7689 else
7690 Assert(pMedium->m->state == MediumState_LockedRead);
7691
7692 /* Open all media but last in read-only mode. Do not handle
7693 * shareable media, as compaction and sharing are mutually
7694 * exclusive. */
7695 vrc = VDOpen(hdd,
7696 pMedium->m->strFormat.c_str(),
7697 pMedium->m->strLocationFull.c_str(),
7698 m->uOpenFlagsDef | (it == mediumListLast) ? VD_OPEN_FLAGS_NORMAL : VD_OPEN_FLAGS_READONLY,
7699 pMedium->m->vdImageIfaces);
7700 if (RT_FAILURE(vrc))
7701 throw setError(VBOX_E_FILE_ERROR,
7702 tr("Could not open the medium storage unit '%s'%s"),
7703 pMedium->m->strLocationFull.c_str(),
7704 vdError(vrc).c_str());
7705 }
7706
7707 Assert(m->state == MediumState_LockedWrite);
7708
7709 Utf8Str location(m->strLocationFull);
7710
7711 /* unlock before the potentially lengthy operation */
7712 thisLock.release();
7713
7714 vrc = VDCompact(hdd, VD_LAST_IMAGE, task.mVDOperationIfaces);
7715 if (RT_FAILURE(vrc))
7716 {
7717 if (vrc == VERR_NOT_SUPPORTED)
7718 throw setError(VBOX_E_NOT_SUPPORTED,
7719 tr("Compacting is not yet supported for medium '%s'"),
7720 location.c_str());
7721 else if (vrc == VERR_NOT_IMPLEMENTED)
7722 throw setError(E_NOTIMPL,
7723 tr("Compacting is not implemented, medium '%s'"),
7724 location.c_str());
7725 else
7726 throw setError(VBOX_E_FILE_ERROR,
7727 tr("Could not compact medium '%s'%s"),
7728 location.c_str(),
7729 vdError(vrc).c_str());
7730 }
7731 }
7732 catch (HRESULT aRC) { rc = aRC; }
7733
7734 VDDestroy(hdd);
7735 }
7736 catch (HRESULT aRC) { rc = aRC; }
7737
7738 /* Everything is explicitly unlocked when the task exits,
7739 * as the task destruction also destroys the media chain. */
7740
7741 return rc;
7742}
7743
7744/**
7745 * Implementation code for the "resize" task.
7746 *
7747 * @param task
7748 * @return
7749 */
7750HRESULT Medium::taskResizeHandler(Medium::ResizeTask &task)
7751{
7752 HRESULT rc = S_OK;
7753
7754 /* Lock all in {parent,child} order. The lock is also used as a
7755 * signal from the task initiator (which releases it only after
7756 * RTThreadCreate()) that we can start the job. */
7757 AutoWriteLock thisLock(this COMMA_LOCKVAL_SRC_POS);
7758
7759 try
7760 {
7761 PVBOXHDD hdd;
7762 int vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
7763 ComAssertRCThrow(vrc, E_FAIL);
7764
7765 try
7766 {
7767 /* Open all media in the chain. */
7768 MediumLockList::Base::const_iterator mediumListBegin =
7769 task.mpMediumLockList->GetBegin();
7770 MediumLockList::Base::const_iterator mediumListEnd =
7771 task.mpMediumLockList->GetEnd();
7772 MediumLockList::Base::const_iterator mediumListLast =
7773 mediumListEnd;
7774 mediumListLast--;
7775 for (MediumLockList::Base::const_iterator it = mediumListBegin;
7776 it != mediumListEnd;
7777 ++it)
7778 {
7779 const MediumLock &mediumLock = *it;
7780 const ComObjPtr<Medium> &pMedium = mediumLock.GetMedium();
7781 AutoReadLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
7782
7783 /* sanity check */
7784 if (it == mediumListLast)
7785 Assert(pMedium->m->state == MediumState_LockedWrite);
7786 else
7787 Assert(pMedium->m->state == MediumState_LockedRead);
7788
7789 /* Open all media but last in read-only mode. Do not handle
7790 * shareable media, as compaction and sharing are mutually
7791 * exclusive. */
7792 vrc = VDOpen(hdd,
7793 pMedium->m->strFormat.c_str(),
7794 pMedium->m->strLocationFull.c_str(),
7795 m->uOpenFlagsDef | (it == mediumListLast) ? VD_OPEN_FLAGS_NORMAL : VD_OPEN_FLAGS_READONLY,
7796 pMedium->m->vdImageIfaces);
7797 if (RT_FAILURE(vrc))
7798 throw setError(VBOX_E_FILE_ERROR,
7799 tr("Could not open the medium storage unit '%s'%s"),
7800 pMedium->m->strLocationFull.c_str(),
7801 vdError(vrc).c_str());
7802 }
7803
7804 Assert(m->state == MediumState_LockedWrite);
7805
7806 Utf8Str location(m->strLocationFull);
7807
7808 /* unlock before the potentially lengthy operation */
7809 thisLock.release();
7810
7811 VDGEOMETRY geo = {0, 0, 0}; /* auto */
7812 vrc = VDResize(hdd, task.mSize, &geo, &geo, task.mVDOperationIfaces);
7813 if (RT_FAILURE(vrc))
7814 {
7815 if (vrc == VERR_NOT_SUPPORTED)
7816 throw setError(VBOX_E_NOT_SUPPORTED,
7817 tr("Compacting is not yet supported for medium '%s'"),
7818 location.c_str());
7819 else if (vrc == VERR_NOT_IMPLEMENTED)
7820 throw setError(E_NOTIMPL,
7821 tr("Compacting is not implemented, medium '%s'"),
7822 location.c_str());
7823 else
7824 throw setError(VBOX_E_FILE_ERROR,
7825 tr("Could not compact medium '%s'%s"),
7826 location.c_str(),
7827 vdError(vrc).c_str());
7828 }
7829 }
7830 catch (HRESULT aRC) { rc = aRC; }
7831
7832 VDDestroy(hdd);
7833 }
7834 catch (HRESULT aRC) { rc = aRC; }
7835
7836 /* Everything is explicitly unlocked when the task exits,
7837 * as the task destruction also destroys the media chain. */
7838
7839 return rc;
7840}
7841
7842/**
7843 * Implementation code for the "export" task.
7844 *
7845 * This only gets started from Medium::exportFile() and always runs
7846 * asynchronously. It doesn't touch anything configuration related, so
7847 * we never save the VirtualBox.xml file here.
7848 *
7849 * @param task
7850 * @return
7851 */
7852HRESULT Medium::taskExportHandler(Medium::ExportTask &task)
7853{
7854 HRESULT rc = S_OK;
7855
7856 try
7857 {
7858 /* Lock all in {parent,child} order. The lock is also used as a
7859 * signal from the task initiator (which releases it only after
7860 * RTThreadCreate()) that we can start the job. */
7861 AutoWriteLock thisLock(this COMMA_LOCKVAL_SRC_POS);
7862
7863 PVBOXHDD hdd;
7864 int vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
7865 ComAssertRCThrow(vrc, E_FAIL);
7866
7867 try
7868 {
7869 /* Open all media in the source chain. */
7870 MediumLockList::Base::const_iterator sourceListBegin =
7871 task.mpSourceMediumLockList->GetBegin();
7872 MediumLockList::Base::const_iterator sourceListEnd =
7873 task.mpSourceMediumLockList->GetEnd();
7874 for (MediumLockList::Base::const_iterator it = sourceListBegin;
7875 it != sourceListEnd;
7876 ++it)
7877 {
7878 const MediumLock &mediumLock = *it;
7879 const ComObjPtr<Medium> &pMedium = mediumLock.GetMedium();
7880 AutoReadLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
7881
7882 /* sanity check */
7883 Assert(pMedium->m->state == MediumState_LockedRead);
7884
7885 /* Open all media in read-only mode. */
7886 vrc = VDOpen(hdd,
7887 pMedium->m->strFormat.c_str(),
7888 pMedium->m->strLocationFull.c_str(),
7889 VD_OPEN_FLAGS_READONLY | m->uOpenFlagsDef,
7890 pMedium->m->vdImageIfaces);
7891 if (RT_FAILURE(vrc))
7892 throw setError(VBOX_E_FILE_ERROR,
7893 tr("Could not open the medium storage unit '%s'%s"),
7894 pMedium->m->strLocationFull.c_str(),
7895 vdError(vrc).c_str());
7896 }
7897
7898 Utf8Str targetFormat(task.mFormat->getId());
7899 Utf8Str targetLocation(task.mFilename);
7900 uint64_t capabilities = task.mFormat->getCapabilities();
7901
7902 Assert(m->state == MediumState_LockedRead);
7903
7904 /* unlock before the potentially lengthy operation */
7905 thisLock.release();
7906
7907 /* ensure the target directory exists */
7908 if (capabilities & MediumFormatCapabilities_File)
7909 {
7910 rc = VirtualBox::ensureFilePathExists(targetLocation, !(task.mVariant & MediumVariant_NoCreateDir) /* fCreate */);
7911 if (FAILED(rc))
7912 throw rc;
7913 }
7914
7915 PVBOXHDD targetHdd;
7916 vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &targetHdd);
7917 ComAssertRCThrow(vrc, E_FAIL);
7918
7919 try
7920 {
7921 vrc = VDCopy(hdd,
7922 VD_LAST_IMAGE,
7923 targetHdd,
7924 targetFormat.c_str(),
7925 targetLocation.c_str(),
7926 false /* fMoveByRename */,
7927 0 /* cbSize */,
7928 task.mVariant & ~MediumVariant_NoCreateDir,
7929 NULL /* pDstUuid */,
7930 VD_OPEN_FLAGS_NORMAL | VD_OPEN_FLAGS_SEQUENTIAL,
7931 NULL /* pVDIfsOperation */,
7932 task.mVDImageIfaces,
7933 task.mVDOperationIfaces);
7934 if (RT_FAILURE(vrc))
7935 throw setError(VBOX_E_FILE_ERROR,
7936 tr("Could not create the clone medium '%s'%s"),
7937 targetLocation.c_str(), vdError(vrc).c_str());
7938 }
7939 catch (HRESULT aRC) { rc = aRC; }
7940
7941 VDDestroy(targetHdd);
7942 }
7943 catch (HRESULT aRC) { rc = aRC; }
7944
7945 VDDestroy(hdd);
7946 }
7947 catch (HRESULT aRC) { rc = aRC; }
7948
7949 /* Everything is explicitly unlocked when the task exits,
7950 * as the task destruction also destroys the source chain. */
7951
7952 /* Make sure the source chain is released early, otherwise it can
7953 * lead to deadlocks with concurrent IAppliance activities. */
7954 task.mpSourceMediumLockList->Clear();
7955
7956 return rc;
7957}
7958
7959/**
7960 * Implementation code for the "import" task.
7961 *
7962 * This only gets started from Medium::importFile() and always runs
7963 * asynchronously. It potentially touches the media registry, so we
7964 * always save the VirtualBox.xml file when we're done here.
7965 *
7966 * @param task
7967 * @return
7968 */
7969HRESULT Medium::taskImportHandler(Medium::ImportTask &task)
7970{
7971 HRESULT rcTmp = S_OK;
7972
7973 const ComObjPtr<Medium> &pParent = task.mParent;
7974
7975 bool fCreatingTarget = false;
7976
7977 uint64_t size = 0, logicalSize = 0;
7978 MediumVariant_T variant = MediumVariant_Standard;
7979 bool fGenerateUuid = false;
7980
7981 try
7982 {
7983 /* Lock all in {parent,child} order. The lock is also used as a
7984 * signal from the task initiator (which releases it only after
7985 * RTThreadCreate()) that we can start the job. */
7986 AutoMultiWriteLock2 thisLock(this, pParent COMMA_LOCKVAL_SRC_POS);
7987
7988 fCreatingTarget = m->state == MediumState_Creating;
7989
7990 /* The object may request a specific UUID (through a special form of
7991 * the setLocation() argument). Otherwise we have to generate it */
7992 Guid targetId = m->id;
7993 fGenerateUuid = targetId.isEmpty();
7994 if (fGenerateUuid)
7995 {
7996 targetId.create();
7997 /* VirtualBox::registerMedium() will need UUID */
7998 unconst(m->id) = targetId;
7999 }
8000
8001
8002 PVBOXHDD hdd;
8003 int vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &hdd);
8004 ComAssertRCThrow(vrc, E_FAIL);
8005
8006 try
8007 {
8008 /* Open source medium. */
8009 vrc = VDOpen(hdd,
8010 task.mFormat->getId().c_str(),
8011 task.mFilename.c_str(),
8012 VD_OPEN_FLAGS_READONLY | VD_OPEN_FLAGS_SEQUENTIAL | m->uOpenFlagsDef,
8013 task.mVDImageIfaces);
8014 if (RT_FAILURE(vrc))
8015 throw setError(VBOX_E_FILE_ERROR,
8016 tr("Could not open the medium storage unit '%s'%s"),
8017 task.mFilename.c_str(),
8018 vdError(vrc).c_str());
8019
8020 Utf8Str targetFormat(m->strFormat);
8021 Utf8Str targetLocation(m->strLocationFull);
8022 uint64_t capabilities = task.mFormat->getCapabilities();
8023
8024 Assert( m->state == MediumState_Creating
8025 || m->state == MediumState_LockedWrite);
8026 Assert( pParent.isNull()
8027 || pParent->m->state == MediumState_LockedRead);
8028
8029 /* unlock before the potentially lengthy operation */
8030 thisLock.release();
8031
8032 /* ensure the target directory exists */
8033 if (capabilities & MediumFormatCapabilities_File)
8034 {
8035 HRESULT rc = VirtualBox::ensureFilePathExists(targetLocation, !(task.mVariant & MediumVariant_NoCreateDir) /* fCreate */);
8036 if (FAILED(rc))
8037 throw rc;
8038 }
8039
8040 PVBOXHDD targetHdd;
8041 vrc = VDCreate(m->vdDiskIfaces, convertDeviceType(), &targetHdd);
8042 ComAssertRCThrow(vrc, E_FAIL);
8043
8044 try
8045 {
8046 /* Open all media in the target chain. */
8047 MediumLockList::Base::const_iterator targetListBegin =
8048 task.mpTargetMediumLockList->GetBegin();
8049 MediumLockList::Base::const_iterator targetListEnd =
8050 task.mpTargetMediumLockList->GetEnd();
8051 for (MediumLockList::Base::const_iterator it = targetListBegin;
8052 it != targetListEnd;
8053 ++it)
8054 {
8055 const MediumLock &mediumLock = *it;
8056 const ComObjPtr<Medium> &pMedium = mediumLock.GetMedium();
8057
8058 /* If the target medium is not created yet there's no
8059 * reason to open it. */
8060 if (pMedium == this && fCreatingTarget)
8061 continue;
8062
8063 AutoReadLock alock(pMedium COMMA_LOCKVAL_SRC_POS);
8064
8065 /* sanity check */
8066 Assert( pMedium->m->state == MediumState_LockedRead
8067 || pMedium->m->state == MediumState_LockedWrite);
8068
8069 unsigned uOpenFlags = VD_OPEN_FLAGS_NORMAL;
8070 if (pMedium->m->state != MediumState_LockedWrite)
8071 uOpenFlags = VD_OPEN_FLAGS_READONLY;
8072 if (pMedium->m->type == MediumType_Shareable)
8073 uOpenFlags |= VD_OPEN_FLAGS_SHAREABLE;
8074
8075 /* Open all media in appropriate mode. */
8076 vrc = VDOpen(targetHdd,
8077 pMedium->m->strFormat.c_str(),
8078 pMedium->m->strLocationFull.c_str(),
8079 uOpenFlags | m->uOpenFlagsDef,
8080 pMedium->m->vdImageIfaces);
8081 if (RT_FAILURE(vrc))
8082 throw setError(VBOX_E_FILE_ERROR,
8083 tr("Could not open the medium storage unit '%s'%s"),
8084 pMedium->m->strLocationFull.c_str(),
8085 vdError(vrc).c_str());
8086 }
8087
8088 /** @todo r=klaus target isn't locked, race getting the state */
8089 vrc = VDCopy(hdd,
8090 VD_LAST_IMAGE,
8091 targetHdd,
8092 targetFormat.c_str(),
8093 (fCreatingTarget) ? targetLocation.c_str() : (char *)NULL,
8094 false /* fMoveByRename */,
8095 0 /* cbSize */,
8096 task.mVariant & ~MediumVariant_NoCreateDir,
8097 targetId.raw(),
8098 VD_OPEN_FLAGS_NORMAL,
8099 NULL /* pVDIfsOperation */,
8100 m->vdImageIfaces,
8101 task.mVDOperationIfaces);
8102 if (RT_FAILURE(vrc))
8103 throw setError(VBOX_E_FILE_ERROR,
8104 tr("Could not create the clone medium '%s'%s"),
8105 targetLocation.c_str(), vdError(vrc).c_str());
8106
8107 size = VDGetFileSize(targetHdd, VD_LAST_IMAGE);
8108 logicalSize = VDGetSize(targetHdd, VD_LAST_IMAGE);
8109 unsigned uImageFlags;
8110 vrc = VDGetImageFlags(targetHdd, 0, &uImageFlags);
8111 if (RT_SUCCESS(vrc))
8112 variant = (MediumVariant_T)uImageFlags;
8113 }
8114 catch (HRESULT aRC) { rcTmp = aRC; }
8115
8116 VDDestroy(targetHdd);
8117 }
8118 catch (HRESULT aRC) { rcTmp = aRC; }
8119
8120 VDDestroy(hdd);
8121 }
8122 catch (HRESULT aRC) { rcTmp = aRC; }
8123
8124 ErrorInfoKeeper eik;
8125 MultiResult mrc(rcTmp);
8126
8127 /* Only do the parent changes for newly created media. */
8128 if (SUCCEEDED(mrc) && fCreatingTarget)
8129 {
8130 /* we set mParent & children() */
8131 AutoWriteLock alock2(m->pVirtualBox->getMediaTreeLockHandle() COMMA_LOCKVAL_SRC_POS);
8132
8133 Assert(m->pParent.isNull());
8134
8135 if (pParent)
8136 {
8137 /* associate the clone with the parent and deassociate
8138 * from VirtualBox */
8139 m->pParent = pParent;
8140 pParent->m->llChildren.push_back(this);
8141
8142 /* register with mVirtualBox as the last step and move to
8143 * Created state only on success (leaving an orphan file is
8144 * better than breaking media registry consistency) */
8145 eik.restore();
8146 ComObjPtr<Medium> pMedium;
8147 mrc = pParent->m->pVirtualBox->registerMedium(this, &pMedium,
8148 DeviceType_HardDisk);
8149 Assert(this == pMedium);
8150 eik.fetch();
8151
8152 if (FAILED(mrc))
8153 /* break parent association on failure to register */
8154 this->deparent(); // removes target from parent
8155 }
8156 else
8157 {
8158 /* just register */
8159 eik.restore();
8160 ComObjPtr<Medium> pMedium;
8161 mrc = m->pVirtualBox->registerMedium(this, &pMedium, DeviceType_HardDisk);
8162 Assert(this == pMedium);
8163 eik.fetch();
8164 }
8165 }
8166
8167 if (fCreatingTarget)
8168 {
8169 AutoWriteLock mLock(this COMMA_LOCKVAL_SRC_POS);
8170
8171 if (SUCCEEDED(mrc))
8172 {
8173 m->state = MediumState_Created;
8174
8175 m->size = size;
8176 m->logicalSize = logicalSize;
8177 m->variant = variant;
8178 }
8179 else
8180 {
8181 /* back to NotCreated on failure */
8182 m->state = MediumState_NotCreated;
8183
8184 /* reset UUID to prevent it from being reused next time */
8185 if (fGenerateUuid)
8186 unconst(m->id).clear();
8187 }
8188 }
8189
8190 // now, at the end of this task (always asynchronous), save the settings
8191 {
8192 // save the settings
8193 markRegistriesModified();
8194 /* collect multiple errors */
8195 eik.restore();
8196 m->pVirtualBox->saveModifiedRegistries();
8197 eik.fetch();
8198 }
8199
8200 /* Everything is explicitly unlocked when the task exits,
8201 * as the task destruction also destroys the target chain. */
8202
8203 /* Make sure the target chain is released early, otherwise it can
8204 * lead to deadlocks with concurrent IAppliance activities. */
8205 task.mpTargetMediumLockList->Clear();
8206
8207 return mrc;
8208}
8209
8210/* vi: set tabstop=4 shiftwidth=4 expandtab: */
Note: See TracBrowser for help on using the repository browser.

© 2024 Oracle Support Privacy / Do Not Sell My Info Terms of Use Trademark Policy Automated Access Etiquette