Method Recv

library/cpp/netliba/v12/udp_socket.cpp:598–633

    }

    TUdpRecvPacket* TUdpSocket::Recv(TSockAddrPair* addr) {
        TAutoPtr<TUdpRecvPacket> result = nullptr;

        for (;;) {
            result = RecvContinuationPacket(addr);
            if (!!result) {
                break;
            }

            result = S->Recv(&addr->RemoteAddr, &addr->MyAddr, UDP_NETLIBA_VERSION_V12);
            if (!result) {
                return nullptr;
            }

            Y_ASSERT(result->DataStart == 0);
            const size_t recvSize = result->DataSize;

            // skip whole corrupted packet even with small packet optimization
            if (!CheckPacketIntegrity(result->Data.get(), recvSize, *addr)) {
                continue;
            }

            result->DataSize = UDP_LOW_LEVEL_HEADER_SIZE + ReadPacketDataSize(result->Data.get());

            if ((size_t)result->DataSize != recvSize) {
                CacheContinuationUdpPacket(*result, recvSize, *addr);
            }
            break;
        }

        // fixes offsets also for continuation packets
        result->DataStart += UDP_LOW_LEVEL_HEADER_SIZE;
        result->DataSize -= UDP_LOW_LEVEL_HEADER_SIZE;

        return result.Release();
    }

    float TUdpSocket::GetAndResetMergeRatio() {
        if (SendStat.Total == 0)