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

test

parent 5da7aa89

src/quic.cpp

+28 −0
Original line number Diff line number Diff line
@@ -7333,6 +7333,15 @@ size_t quic::sendStreamDataEarly(uint64_t stream_id, const uint8_t* data, size_t 
    // FIN here would declare a too-small final size and make that retry a

    // FINAL_SIZE_ERROR at the peer.

    const bool fin_eligible = fin && send_len == len;



    QUIC_DBG("sendStreamDataEarly: sid=%lu requested=%zu fin=%d offset=%lu "

             "stream_limit=%lu conn_sent=%lu conn_limit=%lu admitted=%zu fin_eligible=%d",

             (unsigned long)stream_id, len, (int)fin,

             (unsigned long)stream.send_offset,

             (unsigned long)stream.max_data_remote,

             (unsigned long)_data_sent,

             (unsigned long)_max_data_remote,

             send_len, (int)fin_eligible);

    if (send_len == 0 && !fin) return 0;



    // Conservative fixed chunk size — 0-RTT packets are padded to the same
@@ -7370,6 +7379,11 @@ size_t quic::sendStreamDataEarly(uint64_t stream_id, const uint8_t* data, size_t 
    _data_sent += sent_total;

    if (sent_fin) stream.send_fin = true;



    QUIC_DBG("sendStreamDataEarly: sid=%lu sent=%zu requested=%zu fin=%d "

             "fin_eligible=%d send_fin=%d new_offset=%lu",

             (unsigned long)stream_id, sent_total, len, (int)fin,

             (int)fin_eligible, (int)stream.send_fin,

             (unsigned long)stream.send_offset);

    return sent_total;

}
@@ -7452,6 +7466,15 @@ size_t quic::sendStreamData(uint64_t stream_id, const uint8_t* data, size_t len, 
    // write.  Only the call that can accept all `len` bytes may carry FIN.

    const bool fin_eligible = fin && send_len == len;



    QUIC_DBG("sendStreamData: sid=%lu requested=%zu fin=%d offset=%lu "

             "stream_limit=%lu conn_sent=%lu conn_limit=%lu admitted=%zu fin_eligible=%d",

             (unsigned long)stream_id, len, (int)fin,

             (unsigned long)stream.send_offset,

             (unsigned long)stream.max_data_remote,

             (unsigned long)_data_sent,

             (unsigned long)_max_data_remote,

             send_len, (int)fin_eligible);

    

    if (send_len == 0 && !fin) {

        return 0;

    }
@@ -7795,6 +7818,11 @@ size_t quic::sendStreamData(uint64_t stream_id, const uint8_t* data, size_t len, 
        }

    }



    QUIC_DBG("sendStreamData: sid=%lu sent=%zu requested=%zu fin=%d "

             "fin_eligible=%d send_fin=%d new_offset=%lu",

             (unsigned long)stream_id, sent_total, len, (int)fin,

             (int)fin_eligible, (int)stream.send_fin,

             (unsigned long)stream.send_offset);

    return sent_total;

}