| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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_connection.h" | 5 #include "net/quic/quic_connection.h" |
| 6 | 6 |
| 7 #include "base/basictypes.h" | 7 #include "base/basictypes.h" |
| 8 #include "base/bind.h" | 8 #include "base/bind.h" |
| 9 #include "base/stl_util.h" | 9 #include "base/stl_util.h" |
| 10 #include "net/base/net_errors.h" | 10 #include "net/base/net_errors.h" |
| (...skipping 639 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 650 | 650 |
| 651 QuicVersion version() { | 651 QuicVersion version() { |
| 652 return GetParam(); | 652 return GetParam(); |
| 653 } | 653 } |
| 654 | 654 |
| 655 QuicAckFrame* outgoing_ack() { | 655 QuicAckFrame* outgoing_ack() { |
| 656 outgoing_ack_.reset(QuicConnectionPeer::CreateAckFrame(&connection_)); | 656 outgoing_ack_.reset(QuicConnectionPeer::CreateAckFrame(&connection_)); |
| 657 return outgoing_ack_.get(); | 657 return outgoing_ack_.get(); |
| 658 } | 658 } |
| 659 | 659 |
| 660 QuicStopWaitingFrame* stop_waiting() { |
| 661 stop_waiting_.reset( |
| 662 QuicConnectionPeer::CreateStopWaitingFrame(&connection_)); |
| 663 return stop_waiting_.get(); |
| 664 } |
| 665 |
| 660 QuicPacketSequenceNumber least_unacked() { | 666 QuicPacketSequenceNumber least_unacked() { |
| 661 if (version() <= QUIC_VERSION_15) { | |
| 662 if (writer_->ack_frames().empty()) { | |
| 663 return 0; | |
| 664 } | |
| 665 return writer_->ack_frames()[0].sent_info.least_unacked; | |
| 666 } | |
| 667 if (writer_->stop_waiting_frames().empty()) { | 667 if (writer_->stop_waiting_frames().empty()) { |
| 668 return 0; | 668 return 0; |
| 669 } | 669 } |
| 670 return writer_->stop_waiting_frames()[0].least_unacked; | 670 return writer_->stop_waiting_frames()[0].least_unacked; |
| 671 } | 671 } |
| 672 | 672 |
| 673 void use_tagging_decrypter() { | 673 void use_tagging_decrypter() { |
| 674 writer_->use_tagging_decrypter(); | 674 writer_->use_tagging_decrypter(); |
| 675 } | 675 } |
| 676 | 676 |
| (...skipping 205 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 882 | 882 |
| 883 QuicTime::Delta DefaultRetransmissionTime() { | 883 QuicTime::Delta DefaultRetransmissionTime() { |
| 884 return QuicTime::Delta::FromMilliseconds(kDefaultRetransmissionTimeMs); | 884 return QuicTime::Delta::FromMilliseconds(kDefaultRetransmissionTimeMs); |
| 885 } | 885 } |
| 886 | 886 |
| 887 QuicTime::Delta DefaultDelayedAckTime() { | 887 QuicTime::Delta DefaultDelayedAckTime() { |
| 888 return QuicTime::Delta::FromMilliseconds(kMinRetransmissionTimeMs/2); | 888 return QuicTime::Delta::FromMilliseconds(kMinRetransmissionTimeMs/2); |
| 889 } | 889 } |
| 890 | 890 |
| 891 // Initialize a frame acknowledging all packets up to largest_observed. | 891 // Initialize a frame acknowledging all packets up to largest_observed. |
| 892 const QuicAckFrame InitAckFrame(QuicPacketSequenceNumber largest_observed, | 892 const QuicAckFrame InitAckFrame(QuicPacketSequenceNumber largest_observed) { |
| 893 QuicPacketSequenceNumber least_unacked) { | 893 QuicAckFrame frame(MakeAckFrame(largest_observed)); |
| 894 QuicAckFrame frame(MakeAckFrame(largest_observed, least_unacked)); | |
| 895 if (largest_observed > 0) { | 894 if (largest_observed > 0) { |
| 896 frame.received_info.entropy_hash = | 895 frame.received_info.entropy_hash = |
| 897 QuicConnectionPeer::GetSentEntropyHash(&connection_, largest_observed); | 896 QuicConnectionPeer::GetSentEntropyHash(&connection_, largest_observed); |
| 898 } | 897 } |
| 899 return frame; | 898 return frame; |
| 900 } | 899 } |
| 901 | 900 |
| 902 const QuicStopWaitingFrame InitStopWaitingFrame( | 901 const QuicStopWaitingFrame InitStopWaitingFrame( |
| 903 QuicPacketSequenceNumber least_unacked) { | 902 QuicPacketSequenceNumber least_unacked) { |
| 904 QuicStopWaitingFrame frame; | 903 QuicStopWaitingFrame frame; |
| (...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 968 MockRandom random_generator_; | 967 MockRandom random_generator_; |
| 969 scoped_ptr<TestConnectionHelper> helper_; | 968 scoped_ptr<TestConnectionHelper> helper_; |
| 970 scoped_ptr<TestPacketWriter> writer_; | 969 scoped_ptr<TestPacketWriter> writer_; |
| 971 TestConnection connection_; | 970 TestConnection connection_; |
| 972 StrictMock<MockConnectionVisitor> visitor_; | 971 StrictMock<MockConnectionVisitor> visitor_; |
| 973 | 972 |
| 974 QuicPacketHeader header_; | 973 QuicPacketHeader header_; |
| 975 QuicStreamFrame frame1_; | 974 QuicStreamFrame frame1_; |
| 976 QuicStreamFrame frame2_; | 975 QuicStreamFrame frame2_; |
| 977 scoped_ptr<QuicAckFrame> outgoing_ack_; | 976 scoped_ptr<QuicAckFrame> outgoing_ack_; |
| 977 scoped_ptr<QuicStopWaitingFrame> stop_waiting_; |
| 978 QuicSequenceNumberLength sequence_number_length_; | 978 QuicSequenceNumberLength sequence_number_length_; |
| 979 QuicConnectionIdLength connection_id_length_; | 979 QuicConnectionIdLength connection_id_length_; |
| 980 | 980 |
| 981 private: | 981 private: |
| 982 DISALLOW_COPY_AND_ASSIGN(QuicConnectionTest); | 982 DISALLOW_COPY_AND_ASSIGN(QuicConnectionTest); |
| 983 }; | 983 }; |
| 984 | 984 |
| 985 // Run all end to end tests with all supported versions. | 985 // Run all end to end tests with all supported versions. |
| 986 INSTANTIATE_TEST_CASE_P(SupportedVersion, | 986 INSTANTIATE_TEST_CASE_P(SupportedVersion, |
| 987 QuicConnectionTest, | 987 QuicConnectionTest, |
| (...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1053 ProcessPacket(5); | 1053 ProcessPacket(5); |
| 1054 EXPECT_EQ(5u, outgoing_ack()->received_info.largest_observed); | 1054 EXPECT_EQ(5u, outgoing_ack()->received_info.largest_observed); |
| 1055 EXPECT_TRUE(IsMissing(1)); | 1055 EXPECT_TRUE(IsMissing(1)); |
| 1056 EXPECT_TRUE(IsMissing(4)); | 1056 EXPECT_TRUE(IsMissing(4)); |
| 1057 | 1057 |
| 1058 // Pretend at this point the client has gotten acks for 2 and 3 and 1 is a | 1058 // Pretend at this point the client has gotten acks for 2 and 3 and 1 is a |
| 1059 // packet the peer will not retransmit. It indicates this by sending 'least | 1059 // packet the peer will not retransmit. It indicates this by sending 'least |
| 1060 // awaiting' is 4. The connection should then realize 1 will not be | 1060 // awaiting' is 4. The connection should then realize 1 will not be |
| 1061 // retransmitted, and will remove it from the missing list. | 1061 // retransmitted, and will remove it from the missing list. |
| 1062 peer_creator_.set_sequence_number(5); | 1062 peer_creator_.set_sequence_number(5); |
| 1063 QuicAckFrame frame = InitAckFrame(1, 4); | 1063 QuicAckFrame frame = InitAckFrame(1); |
| 1064 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(_, _, _, _)); | 1064 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(_, _, _, _)); |
| 1065 ProcessAckPacket(&frame); | 1065 ProcessAckPacket(&frame); |
| 1066 | 1066 |
| 1067 // Force an ack to be sent. | 1067 // Force an ack to be sent. |
| 1068 SendAckPacketToPeer(); | 1068 SendAckPacketToPeer(); |
| 1069 EXPECT_TRUE(IsMissing(4)); | 1069 EXPECT_TRUE(IsMissing(4)); |
| 1070 } | 1070 } |
| 1071 | 1071 |
| 1072 TEST_P(QuicConnectionTest, RejectPacketTooFarOut) { | 1072 TEST_P(QuicConnectionTest, RejectPacketTooFarOut) { |
| 1073 EXPECT_CALL(visitor_, | 1073 EXPECT_CALL(visitor_, |
| (...skipping 21 matching lines...) Expand all Loading... |
| 1095 connection_close_frames[0].error_code); | 1095 connection_close_frames[0].error_code); |
| 1096 } | 1096 } |
| 1097 | 1097 |
| 1098 TEST_P(QuicConnectionTest, TruncatedAck) { | 1098 TEST_P(QuicConnectionTest, TruncatedAck) { |
| 1099 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1099 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1100 QuicPacketSequenceNumber num_packets = 256 * 2 + 1; | 1100 QuicPacketSequenceNumber num_packets = 256 * 2 + 1; |
| 1101 for (QuicPacketSequenceNumber i = 0; i < num_packets; ++i) { | 1101 for (QuicPacketSequenceNumber i = 0; i < num_packets; ++i) { |
| 1102 SendStreamDataToPeer(3, "foo", i * 3, !kFin, NULL); | 1102 SendStreamDataToPeer(3, "foo", i * 3, !kFin, NULL); |
| 1103 } | 1103 } |
| 1104 | 1104 |
| 1105 QuicAckFrame frame = InitAckFrame(num_packets, 1); | 1105 QuicAckFrame frame = InitAckFrame(num_packets); |
| 1106 SequenceNumberSet lost_packets; | 1106 SequenceNumberSet lost_packets; |
| 1107 // Create an ack with 256 nacks, none adjacent to one another. | 1107 // Create an ack with 256 nacks, none adjacent to one another. |
| 1108 for (QuicPacketSequenceNumber i = 1; i <= 256; ++i) { | 1108 for (QuicPacketSequenceNumber i = 1; i <= 256; ++i) { |
| 1109 NackPacket(i * 2, &frame); | 1109 NackPacket(i * 2, &frame); |
| 1110 if (i < 256) { // Last packet is nacked, but not lost. | 1110 if (i < 256) { // Last packet is nacked, but not lost. |
| 1111 lost_packets.insert(i * 2); | 1111 lost_packets.insert(i * 2); |
| 1112 } | 1112 } |
| 1113 } | 1113 } |
| 1114 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 1114 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 1115 .WillOnce(Return(lost_packets)); | 1115 .WillOnce(Return(lost_packets)); |
| (...skipping 30 matching lines...) Expand all Loading... |
| 1146 testing::Return(QuicTime::Delta::FromMicroseconds(1))); | 1146 testing::Return(QuicTime::Delta::FromMicroseconds(1))); |
| 1147 QuicConnectionPeer::SendAck(&connection_); | 1147 QuicConnectionPeer::SendAck(&connection_); |
| 1148 | 1148 |
| 1149 // Process an ack with a least unacked of the received ack. | 1149 // Process an ack with a least unacked of the received ack. |
| 1150 // This causes an ack to be sent when TimeUntilSend returns 0. | 1150 // This causes an ack to be sent when TimeUntilSend returns 0. |
| 1151 EXPECT_CALL(*send_algorithm_, | 1151 EXPECT_CALL(*send_algorithm_, |
| 1152 TimeUntilSend(_, _, _)).WillRepeatedly( | 1152 TimeUntilSend(_, _, _)).WillRepeatedly( |
| 1153 testing::Return(QuicTime::Delta::Zero())); | 1153 testing::Return(QuicTime::Delta::Zero())); |
| 1154 // Skip a packet and then record an ack. | 1154 // Skip a packet and then record an ack. |
| 1155 peer_creator_.set_sequence_number(2); | 1155 peer_creator_.set_sequence_number(2); |
| 1156 QuicAckFrame frame = InitAckFrame(0, 3); | 1156 QuicAckFrame frame = InitAckFrame(0); |
| 1157 ProcessAckPacket(&frame); | 1157 ProcessAckPacket(&frame); |
| 1158 } | 1158 } |
| 1159 | 1159 |
| 1160 TEST_P(QuicConnectionTest, OutOfOrderReceiptCausesAckSend) { | 1160 TEST_P(QuicConnectionTest, OutOfOrderReceiptCausesAckSend) { |
| 1161 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1161 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1162 | 1162 |
| 1163 ProcessPacket(3); | 1163 ProcessPacket(3); |
| 1164 // Should ack immediately since we have missing packets. | 1164 // Should ack immediately since we have missing packets. |
| 1165 EXPECT_EQ(1u, writer_->packets_write_attempts()); | 1165 EXPECT_EQ(1u, writer_->packets_write_attempts()); |
| 1166 | 1166 |
| (...skipping 12 matching lines...) Expand all Loading... |
| 1179 | 1179 |
| 1180 TEST_P(QuicConnectionTest, AckReceiptCausesAckSend) { | 1180 TEST_P(QuicConnectionTest, AckReceiptCausesAckSend) { |
| 1181 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1181 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1182 | 1182 |
| 1183 QuicPacketSequenceNumber original; | 1183 QuicPacketSequenceNumber original; |
| 1184 QuicByteCount packet_size; | 1184 QuicByteCount packet_size; |
| 1185 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) | 1185 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) |
| 1186 .WillOnce(DoAll(SaveArg<2>(&original), SaveArg<3>(&packet_size), | 1186 .WillOnce(DoAll(SaveArg<2>(&original), SaveArg<3>(&packet_size), |
| 1187 Return(true))); | 1187 Return(true))); |
| 1188 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); | 1188 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); |
| 1189 QuicAckFrame frame = InitAckFrame(original, 1); | 1189 QuicAckFrame frame = InitAckFrame(original); |
| 1190 NackPacket(original, &frame); | 1190 NackPacket(original, &frame); |
| 1191 // First nack triggers early retransmit. | 1191 // First nack triggers early retransmit. |
| 1192 SequenceNumberSet lost_packets; | 1192 SequenceNumberSet lost_packets; |
| 1193 lost_packets.insert(1); | 1193 lost_packets.insert(1); |
| 1194 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 1194 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 1195 .WillOnce(Return(lost_packets)); | 1195 .WillOnce(Return(lost_packets)); |
| 1196 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1196 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 1197 QuicPacketSequenceNumber retransmission; | 1197 QuicPacketSequenceNumber retransmission; |
| 1198 EXPECT_CALL(*send_algorithm_, | 1198 EXPECT_CALL(*send_algorithm_, |
| 1199 OnPacketSent(_, _, _, packet_size - kQuicVersionSize, _)) | 1199 OnPacketSent(_, _, _, packet_size - kQuicVersionSize, _)) |
| 1200 .WillOnce(DoAll(SaveArg<2>(&retransmission), Return(true))); | 1200 .WillOnce(DoAll(SaveArg<2>(&retransmission), Return(true))); |
| 1201 | 1201 |
| 1202 ProcessAckPacket(&frame); | 1202 ProcessAckPacket(&frame); |
| 1203 | 1203 |
| 1204 QuicAckFrame frame2 = InitAckFrame(retransmission, 1); | 1204 QuicAckFrame frame2 = InitAckFrame(retransmission); |
| 1205 NackPacket(original, &frame2); | 1205 NackPacket(original, &frame2); |
| 1206 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1206 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 1207 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 1207 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 1208 .WillOnce(Return(SequenceNumberSet())); | 1208 .WillOnce(Return(SequenceNumberSet())); |
| 1209 ProcessAckPacket(&frame2); | 1209 ProcessAckPacket(&frame2); |
| 1210 | 1210 |
| 1211 // Now if the peer sends an ack which still reports the retransmitted packet | 1211 // Now if the peer sends an ack which still reports the retransmitted packet |
| 1212 // as missing, that will bundle an ack with data after two acks in a row | 1212 // as missing, that will bundle an ack with data after two acks in a row |
| 1213 // indicate the high water mark needs to be raised. | 1213 // indicate the high water mark needs to be raised. |
| 1214 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, | 1214 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, |
| 1215 HAS_RETRANSMITTABLE_DATA)); | 1215 HAS_RETRANSMITTABLE_DATA)); |
| 1216 connection_.SendStreamDataWithString(3, "foo", 3, !kFin, NULL); | 1216 connection_.SendStreamDataWithString(3, "foo", 3, !kFin, NULL); |
| 1217 // No ack sent. | 1217 // No ack sent. |
| 1218 EXPECT_EQ(1u, writer_->frame_count()); | 1218 EXPECT_EQ(1u, writer_->frame_count()); |
| 1219 EXPECT_EQ(1u, writer_->stream_frames().size()); | 1219 EXPECT_EQ(1u, writer_->stream_frames().size()); |
| 1220 | 1220 |
| 1221 // No more packet loss for the rest of the test. | 1221 // No more packet loss for the rest of the test. |
| 1222 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 1222 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 1223 .WillRepeatedly(Return(SequenceNumberSet())); | 1223 .WillRepeatedly(Return(SequenceNumberSet())); |
| 1224 ProcessAckPacket(&frame2); | 1224 ProcessAckPacket(&frame2); |
| 1225 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, | 1225 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, |
| 1226 HAS_RETRANSMITTABLE_DATA)); | 1226 HAS_RETRANSMITTABLE_DATA)); |
| 1227 connection_.SendStreamDataWithString(3, "foo", 3, !kFin, NULL); | 1227 connection_.SendStreamDataWithString(3, "foo", 3, !kFin, NULL); |
| 1228 // Ack bundled. | 1228 // Ack bundled. |
| 1229 if (version() > QUIC_VERSION_15) { | 1229 EXPECT_EQ(3u, writer_->frame_count()); |
| 1230 EXPECT_EQ(3u, writer_->frame_count()); | |
| 1231 } else { | |
| 1232 EXPECT_EQ(2u, writer_->frame_count()); | |
| 1233 } | |
| 1234 EXPECT_EQ(1u, writer_->stream_frames().size()); | 1230 EXPECT_EQ(1u, writer_->stream_frames().size()); |
| 1235 EXPECT_FALSE(writer_->ack_frames().empty()); | 1231 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 1236 | 1232 |
| 1237 // But an ack with no missing packets will not send an ack. | 1233 // But an ack with no missing packets will not send an ack. |
| 1238 AckPacket(original, &frame2); | 1234 AckPacket(original, &frame2); |
| 1239 ProcessAckPacket(&frame2); | 1235 ProcessAckPacket(&frame2); |
| 1240 ProcessAckPacket(&frame2); | 1236 ProcessAckPacket(&frame2); |
| 1241 } | 1237 } |
| 1242 | 1238 |
| 1243 TEST_P(QuicConnectionTest, LeastUnackedLower) { | 1239 TEST_P(QuicConnectionTest, LeastUnackedLower) { |
| 1244 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1240 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1245 | 1241 |
| 1246 SendStreamDataToPeer(1, "foo", 0, !kFin, NULL); | 1242 SendStreamDataToPeer(1, "foo", 0, !kFin, NULL); |
| 1247 SendStreamDataToPeer(1, "bar", 3, !kFin, NULL); | 1243 SendStreamDataToPeer(1, "bar", 3, !kFin, NULL); |
| 1248 SendStreamDataToPeer(1, "eep", 6, !kFin, NULL); | 1244 SendStreamDataToPeer(1, "eep", 6, !kFin, NULL); |
| 1249 | 1245 |
| 1250 // Start out saying the least unacked is 2. | 1246 // Start out saying the least unacked is 2. |
| 1251 peer_creator_.set_sequence_number(5); | 1247 peer_creator_.set_sequence_number(5); |
| 1252 if (version() > QUIC_VERSION_15) { | 1248 QuicStopWaitingFrame frame = InitStopWaitingFrame(2); |
| 1253 QuicStopWaitingFrame frame = InitStopWaitingFrame(2); | 1249 ProcessStopWaitingPacket(&frame); |
| 1254 ProcessStopWaitingPacket(&frame); | |
| 1255 } else { | |
| 1256 QuicAckFrame frame = InitAckFrame(0, 2); | |
| 1257 ProcessAckPacket(&frame); | |
| 1258 } | |
| 1259 | 1250 |
| 1260 // Change it to 1, but lower the sequence number to fake out-of-order packets. | 1251 // Change it to 1, but lower the sequence number to fake out-of-order packets. |
| 1261 // This should be fine. | 1252 // This should be fine. |
| 1262 peer_creator_.set_sequence_number(1); | 1253 peer_creator_.set_sequence_number(1); |
| 1263 // The scheduler will not process out of order acks, but all packet processing | 1254 // The scheduler will not process out of order acks, but all packet processing |
| 1264 // causes the connection to try to write. | 1255 // causes the connection to try to write. |
| 1265 EXPECT_CALL(visitor_, OnCanWrite()); | 1256 EXPECT_CALL(visitor_, OnCanWrite()); |
| 1266 if (version() > QUIC_VERSION_15) { | 1257 QuicStopWaitingFrame frame2 = InitStopWaitingFrame(1); |
| 1267 QuicStopWaitingFrame frame2 = InitStopWaitingFrame(1); | 1258 ProcessStopWaitingPacket(&frame2); |
| 1268 ProcessStopWaitingPacket(&frame2); | |
| 1269 } else { | |
| 1270 QuicAckFrame frame2 = InitAckFrame(0, 1); | |
| 1271 ProcessAckPacket(&frame2); | |
| 1272 } | |
| 1273 | 1259 |
| 1274 // Now claim it's one, but set the ordering so it was sent "after" the first | 1260 // Now claim it's one, but set the ordering so it was sent "after" the first |
| 1275 // one. This should cause a connection error. | 1261 // one. This should cause a connection error. |
| 1276 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); | 1262 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); |
| 1277 peer_creator_.set_sequence_number(7); | 1263 peer_creator_.set_sequence_number(7); |
| 1278 if (version() > QUIC_VERSION_15) { | 1264 EXPECT_CALL(visitor_, |
| 1279 EXPECT_CALL(visitor_, | 1265 OnConnectionClosed(QUIC_INVALID_STOP_WAITING_DATA, false)); |
| 1280 OnConnectionClosed(QUIC_INVALID_STOP_WAITING_DATA, false)); | 1266 QuicStopWaitingFrame frame3 = InitStopWaitingFrame(1); |
| 1281 QuicStopWaitingFrame frame2 = InitStopWaitingFrame(1); | 1267 ProcessStopWaitingPacket(&frame3); |
| 1282 ProcessStopWaitingPacket(&frame2); | |
| 1283 } else { | |
| 1284 EXPECT_CALL(visitor_, OnConnectionClosed(QUIC_INVALID_ACK_DATA, false)); | |
| 1285 QuicAckFrame frame2 = InitAckFrame(0, 1); | |
| 1286 ProcessAckPacket(&frame2); | |
| 1287 } | |
| 1288 } | 1268 } |
| 1289 | 1269 |
| 1290 TEST_P(QuicConnectionTest, LargestObservedLower) { | 1270 TEST_P(QuicConnectionTest, LargestObservedLower) { |
| 1291 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1271 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1292 | 1272 |
| 1293 SendStreamDataToPeer(1, "foo", 0, !kFin, NULL); | 1273 SendStreamDataToPeer(1, "foo", 0, !kFin, NULL); |
| 1294 SendStreamDataToPeer(1, "bar", 3, !kFin, NULL); | 1274 SendStreamDataToPeer(1, "bar", 3, !kFin, NULL); |
| 1295 SendStreamDataToPeer(1, "eep", 6, !kFin, NULL); | 1275 SendStreamDataToPeer(1, "eep", 6, !kFin, NULL); |
| 1296 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1276 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 1297 | 1277 |
| 1298 // Start out saying the largest observed is 2. | 1278 // Start out saying the largest observed is 2. |
| 1299 QuicAckFrame frame1 = InitAckFrame(1, 0); | 1279 QuicAckFrame frame1 = InitAckFrame(1); |
| 1300 QuicAckFrame frame2 = InitAckFrame(2, 0); | 1280 QuicAckFrame frame2 = InitAckFrame(2); |
| 1301 ProcessAckPacket(&frame2); | 1281 ProcessAckPacket(&frame2); |
| 1302 | 1282 |
| 1303 // Now change it to 1, and it should cause a connection error. | 1283 // Now change it to 1, and it should cause a connection error. |
| 1304 EXPECT_CALL(visitor_, OnConnectionClosed(QUIC_INVALID_ACK_DATA, false)); | 1284 EXPECT_CALL(visitor_, OnConnectionClosed(QUIC_INVALID_ACK_DATA, false)); |
| 1305 EXPECT_CALL(visitor_, OnCanWrite()).Times(0); | 1285 EXPECT_CALL(visitor_, OnCanWrite()).Times(0); |
| 1306 ProcessAckPacket(&frame1); | 1286 ProcessAckPacket(&frame1); |
| 1307 } | 1287 } |
| 1308 | 1288 |
| 1309 TEST_P(QuicConnectionTest, AckUnsentData) { | 1289 TEST_P(QuicConnectionTest, AckUnsentData) { |
| 1310 // Ack a packet which has not been sent. | 1290 // Ack a packet which has not been sent. |
| 1311 EXPECT_CALL(visitor_, OnConnectionClosed(QUIC_INVALID_ACK_DATA, false)); | 1291 EXPECT_CALL(visitor_, OnConnectionClosed(QUIC_INVALID_ACK_DATA, false)); |
| 1312 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1292 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1313 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); | 1293 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); |
| 1314 QuicAckFrame frame(MakeAckFrame(1, 0)); | 1294 QuicAckFrame frame(MakeAckFrame(1)); |
| 1315 EXPECT_CALL(visitor_, OnCanWrite()).Times(0); | 1295 EXPECT_CALL(visitor_, OnCanWrite()).Times(0); |
| 1316 ProcessAckPacket(&frame); | 1296 ProcessAckPacket(&frame); |
| 1317 } | 1297 } |
| 1318 | 1298 |
| 1319 TEST_P(QuicConnectionTest, AckAll) { | 1299 TEST_P(QuicConnectionTest, AckAll) { |
| 1320 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1300 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1321 ProcessPacket(1); | 1301 ProcessPacket(1); |
| 1322 | 1302 |
| 1323 peer_creator_.set_sequence_number(1); | 1303 peer_creator_.set_sequence_number(1); |
| 1324 QuicAckFrame frame1 = InitAckFrame(0, 1); | 1304 QuicAckFrame frame1 = InitAckFrame(0); |
| 1325 ProcessAckPacket(&frame1); | 1305 ProcessAckPacket(&frame1); |
| 1326 } | 1306 } |
| 1327 | 1307 |
| 1328 TEST_P(QuicConnectionTest, SendingDifferentSequenceNumberLengthsBandwidth) { | 1308 TEST_P(QuicConnectionTest, SendingDifferentSequenceNumberLengthsBandwidth) { |
| 1329 QuicPacketSequenceNumber last_packet; | 1309 QuicPacketSequenceNumber last_packet; |
| 1330 QuicPacketCreator* creator = | 1310 QuicPacketCreator* creator = |
| 1331 QuicConnectionPeer::GetPacketCreator(&connection_); | 1311 QuicConnectionPeer::GetPacketCreator(&connection_); |
| 1332 SendStreamDataToPeer(1, "foo", 0, !kFin, &last_packet); | 1312 SendStreamDataToPeer(1, "foo", 0, !kFin, &last_packet); |
| 1333 EXPECT_EQ(1u, last_packet); | 1313 EXPECT_EQ(1u, last_packet); |
| 1334 EXPECT_EQ(PACKET_1BYTE_SEQUENCE_NUMBER, | 1314 EXPECT_EQ(PACKET_1BYTE_SEQUENCE_NUMBER, |
| (...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1436 EXPECT_EQ(1u, least_unacked()); | 1416 EXPECT_EQ(1u, least_unacked()); |
| 1437 | 1417 |
| 1438 SendStreamDataToPeer(1, "bar", 3, !kFin, &last_packet); // Packet 4 | 1418 SendStreamDataToPeer(1, "bar", 3, !kFin, &last_packet); // Packet 4 |
| 1439 EXPECT_EQ(4u, last_packet); | 1419 EXPECT_EQ(4u, last_packet); |
| 1440 SendAckPacketToPeer(); // Packet 5 | 1420 SendAckPacketToPeer(); // Packet 5 |
| 1441 EXPECT_EQ(1u, least_unacked()); | 1421 EXPECT_EQ(1u, least_unacked()); |
| 1442 | 1422 |
| 1443 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1423 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 1444 | 1424 |
| 1445 // Peer acks up to packet 3. | 1425 // Peer acks up to packet 3. |
| 1446 QuicAckFrame frame = InitAckFrame(3, 0); | 1426 QuicAckFrame frame = InitAckFrame(3); |
| 1447 ProcessAckPacket(&frame); | 1427 ProcessAckPacket(&frame); |
| 1448 SendAckPacketToPeer(); // Packet 6 | 1428 SendAckPacketToPeer(); // Packet 6 |
| 1449 | 1429 |
| 1450 // As soon as we've acked one, we skip ack packets 2 and 3 and note lack of | 1430 // As soon as we've acked one, we skip ack packets 2 and 3 and note lack of |
| 1451 // ack for 4. | 1431 // ack for 4. |
| 1452 EXPECT_EQ(4u, least_unacked()); | 1432 EXPECT_EQ(4u, least_unacked()); |
| 1453 | 1433 |
| 1454 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1434 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 1455 | 1435 |
| 1456 // Peer acks up to packet 4, the last packet. | 1436 // Peer acks up to packet 4, the last packet. |
| 1457 QuicAckFrame frame2 = InitAckFrame(6, 0); | 1437 QuicAckFrame frame2 = InitAckFrame(6); |
| 1458 ProcessAckPacket(&frame2); // Acks don't instigate acks. | 1438 ProcessAckPacket(&frame2); // Acks don't instigate acks. |
| 1459 | 1439 |
| 1460 // Verify that we did not send an ack. | 1440 // Verify that we did not send an ack. |
| 1461 EXPECT_EQ(6u, writer_->header().packet_sequence_number); | 1441 EXPECT_EQ(6u, writer_->header().packet_sequence_number); |
| 1462 | 1442 |
| 1463 // So the last ack has not changed. | 1443 // So the last ack has not changed. |
| 1464 EXPECT_EQ(4u, least_unacked()); | 1444 EXPECT_EQ(4u, least_unacked()); |
| 1465 | 1445 |
| 1466 // If we force an ack, we shouldn't change our retransmit state. | 1446 // If we force an ack, we shouldn't change our retransmit state. |
| 1467 SendAckPacketToPeer(); // Packet 7 | 1447 SendAckPacketToPeer(); // Packet 7 |
| (...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1544 EXPECT_TRUE(QuicConnectionPeer::GetPacketCreator( | 1524 EXPECT_TRUE(QuicConnectionPeer::GetPacketCreator( |
| 1545 &connection_)->IsFecEnabled()); | 1525 &connection_)->IsFecEnabled()); |
| 1546 | 1526 |
| 1547 // 1 Data and 1 FEC packet. | 1527 // 1 Data and 1 FEC packet. |
| 1548 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(6); | 1528 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(6); |
| 1549 connection_.SendStreamDataWithStringWithFec(3, "foo", 0, !kFin, NULL); | 1529 connection_.SendStreamDataWithStringWithFec(3, "foo", 0, !kFin, NULL); |
| 1550 // Send some more data afterwards to ensure early retransmit doesn't trigger. | 1530 // Send some more data afterwards to ensure early retransmit doesn't trigger. |
| 1551 connection_.SendStreamDataWithStringWithFec(3, "foo", 3, !kFin, NULL); | 1531 connection_.SendStreamDataWithStringWithFec(3, "foo", 3, !kFin, NULL); |
| 1552 connection_.SendStreamDataWithStringWithFec(3, "foo", 6, !kFin, NULL); | 1532 connection_.SendStreamDataWithStringWithFec(3, "foo", 6, !kFin, NULL); |
| 1553 | 1533 |
| 1554 QuicAckFrame ack_fec = InitAckFrame(2, 1); | 1534 QuicAckFrame ack_fec = InitAckFrame(2); |
| 1555 // Data packet missing. | 1535 // Data packet missing. |
| 1556 // TODO(ianswett): Note that this is not a sensible ack, since if the FEC was | 1536 // TODO(ianswett): Note that this is not a sensible ack, since if the FEC was |
| 1557 // received, it would cause the covered packet to be acked as well. | 1537 // received, it would cause the covered packet to be acked as well. |
| 1558 NackPacket(1, &ack_fec); | 1538 NackPacket(1, &ack_fec); |
| 1559 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1539 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 1560 ProcessAckPacket(&ack_fec); | 1540 ProcessAckPacket(&ack_fec); |
| 1561 clock_.AdvanceTime(DefaultRetransmissionTime()); | 1541 clock_.AdvanceTime(DefaultRetransmissionTime()); |
| 1562 | 1542 |
| 1563 // Don't abandon the acked FEC packet, but it will abandon 2 the subsequent | 1543 // Don't abandon the acked FEC packet, but it will abandon 2 the subsequent |
| 1564 // FEC packets. | 1544 // FEC packets. |
| 1565 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(true)); | 1545 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(true)); |
| 1566 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(3); | 1546 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(3); |
| 1567 connection_.GetRetransmissionAlarm()->Fire(); | 1547 connection_.GetRetransmissionAlarm()->Fire(); |
| 1568 } | 1548 } |
| 1569 | 1549 |
| 1570 TEST_P(QuicConnectionTest, AbandonAllFEC) { | 1550 TEST_P(QuicConnectionTest, AbandonAllFEC) { |
| 1571 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1551 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1572 EXPECT_TRUE(QuicConnectionPeer::GetPacketCreator( | 1552 EXPECT_TRUE(QuicConnectionPeer::GetPacketCreator( |
| 1573 &connection_)->IsFecEnabled()); | 1553 &connection_)->IsFecEnabled()); |
| 1574 | 1554 |
| 1575 // 1 Data and 1 FEC packet. | 1555 // 1 Data and 1 FEC packet. |
| 1576 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(6); | 1556 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(6); |
| 1577 connection_.SendStreamDataWithStringWithFec(3, "foo", 0, !kFin, NULL); | 1557 connection_.SendStreamDataWithStringWithFec(3, "foo", 0, !kFin, NULL); |
| 1578 // Send some more data afterwards to ensure early retransmit doesn't trigger. | 1558 // Send some more data afterwards to ensure early retransmit doesn't trigger. |
| 1579 connection_.SendStreamDataWithStringWithFec(3, "foo", 3, !kFin, NULL); | 1559 connection_.SendStreamDataWithStringWithFec(3, "foo", 3, !kFin, NULL); |
| 1580 // Advance the time so not all the FEC packets are abandoned. | 1560 // Advance the time so not all the FEC packets are abandoned. |
| 1581 clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(1)); | 1561 clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(1)); |
| 1582 connection_.SendStreamDataWithStringWithFec(3, "foo", 6, !kFin, NULL); | 1562 connection_.SendStreamDataWithStringWithFec(3, "foo", 6, !kFin, NULL); |
| 1583 | 1563 |
| 1584 QuicAckFrame ack_fec = InitAckFrame(5, 1); | 1564 QuicAckFrame ack_fec = InitAckFrame(5); |
| 1585 // Ack all data packets, but no fec packets. | 1565 // Ack all data packets, but no fec packets. |
| 1586 NackPacket(2, &ack_fec); | 1566 NackPacket(2, &ack_fec); |
| 1587 NackPacket(4, &ack_fec); | 1567 NackPacket(4, &ack_fec); |
| 1588 | 1568 |
| 1589 // Lose the first FEC packet and ack the three data packets. | 1569 // Lose the first FEC packet and ack the three data packets. |
| 1590 SequenceNumberSet lost_packets; | 1570 SequenceNumberSet lost_packets; |
| 1591 lost_packets.insert(2); | 1571 lost_packets.insert(2); |
| 1592 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 1572 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 1593 .WillOnce(Return(lost_packets)); | 1573 .WillOnce(Return(lost_packets)); |
| 1594 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1574 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| (...skipping 22 matching lines...) Expand all Loading... |
| 1617 &TestConnection::SendStreamData5)))); | 1597 &TestConnection::SendStreamData5)))); |
| 1618 | 1598 |
| 1619 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(1); | 1599 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(1); |
| 1620 CongestionUnblockWrites(); | 1600 CongestionUnblockWrites(); |
| 1621 connection_.GetSendAlarm()->Fire(); | 1601 connection_.GetSendAlarm()->Fire(); |
| 1622 EXPECT_EQ(0u, connection_.NumQueuedPackets()); | 1602 EXPECT_EQ(0u, connection_.NumQueuedPackets()); |
| 1623 EXPECT_FALSE(connection_.HasQueuedData()); | 1603 EXPECT_FALSE(connection_.HasQueuedData()); |
| 1624 | 1604 |
| 1625 // Parse the last packet and ensure it's an ack and two stream frames from | 1605 // Parse the last packet and ensure it's an ack and two stream frames from |
| 1626 // two different streams. | 1606 // two different streams. |
| 1627 if (version() > QUIC_VERSION_15) { | 1607 EXPECT_EQ(4u, writer_->frame_count()); |
| 1628 EXPECT_EQ(4u, writer_->frame_count()); | 1608 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); |
| 1629 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); | |
| 1630 } else { | |
| 1631 EXPECT_EQ(3u, writer_->frame_count()); | |
| 1632 } | |
| 1633 EXPECT_FALSE(writer_->ack_frames().empty()); | 1609 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 1634 ASSERT_EQ(2u, writer_->stream_frames().size()); | 1610 ASSERT_EQ(2u, writer_->stream_frames().size()); |
| 1635 EXPECT_EQ(kClientDataStreamId1, writer_->stream_frames()[0].stream_id); | 1611 EXPECT_EQ(kClientDataStreamId1, writer_->stream_frames()[0].stream_id); |
| 1636 EXPECT_EQ(kClientDataStreamId2, writer_->stream_frames()[1].stream_id); | 1612 EXPECT_EQ(kClientDataStreamId2, writer_->stream_frames()[1].stream_id); |
| 1637 } | 1613 } |
| 1638 | 1614 |
| 1639 TEST_P(QuicConnectionTest, FramePackingNonCryptoThenCrypto) { | 1615 TEST_P(QuicConnectionTest, FramePackingNonCryptoThenCrypto) { |
| 1640 CongestionBlockWrites(); | 1616 CongestionBlockWrites(); |
| 1641 | 1617 |
| 1642 // Send an ack and two stream frames (one non-crypto, then one crypto) in 2 | 1618 // Send an ack and two stream frames (one non-crypto, then one crypto) in 2 |
| (...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1719 EXPECT_CALL(visitor_, OnCanWrite()).WillOnce(DoAll( | 1695 EXPECT_CALL(visitor_, OnCanWrite()).WillOnce(DoAll( |
| 1720 IgnoreResult(InvokeWithoutArgs(&connection_, | 1696 IgnoreResult(InvokeWithoutArgs(&connection_, |
| 1721 &TestConnection::SendStreamData3)), | 1697 &TestConnection::SendStreamData3)), |
| 1722 IgnoreResult(InvokeWithoutArgs(&connection_, | 1698 IgnoreResult(InvokeWithoutArgs(&connection_, |
| 1723 &TestConnection::SendStreamData5)))); | 1699 &TestConnection::SendStreamData5)))); |
| 1724 | 1700 |
| 1725 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(1); | 1701 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(1); |
| 1726 | 1702 |
| 1727 // Process an ack to cause the visitor's OnCanWrite to be invoked. | 1703 // Process an ack to cause the visitor's OnCanWrite to be invoked. |
| 1728 peer_creator_.set_sequence_number(2); | 1704 peer_creator_.set_sequence_number(2); |
| 1729 QuicAckFrame ack_one = InitAckFrame(0, 0); | 1705 QuicAckFrame ack_one = InitAckFrame(0); |
| 1730 ProcessAckPacket(&ack_one); | 1706 ProcessAckPacket(&ack_one); |
| 1731 | 1707 |
| 1732 EXPECT_EQ(0u, connection_.NumQueuedPackets()); | 1708 EXPECT_EQ(0u, connection_.NumQueuedPackets()); |
| 1733 EXPECT_FALSE(connection_.HasQueuedData()); | 1709 EXPECT_FALSE(connection_.HasQueuedData()); |
| 1734 | 1710 |
| 1735 // Parse the last packet and ensure it's an ack and two stream frames from | 1711 // Parse the last packet and ensure it's an ack and two stream frames from |
| 1736 // two different streams. | 1712 // two different streams. |
| 1737 if (version() > QUIC_VERSION_15) { | 1713 EXPECT_EQ(4u, writer_->frame_count()); |
| 1738 EXPECT_EQ(4u, writer_->frame_count()); | 1714 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); |
| 1739 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); | |
| 1740 } else { | |
| 1741 EXPECT_EQ(3u, writer_->frame_count()); | |
| 1742 } | |
| 1743 EXPECT_FALSE(writer_->ack_frames().empty()); | 1715 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 1744 ASSERT_EQ(2u, writer_->stream_frames().size()); | 1716 ASSERT_EQ(2u, writer_->stream_frames().size()); |
| 1745 EXPECT_EQ(kClientDataStreamId1, writer_->stream_frames()[0].stream_id); | 1717 EXPECT_EQ(kClientDataStreamId1, writer_->stream_frames()[0].stream_id); |
| 1746 EXPECT_EQ(kClientDataStreamId2, writer_->stream_frames()[1].stream_id); | 1718 EXPECT_EQ(kClientDataStreamId2, writer_->stream_frames()[1].stream_id); |
| 1747 } | 1719 } |
| 1748 | 1720 |
| 1749 TEST_P(QuicConnectionTest, FramePackingSendv) { | 1721 TEST_P(QuicConnectionTest, FramePackingSendv) { |
| 1750 // Send data in 1 packet by writing multiple blocks in a single iovector | 1722 // Send data in 1 packet by writing multiple blocks in a single iovector |
| 1751 // using writev. | 1723 // using writev. |
| 1752 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); | 1724 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); |
| (...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1839 QuicByteCount second_packet_size; | 1811 QuicByteCount second_packet_size; |
| 1840 SendStreamDataToPeer(3, "foo", 0, !kFin, &last_packet); // Packet 1 | 1812 SendStreamDataToPeer(3, "foo", 0, !kFin, &last_packet); // Packet 1 |
| 1841 second_packet_size = | 1813 second_packet_size = |
| 1842 SendStreamDataToPeer(3, "foos", 3, !kFin, &last_packet); // Packet 2 | 1814 SendStreamDataToPeer(3, "foos", 3, !kFin, &last_packet); // Packet 2 |
| 1843 SendStreamDataToPeer(3, "fooos", 7, !kFin, &last_packet); // Packet 3 | 1815 SendStreamDataToPeer(3, "fooos", 7, !kFin, &last_packet); // Packet 3 |
| 1844 | 1816 |
| 1845 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1817 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1846 | 1818 |
| 1847 // Don't lose a packet on an ack, and nothing is retransmitted. | 1819 // Don't lose a packet on an ack, and nothing is retransmitted. |
| 1848 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1820 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 1849 QuicAckFrame ack_one = InitAckFrame(1, 0); | 1821 QuicAckFrame ack_one = InitAckFrame(1); |
| 1850 ProcessAckPacket(&ack_one); | 1822 ProcessAckPacket(&ack_one); |
| 1851 | 1823 |
| 1852 // Lose a packet and ensure it triggers retransmission. | 1824 // Lose a packet and ensure it triggers retransmission. |
| 1853 QuicAckFrame nack_two = InitAckFrame(3, 0); | 1825 QuicAckFrame nack_two = InitAckFrame(3); |
| 1854 NackPacket(2, &nack_two); | 1826 NackPacket(2, &nack_two); |
| 1855 SequenceNumberSet lost_packets; | 1827 SequenceNumberSet lost_packets; |
| 1856 lost_packets.insert(2); | 1828 lost_packets.insert(2); |
| 1857 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 1829 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 1858 .WillOnce(Return(lost_packets)); | 1830 .WillOnce(Return(lost_packets)); |
| 1859 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1831 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 1860 EXPECT_CALL(*send_algorithm_, | 1832 EXPECT_CALL(*send_algorithm_, |
| 1861 OnPacketSent(_, _, _, second_packet_size - kQuicVersionSize, _)). | 1833 OnPacketSent(_, _, _, second_packet_size - kQuicVersionSize, _)). |
| 1862 Times(1); | 1834 Times(1); |
| 1863 ProcessAckPacket(&nack_two); | 1835 ProcessAckPacket(&nack_two); |
| 1864 } | 1836 } |
| 1865 | 1837 |
| 1866 TEST_P(QuicConnectionTest, DiscardRetransmit) { | 1838 TEST_P(QuicConnectionTest, DiscardRetransmit) { |
| 1867 QuicPacketSequenceNumber last_packet; | 1839 QuicPacketSequenceNumber last_packet; |
| 1868 SendStreamDataToPeer(1, "foo", 0, !kFin, &last_packet); // Packet 1 | 1840 SendStreamDataToPeer(1, "foo", 0, !kFin, &last_packet); // Packet 1 |
| 1869 SendStreamDataToPeer(1, "foos", 3, !kFin, &last_packet); // Packet 2 | 1841 SendStreamDataToPeer(1, "foos", 3, !kFin, &last_packet); // Packet 2 |
| 1870 SendStreamDataToPeer(1, "fooos", 7, !kFin, &last_packet); // Packet 3 | 1842 SendStreamDataToPeer(1, "fooos", 7, !kFin, &last_packet); // Packet 3 |
| 1871 | 1843 |
| 1872 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1844 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1873 | 1845 |
| 1874 // Instigate a loss with an ack. | 1846 // Instigate a loss with an ack. |
| 1875 QuicAckFrame nack_two = InitAckFrame(3, 0); | 1847 QuicAckFrame nack_two = InitAckFrame(3); |
| 1876 NackPacket(2, &nack_two); | 1848 NackPacket(2, &nack_two); |
| 1877 // The first nack should trigger a fast retransmission, but we'll be | 1849 // The first nack should trigger a fast retransmission, but we'll be |
| 1878 // write blocked, so the packet will be queued. | 1850 // write blocked, so the packet will be queued. |
| 1879 BlockOnNextWrite(); | 1851 BlockOnNextWrite(); |
| 1880 SequenceNumberSet lost_packets; | 1852 SequenceNumberSet lost_packets; |
| 1881 lost_packets.insert(2); | 1853 lost_packets.insert(2); |
| 1882 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 1854 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 1883 .WillOnce(Return(lost_packets)); | 1855 .WillOnce(Return(lost_packets)); |
| 1884 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1856 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 1885 ProcessAckPacket(&nack_two); | 1857 ProcessAckPacket(&nack_two); |
| 1886 EXPECT_EQ(1u, connection_.NumQueuedPackets()); | 1858 EXPECT_EQ(1u, connection_.NumQueuedPackets()); |
| 1887 | 1859 |
| 1888 // Now, ack the previous transmission. | 1860 // Now, ack the previous transmission. |
| 1889 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 1861 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 1890 .WillOnce(Return(SequenceNumberSet())); | 1862 .WillOnce(Return(SequenceNumberSet())); |
| 1891 QuicAckFrame ack_all = InitAckFrame(3, 0); | 1863 QuicAckFrame ack_all = InitAckFrame(3); |
| 1892 ProcessAckPacket(&ack_all); | 1864 ProcessAckPacket(&ack_all); |
| 1893 | 1865 |
| 1894 // Unblock the socket and attempt to send the queued packets. However, | 1866 // Unblock the socket and attempt to send the queued packets. However, |
| 1895 // since the previous transmission has been acked, we will not | 1867 // since the previous transmission has been acked, we will not |
| 1896 // send the retransmission. | 1868 // send the retransmission. |
| 1897 EXPECT_CALL(*send_algorithm_, | 1869 EXPECT_CALL(*send_algorithm_, |
| 1898 OnPacketSent(_, _, _, _, _)).Times(0); | 1870 OnPacketSent(_, _, _, _, _)).Times(0); |
| 1899 | 1871 |
| 1900 writer_->SetWritable(); | 1872 writer_->SetWritable(); |
| 1901 connection_.OnCanWrite(); | 1873 connection_.OnCanWrite(); |
| 1902 | 1874 |
| 1903 EXPECT_EQ(0u, connection_.NumQueuedPackets()); | 1875 EXPECT_EQ(0u, connection_.NumQueuedPackets()); |
| 1904 } | 1876 } |
| 1905 | 1877 |
| 1906 TEST_P(QuicConnectionTest, RetransmitNackedLargestObserved) { | 1878 TEST_P(QuicConnectionTest, RetransmitNackedLargestObserved) { |
| 1907 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1879 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1908 QuicPacketSequenceNumber largest_observed; | 1880 QuicPacketSequenceNumber largest_observed; |
| 1909 QuicByteCount packet_size; | 1881 QuicByteCount packet_size; |
| 1910 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) | 1882 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) |
| 1911 .WillOnce(DoAll(SaveArg<2>(&largest_observed), SaveArg<3>(&packet_size), | 1883 .WillOnce(DoAll(SaveArg<2>(&largest_observed), SaveArg<3>(&packet_size), |
| 1912 Return(true))); | 1884 Return(true))); |
| 1913 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); | 1885 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); |
| 1914 | 1886 |
| 1915 QuicAckFrame frame = InitAckFrame(1, largest_observed); | 1887 QuicAckFrame frame = InitAckFrame(1); |
| 1916 NackPacket(largest_observed, &frame); | 1888 NackPacket(largest_observed, &frame); |
| 1917 // The first nack should retransmit the largest observed packet. | 1889 // The first nack should retransmit the largest observed packet. |
| 1918 SequenceNumberSet lost_packets; | 1890 SequenceNumberSet lost_packets; |
| 1919 lost_packets.insert(1); | 1891 lost_packets.insert(1); |
| 1920 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 1892 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 1921 .WillOnce(Return(lost_packets)); | 1893 .WillOnce(Return(lost_packets)); |
| 1922 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1894 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 1923 EXPECT_CALL(*send_algorithm_, | 1895 EXPECT_CALL(*send_algorithm_, |
| 1924 OnPacketSent(_, _, _, packet_size - kQuicVersionSize, _)); | 1896 OnPacketSent(_, _, _, packet_size - kQuicVersionSize, _)); |
| 1925 ProcessAckPacket(&frame); | 1897 ProcessAckPacket(&frame); |
| (...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1963 | 1935 |
| 1964 TEST_P(QuicConnectionTest, WriteBlockedAckedThenSent) { | 1936 TEST_P(QuicConnectionTest, WriteBlockedAckedThenSent) { |
| 1965 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1937 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1966 BlockOnNextWrite(); | 1938 BlockOnNextWrite(); |
| 1967 writer_->set_is_write_blocked_data_buffered(true); | 1939 writer_->set_is_write_blocked_data_buffered(true); |
| 1968 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); | 1940 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); |
| 1969 EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); | 1941 EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); |
| 1970 | 1942 |
| 1971 // Ack the sent packet before the callback returns, which happens in | 1943 // Ack the sent packet before the callback returns, which happens in |
| 1972 // rare circumstances with write blocked sockets. | 1944 // rare circumstances with write blocked sockets. |
| 1973 QuicAckFrame ack = InitAckFrame(1, 0); | 1945 QuicAckFrame ack = InitAckFrame(1); |
| 1974 ProcessAckPacket(&ack); | 1946 ProcessAckPacket(&ack); |
| 1975 | 1947 |
| 1976 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(0); | 1948 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(0); |
| 1977 connection_.OnPacketSent(WriteResult(WRITE_STATUS_OK, 0)); | 1949 connection_.OnPacketSent(WriteResult(WRITE_STATUS_OK, 0)); |
| 1978 EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); | 1950 EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); |
| 1979 } | 1951 } |
| 1980 | 1952 |
| 1981 TEST_P(QuicConnectionTest, RetransmitWriteBlockedAckedOriginalThenSent) { | 1953 TEST_P(QuicConnectionTest, RetransmitWriteBlockedAckedOriginalThenSent) { |
| 1982 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1954 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 1983 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); | 1955 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); |
| 1984 EXPECT_TRUE(connection_.GetRetransmissionAlarm()->IsSet()); | 1956 EXPECT_TRUE(connection_.GetRetransmissionAlarm()->IsSet()); |
| 1985 | 1957 |
| 1986 BlockOnNextWrite(); | 1958 BlockOnNextWrite(); |
| 1987 writer_->set_is_write_blocked_data_buffered(true); | 1959 writer_->set_is_write_blocked_data_buffered(true); |
| 1988 // Simulate the retransmission alarm firing. | 1960 // Simulate the retransmission alarm firing. |
| 1989 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(_)); | 1961 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(_)); |
| 1990 clock_.AdvanceTime(DefaultRetransmissionTime()); | 1962 clock_.AdvanceTime(DefaultRetransmissionTime()); |
| 1991 connection_.GetRetransmissionAlarm()->Fire(); | 1963 connection_.GetRetransmissionAlarm()->Fire(); |
| 1992 | 1964 |
| 1993 // Ack the sent packet before the callback returns, which happens in | 1965 // Ack the sent packet before the callback returns, which happens in |
| 1994 // rare circumstances with write blocked sockets. | 1966 // rare circumstances with write blocked sockets. |
| 1995 QuicAckFrame ack = InitAckFrame(1, 0); | 1967 QuicAckFrame ack = InitAckFrame(1); |
| 1996 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 1968 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 1997 EXPECT_CALL(*send_algorithm_, RevertRetransmissionTimeout()); | 1969 EXPECT_CALL(*send_algorithm_, RevertRetransmissionTimeout()); |
| 1998 ProcessAckPacket(&ack); | 1970 ProcessAckPacket(&ack); |
| 1999 | 1971 |
| 2000 connection_.OnPacketSent(WriteResult(WRITE_STATUS_OK, 0)); | 1972 connection_.OnPacketSent(WriteResult(WRITE_STATUS_OK, 0)); |
| 2001 // There is now a pending packet, but with no retransmittable frames. | 1973 // There is now a pending packet, but with no retransmittable frames. |
| 2002 EXPECT_TRUE(connection_.GetRetransmissionAlarm()->IsSet()); | 1974 EXPECT_TRUE(connection_.GetRetransmissionAlarm()->IsSet()); |
| 2003 EXPECT_FALSE(connection_.sent_packet_manager().HasRetransmittableFrames(2)); | 1975 EXPECT_FALSE(connection_.sent_packet_manager().HasRetransmittableFrames(2)); |
| 2004 } | 1976 } |
| 2005 | 1977 |
| (...skipping 18 matching lines...) Expand all Loading... |
| 2024 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 1996 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 2025 int offset = 0; | 1997 int offset = 0; |
| 2026 // Send packets 1 to 15. | 1998 // Send packets 1 to 15. |
| 2027 for (int i = 0; i < 15; ++i) { | 1999 for (int i = 0; i < 15; ++i) { |
| 2028 SendStreamDataToPeer(1, "foo", offset, !kFin, NULL); | 2000 SendStreamDataToPeer(1, "foo", offset, !kFin, NULL); |
| 2029 offset += 3; | 2001 offset += 3; |
| 2030 } | 2002 } |
| 2031 | 2003 |
| 2032 // Ack 15, nack 1-14. | 2004 // Ack 15, nack 1-14. |
| 2033 SequenceNumberSet lost_packets; | 2005 SequenceNumberSet lost_packets; |
| 2034 QuicAckFrame nack = InitAckFrame(15, 0); | 2006 QuicAckFrame nack = InitAckFrame(15); |
| 2035 for (int i = 1; i < 15; ++i) { | 2007 for (int i = 1; i < 15; ++i) { |
| 2036 NackPacket(i, &nack); | 2008 NackPacket(i, &nack); |
| 2037 lost_packets.insert(i); | 2009 lost_packets.insert(i); |
| 2038 } | 2010 } |
| 2039 | 2011 |
| 2040 // 14 packets have been NACK'd and lost. In TCP cubic, PRR limits | 2012 // 14 packets have been NACK'd and lost. In TCP cubic, PRR limits |
| 2041 // the retransmission rate in the case of burst losses. | 2013 // the retransmission rate in the case of burst losses. |
| 2042 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 2014 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 2043 .WillOnce(Return(lost_packets)); | 2015 .WillOnce(Return(lost_packets)); |
| 2044 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 2016 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| (...skipping 11 matching lines...) Expand all Loading... |
| 2056 SendAckPacketToPeer(); // Packet 3 | 2028 SendAckPacketToPeer(); // Packet 3 |
| 2057 SendStreamDataToPeer(5, "foo", 0, !kFin, &last_packet); // Packet 4 | 2029 SendStreamDataToPeer(5, "foo", 0, !kFin, &last_packet); // Packet 4 |
| 2058 EXPECT_EQ(4u, last_packet); | 2030 EXPECT_EQ(4u, last_packet); |
| 2059 SendStreamDataToPeer(1, "foo", 3, !kFin, &last_packet); // Packet 5 | 2031 SendStreamDataToPeer(1, "foo", 3, !kFin, &last_packet); // Packet 5 |
| 2060 EXPECT_EQ(5u, last_packet); | 2032 EXPECT_EQ(5u, last_packet); |
| 2061 SendStreamDataToPeer(3, "foo", 3, !kFin, &last_packet); // Packet 6 | 2033 SendStreamDataToPeer(3, "foo", 3, !kFin, &last_packet); // Packet 6 |
| 2062 EXPECT_EQ(6u, last_packet); | 2034 EXPECT_EQ(6u, last_packet); |
| 2063 | 2035 |
| 2064 // Client will ack packets 1, 2, [!3], 4, 5. | 2036 // Client will ack packets 1, 2, [!3], 4, 5. |
| 2065 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 2037 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 2066 QuicAckFrame frame1 = InitAckFrame(5, 0); | 2038 QuicAckFrame frame1 = InitAckFrame(5); |
| 2067 NackPacket(3, &frame1); | 2039 NackPacket(3, &frame1); |
| 2068 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2040 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 2069 ProcessAckPacket(&frame1); | 2041 ProcessAckPacket(&frame1); |
| 2070 | 2042 |
| 2071 // Now the client implicitly acks 3, and explicitly acks 6. | 2043 // Now the client implicitly acks 3, and explicitly acks 6. |
| 2072 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 2044 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 2073 QuicAckFrame frame2 = InitAckFrame(6, 0); | 2045 QuicAckFrame frame2 = InitAckFrame(6); |
| 2074 ProcessAckPacket(&frame2); | 2046 ProcessAckPacket(&frame2); |
| 2075 } | 2047 } |
| 2076 | 2048 |
| 2077 TEST_P(QuicConnectionTest, DontLatchUnackedPacket) { | 2049 TEST_P(QuicConnectionTest, DontLatchUnackedPacket) { |
| 2078 SendStreamDataToPeer(1, "foo", 0, !kFin, NULL); // Packet 1; | 2050 SendStreamDataToPeer(1, "foo", 0, !kFin, NULL); // Packet 1; |
| 2079 // From now on, we send acks, so the send algorithm won't mark them pending. | 2051 // From now on, we send acks, so the send algorithm won't mark them pending. |
| 2080 ON_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) | 2052 ON_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) |
| 2081 .WillByDefault(Return(false)); | 2053 .WillByDefault(Return(false)); |
| 2082 SendAckPacketToPeer(); // Packet 2 | 2054 SendAckPacketToPeer(); // Packet 2 |
| 2083 | 2055 |
| 2084 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2056 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 2085 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 2057 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 2086 QuicAckFrame frame = InitAckFrame(1, 0); | 2058 QuicAckFrame frame = InitAckFrame(1); |
| 2087 ProcessAckPacket(&frame); | 2059 ProcessAckPacket(&frame); |
| 2088 | 2060 |
| 2089 // Verify that our internal state has least-unacked as 2, because we're still | 2061 // Verify that our internal state has least-unacked as 2, because we're still |
| 2090 // waiting for a potential ack for 2. | 2062 // waiting for a potential ack for 2. |
| 2091 EXPECT_EQ(2u, outgoing_ack()->sent_info.least_unacked); | 2063 |
| 2064 EXPECT_EQ(2u, stop_waiting()->least_unacked); |
| 2092 | 2065 |
| 2093 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 2066 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 2094 frame = InitAckFrame(2, 0); | 2067 frame = InitAckFrame(2); |
| 2095 ProcessAckPacket(&frame); | 2068 ProcessAckPacket(&frame); |
| 2096 EXPECT_EQ(3u, outgoing_ack()->sent_info.least_unacked); | 2069 EXPECT_EQ(3u, stop_waiting()->least_unacked); |
| 2097 | 2070 |
| 2098 // When we send an ack, we make sure our least-unacked makes sense. In this | 2071 // When we send an ack, we make sure our least-unacked makes sense. In this |
| 2099 // case since we're not waiting on an ack for 2 and all packets are acked, we | 2072 // case since we're not waiting on an ack for 2 and all packets are acked, we |
| 2100 // set it to 3. | 2073 // set it to 3. |
| 2101 SendAckPacketToPeer(); // Packet 3 | 2074 SendAckPacketToPeer(); // Packet 3 |
| 2102 // Least_unacked remains at 3 until another ack is received. | 2075 // Least_unacked remains at 3 until another ack is received. |
| 2103 EXPECT_EQ(3u, outgoing_ack()->sent_info.least_unacked); | 2076 EXPECT_EQ(3u, stop_waiting()->least_unacked); |
| 2104 // Check that the outgoing ack had its sequence number as least_unacked. | 2077 // Check that the outgoing ack had its sequence number as least_unacked. |
| 2105 EXPECT_EQ(3u, least_unacked()); | 2078 EXPECT_EQ(3u, least_unacked()); |
| 2106 | 2079 |
| 2107 // Ack the ack, which updates the rtt and raises the least unacked. | 2080 // Ack the ack, which updates the rtt and raises the least unacked. |
| 2108 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 2081 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 2109 frame = InitAckFrame(3, 0); | 2082 frame = InitAckFrame(3); |
| 2110 ProcessAckPacket(&frame); | 2083 ProcessAckPacket(&frame); |
| 2111 | 2084 |
| 2112 ON_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) | 2085 ON_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) |
| 2113 .WillByDefault(Return(true)); | 2086 .WillByDefault(Return(true)); |
| 2114 SendStreamDataToPeer(1, "bar", 3, false, NULL); // Packet 4 | 2087 SendStreamDataToPeer(1, "bar", 3, false, NULL); // Packet 4 |
| 2115 EXPECT_EQ(4u, outgoing_ack()->sent_info.least_unacked); | 2088 EXPECT_EQ(4u, stop_waiting()->least_unacked); |
| 2116 ON_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) | 2089 ON_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) |
| 2117 .WillByDefault(Return(false)); | 2090 .WillByDefault(Return(false)); |
| 2118 SendAckPacketToPeer(); // Packet 5 | 2091 SendAckPacketToPeer(); // Packet 5 |
| 2119 EXPECT_EQ(4u, least_unacked()); | 2092 EXPECT_EQ(4u, least_unacked()); |
| 2120 | 2093 |
| 2121 // Send two data packets at the end, and ensure if the last one is acked, | 2094 // Send two data packets at the end, and ensure if the last one is acked, |
| 2122 // the least unacked is raised above the ack packets. | 2095 // the least unacked is raised above the ack packets. |
| 2123 ON_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) | 2096 ON_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) |
| 2124 .WillByDefault(Return(true)); | 2097 .WillByDefault(Return(true)); |
| 2125 SendStreamDataToPeer(1, "bar", 6, false, NULL); // Packet 6 | 2098 SendStreamDataToPeer(1, "bar", 6, false, NULL); // Packet 6 |
| 2126 SendStreamDataToPeer(1, "bar", 9, false, NULL); // Packet 7 | 2099 SendStreamDataToPeer(1, "bar", 9, false, NULL); // Packet 7 |
| 2127 | 2100 |
| 2128 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 2101 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 2129 frame = InitAckFrame(7, 0); | 2102 frame = InitAckFrame(7); |
| 2130 NackPacket(5, &frame); | 2103 NackPacket(5, &frame); |
| 2131 NackPacket(6, &frame); | 2104 NackPacket(6, &frame); |
| 2132 ProcessAckPacket(&frame); | 2105 ProcessAckPacket(&frame); |
| 2133 | 2106 |
| 2134 EXPECT_EQ(6u, outgoing_ack()->sent_info.least_unacked); | 2107 EXPECT_EQ(6u, stop_waiting()->least_unacked); |
| 2135 } | 2108 } |
| 2136 | 2109 |
| 2137 TEST_P(QuicConnectionTest, ReviveMissingPacketAfterFecPacket) { | 2110 TEST_P(QuicConnectionTest, ReviveMissingPacketAfterFecPacket) { |
| 2138 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2111 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 2139 | 2112 |
| 2140 // Don't send missing packet 1. | 2113 // Don't send missing packet 1. |
| 2141 ProcessFecPacket(2, 1, true, !kEntropyFlag, NULL); | 2114 ProcessFecPacket(2, 1, true, !kEntropyFlag, NULL); |
| 2142 // Entropy flag should be false, so entropy should be 0. | 2115 // Entropy flag should be false, so entropy should be 0. |
| 2143 EXPECT_EQ(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 2)); | 2116 EXPECT_EQ(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 2)); |
| 2144 } | 2117 } |
| (...skipping 99 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2244 // Ensure entropy is not revived for the missing packet. | 2217 // Ensure entropy is not revived for the missing packet. |
| 2245 EXPECT_EQ(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 2)); | 2218 EXPECT_EQ(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 2)); |
| 2246 EXPECT_NE(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 3)); | 2219 EXPECT_NE(0u, QuicConnectionPeer::ReceivedEntropyHash(&connection_, 3)); |
| 2247 } | 2220 } |
| 2248 | 2221 |
| 2249 TEST_P(QuicConnectionTest, TLP) { | 2222 TEST_P(QuicConnectionTest, TLP) { |
| 2250 QuicSentPacketManagerPeer::SetMaxTailLossProbes( | 2223 QuicSentPacketManagerPeer::SetMaxTailLossProbes( |
| 2251 QuicConnectionPeer::GetSentPacketManager(&connection_), 1); | 2224 QuicConnectionPeer::GetSentPacketManager(&connection_), 1); |
| 2252 | 2225 |
| 2253 SendStreamDataToPeer(3, "foo", 0, !kFin, NULL); | 2226 SendStreamDataToPeer(3, "foo", 0, !kFin, NULL); |
| 2254 EXPECT_EQ(1u, outgoing_ack()->sent_info.least_unacked); | 2227 EXPECT_EQ(1u, stop_waiting()->least_unacked); |
| 2255 QuicTime retransmission_time = | 2228 QuicTime retransmission_time = |
| 2256 connection_.GetRetransmissionAlarm()->deadline(); | 2229 connection_.GetRetransmissionAlarm()->deadline(); |
| 2257 EXPECT_NE(QuicTime::Zero(), retransmission_time); | 2230 EXPECT_NE(QuicTime::Zero(), retransmission_time); |
| 2258 | 2231 |
| 2259 EXPECT_EQ(1u, writer_->header().packet_sequence_number); | 2232 EXPECT_EQ(1u, writer_->header().packet_sequence_number); |
| 2260 // Simulate the retransmission alarm firing and sending a tlp, | 2233 // Simulate the retransmission alarm firing and sending a tlp, |
| 2261 // so send algorithm's OnRetransmissionTimeout is not called. | 2234 // so send algorithm's OnRetransmissionTimeout is not called. |
| 2262 clock_.AdvanceTime(retransmission_time.Subtract(clock_.Now())); | 2235 clock_.AdvanceTime(retransmission_time.Subtract(clock_.Now())); |
| 2263 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, 2u, _, _)); | 2236 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, 2u, _, _)); |
| 2264 connection_.GetRetransmissionAlarm()->Fire(); | 2237 connection_.GetRetransmissionAlarm()->Fire(); |
| 2265 EXPECT_EQ(2u, writer_->header().packet_sequence_number); | 2238 EXPECT_EQ(2u, writer_->header().packet_sequence_number); |
| 2266 // We do not raise the high water mark yet. | 2239 // We do not raise the high water mark yet. |
| 2267 EXPECT_EQ(1u, outgoing_ack()->sent_info.least_unacked); | 2240 EXPECT_EQ(1u, stop_waiting()->least_unacked); |
| 2268 } | 2241 } |
| 2269 | 2242 |
| 2270 TEST_P(QuicConnectionTest, RTO) { | 2243 TEST_P(QuicConnectionTest, RTO) { |
| 2271 QuicTime default_retransmission_time = clock_.ApproximateNow().Add( | 2244 QuicTime default_retransmission_time = clock_.ApproximateNow().Add( |
| 2272 DefaultRetransmissionTime()); | 2245 DefaultRetransmissionTime()); |
| 2273 SendStreamDataToPeer(3, "foo", 0, !kFin, NULL); | 2246 SendStreamDataToPeer(3, "foo", 0, !kFin, NULL); |
| 2274 EXPECT_EQ(1u, outgoing_ack()->sent_info.least_unacked); | 2247 EXPECT_EQ(1u, stop_waiting()->least_unacked); |
| 2275 | 2248 |
| 2276 EXPECT_EQ(1u, writer_->header().packet_sequence_number); | 2249 EXPECT_EQ(1u, writer_->header().packet_sequence_number); |
| 2277 EXPECT_EQ(default_retransmission_time, | 2250 EXPECT_EQ(default_retransmission_time, |
| 2278 connection_.GetRetransmissionAlarm()->deadline()); | 2251 connection_.GetRetransmissionAlarm()->deadline()); |
| 2279 // Simulate the retransmission alarm firing. | 2252 // Simulate the retransmission alarm firing. |
| 2280 clock_.AdvanceTime(DefaultRetransmissionTime()); | 2253 clock_.AdvanceTime(DefaultRetransmissionTime()); |
| 2281 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(true)); | 2254 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(true)); |
| 2282 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, 2u, _, _)); | 2255 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, 2u, _, _)); |
| 2283 connection_.GetRetransmissionAlarm()->Fire(); | 2256 connection_.GetRetransmissionAlarm()->Fire(); |
| 2284 EXPECT_EQ(2u, writer_->header().packet_sequence_number); | 2257 EXPECT_EQ(2u, writer_->header().packet_sequence_number); |
| 2285 // We do not raise the high water mark yet. | 2258 // We do not raise the high water mark yet. |
| 2286 EXPECT_EQ(1u, outgoing_ack()->sent_info.least_unacked); | 2259 EXPECT_EQ(1u, stop_waiting()->least_unacked); |
| 2287 } | 2260 } |
| 2288 | 2261 |
| 2289 TEST_P(QuicConnectionTest, RTOWithSameEncryptionLevel) { | 2262 TEST_P(QuicConnectionTest, RTOWithSameEncryptionLevel) { |
| 2290 QuicTime default_retransmission_time = clock_.ApproximateNow().Add( | 2263 QuicTime default_retransmission_time = clock_.ApproximateNow().Add( |
| 2291 DefaultRetransmissionTime()); | 2264 DefaultRetransmissionTime()); |
| 2292 use_tagging_decrypter(); | 2265 use_tagging_decrypter(); |
| 2293 | 2266 |
| 2294 // A TaggingEncrypter puts kTagSize copies of the given byte (0x01 here) at | 2267 // A TaggingEncrypter puts kTagSize copies of the given byte (0x01 here) at |
| 2295 // the end of the packet. We can test this to check which encrypter was used. | 2268 // the end of the packet. We can test this to check which encrypter was used. |
| 2296 connection_.SetEncrypter(ENCRYPTION_NONE, new TaggingEncrypter(0x01)); | 2269 connection_.SetEncrypter(ENCRYPTION_NONE, new TaggingEncrypter(0x01)); |
| (...skipping 190 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2487 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 2460 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 2488 .WillOnce(Return(lost_packets)); | 2461 .WillOnce(Return(lost_packets)); |
| 2489 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 2462 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 2490 QuicPacketSequenceNumber nack_sequence_number = 0; | 2463 QuicPacketSequenceNumber nack_sequence_number = 0; |
| 2491 // Ack packets might generate some other packets, which are not | 2464 // Ack packets might generate some other packets, which are not |
| 2492 // retransmissions. (More ack packets). | 2465 // retransmissions. (More ack packets). |
| 2493 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) | 2466 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) |
| 2494 .Times(AnyNumber()); | 2467 .Times(AnyNumber()); |
| 2495 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) | 2468 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) |
| 2496 .WillOnce(DoAll(SaveArg<2>(&nack_sequence_number), Return(true))); | 2469 .WillOnce(DoAll(SaveArg<2>(&nack_sequence_number), Return(true))); |
| 2497 QuicAckFrame ack = InitAckFrame(rto_sequence_number, 0); | 2470 QuicAckFrame ack = InitAckFrame(rto_sequence_number); |
| 2498 // Nack the retransmitted packet. | 2471 // Nack the retransmitted packet. |
| 2499 NackPacket(original_sequence_number, &ack); | 2472 NackPacket(original_sequence_number, &ack); |
| 2500 NackPacket(rto_sequence_number, &ack); | 2473 NackPacket(rto_sequence_number, &ack); |
| 2501 ProcessAckPacket(&ack); | 2474 ProcessAckPacket(&ack); |
| 2502 | 2475 |
| 2503 ASSERT_NE(0u, nack_sequence_number); | 2476 ASSERT_NE(0u, nack_sequence_number); |
| 2504 EXPECT_FALSE(QuicConnectionPeer::IsSavedForRetransmission( | 2477 EXPECT_FALSE(QuicConnectionPeer::IsSavedForRetransmission( |
| 2505 &connection_, rto_sequence_number)); | 2478 &connection_, rto_sequence_number)); |
| 2506 ASSERT_TRUE(QuicConnectionPeer::IsSavedForRetransmission( | 2479 ASSERT_TRUE(QuicConnectionPeer::IsSavedForRetransmission( |
| 2507 &connection_, nack_sequence_number)); | 2480 &connection_, nack_sequence_number)); |
| (...skipping 21 matching lines...) Expand all Loading... |
| 2529 connection_.SendStreamDataWithString(3, "bar", 0, !kFin, NULL); | 2502 connection_.SendStreamDataWithString(3, "bar", 0, !kFin, NULL); |
| 2530 QuicAlarm* retransmission_alarm = connection_.GetRetransmissionAlarm(); | 2503 QuicAlarm* retransmission_alarm = connection_.GetRetransmissionAlarm(); |
| 2531 EXPECT_TRUE(retransmission_alarm->IsSet()); | 2504 EXPECT_TRUE(retransmission_alarm->IsSet()); |
| 2532 EXPECT_EQ(clock_.Now().Add(DefaultRetransmissionTime()), | 2505 EXPECT_EQ(clock_.Now().Add(DefaultRetransmissionTime()), |
| 2533 retransmission_alarm->deadline()); | 2506 retransmission_alarm->deadline()); |
| 2534 | 2507 |
| 2535 // Advance the time right before the RTO, then receive an ack for the first | 2508 // Advance the time right before the RTO, then receive an ack for the first |
| 2536 // packet to delay the RTO. | 2509 // packet to delay the RTO. |
| 2537 clock_.AdvanceTime(DefaultRetransmissionTime()); | 2510 clock_.AdvanceTime(DefaultRetransmissionTime()); |
| 2538 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 2511 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 2539 QuicAckFrame ack = InitAckFrame(1, 0); | 2512 QuicAckFrame ack = InitAckFrame(1); |
| 2540 ProcessAckPacket(&ack); | 2513 ProcessAckPacket(&ack); |
| 2541 EXPECT_TRUE(retransmission_alarm->IsSet()); | 2514 EXPECT_TRUE(retransmission_alarm->IsSet()); |
| 2542 EXPECT_GT(retransmission_alarm->deadline(), clock_.Now()); | 2515 EXPECT_GT(retransmission_alarm->deadline(), clock_.Now()); |
| 2543 | 2516 |
| 2544 // Move forward past the original RTO and ensure the RTO is still pending. | 2517 // Move forward past the original RTO and ensure the RTO is still pending. |
| 2545 clock_.AdvanceTime(DefaultRetransmissionTime().Multiply(2)); | 2518 clock_.AdvanceTime(DefaultRetransmissionTime().Multiply(2)); |
| 2546 | 2519 |
| 2547 // Ensure the second packet gets retransmitted when it finally fires. | 2520 // Ensure the second packet gets retransmitted when it finally fires. |
| 2548 EXPECT_TRUE(retransmission_alarm->IsSet()); | 2521 EXPECT_TRUE(retransmission_alarm->IsSet()); |
| 2549 EXPECT_LT(retransmission_alarm->deadline(), clock_.ApproximateNow()); | 2522 EXPECT_LT(retransmission_alarm->deadline(), clock_.ApproximateNow()); |
| (...skipping 26 matching lines...) Expand all Loading... |
| 2576 TEST_P(QuicConnectionTest, CloseFecGroup) { | 2549 TEST_P(QuicConnectionTest, CloseFecGroup) { |
| 2577 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2550 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 2578 // Don't send missing packet 1. | 2551 // Don't send missing packet 1. |
| 2579 // Don't send missing packet 2. | 2552 // Don't send missing packet 2. |
| 2580 ProcessFecProtectedPacket(3, false, !kEntropyFlag); | 2553 ProcessFecProtectedPacket(3, false, !kEntropyFlag); |
| 2581 // Don't send missing FEC packet 3. | 2554 // Don't send missing FEC packet 3. |
| 2582 ASSERT_EQ(1u, connection_.NumFecGroups()); | 2555 ASSERT_EQ(1u, connection_.NumFecGroups()); |
| 2583 | 2556 |
| 2584 // Now send non-fec protected ack packet and close the group. | 2557 // Now send non-fec protected ack packet and close the group. |
| 2585 peer_creator_.set_sequence_number(4); | 2558 peer_creator_.set_sequence_number(4); |
| 2586 if (version() > QUIC_VERSION_15) { | 2559 QuicStopWaitingFrame frame = InitStopWaitingFrame(5); |
| 2587 QuicStopWaitingFrame frame = InitStopWaitingFrame(5); | 2560 ProcessStopWaitingPacket(&frame); |
| 2588 ProcessStopWaitingPacket(&frame); | |
| 2589 } else { | |
| 2590 QuicAckFrame frame = InitAckFrame(0, 5); | |
| 2591 ProcessAckPacket(&frame); | |
| 2592 } | |
| 2593 ASSERT_EQ(0u, connection_.NumFecGroups()); | 2561 ASSERT_EQ(0u, connection_.NumFecGroups()); |
| 2594 } | 2562 } |
| 2595 | 2563 |
| 2596 TEST_P(QuicConnectionTest, NoQuicCongestionFeedbackFrame) { | 2564 TEST_P(QuicConnectionTest, NoQuicCongestionFeedbackFrame) { |
| 2597 SendAckPacketToPeer(); | 2565 SendAckPacketToPeer(); |
| 2598 EXPECT_TRUE(writer_->feedback_frames().empty()); | 2566 EXPECT_TRUE(writer_->feedback_frames().empty()); |
| 2599 } | 2567 } |
| 2600 | 2568 |
| 2601 TEST_P(QuicConnectionTest, WithQuicCongestionFeedbackFrame) { | 2569 TEST_P(QuicConnectionTest, WithQuicCongestionFeedbackFrame) { |
| 2602 QuicCongestionFeedbackFrame info; | 2570 QuicCongestionFeedbackFrame info; |
| (...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2661 clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(5)); | 2629 clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(5)); |
| 2662 EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); | 2630 EXPECT_FALSE(connection_.GetRetransmissionAlarm()->IsSet()); |
| 2663 SendStreamDataToPeer(1, "GET /", 0, kFin, NULL); | 2631 SendStreamDataToPeer(1, "GET /", 0, kFin, NULL); |
| 2664 EXPECT_TRUE(connection_.GetPingAlarm()->IsSet()); | 2632 EXPECT_TRUE(connection_.GetPingAlarm()->IsSet()); |
| 2665 EXPECT_EQ(clock_.ApproximateNow().Add(QuicTime::Delta::FromSeconds(15)), | 2633 EXPECT_EQ(clock_.ApproximateNow().Add(QuicTime::Delta::FromSeconds(15)), |
| 2666 connection_.GetPingAlarm()->deadline()); | 2634 connection_.GetPingAlarm()->deadline()); |
| 2667 | 2635 |
| 2668 // Now recevie and ACK of the previous packet, which will move the | 2636 // Now recevie and ACK of the previous packet, which will move the |
| 2669 // ping alarm forward. | 2637 // ping alarm forward. |
| 2670 clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(5)); | 2638 clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(5)); |
| 2671 QuicAckFrame frame = InitAckFrame(1, 0); | 2639 QuicAckFrame frame = InitAckFrame(1); |
| 2672 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2640 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 2673 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 2641 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 2674 ProcessAckPacket(&frame); | 2642 ProcessAckPacket(&frame); |
| 2675 EXPECT_TRUE(connection_.GetPingAlarm()->IsSet()); | 2643 EXPECT_TRUE(connection_.GetPingAlarm()->IsSet()); |
| 2676 EXPECT_EQ(clock_.ApproximateNow().Add(QuicTime::Delta::FromSeconds(15)), | 2644 EXPECT_EQ(clock_.ApproximateNow().Add(QuicTime::Delta::FromSeconds(15)), |
| 2677 connection_.GetPingAlarm()->deadline()); | 2645 connection_.GetPingAlarm()->deadline()); |
| 2678 | 2646 |
| 2679 writer_->Reset(); | 2647 writer_->Reset(); |
| 2680 clock_.AdvanceTime(QuicTime::Delta::FromSeconds(15)); | 2648 clock_.AdvanceTime(QuicTime::Delta::FromSeconds(15)); |
| 2681 connection_.GetPingAlarm()->Fire(); | 2649 connection_.GetPingAlarm()->Fire(); |
| (...skipping 153 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2835 QuicPacket* packet = ConstructDataPacket(1, 0, !kEntropyFlag); | 2803 QuicPacket* packet = ConstructDataPacket(1, 0, !kEntropyFlag); |
| 2836 EXPECT_CALL(*send_algorithm_, | 2804 EXPECT_CALL(*send_algorithm_, |
| 2837 TimeUntilSend(_, _, _)).WillOnce( | 2805 TimeUntilSend(_, _, _)).WillOnce( |
| 2838 testing::Return(QuicTime::Delta::FromMicroseconds(10))); | 2806 testing::Return(QuicTime::Delta::FromMicroseconds(10))); |
| 2839 connection_.SendPacket( | 2807 connection_.SendPacket( |
| 2840 ENCRYPTION_NONE, 1, packet, kTestEntropyHash, HAS_RETRANSMITTABLE_DATA); | 2808 ENCRYPTION_NONE, 1, packet, kTestEntropyHash, HAS_RETRANSMITTABLE_DATA); |
| 2841 EXPECT_EQ(1u, connection_.NumQueuedPackets()); | 2809 EXPECT_EQ(1u, connection_.NumQueuedPackets()); |
| 2842 | 2810 |
| 2843 // Now send non-retransmitting information, that we're not going to | 2811 // Now send non-retransmitting information, that we're not going to |
| 2844 // retransmit 3. The far end should stop waiting for it. | 2812 // retransmit 3. The far end should stop waiting for it. |
| 2845 QuicAckFrame frame = InitAckFrame(0, 1); | 2813 QuicAckFrame frame = InitAckFrame(0); |
| 2846 EXPECT_CALL(*send_algorithm_, | 2814 EXPECT_CALL(*send_algorithm_, |
| 2847 TimeUntilSend(_, _, _)).WillRepeatedly( | 2815 TimeUntilSend(_, _, _)).WillRepeatedly( |
| 2848 testing::Return(QuicTime::Delta::Zero())); | 2816 testing::Return(QuicTime::Delta::Zero())); |
| 2849 EXPECT_CALL(*send_algorithm_, | 2817 EXPECT_CALL(*send_algorithm_, |
| 2850 OnPacketSent(_, _, _, _, _)); | 2818 OnPacketSent(_, _, _, _, _)); |
| 2851 ProcessAckPacket(&frame); | 2819 ProcessAckPacket(&frame); |
| 2852 | 2820 |
| 2853 EXPECT_EQ(0u, connection_.NumQueuedPackets()); | 2821 EXPECT_EQ(0u, connection_.NumQueuedPackets()); |
| 2854 // Ensure alarm is not set | 2822 // Ensure alarm is not set |
| 2855 EXPECT_FALSE(connection_.GetSendAlarm()->IsSet()); | 2823 EXPECT_FALSE(connection_.GetSendAlarm()->IsSet()); |
| 2856 } | 2824 } |
| 2857 | 2825 |
| 2858 TEST_P(QuicConnectionTest, SendSchedulerDelayThenAckAndHold) { | 2826 TEST_P(QuicConnectionTest, SendSchedulerDelayThenAckAndHold) { |
| 2859 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2827 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 2860 QuicPacket* packet = ConstructDataPacket(1, 0, !kEntropyFlag); | 2828 QuicPacket* packet = ConstructDataPacket(1, 0, !kEntropyFlag); |
| 2861 EXPECT_CALL(*send_algorithm_, | 2829 EXPECT_CALL(*send_algorithm_, |
| 2862 TimeUntilSend(_, _, _)).WillOnce( | 2830 TimeUntilSend(_, _, _)).WillOnce( |
| 2863 testing::Return(QuicTime::Delta::FromMicroseconds(10))); | 2831 testing::Return(QuicTime::Delta::FromMicroseconds(10))); |
| 2864 connection_.SendPacket( | 2832 connection_.SendPacket( |
| 2865 ENCRYPTION_NONE, 1, packet, kTestEntropyHash, HAS_RETRANSMITTABLE_DATA); | 2833 ENCRYPTION_NONE, 1, packet, kTestEntropyHash, HAS_RETRANSMITTABLE_DATA); |
| 2866 EXPECT_EQ(1u, connection_.NumQueuedPackets()); | 2834 EXPECT_EQ(1u, connection_.NumQueuedPackets()); |
| 2867 | 2835 |
| 2868 // Now send non-retransmitting information, that we're not going to | 2836 // Now send non-retransmitting information, that we're not going to |
| 2869 // retransmit 3. The far end should stop waiting for it. | 2837 // retransmit 3. The far end should stop waiting for it. |
| 2870 QuicAckFrame frame = InitAckFrame(0, 1); | 2838 QuicAckFrame frame = InitAckFrame(0); |
| 2871 EXPECT_CALL(*send_algorithm_, | 2839 EXPECT_CALL(*send_algorithm_, |
| 2872 TimeUntilSend(_, _, _)).WillOnce( | 2840 TimeUntilSend(_, _, _)).WillOnce( |
| 2873 testing::Return(QuicTime::Delta::FromMicroseconds(1))); | 2841 testing::Return(QuicTime::Delta::FromMicroseconds(1))); |
| 2874 ProcessAckPacket(&frame); | 2842 ProcessAckPacket(&frame); |
| 2875 | 2843 |
| 2876 EXPECT_EQ(1u, connection_.NumQueuedPackets()); | 2844 EXPECT_EQ(1u, connection_.NumQueuedPackets()); |
| 2877 } | 2845 } |
| 2878 | 2846 |
| 2879 TEST_P(QuicConnectionTest, SendSchedulerDelayThenOnCanWrite) { | 2847 TEST_P(QuicConnectionTest, SendSchedulerDelayThenOnCanWrite) { |
| 2880 // TODO(ianswett): This test is unrealistic, because we would not serialize | 2848 // TODO(ianswett): This test is unrealistic, because we would not serialize |
| (...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2949 // instead of ENCRYPTION_NONE. | 2917 // instead of ENCRYPTION_NONE. |
| 2950 EXPECT_CALL(visitor_, OnStreamFrames(_)).Times(1); | 2918 EXPECT_CALL(visitor_, OnStreamFrames(_)).Times(1); |
| 2951 ProcessDataPacketAtLevel(1, 0, !kEntropyFlag, ENCRYPTION_INITIAL); | 2919 ProcessDataPacketAtLevel(1, 0, !kEntropyFlag, ENCRYPTION_INITIAL); |
| 2952 | 2920 |
| 2953 // Check if delayed ack timer is running for the expected interval. | 2921 // Check if delayed ack timer is running for the expected interval. |
| 2954 EXPECT_TRUE(connection_.GetAckAlarm()->IsSet()); | 2922 EXPECT_TRUE(connection_.GetAckAlarm()->IsSet()); |
| 2955 EXPECT_EQ(ack_time, connection_.GetAckAlarm()->deadline()); | 2923 EXPECT_EQ(ack_time, connection_.GetAckAlarm()->deadline()); |
| 2956 // Simulate delayed ack alarm firing. | 2924 // Simulate delayed ack alarm firing. |
| 2957 connection_.GetAckAlarm()->Fire(); | 2925 connection_.GetAckAlarm()->Fire(); |
| 2958 // Check that ack is sent and that delayed ack alarm is reset. | 2926 // Check that ack is sent and that delayed ack alarm is reset. |
| 2959 if (version() > QUIC_VERSION_15) { | 2927 EXPECT_EQ(2u, writer_->frame_count()); |
| 2960 EXPECT_EQ(2u, writer_->frame_count()); | 2928 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); |
| 2961 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); | |
| 2962 } else { | |
| 2963 EXPECT_EQ(1u, writer_->frame_count()); | |
| 2964 } | |
| 2965 EXPECT_FALSE(writer_->ack_frames().empty()); | 2929 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 2966 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); | 2930 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); |
| 2967 } | 2931 } |
| 2968 | 2932 |
| 2969 TEST_P(QuicConnectionTest, SendEarlyDelayedAckForCrypto) { | 2933 TEST_P(QuicConnectionTest, SendEarlyDelayedAckForCrypto) { |
| 2970 QuicTime ack_time = clock_.ApproximateNow(); | 2934 QuicTime ack_time = clock_.ApproximateNow(); |
| 2971 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2935 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 2972 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); | 2936 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); |
| 2973 // Process a packet from the crypto stream, which is frame1_'s default. | 2937 // Process a packet from the crypto stream, which is frame1_'s default. |
| 2974 ProcessPacket(1); | 2938 ProcessPacket(1); |
| 2975 // Check if delayed ack timer is running for the expected interval. | 2939 // Check if delayed ack timer is running for the expected interval. |
| 2976 EXPECT_TRUE(connection_.GetAckAlarm()->IsSet()); | 2940 EXPECT_TRUE(connection_.GetAckAlarm()->IsSet()); |
| 2977 EXPECT_EQ(ack_time, connection_.GetAckAlarm()->deadline()); | 2941 EXPECT_EQ(ack_time, connection_.GetAckAlarm()->deadline()); |
| 2978 // Simulate delayed ack alarm firing. | 2942 // Simulate delayed ack alarm firing. |
| 2979 connection_.GetAckAlarm()->Fire(); | 2943 connection_.GetAckAlarm()->Fire(); |
| 2980 // Check that ack is sent and that delayed ack alarm is reset. | 2944 // Check that ack is sent and that delayed ack alarm is reset. |
| 2981 if (version() > QUIC_VERSION_15) { | 2945 EXPECT_EQ(2u, writer_->frame_count()); |
| 2982 EXPECT_EQ(2u, writer_->frame_count()); | 2946 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); |
| 2983 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); | |
| 2984 } else { | |
| 2985 EXPECT_EQ(1u, writer_->frame_count()); | |
| 2986 } | |
| 2987 EXPECT_FALSE(writer_->ack_frames().empty()); | 2947 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 2988 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); | 2948 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); |
| 2989 } | 2949 } |
| 2990 | 2950 |
| 2991 TEST_P(QuicConnectionTest, SendDelayedAckOnSecondPacket) { | 2951 TEST_P(QuicConnectionTest, SendDelayedAckOnSecondPacket) { |
| 2992 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2952 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 2993 ProcessPacket(1); | 2953 ProcessPacket(1); |
| 2994 ProcessPacket(2); | 2954 ProcessPacket(2); |
| 2995 // Check that ack is sent and that delayed ack alarm is reset. | 2955 // Check that ack is sent and that delayed ack alarm is reset. |
| 2996 if (version() > QUIC_VERSION_15) { | 2956 EXPECT_EQ(2u, writer_->frame_count()); |
| 2997 EXPECT_EQ(2u, writer_->frame_count()); | 2957 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); |
| 2998 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); | |
| 2999 } else { | |
| 3000 EXPECT_EQ(1u, writer_->frame_count()); | |
| 3001 } | |
| 3002 EXPECT_FALSE(writer_->ack_frames().empty()); | 2958 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 3003 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); | 2959 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); |
| 3004 } | 2960 } |
| 3005 | 2961 |
| 3006 TEST_P(QuicConnectionTest, NoAckOnOldNacks) { | 2962 TEST_P(QuicConnectionTest, NoAckOnOldNacks) { |
| 3007 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2963 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3008 // Drop one packet, triggering a sequence of acks. | 2964 // Drop one packet, triggering a sequence of acks. |
| 3009 ProcessPacket(2); | 2965 ProcessPacket(2); |
| 3010 size_t frames_per_ack = version() > QUIC_VERSION_15 ? 2 : 1; | 2966 size_t frames_per_ack = 2; |
| 3011 EXPECT_EQ(frames_per_ack, writer_->frame_count()); | 2967 EXPECT_EQ(frames_per_ack, writer_->frame_count()); |
| 3012 EXPECT_FALSE(writer_->ack_frames().empty()); | 2968 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 3013 writer_->Reset(); | 2969 writer_->Reset(); |
| 3014 ProcessPacket(3); | 2970 ProcessPacket(3); |
| 3015 EXPECT_EQ(frames_per_ack, writer_->frame_count()); | 2971 EXPECT_EQ(frames_per_ack, writer_->frame_count()); |
| 3016 EXPECT_FALSE(writer_->ack_frames().empty()); | 2972 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 3017 writer_->Reset(); | 2973 writer_->Reset(); |
| 3018 ProcessPacket(4); | 2974 ProcessPacket(4); |
| 3019 EXPECT_EQ(frames_per_ack, writer_->frame_count()); | 2975 EXPECT_EQ(frames_per_ack, writer_->frame_count()); |
| 3020 EXPECT_FALSE(writer_->ack_frames().empty()); | 2976 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 3021 writer_->Reset(); | 2977 writer_->Reset(); |
| 3022 ProcessPacket(5); | 2978 ProcessPacket(5); |
| 3023 EXPECT_EQ(frames_per_ack, writer_->frame_count()); | 2979 EXPECT_EQ(frames_per_ack, writer_->frame_count()); |
| 3024 EXPECT_FALSE(writer_->ack_frames().empty()); | 2980 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 3025 writer_->Reset(); | 2981 writer_->Reset(); |
| 3026 // Now only set the timer on the 6th packet, instead of sending another ack. | 2982 // Now only set the timer on the 6th packet, instead of sending another ack. |
| 3027 ProcessPacket(6); | 2983 ProcessPacket(6); |
| 3028 EXPECT_EQ(0u, writer_->frame_count()); | 2984 EXPECT_EQ(0u, writer_->frame_count()); |
| 3029 EXPECT_TRUE(connection_.GetAckAlarm()->IsSet()); | 2985 EXPECT_TRUE(connection_.GetAckAlarm()->IsSet()); |
| 3030 } | 2986 } |
| 3031 | 2987 |
| 3032 TEST_P(QuicConnectionTest, SendDelayedAckOnOutgoingPacket) { | 2988 TEST_P(QuicConnectionTest, SendDelayedAckOnOutgoingPacket) { |
| 3033 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2989 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3034 ProcessPacket(1); | 2990 ProcessPacket(1); |
| 3035 connection_.SendStreamDataWithString(kClientDataStreamId1, "foo", 0, | 2991 connection_.SendStreamDataWithString(kClientDataStreamId1, "foo", 0, |
| 3036 !kFin, NULL); | 2992 !kFin, NULL); |
| 3037 // Check that ack is bundled with outgoing data and that delayed ack | 2993 // Check that ack is bundled with outgoing data and that delayed ack |
| 3038 // alarm is reset. | 2994 // alarm is reset. |
| 3039 if (version() > QUIC_VERSION_15) { | 2995 EXPECT_EQ(3u, writer_->frame_count()); |
| 3040 EXPECT_EQ(3u, writer_->frame_count()); | 2996 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); |
| 3041 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); | |
| 3042 } else { | |
| 3043 EXPECT_EQ(2u, writer_->frame_count()); | |
| 3044 } | |
| 3045 EXPECT_FALSE(writer_->ack_frames().empty()); | 2997 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 3046 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); | 2998 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); |
| 3047 } | 2999 } |
| 3048 | 3000 |
| 3049 TEST_P(QuicConnectionTest, SendDelayedAckOnOutgoingCryptoPacket) { | 3001 TEST_P(QuicConnectionTest, SendDelayedAckOnOutgoingCryptoPacket) { |
| 3050 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3002 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3051 ProcessPacket(1); | 3003 ProcessPacket(1); |
| 3052 connection_.SendStreamDataWithString(kCryptoStreamId, "foo", 0, !kFin, NULL); | 3004 connection_.SendStreamDataWithString(kCryptoStreamId, "foo", 0, !kFin, NULL); |
| 3053 // Check that ack is bundled with outgoing crypto data. | 3005 // Check that ack is bundled with outgoing crypto data. |
| 3054 EXPECT_EQ(version() <= QUIC_VERSION_15 ? 2u : 3u, writer_->frame_count()); | 3006 EXPECT_EQ(3u, writer_->frame_count()); |
| 3055 EXPECT_FALSE(writer_->ack_frames().empty()); | 3007 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 3056 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); | 3008 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); |
| 3057 } | 3009 } |
| 3058 | 3010 |
| 3059 TEST_P(QuicConnectionTest, BundleAckForSecondCHLO) { | 3011 TEST_P(QuicConnectionTest, BundleAckForSecondCHLO) { |
| 3060 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3012 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3061 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); | 3013 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); |
| 3062 EXPECT_CALL(visitor_, OnCanWrite()).WillOnce( | 3014 EXPECT_CALL(visitor_, OnCanWrite()).WillOnce( |
| 3063 IgnoreResult(InvokeWithoutArgs(&connection_, | 3015 IgnoreResult(InvokeWithoutArgs(&connection_, |
| 3064 &TestConnection::SendCryptoStreamData))); | 3016 &TestConnection::SendCryptoStreamData))); |
| 3065 // Process a packet from the crypto stream, which is frame1_'s default. | 3017 // Process a packet from the crypto stream, which is frame1_'s default. |
| 3066 // Receiving the CHLO as packet 2 first will cause the connection to | 3018 // Receiving the CHLO as packet 2 first will cause the connection to |
| 3067 // immediately send an ack, due to the packet gap. | 3019 // immediately send an ack, due to the packet gap. |
| 3068 ProcessPacket(2); | 3020 ProcessPacket(2); |
| 3069 // Check that ack is sent and that delayed ack alarm is reset. | 3021 // Check that ack is sent and that delayed ack alarm is reset. |
| 3070 if (version() > QUIC_VERSION_15) { | 3022 EXPECT_EQ(3u, writer_->frame_count()); |
| 3071 EXPECT_EQ(3u, writer_->frame_count()); | 3023 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); |
| 3072 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); | |
| 3073 } else { | |
| 3074 EXPECT_EQ(2u, writer_->frame_count()); | |
| 3075 } | |
| 3076 EXPECT_EQ(1u, writer_->stream_frames().size()); | 3024 EXPECT_EQ(1u, writer_->stream_frames().size()); |
| 3077 EXPECT_FALSE(writer_->ack_frames().empty()); | 3025 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 3078 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); | 3026 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); |
| 3079 } | 3027 } |
| 3080 | 3028 |
| 3081 TEST_P(QuicConnectionTest, BundleAckWithDataOnIncomingAck) { | 3029 TEST_P(QuicConnectionTest, BundleAckWithDataOnIncomingAck) { |
| 3082 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3030 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3083 connection_.SendStreamDataWithString(kClientDataStreamId1, "foo", 0, | 3031 connection_.SendStreamDataWithString(kClientDataStreamId1, "foo", 0, |
| 3084 !kFin, NULL); | 3032 !kFin, NULL); |
| 3085 connection_.SendStreamDataWithString(kClientDataStreamId1, "foo", 3, | 3033 connection_.SendStreamDataWithString(kClientDataStreamId1, "foo", 3, |
| 3086 !kFin, NULL); | 3034 !kFin, NULL); |
| 3087 // Ack the second packet, which will retransmit the first packet. | 3035 // Ack the second packet, which will retransmit the first packet. |
| 3088 QuicAckFrame ack = InitAckFrame(2, 0); | 3036 QuicAckFrame ack = InitAckFrame(2); |
| 3089 NackPacket(1, &ack); | 3037 NackPacket(1, &ack); |
| 3090 SequenceNumberSet lost_packets; | 3038 SequenceNumberSet lost_packets; |
| 3091 lost_packets.insert(1); | 3039 lost_packets.insert(1); |
| 3092 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 3040 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 3093 .WillOnce(Return(lost_packets)); | 3041 .WillOnce(Return(lost_packets)); |
| 3094 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3042 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3095 ProcessAckPacket(&ack); | 3043 ProcessAckPacket(&ack); |
| 3096 EXPECT_EQ(1u, writer_->frame_count()); | 3044 EXPECT_EQ(1u, writer_->frame_count()); |
| 3097 EXPECT_EQ(1u, writer_->stream_frames().size()); | 3045 EXPECT_EQ(1u, writer_->stream_frames().size()); |
| 3098 writer_->Reset(); | 3046 writer_->Reset(); |
| 3099 | 3047 |
| 3100 // Now ack the retransmission, which will both raise the high water mark | 3048 // Now ack the retransmission, which will both raise the high water mark |
| 3101 // and see if there is more data to send. | 3049 // and see if there is more data to send. |
| 3102 ack = InitAckFrame(3, 0); | 3050 ack = InitAckFrame(3); |
| 3103 NackPacket(1, &ack); | 3051 NackPacket(1, &ack); |
| 3104 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 3052 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 3105 .WillOnce(Return(SequenceNumberSet())); | 3053 .WillOnce(Return(SequenceNumberSet())); |
| 3106 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3054 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3107 ProcessAckPacket(&ack); | 3055 ProcessAckPacket(&ack); |
| 3108 | 3056 |
| 3109 // Check that no packet is sent and the ack alarm isn't set. | 3057 // Check that no packet is sent and the ack alarm isn't set. |
| 3110 EXPECT_EQ(0u, writer_->frame_count()); | 3058 EXPECT_EQ(0u, writer_->frame_count()); |
| 3111 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); | 3059 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); |
| 3112 writer_->Reset(); | 3060 writer_->Reset(); |
| 3113 | 3061 |
| 3114 // Send the same ack, but send both data and an ack together. | 3062 // Send the same ack, but send both data and an ack together. |
| 3115 ack = InitAckFrame(3, 0); | 3063 ack = InitAckFrame(3); |
| 3116 NackPacket(1, &ack); | 3064 NackPacket(1, &ack); |
| 3117 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 3065 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 3118 .WillOnce(Return(SequenceNumberSet())); | 3066 .WillOnce(Return(SequenceNumberSet())); |
| 3119 EXPECT_CALL(visitor_, OnCanWrite()).WillOnce( | 3067 EXPECT_CALL(visitor_, OnCanWrite()).WillOnce( |
| 3120 IgnoreResult(InvokeWithoutArgs( | 3068 IgnoreResult(InvokeWithoutArgs( |
| 3121 &connection_, | 3069 &connection_, |
| 3122 &TestConnection::EnsureWritableAndSendStreamData5))); | 3070 &TestConnection::EnsureWritableAndSendStreamData5))); |
| 3123 ProcessAckPacket(&ack); | 3071 ProcessAckPacket(&ack); |
| 3124 | 3072 |
| 3125 // Check that ack is bundled with outgoing data and the delayed ack | 3073 // Check that ack is bundled with outgoing data and the delayed ack |
| 3126 // alarm is reset. | 3074 // alarm is reset. |
| 3127 if (version() > QUIC_VERSION_15) { | 3075 EXPECT_EQ(3u, writer_->frame_count()); |
| 3128 EXPECT_EQ(3u, writer_->frame_count()); | 3076 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); |
| 3129 EXPECT_FALSE(writer_->stop_waiting_frames().empty()); | |
| 3130 } else { | |
| 3131 EXPECT_EQ(2u, writer_->frame_count()); | |
| 3132 } | |
| 3133 EXPECT_FALSE(writer_->ack_frames().empty()); | 3077 EXPECT_FALSE(writer_->ack_frames().empty()); |
| 3134 EXPECT_EQ(1u, writer_->stream_frames().size()); | 3078 EXPECT_EQ(1u, writer_->stream_frames().size()); |
| 3135 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); | 3079 EXPECT_FALSE(connection_.GetAckAlarm()->IsSet()); |
| 3136 } | 3080 } |
| 3137 | 3081 |
| 3138 TEST_P(QuicConnectionTest, NoAckSentForClose) { | 3082 TEST_P(QuicConnectionTest, NoAckSentForClose) { |
| 3139 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3083 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3140 ProcessPacket(1); | 3084 ProcessPacket(1); |
| 3141 EXPECT_CALL(visitor_, OnConnectionClosed(QUIC_PEER_GOING_AWAY, true)); | 3085 EXPECT_CALL(visitor_, OnConnectionClosed(QUIC_PEER_GOING_AWAY, true)); |
| 3142 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(0); | 3086 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(0); |
| (...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3204 // The connection close packet should have error details. | 3148 // The connection close packet should have error details. |
| 3205 ASSERT_FALSE(writer_->connection_close_frames().empty()); | 3149 ASSERT_FALSE(writer_->connection_close_frames().empty()); |
| 3206 EXPECT_EQ("Unable to read public flags.", | 3150 EXPECT_EQ("Unable to read public flags.", |
| 3207 writer_->connection_close_frames()[0].error_details); | 3151 writer_->connection_close_frames()[0].error_details); |
| 3208 } | 3152 } |
| 3209 | 3153 |
| 3210 TEST_P(QuicConnectionTest, MissingPacketsBeforeLeastUnacked) { | 3154 TEST_P(QuicConnectionTest, MissingPacketsBeforeLeastUnacked) { |
| 3211 // Set the sequence number of the ack packet to be least unacked (4). | 3155 // Set the sequence number of the ack packet to be least unacked (4). |
| 3212 peer_creator_.set_sequence_number(3); | 3156 peer_creator_.set_sequence_number(3); |
| 3213 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3157 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3214 if (version() > QUIC_VERSION_15) { | 3158 QuicStopWaitingFrame frame = InitStopWaitingFrame(4); |
| 3215 QuicStopWaitingFrame frame = InitStopWaitingFrame(4); | 3159 ProcessStopWaitingPacket(&frame); |
| 3216 ProcessStopWaitingPacket(&frame); | |
| 3217 } else { | |
| 3218 QuicAckFrame ack = InitAckFrame(0, 4); | |
| 3219 ProcessAckPacket(&ack); | |
| 3220 } | |
| 3221 EXPECT_TRUE(outgoing_ack()->received_info.missing_packets.empty()); | 3160 EXPECT_TRUE(outgoing_ack()->received_info.missing_packets.empty()); |
| 3222 } | 3161 } |
| 3223 | 3162 |
| 3224 TEST_P(QuicConnectionTest, ReceivedEntropyHashCalculation) { | 3163 TEST_P(QuicConnectionTest, ReceivedEntropyHashCalculation) { |
| 3225 EXPECT_CALL(visitor_, OnStreamFrames(_)).Times(AtLeast(1)); | 3164 EXPECT_CALL(visitor_, OnStreamFrames(_)).Times(AtLeast(1)); |
| 3226 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3165 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3227 ProcessDataPacket(1, 1, kEntropyFlag); | 3166 ProcessDataPacket(1, 1, kEntropyFlag); |
| 3228 ProcessDataPacket(4, 1, kEntropyFlag); | 3167 ProcessDataPacket(4, 1, kEntropyFlag); |
| 3229 ProcessDataPacket(3, 1, !kEntropyFlag); | 3168 ProcessDataPacket(3, 1, !kEntropyFlag); |
| 3230 ProcessDataPacket(7, 1, kEntropyFlag); | 3169 ProcessDataPacket(7, 1, kEntropyFlag); |
| (...skipping 15 matching lines...) Expand all Loading... |
| 3246 EXPECT_CALL(visitor_, OnStreamFrames(_)).Times(AtLeast(1)); | 3185 EXPECT_CALL(visitor_, OnStreamFrames(_)).Times(AtLeast(1)); |
| 3247 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3186 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3248 ProcessDataPacket(1, 1, kEntropyFlag); | 3187 ProcessDataPacket(1, 1, kEntropyFlag); |
| 3249 ProcessDataPacket(5, 1, kEntropyFlag); | 3188 ProcessDataPacket(5, 1, kEntropyFlag); |
| 3250 ProcessDataPacket(4, 1, !kEntropyFlag); | 3189 ProcessDataPacket(4, 1, !kEntropyFlag); |
| 3251 EXPECT_EQ(34u, outgoing_ack()->received_info.entropy_hash); | 3190 EXPECT_EQ(34u, outgoing_ack()->received_info.entropy_hash); |
| 3252 // Make 4th packet my least unacked, and update entropy for 2, 3 packets. | 3191 // Make 4th packet my least unacked, and update entropy for 2, 3 packets. |
| 3253 peer_creator_.set_sequence_number(5); | 3192 peer_creator_.set_sequence_number(5); |
| 3254 QuicPacketEntropyHash six_packet_entropy_hash = 0; | 3193 QuicPacketEntropyHash six_packet_entropy_hash = 0; |
| 3255 QuicPacketEntropyHash kRandomEntropyHash = 129u; | 3194 QuicPacketEntropyHash kRandomEntropyHash = 129u; |
| 3256 if (version() > QUIC_VERSION_15) { | 3195 QuicStopWaitingFrame frame = InitStopWaitingFrame(4); |
| 3257 QuicStopWaitingFrame frame = InitStopWaitingFrame(4); | 3196 frame.entropy_hash = kRandomEntropyHash; |
| 3258 frame.entropy_hash = kRandomEntropyHash; | 3197 if (ProcessStopWaitingPacket(&frame)) { |
| 3259 if (ProcessStopWaitingPacket(&frame)) { | 3198 six_packet_entropy_hash = 1 << 6; |
| 3260 six_packet_entropy_hash = 1 << 6; | |
| 3261 } | |
| 3262 } else { | |
| 3263 QuicAckFrame ack = InitAckFrame(0, 4); | |
| 3264 ack.sent_info.entropy_hash = kRandomEntropyHash; | |
| 3265 if (ProcessAckPacket(&ack)) { | |
| 3266 six_packet_entropy_hash = 1 << 6; | |
| 3267 } | |
| 3268 } | 3199 } |
| 3269 | 3200 |
| 3270 EXPECT_EQ((kRandomEntropyHash + (1 << 5) + six_packet_entropy_hash), | 3201 EXPECT_EQ((kRandomEntropyHash + (1 << 5) + six_packet_entropy_hash), |
| 3271 outgoing_ack()->received_info.entropy_hash); | 3202 outgoing_ack()->received_info.entropy_hash); |
| 3272 } | 3203 } |
| 3273 | 3204 |
| 3274 TEST_P(QuicConnectionTest, UpdateEntropyHashUptoCurrentPacket) { | 3205 TEST_P(QuicConnectionTest, UpdateEntropyHashUptoCurrentPacket) { |
| 3275 EXPECT_CALL(visitor_, OnStreamFrames(_)).Times(AtLeast(1)); | 3206 EXPECT_CALL(visitor_, OnStreamFrames(_)).Times(AtLeast(1)); |
| 3276 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3207 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3277 ProcessDataPacket(1, 1, kEntropyFlag); | 3208 ProcessDataPacket(1, 1, kEntropyFlag); |
| 3278 ProcessDataPacket(5, 1, !kEntropyFlag); | 3209 ProcessDataPacket(5, 1, !kEntropyFlag); |
| 3279 ProcessDataPacket(22, 1, kEntropyFlag); | 3210 ProcessDataPacket(22, 1, kEntropyFlag); |
| 3280 EXPECT_EQ(66u, outgoing_ack()->received_info.entropy_hash); | 3211 EXPECT_EQ(66u, outgoing_ack()->received_info.entropy_hash); |
| 3281 peer_creator_.set_sequence_number(22); | 3212 peer_creator_.set_sequence_number(22); |
| 3282 QuicPacketEntropyHash kRandomEntropyHash = 85u; | 3213 QuicPacketEntropyHash kRandomEntropyHash = 85u; |
| 3283 // Current packet is the least unacked packet. | 3214 // Current packet is the least unacked packet. |
| 3284 QuicPacketEntropyHash ack_entropy_hash; | 3215 QuicPacketEntropyHash ack_entropy_hash; |
| 3285 if (version() > QUIC_VERSION_15) { | 3216 QuicStopWaitingFrame frame = InitStopWaitingFrame(23); |
| 3286 QuicStopWaitingFrame frame = InitStopWaitingFrame(23); | 3217 frame.entropy_hash = kRandomEntropyHash; |
| 3287 frame.entropy_hash = kRandomEntropyHash; | 3218 ack_entropy_hash = ProcessStopWaitingPacket(&frame); |
| 3288 ack_entropy_hash = ProcessStopWaitingPacket(&frame); | |
| 3289 } else { | |
| 3290 QuicAckFrame ack = InitAckFrame(0, 23); | |
| 3291 ack.sent_info.entropy_hash = kRandomEntropyHash; | |
| 3292 ack_entropy_hash = ProcessAckPacket(&ack); | |
| 3293 } | |
| 3294 EXPECT_EQ((kRandomEntropyHash + ack_entropy_hash), | 3219 EXPECT_EQ((kRandomEntropyHash + ack_entropy_hash), |
| 3295 outgoing_ack()->received_info.entropy_hash); | 3220 outgoing_ack()->received_info.entropy_hash); |
| 3296 ProcessDataPacket(25, 1, kEntropyFlag); | 3221 ProcessDataPacket(25, 1, kEntropyFlag); |
| 3297 EXPECT_EQ((kRandomEntropyHash + ack_entropy_hash + (1 << (25 % 8))), | 3222 EXPECT_EQ((kRandomEntropyHash + ack_entropy_hash + (1 << (25 % 8))), |
| 3298 outgoing_ack()->received_info.entropy_hash); | 3223 outgoing_ack()->received_info.entropy_hash); |
| 3299 } | 3224 } |
| 3300 | 3225 |
| 3301 TEST_P(QuicConnectionTest, EntropyCalculationForTruncatedAck) { | 3226 TEST_P(QuicConnectionTest, EntropyCalculationForTruncatedAck) { |
| 3302 EXPECT_CALL(visitor_, OnStreamFrames(_)).Times(AtLeast(1)); | 3227 EXPECT_CALL(visitor_, OnStreamFrames(_)).Times(AtLeast(1)); |
| 3303 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3228 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| (...skipping 240 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3544 | 3469 |
| 3545 // 2 retransmissions due to rto, 1 due to explicit nack. | 3470 // 2 retransmissions due to rto, 1 due to explicit nack. |
| 3546 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(true)); | 3471 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(true)); |
| 3547 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(3); | 3472 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(3); |
| 3548 | 3473 |
| 3549 // Retransmit due to RTO. | 3474 // Retransmit due to RTO. |
| 3550 clock_.AdvanceTime(QuicTime::Delta::FromSeconds(10)); | 3475 clock_.AdvanceTime(QuicTime::Delta::FromSeconds(10)); |
| 3551 connection_.GetRetransmissionAlarm()->Fire(); | 3476 connection_.GetRetransmissionAlarm()->Fire(); |
| 3552 | 3477 |
| 3553 // Retransmit due to explicit nacks. | 3478 // Retransmit due to explicit nacks. |
| 3554 QuicAckFrame nack_three = InitAckFrame(4, 0); | 3479 QuicAckFrame nack_three = InitAckFrame(4); |
| 3555 NackPacket(3, &nack_three); | 3480 NackPacket(3, &nack_three); |
| 3556 NackPacket(1, &nack_three); | 3481 NackPacket(1, &nack_three); |
| 3557 SequenceNumberSet lost_packets; | 3482 SequenceNumberSet lost_packets; |
| 3558 lost_packets.insert(1); | 3483 lost_packets.insert(1); |
| 3559 lost_packets.insert(3); | 3484 lost_packets.insert(3); |
| 3560 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 3485 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 3561 .WillOnce(Return(lost_packets)); | 3486 .WillOnce(Return(lost_packets)); |
| 3562 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3487 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3563 EXPECT_CALL(visitor_, OnCanWrite()).Times(2); | 3488 EXPECT_CALL(visitor_, OnCanWrite()).Times(2); |
| 3564 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3489 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| (...skipping 163 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3728 | 3653 |
| 3729 // Create a delegate which we expect to be called. | 3654 // Create a delegate which we expect to be called. |
| 3730 scoped_refptr<MockAckNotifierDelegate> delegate(new MockAckNotifierDelegate); | 3655 scoped_refptr<MockAckNotifierDelegate> delegate(new MockAckNotifierDelegate); |
| 3731 EXPECT_CALL(*delegate, OnAckNotification(_, _, _, _, _)).Times(1); | 3656 EXPECT_CALL(*delegate, OnAckNotification(_, _, _, _, _)).Times(1); |
| 3732 | 3657 |
| 3733 // Send some data, which will register the delegate to be notified. | 3658 // Send some data, which will register the delegate to be notified. |
| 3734 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, delegate.get()); | 3659 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, delegate.get()); |
| 3735 | 3660 |
| 3736 // Process an ACK from the server which should trigger the callback. | 3661 // Process an ACK from the server which should trigger the callback. |
| 3737 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3662 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3738 QuicAckFrame frame = InitAckFrame(1, 0); | 3663 QuicAckFrame frame = InitAckFrame(1); |
| 3739 ProcessAckPacket(&frame); | 3664 ProcessAckPacket(&frame); |
| 3740 } | 3665 } |
| 3741 | 3666 |
| 3742 TEST_P(QuicConnectionTest, AckNotifierFailToTriggerCallback) { | 3667 TEST_P(QuicConnectionTest, AckNotifierFailToTriggerCallback) { |
| 3743 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3668 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3744 | 3669 |
| 3745 // Create a delegate which we don't expect to be called. | 3670 // Create a delegate which we don't expect to be called. |
| 3746 scoped_refptr<MockAckNotifierDelegate> delegate(new MockAckNotifierDelegate); | 3671 scoped_refptr<MockAckNotifierDelegate> delegate(new MockAckNotifierDelegate); |
| 3747 EXPECT_CALL(*delegate, OnAckNotification(_, _, _, _, _)).Times(0); | 3672 EXPECT_CALL(*delegate, OnAckNotification(_, _, _, _, _)).Times(0); |
| 3748 | 3673 |
| 3749 // Send some data, which will register the delegate to be notified. This will | 3674 // Send some data, which will register the delegate to be notified. This will |
| 3750 // not be ACKed and so the delegate should never be called. | 3675 // not be ACKed and so the delegate should never be called. |
| 3751 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, delegate.get()); | 3676 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, delegate.get()); |
| 3752 | 3677 |
| 3753 // Send some other data which we will ACK. | 3678 // Send some other data which we will ACK. |
| 3754 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); | 3679 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, NULL); |
| 3755 connection_.SendStreamDataWithString(1, "bar", 0, !kFin, NULL); | 3680 connection_.SendStreamDataWithString(1, "bar", 0, !kFin, NULL); |
| 3756 | 3681 |
| 3757 // Now we receive ACK for packets 2 and 3, but importantly missing packet 1 | 3682 // Now we receive ACK for packets 2 and 3, but importantly missing packet 1 |
| 3758 // which we registered to be notified about. | 3683 // which we registered to be notified about. |
| 3759 QuicAckFrame frame = InitAckFrame(3, 0); | 3684 QuicAckFrame frame = InitAckFrame(3); |
| 3760 NackPacket(1, &frame); | 3685 NackPacket(1, &frame); |
| 3761 SequenceNumberSet lost_packets; | 3686 SequenceNumberSet lost_packets; |
| 3762 lost_packets.insert(1); | 3687 lost_packets.insert(1); |
| 3763 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 3688 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 3764 .WillOnce(Return(lost_packets)); | 3689 .WillOnce(Return(lost_packets)); |
| 3765 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3690 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3766 ProcessAckPacket(&frame); | 3691 ProcessAckPacket(&frame); |
| 3767 } | 3692 } |
| 3768 | 3693 |
| 3769 TEST_P(QuicConnectionTest, AckNotifierCallbackAfterRetransmission) { | 3694 TEST_P(QuicConnectionTest, AckNotifierCallbackAfterRetransmission) { |
| 3770 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3695 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3771 | 3696 |
| 3772 // Create a delegate which we expect to be called. | 3697 // Create a delegate which we expect to be called. |
| 3773 scoped_refptr<MockAckNotifierDelegate> delegate(new MockAckNotifierDelegate); | 3698 scoped_refptr<MockAckNotifierDelegate> delegate(new MockAckNotifierDelegate); |
| 3774 EXPECT_CALL(*delegate, OnAckNotification(_, _, _, _, _)).Times(1); | 3699 EXPECT_CALL(*delegate, OnAckNotification(_, _, _, _, _)).Times(1); |
| 3775 | 3700 |
| 3776 // Send four packets, and register to be notified on ACK of packet 2. | 3701 // Send four packets, and register to be notified on ACK of packet 2. |
| 3777 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); | 3702 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); |
| 3778 connection_.SendStreamDataWithString(3, "bar", 0, !kFin, delegate.get()); | 3703 connection_.SendStreamDataWithString(3, "bar", 0, !kFin, delegate.get()); |
| 3779 connection_.SendStreamDataWithString(3, "baz", 0, !kFin, NULL); | 3704 connection_.SendStreamDataWithString(3, "baz", 0, !kFin, NULL); |
| 3780 connection_.SendStreamDataWithString(3, "qux", 0, !kFin, NULL); | 3705 connection_.SendStreamDataWithString(3, "qux", 0, !kFin, NULL); |
| 3781 | 3706 |
| 3782 // Now we receive ACK for packets 1, 3, and 4 and lose 2. | 3707 // Now we receive ACK for packets 1, 3, and 4 and lose 2. |
| 3783 QuicAckFrame frame = InitAckFrame(4, 0); | 3708 QuicAckFrame frame = InitAckFrame(4); |
| 3784 NackPacket(2, &frame); | 3709 NackPacket(2, &frame); |
| 3785 SequenceNumberSet lost_packets; | 3710 SequenceNumberSet lost_packets; |
| 3786 lost_packets.insert(2); | 3711 lost_packets.insert(2); |
| 3787 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 3712 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 3788 .WillOnce(Return(lost_packets)); | 3713 .WillOnce(Return(lost_packets)); |
| 3789 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3714 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3790 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); | 3715 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); |
| 3791 ProcessAckPacket(&frame); | 3716 ProcessAckPacket(&frame); |
| 3792 | 3717 |
| 3793 // Now we get an ACK for packet 5 (retransmitted packet 2), which should | 3718 // Now we get an ACK for packet 5 (retransmitted packet 2), which should |
| 3794 // trigger the callback. | 3719 // trigger the callback. |
| 3795 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 3720 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 3796 .WillRepeatedly(Return(SequenceNumberSet())); | 3721 .WillRepeatedly(Return(SequenceNumberSet())); |
| 3797 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3722 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3798 QuicAckFrame second_ack_frame = InitAckFrame(5, 0); | 3723 QuicAckFrame second_ack_frame = InitAckFrame(5); |
| 3799 ProcessAckPacket(&second_ack_frame); | 3724 ProcessAckPacket(&second_ack_frame); |
| 3800 } | 3725 } |
| 3801 | 3726 |
| 3802 // AckNotifierCallback is triggered by the ack of a packet that timed | 3727 // AckNotifierCallback is triggered by the ack of a packet that timed |
| 3803 // out and was retransmitted, even though the retransmission has a | 3728 // out and was retransmitted, even though the retransmission has a |
| 3804 // different sequence number. | 3729 // different sequence number. |
| 3805 TEST_P(QuicConnectionTest, AckNotifierCallbackForAckAfterRTO) { | 3730 TEST_P(QuicConnectionTest, AckNotifierCallbackForAckAfterRTO) { |
| 3806 InSequence s; | 3731 InSequence s; |
| 3807 | 3732 |
| 3808 // Create a delegate which we expect to be called. | 3733 // Create a delegate which we expect to be called. |
| 3809 scoped_refptr<MockAckNotifierDelegate> delegate( | 3734 scoped_refptr<MockAckNotifierDelegate> delegate( |
| 3810 new StrictMock<MockAckNotifierDelegate>); | 3735 new StrictMock<MockAckNotifierDelegate>); |
| 3811 | 3736 |
| 3812 QuicTime default_retransmission_time = clock_.ApproximateNow().Add( | 3737 QuicTime default_retransmission_time = clock_.ApproximateNow().Add( |
| 3813 DefaultRetransmissionTime()); | 3738 DefaultRetransmissionTime()); |
| 3814 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, delegate.get()); | 3739 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, delegate.get()); |
| 3815 EXPECT_EQ(1u, outgoing_ack()->sent_info.least_unacked); | 3740 EXPECT_EQ(1u, stop_waiting()->least_unacked); |
| 3816 | 3741 |
| 3817 EXPECT_EQ(1u, writer_->header().packet_sequence_number); | 3742 EXPECT_EQ(1u, writer_->header().packet_sequence_number); |
| 3818 EXPECT_EQ(default_retransmission_time, | 3743 EXPECT_EQ(default_retransmission_time, |
| 3819 connection_.GetRetransmissionAlarm()->deadline()); | 3744 connection_.GetRetransmissionAlarm()->deadline()); |
| 3820 // Simulate the retransmission alarm firing. | 3745 // Simulate the retransmission alarm firing. |
| 3821 clock_.AdvanceTime(DefaultRetransmissionTime()); | 3746 clock_.AdvanceTime(DefaultRetransmissionTime()); |
| 3822 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(true)); | 3747 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(true)); |
| 3823 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, 2u, _, _)); | 3748 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, 2u, _, _)); |
| 3824 connection_.GetRetransmissionAlarm()->Fire(); | 3749 connection_.GetRetransmissionAlarm()->Fire(); |
| 3825 EXPECT_EQ(2u, writer_->header().packet_sequence_number); | 3750 EXPECT_EQ(2u, writer_->header().packet_sequence_number); |
| 3826 // We do not raise the high water mark yet. | 3751 // We do not raise the high water mark yet. |
| 3827 EXPECT_EQ(1u, outgoing_ack()->sent_info.least_unacked); | 3752 EXPECT_EQ(1u, stop_waiting()->least_unacked); |
| 3828 | 3753 |
| 3829 // Ack the original packet, which will revert the RTO. | 3754 // Ack the original packet, which will revert the RTO. |
| 3830 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3755 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3831 EXPECT_CALL(*delegate, OnAckNotification(1, _, 1, _, _)); | 3756 EXPECT_CALL(*delegate, OnAckNotification(1, _, 1, _, _)); |
| 3832 EXPECT_CALL(*send_algorithm_, RevertRetransmissionTimeout()); | 3757 EXPECT_CALL(*send_algorithm_, RevertRetransmissionTimeout()); |
| 3833 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3758 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3834 QuicAckFrame ack_frame = InitAckFrame(1, 0); | 3759 QuicAckFrame ack_frame = InitAckFrame(1); |
| 3835 ProcessAckPacket(&ack_frame); | 3760 ProcessAckPacket(&ack_frame); |
| 3836 | 3761 |
| 3837 // Delegate is not notified again when the retransmit is acked. | 3762 // Delegate is not notified again when the retransmit is acked. |
| 3838 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3763 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3839 QuicAckFrame second_ack_frame = InitAckFrame(2, 0); | 3764 QuicAckFrame second_ack_frame = InitAckFrame(2); |
| 3840 ProcessAckPacket(&second_ack_frame); | 3765 ProcessAckPacket(&second_ack_frame); |
| 3841 } | 3766 } |
| 3842 | 3767 |
| 3843 // AckNotifierCallback is triggered by the ack of a packet that was | 3768 // AckNotifierCallback is triggered by the ack of a packet that was |
| 3844 // previously nacked, even though the retransmission has a different | 3769 // previously nacked, even though the retransmission has a different |
| 3845 // sequence number. | 3770 // sequence number. |
| 3846 TEST_P(QuicConnectionTest, AckNotifierCallbackForAckOfNackedPacket) { | 3771 TEST_P(QuicConnectionTest, AckNotifierCallbackForAckOfNackedPacket) { |
| 3847 InSequence s; | 3772 InSequence s; |
| 3848 | 3773 |
| 3849 // Create a delegate which we expect to be called. | 3774 // Create a delegate which we expect to be called. |
| 3850 scoped_refptr<MockAckNotifierDelegate> delegate( | 3775 scoped_refptr<MockAckNotifierDelegate> delegate( |
| 3851 new StrictMock<MockAckNotifierDelegate>); | 3776 new StrictMock<MockAckNotifierDelegate>); |
| 3852 | 3777 |
| 3853 // Send four packets, and register to be notified on ACK of packet 2. | 3778 // Send four packets, and register to be notified on ACK of packet 2. |
| 3854 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); | 3779 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, NULL); |
| 3855 connection_.SendStreamDataWithString(3, "bar", 0, !kFin, delegate.get()); | 3780 connection_.SendStreamDataWithString(3, "bar", 0, !kFin, delegate.get()); |
| 3856 connection_.SendStreamDataWithString(3, "baz", 0, !kFin, NULL); | 3781 connection_.SendStreamDataWithString(3, "baz", 0, !kFin, NULL); |
| 3857 connection_.SendStreamDataWithString(3, "qux", 0, !kFin, NULL); | 3782 connection_.SendStreamDataWithString(3, "qux", 0, !kFin, NULL); |
| 3858 | 3783 |
| 3859 // Now we receive ACK for packets 1, 3, and 4 and lose 2. | 3784 // Now we receive ACK for packets 1, 3, and 4 and lose 2. |
| 3860 QuicAckFrame frame = InitAckFrame(4, 0); | 3785 QuicAckFrame frame = InitAckFrame(4); |
| 3861 NackPacket(2, &frame); | 3786 NackPacket(2, &frame); |
| 3862 SequenceNumberSet lost_packets; | 3787 SequenceNumberSet lost_packets; |
| 3863 lost_packets.insert(2); | 3788 lost_packets.insert(2); |
| 3864 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3789 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3865 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 3790 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 3866 .WillOnce(Return(lost_packets)); | 3791 .WillOnce(Return(lost_packets)); |
| 3867 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3792 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3868 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); | 3793 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)); |
| 3869 ProcessAckPacket(&frame); | 3794 ProcessAckPacket(&frame); |
| 3870 | 3795 |
| 3871 // Now we get an ACK for packet 2, which was previously nacked. | 3796 // Now we get an ACK for packet 2, which was previously nacked. |
| 3872 SequenceNumberSet no_lost_packets; | 3797 SequenceNumberSet no_lost_packets; |
| 3873 EXPECT_CALL(*delegate, OnAckNotification(1, _, 1, _, _)); | 3798 EXPECT_CALL(*delegate, OnAckNotification(1, _, 1, _, _)); |
| 3874 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 3799 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 3875 .WillOnce(Return(no_lost_packets)); | 3800 .WillOnce(Return(no_lost_packets)); |
| 3876 QuicAckFrame second_ack_frame = InitAckFrame(4, 0); | 3801 QuicAckFrame second_ack_frame = InitAckFrame(4); |
| 3877 ProcessAckPacket(&second_ack_frame); | 3802 ProcessAckPacket(&second_ack_frame); |
| 3878 | 3803 |
| 3879 // Verify that the delegate is not notified again when the | 3804 // Verify that the delegate is not notified again when the |
| 3880 // retransmit is acked. | 3805 // retransmit is acked. |
| 3881 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 3806 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 3882 .WillOnce(Return(no_lost_packets)); | 3807 .WillOnce(Return(no_lost_packets)); |
| 3883 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3808 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3884 QuicAckFrame third_ack_frame = InitAckFrame(5, 0); | 3809 QuicAckFrame third_ack_frame = InitAckFrame(5); |
| 3885 ProcessAckPacket(&third_ack_frame); | 3810 ProcessAckPacket(&third_ack_frame); |
| 3886 } | 3811 } |
| 3887 | 3812 |
| 3888 TEST_P(QuicConnectionTest, AckNotifierFECTriggerCallback) { | 3813 TEST_P(QuicConnectionTest, AckNotifierFECTriggerCallback) { |
| 3889 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3814 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3890 | 3815 |
| 3891 // Create a delegate which we expect to be called. | 3816 // Create a delegate which we expect to be called. |
| 3892 scoped_refptr<MockAckNotifierDelegate> delegate( | 3817 scoped_refptr<MockAckNotifierDelegate> delegate( |
| 3893 new MockAckNotifierDelegate); | 3818 new MockAckNotifierDelegate); |
| 3894 EXPECT_CALL(*delegate, OnAckNotification(_, _, _, _, _)).Times(1); | 3819 EXPECT_CALL(*delegate, OnAckNotification(_, _, _, _, _)).Times(1); |
| 3895 | 3820 |
| 3896 // Send some data, which will register the delegate to be notified. | 3821 // Send some data, which will register the delegate to be notified. |
| 3897 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, delegate.get()); | 3822 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, delegate.get()); |
| 3898 connection_.SendStreamDataWithString(2, "bar", 0, !kFin, NULL); | 3823 connection_.SendStreamDataWithString(2, "bar", 0, !kFin, NULL); |
| 3899 | 3824 |
| 3900 // Process an ACK from the server with a revived packet, which should trigger | 3825 // Process an ACK from the server with a revived packet, which should trigger |
| 3901 // the callback. | 3826 // the callback. |
| 3902 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3827 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3903 QuicAckFrame frame = InitAckFrame(2, 0); | 3828 QuicAckFrame frame = InitAckFrame(2); |
| 3904 NackPacket(1, &frame); | 3829 NackPacket(1, &frame); |
| 3905 frame.received_info.revived_packets.insert(1); | 3830 frame.received_info.revived_packets.insert(1); |
| 3906 ProcessAckPacket(&frame); | 3831 ProcessAckPacket(&frame); |
| 3907 // If the ack is processed again, the notifier should not be called again. | 3832 // If the ack is processed again, the notifier should not be called again. |
| 3908 ProcessAckPacket(&frame); | 3833 ProcessAckPacket(&frame); |
| 3909 } | 3834 } |
| 3910 | 3835 |
| 3911 TEST_P(QuicConnectionTest, AckNotifierCallbackAfterFECRecovery) { | 3836 TEST_P(QuicConnectionTest, AckNotifierCallbackAfterFECRecovery) { |
| 3912 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 3837 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
| 3913 EXPECT_CALL(visitor_, OnCanWrite()); | 3838 EXPECT_CALL(visitor_, OnCanWrite()); |
| 3914 | 3839 |
| 3915 // Create a delegate which we expect to be called. | 3840 // Create a delegate which we expect to be called. |
| 3916 scoped_refptr<MockAckNotifierDelegate> delegate(new MockAckNotifierDelegate); | 3841 scoped_refptr<MockAckNotifierDelegate> delegate(new MockAckNotifierDelegate); |
| 3917 EXPECT_CALL(*delegate, OnAckNotification(_, _, _, _, _)).Times(1); | 3842 EXPECT_CALL(*delegate, OnAckNotification(_, _, _, _, _)).Times(1); |
| 3918 | 3843 |
| 3919 // Expect ACKs for 1 packet. | 3844 // Expect ACKs for 1 packet. |
| 3920 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); | 3845 EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _)); |
| 3921 | 3846 |
| 3922 // Send one packet, and register to be notified on ACK. | 3847 // Send one packet, and register to be notified on ACK. |
| 3923 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, delegate.get()); | 3848 connection_.SendStreamDataWithString(1, "foo", 0, !kFin, delegate.get()); |
| 3924 | 3849 |
| 3925 // Ack packet gets dropped, but we receive an FEC packet that covers it. | 3850 // Ack packet gets dropped, but we receive an FEC packet that covers it. |
| 3926 // Should recover the Ack packet and trigger the notification callback. | 3851 // Should recover the Ack packet and trigger the notification callback. |
| 3927 QuicFrames frames; | 3852 QuicFrames frames; |
| 3928 | 3853 |
| 3929 QuicAckFrame ack_frame = InitAckFrame(1, 0); | 3854 QuicAckFrame ack_frame = InitAckFrame(1); |
| 3930 frames.push_back(QuicFrame(&ack_frame)); | 3855 frames.push_back(QuicFrame(&ack_frame)); |
| 3931 | 3856 |
| 3932 // Dummy stream frame to satisfy expectations set elsewhere. | 3857 // Dummy stream frame to satisfy expectations set elsewhere. |
| 3933 frames.push_back(QuicFrame(&frame1_)); | 3858 frames.push_back(QuicFrame(&frame1_)); |
| 3934 | 3859 |
| 3935 QuicPacketHeader ack_header; | 3860 QuicPacketHeader ack_header; |
| 3936 ack_header.public_header.connection_id = connection_id_; | 3861 ack_header.public_header.connection_id = connection_id_; |
| 3937 ack_header.public_header.reset_flag = false; | 3862 ack_header.public_header.reset_flag = false; |
| 3938 ack_header.public_header.version_flag = false; | 3863 ack_header.public_header.version_flag = false; |
| 3939 ack_header.entropy_flag = !kEntropyFlag; | 3864 ack_header.entropy_flag = !kEntropyFlag; |
| (...skipping 121 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4061 QuicBlockedFrame blocked; | 3986 QuicBlockedFrame blocked; |
| 4062 blocked.stream_id = 3; | 3987 blocked.stream_id = 3; |
| 4063 EXPECT_CALL(visitor_, OnBlockedFrames(_)); | 3988 EXPECT_CALL(visitor_, OnBlockedFrames(_)); |
| 4064 ProcessFramePacket(QuicFrame(&blocked)); | 3989 ProcessFramePacket(QuicFrame(&blocked)); |
| 4065 EXPECT_TRUE(ack_alarm->IsSet()); | 3990 EXPECT_TRUE(ack_alarm->IsSet()); |
| 4066 } | 3991 } |
| 4067 | 3992 |
| 4068 } // namespace | 3993 } // namespace |
| 4069 } // namespace test | 3994 } // namespace test |
| 4070 } // namespace net | 3995 } // namespace net |
| OLD | NEW |