ApplianceImpl.cpp revision 6a74d2edb239c0daeb51ccf267b4f66b7add5335
/* $Id$ */
/** @file
*
* IAppliance and IVirtualSystem COM class implementations.
*/
/*
* Copyright (C) 2008-2013 Oracle Corporation
*
* This file is part of VirtualBox Open Source Edition (OSE), as
* available from http://www.virtualbox.org. This file is free software;
* you can redistribute it and/or modify it under the terms of the GNU
* General Public License (GPL) as published by the Free Software
* Foundation, in version 2 as it comes in the "COPYING" file of the
* VirtualBox OSE distribution. VirtualBox OSE is distributed in the
* hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
*/
#include <iprt/path.h>
#include <iprt/cpp/utils.h>
#include <VBox/com/array.h>
#include <map>
#include "ApplianceImpl.h"
#include "VFSExplorerImpl.h"
#include "VirtualBoxImpl.h"
#include "GuestOSTypeImpl.h"
#include "Global.h"
#include "ProgressImpl.h"
#include "MachineImpl.h"
#include "SystemPropertiesImpl.h"
#include "AutoCaller.h"
#include "Logging.h"
#include "ApplianceImplPrivate.h"
using namespace std;
////////////////////////////////////////////////////////////////////////////////
//
// Appliance constructor / destructor
//
// ////////////////////////////////////////////////////////////////////////////////
DEFINE_EMPTY_CTOR_DTOR(VirtualSystemDescription)
HRESULT VirtualSystemDescription::FinalConstruct()
{
return BaseFinalConstruct();
}
void VirtualSystemDescription::FinalRelease()
{
uninit();
BaseFinalRelease();
}
Appliance::Appliance()
: mVirtualBox(NULL)
{
}
Appliance::~Appliance()
{
}
HRESULT Appliance::FinalConstruct()
{
return BaseFinalConstruct();
}
void Appliance::FinalRelease()
{
uninit();
BaseFinalRelease();
}
////////////////////////////////////////////////////////////////////////////////
//
// Internal helpers
//
////////////////////////////////////////////////////////////////////////////////
static const char* const strISOURI = "http://www.ecma-international.org/publications/standards/Ecma-119.htm";
static const char* const strVMDKStreamURI = "http://www.vmware.com/interfaces/specifications/vmdk.html#streamOptimized";
static const char* const strVMDKSparseURI = "http://www.vmware.com/specifications/vmdk.html#sparse";
static const char* const strVMDKCompressedURI = "http://www.vmware.com/specifications/vmdk.html#compressed";
static const char* const strVMDKCompressedURI2 = "http://www.vmware.com/interfaces/specifications/vmdk.html#compressed";
static const char* const strVHDURI = "http://go.microsoft.com/fwlink/?LinkId=137171";
static std::map<Utf8Str, Utf8Str> supportedStandardsURI;
static const char* const applianceIOTarName = "Appliance::IOTar";
static const char* const applianceIOShaName = "Appliance::IOSha";
static const char* const applianceIOFileName = "Appliance::IOFile";
static std::map<APPLIANCEIONAME, Utf8Str> applianceIONameMap;
static const struct
{
ovf::CIMOSType_T cim;
VBOXOSTYPE osType;
}
g_osTypes[] =
{
{ ovf::CIMOSType_CIMOS_Unknown, VBOXOSTYPE_Unknown },
{ ovf::CIMOSType_CIMOS_OS2, VBOXOSTYPE_OS2 },
{ ovf::CIMOSType_CIMOS_OS2, VBOXOSTYPE_OS2Warp3 },
{ ovf::CIMOSType_CIMOS_OS2, VBOXOSTYPE_OS2Warp4 },
{ ovf::CIMOSType_CIMOS_OS2, VBOXOSTYPE_OS2Warp45 },
{ ovf::CIMOSType_CIMOS_MSDOS, VBOXOSTYPE_DOS },
{ ovf::CIMOSType_CIMOS_WIN3x, VBOXOSTYPE_Win31 },
{ ovf::CIMOSType_CIMOS_WIN95, VBOXOSTYPE_Win95 },
{ ovf::CIMOSType_CIMOS_WIN98, VBOXOSTYPE_Win98 },
{ ovf::CIMOSType_CIMOS_WINNT, VBOXOSTYPE_WinNT },
{ ovf::CIMOSType_CIMOS_WINNT, VBOXOSTYPE_WinNT4 },
{ ovf::CIMOSType_CIMOS_NetWare, VBOXOSTYPE_Netware },
{ ovf::CIMOSType_CIMOS_NovellOES, VBOXOSTYPE_Netware },
{ ovf::CIMOSType_CIMOS_Solaris, VBOXOSTYPE_Solaris },
{ ovf::CIMOSType_CIMOS_SunOS, VBOXOSTYPE_Solaris },
{ ovf::CIMOSType_CIMOS_FreeBSD, VBOXOSTYPE_FreeBSD },
{ ovf::CIMOSType_CIMOS_NetBSD, VBOXOSTYPE_NetBSD },
{ ovf::CIMOSType_CIMOS_QNX, VBOXOSTYPE_QNX },
{ ovf::CIMOSType_CIMOS_Windows2000, VBOXOSTYPE_Win2k },
{ ovf::CIMOSType_CIMOS_WindowsMe, VBOXOSTYPE_WinMe },
{ ovf::CIMOSType_CIMOS_OpenBSD, VBOXOSTYPE_OpenBSD },
{ ovf::CIMOSType_CIMOS_WindowsXP, VBOXOSTYPE_WinXP },
{ ovf::CIMOSType_CIMOS_WindowsXPEmbedded, VBOXOSTYPE_WinXP },
{ ovf::CIMOSType_CIMOS_WindowsEmbeddedforPointofService, VBOXOSTYPE_WinXP },
{ ovf::CIMOSType_CIMOS_MicrosoftWindowsServer2003, VBOXOSTYPE_Win2k3 },
{ ovf::CIMOSType_CIMOS_MicrosoftWindowsServer2003_64, VBOXOSTYPE_Win2k3_x64 },
{ ovf::CIMOSType_CIMOS_WindowsXP_64, VBOXOSTYPE_WinXP_x64 },
{ ovf::CIMOSType_CIMOS_WindowsVista, VBOXOSTYPE_WinVista },
{ ovf::CIMOSType_CIMOS_WindowsVista_64, VBOXOSTYPE_WinVista_x64 },
{ ovf::CIMOSType_CIMOS_MicrosoftWindowsServer2008, VBOXOSTYPE_Win2k8 },
{ ovf::CIMOSType_CIMOS_MicrosoftWindowsServer2008_64, VBOXOSTYPE_Win2k8_x64 },
{ ovf::CIMOSType_CIMOS_FreeBSD_64, VBOXOSTYPE_FreeBSD_x64 },
{ ovf::CIMOSType_CIMOS_MACOS, VBOXOSTYPE_MacOS },
{ ovf::CIMOSType_CIMOS_MACOS, VBOXOSTYPE_MacOS_x64 }, // there is no CIM 64-bit type for this
{ ovf::CIMOSType_CIMOS_MACOS, VBOXOSTYPE_MacOS106 },
{ ovf::CIMOSType_CIMOS_MACOS, VBOXOSTYPE_MacOS106_x64 },
{ ovf::CIMOSType_CIMOS_MACOS, VBOXOSTYPE_MacOS107_x64 },
{ ovf::CIMOSType_CIMOS_MACOS, VBOXOSTYPE_MacOS108_x64 },
{ ovf::CIMOSType_CIMOS_MACOS, VBOXOSTYPE_MacOS109_x64 },
// Linuxes
{ ovf::CIMOSType_CIMOS_RedHatEnterpriseLinux, VBOXOSTYPE_RedHat },
{ ovf::CIMOSType_CIMOS_RedHatEnterpriseLinux_64, VBOXOSTYPE_RedHat_x64 },
{ ovf::CIMOSType_CIMOS_Solaris_64, VBOXOSTYPE_Solaris_x64 },
{ ovf::CIMOSType_CIMOS_SUSE, VBOXOSTYPE_OpenSUSE },
{ ovf::CIMOSType_CIMOS_SLES, VBOXOSTYPE_OpenSUSE },
{ ovf::CIMOSType_CIMOS_NovellLinuxDesktop, VBOXOSTYPE_OpenSUSE },
{ ovf::CIMOSType_CIMOS_SUSE_64, VBOXOSTYPE_OpenSUSE_x64 },
{ ovf::CIMOSType_CIMOS_SLES_64, VBOXOSTYPE_OpenSUSE_x64 },
{ ovf::CIMOSType_CIMOS_LINUX, VBOXOSTYPE_Linux },
{ ovf::CIMOSType_CIMOS_LINUX, VBOXOSTYPE_Linux22 },
{ ovf::CIMOSType_CIMOS_SunJavaDesktopSystem, VBOXOSTYPE_Linux },
{ ovf::CIMOSType_CIMOS_TurboLinux, VBOXOSTYPE_Turbolinux },
{ ovf::CIMOSType_CIMOS_TurboLinux_64, VBOXOSTYPE_Turbolinux_x64 },
{ ovf::CIMOSType_CIMOS_Mandriva, VBOXOSTYPE_Mandriva },
{ ovf::CIMOSType_CIMOS_Mandriva_64, VBOXOSTYPE_Mandriva_x64 },
{ ovf::CIMOSType_CIMOS_Ubuntu, VBOXOSTYPE_Ubuntu },
{ ovf::CIMOSType_CIMOS_Ubuntu_64, VBOXOSTYPE_Ubuntu_x64 },
{ ovf::CIMOSType_CIMOS_Debian, VBOXOSTYPE_Debian },
{ ovf::CIMOSType_CIMOS_Debian_64, VBOXOSTYPE_Debian_x64 },
{ ovf::CIMOSType_CIMOS_Linux_2_4_x, VBOXOSTYPE_Linux24 },
{ ovf::CIMOSType_CIMOS_Linux_2_4_x_64, VBOXOSTYPE_Linux24_x64 },
{ ovf::CIMOSType_CIMOS_Linux_2_6_x, VBOXOSTYPE_Linux26 },
{ ovf::CIMOSType_CIMOS_Linux_2_6_x_64, VBOXOSTYPE_Linux26_x64 },
{ ovf::CIMOSType_CIMOS_Linux_64, VBOXOSTYPE_Linux26_x64 },
// types that we have support for but CIM doesn't
{ ovf::CIMOSType_CIMOS_Linux_2_6_x, VBOXOSTYPE_ArchLinux },
{ ovf::CIMOSType_CIMOS_Linux_2_6_x_64, VBOXOSTYPE_ArchLinux_x64 },
{ ovf::CIMOSType_CIMOS_Linux_2_6_x, VBOXOSTYPE_FedoraCore },
{ ovf::CIMOSType_CIMOS_Linux_2_6_x_64, VBOXOSTYPE_FedoraCore_x64 },
{ ovf::CIMOSType_CIMOS_Linux_2_6_x, VBOXOSTYPE_Gentoo },
{ ovf::CIMOSType_CIMOS_Linux_2_6_x_64, VBOXOSTYPE_Gentoo_x64 },
{ ovf::CIMOSType_CIMOS_Linux_2_6_x, VBOXOSTYPE_Xandros },
{ ovf::CIMOSType_CIMOS_Linux_2_6_x_64, VBOXOSTYPE_Xandros_x64 },
{ ovf::CIMOSType_CIMOS_Solaris, VBOXOSTYPE_OpenSolaris },
{ ovf::CIMOSType_CIMOS_Solaris_64, VBOXOSTYPE_OpenSolaris_x64 },
// types added with CIM 2.25.0 follow:
{ ovf::CIMOSType_CIMOS_WindowsServer2008R2, VBOXOSTYPE_Win2k8 }, // duplicate, see above
// { ovf::CIMOSType_CIMOS_VMwareESXi = 104, // we can't run ESX in a VM
{ ovf::CIMOSType_CIMOS_Windows7, VBOXOSTYPE_Win7 },
{ ovf::CIMOSType_CIMOS_Windows7, VBOXOSTYPE_Win7_x64 }, // there is no CIM 64-bit type for this
{ ovf::CIMOSType_CIMOS_CentOS, VBOXOSTYPE_RedHat },
{ ovf::CIMOSType_CIMOS_CentOS_64, VBOXOSTYPE_RedHat_x64 },
{ ovf::CIMOSType_CIMOS_OracleEnterpriseLinux, VBOXOSTYPE_Oracle },
{ ovf::CIMOSType_CIMOS_OracleEnterpriseLinux_64, VBOXOSTYPE_Oracle_x64 },
{ ovf::CIMOSType_CIMOS_eComStation, VBOXOSTYPE_ECS }
// there are no CIM types for these, so these turn to "other" on export:
// VBOXOSTYPE_OpenBSD
// VBOXOSTYPE_OpenBSD_x64
// VBOXOSTYPE_NetBSD
// VBOXOSTYPE_NetBSD_x64
};
/* Pattern structure for matching the OS type description field */
struct osTypePattern
{
const char *pcszPattern;
VBOXOSTYPE osType;
};
/* These are the 32-Bit ones. They are sorted by priority. */
static const osTypePattern g_osTypesPattern[] =
{
{"Windows NT", VBOXOSTYPE_WinNT4},
{"Windows XP", VBOXOSTYPE_WinXP},
{"Windows 2000", VBOXOSTYPE_Win2k},
{"Windows 2003", VBOXOSTYPE_Win2k3},
{"Windows Vista", VBOXOSTYPE_WinVista},
{"Windows 2008", VBOXOSTYPE_Win2k8},
{"SUSE", VBOXOSTYPE_OpenSUSE},
{"Novell", VBOXOSTYPE_OpenSUSE},
{"Red Hat", VBOXOSTYPE_RedHat},
{"Mandriva", VBOXOSTYPE_Mandriva},
{"Ubuntu", VBOXOSTYPE_Ubuntu},
{"Debian", VBOXOSTYPE_Debian},
{"QNX", VBOXOSTYPE_QNX},
{"Linux 2.4", VBOXOSTYPE_Linux24},
{"Linux 2.6", VBOXOSTYPE_Linux26},
{"Linux", VBOXOSTYPE_Linux},
{"OpenSolaris", VBOXOSTYPE_OpenSolaris},
{"Solaris", VBOXOSTYPE_OpenSolaris},
{"FreeBSD", VBOXOSTYPE_FreeBSD},
{"NetBSD", VBOXOSTYPE_NetBSD},
{"Windows 95", VBOXOSTYPE_Win95},
{"Windows 98", VBOXOSTYPE_Win98},
{"Windows Me", VBOXOSTYPE_WinMe},
{"Windows 3.", VBOXOSTYPE_Win31},
{"DOS", VBOXOSTYPE_DOS},
{"OS2", VBOXOSTYPE_OS2}
};
/* These are the 64-Bit ones. They are sorted by priority. */
static const osTypePattern g_osTypesPattern64[] =
{
{"Windows XP", VBOXOSTYPE_WinXP_x64},
{"Windows 2003", VBOXOSTYPE_Win2k3_x64},
{"Windows Vista", VBOXOSTYPE_WinVista_x64},
{"Windows 2008", VBOXOSTYPE_Win2k8_x64},
{"SUSE", VBOXOSTYPE_OpenSUSE_x64},
{"Novell", VBOXOSTYPE_OpenSUSE_x64},
{"Red Hat", VBOXOSTYPE_RedHat_x64},
{"Mandriva", VBOXOSTYPE_Mandriva_x64},
{"Ubuntu", VBOXOSTYPE_Ubuntu_x64},
{"Debian", VBOXOSTYPE_Debian_x64},
{"Linux 2.4", VBOXOSTYPE_Linux24_x64},
{"Linux 2.6", VBOXOSTYPE_Linux26_x64},
{"Linux", VBOXOSTYPE_Linux26_x64},
{"OpenSolaris", VBOXOSTYPE_OpenSolaris_x64},
{"Solaris", VBOXOSTYPE_OpenSolaris_x64},
{"FreeBSD", VBOXOSTYPE_FreeBSD_x64},
};
/**
* Private helper func that suggests a VirtualBox guest OS type
* for the given OVF operating system type.
* @param osTypeVBox
* @param c
* @param cStr
*/
void convertCIMOSType2VBoxOSType(Utf8Str &strType, ovf::CIMOSType_T c, const Utf8Str &cStr)
{
/* First check if the type is other/other_64 */
if (c == ovf::CIMOSType_CIMOS_Other)
{
for (size_t i=0; i < RT_ELEMENTS(g_osTypesPattern); ++i)
if (cStr.contains (g_osTypesPattern[i].pcszPattern, Utf8Str::CaseInsensitive))
{
strType = Global::OSTypeId(g_osTypesPattern[i].osType);
return;
}
}
else if (c == ovf::CIMOSType_CIMOS_Other_64)
{
for (size_t i=0; i < RT_ELEMENTS(g_osTypesPattern64); ++i)
if (cStr.contains (g_osTypesPattern64[i].pcszPattern, Utf8Str::CaseInsensitive))
{
strType = Global::OSTypeId(g_osTypesPattern64[i].osType);
return;
}
}
for (size_t i = 0; i < RT_ELEMENTS(g_osTypes); ++i)
{
if (c == g_osTypes[i].cim)
{
strType = Global::OSTypeId(g_osTypes[i].osType);
return;
}
}
if (c == ovf::CIMOSType_CIMOS_Other_64)
strType = Global::OSTypeId(VBOXOSTYPE_Unknown_x64);
else
strType = Global::OSTypeId(VBOXOSTYPE_Unknown);
}
/**
* Private helper func that suggests a VirtualBox guest OS type
* for the given OVF operating system type.
* @returns CIM OS type.
* @param pcszVBox Our guest OS type identifier string.
* @param fLongMode Whether long mode is enabled and a 64-bit CIM type is
* preferred even if the VBox guest type isn't 64-bit.
*/
ovf::CIMOSType_T convertVBoxOSType2CIMOSType(const char *pcszVBox, BOOL fLongMode)
{
for (size_t i = 0; i < RT_ELEMENTS(g_osTypes); ++i)
{
if (!RTStrICmp(pcszVBox, Global::OSTypeId(g_osTypes[i].osType)))
{
if (fLongMode && !(g_osTypes[i].osType & VBOXOSTYPE_x64))
{
VBOXOSTYPE enmDesiredOsType = (VBOXOSTYPE)((int)g_osTypes[i].osType | (int)VBOXOSTYPE_x64);
size_t j = i;
while (++j < RT_ELEMENTS(g_osTypes))
if (g_osTypes[j].osType == enmDesiredOsType)
return g_osTypes[j].cim;
j = i;
while (--j > 0)
if (g_osTypes[j].osType == enmDesiredOsType)
return g_osTypes[j].cim;
/* Not all OSes have 64-bit versions, so just return the 32-bit variant. */
}
return g_osTypes[i].cim;
}
}
return fLongMode ? ovf::CIMOSType_CIMOS_Other_64 : ovf::CIMOSType_CIMOS_Other;
}
Utf8Str convertNetworkAttachmentTypeToString(NetworkAttachmentType_T type)
{
Utf8Str strType;
switch (type)
{
case NetworkAttachmentType_NAT: strType = "NAT"; break;
case NetworkAttachmentType_Bridged: strType = "Bridged"; break;
case NetworkAttachmentType_Internal: strType = "Internal"; break;
case NetworkAttachmentType_HostOnly: strType = "HostOnly"; break;
case NetworkAttachmentType_Generic: strType = "Generic"; break;
case NetworkAttachmentType_NATNetwork: strType = "NATNetwork"; break;
case NetworkAttachmentType_Null: strType = "Null"; break;
}
return strType;
}
////////////////////////////////////////////////////////////////////////////////
//
// IVirtualBox public methods
//
////////////////////////////////////////////////////////////////////////////////
// This code is here so we won't have to include the appliance headers in the
// IVirtualBox implementation.
/**
* Implementation for IVirtualBox::createAppliance.
*
* @param anAppliance IAppliance object created if S_OK is returned.
* @return S_OK or error.
*/
STDMETHODIMP VirtualBox::CreateAppliance(IAppliance** anAppliance)
{
HRESULT rc;
ComObjPtr<Appliance> appliance;
appliance.createObject();
rc = appliance->init(this);
if (SUCCEEDED(rc))
appliance.queryInterfaceTo(anAppliance);
return rc;
}
/**
* Appliance COM initializer.
* @param
* @return
*/
HRESULT Appliance::init(VirtualBox *aVirtualBox)
{
HRESULT rc = S_OK;
/* Enclose the state transition NotReady->InInit->Ready */
AutoInitSpan autoInitSpan(this);
AssertReturn(autoInitSpan.isOk(), E_FAIL);
/* Weak reference to a VirtualBox object */
unconst(mVirtualBox) = aVirtualBox;
// initialize data
m = new Data;
i_initApplianceIONameMap();
rc = i_initSetOfSupportedStandardsURI();
/* Confirm a successful initialization */
autoInitSpan.setSucceeded();
return rc;
}
/**
* Appliance COM uninitializer.
* @return
*/
void Appliance::uninit()
{
/* Enclose the state transition Ready->InUninit->NotReady */
AutoUninitSpan autoUninitSpan(this);
if (autoUninitSpan.uninitDone())
return;
delete m;
m = NULL;
}
////////////////////////////////////////////////////////////////////////////////
//
// IAppliance public methods
//
////////////////////////////////////////////////////////////////////////////////
/**
* Public method implementation.
* @param
* @return
*/
HRESULT Appliance::getPath(com::Utf8Str &aPath)
{
AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
if (!i_isApplianceIdle())
return E_ACCESSDENIED;
aPath = m->locInfo.strPath;
return S_OK;
}
/**
* Public method implementation.
* @param
* @return
*/
HRESULT Appliance::getDisks(std::vector<com::Utf8Str> &aDisks)
{
AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
aDisks.resize(0);
if (!i_isApplianceIdle())
return E_ACCESSDENIED;
if (m->pReader) // OVFReader instantiated?
{
aDisks.resize(m->pReader->m_mapDisks.size());
ovf::DiskImagesMap::const_iterator it;
size_t i = 0;
for (it = m->pReader->m_mapDisks.begin();
it != m->pReader->m_mapDisks.end();
++it, ++i)
{
// create a string representing this disk
const ovf::DiskImage &d = it->second;
char *psz = NULL;
RTStrAPrintf(&psz,
"%s\t"
"%RI64\t"
"%RI64\t"
"%s\t"
"%s\t"
"%RI64\t"
"%RI64\t"
"%s",
d.strDiskId.c_str(),
d.iCapacity,
d.iPopulatedSize,
d.strFormat.c_str(),
d.strHref.c_str(),
d.iSize,
d.iChunkSize,
d.strCompression.c_str());
Utf8Str utf(psz);
aDisks[i] = utf;
RTStrFree(psz);
}
}
return S_OK;
}
/**
* Public method implementation.
* @param
* @return
*/
HRESULT Appliance::getVirtualSystemDescriptions(std::vector<ComPtr<IVirtualSystemDescription> > &aVirtualSystemDescriptions)
{
AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
if (!i_isApplianceIdle())
return E_ACCESSDENIED;
aVirtualSystemDescriptions.resize(m->virtualSystemDescriptions.size());
std::list< ComObjPtr<VirtualSystemDescription> > vsds(m->virtualSystemDescriptions);
size_t i = 0;
for (std::list< ComObjPtr<VirtualSystemDescription> >::iterator it = vsds.begin(); it != vsds.end(); ++it, ++i)
{
(*it).queryInterfaceTo(aVirtualSystemDescriptions[i].asOutParam());
}
return S_OK;
}
/**
* Public method implementation.
* @param aDisks
* @return
*/
HRESULT Appliance::getMachines(std::vector<com::Utf8Str> &aMachines)
{
AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
if (!i_isApplianceIdle())
return E_ACCESSDENIED;
aMachines.resize(m->llGuidsMachinesCreated.size());
size_t i = 0;
for (std::list<Guid>::const_iterator it = m->llGuidsMachinesCreated.begin();
it != m->llGuidsMachinesCreated.end();
++it, ++i)
{
const Guid &uuid = *it;
aMachines[i] = uuid.toUtf16();
}
return S_OK;
}
HRESULT Appliance::createVFSExplorer(const com::Utf8Str &aURI, ComPtr<IVFSExplorer> &aExplorer)
{
AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
ComObjPtr<VFSExplorer> explorer;
HRESULT rc = S_OK;
try
{
Utf8Str uri(aURI);
/* Check which kind of export the user has requested */
LocationInfo li;
i_parseURI(aURI, li);
/* Create the explorer object */
explorer.createObject();
rc = explorer->init(li.storageType, li.strPath, li.strHostname, li.strUsername, li.strPassword, mVirtualBox);
}
catch (HRESULT aRC)
{
rc = aRC;
}
if (SUCCEEDED(rc))
/* Return explorer to the caller */
explorer.queryInterfaceTo(aExplorer.asOutParam());
return rc;
}
/**
* Public method implementation.
* @return
*/
HRESULT Appliance::getWarnings(std::vector<com::Utf8Str> &aWarnings)
{
AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
aWarnings.resize(m->llWarnings.size());
list<Utf8Str>::const_iterator it;
size_t i = 0;
for (it = m->llWarnings.begin();
it != m->llWarnings.end();
++it, ++i)
{
aWarnings[i] = *it;
}
return S_OK;
}
////////////////////////////////////////////////////////////////////////////////
//
// Appliance private methods
//
////////////////////////////////////////////////////////////////////////////////
//
HRESULT Appliance::i_initSetOfSupportedStandardsURI()
{
HRESULT rc = S_OK;
if (!supportedStandardsURI.empty())
return rc;
/* Get the system properties. */
SystemProperties *pSysProps = mVirtualBox->getSystemProperties();
{
ComObjPtr<MediumFormat> trgFormat = pSysProps->mediumFormatFromExtension("iso");
if (trgFormat.isNull())
return setError(E_FAIL, tr("Can't find appropriate medium format for ISO type of a virtual disk."));
Bstr bstrFormatName;
rc = trgFormat->COMGETTER(Name)(bstrFormatName.asOutParam());
if (FAILED(rc)) return rc;
Utf8Str strTrgFormat = Utf8Str(bstrFormatName);
supportedStandardsURI.insert(std::make_pair(Utf8Str(strISOURI), strTrgFormat));
}
{
ComObjPtr<MediumFormat> trgFormat = pSysProps->mediumFormatFromExtension("vmdk");
if (trgFormat.isNull())
return setError(E_FAIL, tr("Can't find appropriate medium format for VMDK type of a virtual disk."));
Bstr bstrFormatName;
rc = trgFormat->COMGETTER(Name)(bstrFormatName.asOutParam());
if (FAILED(rc)) return rc;
Utf8Str strTrgFormat = Utf8Str(bstrFormatName);
supportedStandardsURI.insert(std::make_pair(Utf8Str(strVMDKStreamURI), strTrgFormat));
supportedStandardsURI.insert(std::make_pair(Utf8Str(strVMDKSparseURI), strTrgFormat));
supportedStandardsURI.insert(std::make_pair(Utf8Str(strVMDKCompressedURI), strTrgFormat));
supportedStandardsURI.insert(std::make_pair(Utf8Str(strVMDKCompressedURI2), strTrgFormat));
}
{
ComObjPtr<MediumFormat> trgFormat = pSysProps->mediumFormatFromExtension("vhd");
if (trgFormat.isNull())
return setError(E_FAIL, tr("Can't find appropriate medium format for VHD type of a virtual disk."));
Bstr bstrFormatName;
rc = trgFormat->COMGETTER(Name)(bstrFormatName.asOutParam());
if (FAILED(rc)) return rc;
Utf8Str strTrgFormat = Utf8Str(bstrFormatName);
supportedStandardsURI.insert(std::make_pair(Utf8Str(strVHDURI), strTrgFormat));
}
return rc;
}
Utf8Str Appliance::i_typeOfVirtualDiskFormatFromURI(Utf8Str uri) const
{
Utf8Str type;
std::map<Utf8Str, Utf8Str>::const_iterator cit = supportedStandardsURI.find(uri);
if (cit != supportedStandardsURI.end())
{
type = cit->second;
}
return type;
}
std::set<Utf8Str> Appliance::i_URIFromTypeOfVirtualDiskFormat(Utf8Str type)
{
std::set<Utf8Str> uri;
std::map<Utf8Str, Utf8Str>::const_iterator cit = supportedStandardsURI.begin();
while(cit != supportedStandardsURI.end())
{
if (cit->second.compare(type,Utf8Str::CaseInsensitive) == 0)
uri.insert(cit->first);
++cit;
}
return uri;
}
HRESULT Appliance::i_initApplianceIONameMap()
{
HRESULT rc = S_OK;
if (!applianceIONameMap.empty())
return rc;
applianceIONameMap.insert(std::make_pair(applianceIOTar, applianceIOTarName));
applianceIONameMap.insert(std::make_pair(applianceIOFile, applianceIOFileName));
applianceIONameMap.insert(std::make_pair(applianceIOSha, applianceIOShaName));
return rc;
}
Utf8Str Appliance::i_applianceIOName(APPLIANCEIONAME type) const
{
Utf8Str name;
std::map<APPLIANCEIONAME, Utf8Str>::const_iterator cit = applianceIONameMap.find(type);
if (cit != applianceIONameMap.end())
{
name = cit->second;
}
return name;
}
/**
* Returns a medium format object corresponding to the given
* disk image or null if no such format.
*
* @param di Disk Image
* @param mf Medium Format
*
* @return ComObjPtr<MediumFormat>
*/
HRESULT Appliance::i_findMediumFormatFromDiskImage(const ovf::DiskImage &di, ComObjPtr<MediumFormat>& mf)
{
HRESULT rc = S_OK;
/* Get the system properties. */
SystemProperties *pSysProps = mVirtualBox->getSystemProperties();
/* We need a proper source format description */
/* Which format to use? */
Utf8Str strSrcFormat = i_typeOfVirtualDiskFormatFromURI(di.strFormat);
/*
* fallback, if we can't determine virtual disk format using URI from the attribute ovf:format
* in the corresponding section <Disk> in the OVF file.
*/
if (strSrcFormat.isEmpty())
{
/* Figure out from extension which format the image of disk has. */
{
char *pszExt = RTPathSuffix(di.strHref.c_str());
if (pszExt)
pszExt++;
mf = pSysProps->mediumFormatFromExtension(pszExt);
}
}
else
mf = pSysProps->mediumFormat(strSrcFormat);
if (mf.isNull())
{
rc = setError(E_FAIL,
tr("Internal inconsistency looking up medium format for the disk image '%s'"),
di.strHref.c_str());
}
return rc;
}
/**
* Returns true if the appliance is in "idle" state. This should always be the
* case unless an import or export is currently in progress. Similar to machine
* states, this permits the Appliance implementation code to let go of the
* Appliance object lock while a time-consuming disk conversion is in progress
* without exposing the appliance to conflicting calls.
*
* This sets an error on "this" (the appliance) and returns false if the appliance
* is busy. The caller should then return E_ACCESSDENIED.
*
* Must be called from under the object lock!
*
* @return
*/
bool Appliance::i_isApplianceIdle()
{
if (m->state == Data::ApplianceImporting)
setError(VBOX_E_INVALID_OBJECT_STATE, tr("The appliance is busy importing files"));
else if (m->state == Data::ApplianceExporting)
setError(VBOX_E_INVALID_OBJECT_STATE, tr("The appliance is busy exporting files"));
else
return true;
return false;
}
HRESULT Appliance::i_searchUniqueVMName(Utf8Str& aName) const
{
IMachine *machine = NULL;
char *tmpName = RTStrDup(aName.c_str());
int i = 1;
/** @todo: Maybe too cost-intensive; try to find a lighter way */
while (mVirtualBox->FindMachine(Bstr(tmpName).raw(), &machine) != VBOX_E_OBJECT_NOT_FOUND)
{
RTStrFree(tmpName);
RTStrAPrintf(&tmpName, "%s_%d", aName.c_str(), i);
++i;
}
aName = tmpName;
RTStrFree(tmpName);
return S_OK;
}
HRESULT Appliance::i_searchUniqueDiskImageFilePath(Utf8Str& aName) const
{
IMedium *harddisk = NULL;
char *tmpName = RTStrDup(aName.c_str());
int i = 1;
/* Check if the file exists or if a file with this path is registered
* already */
/** @todo: Maybe too cost-intensive; try to find a lighter way */
while ( RTPathExists(tmpName)
|| mVirtualBox->OpenMedium(Bstr(tmpName).raw(), DeviceType_HardDisk, AccessMode_ReadWrite, FALSE /* fForceNewUuid */, &harddisk) != VBOX_E_OBJECT_NOT_FOUND
)
{
RTStrFree(tmpName);
char *tmpDir = RTStrDup(aName.c_str());
RTPathStripFilename(tmpDir);;
char *tmpFile = RTStrDup(RTPathFilename(aName.c_str()));
RTPathStripSuffix(tmpFile);
const char *pszTmpSuff = RTPathSuffix(aName.c_str());
RTStrAPrintf(&tmpName, "%s%c%s_%d%s", tmpDir, RTPATH_DELIMITER, tmpFile, i, pszTmpSuff);
RTStrFree(tmpFile);
RTStrFree(tmpDir);
++i;
}
aName = tmpName;
RTStrFree(tmpName);
return S_OK;
}
/**
* Called from Appliance::importImpl() and Appliance::writeImpl() to set up a
* progress object with the proper weights and maximum progress values.
*
* @param pProgress
* @param bstrDescription
* @param mode
* @return
*/
HRESULT Appliance::i_setUpProgress(ComObjPtr<Progress> &pProgress,
const Bstr &bstrDescription,
SetUpProgressMode mode)
{
HRESULT rc;
/* Create the progress object */
pProgress.createObject();
// compute the disks weight (this sets ulTotalDisksMB and cDisks in the instance data)
i_disksWeight();
m->ulWeightForManifestOperation = 0;
ULONG cOperations;
ULONG ulTotalOperationsWeight;
cOperations = 1 // one for XML setup
+ m->cDisks; // plus one per disk
if (m->ulTotalDisksMB)
{
m->ulWeightForXmlOperation = (ULONG)((double)m->ulTotalDisksMB * 1 / 100); // use 1% of the progress for the XML
ulTotalOperationsWeight = m->ulTotalDisksMB + m->ulWeightForXmlOperation;
}
else
{
// no disks to export:
m->ulWeightForXmlOperation = 1;
ulTotalOperationsWeight = 1;
}
switch (mode)
{
case ImportFile:
{
break;
}
case WriteFile:
{
// assume that creating the manifest will take .1% of the time it takes to export the disks
if (m->fManifest)
{
++cOperations; // another one for creating the manifest
m->ulWeightForManifestOperation = (ULONG)((double)m->ulTotalDisksMB * .1 / 100); // use .5% of the progress for the manifest
ulTotalOperationsWeight += m->ulWeightForManifestOperation;
}
break;
}
case ImportS3:
{
cOperations += 1 + 1; // another one for the manifest file & another one for the import
ulTotalOperationsWeight = m->ulTotalDisksMB;
if (!m->ulTotalDisksMB)
// no disks to export:
ulTotalOperationsWeight = 1;
ULONG ulImportWeight = (ULONG)((double)ulTotalOperationsWeight * 50 / 100); // use 50% for import
ulTotalOperationsWeight += ulImportWeight;
m->ulWeightForXmlOperation = ulImportWeight; /* save for using later */
ULONG ulInitWeight = (ULONG)((double)ulTotalOperationsWeight * 0.1 / 100); // use 0.1% for init
ulTotalOperationsWeight += ulInitWeight;
break;
}
case WriteS3:
{
cOperations += 1 + 1; // another one for the mf & another one for temporary creation
if (m->ulTotalDisksMB)
{
m->ulWeightForXmlOperation = (ULONG)((double)m->ulTotalDisksMB * 1 / 100); // use 1% of the progress for OVF file upload (we didn't know the size at this point)
ulTotalOperationsWeight = m->ulTotalDisksMB + m->ulWeightForXmlOperation;
}
else
{
// no disks to export:
ulTotalOperationsWeight = 1;
m->ulWeightForXmlOperation = 1;
}
ULONG ulOVFCreationWeight = (ULONG)((double)ulTotalOperationsWeight * 50.0 / 100.0); /* Use 50% for the creation of the OVF & the disks */
ulTotalOperationsWeight += ulOVFCreationWeight;
break;
}
}
Log(("Setting up progress object: ulTotalMB = %d, cDisks = %d, => cOperations = %d, ulTotalOperationsWeight = %d, m->ulWeightForXmlOperation = %d\n",
m->ulTotalDisksMB, m->cDisks, cOperations, ulTotalOperationsWeight, m->ulWeightForXmlOperation));
rc = pProgress->init(mVirtualBox, static_cast<IAppliance*>(this),
bstrDescription.raw(),
TRUE /* aCancelable */,
cOperations, // ULONG cOperations,
ulTotalOperationsWeight, // ULONG ulTotalOperationsWeight,
bstrDescription.raw(), // CBSTR bstrFirstOperationDescription,
m->ulWeightForXmlOperation); // ULONG ulFirstOperationWeight,
return rc;
}
/**
* Called from the import and export background threads to synchronize the second
* background disk thread's progress object with the current progress object so
* that the user interface sees progress correctly and that cancel signals are
* passed on to the second thread.
* @param pProgressThis Progress object of the current thread.
* @param pProgressAsync Progress object of asynchronous task running in background.
*/
void Appliance::i_waitForAsyncProgress(ComObjPtr<Progress> &pProgressThis,
ComPtr<IProgress> &pProgressAsync)
{
HRESULT rc;
// now loop until the asynchronous operation completes and then report its result
BOOL fCompleted;
BOOL fCanceled;
ULONG currentPercent;
ULONG cOp = 0;
while (SUCCEEDED(pProgressAsync->COMGETTER(Completed(&fCompleted))))
{
rc = pProgressThis->COMGETTER(Canceled)(&fCanceled);
if (FAILED(rc)) throw rc;
if (fCanceled)
pProgressAsync->Cancel();
/* Check if the current operation has changed. It is also possible
that in the meantime more than one async operation was finished. So
we have to loop as long as we reached the same operation count. */
ULONG curOp;
for (;;)
{
rc = pProgressAsync->COMGETTER(Operation(&curOp));
if (FAILED(rc)) throw rc;
if (cOp != curOp)
{
Bstr bstr;
ULONG currentWeight;
rc = pProgressAsync->COMGETTER(OperationDescription(bstr.asOutParam()));
if (FAILED(rc)) throw rc;
rc = pProgressAsync->COMGETTER(OperationWeight(&currentWeight));
if (FAILED(rc)) throw rc;
rc = pProgressThis->SetNextOperation(bstr.raw(), currentWeight);
if (FAILED(rc)) throw rc;
++cOp;
}
else
break;
}
rc = pProgressAsync->COMGETTER(OperationPercent(&currentPercent));
if (FAILED(rc)) throw rc;
pProgressThis->SetCurrentOperationProgress(currentPercent);
if (fCompleted)
break;
/* Make sure the loop is not too tight */
rc = pProgressAsync->WaitForCompletion(100);
if (FAILED(rc)) throw rc;
}
// report result of asynchronous operation
LONG iRc;
rc = pProgressAsync->COMGETTER(ResultCode)(&iRc);
if (FAILED(rc)) throw rc;
// if the thread of the progress object has an error, then
// retrieve the error info from there, or it'll be lost
if (FAILED(iRc))
{
ProgressErrorInfo info(pProgressAsync);
Utf8Str str(info.getText());
const char *pcsz = str.c_str();
HRESULT rc2 = setError(iRc, pcsz);
throw rc2;
}
}
void Appliance::i_addWarning(const char* aWarning, ...)
{
va_list args;
va_start(args, aWarning);
Utf8Str str(aWarning, args);
va_end(args);
m->llWarnings.push_back(str);
}
/**
* Refreshes the cDisks and ulTotalDisksMB members in the instance data.
* Requires that virtual system descriptions are present.
*/
void Appliance::i_disksWeight()
{
m->ulTotalDisksMB = 0;
m->cDisks = 0;
// weigh the disk images according to their sizes
list< ComObjPtr<VirtualSystemDescription> >::const_iterator it;
for (it = m->virtualSystemDescriptions.begin();
it != m->virtualSystemDescriptions.end();
++it)
{
ComObjPtr<VirtualSystemDescription> vsdescThis = (*it);
/* One for every hard disk of the Virtual System */
std::list<VirtualSystemDescriptionEntry*> avsdeHDs = vsdescThis->i_findByType(VirtualSystemDescriptionType_HardDiskImage);
std::list<VirtualSystemDescriptionEntry*>::const_iterator itH;
for (itH = avsdeHDs.begin();
itH != avsdeHDs.end();
++itH)
{
const VirtualSystemDescriptionEntry *pHD = *itH;
m->ulTotalDisksMB += pHD->ulSizeMB;
++m->cDisks;
}
avsdeHDs = vsdescThis->i_findByType(VirtualSystemDescriptionType_CDROM);
for (itH = avsdeHDs.begin();
itH != avsdeHDs.end();
++itH)
{
const VirtualSystemDescriptionEntry *pHD = *itH;
m->ulTotalDisksMB += pHD->ulSizeMB;
++m->cDisks;
}
}
}
void Appliance::i_parseBucket(Utf8Str &aPath, Utf8Str &aBucket)
{
/* Buckets are S3 specific. So parse the bucket out of the file path */
if (!aPath.startsWith("/"))
throw setError(E_INVALIDARG,
tr("The path '%s' must start with /"), aPath.c_str());
size_t bpos = aPath.find("/", 1);
if (bpos != Utf8Str::npos)
{
aBucket = aPath.substr(1, bpos - 1); /* The bucket without any slashes */
aPath = aPath.substr(bpos); /* The rest of the file path */
}
/* If there is no bucket name provided reject it */
if (aBucket.isEmpty())
throw setError(E_INVALIDARG,
tr("You doesn't provide a bucket name in the URI '%s'"), aPath.c_str());
}
/**
*
* @return
*/
int Appliance::TaskOVF::startThread()
{
int vrc = RTThreadCreate(NULL, Appliance::i_taskThreadImportOrExport, this,
0, RTTHREADTYPE_MAIN_HEAVY_WORKER, 0,
"Appliance::Task");
if (RT_FAILURE(vrc))
return Appliance::i_setErrorStatic(E_FAIL,
Utf8StrFmt("Could not create OVF task thread (%Rrc)\n", vrc));
return S_OK;
}
/**
* Thread function for the thread started in Appliance::readImpl() and Appliance::importImpl()
* and Appliance::writeImpl().
* This will in turn call Appliance::readFS() or Appliance::readS3() or Appliance::importFS()
* or Appliance::importS3() or Appliance::writeFS() or Appliance::writeS3().
*
* @param aThread
* @param pvUser
*/
/* static */
DECLCALLBACK(int) Appliance::i_taskThreadImportOrExport(RTTHREAD /* aThread */, void *pvUser)
{
std::auto_ptr<TaskOVF> task(static_cast<TaskOVF*>(pvUser));
AssertReturn(task.get(), VERR_GENERAL_FAILURE);
Appliance *pAppliance = task->pAppliance;
LogFlowFuncEnter();
LogFlowFunc(("Appliance %p\n", pAppliance));
HRESULT taskrc = S_OK;
switch (task->taskType)
{
case TaskOVF::Read:
if (task->locInfo.storageType == VFSType_File)
taskrc = pAppliance->i_readFS(task.get());
else if (task->locInfo.storageType == VFSType_S3)
#ifdef VBOX_WITH_S3
taskrc = pAppliance->i_readS3(task.get());
#else
taskrc = VERR_NOT_IMPLEMENTED;
#endif
break;
case TaskOVF::Import:
if (task->locInfo.storageType == VFSType_File)
taskrc = pAppliance->i_importFS(task.get());
else if (task->locInfo.storageType == VFSType_S3)
#ifdef VBOX_WITH_S3
taskrc = pAppliance->i_importS3(task.get());
#else
taskrc = VERR_NOT_IMPLEMENTED;
#endif
break;
case TaskOVF::Write:
if (task->locInfo.storageType == VFSType_File)
taskrc = pAppliance->i_writeFS(task.get());
else if (task->locInfo.storageType == VFSType_S3)
#ifdef VBOX_WITH_S3
taskrc = pAppliance->i_writeS3(task.get());
#else
taskrc = VERR_NOT_IMPLEMENTED;
#endif
break;
}
task->rc = taskrc;
if (!task->pProgress.isNull())
task->pProgress->notifyComplete(taskrc);
LogFlowFuncLeave();
return VINF_SUCCESS;
}
/* static */
int Appliance::TaskOVF::updateProgress(unsigned uPercent, void *pvUser)
{
Appliance::TaskOVF* pTask = *(Appliance::TaskOVF**)pvUser;
if ( pTask
&& !pTask->pProgress.isNull())
{
BOOL fCanceled;
pTask->pProgress->COMGETTER(Canceled)(&fCanceled);
if (fCanceled)
return -1;
pTask->pProgress->SetCurrentOperationProgress(uPercent);
}
return VINF_SUCCESS;
}
void i_parseURI(Utf8Str strUri, LocationInfo &locInfo)
{
/* Check the URI for the protocol */
if (strUri.startsWith("file://", Utf8Str::CaseInsensitive)) /* File based */
{
locInfo.storageType = VFSType_File;
strUri = strUri.substr(sizeof("file://") - 1);
}
else if (strUri.startsWith("SunCloud://", Utf8Str::CaseInsensitive)) /* Sun Cloud service */
{
locInfo.storageType = VFSType_S3;
strUri = strUri.substr(sizeof("SunCloud://") - 1);
}
else if (strUri.startsWith("S3://", Utf8Str::CaseInsensitive)) /* S3 service */
{
locInfo.storageType = VFSType_S3;
strUri = strUri.substr(sizeof("S3://") - 1);
}
else if (strUri.startsWith("webdav://", Utf8Str::CaseInsensitive)) /* webdav service */
throw E_NOTIMPL;
/* Not necessary on a file based URI */
if (locInfo.storageType != VFSType_File)
{
size_t uppos = strUri.find("@"); /* username:password combo */
if (uppos != Utf8Str::npos)
{
locInfo.strUsername = strUri.substr(0, uppos);
strUri = strUri.substr(uppos + 1);
size_t upos = locInfo.strUsername.find(":");
if (upos != Utf8Str::npos)
{
locInfo.strPassword = locInfo.strUsername.substr(upos + 1);
locInfo.strUsername = locInfo.strUsername.substr(0, upos);
}
}
size_t hpos = strUri.find("/"); /* hostname part */
if (hpos != Utf8Str::npos)
{
locInfo.strHostname = strUri.substr(0, hpos);
strUri = strUri.substr(hpos);
}
}
locInfo.strPath = strUri;
}
////////////////////////////////////////////////////////////////////////////////
//
// IVirtualSystemDescription constructor / destructor
//
////////////////////////////////////////////////////////////////////////////////
/**
* COM initializer.
* @return
*/
HRESULT VirtualSystemDescription::init()
{
/* Enclose the state transition NotReady->InInit->Ready */
AutoInitSpan autoInitSpan(this);
AssertReturn(autoInitSpan.isOk(), E_FAIL);
/* Initialize data */
m = new Data();
m->pConfig = NULL;
/* Confirm a successful initialization */
autoInitSpan.setSucceeded();
return S_OK;
}
/**
* COM uninitializer.
*/
void VirtualSystemDescription::uninit()
{
if (m->pConfig)
delete m->pConfig;
delete m;
m = NULL;
}
////////////////////////////////////////////////////////////////////////////////
//
// IVirtualSystemDescription public methods
//
////////////////////////////////////////////////////////////////////////////////
/**
* Public method implementation.
* @param
* @return
*/
HRESULT VirtualSystemDescription::getCount(ULONG *aCount)
{
if (!aCount)
return E_POINTER;
AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
*aCount = (ULONG)m->maDescriptions.size();
return S_OK;
}
/**
* Public method implementation.
* @return
*/
HRESULT VirtualSystemDescription::getDescription(std::vector<VirtualSystemDescriptionType_T> &aTypes,
std::vector<com::Utf8Str> &aRefs,
std::vector<com::Utf8Str> &aOVFValues,
std::vector<com::Utf8Str> &aVBoxValues,
std::vector<com::Utf8Str> &aExtraConfigValues)
{
AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
size_t c = m->maDescriptions.size();
aTypes.resize(c);
aRefs.resize(c);
aOVFValues.resize(c);
aVBoxValues.resize(c);
aExtraConfigValues.resize(c);
for (size_t i = 0; i < c; i++)
{
const VirtualSystemDescriptionEntry &vsde = m->maDescriptions[i];
aTypes[i] = vsde.type;
aRefs[i] = vsde.strRef;
aOVFValues[i] = vsde.strOvf;
aVBoxValues[i] = vsde.strVboxCurrent;
aExtraConfigValues[i] = vsde.strExtraConfigCurrent;
}
return S_OK;
}
/**
* Public method implementation.
* @return
*/
HRESULT VirtualSystemDescription::getDescriptionByType(VirtualSystemDescriptionType_T aType,
std::vector<VirtualSystemDescriptionType_T> &aTypes,
std::vector<com::Utf8Str> &aRefs,
std::vector<com::Utf8Str> &aOVFValues,
std::vector<com::Utf8Str> &aVBoxValues,
std::vector<com::Utf8Str> &aExtraConfigValues)
{
AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
std::list<VirtualSystemDescriptionEntry*> vsd = i_findByType(aType);
size_t c = vsd.size();
aTypes.resize(c);
aRefs.resize(c);
aOVFValues.resize(c);
aVBoxValues.resize(c);
aExtraConfigValues.resize(c);
size_t i = 0;
for (list<VirtualSystemDescriptionEntry*>::const_iterator it = vsd.begin(); it != vsd.end(); ++it, ++i)
{
const VirtualSystemDescriptionEntry *vsde = (*it);
aTypes[i] = vsde->type;
aRefs[i] = vsde->strRef;
aOVFValues[i] = vsde->strOvf;
aVBoxValues[i] = vsde->strVboxCurrent;
aExtraConfigValues[i] = vsde->strExtraConfigCurrent;
}
return S_OK;
}
/**
* Public method implementation.
* @return
*/
HRESULT VirtualSystemDescription::getValuesByType(VirtualSystemDescriptionType_T aType,
VirtualSystemDescriptionValueType_T aWhich,
std::vector<com::Utf8Str> &aValues)
{
AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
std::list<VirtualSystemDescriptionEntry*> vsd = i_findByType (aType);
aValues.resize((ULONG)vsd.size());
list<VirtualSystemDescriptionEntry*>::const_iterator it;
size_t i = 0;
for (it = vsd.begin();
it != vsd.end();
++it, ++i)
{
const VirtualSystemDescriptionEntry *vsde = (*it);
Bstr bstr;
switch (aWhich)
{
case VirtualSystemDescriptionValueType_Reference: aValues[i] = vsde->strRef; break;
case VirtualSystemDescriptionValueType_Original: aValues[i] = vsde->strOvf; break;
case VirtualSystemDescriptionValueType_Auto: aValues[i] = vsde->strVboxCurrent; break;
case VirtualSystemDescriptionValueType_ExtraConfig: aValues[i] = vsde->strExtraConfigCurrent; break;
}
}
return S_OK;
}
/**
* Public method implementation.
* @return
*/
HRESULT VirtualSystemDescription::setFinalValues(const std::vector<BOOL> &aEnabled,
const std::vector<com::Utf8Str> &aVBoxValues,
const std::vector<com::Utf8Str> &aExtraConfigValues)
{
#ifndef RT_OS_WINDOWS
// NOREF(aEnabledSize);
#endif /* RT_OS_WINDOWS */
AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
if ( (aEnabled.size() != m->maDescriptions.size())
|| (aVBoxValues.size() != m->maDescriptions.size())
|| (aExtraConfigValues.size() != m->maDescriptions.size())
)
return E_INVALIDARG;
size_t i = 0;
for (vector<VirtualSystemDescriptionEntry>::iterator it = m->maDescriptions.begin();
it != m->maDescriptions.end();
++it, ++i)
{
VirtualSystemDescriptionEntry& vsde = *it;
if (aEnabled[i])
{
vsde.strVboxCurrent = aVBoxValues[i];
vsde.strExtraConfigCurrent = aExtraConfigValues[i];
}
else
vsde.type = VirtualSystemDescriptionType_Ignore;
}
return S_OK;
}
/**
* Public method implementation.
* @return
*/
HRESULT VirtualSystemDescription::addDescription(VirtualSystemDescriptionType_T aType,
const com::Utf8Str &aVBoxValue,
const com::Utf8Str &aExtraConfigValue)
{
AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
i_addEntry(aType, "", aVBoxValue, aVBoxValue, 0, aExtraConfigValue);
return S_OK;
}
/**
* Internal method; adds a new description item to the member list.
* @param aType Type of description for the new item.
* @param strRef Reference item; only used with hard disk controllers.
* @param aOrigValue Corresponding original value from OVF.
* @param aAutoValue Initial configuration value (can be overridden by caller with setFinalValues).
* @param ulSizeMB Weight for IProgress
* @param strExtraConfig Extra configuration; meaning dependent on type.
*/
void VirtualSystemDescription::i_addEntry(VirtualSystemDescriptionType_T aType,
const Utf8Str &strRef,
const Utf8Str &aOvfValue,
const Utf8Str &aVboxValue,
uint32_t ulSizeMB,
const Utf8Str &strExtraConfig /*= ""*/)
{
VirtualSystemDescriptionEntry vsde;
vsde.ulIndex = (uint32_t)m->maDescriptions.size(); // each entry gets an index so the client side can reference them
vsde.type = aType;
vsde.strRef = strRef;
vsde.strOvf = aOvfValue;
vsde.strVboxSuggested // remember original value
= vsde.strVboxCurrent // and set current value which can be overridden by setFinalValues()
= aVboxValue;
vsde.strExtraConfigSuggested
= vsde.strExtraConfigCurrent
= strExtraConfig;
vsde.ulSizeMB = ulSizeMB;
m->maDescriptions.push_back(vsde);
}
/**
* Private method; returns a list of description items containing all the items from the member
* description items of this virtual system that match the given type.
* @param aType
* @return
*/
std::list<VirtualSystemDescriptionEntry*> VirtualSystemDescription::i_findByType(VirtualSystemDescriptionType_T aType)
{
std::list<VirtualSystemDescriptionEntry*> vsd;
for (vector<VirtualSystemDescriptionEntry>::iterator it = m->maDescriptions.begin();
it != m->maDescriptions.end();
++it)
{
if (it->type == aType)
vsd.push_back(&(*it));
}
return vsd;
}
/* Private method; delete all records from the list
* m->llDescriptions that match the given type.
* @param aType
* @return
*/
void VirtualSystemDescription::i_removeByType(VirtualSystemDescriptionType_T aType)
{
std::vector<VirtualSystemDescriptionEntry>::iterator it = m->maDescriptions.begin();
while (it != m->maDescriptions.end())
{
if (it->type == aType)
it = m->maDescriptions.erase(it);
else
++it;
}
}
/**
* Private method; looks thru the member hardware items for the IDE, SATA, or SCSI controller with
* the given reference ID. Useful when needing the controller for a particular
* virtual disk.
* @param id
* @return
*/
const VirtualSystemDescriptionEntry* VirtualSystemDescription::i_findControllerFromID(uint32_t id)
{
Utf8Str strRef = Utf8StrFmt("%RI32", id);
vector<VirtualSystemDescriptionEntry>::const_iterator it;
for (it = m->maDescriptions.begin();
it != m->maDescriptions.end();
++it)
{
const VirtualSystemDescriptionEntry &d = *it;
switch (d.type)
{
case VirtualSystemDescriptionType_HardDiskControllerIDE:
case VirtualSystemDescriptionType_HardDiskControllerSATA:
case VirtualSystemDescriptionType_HardDiskControllerSCSI:
case VirtualSystemDescriptionType_HardDiskControllerSAS:
if (d.strRef == strRef)
return &d;
break;
}
}
return NULL;
}
/**
* Method called from Appliance::Interpret() if the source OVF for a virtual system
* contains a <vbox:Machine> element. This method then attempts to parse that and
* create a MachineConfigFile instance from it which is stored in this instance data
* and can then be used to create a machine.
*
* This must only be called once per instance.
*
* This rethrows all XML and logic errors from MachineConfigFile.
*
* @param elmMachine <vbox:Machine> element with attributes and subelements from some
* DOM tree.
*/
void VirtualSystemDescription::i_importVboxMachineXML(const xml::ElementNode &elmMachine)
{
settings::MachineConfigFile *pConfig = NULL;
Assert(m->pConfig == NULL);
try
{
pConfig = new settings::MachineConfigFile(NULL);
pConfig->importMachineXML(elmMachine);
m->pConfig = pConfig;
}
catch (...)
{
if (pConfig)
delete pConfig;
throw;
}
}
/**
* Returns the machine config created by importVboxMachineXML() or NULL if there's none.
* @return
*/
const settings::MachineConfigFile* VirtualSystemDescription::i_getMachineConfig() const
{
return m->pConfig;
}