| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_sent_packet_manager.h" | 5 #include "net/quic/core/quic_sent_packet_manager.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <string> | 8 #include <string> |
| 9 | 9 |
| 10 #include "base/logging.h" | 10 #include "base/logging.h" |
| (...skipping 134 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 145 use_new_rto_ = true; | 145 use_new_rto_ = true; |
| 146 } | 146 } |
| 147 if (config.HasReceivedConnectionOptions() && | 147 if (config.HasReceivedConnectionOptions() && |
| 148 ContainsQuicTag(config.ReceivedConnectionOptions(), kTIME)) { | 148 ContainsQuicTag(config.ReceivedConnectionOptions(), kTIME)) { |
| 149 general_loss_algorithm_.SetLossDetectionType(kTime); | 149 general_loss_algorithm_.SetLossDetectionType(kTime); |
| 150 } | 150 } |
| 151 if (config.HasReceivedConnectionOptions() && | 151 if (config.HasReceivedConnectionOptions() && |
| 152 ContainsQuicTag(config.ReceivedConnectionOptions(), kATIM)) { | 152 ContainsQuicTag(config.ReceivedConnectionOptions(), kATIM)) { |
| 153 general_loss_algorithm_.SetLossDetectionType(kAdaptiveTime); | 153 general_loss_algorithm_.SetLossDetectionType(kAdaptiveTime); |
| 154 } | 154 } |
| 155 if (FLAGS_quic_enable_lazy_fack && |
| 156 config.HasReceivedConnectionOptions() && |
| 157 ContainsQuicTag(config.ReceivedConnectionOptions(), kLFAK)) { |
| 158 general_loss_algorithm_.SetLossDetectionType(kLazyFack); |
| 159 } |
| 155 if (config.HasClientSentConnectionOption(kUNDO, perspective_)) { | 160 if (config.HasClientSentConnectionOption(kUNDO, perspective_)) { |
| 156 undo_pending_retransmits_ = true; | 161 undo_pending_retransmits_ = true; |
| 157 } | 162 } |
| 158 if (FLAGS_quic_conservative_handshake_retransmits && | 163 if (FLAGS_quic_conservative_handshake_retransmits && |
| 159 config.HasClientSentConnectionOption(kCONH, perspective_)) { | 164 config.HasClientSentConnectionOption(kCONH, perspective_)) { |
| 160 conservative_handshake_retransmits_ = true; | 165 conservative_handshake_retransmits_ = true; |
| 161 } | 166 } |
| 162 send_algorithm_->SetFromConfig(config, perspective_); | 167 send_algorithm_->SetFromConfig(config, perspective_); |
| 163 | 168 |
| 164 if (network_change_visitor_ != nullptr) { | 169 if (network_change_visitor_ != nullptr) { |
| (...skipping 841 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1006 | 1011 |
| 1007 void QuicSentPacketManager::RemoveObsoletePackets() { | 1012 void QuicSentPacketManager::RemoveObsoletePackets() { |
| 1008 unacked_packets_.RemoveObsoletePackets(); | 1013 unacked_packets_.RemoveObsoletePackets(); |
| 1009 } | 1014 } |
| 1010 | 1015 |
| 1011 void QuicSentPacketManager::OnApplicationLimited() { | 1016 void QuicSentPacketManager::OnApplicationLimited() { |
| 1012 send_algorithm_->OnApplicationLimited(unacked_packets_.bytes_in_flight()); | 1017 send_algorithm_->OnApplicationLimited(unacked_packets_.bytes_in_flight()); |
| 1013 } | 1018 } |
| 1014 | 1019 |
| 1015 } // namespace net | 1020 } // namespace net |
| OLD | NEW |