- Timestamp:
- Aug 25, 2021 9:16:25 AM (3 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/src/VBox/Devices/Audio/AudioTestService.cpp
r90830 r90867 117 117 } ATSCLIENTINST; 118 118 /** Pointer to a ATS client instance. */ 119 typedef ATSCLIENTINST *PATS SERVERINST;119 typedef ATSCLIENTINST *PATSCLIENTINST; 120 120 121 121 /** … … 152 152 * aligned buffer. 153 153 */ 154 static int atsSendPkt(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPkt)154 static int atsSendPkt(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPkt) 155 155 { 156 156 Assert(pPkt->cb >= sizeof(*pPkt)); … … 175 175 * @param pszOpcode The BABBLE opcode. 176 176 */ 177 static void atsReplyBabble(PATSSERVER pThis, PATS SERVERINST pInst, const char *pszOpcode)177 static void atsReplyBabble(PATSSERVER pThis, PATSCLIENTINST pInst, const char *pszOpcode) 178 178 { 179 179 ATSPKTHDR Reply; … … 198 198 * @param fAutoRetryOnFailure Whether to retry on error. 199 199 */ 200 static int atsRecvPkt(PATSSERVER pThis, PATS SERVERINST pInst, PPATSPKTHDR ppPktHdr, bool fAutoRetryOnFailure)200 static int atsRecvPkt(PATSSERVER pThis, PATSCLIENTINST pInst, PPATSPKTHDR ppPktHdr, bool fAutoRetryOnFailure) 201 201 { 202 202 for (;;) … … 281 281 * @param cbExtra Bytes in addition to the header. 282 282 */ 283 static int atsReplyInternal(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pReply, const char *pszOpcode, size_t cbExtra)283 static int atsReplyInternal(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pReply, const char *pszOpcode, size_t cbExtra) 284 284 { 285 285 /* copy the opcode, don't be too strict in case of a padding screw up. */ … … 313 313 * with space. 314 314 */ 315 static int atsReplySimple(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr, const char *pszOpcode)315 static int atsReplySimple(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr, const char *pszOpcode) 316 316 { 317 317 return atsReplyInternal(pThis, pInst, pPktHdr, pszOpcode, 0); … … 326 326 * @param pPktHdr The original packet (for future use). 327 327 */ 328 static int atsReplyAck(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr)328 static int atsReplyAck(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr) 329 329 { 330 330 return atsReplySimple(pThis, pInst, pPktHdr, "ACK "); … … 344 344 * @param va Format arguments. 345 345 */ 346 static int atsReplyFailureV(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr,346 static int atsReplyFailureV(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr, 347 347 const char *pszOpcode, int rcReq, const char *pszDetailFmt, va_list va) 348 348 { … … 378 378 * @param ... Format arguments. 379 379 */ 380 static int atsReplyFailure(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr,380 static int atsReplyFailure(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr, 381 381 const char *pszOpcode, int rcReq, const char *pszDetailFmt, ...) 382 382 { … … 401 401 */ 402 402 static int atsReplyRC(PATSSERVER pThis, 403 PATS SERVERINST pInst, PATSPKTHDR pPktHdr, int rcOperation, const char *pszOperationFmt, ...)403 PATSCLIENTINST pInst, PATSPKTHDR pPktHdr, int rcOperation, const char *pszOperationFmt, ...) 404 404 { 405 405 if (RT_SUCCESS(rcOperation)) … … 425 425 * @param cb The wanted size. 426 426 */ 427 static int atsReplyBadSize(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr, size_t cb)427 static int atsReplyBadSize(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr, size_t cb) 428 428 { 429 429 return atsReplyFailure(pThis, pInst, pPktHdr, "BAD SIZE", VERR_INVALID_PARAMETER, "Expected at %zu bytes, got %u (opcode '%.8s')", … … 439 439 * @param pPktHdr The packet to reply to. 440 440 */ 441 static int atsReplyUnknown(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr)441 static int atsReplyUnknown(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr) 442 442 { 443 443 return atsReplyFailure(pThis, pInst, pPktHdr, "UNKNOWN ", VERR_NOT_FOUND, "Opcode '%.8s' is not known", pPktHdr->achOpcode); … … 452 452 * @param pPktHdr The packet containing the unterminated string. 453 453 */ 454 static int atsReplyInvalidState(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr)454 static int atsReplyInvalidState(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr) 455 455 { 456 456 return atsReplyFailure(pThis, pInst, pPktHdr, "INVSTATE", VERR_INVALID_STATE, "Opcode '%.8s' is not supported at client state '%s", … … 466 466 * @param pPktHdr The bye packet. 467 467 */ 468 static int atsDoBye(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr)468 static int atsDoBye(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr) 469 469 { 470 470 int rc; … … 501 501 * @param pPktHdr The howdy packet. 502 502 */ 503 static int atsDoHowdy(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr)503 static int atsDoHowdy(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr) 504 504 { 505 505 int rc = VINF_SUCCESS; … … 544 544 * @param pPktHdr The test set begin packet. 545 545 */ 546 static int atsDoTestSetBegin(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr)546 static int atsDoTestSetBegin(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr) 547 547 { 548 548 if (pPktHdr->cb != sizeof(ATSPKTREQTSETBEG)) … … 578 578 * @param pPktHdr The test set end packet. 579 579 */ 580 static int atsDoTestSetEnd(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr)580 static int atsDoTestSetEnd(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr) 581 581 { 582 582 if (pPktHdr->cb != sizeof(ATSPKTREQTSETEND)) … … 613 613 * @param pPktHdr The original packet (for future use). 614 614 */ 615 static int atsWaitForAck(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr)615 static int atsWaitForAck(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr) 616 616 { 617 617 RT_NOREF(pPktHdr); … … 643 643 * @param pPktHdr The test set end packet. 644 644 */ 645 static int atsDoTestSetSend(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr)645 static int atsDoTestSetSend(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr) 646 646 { 647 647 if (pPktHdr->cb != sizeof(ATSPKTREQTSETSND)) … … 727 727 * @param pPktHdr The packet header. 728 728 */ 729 static int atsDoTonePlay(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr)729 static int atsDoTonePlay(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr) 730 730 { 731 731 int rc = VINF_SUCCESS; … … 758 758 * @param pPktHdr The packet header. 759 759 */ 760 static int atsDoToneRecord(PATSSERVER pThis, PATS SERVERINST pInst, PATSPKTHDR pPktHdr)760 static int atsDoToneRecord(PATSSERVER pThis, PATSCLIENTINST pInst, PATSPKTHDR pPktHdr) 761 761 { 762 762 int rc = VINF_SUCCESS; … … 788 788 * @param pInst The ATS client structure sending the request. 789 789 */ 790 static int atsClientReqProcess(PATSSERVER pThis, PATS SERVERINST pInst)790 static int atsClientReqProcess(PATSSERVER pThis, PATSCLIENTINST pInst) 791 791 { 792 792 /* … … 833 833 * @param pInst The opaque ATS instance structure. 834 834 */ 835 static void atsClientDestroy(PATS SERVERINST pInst)835 static void atsClientDestroy(PATSCLIENTINST pInst) 836 836 { 837 837 if (pInst->pszHostname) … … 852 852 unsigned cClientsMax = 0; 853 853 unsigned cClientsCur = 0; 854 PATS SERVERINST *papInsts = NULL;854 PATSCLIENTINST *papInsts = NULL; 855 855 856 856 /* Add the pipe to the poll set. */ … … 880 880 RTCritSectEnter(&pThis->CritSectClients); 881 881 /* Walk the list and add all new clients. */ 882 PATS SERVERINST pIt, pItNext;882 PATSCLIENTINST pIt, pItNext; 883 883 RTListForEachSafe(&pThis->LstClientsNew, pIt, pItNext, ATSCLIENTINST, NdLst) 884 884 { … … 888 888 { 889 889 /* Realloc to accommodate for the new clients. */ 890 PATS SERVERINST *papInstsNew = (PATSSERVERINST *)RTMemRealloc(papInsts, (cClientsMax + 10) * sizeof(PATSSERVERINST));890 PATSCLIENTINST *papInstsNew = (PATSCLIENTINST *)RTMemRealloc(papInsts, (cClientsMax + 10) * sizeof(PATSCLIENTINST)); 891 891 if (RT_LIKELY(papInstsNew)) 892 892 { … … 926 926 { 927 927 /* Client sends a request, pick the right client and process it. */ 928 PATS SERVERINST pInst = papInsts[uId - 1];928 PATSCLIENTINST pInst = papInsts[uId - 1]; 929 929 AssertPtr(pInst); 930 930 if (fEvts & RTPOLL_EVT_READ) … … 982 982 * the request handling thread. 983 983 */ 984 PATS SERVERINST pInst = (PATSSERVERINST)RTMemAllocZ(sizeof(ATSCLIENTINST));984 PATSCLIENTINST pInst = (PATSCLIENTINST)RTMemAllocZ(sizeof(ATSCLIENTINST)); 985 985 if (RT_LIKELY(pInst)) 986 986 { … … 1195 1195 pThis->hPollSet = NIL_RTPOLLSET; 1196 1196 1197 PATS SERVERINST pIt, pItNext;1197 PATSCLIENTINST pIt, pItNext; 1198 1198 RTListForEachSafe(&pThis->LstClientsNew, pIt, pItNext, ATSCLIENTINST, NdLst) 1199 1199 {
Note:
See TracChangeset
for help on using the changeset viewer.