| 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 886 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 897 } | 897 } |
| 898 QUIC_DLOG(INFO) << ENDPOINT | 898 QUIC_DLOG(INFO) << ENDPOINT |
| 899 << "BLOCKED_FRAME received for stream: " << frame.stream_id; | 899 << "BLOCKED_FRAME received for stream: " << frame.stream_id; |
| 900 visitor_->OnBlockedFrame(frame); | 900 visitor_->OnBlockedFrame(frame); |
| 901 visitor_->PostProcessAfterData(); | 901 visitor_->PostProcessAfterData(); |
| 902 stats_.blocked_frames_received++; | 902 stats_.blocked_frames_received++; |
| 903 should_last_packet_instigate_acks_ = true; | 903 should_last_packet_instigate_acks_ = true; |
| 904 return connected_; | 904 return connected_; |
| 905 } | 905 } |
| 906 | 906 |
| 907 bool QuicConnection::OnPathCloseFrame(const QuicPathCloseFrame& frame) { | |
| 908 DCHECK(connected_); | |
| 909 if (debug_visitor_ != nullptr) { | |
| 910 debug_visitor_->OnPathCloseFrame(frame); | |
| 911 } | |
| 912 QUIC_DLOG(INFO) << ENDPOINT | |
| 913 << "PATH_CLOSE_FRAME received for path: " << frame.path_id; | |
| 914 return connected_; | |
| 915 } | |
| 916 | |
| 917 void QuicConnection::OnPacketComplete() { | 907 void QuicConnection::OnPacketComplete() { |
| 918 // Don't do anything if this packet closed the connection. | 908 // Don't do anything if this packet closed the connection. |
| 919 if (!connected_) { | 909 if (!connected_) { |
| 920 ClearLastFrames(); | 910 ClearLastFrames(); |
| 921 return; | 911 return; |
| 922 } | 912 } |
| 923 | 913 |
| 924 QUIC_DVLOG(1) << ENDPOINT << "Got packet " << last_header_.packet_number | 914 QUIC_DVLOG(1) << ENDPOINT << "Got packet " << last_header_.packet_number |
| 925 << " for " << last_header_.public_header.connection_id; | 915 << " for " << last_header_.public_header.connection_id; |
| 926 | 916 |
| (...skipping 1469 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2396 | 2386 |
| 2397 void QuicConnection::CheckIfApplicationLimited() { | 2387 void QuicConnection::CheckIfApplicationLimited() { |
| 2398 if (queued_packets_.empty() && | 2388 if (queued_packets_.empty() && |
| 2399 !sent_packet_manager_.HasPendingRetransmissions() && | 2389 !sent_packet_manager_.HasPendingRetransmissions() && |
| 2400 !visitor_->WillingAndAbleToWrite()) { | 2390 !visitor_->WillingAndAbleToWrite()) { |
| 2401 sent_packet_manager_.OnApplicationLimited(); | 2391 sent_packet_manager_.OnApplicationLimited(); |
| 2402 } | 2392 } |
| 2403 } | 2393 } |
| 2404 | 2394 |
| 2405 } // namespace net | 2395 } // namespace net |
| OLD | NEW |