| Index: net/quic/quic_unacked_packet_map.cc
|
| diff --git a/net/quic/quic_unacked_packet_map.cc b/net/quic/quic_unacked_packet_map.cc
|
| index c84ab1109e9b7b9272b917263f6e8c9a46d86713..b230485a9288548893637ee9153fe8be1db89408 100644
|
| --- a/net/quic/quic_unacked_packet_map.cc
|
| +++ b/net/quic/quic_unacked_packet_map.cc
|
| @@ -84,10 +84,10 @@ void QuicUnackedPacketMap::ClearPreviousRetransmissions(size_t num_to_clear) {
|
| UnackedPacketMap::iterator it = unacked_packets_.begin();
|
| while (it != unacked_packets_.end() && num_to_clear > 0) {
|
| QuicPacketSequenceNumber sequence_number = it->first;
|
| - // If this is a pending packet, or has retransmittable data, then there is
|
| + // If this packet is in flight, or has retransmittable data, then there is
|
| // no point in clearing out any further packets, because they would not
|
| // affect the high water mark.
|
| - if (it->second.pending || it->second.retransmittable_frames != NULL) {
|
| + if (it->second.in_flight || it->second.retransmittable_frames != NULL) {
|
| break;
|
| }
|
|
|
| @@ -143,7 +143,7 @@ void QuicUnackedPacketMap::RemoveRetransmittability(
|
| continue;
|
| }
|
| MaybeRemoveRetransmittableFrames(transmission_info);
|
| - if (*it <= largest_observed_ && !transmission_info->pending) {
|
| + if (*it <= largest_observed_ && !transmission_info->in_flight) {
|
| unacked_packets_.erase(*it);
|
| } else {
|
| transmission_info->all_transmissions = new SequenceNumberSet();
|
| @@ -184,9 +184,9 @@ void QuicUnackedPacketMap::IncreaseLargestObserved(
|
| }
|
|
|
| bool QuicUnackedPacketMap::IsPacketUseless(
|
| - UnackedPacketMap::const_iterator it) {
|
| + UnackedPacketMap::const_iterator it) const {
|
| return it->first <= largest_observed_ &&
|
| - !it->second.pending &&
|
| + !it->second.in_flight &&
|
| it->second.retransmittable_frames == NULL &&
|
| it->second.all_transmissions->size() == 1;
|
| }
|
| @@ -196,18 +196,18 @@ bool QuicUnackedPacketMap::IsUnacked(
|
| return ContainsKey(unacked_packets_, sequence_number);
|
| }
|
|
|
| -void QuicUnackedPacketMap::SetNotPending(
|
| +void QuicUnackedPacketMap::RemoveFromInFlight(
|
| QuicPacketSequenceNumber sequence_number) {
|
| UnackedPacketMap::iterator it = unacked_packets_.find(sequence_number);
|
| if (it == unacked_packets_.end()) {
|
| - LOG(DFATAL) << "SetNotPending called for packet that is not unacked: "
|
| + LOG(DFATAL) << "RemoveFromFlight called for packet that is not unacked: "
|
| << sequence_number;
|
| return;
|
| }
|
| - if (it->second.pending) {
|
| + if (it->second.in_flight) {
|
| LOG_IF(DFATAL, bytes_in_flight_ < it->second.bytes_sent);
|
| bytes_in_flight_ -= it->second.bytes_sent;
|
| - it->second.pending = false;
|
| + it->second.in_flight = false;
|
| }
|
| if (IsPacketUseless(it)) {
|
| delete it->second.all_transmissions;
|
| @@ -219,7 +219,7 @@ bool QuicUnackedPacketMap::HasUnackedPackets() const {
|
| return !unacked_packets_.empty();
|
| }
|
|
|
| -bool QuicUnackedPacketMap::HasPendingPackets() const {
|
| +bool QuicUnackedPacketMap::HasInFlightPackets() const {
|
| return bytes_in_flight_ > 0;
|
| }
|
|
|
| @@ -231,25 +231,24 @@ const TransmissionInfo& QuicUnackedPacketMap::GetTransmissionInfo(
|
| QuicTime QuicUnackedPacketMap::GetLastPacketSentTime() const {
|
| UnackedPacketMap::const_reverse_iterator it = unacked_packets_.rbegin();
|
| while (it != unacked_packets_.rend()) {
|
| - if (it->second.pending) {
|
| + if (it->second.in_flight) {
|
| LOG_IF(DFATAL, it->second.sent_time == QuicTime::Zero())
|
| - << "Sent time can never be zero for a pending packet.";
|
| + << "Sent time can never be zero for a packet in flight.";
|
| return it->second.sent_time;
|
| }
|
| ++it;
|
| }
|
| - LOG(DFATAL) << "Unable to find sent time. "
|
| - << "This method is only intended when there are pending packets.";
|
| + LOG(DFATAL) << "GetLastPacketSentTime requires in flight packets.";
|
| return QuicTime::Zero();
|
| }
|
|
|
| -QuicTime QuicUnackedPacketMap::GetFirstPendingPacketSentTime() const {
|
| +QuicTime QuicUnackedPacketMap::GetFirstInFlightPacketSentTime() const {
|
| UnackedPacketMap::const_iterator it = unacked_packets_.begin();
|
| - while (it != unacked_packets_.end() && !it->second.pending) {
|
| + while (it != unacked_packets_.end() && !it->second.in_flight) {
|
| ++it;
|
| }
|
| if (it == unacked_packets_.end()) {
|
| - LOG(DFATAL) << "No pending packets";
|
| + LOG(DFATAL) << "GetFirstInFlightPacketSentTime requires in flight packets.";
|
| return QuicTime::Zero();
|
| }
|
| return it->second.sent_time;
|
| @@ -259,14 +258,14 @@ size_t QuicUnackedPacketMap::GetNumUnackedPackets() const {
|
| return unacked_packets_.size();
|
| }
|
|
|
| -bool QuicUnackedPacketMap::HasMultiplePendingPackets() const {
|
| - size_t num_pending = 0;
|
| +bool QuicUnackedPacketMap::HasMultipleInFlightPackets() const {
|
| + size_t num_in_flight = 0;
|
| for (UnackedPacketMap::const_reverse_iterator it = unacked_packets_.rbegin();
|
| it != unacked_packets_.rend(); ++it) {
|
| - if (it->second.pending) {
|
| - ++num_pending;
|
| + if (it->second.in_flight) {
|
| + ++num_in_flight;
|
| }
|
| - if (num_pending > 1) {
|
| + if (num_in_flight > 1) {
|
| return true;
|
| }
|
| }
|
| @@ -280,7 +279,7 @@ bool QuicUnackedPacketMap::HasPendingCryptoPackets() const {
|
| bool QuicUnackedPacketMap::HasUnackedRetransmittableFrames() const {
|
| for (UnackedPacketMap::const_reverse_iterator it =
|
| unacked_packets_.rbegin(); it != unacked_packets_.rend(); ++it) {
|
| - if (it->second.pending && it->second.retransmittable_frames) {
|
| + if (it->second.in_flight && it->second.retransmittable_frames) {
|
| return true;
|
| }
|
| }
|
| @@ -300,7 +299,7 @@ QuicUnackedPacketMap::GetLeastUnackedSentPacket() const {
|
| void QuicUnackedPacketMap::SetSent(QuicPacketSequenceNumber sequence_number,
|
| QuicTime sent_time,
|
| QuicByteCount bytes_sent,
|
| - bool set_pending) {
|
| + bool set_in_flight) {
|
| DCHECK_LT(0u, sequence_number);
|
| UnackedPacketMap::iterator it = unacked_packets_.find(sequence_number);
|
| if (it == unacked_packets_.end()) {
|
| @@ -308,14 +307,14 @@ void QuicUnackedPacketMap::SetSent(QuicPacketSequenceNumber sequence_number,
|
| << sequence_number;
|
| return;
|
| }
|
| - DCHECK(!it->second.pending);
|
| + DCHECK(!it->second.in_flight);
|
|
|
| largest_sent_packet_ = max(sequence_number, largest_sent_packet_);
|
| it->second.sent_time = sent_time;
|
| - if (set_pending) {
|
| + if (set_in_flight) {
|
| bytes_in_flight_ += bytes_sent;
|
| it->second.bytes_sent = bytes_sent;
|
| - it->second.pending = true;
|
| + it->second.in_flight = true;
|
| }
|
| }
|
|
|
|
|