/vbox/src/VBox/Runtime/testcase/ |
H A D | tstRTPipe.cpp | 98 RTPIPE hPipeR; local 100 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_READ), VINF_SUCCESS); 102 RTHCINTPTR hNative = RTPipeToNative(hPipeR); 111 RTTESTI_CHECK_RC_RETV(RTPipeClose(hPipeR), VINF_SUCCESS); 161 RTPIPE hPipeR; local 163 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_WRITE), VINF_SUCCESS); 179 RTTESTI_CHECK_RC(rc = RTPipeReadBlocking(hPipeR, szTmp, sizeof(szTmp) - 1, &cbRead), VINF_SUCCESS); 187 RTTESTI_CHECK_RC(RTPipeReadBlocking(hPipeR, szTmp2, sizeof(szTmp2), &cbRead2), VERR_BROKEN_PIPE); 188 RTTESTI_CHECK_RC(rc = RTPipeClose(hPipeR), VINF_SUCCESS); 207 RTPIPE hPipeR [all...] |
H A D | tstRTProcCreateEx.cpp | 230 RTPIPE hPipeR, hPipeW; local 231 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_WRITE), VINF_SUCCESS); 256 int rc = RTPipeReadBlocking(hPipeR, &szOutput[offOutput], cbLeft, &cbRead); 265 RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS); 295 RTPIPE hPipeR, hPipeW; local 296 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, RTPIPE_C_INHERIT_WRITE), VINF_SUCCESS); 321 int rc = RTPipeReadBlocking(hPipeR, &szOutput[offOutput], cbLeft, &cbRead); 330 RTTESTI_CHECK_RC(RTPipeClose(hPipeR), VINF_SUCCESS); 361 RTPIPE hPipeR, hPipeW; local 362 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, [all...] |
H A D | tstRTPoll.cpp | 83 RTPIPE hPipeR; local 85 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0/*fFlags*/), VINF_SUCCESS); 86 RTTESTI_CHECK_RC(RTPollSetAddPipe(hSet, hPipeR, RTPOLL_EVT_ERROR, 0), VINF_SUCCESS); 87 RTTESTI_CHECK_RC(RTPollSetAddPipe(hSet, hPipeR, RTPOLL_EVT_ERROR, 0), VERR_POLL_HANDLE_ID_EXISTS); 89 RTPipeClose(hPipeR); 137 RTPIPE hPipeR; local 139 RTTESTI_CHECK_RC_RETV(RTPipeCreate(&hPipeR, &hPipeW, 0/*fFlags*/), VINF_SUCCESS); 146 RTTESTI_CHECK_RC_RETV(RTPollSetAddPipe(hSet, hPipeR, RTPOLL_EVT_READ, 1 /*id*/), VINF_SUCCESS); 152 RTTESTI_CHECK(Handle.u.hPipe == hPipeR); 180 RTTESTI_CHECK(Handle.u.hPipe == hPipeR); [all...] |
/vbox/src/VBox/Runtime/r3/win/ |
H A D | pipe-win.cpp | 171 HANDLE hPipeR; local 200 hPipeR = CreateNamedPipeA(szName, dwOpenMode, dwPipeMode, 1 /*nMaxInstances*/, RTPIPE_NT_SIZE, RTPIPE_NT_SIZE, 203 if (hPipeR == INVALID_HANDLE_VALUE && GetLastError() == ERROR_INVALID_PARAMETER) 206 hPipeR = CreateNamedPipeA(szName, dwOpenMode, dwPipeMode, 1 /*nMaxInstances*/, RTPIPE_NT_SIZE, RTPIPE_NT_SIZE, 211 if (hPipeR == INVALID_HANDLE_VALUE && GetLastError() == ERROR_INVALID_PARAMETER) 214 hPipeR = CreateNamedPipeA(szName, dwOpenMode, dwPipeMode, 1 /*nMaxInstances*/, RTPIPE_NT_SIZE, RTPIPE_NT_SIZE, 218 if (hPipeR != INVALID_HANDLE_VALUE) 244 CloseHandle(hPipeR); 279 pThisR->hPipe = hPipeR; 321 CloseHandle(hPipeR); [all...] |
/vbox/src/VBox/Devices/USB/usbip/ |
H A D | USBProxyDevice-usbip.cpp | 321 RTPIPE hPipeR; member in struct:USBPROXYDEVUSBIP 734 pDevUsbIp->hPipeR = NIL_RTPIPE; 741 rc = RTPipeCreate(&pDevUsbIp->hPipeR, &pDevUsbIp->hPipeW, 0); 747 rc = RTPollSetAddPipe(pDevUsbIp->hPollSet, pDevUsbIp->hPipeR, 767 int rc2 = RTPipeClose(pDevUsbIp->hPipeR); 795 rc = RTPipeClose(pDevUsbIp->hPipeR);
|
/vbox/src/VBox/Runtime/r3/os2/ |
H A D | pipe-os2.cpp | 127 HPIPE hPipeR; local 145 orc = DosCreateNPipe((PSZ)szName, &hPipeR, fOpenMode, fPipeMode, RTPIPE_OS2_SIZE, RTPIPE_OS2_SIZE, NP_DEFAULT_WAIT); 148 orc = DosConnectNPipe(hPipeR); 164 DosClose(hPipeR); 191 pThisR->hPipe = hPipeR; 224 DosClose(hPipeR);
|
/vbox/src/VBox/Devices/Storage/ |
H A D | DrvVD.cpp | 1094 RTPIPE hPipeR; member in struct:VDSOCKETINT 1123 pSockInt->hPipeR = NIL_RTPIPE; 1131 rc = RTPipeCreate(&pSockInt->hPipeR, &pSockInt->hPipeW, 0); 1137 rc = RTPollSetAddPipe(pSockInt->hPollSet, pSockInt->hPipeR, 1150 rc2 = RTPipeClose(pSockInt->hPipeR); 1185 rc = RTPipeClose(pSockInt->hPipeR); 1403 rc = RTPipeRead(pSockInt->hPipeR, abBuf, sizeof(abBuf), &cbRead); 1440 rc = RTPipeReadBlocking(pSockInt->hPipeR, &ch, 1, &cbRead); 1496 rc = RTPipeRead(pSockInt->hPipeR, abBuf, sizeof(abBuf), &cbRead); 1523 rc = RTPipeRead(pSockInt->hPipeR, [all...] |
/vbox/src/VBox/Main/src-all/ |
H A D | ExtPackManagerImpl.cpp | 2195 RTPIPE hPipeR; 2198 vrc = RTPipeCreate(&hPipeR, &hStdErrPipe.u.hPipe, RTPIPE_C_INHERIT_WRITE); 2234 if (hPipeR != NIL_RTPIPE) 2238 vrc = RTPipeReadBlocking(hPipeR, achBuf, sizeof(achBuf), &cbRead); 2266 RTPipeClose(hPipeR); 2267 hPipeR = NIL_RTPIPE; 2277 hPipeR == NIL_RTPIPE ? RTPROCWAIT_FLAGS_BLOCK : RTPROCWAIT_FLAGS_NOBLOCK, 2284 } while ( hPipeR != NIL_RTPIPE 2337 RTPipeClose(hPipeR);
|