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 <limits> | 7 #include <limits> |
8 #include <utility> | 8 #include <utility> |
9 | 9 |
10 #include "base/logging.h" | 10 #include "base/logging.h" |
(...skipping 166 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
177 entropy_tracker_.RecordPacketEntropyHash(packet_number, header.entropy_hash); | 177 entropy_tracker_.RecordPacketEntropyHash(packet_number, header.entropy_hash); |
178 | 178 |
179 ack_frame_.received_packet_times.push_back( | 179 ack_frame_.received_packet_times.push_back( |
180 std::make_pair(packet_number, receipt_time)); | 180 std::make_pair(packet_number, receipt_time)); |
181 | 181 |
182 if (ack_frame_.latest_revived_packet == packet_number) { | 182 if (ack_frame_.latest_revived_packet == packet_number) { |
183 ack_frame_.latest_revived_packet = 0; | 183 ack_frame_.latest_revived_packet = 0; |
184 } | 184 } |
185 } | 185 } |
186 | 186 |
187 void QuicReceivedPacketManager::RecordPacketRevived( | |
188 QuicPacketNumber packet_number) { | |
189 QUIC_BUG_IF(!IsAwaitingPacket(packet_number)) << base::StringPrintf( | |
190 "Not waiting for %llu", static_cast<unsigned long long>(packet_number)); | |
191 ack_frame_updated_ = true; | |
192 ack_frame_.latest_revived_packet = packet_number; | |
193 } | |
194 | |
195 bool QuicReceivedPacketManager::IsMissing(QuicPacketNumber packet_number) { | 187 bool QuicReceivedPacketManager::IsMissing(QuicPacketNumber packet_number) { |
196 return ack_frame_.missing_packets.Contains(packet_number); | 188 return ack_frame_.missing_packets.Contains(packet_number); |
197 } | 189 } |
198 | 190 |
199 bool QuicReceivedPacketManager::IsAwaitingPacket( | 191 bool QuicReceivedPacketManager::IsAwaitingPacket( |
200 QuicPacketNumber packet_number) { | 192 QuicPacketNumber packet_number) { |
201 return ::net::IsAwaitingPacket(ack_frame_, packet_number); | 193 return ::net::IsAwaitingPacket(ack_frame_, packet_number); |
202 } | 194 } |
203 | 195 |
204 namespace { | 196 namespace { |
(...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
299 | 291 |
300 size_t QuicReceivedPacketManager::NumTrackedPackets() const { | 292 size_t QuicReceivedPacketManager::NumTrackedPackets() const { |
301 return entropy_tracker_.size(); | 293 return entropy_tracker_.size(); |
302 } | 294 } |
303 | 295 |
304 bool QuicReceivedPacketManager::ack_frame_updated() const { | 296 bool QuicReceivedPacketManager::ack_frame_updated() const { |
305 return ack_frame_updated_; | 297 return ack_frame_updated_; |
306 } | 298 } |
307 | 299 |
308 } // namespace net | 300 } // namespace net |
OLD | NEW |