| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/quic/quic_unacked_packet_map.h" | 5 #include "net/quic/quic_unacked_packet_map.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/stl_util.h" | 8 #include "base/stl_util.h" |
| 9 #include "net/quic/quic_connection_stats.h" | 9 #include "net/quic/quic_connection_stats.h" |
| 10 #include "net/quic/quic_utils_chromium.h" | 10 #include "net/quic/quic_utils_chromium.h" |
| (...skipping 180 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 191 bytes_in_flight_ -= it->second.bytes_sent; | 191 bytes_in_flight_ -= it->second.bytes_sent; |
| 192 it->second.pending = false; | 192 it->second.pending = false; |
| 193 } | 193 } |
| 194 } | 194 } |
| 195 | 195 |
| 196 bool QuicUnackedPacketMap::HasUnackedPackets() const { | 196 bool QuicUnackedPacketMap::HasUnackedPackets() const { |
| 197 return !unacked_packets_.empty(); | 197 return !unacked_packets_.empty(); |
| 198 } | 198 } |
| 199 | 199 |
| 200 bool QuicUnackedPacketMap::HasPendingPackets() const { | 200 bool QuicUnackedPacketMap::HasPendingPackets() const { |
| 201 for (UnackedPacketMap::const_reverse_iterator it = | 201 return bytes_in_flight_ > 0; |
| 202 unacked_packets_.rbegin(); it != unacked_packets_.rend(); ++it) { | |
| 203 if (it->second.pending) { | |
| 204 return true; | |
| 205 } | |
| 206 } | |
| 207 return false; | |
| 208 } | 202 } |
| 209 | 203 |
| 210 const TransmissionInfo& QuicUnackedPacketMap::GetTransmissionInfo( | 204 const TransmissionInfo& QuicUnackedPacketMap::GetTransmissionInfo( |
| 211 QuicPacketSequenceNumber sequence_number) const { | 205 QuicPacketSequenceNumber sequence_number) const { |
| 212 return unacked_packets_.find(sequence_number)->second; | 206 return unacked_packets_.find(sequence_number)->second; |
| 213 } | 207 } |
| 214 | 208 |
| 215 QuicTime QuicUnackedPacketMap::GetLastPacketSentTime() const { | 209 QuicTime QuicUnackedPacketMap::GetLastPacketSentTime() const { |
| 216 UnackedPacketMap::const_reverse_iterator it = unacked_packets_.rbegin(); | 210 UnackedPacketMap::const_reverse_iterator it = unacked_packets_.rbegin(); |
| 217 while (it != unacked_packets_.rend()) { | 211 while (it != unacked_packets_.rend()) { |
| (...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 264 bool QuicUnackedPacketMap::HasUnackedRetransmittableFrames() const { | 258 bool QuicUnackedPacketMap::HasUnackedRetransmittableFrames() const { |
| 265 for (UnackedPacketMap::const_reverse_iterator it = | 259 for (UnackedPacketMap::const_reverse_iterator it = |
| 266 unacked_packets_.rbegin(); it != unacked_packets_.rend(); ++it) { | 260 unacked_packets_.rbegin(); it != unacked_packets_.rend(); ++it) { |
| 267 if (it->second.pending && it->second.retransmittable_frames) { | 261 if (it->second.pending && it->second.retransmittable_frames) { |
| 268 return true; | 262 return true; |
| 269 } | 263 } |
| 270 } | 264 } |
| 271 return false; | 265 return false; |
| 272 } | 266 } |
| 273 | 267 |
| 274 size_t QuicUnackedPacketMap::GetNumRetransmittablePackets() const { | |
| 275 size_t num_unacked_packets = 0; | |
| 276 for (UnackedPacketMap::const_iterator it = unacked_packets_.begin(); | |
| 277 it != unacked_packets_.end(); ++it) { | |
| 278 if (it->second.retransmittable_frames != NULL) { | |
| 279 ++num_unacked_packets; | |
| 280 } | |
| 281 } | |
| 282 return num_unacked_packets; | |
| 283 } | |
| 284 | |
| 285 QuicPacketSequenceNumber | 268 QuicPacketSequenceNumber |
| 286 QuicUnackedPacketMap::GetLeastUnackedSentPacket() const { | 269 QuicUnackedPacketMap::GetLeastUnackedSentPacket() const { |
| 287 if (unacked_packets_.empty()) { | 270 if (unacked_packets_.empty()) { |
| 288 // If there are no unacked packets, return 0. | 271 // If there are no unacked packets, return 0. |
| 289 return 0; | 272 return 0; |
| 290 } | 273 } |
| 291 | 274 |
| 292 return unacked_packets_.begin()->first; | 275 return unacked_packets_.begin()->first; |
| 293 } | 276 } |
| 294 | 277 |
| (...skipping 13 matching lines...) Expand all Loading... |
| 308 largest_sent_packet_ = max(sequence_number, largest_sent_packet_); | 291 largest_sent_packet_ = max(sequence_number, largest_sent_packet_); |
| 309 it->second.sent_time = sent_time; | 292 it->second.sent_time = sent_time; |
| 310 if (set_pending) { | 293 if (set_pending) { |
| 311 bytes_in_flight_ += bytes_sent; | 294 bytes_in_flight_ += bytes_sent; |
| 312 it->second.bytes_sent = bytes_sent; | 295 it->second.bytes_sent = bytes_sent; |
| 313 it->second.pending = true; | 296 it->second.pending = true; |
| 314 } | 297 } |
| 315 } | 298 } |
| 316 | 299 |
| 317 } // namespace net | 300 } // namespace net |
| OLD | NEW |