Cross Reference: /vbox/src/VBox/Devices/Storage/DrvVD.cpp

Lines Matching refs:pSockInt
1115     PVDSOCKETINT pSockInt = NULL;
1117     pSockInt = (PVDSOCKETINT)RTMemAllocZ(sizeof(VDSOCKETINT));
1118     if (!pSockInt)
1121     pSockInt->hSocket  = NIL_RTSOCKET;
1122     pSockInt->hPollSet = NIL_RTPOLLSET;
1123     pSockInt->hPipeR   = NIL_RTPIPE;
1124     pSockInt->hPipeW   = NIL_RTPIPE;
1125     pSockInt->fWokenUp = false;
1126     pSockInt->fWaiting = false;
1131         rc = RTPipeCreate(&pSockInt->hPipeR, &pSockInt->hPipeW, 0);
1134             rc = RTPollSetCreate(&pSockInt->hPollSet);
1137                 rc = RTPollSetAddPipe(pSockInt->hPollSet, pSockInt->hPipeR,
1141                     *pSock = pSockInt;
1145                 RTPollSetRemove(pSockInt->hPollSet, VDSOCKET_POLL_ID_PIPE);
1146                 rc2 = RTPollSetDestroy(pSockInt->hPollSet);
1150             rc2 = RTPipeClose(pSockInt->hPipeR);
1152             rc2 = RTPipeClose(pSockInt->hPipeW);
1158         *pSock = pSockInt;
1162     RTMemFree(pSockInt);
1171     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1174     if (pSockInt->hPollSet != NIL_RTPOLLSET)
1176         if (pSockInt->hSocket != NIL_RTSOCKET)
1178             rc = RTPollSetRemove(pSockInt->hPollSet, VDSOCKET_POLL_ID_SOCKET);
1181         rc = RTPollSetRemove(pSockInt->hPollSet, VDSOCKET_POLL_ID_PIPE);
1183         rc = RTPollSetDestroy(pSockInt->hPollSet);
1185         rc = RTPipeClose(pSockInt->hPipeR);
1187         rc = RTPipeClose(pSockInt->hPipeW);
1191     if (pSockInt->hSocket != NIL_RTSOCKET)
1192         rc = RTTcpClientCloseEx(pSockInt->hSocket, false /*fGracefulShutdown*/);
1194     RTMemFree(pSockInt);
1204     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1206     rc = RTTcpClientConnectEx(pszAddress, uPort, &pSockInt->hSocket, cMillies, NULL);
1210         if (pSockInt->hPollSet != NIL_RTPOLLSET)
1212             pSockInt->fEventsOld = RTPOLL_EVT_READ | RTPOLL_EVT_WRITE | RTPOLL_EVT_ERROR;
1214             rc = RTPollSetAddSocket(pSockInt->hPollSet, pSockInt->hSocket,
1215                                     pSockInt->fEventsOld, VDSOCKET_POLL_ID_SOCKET);
1221         rc = RTTcpClientCloseEx(pSockInt->hSocket, false /*fGracefulShutdown*/);
1231     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1233     if (pSockInt->hPollSet != NIL_RTPOLLSET)
1235         rc = RTPollSetRemove(pSockInt->hPollSet, VDSOCKET_POLL_ID_SOCKET);
1239     rc = RTTcpClientCloseEx(pSockInt->hSocket, false /*fGracefulShutdown*/);
1240     pSockInt->hSocket = NIL_RTSOCKET;
1248     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1250     return pSockInt->hSocket != NIL_RTSOCKET;
1256     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1258     return RTTcpSelectOne(pSockInt->hSocket, cMillies);
1264     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1266     return RTTcpRead(pSockInt->hSocket, pvBuffer, cbBuffer, pcbRead);
1272     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1274     return RTTcpWrite(pSockInt->hSocket, pvBuffer, cbBuffer);
1280     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1282     return RTTcpSgWrite(pSockInt->hSocket, pSgBuf);
1288     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1290     return RTTcpReadNB(pSockInt->hSocket, pvBuffer, cbBuffer, pcbRead);
1296     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1298     return RTTcpWriteNB(pSockInt->hSocket, pvBuffer, cbBuffer, pcbWritten);
1304     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1306     return RTTcpSgWriteNB(pSockInt->hSocket, pSgBuf, pcbWritten);
1312     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1314     return RTTcpFlush(pSockInt->hSocket);
1320     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1322     return RTTcpSetSendCoalescing(pSockInt->hSocket, fEnable);
1328     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1330     return RTTcpGetLocalAddress(pSockInt->hSocket, pAddr);
1336     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1338     return RTTcpGetPeerAddress(pSockInt->hSocket, pAddr);
1347     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1351     if (   pSockInt->fEventsOld != fEvents
1352         && pSockInt->hSocket != NIL_RTSOCKET)
1363         rc = RTPollSetEventsChange(pSockInt->hPollSet, VDSOCKET_POLL_ID_SOCKET, fPollEvents);
1367         pSockInt->fEventsOld = fEvents;
1370     ASMAtomicXchgBool(&pSockInt->fWaiting, true);
1371     if (ASMAtomicXchgBool(&pSockInt->fWokenUp, false))
1373         ASMAtomicXchgBool(&pSockInt->fWaiting, false);
1377     rc = RTPoll(pSockInt->hPollSet, cMillies, &fEventsRecv, &id);
1380     ASMAtomicXchgBool(&pSockInt->fWaiting, false);
1403             rc = RTPipeRead(pSockInt->hPipeR, abBuf, sizeof(abBuf), &cbRead);
1406             ASMAtomicXchgBool(&pSockInt->fWokenUp, false);
1420     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1424     ASMAtomicXchgBool(&pSockInt->fWaiting, true);
1425     if (ASMAtomicXchgBool(&pSockInt->fWokenUp, false))
1427         ASMAtomicXchgBool(&pSockInt->fWaiting, false);
1431     if (   pSockInt->hSocket == NIL_RTSOCKET
1440         rc = RTPipeReadBlocking(pSockInt->hPipeR, &ch, 1, &cbRead);
1445             ASMAtomicXchgBool(&pSockInt->fWokenUp, false);
1464             rc = RTPollSetRemove(pSockInt->hPollSet, VDSOCKET_POLL_ID_SOCKET);
1470                 rc = RTPoll(pSockInt->hPollSet, 5, &fEvents, &id);
1474                     rc = RTTcpSelectOneEx(pSockInt->hSocket, fSelectEvents, &fEventsRecv, 0);
1496                     rc = RTPipeRead(pSockInt->hPipeR, abBuf, sizeof(abBuf), &cbRead);
1499                     ASMAtomicXchgBool(&pSockInt->fWokenUp, false);
1517                 rc = RTTcpSelectOneEx(pSockInt->hSocket, fSelectEvents, &fEventsRecv, 5);
1523                     rc = RTPipeRead(pSockInt->hPipeR, &ch, 1, &cbRead);
1528                         ASMAtomicXchgBool(&pSockInt->fWokenUp, false);
1550     ASMAtomicXchgBool(&pSockInt->fWaiting, false);
1560     PVDSOCKETINT pSockInt = (PVDSOCKETINT)Sock;
1562     ASMAtomicXchgBool(&pSockInt->fWokenUp, true);
1564     if (ASMAtomicReadBool(&pSockInt->fWaiting))
1566         rc = RTPipeWrite(pSockInt->hPipeW, "", 1, &cbWritten);