Function SessionLevelTest

library/cpp/netliba/v6/udp_test.cpp:78–155

    //}

    static void SessionLevelTest(bool client, const char* serverName, int packetSize, int packetsInFly, int srcPort) {
        BindToSocket(0);
        TIntrusivePtr<IRequester> reqHost;
        //    reqHost = CreateHttpUdpRequester(13013);
        reqHost = CreateHttpUdpRequester(client ? srcPort : 13013);
        TUdpAddress serverAddr = CreateAddress(serverName, 13013);
        TVector<char> dummyPacket;
        dummyPacket.resize(packetSize);
        TReallyFastRng32 rr((unsigned int)GetCycleCount());
        for (size_t i = 0; i < dummyPacket.size(); ++i)
            dummyPacket[i] = (char)rr.Uniform(256);
        bool cont = true;
        NHPTimer::STime t;
        NHPTimer::GetTime(&t);
        THashMap<TGUID, bool, TGUIDHash> seenReqs;
        if (client) {
            THashMap<TGUID, bool, TGUIDHash> reqList;
            int packetsSentCount = 0;
            TUdpHttpRequest* udpReq;
            for (int i = 1; cont; ++i) {
                for (;;) {
                    udpReq = reqHost->GetRequest();
                    if (udpReq == nullptr)
                        break;
                    udpReq->Data.resize(10);
                    reqHost->SendResponse(udpReq->ReqId, &udpReq->Data);
                    delete udpReq;
                }
                while (TUdpHttpResponse* res = reqHost->GetResponse()) {
                    THashMap<TGUID, bool, TGUIDHash>::iterator z = reqList.find(res->ReqId);
                    if (z == reqList.end()) {
                        printf("Unexpected response\n");
                        abort();
                    }
                    reqList.erase(z);
                    if (res->Ok) {
                        ++packetsSentCount;
                        //Y_ASSERT(res->Data == dummyPacket);
                        NHPTimer::STime tChk = t;
                        if (NHPTimer::GetTimePassed(&tChk) > 1) {
                            printf("packet size = %d\n", dummyPacket.ysize());
                            double passedTime = NHPTimer::GetTimePassed(&t);
                            double rate = packetsSentCount / passedTime;
                            printf("packet rate %g, transfer %gmb\n", rate, rate * dummyPacket.size() / 1000000);
                            packetsSentCount = 0;
                        }
                    } else {
                        printf("Failed request!\n");
                        //Sleep(INFINITE);
                    }
                    delete res;
                }
                while (reqList.ysize() < packetsInFly) {
                    *(int*)&dummyPacket[0] = i;
                    TVector<char> fakePacket = dummyPacket;
                    TGUID req2 = reqHost->SendRequest(serverAddr, "blaxuz", &fakePacket);
                    reqList[req2];
                }