Disable connection migration if disabled in config sent by server.

net/quic/quic_stream_factory.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/quic_stream_factory.h"
 
 #include <algorithm>
 #include <set>
 #include <utility>
 
@@ skipping 66 matching lines @@
   CREATION_ERROR_MAX
 };
 
 enum QuicConnectionMigrationStatus {
   MIGRATION_STATUS_NO_MIGRATABLE_STREAMS,
   MIGRATION_STATUS_ALREADY_MIGRATED,
   MIGRATION_STATUS_INTERNAL_ERROR,
   MIGRATION_STATUS_TOO_MANY_CHANGES,
   MIGRATION_STATUS_SUCCESS,
   MIGRATION_STATUS_NON_MIGRATABLE_STREAM,
+  MIGRATION_STATUS_DISABLED,
   MIGRATION_STATUS_MAX
 };
 
 // The maximum receive window sizes for QUIC sessions and streams.
 const int32_t kQuicSessionMaxRecvWindowSize = 15 * 1024 * 1024;  // 15 MB
 const int32_t kQuicStreamMaxRecvWindowSize = 6 * 1024 * 1024;    // 6 MB
 
 // Set the maximum number of undecryptable packets the connection will store.
 const int32_t kMaxUndecryptablePackets = 100;
 
@@ skipping 1239 matching lines @@
     OnSessionGoingAway(session);
 
     if (new_network == NetworkChangeNotifier::kInvalidNetworkHandle) {
       // No new network was found.
       if (force_close) {
         session->CloseSessionOnError(ERR_NETWORK_CHANGED,
                                      QUIC_CONNECTION_MIGRATION_NO_NEW_NETWORK);
       }
       continue;
     }
+    if (session->config()->DisableConnectionMigration()) {
+      // Do not migrate sessions where connection migration is disabled by
+      // config.
+      if (force_close) {
+        // Close sessions where connection migration is disabled.
+        session->CloseSessionOnError(ERR_NETWORK_CHANGED,
+                                     QUIC_IP_ADDRESS_CHANGED);
+        HistogramMigrationStatus(MIGRATION_STATUS_DISABLED);
+      }
+      continue;
+    }
     if (session->HasNonMigratableStreams()) {
       // Do not migrate sessions with non-migratable streams.
       if (force_close) {
         // Close sessions with non-migratable streams.
         session->CloseSessionOnError(
             ERR_NETWORK_CHANGED,
             QUIC_CONNECTION_MIGRATION_NON_MIGRATABLE_STREAM);
         HistogramMigrationStatus(MIGRATION_STATUS_NON_MIGRATABLE_STREAM);
       }
       continue;
     }
 
     MigrateSessionToNetwork(session, new_network);
   }
 }
 
 void QuicStreamFactory::MaybeMigrateSessionEarly(
     QuicChromiumClientSession* session) {
-  if (!migrate_sessions_early_ || session->HasNonMigratableStreams()) {
+  if (!migrate_sessions_early_ || session->HasNonMigratableStreams() ||
+      session->config()->DisableConnectionMigration()) {
     return;
   }
   NetworkHandle new_network =
       FindAlternateNetwork(session->GetDefaultSocket()->GetBoundNetwork());
   if (new_network == NetworkChangeNotifier::kInvalidNetworkHandle) {
     // No alternate network found.
     return;
   }
   OnSessionGoingAway(session);
   MigrateSessionToNetwork(session, new_network);
@@ skipping 372 matching lines @@
   // Since the session was active, there's no longer an
   // HttpStreamFactoryImpl::Job running which can mark it broken, unless the TCP
   // job also fails. So to avoid not using QUIC when we otherwise could, we mark
   // it as recently broken, which means that 0-RTT will be disabled but we'll
   // still race.
   http_server_properties_->MarkAlternativeServiceRecentlyBroken(
       alternative_service);
 }
 
 }  // namespace net