Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(290)

Side by Side Diff: net/quic/quic_multipath_sent_packet_manager.cc

Issue 2179713004: Deprecate FLAGS_quic_always_write_queued_retransmissions. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@128171703
Patch Set: Created 4 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 #include "net/quic/quic_multipath_sent_packet_manager.h" 1 #include "net/quic/quic_multipath_sent_packet_manager.h"
2 2
3 #include <cstdint> 3 #include <cstdint>
4 4
5 #include "base/strings/string_number_conversions.h" 5 #include "base/strings/string_number_conversions.h"
6 #include "net/quic/quic_bug_tracker.h" 6 #include "net/quic/quic_bug_tracker.h"
7 7
8 using std::string; 8 using std::string;
9 using std::max; 9 using std::max;
10 10
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after
77 const QuicAckFrame& ack_frame, 77 const QuicAckFrame& ack_frame,
78 QuicTime ack_receive_time) { 78 QuicTime ack_receive_time) {
79 if (ack_frame.path_id >= path_managers_info_.size() || 79 if (ack_frame.path_id >= path_managers_info_.size() ||
80 path_managers_info_[ack_frame.path_id].state != ACTIVE) { 80 path_managers_info_[ack_frame.path_id].state != ACTIVE) {
81 return; 81 return;
82 } 82 }
83 path_managers_info_[ack_frame.path_id].manager->OnIncomingAck( 83 path_managers_info_[ack_frame.path_id].manager->OnIncomingAck(
84 ack_frame, ack_receive_time); 84 ack_frame, ack_receive_time);
85 } 85 }
86 86
87 bool QuicMultipathSentPacketManager::IsUnacked(
88 QuicPathId path_id,
89 QuicPacketNumber packet_number) const {
90 QuicSentPacketManagerInterface* path_manager =
91 MaybeGetSentPacketManagerForPath(path_id);
92 return path_manager != nullptr &&
93 path_manager->IsUnacked(path_id, packet_number);
94 }
95
96 bool QuicMultipathSentPacketManager::HasRetransmittableFrames(
97 QuicPathId path_id,
98 QuicPacketNumber packet_number) const {
99 QuicSentPacketManagerInterface* path_manager =
100 MaybeGetSentPacketManagerForPath(path_id);
101 return path_manager != nullptr &&
102 path_manager->HasRetransmittableFrames(path_id, packet_number);
103 }
104
105 void QuicMultipathSentPacketManager::RetransmitUnackedPackets( 87 void QuicMultipathSentPacketManager::RetransmitUnackedPackets(
106 TransmissionType retransmission_type) { 88 TransmissionType retransmission_type) {
107 QuicSentPacketManagerInterface* path_manager = 89 QuicSentPacketManagerInterface* path_manager =
108 MaybeGetSentPacketManagerForActivePath(kDefaultPathId); 90 MaybeGetSentPacketManagerForActivePath(kDefaultPathId);
109 if (path_manager == nullptr) { 91 if (path_manager == nullptr) {
110 OnUnrecoverablePathError(kDefaultPathId); 92 OnUnrecoverablePathError(kDefaultPathId);
111 return; 93 return;
112 } 94 }
113 path_manager->RetransmitUnackedPackets(retransmission_type); 95 path_manager->RetransmitUnackedPackets(retransmission_type);
114 } 96 }
(...skipping 396 matching lines...) Expand 10 before | Expand all | Expand 10 after
511 return; 493 return;
512 } 494 }
513 const string error_details = 495 const string error_details =
514 "Sent packet manager of path: (" + base::IntToString(path_id) + 496 "Sent packet manager of path: (" + base::IntToString(path_id) +
515 ") must be active but is not."; 497 ") must be active but is not.";
516 delegate_->OnUnrecoverableError(QUIC_MULTIPATH_PATH_NOT_ACTIVE, error_details, 498 delegate_->OnUnrecoverableError(QUIC_MULTIPATH_PATH_NOT_ACTIVE, error_details,
517 ConnectionCloseSource::FROM_SELF); 499 ConnectionCloseSource::FROM_SELF);
518 } 500 }
519 501
520 } // namespace net 502 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/quic_multipath_sent_packet_manager.h ('k') | net/quic/quic_multipath_sent_packet_manager_test.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698