Landing Recent QUIC changes until 4AM, Aug 7, 2016 UTC-4

net/quic/core/quic_multipath_sent_packet_manager.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "net/quic/core/quic_multipath_sent_packet_manager.h"
 
 #include <cstdint>
 
 #include "base/strings/string_number_conversions.h"
 #include "net/quic/core/quic_bug_tracker.h"
@@ skipping 298 matching lines @@
 QuicPacketCount QuicMultipathSentPacketManager::GetSlowStartThresholdInTcpMss()
     const {
   QuicSentPacketManagerInterface* path_manager =
       MaybeGetSentPacketManagerForActivePath(kDefaultPathId);
   if (path_manager == nullptr) {
     return 0;
   }
   return path_manager->GetSlowStartThresholdInTcpMss();
 }
 
+string QuicMultipathSentPacketManager::GetDebugState() const {
+  string debug_state_by_path;
+  for (size_t i = 0; i < path_managers_info_.size(); ++i) {
+    if (path_managers_info_[i].manager == nullptr ||
+        path_managers_info_[i].state != ACTIVE) {
+      continue;
+    }
+    const string& debug_state = path_managers_info_[i].manager->GetDebugState();
+    if (debug_state.empty()) {
+      continue;
+    }
+    debug_state_by_path =
+        debug_state_by_path + "[" + base::IntToString(i) + "]:" + debug_state;
+  }
+  return debug_state_by_path;
+}
+
 void QuicMultipathSentPacketManager::CancelRetransmissionsForStream(
     QuicStreamId stream_id) {
   for (PathSentPacketManagerInfo path_manager_info : path_managers_info_) {
     if (path_manager_info.manager != nullptr) {
       path_manager_info.manager->CancelRetransmissionsForStream(stream_id);
     }
   }
 }
 
 void QuicMultipathSentPacketManager::OnConnectionMigration(
@@ skipping 164 matching lines @@
                                     ConnectionCloseSource::FROM_SELF);
     return;
   }
   const string error_details = "Sent packet manager of path: (" +
                                base::IntToString(path_id) +
                                ") must be active but is not.";
   delegate_->OnUnrecoverableError(QUIC_MULTIPATH_PATH_NOT_ACTIVE, error_details,
                                   ConnectionCloseSource::FROM_SELF);
 }
 
+void QuicMultipathSentPacketManager::OnApplicationLimited() {
+  for (PathSentPacketManagerInfo& path_manager_info : path_managers_info_) {
+    if (path_manager_info.manager == nullptr ||
+        path_manager_info.state != ACTIVE) {
+      continue;
+    }
+    path_manager_info.manager->OnApplicationLimited();
+  }
+}
+
 }  // namespace net