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_protocol.h" | 5 #include "net/quic/core/quic_protocol.h" |
6 | 6 |
7 #include "base/stl_util.h" | 7 #include "base/stl_util.h" |
8 #include "base/strings/string_number_conversions.h" | 8 #include "base/strings/string_number_conversions.h" |
9 #include "net/quic/core/quic_flags.h" | 9 #include "net/quic/core/quic_flags.h" |
10 #include "net/quic/core/quic_utils.h" | 10 #include "net/quic/core/quic_utils.h" |
(...skipping 720 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
731 QuicGoAwayFrame::QuicGoAwayFrame(QuicErrorCode error_code, | 731 QuicGoAwayFrame::QuicGoAwayFrame(QuicErrorCode error_code, |
732 QuicStreamId last_good_stream_id, | 732 QuicStreamId last_good_stream_id, |
733 const string& reason) | 733 const string& reason) |
734 : error_code(error_code), | 734 : error_code(error_code), |
735 last_good_stream_id(last_good_stream_id), | 735 last_good_stream_id(last_good_stream_id), |
736 reason_phrase(reason) {} | 736 reason_phrase(reason) {} |
737 | 737 |
738 QuicData::QuicData(const char* buffer, size_t length) | 738 QuicData::QuicData(const char* buffer, size_t length) |
739 : buffer_(buffer), length_(length), owns_buffer_(false) {} | 739 : buffer_(buffer), length_(length), owns_buffer_(false) {} |
740 | 740 |
741 QuicData::QuicData(char* buffer, size_t length, bool owns_buffer) | 741 QuicData::QuicData(const char* buffer, size_t length, bool owns_buffer) |
742 : buffer_(buffer), length_(length), owns_buffer_(owns_buffer) {} | 742 : buffer_(buffer), length_(length), owns_buffer_(owns_buffer) {} |
743 | 743 |
744 QuicData::~QuicData() { | 744 QuicData::~QuicData() { |
745 if (owns_buffer_) { | 745 if (owns_buffer_) { |
746 delete[] const_cast<char*>(buffer_); | 746 delete[] const_cast<char*>(buffer_); |
747 } | 747 } |
748 } | 748 } |
749 | 749 |
750 QuicWindowUpdateFrame::QuicWindowUpdateFrame(QuicStreamId stream_id, | 750 QuicWindowUpdateFrame::QuicWindowUpdateFrame(QuicStreamId stream_id, |
751 QuicStreamOffset byte_offset) | 751 QuicStreamOffset byte_offset) |
(...skipping 16 matching lines...) Expand all Loading... |
768 buffer_(buffer), | 768 buffer_(buffer), |
769 connection_id_length_(connection_id_length), | 769 connection_id_length_(connection_id_length), |
770 includes_version_(includes_version), | 770 includes_version_(includes_version), |
771 includes_path_id_(includes_path_id), | 771 includes_path_id_(includes_path_id), |
772 includes_diversification_nonce_(includes_diversification_nonce), | 772 includes_diversification_nonce_(includes_diversification_nonce), |
773 packet_number_length_(packet_number_length) {} | 773 packet_number_length_(packet_number_length) {} |
774 | 774 |
775 QuicEncryptedPacket::QuicEncryptedPacket(const char* buffer, size_t length) | 775 QuicEncryptedPacket::QuicEncryptedPacket(const char* buffer, size_t length) |
776 : QuicData(buffer, length) {} | 776 : QuicData(buffer, length) {} |
777 | 777 |
778 QuicEncryptedPacket::QuicEncryptedPacket(char* buffer, | 778 QuicEncryptedPacket::QuicEncryptedPacket(const char* buffer, |
779 size_t length, | 779 size_t length, |
780 bool owns_buffer) | 780 bool owns_buffer) |
781 : QuicData(buffer, length, owns_buffer) {} | 781 : QuicData(buffer, length, owns_buffer) {} |
782 | 782 |
783 QuicEncryptedPacket* QuicEncryptedPacket::Clone() const { | 783 QuicEncryptedPacket* QuicEncryptedPacket::Clone() const { |
784 char* buffer = new char[this->length()]; | 784 char* buffer = new char[this->length()]; |
785 memcpy(buffer, this->data(), this->length()); | 785 memcpy(buffer, this->data(), this->length()); |
786 return new QuicEncryptedPacket(buffer, this->length(), true); | 786 return new QuicEncryptedPacket(buffer, this->length(), true); |
787 } | 787 } |
788 | 788 |
789 ostream& operator<<(ostream& os, const QuicEncryptedPacket& s) { | 789 ostream& operator<<(ostream& os, const QuicEncryptedPacket& s) { |
790 os << s.length() << "-byte data"; | 790 os << s.length() << "-byte data"; |
791 return os; | 791 return os; |
792 } | 792 } |
793 | 793 |
794 QuicReceivedPacket::QuicReceivedPacket(const char* buffer, | 794 QuicReceivedPacket::QuicReceivedPacket(const char* buffer, |
795 size_t length, | 795 size_t length, |
796 QuicTime receipt_time) | 796 QuicTime receipt_time) |
797 : QuicEncryptedPacket(buffer, length), receipt_time_(receipt_time) {} | 797 : QuicEncryptedPacket(buffer, length), |
| 798 receipt_time_(receipt_time), |
| 799 ttl_(0) {} |
798 | 800 |
799 QuicReceivedPacket::QuicReceivedPacket(char* buffer, | 801 QuicReceivedPacket::QuicReceivedPacket(const char* buffer, |
800 size_t length, | 802 size_t length, |
801 QuicTime receipt_time, | 803 QuicTime receipt_time, |
802 bool owns_buffer) | 804 bool owns_buffer) |
803 : QuicEncryptedPacket(buffer, length, owns_buffer), | 805 : QuicEncryptedPacket(buffer, length, owns_buffer), |
804 receipt_time_(receipt_time) {} | 806 receipt_time_(receipt_time), |
| 807 ttl_(0) {} |
| 808 |
| 809 QuicReceivedPacket::QuicReceivedPacket(const char* buffer, |
| 810 size_t length, |
| 811 QuicTime receipt_time, |
| 812 bool owns_buffer, |
| 813 int ttl, |
| 814 bool ttl_valid) |
| 815 : QuicEncryptedPacket(buffer, length, owns_buffer), |
| 816 receipt_time_(receipt_time), |
| 817 ttl_(ttl_valid ? ttl : -1) {} |
805 | 818 |
806 QuicReceivedPacket* QuicReceivedPacket::Clone() const { | 819 QuicReceivedPacket* QuicReceivedPacket::Clone() const { |
807 char* buffer = new char[this->length()]; | 820 char* buffer = new char[this->length()]; |
808 memcpy(buffer, this->data(), this->length()); | 821 memcpy(buffer, this->data(), this->length()); |
809 return new QuicReceivedPacket(buffer, this->length(), receipt_time(), true); | 822 return new QuicReceivedPacket(buffer, this->length(), receipt_time(), true, |
| 823 ttl(), ttl() >= 0); |
810 } | 824 } |
811 | 825 |
812 ostream& operator<<(ostream& os, const QuicReceivedPacket& s) { | 826 ostream& operator<<(ostream& os, const QuicReceivedPacket& s) { |
813 os << s.length() << "-byte data"; | 827 os << s.length() << "-byte data"; |
814 return os; | 828 return os; |
815 } | 829 } |
816 | 830 |
817 StringPiece QuicPacket::AssociatedData(QuicVersion version) const { | 831 StringPiece QuicPacket::AssociatedData(QuicVersion version) const { |
818 return StringPiece( | 832 return StringPiece( |
819 data(), GetStartOfEncryptedData(version, connection_id_length_, | 833 data(), GetStartOfEncryptedData(version, connection_id_length_, |
(...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
916 is_unackable(false), | 930 is_unackable(false), |
917 has_crypto_handshake(has_crypto_handshake), | 931 has_crypto_handshake(has_crypto_handshake), |
918 num_padding_bytes(num_padding_bytes), | 932 num_padding_bytes(num_padding_bytes), |
919 retransmission(0) {} | 933 retransmission(0) {} |
920 | 934 |
921 TransmissionInfo::TransmissionInfo(const TransmissionInfo& other) = default; | 935 TransmissionInfo::TransmissionInfo(const TransmissionInfo& other) = default; |
922 | 936 |
923 TransmissionInfo::~TransmissionInfo() {} | 937 TransmissionInfo::~TransmissionInfo() {} |
924 | 938 |
925 } // namespace net | 939 } // namespace net |
OLD | NEW |