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 |