| 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 |