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 <algorithm> | 5 #include <algorithm> |
6 #include <map> | 6 #include <map> |
7 #include <string> | 7 #include <string> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/containers/hash_tables.h" | 10 #include "base/containers/hash_tables.h" |
(...skipping 181 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
192 } | 192 } |
193 | 193 |
194 virtual ~TestQuicVisitor() { | 194 virtual ~TestQuicVisitor() { |
195 STLDeleteElements(&stream_frames_); | 195 STLDeleteElements(&stream_frames_); |
196 STLDeleteElements(&ack_frames_); | 196 STLDeleteElements(&ack_frames_); |
197 STLDeleteElements(&congestion_feedback_frames_); | 197 STLDeleteElements(&congestion_feedback_frames_); |
198 STLDeleteElements(&fec_data_); | 198 STLDeleteElements(&fec_data_); |
199 } | 199 } |
200 | 200 |
201 virtual void OnError(QuicFramer* f) OVERRIDE { | 201 virtual void OnError(QuicFramer* f) OVERRIDE { |
202 DLOG(INFO) << "QuicFramer Error: " << QuicUtils::ErrorToString(f->error()) | 202 DVLOG(0) << "QuicFramer Error: " << QuicUtils::ErrorToString(f->error()) |
203 << " (" << f->error() << ")"; | 203 << " (" << f->error() << ")"; |
204 error_count_++; | 204 error_count_++; |
205 } | 205 } |
206 | 206 |
207 virtual void OnPacket() OVERRIDE {} | 207 virtual void OnPacket() OVERRIDE {} |
208 | 208 |
209 virtual void OnPublicResetPacket( | 209 virtual void OnPublicResetPacket( |
210 const QuicPublicResetPacket& packet) OVERRIDE { | 210 const QuicPublicResetPacket& packet) OVERRIDE { |
211 public_reset_packet_.reset(new QuicPublicResetPacket(packet)); | 211 public_reset_packet_.reset(new QuicPublicResetPacket(packet)); |
212 } | 212 } |
213 | 213 |
214 virtual void OnVersionNegotiationPacket( | 214 virtual void OnVersionNegotiationPacket( |
215 const QuicVersionNegotiationPacket& packet) OVERRIDE { | 215 const QuicVersionNegotiationPacket& packet) OVERRIDE { |
216 version_negotiation_packet_.reset(new QuicVersionNegotiationPacket(packet)); | 216 version_negotiation_packet_.reset(new QuicVersionNegotiationPacket(packet)); |
217 } | 217 } |
218 | 218 |
219 virtual void OnRevivedPacket() OVERRIDE { | 219 virtual void OnRevivedPacket() OVERRIDE { |
220 revived_packets_++; | 220 revived_packets_++; |
221 } | 221 } |
222 | 222 |
223 virtual bool OnProtocolVersionMismatch(QuicVersion version) OVERRIDE { | 223 virtual bool OnProtocolVersionMismatch(QuicVersion version) OVERRIDE { |
224 DLOG(INFO) << "QuicFramer Version Mismatch, version: " << version; | 224 DVLOG(0) << "QuicFramer Version Mismatch, version: " << version; |
225 version_mismatch_++; | 225 version_mismatch_++; |
226 return true; | 226 return true; |
227 } | 227 } |
228 | 228 |
229 virtual bool OnPacketHeader(const QuicPacketHeader& header) OVERRIDE { | 229 virtual bool OnPacketHeader(const QuicPacketHeader& header) OVERRIDE { |
230 packet_count_++; | 230 packet_count_++; |
231 header_.reset(new QuicPacketHeader(header)); | 231 header_.reset(new QuicPacketHeader(header)); |
232 return accept_packet_; | 232 return accept_packet_; |
233 } | 233 } |
234 | 234 |
(...skipping 2229 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2464 EXPECT_TRUE(visitor_.public_reset_packet_->public_header.reset_flag); | 2464 EXPECT_TRUE(visitor_.public_reset_packet_->public_header.reset_flag); |
2465 EXPECT_FALSE(visitor_.public_reset_packet_->public_header.version_flag); | 2465 EXPECT_FALSE(visitor_.public_reset_packet_->public_header.version_flag); |
2466 EXPECT_EQ(GG_UINT64_C(0xABCDEF0123456789), | 2466 EXPECT_EQ(GG_UINT64_C(0xABCDEF0123456789), |
2467 visitor_.public_reset_packet_->nonce_proof); | 2467 visitor_.public_reset_packet_->nonce_proof); |
2468 EXPECT_EQ(GG_UINT64_C(0x123456789ABC), | 2468 EXPECT_EQ(GG_UINT64_C(0x123456789ABC), |
2469 visitor_.public_reset_packet_->rejected_sequence_number); | 2469 visitor_.public_reset_packet_->rejected_sequence_number); |
2470 | 2470 |
2471 // Now test framing boundaries | 2471 // Now test framing boundaries |
2472 for (size_t i = 0; i < GetPublicResetPacketSize(); ++i) { | 2472 for (size_t i = 0; i < GetPublicResetPacketSize(); ++i) { |
2473 string expected_error; | 2473 string expected_error; |
2474 DLOG(INFO) << "iteration: " << i; | 2474 DVLOG(0) << "iteration: " << i; |
2475 if (i < kGuidOffset) { | 2475 if (i < kGuidOffset) { |
2476 expected_error = "Unable to read public flags."; | 2476 expected_error = "Unable to read public flags."; |
2477 CheckProcessingFails(packet, i, expected_error, | 2477 CheckProcessingFails(packet, i, expected_error, |
2478 QUIC_INVALID_PACKET_HEADER); | 2478 QUIC_INVALID_PACKET_HEADER); |
2479 } else if (i < kPublicResetPacketNonceProofOffset) { | 2479 } else if (i < kPublicResetPacketNonceProofOffset) { |
2480 expected_error = "Unable to read GUID."; | 2480 expected_error = "Unable to read GUID."; |
2481 CheckProcessingFails(packet, i, expected_error, | 2481 CheckProcessingFails(packet, i, expected_error, |
2482 QUIC_INVALID_PACKET_HEADER); | 2482 QUIC_INVALID_PACKET_HEADER); |
2483 } else if (i < kPublicResetPacketRejectedSequenceNumberOffset) { | 2483 } else if (i < kPublicResetPacketRejectedSequenceNumberOffset) { |
2484 expected_error = "Unable to read nonce proof."; | 2484 expected_error = "Unable to read nonce proof."; |
(...skipping 1479 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3964 EXPECT_CALL(visitor, OnConnectionCloseFrame(_)).Times(0); | 3964 EXPECT_CALL(visitor, OnConnectionCloseFrame(_)).Times(0); |
3965 EXPECT_CALL(visitor, OnPacketComplete()); | 3965 EXPECT_CALL(visitor, OnPacketComplete()); |
3966 | 3966 |
3967 QuicEncryptedPacket encrypted(AsChars(packet), arraysize(packet), false); | 3967 QuicEncryptedPacket encrypted(AsChars(packet), arraysize(packet), false); |
3968 EXPECT_TRUE(framer_.ProcessPacket(encrypted)); | 3968 EXPECT_TRUE(framer_.ProcessPacket(encrypted)); |
3969 EXPECT_EQ(QUIC_NO_ERROR, framer_.error()); | 3969 EXPECT_EQ(QUIC_NO_ERROR, framer_.error()); |
3970 } | 3970 } |
3971 | 3971 |
3972 } // namespace test | 3972 } // namespace test |
3973 } // namespace net | 3973 } // namespace net |
OLD | NEW |