DrvVD.cpp revision a9f41cb889f53e8407561a6155052c441eb0fc5f
af062818b47340eef15700d2f0211576ba3506eevboxsync/* $Id$ */
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @file
af062818b47340eef15700d2f0211576ba3506eevboxsync * DrvVD - Generic VBox disk media driver.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*
af062818b47340eef15700d2f0211576ba3506eevboxsync * Copyright (C) 2006-2010 Sun Microsystems, Inc.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * This file is part of VirtualBox Open Source Edition (OSE), as
af062818b47340eef15700d2f0211576ba3506eevboxsync * available from http://www.virtualbox.org. This file is free software;
af062818b47340eef15700d2f0211576ba3506eevboxsync * you can redistribute it and/or modify it under the terms of the GNU
af062818b47340eef15700d2f0211576ba3506eevboxsync * General Public License (GPL) as published by the Free Software
af062818b47340eef15700d2f0211576ba3506eevboxsync * Foundation, in version 2 as it comes in the "COPYING" file of the
af062818b47340eef15700d2f0211576ba3506eevboxsync * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
af062818b47340eef15700d2f0211576ba3506eevboxsync * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa
af062818b47340eef15700d2f0211576ba3506eevboxsync * Clara, CA 95054 USA or visit http://www.sun.com if you need
b955672b950093ff7416d1269dd4d3b69983bd8fvboxsync * additional information or have any questions.
4b9d6701570cb98fd36e209314239d104ec584d3vboxsync */
4b9d6701570cb98fd36e209314239d104ec584d3vboxsync
b955672b950093ff7416d1269dd4d3b69983bd8fvboxsync
b955672b950093ff7416d1269dd4d3b69983bd8fvboxsync/*******************************************************************************
b955672b950093ff7416d1269dd4d3b69983bd8fvboxsync* Header files *
b955672b950093ff7416d1269dd4d3b69983bd8fvboxsync*******************************************************************************/
b955672b950093ff7416d1269dd4d3b69983bd8fvboxsync#define LOG_GROUP LOG_GROUP_DRV_VD
b955672b950093ff7416d1269dd4d3b69983bd8fvboxsync#include <VBox/VBoxHDD.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <VBox/pdmdrv.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <VBox/pdmasynccompletion.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <iprt/asm.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <iprt/alloc.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <iprt/assert.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <iprt/uuid.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <iprt/file.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <iprt/string.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <iprt/tcp.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <iprt/semaphore.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <iprt/sg.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync#ifdef VBOX_WITH_INIP
af062818b47340eef15700d2f0211576ba3506eevboxsync/* All lwip header files are not C++ safe. So hack around this. */
af062818b47340eef15700d2f0211576ba3506eevboxsyncRT_C_DECLS_BEGIN
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <lwip/inet.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <lwip/tcp.h>
af062818b47340eef15700d2f0211576ba3506eevboxsync#include <lwip/sockets.h>
af062818b47340eef15700d2f0211576ba3506eevboxsyncRT_C_DECLS_END
af062818b47340eef15700d2f0211576ba3506eevboxsync#endif /* VBOX_WITH_INIP */
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync#include "Builtins.h"
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync#ifdef VBOX_WITH_INIP
af062818b47340eef15700d2f0211576ba3506eevboxsync/* Small hack to get at lwIP initialized status */
af062818b47340eef15700d2f0211576ba3506eevboxsyncextern bool DevINIPConfigured(void);
af062818b47340eef15700d2f0211576ba3506eevboxsync#endif /* VBOX_WITH_INIP */
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* Defined types, constants and macros *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** Converts a pointer to VBOXDISK::IMedia to a PVBOXDISK. */
af062818b47340eef15700d2f0211576ba3506eevboxsync#define PDMIMEDIA_2_VBOXDISK(pInterface) \
af062818b47340eef15700d2f0211576ba3506eevboxsync ( (PVBOXDISK)((uintptr_t)pInterface - RT_OFFSETOF(VBOXDISK, IMedia)) )
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** Converts a pointer to PDMDRVINS::IBase to a PPDMDRVINS. */
af062818b47340eef15700d2f0211576ba3506eevboxsync#define PDMIBASE_2_DRVINS(pInterface) \
af062818b47340eef15700d2f0211576ba3506eevboxsync ( (PPDMDRVINS)((uintptr_t)pInterface - RT_OFFSETOF(PDMDRVINS, IBase)) )
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** Converts a pointer to PDMDRVINS::IBase to a PVBOXDISK. */
af062818b47340eef15700d2f0211576ba3506eevboxsync#define PDMIBASE_2_VBOXDISK(pInterface) \
af062818b47340eef15700d2f0211576ba3506eevboxsync ( PDMINS_2_DATA(PDMIBASE_2_DRVINS(pInterface), PVBOXDISK) )
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** Converts a pointer to VBOXDISK::IMediaAsync to a PVBOXDISK. */
af062818b47340eef15700d2f0211576ba3506eevboxsync#define PDMIMEDIAASYNC_2_VBOXDISK(pInterface) \
af062818b47340eef15700d2f0211576ba3506eevboxsync ( (PVBOXDISK)((uintptr_t)pInterface - RT_OFFSETOF(VBOXDISK, IMediaAsync)) )
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * VBox disk container, image information, private part.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsynctypedef struct VBOXIMAGE
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Pointer to next image. */
af062818b47340eef15700d2f0211576ba3506eevboxsync struct VBOXIMAGE *pNext;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Pointer to list of VD interfaces. Per-image. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PVDINTERFACE pVDIfsImage;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Common structure for the configuration information interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACE VDIConfig;
af062818b47340eef15700d2f0211576ba3506eevboxsync} VBOXIMAGE, *PVBOXIMAGE;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * Storage backend data.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsynctypedef struct DRVVDSTORAGEBACKEND
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync /** PDM async completion end point. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PPDMASYNCCOMPLETIONENDPOINT pEndpoint;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** The template. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PPDMASYNCCOMPLETIONTEMPLATE pTemplate;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Event semaphore for synchronous operations. */
af062818b47340eef15700d2f0211576ba3506eevboxsync RTSEMEVENT EventSem;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Flag whether a synchronous operation is currently pending. */
af062818b47340eef15700d2f0211576ba3506eevboxsync volatile bool fSyncIoPending;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Return code of the last completed request. */
af062818b47340eef15700d2f0211576ba3506eevboxsync int rcReqLast;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Callback routine */
af062818b47340eef15700d2f0211576ba3506eevboxsync PFNVDCOMPLETED pfnCompleted;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Pointer to the optional thread synchronization interface of the disk. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PVDINTERFACE pInterfaceThreadSync;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Pointer to the optional thread synchronization callbacks of the disk. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PVDINTERFACETHREADSYNC pInterfaceThreadSyncCallbacks;
af062818b47340eef15700d2f0211576ba3506eevboxsync} DRVVDSTORAGEBACKEND, *PDRVVDSTORAGEBACKEND;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * VBox disk container media main structure, private part.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * @implements PDMIMEDIA
af062818b47340eef15700d2f0211576ba3506eevboxsync * @implements PDMIMEDIAASYNC
af062818b47340eef15700d2f0211576ba3506eevboxsync * @implements VDINTERFACEERROR
af062818b47340eef15700d2f0211576ba3506eevboxsync * @implements VDINTERFACETCPNET
af062818b47340eef15700d2f0211576ba3506eevboxsync * @implements VDINTERFACEASYNCIO
af062818b47340eef15700d2f0211576ba3506eevboxsync * @implements VDINTERFACECONFIG
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsynctypedef struct VBOXDISK
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync /** The VBox disk container. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXHDD pDisk;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** The media interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMIMEDIA IMedia;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Pointer to the driver instance. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PPDMDRVINS pDrvIns;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Flag whether suspend has changed image open mode to read only. */
af062818b47340eef15700d2f0211576ba3506eevboxsync bool fTempReadOnly;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Flag whether to use the runtime (true) or startup error facility. */
af062818b47340eef15700d2f0211576ba3506eevboxsync bool fErrorUseRuntime;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Pointer to list of VD interfaces. Per-disk. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PVDINTERFACE pVDIfsDisk;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Common structure for the supported error interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACE VDIError;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Callback table for error interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACEERROR VDIErrorCallbacks;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Common structure for the supported TCP network stack interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACE VDITcpNet;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Callback table for TCP network stack interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACETCPNET VDITcpNetCallbacks;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Common structure for the supported async I/O interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACE VDIAsyncIO;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Callback table for async I/O interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACEASYNCIO VDIAsyncIOCallbacks;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Common structure for the supported thread synchronization interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACE VDIThreadSync;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Callback table for thread synchronization interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACETHREADSYNC VDIThreadSyncCallbacks;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Callback table for the configuration information interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACECONFIG VDIConfigCallbacks;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Flag whether opened disk suppports async I/O operations. */
af062818b47340eef15700d2f0211576ba3506eevboxsync bool fAsyncIOSupported;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** The async media interface. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMIMEDIAASYNC IMediaAsync;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** The async media port interface above. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PPDMIMEDIAASYNCPORT pDrvMediaAsyncPort;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Pointer to the list of data we need to keep per image. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXIMAGE pImages;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Flag whether a merge operation has been set up. */
af062818b47340eef15700d2f0211576ba3506eevboxsync bool fMergePending;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Synchronization to prevent destruction before merge finishes. */
af062818b47340eef15700d2f0211576ba3506eevboxsync RTSEMFASTMUTEX MergeCompleteMutex;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Synchronization between merge and other image accesses. */
af062818b47340eef15700d2f0211576ba3506eevboxsync RTSEMRW MergeLock;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Source image index for merging. */
af062818b47340eef15700d2f0211576ba3506eevboxsync unsigned uMergeSource;
af062818b47340eef15700d2f0211576ba3506eevboxsync /** Target image index for merging. */
af062818b47340eef15700d2f0211576ba3506eevboxsync unsigned uMergeTarget;
af062818b47340eef15700d2f0211576ba3506eevboxsync} VBOXDISK, *PVBOXDISK;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* Internal Functions *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * Internal: allocate new image descriptor and put it in the list
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic PVBOXIMAGE drvvdNewImage(PVBOXDISK pThis)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertPtr(pThis);
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXIMAGE pImage = (PVBOXIMAGE)RTMemAllocZ(sizeof(VBOXIMAGE));
af062818b47340eef15700d2f0211576ba3506eevboxsync if (pImage)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync pImage->pVDIfsImage = NULL;
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXIMAGE *pp = &pThis->pImages;
af062818b47340eef15700d2f0211576ba3506eevboxsync while (*pp != NULL)
af062818b47340eef15700d2f0211576ba3506eevboxsync pp = &(*pp)->pNext;
af062818b47340eef15700d2f0211576ba3506eevboxsync *pp = pImage;
af062818b47340eef15700d2f0211576ba3506eevboxsync pImage->pNext = NULL;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return pImage;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * Internal: free the list of images descriptors.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic void drvvdFreeImages(PVBOXDISK pThis)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync while (pThis->pImages != NULL)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXIMAGE p = pThis->pImages;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->pImages = pThis->pImages->pNext;
af062818b47340eef15700d2f0211576ba3506eevboxsync RTMemFree(p);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * Make the image temporarily read-only.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * @returns VBox status code.
af062818b47340eef15700d2f0211576ba3506eevboxsync * @param pThis The driver instance data.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic int drvvdSetReadonly(PVBOXDISK pThis)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync if (!VDIsReadOnly(pThis->pDisk))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync unsigned uOpenFlags;
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VDGetOpenFlags(pThis->pDisk, VD_LAST_IMAGE, &uOpenFlags);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync uOpenFlags |= VD_OPEN_FLAGS_READONLY;
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VDSetOpenFlags(pThis->pDisk, VD_LAST_IMAGE, uOpenFlags);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->fTempReadOnly = true;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * Undo the temporary read-only status of the image.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * @returns VBox status code.
af062818b47340eef15700d2f0211576ba3506eevboxsync * @param pThis The driver instance data.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic int drvvdSetWritable(PVBOXDISK pThis)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync if (pThis->fTempReadOnly)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync unsigned uOpenFlags;
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VDGetOpenFlags(pThis->pDisk, VD_LAST_IMAGE, &uOpenFlags);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync uOpenFlags &= ~VD_OPEN_FLAGS_READONLY;
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VDSetOpenFlags(pThis->pDisk, VD_LAST_IMAGE, uOpenFlags);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_SUCCESS(rc))
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->fTempReadOnly = false;
af062818b47340eef15700d2f0211576ba3506eevboxsync else
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* Error reporting callback *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic void drvvdErrorCallback(void *pvUser, int rc, RT_SRC_POS_DECL,
af062818b47340eef15700d2f0211576ba3506eevboxsync const char *pszFormat, va_list va)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PPDMDRVINS pDrvIns = (PPDMDRVINS)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMINS_2_DATA(pDrvIns, PVBOXDISK);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (pThis->fErrorUseRuntime)
af062818b47340eef15700d2f0211576ba3506eevboxsync /* We must not pass VMSETRTERR_FLAGS_FATAL as it could lead to a
af062818b47340eef15700d2f0211576ba3506eevboxsync * deadlock: We are probably executed in a thread context != EMT
af062818b47340eef15700d2f0211576ba3506eevboxsync * and the EM thread would wait until every thread is suspended
af062818b47340eef15700d2f0211576ba3506eevboxsync * but we would wait for the EM thread ... */
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMDrvHlpVMSetRuntimeErrorV(pDrvIns, /* fFlags=*/ 0, "DrvVD", pszFormat, va);
af062818b47340eef15700d2f0211576ba3506eevboxsync else
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMDrvHlpVMSetErrorV(pDrvIns, rc, RT_SRC_POS_ARGS, pszFormat, va);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* VD Async I/O interface implementation *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync#ifdef VBOX_WITH_PDM_ASYNC_COMPLETION
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(void) drvvdAsyncTaskCompleted(PPDMDRVINS pDrvIns, void *pvTemplateUser, void *pvUser, int rcReq)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMINS_2_DATA(pDrvIns, PVBOXDISK);
af062818b47340eef15700d2f0211576ba3506eevboxsync PDRVVDSTORAGEBACKEND pStorageBackend = (PDRVVDSTORAGEBACKEND)pvTemplateUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync if (pStorageBackend->fSyncIoPending)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync pStorageBackend->rcReqLast = rcReq;
af062818b47340eef15700d2f0211576ba3506eevboxsync pStorageBackend->fSyncIoPending = false;
af062818b47340eef15700d2f0211576ba3506eevboxsync RTSemEventSignal(pStorageBackend->EventSem);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync else
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertPtr(pStorageBackend->pfnCompleted);
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = pStorageBackend->pfnCompleted(pvUser);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /* If thread synchronization is active, then signal the end of the
af062818b47340eef15700d2f0211576ba3506eevboxsync * this disk read/write operation. */
af062818b47340eef15700d2f0211576ba3506eevboxsync /** @todo provide a way to determine the type of task (read/write)
af062818b47340eef15700d2f0211576ba3506eevboxsync * which was completed, see also VBoxHDD.cpp. */
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_UNLIKELY(pStorageBackend->pInterfaceThreadSyncCallbacks))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc2 = pStorageBackend->pInterfaceThreadSyncCallbacks->pfnFinishWrite(pStorageBackend->pInterfaceThreadSync->pvUser);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc2);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdAsyncIOOpen(void *pvUser, const char *pszLocation,
af062818b47340eef15700d2f0211576ba3506eevboxsync unsigned uOpenFlags,
af062818b47340eef15700d2f0211576ba3506eevboxsync PFNVDCOMPLETED pfnCompleted,
af062818b47340eef15700d2f0211576ba3506eevboxsync PVDINTERFACE pVDIfsDisk,
af062818b47340eef15700d2f0211576ba3506eevboxsync void **ppStorage)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync PDRVVDSTORAGEBACKEND pStorageBackend = (PDRVVDSTORAGEBACKEND)RTMemAllocZ(sizeof(DRVVDSTORAGEBACKEND));
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync if (pStorageBackend)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync pStorageBackend->fSyncIoPending = false;
af062818b47340eef15700d2f0211576ba3506eevboxsync pStorageBackend->rcReqLast = VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync pStorageBackend->pfnCompleted = pfnCompleted;
af062818b47340eef15700d2f0211576ba3506eevboxsync pStorageBackend->pInterfaceThreadSync = NULL;
af062818b47340eef15700d2f0211576ba3506eevboxsync pStorageBackend->pInterfaceThreadSyncCallbacks = NULL;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync pStorageBackend->pInterfaceThreadSync = VDInterfaceGet(pVDIfsDisk, VDINTERFACETYPE_THREADSYNC);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_UNLIKELY(pStorageBackend->pInterfaceThreadSync))
af062818b47340eef15700d2f0211576ba3506eevboxsync pStorageBackend->pInterfaceThreadSyncCallbacks = VDGetInterfaceThreadSync(pStorageBackend->pInterfaceThreadSync);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = RTSemEventCreate(&pStorageBackend->EventSem);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_SUCCESS(rc))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = PDMDrvHlpPDMAsyncCompletionTemplateCreate(pThis->pDrvIns, &pStorageBackend->pTemplate,
af062818b47340eef15700d2f0211576ba3506eevboxsync drvvdAsyncTaskCompleted, pStorageBackend, "AsyncTaskCompleted");
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_SUCCESS(rc))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = PDMR3AsyncCompletionEpCreateForFile(&pStorageBackend->pEndpoint, pszLocation,
af062818b47340eef15700d2f0211576ba3506eevboxsync uOpenFlags & VD_INTERFACEASYNCIO_OPEN_FLAGS_READONLY
af062818b47340eef15700d2f0211576ba3506eevboxsync ? PDMACEP_FILE_FLAGS_READ_ONLY | PDMACEP_FILE_FLAGS_CACHING
af062818b47340eef15700d2f0211576ba3506eevboxsync : PDMACEP_FILE_FLAGS_CACHING,
af062818b47340eef15700d2f0211576ba3506eevboxsync pStorageBackend->pTemplate);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_SUCCESS(rc))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync *ppStorage = pStorageBackend;
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMR3AsyncCompletionTemplateDestroy(pStorageBackend->pTemplate);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync RTSemEventDestroy(pStorageBackend->EventSem);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync RTMemFree(pStorageBackend);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync else
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VERR_NO_MEMORY;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdAsyncIOClose(void *pvUser, void *pStorage)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync PDRVVDSTORAGEBACKEND pStorageBackend = (PDRVVDSTORAGEBACKEND)pStorage;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMR3AsyncCompletionEpClose(pStorageBackend->pEndpoint);
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMR3AsyncCompletionTemplateDestroy(pStorageBackend->pTemplate);
af062818b47340eef15700d2f0211576ba3506eevboxsync RTSemEventDestroy(pStorageBackend->EventSem);
af062818b47340eef15700d2f0211576ba3506eevboxsync RTMemFree(pStorageBackend);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS;;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdAsyncIOReadSync(void *pvUser, void *pStorage, uint64_t uOffset,
af062818b47340eef15700d2f0211576ba3506eevboxsync size_t cbRead, void *pvBuf, size_t *pcbRead)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync PDRVVDSTORAGEBACKEND pStorageBackend = (PDRVVDSTORAGEBACKEND)pStorage;
af062818b47340eef15700d2f0211576ba3506eevboxsync RTSGSEG DataSeg;
af062818b47340eef15700d2f0211576ba3506eevboxsync PPDMASYNCCOMPLETIONTASK pTask;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync Assert(!pStorageBackend->fSyncIoPending);
af062818b47340eef15700d2f0211576ba3506eevboxsync ASMAtomicXchgBool(&pStorageBackend->fSyncIoPending, true);
af062818b47340eef15700d2f0211576ba3506eevboxsync DataSeg.cbSeg = cbRead;
af062818b47340eef15700d2f0211576ba3506eevboxsync DataSeg.pvSeg = pvBuf;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = PDMR3AsyncCompletionEpRead(pStorageBackend->pEndpoint, uOffset, &DataSeg, 1, cbRead, NULL, &pTask);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_FAILURE(rc))
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync if (rc == VINF_AIO_TASK_PENDING)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Wait */
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = RTSemEventWait(pStorageBackend->EventSem, RT_INDEFINITE_WAIT);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync else
af062818b47340eef15700d2f0211576ba3506eevboxsync ASMAtomicXchgBool(&pStorageBackend->fSyncIoPending, false);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync if (pcbRead)
af062818b47340eef15700d2f0211576ba3506eevboxsync *pcbRead = cbRead;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return pStorageBackend->rcReqLast;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdAsyncIOWriteSync(void *pvUser, void *pStorage, uint64_t uOffset,
af062818b47340eef15700d2f0211576ba3506eevboxsync size_t cbWrite, const void *pvBuf, size_t *pcbWritten)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync PDRVVDSTORAGEBACKEND pStorageBackend = (PDRVVDSTORAGEBACKEND)pStorage;
af062818b47340eef15700d2f0211576ba3506eevboxsync RTSGSEG DataSeg;
af062818b47340eef15700d2f0211576ba3506eevboxsync PPDMASYNCCOMPLETIONTASK pTask;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync Assert(!pStorageBackend->fSyncIoPending);
af062818b47340eef15700d2f0211576ba3506eevboxsync ASMAtomicXchgBool(&pStorageBackend->fSyncIoPending, true);
af062818b47340eef15700d2f0211576ba3506eevboxsync DataSeg.cbSeg = cbWrite;
af062818b47340eef15700d2f0211576ba3506eevboxsync DataSeg.pvSeg = (void *)pvBuf;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = PDMR3AsyncCompletionEpWrite(pStorageBackend->pEndpoint, uOffset, &DataSeg, 1, cbWrite, NULL, &pTask);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_FAILURE(rc))
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync if (rc == VINF_AIO_TASK_PENDING)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Wait */
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = RTSemEventWait(pStorageBackend->EventSem, RT_INDEFINITE_WAIT);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync else
af062818b47340eef15700d2f0211576ba3506eevboxsync ASMAtomicXchgBool(&pStorageBackend->fSyncIoPending, false);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync if (pcbWritten)
af062818b47340eef15700d2f0211576ba3506eevboxsync *pcbWritten = cbWrite;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return pStorageBackend->rcReqLast;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdAsyncIOFlushSync(void *pvUser, void *pStorage)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync PDRVVDSTORAGEBACKEND pStorageBackend = (PDRVVDSTORAGEBACKEND)pStorage;
af062818b47340eef15700d2f0211576ba3506eevboxsync PPDMASYNCCOMPLETIONTASK pTask;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync Assert(!pStorageBackend->fSyncIoPending);
af062818b47340eef15700d2f0211576ba3506eevboxsync ASMAtomicXchgBool(&pStorageBackend->fSyncIoPending, true);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = PDMR3AsyncCompletionEpFlush(pStorageBackend->pEndpoint, NULL, &pTask);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_FAILURE(rc))
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync if (rc == VINF_AIO_TASK_PENDING)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Wait */
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = RTSemEventWait(pStorageBackend->EventSem, RT_INDEFINITE_WAIT);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync else
af062818b47340eef15700d2f0211576ba3506eevboxsync ASMAtomicXchgBool(&pStorageBackend->fSyncIoPending, false);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return pStorageBackend->rcReqLast;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdAsyncIOReadAsync(void *pvUser, void *pStorage, uint64_t uOffset,
af062818b47340eef15700d2f0211576ba3506eevboxsync PCRTSGSEG paSegments, size_t cSegments,
af062818b47340eef15700d2f0211576ba3506eevboxsync size_t cbRead, void *pvCompletion,
af062818b47340eef15700d2f0211576ba3506eevboxsync void **ppTask)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync PDRVVDSTORAGEBACKEND pStorageBackend = (PDRVVDSTORAGEBACKEND)pStorage;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = PDMR3AsyncCompletionEpRead(pStorageBackend->pEndpoint, uOffset, paSegments, cSegments, cbRead,
af062818b47340eef15700d2f0211576ba3506eevboxsync pvCompletion, (PPPDMASYNCCOMPLETIONTASK)ppTask);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (rc == VINF_AIO_TASK_PENDING)
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VERR_VD_ASYNC_IO_IN_PROGRESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdAsyncIOWriteAsync(void *pvUser, void *pStorage, uint64_t uOffset,
af062818b47340eef15700d2f0211576ba3506eevboxsync PCRTSGSEG paSegments, size_t cSegments,
af062818b47340eef15700d2f0211576ba3506eevboxsync size_t cbWrite, void *pvCompletion,
af062818b47340eef15700d2f0211576ba3506eevboxsync void **ppTask)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync PDRVVDSTORAGEBACKEND pStorageBackend = (PDRVVDSTORAGEBACKEND)pStorage;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = PDMR3AsyncCompletionEpWrite(pStorageBackend->pEndpoint, uOffset, paSegments, cSegments, cbWrite,
af062818b47340eef15700d2f0211576ba3506eevboxsync pvCompletion, (PPPDMASYNCCOMPLETIONTASK)ppTask);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (rc == VINF_AIO_TASK_PENDING)
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VERR_VD_ASYNC_IO_IN_PROGRESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdAsyncIOFlushAsync(void *pvUser, void *pStorage,
af062818b47340eef15700d2f0211576ba3506eevboxsync void *pvCompletion, void **ppTask)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync PDRVVDSTORAGEBACKEND pStorageBackend = (PDRVVDSTORAGEBACKEND)pStorage;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = PDMR3AsyncCompletionEpFlush(pStorageBackend->pEndpoint, pvCompletion,
af062818b47340eef15700d2f0211576ba3506eevboxsync (PPPDMASYNCCOMPLETIONTASK)ppTask);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (rc == VINF_AIO_TASK_PENDING)
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VERR_VD_ASYNC_IO_IN_PROGRESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdAsyncIOGetSize(void *pvUser, void *pStorage, uint64_t *pcbSize)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pDrvVD = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync PDRVVDSTORAGEBACKEND pStorageBackend = (PDRVVDSTORAGEBACKEND)pStorage;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return PDMR3AsyncCompletionEpGetSize(pStorageBackend->pEndpoint, pcbSize);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdAsyncIOSetSize(void *pvUser, void *pStorage, uint64_t cbSize)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pDrvVD = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync PDRVVDSTORAGEBACKEND pStorageBackend = (PDRVVDSTORAGEBACKEND)pStorage;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = drvvdAsyncIOFlushSync(pvUser, pStorage);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_SUCCESS(rc))
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = PDMR3AsyncCompletionEpSetSize(pStorageBackend->pEndpoint, cbSize);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync#endif /* VBOX_WITH_PDM_ASYNC_COMPLETION */
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* VD Thread Synchronization interface implementation *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdThreadStartRead(void *pvUser)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return RTSemRWRequestRead(pThis->MergeLock, RT_INDEFINITE_WAIT);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdThreadFinishRead(void *pvUser)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return RTSemRWReleaseRead(pThis->MergeLock);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdThreadStartWrite(void *pvUser)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return RTSemRWRequestWrite(pThis->MergeLock, RT_INDEFINITE_WAIT);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdThreadFinishWrite(void *pvUser)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return RTSemRWReleaseWrite(pThis->MergeLock);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* VD Configuration interface implementation *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic bool drvvdCfgAreKeysValid(void *pvUser, const char *pszzValid)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync return CFGMR3AreValuesValid((PCFGMNODE)pvUser, pszzValid);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic int drvvdCfgQuerySize(void *pvUser, const char *pszName, size_t *pcb)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync return CFGMR3QuerySize((PCFGMNODE)pvUser, pszName, pcb);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic int drvvdCfgQuery(void *pvUser, const char *pszName, char *pszString, size_t cchString)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync return CFGMR3QueryString((PCFGMNODE)pvUser, pszName, pszString, cchString);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync#ifdef VBOX_WITH_INIP
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* VD TCP network stack interface implementation - INIP case *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc VDINTERFACETCPNET::pfnClientConnect */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdINIPClientConnect(const char *pszAddress, uint32_t uPort, PRTSOCKET pSock)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync /* First check whether lwIP is set up in this VM instance. */
af062818b47340eef15700d2f0211576ba3506eevboxsync if (!DevINIPConfigured())
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync LogRelFunc(("no IP stack\n"));
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_NET_HOST_UNREACHABLE;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Resolve hostname. As there is no standard resolver for lwIP yet,
af062818b47340eef15700d2f0211576ba3506eevboxsync * just accept numeric IP addresses for now. */
af062818b47340eef15700d2f0211576ba3506eevboxsync struct in_addr ip;
af062818b47340eef15700d2f0211576ba3506eevboxsync if (!lwip_inet_aton(pszAddress, &ip))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync LogRelFunc(("cannot resolve IP %s\n", pszAddress));
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_NET_HOST_UNREACHABLE;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Create socket and connect. */
af062818b47340eef15700d2f0211576ba3506eevboxsync RTSOCKET Sock = lwip_socket(PF_INET, SOCK_STREAM, 0);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (Sock != -1)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync struct sockaddr_in InAddr = {0};
af062818b47340eef15700d2f0211576ba3506eevboxsync InAddr.sin_family = AF_INET;
af062818b47340eef15700d2f0211576ba3506eevboxsync InAddr.sin_port = htons(uPort);
af062818b47340eef15700d2f0211576ba3506eevboxsync InAddr.sin_addr = ip;
af062818b47340eef15700d2f0211576ba3506eevboxsync if (!lwip_connect(Sock, (struct sockaddr *)&InAddr, sizeof(InAddr)))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync *pSock = Sock;
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VERR_NET_CONNECTION_REFUSED; /* @todo real solution needed */
af062818b47340eef15700d2f0211576ba3506eevboxsync lwip_close(Sock);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync else
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VERR_NET_CONNECTION_REFUSED; /* @todo real solution needed */
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc VDINTERFACETCPNET::pfnClientClose */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdINIPClientClose(RTSOCKET Sock)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync lwip_close(Sock);
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS; /** @todo real solution needed */
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc VDINTERFACETCPNET::pfnSelectOne */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdINIPSelectOne(RTSOCKET Sock, RTMSINTERVAL cMillies)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync fd_set fdsetR;
af062818b47340eef15700d2f0211576ba3506eevboxsync FD_ZERO(&fdsetR);
af062818b47340eef15700d2f0211576ba3506eevboxsync FD_SET(Sock, &fdsetR);
af062818b47340eef15700d2f0211576ba3506eevboxsync fd_set fdsetE = fdsetR;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync if (cMillies == RT_INDEFINITE_WAIT)
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = lwip_select(Sock + 1, &fdsetR, NULL, &fdsetE, NULL);
af062818b47340eef15700d2f0211576ba3506eevboxsync else
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync struct timeval timeout;
af062818b47340eef15700d2f0211576ba3506eevboxsync timeout.tv_sec = cMillies / 1000;
af062818b47340eef15700d2f0211576ba3506eevboxsync timeout.tv_usec = (cMillies % 1000) * 1000;
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = lwip_select(Sock + 1, &fdsetR, NULL, &fdsetE, &timeout);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync if (rc > 0)
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync if (rc == 0)
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_TIMEOUT;
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_NET_CONNECTION_REFUSED; /** @todo real solution needed */
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc VDINTERFACETCPNET::pfnRead */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdINIPRead(RTSOCKET Sock, void *pvBuffer, size_t cbBuffer, size_t *pcbRead)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Do params checking */
af062818b47340eef15700d2f0211576ba3506eevboxsync if (!pvBuffer || !cbBuffer)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertMsgFailed(("Invalid params\n"));
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_INVALID_PARAMETER;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /*
af062818b47340eef15700d2f0211576ba3506eevboxsync * Read loop.
af062818b47340eef15700d2f0211576ba3506eevboxsync * If pcbRead is NULL we have to fill the entire buffer!
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsync size_t cbRead = 0;
af062818b47340eef15700d2f0211576ba3506eevboxsync size_t cbToRead = cbBuffer;
af062818b47340eef15700d2f0211576ba3506eevboxsync for (;;)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync /** @todo this clipping here is just in case (the send function
af062818b47340eef15700d2f0211576ba3506eevboxsync * needed it, so I added it here, too). Didn't investigate if this
af062818b47340eef15700d2f0211576ba3506eevboxsync * really has issues. Better be safe than sorry. */
af062818b47340eef15700d2f0211576ba3506eevboxsync ssize_t cbBytesRead = lwip_recv(Sock, (char *)pvBuffer + cbRead,
af062818b47340eef15700d2f0211576ba3506eevboxsync RT_MIN(cbToRead, 32768), 0);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (cbBytesRead < 0)
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_NET_CONNECTION_REFUSED; /** @todo real solution */
af062818b47340eef15700d2f0211576ba3506eevboxsync if (cbBytesRead == 0 && errno)
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_NET_CONNECTION_REFUSED; /** @todo real solution */
af062818b47340eef15700d2f0211576ba3506eevboxsync if (pcbRead)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync /* return partial data */
af062818b47340eef15700d2f0211576ba3506eevboxsync *pcbRead = cbBytesRead;
af062818b47340eef15700d2f0211576ba3506eevboxsync break;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /* read more? */
af062818b47340eef15700d2f0211576ba3506eevboxsync cbRead += cbBytesRead;
af062818b47340eef15700d2f0211576ba3506eevboxsync if (cbRead == cbBuffer)
af062818b47340eef15700d2f0211576ba3506eevboxsync break;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /* next */
af062818b47340eef15700d2f0211576ba3506eevboxsync cbToRead = cbBuffer - cbRead;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc VDINTERFACETCPNET::pfnWrite */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdINIPWrite(RTSOCKET Sock, const void *pvBuffer, size_t cbBuffer)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync do
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync /** @todo lwip send only supports up to 65535 bytes in a single
af062818b47340eef15700d2f0211576ba3506eevboxsync * send (stupid limitation buried in the code), so make sure we
af062818b47340eef15700d2f0211576ba3506eevboxsync * don't get any wraparounds. This should be moved to DevINIP
af062818b47340eef15700d2f0211576ba3506eevboxsync * stack interface once that's implemented. */
af062818b47340eef15700d2f0211576ba3506eevboxsync ssize_t cbWritten = lwip_send(Sock, (void *)pvBuffer,
af062818b47340eef15700d2f0211576ba3506eevboxsync RT_MIN(cbBuffer, 32768), 0);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (cbWritten < 0)
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_NET_CONNECTION_REFUSED; /** @todo real solution needed */
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertMsg(cbBuffer >= (size_t)cbWritten, ("Wrote more than we requested!!! cbWritten=%d cbBuffer=%d\n",
af062818b47340eef15700d2f0211576ba3506eevboxsync cbWritten, cbBuffer));
af062818b47340eef15700d2f0211576ba3506eevboxsync cbBuffer -= cbWritten;
af062818b47340eef15700d2f0211576ba3506eevboxsync pvBuffer = (const char *)pvBuffer + cbWritten;
af062818b47340eef15700d2f0211576ba3506eevboxsync } while (cbBuffer);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc VDINTERFACETCPNET::pfnFlush */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdINIPFlush(RTSOCKET Sock)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync int fFlag = 1;
af062818b47340eef15700d2f0211576ba3506eevboxsync lwip_setsockopt(Sock, IPPROTO_TCP, TCP_NODELAY,
af062818b47340eef15700d2f0211576ba3506eevboxsync (const char *)&fFlag, sizeof(fFlag));
af062818b47340eef15700d2f0211576ba3506eevboxsync fFlag = 0;
af062818b47340eef15700d2f0211576ba3506eevboxsync lwip_setsockopt(Sock, IPPROTO_TCP, TCP_NODELAY,
af062818b47340eef15700d2f0211576ba3506eevboxsync (const char *)&fFlag, sizeof(fFlag));
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc VDINTERFACETCPNET::pfnGetLocalAddress */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdINIPGetLocalAddress(RTSOCKET Sock, PRTNETADDR pAddr)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync union
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync struct sockaddr Addr;
af062818b47340eef15700d2f0211576ba3506eevboxsync struct sockaddr_in Ipv4;
af062818b47340eef15700d2f0211576ba3506eevboxsync } u;
af062818b47340eef15700d2f0211576ba3506eevboxsync socklen_t cbAddr = sizeof(u);
af062818b47340eef15700d2f0211576ba3506eevboxsync RT_ZERO(u);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (!lwip_getsockname(Sock, &u.Addr, &cbAddr))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync /*
af062818b47340eef15700d2f0211576ba3506eevboxsync * Convert the address.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsync if ( cbAddr == sizeof(struct sockaddr_in)
af062818b47340eef15700d2f0211576ba3506eevboxsync && u.Addr.sa_family == AF_INET)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync RT_ZERO(*pAddr);
af062818b47340eef15700d2f0211576ba3506eevboxsync pAddr->enmType = RTNETADDRTYPE_IPV4;
af062818b47340eef15700d2f0211576ba3506eevboxsync pAddr->uPort = RT_N2H_U16(u.Ipv4.sin_port);
af062818b47340eef15700d2f0211576ba3506eevboxsync pAddr->uAddr.IPv4.u = u.Ipv4.sin_addr.s_addr;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync else
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_NET_ADDRESS_FAMILY_NOT_SUPPORTED;
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_NET_OPERATION_NOT_SUPPORTED;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc VDINTERFACETCPNET::pfnGetPeerAddress */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdINIPGetPeerAddress(RTSOCKET Sock, PRTNETADDR pAddr)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync union
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync struct sockaddr Addr;
af062818b47340eef15700d2f0211576ba3506eevboxsync struct sockaddr_in Ipv4;
af062818b47340eef15700d2f0211576ba3506eevboxsync } u;
af062818b47340eef15700d2f0211576ba3506eevboxsync socklen_t cbAddr = sizeof(u);
af062818b47340eef15700d2f0211576ba3506eevboxsync RT_ZERO(u);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (!lwip_getpeername(Sock, &u.Addr, &cbAddr))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync /*
af062818b47340eef15700d2f0211576ba3506eevboxsync * Convert the address.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsync if ( cbAddr == sizeof(struct sockaddr_in)
af062818b47340eef15700d2f0211576ba3506eevboxsync && u.Addr.sa_family == AF_INET)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync RT_ZERO(*pAddr);
af062818b47340eef15700d2f0211576ba3506eevboxsync pAddr->enmType = RTNETADDRTYPE_IPV4;
af062818b47340eef15700d2f0211576ba3506eevboxsync pAddr->uPort = RT_N2H_U16(u.Ipv4.sin_port);
af062818b47340eef15700d2f0211576ba3506eevboxsync pAddr->uAddr.IPv4.u = u.Ipv4.sin_addr.s_addr;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync else
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_NET_ADDRESS_FAMILY_NOT_SUPPORTED;
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync return VERR_NET_OPERATION_NOT_SUPPORTED;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync#endif /* VBOX_WITH_INIP */
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* Media interface methods *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc PDMIMEDIA::pfnRead */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdRead(PPDMIMEDIA pInterface,
af062818b47340eef15700d2f0211576ba3506eevboxsync uint64_t off, void *pvBuf, size_t cbRead)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: off=%#llx pvBuf=%p cbRead=%d\n", __FUNCTION__,
af062818b47340eef15700d2f0211576ba3506eevboxsync off, pvBuf, cbRead));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIA_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VDRead(pThis->pDisk, off, pvBuf, cbRead);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_SUCCESS(rc))
af062818b47340eef15700d2f0211576ba3506eevboxsync Log2(("%s: off=%#llx pvBuf=%p cbRead=%d %.*Rhxd\n", __FUNCTION__,
af062818b47340eef15700d2f0211576ba3506eevboxsync off, pvBuf, cbRead, cbRead, pvBuf));
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %Rrc\n", __FUNCTION__, rc));
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc PDMIMEDIA::pfnWrite */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdWrite(PPDMIMEDIA pInterface,
af062818b47340eef15700d2f0211576ba3506eevboxsync uint64_t off, const void *pvBuf,
af062818b47340eef15700d2f0211576ba3506eevboxsync size_t cbWrite)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: off=%#llx pvBuf=%p cbWrite=%d\n", __FUNCTION__,
af062818b47340eef15700d2f0211576ba3506eevboxsync off, pvBuf, cbWrite));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIA_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync Log2(("%s: off=%#llx pvBuf=%p cbWrite=%d %.*Rhxd\n", __FUNCTION__,
af062818b47340eef15700d2f0211576ba3506eevboxsync off, pvBuf, cbWrite, cbWrite, pvBuf));
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VDWrite(pThis->pDisk, off, pvBuf, cbWrite);
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %Rrc\n", __FUNCTION__, rc));
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc PDMIMEDIA::pfnFlush */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdFlush(PPDMIMEDIA pInterface)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIA_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VDFlush(pThis->pDisk);
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %Rrc\n", __FUNCTION__, rc));
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc PDMIMEDIA::pfnMerge */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdMerge(PPDMIMEDIA pInterface,
af062818b47340eef15700d2f0211576ba3506eevboxsync PFNSIMPLEPROGRESS pfnProgress,
af062818b47340eef15700d2f0211576ba3506eevboxsync void *pvUser)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIA_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Note: There is an unavoidable race between destruction and another
af062818b47340eef15700d2f0211576ba3506eevboxsync * thread invoking this function. This is handled safely and gracefully by
af062818b47340eef15700d2f0211576ba3506eevboxsync * atomically invalidating the lock handle in drvvdDestruct. */
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc2 = RTSemFastMutexRequest(pThis->MergeCompleteMutex);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc2);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_SUCCESS(rc2) && pThis->fMergePending)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Take shortcut: PFNSIMPLEPROGRESS is exactly the same type as
af062818b47340eef15700d2f0211576ba3506eevboxsync * PFNVDPROGRESS, so there's no need for a conversion function. */
af062818b47340eef15700d2f0211576ba3506eevboxsync /** @todo maybe introduce a conversion which limits update frequency. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PVDINTERFACE pVDIfsOperation = NULL;
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACE VDIProgress;
af062818b47340eef15700d2f0211576ba3506eevboxsync VDINTERFACEPROGRESS VDIProgressCallbacks;
af062818b47340eef15700d2f0211576ba3506eevboxsync VDIProgressCallbacks.cbSize = sizeof(VDINTERFACEPROGRESS);
af062818b47340eef15700d2f0211576ba3506eevboxsync VDIProgressCallbacks.enmInterface = VDINTERFACETYPE_PROGRESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync VDIProgressCallbacks.pfnProgress = pfnProgress;
af062818b47340eef15700d2f0211576ba3506eevboxsync rc2 = VDInterfaceAdd(&VDIProgress, "DrvVD_VDIProgress", VDINTERFACETYPE_PROGRESS,
af062818b47340eef15700d2f0211576ba3506eevboxsync &VDIProgressCallbacks, pvUser, &pVDIfsOperation);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc2);
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->fMergePending = false;
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VDMerge(pThis->pDisk, pThis->uMergeSource,
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->uMergeTarget, pVDIfsOperation);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync rc2 = RTSemFastMutexRelease(pThis->MergeCompleteMutex);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc2);
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %Rrc\n", __FUNCTION__, rc));
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc PDMIMEDIA::pfnGetSize */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(uint64_t) drvvdGetSize(PPDMIMEDIA pInterface)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIA_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync uint64_t cb = VDGetSize(pThis->pDisk, VD_LAST_IMAGE);
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %#llx (%llu)\n", __FUNCTION__, cb, cb));
af062818b47340eef15700d2f0211576ba3506eevboxsync return cb;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc PDMIMEDIA::pfnIsReadOnly */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(bool) drvvdIsReadOnly(PPDMIMEDIA pInterface)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIA_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync bool f = VDIsReadOnly(pThis->pDisk);
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %d\n", __FUNCTION__, f));
af062818b47340eef15700d2f0211576ba3506eevboxsync return f;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc PDMIMEDIA::pfnBiosGetPCHSGeometry */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdBiosGetPCHSGeometry(PPDMIMEDIA pInterface,
af062818b47340eef15700d2f0211576ba3506eevboxsync PPDMMEDIAGEOMETRY pPCHSGeometry)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIA_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VDGetPCHSGeometry(pThis->pDisk, VD_LAST_IMAGE, pPCHSGeometry);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_FAILURE(rc))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync Log(("%s: geometry not available.\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VERR_PDM_GEOMETRY_NOT_SET;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %Rrc (CHS=%d/%d/%d)\n", __FUNCTION__,
af062818b47340eef15700d2f0211576ba3506eevboxsync rc, pPCHSGeometry->cCylinders, pPCHSGeometry->cHeads, pPCHSGeometry->cSectors));
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc PDMIMEDIA::pfnBiosSetPCHSGeometry */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdBiosSetPCHSGeometry(PPDMIMEDIA pInterface,
af062818b47340eef15700d2f0211576ba3506eevboxsync PCPDMMEDIAGEOMETRY pPCHSGeometry)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: CHS=%d/%d/%d\n", __FUNCTION__,
af062818b47340eef15700d2f0211576ba3506eevboxsync pPCHSGeometry->cCylinders, pPCHSGeometry->cHeads, pPCHSGeometry->cSectors));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIA_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VDSetPCHSGeometry(pThis->pDisk, VD_LAST_IMAGE, pPCHSGeometry);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (rc == VERR_VD_GEOMETRY_NOT_SET)
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VERR_PDM_GEOMETRY_NOT_SET;
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %Rrc\n", __FUNCTION__, rc));
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc PDMIMEDIA::pfnBiosGetLCHSGeometry */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdBiosGetLCHSGeometry(PPDMIMEDIA pInterface,
af062818b47340eef15700d2f0211576ba3506eevboxsync PPDMMEDIAGEOMETRY pLCHSGeometry)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIA_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VDGetLCHSGeometry(pThis->pDisk, VD_LAST_IMAGE, pLCHSGeometry);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_FAILURE(rc))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync Log(("%s: geometry not available.\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VERR_PDM_GEOMETRY_NOT_SET;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %Rrc (CHS=%d/%d/%d)\n", __FUNCTION__,
af062818b47340eef15700d2f0211576ba3506eevboxsync rc, pLCHSGeometry->cCylinders, pLCHSGeometry->cHeads, pLCHSGeometry->cSectors));
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc PDMIMEDIA::pfnBiosSetLCHSGeometry */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdBiosSetLCHSGeometry(PPDMIMEDIA pInterface,
af062818b47340eef15700d2f0211576ba3506eevboxsync PCPDMMEDIAGEOMETRY pLCHSGeometry)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: CHS=%d/%d/%d\n", __FUNCTION__,
af062818b47340eef15700d2f0211576ba3506eevboxsync pLCHSGeometry->cCylinders, pLCHSGeometry->cHeads, pLCHSGeometry->cSectors));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIA_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VDSetLCHSGeometry(pThis->pDisk, VD_LAST_IMAGE, pLCHSGeometry);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (rc == VERR_VD_GEOMETRY_NOT_SET)
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VERR_PDM_GEOMETRY_NOT_SET;
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %Rrc\n", __FUNCTION__, rc));
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/** @copydoc PDMIMEDIA::pfnGetUuid */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdGetUuid(PPDMIMEDIA pInterface, PRTUUID pUuid)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIA_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VDGetUuid(pThis->pDisk, 0, pUuid);
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %Rrc ({%RTuuid})\n", __FUNCTION__, rc, pUuid));
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* Async Media interface methods *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic void drvvdAsyncReqComplete(void *pvUser1, void *pvUser2)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = (PVBOXDISK)pvUser1;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = pThis->pDrvMediaAsyncPort->pfnTransferCompleteNotify(pThis->pDrvMediaAsyncPort,
af062818b47340eef15700d2f0211576ba3506eevboxsync pvUser2);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdStartRead(PPDMIMEDIAASYNC pInterface, uint64_t uOffset,
af062818b47340eef15700d2f0211576ba3506eevboxsync PCRTSGSEG paSeg, unsigned cSeg,
af062818b47340eef15700d2f0211576ba3506eevboxsync size_t cbRead, void *pvUser)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: uOffset=%#llx paSeg=%#p cSeg=%u cbRead=%d\n pvUser=%#p", __FUNCTION__,
af062818b47340eef15700d2f0211576ba3506eevboxsync uOffset, paSeg, cSeg, cbRead, pvUser));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIAASYNC_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VDAsyncRead(pThis->pDisk, uOffset, cbRead, paSeg, cSeg,
af062818b47340eef15700d2f0211576ba3506eevboxsync drvvdAsyncReqComplete, pThis, pvUser);
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %Rrc\n", __FUNCTION__, rc));
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdStartWrite(PPDMIMEDIAASYNC pInterface, uint64_t uOffset,
af062818b47340eef15700d2f0211576ba3506eevboxsync PCRTSGSEG paSeg, unsigned cSeg,
af062818b47340eef15700d2f0211576ba3506eevboxsync size_t cbWrite, void *pvUser)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: uOffset=%#llx paSeg=%#p cSeg=%u cbWrite=%d\n pvUser=%#p", __FUNCTION__,
af062818b47340eef15700d2f0211576ba3506eevboxsync uOffset, paSeg, cSeg, cbWrite, pvUser));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMIMEDIAASYNC_2_VBOXDISK(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VDAsyncWrite(pThis->pDisk, uOffset, cbWrite, paSeg, cSeg,
af062818b47340eef15700d2f0211576ba3506eevboxsync drvvdAsyncReqComplete, pThis, pvUser);
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s: returns %Rrc\n", __FUNCTION__, rc));
af062818b47340eef15700d2f0211576ba3506eevboxsync return rc;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* Base interface methods *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * @interface_method_impl{PDMIBASE,pfnQueryInterface}
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(void *) drvvdQueryInterface(PPDMIBASE pInterface, const char *pszIID)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PPDMDRVINS pDrvIns = PDMIBASE_2_DRVINS(pInterface);
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMINS_2_DATA(pDrvIns, PVBOXDISK);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMIBASE_RETURN_INTERFACE(pszIID, PDMIBASE, &pDrvIns->IBase);
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMIBASE_RETURN_INTERFACE(pszIID, PDMIMEDIA, &pThis->IMedia);
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMIBASE_RETURN_INTERFACE(pszIID, PDMIMEDIAASYNC, pThis->fAsyncIOSupported ? &pThis->IMediaAsync : NULL);
af062818b47340eef15700d2f0211576ba3506eevboxsync return NULL;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* Saved state notification methods *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * Load done callback for re-opening the image writable during teleportation.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * This is called both for successful and failed load runs, we only care about
af062818b47340eef15700d2f0211576ba3506eevboxsync * successfull ones.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * @returns VBox status code.
af062818b47340eef15700d2f0211576ba3506eevboxsync * @param pDrvIns The driver instance.
af062818b47340eef15700d2f0211576ba3506eevboxsync * @param pSSM The saved state handle.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdLoadDone(PPDMDRVINS pDrvIns, PSSMHANDLE pSSM)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMINS_2_DATA(pDrvIns, PVBOXDISK);
af062818b47340eef15700d2f0211576ba3506eevboxsync Assert(!pThis->fErrorUseRuntime);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Drop out if we don't have any work to do or if it's a failed load. */
af062818b47340eef15700d2f0211576ba3506eevboxsync if ( !pThis->fTempReadOnly
af062818b47340eef15700d2f0211576ba3506eevboxsync || RT_FAILURE(SSMR3HandleGetStatus(pSSM)))
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = drvvdSetWritable(pThis);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (RT_FAILURE(rc)) /** @todo does the bugger set any errors? */
af062818b47340eef15700d2f0211576ba3506eevboxsync return SSMR3SetLoadError(pSSM, rc, RT_SRC_POS,
af062818b47340eef15700d2f0211576ba3506eevboxsync N_("Failed to write lock the images"));
af062818b47340eef15700d2f0211576ba3506eevboxsync return VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/*******************************************************************************
af062818b47340eef15700d2f0211576ba3506eevboxsync* Driver methods *
af062818b47340eef15700d2f0211576ba3506eevboxsync*******************************************************************************/
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(void) drvvdPowerOff(PPDMDRVINS pDrvIns)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMINS_2_DATA(pDrvIns, PVBOXDISK);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /*
af062818b47340eef15700d2f0211576ba3506eevboxsync * We must close the disk here to ensure that
af062818b47340eef15700d2f0211576ba3506eevboxsync * the backend closes all files before the
af062818b47340eef15700d2f0211576ba3506eevboxsync * async transport driver is destructed.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VDCloseAll(pThis->pDisk);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * VM resume notification that we use to undo what the temporary read-only image
af062818b47340eef15700d2f0211576ba3506eevboxsync * mode set by drvvdSuspend.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * Also switch to runtime error mode if we're resuming after a state load
af062818b47340eef15700d2f0211576ba3506eevboxsync * without having been powered on first.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * @param pDrvIns The driver instance data.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * @todo The VMSetError vs VMSetRuntimeError mess must be fixed elsewhere,
af062818b47340eef15700d2f0211576ba3506eevboxsync * we're making assumptions about Main behavior here!
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(void) drvvdResume(PPDMDRVINS pDrvIns)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMINS_2_DATA(pDrvIns, PVBOXDISK);
af062818b47340eef15700d2f0211576ba3506eevboxsync drvvdSetWritable(pThis);
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->fErrorUseRuntime = true;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * The VM is being suspended, temporarily change to read-only image mode.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * This is important for several reasons:
af062818b47340eef15700d2f0211576ba3506eevboxsync * -# It makes sure that there are no pending writes to the image. Most
af062818b47340eef15700d2f0211576ba3506eevboxsync * backends implements this by closing and reopening the image in read-only
af062818b47340eef15700d2f0211576ba3506eevboxsync * mode.
af062818b47340eef15700d2f0211576ba3506eevboxsync * -# It allows Main to read the images during snapshotting without having
af062818b47340eef15700d2f0211576ba3506eevboxsync * to account for concurrent writes.
af062818b47340eef15700d2f0211576ba3506eevboxsync * -# This is essential for making teleportation targets sharing images work
af062818b47340eef15700d2f0211576ba3506eevboxsync * right. Both with regards to caching and with regards to file sharing
af062818b47340eef15700d2f0211576ba3506eevboxsync * locks (RTFILE_O_DENY_*). (See also drvvdLoadDone.)
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * @param pDrvIns The driver instance data.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(void) drvvdSuspend(PPDMDRVINS pDrvIns)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMINS_2_DATA(pDrvIns, PVBOXDISK);
af062818b47340eef15700d2f0211576ba3506eevboxsync drvvdSetReadonly(pThis);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * VM PowerOn notification for undoing the TempReadOnly config option and
af062818b47340eef15700d2f0211576ba3506eevboxsync * changing to runtime error mode.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * @param pDrvIns The driver instance data.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * @todo The VMSetError vs VMSetRuntimeError mess must be fixed elsewhere,
af062818b47340eef15700d2f0211576ba3506eevboxsync * we're making assumptions about Main behavior here!
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(void) drvvdPowerOn(PPDMDRVINS pDrvIns)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMINS_2_DATA(pDrvIns, PVBOXDISK);
af062818b47340eef15700d2f0211576ba3506eevboxsync drvvdSetWritable(pThis);
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->fErrorUseRuntime = true;
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * @copydoc FNPDMDRVDESTRUCT
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(void) drvvdDestruct(PPDMDRVINS pDrvIns)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMINS_2_DATA(pDrvIns, PVBOXDISK);
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMDRV_CHECK_VERSIONS_RETURN_VOID(pDrvIns);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync RTSEMFASTMUTEX mutex = (RTSEMFASTMUTEX)ASMAtomicXchgPtr((void **)&pThis->MergeCompleteMutex,
af062818b47340eef15700d2f0211576ba3506eevboxsync (void *)NIL_RTSEMFASTMUTEX);
af062818b47340eef15700d2f0211576ba3506eevboxsync if (mutex != NIL_RTSEMFASTMUTEX)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Request the semaphore to wait until a potentially running merge
af062818b47340eef15700d2f0211576ba3506eevboxsync * operation has been finished. */
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = RTSemFastMutexRequest(mutex);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->fMergePending = false;
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = RTSemFastMutexRelease(mutex);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = RTSemFastMutexDestroy(mutex);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync if (pThis->MergeLock != NIL_RTSEMRW)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = RTSemRWDestroy(pThis->MergeLock);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->MergeLock = NIL_RTSEMRW;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync if (VALID_PTR(pThis->pDisk))
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync VDDestroy(pThis->pDisk);
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->pDisk = NULL;
af062818b47340eef15700d2f0211576ba3506eevboxsync }
af062818b47340eef15700d2f0211576ba3506eevboxsync drvvdFreeImages(pThis);
af062818b47340eef15700d2f0211576ba3506eevboxsync}
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync/**
af062818b47340eef15700d2f0211576ba3506eevboxsync * Construct a VBox disk media driver instance.
af062818b47340eef15700d2f0211576ba3506eevboxsync *
af062818b47340eef15700d2f0211576ba3506eevboxsync * @copydoc FNPDMDRVCONSTRUCT
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsyncstatic DECLCALLBACK(int) drvvdConstruct(PPDMDRVINS pDrvIns,
af062818b47340eef15700d2f0211576ba3506eevboxsync PCFGMNODE pCfg,
af062818b47340eef15700d2f0211576ba3506eevboxsync uint32_t fFlags)
af062818b47340eef15700d2f0211576ba3506eevboxsync{
af062818b47340eef15700d2f0211576ba3506eevboxsync LogFlow(("%s:\n", __FUNCTION__));
af062818b47340eef15700d2f0211576ba3506eevboxsync PVBOXDISK pThis = PDMINS_2_DATA(pDrvIns, PVBOXDISK);
af062818b47340eef15700d2f0211576ba3506eevboxsync int rc = VINF_SUCCESS;
af062818b47340eef15700d2f0211576ba3506eevboxsync char *pszName = NULL; /**< The path of the disk image file. */
af062818b47340eef15700d2f0211576ba3506eevboxsync char *pszFormat = NULL; /**< The format backed to use for this image. */
af062818b47340eef15700d2f0211576ba3506eevboxsync bool fReadOnly; /**< True if the media is read-only. */
af062818b47340eef15700d2f0211576ba3506eevboxsync bool fHonorZeroWrites; /**< True if zero blocks should be written. */
af062818b47340eef15700d2f0211576ba3506eevboxsync PDMDRV_CHECK_VERSIONS_RETURN(pDrvIns);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /*
af062818b47340eef15700d2f0211576ba3506eevboxsync * Init the static parts.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsync pDrvIns->IBase.pfnQueryInterface = drvvdQueryInterface;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->pDrvIns = pDrvIns;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->fTempReadOnly = false;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->pDisk = NULL;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->fAsyncIOSupported = false;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->fMergePending = false;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->MergeCompleteMutex = NIL_RTSEMFASTMUTEX;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->uMergeSource = VD_LAST_IMAGE;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->uMergeTarget = VD_LAST_IMAGE;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /* IMedia */
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMedia.pfnRead = drvvdRead;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMedia.pfnWrite = drvvdWrite;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMedia.pfnFlush = drvvdFlush;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMedia.pfnMerge = drvvdMerge;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMedia.pfnGetSize = drvvdGetSize;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMedia.pfnIsReadOnly = drvvdIsReadOnly;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMedia.pfnBiosGetPCHSGeometry = drvvdBiosGetPCHSGeometry;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMedia.pfnBiosSetPCHSGeometry = drvvdBiosSetPCHSGeometry;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMedia.pfnBiosGetLCHSGeometry = drvvdBiosGetLCHSGeometry;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMedia.pfnBiosSetLCHSGeometry = drvvdBiosSetLCHSGeometry;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMedia.pfnGetUuid = drvvdGetUuid;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /* IMediaAsync */
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMediaAsync.pfnStartRead = drvvdStartRead;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->IMediaAsync.pfnStartWrite = drvvdStartWrite;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Initialize supported VD interfaces. */
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->pVDIfsDisk = NULL;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->VDIErrorCallbacks.cbSize = sizeof(VDINTERFACEERROR);
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->VDIErrorCallbacks.enmInterface = VDINTERFACETYPE_ERROR;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->VDIErrorCallbacks.pfnError = drvvdErrorCallback;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->VDIErrorCallbacks.pfnMessage = NULL;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync rc = VDInterfaceAdd(&pThis->VDIError, "DrvVD_VDIError", VDINTERFACETYPE_ERROR,
af062818b47340eef15700d2f0211576ba3506eevboxsync &pThis->VDIErrorCallbacks, pDrvIns, &pThis->pVDIfsDisk);
af062818b47340eef15700d2f0211576ba3506eevboxsync AssertRC(rc);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /* This is just prepared here, the actual interface is per-image, so it's
af062818b47340eef15700d2f0211576ba3506eevboxsync * added later. No need to have separate callback tables. */
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->VDIConfigCallbacks.cbSize = sizeof(VDINTERFACECONFIG);
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->VDIConfigCallbacks.enmInterface = VDINTERFACETYPE_CONFIG;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->VDIConfigCallbacks.pfnAreKeysValid = drvvdCfgAreKeysValid;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->VDIConfigCallbacks.pfnQuerySize = drvvdCfgQuerySize;
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->VDIConfigCallbacks.pfnQuery = drvvdCfgQuery;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /* List of images is empty now. */
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->pImages = NULL;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /* Try to attach async media port interface above.*/
af062818b47340eef15700d2f0211576ba3506eevboxsync pThis->pDrvMediaAsyncPort = PDMIBASE_QUERY_INTERFACE(pDrvIns->pUpBase, PDMIMEDIAASYNCPORT);
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync /*
af062818b47340eef15700d2f0211576ba3506eevboxsync * Validate configuration and find all parent images.
af062818b47340eef15700d2f0211576ba3506eevboxsync * It's sort of up side down from the image dependency tree.
af062818b47340eef15700d2f0211576ba3506eevboxsync */
af062818b47340eef15700d2f0211576ba3506eevboxsync bool fHostIP = false;
af062818b47340eef15700d2f0211576ba3506eevboxsync bool fUseNewIo = false;
af062818b47340eef15700d2f0211576ba3506eevboxsync unsigned iLevel = 0;
af062818b47340eef15700d2f0211576ba3506eevboxsync PCFGMNODE pCurNode = pCfg;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync for (;;)
af062818b47340eef15700d2f0211576ba3506eevboxsync {
af062818b47340eef15700d2f0211576ba3506eevboxsync bool fValid;
af062818b47340eef15700d2f0211576ba3506eevboxsync
af062818b47340eef15700d2f0211576ba3506eevboxsync if (pCurNode == pCfg)
{
/* Toplevel configuration additionally contains the global image
* open flags. Some might be converted to per-image flags later. */
fValid = CFGMR3AreValuesValid(pCurNode,
"Format\0Path\0"
"ReadOnly\0TempReadOnly\0HonorZeroWrites\0"
"HostIPStack\0UseNewIo\0SetupMerge\0");
}
else
{
/* All other image configurations only contain image name and
* the format information. */
fValid = CFGMR3AreValuesValid(pCurNode, "Format\0Path\0"
"MergeSource\0MergeTarget\0");
}
if (!fValid)
{
rc = PDMDrvHlpVMSetError(pDrvIns, VERR_PDM_DRVINS_UNKNOWN_CFG_VALUES,
RT_SRC_POS, N_("DrvVD: Configuration error: keys incorrect at level %d"), iLevel);
break;
}
if (pCurNode == pCfg)
{
rc = CFGMR3QueryBoolDef(pCurNode, "HostIPStack", &fHostIP, true);
if (RT_FAILURE(rc))
{
rc = PDMDRV_SET_ERROR(pDrvIns, rc,
N_("DrvVD: Configuration error: Querying \"HostIPStack\" as boolean failed"));
break;
}
rc = CFGMR3QueryBoolDef(pCurNode, "HonorZeroWrites", &fHonorZeroWrites, false);
if (RT_FAILURE(rc))
{
rc = PDMDRV_SET_ERROR(pDrvIns, rc,
N_("DrvVD: Configuration error: Querying \"HonorZeroWrites\" as boolean failed"));
break;
}
rc = CFGMR3QueryBoolDef(pCurNode, "ReadOnly", &fReadOnly, false);
if (RT_FAILURE(rc))
{
rc = PDMDRV_SET_ERROR(pDrvIns, rc,
N_("DrvVD: Configuration error: Querying \"ReadOnly\" as boolean failed"));
break;
}
rc = CFGMR3QueryBoolDef(pCurNode, "TempReadOnly", &pThis->fTempReadOnly, false);
if (RT_FAILURE(rc))
{
rc = PDMDRV_SET_ERROR(pDrvIns, rc,
N_("DrvVD: Configuration error: Querying \"TempReadOnly\" as boolean failed"));
break;
}
if (fReadOnly && pThis->fTempReadOnly)
{
rc = PDMDRV_SET_ERROR(pDrvIns, VERR_PDM_DRIVER_INVALID_PROPERTIES,
N_("DrvVD: Configuration error: Both \"ReadOnly\" and \"TempReadOnly\" are set"));
break;
}
rc = CFGMR3QueryBoolDef(pCurNode, "UseNewIo", &fUseNewIo, false);
if (RT_FAILURE(rc))
{
rc = PDMDRV_SET_ERROR(pDrvIns, rc,
N_("DrvVD: Configuration error: Querying \"UseNewIo\" as boolean failed"));
break;
}
rc = CFGMR3QueryBoolDef(pCurNode, "SetupMerge", &pThis->fMergePending, false);
if (RT_FAILURE(rc))
{
rc = PDMDRV_SET_ERROR(pDrvIns, rc,
N_("DrvVD: Configuration error: Querying \"SetupMerge\" as boolean failed"));
break;
}
if (fReadOnly && pThis->fMergePending)
{
rc = PDMDRV_SET_ERROR(pDrvIns, VERR_PDM_DRIVER_INVALID_PROPERTIES,
N_("DrvVD: Configuration error: Both \"ReadOnly\" and \"MergePending\" are set"));
break;
}
}
PCFGMNODE pParent = CFGMR3GetChild(pCurNode, "Parent");
if (!pParent)
break;
pCurNode = pParent;
iLevel++;
}
/*
* Create the image container and the necessary interfaces.
*/
if (RT_SUCCESS(rc))
{
/* First of all figure out what kind of TCP networking stack interface
* to use. This is done unconditionally, as backends which don't need
* it will just ignore it. */
if (fHostIP)
{
pThis->VDITcpNetCallbacks.cbSize = sizeof(VDINTERFACETCPNET);
pThis->VDITcpNetCallbacks.enmInterface = VDINTERFACETYPE_TCPNET;
pThis->VDITcpNetCallbacks.pfnClientConnect = RTTcpClientConnect;
pThis->VDITcpNetCallbacks.pfnClientClose = RTTcpClientClose;
pThis->VDITcpNetCallbacks.pfnSelectOne = RTTcpSelectOne;
pThis->VDITcpNetCallbacks.pfnRead = RTTcpRead;
pThis->VDITcpNetCallbacks.pfnWrite = RTTcpWrite;
pThis->VDITcpNetCallbacks.pfnFlush = RTTcpFlush;
pThis->VDITcpNetCallbacks.pfnGetLocalAddress = RTTcpGetLocalAddress;
pThis->VDITcpNetCallbacks.pfnGetPeerAddress = RTTcpGetPeerAddress;
}
else
{
#ifndef VBOX_WITH_INIP
rc = PDMDrvHlpVMSetError(pDrvIns, VERR_PDM_DRVINS_UNKNOWN_CFG_VALUES,
RT_SRC_POS, N_("DrvVD: Configuration error: TCP over Internal Networking not compiled in"));
#else /* VBOX_WITH_INIP */
pThis->VDITcpNetCallbacks.cbSize = sizeof(VDINTERFACETCPNET);
pThis->VDITcpNetCallbacks.enmInterface = VDINTERFACETYPE_TCPNET;
pThis->VDITcpNetCallbacks.pfnClientConnect = drvvdINIPClientConnect;
pThis->VDITcpNetCallbacks.pfnClientClose = drvvdINIPClientClose;
pThis->VDITcpNetCallbacks.pfnSelectOne = drvvdINIPSelectOne;
pThis->VDITcpNetCallbacks.pfnRead = drvvdINIPRead;
pThis->VDITcpNetCallbacks.pfnWrite = drvvdINIPWrite;
pThis->VDITcpNetCallbacks.pfnFlush = drvvdINIPFlush;
pThis->VDITcpNetCallbacks.pfnGetLocalAddress = drvvdINIPGetLocalAddress;
pThis->VDITcpNetCallbacks.pfnGetPeerAddress = drvvdINIPGetPeerAddress;
#endif /* VBOX_WITH_INIP */
}
if (RT_SUCCESS(rc))
{
rc = VDInterfaceAdd(&pThis->VDITcpNet, "DrvVD_INIP",
VDINTERFACETYPE_TCPNET,
&pThis->VDITcpNetCallbacks, NULL,
&pThis->pVDIfsDisk);
}
if (RT_SUCCESS(rc) && fUseNewIo)
{
#ifdef VBOX_WITH_PDM_ASYNC_COMPLETION
pThis->VDIAsyncIOCallbacks.cbSize = sizeof(VDINTERFACEASYNCIO);
pThis->VDIAsyncIOCallbacks.enmInterface = VDINTERFACETYPE_ASYNCIO;
pThis->VDIAsyncIOCallbacks.pfnOpen = drvvdAsyncIOOpen;
pThis->VDIAsyncIOCallbacks.pfnClose = drvvdAsyncIOClose;
pThis->VDIAsyncIOCallbacks.pfnGetSize = drvvdAsyncIOGetSize;
pThis->VDIAsyncIOCallbacks.pfnSetSize = drvvdAsyncIOSetSize;
pThis->VDIAsyncIOCallbacks.pfnReadSync = drvvdAsyncIOReadSync;
pThis->VDIAsyncIOCallbacks.pfnWriteSync = drvvdAsyncIOWriteSync;
pThis->VDIAsyncIOCallbacks.pfnFlushSync = drvvdAsyncIOFlushSync;
pThis->VDIAsyncIOCallbacks.pfnReadAsync = drvvdAsyncIOReadAsync;
pThis->VDIAsyncIOCallbacks.pfnWriteAsync = drvvdAsyncIOWriteAsync;
pThis->VDIAsyncIOCallbacks.pfnFlushAsync = drvvdAsyncIOFlushAsync;
rc = VDInterfaceAdd(&pThis->VDIAsyncIO, "DrvVD_AsyncIO", VDINTERFACETYPE_ASYNCIO,
&pThis->VDIAsyncIOCallbacks, pThis, &pThis->pVDIfsDisk);
#else /* !VBOX_WITH_PDM_ASYNC_COMPLETION */
rc = PDMDrvHlpVMSetError(pDrvIns, VERR_PDM_DRVINS_UNKNOWN_CFG_VALUES,
RT_SRC_POS, N_("DrvVD: Configuration error: Async Completion Framework not compiled in"));
#endif /* !VBOX_WITH_PDM_ASYNC_COMPLETION */
}
if (RT_SUCCESS(rc) && pThis->fMergePending)
{
rc = RTSemFastMutexCreate(&pThis->MergeCompleteMutex);
if (RT_SUCCESS(rc))
rc = RTSemRWCreate(&pThis->MergeLock);
if (RT_SUCCESS(rc))
{
pThis->VDIThreadSyncCallbacks.cbSize = sizeof(VDINTERFACETHREADSYNC);
pThis->VDIThreadSyncCallbacks.enmInterface = VDINTERFACETYPE_THREADSYNC;
pThis->VDIThreadSyncCallbacks.pfnStartRead = drvvdThreadStartRead;
pThis->VDIThreadSyncCallbacks.pfnFinishRead = drvvdThreadFinishRead;
pThis->VDIThreadSyncCallbacks.pfnStartWrite = drvvdThreadStartWrite;
pThis->VDIThreadSyncCallbacks.pfnFinishWrite = drvvdThreadFinishWrite;
rc = VDInterfaceAdd(&pThis->VDIThreadSync, "DrvVD_ThreadSync", VDINTERFACETYPE_THREADSYNC,
&pThis->VDIThreadSyncCallbacks, pThis, &pThis->pVDIfsDisk);
}
else
{
rc = PDMDRV_SET_ERROR(pDrvIns, rc,
N_("DrvVD: Failed to create semaphores for \"MergePending\""));
}
}
if (RT_SUCCESS(rc))
{
rc = VDCreate(pThis->pVDIfsDisk, &pThis->pDisk);
/* Error message is already set correctly. */
}
}
if (pThis->pDrvMediaAsyncPort && fUseNewIo)
pThis->fAsyncIOSupported = true;
unsigned iImageIdx = 0;
while (pCurNode && RT_SUCCESS(rc))
{
/* Allocate per-image data. */
PVBOXIMAGE pImage = drvvdNewImage(pThis);
if (!pImage)
{
rc = VERR_NO_MEMORY;
break;
}
/*
* Read the image configuration.
*/
rc = CFGMR3QueryStringAlloc(pCurNode, "Path", &pszName);
if (RT_FAILURE(rc))
{
rc = PDMDRV_SET_ERROR(pDrvIns, rc,
N_("DrvVD: Configuration error: Querying \"Path\" as string failed"));
break;
}
rc = CFGMR3QueryStringAlloc(pCurNode, "Format", &pszFormat);
if (RT_FAILURE(rc))
{
rc = PDMDRV_SET_ERROR(pDrvIns, rc,
N_("DrvVD: Configuration error: Querying \"Format\" as string failed"));
break;
}
bool fMergeSource;
rc = CFGMR3QueryBoolDef(pCurNode, "MergeSource", &fMergeSource, false);
if (RT_FAILURE(rc))
{
rc = PDMDRV_SET_ERROR(pDrvIns, rc,
N_("DrvVD: Configuration error: Querying \"MergeSource\" as boolean failed"));
break;
}
if (fMergeSource)
{
if (pThis->uMergeSource == VD_LAST_IMAGE)
pThis->uMergeSource = iImageIdx;
else
{
rc = PDMDRV_SET_ERROR(pDrvIns, VERR_PDM_DRIVER_INVALID_PROPERTIES,
N_("DrvVD: Configuration error: Multiple \"MergeSource\" occurrences"));
break;
}
}
bool fMergeTarget;
rc = CFGMR3QueryBoolDef(pCurNode, "MergeTarget", &fMergeTarget, false);
if (RT_FAILURE(rc))
{
rc = PDMDRV_SET_ERROR(pDrvIns, rc,
N_("DrvVD: Configuration error: Querying \"MergeTarget\" as boolean failed"));
break;
}
if (fMergeTarget)
{
if (pThis->uMergeTarget == VD_LAST_IMAGE)
pThis->uMergeTarget = iImageIdx;
else
{
rc = PDMDRV_SET_ERROR(pDrvIns, VERR_PDM_DRIVER_INVALID_PROPERTIES,
N_("DrvVD: Configuration error: Multiple \"MergeTarget\" occurrences"));
break;
}
}
PCFGMNODE pCfgVDConfig = CFGMR3GetChild(pCurNode, "VDConfig");
rc = VDInterfaceAdd(&pImage->VDIConfig, "DrvVD_Config", VDINTERFACETYPE_CONFIG,
&pThis->VDIConfigCallbacks, pCfgVDConfig, &pImage->pVDIfsImage);
AssertRC(rc);
/*
* Open the image.
*/
unsigned uOpenFlags;
if (fReadOnly || pThis->fTempReadOnly || iLevel != 0)
uOpenFlags = VD_OPEN_FLAGS_READONLY;
else
uOpenFlags = VD_OPEN_FLAGS_NORMAL;
if (fHonorZeroWrites)
uOpenFlags |= VD_OPEN_FLAGS_HONOR_ZEROES;
if (pThis->fAsyncIOSupported)
uOpenFlags |= VD_OPEN_FLAGS_ASYNC_IO;
/* Try to open backend in async I/O mode first. */
rc = VDOpen(pThis->pDisk, pszFormat, pszName, uOpenFlags, pImage->pVDIfsImage);
if (rc == VERR_NOT_SUPPORTED)
{
pThis->fAsyncIOSupported = false;
uOpenFlags &= ~VD_OPEN_FLAGS_ASYNC_IO;
rc = VDOpen(pThis->pDisk, pszFormat, pszName, uOpenFlags, pImage->pVDIfsImage);
}
if (RT_SUCCESS(rc))
{
Log(("%s: %d - Opened '%s' in %s mode\n", __FUNCTION__,
iLevel, pszName,
VDIsReadOnly(pThis->pDisk) ? "read-only" : "read-write"));
if ( VDIsReadOnly(pThis->pDisk)
&& !fReadOnly
&& !pThis->fTempReadOnly
&& iLevel == 0)
{
rc = PDMDrvHlpVMSetError(pDrvIns, VERR_VD_IMAGE_READ_ONLY, RT_SRC_POS,
N_("Failed to open image '%s' for writing due to wrong permissions"),
pszName);
break;
}
}
else
{
rc = PDMDrvHlpVMSetError(pDrvIns, rc, RT_SRC_POS,
N_("Failed to open image '%s' in %s mode rc=%Rrc"), pszName,
(uOpenFlags & VD_OPEN_FLAGS_READONLY) ? "read-only" : "read-write", rc);
break;
}
MMR3HeapFree(pszName);
pszName = NULL;
MMR3HeapFree(pszFormat);
pszFormat = NULL;
/* next */
iLevel--;
iImageIdx--;
pCurNode = CFGMR3GetParent(pCurNode);
}
if ( RT_SUCCESS(rc)
&& pThis->fMergePending
&& ( pThis->uMergeSource == VD_LAST_IMAGE
|| pThis->uMergeTarget == VD_LAST_IMAGE))
{
rc = PDMDRV_SET_ERROR(pDrvIns, VERR_PDM_DRIVER_INVALID_PROPERTIES,
N_("DrvVD: Configuration error: Inconsistent image merge data"));
}
/*
* Register a load-done callback so we can undo TempReadOnly config before
* we get to drvvdResume. Autoamtically deregistered upon destruction.
*/
if (RT_SUCCESS(rc))
rc = PDMDrvHlpSSMRegisterEx(pDrvIns, 0 /* version */, 0 /* cbGuess */,
NULL /*pfnLivePrep*/, NULL /*pfnLiveExec*/, NULL /*pfnLiveVote*/,
NULL /*pfnSavePrep*/, NULL /*pfnSaveExec*/, NULL /*pfnSaveDone*/,
NULL /*pfnDonePrep*/, NULL /*pfnLoadExec*/, drvvdLoadDone);
if (RT_FAILURE(rc))
{
if (VALID_PTR(pszName))
MMR3HeapFree(pszName);
if (VALID_PTR(pszFormat))
MMR3HeapFree(pszFormat);
/* drvvdDestruct does the rest. */
}
LogFlow(("%s: returns %Rrc\n", __FUNCTION__, rc));
return rc;
}
/**
* VBox disk container media driver registration record.
*/
const PDMDRVREG g_DrvVD =
{
/* u32Version */
PDM_DRVREG_VERSION,
/* szName */
"VD",
/* szRCMod */
"",
/* szR0Mod */
"",
/* pszDescription */
"Generic VBox disk media driver.",
/* fFlags */
PDM_DRVREG_FLAGS_HOST_BITS_DEFAULT,
/* fClass. */
PDM_DRVREG_CLASS_MEDIA,
/* cMaxInstances */
~0,
/* cbInstance */
sizeof(VBOXDISK),
/* pfnConstruct */
drvvdConstruct,
/* pfnDestruct */
drvvdDestruct,
/* pfnRelocate */
NULL,
/* pfnIOCtl */
NULL,
/* pfnPowerOn */
drvvdPowerOn,
/* pfnReset */
NULL,
/* pfnSuspend */
drvvdSuspend,
/* pfnResume */
drvvdResume,
/* pfnAttach */
NULL,
/* pfnDetach */
NULL,
/* pfnPowerOff */
drvvdPowerOff,
/* pfnSoftReset */
NULL,
/* u32EndVersion */
PDM_DRVREG_VERSION
};