[15532] | 1 | /* $Id: vboxhgcm.c 69989 2017-12-07 16:25:08Z vboxsync $ */
|
---|
| 2 | /** @file
|
---|
| 3 | * VBox HGCM connection
|
---|
| 4 | */
|
---|
| 5 |
|
---|
| 6 | /*
|
---|
[69500] | 7 | * Copyright (C) 2008-2017 Oracle Corporation
|
---|
[15532] | 8 | *
|
---|
| 9 | * This file is part of VirtualBox Open Source Edition (OSE), as
|
---|
| 10 | * available from http://www.virtualbox.org. This file is free software;
|
---|
| 11 | * you can redistribute it and/or modify it under the terms of the GNU
|
---|
| 12 | * General Public License (GPL) as published by the Free Software
|
---|
| 13 | * Foundation, in version 2 as it comes in the "COPYING" file of the
|
---|
| 14 | * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
|
---|
| 15 | * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
|
---|
| 16 | */
|
---|
[62812] | 17 |
|
---|
[15532] | 18 | #ifdef RT_OS_WINDOWS
|
---|
[62680] | 19 | # include <iprt/win/windows.h>
|
---|
| 20 | # include <ddraw.h>
|
---|
[15532] | 21 | #else
|
---|
[62680] | 22 | # include <sys/ioctl.h>
|
---|
| 23 | # include <errno.h>
|
---|
| 24 | # include <fcntl.h>
|
---|
| 25 | # include <string.h>
|
---|
| 26 | # include <unistd.h>
|
---|
[15532] | 27 | #endif
|
---|
| 28 |
|
---|
| 29 | #include "cr_error.h"
|
---|
| 30 | #include "cr_net.h"
|
---|
| 31 | #include "cr_bufpool.h"
|
---|
| 32 | #include "cr_mem.h"
|
---|
| 33 | #include "cr_string.h"
|
---|
| 34 | #include "cr_endian.h"
|
---|
| 35 | #include "cr_threads.h"
|
---|
| 36 | #include "net_internals.h"
|
---|
[33988] | 37 | #include "cr_process.h"
|
---|
[15532] | 38 |
|
---|
[69989] | 39 | #include <iprt/initterm.h>
|
---|
[32511] | 40 | #include <iprt/thread.h>
|
---|
| 41 |
|
---|
[68472] | 42 | #include <VBox/VBoxGuestLib.h>
|
---|
[15532] | 43 | #include <VBox/HostServices/VBoxCrOpenGLSvc.h>
|
---|
| 44 |
|
---|
[33561] | 45 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
[65381] | 46 | #include <VBoxCrHgsmi.h>
|
---|
[33561] | 47 | #endif
|
---|
| 48 |
|
---|
[69392] | 49 | /** @todo move define somewhere else, and make sure it's less than VBGLR0_MAX_HGCM_KERNEL_PARM*/
|
---|
[34571] | 50 | /*If we fail to pass data in one chunk, send it in chunks of this size instead*/
|
---|
| 51 | #define CR_HGCM_SPLIT_BUFFER_SIZE (8*_1M)
|
---|
| 52 |
|
---|
| 53 | #ifndef MIN
|
---|
| 54 | # define MIN(a, b) ((a) < (b) ? (a) : (b))
|
---|
| 55 | #endif
|
---|
| 56 |
|
---|
[33684] | 57 | #ifdef DEBUG_misha
|
---|
| 58 | #ifdef CRASSERT
|
---|
| 59 | # undef CRASSERT
|
---|
| 60 | #endif
|
---|
| 61 | #define CRASSERT Assert
|
---|
| 62 | #endif
|
---|
[63199] | 63 | /*#define IN_GUEST
|
---|
| 64 | #if defined(IN_GUEST)
|
---|
| 65 | #define VBOX_WITH_CRHGSMIPROFILE
|
---|
| 66 | #endif */
|
---|
[33365] | 67 | #ifdef VBOX_WITH_CRHGSMIPROFILE
|
---|
| 68 | #include <iprt/time.h>
|
---|
| 69 | #include <stdio.h>
|
---|
| 70 |
|
---|
| 71 | typedef struct VBOXCRHGSMIPROFILE
|
---|
| 72 | {
|
---|
| 73 | uint64_t cStartTime;
|
---|
| 74 | uint64_t cStepsTime;
|
---|
| 75 | uint64_t cSteps;
|
---|
| 76 | } VBOXCRHGSMIPROFILE, *PVBOXCRHGSMIPROFILE;
|
---|
| 77 |
|
---|
| 78 | #define VBOXCRHGSMIPROFILE_GET_TIME_NANO() RTTimeNanoTS()
|
---|
| 79 | #define VBOXCRHGSMIPROFILE_GET_TIME_MILLI() RTTimeMilliTS()
|
---|
| 80 |
|
---|
| 81 | /* 10 sec */
|
---|
| 82 | #define VBOXCRHGSMIPROFILE_LOG_STEP_TIME (10000000000.)
|
---|
| 83 |
|
---|
| 84 | DECLINLINE(void) vboxCrHgsmiProfileStart(PVBOXCRHGSMIPROFILE pProfile)
|
---|
| 85 | {
|
---|
| 86 | pProfile->cStepsTime = 0;
|
---|
| 87 | pProfile->cSteps = 0;
|
---|
| 88 | pProfile->cStartTime = VBOXCRHGSMIPROFILE_GET_TIME_NANO();
|
---|
| 89 | }
|
---|
| 90 |
|
---|
| 91 | DECLINLINE(void) vboxCrHgsmiProfileStep(PVBOXCRHGSMIPROFILE pProfile, uint64_t cStepTime)
|
---|
| 92 | {
|
---|
| 93 | pProfile->cStepsTime += cStepTime;
|
---|
| 94 | ++pProfile->cSteps;
|
---|
| 95 | }
|
---|
| 96 |
|
---|
| 97 | typedef struct VBOXCRHGSMIPROFILE_SCOPE
|
---|
| 98 | {
|
---|
| 99 | uint64_t cStartTime;
|
---|
[63199] | 100 | /* bool bDisable;*/
|
---|
[33365] | 101 | } VBOXCRHGSMIPROFILE_SCOPE, *PVBOXCRHGSMIPROFILE_SCOPE;
|
---|
| 102 |
|
---|
| 103 | static VBOXCRHGSMIPROFILE g_VBoxProfile;
|
---|
| 104 |
|
---|
| 105 | static void vboxCrHgsmiLog(char * szString, ...)
|
---|
| 106 | {
|
---|
| 107 | char szBuffer[4096] = {0};
|
---|
| 108 | va_list pArgList;
|
---|
| 109 | va_start(pArgList, szString);
|
---|
| 110 | _vsnprintf(szBuffer, sizeof(szBuffer) / sizeof(szBuffer[0]), szString, pArgList);
|
---|
| 111 | va_end(pArgList);
|
---|
| 112 |
|
---|
| 113 | #ifdef VBOX_WITH_CRHGSMI
|
---|
| 114 | VBoxCrHgsmiLog(szBuffer);
|
---|
| 115 | #else
|
---|
| 116 | OutputDebugString(szBuffer);
|
---|
| 117 | #endif
|
---|
| 118 | }
|
---|
| 119 |
|
---|
| 120 | DECLINLINE(void) vboxCrHgsmiProfileLog(PVBOXCRHGSMIPROFILE pProfile, uint64_t cTime)
|
---|
| 121 | {
|
---|
| 122 | uint64_t profileTime = cTime - pProfile->cStartTime;
|
---|
| 123 | double percent = ((double)100.0) * pProfile->cStepsTime / profileTime;
|
---|
| 124 | double cps = ((double)1000000000.) * pProfile->cSteps / profileTime;
|
---|
| 125 | vboxCrHgsmiLog("hgcm: cps: %.1f, host %.1f%%\n", cps, percent);
|
---|
| 126 | }
|
---|
| 127 |
|
---|
| 128 | DECLINLINE(void) vboxCrHgsmiProfileScopeEnter(PVBOXCRHGSMIPROFILE_SCOPE pScope)
|
---|
| 129 | {
|
---|
[63199] | 130 | /* pScope->bDisable = false; */
|
---|
[33365] | 131 | pScope->cStartTime = VBOXCRHGSMIPROFILE_GET_TIME_NANO();
|
---|
| 132 | }
|
---|
| 133 |
|
---|
| 134 | DECLINLINE(void) vboxCrHgsmiProfileScopeExit(PVBOXCRHGSMIPROFILE_SCOPE pScope)
|
---|
| 135 | {
|
---|
[63199] | 136 | /* if (!pScope->bDisable) */
|
---|
[33365] | 137 | {
|
---|
| 138 | uint64_t cTime = VBOXCRHGSMIPROFILE_GET_TIME_NANO();
|
---|
| 139 | vboxCrHgsmiProfileStep(&g_VBoxProfile, cTime - pScope->cStartTime);
|
---|
| 140 | if (VBOXCRHGSMIPROFILE_LOG_STEP_TIME < cTime - g_VBoxProfile.cStartTime)
|
---|
| 141 | {
|
---|
| 142 | vboxCrHgsmiProfileLog(&g_VBoxProfile, cTime);
|
---|
| 143 | vboxCrHgsmiProfileStart(&g_VBoxProfile);
|
---|
| 144 | }
|
---|
| 145 | }
|
---|
| 146 | }
|
---|
| 147 |
|
---|
| 148 |
|
---|
| 149 | #define VBOXCRHGSMIPROFILE_INIT() vboxCrHgsmiProfileStart(&g_VBoxProfile)
|
---|
| 150 | #define VBOXCRHGSMIPROFILE_TERM() do {} while (0)
|
---|
| 151 |
|
---|
| 152 | #define VBOXCRHGSMIPROFILE_FUNC_PROLOGUE() \
|
---|
| 153 | VBOXCRHGSMIPROFILE_SCOPE __vboxCrHgsmiProfileScope; \
|
---|
| 154 | vboxCrHgsmiProfileScopeEnter(&__vboxCrHgsmiProfileScope);
|
---|
| 155 |
|
---|
| 156 | #define VBOXCRHGSMIPROFILE_FUNC_EPILOGUE() \
|
---|
| 157 | vboxCrHgsmiProfileScopeExit(&__vboxCrHgsmiProfileScope); \
|
---|
| 158 |
|
---|
| 159 |
|
---|
| 160 | #else
|
---|
| 161 | #define VBOXCRHGSMIPROFILE_INIT() do {} while (0)
|
---|
| 162 | #define VBOXCRHGSMIPROFILE_TERM() do {} while (0)
|
---|
| 163 | #define VBOXCRHGSMIPROFILE_FUNC_PROLOGUE() do {} while (0)
|
---|
| 164 | #define VBOXCRHGSMIPROFILE_FUNC_EPILOGUE() do {} while (0)
|
---|
| 165 | #endif
|
---|
| 166 |
|
---|
[15532] | 167 | typedef struct {
|
---|
| 168 | int initialized;
|
---|
| 169 | int num_conns;
|
---|
| 170 | CRConnection **conns;
|
---|
| 171 | CRBufferPool *bufpool;
|
---|
| 172 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 173 | CRmutex mutex;
|
---|
| 174 | CRmutex recvmutex;
|
---|
| 175 | #endif
|
---|
| 176 | CRNetReceiveFuncList *recv_list;
|
---|
| 177 | CRNetCloseFuncList *close_list;
|
---|
| 178 | #ifdef RT_OS_WINDOWS
|
---|
| 179 | LPDIRECTDRAW pDirectDraw;
|
---|
| 180 | #endif
|
---|
[50984] | 181 | #ifdef IN_GUEST
|
---|
| 182 | uint32_t u32HostCaps;
|
---|
| 183 | bool fHostCapsInitialized;
|
---|
| 184 | #endif
|
---|
[33561] | 185 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 186 | bool bHgsmiOn;
|
---|
| 187 | #endif
|
---|
[15532] | 188 | } CRVBOXHGCMDATA;
|
---|
| 189 |
|
---|
| 190 | static CRVBOXHGCMDATA g_crvboxhgcm = {0,};
|
---|
| 191 |
|
---|
| 192 | typedef enum {
|
---|
| 193 | CR_VBOXHGCM_USERALLOCATED,
|
---|
| 194 | CR_VBOXHGCM_MEMORY,
|
---|
| 195 | CR_VBOXHGCM_MEMORY_BIG
|
---|
[33561] | 196 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 197 | ,CR_VBOXHGCM_UHGSMI_BUFFER
|
---|
| 198 | #endif
|
---|
[15532] | 199 | } CRVBOXHGCMBUFFERKIND;
|
---|
| 200 |
|
---|
| 201 | #define CR_VBOXHGCM_BUFFER_MAGIC 0xABCDE321
|
---|
| 202 |
|
---|
| 203 | typedef struct CRVBOXHGCMBUFFER {
|
---|
| 204 | uint32_t magic;
|
---|
| 205 | CRVBOXHGCMBUFFERKIND kind;
|
---|
[33561] | 206 | union
|
---|
| 207 | {
|
---|
| 208 | struct
|
---|
| 209 | {
|
---|
| 210 | uint32_t len;
|
---|
| 211 | uint32_t allocated;
|
---|
| 212 | };
|
---|
| 213 |
|
---|
| 214 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 215 | PVBOXUHGSMI_BUFFER pBuffer;
|
---|
| 216 | #endif
|
---|
| 217 | };
|
---|
[15532] | 218 | } CRVBOXHGCMBUFFER;
|
---|
| 219 |
|
---|
| 220 | #ifndef RT_OS_WINDOWS
|
---|
| 221 | #define TRUE true
|
---|
| 222 | #define FALSE false
|
---|
| 223 | #define INVALID_HANDLE_VALUE (-1)
|
---|
| 224 | #endif
|
---|
| 225 |
|
---|
[33561] | 226 |
|
---|
| 227 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 228 |
|
---|
| 229 | /* add sizeof header + page align */
|
---|
| 230 | #define CRVBOXHGSMI_PAGE_ALIGN(_s) (((_s) + 0xfff) & ~0xfff)
|
---|
| 231 | #define CRVBOXHGSMI_BUF_HDR_SIZE() (sizeof (CRVBOXHGCMBUFFER))
|
---|
| 232 | #define CRVBOXHGSMI_BUF_SIZE(_s) CRVBOXHGSMI_PAGE_ALIGN((_s) + CRVBOXHGSMI_BUF_HDR_SIZE())
|
---|
| 233 | #define CRVBOXHGSMI_BUF_LOCK_SIZE(_s) ((_s) + CRVBOXHGSMI_BUF_HDR_SIZE())
|
---|
| 234 | #define CRVBOXHGSMI_BUF_DATA(_p) ((void*)(((CRVBOXHGCMBUFFER*)(_p)) + 1))
|
---|
| 235 | #define CRVBOXHGSMI_BUF_HDR(_p) (((CRVBOXHGCMBUFFER*)(_p)) - 1)
|
---|
| 236 | #define CRVBOXHGSMI_BUF_OFFSET(_st2, _st1) ((uint32_t)(((uint8_t*)(_st2)) - ((uint8_t*)(_st1))))
|
---|
| 237 |
|
---|
[33714] | 238 | static int _crVBoxHGSMIClientInit(PCRVBOXHGSMI_CLIENT pClient, PVBOXUHGSMI pHgsmi)
|
---|
| 239 | {
|
---|
| 240 | int rc;
|
---|
[41058] | 241 | VBOXUHGSMI_BUFFER_TYPE_FLAGS Flags = {0};
|
---|
[33714] | 242 | pClient->pHgsmi = pHgsmi;
|
---|
[41058] | 243 | Flags.fCommand = 1;
|
---|
| 244 | rc = pHgsmi->pfnBufferCreate(pHgsmi, CRVBOXHGSMI_PAGE_ALIGN(1), Flags, &pClient->pCmdBuffer);
|
---|
[33714] | 245 | if (RT_SUCCESS(rc))
|
---|
| 246 | {
|
---|
[41058] | 247 | Flags.Value = 0;
|
---|
| 248 | rc = pHgsmi->pfnBufferCreate(pHgsmi, CRVBOXHGSMI_PAGE_ALIGN(1), Flags, &pClient->pHGBuffer);
|
---|
[33714] | 249 | if (RT_SUCCESS(rc))
|
---|
| 250 | {
|
---|
| 251 | pClient->pvHGBuffer = NULL;
|
---|
| 252 | pClient->bufpool = crBufferPoolInit(16);
|
---|
| 253 | return VINF_SUCCESS;
|
---|
| 254 | }
|
---|
[41264] | 255 | else
|
---|
| 256 | crWarning("_crVBoxHGSMIClientInit: pfnBufferCreate failed to allocate host->guest buffer");
|
---|
| 257 |
|
---|
[33714] | 258 | pClient->pCmdBuffer->pfnDestroy(pClient->pCmdBuffer);
|
---|
| 259 | }
|
---|
[41264] | 260 | else
|
---|
| 261 | crWarning("_crVBoxHGSMIClientInit: pfnBufferCreate failed to allocate cmd buffer");
|
---|
| 262 |
|
---|
[33714] | 263 | pClient->pHgsmi = NULL;
|
---|
| 264 | return rc;
|
---|
| 265 | }
|
---|
| 266 |
|
---|
| 267 | void _crVBoxHGSMIBufferFree(void *data)
|
---|
| 268 | {
|
---|
| 269 | PVBOXUHGSMI_BUFFER pBuffer = (PVBOXUHGSMI_BUFFER)data;
|
---|
| 270 | pBuffer->pfnDestroy(pBuffer);
|
---|
| 271 | }
|
---|
| 272 |
|
---|
| 273 | static int _crVBoxHGSMIClientTerm(PCRVBOXHGSMI_CLIENT pClient, PVBOXUHGSMI *ppHgsmi)
|
---|
| 274 | {
|
---|
| 275 | if (pClient->bufpool)
|
---|
| 276 | crBufferPoolCallbackFree(pClient->bufpool, _crVBoxHGSMIBufferFree);
|
---|
| 277 | pClient->bufpool = NULL;
|
---|
| 278 |
|
---|
| 279 | if (pClient->pHGBuffer)
|
---|
| 280 | {
|
---|
| 281 | pClient->pHGBuffer->pfnDestroy(pClient->pHGBuffer);
|
---|
| 282 | pClient->pHGBuffer = NULL;
|
---|
| 283 | }
|
---|
| 284 |
|
---|
| 285 | if (pClient->pCmdBuffer)
|
---|
| 286 | {
|
---|
| 287 | pClient->pCmdBuffer->pfnDestroy(pClient->pCmdBuffer);
|
---|
| 288 | pClient->pCmdBuffer = NULL;
|
---|
| 289 | }
|
---|
| 290 |
|
---|
| 291 | if (ppHgsmi)
|
---|
| 292 | {
|
---|
| 293 | *ppHgsmi = pClient->pHgsmi;
|
---|
| 294 | }
|
---|
| 295 | pClient->pHgsmi = NULL;
|
---|
| 296 |
|
---|
| 297 | return VINF_SUCCESS;
|
---|
| 298 | }
|
---|
| 299 |
|
---|
| 300 |
|
---|
| 301 | #ifdef VBOX_CRHGSMI_WITH_D3DDEV
|
---|
| 302 |
|
---|
[57443] | 303 | static DECLCALLBACK(HVBOXCRHGSMI_CLIENT) _crVBoxHGSMIClientCreate(PVBOXUHGSMI pHgsmi)
|
---|
[33714] | 304 | {
|
---|
| 305 | PCRVBOXHGSMI_CLIENT pClient = crAlloc(sizeof (CRVBOXHGSMI_CLIENT));
|
---|
| 306 |
|
---|
| 307 | if (pClient)
|
---|
| 308 | {
|
---|
| 309 | int rc = _crVBoxHGSMIClientInit(pClient, pHgsmi);
|
---|
| 310 | if (RT_SUCCESS(rc))
|
---|
| 311 | return (HVBOXCRHGSMI_CLIENT)pClient;
|
---|
[41265] | 312 | else
|
---|
| 313 | crWarning("_crVBoxHGSMIClientCreate: _crVBoxHGSMIClientInit failed rc %d", rc);
|
---|
[33714] | 314 |
|
---|
| 315 | crFree(pCLient);
|
---|
| 316 | }
|
---|
| 317 |
|
---|
| 318 | return NULL;
|
---|
| 319 | }
|
---|
| 320 |
|
---|
[57443] | 321 | static DECLCALLBACK(void) _crVBoxHGSMIClientDestroy(HVBOXCRHGSMI_CLIENT hClient)
|
---|
[33714] | 322 | {
|
---|
| 323 | PCRVBOXHGSMI_CLIENT pClient = (PCRVBOXHGSMI_CLIENT)hClient;
|
---|
| 324 | _crVBoxHGSMIClientTerm(pClient, NULL);
|
---|
| 325 | crFree(pClient);
|
---|
| 326 | }
|
---|
| 327 | #endif
|
---|
| 328 |
|
---|
[33561] | 329 | DECLINLINE(PCRVBOXHGSMI_CLIENT) _crVBoxHGSMIClientGet(CRConnection *conn)
|
---|
| 330 | {
|
---|
[33714] | 331 | #ifdef VBOX_CRHGSMI_WITH_D3DDEV
|
---|
[33561] | 332 | PCRVBOXHGSMI_CLIENT pClient = (PCRVBOXHGSMI_CLIENT)VBoxCrHgsmiQueryClient();
|
---|
[36317] | 333 | CRASSERT(pClient);
|
---|
[33561] | 334 | return pClient;
|
---|
[33714] | 335 | #else
|
---|
| 336 | if (conn->HgsmiClient.pHgsmi)
|
---|
| 337 | return &conn->HgsmiClient;
|
---|
| 338 | {
|
---|
[42499] | 339 | PVBOXUHGSMI pHgsmi = conn->pExternalHgsmi ? conn->pExternalHgsmi : VBoxCrHgsmiCreate();
|
---|
[33714] | 340 | if (pHgsmi)
|
---|
| 341 | {
|
---|
| 342 | int rc = _crVBoxHGSMIClientInit(&conn->HgsmiClient, pHgsmi);
|
---|
| 343 | if (RT_SUCCESS(rc))
|
---|
| 344 | {
|
---|
[36317] | 345 | CRASSERT(conn->HgsmiClient.pHgsmi);
|
---|
[33714] | 346 | return &conn->HgsmiClient;
|
---|
| 347 | }
|
---|
[41265] | 348 | else
|
---|
| 349 | crWarning("_crVBoxHGSMIClientGet: _crVBoxHGSMIClientInit failed rc %d", rc);
|
---|
[42499] | 350 | if (!conn->pExternalHgsmi)
|
---|
| 351 | VBoxCrHgsmiDestroy(pHgsmi);
|
---|
[33714] | 352 | }
|
---|
[40544] | 353 | else
|
---|
| 354 | {
|
---|
| 355 | crWarning("VBoxCrHgsmiCreate failed");
|
---|
| 356 | }
|
---|
[33714] | 357 | }
|
---|
| 358 | return NULL;
|
---|
| 359 | #endif
|
---|
[33561] | 360 | }
|
---|
| 361 |
|
---|
| 362 | static PVBOXUHGSMI_BUFFER _crVBoxHGSMIBufAlloc(PCRVBOXHGSMI_CLIENT pClient, uint32_t cbSize)
|
---|
| 363 | {
|
---|
| 364 | PVBOXUHGSMI_BUFFER buf;
|
---|
| 365 | int rc;
|
---|
| 366 |
|
---|
| 367 | buf = (PVBOXUHGSMI_BUFFER ) crBufferPoolPop(pClient->bufpool, cbSize);
|
---|
| 368 |
|
---|
| 369 | if (!buf)
|
---|
| 370 | {
|
---|
[41058] | 371 | VBOXUHGSMI_BUFFER_TYPE_FLAGS Flags = {0};
|
---|
[33561] | 372 | crDebug("Buffer pool %p was empty; allocating new %d byte buffer.",
|
---|
| 373 | (void *) pClient->bufpool,
|
---|
| 374 | cbSize);
|
---|
[41058] | 375 | rc = pClient->pHgsmi->pfnBufferCreate(pClient->pHgsmi, cbSize, Flags, &buf);
|
---|
[33561] | 376 | if (RT_FAILURE(rc))
|
---|
[41264] | 377 | crWarning("_crVBoxHGSMIBufAlloc: Failed to Create a buffer of size(%d), rc(%d)\n", cbSize, rc);
|
---|
[33561] | 378 | }
|
---|
| 379 | return buf;
|
---|
| 380 | }
|
---|
| 381 |
|
---|
| 382 | static PVBOXUHGSMI_BUFFER _crVBoxHGSMIBufFromHdr(CRVBOXHGCMBUFFER *pHdr)
|
---|
| 383 | {
|
---|
| 384 | PVBOXUHGSMI_BUFFER pBuf;
|
---|
| 385 | int rc;
|
---|
| 386 | CRASSERT(pHdr->magic == CR_VBOXHGCM_BUFFER_MAGIC);
|
---|
| 387 | CRASSERT(pHdr->kind == CR_VBOXHGCM_UHGSMI_BUFFER);
|
---|
| 388 | pBuf = pHdr->pBuffer;
|
---|
| 389 | rc = pBuf->pfnUnlock(pBuf);
|
---|
| 390 | if (RT_FAILURE(rc))
|
---|
| 391 | {
|
---|
[41265] | 392 | crWarning("_crVBoxHGSMIBufFromHdr: pfnUnlock failed rc %d", rc);
|
---|
[33561] | 393 | return NULL;
|
---|
| 394 | }
|
---|
| 395 | return pBuf;
|
---|
| 396 | }
|
---|
| 397 |
|
---|
| 398 | static void _crVBoxHGSMIBufFree(PCRVBOXHGSMI_CLIENT pClient, PVBOXUHGSMI_BUFFER pBuf)
|
---|
| 399 | {
|
---|
| 400 | crBufferPoolPush(pClient->bufpool, pBuf, pBuf->cbBuffer);
|
---|
| 401 | }
|
---|
| 402 |
|
---|
| 403 | static CRVBOXHGSMIHDR *_crVBoxHGSMICmdBufferLock(PCRVBOXHGSMI_CLIENT pClient, uint32_t cbBuffer)
|
---|
| 404 | {
|
---|
| 405 | /* in theory it is OK to use one cmd buffer for asynch cmd submission
|
---|
| 406 | * because bDiscard flag should result in allocating a new memory backend if the
|
---|
| 407 | * allocation is still in use.
|
---|
| 408 | * However, NOTE: since one and the same semaphore synch event is used for completion notification,
|
---|
| 409 | * for the notification mechanism working as expected
|
---|
| 410 | * 1. host must complete commands in the same order as it receives them
|
---|
| 411 | * (to avoid situation when guest receives notification for another command completion)
|
---|
| 412 | * 2. guest must eventually wait for command completion unless he specified bDoNotSignalCompletion
|
---|
| 413 | * 3. guest must wait for command completion in the same order as it submits them
|
---|
| 414 | * in case we can not satisfy any of the above, we should introduce multiple command buffers */
|
---|
| 415 | CRVBOXHGSMIHDR * pHdr;
|
---|
| 416 | VBOXUHGSMI_BUFFER_LOCK_FLAGS fFlags;
|
---|
| 417 | int rc;
|
---|
| 418 | fFlags.Value = 0;
|
---|
| 419 | fFlags.bDiscard = 1;
|
---|
| 420 | rc = pClient->pCmdBuffer->pfnLock(pClient->pCmdBuffer, 0, cbBuffer, fFlags, (void**)&pHdr);
|
---|
| 421 | if (RT_SUCCESS(rc))
|
---|
| 422 | return pHdr;
|
---|
[41265] | 423 | else
|
---|
| 424 | crWarning("_crVBoxHGSMICmdBufferLock: pfnLock failed rc %d", rc);
|
---|
[33561] | 425 |
|
---|
| 426 | crWarning("Failed to Lock the command buffer of size(%d), rc(%d)\n", cbBuffer, rc);
|
---|
| 427 | return NULL;
|
---|
| 428 | }
|
---|
| 429 |
|
---|
| 430 | static CRVBOXHGSMIHDR *_crVBoxHGSMICmdBufferLockRo(PCRVBOXHGSMI_CLIENT pClient, uint32_t cbBuffer)
|
---|
| 431 | {
|
---|
| 432 | /* in theory it is OK to use one cmd buffer for asynch cmd submission
|
---|
| 433 | * because bDiscard flag should result in allocating a new memory backend if the
|
---|
| 434 | * allocation is still in use.
|
---|
| 435 | * However, NOTE: since one and the same semaphore synch event is used for completion notification,
|
---|
| 436 | * for the notification mechanism working as expected
|
---|
| 437 | * 1. host must complete commands in the same order as it receives them
|
---|
| 438 | * (to avoid situation when guest receives notification for another command completion)
|
---|
| 439 | * 2. guest must eventually wait for command completion unless he specified bDoNotSignalCompletion
|
---|
| 440 | * 3. guest must wait for command completion in the same order as it submits them
|
---|
| 441 | * in case we can not satisfy any of the above, we should introduce multiple command buffers */
|
---|
[41265] | 442 | CRVBOXHGSMIHDR * pHdr = NULL;
|
---|
[33561] | 443 | VBOXUHGSMI_BUFFER_LOCK_FLAGS fFlags;
|
---|
| 444 | int rc;
|
---|
| 445 | fFlags.Value = 0;
|
---|
| 446 | fFlags.bReadOnly = 1;
|
---|
| 447 | rc = pClient->pCmdBuffer->pfnLock(pClient->pCmdBuffer, 0, cbBuffer, fFlags, (void**)&pHdr);
|
---|
| 448 | if (RT_FAILURE(rc))
|
---|
| 449 | crWarning("Failed to Lock the command buffer of size(%d), rc(%d)\n", cbBuffer, rc);
|
---|
| 450 | return pHdr;
|
---|
| 451 | }
|
---|
| 452 |
|
---|
| 453 | static void _crVBoxHGSMICmdBufferUnlock(PCRVBOXHGSMI_CLIENT pClient)
|
---|
| 454 | {
|
---|
| 455 | int rc = pClient->pCmdBuffer->pfnUnlock(pClient->pCmdBuffer);
|
---|
| 456 | if (RT_FAILURE(rc))
|
---|
[41265] | 457 | crError("Failed to Unlock the command buffer rc(%d)\n", rc);
|
---|
[33561] | 458 | }
|
---|
| 459 |
|
---|
| 460 | static int32_t _crVBoxHGSMICmdBufferGetRc(PCRVBOXHGSMI_CLIENT pClient)
|
---|
| 461 | {
|
---|
| 462 | CRVBOXHGSMIHDR * pHdr;
|
---|
| 463 | VBOXUHGSMI_BUFFER_LOCK_FLAGS fFlags;
|
---|
| 464 | int rc;
|
---|
| 465 |
|
---|
| 466 | fFlags.Value = 0;
|
---|
| 467 | fFlags.bReadOnly = 1;
|
---|
| 468 | rc = pClient->pCmdBuffer->pfnLock(pClient->pCmdBuffer, 0, sizeof (*pHdr), fFlags, (void**)&pHdr);
|
---|
| 469 | if (RT_FAILURE(rc))
|
---|
| 470 | {
|
---|
| 471 | crWarning("Failed to Lock the command buffer of size(%d), rc(%d)\n", sizeof (*pHdr), rc);
|
---|
| 472 | return rc;
|
---|
| 473 | }
|
---|
| 474 |
|
---|
| 475 | rc = pHdr->result;
|
---|
| 476 | AssertRC(rc);
|
---|
| 477 | pClient->pCmdBuffer->pfnUnlock(pClient->pCmdBuffer);
|
---|
| 478 |
|
---|
| 479 | return rc;
|
---|
| 480 | }
|
---|
| 481 |
|
---|
| 482 | DECLINLINE(PVBOXUHGSMI_BUFFER) _crVBoxHGSMIRecvBufGet(PCRVBOXHGSMI_CLIENT pClient)
|
---|
| 483 | {
|
---|
| 484 | if (pClient->pvHGBuffer)
|
---|
| 485 | {
|
---|
| 486 | int rc = pClient->pHGBuffer->pfnUnlock(pClient->pHGBuffer);
|
---|
| 487 | if (RT_FAILURE(rc))
|
---|
| 488 | {
|
---|
| 489 | return NULL;
|
---|
| 490 | }
|
---|
| 491 | pClient->pvHGBuffer = NULL;
|
---|
| 492 | }
|
---|
| 493 | return pClient->pHGBuffer;
|
---|
| 494 | }
|
---|
| 495 |
|
---|
| 496 | DECLINLINE(void*) _crVBoxHGSMIRecvBufData(PCRVBOXHGSMI_CLIENT pClient, uint32_t cbBuffer)
|
---|
| 497 | {
|
---|
| 498 | VBOXUHGSMI_BUFFER_LOCK_FLAGS fFlags;
|
---|
| 499 | int rc;
|
---|
[36317] | 500 | CRASSERT(!pClient->pvHGBuffer);
|
---|
[33561] | 501 | fFlags.Value = 0;
|
---|
| 502 | rc = pClient->pHGBuffer->pfnLock(pClient->pHGBuffer, 0, cbBuffer, fFlags, &pClient->pvHGBuffer);
|
---|
| 503 | if (RT_SUCCESS(rc))
|
---|
| 504 | return pClient->pvHGBuffer;
|
---|
[41265] | 505 | else
|
---|
| 506 | crWarning("_crVBoxHGSMIRecvBufData: pfnLock failed rc %d", rc);
|
---|
| 507 |
|
---|
[33561] | 508 | return NULL;
|
---|
| 509 | }
|
---|
| 510 |
|
---|
| 511 | DECLINLINE(void) _crVBoxHGSMIFillCmd(VBOXUHGSMI_BUFFER_SUBMIT *pSubm, PCRVBOXHGSMI_CLIENT pClient, uint32_t cbData)
|
---|
| 512 | {
|
---|
| 513 | pSubm->pBuf = pClient->pCmdBuffer;
|
---|
| 514 | pSubm->offData = 0;
|
---|
| 515 | pSubm->cbData = cbData;
|
---|
| 516 | pSubm->fFlags.Value = 0;
|
---|
| 517 | pSubm->fFlags.bDoNotRetire = 1;
|
---|
[63199] | 518 | # if 0
|
---|
| 519 | pSubm->fFlags.bDoNotSignalCompletion = 1; /* <- we do not need that actually since
|
---|
| 520 | * in case we want completion,
|
---|
| 521 | * we will block in _crVBoxHGSMICmdBufferGetRc (when locking the buffer)
|
---|
| 522 | * which is needed for getting the result */
|
---|
| 523 | # endif
|
---|
[33561] | 524 | }
|
---|
| 525 | #endif
|
---|
| 526 |
|
---|
[15532] | 527 | /* Some forward declarations */
|
---|
[33365] | 528 | static void _crVBoxHGCMReceiveMessage(CRConnection *conn);
|
---|
[15532] | 529 |
|
---|
[17190] | 530 | #ifndef IN_GUEST
|
---|
[15532] | 531 | static bool _crVBoxHGCMReadBytes(CRConnection *conn, void *buf, uint32_t len)
|
---|
| 532 | {
|
---|
| 533 | CRASSERT(conn && buf);
|
---|
| 534 |
|
---|
| 535 | if (!conn->pBuffer || (conn->cbBuffer<len))
|
---|
| 536 | return FALSE;
|
---|
| 537 |
|
---|
| 538 | crMemcpy(buf, conn->pBuffer, len);
|
---|
| 539 |
|
---|
| 540 | conn->cbBuffer -= len;
|
---|
| 541 | conn->pBuffer = conn->cbBuffer>0 ? (uint8_t*)conn->pBuffer+len : NULL;
|
---|
| 542 |
|
---|
| 543 | return TRUE;
|
---|
| 544 | }
|
---|
[17190] | 545 | #endif
|
---|
[15532] | 546 |
|
---|
[63199] | 547 | #ifndef IN_GUEST
|
---|
[69392] | 548 | /** @todo get rid of it*/
|
---|
[15532] | 549 | static bool _crVBoxHGCMWriteBytes(CRConnection *conn, const void *buf, uint32_t len)
|
---|
| 550 | {
|
---|
| 551 | CRASSERT(conn && buf);
|
---|
| 552 |
|
---|
| 553 | /* make sure there's host buffer and it's clear */
|
---|
| 554 | CRASSERT(conn->pHostBuffer && !conn->cbHostBuffer);
|
---|
| 555 |
|
---|
[15707] | 556 | if (conn->cbHostBufferAllocated < len)
|
---|
| 557 | {
|
---|
[33595] | 558 | crDebug("Host buffer too small %d out of requested %d bytes, reallocating", conn->cbHostBufferAllocated, len);
|
---|
[15707] | 559 | crFree(conn->pHostBuffer);
|
---|
| 560 | conn->pHostBuffer = crAlloc(len);
|
---|
| 561 | if (!conn->pHostBuffer)
|
---|
| 562 | {
|
---|
| 563 | conn->cbHostBufferAllocated = 0;
|
---|
| 564 | crError("OUT_OF_MEMORY trying to allocate %d bytes", len);
|
---|
| 565 | return FALSE;
|
---|
| 566 | }
|
---|
| 567 | conn->cbHostBufferAllocated = len;
|
---|
| 568 | }
|
---|
| 569 |
|
---|
[15532] | 570 | crMemcpy(conn->pHostBuffer, buf, len);
|
---|
| 571 | conn->cbHostBuffer = len;
|
---|
| 572 |
|
---|
| 573 | return TRUE;
|
---|
| 574 | }
|
---|
[63199] | 575 | #endif
|
---|
[15532] | 576 |
|
---|
| 577 | /**
|
---|
| 578 | * Send an HGCM request
|
---|
| 579 | *
|
---|
| 580 | * @return VBox status code
|
---|
| 581 | * @param pvData Data pointer
|
---|
| 582 | * @param cbData Data size
|
---|
| 583 | */
|
---|
[68550] | 584 | static int crVBoxHGCMCall(CRConnection *conn, PVBGLIOCHGCMCALL pData, unsigned cbData)
|
---|
[15532] | 585 | {
|
---|
| 586 | #ifdef IN_GUEST
|
---|
[68473] | 587 | int rc;
|
---|
[63199] | 588 | # ifndef VBOX_WITH_CRHGSMI
|
---|
| 589 | RT_NOREF(conn);
|
---|
| 590 | # else
|
---|
[41912] | 591 | PCRVBOXHGSMI_CLIENT pClient = g_crvboxhgcm.bHgsmiOn ? _crVBoxHGSMIClientGet(conn) : NULL;
|
---|
[40483] | 592 | if (pClient)
|
---|
[68472] | 593 | rc = VBoxCrHgsmiCtlConCall(pClient->pHgsmi, pData, cbData);
|
---|
[40483] | 594 | else
|
---|
[40485] | 595 | # endif
|
---|
[69392] | 596 | {
|
---|
[68472] | 597 | rc = VbglR3HGCMCall(pData, cbData);
|
---|
| 598 | if (RT_SUCCESS(rc))
|
---|
| 599 | { /* likely */ }
|
---|
| 600 | else
|
---|
[32511] | 601 | {
|
---|
[68472] | 602 | crWarning("vboxCall failed with VBox status code %Rrc\n", rc);
|
---|
[68473] | 603 | # ifndef RT_OS_WINDOWS
|
---|
[68472] | 604 | if (rc == VERR_INTERRUPTED)
|
---|
[32511] | 605 | {
|
---|
[68472] | 606 | /* Not sure why we're doing the sleep stuff here. The original coder didn't
|
---|
| 607 | bother to mention why he thought it necessary. :-( */
|
---|
| 608 | RTMSINTERVAL msSleep;
|
---|
| 609 | int i;
|
---|
| 610 | for (i = 0, msSleep = 50; i < 6; i++, msSleep = msSleep * 2)
|
---|
[32511] | 611 | {
|
---|
[68472] | 612 | RTThreadSleep(msSleep);
|
---|
| 613 | rc = VbglR3HGCMCall(pData, cbData);
|
---|
| 614 | if (rc != VERR_INTERRUPTED)
|
---|
| 615 | {
|
---|
| 616 | if (RT_SUCCESS(rc))
|
---|
| 617 | crWarning("vboxCall retry(%i) succeeded", i + 1);
|
---|
| 618 | else
|
---|
| 619 | crWarning("vboxCall retry(%i) failed with VBox status code %Rrc", i + 1, rc);
|
---|
| 620 | break;
|
---|
| 621 | }
|
---|
[32511] | 622 | }
|
---|
| 623 | }
|
---|
[68472] | 624 | # endif
|
---|
[32511] | 625 | }
|
---|
| 626 | }
|
---|
[68472] | 627 | return rc;
|
---|
[63199] | 628 |
|
---|
| 629 | #else /* IN_GUEST */
|
---|
[68472] | 630 | RT_NOREF(conn, pData, cbData);
|
---|
[15532] | 631 | crError("crVBoxHGCMCall called on host side!");
|
---|
| 632 | CRASSERT(FALSE);
|
---|
| 633 | return VERR_NOT_SUPPORTED;
|
---|
[63199] | 634 | #endif /* IN_GUEST */
|
---|
[15532] | 635 | }
|
---|
| 636 |
|
---|
[33365] | 637 | static void *_crVBoxHGCMAlloc(CRConnection *conn)
|
---|
[15532] | 638 | {
|
---|
| 639 | CRVBOXHGCMBUFFER *buf;
|
---|
| 640 |
|
---|
| 641 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 642 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 643 | #endif
|
---|
| 644 |
|
---|
| 645 | buf = (CRVBOXHGCMBUFFER *) crBufferPoolPop(g_crvboxhgcm.bufpool, conn->buffer_size);
|
---|
| 646 |
|
---|
| 647 | if (!buf)
|
---|
| 648 | {
|
---|
| 649 | crDebug("Buffer pool %p was empty; allocating new %d byte buffer.",
|
---|
| 650 | (void *) g_crvboxhgcm.bufpool,
|
---|
| 651 | (unsigned int)sizeof(CRVBOXHGCMBUFFER) + conn->buffer_size);
|
---|
| 652 |
|
---|
| 653 | /* We're either on host side, or we failed to allocate DDRAW buffer */
|
---|
| 654 | if (!buf)
|
---|
| 655 | {
|
---|
| 656 | crDebug("Using system malloc\n");
|
---|
| 657 | buf = (CRVBOXHGCMBUFFER *) crAlloc( sizeof(CRVBOXHGCMBUFFER) + conn->buffer_size );
|
---|
| 658 | CRASSERT(buf);
|
---|
| 659 | buf->magic = CR_VBOXHGCM_BUFFER_MAGIC;
|
---|
| 660 | buf->kind = CR_VBOXHGCM_MEMORY;
|
---|
| 661 | buf->allocated = conn->buffer_size;
|
---|
| 662 | }
|
---|
| 663 | }
|
---|
| 664 |
|
---|
| 665 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 666 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 667 | #endif
|
---|
| 668 |
|
---|
| 669 | return (void *)( buf + 1 );
|
---|
| 670 |
|
---|
| 671 | }
|
---|
| 672 |
|
---|
[33365] | 673 | static void *crVBoxHGCMAlloc(CRConnection *conn)
|
---|
[15532] | 674 | {
|
---|
[33365] | 675 | void *pvBuff;
|
---|
| 676 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[38314] | 677 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 678 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 679 | #endif
|
---|
[33365] | 680 | pvBuff = _crVBoxHGCMAlloc(conn);
|
---|
[38314] | 681 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 682 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 683 | #endif
|
---|
[33365] | 684 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 685 | return pvBuff;
|
---|
| 686 | }
|
---|
| 687 |
|
---|
| 688 | static void _crVBoxHGCMWriteExact(CRConnection *conn, const void *buf, unsigned int len)
|
---|
| 689 | {
|
---|
[15532] | 690 | int rc;
|
---|
[30440] | 691 | int32_t callRes;
|
---|
[15532] | 692 |
|
---|
[30440] | 693 | #ifdef IN_GUEST
|
---|
| 694 | if (conn->u32InjectClientID)
|
---|
| 695 | {
|
---|
| 696 | CRVBOXHGCMINJECT parms;
|
---|
[15532] | 697 |
|
---|
[68458] | 698 | VBGL_HGCM_HDR_INIT(&parms.hdr, conn->u32ClientID, SHCRGL_GUEST_FN_INJECT, SHCRGL_CPARMS_INJECT);
|
---|
[15532] | 699 |
|
---|
[30440] | 700 | parms.u32ClientID.type = VMMDevHGCMParmType_32bit;
|
---|
| 701 | parms.u32ClientID.u.value32 = conn->u32InjectClientID;
|
---|
[15532] | 702 |
|
---|
[30440] | 703 | parms.pBuffer.type = VMMDevHGCMParmType_LinAddr_In;
|
---|
| 704 | parms.pBuffer.u.Pointer.size = len;
|
---|
| 705 | parms.pBuffer.u.Pointer.u.linearAddr = (uintptr_t) buf;
|
---|
| 706 |
|
---|
[68472] | 707 | rc = crVBoxHGCMCall(conn, &parms.hdr, sizeof(parms));
|
---|
[69989] | 708 | callRes = parms.hdr.Hdr.rc; /** @todo now rc == parms.hdr.Hdr.rc */
|
---|
[30440] | 709 | }
|
---|
| 710 | else
|
---|
| 711 | #endif
|
---|
[15532] | 712 | {
|
---|
[30440] | 713 | CRVBOXHGCMWRITE parms;
|
---|
| 714 |
|
---|
[68458] | 715 | VBGL_HGCM_HDR_INIT(&parms.hdr, conn->u32ClientID, SHCRGL_GUEST_FN_WRITE, SHCRGL_CPARMS_WRITE);
|
---|
[30440] | 716 |
|
---|
| 717 | parms.pBuffer.type = VMMDevHGCMParmType_LinAddr_In;
|
---|
| 718 | parms.pBuffer.u.Pointer.size = len;
|
---|
| 719 | parms.pBuffer.u.Pointer.u.linearAddr = (uintptr_t) buf;
|
---|
| 720 |
|
---|
[68472] | 721 | rc = crVBoxHGCMCall(conn, &parms.hdr, sizeof(parms));
|
---|
[69989] | 722 | callRes = parms.hdr.Hdr.rc; /** @todo now rc == parms.hdr.Hdr.rc */
|
---|
[15532] | 723 | }
|
---|
[30440] | 724 |
|
---|
| 725 | if (RT_FAILURE(rc) || RT_FAILURE(callRes))
|
---|
| 726 | {
|
---|
| 727 | crWarning("SHCRGL_GUEST_FN_WRITE failed with %x %x\n", rc, callRes);
|
---|
| 728 | }
|
---|
[15532] | 729 | }
|
---|
| 730 |
|
---|
[33365] | 731 | static void crVBoxHGCMWriteExact(CRConnection *conn, const void *buf, unsigned int len)
|
---|
| 732 | {
|
---|
| 733 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[38314] | 734 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 735 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 736 | #endif
|
---|
[33365] | 737 | _crVBoxHGCMWriteExact(conn, buf, len);
|
---|
[38314] | 738 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 739 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 740 | #endif
|
---|
[33365] | 741 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 742 | }
|
---|
| 743 |
|
---|
[15707] | 744 | static void crVBoxHGCMReadExact( CRConnection *conn, const void *buf, unsigned int len )
|
---|
| 745 | {
|
---|
| 746 | CRVBOXHGCMREAD parms;
|
---|
| 747 | int rc;
|
---|
[63199] | 748 | RT_NOREF(buf, len);
|
---|
[15707] | 749 |
|
---|
[68458] | 750 | VBGL_HGCM_HDR_INIT(&parms.hdr, conn->u32ClientID, SHCRGL_GUEST_FN_READ, SHCRGL_CPARMS_READ);
|
---|
[15707] | 751 |
|
---|
[63199] | 752 | CRASSERT(!conn->pBuffer); /* make sure there's no data to process */
|
---|
[15707] | 753 | parms.pBuffer.type = VMMDevHGCMParmType_LinAddr_Out;
|
---|
| 754 | parms.pBuffer.u.Pointer.size = conn->cbHostBufferAllocated;
|
---|
[21225] | 755 | parms.pBuffer.u.Pointer.u.linearAddr = (uintptr_t) conn->pHostBuffer;
|
---|
[15707] | 756 |
|
---|
| 757 | parms.cbBuffer.type = VMMDevHGCMParmType_32bit;
|
---|
| 758 | parms.cbBuffer.u.value32 = 0;
|
---|
| 759 |
|
---|
[68472] | 760 | rc = crVBoxHGCMCall(conn, &parms.hdr, sizeof(parms));
|
---|
[15707] | 761 |
|
---|
[69989] | 762 | if (RT_FAILURE(rc) || RT_FAILURE(parms.hdr.Hdr.rc) /** @todo now rc == parms.hdr.Hdr.rc */)
|
---|
[15707] | 763 | {
|
---|
[68550] | 764 | crWarning("SHCRGL_GUEST_FN_READ failed with %x %x\n", rc, parms.hdr.Hdr.rc);
|
---|
[15707] | 765 | return;
|
---|
| 766 | }
|
---|
| 767 |
|
---|
| 768 | if (parms.cbBuffer.u.value32)
|
---|
| 769 | {
|
---|
[63199] | 770 | /*conn->pBuffer = (uint8_t*) parms.pBuffer.u.Pointer.u.linearAddr; */
|
---|
[16379] | 771 | conn->pBuffer = conn->pHostBuffer;
|
---|
[15707] | 772 | conn->cbBuffer = parms.cbBuffer.u.value32;
|
---|
| 773 | }
|
---|
| 774 |
|
---|
| 775 | if (conn->cbBuffer)
|
---|
[33365] | 776 | _crVBoxHGCMReceiveMessage(conn);
|
---|
[15707] | 777 |
|
---|
| 778 | }
|
---|
| 779 |
|
---|
[15532] | 780 | /* Same as crVBoxHGCMWriteExact, but combined with read of writeback data.
|
---|
| 781 | * This halves the number of HGCM calls we do,
|
---|
| 782 | * most likely crVBoxHGCMPollHost shouldn't be called at all now.
|
---|
| 783 | */
|
---|
| 784 | static void
|
---|
| 785 | crVBoxHGCMWriteReadExact(CRConnection *conn, const void *buf, unsigned int len, CRVBOXHGCMBUFFERKIND bufferKind)
|
---|
| 786 | {
|
---|
| 787 | CRVBOXHGCMWRITEREAD parms;
|
---|
| 788 | int rc;
|
---|
| 789 |
|
---|
[68458] | 790 | VBGL_HGCM_HDR_INIT(&parms.hdr, conn->u32ClientID, SHCRGL_GUEST_FN_WRITE_READ, SHCRGL_CPARMS_WRITE_READ);
|
---|
[15532] | 791 |
|
---|
[49591] | 792 | parms.pBuffer.type = VMMDevHGCMParmType_LinAddr_In;
|
---|
| 793 | parms.pBuffer.u.Pointer.size = len;
|
---|
| 794 | parms.pBuffer.u.Pointer.u.linearAddr = (uintptr_t) buf;
|
---|
[15532] | 795 |
|
---|
[63199] | 796 | CRASSERT(!conn->pBuffer); /*make sure there's no data to process*/
|
---|
[15532] | 797 | parms.pWriteback.type = VMMDevHGCMParmType_LinAddr_Out;
|
---|
| 798 | parms.pWriteback.u.Pointer.size = conn->cbHostBufferAllocated;
|
---|
[21225] | 799 | parms.pWriteback.u.Pointer.u.linearAddr = (uintptr_t) conn->pHostBuffer;
|
---|
[15532] | 800 |
|
---|
| 801 | parms.cbWriteback.type = VMMDevHGCMParmType_32bit;
|
---|
| 802 | parms.cbWriteback.u.value32 = 0;
|
---|
| 803 |
|
---|
[68472] | 804 | rc = crVBoxHGCMCall(conn, &parms.hdr, sizeof(parms));
|
---|
[15532] | 805 |
|
---|
[35941] | 806 | #if defined(RT_OS_LINUX) || defined(RT_OS_WINDOWS)
|
---|
[34571] | 807 | if (VERR_OUT_OF_RANGE==rc && CR_VBOXHGCM_USERALLOCATED==bufferKind)
|
---|
| 808 | {
|
---|
| 809 | /*Buffer is too big, so send it in split chunks*/
|
---|
| 810 | CRVBOXHGCMWRITEBUFFER wbParms;
|
---|
| 811 |
|
---|
[68458] | 812 | VBGL_HGCM_HDR_INIT(&wbParms.hdr, conn->u32ClientID, SHCRGL_GUEST_FN_WRITE_BUFFER, SHCRGL_CPARMS_WRITE_BUFFER);
|
---|
[34571] | 813 |
|
---|
| 814 | wbParms.iBufferID.type = VMMDevHGCMParmType_32bit;
|
---|
| 815 | wbParms.iBufferID.u.value32 = 0;
|
---|
| 816 |
|
---|
| 817 | wbParms.cbBufferSize.type = VMMDevHGCMParmType_32bit;
|
---|
| 818 | wbParms.cbBufferSize.u.value32 = len;
|
---|
| 819 |
|
---|
| 820 | wbParms.ui32Offset.type = VMMDevHGCMParmType_32bit;
|
---|
| 821 | wbParms.ui32Offset.u.value32 = 0;
|
---|
| 822 |
|
---|
| 823 | wbParms.pBuffer.type = VMMDevHGCMParmType_LinAddr_In;
|
---|
| 824 | wbParms.pBuffer.u.Pointer.size = MIN(CR_HGCM_SPLIT_BUFFER_SIZE, len);
|
---|
| 825 | wbParms.pBuffer.u.Pointer.u.linearAddr = (uintptr_t) buf;
|
---|
| 826 |
|
---|
| 827 | if (len<CR_HGCM_SPLIT_BUFFER_SIZE)
|
---|
| 828 | {
|
---|
| 829 | crError("VERR_OUT_OF_RANGE in crVBoxHGCMWriteReadExact for %u bytes write", len);
|
---|
| 830 | return;
|
---|
| 831 | }
|
---|
| 832 |
|
---|
| 833 | while (wbParms.pBuffer.u.Pointer.size)
|
---|
| 834 | {
|
---|
| 835 | crDebug("SHCRGL_GUEST_FN_WRITE_BUFFER, offset=%u, size=%u", wbParms.ui32Offset.u.value32, wbParms.pBuffer.u.Pointer.size);
|
---|
| 836 |
|
---|
[68472] | 837 | rc = crVBoxHGCMCall(conn, &wbParms.hdr, sizeof(wbParms));
|
---|
[69989] | 838 | if (RT_FAILURE(rc) || RT_FAILURE(wbParms.hdr.Hdr.rc) /** @todo now rc == wbParms.hdr.Hdr.rc */)
|
---|
[34571] | 839 | {
|
---|
[68550] | 840 | crError("SHCRGL_GUEST_FN_WRITE_BUFFER (%i) failed with %x %x\n", wbParms.pBuffer.u.Pointer.size, rc, wbParms.hdr.Hdr.rc);
|
---|
[34571] | 841 | return;
|
---|
| 842 | }
|
---|
| 843 |
|
---|
| 844 | wbParms.ui32Offset.u.value32 += wbParms.pBuffer.u.Pointer.size;
|
---|
| 845 | wbParms.pBuffer.u.Pointer.u.linearAddr += (uintptr_t) wbParms.pBuffer.u.Pointer.size;
|
---|
| 846 | wbParms.pBuffer.u.Pointer.size = MIN(CR_HGCM_SPLIT_BUFFER_SIZE, len-wbParms.ui32Offset.u.value32);
|
---|
| 847 | }
|
---|
| 848 |
|
---|
| 849 | /*now issue GUEST_FN_WRITE_READ_BUFFERED referencing the buffer we'd made*/
|
---|
| 850 | {
|
---|
| 851 | CRVBOXHGCMWRITEREADBUFFERED wrbParms;
|
---|
| 852 |
|
---|
[68458] | 853 | VBGL_HGCM_HDR_INIT(&wrbParms.hdr, conn->u32ClientID, SHCRGL_GUEST_FN_WRITE_READ_BUFFERED, SHCRGL_CPARMS_WRITE_READ_BUFFERED);
|
---|
[34571] | 854 |
|
---|
| 855 | crMemcpy(&wrbParms.iBufferID, &wbParms.iBufferID, sizeof(HGCMFunctionParameter));
|
---|
| 856 | crMemcpy(&wrbParms.pWriteback, &parms.pWriteback, sizeof(HGCMFunctionParameter));
|
---|
| 857 | crMemcpy(&wrbParms.cbWriteback, &parms.cbWriteback, sizeof(HGCMFunctionParameter));
|
---|
| 858 |
|
---|
[68472] | 859 | rc = crVBoxHGCMCall(conn, &wrbParms.hdr, sizeof(wrbParms));
|
---|
[34571] | 860 |
|
---|
| 861 | /*bit of hack to reuse code below*/
|
---|
[68550] | 862 | parms.hdr.Hdr.rc = wrbParms.hdr.Hdr.rc;
|
---|
[34571] | 863 | crMemcpy(&parms.cbWriteback, &wrbParms.cbWriteback, sizeof(HGCMFunctionParameter));
|
---|
| 864 | crMemcpy(&parms.pWriteback, &wrbParms.pWriteback, sizeof(HGCMFunctionParameter));
|
---|
| 865 | }
|
---|
| 866 | }
|
---|
| 867 | #endif
|
---|
| 868 |
|
---|
[69989] | 869 | if (RT_FAILURE(rc) || RT_FAILURE(parms.hdr.Hdr.rc) /** @todo now rc == parms.hdr.Hdr.rc */)
|
---|
[15532] | 870 | {
|
---|
[15707] | 871 |
|
---|
[69989] | 872 | if ((VERR_BUFFER_OVERFLOW == parms.hdr.Hdr.rc) /* && RT_SUCCESS(rc) */)
|
---|
[15707] | 873 | {
|
---|
| 874 | /* reallocate buffer and retry */
|
---|
| 875 |
|
---|
| 876 | CRASSERT(parms.cbWriteback.u.value32>conn->cbHostBufferAllocated);
|
---|
| 877 |
|
---|
| 878 | crDebug("Reallocating host buffer from %d to %d bytes", conn->cbHostBufferAllocated, parms.cbWriteback.u.value32);
|
---|
| 879 |
|
---|
| 880 | crFree(conn->pHostBuffer);
|
---|
| 881 | conn->cbHostBufferAllocated = parms.cbWriteback.u.value32;
|
---|
| 882 | conn->pHostBuffer = crAlloc(conn->cbHostBufferAllocated);
|
---|
| 883 |
|
---|
| 884 | crVBoxHGCMReadExact(conn, buf, len);
|
---|
| 885 |
|
---|
| 886 | return;
|
---|
| 887 | }
|
---|
| 888 | else
|
---|
| 889 | {
|
---|
[68550] | 890 | crWarning("SHCRGL_GUEST_FN_WRITE_READ (%i) failed with %x %x\n", len, rc, parms.hdr.Hdr.rc);
|
---|
[15707] | 891 | return;
|
---|
| 892 | }
|
---|
[15532] | 893 | }
|
---|
| 894 |
|
---|
| 895 | if (parms.cbWriteback.u.value32)
|
---|
| 896 | {
|
---|
[63199] | 897 | /*conn->pBuffer = (uint8_t*) parms.pWriteback.u.Pointer.u.linearAddr;*/
|
---|
[16379] | 898 | conn->pBuffer = conn->pHostBuffer;
|
---|
[15532] | 899 | conn->cbBuffer = parms.cbWriteback.u.value32;
|
---|
| 900 | }
|
---|
| 901 |
|
---|
| 902 | if (conn->cbBuffer)
|
---|
[33365] | 903 | _crVBoxHGCMReceiveMessage(conn);
|
---|
[15532] | 904 | }
|
---|
| 905 |
|
---|
| 906 | static void crVBoxHGCMSend(CRConnection *conn, void **bufp,
|
---|
| 907 | const void *start, unsigned int len)
|
---|
| 908 | {
|
---|
| 909 | CRVBOXHGCMBUFFER *hgcm_buffer;
|
---|
[33365] | 910 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[15532] | 911 |
|
---|
[38314] | 912 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 913 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 914 | #endif
|
---|
| 915 |
|
---|
[15532] | 916 | if (!bufp) /* We're sending a user-allocated buffer. */
|
---|
| 917 | {
|
---|
| 918 | #ifndef IN_GUEST
|
---|
[69392] | 919 | /** @todo remove temp buffer allocation in unpacker*/
|
---|
[15532] | 920 | /* we're at the host side, so just store data until guest polls us */
|
---|
| 921 | _crVBoxHGCMWriteBytes(conn, start, len);
|
---|
| 922 | #else
|
---|
[30440] | 923 | CRASSERT(!conn->u32InjectClientID);
|
---|
[15532] | 924 | crDebug("SHCRGL: sending userbuf with %d bytes\n", len);
|
---|
| 925 | crVBoxHGCMWriteReadExact(conn, start, len, CR_VBOXHGCM_USERALLOCATED);
|
---|
| 926 | #endif
|
---|
[38314] | 927 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 928 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 929 | #endif
|
---|
[33365] | 930 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
[15532] | 931 | return;
|
---|
| 932 | }
|
---|
| 933 |
|
---|
| 934 | /* The region [start .. start + len + 1] lies within a buffer that
|
---|
| 935 | * was allocated with crVBoxHGCMAlloc() and can be put into the free
|
---|
| 936 | * buffer pool when we're done sending it.
|
---|
| 937 | */
|
---|
| 938 |
|
---|
| 939 | hgcm_buffer = (CRVBOXHGCMBUFFER *)(*bufp) - 1;
|
---|
| 940 | CRASSERT(hgcm_buffer->magic == CR_VBOXHGCM_BUFFER_MAGIC);
|
---|
| 941 |
|
---|
| 942 | /* Length would be passed as part of HGCM pointer description
|
---|
| 943 | * No need to prepend it to the buffer
|
---|
| 944 | */
|
---|
[30440] | 945 | #ifdef IN_GUEST
|
---|
| 946 | if (conn->u32InjectClientID)
|
---|
| 947 | {
|
---|
[33365] | 948 | _crVBoxHGCMWriteExact(conn, start, len);
|
---|
[30440] | 949 | }
|
---|
| 950 | else
|
---|
| 951 | #endif
|
---|
[15532] | 952 | crVBoxHGCMWriteReadExact(conn, start, len, hgcm_buffer->kind);
|
---|
| 953 |
|
---|
| 954 | /* Reclaim this pointer for reuse */
|
---|
| 955 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 956 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 957 | #endif
|
---|
| 958 | crBufferPoolPush(g_crvboxhgcm.bufpool, hgcm_buffer, hgcm_buffer->allocated);
|
---|
| 959 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 960 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 961 | #endif
|
---|
| 962 |
|
---|
| 963 | /* Since the buffer's now in the 'free' buffer pool, the caller can't
|
---|
| 964 | * use it any more. Setting bufp to NULL will make sure the caller
|
---|
| 965 | * doesn't try to re-use the buffer.
|
---|
| 966 | */
|
---|
| 967 | *bufp = NULL;
|
---|
[33365] | 968 |
|
---|
[38314] | 969 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 970 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 971 | #endif
|
---|
| 972 |
|
---|
[33365] | 973 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
[15532] | 974 | }
|
---|
| 975 |
|
---|
| 976 | static void crVBoxHGCMPollHost(CRConnection *conn)
|
---|
| 977 | {
|
---|
| 978 | CRVBOXHGCMREAD parms;
|
---|
| 979 | int rc;
|
---|
| 980 |
|
---|
| 981 | CRASSERT(!conn->pBuffer);
|
---|
| 982 |
|
---|
[68458] | 983 | VBGL_HGCM_HDR_INIT(&parms.hdr, conn->u32ClientID, SHCRGL_GUEST_FN_READ, SHCRGL_CPARMS_READ);
|
---|
[15532] | 984 |
|
---|
| 985 | parms.pBuffer.type = VMMDevHGCMParmType_LinAddr_Out;
|
---|
| 986 | parms.pBuffer.u.Pointer.size = conn->cbHostBufferAllocated;
|
---|
[21225] | 987 | parms.pBuffer.u.Pointer.u.linearAddr = (uintptr_t) conn->pHostBuffer;
|
---|
[15532] | 988 |
|
---|
| 989 | parms.cbBuffer.type = VMMDevHGCMParmType_32bit;
|
---|
| 990 | parms.cbBuffer.u.value32 = 0;
|
---|
| 991 |
|
---|
[68472] | 992 | rc = crVBoxHGCMCall(conn, &parms.hdr, sizeof(parms));
|
---|
[15532] | 993 |
|
---|
[69989] | 994 | if (RT_FAILURE(rc) || RT_FAILURE(parms.hdr.Hdr.rc) /** @todo now rc == parms.hdr.Hdr.rc */)
|
---|
[15532] | 995 | {
|
---|
[68550] | 996 | crDebug("SHCRGL_GUEST_FN_READ failed with %x %x\n", rc, parms.hdr.Hdr.rc);
|
---|
[15532] | 997 | return;
|
---|
| 998 | }
|
---|
| 999 |
|
---|
| 1000 | if (parms.cbBuffer.u.value32)
|
---|
| 1001 | {
|
---|
| 1002 | conn->pBuffer = (uint8_t*) parms.pBuffer.u.Pointer.u.linearAddr;
|
---|
| 1003 | conn->cbBuffer = parms.cbBuffer.u.value32;
|
---|
| 1004 | }
|
---|
| 1005 | }
|
---|
| 1006 |
|
---|
| 1007 | static void crVBoxHGCMSingleRecv(CRConnection *conn, void *buf, unsigned int len)
|
---|
| 1008 | {
|
---|
[33365] | 1009 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[38314] | 1010 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1011 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1012 | #endif
|
---|
[15532] | 1013 | crVBoxHGCMReadExact(conn, buf, len);
|
---|
[38314] | 1014 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1015 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1016 | #endif
|
---|
[33365] | 1017 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
[15532] | 1018 | }
|
---|
| 1019 |
|
---|
[33365] | 1020 | static void _crVBoxHGCMFree(CRConnection *conn, void *buf)
|
---|
[15532] | 1021 | {
|
---|
| 1022 | CRVBOXHGCMBUFFER *hgcm_buffer = (CRVBOXHGCMBUFFER *) buf - 1;
|
---|
| 1023 |
|
---|
| 1024 | CRASSERT(hgcm_buffer->magic == CR_VBOXHGCM_BUFFER_MAGIC);
|
---|
| 1025 |
|
---|
[69392] | 1026 | /** @todo wrong len for redir buffers*/
|
---|
[15532] | 1027 | conn->recv_credits += hgcm_buffer->len;
|
---|
| 1028 |
|
---|
| 1029 | switch (hgcm_buffer->kind)
|
---|
| 1030 | {
|
---|
| 1031 | case CR_VBOXHGCM_MEMORY:
|
---|
| 1032 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1033 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1034 | #endif
|
---|
| 1035 | if (g_crvboxhgcm.bufpool) {
|
---|
[69392] | 1036 | /** @todo o'rly? */
|
---|
[15532] | 1037 | /* pool may have been deallocated just a bit earlier in response
|
---|
| 1038 | * to a SIGPIPE (Broken Pipe) signal.
|
---|
| 1039 | */
|
---|
| 1040 | crBufferPoolPush(g_crvboxhgcm.bufpool, hgcm_buffer, hgcm_buffer->allocated);
|
---|
| 1041 | }
|
---|
| 1042 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1043 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1044 | #endif
|
---|
| 1045 | break;
|
---|
| 1046 |
|
---|
| 1047 | case CR_VBOXHGCM_MEMORY_BIG:
|
---|
| 1048 | crFree( hgcm_buffer );
|
---|
| 1049 | break;
|
---|
| 1050 |
|
---|
| 1051 | default:
|
---|
| 1052 | crError( "Weird buffer kind trying to free in crVBoxHGCMFree: %d", hgcm_buffer->kind );
|
---|
| 1053 | }
|
---|
| 1054 | }
|
---|
| 1055 |
|
---|
[33365] | 1056 | static void crVBoxHGCMFree(CRConnection *conn, void *buf)
|
---|
[15532] | 1057 | {
|
---|
[33365] | 1058 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[38314] | 1059 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1060 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1061 | #endif
|
---|
[33365] | 1062 | _crVBoxHGCMFree(conn, buf);
|
---|
[38314] | 1063 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1064 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1065 | #endif
|
---|
[33365] | 1066 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 1067 | }
|
---|
| 1068 |
|
---|
| 1069 | static void _crVBoxHGCMReceiveMessage(CRConnection *conn)
|
---|
| 1070 | {
|
---|
[15532] | 1071 | uint32_t len;
|
---|
| 1072 | CRVBOXHGCMBUFFER *hgcm_buffer;
|
---|
| 1073 | CRMessage *msg;
|
---|
| 1074 | CRMessageType cached_type;
|
---|
| 1075 |
|
---|
| 1076 | len = conn->cbBuffer;
|
---|
| 1077 | CRASSERT(len > 0);
|
---|
| 1078 | CRASSERT(conn->pBuffer);
|
---|
| 1079 |
|
---|
| 1080 | #ifndef IN_GUEST
|
---|
| 1081 | if (conn->allow_redir_ptr)
|
---|
| 1082 | {
|
---|
[63199] | 1083 | #endif
|
---|
[15532] | 1084 | CRASSERT(conn->buffer_size >= sizeof(CRMessageRedirPtr));
|
---|
| 1085 |
|
---|
[33365] | 1086 | hgcm_buffer = (CRVBOXHGCMBUFFER *) _crVBoxHGCMAlloc( conn ) - 1;
|
---|
[15532] | 1087 | hgcm_buffer->len = sizeof(CRMessageRedirPtr);
|
---|
| 1088 |
|
---|
| 1089 | msg = (CRMessage *) (hgcm_buffer + 1);
|
---|
| 1090 |
|
---|
| 1091 | msg->header.type = CR_MESSAGE_REDIR_PTR;
|
---|
| 1092 | msg->redirptr.pMessage = (CRMessageHeader*) (conn->pBuffer);
|
---|
| 1093 | msg->header.conn_id = msg->redirptr.pMessage->conn_id;
|
---|
| 1094 |
|
---|
[39288] | 1095 | #if defined(VBOX_WITH_CRHGSMI) && !defined(IN_GUEST)
|
---|
| 1096 | msg->redirptr.CmdData = conn->CmdData;
|
---|
| 1097 | CRVBOXHGSMI_CMDDATA_ASSERT_CONSISTENT(&msg->redirptr.CmdData);
|
---|
| 1098 | CRVBOXHGSMI_CMDDATA_CLEANUP(&conn->CmdData);
|
---|
| 1099 | #endif
|
---|
| 1100 |
|
---|
[15532] | 1101 | cached_type = msg->redirptr.pMessage->type;
|
---|
| 1102 |
|
---|
| 1103 | conn->cbBuffer = 0;
|
---|
| 1104 | conn->pBuffer = NULL;
|
---|
| 1105 | #ifndef IN_GUEST
|
---|
| 1106 | }
|
---|
| 1107 | else
|
---|
| 1108 | {
|
---|
[39288] | 1109 | /* we should NEVER have redir_ptr disabled with HGSMI command now */
|
---|
[49591] | 1110 | CRASSERT(!conn->CmdData.pvCmd);
|
---|
[15532] | 1111 | if ( len <= conn->buffer_size )
|
---|
| 1112 | {
|
---|
| 1113 | /* put in pre-allocated buffer */
|
---|
[33365] | 1114 | hgcm_buffer = (CRVBOXHGCMBUFFER *) _crVBoxHGCMAlloc( conn ) - 1;
|
---|
[15532] | 1115 | }
|
---|
| 1116 | else
|
---|
| 1117 | {
|
---|
| 1118 | /* allocate new buffer,
|
---|
| 1119 | * not using pool here as it's most likely one time transfer of huge texture
|
---|
| 1120 | */
|
---|
| 1121 | hgcm_buffer = (CRVBOXHGCMBUFFER *) crAlloc( sizeof(CRVBOXHGCMBUFFER) + len );
|
---|
| 1122 | hgcm_buffer->magic = CR_VBOXHGCM_BUFFER_MAGIC;
|
---|
| 1123 | hgcm_buffer->kind = CR_VBOXHGCM_MEMORY_BIG;
|
---|
| 1124 | hgcm_buffer->allocated = sizeof(CRVBOXHGCMBUFFER) + len;
|
---|
| 1125 | }
|
---|
| 1126 |
|
---|
| 1127 | hgcm_buffer->len = len;
|
---|
| 1128 | _crVBoxHGCMReadBytes(conn, hgcm_buffer + 1, len);
|
---|
| 1129 |
|
---|
| 1130 | msg = (CRMessage *) (hgcm_buffer + 1);
|
---|
| 1131 | cached_type = msg->header.type;
|
---|
| 1132 | }
|
---|
[63199] | 1133 | #endif /* !IN_GUEST*/
|
---|
[15532] | 1134 |
|
---|
| 1135 | conn->recv_credits -= len;
|
---|
| 1136 | conn->total_bytes_recv += len;
|
---|
[32909] | 1137 | conn->recv_count++;
|
---|
[15532] | 1138 |
|
---|
| 1139 | crNetDispatchMessage( g_crvboxhgcm.recv_list, conn, msg, len );
|
---|
| 1140 |
|
---|
| 1141 | /* CR_MESSAGE_OPCODES is freed in crserverlib/server_stream.c with crNetFree.
|
---|
| 1142 | * OOB messages are the programmer's problem. -- Humper 12/17/01
|
---|
| 1143 | */
|
---|
| 1144 | if (cached_type != CR_MESSAGE_OPCODES
|
---|
| 1145 | && cached_type != CR_MESSAGE_OOB
|
---|
| 1146 | && cached_type != CR_MESSAGE_GATHER)
|
---|
| 1147 | {
|
---|
[33365] | 1148 | _crVBoxHGCMFree(conn, msg);
|
---|
[15532] | 1149 | }
|
---|
| 1150 | }
|
---|
| 1151 |
|
---|
[33365] | 1152 | static void crVBoxHGCMReceiveMessage(CRConnection *conn)
|
---|
| 1153 | {
|
---|
| 1154 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[38314] | 1155 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1156 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1157 | #endif
|
---|
[33365] | 1158 | _crVBoxHGCMReceiveMessage(conn);
|
---|
[38314] | 1159 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1160 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1161 | #endif
|
---|
[33365] | 1162 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 1163 | }
|
---|
| 1164 |
|
---|
| 1165 |
|
---|
[15532] | 1166 | /*
|
---|
| 1167 | * Called on host side only, to "accept" client connection
|
---|
| 1168 | */
|
---|
| 1169 | static void crVBoxHGCMAccept( CRConnection *conn, const char *hostname, unsigned short port )
|
---|
| 1170 | {
|
---|
[63199] | 1171 | RT_NOREF(hostname, port);
|
---|
[33365] | 1172 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[15532] | 1173 | CRASSERT(conn && conn->pHostBuffer);
|
---|
| 1174 | #ifdef IN_GUEST
|
---|
| 1175 | CRASSERT(FALSE);
|
---|
| 1176 | #endif
|
---|
[33365] | 1177 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
[15532] | 1178 | }
|
---|
| 1179 |
|
---|
[21523] | 1180 | static int crVBoxHGCMSetVersion(CRConnection *conn, unsigned int vMajor, unsigned int vMinor)
|
---|
| 1181 | {
|
---|
| 1182 | CRVBOXHGCMSETVERSION parms;
|
---|
| 1183 | int rc;
|
---|
[63199] | 1184 | RT_NOREF(vMajor, vMinor);
|
---|
[21523] | 1185 |
|
---|
[68458] | 1186 | VBGL_HGCM_HDR_INIT(&parms.hdr, conn->u32ClientID, SHCRGL_GUEST_FN_SET_VERSION, SHCRGL_CPARMS_SET_VERSION);
|
---|
[21523] | 1187 |
|
---|
| 1188 | parms.vMajor.type = VMMDevHGCMParmType_32bit;
|
---|
| 1189 | parms.vMajor.u.value32 = CR_PROTOCOL_VERSION_MAJOR;
|
---|
| 1190 | parms.vMinor.type = VMMDevHGCMParmType_32bit;
|
---|
| 1191 | parms.vMinor.u.value32 = CR_PROTOCOL_VERSION_MINOR;
|
---|
| 1192 |
|
---|
[68472] | 1193 | rc = crVBoxHGCMCall(conn, &parms.hdr, sizeof(parms));
|
---|
[21523] | 1194 |
|
---|
[50984] | 1195 | if (RT_SUCCESS(rc))
|
---|
[21523] | 1196 | {
|
---|
[69989] | 1197 | rc = parms.hdr.Hdr.rc; /** @todo now rc == parms.hdr.Hdr.rc */
|
---|
[50984] | 1198 | if (RT_SUCCESS(rc))
|
---|
| 1199 | {
|
---|
| 1200 | conn->vMajor = CR_PROTOCOL_VERSION_MAJOR;
|
---|
| 1201 | conn->vMinor = CR_PROTOCOL_VERSION_MINOR;
|
---|
| 1202 |
|
---|
| 1203 | return VINF_SUCCESS;
|
---|
| 1204 | }
|
---|
| 1205 | else
|
---|
| 1206 | WARN(("Host doesn't accept our version %d.%d. Make sure you have appropriate additions installed!",
|
---|
| 1207 | parms.vMajor.u.value32, parms.vMinor.u.value32));
|
---|
| 1208 | }
|
---|
| 1209 | else
|
---|
| 1210 | WARN(("crVBoxHGCMCall failed %d", rc));
|
---|
| 1211 |
|
---|
| 1212 | return rc;
|
---|
| 1213 | }
|
---|
| 1214 |
|
---|
[51330] | 1215 | static int crVBoxHGCMGetHostCapsLegacy(CRConnection *conn, uint32_t *pu32HostCaps)
|
---|
[50984] | 1216 | {
|
---|
| 1217 | CRVBOXHGCMGETCAPS caps;
|
---|
| 1218 | int rc;
|
---|
| 1219 |
|
---|
[68458] | 1220 | VBGL_HGCM_HDR_INIT(&caps.hdr, conn->u32ClientID, SHCRGL_GUEST_FN_GET_CAPS_LEGACY, SHCRGL_CPARMS_GET_CAPS_LEGACY);
|
---|
[50984] | 1221 |
|
---|
| 1222 | caps.Caps.type = VMMDevHGCMParmType_32bit;
|
---|
| 1223 | caps.Caps.u.value32 = 0;
|
---|
| 1224 |
|
---|
[68472] | 1225 | rc = crVBoxHGCMCall(conn, &caps.hdr, sizeof(caps));
|
---|
[50984] | 1226 |
|
---|
| 1227 | if (RT_SUCCESS(rc))
|
---|
| 1228 | {
|
---|
[68550] | 1229 | rc = caps.hdr.Hdr.rc;
|
---|
[50984] | 1230 | if (RT_SUCCESS(rc))
|
---|
| 1231 | {
|
---|
| 1232 | *pu32HostCaps = caps.Caps.u.value32;
|
---|
| 1233 | return VINF_SUCCESS;
|
---|
| 1234 | }
|
---|
| 1235 | else
|
---|
| 1236 | WARN(("SHCRGL_GUEST_FN_GET_CAPS failed %d", rc));
|
---|
[21523] | 1237 | return FALSE;
|
---|
| 1238 | }
|
---|
[50984] | 1239 | else
|
---|
| 1240 | WARN(("crVBoxHGCMCall failed %d", rc));
|
---|
[21523] | 1241 |
|
---|
[50984] | 1242 | *pu32HostCaps = 0;
|
---|
[21523] | 1243 |
|
---|
[50984] | 1244 | return rc;
|
---|
[21523] | 1245 | }
|
---|
| 1246 |
|
---|
[34110] | 1247 | static int crVBoxHGCMSetPID(CRConnection *conn, unsigned long long pid)
|
---|
[33988] | 1248 | {
|
---|
| 1249 | CRVBOXHGCMSETPID parms;
|
---|
| 1250 | int rc;
|
---|
| 1251 |
|
---|
[68458] | 1252 | VBGL_HGCM_HDR_INIT(&parms.hdr, conn->u32ClientID, SHCRGL_GUEST_FN_SET_PID, SHCRGL_CPARMS_SET_PID);
|
---|
[33988] | 1253 |
|
---|
[68550] | 1254 | parms.u64PID.type = VMMDevHGCMParmType_64bit;
|
---|
[34110] | 1255 | parms.u64PID.u.value64 = pid;
|
---|
[33988] | 1256 |
|
---|
[68472] | 1257 | rc = crVBoxHGCMCall(conn, &parms.hdr, sizeof(parms));
|
---|
[33988] | 1258 |
|
---|
[69989] | 1259 | if (RT_FAILURE(rc) || RT_FAILURE(parms.hdr.Hdr.rc) /** @todo now rc == parms.hdr.Hdr.rc */)
|
---|
[33988] | 1260 | {
|
---|
| 1261 | crWarning("SHCRGL_GUEST_FN_SET_PID failed!");
|
---|
| 1262 | return FALSE;
|
---|
| 1263 | }
|
---|
| 1264 |
|
---|
| 1265 | return TRUE;
|
---|
| 1266 | }
|
---|
| 1267 |
|
---|
[15532] | 1268 | /**
|
---|
| 1269 | * The function that actually connects. This should only be called by clients,
|
---|
| 1270 | * guests in vbox case.
|
---|
| 1271 | * Servers go through crVBoxHGCMAccept;
|
---|
| 1272 | */
|
---|
| 1273 | static int crVBoxHGCMDoConnect( CRConnection *conn )
|
---|
| 1274 | {
|
---|
| 1275 | #ifdef IN_GUEST
|
---|
[68550] | 1276 | int rc;
|
---|
[33365] | 1277 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[69989] | 1278 | RTR3InitDll(RTR3INIT_FLAGS_UNOBTRUSIVE);
|
---|
[68472] | 1279 | rc = VbglR3InitUser();
|
---|
| 1280 | if (RT_SUCCESS(rc))
|
---|
[15532] | 1281 | {
|
---|
[68472] | 1282 | uint32_t idClient;
|
---|
| 1283 | rc = VbglR3HGCMConnect("VBoxSharedCrOpenGL", &idClient);
|
---|
| 1284 | if (RT_SUCCESS(rc))
|
---|
[15532] | 1285 | {
|
---|
[68472] | 1286 | conn->u32ClientID = idClient;
|
---|
[18380] | 1287 | crDebug("HGCM connect was successful: client id =0x%x\n", conn->u32ClientID);
|
---|
[21523] | 1288 |
|
---|
[33988] | 1289 | rc = crVBoxHGCMSetVersion(conn, CR_PROTOCOL_VERSION_MAJOR, CR_PROTOCOL_VERSION_MINOR);
|
---|
[50984] | 1290 | if (RT_FAILURE(rc))
|
---|
[33988] | 1291 | {
|
---|
[50984] | 1292 | WARN(("crVBoxHGCMSetVersion failed %d", rc));
|
---|
[51160] | 1293 | return FALSE;
|
---|
[33988] | 1294 | }
|
---|
[34110] | 1295 | #ifdef RT_OS_WINDOWS
|
---|
| 1296 | rc = crVBoxHGCMSetPID(conn, GetCurrentProcessId());
|
---|
| 1297 | #else
|
---|
[33988] | 1298 | rc = crVBoxHGCMSetPID(conn, crGetPID());
|
---|
[34110] | 1299 | #endif
|
---|
[50984] | 1300 | if (RT_FAILURE(rc))
|
---|
| 1301 | {
|
---|
[68472] | 1302 | WARN(("crVBoxHGCMSetPID failed %Rrc", rc));
|
---|
[51160] | 1303 | return FALSE;
|
---|
[50984] | 1304 | }
|
---|
| 1305 |
|
---|
| 1306 | if (!g_crvboxhgcm.fHostCapsInitialized)
|
---|
| 1307 | {
|
---|
[51330] | 1308 | rc = crVBoxHGCMGetHostCapsLegacy(conn, &g_crvboxhgcm.u32HostCaps);
|
---|
[50984] | 1309 | if (RT_FAILURE(rc))
|
---|
| 1310 | {
|
---|
[68472] | 1311 | WARN(("VBoxCrHgsmiCtlConGetHostCaps failed %Rrc", rc));
|
---|
[50984] | 1312 | g_crvboxhgcm.u32HostCaps = 0;
|
---|
| 1313 | }
|
---|
| 1314 |
|
---|
| 1315 | /* host may not support it, ignore any failures */
|
---|
| 1316 | g_crvboxhgcm.fHostCapsInitialized = true;
|
---|
| 1317 | }
|
---|
| 1318 |
|
---|
[59177] | 1319 | if (g_crvboxhgcm.u32HostCaps & CR_VBOX_CAP_HOST_CAPS_NOT_SUFFICIENT)
|
---|
| 1320 | {
|
---|
| 1321 | crDebug("HGCM connect: insufficient host capabilities\n");
|
---|
| 1322 | g_crvboxhgcm.u32HostCaps = 0;
|
---|
| 1323 | return FALSE;
|
---|
| 1324 | }
|
---|
| 1325 |
|
---|
[33365] | 1326 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
[68472] | 1327 | return TRUE;
|
---|
[15532] | 1328 | }
|
---|
[33365] | 1329 |
|
---|
[68472] | 1330 | crDebug("HGCM connect failed: %Rrc\n", rc);
|
---|
| 1331 | VbglR3Term();
|
---|
[15532] | 1332 | }
|
---|
[68472] | 1333 | else
|
---|
| 1334 | crDebug("Failed to initialize VbglR3 library: %Rrc\n", rc);
|
---|
| 1335 |
|
---|
[33365] | 1336 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
[51160] | 1337 | return FALSE;
|
---|
[15532] | 1338 |
|
---|
[68472] | 1339 | #else /* !IN_GUEST */
|
---|
[15532] | 1340 | crError("crVBoxHGCMDoConnect called on host side!");
|
---|
| 1341 | CRASSERT(FALSE);
|
---|
| 1342 | return FALSE;
|
---|
[68472] | 1343 | #endif /* !IN_GUEST */
|
---|
[15532] | 1344 | }
|
---|
| 1345 |
|
---|
[40483] | 1346 | static bool _crVBoxCommonDoDisconnectLocked( CRConnection *conn )
|
---|
[15532] | 1347 | {
|
---|
[18508] | 1348 | int i;
|
---|
[15532] | 1349 | if (conn->pHostBuffer)
|
---|
| 1350 | {
|
---|
| 1351 | crFree(conn->pHostBuffer);
|
---|
| 1352 | conn->pHostBuffer = NULL;
|
---|
| 1353 | conn->cbHostBuffer = 0;
|
---|
| 1354 | conn->cbHostBufferAllocated = 0;
|
---|
| 1355 | }
|
---|
| 1356 |
|
---|
| 1357 | conn->pBuffer = NULL;
|
---|
| 1358 | conn->cbBuffer = 0;
|
---|
| 1359 |
|
---|
| 1360 | if (conn->type == CR_VBOXHGCM)
|
---|
| 1361 | {
|
---|
| 1362 | --g_crvboxhgcm.num_conns;
|
---|
| 1363 |
|
---|
| 1364 | if (conn->index < g_crvboxhgcm.num_conns)
|
---|
| 1365 | {
|
---|
| 1366 | g_crvboxhgcm.conns[conn->index] = g_crvboxhgcm.conns[g_crvboxhgcm.num_conns];
|
---|
| 1367 | g_crvboxhgcm.conns[conn->index]->index = conn->index;
|
---|
| 1368 | }
|
---|
| 1369 | else g_crvboxhgcm.conns[conn->index] = NULL;
|
---|
[15818] | 1370 |
|
---|
[15532] | 1371 | conn->type = CR_NO_CONNECTION;
|
---|
| 1372 | }
|
---|
| 1373 |
|
---|
[40483] | 1374 | for (i = 0; i < g_crvboxhgcm.num_conns; i++)
|
---|
| 1375 | if (g_crvboxhgcm.conns[i] && g_crvboxhgcm.conns[i]->type != CR_NO_CONNECTION)
|
---|
| 1376 | return true;
|
---|
| 1377 | return false;
|
---|
| 1378 | }
|
---|
| 1379 |
|
---|
[69392] | 1380 | /** @todo same, replace DeviceIoControl with vbglR3DoIOCtl */
|
---|
[40483] | 1381 | static void crVBoxHGCMDoDisconnect( CRConnection *conn )
|
---|
| 1382 | {
|
---|
| 1383 | bool fHasActiveCons = false;
|
---|
| 1384 |
|
---|
| 1385 | if (!g_crvboxhgcm.initialized) return;
|
---|
| 1386 |
|
---|
| 1387 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1388 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1389 | #endif
|
---|
| 1390 |
|
---|
| 1391 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
| 1392 |
|
---|
| 1393 | fHasActiveCons = _crVBoxCommonDoDisconnectLocked(conn);
|
---|
| 1394 |
|
---|
[15532] | 1395 | #ifndef IN_GUEST
|
---|
[18508] | 1396 | #else /* IN_GUEST */
|
---|
[15532] | 1397 | if (conn->u32ClientID)
|
---|
| 1398 | {
|
---|
[68472] | 1399 | int rc = VbglR3HGCMDisconnect(conn->u32ClientID);
|
---|
| 1400 | if (RT_FAILURE(rc))
|
---|
| 1401 | crDebug("Disconnect failed with %Rrc\n", rc);
|
---|
[15532] | 1402 | conn->u32ClientID = 0;
|
---|
| 1403 |
|
---|
[68472] | 1404 | VbglR3Term();
|
---|
[15532] | 1405 | }
|
---|
[18508] | 1406 | #endif /* IN_GUEST */
|
---|
[33365] | 1407 |
|
---|
| 1408 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
[34887] | 1409 |
|
---|
| 1410 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1411 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1412 | #endif
|
---|
[15532] | 1413 | }
|
---|
| 1414 |
|
---|
| 1415 | static void crVBoxHGCMInstantReclaim(CRConnection *conn, CRMessage *mess)
|
---|
| 1416 | {
|
---|
[33365] | 1417 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[38314] | 1418 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1419 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1420 | #endif
|
---|
[33365] | 1421 | _crVBoxHGCMFree(conn, mess);
|
---|
[15532] | 1422 | CRASSERT(FALSE);
|
---|
[38314] | 1423 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1424 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1425 | #endif
|
---|
[33365] | 1426 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
[15532] | 1427 | }
|
---|
| 1428 |
|
---|
| 1429 | static void crVBoxHGCMHandleNewMessage( CRConnection *conn, CRMessage *msg, unsigned int len )
|
---|
| 1430 | {
|
---|
[63199] | 1431 | RT_NOREF(conn, msg, len);
|
---|
[33365] | 1432 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[15532] | 1433 | CRASSERT(FALSE);
|
---|
[33365] | 1434 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
[15532] | 1435 | }
|
---|
| 1436 |
|
---|
[33561] | 1437 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 1438 |
|
---|
| 1439 | bool _crVBoxHGSMIInit()
|
---|
| 1440 | {
|
---|
[33714] | 1441 | #ifndef VBOX_CRHGSMI_WITH_D3DDEV
|
---|
| 1442 | static
|
---|
| 1443 | #endif
|
---|
[33561] | 1444 | int bHasHGSMI = -1;
|
---|
| 1445 |
|
---|
| 1446 | if (bHasHGSMI < 0)
|
---|
| 1447 | {
|
---|
| 1448 | int rc;
|
---|
[63064] | 1449 | rc = VBoxCrHgsmiInit();
|
---|
[33561] | 1450 | if (RT_SUCCESS(rc))
|
---|
| 1451 | bHasHGSMI = 1;
|
---|
| 1452 | else
|
---|
| 1453 | bHasHGSMI = 0;
|
---|
[34884] | 1454 |
|
---|
| 1455 | crDebug("CrHgsmi is %s", bHasHGSMI ? "ENABLED" : "DISABLED");
|
---|
[33561] | 1456 | }
|
---|
| 1457 |
|
---|
[36317] | 1458 | CRASSERT(bHasHGSMI >= 0);
|
---|
[33561] | 1459 |
|
---|
| 1460 | return bHasHGSMI;
|
---|
| 1461 | }
|
---|
| 1462 |
|
---|
| 1463 | void _crVBoxHGSMITearDown()
|
---|
| 1464 | {
|
---|
| 1465 | VBoxCrHgsmiTerm();
|
---|
| 1466 | }
|
---|
| 1467 |
|
---|
| 1468 | static void *_crVBoxHGSMIDoAlloc(CRConnection *conn, PCRVBOXHGSMI_CLIENT pClient)
|
---|
| 1469 | {
|
---|
| 1470 | PVBOXUHGSMI_BUFFER buf;
|
---|
| 1471 | CRVBOXHGCMBUFFER *pData = NULL;
|
---|
| 1472 | uint32_t cbSize = conn->buffer_size;
|
---|
| 1473 | int rc;
|
---|
| 1474 |
|
---|
| 1475 | buf = _crVBoxHGSMIBufAlloc(pClient, CRVBOXHGSMI_BUF_SIZE(cbSize));
|
---|
| 1476 | if (buf)
|
---|
| 1477 | {
|
---|
| 1478 | VBOXUHGSMI_BUFFER_LOCK_FLAGS fFlags;
|
---|
| 1479 | buf->pvUserData = pClient;
|
---|
| 1480 | fFlags.Value = 0;
|
---|
| 1481 | fFlags.bDiscard = 1;
|
---|
| 1482 | rc = buf->pfnLock(buf, 0, CRVBOXHGSMI_BUF_LOCK_SIZE(cbSize), fFlags, (void**)&pData);
|
---|
| 1483 | if (RT_SUCCESS(rc))
|
---|
| 1484 | {
|
---|
| 1485 | pData->magic = CR_VBOXHGCM_BUFFER_MAGIC;
|
---|
| 1486 | pData->kind = CR_VBOXHGCM_UHGSMI_BUFFER;
|
---|
| 1487 | pData->pBuffer = buf;
|
---|
| 1488 | }
|
---|
| 1489 | else
|
---|
| 1490 | {
|
---|
| 1491 | crWarning("Failed to Lock the buffer, rc(%d)\n", rc);
|
---|
| 1492 | }
|
---|
| 1493 | return CRVBOXHGSMI_BUF_DATA(pData);
|
---|
| 1494 | }
|
---|
[41262] | 1495 | else
|
---|
| 1496 | {
|
---|
| 1497 | crWarning("_crVBoxHGSMIBufAlloc failed to allocate buffer of size (%d)", CRVBOXHGSMI_BUF_SIZE(cbSize));
|
---|
| 1498 | }
|
---|
[33561] | 1499 |
|
---|
| 1500 | /* fall back */
|
---|
| 1501 | return _crVBoxHGCMAlloc(conn);
|
---|
| 1502 | }
|
---|
| 1503 |
|
---|
| 1504 | static void _crVBoxHGSMIFree(CRConnection *conn, void *buf)
|
---|
| 1505 | {
|
---|
| 1506 | CRVBOXHGCMBUFFER *hgcm_buffer = (CRVBOXHGCMBUFFER *) buf - 1;
|
---|
| 1507 |
|
---|
| 1508 | CRASSERT(hgcm_buffer->magic == CR_VBOXHGCM_BUFFER_MAGIC);
|
---|
| 1509 |
|
---|
| 1510 | if (hgcm_buffer->kind == CR_VBOXHGCM_UHGSMI_BUFFER)
|
---|
| 1511 | {
|
---|
| 1512 | PVBOXUHGSMI_BUFFER pBuf = _crVBoxHGSMIBufFromHdr(hgcm_buffer);
|
---|
| 1513 | PCRVBOXHGSMI_CLIENT pClient = (PCRVBOXHGSMI_CLIENT)pBuf->pvUserData;
|
---|
| 1514 | _crVBoxHGSMIBufFree(pClient, pBuf);
|
---|
| 1515 | }
|
---|
| 1516 | else
|
---|
| 1517 | {
|
---|
| 1518 | _crVBoxHGCMFree(conn, buf);
|
---|
| 1519 | }
|
---|
| 1520 | }
|
---|
| 1521 |
|
---|
| 1522 | static void *crVBoxHGSMIAlloc(CRConnection *conn)
|
---|
| 1523 | {
|
---|
| 1524 | PCRVBOXHGSMI_CLIENT pClient;
|
---|
| 1525 | void *pvBuf;
|
---|
| 1526 |
|
---|
| 1527 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
| 1528 |
|
---|
[38314] | 1529 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1530 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1531 | #endif
|
---|
| 1532 |
|
---|
[33561] | 1533 | pClient = _crVBoxHGSMIClientGet(conn);
|
---|
| 1534 | if (pClient)
|
---|
| 1535 | {
|
---|
| 1536 | pvBuf = _crVBoxHGSMIDoAlloc(conn, pClient);
|
---|
[36317] | 1537 | CRASSERT(pvBuf);
|
---|
[33561] | 1538 | }
|
---|
| 1539 | else
|
---|
| 1540 | {
|
---|
| 1541 | pvBuf = _crVBoxHGCMAlloc(conn);
|
---|
| 1542 | }
|
---|
| 1543 |
|
---|
[38314] | 1544 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1545 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1546 | #endif
|
---|
| 1547 |
|
---|
[33561] | 1548 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 1549 |
|
---|
| 1550 | return pvBuf;
|
---|
| 1551 | }
|
---|
| 1552 |
|
---|
| 1553 | static void crVBoxHGSMIFree(CRConnection *conn, void *buf)
|
---|
| 1554 | {
|
---|
| 1555 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[38314] | 1556 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1557 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1558 | #endif
|
---|
[33561] | 1559 | _crVBoxHGSMIFree(conn, buf);
|
---|
[38314] | 1560 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1561 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1562 | #endif
|
---|
[33561] | 1563 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 1564 | }
|
---|
| 1565 |
|
---|
| 1566 | static void _crVBoxHGSMIPollHost(CRConnection *conn, PCRVBOXHGSMI_CLIENT pClient)
|
---|
| 1567 | {
|
---|
| 1568 | CRVBOXHGSMIREAD *parms = (CRVBOXHGSMIREAD *)_crVBoxHGSMICmdBufferLock(pClient, sizeof (*parms));
|
---|
| 1569 | int rc;
|
---|
| 1570 | VBOXUHGSMI_BUFFER_SUBMIT aSubmit[2];
|
---|
| 1571 | PVBOXUHGSMI_BUFFER pRecvBuffer;
|
---|
| 1572 | uint32_t cbBuffer;
|
---|
| 1573 |
|
---|
[36317] | 1574 | CRASSERT(parms);
|
---|
[33561] | 1575 |
|
---|
| 1576 | parms->hdr.result = VERR_WRONG_ORDER;
|
---|
| 1577 | parms->hdr.u32ClientID = conn->u32ClientID;
|
---|
| 1578 | parms->hdr.u32Function = SHCRGL_GUEST_FN_READ;
|
---|
[63199] | 1579 | /* parms->hdr.u32Reserved = 0;*/
|
---|
[33561] | 1580 |
|
---|
[63199] | 1581 | CRASSERT(!conn->pBuffer); /* make sure there's no data to process */
|
---|
[33561] | 1582 | parms->iBuffer = 1;
|
---|
| 1583 | parms->cbBuffer = 0;
|
---|
| 1584 |
|
---|
| 1585 | _crVBoxHGSMICmdBufferUnlock(pClient);
|
---|
| 1586 |
|
---|
| 1587 | pRecvBuffer = _crVBoxHGSMIRecvBufGet(pClient);
|
---|
[36317] | 1588 | CRASSERT(pRecvBuffer);
|
---|
[33561] | 1589 | if (!pRecvBuffer)
|
---|
| 1590 | return;
|
---|
| 1591 |
|
---|
| 1592 | _crVBoxHGSMIFillCmd(&aSubmit[0], pClient, sizeof (*parms));
|
---|
| 1593 |
|
---|
| 1594 | aSubmit[1].pBuf = pRecvBuffer;
|
---|
| 1595 | aSubmit[1].offData = 0;
|
---|
| 1596 | aSubmit[1].cbData = pRecvBuffer->cbBuffer;
|
---|
| 1597 | aSubmit[1].fFlags.Value = 0;
|
---|
| 1598 | aSubmit[1].fFlags.bHostWriteOnly = 1;
|
---|
| 1599 |
|
---|
[41058] | 1600 | rc = pClient->pHgsmi->pfnBufferSubmit(pClient->pHgsmi, aSubmit, 2);
|
---|
[33561] | 1601 | if (RT_FAILURE(rc))
|
---|
| 1602 | {
|
---|
[41058] | 1603 | crError("pfnBufferSubmit failed with %d \n", rc);
|
---|
[33561] | 1604 | return;
|
---|
| 1605 | }
|
---|
| 1606 |
|
---|
| 1607 | parms = (CRVBOXHGSMIREAD *)_crVBoxHGSMICmdBufferLockRo(pClient, sizeof (*parms));
|
---|
[36317] | 1608 | CRASSERT(parms);
|
---|
[33561] | 1609 | if (!parms)
|
---|
| 1610 | {
|
---|
| 1611 | crWarning("_crVBoxHGSMICmdBufferLockRo failed\n");
|
---|
| 1612 | return;
|
---|
| 1613 | }
|
---|
| 1614 |
|
---|
| 1615 | if (RT_SUCCESS(parms->hdr.result))
|
---|
| 1616 | cbBuffer = parms->cbBuffer;
|
---|
| 1617 | else
|
---|
| 1618 | cbBuffer = 0;
|
---|
| 1619 |
|
---|
| 1620 | _crVBoxHGSMICmdBufferUnlock(pClient);
|
---|
| 1621 |
|
---|
| 1622 | if (cbBuffer)
|
---|
| 1623 | {
|
---|
| 1624 | void *pvData = _crVBoxHGSMIRecvBufData(pClient, cbBuffer);
|
---|
[36317] | 1625 | CRASSERT(pvData);
|
---|
[33561] | 1626 | if (pvData)
|
---|
| 1627 | {
|
---|
| 1628 | conn->pBuffer = pvData;
|
---|
| 1629 | conn->cbBuffer = cbBuffer;
|
---|
| 1630 | }
|
---|
| 1631 | }
|
---|
| 1632 | }
|
---|
| 1633 |
|
---|
| 1634 | static void _crVBoxHGSMIReadExact(CRConnection *conn, PCRVBOXHGSMI_CLIENT pClient)
|
---|
| 1635 | {
|
---|
| 1636 | _crVBoxHGSMIPollHost(conn, pClient);
|
---|
| 1637 |
|
---|
| 1638 | if (conn->cbBuffer)
|
---|
| 1639 | _crVBoxHGCMReceiveMessage(conn);
|
---|
| 1640 | }
|
---|
| 1641 |
|
---|
| 1642 | /* Same as crVBoxHGCMWriteExact, but combined with read of writeback data.
|
---|
| 1643 | * This halves the number of HGCM calls we do,
|
---|
| 1644 | * most likely crVBoxHGCMPollHost shouldn't be called at all now.
|
---|
| 1645 | */
|
---|
| 1646 | static void
|
---|
| 1647 | _crVBoxHGSMIWriteReadExact(CRConnection *conn, PCRVBOXHGSMI_CLIENT pClient, void *buf, uint32_t offBuffer, unsigned int len, bool bIsBuffer)
|
---|
| 1648 | {
|
---|
| 1649 | CRVBOXHGSMIWRITEREAD *parms = (CRVBOXHGSMIWRITEREAD*)_crVBoxHGSMICmdBufferLock(pClient, sizeof (*parms));
|
---|
| 1650 | int rc;
|
---|
| 1651 | VBOXUHGSMI_BUFFER_SUBMIT aSubmit[3];
|
---|
| 1652 | PVBOXUHGSMI_BUFFER pBuf = NULL;
|
---|
| 1653 | VBOXUHGSMI_BUFFER_LOCK_FLAGS fFlags;
|
---|
[63199] | 1654 | /* uint32_t cbBuffer;*/
|
---|
[33561] | 1655 |
|
---|
| 1656 | parms->hdr.result = VERR_WRONG_ORDER;
|
---|
| 1657 | parms->hdr.u32ClientID = conn->u32ClientID;
|
---|
| 1658 | parms->hdr.u32Function = SHCRGL_GUEST_FN_WRITE_READ;
|
---|
[63199] | 1659 | /* parms->hdr.u32Reserved = 0;*/
|
---|
[33561] | 1660 |
|
---|
| 1661 | parms->iBuffer = 1;
|
---|
| 1662 |
|
---|
[63199] | 1663 | CRASSERT(!conn->pBuffer); /* make sure there's no data to process */
|
---|
[33561] | 1664 | parms->iWriteback = 2;
|
---|
| 1665 | parms->cbWriteback = 0;
|
---|
| 1666 |
|
---|
| 1667 | _crVBoxHGSMICmdBufferUnlock(pClient);
|
---|
| 1668 |
|
---|
| 1669 | if (!bIsBuffer)
|
---|
| 1670 | {
|
---|
| 1671 | void *pvBuf;
|
---|
| 1672 | pBuf = _crVBoxHGSMIBufAlloc(pClient, len);
|
---|
[37714] | 1673 |
|
---|
[33561] | 1674 | if (!pBuf)
|
---|
| 1675 | {
|
---|
| 1676 | /* fallback */
|
---|
| 1677 | crVBoxHGCMWriteReadExact(conn, buf, len, CR_VBOXHGCM_USERALLOCATED);
|
---|
| 1678 | return;
|
---|
| 1679 | }
|
---|
| 1680 |
|
---|
[36317] | 1681 | CRASSERT(!offBuffer);
|
---|
[33561] | 1682 |
|
---|
| 1683 | offBuffer = 0;
|
---|
| 1684 | fFlags.Value = 0;
|
---|
| 1685 | fFlags.bDiscard = 1;
|
---|
| 1686 | fFlags.bWriteOnly = 1;
|
---|
| 1687 | rc = pBuf->pfnLock(pBuf, 0, len, fFlags, &pvBuf);
|
---|
| 1688 | if (RT_SUCCESS(rc))
|
---|
| 1689 | {
|
---|
| 1690 | memcpy(pvBuf, buf, len);
|
---|
| 1691 | rc = pBuf->pfnUnlock(pBuf);
|
---|
| 1692 | CRASSERT(RT_SUCCESS(rc));
|
---|
| 1693 | }
|
---|
| 1694 | else
|
---|
| 1695 | {
|
---|
[41265] | 1696 | crWarning("_crVBoxHGSMIWriteReadExact: pfnUnlock failed rc %d", rc);
|
---|
[33561] | 1697 | _crVBoxHGSMIBufFree(pClient, pBuf);
|
---|
| 1698 | /* fallback */
|
---|
| 1699 | crVBoxHGCMWriteReadExact(conn, buf, len, CR_VBOXHGCM_USERALLOCATED);
|
---|
| 1700 | return;
|
---|
| 1701 | }
|
---|
| 1702 | }
|
---|
| 1703 | else
|
---|
| 1704 | {
|
---|
| 1705 | pBuf = (PVBOXUHGSMI_BUFFER)buf;
|
---|
| 1706 | }
|
---|
| 1707 |
|
---|
| 1708 | do
|
---|
| 1709 | {
|
---|
| 1710 | PVBOXUHGSMI_BUFFER pRecvBuffer = _crVBoxHGSMIRecvBufGet(pClient);
|
---|
[36317] | 1711 | CRASSERT(pRecvBuffer);
|
---|
[33561] | 1712 | if (!pRecvBuffer)
|
---|
| 1713 | {
|
---|
| 1714 | break;
|
---|
| 1715 | }
|
---|
| 1716 |
|
---|
| 1717 | _crVBoxHGSMIFillCmd(&aSubmit[0], pClient, sizeof (*parms));
|
---|
| 1718 |
|
---|
| 1719 | aSubmit[1].pBuf = pBuf;
|
---|
| 1720 | aSubmit[1].offData = offBuffer;
|
---|
| 1721 | aSubmit[1].cbData = len;
|
---|
| 1722 | aSubmit[1].fFlags.Value = 0;
|
---|
| 1723 | aSubmit[1].fFlags.bHostReadOnly = 1;
|
---|
| 1724 |
|
---|
| 1725 | aSubmit[2].pBuf = pRecvBuffer;
|
---|
| 1726 | aSubmit[2].offData = 0;
|
---|
| 1727 | aSubmit[2].cbData = pRecvBuffer->cbBuffer;
|
---|
| 1728 | aSubmit[2].fFlags.Value = 0;
|
---|
| 1729 |
|
---|
[41058] | 1730 | rc = pClient->pHgsmi->pfnBufferSubmit(pClient->pHgsmi, aSubmit, 3);
|
---|
[33561] | 1731 | if (RT_FAILURE(rc))
|
---|
| 1732 | {
|
---|
[41058] | 1733 | crError("pfnBufferSubmit failed with %d \n", rc);
|
---|
[33561] | 1734 | break;
|
---|
| 1735 | }
|
---|
| 1736 |
|
---|
| 1737 | parms = (CRVBOXHGSMIWRITEREAD *)_crVBoxHGSMICmdBufferLockRo(pClient, sizeof (*parms));
|
---|
[36317] | 1738 | CRASSERT(parms);
|
---|
[33561] | 1739 | if (parms)
|
---|
| 1740 | {
|
---|
| 1741 | uint32_t cbWriteback = parms->cbWriteback;
|
---|
| 1742 | rc = parms->hdr.result;
|
---|
[50987] | 1743 | #ifdef DEBUG_misha
|
---|
| 1744 | /* catch it here to test the buffer */
|
---|
[68550] | 1745 | Assert(RT_SUCCESS(parms->hdr.Hdr.rc) || parms->hdr.Hdr.rc == VERR_BUFFER_OVERFLOW);
|
---|
[50987] | 1746 | #endif
|
---|
[33561] | 1747 | _crVBoxHGSMICmdBufferUnlock(pClient);
|
---|
| 1748 | #ifdef DEBUG
|
---|
| 1749 | parms = NULL;
|
---|
| 1750 | #endif
|
---|
| 1751 | if (RT_SUCCESS(rc))
|
---|
| 1752 | {
|
---|
| 1753 | if (cbWriteback)
|
---|
| 1754 | {
|
---|
| 1755 | void *pvData = _crVBoxHGSMIRecvBufData(pClient, cbWriteback);
|
---|
[36317] | 1756 | CRASSERT(pvData);
|
---|
[33561] | 1757 | if (pvData)
|
---|
| 1758 | {
|
---|
| 1759 | conn->pBuffer = pvData;
|
---|
| 1760 | conn->cbBuffer = cbWriteback;
|
---|
| 1761 | _crVBoxHGCMReceiveMessage(conn);
|
---|
| 1762 | }
|
---|
| 1763 | }
|
---|
| 1764 | }
|
---|
| 1765 | else if (VERR_BUFFER_OVERFLOW == rc)
|
---|
| 1766 | {
|
---|
[41058] | 1767 | VBOXUHGSMI_BUFFER_TYPE_FLAGS Flags = {0};
|
---|
[49088] | 1768 | PVBOXUHGSMI_BUFFER pNewBuf;
|
---|
[36317] | 1769 | CRASSERT(!pClient->pvHGBuffer);
|
---|
[33561] | 1770 | CRASSERT(cbWriteback>pClient->pHGBuffer->cbBuffer);
|
---|
| 1771 | crDebug("Reallocating host buffer from %d to %d bytes", conn->cbHostBufferAllocated, cbWriteback);
|
---|
| 1772 |
|
---|
[49088] | 1773 | rc = pClient->pHgsmi->pfnBufferCreate(pClient->pHgsmi, CRVBOXHGSMI_PAGE_ALIGN(cbWriteback), Flags, &pNewBuf);
|
---|
[33561] | 1774 | if (RT_SUCCESS(rc))
|
---|
| 1775 | {
|
---|
[49088] | 1776 | rc = pClient->pHGBuffer->pfnDestroy(pClient->pHGBuffer);
|
---|
[33561] | 1777 | CRASSERT(RT_SUCCESS(rc));
|
---|
| 1778 |
|
---|
[49088] | 1779 | pClient->pHGBuffer = pNewBuf;
|
---|
| 1780 |
|
---|
[33561] | 1781 | _crVBoxHGSMIReadExact(conn, pClient/*, cbWriteback*/);
|
---|
| 1782 | }
|
---|
| 1783 | else
|
---|
| 1784 | {
|
---|
[41264] | 1785 | crWarning("_crVBoxHGSMIWriteReadExact: pfnBufferCreate(%d) failed!", CRVBOXHGSMI_PAGE_ALIGN(cbWriteback));
|
---|
[49088] | 1786 | if (conn->cbHostBufferAllocated < cbWriteback)
|
---|
| 1787 | {
|
---|
| 1788 | crFree(conn->pHostBuffer);
|
---|
| 1789 | conn->cbHostBufferAllocated = cbWriteback;
|
---|
| 1790 | conn->pHostBuffer = crAlloc(conn->cbHostBufferAllocated);
|
---|
| 1791 | }
|
---|
[33561] | 1792 | crVBoxHGCMReadExact(conn, NULL, cbWriteback);
|
---|
| 1793 | }
|
---|
| 1794 | }
|
---|
| 1795 | else
|
---|
| 1796 | {
|
---|
| 1797 | crWarning("SHCRGL_GUEST_FN_WRITE_READ (%i) failed with %x \n", len, rc);
|
---|
| 1798 | }
|
---|
| 1799 | }
|
---|
| 1800 | else
|
---|
| 1801 | {
|
---|
| 1802 | crWarning("_crVBoxHGSMICmdBufferLockRo failed\n");
|
---|
| 1803 | break;
|
---|
| 1804 | }
|
---|
| 1805 | } while (0);
|
---|
| 1806 |
|
---|
| 1807 | if (!bIsBuffer)
|
---|
| 1808 | _crVBoxHGSMIBufFree(pClient, pBuf);
|
---|
| 1809 |
|
---|
| 1810 | return;
|
---|
| 1811 | }
|
---|
| 1812 |
|
---|
| 1813 | static void _crVBoxHGSMIWriteExact(CRConnection *conn, PCRVBOXHGSMI_CLIENT pClient, PVBOXUHGSMI_BUFFER pBuf, uint32_t offStart, unsigned int len)
|
---|
| 1814 | {
|
---|
| 1815 | int rc;
|
---|
[62814] | 1816 | int32_t callRes = VINF_SUCCESS; /* Shut up MSC. */
|
---|
[33561] | 1817 | VBOXUHGSMI_BUFFER_SUBMIT aSubmit[2];
|
---|
| 1818 |
|
---|
| 1819 | #ifdef IN_GUEST
|
---|
| 1820 | if (conn->u32InjectClientID)
|
---|
| 1821 | {
|
---|
| 1822 | CRVBOXHGSMIINJECT *parms = (CRVBOXHGSMIINJECT *)_crVBoxHGSMICmdBufferLock(pClient, sizeof (*parms));
|
---|
[36317] | 1823 | CRASSERT(parms);
|
---|
[33561] | 1824 | if (!parms)
|
---|
| 1825 | {
|
---|
| 1826 | return;
|
---|
| 1827 | }
|
---|
| 1828 |
|
---|
| 1829 | parms->hdr.result = VERR_WRONG_ORDER;
|
---|
| 1830 | parms->hdr.u32ClientID = conn->u32ClientID;
|
---|
| 1831 | parms->hdr.u32Function = SHCRGL_GUEST_FN_INJECT;
|
---|
[63199] | 1832 | /* parms->hdr.u32Reserved = 0;*/
|
---|
[33561] | 1833 |
|
---|
| 1834 | parms->u32ClientID = conn->u32InjectClientID;
|
---|
| 1835 |
|
---|
| 1836 | parms->iBuffer = 1;
|
---|
| 1837 | _crVBoxHGSMICmdBufferUnlock(pClient);
|
---|
| 1838 |
|
---|
| 1839 | _crVBoxHGSMIFillCmd(&aSubmit[0], pClient, sizeof (*parms));
|
---|
| 1840 |
|
---|
| 1841 | aSubmit[1].pBuf = pBuf;
|
---|
| 1842 | aSubmit[1].offData = offStart;
|
---|
| 1843 | aSubmit[1].cbData = len;
|
---|
| 1844 | aSubmit[1].fFlags.Value = 0;
|
---|
| 1845 | aSubmit[1].fFlags.bHostReadOnly = 1;
|
---|
| 1846 |
|
---|
[41058] | 1847 | rc = pClient->pHgsmi->pfnBufferSubmit(pClient->pHgsmi, aSubmit, 2);
|
---|
[33561] | 1848 | if (RT_SUCCESS(rc))
|
---|
| 1849 | {
|
---|
| 1850 | callRes = _crVBoxHGSMICmdBufferGetRc(pClient);
|
---|
| 1851 | }
|
---|
[33929] | 1852 | else
|
---|
| 1853 | {
|
---|
| 1854 | /* we can not recover at this point, report error & exit */
|
---|
[41058] | 1855 | crError("pfnBufferSubmit failed with %d \n", rc);
|
---|
[33929] | 1856 | }
|
---|
[33561] | 1857 | }
|
---|
| 1858 | else
|
---|
| 1859 | #endif
|
---|
| 1860 | {
|
---|
| 1861 | CRVBOXHGSMIWRITE * parms = (CRVBOXHGSMIWRITE *)_crVBoxHGSMICmdBufferLock(pClient, sizeof (*parms));;
|
---|
| 1862 |
|
---|
| 1863 | parms->hdr.result = VERR_WRONG_ORDER;
|
---|
| 1864 | parms->hdr.u32ClientID = conn->u32ClientID;
|
---|
| 1865 | parms->hdr.u32Function = SHCRGL_GUEST_FN_WRITE;
|
---|
[63199] | 1866 | /* parms->hdr.u32Reserved = 0; */
|
---|
[33561] | 1867 |
|
---|
| 1868 | parms->iBuffer = 1;
|
---|
| 1869 | _crVBoxHGSMICmdBufferUnlock(pClient);
|
---|
| 1870 |
|
---|
| 1871 | _crVBoxHGSMIFillCmd(&aSubmit[0], pClient, sizeof (*parms));
|
---|
| 1872 |
|
---|
| 1873 | aSubmit[1].pBuf = pBuf;
|
---|
| 1874 | aSubmit[1].offData = offStart;
|
---|
| 1875 | aSubmit[1].cbData = len;
|
---|
| 1876 | aSubmit[1].fFlags.Value = 0;
|
---|
| 1877 | aSubmit[1].fFlags.bHostReadOnly = 1;
|
---|
| 1878 |
|
---|
[41058] | 1879 | rc = pClient->pHgsmi->pfnBufferSubmit(pClient->pHgsmi, aSubmit, 2);
|
---|
[33561] | 1880 | if (RT_SUCCESS(rc))
|
---|
| 1881 | {
|
---|
| 1882 | callRes = _crVBoxHGSMICmdBufferGetRc(pClient);
|
---|
| 1883 | }
|
---|
[33929] | 1884 | else
|
---|
| 1885 | {
|
---|
| 1886 | /* we can not recover at this point, report error & exit */
|
---|
| 1887 | crError("Failed to submit CrHhgsmi buffer");
|
---|
| 1888 | }
|
---|
[33561] | 1889 | }
|
---|
| 1890 |
|
---|
| 1891 | if (RT_FAILURE(rc) || RT_FAILURE(callRes))
|
---|
| 1892 | {
|
---|
| 1893 | crWarning("SHCRGL_GUEST_FN_WRITE failed with %x %x\n", rc, callRes);
|
---|
| 1894 | }
|
---|
| 1895 | }
|
---|
| 1896 |
|
---|
| 1897 | static void crVBoxHGSMISend(CRConnection *conn, void **bufp,
|
---|
| 1898 | const void *start, unsigned int len)
|
---|
| 1899 | {
|
---|
| 1900 | PCRVBOXHGSMI_CLIENT pClient;
|
---|
| 1901 | PVBOXUHGSMI_BUFFER pBuf;
|
---|
| 1902 | CRVBOXHGCMBUFFER *hgcm_buffer;
|
---|
| 1903 |
|
---|
| 1904 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
| 1905 |
|
---|
[38314] | 1906 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1907 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1908 | #endif
|
---|
| 1909 |
|
---|
[33561] | 1910 | if (!bufp) /* We're sending a user-allocated buffer. */
|
---|
| 1911 | {
|
---|
| 1912 | pClient = _crVBoxHGSMIClientGet(conn);
|
---|
| 1913 | if (pClient)
|
---|
| 1914 | {
|
---|
| 1915 | #ifndef IN_GUEST
|
---|
[63199] | 1916 | /** @todo remove temp buffer allocation in unpacker */
|
---|
[33561] | 1917 | /* we're at the host side, so just store data until guest polls us */
|
---|
| 1918 | _crVBoxHGCMWriteBytes(conn, start, len);
|
---|
| 1919 | #else
|
---|
| 1920 | CRASSERT(!conn->u32InjectClientID);
|
---|
| 1921 | crDebug("SHCRGL: sending userbuf with %d bytes\n", len);
|
---|
| 1922 | _crVBoxHGSMIWriteReadExact(conn, pClient, (void*)start, 0, len, false);
|
---|
| 1923 | #endif
|
---|
[38314] | 1924 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1925 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1926 | #endif
|
---|
[33561] | 1927 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 1928 | return;
|
---|
| 1929 | }
|
---|
| 1930 |
|
---|
| 1931 | /* fallback */
|
---|
| 1932 | crVBoxHGCMSend(conn, bufp, start, len);
|
---|
[38314] | 1933 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1934 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1935 | #endif
|
---|
[33561] | 1936 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 1937 | return;
|
---|
| 1938 | }
|
---|
| 1939 |
|
---|
| 1940 | hgcm_buffer = (CRVBOXHGCMBUFFER *) *bufp - 1;
|
---|
[36317] | 1941 | CRASSERT(hgcm_buffer->magic == CR_VBOXHGCM_BUFFER_MAGIC);
|
---|
[37490] | 1942 | if (hgcm_buffer->magic != CR_VBOXHGCM_BUFFER_MAGIC)
|
---|
| 1943 | {
|
---|
| 1944 | crError("HGCM buffer magic mismatch");
|
---|
| 1945 | }
|
---|
| 1946 |
|
---|
| 1947 |
|
---|
[33561] | 1948 | if (hgcm_buffer->kind != CR_VBOXHGCM_UHGSMI_BUFFER)
|
---|
| 1949 | {
|
---|
| 1950 | /* fallback */
|
---|
| 1951 | crVBoxHGCMSend(conn, bufp, start, len);
|
---|
[38314] | 1952 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1953 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1954 | #endif
|
---|
[33561] | 1955 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 1956 | return;
|
---|
| 1957 | }
|
---|
| 1958 |
|
---|
| 1959 | /* The region [start .. start + len + 1] lies within a buffer that
|
---|
| 1960 | * was allocated with crVBoxHGCMAlloc() and can be put into the free
|
---|
| 1961 | * buffer pool when we're done sending it.
|
---|
| 1962 | */
|
---|
| 1963 |
|
---|
| 1964 | pBuf = _crVBoxHGSMIBufFromHdr(hgcm_buffer);
|
---|
[36317] | 1965 | CRASSERT(pBuf);
|
---|
[33561] | 1966 | if (!pBuf)
|
---|
| 1967 | {
|
---|
| 1968 | crVBoxHGCMSend(conn, bufp, start, len);
|
---|
[38314] | 1969 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 1970 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 1971 | #endif
|
---|
[33561] | 1972 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 1973 | return;
|
---|
| 1974 | }
|
---|
| 1975 |
|
---|
| 1976 | pClient = (PCRVBOXHGSMI_CLIENT)pBuf->pvUserData;
|
---|
[37490] | 1977 | if (pClient != &conn->HgsmiClient)
|
---|
| 1978 | {
|
---|
| 1979 | crError("HGSMI client mismatch");
|
---|
| 1980 | }
|
---|
[33561] | 1981 |
|
---|
| 1982 | /* Length would be passed as part of HGCM pointer description
|
---|
| 1983 | * No need to prepend it to the buffer
|
---|
| 1984 | */
|
---|
| 1985 | #ifdef IN_GUEST
|
---|
| 1986 | if (conn->u32InjectClientID)
|
---|
| 1987 | {
|
---|
| 1988 | _crVBoxHGSMIWriteExact(conn, pClient, pBuf, CRVBOXHGSMI_BUF_OFFSET(start, *bufp) + CRVBOXHGSMI_BUF_HDR_SIZE(), len);
|
---|
| 1989 | }
|
---|
| 1990 | else
|
---|
| 1991 | #endif
|
---|
| 1992 | {
|
---|
| 1993 | _crVBoxHGSMIWriteReadExact(conn, pClient, pBuf, CRVBOXHGSMI_BUF_OFFSET(start, *bufp) + CRVBOXHGSMI_BUF_HDR_SIZE(), len, true);
|
---|
| 1994 | }
|
---|
| 1995 |
|
---|
| 1996 | /* Reclaim this pointer for reuse */
|
---|
| 1997 | _crVBoxHGSMIBufFree(pClient, pBuf);
|
---|
| 1998 | /* Since the buffer's now in the 'free' buffer pool, the caller can't
|
---|
| 1999 | * use it any more. Setting bufp to NULL will make sure the caller
|
---|
| 2000 | * doesn't try to re-use the buffer.
|
---|
| 2001 | */
|
---|
| 2002 | *bufp = NULL;
|
---|
| 2003 |
|
---|
[38314] | 2004 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2005 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2006 | #endif
|
---|
| 2007 |
|
---|
[33561] | 2008 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 2009 | }
|
---|
| 2010 |
|
---|
| 2011 | static void crVBoxHGSMIWriteExact(CRConnection *conn, const void *buf, unsigned int len)
|
---|
| 2012 | {
|
---|
| 2013 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
| 2014 |
|
---|
| 2015 | CRASSERT(0);
|
---|
[38314] | 2016 |
|
---|
[33561] | 2017 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 2018 | }
|
---|
| 2019 |
|
---|
| 2020 | static void crVBoxHGSMISingleRecv(CRConnection *conn, void *buf, unsigned int len)
|
---|
| 2021 | {
|
---|
| 2022 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[38314] | 2023 |
|
---|
[33561] | 2024 | CRASSERT(0);
|
---|
[38314] | 2025 |
|
---|
[33561] | 2026 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 2027 | }
|
---|
| 2028 |
|
---|
| 2029 | static void crVBoxHGSMIReceiveMessage(CRConnection *conn)
|
---|
| 2030 | {
|
---|
| 2031 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
| 2032 |
|
---|
[38314] | 2033 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2034 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2035 | #endif
|
---|
| 2036 |
|
---|
[36317] | 2037 | CRASSERT(0);
|
---|
[33561] | 2038 |
|
---|
| 2039 | _crVBoxHGCMReceiveMessage(conn);
|
---|
[38314] | 2040 |
|
---|
| 2041 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2042 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2043 | #endif
|
---|
| 2044 |
|
---|
[33561] | 2045 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 2046 | }
|
---|
| 2047 |
|
---|
| 2048 | /*
|
---|
| 2049 | * Called on host side only, to "accept" client connection
|
---|
| 2050 | */
|
---|
| 2051 | static void crVBoxHGSMIAccept( CRConnection *conn, const char *hostname, unsigned short port )
|
---|
| 2052 | {
|
---|
| 2053 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[36317] | 2054 | CRASSERT(0);
|
---|
[33561] | 2055 |
|
---|
| 2056 | CRASSERT(conn && conn->pHostBuffer);
|
---|
| 2057 | #ifdef IN_GUEST
|
---|
| 2058 | CRASSERT(FALSE);
|
---|
| 2059 | #endif
|
---|
| 2060 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 2061 | }
|
---|
| 2062 |
|
---|
| 2063 | static int crVBoxHGSMIDoConnect( CRConnection *conn )
|
---|
| 2064 | {
|
---|
[40483] | 2065 | PCRVBOXHGSMI_CLIENT pClient;
|
---|
| 2066 | int rc = VINF_SUCCESS;
|
---|
| 2067 |
|
---|
| 2068 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2069 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2070 | #endif
|
---|
| 2071 |
|
---|
| 2072 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
| 2073 |
|
---|
| 2074 | pClient = _crVBoxHGSMIClientGet(conn);
|
---|
| 2075 | if (pClient)
|
---|
[50984] | 2076 | {
|
---|
[40483] | 2077 | rc = VBoxCrHgsmiCtlConGetClientID(pClient->pHgsmi, &conn->u32ClientID);
|
---|
[50984] | 2078 | if (RT_FAILURE(rc))
|
---|
| 2079 | {
|
---|
| 2080 | WARN(("VBoxCrHgsmiCtlConGetClientID failed %d", rc));
|
---|
| 2081 | }
|
---|
| 2082 | if (!g_crvboxhgcm.fHostCapsInitialized)
|
---|
| 2083 | {
|
---|
| 2084 | rc = VBoxCrHgsmiCtlConGetHostCaps(pClient->pHgsmi, &g_crvboxhgcm.u32HostCaps);
|
---|
| 2085 | if (RT_SUCCESS(rc))
|
---|
| 2086 | {
|
---|
| 2087 | g_crvboxhgcm.fHostCapsInitialized = true;
|
---|
| 2088 | }
|
---|
| 2089 | else
|
---|
| 2090 | {
|
---|
| 2091 | WARN(("VBoxCrHgsmiCtlConGetHostCaps failed %d", rc));
|
---|
| 2092 | g_crvboxhgcm.u32HostCaps = 0;
|
---|
| 2093 | }
|
---|
| 2094 | }
|
---|
| 2095 | }
|
---|
[40708] | 2096 | else
|
---|
[50984] | 2097 | {
|
---|
| 2098 | WARN(("_crVBoxHGSMIClientGet failed %d", rc));
|
---|
[40708] | 2099 | rc = VERR_GENERAL_FAILURE;
|
---|
[50984] | 2100 | }
|
---|
[40483] | 2101 |
|
---|
| 2102 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 2103 |
|
---|
| 2104 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2105 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2106 | #endif
|
---|
| 2107 | return RT_SUCCESS(rc);
|
---|
[33561] | 2108 | }
|
---|
| 2109 |
|
---|
| 2110 | static void crVBoxHGSMIDoDisconnect( CRConnection *conn )
|
---|
| 2111 | {
|
---|
[40483] | 2112 | bool fHasActiveCons = false;
|
---|
| 2113 |
|
---|
| 2114 | if (!g_crvboxhgcm.initialized) return;
|
---|
| 2115 |
|
---|
| 2116 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
| 2117 |
|
---|
[38314] | 2118 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2119 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2120 | #endif
|
---|
[40483] | 2121 |
|
---|
| 2122 | fHasActiveCons = _crVBoxCommonDoDisconnectLocked(conn);
|
---|
| 2123 |
|
---|
[33714] | 2124 | #ifndef VBOX_CRHGSMI_WITH_D3DDEV
|
---|
| 2125 | if (conn->HgsmiClient.pHgsmi)
|
---|
| 2126 | {
|
---|
| 2127 | PVBOXUHGSMI pHgsmi;
|
---|
| 2128 | _crVBoxHGSMIClientTerm(&conn->HgsmiClient, &pHgsmi);
|
---|
[36317] | 2129 | CRASSERT(pHgsmi);
|
---|
[42499] | 2130 | if (!conn->pExternalHgsmi)
|
---|
| 2131 | VBoxCrHgsmiDestroy(pHgsmi);
|
---|
[33714] | 2132 | }
|
---|
[40483] | 2133 | #else
|
---|
| 2134 | # error "port me!"
|
---|
[33714] | 2135 | #endif
|
---|
[40483] | 2136 |
|
---|
| 2137 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 2138 |
|
---|
[38314] | 2139 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2140 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2141 | #endif
|
---|
[33561] | 2142 | }
|
---|
| 2143 |
|
---|
| 2144 | static void crVBoxHGSMIInstantReclaim(CRConnection *conn, CRMessage *mess)
|
---|
| 2145 | {
|
---|
| 2146 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[38314] | 2147 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2148 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2149 | #endif
|
---|
[36317] | 2150 | CRASSERT(0);
|
---|
[33561] | 2151 |
|
---|
| 2152 | _crVBoxHGSMIFree(conn, mess);
|
---|
| 2153 |
|
---|
[38314] | 2154 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2155 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2156 | #endif
|
---|
[33561] | 2157 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 2158 | }
|
---|
| 2159 |
|
---|
| 2160 | static void crVBoxHGSMIHandleNewMessage( CRConnection *conn, CRMessage *msg, unsigned int len )
|
---|
| 2161 | {
|
---|
| 2162 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
[36317] | 2163 | CRASSERT(0);
|
---|
[33561] | 2164 |
|
---|
| 2165 | CRASSERT(FALSE);
|
---|
| 2166 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 2167 | }
|
---|
| 2168 | #endif
|
---|
| 2169 |
|
---|
[15532] | 2170 | void crVBoxHGCMInit(CRNetReceiveFuncList *rfl, CRNetCloseFuncList *cfl, unsigned int mtu)
|
---|
| 2171 | {
|
---|
| 2172 | (void) mtu;
|
---|
| 2173 |
|
---|
| 2174 | g_crvboxhgcm.recv_list = rfl;
|
---|
| 2175 | g_crvboxhgcm.close_list = cfl;
|
---|
| 2176 | if (g_crvboxhgcm.initialized)
|
---|
| 2177 | {
|
---|
| 2178 | return;
|
---|
| 2179 | }
|
---|
| 2180 |
|
---|
[33365] | 2181 | VBOXCRHGSMIPROFILE_INIT();
|
---|
| 2182 |
|
---|
[15532] | 2183 | g_crvboxhgcm.initialized = 1;
|
---|
| 2184 |
|
---|
[33561] | 2185 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 2186 | g_crvboxhgcm.bHgsmiOn = _crVBoxHGSMIInit();
|
---|
| 2187 | #endif
|
---|
| 2188 |
|
---|
[15532] | 2189 | g_crvboxhgcm.num_conns = 0;
|
---|
| 2190 | g_crvboxhgcm.conns = NULL;
|
---|
| 2191 |
|
---|
| 2192 | /* Can't open VBox guest driver here, because it gets called for host side as well */
|
---|
[69392] | 2193 | /** @todo as we have 2 dll versions, can do it now.*/
|
---|
[15532] | 2194 |
|
---|
| 2195 | #ifdef RT_OS_WINDOWS
|
---|
| 2196 | g_crvboxhgcm.pDirectDraw = NULL;
|
---|
| 2197 | #endif
|
---|
| 2198 |
|
---|
| 2199 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2200 | crInitMutex(&g_crvboxhgcm.mutex);
|
---|
| 2201 | crInitMutex(&g_crvboxhgcm.recvmutex);
|
---|
| 2202 | #endif
|
---|
| 2203 | g_crvboxhgcm.bufpool = crBufferPoolInit(16);
|
---|
[50984] | 2204 |
|
---|
| 2205 | #ifdef IN_GUEST
|
---|
| 2206 | g_crvboxhgcm.fHostCapsInitialized = false;
|
---|
| 2207 | g_crvboxhgcm.u32HostCaps = 0;
|
---|
| 2208 | #endif
|
---|
[15532] | 2209 | }
|
---|
| 2210 |
|
---|
| 2211 | /* Callback function used to free buffer pool entries */
|
---|
[63199] | 2212 | static void crVBoxHGCMBufferFree(void *data)
|
---|
[15532] | 2213 | {
|
---|
| 2214 | CRVBOXHGCMBUFFER *hgcm_buffer = (CRVBOXHGCMBUFFER *) data;
|
---|
| 2215 |
|
---|
| 2216 | CRASSERT(hgcm_buffer->magic == CR_VBOXHGCM_BUFFER_MAGIC);
|
---|
| 2217 |
|
---|
| 2218 | switch (hgcm_buffer->kind)
|
---|
| 2219 | {
|
---|
| 2220 | case CR_VBOXHGCM_MEMORY:
|
---|
[55042] | 2221 | crDebug("crVBoxHGCMBufferFree: CR_VBOXHGCM_MEMORY: %p", hgcm_buffer);
|
---|
[15532] | 2222 | crFree( hgcm_buffer );
|
---|
| 2223 | break;
|
---|
| 2224 | case CR_VBOXHGCM_MEMORY_BIG:
|
---|
[55042] | 2225 | crDebug("crVBoxHGCMBufferFree: CR_VBOXHGCM_MEMORY_BIG: %p", hgcm_buffer);
|
---|
[15532] | 2226 | crFree( hgcm_buffer );
|
---|
| 2227 | break;
|
---|
| 2228 |
|
---|
| 2229 | default:
|
---|
| 2230 | crError( "Weird buffer kind trying to free in crVBoxHGCMBufferFree: %d", hgcm_buffer->kind );
|
---|
| 2231 | }
|
---|
| 2232 | }
|
---|
| 2233 |
|
---|
| 2234 | void crVBoxHGCMTearDown(void)
|
---|
| 2235 | {
|
---|
[15759] | 2236 | int32_t i, cCons;
|
---|
[15532] | 2237 |
|
---|
| 2238 | if (!g_crvboxhgcm.initialized) return;
|
---|
| 2239 |
|
---|
[34887] | 2240 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2241 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2242 | #endif
|
---|
| 2243 |
|
---|
[15964] | 2244 | /* Connection count would be changed in calls to crNetDisconnect, so we have to store original value.
|
---|
| 2245 | * Walking array backwards is not a good idea as it could cause some issues if we'd disconnect clients not in the
|
---|
| 2246 | * order of their connection.
|
---|
| 2247 | */
|
---|
[15759] | 2248 | cCons = g_crvboxhgcm.num_conns;
|
---|
| 2249 | for (i=0; i<cCons; i++)
|
---|
[15532] | 2250 | {
|
---|
[15964] | 2251 | /* Note that [0] is intended, as the connections array would be shifted in each call to crNetDisconnect */
|
---|
| 2252 | crNetDisconnect(g_crvboxhgcm.conns[0]);
|
---|
[15532] | 2253 | }
|
---|
[15759] | 2254 | CRASSERT(0==g_crvboxhgcm.num_conns);
|
---|
[15532] | 2255 |
|
---|
[34887] | 2256 | g_crvboxhgcm.initialized = 0;
|
---|
| 2257 |
|
---|
[55042] | 2258 | if (g_crvboxhgcm.bufpool)
|
---|
| 2259 | crBufferPoolCallbackFree(g_crvboxhgcm.bufpool, crVBoxHGCMBufferFree);
|
---|
| 2260 | g_crvboxhgcm.bufpool = NULL;
|
---|
| 2261 |
|
---|
[15532] | 2262 | #ifdef CHROMIUM_THREADSAFE
|
---|
[34887] | 2263 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
[15532] | 2264 | crFreeMutex(&g_crvboxhgcm.mutex);
|
---|
| 2265 | crFreeMutex(&g_crvboxhgcm.recvmutex);
|
---|
| 2266 | #endif
|
---|
| 2267 |
|
---|
| 2268 | crFree(g_crvboxhgcm.conns);
|
---|
| 2269 | g_crvboxhgcm.conns = NULL;
|
---|
| 2270 |
|
---|
[33561] | 2271 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 2272 | if (g_crvboxhgcm.bHgsmiOn)
|
---|
| 2273 | {
|
---|
| 2274 | _crVBoxHGSMITearDown();
|
---|
| 2275 | }
|
---|
| 2276 | #endif
|
---|
| 2277 |
|
---|
[15532] | 2278 | #ifdef RT_OS_WINDOWS
|
---|
| 2279 | if (g_crvboxhgcm.pDirectDraw)
|
---|
| 2280 | {
|
---|
| 2281 | IDirectDraw_Release(g_crvboxhgcm.pDirectDraw);
|
---|
| 2282 | g_crvboxhgcm.pDirectDraw = NULL;
|
---|
| 2283 | crDebug("DirectDraw released\n");
|
---|
| 2284 | }
|
---|
| 2285 | #endif
|
---|
| 2286 | }
|
---|
| 2287 |
|
---|
[42499] | 2288 | void crVBoxHGCMConnection(CRConnection *conn
|
---|
| 2289 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 2290 | , struct VBOXUHGSMI *pHgsmi
|
---|
| 2291 | #endif
|
---|
| 2292 | )
|
---|
[15532] | 2293 | {
|
---|
| 2294 | int i, found = 0;
|
---|
| 2295 | int n_bytes;
|
---|
| 2296 |
|
---|
| 2297 | CRASSERT(g_crvboxhgcm.initialized);
|
---|
| 2298 |
|
---|
[33561] | 2299 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 2300 | if (g_crvboxhgcm.bHgsmiOn)
|
---|
| 2301 | {
|
---|
| 2302 | conn->type = CR_VBOXHGCM;
|
---|
| 2303 | conn->Alloc = crVBoxHGSMIAlloc;
|
---|
| 2304 | conn->Send = crVBoxHGSMISend;
|
---|
| 2305 | conn->SendExact = crVBoxHGSMIWriteExact;
|
---|
| 2306 | conn->Recv = crVBoxHGSMISingleRecv;
|
---|
| 2307 | conn->RecvMsg = crVBoxHGSMIReceiveMessage;
|
---|
| 2308 | conn->Free = crVBoxHGSMIFree;
|
---|
| 2309 | conn->Accept = crVBoxHGSMIAccept;
|
---|
| 2310 | conn->Connect = crVBoxHGSMIDoConnect;
|
---|
| 2311 | conn->Disconnect = crVBoxHGSMIDoDisconnect;
|
---|
| 2312 | conn->InstantReclaim = crVBoxHGSMIInstantReclaim;
|
---|
| 2313 | conn->HandleNewMessage = crVBoxHGSMIHandleNewMessage;
|
---|
[42499] | 2314 | conn->pExternalHgsmi = pHgsmi;
|
---|
[33561] | 2315 | }
|
---|
| 2316 | else
|
---|
| 2317 | #endif
|
---|
| 2318 | {
|
---|
| 2319 | conn->type = CR_VBOXHGCM;
|
---|
| 2320 | conn->Alloc = crVBoxHGCMAlloc;
|
---|
| 2321 | conn->Send = crVBoxHGCMSend;
|
---|
| 2322 | conn->SendExact = crVBoxHGCMWriteExact;
|
---|
| 2323 | conn->Recv = crVBoxHGCMSingleRecv;
|
---|
| 2324 | conn->RecvMsg = crVBoxHGCMReceiveMessage;
|
---|
| 2325 | conn->Free = crVBoxHGCMFree;
|
---|
| 2326 | conn->Accept = crVBoxHGCMAccept;
|
---|
| 2327 | conn->Connect = crVBoxHGCMDoConnect;
|
---|
| 2328 | conn->Disconnect = crVBoxHGCMDoDisconnect;
|
---|
| 2329 | conn->InstantReclaim = crVBoxHGCMInstantReclaim;
|
---|
| 2330 | conn->HandleNewMessage = crVBoxHGCMHandleNewMessage;
|
---|
| 2331 | }
|
---|
[15532] | 2332 | conn->sizeof_buffer_header = sizeof(CRVBOXHGCMBUFFER);
|
---|
| 2333 | conn->actual_network = 1;
|
---|
| 2334 |
|
---|
| 2335 | conn->krecv_buf_size = 0;
|
---|
| 2336 |
|
---|
| 2337 | conn->pBuffer = NULL;
|
---|
| 2338 | conn->cbBuffer = 0;
|
---|
| 2339 | conn->allow_redir_ptr = 1;
|
---|
| 2340 |
|
---|
[63199] | 2341 | /** @todo remove this crap at all later */
|
---|
[18109] | 2342 | conn->cbHostBufferAllocated = 2*1024;
|
---|
[15532] | 2343 | conn->pHostBuffer = (uint8_t*) crAlloc(conn->cbHostBufferAllocated);
|
---|
| 2344 | CRASSERT(conn->pHostBuffer);
|
---|
| 2345 | conn->cbHostBuffer = 0;
|
---|
| 2346 |
|
---|
[50973] | 2347 | #if !defined(IN_GUEST)
|
---|
| 2348 | RTListInit(&conn->PendingMsgList);
|
---|
| 2349 | #endif
|
---|
| 2350 |
|
---|
[34887] | 2351 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2352 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2353 | #endif
|
---|
[15532] | 2354 | /* Find a free slot */
|
---|
| 2355 | for (i = 0; i < g_crvboxhgcm.num_conns; i++) {
|
---|
| 2356 | if (g_crvboxhgcm.conns[i] == NULL) {
|
---|
| 2357 | conn->index = i;
|
---|
| 2358 | g_crvboxhgcm.conns[i] = conn;
|
---|
| 2359 | found = 1;
|
---|
| 2360 | break;
|
---|
| 2361 | }
|
---|
| 2362 | }
|
---|
| 2363 |
|
---|
| 2364 | /* Realloc connection stack if we couldn't find a free slot */
|
---|
| 2365 | if (found == 0) {
|
---|
| 2366 | n_bytes = ( g_crvboxhgcm.num_conns + 1 ) * sizeof(*g_crvboxhgcm.conns);
|
---|
| 2367 | crRealloc( (void **) &g_crvboxhgcm.conns, n_bytes );
|
---|
[34887] | 2368 | conn->index = g_crvboxhgcm.num_conns;
|
---|
[15532] | 2369 | g_crvboxhgcm.conns[g_crvboxhgcm.num_conns++] = conn;
|
---|
| 2370 | }
|
---|
[34887] | 2371 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2372 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2373 | #endif
|
---|
[15532] | 2374 | }
|
---|
| 2375 |
|
---|
[42499] | 2376 | #if defined(IN_GUEST)
|
---|
[63199] | 2377 | static void _crVBoxHGCMPerformPollHost(CRConnection *conn)
|
---|
[15532] | 2378 | {
|
---|
[42499] | 2379 | if (conn->type == CR_NO_CONNECTION )
|
---|
| 2380 | return;
|
---|
| 2381 |
|
---|
| 2382 | if (!conn->pBuffer)
|
---|
| 2383 | {
|
---|
| 2384 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 2385 | PCRVBOXHGSMI_CLIENT pClient;
|
---|
| 2386 | if (g_crvboxhgcm.bHgsmiOn && !!(pClient = _crVBoxHGSMIClientGet(conn)))
|
---|
| 2387 | {
|
---|
| 2388 | _crVBoxHGSMIPollHost(conn, pClient);
|
---|
| 2389 | }
|
---|
| 2390 | else
|
---|
| 2391 | #endif
|
---|
| 2392 | {
|
---|
| 2393 | crVBoxHGCMPollHost(conn);
|
---|
| 2394 | }
|
---|
| 2395 | }
|
---|
| 2396 | }
|
---|
| 2397 | #endif
|
---|
| 2398 |
|
---|
[63199] | 2399 | static void _crVBoxHGCMPerformReceiveMessage(CRConnection *conn)
|
---|
[42499] | 2400 | {
|
---|
| 2401 | if ( conn->type == CR_NO_CONNECTION )
|
---|
| 2402 | return;
|
---|
| 2403 |
|
---|
| 2404 | if (conn->cbBuffer>0)
|
---|
| 2405 | {
|
---|
| 2406 | _crVBoxHGCMReceiveMessage(conn);
|
---|
| 2407 | }
|
---|
| 2408 | }
|
---|
| 2409 |
|
---|
[50984] | 2410 | #ifdef IN_GUEST
|
---|
[63199] | 2411 | uint32_t crVBoxHGCMHostCapsGet(void)
|
---|
[50984] | 2412 | {
|
---|
| 2413 | Assert(g_crvboxhgcm.fHostCapsInitialized);
|
---|
| 2414 | return g_crvboxhgcm.u32HostCaps;
|
---|
| 2415 | }
|
---|
| 2416 | #endif
|
---|
| 2417 |
|
---|
[42499] | 2418 | int crVBoxHGCMRecv(
|
---|
| 2419 | #if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 2420 | CRConnection *conn
|
---|
[63199] | 2421 | #else
|
---|
| 2422 | void
|
---|
[42499] | 2423 | #endif
|
---|
| 2424 | )
|
---|
| 2425 | {
|
---|
[15532] | 2426 | int32_t i;
|
---|
| 2427 |
|
---|
[33365] | 2428 | VBOXCRHGSMIPROFILE_FUNC_PROLOGUE();
|
---|
| 2429 |
|
---|
[34887] | 2430 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2431 | crLockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2432 | #endif
|
---|
| 2433 |
|
---|
[15532] | 2434 | #ifdef IN_GUEST
|
---|
[42499] | 2435 | # if defined(VBOX_WITH_CRHGSMI) && defined(IN_GUEST)
|
---|
| 2436 | if (conn && g_crvboxhgcm.bHgsmiOn)
|
---|
| 2437 | {
|
---|
| 2438 | _crVBoxHGCMPerformPollHost(conn);
|
---|
| 2439 | _crVBoxHGCMPerformReceiveMessage(conn);
|
---|
| 2440 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 2441 | return 0;
|
---|
| 2442 | }
|
---|
| 2443 | # endif
|
---|
[15532] | 2444 | /* we're on guest side, poll host if it got something for us */
|
---|
| 2445 | for (i=0; i<g_crvboxhgcm.num_conns; i++)
|
---|
| 2446 | {
|
---|
| 2447 | CRConnection *conn = g_crvboxhgcm.conns[i];
|
---|
| 2448 |
|
---|
[42499] | 2449 | if ( !conn )
|
---|
[15532] | 2450 | continue;
|
---|
| 2451 |
|
---|
[42499] | 2452 | _crVBoxHGCMPerformPollHost(conn);
|
---|
[15532] | 2453 | }
|
---|
| 2454 | #endif
|
---|
| 2455 |
|
---|
| 2456 | for (i=0; i<g_crvboxhgcm.num_conns; i++)
|
---|
| 2457 | {
|
---|
| 2458 | CRConnection *conn = g_crvboxhgcm.conns[i];
|
---|
| 2459 |
|
---|
[42499] | 2460 | if ( !conn )
|
---|
[15532] | 2461 | continue;
|
---|
| 2462 |
|
---|
[42499] | 2463 | _crVBoxHGCMPerformReceiveMessage(conn);
|
---|
[15532] | 2464 | }
|
---|
| 2465 |
|
---|
[34887] | 2466 | #ifdef CHROMIUM_THREADSAFE
|
---|
| 2467 | crUnlockMutex(&g_crvboxhgcm.mutex);
|
---|
| 2468 | #endif
|
---|
| 2469 |
|
---|
[33365] | 2470 | VBOXCRHGSMIPROFILE_FUNC_EPILOGUE();
|
---|
| 2471 |
|
---|
[15532] | 2472 | return 0;
|
---|
| 2473 | }
|
---|
| 2474 |
|
---|
| 2475 | CRConnection** crVBoxHGCMDump( int *num )
|
---|
| 2476 | {
|
---|
| 2477 | *num = g_crvboxhgcm.num_conns;
|
---|
| 2478 |
|
---|
| 2479 | return g_crvboxhgcm.conns;
|
---|
| 2480 | }
|
---|