| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_received_packet_manager.h" | 5 #include "net/quic/quic_received_packet_manager.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/base/linked_hash_map.h" | 9 #include "net/base/linked_hash_map.h" |
| 10 | 10 |
| (...skipping 164 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 175 packets_entropy_hash_ ^= it->second; | 175 packets_entropy_hash_ ^= it->second; |
| 176 } | 176 } |
| 177 // Discard entropies before least unacked. | 177 // Discard entropies before least unacked. |
| 178 packets_entropy_.erase( | 178 packets_entropy_.erase( |
| 179 packets_entropy_.begin(), | 179 packets_entropy_.begin(), |
| 180 packets_entropy_.lower_bound( | 180 packets_entropy_.lower_bound( |
| 181 min(peer_least_unacked, received_info_.largest_observed))); | 181 min(peer_least_unacked, received_info_.largest_observed))); |
| 182 } | 182 } |
| 183 | 183 |
| 184 void QuicReceivedPacketManager::UpdatePacketInformationReceivedByPeer( | 184 void QuicReceivedPacketManager::UpdatePacketInformationReceivedByPeer( |
| 185 const QuicAckFrame& incoming_ack) { | 185 const ReceivedPacketInfo& received_info) { |
| 186 // ValidateAck should fail if largest_observed ever shrinks. | 186 // ValidateAck should fail if largest_observed ever shrinks. |
| 187 DCHECK_LE(peer_largest_observed_packet_, | 187 DCHECK_LE(peer_largest_observed_packet_, received_info.largest_observed); |
| 188 incoming_ack.received_info.largest_observed); | 188 peer_largest_observed_packet_ = received_info.largest_observed; |
| 189 peer_largest_observed_packet_ = incoming_ack.received_info.largest_observed; | |
| 190 | 189 |
| 191 if (incoming_ack.received_info.missing_packets.empty()) { | 190 if (received_info.missing_packets.empty()) { |
| 192 least_packet_awaited_by_peer_ = peer_largest_observed_packet_ + 1; | 191 least_packet_awaited_by_peer_ = peer_largest_observed_packet_ + 1; |
| 193 } else { | 192 } else { |
| 194 least_packet_awaited_by_peer_ = | 193 least_packet_awaited_by_peer_ = *(received_info.missing_packets.begin()); |
| 195 *(incoming_ack.received_info.missing_packets.begin()); | |
| 196 } | 194 } |
| 197 } | 195 } |
| 198 | 196 |
| 199 bool QuicReceivedPacketManager::DontWaitForPacketsBefore( | 197 bool QuicReceivedPacketManager::DontWaitForPacketsBefore( |
| 200 QuicPacketSequenceNumber least_unacked) { | 198 QuicPacketSequenceNumber least_unacked) { |
| 201 received_info_.revived_packets.erase( | 199 received_info_.revived_packets.erase( |
| 202 received_info_.revived_packets.begin(), | 200 received_info_.revived_packets.begin(), |
| 203 received_info_.revived_packets.lower_bound(least_unacked)); | 201 received_info_.revived_packets.lower_bound(least_unacked)); |
| 204 size_t missing_packets_count = received_info_.missing_packets.size(); | 202 size_t missing_packets_count = received_info_.missing_packets.size(); |
| 205 received_info_.missing_packets.erase( | 203 received_info_.missing_packets.erase( |
| 206 received_info_.missing_packets.begin(), | 204 received_info_.missing_packets.begin(), |
| 207 received_info_.missing_packets.lower_bound(least_unacked)); | 205 received_info_.missing_packets.lower_bound(least_unacked)); |
| 208 return missing_packets_count != received_info_.missing_packets.size(); | 206 return missing_packets_count != received_info_.missing_packets.size(); |
| 209 } | 207 } |
| 210 | 208 |
| 211 void QuicReceivedPacketManager::UpdatePacketInformationSentByPeer( | 209 void QuicReceivedPacketManager::UpdatePacketInformationSentByPeer( |
| 212 const QuicAckFrame& incoming_ack) { | 210 const SentPacketInfo& sent_info) { |
| 213 // ValidateAck() should fail if peer_least_packet_awaiting_ack_ shrinks. | 211 // ValidateAck() should fail if peer_least_packet_awaiting_ack_ shrinks. |
| 214 DCHECK_LE(peer_least_packet_awaiting_ack_, | 212 DCHECK_LE(peer_least_packet_awaiting_ack_, sent_info.least_unacked); |
| 215 incoming_ack.sent_info.least_unacked); | 213 if (sent_info.least_unacked > peer_least_packet_awaiting_ack_) { |
| 216 if (incoming_ack.sent_info.least_unacked > peer_least_packet_awaiting_ack_) { | 214 bool missed_packets = DontWaitForPacketsBefore(sent_info.least_unacked); |
| 217 bool missed_packets = | 215 if (missed_packets || sent_info.least_unacked > |
| 218 DontWaitForPacketsBefore(incoming_ack.sent_info.least_unacked); | |
| 219 if (missed_packets || incoming_ack.sent_info.least_unacked > | |
| 220 received_info_.largest_observed + 1) { | 216 received_info_.largest_observed + 1) { |
| 221 DVLOG(1) << "Updating entropy hashed since we missed packets"; | 217 DVLOG(1) << "Updating entropy hashed since we missed packets"; |
| 222 // There were some missing packets that we won't ever get now. Recalculate | 218 // There were some missing packets that we won't ever get now. Recalculate |
| 223 // the received entropy hash. | 219 // the received entropy hash. |
| 224 RecalculateEntropyHash(incoming_ack.sent_info.least_unacked, | 220 RecalculateEntropyHash(sent_info.least_unacked, sent_info.entropy_hash); |
| 225 incoming_ack.sent_info.entropy_hash); | |
| 226 } | 221 } |
| 227 peer_least_packet_awaiting_ack_ = incoming_ack.sent_info.least_unacked; | 222 peer_least_packet_awaiting_ack_ = sent_info.least_unacked; |
| 228 } | 223 } |
| 229 DCHECK(received_info_.missing_packets.empty() || | 224 DCHECK(received_info_.missing_packets.empty() || |
| 230 *received_info_.missing_packets.begin() >= | 225 *received_info_.missing_packets.begin() >= |
| 231 peer_least_packet_awaiting_ack_); | 226 peer_least_packet_awaiting_ack_); |
| 232 } | 227 } |
| 233 | 228 |
| 234 bool QuicReceivedPacketManager::HasMissingPackets() { | 229 bool QuicReceivedPacketManager::HasMissingPackets() { |
| 235 return !received_info_.missing_packets.empty(); | 230 return !received_info_.missing_packets.empty(); |
| 236 } | 231 } |
| 237 | 232 |
| 238 bool QuicReceivedPacketManager::HasNewMissingPackets() { | 233 bool QuicReceivedPacketManager::HasNewMissingPackets() { |
| 239 return HasMissingPackets() && | 234 return HasMissingPackets() && |
| 240 (received_info_.largest_observed - | 235 (received_info_.largest_observed - |
| 241 *received_info_.missing_packets.rbegin()) <= kMaxPacketsAfterNewMissing; | 236 *received_info_.missing_packets.rbegin()) <= kMaxPacketsAfterNewMissing; |
| 242 } | 237 } |
| 243 | 238 |
| 244 } // namespace net | 239 } // namespace net |
| OLD | NEW |