| 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/core/quic_connection.h" | 5 #include "net/quic/core/quic_connection.h" |
| 6 | 6 |
| 7 #include <errno.h> | 7 #include <errno.h> |
| 8 #include <memory> | 8 #include <memory> |
| 9 #include <ostream> | 9 #include <ostream> |
| 10 #include <utility> | 10 #include <utility> |
| (...skipping 832 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 843 } | 843 } |
| 844 | 844 |
| 845 size_t ProcessFramePacketAtLevel(QuicPacketNumber number, | 845 size_t ProcessFramePacketAtLevel(QuicPacketNumber number, |
| 846 QuicFrame frame, | 846 QuicFrame frame, |
| 847 EncryptionLevel level) { | 847 EncryptionLevel level) { |
| 848 QuicPacketHeader header; | 848 QuicPacketHeader header; |
| 849 header.public_header.connection_id = | 849 header.public_header.connection_id = |
| 850 GetPeerInMemoryConnectionId(connection_id_); | 850 GetPeerInMemoryConnectionId(connection_id_); |
| 851 header.public_header.packet_number_length = packet_number_length_; | 851 header.public_header.packet_number_length = packet_number_length_; |
| 852 header.public_header.connection_id_length = connection_id_length_; | 852 header.public_header.connection_id_length = connection_id_length_; |
| 853 header.public_header.multipath_flag = false; | |
| 854 header.packet_number = number; | 853 header.packet_number = number; |
| 855 QuicFrames frames; | 854 QuicFrames frames; |
| 856 frames.push_back(frame); | 855 frames.push_back(frame); |
| 857 std::unique_ptr<QuicPacket> packet(ConstructPacket(header, frames)); | 856 std::unique_ptr<QuicPacket> packet(ConstructPacket(header, frames)); |
| 858 | 857 |
| 859 char buffer[kMaxPacketSize]; | 858 char buffer[kMaxPacketSize]; |
| 860 size_t encrypted_length = | 859 size_t encrypted_length = |
| 861 framer_.EncryptPayload(level, number, *packet, buffer, kMaxPacketSize); | 860 framer_.EncryptPayload(level, number, *packet, buffer, kMaxPacketSize); |
| 862 connection_.ProcessUdpPacket( | 861 connection_.ProcessUdpPacket( |
| 863 kSelfAddress, kPeerAddress, | 862 kSelfAddress, kPeerAddress, |
| (...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 956 | 955 |
| 957 QuicPacket* ConstructDataPacket(QuicPacketNumber number, | 956 QuicPacket* ConstructDataPacket(QuicPacketNumber number, |
| 958 bool has_stop_waiting) { | 957 bool has_stop_waiting) { |
| 959 QuicPacketHeader header; | 958 QuicPacketHeader header; |
| 960 // Set connection_id to peer's in memory representation as this data packet | 959 // Set connection_id to peer's in memory representation as this data packet |
| 961 // is created by peer_framer. | 960 // is created by peer_framer. |
| 962 header.public_header.connection_id = | 961 header.public_header.connection_id = |
| 963 GetPeerInMemoryConnectionId(connection_id_); | 962 GetPeerInMemoryConnectionId(connection_id_); |
| 964 header.public_header.packet_number_length = packet_number_length_; | 963 header.public_header.packet_number_length = packet_number_length_; |
| 965 header.public_header.connection_id_length = connection_id_length_; | 964 header.public_header.connection_id_length = connection_id_length_; |
| 966 header.public_header.multipath_flag = false; | |
| 967 header.packet_number = number; | 965 header.packet_number = number; |
| 968 | 966 |
| 969 QuicFrames frames; | 967 QuicFrames frames; |
| 970 frames.push_back(QuicFrame(&frame1_)); | 968 frames.push_back(QuicFrame(&frame1_)); |
| 971 if (has_stop_waiting) { | 969 if (has_stop_waiting) { |
| 972 frames.push_back(QuicFrame(&stop_waiting_)); | 970 frames.push_back(QuicFrame(&stop_waiting_)); |
| 973 } | 971 } |
| 974 return ConstructPacket(header, frames); | 972 return ConstructPacket(header, frames); |
| 975 } | 973 } |
| 976 | 974 |
| (...skipping 4286 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5263 error_details, ConnectionCloseSource::FROM_PEER)); | 5261 error_details, ConnectionCloseSource::FROM_PEER)); |
| 5264 connection_.set_perspective(Perspective::IS_CLIENT); | 5262 connection_.set_perspective(Perspective::IS_CLIENT); |
| 5265 connection_.CloseConnection(QUIC_CRYPTO_HANDSHAKE_STATELESS_REJECT, | 5263 connection_.CloseConnection(QUIC_CRYPTO_HANDSHAKE_STATELESS_REJECT, |
| 5266 error_details, | 5264 error_details, |
| 5267 ConnectionCloseBehavior::SILENT_CLOSE); | 5265 ConnectionCloseBehavior::SILENT_CLOSE); |
| 5268 } | 5266 } |
| 5269 | 5267 |
| 5270 } // namespace | 5268 } // namespace |
| 5271 } // namespace test | 5269 } // namespace test |
| 5272 } // namespace net | 5270 } // namespace net |
| OLD | NEW |