Cross Reference: /vbox/src/VBox/ValidationKit/utils/network/NetPerf.cpp

Lines Matching defs:pBuf
494  * @param   pBuf                The buffer we're using when sending.
497 static int netperfTCPThroughputSend(NETPERFPARAMS const *pParams, NETPERFHDR *pBuf, NETPERFSTATS *pSendStats)
511         RT_BZERO(pBuf, pParams->cbPacket);
512         pBuf->u32Magic      = RT_H2LE_U32_C(NETPERFHDR_MAGIC);
513         pBuf->u32State      = 0;
514         pBuf->u32Seq        = 0;
515         pBuf->u32Reserved   = 0;
520         pBuf->u32State = RT_H2LE_U32_C(NETPERFHDR_WARMUP);
527                 pBuf->u32Seq = RT_H2LE_U32(u32Seq);
528                 rc = RTTcpWrite(pParams->hSocket, pBuf, pParams->cbPacket);
544             pBuf->u32State = RT_H2LE_U32_C(NETPERFHDR_TESTING);
553                     pBuf->u32Seq = RT_H2LE_U32(u32Seq);
554                     rc = RTTcpWrite(pParams->hSocket, pBuf, pParams->cbPacket);
573             pBuf->u32State = RT_H2LE_U32_C(NETPERFHDR_COOL_DOWN);
581                     pBuf->u32Seq = RT_H2LE_U32(u32Seq);
582                     rc = RTTcpWrite(pParams->hSocket, pBuf, pParams->cbPacket);
600             pBuf->u32Seq   = RT_H2LE_U32(u32Seq);
601             pBuf->u32State = RT_H2LE_U32_C(NETPERFHDR_DONE);
602             rc = RTTcpWrite(pParams->hSocket, pBuf, pParams->cbPacket);
620  * @param   pBuf                The buffer we're using when sending.
623 static int netperfTCPThroughputRecv(NETPERFPARAMS const *pParams, NETPERFHDR *pBuf, NETPERFSTATS *pStats)
635         rc = RTTcpRead(pParams->hSocket, pBuf, pParams->cbPacket, NULL);
642         if (RT_UNLIKELY(   pBuf->u32Magic    != RT_H2LE_U32_C(NETPERFHDR_MAGIC)
643                         || pBuf->u32Reserved != 0))
646             RTTestIFailed("Invalid magic or reserved field value: %#x %#x\n", RT_H2LE_U32(pBuf->u32Magic), RT_H2LE_U32(pBuf->u32Reserved));
652         if (RT_UNLIKELY(pBuf->u32Seq != RT_H2LE_U32(u32Seq)))
655             RTTestIFailed("Out of sequence: got %#x, expected %#x\n", RT_H2LE_U32(pBuf->u32Seq), u32Seq);
664                 if (((unsigned char *)pBuf)[i])
669                 RTTestIFailed("Broken payload: at %#x got %#x, expected %#x\n", i, ((unsigned char *)pBuf)[i], 0);
674         if (RT_LIKELY(pBuf->u32State == uState))
680                  && pBuf->u32State == RT_H2LE_U32_C(NETPERFHDR_TESTING))
684             uState = pBuf->u32State;
687                  && (   pBuf->u32State == RT_H2LE_U32_C(NETPERFHDR_COOL_DOWN)
688                      || pBuf->u32State == RT_H2LE_U32_C(NETPERFHDR_DONE)) )
692             uState = pBuf->u32State;
697                  && pBuf->u32State == RT_H2LE_U32_C(NETPERFHDR_DONE))
699             uState = pBuf->u32State;
706                           RT_LE2H_U32(uState), RT_LE2H_U32(pBuf->u32State));
794     NETPERFHDR *pBuf = (NETPERFHDR *)RTMemAllocZ(pParams->cbPacket);
795     if (!pBuf)
802     int rc = netperfTCPThroughputRecv(pParams, pBuf, &RecvStats);
809             rc = netperfTCPThroughputSend(pParams, pBuf, &SendStats);
832     NETPERFHDR *pBuf = (NETPERFHDR *)RTMemAllocZ(pParams->cbPacket);
833     if (!pBuf)
840     int rc = netperfTCPThroughputRecv(pParams, pBuf, &RecvStats);
862     NETPERFHDR *pBuf = (NETPERFHDR *)RTMemAllocZ(pParams->cbPacket);
863     if (!pBuf)
870     int rc = netperfTCPThroughputSend(pParams, pBuf, &SendStats);
889     NETPERFHDR *pBuf = (NETPERFHDR *)RTMemAllocZ(pParams->cbPacket);
890     if (!pBuf)
906         rc = RTTcpRead(pParams->hSocket, pBuf, pParams->cbPacket, NULL);
916         if (RT_UNLIKELY(   pBuf->u32Magic    != RT_H2LE_U32_C(NETPERFHDR_MAGIC)
917                         || pBuf->u32Reserved != 0))
919             RTTestIFailed("Invalid magic or reserved field value: %#x %#x\n", RT_H2LE_U32(pBuf->u32Magic), RT_H2LE_U32(pBuf->u32Reserved));
925         if (RT_UNLIKELY(pBuf->u32Seq != RT_H2LE_U32(u32Seq)))
927             RTTestIFailed("Out of sequence: got %#x, expected %#x\n", RT_H2LE_U32(pBuf->u32Seq), u32Seq);
935         if (RT_LIKELY(pBuf->u32State == uState))
941                  && pBuf->u32State == RT_H2LE_U32_C(NETPERFHDR_TESTING))
945             uState = pBuf->u32State;
948                  && (   pBuf->u32State == RT_H2LE_U32_C(NETPERFHDR_COOL_DOWN)
949                      || pBuf->u32State == RT_H2LE_U32_C(NETPERFHDR_DONE)) )
955             uState = pBuf->u32State;
960                  && pBuf->u32State == RT_H2LE_U32_C(NETPERFHDR_DONE))
962             uState = pBuf->u32State;
968                           RT_LE2H_U32(uState), RT_LE2H_U32(pBuf->u32State));
975         rc = RTTcpWrite(pParams->hSocket, pBuf, pParams->cbPacket);
995     RTMemFree(pBuf);
1284     NETPERFHDR *pBuf = (NETPERFHDR *)RTMemAllocZ(pParams->cbPacket);
1285     if (!pBuf)
1292     int rc = netperfTCPThroughputSend(pParams, pBuf, &SendStats);
1300             rc = netperfTCPThroughputRecv(pParams, pBuf, &RecvStats);
1331     NETPERFHDR *pBuf = (NETPERFHDR *)RTMemAllocZ(pParams->cbPacket);
1332     if (!pBuf)
1339     int rc = netperfTCPThroughputSend(pParams, pBuf, &SendStats);
1368     NETPERFHDR *pBuf = (NETPERFHDR *)RTMemAllocZ(pParams->cbPacket);
1369     if (!pBuf)
1376     int rc = netperfTCPThroughputRecv(pParams, pBuf, &RecvStats);