Changeset 94917 in vbox
- Timestamp:
- May 8, 2022 7:39:41 PM (3 years ago)
- svn:sync-xref-src-repo-rev:
- 151325
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/src/VBox/Main/src-client/ConsoleImplTeleporter.cpp
r93444 r94917 205 205 { 206 206 char ch; 207 int rc = RTTcpRead(hSocket, &ch, sizeof(ch), NULL);208 if (RT_FAILURE( rc))209 { 210 LogRel(("Teleporter: RTTcpRead -> %Rrc while reading string ('%s')\n", rc, pszStart));211 return rc;207 int vrc = RTTcpRead(hSocket, &ch, sizeof(ch), NULL); 208 if (RT_FAILURE(vrc)) 209 { 210 LogRel(("Teleporter: RTTcpRead -> %Rrc while reading string ('%s')\n", vrc, pszStart)); 211 return vrc; 212 212 } 213 213 if ( ch == '\n' … … 328 328 Hdr.u32Magic = TELEPORTERTCPHDR_MAGIC; 329 329 Hdr.cb = RT_MIN((uint32_t)cbToWrite, TELEPORTERTCPHDR_MAX_SIZE); 330 int rc = RTTcpSgWriteL(pState->mhSocket, 2, &Hdr, sizeof(Hdr), pvBuf, (size_t)Hdr.cb);331 if (RT_FAILURE( rc))332 { 333 LogRel(("Teleporter/TCP: Write error: %Rrc (cb=%#x)\n", rc, Hdr.cb));334 return rc;330 int vrc = RTTcpSgWriteL(pState->mhSocket, 2, &Hdr, sizeof(Hdr), pvBuf, (size_t)Hdr.cb); 331 if (RT_FAILURE(vrc)) 332 { 333 LogRel(("Teleporter/TCP: Write error: %Rrc (cb=%#x)\n", vrc, Hdr.cb)); 334 return vrc; 335 335 } 336 336 pState->moffStream += Hdr.cb; … … 358 358 static int teleporterTcpReadSelect(TeleporterState *pState) 359 359 { 360 int rc;360 int vrc; 361 361 do 362 362 { 363 rc = RTTcpSelectOne(pState->mhSocket, 1000);364 if (RT_FAILURE( rc) &&rc != VERR_TIMEOUT)363 vrc = RTTcpSelectOne(pState->mhSocket, 1000); 364 if (RT_FAILURE(vrc) && vrc != VERR_TIMEOUT) 365 365 { 366 366 pState->mfIOError = true; 367 LogRel(("Teleporter/TCP: Header select error: %Rrc\n", rc));367 LogRel(("Teleporter/TCP: Header select error: %Rrc\n", vrc)); 368 368 break; 369 369 } 370 370 if (pState->mfStopReading) 371 371 { 372 rc = VERR_EOF;372 vrc = VERR_EOF; 373 373 break; 374 374 } 375 } while ( rc == VERR_TIMEOUT);376 return rc;375 } while (vrc == VERR_TIMEOUT); 376 return vrc; 377 377 } 378 378 … … 389 389 for (;;) 390 390 { 391 int rc;391 int vrc; 392 392 393 393 /* … … 407 407 if (!pState->mcbReadBlock) 408 408 { 409 rc = teleporterTcpReadSelect(pState);410 if (RT_FAILURE( rc))411 return rc;409 vrc = teleporterTcpReadSelect(pState); 410 if (RT_FAILURE(vrc)) 411 return vrc; 412 412 TELEPORTERTCPHDR Hdr; 413 rc = RTTcpRead(pState->mhSocket, &Hdr, sizeof(Hdr), NULL);414 if (RT_FAILURE( rc))413 vrc = RTTcpRead(pState->mhSocket, &Hdr, sizeof(Hdr), NULL); 414 if (RT_FAILURE(vrc)) 415 415 { 416 416 pState->mfIOError = true; 417 LogRel(("Teleporter/TCP: Header read error: %Rrc\n", rc));418 return rc;417 LogRel(("Teleporter/TCP: Header read error: %Rrc\n", vrc)); 418 return vrc; 419 419 } 420 420 … … 445 445 * Read more data. 446 446 */ 447 rc = teleporterTcpReadSelect(pState);448 if (RT_FAILURE( rc))449 return rc;447 vrc = teleporterTcpReadSelect(pState); 448 if (RT_FAILURE(vrc)) 449 return vrc; 450 450 uint32_t cb = (uint32_t)RT_MIN(pState->mcbReadBlock, cbToRead); 451 rc = RTTcpRead(pState->mhSocket, pvBuf, cb, pcbRead);452 if (RT_FAILURE( rc))451 vrc = RTTcpRead(pState->mhSocket, pvBuf, cb, pcbRead); 452 if (RT_FAILURE(vrc)) 453 453 { 454 454 pState->mfIOError = true; 455 LogRel(("Teleporter/TCP: Data read error: %Rrc (cb=%#x)\n", rc, cb));456 return rc;455 LogRel(("Teleporter/TCP: Data read error: %Rrc (cb=%#x)\n", vrc, cb)); 456 return vrc; 457 457 } 458 458 if (pcbRead) … … 515 515 { 516 516 /* Poll for incoming NACKs and errors from the other side */ 517 int rc = RTTcpSelectOne(pState->mhSocket, 0);518 if ( rc != VERR_TIMEOUT)519 { 520 if (RT_SUCCESS( rc))517 int vrc = RTTcpSelectOne(pState->mhSocket, 0); 518 if (vrc != VERR_TIMEOUT) 519 { 520 if (RT_SUCCESS(vrc)) 521 521 { 522 522 LogRel(("Teleporter/TCP: Incoming data detect by IsOk, assuming it is a cancellation NACK.\n")); 523 rc = VERR_SSM_CANCELLED;523 vrc = VERR_SSM_CANCELLED; 524 524 } 525 525 else 526 LogRel(("Teleporter/TCP: RTTcpSelectOne -> %Rrc (IsOk).\n", rc));527 return rc;526 LogRel(("Teleporter/TCP: RTTcpSelectOne -> %Rrc (IsOk).\n", vrc)); 527 return vrc; 528 528 } 529 529 } … … 545 545 EofHdr.u32Magic = TELEPORTERTCPHDR_MAGIC; 546 546 EofHdr.cb = fCancelled ? UINT32_MAX : 0; 547 int rc = RTTcpWrite(pState->mhSocket, &EofHdr, sizeof(EofHdr));548 if (RT_FAILURE( rc))549 { 550 LogRel(("Teleporter/TCP: EOF Header write error: %Rrc\n", rc));551 return rc;547 int vrc = RTTcpWrite(pState->mhSocket, &EofHdr, sizeof(EofHdr)); 548 if (RT_FAILURE(vrc)) 549 { 550 LogRel(("Teleporter/TCP: EOF Header write error: %Rrc\n", vrc)); 551 return vrc; 552 552 } 553 553 } … … 906 906 { 907 907 autoLock.release(); 908 int rc = pState->mpVMM->pfnVMR3Resume(pState->mpUVM, VMRESUMEREASON_TELEPORT_FAILED);909 AssertLogRelMsgRC( rc, ("VMR3Resume -> %Rrc\n",rc));908 int vrc = pState->mpVMM->pfnVMR3Resume(pState->mpUVM, VMRESUMEREASON_TELEPORT_FAILED); 909 AssertLogRelMsgRC(vrc, ("VMR3Resume -> %Rrc\n", vrc)); 910 910 autoLock.acquire(); 911 911 } … … 1220 1220 static int teleporterTcpWriteACK(TeleporterStateTrg *pState, bool fAutomaticUnlock = true) 1221 1221 { 1222 int rc = RTTcpWrite(pState->mhSocket, "ACK\n", sizeof("ACK\n") - 1);1223 if (RT_FAILURE( rc))1224 { 1225 LogRel(("Teleporter: RTTcpWrite(,ACK,) -> %Rrc\n", rc));1222 int vrc = RTTcpWrite(pState->mhSocket, "ACK\n", sizeof("ACK\n") - 1); 1223 if (RT_FAILURE(vrc)) 1224 { 1225 LogRel(("Teleporter: RTTcpWrite(,ACK,) -> %Rrc\n", vrc)); 1226 1226 if (fAutomaticUnlock) 1227 1227 teleporterTrgUnlockMedia(pState); 1228 1228 } 1229 return rc;1229 return vrc; 1230 1230 } 1231 1231 … … 1250 1250 else 1251 1251 cch = RTStrPrintf(szMsg, sizeof(szMsg), "NACK=%d\n", rc2); 1252 int rc = RTTcpWrite(pState->mhSocket, szMsg, cch);1253 if (RT_FAILURE( rc))1254 LogRel(("Teleporter: RTTcpWrite(,%s,%zu) -> %Rrc\n", szMsg, cch, rc));1255 return rc;1252 int vrc = RTTcpWrite(pState->mhSocket, szMsg, cch); 1253 if (RT_FAILURE(vrc)) 1254 LogRel(("Teleporter: RTTcpWrite(,%s,%zu) -> %Rrc\n", szMsg, cch, vrc)); 1255 return vrc; 1256 1256 } 1257 1257
Note:
See TracChangeset
for help on using the changeset viewer.