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/core/quic_sent_packet_manager.h" | 5 #include "net/quic/core/quic_sent_packet_manager.h" |
6 | 6 |
7 #include <memory> | 7 #include <memory> |
8 | 8 |
9 #include "base/memory/ptr_util.h" | 9 #include "base/memory/ptr_util.h" |
10 #include "net/quic/core/quic_flags.h" | 10 #include "net/quic/core/quic_flags.h" |
(...skipping 159 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
170 RetransmitAndSendPacket(old_packet_number, new_packet_number, | 170 RetransmitAndSendPacket(old_packet_number, new_packet_number, |
171 TLP_RETRANSMISSION); | 171 TLP_RETRANSMISSION); |
172 } | 172 } |
173 | 173 |
174 void RetransmitAndSendPacket(QuicPacketNumber old_packet_number, | 174 void RetransmitAndSendPacket(QuicPacketNumber old_packet_number, |
175 QuicPacketNumber new_packet_number, | 175 QuicPacketNumber new_packet_number, |
176 TransmissionType transmission_type) { | 176 TransmissionType transmission_type) { |
177 QuicSentPacketManagerPeer::MarkForRetransmission( | 177 QuicSentPacketManagerPeer::MarkForRetransmission( |
178 &manager_, kDefaultPathId, old_packet_number, transmission_type); | 178 &manager_, kDefaultPathId, old_packet_number, transmission_type); |
179 EXPECT_TRUE(manager_.HasPendingRetransmissions()); | 179 EXPECT_TRUE(manager_.HasPendingRetransmissions()); |
180 PendingRetransmission next_retransmission = | 180 QuicPendingRetransmission next_retransmission = |
181 manager_.NextPendingRetransmission(); | 181 manager_.NextPendingRetransmission(); |
182 EXPECT_EQ(old_packet_number, next_retransmission.packet_number); | 182 EXPECT_EQ(old_packet_number, next_retransmission.packet_number); |
183 EXPECT_EQ(transmission_type, next_retransmission.transmission_type); | 183 EXPECT_EQ(transmission_type, next_retransmission.transmission_type); |
184 | 184 |
185 EXPECT_CALL(*send_algorithm_, | 185 EXPECT_CALL(*send_algorithm_, |
186 OnPacketSent(_, BytesInFlight(), new_packet_number, | 186 OnPacketSent(_, BytesInFlight(), new_packet_number, |
187 kDefaultLength, HAS_RETRANSMITTABLE_DATA)) | 187 kDefaultLength, HAS_RETRANSMITTABLE_DATA)) |
188 .WillOnce(Return(true)); | 188 .WillOnce(Return(true)); |
189 SerializedPacket packet(CreatePacket(new_packet_number, false)); | 189 SerializedPacket packet(CreatePacket(new_packet_number, false)); |
190 manager_.OnPacketSent(&packet, packet.path_id, old_packet_number, | 190 manager_.OnPacketSent(&packet, packet.path_id, old_packet_number, |
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
246 } | 246 } |
247 | 247 |
248 // Based on QuicConnection's WritePendingRetransmissions. | 248 // Based on QuicConnection's WritePendingRetransmissions. |
249 void RetransmitNextPacket(QuicPacketNumber retransmission_packet_number) { | 249 void RetransmitNextPacket(QuicPacketNumber retransmission_packet_number) { |
250 EXPECT_TRUE(manager_.HasPendingRetransmissions()); | 250 EXPECT_TRUE(manager_.HasPendingRetransmissions()); |
251 EXPECT_CALL(*send_algorithm_, | 251 EXPECT_CALL(*send_algorithm_, |
252 OnPacketSent(_, _, retransmission_packet_number, kDefaultLength, | 252 OnPacketSent(_, _, retransmission_packet_number, kDefaultLength, |
253 HAS_RETRANSMITTABLE_DATA)) | 253 HAS_RETRANSMITTABLE_DATA)) |
254 .Times(1) | 254 .Times(1) |
255 .WillOnce(Return(true)); | 255 .WillOnce(Return(true)); |
256 const PendingRetransmission pending = manager_.NextPendingRetransmission(); | 256 const QuicPendingRetransmission pending = |
| 257 manager_.NextPendingRetransmission(); |
257 SerializedPacket packet(CreatePacket(retransmission_packet_number, false)); | 258 SerializedPacket packet(CreatePacket(retransmission_packet_number, false)); |
258 manager_.OnPacketSent(&packet, pending.path_id, pending.packet_number, | 259 manager_.OnPacketSent(&packet, pending.path_id, pending.packet_number, |
259 clock_.Now(), pending.transmission_type, | 260 clock_.Now(), pending.transmission_type, |
260 HAS_RETRANSMITTABLE_DATA); | 261 HAS_RETRANSMITTABLE_DATA); |
261 } | 262 } |
262 | 263 |
263 // Initialize a frame acknowledging all packets up to largest_observed. | 264 // Initialize a frame acknowledging all packets up to largest_observed. |
264 const QuicAckFrame InitAckFrame(QuicPacketNumber largest_observed) { | 265 const QuicAckFrame InitAckFrame(QuicPacketNumber largest_observed) { |
265 QuicAckFrame frame(MakeAckFrame(largest_observed)); | 266 QuicAckFrame frame(MakeAckFrame(largest_observed)); |
266 if (largest_observed > 0) { | 267 if (largest_observed > 0) { |
(...skipping 1494 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1761 ExpectAck(1); | 1762 ExpectAck(1); |
1762 EXPECT_CALL(*network_change_visitor_, | 1763 EXPECT_CALL(*network_change_visitor_, |
1763 OnPathMtuIncreased(kDefaultLength + 100)); | 1764 OnPathMtuIncreased(kDefaultLength + 100)); |
1764 QuicAckFrame ack_frame = InitAckFrame(1); | 1765 QuicAckFrame ack_frame = InitAckFrame(1); |
1765 manager_.OnIncomingAck(ack_frame, clock_.Now()); | 1766 manager_.OnIncomingAck(ack_frame, clock_.Now()); |
1766 } | 1767 } |
1767 | 1768 |
1768 } // namespace | 1769 } // namespace |
1769 } // namespace test | 1770 } // namespace test |
1770 } // namespace net | 1771 } // namespace net |
OLD | NEW |