Implement redirect handling on MojoAsyncResourceHandler

content/child/resource_dispatcher.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.
 
 // See http://dev.chromium.org/developers/design-documents/multi-process-resource-loading
 
 #include "content/child/resource_dispatcher.h"
 
 #include <utility>
 
@@ skipping 80 matching lines @@
   }
 
   void OnReceiveResponse(const ResourceResponseHead& response_head) override {
     has_received_response_ = true;
     if (body_consumer_)
       body_consumer_->Start(task_runner_.get());
     resource_dispatcher_->OnMessageReceived(
         ResourceMsg_ReceivedResponse(request_id_, response_head));
   }
 
+  void OnReceiveRedirect(const net::RedirectInfo& redirect_info,
+                         const ResourceResponseHead& response_head) override {
+    DCHECK(!has_received_response_);
+    DCHECK(!body_consumer_);
+    resource_dispatcher_->OnMessageReceived(ResourceMsg_ReceivedRedirect(
+        request_id_, redirect_info, response_head));
+  }
+
   void OnDataDownloaded(int64_t data_len, int64_t encoded_data_len) override {
     resource_dispatcher_->OnMessageReceived(
         ResourceMsg_DataDownloaded(request_id_, data_len, encoded_data_len));
   }
 
   void OnStartLoadingResponseBody(
       mojo::ScopedDataPipeConsumerHandle body) override {
     DCHECK(!body_consumer_);
     body_consumer_ = new URLResponseBodyConsumer(
         request_id_, resource_dispatcher_, std::move(body), task_runner_);
@@ skipping 292 matching lines @@
     }
   } else {
     Cancel(request_id);
   }
 }
 
 void ResourceDispatcher::FollowPendingRedirect(
     int request_id,
     PendingRequestInfo* request_info) {
   IPC::Message* msg = request_info->pending_redirect_message.release();
-  if (msg)
-    message_sender_->Send(msg);
+  if (msg) {
+    if (request_info->url_loader) {
+      request_info->url_loader->FollowRedirect();
+      delete msg;
+    } else {
+      message_sender_->Send(msg);
+    }
+  }
 }
 
 void ResourceDispatcher::OnRequestComplete(
     int request_id,
     const ResourceRequestCompletionStatus& request_complete_data) {
   TRACE_EVENT0("loader", "ResourceDispatcher::OnRequestComplete");
 
   PendingRequestInfo* request_info = GetPendingRequestInfo(request_id);
   if (!request_info)
     return;
@@ skipping 412 matching lines @@
     delete message;
   }
 }
 
 void ResourceDispatcher::SetResourceSchedulingFilter(
     scoped_refptr<ResourceSchedulingFilter> resource_scheduling_filter) {
   resource_scheduling_filter_ = resource_scheduling_filter;
 }
 
 }  // namespace content