Commit b7f5eabe authored by jan.koester's avatar jan.koester
Browse files

test

parent f3378f66

src/quic.cpp

+9 −1
Original line number Diff line number Diff line
@@ -2517,7 +2517,15 @@ size_t quic::recvData(buffer& data, int flags) { 
void quic::pumpNetwork(int flags) {

    int recv_flags = (flags & MSG_DONTWAIT) ? MSG_DONTWAIT : 0;

    _pump_buf.size = 65535;  // Reset capacity — udp::recvData shrinks it to bytes-received

    size_t recv_len = udp::recvData(_pump_buf, recv_flags);

    size_t recv_len;

    try {

        recv_len = udp::recvData(_pump_buf, recv_flags);

    } catch (NetException& e) {

        if (e.getErrorType() == NetException::Note) {

            return; // EAGAIN / would block — nothing to read

        }

        throw; // re-throw real errors

    }

    if (recv_len > 0) {

        std::vector<PendingDispatch> dispatches;

        {