| 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 <string.h> | 7 #include <string.h> |
| 8 #include <sys/types.h> | 8 #include <sys/types.h> |
| 9 | 9 |
| 10 #include <algorithm> | 10 #include <algorithm> |
| (...skipping 911 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 922 const QuicConnectionCloseFrame& frame) { | 922 const QuicConnectionCloseFrame& frame) { |
| 923 DCHECK(connected_); | 923 DCHECK(connected_); |
| 924 if (debug_visitor_ != nullptr) { | 924 if (debug_visitor_ != nullptr) { |
| 925 debug_visitor_->OnConnectionCloseFrame(frame); | 925 debug_visitor_->OnConnectionCloseFrame(frame); |
| 926 } | 926 } |
| 927 DVLOG(1) << ENDPOINT | 927 DVLOG(1) << ENDPOINT |
| 928 << "Received ConnectionClose for connection: " << connection_id() | 928 << "Received ConnectionClose for connection: " << connection_id() |
| 929 << ", with error: " << QuicUtils::ErrorToString(frame.error_code) | 929 << ", with error: " << QuicUtils::ErrorToString(frame.error_code) |
| 930 << " (" << frame.error_details << ")"; | 930 << " (" << frame.error_details << ")"; |
| 931 if (frame.error_code == QUIC_BAD_MULTIPATH_FLAG) { | 931 if (frame.error_code == QUIC_BAD_MULTIPATH_FLAG) { |
| 932 LOG(ERROR) << " quic_version: " << version() | 932 LOG(ERROR) << "Unexpected QUIC_BAD_MULTIPATH_FLAG error." |
| 933 << " last_received_header: " << last_header_ | 933 << " last_received_header: " << last_header_ |
| 934 << " encryption_level: " << encryption_level_; | 934 << " encryption_level: " << encryption_level_; |
| 935 } | 935 } |
| 936 TearDownLocalConnectionState(frame.error_code, frame.error_details, | 936 TearDownLocalConnectionState(frame.error_code, frame.error_details, |
| 937 ConnectionCloseSource::FROM_PEER); | 937 ConnectionCloseSource::FROM_PEER); |
| 938 return connected_; | 938 return connected_; |
| 939 } | 939 } |
| 940 | 940 |
| 941 bool QuicConnection::OnGoAwayFrame(const QuicGoAwayFrame& frame) { | 941 bool QuicConnection::OnGoAwayFrame(const QuicGoAwayFrame& frame) { |
| 942 DCHECK(connected_); | 942 DCHECK(connected_); |
| (...skipping 1612 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2555 | 2555 |
| 2556 void QuicConnection::CheckIfApplicationLimited() { | 2556 void QuicConnection::CheckIfApplicationLimited() { |
| 2557 if (queued_packets_.empty() && | 2557 if (queued_packets_.empty() && |
| 2558 !sent_packet_manager_->HasPendingRetransmissions() && | 2558 !sent_packet_manager_->HasPendingRetransmissions() && |
| 2559 !visitor_->WillingAndAbleToWrite()) { | 2559 !visitor_->WillingAndAbleToWrite()) { |
| 2560 sent_packet_manager_->OnApplicationLimited(); | 2560 sent_packet_manager_->OnApplicationLimited(); |
| 2561 } | 2561 } |
| 2562 } | 2562 } |
| 2563 | 2563 |
| 2564 } // namespace net | 2564 } // namespace net |
| OLD | NEW |