| Index: net/quic/core/quic_protocol.cc
|
| diff --git a/net/quic/core/quic_protocol.cc b/net/quic/core/quic_protocol.cc
|
| deleted file mode 100644
|
| index 1a27c0663b6ded979b11e342fa074e50a81ea882..0000000000000000000000000000000000000000
|
| --- a/net/quic/core/quic_protocol.cc
|
| +++ /dev/null
|
| @@ -1,296 +0,0 @@
|
| -// Copyright (c) 2012 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "net/quic/core/quic_protocol.h"
|
| -
|
| -#include "base/memory/ptr_util.h"
|
| -#include "base/strings/string_number_conversions.h"
|
| -#include "net/quic/core/quic_flags.h"
|
| -#include "net/quic/core/quic_utils.h"
|
| -#include "net/quic/core/quic_versions.h"
|
| -
|
| -using base::StringPiece;
|
| -using std::map;
|
| -using std::numeric_limits;
|
| -using std::ostream;
|
| -using std::string;
|
| -
|
| -namespace net {
|
| -
|
| -size_t GetPacketHeaderSize(QuicVersion version,
|
| - const QuicPacketHeader& header) {
|
| - return GetPacketHeaderSize(version, header.public_header.connection_id_length,
|
| - header.public_header.version_flag,
|
| - header.public_header.multipath_flag,
|
| - header.public_header.nonce != nullptr,
|
| - header.public_header.packet_number_length);
|
| -}
|
| -
|
| -size_t GetPacketHeaderSize(QuicVersion version,
|
| - QuicConnectionIdLength connection_id_length,
|
| - bool include_version,
|
| - bool include_path_id,
|
| - bool include_diversification_nonce,
|
| - QuicPacketNumberLength packet_number_length) {
|
| - return kPublicFlagsSize + connection_id_length +
|
| - (include_version ? kQuicVersionSize : 0) +
|
| - (include_path_id ? kQuicPathIdSize : 0) + packet_number_length +
|
| - (include_diversification_nonce ? kDiversificationNonceSize : 0);
|
| -}
|
| -
|
| -size_t GetStartOfEncryptedData(QuicVersion version,
|
| - const QuicPacketHeader& header) {
|
| - return GetPacketHeaderSize(version, header);
|
| -}
|
| -
|
| -size_t GetStartOfEncryptedData(QuicVersion version,
|
| - QuicConnectionIdLength connection_id_length,
|
| - bool include_version,
|
| - bool include_path_id,
|
| - bool include_diversification_nonce,
|
| - QuicPacketNumberLength packet_number_length) {
|
| - // Encryption starts before private flags.
|
| - return GetPacketHeaderSize(version, connection_id_length, include_version,
|
| - include_path_id, include_diversification_nonce,
|
| - packet_number_length);
|
| -}
|
| -
|
| -QuicPacketPublicHeader::QuicPacketPublicHeader()
|
| - : connection_id(0),
|
| - connection_id_length(PACKET_8BYTE_CONNECTION_ID),
|
| - multipath_flag(false),
|
| - reset_flag(false),
|
| - version_flag(false),
|
| - packet_number_length(PACKET_6BYTE_PACKET_NUMBER),
|
| - nonce(nullptr) {}
|
| -
|
| -QuicPacketPublicHeader::QuicPacketPublicHeader(
|
| - const QuicPacketPublicHeader& other) = default;
|
| -
|
| -QuicPacketPublicHeader::~QuicPacketPublicHeader() {}
|
| -
|
| -QuicPacketHeader::QuicPacketHeader()
|
| - : packet_number(0), path_id(kDefaultPathId) {}
|
| -
|
| -QuicPacketHeader::QuicPacketHeader(const QuicPacketPublicHeader& header)
|
| - : public_header(header), packet_number(0), path_id(kDefaultPathId) {}
|
| -
|
| -QuicPacketHeader::QuicPacketHeader(const QuicPacketHeader& other) = default;
|
| -
|
| -QuicPublicResetPacket::QuicPublicResetPacket()
|
| - : nonce_proof(0), rejected_packet_number(0) {}
|
| -
|
| -QuicPublicResetPacket::QuicPublicResetPacket(
|
| - const QuicPacketPublicHeader& header)
|
| - : public_header(header), nonce_proof(0), rejected_packet_number(0) {}
|
| -
|
| -ostream& operator<<(ostream& os, const QuicPacketHeader& header) {
|
| - os << "{ connection_id: " << header.public_header.connection_id
|
| - << ", connection_id_length: " << header.public_header.connection_id_length
|
| - << ", packet_number_length: " << header.public_header.packet_number_length
|
| - << ", multipath_flag: " << header.public_header.multipath_flag
|
| - << ", reset_flag: " << header.public_header.reset_flag
|
| - << ", version_flag: " << header.public_header.version_flag;
|
| - if (header.public_header.version_flag) {
|
| - os << ", version:";
|
| - for (size_t i = 0; i < header.public_header.versions.size(); ++i) {
|
| - os << " ";
|
| - os << QuicVersionToString(header.public_header.versions[i]);
|
| - }
|
| - }
|
| - if (header.public_header.nonce != nullptr) {
|
| - os << ", diversification_nonce: "
|
| - << QuicUtils::HexEncode(StringPiece(header.public_header.nonce->data(),
|
| - header.public_header.nonce->size()));
|
| - }
|
| - os << ", path_id: " << static_cast<int>(header.path_id)
|
| - << ", packet_number: " << header.packet_number << " }\n";
|
| - return os;
|
| -}
|
| -
|
| -QuicData::QuicData(const char* buffer, size_t length)
|
| - : buffer_(buffer), length_(length), owns_buffer_(false) {}
|
| -
|
| -QuicData::QuicData(const char* buffer, size_t length, bool owns_buffer)
|
| - : buffer_(buffer), length_(length), owns_buffer_(owns_buffer) {}
|
| -
|
| -QuicData::~QuicData() {
|
| - if (owns_buffer_) {
|
| - delete[] const_cast<char*>(buffer_);
|
| - }
|
| -}
|
| -
|
| -QuicPacket::QuicPacket(char* buffer,
|
| - size_t length,
|
| - bool owns_buffer,
|
| - QuicConnectionIdLength connection_id_length,
|
| - bool includes_version,
|
| - bool includes_path_id,
|
| - bool includes_diversification_nonce,
|
| - QuicPacketNumberLength packet_number_length)
|
| - : QuicData(buffer, length, owns_buffer),
|
| - buffer_(buffer),
|
| - connection_id_length_(connection_id_length),
|
| - includes_version_(includes_version),
|
| - includes_path_id_(includes_path_id),
|
| - includes_diversification_nonce_(includes_diversification_nonce),
|
| - packet_number_length_(packet_number_length) {}
|
| -
|
| -QuicEncryptedPacket::QuicEncryptedPacket(const char* buffer, size_t length)
|
| - : QuicData(buffer, length) {}
|
| -
|
| -QuicEncryptedPacket::QuicEncryptedPacket(const char* buffer,
|
| - size_t length,
|
| - bool owns_buffer)
|
| - : QuicData(buffer, length, owns_buffer) {}
|
| -
|
| -std::unique_ptr<QuicEncryptedPacket> QuicEncryptedPacket::Clone() const {
|
| - char* buffer = new char[this->length()];
|
| - memcpy(buffer, this->data(), this->length());
|
| - return base::MakeUnique<QuicEncryptedPacket>(buffer, this->length(), true);
|
| -}
|
| -
|
| -ostream& operator<<(ostream& os, const QuicEncryptedPacket& s) {
|
| - os << s.length() << "-byte data";
|
| - return os;
|
| -}
|
| -
|
| -QuicReceivedPacket::QuicReceivedPacket(const char* buffer,
|
| - size_t length,
|
| - QuicTime receipt_time)
|
| - : QuicEncryptedPacket(buffer, length),
|
| - receipt_time_(receipt_time),
|
| - ttl_(0) {}
|
| -
|
| -QuicReceivedPacket::QuicReceivedPacket(const char* buffer,
|
| - size_t length,
|
| - QuicTime receipt_time,
|
| - bool owns_buffer)
|
| - : QuicEncryptedPacket(buffer, length, owns_buffer),
|
| - receipt_time_(receipt_time),
|
| - ttl_(0) {}
|
| -
|
| -QuicReceivedPacket::QuicReceivedPacket(const char* buffer,
|
| - size_t length,
|
| - QuicTime receipt_time,
|
| - bool owns_buffer,
|
| - int ttl,
|
| - bool ttl_valid)
|
| - : QuicEncryptedPacket(buffer, length, owns_buffer),
|
| - receipt_time_(receipt_time),
|
| - ttl_(ttl_valid ? ttl : -1) {}
|
| -
|
| -std::unique_ptr<QuicReceivedPacket> QuicReceivedPacket::Clone() const {
|
| - char* buffer = new char[this->length()];
|
| - memcpy(buffer, this->data(), this->length());
|
| - return base::MakeUnique<QuicReceivedPacket>(
|
| - buffer, this->length(), receipt_time(), true, ttl(), ttl() >= 0);
|
| -}
|
| -
|
| -ostream& operator<<(ostream& os, const QuicReceivedPacket& s) {
|
| - os << s.length() << "-byte data";
|
| - return os;
|
| -}
|
| -
|
| -StringPiece QuicPacket::AssociatedData(QuicVersion version) const {
|
| - return StringPiece(
|
| - data(), GetStartOfEncryptedData(version, connection_id_length_,
|
| - includes_version_, includes_path_id_,
|
| - includes_diversification_nonce_,
|
| - packet_number_length_));
|
| -}
|
| -
|
| -StringPiece QuicPacket::Plaintext(QuicVersion version) const {
|
| - const size_t start_of_encrypted_data = GetStartOfEncryptedData(
|
| - version, connection_id_length_, includes_version_, includes_path_id_,
|
| - includes_diversification_nonce_, packet_number_length_);
|
| - return StringPiece(data() + start_of_encrypted_data,
|
| - length() - start_of_encrypted_data);
|
| -}
|
| -
|
| -AckListenerWrapper::AckListenerWrapper(QuicAckListenerInterface* listener,
|
| - QuicPacketLength data_length)
|
| - : ack_listener(listener), length(data_length) {
|
| - DCHECK(listener != nullptr);
|
| -}
|
| -
|
| -AckListenerWrapper::AckListenerWrapper(const AckListenerWrapper& other) =
|
| - default;
|
| -
|
| -AckListenerWrapper::~AckListenerWrapper() {}
|
| -
|
| -SerializedPacket::SerializedPacket(QuicPathId path_id,
|
| - QuicPacketNumber packet_number,
|
| - QuicPacketNumberLength packet_number_length,
|
| - const char* encrypted_buffer,
|
| - QuicPacketLength encrypted_length,
|
| - bool has_ack,
|
| - bool has_stop_waiting)
|
| - : encrypted_buffer(encrypted_buffer),
|
| - encrypted_length(encrypted_length),
|
| - has_crypto_handshake(NOT_HANDSHAKE),
|
| - num_padding_bytes(0),
|
| - path_id(path_id),
|
| - packet_number(packet_number),
|
| - packet_number_length(packet_number_length),
|
| - encryption_level(ENCRYPTION_NONE),
|
| - has_ack(has_ack),
|
| - has_stop_waiting(has_stop_waiting),
|
| - transmission_type(NOT_RETRANSMISSION),
|
| - original_path_id(kInvalidPathId),
|
| - original_packet_number(0) {}
|
| -
|
| -SerializedPacket::SerializedPacket(const SerializedPacket& other) = default;
|
| -
|
| -SerializedPacket::~SerializedPacket() {}
|
| -
|
| -TransmissionInfo::TransmissionInfo()
|
| - : encryption_level(ENCRYPTION_NONE),
|
| - packet_number_length(PACKET_1BYTE_PACKET_NUMBER),
|
| - bytes_sent(0),
|
| - sent_time(QuicTime::Zero()),
|
| - transmission_type(NOT_RETRANSMISSION),
|
| - in_flight(false),
|
| - is_unackable(false),
|
| - has_crypto_handshake(false),
|
| - num_padding_bytes(0),
|
| - retransmission(0) {}
|
| -
|
| -void ClearSerializedPacket(SerializedPacket* serialized_packet) {
|
| - if (!serialized_packet->retransmittable_frames.empty()) {
|
| - DeleteFrames(&serialized_packet->retransmittable_frames);
|
| - }
|
| - serialized_packet->encrypted_buffer = nullptr;
|
| - serialized_packet->encrypted_length = 0;
|
| -}
|
| -
|
| -char* CopyBuffer(const SerializedPacket& packet) {
|
| - char* dst_buffer = new char[packet.encrypted_length];
|
| - memcpy(dst_buffer, packet.encrypted_buffer, packet.encrypted_length);
|
| - return dst_buffer;
|
| -}
|
| -
|
| -TransmissionInfo::TransmissionInfo(EncryptionLevel level,
|
| - QuicPacketNumberLength packet_number_length,
|
| - TransmissionType transmission_type,
|
| - QuicTime sent_time,
|
| - QuicPacketLength bytes_sent,
|
| - bool has_crypto_handshake,
|
| - int num_padding_bytes)
|
| - : encryption_level(level),
|
| - packet_number_length(packet_number_length),
|
| - bytes_sent(bytes_sent),
|
| - sent_time(sent_time),
|
| - transmission_type(transmission_type),
|
| - in_flight(false),
|
| - is_unackable(false),
|
| - has_crypto_handshake(has_crypto_handshake),
|
| - num_padding_bytes(num_padding_bytes),
|
| - retransmission(0) {}
|
| -
|
| -TransmissionInfo::TransmissionInfo(const TransmissionInfo& other) = default;
|
| -
|
| -TransmissionInfo::~TransmissionInfo() {}
|
| -
|
| -} // namespace net
|
|
|