Retry HttpNetworkTransactions upon receipt of ERR_NETWORK_CHANGED during host resolution and …

net/http/http_network_transaction.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/http/http_network_transaction.h"
 
 #include <set>
 #include <vector>
 
 #include "base/bind.h"
@@ skipping 120 matching lines @@
       request_(NULL),
       priority_(priority),
       headers_valid_(false),
       logged_response_time_(false),
       fallback_error_code_(ERR_SSL_INAPPROPRIATE_FALLBACK),
       request_headers_(),
       read_buf_len_(0),
       total_received_bytes_(0),
       next_state_(STATE_NONE),
       establishing_tunnel_(false),
-      websocket_handshake_stream_base_create_helper_(NULL) {
+      websocket_handshake_stream_base_create_helper_(NULL),
+      num_automatic_retries_on_network_changes_(0),
+      weak_factory_(this) {
   session->ssl_config_service()->GetSSLConfig(&server_ssl_config_);
   if (session->http_stream_factory()->has_next_protos()) {
     server_ssl_config_.next_protos =
         session->http_stream_factory()->next_protos();
   }
   proxy_ssl_config_ = server_ssl_config_;
 }
 
 HttpNetworkTransaction::~HttpNetworkTransaction() {
   if (stream_.get()) {
@@ skipping 586 matching lines @@
 int HttpNetworkTransaction::DoCreateStreamComplete(int result) {
   if (result == OK) {
     next_state_ = STATE_INIT_STREAM;
     DCHECK(stream_.get());
   } else if (result == ERR_SSL_CLIENT_AUTH_CERT_NEEDED) {
     result = HandleCertificateRequest(result);
   } else if (result == ERR_HTTPS_PROXY_TUNNEL_RESPONSE) {
     // Return OK and let the caller read the proxy's error page
     next_state_ = STATE_NONE;
     return OK;
+  } else if (result == ERR_NETWORK_CHANGED &&
+      num_automatic_retries_on_network_changes_ <
+      request_->max_automatic_retries_on_network_changes_) {
+    // Try again to create the stream.
+    ++num_automatic_retries_on_network_changes_;
+    next_state_ = STATE_CREATE_STREAM;
+    // Retry after flushing all the current tasks which may include further
+    // network change observers that could trigger another ERR_NETWORK_CHANGED
+    // failure.
+    base::MessageLoop::current()->PostTask(
+        FROM_HERE,
+        base::Bind(&HttpNetworkTransaction::OnIOComplete,
+                   weak_factory_.GetWeakPtr(), OK));
+    return ERR_IO_PENDING;
   }
 
   // Handle possible handshake errors that may have occurred if the stream
   // used SSL for one or more of the layers.
   result = HandleSSLHandshakeError(result);
 
   // At this point we are done with the stream_request_.
   stream_request_.reset();
   return result;
 }
@@ skipping 855 matching lines @@
       description = base::StringPrintf("Unknown state 0x%08X (%u)", state,
                                        state);
       break;
   }
   return description;
 }
 
 #undef STATE_CASE
 
 }  // namespace net