crservice.cpp revision 01df41f7a4e5f7de195a059541d1c89676da9673
312N/A/* $Id$ */
312N/A
312N/A/** @file
312N/A * VBox crOpenGL: Host service entry points.
312N/A */
312N/A
312N/A/*
312N/A * Copyright (C) 2006-2012 Oracle Corporation
312N/A *
312N/A * This file is part of VirtualBox Open Source Edition (OSE), as
312N/A * available from http://www.virtualbox.org. This file is free software;
312N/A * you can redistribute it and/or modify it under the terms of the GNU
312N/A * General Public License (GPL) as published by the Free Software
312N/A * Foundation, in version 2 as it comes in the "COPYING" file of the
312N/A * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
312N/A * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
312N/A */
312N/A
312N/A#define __STDC_CONSTANT_MACROS /* needed for a definition in iprt/string.h */
5680N/A
312N/A#define LOG_GROUP LOG_GROUP_SHARED_CROPENGL
312N/A
5680N/A#include <iprt/assert.h>
312N/A#include <iprt/asm.h>
5829N/A#include <iprt/critsect.h>
5680N/A#include <iprt/mem.h>
5680N/A#include <iprt/semaphore.h>
312N/A#include <iprt/stream.h>
312N/A#include <iprt/string.h>
312N/A#include <iprt/thread.h>
6913N/A
844N/A#include <VBox/hgcmsvc.h>
6913N/A#include <VBox/log.h>
5829N/A#include <VBox/com/ErrorInfo.h>
312N/A#include <VBox/com/VirtualBox.h>
312N/A#include <VBox/com/errorprint.h>
6913N/A#include <VBox/HostServices/VBoxCrOpenGLSvc.h>
2899N/A#include <VBox/vmm/ssm.h>
5680N/A
5680N/A#include "cr_mem.h"
5680N/A#include "cr_server.h"
5680N/A
5680N/APVBOXHGCMSVCHELPERS g_pHelpers;
5680N/Astatic IConsole* g_pConsole = NULL;
6913N/Astatic PVM g_pVM = NULL;
5680N/A
312N/A#ifndef RT_OS_WINDOWS
5079N/A# define DWORD int
5079N/A# define WINAPI
5079N/A#endif
5829N/A
5829N/Astatic const char* gszVBoxOGLSSMMagic = "***OpenGL state data***";
5829N/A
5829N/A/* Used to process guest calls exceeding maximum allowed HGCM call size in a sequence of smaller calls */
5829N/Atypedef struct _CRVBOXSVCBUFFER_t {
5829N/A uint32_t uiId;
5829N/A uint32_t uiSize;
5829N/A void* pData;
5829N/A _CRVBOXSVCBUFFER_t *pNext, *pPrev;
5829N/A} CRVBOXSVCBUFFER_t;
5079N/A
312N/Astatic CRVBOXSVCBUFFER_t *g_pCRVBoxSVCBuffers = NULL;
312N/Astatic uint32_t g_CRVBoxSVCBufferID = 0;
312N/A
5680N/A/* svcPresentFBO related data */
312N/Atypedef struct _CRVBOXSVCPRESENTFBOCMD_t {
7243N/A void *pData;
7243N/A int32_t screenId, x, y, w, h;
7243N/A _CRVBOXSVCPRESENTFBOCMD_t *pNext;
7243N/A} CRVBOXSVCPRESENTFBOCMD_t, *PCRVBOXSVCPRESENTFBOCMD_t;
7243N/A
312N/Atypedef struct _CRVBOXSVCPRESENTFBO_t {
312N/A PCRVBOXSVCPRESENTFBOCMD_t pQueueHead, pQueueTail; /* Head/Tail of FIFO cmds queue */
5829N/A RTCRITSECT hQueueLock; /* Queue lock */
5829N/A RTTHREAD hWorkerThread; /* Worker thread */
5829N/A bool volatile bShutdownWorker; /* Shutdown flag */
5829N/A RTSEMEVENT hEventProcess; /* Signalled when worker thread should process data or exit */
5079N/A} CRVBOXSVCPRESENTFBO_t;
623N/A
5079N/Astatic CRVBOXSVCPRESENTFBO_t g_SvcPresentFBO;
5829N/A
5829N/A/* Schedule a call to a separate worker thread to avoid deadlock on EMT thread when the screen configuration changes
5829N/A and we're processing crServerPresentFBO caused by guest application command.
623N/A To avoid unnecessary memcpy, worker thread frees the data passed.
623N/A*/
623N/Astatic DECLCALLBACK(void) svcPresentFBO(void *data, int32_t screenId, int32_t x, int32_t y, uint32_t w, uint32_t h)
623N/A{
5079N/A PCRVBOXSVCPRESENTFBOCMD_t pCmd;
5829N/A
312N/A pCmd = (PCRVBOXSVCPRESENTFBOCMD_t) RTMemAlloc(sizeof(CRVBOXSVCPRESENTFBOCMD_t));
5829N/A if (!pCmd)
5829N/A {
5829N/A LogRel(("SHARED_CROPENGL svcPresentFBO: not enough memory (%d)\n", sizeof(CRVBOXSVCPRESENTFBOCMD_t)));
5829N/A return;
3814N/A }
3814N/A pCmd->pData = data;
312N/A pCmd->screenId = screenId;
312N/A pCmd->x = x;
623N/A pCmd->y = y;
623N/A pCmd->w = w;
623N/A pCmd->h = h;
5829N/A pCmd->pNext = NULL;
5829N/A
5829N/A RTCritSectEnter(&g_SvcPresentFBO.hQueueLock);
5829N/A
5829N/A if (g_SvcPresentFBO.pQueueTail)
5829N/A {
5829N/A g_SvcPresentFBO.pQueueTail->pNext = pCmd;
623N/A }
6913N/A else
6913N/A {
6913N/A Assert(!g_SvcPresentFBO.pQueueHead);
312N/A g_SvcPresentFBO.pQueueHead = pCmd;
312N/A }
3814N/A g_SvcPresentFBO.pQueueTail = pCmd;
3814N/A
6913N/A RTCritSectLeave(&g_SvcPresentFBO.hQueueLock);
6913N/A
6913N/A RTSemEventSignal(g_SvcPresentFBO.hEventProcess);
6913N/A}
6913N/A
6913N/Astatic DECLCALLBACK(int) svcPresentFBOWorkerThreadProc(RTTHREAD ThreadSelf, void *pvUser)
6913N/A{
3814N/A int rc = VINF_SUCCESS;
5829N/A PCRVBOXSVCPRESENTFBOCMD_t pCmd;
5829N/A
5829N/A Log(("SHARED_CROPENGL svcPresentFBOWorkerThreadProc started\n"));
5829N/A
5829N/A for (;;)
5829N/A {
5829N/A rc = RTSemEventWait(g_SvcPresentFBO.hEventProcess, RT_INDEFINITE_WAIT);
5829N/A AssertRCReturn(rc, rc);
5829N/A
5079N/A if (g_SvcPresentFBO.bShutdownWorker)
5079N/A {
5079N/A break;
5829N/A }
5829N/A
5829N/A // @todo use critsect only to fetch the list and update the g_SvcPresentFBO's pQueueHead and pQueueTail.
5829N/A rc = RTCritSectEnter(&g_SvcPresentFBO.hQueueLock);
5829N/A AssertRCReturn(rc, rc);
5829N/A
5079N/A pCmd = g_SvcPresentFBO.pQueueHead;
5079N/A while (pCmd)
5079N/A {
5079N/A ComPtr<IDisplay> pDisplay;
5079N/A
5079N/A /*remove from queue*/
5680N/A g_SvcPresentFBO.pQueueHead = pCmd->pNext;
5680N/A if (!g_SvcPresentFBO.pQueueHead)
5079N/A {
5079N/A g_SvcPresentFBO.pQueueTail = NULL;
5079N/A }
5079N/A
5079N/A CHECK_ERROR_RET(g_pConsole, COMGETTER(Display)(pDisplay.asOutParam()), rc);
5079N/A
3817N/A RTCritSectLeave(&g_SvcPresentFBO.hQueueLock);
5079N/A
3817N/A CHECK_ERROR_RET(pDisplay, DrawToScreen(pCmd->screenId, (BYTE*)pCmd->pData, pCmd->x, pCmd->y, pCmd->w, pCmd->h), rc);
5079N/A
5079N/A crFree(pCmd->pData);
3817N/A RTMemFree(pCmd);
5079N/A
5079N/A rc = RTCritSectEnter(&g_SvcPresentFBO.hQueueLock);
3817N/A AssertRCReturn(rc, rc);
3817N/A pCmd = g_SvcPresentFBO.pQueueHead;
}
RTCritSectLeave(&g_SvcPresentFBO.hQueueLock);
}
Log(("SHARED_CROPENGL svcPresentFBOWorkerThreadProc finished\n"));
return rc;
}
static int svcPresentFBOInit(void)
{
int rc = VINF_SUCCESS;
g_SvcPresentFBO.pQueueHead = NULL;
g_SvcPresentFBO.pQueueTail = NULL;
g_SvcPresentFBO.bShutdownWorker = false;
rc = RTCritSectInit(&g_SvcPresentFBO.hQueueLock);
AssertRCReturn(rc, rc);
rc = RTSemEventCreate(&g_SvcPresentFBO.hEventProcess);
AssertRCReturn(rc, rc);
rc = RTThreadCreate(&g_SvcPresentFBO.hWorkerThread, svcPresentFBOWorkerThreadProc, NULL, 0,
RTTHREADTYPE_IO, RTTHREADFLAGS_WAITABLE, "OpenGLWorker");
AssertRCReturn(rc, rc);
crVBoxServerSetPresentFBOCB(svcPresentFBO);
return rc;
}
static int svcPresentFBOTearDown(void)
{
int rc = VINF_SUCCESS;
PCRVBOXSVCPRESENTFBOCMD_t pQueue, pTmp;
ASMAtomicWriteBool(&g_SvcPresentFBO.bShutdownWorker, true);
RTSemEventSignal(g_SvcPresentFBO.hEventProcess);
rc = RTThreadWait(g_SvcPresentFBO.hWorkerThread, 5000, NULL);
AssertRCReturn(rc, rc);
RTCritSectDelete(&g_SvcPresentFBO.hQueueLock);
RTSemEventDestroy(g_SvcPresentFBO.hEventProcess);
pQueue = g_SvcPresentFBO.pQueueHead;
while (pQueue)
{
pTmp = pQueue->pNext;
crFree(pQueue->pData);
RTMemFree(pQueue);
pQueue = pTmp;
}
g_SvcPresentFBO.pQueueHead = NULL;
g_SvcPresentFBO.pQueueTail = NULL;
return rc;
}
static DECLCALLBACK(void) svcNotifyEventCB(int32_t screenId, uint32_t uEvent, void*pvData)
{
ComPtr<IDisplay> pDisplay;
ComPtr<IFramebuffer> pFramebuffer;
LONG xo, yo;
if (!g_pConsole)
{
crWarning("Console not defined!");
return;
}
CHECK_ERROR2_STMT(g_pConsole, COMGETTER(Display)(pDisplay.asOutParam()), return);
CHECK_ERROR2_STMT(pDisplay, GetFramebuffer(screenId, pFramebuffer.asOutParam(), &xo, &yo), return);
if (!pFramebuffer)
return;
pFramebuffer->Notify3DEvent(uEvent, (BYTE*)pvData);
}
static DECLCALLBACK(int) svcUnload (void *)
{
int rc = VINF_SUCCESS;
Log(("SHARED_CROPENGL svcUnload\n"));
crVBoxServerTearDown();
svcPresentFBOTearDown();
return rc;
}
static DECLCALLBACK(int) svcConnect (void *, uint32_t u32ClientID, void *pvClient)
{
int rc = VINF_SUCCESS;
NOREF(pvClient);
Log(("SHARED_CROPENGL svcConnect: u32ClientID = %d\n", u32ClientID));
rc = crVBoxServerAddClient(u32ClientID);
return rc;
}
static DECLCALLBACK(int) svcDisconnect (void *, uint32_t u32ClientID, void *pvClient)
{
int rc = VINF_SUCCESS;
NOREF(pvClient);
Log(("SHARED_CROPENGL svcDisconnect: u32ClientID = %d\n", u32ClientID));
crVBoxServerRemoveClient(u32ClientID);
return rc;
}
static DECLCALLBACK(int) svcSaveState(void *, uint32_t u32ClientID, void *pvClient, PSSMHANDLE pSSM)
{
int rc = VINF_SUCCESS;
NOREF(pvClient);
Log(("SHARED_CROPENGL svcSaveState: u32ClientID = %d\n", u32ClientID));
/* Start*/
rc = SSMR3PutStrZ(pSSM, gszVBoxOGLSSMMagic);
AssertRCReturn(rc, rc);
/* Version */
rc = SSMR3PutU32(pSSM, (uint32_t) SHCROGL_SSM_VERSION);
AssertRCReturn(rc, rc);
/* The state itself */
rc = crVBoxServerSaveState(pSSM);
AssertRCReturn(rc, rc);
/* Save svc buffers info */
{
CRVBOXSVCBUFFER_t *pBuffer = g_pCRVBoxSVCBuffers;
rc = SSMR3PutU32(pSSM, g_CRVBoxSVCBufferID);
AssertRCReturn(rc, rc);
while (pBuffer)
{
rc = SSMR3PutU32(pSSM, pBuffer->uiId);
AssertRCReturn(rc, rc);
rc = SSMR3PutU32(pSSM, pBuffer->uiSize);
AssertRCReturn(rc, rc);
rc = SSMR3PutMem(pSSM, pBuffer->pData, pBuffer->uiSize);
AssertRCReturn(rc, rc);
pBuffer = pBuffer->pNext;
}
rc = SSMR3PutU32(pSSM, 0);
AssertRCReturn(rc, rc);
}
/* End */
rc = SSMR3PutStrZ(pSSM, gszVBoxOGLSSMMagic);
AssertRCReturn(rc, rc);
return VINF_SUCCESS;
}
static DECLCALLBACK(int) svcLoadState(void *, uint32_t u32ClientID, void *pvClient, PSSMHANDLE pSSM)
{
int rc = VINF_SUCCESS;
NOREF(pvClient);
Log(("SHARED_CROPENGL svcLoadState: u32ClientID = %d\n", u32ClientID));
char psz[2000];
uint32_t ui32;
/* Start of data */
rc = SSMR3GetStrZEx(pSSM, psz, 2000, NULL);
AssertRCReturn(rc, rc);
if (strcmp(gszVBoxOGLSSMMagic, psz))
return VERR_SSM_UNEXPECTED_DATA;
/* Version */
rc = SSMR3GetU32(pSSM, &ui32);
AssertRCReturn(rc, rc);
/* The state itself */
rc = crVBoxServerLoadState(pSSM, ui32);
if (rc==VERR_SSM_DATA_UNIT_FORMAT_CHANGED && ui32!=SHCROGL_SSM_VERSION)
{
LogRel(("SHARED_CROPENGL svcLoadState: unsupported save state version %d\n", ui32));
/*@todo ugly hack, as we don't know size of stored opengl data try to read untill end of opengl data marker*/
/*VboxSharedCrOpenGL isn't last hgcm service now, so can't use SSMR3SkipToEndOfUnit*/
{
const char *pMatch = &gszVBoxOGLSSMMagic[0];
char current;
while (*pMatch)
{
rc = SSMR3GetS8(pSSM, (int8_t*)&current);
AssertRCReturn(rc, rc);
if (current==*pMatch)
{
pMatch++;
}
else
{
pMatch = &gszVBoxOGLSSMMagic[0];
}
}
}
return VINF_SUCCESS;
}
AssertRCReturn(rc, rc);
/* Load svc buffers info */
if (ui32>=24)
{
uint32_t uiId;
rc = SSMR3GetU32(pSSM, &g_CRVBoxSVCBufferID);
AssertRCReturn(rc, rc);
rc = SSMR3GetU32(pSSM, &uiId);
AssertRCReturn(rc, rc);
while (uiId)
{
CRVBOXSVCBUFFER_t *pBuffer = (CRVBOXSVCBUFFER_t *) RTMemAlloc(sizeof(CRVBOXSVCBUFFER_t));
if (!pBuffer)
{
return VERR_NO_MEMORY;
}
pBuffer->uiId = uiId;
rc = SSMR3GetU32(pSSM, &pBuffer->uiSize);
AssertRCReturn(rc, rc);
pBuffer->pData = RTMemAlloc(pBuffer->uiSize);
if (!pBuffer->pData)
{
RTMemFree(pBuffer);
return VERR_NO_MEMORY;
}
rc = SSMR3GetMem(pSSM, pBuffer->pData, pBuffer->uiSize);
AssertRCReturn(rc, rc);
pBuffer->pNext = g_pCRVBoxSVCBuffers;
pBuffer->pPrev = NULL;
if (g_pCRVBoxSVCBuffers)
{
g_pCRVBoxSVCBuffers->pPrev = pBuffer;
}
g_pCRVBoxSVCBuffers = pBuffer;
rc = SSMR3GetU32(pSSM, &uiId);
AssertRCReturn(rc, rc);
}
}
/* End of data */
rc = SSMR3GetStrZEx(pSSM, psz, 2000, NULL);
AssertRCReturn(rc, rc);
if (strcmp(gszVBoxOGLSSMMagic, psz))
return VERR_SSM_UNEXPECTED_DATA;
return VINF_SUCCESS;
}
static void svcClientVersionUnsupported(uint32_t minor, uint32_t major)
{
LogRel(("SHARED_CROPENGL: unsupported client version %d.%d\n", minor, major));
/*MS's opengl32 tries to load our ICD around 30 times on failure...this is to prevent unnecessary spam*/
static int shown = 0;
if (g_pVM && !shown)
{
VMSetRuntimeError(g_pVM, VMSETRTERR_FLAGS_NO_WAIT, "3DSupportIncompatibleAdditions",
"An attempt by the virtual machine to use hardware 3D acceleration failed. "
"The version of the Guest Additions installed in the virtual machine does not match the "
"version of VirtualBox on the host. Please install appropriate Guest Additions to fix this issue");
shown = 1;
}
}
static CRVBOXSVCBUFFER_t* svcGetBuffer(uint32_t iBuffer, uint32_t cbBufferSize)
{
CRVBOXSVCBUFFER_t* pBuffer;
if (iBuffer)
{
pBuffer = g_pCRVBoxSVCBuffers;
while (pBuffer)
{
if (pBuffer->uiId == iBuffer)
{
if (cbBufferSize && pBuffer->uiSize!=cbBufferSize)
{
static int shown=0;
if (shown<20)
{
shown++;
LogRel(("SHARED_CROPENGL svcGetBuffer: invalid buffer(%i) size %i instead of %i\n",
iBuffer, pBuffer->uiSize, cbBufferSize));
}
return NULL;
}
return pBuffer;
}
pBuffer = pBuffer->pNext;
}
return NULL;
}
else /*allocate new buffer*/
{
pBuffer = (CRVBOXSVCBUFFER_t*) RTMemAlloc(sizeof(CRVBOXSVCBUFFER_t));
if (pBuffer)
{
pBuffer->pData = RTMemAlloc(cbBufferSize);
if (!pBuffer->pData)
{
LogRel(("SHARED_CROPENGL svcGetBuffer: not enough memory (%d)\n", cbBufferSize));
RTMemFree(pBuffer);
return NULL;
}
pBuffer->uiId = ++g_CRVBoxSVCBufferID;
if (!pBuffer->uiId)
{
pBuffer->uiId = ++g_CRVBoxSVCBufferID;
}
Assert(pBuffer->uiId);
pBuffer->uiSize = cbBufferSize;
pBuffer->pPrev = NULL;
pBuffer->pNext = g_pCRVBoxSVCBuffers;
if (g_pCRVBoxSVCBuffers)
{
g_pCRVBoxSVCBuffers->pPrev = pBuffer;
}
g_pCRVBoxSVCBuffers = pBuffer;
}
else
{
LogRel(("SHARED_CROPENGL svcGetBuffer: not enough memory (%d)\n", sizeof(CRVBOXSVCBUFFER_t)));
}
return pBuffer;
}
}
static void svcFreeBuffer(CRVBOXSVCBUFFER_t* pBuffer)
{
Assert(pBuffer);
if (pBuffer->pPrev)
{
pBuffer->pPrev->pNext = pBuffer->pNext;
}
else
{
Assert(pBuffer==g_pCRVBoxSVCBuffers);
g_pCRVBoxSVCBuffers = pBuffer->pNext;
}
if (pBuffer->pNext)
{
pBuffer->pNext->pPrev = pBuffer->pPrev;
}
RTMemFree(pBuffer->pData);
RTMemFree(pBuffer);
}
static DECLCALLBACK(void) svcCall (void *, VBOXHGCMCALLHANDLE callHandle, uint32_t u32ClientID, void *pvClient, uint32_t u32Function, uint32_t cParms, VBOXHGCMSVCPARM paParms[])
{
int rc = VINF_SUCCESS;
NOREF(pvClient);
Log(("SHARED_CROPENGL svcCall: u32ClientID = %d, fn = %d, cParms = %d, pparms = %d\n", u32ClientID, u32Function, cParms, paParms));
#ifdef DEBUG
uint32_t i;
for (i = 0; i < cParms; i++)
{
/** @todo parameters other than 32 bit */
Log((" pparms[%d]: type %d value %d\n", i, paParms[i].type, paParms[i].u.uint32));
}
#endif
switch (u32Function)
{
case SHCRGL_GUEST_FN_WRITE:
{
Log(("svcCall: SHCRGL_GUEST_FN_WRITE\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_WRITE)
{
rc = VERR_INVALID_PARAMETER;
}
else
if ( paParms[0].type != VBOX_HGCM_SVC_PARM_PTR /* pBuffer */
)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Fetch parameters. */
uint8_t *pBuffer = (uint8_t *)paParms[0].u.pointer.addr;
uint32_t cbBuffer = paParms[0].u.pointer.size;
/* Execute the function. */
rc = crVBoxServerClientWrite(u32ClientID, pBuffer, cbBuffer);
if (!RT_SUCCESS(rc))
{
Assert(VERR_NOT_SUPPORTED==rc);
svcClientVersionUnsupported(0, 0);
}
}
break;
}
case SHCRGL_GUEST_FN_INJECT:
{
Log(("svcCall: SHCRGL_GUEST_FN_INJECT\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_INJECT)
{
rc = VERR_INVALID_PARAMETER;
}
else
if ( paParms[0].type != VBOX_HGCM_SVC_PARM_32BIT /* u32ClientID */
|| paParms[1].type != VBOX_HGCM_SVC_PARM_PTR /* pBuffer */
)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Fetch parameters. */
uint32_t u32InjectClientID = paParms[0].u.uint32;
uint8_t *pBuffer = (uint8_t *)paParms[1].u.pointer.addr;
uint32_t cbBuffer = paParms[1].u.pointer.size;
/* Execute the function. */
rc = crVBoxServerClientWrite(u32InjectClientID, pBuffer, cbBuffer);
if (!RT_SUCCESS(rc))
{
if (VERR_NOT_SUPPORTED==rc)
{
svcClientVersionUnsupported(0, 0);
}
else
{
crWarning("SHCRGL_GUEST_FN_INJECT failed to inject for %i from %i", u32InjectClientID, u32ClientID);
}
}
}
break;
}
case SHCRGL_GUEST_FN_READ:
{
Log(("svcCall: SHCRGL_GUEST_FN_READ\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_READ)
{
rc = VERR_INVALID_PARAMETER;
}
else
if ( paParms[0].type != VBOX_HGCM_SVC_PARM_PTR /* pBuffer */
|| paParms[1].type != VBOX_HGCM_SVC_PARM_32BIT /* cbBuffer */
)
{
rc = VERR_INVALID_PARAMETER;
}
/* Fetch parameters. */
uint8_t *pBuffer = (uint8_t *)paParms[0].u.pointer.addr;
uint32_t cbBuffer = paParms[0].u.pointer.size;
/* Execute the function. */
rc = crVBoxServerClientRead(u32ClientID, pBuffer, &cbBuffer);
if (RT_SUCCESS(rc))
{
/* Update parameters.*/
paParms[0].u.pointer.size = cbBuffer; //@todo guest doesn't see this change somehow?
} else if (VERR_NOT_SUPPORTED==rc)
{
svcClientVersionUnsupported(0, 0);
}
/* Return the required buffer size always */
paParms[1].u.uint32 = cbBuffer;
break;
}
case SHCRGL_GUEST_FN_WRITE_READ:
{
Log(("svcCall: SHCRGL_GUEST_FN_WRITE_READ\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_WRITE_READ)
{
rc = VERR_INVALID_PARAMETER;
}
else
if ( paParms[0].type != VBOX_HGCM_SVC_PARM_PTR /* pBuffer */
|| paParms[1].type != VBOX_HGCM_SVC_PARM_PTR /* pWriteback */
|| paParms[2].type != VBOX_HGCM_SVC_PARM_32BIT /* cbWriteback */
)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Fetch parameters. */
uint8_t *pBuffer = (uint8_t *)paParms[0].u.pointer.addr;
uint32_t cbBuffer = paParms[0].u.pointer.size;
uint8_t *pWriteback = (uint8_t *)paParms[1].u.pointer.addr;
uint32_t cbWriteback = paParms[1].u.pointer.size;
/* Execute the function. */
rc = crVBoxServerClientWrite(u32ClientID, pBuffer, cbBuffer);
if (!RT_SUCCESS(rc))
{
Assert(VERR_NOT_SUPPORTED==rc);
svcClientVersionUnsupported(0, 0);
}
rc = crVBoxServerClientRead(u32ClientID, pWriteback, &cbWriteback);
if (RT_SUCCESS(rc))
{
/* Update parameters.*/
paParms[1].u.pointer.size = cbWriteback;
}
/* Return the required buffer size always */
paParms[2].u.uint32 = cbWriteback;
}
break;
}
case SHCRGL_GUEST_FN_SET_VERSION:
{
Log(("svcCall: SHCRGL_GUEST_FN_SET_VERSION\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_SET_VERSION)
{
rc = VERR_INVALID_PARAMETER;
}
else
if ( paParms[0].type != VBOX_HGCM_SVC_PARM_32BIT /* vMajor */
|| paParms[1].type != VBOX_HGCM_SVC_PARM_32BIT /* vMinor */
)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Fetch parameters. */
uint32_t vMajor = paParms[0].u.uint32;
uint32_t vMinor = paParms[1].u.uint32;
/* Execute the function. */
rc = crVBoxServerClientSetVersion(u32ClientID, vMajor, vMinor);
if (!RT_SUCCESS(rc))
{
svcClientVersionUnsupported(vMajor, vMinor);
}
}
break;
}
case SHCRGL_GUEST_FN_SET_PID:
{
Log(("svcCall: SHCRGL_GUEST_FN_SET_PID\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_SET_PID)
{
rc = VERR_INVALID_PARAMETER;
}
else
if (paParms[0].type != VBOX_HGCM_SVC_PARM_64BIT)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Fetch parameters. */
uint64_t pid = paParms[0].u.uint64;
/* Execute the function. */
rc = crVBoxServerClientSetPID(u32ClientID, pid);
}
break;
}
case SHCRGL_GUEST_FN_WRITE_BUFFER:
{
Log(("svcCall: SHCRGL_GUEST_FN_WRITE_BUFFER\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_WRITE_BUFFER)
{
rc = VERR_INVALID_PARAMETER;
}
else
if ( paParms[0].type != VBOX_HGCM_SVC_PARM_32BIT /*iBufferID*/
|| paParms[1].type != VBOX_HGCM_SVC_PARM_32BIT /*cbBufferSize*/
|| paParms[2].type != VBOX_HGCM_SVC_PARM_32BIT /*ui32Offset*/
|| paParms[3].type != VBOX_HGCM_SVC_PARM_PTR /*pBuffer*/
)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Fetch parameters. */
uint32_t iBuffer = paParms[0].u.uint32;
uint32_t cbBufferSize = paParms[1].u.uint32;
uint32_t ui32Offset = paParms[2].u.uint32;
uint8_t *pBuffer = (uint8_t *)paParms[3].u.pointer.addr;
uint32_t cbBuffer = paParms[3].u.pointer.size;
/* Execute the function. */
CRVBOXSVCBUFFER_t *pSvcBuffer = svcGetBuffer(iBuffer, cbBufferSize);
if (!pSvcBuffer || ((uint64_t)ui32Offset+cbBuffer)>cbBufferSize)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
memcpy((void*)((uintptr_t)pSvcBuffer->pData+ui32Offset), pBuffer, cbBuffer);
/* Return the buffer id */
paParms[0].u.uint32 = pSvcBuffer->uiId;
}
}
break;
}
case SHCRGL_GUEST_FN_WRITE_READ_BUFFERED:
{
Log(("svcCall: SHCRGL_GUEST_FN_WRITE_READ_BUFFERED\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_WRITE_READ_BUFFERED)
{
rc = VERR_INVALID_PARAMETER;
}
else
if ( paParms[0].type != VBOX_HGCM_SVC_PARM_32BIT /* iBufferID */
|| paParms[1].type != VBOX_HGCM_SVC_PARM_PTR /* pWriteback */
|| paParms[2].type != VBOX_HGCM_SVC_PARM_32BIT /* cbWriteback */
|| !paParms[0].u.uint32 /*iBufferID can't be 0 here*/
)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Fetch parameters. */
uint32_t iBuffer = paParms[0].u.uint32;
uint8_t *pWriteback = (uint8_t *)paParms[1].u.pointer.addr;
uint32_t cbWriteback = paParms[1].u.pointer.size;
CRVBOXSVCBUFFER_t *pSvcBuffer = svcGetBuffer(iBuffer, 0);
if (!pSvcBuffer)
{
LogRel(("SHARED_CROPENGL svcCall(WRITE_READ_BUFFERED): invalid buffer (%d)\n", iBuffer));
rc = VERR_INVALID_PARAMETER;
break;
}
uint8_t *pBuffer = (uint8_t *)pSvcBuffer->pData;
uint32_t cbBuffer = pSvcBuffer->uiSize;
/* Execute the function. */
rc = crVBoxServerClientWrite(u32ClientID, pBuffer, cbBuffer);
if (!RT_SUCCESS(rc))
{
Assert(VERR_NOT_SUPPORTED==rc);
svcClientVersionUnsupported(0, 0);
}
rc = crVBoxServerClientRead(u32ClientID, pWriteback, &cbWriteback);
if (RT_SUCCESS(rc))
{
/* Update parameters.*/
paParms[1].u.pointer.size = cbWriteback;
}
/* Return the required buffer size always */
paParms[2].u.uint32 = cbWriteback;
svcFreeBuffer(pSvcBuffer);
}
break;
}
case SHCRGL_GUEST_FN_GET_CAPS:
{
Log(("svcCall: SHCRGL_GUEST_FN_GET_CAPS\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_GET_CAPS)
{
rc = VERR_INVALID_PARAMETER;
}
else
if (paParms[0].type != VBOX_HGCM_SVC_PARM_32BIT)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Execute the function. */
rc = crVBoxServerClientGetCaps(u32ClientID, &paParms[0].u.uint32);
AssertRC(rc);
}
break;
}
default:
{
rc = VERR_NOT_IMPLEMENTED;
}
}
LogFlow(("svcCall: rc = %Rrc\n", rc));
g_pHelpers->pfnCallComplete (callHandle, rc);
}
/*
* We differentiate between a function handler for the guest and one for the host.
*/
static DECLCALLBACK(int) svcHostCall (void *, uint32_t u32Function, uint32_t cParms, VBOXHGCMSVCPARM paParms[])
{
int rc = VINF_SUCCESS;
Log(("SHARED_CROPENGL svcHostCall: fn = %d, cParms = %d, pparms = %d\n", u32Function, cParms, paParms));
#ifdef DEBUG
uint32_t i;
for (i = 0; i < cParms; i++)
{
/** @todo parameters other than 32 bit */
Log((" pparms[%d]: type %d value %d\n", i, paParms[i].type, paParms[i].u.uint32));
}
#endif
switch (u32Function)
{
case SHCRGL_HOST_FN_CRCMD_NOTIFY_CMDS:
{
rc = crVBoxServerCrCmdNotifyCmds();
} break;
#ifdef VBOX_WITH_CRHGSMI
case SHCRGL_HOST_FN_CRHGSMI_CMD:
{
Assert(cParms == 1 && paParms[0].type == VBOX_HGCM_SVC_PARM_PTR);
if (cParms == 1 && paParms[0].type == VBOX_HGCM_SVC_PARM_PTR)
{
rc = crVBoxServerCrHgsmiCmd((PVBOXVDMACMD_CHROMIUM_CMD)paParms[0].u.pointer.addr, paParms[0].u.pointer.size);
if (VERR_NOT_SUPPORTED == rc)
{
svcClientVersionUnsupported(0, 0);
}
}
else
rc = VERR_INVALID_PARAMETER;
} break;
case SHCRGL_HOST_FN_CRHGSMI_CTL:
{
Assert(cParms == 1 && paParms[0].type == VBOX_HGCM_SVC_PARM_PTR);
if (cParms == 1 && paParms[0].type == VBOX_HGCM_SVC_PARM_PTR)
rc = crVBoxServerCrHgsmiCtl((PVBOXVDMACMD_CHROMIUM_CTL)paParms[0].u.pointer.addr, paParms[0].u.pointer.size);
else
rc = VERR_INVALID_PARAMETER;
} break;
#endif
case SHCRGL_HOST_FN_SET_CONSOLE:
{
Log(("svcCall: SHCRGL_HOST_FN_SET_DISPLAY\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_SET_CONSOLE)
{
rc = VERR_INVALID_PARAMETER;
}
else if (paParms[0].type != VBOX_HGCM_SVC_PARM_PTR)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Fetch parameters. */
IConsole* pConsole = (IConsole*)paParms[0].u.pointer.addr;
uint32_t cbData = paParms[0].u.pointer.size;
/* Verify parameters values. */
if (cbData != sizeof (IConsole*))
{
rc = VERR_INVALID_PARAMETER;
}
else if (!pConsole)
{
rc = VERR_INVALID_PARAMETER;
}
else /* Execute the function. */
{
ComPtr<IMachine> pMachine;
ComPtr<IDisplay> pDisplay;
ComPtr<IFramebuffer> pFramebuffer;
LONG xo, yo;
LONG64 winId = 0;
ULONG monitorCount, i, w, h;
CHECK_ERROR_BREAK(pConsole, COMGETTER(Machine)(pMachine.asOutParam()));
CHECK_ERROR_BREAK(pMachine, COMGETTER(MonitorCount)(&monitorCount));
CHECK_ERROR_BREAK(pConsole, COMGETTER(Display)(pDisplay.asOutParam()));
crServerVBoxCompositionSetEnableStateGlobal(GL_FALSE);
g_pConsole = pConsole;
rc = crVBoxServerSetScreenCount(monitorCount);
AssertRCReturn(rc, rc);
for (i=0; i<monitorCount; ++i)
{
CHECK_ERROR_RET(pDisplay, GetFramebuffer(i, pFramebuffer.asOutParam(), &xo, &yo), rc);
if (!pFramebuffer)
{
rc = crVBoxServerUnmapScreen(i);
AssertRCReturn(rc, rc);
}
else
{
CHECK_ERROR_RET(pFramebuffer, COMGETTER(WinId)(&winId), rc);
CHECK_ERROR_RET(pFramebuffer, COMGETTER(Width)(&w), rc);
CHECK_ERROR_RET(pFramebuffer, COMGETTER(Height)(&h), rc);
rc = crVBoxServerMapScreen(i, xo, yo, w, h, winId);
AssertRCReturn(rc, rc);
}
}
crServerVBoxCompositionSetEnableStateGlobal(GL_TRUE);
rc = VINF_SUCCESS;
}
}
break;
}
case SHCRGL_HOST_FN_SET_VM:
{
Log(("svcCall: SHCRGL_HOST_FN_SET_VM\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_SET_VM)
{
rc = VERR_INVALID_PARAMETER;
}
else if (paParms[0].type != VBOX_HGCM_SVC_PARM_PTR)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Fetch parameters. */
PVM pVM = (PVM)paParms[0].u.pointer.addr;
uint32_t cbData = paParms[0].u.pointer.size;
/* Verify parameters values. */
if (cbData != sizeof (PVM))
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Execute the function. */
g_pVM = pVM;
rc = VINF_SUCCESS;
}
}
break;
}
case SHCRGL_HOST_FN_SET_VISIBLE_REGION:
{
Log(("svcCall: SHCRGL_HOST_FN_SET_VISIBLE_REGION\n"));
if (cParms != SHCRGL_CPARMS_SET_VISIBLE_REGION)
{
rc = VERR_INVALID_PARAMETER;
break;
}
if ( paParms[0].type != VBOX_HGCM_SVC_PARM_PTR /* pRects */
|| paParms[1].type != VBOX_HGCM_SVC_PARM_32BIT /* cRects */
)
{
rc = VERR_INVALID_PARAMETER;
break;
}
Assert(sizeof(RTRECT)==4*sizeof(GLint));
rc = crVBoxServerSetRootVisibleRegion(paParms[1].u.uint32, (const RTRECT*)paParms[0].u.pointer.addr);
break;
}
case SHCRGL_HOST_FN_SCREEN_CHANGED:
{
Log(("svcCall: SHCRGL_HOST_FN_SCREEN_CHANGED\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_SCREEN_CHANGED)
{
rc = VERR_INVALID_PARAMETER;
}
else if (paParms[0].type != VBOX_HGCM_SVC_PARM_32BIT)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Fetch parameters. */
uint32_t screenId = paParms[0].u.uint32;
/* Execute the function. */
ComPtr<IDisplay> pDisplay;
ComPtr<IFramebuffer> pFramebuffer;
LONG xo, yo;
LONG64 winId = 0;
ULONG w, h;
Assert(g_pConsole);
CHECK_ERROR_RET(g_pConsole, COMGETTER(Display)(pDisplay.asOutParam()), rc);
CHECK_ERROR_RET(pDisplay, GetFramebuffer(screenId, pFramebuffer.asOutParam(), &xo, &yo), rc);
crServerVBoxCompositionSetEnableStateGlobal(GL_FALSE);
if (!pFramebuffer)
{
rc = crVBoxServerUnmapScreen(screenId);
AssertRCReturn(rc, rc);
}
else
{
CHECK_ERROR_RET(pFramebuffer, COMGETTER(WinId)(&winId), rc);
if (!winId)
{
/* View associated with framebuffer is destroyed, happens with 2d accel enabled */
rc = crVBoxServerUnmapScreen(screenId);
AssertRCReturn(rc, rc);
}
else
{
CHECK_ERROR_RET(pFramebuffer, COMGETTER(Width)(&w), rc);
CHECK_ERROR_RET(pFramebuffer, COMGETTER(Height)(&h), rc);
rc = crVBoxServerMapScreen(screenId, xo, yo, w, h, winId);
AssertRCReturn(rc, rc);
}
}
crServerVBoxCompositionSetEnableStateGlobal(GL_TRUE);
rc = VINF_SUCCESS;
}
break;
}
case SHCRGL_HOST_FN_DEV_RESIZE:
{
Log(("svcCall: SHCRGL_HOST_FN_DEV_RESIZE\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_DEV_RESIZE)
{
LogRel(("SHCRGL_HOST_FN_DEV_RESIZE: cParms invalid - %d", cParms));
rc = VERR_INVALID_PARAMETER;
break;
}
for (int i = 0; i < SHCRGL_CPARMS_DEV_RESIZE; ++i)
{
if (paParms[i].type != VBOX_HGCM_SVC_PARM_PTR
|| !paParms[i].u.pointer.addr)
{
AssertMsgFailed(("invalid param\n"));
return VERR_INVALID_PARAMETER;
}
}
rc = crVBoxServerNotifyResize((const VBVAINFOSCREEN *)paParms[0].u.pointer.addr, paParms[1].u.pointer.addr);
break;
}
case SHCRGL_HOST_FN_VIEWPORT_CHANGED:
{
Log(("svcCall: SHCRGL_HOST_FN_VIEWPORT_CHANGED\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_VIEWPORT_CHANGED)
{
LogRel(("SHCRGL_HOST_FN_VIEWPORT_CHANGED: cParms invalid - %d", cParms));
rc = VERR_INVALID_PARAMETER;
break;
}
for (int i = 0; i < SHCRGL_CPARMS_VIEWPORT_CHANGED; ++i)
{
if (paParms[i].type != VBOX_HGCM_SVC_PARM_32BIT)
{
LogRel(("SHCRGL_HOST_FN_VIEWPORT_CHANGED: param[%d] type invalid - %d", i, paParms[i].type));
rc = VERR_INVALID_PARAMETER;
break;
}
}
if (!RT_SUCCESS(rc))
{
LogRel(("SHCRGL_HOST_FN_VIEWPORT_CHANGED: param validation failed, returning.."));
break;
}
crServerVBoxCompositionSetEnableStateGlobal(GL_FALSE);
rc = crVBoxServerSetScreenViewport((int)paParms[0].u.uint32,
paParms[1].u.uint32, /* x */
paParms[2].u.uint32, /* y */
paParms[3].u.uint32, /* w */
paParms[4].u.uint32 /* h */);
if (!RT_SUCCESS(rc))
{
LogRel(("SHCRGL_HOST_FN_VIEWPORT_CHANGED: crVBoxServerSetScreenViewport failed, rc %d", rc));
}
crServerVBoxCompositionSetEnableStateGlobal(GL_TRUE);
break;
}
case SHCRGL_HOST_FN_SET_OUTPUT_REDIRECT:
{
/*
* OutputRedirect.
* Note: the service calls OutputRedirect callbacks directly
* and they must not block. If asynchronous processing is needed,
* the callback provider must organize this.
*/
Log(("svcCall: SHCRGL_HOST_FN_SET_OUTPUT_REDIRECT\n"));
/* Verify parameter count and types. */
if (cParms != SHCRGL_CPARMS_SET_OUTPUT_REDIRECT)
{
rc = VERR_INVALID_PARAMETER;
}
else if (paParms[0].type != VBOX_HGCM_SVC_PARM_PTR)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
/* Fetch parameters. */
H3DOUTPUTREDIRECT *pOutputRedirect = (H3DOUTPUTREDIRECT *)paParms[0].u.pointer.addr;
uint32_t cbData = paParms[0].u.pointer.size;
/* Verify parameters values. */
if (cbData != sizeof (H3DOUTPUTREDIRECT))
{
rc = VERR_INVALID_PARAMETER;
}
else /* Execute the function. */
{
if (pOutputRedirect->H3DORBegin != NULL)
{
CROutputRedirect outputRedirect;
outputRedirect.pvContext = pOutputRedirect->pvContext;
outputRedirect.CRORBegin = pOutputRedirect->H3DORBegin;
outputRedirect.CRORGeometry = pOutputRedirect->H3DORGeometry;
outputRedirect.CRORVisibleRegion = pOutputRedirect->H3DORVisibleRegion;
outputRedirect.CRORFrame = pOutputRedirect->H3DORFrame;
outputRedirect.CROREnd = pOutputRedirect->H3DOREnd;
outputRedirect.CRORContextProperty = pOutputRedirect->H3DORContextProperty;
rc = crVBoxServerOutputRedirectSet(&outputRedirect);
if (RT_SUCCESS(rc))
{
rc = crVBoxServerSetOffscreenRendering(GL_TRUE);
}
}
else
{
/* Redirection is disabled. */
crVBoxServerSetOffscreenRendering(GL_FALSE);
crVBoxServerOutputRedirectSet(NULL);
}
}
}
break;
}
default:
rc = VERR_NOT_IMPLEMENTED;
break;
}
LogFlow(("svcHostCall: rc = %Rrc\n", rc));
return rc;
}
extern "C" DECLCALLBACK(DECLEXPORT(int)) VBoxHGCMSvcLoad (VBOXHGCMSVCFNTABLE *ptable)
{
int rc = VINF_SUCCESS;
Log(("SHARED_CROPENGL VBoxHGCMSvcLoad: ptable = %p\n", ptable));
if (!ptable)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
Log(("VBoxHGCMSvcLoad: ptable->cbSize = %d, ptable->u32Version = 0x%08X\n", ptable->cbSize, ptable->u32Version));
if ( ptable->cbSize != sizeof (VBOXHGCMSVCFNTABLE)
|| ptable->u32Version != VBOX_HGCM_SVC_VERSION)
{
rc = VERR_INVALID_PARAMETER;
}
else
{
g_pHelpers = ptable->pHelpers;
ptable->cbClient = sizeof (void*);
ptable->pfnUnload = svcUnload;
ptable->pfnConnect = svcConnect;
ptable->pfnDisconnect = svcDisconnect;
ptable->pfnCall = svcCall;
ptable->pfnHostCall = svcHostCall;
ptable->pfnSaveState = svcSaveState;
ptable->pfnLoadState = svcLoadState;
ptable->pvService = NULL;
if (!crVBoxServerInit())
return VERR_NOT_SUPPORTED;
rc = svcPresentFBOInit();
crServerVBoxSetNotifyEventCB(svcNotifyEventCB);
}
}
return rc;
}
#ifdef RT_OS_WINDOWS
#define WIN32_LEAN_AND_MEAN
#include <windows.h>
BOOL WINAPI DllMain(HINSTANCE hDLLInst, DWORD fdwReason, LPVOID lpvReserved)
{
(void) lpvReserved;
switch (fdwReason)
{
case DLL_THREAD_ATTACH:
{
crStateVBoxAttachThread();
break;
}
case DLL_PROCESS_DETACH:
/* do exactly the same thing as for DLL_THREAD_DETACH since
* DLL_THREAD_DETACH is not called for the thread doing DLL_PROCESS_DETACH according to msdn docs */
case DLL_THREAD_DETACH:
{
crStateVBoxDetachThread();
break;
}
case DLL_PROCESS_ATTACH:
default:
break;
}
return TRUE;
}
#endif