Index: net/quic/quic_protocol.cc |
diff --git a/net/quic/quic_protocol.cc b/net/quic/quic_protocol.cc |
index facb15fe010d0c2b4165cc8158c6634f749de19c..e5f89de9b966f9c4ff8df9fb1890f67ce15ba48d 100644 |
--- a/net/quic/quic_protocol.cc |
+++ b/net/quic/quic_protocol.cc |
@@ -27,8 +27,9 @@ size_t GetPacketHeaderSize(QuicConnectionIdLength connection_id_length, |
QuicSequenceNumberLength sequence_number_length, |
InFecGroup is_in_fec_group) { |
return kPublicFlagsSize + connection_id_length + |
- (include_version ? kQuicVersionSize : 0) + sequence_number_length + |
- kPrivateFlagsSize + (is_in_fec_group == IN_FEC_GROUP ? kFecGroupSize : 0); |
+ (include_version ? kQuicVersionSize : 0) + sequence_number_length + |
+ kPrivateFlagsSize + |
+ (is_in_fec_group == IN_FEC_GROUP ? kFecGroupSize : 0); |
} |
size_t GetStartOfFecProtectedData( |
@@ -49,7 +50,8 @@ size_t GetStartOfEncryptedData( |
return GetPacketHeaderSize(connection_id_length, |
include_version, |
sequence_number_length, |
- NOT_IN_FEC_GROUP) - kPrivateFlagsSize; |
+ NOT_IN_FEC_GROUP) - |
+ kPrivateFlagsSize; |
} |
QuicPacketPublicHeader::QuicPacketPublicHeader() |
@@ -70,7 +72,8 @@ QuicPacketPublicHeader::QuicPacketPublicHeader( |
versions(other.versions) { |
} |
-QuicPacketPublicHeader::~QuicPacketPublicHeader() {} |
+QuicPacketPublicHeader::~QuicPacketPublicHeader() { |
+} |
QuicPacketHeader::QuicPacketHeader() |
: fec_flag(false), |
@@ -92,20 +95,17 @@ QuicPacketHeader::QuicPacketHeader(const QuicPacketPublicHeader& header) |
} |
QuicPublicResetPacket::QuicPublicResetPacket() |
- : nonce_proof(0), |
- rejected_sequence_number(0) {} |
+ : nonce_proof(0), rejected_sequence_number(0) { |
+} |
QuicPublicResetPacket::QuicPublicResetPacket( |
const QuicPacketPublicHeader& header) |
- : public_header(header), |
- nonce_proof(0), |
- rejected_sequence_number(0) {} |
+ : public_header(header), nonce_proof(0), rejected_sequence_number(0) { |
+} |
QuicStreamFrame::QuicStreamFrame() |
- : stream_id(0), |
- fin(false), |
- offset(0), |
- notifier(NULL) {} |
+ : stream_id(0), fin(false), offset(0), notifier(NULL) { |
+} |
QuicStreamFrame::QuicStreamFrame(const QuicStreamFrame& frame) |
: stream_id(frame.stream_id), |
@@ -138,10 +138,8 @@ string* QuicStreamFrame::GetDataAsString() const { |
} |
uint32 MakeQuicTag(char a, char b, char c, char d) { |
- return static_cast<uint32>(a) | |
- static_cast<uint32>(b) << 8 | |
- static_cast<uint32>(c) << 16 | |
- static_cast<uint32>(d) << 24; |
+ return static_cast<uint32>(a) | static_cast<uint32>(b) << 8 | |
+ static_cast<uint32>(c) << 16 | static_cast<uint32>(d) << 24; |
} |
QuicVersionVector QuicSupportedVersions() { |
@@ -183,8 +181,8 @@ QuicVersion QuicTagToQuicVersion(const QuicTag version_tag) { |
} |
#define RETURN_STRING_LITERAL(x) \ |
-case x: \ |
-return #x |
+ case x: \ |
+ return #x |
string QuicVersionToString(const QuicVersion version) { |
switch (version) { |
@@ -226,7 +224,7 @@ ostream& operator<<(ostream& os, const QuicPacketHeader& header) { |
<< ", entropy hash: " << static_cast<int>(header.entropy_hash) |
<< ", sequence_number: " << header.packet_sequence_number |
<< ", is_in_fec_group:" << header.is_in_fec_group |
- << ", fec_group: " << header.fec_group<< "}\n"; |
+ << ", fec_group: " << header.fec_group << "}\n"; |
return os; |
} |
@@ -234,14 +232,16 @@ ReceivedPacketInfo::ReceivedPacketInfo() |
: entropy_hash(0), |
largest_observed(0), |
delta_time_largest_observed(QuicTime::Delta::Infinite()), |
- is_truncated(false) {} |
+ is_truncated(false) { |
+} |
-ReceivedPacketInfo::~ReceivedPacketInfo() {} |
+ReceivedPacketInfo::~ReceivedPacketInfo() { |
+} |
bool IsAwaitingPacket(const ReceivedPacketInfo& received_info, |
QuicPacketSequenceNumber sequence_number) { |
return sequence_number > received_info.largest_observed || |
- ContainsKey(received_info.missing_packets, sequence_number); |
+ ContainsKey(received_info.missing_packets, sequence_number); |
} |
void InsertMissingPacketsBetween(ReceivedPacketInfo* received_info, |
@@ -253,13 +253,14 @@ void InsertMissingPacketsBetween(ReceivedPacketInfo* received_info, |
} |
QuicStopWaitingFrame::QuicStopWaitingFrame() |
- : entropy_hash(0), |
- least_unacked(0) { |
+ : entropy_hash(0), least_unacked(0) { |
} |
-QuicStopWaitingFrame::~QuicStopWaitingFrame() {} |
+QuicStopWaitingFrame::~QuicStopWaitingFrame() { |
+} |
-QuicAckFrame::QuicAckFrame() {} |
+QuicAckFrame::QuicAckFrame() { |
+} |
CongestionFeedbackMessageTCP::CongestionFeedbackMessageTCP() |
: receive_window(0) { |
@@ -269,15 +270,17 @@ CongestionFeedbackMessageInterArrival::CongestionFeedbackMessageInterArrival() { |
} |
CongestionFeedbackMessageInterArrival:: |
- ~CongestionFeedbackMessageInterArrival() {} |
+ ~CongestionFeedbackMessageInterArrival() { |
+} |
-QuicCongestionFeedbackFrame::QuicCongestionFeedbackFrame() : type(kTCP) {} |
+QuicCongestionFeedbackFrame::QuicCongestionFeedbackFrame() : type(kTCP) { |
+} |
-QuicCongestionFeedbackFrame::~QuicCongestionFeedbackFrame() {} |
+QuicCongestionFeedbackFrame::~QuicCongestionFeedbackFrame() { |
+} |
-QuicRstStreamErrorCode AdjustErrorForVersion( |
- QuicRstStreamErrorCode error_code, |
- QuicVersion version) { |
+QuicRstStreamErrorCode AdjustErrorForVersion(QuicRstStreamErrorCode error_code, |
+ QuicVersion version) { |
switch (error_code) { |
case QUIC_RST_FLOW_CONTROL_ACCOUNTING: |
if (version <= QUIC_VERSION_17) { |
@@ -291,16 +294,13 @@ QuicRstStreamErrorCode AdjustErrorForVersion( |
} |
QuicRstStreamFrame::QuicRstStreamFrame() |
- : stream_id(0), |
- error_code(QUIC_STREAM_NO_ERROR) { |
+ : stream_id(0), error_code(QUIC_STREAM_NO_ERROR) { |
} |
QuicRstStreamFrame::QuicRstStreamFrame(QuicStreamId stream_id, |
QuicRstStreamErrorCode error_code, |
QuicStreamOffset bytes_written) |
- : stream_id(stream_id), |
- error_code(error_code), |
- byte_offset(bytes_written) { |
+ : stream_id(stream_id), error_code(error_code), byte_offset(bytes_written) { |
DCHECK_LE(error_code, numeric_limits<uint8>::max()); |
} |
@@ -308,64 +308,54 @@ QuicConnectionCloseFrame::QuicConnectionCloseFrame() |
: error_code(QUIC_NO_ERROR) { |
} |
-QuicFrame::QuicFrame() {} |
+QuicFrame::QuicFrame() { |
+} |
QuicFrame::QuicFrame(QuicPaddingFrame* padding_frame) |
- : type(PADDING_FRAME), |
- padding_frame(padding_frame) { |
+ : type(PADDING_FRAME), padding_frame(padding_frame) { |
} |
QuicFrame::QuicFrame(QuicStreamFrame* stream_frame) |
- : type(STREAM_FRAME), |
- stream_frame(stream_frame) { |
+ : type(STREAM_FRAME), stream_frame(stream_frame) { |
} |
-QuicFrame::QuicFrame(QuicAckFrame* frame) |
- : type(ACK_FRAME), |
- ack_frame(frame) { |
+QuicFrame::QuicFrame(QuicAckFrame* frame) : type(ACK_FRAME), ack_frame(frame) { |
} |
QuicFrame::QuicFrame(QuicCongestionFeedbackFrame* frame) |
- : type(CONGESTION_FEEDBACK_FRAME), |
- congestion_feedback_frame(frame) { |
+ : type(CONGESTION_FEEDBACK_FRAME), congestion_feedback_frame(frame) { |
} |
QuicFrame::QuicFrame(QuicStopWaitingFrame* frame) |
- : type(STOP_WAITING_FRAME), |
- stop_waiting_frame(frame) { |
+ : type(STOP_WAITING_FRAME), stop_waiting_frame(frame) { |
} |
QuicFrame::QuicFrame(QuicPingFrame* frame) |
- : type(PING_FRAME), |
- ping_frame(frame) { |
+ : type(PING_FRAME), ping_frame(frame) { |
} |
QuicFrame::QuicFrame(QuicRstStreamFrame* frame) |
- : type(RST_STREAM_FRAME), |
- rst_stream_frame(frame) { |
+ : type(RST_STREAM_FRAME), rst_stream_frame(frame) { |
} |
QuicFrame::QuicFrame(QuicConnectionCloseFrame* frame) |
- : type(CONNECTION_CLOSE_FRAME), |
- connection_close_frame(frame) { |
+ : type(CONNECTION_CLOSE_FRAME), connection_close_frame(frame) { |
} |
QuicFrame::QuicFrame(QuicGoAwayFrame* frame) |
- : type(GOAWAY_FRAME), |
- goaway_frame(frame) { |
+ : type(GOAWAY_FRAME), goaway_frame(frame) { |
} |
QuicFrame::QuicFrame(QuicWindowUpdateFrame* frame) |
- : type(WINDOW_UPDATE_FRAME), |
- window_update_frame(frame) { |
+ : type(WINDOW_UPDATE_FRAME), window_update_frame(frame) { |
} |
QuicFrame::QuicFrame(QuicBlockedFrame* frame) |
- : type(BLOCKED_FRAME), |
- blocked_frame(frame) { |
+ : type(BLOCKED_FRAME), blocked_frame(frame) { |
} |
-QuicFecData::QuicFecData() : fec_group(0) {} |
+QuicFecData::QuicFecData() : fec_group(0) { |
+} |
ostream& operator<<(ostream& os, const QuicStopWaitingFrame& sent_info) { |
os << "entropy_hash: " << static_cast<int>(sent_info.entropy_hash) |
@@ -382,13 +372,15 @@ ostream& operator<<(ostream& os, const ReceivedPacketInfo& received_info) { |
<< " missing_packets: [ "; |
for (SequenceNumberSet::const_iterator it = |
received_info.missing_packets.begin(); |
- it != received_info.missing_packets.end(); ++it) { |
+ it != received_info.missing_packets.end(); |
+ ++it) { |
os << *it << " "; |
} |
os << " ] revived_packets: [ "; |
for (SequenceNumberSet::const_iterator it = |
received_info.revived_packets.begin(); |
- it != received_info.revived_packets.end(); ++it) { |
+ it != received_info.revived_packets.end(); |
+ ++it) { |
os << *it << " "; |
} |
os << " ]"; |
@@ -397,7 +389,7 @@ ostream& operator<<(ostream& os, const ReceivedPacketInfo& received_info) { |
ostream& operator<<(ostream& os, const QuicFrame& frame) { |
switch (frame.type) { |
- case PADDING_FRAME: { |
+ case PADDING_FRAME: { |
os << "type { PADDING_FRAME } "; |
break; |
} |
@@ -506,7 +498,8 @@ ostream& operator<<(ostream& os, |
os << " received packets: [ "; |
for (TimeMap::const_iterator it = |
inter_arrival.received_packet_times.begin(); |
- it != inter_arrival.received_packet_times.end(); ++it) { |
+ it != inter_arrival.received_packet_times.end(); |
+ ++it) { |
os << it->first << "@" << it->second.ToDebuggingValue() << " "; |
} |
os << "]"; |
@@ -531,8 +524,7 @@ CongestionFeedbackMessageFixRate::CongestionFeedbackMessageFixRate() |
} |
QuicGoAwayFrame::QuicGoAwayFrame() |
- : error_code(QUIC_NO_ERROR), |
- last_good_stream_id(0) { |
+ : error_code(QUIC_NO_ERROR), last_good_stream_id(0) { |
} |
QuicGoAwayFrame::QuicGoAwayFrame(QuicErrorCode error_code, |
@@ -544,34 +536,28 @@ QuicGoAwayFrame::QuicGoAwayFrame(QuicErrorCode error_code, |
DCHECK_LE(error_code, numeric_limits<uint8>::max()); |
} |
-QuicData::QuicData(const char* buffer, |
- size_t length) |
- : buffer_(buffer), |
- length_(length), |
- owns_buffer_(false) { |
+QuicData::QuicData(const char* buffer, size_t length) |
+ : buffer_(buffer), length_(length), owns_buffer_(false) { |
} |
-QuicData::QuicData(char* buffer, |
- size_t length, |
- bool owns_buffer) |
- : buffer_(buffer), |
- length_(length), |
- owns_buffer_(owns_buffer) { |
+QuicData::QuicData(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_); |
+ delete[] const_cast<char*>(buffer_); |
} |
} |
QuicWindowUpdateFrame::QuicWindowUpdateFrame(QuicStreamId stream_id, |
QuicStreamOffset byte_offset) |
- : stream_id(stream_id), |
- byte_offset(byte_offset) {} |
+ : stream_id(stream_id), byte_offset(byte_offset) { |
+} |
QuicBlockedFrame::QuicBlockedFrame(QuicStreamId stream_id) |
- : stream_id(stream_id) {} |
+ : stream_id(stream_id) { |
+} |
QuicPacket::QuicPacket(char* buffer, |
size_t length, |
@@ -588,15 +574,14 @@ QuicPacket::QuicPacket(char* buffer, |
sequence_number_length_(sequence_number_length) { |
} |
-QuicEncryptedPacket::QuicEncryptedPacket(const char* buffer, |
- size_t length) |
+QuicEncryptedPacket::QuicEncryptedPacket(const char* buffer, size_t length) |
: QuicData(buffer, length) { |
} |
QuicEncryptedPacket::QuicEncryptedPacket(char* buffer, |
size_t length, |
bool owns_buffer) |
- : QuicData(buffer, length, owns_buffer) { |
+ : QuicData(buffer, length, owns_buffer) { |
} |
StringPiece QuicPacket::FecProtectedData() const { |
@@ -610,19 +595,19 @@ StringPiece QuicPacket::AssociatedData() const { |
data() + kStartOfHashData, |
GetStartOfEncryptedData( |
connection_id_length_, includes_version_, sequence_number_length_) - |
- kStartOfHashData); |
+ kStartOfHashData); |
} |
StringPiece QuicPacket::BeforePlaintext() const { |
- return StringPiece(data(), GetStartOfEncryptedData(connection_id_length_, |
- includes_version_, |
- sequence_number_length_)); |
+ return StringPiece( |
+ data(), |
+ GetStartOfEncryptedData( |
+ connection_id_length_, includes_version_, sequence_number_length_)); |
} |
StringPiece QuicPacket::Plaintext() const { |
- const size_t start_of_encrypted_data = |
- GetStartOfEncryptedData( |
- connection_id_length_, includes_version_, sequence_number_length_); |
+ const size_t start_of_encrypted_data = GetStartOfEncryptedData( |
+ connection_id_length_, includes_version_, sequence_number_length_); |
return StringPiece(data() + start_of_encrypted_data, |
length() - start_of_encrypted_data); |
} |
@@ -720,7 +705,8 @@ SerializedPacket::SerializedPacket( |
retransmittable_frames(retransmittable_frames) { |
} |
-SerializedPacket::~SerializedPacket() {} |
+SerializedPacket::~SerializedPacket() { |
+} |
QuicEncryptedPacket* QuicEncryptedPacket::Clone() const { |
char* buffer = new char[this->length()]; |
@@ -733,10 +719,8 @@ ostream& operator<<(ostream& os, const QuicEncryptedPacket& s) { |
return os; |
} |
-QuicConsumedData::QuicConsumedData(size_t bytes_consumed, |
- bool fin_consumed) |
- : bytes_consumed(bytes_consumed), |
- fin_consumed(fin_consumed) { |
+QuicConsumedData::QuicConsumedData(size_t bytes_consumed, bool fin_consumed) |
+ : bytes_consumed(bytes_consumed), fin_consumed(fin_consumed) { |
} |
ostream& operator<<(ostream& os, const QuicConsumedData& s) { |
@@ -745,15 +729,11 @@ ostream& operator<<(ostream& os, const QuicConsumedData& s) { |
return os; |
} |
-WriteResult::WriteResult() |
- : status(WRITE_STATUS_ERROR), |
- bytes_written(0) { |
+WriteResult::WriteResult() : status(WRITE_STATUS_ERROR), bytes_written(0) { |
} |
-WriteResult::WriteResult(WriteStatus status, |
- int bytes_written_or_error_code) |
- : status(status), |
- bytes_written(bytes_written_or_error_code) { |
+WriteResult::WriteResult(WriteStatus status, int bytes_written_or_error_code) |
+ : status(status), bytes_written(bytes_written_or_error_code) { |
} |
} // namespace net |