PlzNavigate: Add first version of NavigationURLLoader.

content/browser/loader/navigation_url_loader_impl_core.cc

Index: content/browser/loader/navigation_url_loader_impl_core.cc
diff --git a/content/browser/loader/navigation_url_loader_impl_core.cc b/content/browser/loader/navigation_url_loader_impl_core.cc
new file mode 100644
index 0000000000000000000000000000000000000000..e720842880ccfca56cdb98b97ff8d5cc3f8770bf
--- /dev/null
+++ b/content/browser/loader/navigation_url_loader_impl_core.cc
@@ -0,0 +1,104 @@
+// Copyright 2014 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 "content/browser/loader/navigation_url_loader_impl_core.h"
+
+#include "base/bind.h"
+#include "base/location.h"
+#include "content/browser/frame_host/navigation_request_info.h"
+#include "content/browser/loader/navigation_resource_handler.h"
+#include "content/browser/loader/resource_dispatcher_host_impl.h"
+#include "content/common/navigation_params.h"
+#include "content/public/browser/browser_thread.h"
+#include "content/public/browser/stream_handle.h"
+#include "content/public/common/resource_response.h"
+#include "net/base/net_errors.h"
+#include "net/url_request/redirect_info.h"
+
+namespace content {
+
+NavigationURLLoaderImplCore::NavigationURLLoaderImplCore(
+    const base::WeakPtr<NavigationURLLoaderImpl>& loader)
+    : loader_(loader),
+      resource_handler_(nullptr) {
+  // This object is created on the UI thread but otherwise lives entirely on the

[nasko, 2014/10/23 22:36:17]

nit: Let's add that it is also deleted on the IO thread, not that just living
there.

[davidben, 2014/10/27 20:46:04]

Done.

+  // IO thread.
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+}
+
+NavigationURLLoaderImplCore::~NavigationURLLoaderImplCore() {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+  if (resource_handler_)
+    resource_handler_->Cancel();
+}
+
+void NavigationURLLoaderImplCore::Start(
+    ResourceContext* resource_context,
+    int64 frame_tree_node_id,
+    const CommonNavigationParams& common_params,
+    scoped_ptr<NavigationRequestInfo> request_info,
+    ResourceRequestBody* request_body) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+  ResourceDispatcherHostImpl::Get()->BeginNavigationRequest(
+      resource_context, frame_tree_node_id,
+      common_params, *request_info, request_body,
+      this);
+}
+
+void NavigationURLLoaderImplCore::FollowRedirect() {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+  if (resource_handler_)
+    resource_handler_->FollowRedirect();
+}
+
+
+void NavigationURLLoaderImplCore::NotifyRequestRedirected(
+    const net::RedirectInfo& redirect_info,
+    ResourceResponse* response) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+  // Make a copy of the ResourceResponse before it is passed to another thread.
+  //
+  // TODO(davidben): This copy could be avoided if ResourceResponse weren't
+  // reference counted and the loader stack passed unique ownership of the
+  // response. https://crbug.com/416050
+  BrowserThread::PostTask(
+      BrowserThread::UI, FROM_HERE,
+      base::Bind(&NavigationURLLoaderImpl::NotifyRequestRedirected, loader_,
+                 redirect_info, response->DeepCopy()));
+}
+
+void NavigationURLLoaderImplCore::NotifyResponseStarted(
+    ResourceResponse* response,
+    scoped_ptr<StreamHandle> body) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+  // If, by the time the task reaches the UI thread, |loader_| has already been
+  // destroyed, NotifyResponseStarted will not run. |body| will be destructed
+  // and the request released at that point.
+
+  // Make a copy of the ResourceResponse before it is passed to another thread.
+  //
+  // TODO(davidben): This copy could be avoided if ResourceResponse weren't
+  // reference counted and the loader stack passed unique ownership of the
+  // response. https://crbug.com/416050
+  BrowserThread::PostTask(
+      BrowserThread::UI, FROM_HERE,
+      base::Bind(&NavigationURLLoaderImpl::NotifyResponseStarted, loader_,
+                 response->DeepCopy(), base::Passed(&body)));
+}
+
+void NavigationURLLoaderImplCore::NotifyRequestFailed(int net_error) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+  BrowserThread::PostTask(
+      BrowserThread::UI, FROM_HERE,
+      base::Bind(&NavigationURLLoaderImpl::NotifyRequestFailed, loader_,
+                 net_error));
+}
+
+}  // namespace content