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/quic_protocol.h" | 5 #include "net/quic/quic_protocol.h" |
6 | 6 |
7 #include "base/stl_util.h" | 7 #include "base/stl_util.h" |
8 #include "net/quic/quic_utils.h" | 8 #include "net/quic/quic_utils.h" |
9 | 9 |
10 using base::StringPiece; | 10 using base::StringPiece; |
(...skipping 253 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
264 largest_observed(0), | 264 largest_observed(0), |
265 delta_time_largest_observed(QuicTime::Delta::Infinite()), | 265 delta_time_largest_observed(QuicTime::Delta::Infinite()), |
266 is_truncated(false) {} | 266 is_truncated(false) {} |
267 | 267 |
268 QuicAckFrame::~QuicAckFrame() {} | 268 QuicAckFrame::~QuicAckFrame() {} |
269 | 269 |
270 CongestionFeedbackMessageTCP::CongestionFeedbackMessageTCP() | 270 CongestionFeedbackMessageTCP::CongestionFeedbackMessageTCP() |
271 : receive_window(0) { | 271 : receive_window(0) { |
272 } | 272 } |
273 | 273 |
274 CongestionFeedbackMessageInterArrival::CongestionFeedbackMessageInterArrival() { | 274 CongestionFeedbackMessageTimestamp::CongestionFeedbackMessageTimestamp() { |
275 } | 275 } |
276 | 276 |
277 CongestionFeedbackMessageInterArrival:: | 277 CongestionFeedbackMessageTimestamp::~CongestionFeedbackMessageTimestamp() {} |
278 ~CongestionFeedbackMessageInterArrival() {} | |
279 | 278 |
280 QuicCongestionFeedbackFrame::QuicCongestionFeedbackFrame() : type(kTCP) {} | 279 QuicCongestionFeedbackFrame::QuicCongestionFeedbackFrame() : type(kTCP) {} |
281 | 280 |
282 QuicCongestionFeedbackFrame::~QuicCongestionFeedbackFrame() {} | 281 QuicCongestionFeedbackFrame::~QuicCongestionFeedbackFrame() {} |
283 | 282 |
284 QuicRstStreamErrorCode AdjustErrorForVersion( | 283 QuicRstStreamErrorCode AdjustErrorForVersion( |
285 QuicRstStreamErrorCode error_code, | 284 QuicRstStreamErrorCode error_code, |
286 QuicVersion version) { | 285 QuicVersion version) { |
287 switch (error_code) { | 286 switch (error_code) { |
288 case QUIC_RST_FLOW_CONTROL_ACCOUNTING: | 287 case QUIC_RST_FLOW_CONTROL_ACCOUNTING: |
(...skipping 206 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
495 << "data { " | 494 << "data { " |
496 << QuicUtils::StringToHexASCIIDump(*(stream_frame.GetDataAsString())) | 495 << QuicUtils::StringToHexASCIIDump(*(stream_frame.GetDataAsString())) |
497 << " }\n"; | 496 << " }\n"; |
498 return os; | 497 return os; |
499 } | 498 } |
500 | 499 |
501 ostream& operator<<(ostream& os, | 500 ostream& operator<<(ostream& os, |
502 const QuicCongestionFeedbackFrame& congestion_frame) { | 501 const QuicCongestionFeedbackFrame& congestion_frame) { |
503 os << "type: " << congestion_frame.type; | 502 os << "type: " << congestion_frame.type; |
504 switch (congestion_frame.type) { | 503 switch (congestion_frame.type) { |
505 case kInterArrival: { | 504 case kTimestamp: { |
506 const CongestionFeedbackMessageInterArrival& inter_arrival = | 505 const CongestionFeedbackMessageTimestamp& timestamp = |
507 congestion_frame.inter_arrival; | 506 congestion_frame.timestamp; |
508 os << " received packets: [ "; | 507 os << " received packets: [ "; |
509 for (TimeMap::const_iterator it = | 508 for (TimeMap::const_iterator it = timestamp.received_packet_times.begin(); |
510 inter_arrival.received_packet_times.begin(); | 509 it != timestamp.received_packet_times.end(); ++it) { |
511 it != inter_arrival.received_packet_times.end(); ++it) { | |
512 os << it->first << "@" << it->second.ToDebuggingValue() << " "; | 510 os << it->first << "@" << it->second.ToDebuggingValue() << " "; |
513 } | 511 } |
514 os << "]"; | 512 os << "]"; |
515 break; | 513 break; |
516 } | 514 } |
517 case kTCP: { | 515 case kTCP: { |
518 const CongestionFeedbackMessageTCP& tcp = congestion_frame.tcp; | 516 const CongestionFeedbackMessageTCP& tcp = congestion_frame.tcp; |
519 os << " receive_window: " << tcp.receive_window; | 517 os << " receive_window: " << tcp.receive_window; |
520 break; | 518 break; |
521 } | 519 } |
(...skipping 240 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
762 sent_time(QuicTime::Zero()), | 760 sent_time(QuicTime::Zero()), |
763 bytes_sent(0), | 761 bytes_sent(0), |
764 nack_count(0), | 762 nack_count(0), |
765 transmission_type(transmission_type), | 763 transmission_type(transmission_type), |
766 all_transmissions(all_transmissions), | 764 all_transmissions(all_transmissions), |
767 in_flight(false) { | 765 in_flight(false) { |
768 all_transmissions->insert(sequence_number); | 766 all_transmissions->insert(sequence_number); |
769 } | 767 } |
770 | 768 |
771 } // namespace net | 769 } // namespace net |
OLD | NEW |