[Net] Add a priority parameter to URLRequest's constructor

net/url_request/url_request_unittest.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 "build/build_config.h"
 
 #if defined(OS_WIN)
 #include <windows.h>
 #include <shlobj.h>
 #endif
@@ skipping 19 matching lines @@
 #include "base/strings/utf_string_conversions.h"
 #include "net/base/capturing_net_log.h"
 #include "net/base/load_flags.h"
 #include "net/base/load_timing_info.h"
 #include "net/base/load_timing_info_test_util.h"
 #include "net/base/net_errors.h"
 #include "net/base/net_log.h"
 #include "net/base/net_log_unittest.h"
 #include "net/base/net_module.h"
 #include "net/base/net_util.h"
+#include "net/base/request_priority.h"
 #include "net/base/test_data_directory.h"
 #include "net/base/upload_bytes_element_reader.h"
 #include "net/base/upload_data_stream.h"
 #include "net/base/upload_file_element_reader.h"
 #include "net/cert/ev_root_ca_metadata.h"
 #include "net/cert/test_root_certs.h"
 #include "net/cookies/cookie_monster.h"
 #include "net/cookies/cookie_store_test_helpers.h"
 #include "net/disk_cache/disk_cache.h"
 #include "net/dns/mock_host_resolver.h"
@@ skipping 564 matching lines @@
  protected:
   CapturingNetLog net_log_;
   TestNetworkDelegate default_network_delegate_;  // Must outlive URLRequest.
   URLRequestJobFactoryImpl job_factory_;
   TestURLRequestContext default_context_;
 };
 
 TEST_F(URLRequestTest, AboutBlankTest) {
   TestDelegate d;
   {
-    URLRequest r(GURL("about:blank"), &d, &default_context_);
+    URLRequest r(GURL("about:blank"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_TRUE(!r.is_pending());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(d.bytes_received(), 0);
     EXPECT_EQ("", r.GetSocketAddress().host());
     EXPECT_EQ(0, r.GetSocketAddress().port());
 
     HttpRequestHeaders headers;
     EXPECT_FALSE(r.GetFullRequestHeaders(&headers));
   }
 }
 
 TEST_F(URLRequestTest, DataURLImageTest) {
   TestDelegate d;
   {
     // Use our nice little Chrome logo.
-    URLRequest r(GURL(
-        "data:image/png;base64,"
-        "iVBORw0KGgoAAAANSUhEUgAAABAAAAAQCAYAAAAf8/9hAAADVklEQVQ4jX2TfUwUBBjG3"
-        "w1y+HGcd9dxhXR8T4awOccJGgOSWclHImznLkTlSw0DDQXkrmgYgbUYnlQTqQxIEVxitD"
-        "5UMCATRA1CEEg+Qjw3bWDxIauJv/5oumqs39/P827vnucRmYN0gyF01GI5MpCVdW0gO7t"
-        "vNC+vqSEtbZefk5NuLv1jdJ46p/zw0HeH4+PHr3h7c1mjoV2t5rKzMx1+fg9bAgK6zHq9"
-        "cU5z+LpA3xOtx34+vTeT21onRuzssC3zxbbSwC13d/pFuC7CkIMDxQpF7r/MWq12UctI1"
-        "dWWm99ypqSYmRUBdKem8MkrO/kgaTt1O7YzlpzE5GIVd0WYUqt57yWf2McHTObYPbVD+Z"
-        "wbtlLTVMZ3BW+TnLyXLaWtmEq6WJVbT3HBh3Svj2HQQcm43XwmtoYM6vVKleh0uoWvnzW"
-        "3v3MpidruPTQPf0bia7sJOtBM0ufTWNvus/nkDFHF9ZS+uYVjRUasMeHUmyLYtcklTvzW"
-        "GFZnNOXczThvpKIzjcahSqIzkvDLayDq6D3eOjtBbNUEIZYyqsvj4V4wY92eNJ4IoyhTb"
-        "xXX1T5xsV9tm9r4TQwHLiZw/pdDZJea8TKmsmR/K0uLh/GwnCHghTja6lPhphezPfO5/5"
-        "MrVvMzNaI3+ERHfrFzPKQukrQGI4d/3EFD/3E2mVNYvi4at7CXWREaxZGD+3hg28zD3gV"
-        "Md6q5c8GdosynKmSeRuGzpjyl1/9UDGtPR5HeaKT8Wjo17WXk579BXVUhN64ehF9fhRtq"
-        "/uxxZKzNiZFGD0wRC3NFROZ5mwIPL/96K/rKMMLrIzF9uhHr+/sYH7DAbwlgC4J+R2Z7F"
-        "Ux1qLnV7MGF40smVSoJ/jvHRfYhQeUJd/SnYtGWhPHR0Sz+GE2F2yth0B36Vcz2KpnufB"
-        "JbsysjjW4kblBUiIjiURUWqJY65zxbnTy57GQyH58zgy0QBtTQv5gH15XMdKkYu+TGaJM"
-        "nlm2O34uI4b9tflqp1+QEFGzoW/ulmcofcpkZCYJhDfSpme7QcrHa+Xfji8paEQkTkSfm"
-        "moRWRNZr/F1KfVMjW+IKEnv2FwZfKdzt0BQR6lClcZR0EfEXEfv/G6W9iLiIyCoReV5En"
-        "hORIBHx+ufPj/gLB/zGI/G4Bk0AAAAASUVORK5CYII="),
+    URLRequest r(
+        GURL(
+            "data:image/png;base64,"
+            "iVBORw0KGgoAAAANSUhEUgAAABAAAAAQCAYAAAAf8/"
+            "9hAAADVklEQVQ4jX2TfUwUBBjG3"
+            "w1y+"
+            "HGcd9dxhXR8T4awOccJGgOSWclHImznLkTlSw0DDQXkrmgYgbUYnlQTqQxIEVxitD"
+            "5UMCATRA1CEEg+Qjw3bWDxIauJv/5oumqs39/"
+            "P827vnucRmYN0gyF01GI5MpCVdW0gO7t"
+            "vNC+vqSEtbZefk5NuLv1jdJ46p/"
+            "zw0HeH4+PHr3h7c1mjoV2t5rKzMx1+fg9bAgK6zHq9"
+            "cU5z+LpA3xOtx34+vTeT21onRuzssC3zxbbSwC13d/pFuC7CkIMDxQpF7r/"
+            "MWq12UctI1"
+            "dWWm99ypqSYmRUBdKem8MkrO/"
+            "kgaTt1O7YzlpzE5GIVd0WYUqt57yWf2McHTObYPbVD+Z"
+            "wbtlLTVMZ3BW+"
+            "TnLyXLaWtmEq6WJVbT3HBh3Svj2HQQcm43XwmtoYM6vVKleh0uoWvnzW"
+            "3v3MpidruPTQPf0bia7sJOtBM0ufTWNvus/"
+            "nkDFHF9ZS+uYVjRUasMeHUmyLYtcklTvzW"
+            "GFZnNOXczThvpKIzjcahSqIzkvDLayDq6D3eOjtBbNUEIZYyqsvj4V4wY92eNJ4Ioy"
+            "hTb"
+            "xXX1T5xsV9tm9r4TQwHLiZw/pdDZJea8TKmsmR/K0uLh/"
+            "GwnCHghTja6lPhphezPfO5/5"
+            "MrVvMzNaI3+ERHfrFzPKQukrQGI4d/3EFD/"
+            "3E2mVNYvi4at7CXWREaxZGD+3hg28zD3gV"
+            "Md6q5c8GdosynKmSeRuGzpjyl1/"
+            "9UDGtPR5HeaKT8Wjo17WXk579BXVUhN64ehF9fhRtq"
+            "/uxxZKzNiZFGD0wRC3NFROZ5mwIPL/96K/rKMMLrIzF9uhHr+/"
+            "sYH7DAbwlgC4J+R2Z7F"
+            "Ux1qLnV7MGF40smVSoJ/jvHRfYhQeUJd/"
+            "SnYtGWhPHR0Sz+GE2F2yth0B36Vcz2KpnufB"
+            "JbsysjjW4kblBUiIjiURUWqJY65zxbnTy57GQyH58zgy0QBtTQv5gH15XMdKkYu+"
+            "TGaJM"
+            "nlm2O34uI4b9tflqp1+QEFGzoW/"
+            "ulmcofcpkZCYJhDfSpme7QcrHa+Xfji8paEQkTkSfm"
+            "moRWRNZr/F1KfVMjW+IKEnv2FwZfKdzt0BQR6lClcZR0EfEXEfv/"
+            "G6W9iLiIyCoReV5En"
+            "hORIBHx+ufPj/gLB/zGI/G4Bk0AAAAASUVORK5CYII="),

[mmenke, 2013/10/30 15:27:11]

I think this was much better before.  Assume you used auto formatting, but this
now looks pretty hideous.

[akalin, 2013/10/30 21:44:37]

Done.

+        DEFAULT_PRIORITY,
         &d,
-        &default_context_);
+        &default_context_,
+        &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_TRUE(!r.is_pending());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(d.bytes_received(), 911);
     EXPECT_EQ("", r.GetSocketAddress().host());
     EXPECT_EQ(0, r.GetSocketAddress().port());
 
     HttpRequestHeaders headers;
     EXPECT_FALSE(r.GetFullRequestHeaders(&headers));
   }
 }
 
 TEST_F(URLRequestTest, FileTest) {
   base::FilePath app_path;
   PathService::Get(base::FILE_EXE, &app_path);
   GURL app_url = FilePathToFileURL(app_path);
 
   TestDelegate d;
   {
-    URLRequest r(app_url, &d, &default_context_);
+    URLRequest r(app_url,
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     int64 file_size = -1;
     EXPECT_TRUE(file_util::GetFileSize(app_path, &file_size));
 
     EXPECT_TRUE(!r.is_pending());
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(d.bytes_received(), static_cast<int>(file_size));
     EXPECT_EQ("", r.GetSocketAddress().host());
     EXPECT_EQ(0, r.GetSocketAddress().port());
 
     HttpRequestHeaders headers;
     EXPECT_FALSE(r.GetFullRequestHeaders(&headers));
   }
 }
 
 TEST_F(URLRequestTest, FileTestCancel) {
   base::FilePath app_path;
   PathService::Get(base::FILE_EXE, &app_path);
   GURL app_url = FilePathToFileURL(app_path);
 
   TestDelegate d;
   {
-    URLRequest r(app_url, &d, &default_context_);
+    URLRequest r(app_url,
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
     r.Cancel();
   }
   // Async cancellation should be safe even when URLRequest has been already
   // destroyed.
   base::RunLoop().RunUntilIdle();
 }
 
@@ skipping 11 matching lines @@
   EXPECT_TRUE(file_util::GetFileSize(temp_path, &file_size));
 
   const size_t first_byte_position = 500;
   const size_t last_byte_position = buffer_size - first_byte_position;
   const size_t content_length = last_byte_position - first_byte_position + 1;
   std::string partial_buffer_string(buffer.get() + first_byte_position,
                                     buffer.get() + last_byte_position + 1);
 
   TestDelegate d;
   {
-    URLRequest r(temp_url, &d, &default_context_);
+    URLRequest r(temp_url,
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     HttpRequestHeaders headers;
     headers.SetHeader(HttpRequestHeaders::kRange,
                       base::StringPrintf(
                            "bytes=%" PRIuS "-%" PRIuS,
                            first_byte_position, last_byte_position));
     r.SetExtraRequestHeaders(headers);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
@@ skipping 23 matching lines @@
   EXPECT_TRUE(file_util::GetFileSize(temp_path, &file_size));
 
   const size_t first_byte_position = 500;
   const size_t last_byte_position = buffer_size - 1;
   const size_t content_length = last_byte_position - first_byte_position + 1;
   std::string partial_buffer_string(buffer.get() + first_byte_position,
                                     buffer.get() + last_byte_position + 1);
 
   TestDelegate d;
   {
-    URLRequest r(temp_url, &d, &default_context_);
+    URLRequest r(temp_url,
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     HttpRequestHeaders headers;
     headers.SetHeader(HttpRequestHeaders::kRange,
                       base::StringPrintf("bytes=%" PRIuS "-",
                                          first_byte_position));
     r.SetExtraRequestHeaders(headers);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
@@ skipping 16 matching lines @@
   base::FilePath temp_path;
   EXPECT_TRUE(file_util::CreateTemporaryFile(&temp_path));
   GURL temp_url = FilePathToFileURL(temp_path);
   EXPECT_TRUE(file_util::WriteFile(temp_path, buffer.get(), buffer_size));
 
   int64 file_size;
   EXPECT_TRUE(file_util::GetFileSize(temp_path, &file_size));
 
   TestDelegate d;
   {
-    URLRequest r(temp_url, &d, &default_context_);
+    URLRequest r(temp_url,
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     HttpRequestHeaders headers;
     headers.SetHeader(HttpRequestHeaders::kRange,
                       "bytes=0-0,10-200,200-300");
     r.SetExtraRequestHeaders(headers);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
     EXPECT_TRUE(d.request_failed());
   }
 
   EXPECT_TRUE(base::DeleteFile(temp_path, false));
 }
 
 TEST_F(URLRequestTest, InvalidUrlTest) {
   TestDelegate d;
   {
-    URLRequest r(GURL("invalid url"), &d, &default_context_);
+    URLRequest r(GURL("invalid url"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
     EXPECT_TRUE(d.request_failed());
   }
 }
 
 #if defined(OS_WIN)
@@ skipping 16 matching lines @@
                                                CLSCTX_INPROC_SERVER)));
     base::win::ScopedComPtr<IPersistFile> persist;
     ASSERT_TRUE(SUCCEEDED(shell.QueryInterface(persist.Receive())));
     EXPECT_TRUE(SUCCEEDED(shell->SetPath(app_path.value().c_str())));
     EXPECT_TRUE(SUCCEEDED(shell->SetDescription(L"ResolveShortcutTest")));
     EXPECT_TRUE(SUCCEEDED(persist->Save(lnk_path.c_str(), TRUE)));
   }
 
   TestDelegate d;
   {
-    URLRequest r(FilePathToFileURL(base::FilePath(lnk_path)), &d,
-                 &default_context_);
+    URLRequest r(FilePathToFileURL(base::FilePath(lnk_path)),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     WIN32_FILE_ATTRIBUTE_DATA data;
     GetFileAttributesEx(app_path.value().c_str(),
                         GetFileExInfoStandard, &data);
     HANDLE file = CreateFile(app_path.value().c_str(), GENERIC_READ,
@@ skipping 22 matching lines @@
   // Put in mock resource provider.
   NetModule::SetResourceProvider(TestNetResourceProvider);
 
   TestDelegate d;
   {
     base::FilePath file_path;
     PathService::Get(base::DIR_SOURCE_ROOT, &file_path);
     file_path = file_path.Append(FILE_PATH_LITERAL("net"));
     file_path = file_path.Append(FILE_PATH_LITERAL("data"));
 
-    URLRequest req(FilePathToFileURL(file_path), &d, &default_context_);
+    URLRequest req(FilePathToFileURL(file_path),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
     req.Start();
     EXPECT_TRUE(req.is_pending());
 
     d.set_cancel_in_received_data_pending(true);
 
     base::RunLoop().Run();
   }
 
   // Take out mock resource provider.
   NetModule::SetResourceProvider(NULL);
 }
 
 TEST_F(URLRequestTest, FileDirRedirectNoCrash) {
   // There is an implicit redirect when loading a file path that matches a
   // directory and does not end with a slash.  Ensure that following such
   // redirects does not crash.  See http://crbug.com/18686.
 
   base::FilePath path;
   PathService::Get(base::DIR_SOURCE_ROOT, &path);
   path = path.Append(FILE_PATH_LITERAL("net"));
   path = path.Append(FILE_PATH_LITERAL("data"));
   path = path.Append(FILE_PATH_LITERAL("url_request_unittest"));
 
   TestDelegate d;
-  URLRequest req(FilePathToFileURL(path), &d, &default_context_);
+  URLRequest req(FilePathToFileURL(path),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::RunLoop().Run();
 
   ASSERT_EQ(1, d.received_redirect_count());
   ASSERT_LT(0, d.bytes_received());
   ASSERT_FALSE(d.request_failed());
   ASSERT_TRUE(req.status().is_success());
 }
 
 #if defined(OS_WIN)
 // Don't accept the url "file:///" on windows. See http://crbug.com/1474.
 TEST_F(URLRequestTest, FileDirRedirectSingleSlash) {
   TestDelegate d;
-  URLRequest req(GURL("file:///"), &d, &default_context_);
+  URLRequest req(GURL("file:///"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::RunLoop().Run();
 
   ASSERT_EQ(1, d.received_redirect_count());
   ASSERT_FALSE(req.status().is_success());
 }
 #endif
 
 // Custom URLRequestJobs for use with interceptor tests
 class RestartTestJob : public URLRequestTestJob {
@@ skipping 200 matching lines @@
 
 TEST_F(URLRequestTest, Intercept) {
   TestInterceptor interceptor;
 
   // intercept the main request and respond with a simple response
   interceptor.intercept_main_request_ = true;
   interceptor.main_headers_ = TestInterceptor::ok_headers();
   interceptor.main_data_ = TestInterceptor::ok_data();
 
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   base::SupportsUserData::Data* user_data0 = new base::SupportsUserData::Data();
   base::SupportsUserData::Data* user_data1 = new base::SupportsUserData::Data();
   base::SupportsUserData::Data* user_data2 = new base::SupportsUserData::Data();
   req.SetUserData(NULL, user_data0);
   req.SetUserData(&user_data1, user_data1);
   req.SetUserData(&user_data2, user_data2);
   req.set_method("GET");
   req.Start();
   base::RunLoop().Run();
 
@@ skipping 20 matching lines @@
   interceptor.intercept_main_request_ = true;
   interceptor.main_headers_ = TestInterceptor::redirect_headers();
   interceptor.main_data_ = TestInterceptor::redirect_data();
 
   // intercept that redirect and respond a final OK response
   interceptor.intercept_redirect_ = true;
   interceptor.redirect_headers_ =  TestInterceptor::ok_headers();
   interceptor.redirect_data_ = TestInterceptor::ok_data();
 
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.set_method("GET");
   req.Start();
   base::RunLoop().Run();
 
   // Check the interceptor got called as expected
   EXPECT_TRUE(interceptor.did_intercept_main_);
   EXPECT_TRUE(interceptor.did_intercept_redirect_);
 
   // Check we got one good response
   EXPECT_TRUE(req.status().is_success());
@@ skipping 12 matching lines @@
   interceptor.intercept_main_request_ = true;
   interceptor.main_headers_ = TestInterceptor::error_headers();
   interceptor.main_data_ = TestInterceptor::error_data();
 
   // intercept that error and respond with an OK response
   interceptor.intercept_final_response_ = true;
   interceptor.final_headers_ = TestInterceptor::ok_headers();
   interceptor.final_data_ = TestInterceptor::ok_data();
 
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.set_method("GET");
   req.Start();
   base::RunLoop().Run();
 
   // Check the interceptor got called as expected
   EXPECT_TRUE(interceptor.did_intercept_main_);
   EXPECT_TRUE(interceptor.did_intercept_final_);
 
   // Check we got one good response
   EXPECT_TRUE(req.status().is_success());
   EXPECT_EQ(200, req.response_headers()->response_code());
   EXPECT_EQ(TestInterceptor::ok_data(), d.data_received());
   EXPECT_EQ(1, d.response_started_count());
   EXPECT_EQ(0, d.received_redirect_count());
 }
 
 TEST_F(URLRequestTest, InterceptNetworkError) {
   TestInterceptor interceptor;
 
   // intercept the main request to simulate a network error
   interceptor.simulate_main_network_error_ = true;
 
   // intercept that error and respond with an OK response
   interceptor.intercept_final_response_ = true;
   interceptor.final_headers_ = TestInterceptor::ok_headers();
   interceptor.final_data_ = TestInterceptor::ok_data();
 
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.set_method("GET");
   req.Start();
   base::RunLoop().Run();
 
   // Check the interceptor got called as expected
   EXPECT_TRUE(interceptor.did_simulate_error_main_);
   EXPECT_TRUE(interceptor.did_intercept_final_);
 
   // Check we received one good response
   EXPECT_TRUE(req.status().is_success());
   EXPECT_EQ(200, req.response_headers()->response_code());
   EXPECT_EQ(TestInterceptor::ok_data(), d.data_received());
   EXPECT_EQ(1, d.response_started_count());
   EXPECT_EQ(0, d.received_redirect_count());
 }
 
 TEST_F(URLRequestTest, InterceptRestartRequired) {
   TestInterceptor interceptor;
 
   // restart the main request
   interceptor.restart_main_request_ = true;
 
   // then intercept the new main request and respond with an OK response
   interceptor.intercept_main_request_ = true;
   interceptor.main_headers_ = TestInterceptor::ok_headers();
   interceptor.main_data_ = TestInterceptor::ok_data();
 
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.set_method("GET");
   req.Start();
   base::RunLoop().Run();
 
   // Check the interceptor got called as expected
   EXPECT_TRUE(interceptor.did_restart_main_);
   EXPECT_TRUE(interceptor.did_intercept_main_);
 
   // Check we received one good response
   EXPECT_TRUE(req.status().is_success());
@@ skipping 10 matching lines @@
 
   // intercept the main request and cancel from within the restarted job
   interceptor.cancel_main_request_ = true;
 
   // setup to intercept final response and override it with an OK response
   interceptor.intercept_final_response_ = true;
   interceptor.final_headers_ = TestInterceptor::ok_headers();
   interceptor.final_data_ = TestInterceptor::ok_data();
 
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.set_method("GET");
   req.Start();
   base::RunLoop().Run();
 
   // Check the interceptor got called as expected
   EXPECT_TRUE(interceptor.did_cancel_main_);
   EXPECT_FALSE(interceptor.did_intercept_final_);
 
   // Check we see a canceled request
   EXPECT_FALSE(req.status().is_success());
@@ skipping 10 matching lines @@
 
   // intercept the redirect and cancel from within that job
   interceptor.cancel_redirect_request_ = true;
 
   // setup to intercept final response and override it with an OK response
   interceptor.intercept_final_response_ = true;
   interceptor.final_headers_ = TestInterceptor::ok_headers();
   interceptor.final_data_ = TestInterceptor::ok_data();
 
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.set_method("GET");
   req.Start();
   base::RunLoop().Run();
 
   // Check the interceptor got called as expected
   EXPECT_TRUE(interceptor.did_intercept_main_);
   EXPECT_TRUE(interceptor.did_cancel_redirect_);
   EXPECT_FALSE(interceptor.did_intercept_final_);
 
   // Check we see a canceled request
   EXPECT_FALSE(req.status().is_success());
   EXPECT_EQ(URLRequestStatus::CANCELED, req.status().status());
 }
 
 TEST_F(URLRequestTest, InterceptRespectsCancelFinal) {
   TestInterceptor interceptor;
 
   // intercept the main request to simulate a network error
   interceptor.simulate_main_network_error_ = true;
 
   // setup to intercept final response and cancel from within that job
   interceptor.cancel_final_request_ = true;
 
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.set_method("GET");
   req.Start();
   base::RunLoop().Run();
 
   // Check the interceptor got called as expected
   EXPECT_TRUE(interceptor.did_simulate_error_main_);
   EXPECT_TRUE(interceptor.did_cancel_final_);
 
   // Check we see a canceled request
   EXPECT_FALSE(req.status().is_success());
   EXPECT_EQ(URLRequestStatus::CANCELED, req.status().status());
 }
 
 TEST_F(URLRequestTest, InterceptRespectsCancelInRestart) {
   TestInterceptor interceptor;
 
   // intercept the main request and cancel then restart from within that job
   interceptor.cancel_then_restart_main_request_ = true;
 
   // setup to intercept final response and override it with an OK response
   interceptor.intercept_final_response_ = true;
   interceptor.final_headers_ = TestInterceptor::ok_headers();
   interceptor.final_data_ = TestInterceptor::ok_data();
 
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.set_method("GET");
   req.Start();
   base::RunLoop().Run();
 
   // Check the interceptor got called as expected
   EXPECT_TRUE(interceptor.did_cancel_then_restart_main_);
   EXPECT_FALSE(interceptor.did_intercept_final_);
 
   // Check we see a canceled request
   EXPECT_FALSE(req.status().is_success());
   EXPECT_EQ(URLRequestStatus::CANCELED, req.status().status());
 }
 
 LoadTimingInfo RunLoadTimingTest(const LoadTimingInfo& job_load_timing,
-                                 URLRequestContext* context) {
+                                 URLRequestContext* context,
+                                 NetworkDelegate* delegate) {
   TestInterceptor interceptor;
   interceptor.intercept_main_request_ = true;
   interceptor.main_request_load_timing_info_ = job_load_timing;
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, context);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 context,
+                 delegate);
   req.Start();
   base::RunLoop().Run();
 
   LoadTimingInfo resulting_load_timing;
   req.GetLoadTimingInfo(&resulting_load_timing);
 
   // None of these should be modified by the URLRequest.
   EXPECT_EQ(job_load_timing.socket_reused, resulting_load_timing.socket_reused);
   EXPECT_EQ(job_load_timing.socket_log_id, resulting_load_timing.socket_log_id);
   EXPECT_EQ(job_load_timing.send_start, resulting_load_timing.send_start);
@@ skipping 53 matching lines @@
   load_timing.receive_headers_end = now + base::TimeDelta::FromDays(11);
   return load_timing;
 }
 
 // Basic test that the intercept + load timing tests work.
 TEST_F(URLRequestTest, InterceptLoadTiming) {
   base::TimeTicks now = base::TimeTicks::Now();
   LoadTimingInfo job_load_timing =
       NormalLoadTimingInfo(now, CONNECT_TIMING_HAS_DNS_TIMES, false);
 
-  LoadTimingInfo load_timing_result = RunLoadTimingTest(job_load_timing,
-                                                        &default_context_);
+  LoadTimingInfo load_timing_result = RunLoadTimingTest(
+      job_load_timing, &default_context_, &default_network_delegate_);
 
   // Nothing should have been changed by the URLRequest.
   EXPECT_EQ(job_load_timing.proxy_resolve_start,
             load_timing_result.proxy_resolve_start);
   EXPECT_EQ(job_load_timing.proxy_resolve_end,
             load_timing_result.proxy_resolve_end);
   EXPECT_EQ(job_load_timing.connect_timing.dns_start,
             load_timing_result.connect_timing.dns_start);
   EXPECT_EQ(job_load_timing.connect_timing.dns_end,
             load_timing_result.connect_timing.dns_end);
   EXPECT_EQ(job_load_timing.connect_timing.connect_start,
             load_timing_result.connect_timing.connect_start);
   EXPECT_EQ(job_load_timing.connect_timing.connect_end,
             load_timing_result.connect_timing.connect_end);
   EXPECT_EQ(job_load_timing.connect_timing.ssl_start,
             load_timing_result.connect_timing.ssl_start);
   EXPECT_EQ(job_load_timing.connect_timing.ssl_end,
             load_timing_result.connect_timing.ssl_end);
 
   // Redundant sanity check.
   TestLoadTimingNotReused(load_timing_result, CONNECT_TIMING_HAS_DNS_TIMES);
 }
 
 // Another basic test, with proxy and SSL times, but no DNS times.
 TEST_F(URLRequestTest, InterceptLoadTimingProxy) {
   base::TimeTicks now = base::TimeTicks::Now();
   LoadTimingInfo job_load_timing =
       NormalLoadTimingInfo(now, CONNECT_TIMING_HAS_SSL_TIMES, true);
 
-  LoadTimingInfo load_timing_result = RunLoadTimingTest(job_load_timing,
-                                                        &default_context_);
+  LoadTimingInfo load_timing_result = RunLoadTimingTest(
+      job_load_timing, &default_context_, &default_network_delegate_);
 
   // Nothing should have been changed by the URLRequest.
   EXPECT_EQ(job_load_timing.proxy_resolve_start,
             load_timing_result.proxy_resolve_start);
   EXPECT_EQ(job_load_timing.proxy_resolve_end,
             load_timing_result.proxy_resolve_end);
   EXPECT_EQ(job_load_timing.connect_timing.dns_start,
             load_timing_result.connect_timing.dns_start);
   EXPECT_EQ(job_load_timing.connect_timing.dns_end,
             load_timing_result.connect_timing.dns_end);
@@ skipping 23 matching lines @@
       NormalLoadTimingInfo(now, CONNECT_TIMING_HAS_DNS_TIMES, true);
   job_load_timing.proxy_resolve_start = now - base::TimeDelta::FromDays(6);
   job_load_timing.proxy_resolve_end = now - base::TimeDelta::FromDays(5);
   job_load_timing.connect_timing.dns_start = now - base::TimeDelta::FromDays(4);
   job_load_timing.connect_timing.dns_end = now - base::TimeDelta::FromDays(3);
   job_load_timing.connect_timing.connect_start =
       now - base::TimeDelta::FromDays(2);
   job_load_timing.connect_timing.connect_end =
       now - base::TimeDelta::FromDays(1);
 
-  LoadTimingInfo load_timing_result = RunLoadTimingTest(job_load_timing,
-                                                        &default_context_);
+  LoadTimingInfo load_timing_result = RunLoadTimingTest(
+      job_load_timing, &default_context_, &default_network_delegate_);
 
   // Proxy times, connect times, and DNS times should all be replaced with
   // request_start.
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.proxy_resolve_start);
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.proxy_resolve_end);
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.connect_timing.dns_start);
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.connect_timing.dns_end);
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.connect_timing.connect_start);
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.connect_timing.connect_end);
 
   // Other times should have been left null.
   TestLoadTimingNotReusedWithProxy(load_timing_result,
                                    CONNECT_TIMING_HAS_DNS_TIMES);
 }
 
 // Same as above, but in the reused case.
 TEST_F(URLRequestTest, InterceptLoadTimingEarlyProxyResolutionReused) {
   base::TimeTicks now = base::TimeTicks::Now();
   LoadTimingInfo job_load_timing = NormalLoadTimingInfoReused(now, true);
   job_load_timing.proxy_resolve_start = now - base::TimeDelta::FromDays(4);
   job_load_timing.proxy_resolve_end = now - base::TimeDelta::FromDays(3);
 
-  LoadTimingInfo load_timing_result = RunLoadTimingTest(job_load_timing,
-                                                        &default_context_);
+  LoadTimingInfo load_timing_result = RunLoadTimingTest(
+      job_load_timing, &default_context_, &default_network_delegate_);
 
   // Proxy times and connect times should all be replaced with request_start.
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.proxy_resolve_start);
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.proxy_resolve_end);
 
   // Other times should have been left null.
   TestLoadTimingReusedWithProxy(load_timing_result);
 }
 
 // Make sure that URLRequest correctly adjusts connect times when they're before
 // |request_start|, due to reusing a connected socket.  The connected socket is
 // not considered reused in this test (May be a preconnect).
 //
 // To mix things up, the request has SSL times, but no DNS times.
 TEST_F(URLRequestTest, InterceptLoadTimingEarlyConnect) {
   base::TimeTicks now = base::TimeTicks::Now();
   LoadTimingInfo job_load_timing =
       NormalLoadTimingInfo(now, CONNECT_TIMING_HAS_SSL_TIMES, false);
   job_load_timing.connect_timing.connect_start =
       now - base::TimeDelta::FromDays(1);
   job_load_timing.connect_timing.ssl_start = now - base::TimeDelta::FromDays(2);
   job_load_timing.connect_timing.ssl_end = now - base::TimeDelta::FromDays(3);
   job_load_timing.connect_timing.connect_end =
       now - base::TimeDelta::FromDays(4);
 
-  LoadTimingInfo load_timing_result = RunLoadTimingTest(job_load_timing,
-                                                        &default_context_);
+  LoadTimingInfo load_timing_result = RunLoadTimingTest(
+      job_load_timing, &default_context_, &default_network_delegate_);
 
   // Connect times, and SSL times should be replaced with request_start.
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.connect_timing.connect_start);
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.connect_timing.ssl_start);
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.connect_timing.ssl_end);
   EXPECT_EQ(load_timing_result.request_start,
             load_timing_result.connect_timing.connect_end);
@@ skipping 10 matching lines @@
 // In this test, there are no SSL or DNS times.
 TEST_F(URLRequestTest, InterceptLoadTimingEarlyConnectWithProxy) {
   base::TimeTicks now = base::TimeTicks::Now();
   LoadTimingInfo job_load_timing =
       NormalLoadTimingInfo(now, CONNECT_TIMING_HAS_CONNECT_TIMES_ONLY, true);
   job_load_timing.connect_timing.connect_start =
       now - base::TimeDelta::FromDays(1);
   job_load_timing.connect_timing.connect_end =
       now - base::TimeDelta::FromDays(2);
 
-  LoadTimingInfo load_timing_result = RunLoadTimingTest(job_load_timing,
-                                                        &default_context_);
+  LoadTimingInfo load_timing_result = RunLoadTimingTest(
+      job_load_timing, &default_context_, &default_network_delegate_);
 
   // Connect times should be replaced with proxy_resolve_end.
   EXPECT_EQ(load_timing_result.proxy_resolve_end,
             load_timing_result.connect_timing.connect_start);
   EXPECT_EQ(load_timing_result.proxy_resolve_end,
             load_timing_result.connect_timing.connect_end);
 
   // Other times should have been left null.
   TestLoadTimingNotReusedWithProxy(load_timing_result,
                                    CONNECT_TIMING_HAS_CONNECT_TIMES_ONLY);
 }
 
 // Check that two different URL requests have different identifiers.
 TEST_F(URLRequestTest, Identifiers) {
   TestDelegate d;
   TestURLRequestContext context;
-  TestURLRequest req(GURL("http://example.com"), &d, &context, NULL);
-  TestURLRequest other_req(GURL("http://example.com"), &d, &context, NULL);
+  TestURLRequest req(
+      GURL("http://example.com"), DEFAULT_PRIORITY, &d, &context, NULL);
+  TestURLRequest other_req(
+      GURL("http://example.com"), DEFAULT_PRIORITY, &d, &context, NULL);
 
   ASSERT_NE(req.identifier(), other_req.identifier());
 }
 
 // Check that a failure to connect to the proxy is reported to the network
 // delegate.
 TEST_F(URLRequestTest, NetworkDelegateProxyError) {
   MockHostResolver host_resolver;
   host_resolver.rules()->AddSimulatedFailure("*");
 
   TestNetworkDelegate network_delegate;  // Must outlive URLRequests.
   TestURLRequestContextWithProxy context("myproxy:70", &network_delegate);
 
   TestDelegate d;
-  URLRequest req(GURL("http://example.com"), &d, &context);
+  URLRequest req(GURL("http://example.com"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
   req.set_method("GET");
 
   req.Start();
   base::RunLoop().Run();
 
   // Check we see a failed request.
   EXPECT_FALSE(req.status().is_success());
   EXPECT_EQ(URLRequestStatus::FAILED, req.status().status());
   EXPECT_EQ(ERR_PROXY_CONNECTION_FAILED, req.status().error());
 
   EXPECT_EQ(1, network_delegate.error_count());
   EXPECT_EQ(ERR_PROXY_CONNECTION_FAILED, network_delegate.last_error());
   EXPECT_EQ(1, network_delegate.completed_requests());
 }
 
 // Make sure that net::NetworkDelegate::NotifyCompleted is called if
 // content is empty.
 TEST_F(URLRequestTest, RequestCompletionForEmptyResponse) {
   TestDelegate d;
-  URLRequest req(GURL("data:,"), &d, &default_context_);
+  URLRequest req(GURL("data:,"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::RunLoop().Run();
   EXPECT_EQ("", d.data_received());
   EXPECT_EQ(1, default_network_delegate_.completed_requests());
 }
 
 // Make sure that SetPriority actually sets the URLRequest's priority
 // correctly, both before and after start.
 TEST_F(URLRequestTest, SetPriorityBasic) {
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   EXPECT_EQ(DEFAULT_PRIORITY, req.priority());
 
   req.SetPriority(LOW);
   EXPECT_EQ(LOW, req.priority());
 
   req.Start();
   EXPECT_EQ(LOW, req.priority());
 
   req.SetPriority(MEDIUM);
   EXPECT_EQ(MEDIUM, req.priority());
 }
 
 // Make sure that URLRequest calls SetPriority on a job before calling
 // Start on it.
 TEST_F(URLRequestTest, SetJobPriorityBeforeJobStart) {
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   EXPECT_EQ(DEFAULT_PRIORITY, req.priority());
 
   scoped_refptr<URLRequestTestJob> job =
       new URLRequestTestJob(&req, &default_network_delegate_);
   AddTestInterceptor()->set_main_intercept_job(job.get());
   EXPECT_EQ(DEFAULT_PRIORITY, job->priority());
 
   req.SetPriority(LOW);
 
   req.Start();
   EXPECT_EQ(LOW, job->priority());
 }
 
 // Make sure that URLRequest passes on its priority updates to its
 // job.
 TEST_F(URLRequestTest, SetJobPriority) {
   TestDelegate d;
-  URLRequest req(GURL("http://test_intercept/foo"), &d, &default_context_);
+  URLRequest req(GURL("http://test_intercept/foo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
   scoped_refptr<URLRequestTestJob> job =
       new URLRequestTestJob(&req, &default_network_delegate_);
   AddTestInterceptor()->set_main_intercept_job(job.get());
 
   req.SetPriority(LOW);
   req.Start();
   EXPECT_EQ(LOW, job->priority());
 
   req.SetPriority(MEDIUM);
@@ skipping 26 matching lines @@
   scoped_refptr<DelayedCookieMonster> delayed_cm =
       new DelayedCookieMonster();
   scoped_refptr<CookieStore> cookie_store = delayed_cm;
   context.set_cookie_store(delayed_cm.get());
 
   // Set up a cookie.
   {
     TestNetworkDelegate network_delegate;
     context.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("set-cookie?CookieToNotSend=1"), &d, &context);
+    URLRequest req(test_server.GetURL("set-cookie?CookieToNotSend=1"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &context,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
     EXPECT_EQ(1, network_delegate.set_cookie_count());
   }
 
   // Verify that the cookie is set.
   {
     TestNetworkDelegate network_delegate;
     context.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(test_server.GetURL("echoheader?Cookie"), &d, &context);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &context,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("CookieToNotSend=1")
                 != std::string::npos);
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 }
 
 TEST_F(URLRequestTest, DoNotSendCookies) {
   LocalHttpTestServer test_server;
   ASSERT_TRUE(test_server.Start());
 
   // Set up a cookie.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
     URLRequest req(test_server.GetURL("set-cookie?CookieToNotSend=1"),
+                   DEFAULT_PRIORITY,
                    &d,
-                   &default_context_);
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 
   // Verify that the cookie is set.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("echoheader?Cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("CookieToNotSend=1")
                 != std::string::npos);
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 
   // Verify that the cookie isn't sent when LOAD_DO_NOT_SEND_COOKIES is set.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("echoheader?Cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.set_load_flags(LOAD_DO_NOT_SEND_COOKIES);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("Cookie: CookieToNotSend=1")
                 == std::string::npos);
 
     // LOAD_DO_NOT_SEND_COOKIES does not trigger OnGetCookies.
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 }
 
 TEST_F(URLRequestTest, DoNotSaveCookies) {
   LocalHttpTestServer test_server;
   ASSERT_TRUE(test_server.Start());
 
   // Set up a cookie.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
     URLRequest req(test_server.GetURL("set-cookie?CookieToNotUpdate=2"),
+                   DEFAULT_PRIORITY,
                    &d,
-                   &default_context_);
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
     EXPECT_EQ(1, network_delegate.set_cookie_count());
   }
 
   // Try to set-up another cookie and update the previous cookie.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
     URLRequest req(
         test_server.GetURL("set-cookie?CookieToNotSave=1&CookieToNotUpdate=1"),
+        DEFAULT_PRIORITY,
         &d,
-        &default_context_);
+        &default_context_,
+        &network_delegate);
     req.set_load_flags(LOAD_DO_NOT_SAVE_COOKIES);
     req.Start();
 
     base::RunLoop().Run();
 
     // LOAD_DO_NOT_SAVE_COOKIES does not trigger OnSetCookie.
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
     EXPECT_EQ(0, network_delegate.set_cookie_count());
   }
 
   // Verify the cookies weren't saved or updated.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("echoheader?Cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("CookieToNotSave=1")
                 == std::string::npos);
     EXPECT_TRUE(d.data_received().find("CookieToNotUpdate=2")
                 != std::string::npos);
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
     EXPECT_EQ(0, network_delegate.set_cookie_count());
   }
 }
 
 TEST_F(URLRequestTest, DoNotSendCookies_ViaPolicy) {
   LocalHttpTestServer test_server;
   ASSERT_TRUE(test_server.Start());
 
   // Set up a cookie.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
     URLRequest req(test_server.GetURL("set-cookie?CookieToNotSend=1"),
+                   DEFAULT_PRIORITY,
                    &d,
-                   &default_context_);
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 
   // Verify that the cookie is set.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("echoheader?Cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("CookieToNotSend=1")
                 != std::string::npos);
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 
   // Verify that the cookie isn't sent.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
     network_delegate.set_cookie_options(TestNetworkDelegate::NO_GET_COOKIES);
-    URLRequest req(
-        test_server.GetURL("echoheader?Cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("Cookie: CookieToNotSend=1")
                 == std::string::npos);
 
     EXPECT_EQ(1, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 }
 
 TEST_F(URLRequestTest, DoNotSaveCookies_ViaPolicy) {
   LocalHttpTestServer test_server;
   ASSERT_TRUE(test_server.Start());
 
   // Set up a cookie.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
     URLRequest req(test_server.GetURL("set-cookie?CookieToNotUpdate=2"),
+                   DEFAULT_PRIORITY,
                    &d,
-                   &default_context_);
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 
   // Try to set-up another cookie and update the previous cookie.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
     network_delegate.set_cookie_options(TestNetworkDelegate::NO_SET_COOKIE);
     URLRequest req(
         test_server.GetURL("set-cookie?CookieToNotSave=1&CookieToNotUpdate=1"),
+        DEFAULT_PRIORITY,
         &d,
-        &default_context_);
+        &default_context_,
+        &network_delegate);
     req.Start();
 
     base::RunLoop().Run();
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(2, network_delegate.blocked_set_cookie_count());
   }
 
   // Verify the cookies weren't saved or updated.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("echoheader?Cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("CookieToNotSave=1")
                 == std::string::npos);
     EXPECT_TRUE(d.data_received().find("CookieToNotUpdate=2")
                 != std::string::npos);
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 }
 
 TEST_F(URLRequestTest, DoNotSaveEmptyCookies) {
   LocalHttpTestServer test_server;
   ASSERT_TRUE(test_server.Start());
 
   // Set up an empty cookie.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(test_server.GetURL("set-cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("set-cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
     EXPECT_EQ(0, network_delegate.set_cookie_count());
   }
 }
 
 TEST_F(URLRequestTest, DoNotSendCookies_ViaPolicy_Async) {
   LocalHttpTestServer test_server;
   ASSERT_TRUE(test_server.Start());
 
   // Set up a cookie.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
     URLRequest req(test_server.GetURL("set-cookie?CookieToNotSend=1"),
+                   DEFAULT_PRIORITY,
                    &d,
-                   &default_context_);
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 
   // Verify that the cookie is set.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("echoheader?Cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("CookieToNotSend=1")
                 != std::string::npos);
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 
   // Verify that the cookie isn't sent.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
     network_delegate.set_cookie_options(TestNetworkDelegate::NO_GET_COOKIES);
-    URLRequest req(
-        test_server.GetURL("echoheader?Cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("Cookie: CookieToNotSend=1")
                 == std::string::npos);
 
     EXPECT_EQ(1, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 }
 
 TEST_F(URLRequestTest, DoNotSaveCookies_ViaPolicy_Async) {
   LocalHttpTestServer test_server;
   ASSERT_TRUE(test_server.Start());
 
   // Set up a cookie.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
     URLRequest req(test_server.GetURL("set-cookie?CookieToNotUpdate=2"),
+                   DEFAULT_PRIORITY,
                    &d,
-                   &default_context_);
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
   }
 
   // Try to set-up another cookie and update the previous cookie.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
     network_delegate.set_cookie_options(TestNetworkDelegate::NO_SET_COOKIE);
     URLRequest req(
         test_server.GetURL("set-cookie?CookieToNotSave=1&CookieToNotUpdate=1"),
+        DEFAULT_PRIORITY,
         &d,
-        &default_context_);
+        &default_context_,
+        &network_delegate);
     req.Start();
 
     base::RunLoop().Run();
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(2, network_delegate.blocked_set_cookie_count());
   }
 
   // Verify the cookies weren't saved or updated.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("echoheader?Cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("CookieToNotSave=1")
                 == std::string::npos);
     EXPECT_TRUE(d.data_received().find("CookieToNotUpdate=2")
                 != std::string::npos);
 
     EXPECT_EQ(0, network_delegate.blocked_get_cookies_count());
     EXPECT_EQ(0, network_delegate.blocked_set_cookie_count());
@@ skipping 45 matching lines @@
 // headers by defaulting to GMT. (crbug.com/135131)
 TEST_F(URLRequestTest, AcceptClockSkewCookieWithWrongDateTimezone) {
   LocalHttpTestServer test_server;
   ASSERT_TRUE(test_server.Start());
 
   // Set up an expired cookie.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(test_server.GetURL(
-        "set-cookie?StillGood=1;expires=Mon,18-Apr-1977,22:50:13,GMT"),
+    URLRequest req(
+        test_server.GetURL(
+            "set-cookie?StillGood=1;expires=Mon,18-Apr-1977,22:50:13,GMT"),
+        DEFAULT_PRIORITY,
         &d,
-        &default_context_);
+        &default_context_,
+        &network_delegate);
     req.Start();
     base::RunLoop().Run();
   }
   // Verify that the cookie is not set.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("echoheader?Cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("StillGood=1") == std::string::npos);
   }
   // Set up a cookie with clock skew and "UTC" HTTP Date timezone specifier.
   {
     FixedDateNetworkDelegate network_delegate("18-Apr-1977 22:49:13 UTC");
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(test_server.GetURL(
-        "set-cookie?StillGood=1;expires=Mon,18-Apr-1977,22:50:13,GMT"),
+    URLRequest req(
+        test_server.GetURL(
+            "set-cookie?StillGood=1;expires=Mon,18-Apr-1977,22:50:13,GMT"),
+        DEFAULT_PRIORITY,
         &d,
-        &default_context_);
+        &default_context_,
+        &network_delegate);
     req.Start();
     base::RunLoop().Run();
   }
   // Verify that the cookie is set.
   {
     TestNetworkDelegate network_delegate;
     default_context_.set_network_delegate(&network_delegate);
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("echoheader?Cookie"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Cookie"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("StillGood=1") != std::string::npos);
   }
 }
 
 
 // Check that it is impossible to change the referrer in the extra headers of
 // an URLRequest.
 TEST_F(URLRequestTest, DoNotOverrideReferrer) {
   LocalHttpTestServer test_server;
   ASSERT_TRUE(test_server.Start());
 
   // If extra headers contain referer and the request contains a referer,
   // only the latter shall be respected.
   {
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("echoheader?Referer"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Referer"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
     req.SetReferrer("http://foo.com/");
 
     HttpRequestHeaders headers;
     headers.SetHeader(HttpRequestHeaders::kReferer, "http://bar.com/");
     req.SetExtraRequestHeaders(headers);
 
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ("http://foo.com/", d.data_received());
   }
 
   // If extra headers contain a referer but the request does not, no referer
   // shall be sent in the header.
   {
     TestDelegate d;
-    URLRequest req(
-        test_server.GetURL("echoheader?Referer"), &d, &default_context_);
+    URLRequest req(test_server.GetURL("echoheader?Referer"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
 
     HttpRequestHeaders headers;
     headers.SetHeader(HttpRequestHeaders::kReferer, "http://bar.com/");
     req.SetExtraRequestHeaders(headers);
     req.set_load_flags(LOAD_VALIDATE_CACHE);
 
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ("None", d.data_received());
@@ skipping 14 matching lines @@
   // request, after redirection.
   // If |include_data| is true, data is uploaded with the request.  The
   // response body is expected to match it exactly, if and only if
   // |request_method| == |redirect_method|.
   void HTTPRedirectMethodTest(const GURL& redirect_url,
                               const std::string& request_method,
                               const std::string& redirect_method,
                               bool include_data) {
     static const char kData[] = "hello world";
     TestDelegate d;
-    URLRequest req(redirect_url, &d, &default_context_);
+    URLRequest req(redirect_url,
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
     req.set_method(request_method);
     if (include_data) {
       req.set_upload(make_scoped_ptr(CreateSimpleUploadData(kData)));
       HttpRequestHeaders headers;
       headers.SetHeader(HttpRequestHeaders::kContentLength,
                         base::UintToString(arraysize(kData) - 1));
       req.SetExtraRequestHeaders(headers);
     }
     req.Start();
     base::RunLoop().Run();
@@ skipping 24 matching lines @@
         ptr--;
         *ptr++ = marker;
         if (++marker > 'z')
           marker = 'a';
       }
     }
     uploadBytes[kMsgSize] = '\0';
 
     for (int i = 0; i < kIterations; ++i) {
       TestDelegate d;
-      URLRequest r(test_server_.GetURL("echo"), &d, &default_context_);
+      URLRequest r(test_server_.GetURL("echo"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
       r.set_method(method.c_str());
 
       r.set_upload(make_scoped_ptr(CreateSimpleUploadData(uploadBytes)));
 
       r.Start();
       EXPECT_TRUE(r.is_pending());
 
       base::RunLoop().Run();
 
       ASSERT_EQ(1, d.response_started_count())
@@ skipping 27 matching lines @@
     EXPECT_FALSE(d->received_data_before_response());
 
     EXPECT_EQ(expected_data.size(), static_cast<size_t>(d->bytes_received()));
     EXPECT_EQ(expected_data, d->data_received());
   }
 
   bool DoManyCookiesRequest(int num_cookies) {
     TestDelegate d;
     URLRequest r(test_server_.GetURL("set-many-cookies?" +
                                      base::IntToString(num_cookies)),
-                                     &d,
-                                     &default_context_);
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     bool is_success = r.status().is_success();
 
     if (!is_success) {
       // Requests handled by ChromeFrame send a less precise error message,
@@ skipping 19 matching lines @@
 TEST_F(URLRequestTestHTTP, ProxyTunnelRedirectTest) {
   ASSERT_TRUE(test_server_.Start());
 
   TestNetworkDelegate network_delegate;  // Must outlive URLRequest.
   TestURLRequestContextWithProxy context(
       test_server_.host_port_pair().ToString(),
       &network_delegate);
 
   TestDelegate d;
   {
-    URLRequest r(GURL("https://www.redirect.com/"), &d, &context);
+    URLRequest r(GURL("https://www.redirect.com/"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::FAILED, r.status().status());
     EXPECT_EQ(ERR_TUNNEL_CONNECTION_FAILED, r.status().error());
     EXPECT_EQ(1, d.response_started_count());
     // We should not have followed the redirect.
     EXPECT_EQ(0, d.received_redirect_count());
   }
 }
 
 // This is the same as the previous test, but checks that the network delegate
 // registers the error.
 TEST_F(URLRequestTestHTTP, NetworkDelegateTunnelConnectionFailed) {
   ASSERT_TRUE(test_server_.Start());
 
   TestNetworkDelegate network_delegate;  // Must outlive URLRequest.
   TestURLRequestContextWithProxy context(
       test_server_.host_port_pair().ToString(),
       &network_delegate);
 
   TestDelegate d;
   {
-    URLRequest r(GURL("https://www.redirect.com/"), &d, &context);
+    URLRequest r(GURL("https://www.redirect.com/"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::FAILED, r.status().status());
     EXPECT_EQ(ERR_TUNNEL_CONNECTION_FAILED, r.status().error());
     EXPECT_EQ(1, d.response_started_count());
     // We should not have followed the redirect.
     EXPECT_EQ(0, d.received_redirect_count());
@@ skipping 20 matching lines @@
   network_delegate.set_block_on(
       BlockingNetworkDelegate::ON_BEFORE_URL_REQUEST |
       BlockingNetworkDelegate::ON_BEFORE_SEND_HEADERS |
       BlockingNetworkDelegate::ON_HEADERS_RECEIVED);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
-    URLRequest r(test_server_.GetURL("empty.html"), &d, &context);
+    URLRequest r(test_server_.GetURL("empty.html"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
 
     r.Start();
     for (size_t i = 0; i < blocking_stages_length; ++i) {
       base::RunLoop().Run();
       EXPECT_EQ(blocking_stages[i],
                 network_delegate.stage_blocked_for_callback());
       network_delegate.DoCallback(OK);
     }
     base::RunLoop().Run();
     EXPECT_EQ(200, r.GetResponseCode());
@@ skipping 12 matching lines @@
   BlockingNetworkDelegate network_delegate(
       BlockingNetworkDelegate::AUTO_CALLBACK);
   network_delegate.set_block_on(BlockingNetworkDelegate::ON_BEFORE_URL_REQUEST);
   network_delegate.set_retval(ERR_EMPTY_RESPONSE);
 
   TestURLRequestContextWithProxy context(
       test_server_.host_port_pair().ToString(),
       &network_delegate);
 
   {
-    URLRequest r(test_server_.GetURL(std::string()), &d, &context);
+    URLRequest r(test_server_.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
 
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::FAILED, r.status().status());
     EXPECT_EQ(ERR_EMPTY_RESPONSE, r.status().error());
     EXPECT_EQ(1, network_delegate.created_requests());
     EXPECT_EQ(0, network_delegate.destroyed_requests());
   }
   EXPECT_EQ(1, network_delegate.destroyed_requests());
 }
 
 // Helper function for NetworkDelegateCancelRequestAsynchronously and
 // NetworkDelegateCancelRequestSynchronously. Sets up a blocking network
 // delegate operating in |block_mode| and a request for |url|. It blocks the
 // request in |stage| and cancels it with ERR_BLOCKED_BY_CLIENT.
 void NetworkDelegateCancelRequest(BlockingNetworkDelegate::BlockMode block_mode,
                                   BlockingNetworkDelegate::Stage stage,
                                   const GURL& url) {
   TestDelegate d;
   BlockingNetworkDelegate network_delegate(block_mode);
   network_delegate.set_retval(ERR_BLOCKED_BY_CLIENT);
   network_delegate.set_block_on(stage);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
-    URLRequest r(url, &d, &context);
+    URLRequest r(url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
 
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::FAILED, r.status().status());
     EXPECT_EQ(ERR_BLOCKED_BY_CLIENT, r.status().error());
     EXPECT_EQ(1, network_delegate.created_requests());
     EXPECT_EQ(0, network_delegate.destroyed_requests());
   }
   EXPECT_EQ(1, network_delegate.destroyed_requests());
@@ skipping 56 matching lines @@
   network_delegate.set_block_on(BlockingNetworkDelegate::ON_BEFORE_URL_REQUEST);
   GURL redirect_url(test_server_.GetURL("simple.html"));
   network_delegate.set_redirect_url(redirect_url);
 
   TestURLRequestContextWithProxy context(
       test_server_.host_port_pair().ToString(),
       &network_delegate);
 
   {
     GURL original_url(test_server_.GetURL("empty.html"));
-    URLRequest r(original_url, &d, &context);
+    URLRequest r(
+        original_url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
 
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(0, r.status().error());
     EXPECT_EQ(redirect_url, r.url());
     EXPECT_EQ(original_url, r.original_url());
     EXPECT_EQ(2U, r.url_chain().size());
     EXPECT_EQ(1, network_delegate.created_requests());
@@ skipping 12 matching lines @@
       BlockingNetworkDelegate::SYNCHRONOUS);
   GURL redirect_url(test_server_.GetURL("simple.html"));
   network_delegate.set_redirect_url(redirect_url);
 
   TestURLRequestContextWithProxy context(
       test_server_.host_port_pair().ToString(),
       &network_delegate);
 
   {
     GURL original_url(test_server_.GetURL("empty.html"));
-    URLRequest r(original_url, &d, &context);
+    URLRequest r(
+        original_url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
 
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(0, r.status().error());
     EXPECT_EQ(redirect_url, r.url());
     EXPECT_EQ(original_url, r.original_url());
     EXPECT_EQ(2U, r.url_chain().size());
     EXPECT_EQ(1, network_delegate.created_requests());
@@ skipping 14 matching lines @@
   network_delegate.set_block_on(BlockingNetworkDelegate::ON_BEFORE_URL_REQUEST);
   GURL redirect_url(test_server_.GetURL("echo"));
   network_delegate.set_redirect_url(redirect_url);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
     GURL original_url(test_server_.GetURL("empty.html"));
-    URLRequest r(original_url, &d, &context);
+    URLRequest r(
+        original_url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
     r.set_method("POST");
     r.set_upload(make_scoped_ptr(CreateSimpleUploadData(kData)));
     HttpRequestHeaders headers;
     headers.SetHeader(HttpRequestHeaders::kContentLength,
                       base::UintToString(arraysize(kData) - 1));
     r.SetExtraRequestHeaders(headers);
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
@@ skipping 21 matching lines @@
       BlockingNetworkDelegate::SYNCHRONOUS);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   d.set_credentials(AuthCredentials(kUser, kSecret));
 
   {
     GURL url(test_server_.GetURL("auth-basic"));
-    URLRequest r(url, &d, &context);
+    URLRequest r(url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
     r.Start();
 
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(0, r.status().error());
     EXPECT_EQ(200, r.GetResponseCode());
     EXPECT_TRUE(d.auth_required_called());
     EXPECT_EQ(1, network_delegate.created_requests());
     EXPECT_EQ(0, network_delegate.destroyed_requests());
@@ skipping 10 matching lines @@
       BlockingNetworkDelegate::SYNCHRONOUS);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   d.set_credentials(AuthCredentials(kUser, kSecret));
 
   {
     GURL url(test_server_.GetURL("auth-basic"));
-    URLRequest r(url, &d, &context);
+    URLRequest r(url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
     r.Start();
 
     {
       HttpRequestHeaders headers;
       EXPECT_TRUE(r.GetFullRequestHeaders(&headers));
       EXPECT_FALSE(headers.HasHeader("Authorization"));
     }
 
     base::RunLoop().Run();
 
@@ skipping 20 matching lines @@
       NetworkDelegate::AUTH_REQUIRED_RESPONSE_SET_AUTH);
 
   network_delegate.set_auth_credentials(AuthCredentials(kUser, kSecret));
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
     GURL url(test_server_.GetURL("auth-basic"));
-    URLRequest r(url, &d, &context);
+    URLRequest r(url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(0, r.status().error());
     EXPECT_EQ(200, r.GetResponseCode());
     EXPECT_FALSE(d.auth_required_called());
     EXPECT_EQ(1, network_delegate.created_requests());
     EXPECT_EQ(0, network_delegate.destroyed_requests());
   }
@@ skipping 14 matching lines @@
       NetworkDelegate::AUTH_REQUIRED_RESPONSE_SET_AUTH);
 
   network_delegate.set_auth_credentials(AuthCredentials(kUser, kSecret));
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
     GURL url(test_server_.GetURL("auth-basic"));
-    URLRequest r(url, &d, &context);
+    URLRequest r(url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(0, r.status().error());
     EXPECT_EQ(200, r.GetResponseCode());
     EXPECT_FALSE(d.auth_required_called());
     EXPECT_EQ(1, network_delegate.created_requests());
     EXPECT_EQ(0, network_delegate.destroyed_requests());
 
@@ skipping 17 matching lines @@
   network_delegate.set_block_on(BlockingNetworkDelegate::ON_AUTH_REQUIRED);
   network_delegate.set_auth_retval(
       NetworkDelegate::AUTH_REQUIRED_RESPONSE_CANCEL_AUTH);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
     GURL url(test_server_.GetURL("auth-basic"));
-    URLRequest r(url, &d, &context);
+    URLRequest r(url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(OK, r.status().error());
     EXPECT_EQ(401, r.GetResponseCode());
     EXPECT_FALSE(d.auth_required_called());
     EXPECT_EQ(1, network_delegate.created_requests());
     EXPECT_EQ(0, network_delegate.destroyed_requests());
   }
@@ skipping 13 matching lines @@
   network_delegate.set_block_on(BlockingNetworkDelegate::ON_AUTH_REQUIRED);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   d.set_credentials(AuthCredentials(kUser, kSecret));
 
   {
     GURL url(test_server_.GetURL("auth-basic"));
-    URLRequest r(url, &d, &context);
+    URLRequest r(url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(0, r.status().error());
     EXPECT_EQ(200, r.GetResponseCode());
     EXPECT_TRUE(d.auth_required_called());
     EXPECT_EQ(1, network_delegate.created_requests());
     EXPECT_EQ(0, network_delegate.destroyed_requests());
   }
@@ skipping 14 matching lines @@
 
   AuthCredentials auth_credentials(kUser, kSecret);
   network_delegate.set_auth_credentials(auth_credentials);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
     GURL url(test_server_.GetURL("auth-basic"));
-    URLRequest r(url, &d, &context);
+    URLRequest r(url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(0, r.status().error());
 
     EXPECT_EQ(200, r.GetResponseCode());
     EXPECT_FALSE(d.auth_required_called());
     EXPECT_EQ(1, network_delegate.created_requests());
     EXPECT_EQ(0, network_delegate.destroyed_requests());
@@ skipping 12 matching lines @@
   network_delegate.set_block_on(BlockingNetworkDelegate::ON_AUTH_REQUIRED);
   network_delegate.set_auth_retval(
       NetworkDelegate::AUTH_REQUIRED_RESPONSE_CANCEL_AUTH);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
     GURL url(test_server_.GetURL("auth-basic"));
-    URLRequest r(url, &d, &context);
+    URLRequest r(url, DEFAULT_PRIORITY, &d, &context, &network_delegate);
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(OK, r.status().error());
     EXPECT_EQ(401, r.GetResponseCode());
     EXPECT_FALSE(d.auth_required_called());
     EXPECT_EQ(1, network_delegate.created_requests());
     EXPECT_EQ(0, network_delegate.destroyed_requests());
   }
   EXPECT_EQ(1, network_delegate.destroyed_requests());
 }
 
 // Tests that we can handle when a network request was canceled while we were
 // waiting for the network delegate.
 // Part 1: Request is cancelled while waiting for OnBeforeURLRequest callback.
 TEST_F(URLRequestTestHTTP, NetworkDelegateCancelWhileWaiting1) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   BlockingNetworkDelegate network_delegate(
       BlockingNetworkDelegate::USER_CALLBACK);
   network_delegate.set_block_on(BlockingNetworkDelegate::ON_BEFORE_URL_REQUEST);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
-    URLRequest r(test_server_.GetURL(std::string()), &d, &context);
+    URLRequest r(test_server_.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
 
     r.Start();
     base::RunLoop().Run();
     EXPECT_EQ(BlockingNetworkDelegate::ON_BEFORE_URL_REQUEST,
               network_delegate.stage_blocked_for_callback());
     EXPECT_EQ(0, network_delegate.completed_requests());
     // Cancel before callback.
     r.Cancel();
     // Ensure that network delegate is notified.
     EXPECT_EQ(1, network_delegate.completed_requests());
@@ skipping 15 matching lines @@
   BlockingNetworkDelegate network_delegate(
       BlockingNetworkDelegate::USER_CALLBACK);
   network_delegate.set_block_on(
       BlockingNetworkDelegate::ON_BEFORE_SEND_HEADERS);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
-    URLRequest r(test_server_.GetURL(std::string()), &d, &context);
+    URLRequest r(test_server_.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
 
     r.Start();
     base::RunLoop().Run();
     EXPECT_EQ(BlockingNetworkDelegate::ON_BEFORE_SEND_HEADERS,
               network_delegate.stage_blocked_for_callback());
     EXPECT_EQ(0, network_delegate.completed_requests());
     // Cancel before callback.
     r.Cancel();
     // Ensure that network delegate is notified.
     EXPECT_EQ(1, network_delegate.completed_requests());
@@ skipping 14 matching lines @@
   TestDelegate d;
   BlockingNetworkDelegate network_delegate(
       BlockingNetworkDelegate::USER_CALLBACK);
   network_delegate.set_block_on(BlockingNetworkDelegate::ON_HEADERS_RECEIVED);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
-    URLRequest r(test_server_.GetURL(std::string()), &d, &context);
+    URLRequest r(test_server_.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
 
     r.Start();
     base::RunLoop().Run();
     EXPECT_EQ(BlockingNetworkDelegate::ON_HEADERS_RECEIVED,
               network_delegate.stage_blocked_for_callback());
     EXPECT_EQ(0, network_delegate.completed_requests());
     // Cancel before callback.
     r.Cancel();
     // Ensure that network delegate is notified.
     EXPECT_EQ(1, network_delegate.completed_requests());
@@ skipping 14 matching lines @@
   TestDelegate d;
   BlockingNetworkDelegate network_delegate(
       BlockingNetworkDelegate::USER_CALLBACK);
   network_delegate.set_block_on(BlockingNetworkDelegate::ON_AUTH_REQUIRED);
 
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   {
-    URLRequest r(test_server_.GetURL("auth-basic"), &d, &context);
+    URLRequest r(test_server_.GetURL("auth-basic"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
 
     r.Start();
     base::RunLoop().Run();
     EXPECT_EQ(BlockingNetworkDelegate::ON_AUTH_REQUIRED,
               network_delegate.stage_blocked_for_callback());
     EXPECT_EQ(0, network_delegate.completed_requests());
     // Cancel before callback.
     r.Cancel();
     // Ensure that network delegate is notified.
     EXPECT_EQ(1, network_delegate.completed_requests());
@@ skipping 11 matching lines @@
 TEST_F(URLRequestTestHTTP, UnexpectedServerAuthTest) {
   ASSERT_TRUE(test_server_.Start());
 
   TestNetworkDelegate network_delegate;  // Must outlive URLRequest.
   TestURLRequestContextWithProxy context(
       test_server_.host_port_pair().ToString(),
       &network_delegate);
 
   TestDelegate d;
   {
-    URLRequest r(GURL("https://www.server-auth.com/"), &d, &context);
+    URLRequest r(GURL("https://www.server-auth.com/"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::FAILED, r.status().status());
     EXPECT_EQ(ERR_TUNNEL_CONNECTION_FAILED, r.status().error());
   }
 }
 
 TEST_F(URLRequestTestHTTP, GetTest_NoCache) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL(std::string()), &d, &default_context_);
+    URLRequest r(test_server_.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_NE(0, d.bytes_received());
     EXPECT_EQ(test_server_.host_port_pair().host(),
@@ skipping 45 matching lines @@
       upper_bound = num_cookies;
   }
   // Success: the test did not crash.
 }
 
 TEST_F(URLRequestTestHTTP, GetTest) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL(std::string()), &d, &default_context_);
+    URLRequest r(test_server_.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_NE(0, d.bytes_received());
     EXPECT_EQ(test_server_.host_port_pair().host(),
               r.GetSocketAddress().host());
     EXPECT_EQ(test_server_.host_port_pair().port(),
               r.GetSocketAddress().port());
   }
 }
 
 TEST_F(URLRequestTestHTTP, GetTest_GetFullRequestHeaders) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
     GURL test_url(test_server_.GetURL(std::string()));
-    URLRequest r(test_url, &d, &default_context_);
+    URLRequest r(test_url,
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     HttpRequestHeaders headers;
     EXPECT_FALSE(r.GetFullRequestHeaders(&headers));
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_NE(0, d.bytes_received());
     EXPECT_EQ(test_server_.host_port_pair().host(),
               r.GetSocketAddress().host());
     EXPECT_EQ(test_server_.host_port_pair().port(),
               r.GetSocketAddress().port());
 
     EXPECT_TRUE(d.have_full_request_headers());
     CheckFullRequestHeaders(d.full_request_headers(), test_url);
   }
 }
 
 TEST_F(URLRequestTestHTTP, GetTestLoadTiming) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL(std::string()), &d, &default_context_);
+    URLRequest r(test_server_.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     LoadTimingInfo load_timing_info;
     r.GetLoadTimingInfo(&load_timing_info);
     TestLoadTimingNotReused(load_timing_info, CONNECT_TIMING_HAS_DNS_TIMES);
 
@@ skipping 29 matching lines @@
     {
       std::string test_file =
           base::StringPrintf("compressedfiles/BullRunSpeech.txt?%c",
                              test_parameters[i]);
 
       TestNetworkDelegate network_delegate;  // Must outlive URLRequest.
       TestURLRequestContext context(true);
       context.set_network_delegate(&network_delegate);
       context.Init();
 
-      URLRequest r(test_server_.GetURL(test_file), &d, &context);
+      URLRequest r(test_server_.GetURL(test_file),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &context,
+                   &network_delegate);
       r.Start();
       EXPECT_TRUE(r.is_pending());
 
       base::RunLoop().Run();
 
       EXPECT_EQ(1, d.response_started_count());
       EXPECT_FALSE(d.received_data_before_response());
       VLOG(1) << " Received " << d.bytes_received() << " bytes"
               << " status = " << r.status().status()
               << " error = " << r.status().error();
@@ skipping 15 matching lines @@
   SpawnedTestServer https_test_server(
       SpawnedTestServer::TYPE_HTTPS, SpawnedTestServer::kLocalhost,
       base::FilePath(FILE_PATH_LITERAL("net/data/ssl")));
   ASSERT_TRUE(https_test_server.Start());
 
   // An https server is sent a request with an https referer,
   // and responds with a redirect to an http url. The http
   // server should not be sent the referer.
   GURL http_destination = test_server_.GetURL(std::string());
   TestDelegate d;
-  URLRequest req(https_test_server.GetURL(
-      "server-redirect?" + http_destination.spec()), &d, &default_context_);
+  URLRequest req(
+      https_test_server.GetURL("server-redirect?" + http_destination.spec()),
+      DEFAULT_PRIORITY,
+      &d,
+      &default_context_,
+      &default_network_delegate_);
   req.SetReferrer("https://www.referrer.com/");
   req.Start();
   base::RunLoop().Run();
 
   EXPECT_EQ(1, d.response_started_count());
   EXPECT_EQ(1, d.received_redirect_count());
   EXPECT_EQ(http_destination, req.url());
   EXPECT_EQ(std::string(), req.referrer());
 }
 
 TEST_F(URLRequestTestHTTP, RedirectLoadTiming) {
   ASSERT_TRUE(test_server_.Start());
 
   GURL destination_url = test_server_.GetURL(std::string());
   GURL original_url =
       test_server_.GetURL("server-redirect?" + destination_url.spec());
   TestDelegate d;
-  URLRequest req(original_url, &d, &default_context_);
+  URLRequest req(original_url,
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::RunLoop().Run();
 
   EXPECT_EQ(1, d.response_started_count());
   EXPECT_EQ(1, d.received_redirect_count());
   EXPECT_EQ(destination_url, req.url());
   EXPECT_EQ(original_url, req.original_url());
   ASSERT_EQ(2U, req.url_chain().size());
   EXPECT_EQ(original_url, req.url_chain()[0]);
   EXPECT_EQ(destination_url, req.url_chain()[1]);
@@ skipping 19 matching lines @@
 
 TEST_F(URLRequestTestHTTP, MultipleRedirectTest) {
   ASSERT_TRUE(test_server_.Start());
 
   GURL destination_url = test_server_.GetURL(std::string());
   GURL middle_redirect_url =
       test_server_.GetURL("server-redirect?" + destination_url.spec());
   GURL original_url = test_server_.GetURL(
       "server-redirect?" + middle_redirect_url.spec());
   TestDelegate d;
-  URLRequest req(original_url, &d, &default_context_);
+  URLRequest req(original_url,
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::RunLoop().Run();
 
   EXPECT_EQ(1, d.response_started_count());
   EXPECT_EQ(2, d.received_redirect_count());
   EXPECT_EQ(destination_url, req.url());
   EXPECT_EQ(original_url, req.original_url());
   ASSERT_EQ(3U, req.url_chain().size());
   EXPECT_EQ(original_url, req.url_chain()[0]);
   EXPECT_EQ(middle_redirect_url, req.url_chain()[1]);
@@ skipping 295 matching lines @@
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate request_delegate;
   TestURLRequestContext context(true);
   context.set_network_delegate(NULL);
   context.set_net_log(&net_log_);
   context.Init();
 
   {
     URLRequest r(test_server_.GetURL("empty.html"),
-                 &request_delegate, &context);
+                 DEFAULT_PRIORITY,
+                 &request_delegate,
+                 &context,
+                 NULL);
     LoadStateWithParam load_state = r.GetLoadState();
     EXPECT_EQ(LOAD_STATE_IDLE, load_state.state);
     EXPECT_EQ(string16(), load_state.param);
 
     AsyncDelegateLogger::Run(
         &r,
         LOAD_STATE_WAITING_FOR_DELEGATE,
         LOAD_STATE_WAITING_FOR_DELEGATE,
         LOAD_STATE_IDLE,
         base::Bind(&URLRequest::Start, base::Unretained(&r)));
@@ skipping 25 matching lines @@
 
   TestDelegate request_delegate;
   AsyncLoggingNetworkDelegate network_delegate;
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.set_net_log(&net_log_);
   context.Init();
 
   {
     URLRequest r(test_server_.GetURL("simple.html"),
-                 &request_delegate, &context);
+                 DEFAULT_PRIORITY,
+                 &request_delegate,
+                 &context,
+                 &network_delegate);
     LoadStateWithParam load_state = r.GetLoadState();
     EXPECT_EQ(LOAD_STATE_IDLE, load_state.state);
     EXPECT_EQ(string16(), load_state.param);
 
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(200, r.GetResponseCode());
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(1, network_delegate.created_requests());
@@ skipping 30 matching lines @@
 
   TestDelegate request_delegate;
   AsyncLoggingNetworkDelegate network_delegate;
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.set_net_log(&net_log_);
   context.Init();
 
   {
     URLRequest r(test_server_.GetURL("server-redirect?simple.html"),
-                 &request_delegate, &context);
+                 DEFAULT_PRIORITY,
+                 &request_delegate,
+                 &context,
+                 &network_delegate);
     LoadStateWithParam load_state = r.GetLoadState();
     EXPECT_EQ(LOAD_STATE_IDLE, load_state.state);
     EXPECT_EQ(string16(), load_state.param);
 
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(200, r.GetResponseCode());
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(2, network_delegate.created_requests());
@@ skipping 55 matching lines @@
 
   TestDelegate request_delegate;
   AsyncLoggingNetworkDelegate network_delegate;
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.set_net_log(&net_log_);
   context.Init();
 
   {
     URLRequest r(test_server_.GetURL("auth-basic"),
-                 &request_delegate, &context);
+                 DEFAULT_PRIORITY,
+                 &request_delegate,
+                 &context,
+                 &network_delegate);
     LoadStateWithParam load_state = r.GetLoadState();
     EXPECT_EQ(LOAD_STATE_IDLE, load_state.state);
     EXPECT_EQ(string16(), load_state.param);
 
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(200, r.GetResponseCode());
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
     EXPECT_EQ(1, network_delegate.created_requests());
@@ skipping 37 matching lines @@
   context.set_net_log(&net_log_);
   context.Init();
 
   {
     // A chunked response with delays between chunks is used to make sure that
     // attempts by the URLRequest delegate to log information while reading the
     // body are ignored.  Since they are ignored, this test is robust against
     // the possability of multiple reads being combined in the unlikely event
     // that it occurs.
     URLRequest r(test_server_.GetURL("chunked?waitBetweenChunks=20"),
-                 &request_delegate, &context);
+                 DEFAULT_PRIORITY,
+                 &request_delegate,
+                 &context,
+                 NULL);
     LoadStateWithParam load_state = r.GetLoadState();
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(200, r.GetResponseCode());
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
   }
 
   CapturingNetLog::CapturedEntryList entries;
   net_log_.GetEntries(&entries);
@@ skipping 27 matching lines @@
 
   AsyncLoggingUrlRequestDelegate request_delegate(
       AsyncLoggingUrlRequestDelegate::NO_CANCEL);
   TestURLRequestContext context(true);
   context.set_network_delegate(NULL);
   context.set_net_log(&net_log_);
   context.Init();
 
   {
     URLRequest r(test_server_.GetURL("server-redirect?simple.html"),
-                 &request_delegate, &context);
+                 DEFAULT_PRIORITY,
+                 &request_delegate,
+                 &context,
+                 NULL);
     LoadStateWithParam load_state = r.GetLoadState();
     r.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(200, r.GetResponseCode());
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
   }
 
   CapturingNetLog::CapturedEntryList entries;
   net_log_.GetEntries(&entries);
@@ skipping 37 matching lines @@
        ++test_case) {
     AsyncLoggingUrlRequestDelegate request_delegate(kCancelStages[test_case]);
     TestURLRequestContext context(true);
     CapturingNetLog net_log;
     context.set_network_delegate(NULL);
     context.set_net_log(&net_log);
     context.Init();
 
     {
       URLRequest r(test_server_.GetURL("server-redirect?simple.html"),
-                   &request_delegate, &context);
+                   DEFAULT_PRIORITY,
+                   &request_delegate,
+                   &context,
+                   NULL);
       LoadStateWithParam load_state = r.GetLoadState();
       r.Start();
       base::RunLoop().Run();
       EXPECT_EQ(URLRequestStatus::CANCELED, r.status().status());
     }
 
     CapturingNetLog::CapturedEntryList entries;
     net_log.GetEntries(&entries);
 
     // Delegate info is always logged in both OnReceivedRedirect and
@@ skipping 40 matching lines @@
 }  // namespace
 
 TEST_F(URLRequestTestHTTP, RedirectWithAdditionalHeadersTest) {
   ASSERT_TRUE(test_server_.Start());
 
   GURL destination_url = test_server_.GetURL(
       "echoheader?" + std::string(kExtraHeader));
   GURL original_url = test_server_.GetURL(
       "server-redirect?" + destination_url.spec());
   RedirectWithAdditionalHeadersDelegate d;
-  URLRequest req(original_url, &d, &default_context_);
+  URLRequest req(original_url,
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::RunLoop().Run();
 
   std::string value;
   const HttpRequestHeaders& headers = req.extra_request_headers();
   EXPECT_TRUE(headers.GetHeader(kExtraHeader, &value));
   EXPECT_EQ(kExtraValue, value);
   EXPECT_FALSE(req.is_pending());
   EXPECT_FALSE(req.is_redirecting());
   EXPECT_EQ(kExtraValue, d.data_received());
@@ skipping 15 matching lines @@
 }  // namespace
 
 TEST_F(URLRequestTestHTTP, RedirectWithHeaderRemovalTest) {
   ASSERT_TRUE(test_server_.Start());
 
   GURL destination_url = test_server_.GetURL(
       "echoheader?" + std::string(kExtraHeaderToRemove));
   GURL original_url = test_server_.GetURL(
       "server-redirect?" + destination_url.spec());
   RedirectWithHeaderRemovalDelegate d;
-  URLRequest req(original_url, &d, &default_context_);
+  URLRequest req(original_url,
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.SetExtraRequestHeaderByName(kExtraHeaderToRemove, "dummy", false);
   req.Start();
   base::RunLoop().Run();
 
   std::string value;
   const HttpRequestHeaders& headers = req.extra_request_headers();
   EXPECT_FALSE(headers.GetHeader(kExtraHeaderToRemove, &value));
   EXPECT_FALSE(req.is_pending());
   EXPECT_FALSE(req.is_redirecting());
   EXPECT_EQ("None", d.data_received());
 }
 
 TEST_F(URLRequestTestHTTP, CancelTest) {
   TestDelegate d;
   {
-    URLRequest r(GURL("http://www.google.com/"), &d, &default_context_);
+    URLRequest r(GURL("http://www.google.com/"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     r.Cancel();
 
     base::RunLoop().Run();
 
     // We expect to receive OnResponseStarted even though the request has been
     // cancelled.
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_EQ(0, d.bytes_received());
     EXPECT_FALSE(d.received_data_before_response());
   }
 }
 
 TEST_F(URLRequestTestHTTP, CancelTest2) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL(std::string()), &d, &default_context_);
+    URLRequest r(test_server_.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     d.set_cancel_in_response_started(true);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_EQ(0, d.bytes_received());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(URLRequestStatus::CANCELED, r.status().status());
   }
 }
 
 TEST_F(URLRequestTestHTTP, CancelTest3) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL(std::string()), &d, &default_context_);
+    URLRequest r(test_server_.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     d.set_cancel_in_received_data(true);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
     // There is no guarantee about how much data was received
     // before the cancel was issued.  It could have been 0 bytes,
     // or it could have been all the bytes.
     // EXPECT_EQ(0, d.bytes_received());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(URLRequestStatus::CANCELED, r.status().status());
   }
 }
 
 TEST_F(URLRequestTestHTTP, CancelTest4) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL(std::string()), &d, &default_context_);
+    URLRequest r(test_server_.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     // The request will be implicitly canceled when it is destroyed. The
     // test delegate must not post a quit message when this happens because
     // this test doesn't actually have a message loop. The quit message would
     // get put on this thread's message queue and the next test would exit
     // early, causing problems.
     d.set_quit_on_complete(false);
   }
   // expect things to just cleanup properly.
 
   // we won't actually get a received reponse here because we've never run the
   // message loop
   EXPECT_FALSE(d.received_data_before_response());
   EXPECT_EQ(0, d.bytes_received());
 }
 
 TEST_F(URLRequestTestHTTP, CancelTest5) {
   ASSERT_TRUE(test_server_.Start());
 
   // populate cache
   {
     TestDelegate d;
-    URLRequest r(test_server_.GetURL("cachetime"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("cachetime"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     base::RunLoop().Run();
     EXPECT_EQ(URLRequestStatus::SUCCESS, r.status().status());
   }
 
   // cancel read from cache (see bug 990242)
   {
     TestDelegate d;
-    URLRequest r(test_server_.GetURL("cachetime"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("cachetime"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     r.Cancel();
     base::RunLoop().Run();
 
     EXPECT_EQ(URLRequestStatus::CANCELED, r.status().status());
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_EQ(0, d.bytes_received());
     EXPECT_FALSE(d.received_data_before_response());
   }
 }
 
 TEST_F(URLRequestTestHTTP, PostTest) {
   ASSERT_TRUE(test_server_.Start());
   HTTPUploadDataOperationTest("POST");
 }
 
 TEST_F(URLRequestTestHTTP, PutTest) {
   ASSERT_TRUE(test_server_.Start());
   HTTPUploadDataOperationTest("PUT");
 }
 
 TEST_F(URLRequestTestHTTP, PostEmptyTest) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL("echo"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("echo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.set_method("POST");
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     ASSERT_EQ(1, d.response_started_count())
         << "request failed: " << r.status().status()
         << ", error: " << r.status().error();
 
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_TRUE(d.data_received().empty());
   }
 }
 
 TEST_F(URLRequestTestHTTP, PostFileTest) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL("echo"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("echo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.set_method("POST");
 
     base::FilePath dir;
     PathService::Get(base::DIR_EXE, &dir);
     file_util::SetCurrentDirectory(dir);
 
     ScopedVector<UploadElementReader> element_readers;
 
     base::FilePath path;
     PathService::Get(base::DIR_SOURCE_ROOT, &path);
@@ skipping 39 matching lines @@
     EXPECT_EQ(size, d.bytes_received());
     EXPECT_EQ(std::string(&buf[0], size), d.data_received());
   }
 }
 
 TEST_F(URLRequestTestHTTP, TestPostChunkedDataBeforeStart) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL("echo"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("echo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.EnableChunkedUpload();
     r.set_method("POST");
     AddChunksToUpload(&r);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     VerifyReceivedDataMatchesChunks(&r, &d);
   }
 }
 
 TEST_F(URLRequestTestHTTP, TestPostChunkedDataJustAfterStart) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL("echo"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("echo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.EnableChunkedUpload();
     r.set_method("POST");
     r.Start();
     EXPECT_TRUE(r.is_pending());
     AddChunksToUpload(&r);
     base::RunLoop().Run();
 
     VerifyReceivedDataMatchesChunks(&r, &d);
   }
 }
 
 TEST_F(URLRequestTestHTTP, TestPostChunkedDataAfterStart) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL("echo"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("echo"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.EnableChunkedUpload();
     r.set_method("POST");
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().RunUntilIdle();
     AddChunksToUpload(&r);
     base::RunLoop().Run();
 
     VerifyReceivedDataMatchesChunks(&r, &d);
   }
 }
 
 TEST_F(URLRequestTestHTTP, ResponseHeadersTest) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
-  URLRequest req(
-      test_server_.GetURL("files/with-headers.html"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("files/with-headers.html"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::RunLoop().Run();
 
   const HttpResponseHeaders* headers = req.response_headers();
 
   // Simple sanity check that response_info() accesses the same data.
   EXPECT_EQ(headers, req.response_info().headers.get());
 
   std::string header;
   EXPECT_TRUE(headers->GetNormalizedHeader("cache-control", &header));
@@ skipping 12 matching lines @@
 
 TEST_F(URLRequestTestHTTP, ProcessSTS) {
   SpawnedTestServer::SSLOptions ssl_options;
   SpawnedTestServer https_test_server(
       SpawnedTestServer::TYPE_HTTPS,
       ssl_options,
       base::FilePath(FILE_PATH_LITERAL("net/data/url_request_unittest")));
   ASSERT_TRUE(https_test_server.Start());
 
   TestDelegate d;
-  URLRequest request(
-      https_test_server.GetURL("files/hsts-headers.html"),
-      &d,
-      &default_context_);
+  URLRequest request(https_test_server.GetURL("files/hsts-headers.html"),
+                     DEFAULT_PRIORITY,
+                     &d,
+                     &default_context_,
+                     &default_network_delegate_);
   request.Start();
   base::RunLoop().Run();
 
   TransportSecurityState* security_state =
       default_context_.transport_security_state();
   bool sni_available = true;
   TransportSecurityState::DomainState domain_state;
   EXPECT_TRUE(security_state->GetDomainState(
       SpawnedTestServer::kLocalhost, sni_available, &domain_state));
   EXPECT_EQ(TransportSecurityState::DomainState::MODE_FORCE_HTTPS,
@@ skipping 20 matching lines @@
 // validity/expiration.
 TEST_F(URLRequestTestHTTP, MAYBE_ProcessPKP) {
   SpawnedTestServer::SSLOptions ssl_options;
   SpawnedTestServer https_test_server(
       SpawnedTestServer::TYPE_HTTPS,
       ssl_options,
       base::FilePath(FILE_PATH_LITERAL("net/data/url_request_unittest")));
   ASSERT_TRUE(https_test_server.Start());
 
   TestDelegate d;
-  URLRequest request(
-      https_test_server.GetURL("files/hpkp-headers.html"),
-      &d,
-      &default_context_);
+  URLRequest request(https_test_server.GetURL("files/hpkp-headers.html"),
+                     DEFAULT_PRIORITY,
+                     &d,
+                     &default_context_,
+                     &default_network_delegate_);
   request.Start();
   base::RunLoop().Run();
 
   TransportSecurityState* security_state =
       default_context_.transport_security_state();
   bool sni_available = true;
   TransportSecurityState::DomainState domain_state;
   EXPECT_TRUE(security_state->GetDomainState(
       SpawnedTestServer::kLocalhost, sni_available, &domain_state));
   EXPECT_EQ(TransportSecurityState::DomainState::MODE_DEFAULT,
             domain_state.upgrade_mode);
   EXPECT_FALSE(domain_state.sts_include_subdomains);
   EXPECT_FALSE(domain_state.pkp_include_subdomains);
   EXPECT_TRUE(domain_state.HasPublicKeyPins());
   EXPECT_NE(domain_state.upgrade_expiry,
             domain_state.dynamic_spki_hashes_expiry);
 }
 
 TEST_F(URLRequestTestHTTP, ProcessSTSOnce) {
   SpawnedTestServer::SSLOptions ssl_options;
   SpawnedTestServer https_test_server(
       SpawnedTestServer::TYPE_HTTPS,
       ssl_options,
       base::FilePath(FILE_PATH_LITERAL("net/data/url_request_unittest")));
   ASSERT_TRUE(https_test_server.Start());
 
   TestDelegate d;
   URLRequest request(
       https_test_server.GetURL("files/hsts-multiple-headers.html"),
+      DEFAULT_PRIORITY,
       &d,
-      &default_context_);
+      &default_context_,
+      &default_network_delegate_);
   request.Start();
   base::RunLoop().Run();
 
   // We should have set parameters from the first header, not the second.
   TransportSecurityState* security_state =
       default_context_.transport_security_state();
   bool sni_available = true;
   TransportSecurityState::DomainState domain_state;
   EXPECT_TRUE(security_state->GetDomainState(
       SpawnedTestServer::kLocalhost, sni_available, &domain_state));
   EXPECT_EQ(TransportSecurityState::DomainState::MODE_FORCE_HTTPS,
             domain_state.upgrade_mode);
   EXPECT_FALSE(domain_state.sts_include_subdomains);
   EXPECT_FALSE(domain_state.pkp_include_subdomains);
 }
 
 TEST_F(URLRequestTestHTTP, ProcessSTSAndPKP) {
   SpawnedTestServer::SSLOptions ssl_options;
   SpawnedTestServer https_test_server(
       SpawnedTestServer::TYPE_HTTPS,
       ssl_options,
       base::FilePath(FILE_PATH_LITERAL("net/data/url_request_unittest")));
   ASSERT_TRUE(https_test_server.Start());
 
   TestDelegate d;
   URLRequest request(
       https_test_server.GetURL("files/hsts-and-hpkp-headers.html"),
+      DEFAULT_PRIORITY,
       &d,
-      &default_context_);
+      &default_context_,
+      &default_network_delegate_);
   request.Start();
   base::RunLoop().Run();
 
   // We should have set parameters from the first header, not the second.
   TransportSecurityState* security_state =
       default_context_.transport_security_state();
   bool sni_available = true;
   TransportSecurityState::DomainState domain_state;
   EXPECT_TRUE(security_state->GetDomainState(
       SpawnedTestServer::kLocalhost, sni_available, &domain_state));
@@ skipping 20 matching lines @@
   SpawnedTestServer::SSLOptions ssl_options;
   SpawnedTestServer https_test_server(
       SpawnedTestServer::TYPE_HTTPS,
       ssl_options,
       base::FilePath(FILE_PATH_LITERAL("net/data/url_request_unittest")));
   ASSERT_TRUE(https_test_server.Start());
 
   TestDelegate d;
   URLRequest request(
       https_test_server.GetURL("files/hsts-and-hpkp-headers2.html"),
+      DEFAULT_PRIORITY,
       &d,
-      &default_context_);
+      &default_context_,
+      &default_network_delegate_);
   request.Start();
   base::RunLoop().Run();
 
   TransportSecurityState* security_state =
       default_context_.transport_security_state();
   bool sni_available = true;
   TransportSecurityState::DomainState domain_state;
   EXPECT_TRUE(security_state->GetDomainState(
       SpawnedTestServer::kLocalhost, sni_available, &domain_state));
   EXPECT_EQ(TransportSecurityState::DomainState::MODE_FORCE_HTTPS,
             domain_state.upgrade_mode);
 #if defined(OS_ANDROID)
   // Android's CertVerifyProc does not (yet) handle pins.
 #else
   EXPECT_TRUE(domain_state.HasPublicKeyPins());
 #endif
   EXPECT_NE(domain_state.upgrade_expiry,
             domain_state.dynamic_spki_hashes_expiry);
 
   EXPECT_TRUE(domain_state.sts_include_subdomains);
   EXPECT_FALSE(domain_state.pkp_include_subdomains);
 }
 
 TEST_F(URLRequestTestHTTP, ContentTypeNormalizationTest) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
-  URLRequest req(test_server_.GetURL(
-      "files/content-type-normalization.html"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("files/content-type-normalization.html"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::RunLoop().Run();
 
   std::string mime_type;
   req.GetMimeType(&mime_type);
   EXPECT_EQ("text/html", mime_type);
 
   std::string charset;
   req.GetCharset(&charset);
   EXPECT_EQ("utf-8", charset);
@@ skipping 11 matching lines @@
 
   // Test URLRequestJobFactoryImpl::IsSafeRedirectTarget().
   EXPECT_FALSE(job_factory_.IsSafeRedirectTarget(file_url));
   EXPECT_FALSE(job_factory_.IsSafeRedirectTarget(data_url));
 }
 
 TEST_F(URLRequestTestHTTP, RestrictFileRedirects) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
-  URLRequest req(test_server_.GetURL(
-      "files/redirect-to-file.html"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("files/redirect-to-file.html"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::RunLoop().Run();
 
   EXPECT_EQ(URLRequestStatus::FAILED, req.status().status());
   EXPECT_EQ(ERR_UNSAFE_REDIRECT, req.status().error());
 }
 
 TEST_F(URLRequestTestHTTP, RestrictDataRedirects) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
-  URLRequest req(test_server_.GetURL(
-      "files/redirect-to-data.html"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("files/redirect-to-data.html"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::MessageLoop::current()->Run();
 
   EXPECT_EQ(URLRequestStatus::FAILED, req.status().status());
   EXPECT_EQ(ERR_UNSAFE_REDIRECT, req.status().error());
 }
 
 TEST_F(URLRequestTestHTTP, RedirectToInvalidURL) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
-  URLRequest req(test_server_.GetURL(
-      "files/redirect-to-invalid-url.html"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("files/redirect-to-invalid-url.html"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::RunLoop().Run();
 
   EXPECT_EQ(URLRequestStatus::FAILED, req.status().status());
   EXPECT_EQ(ERR_INVALID_URL, req.status().error());
 }
 
 TEST_F(URLRequestTestHTTP, NoUserPassInReferrer) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
-  URLRequest req(
-      test_server_.GetURL("echoheader?Referer"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("echoheader?Referer"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.SetReferrer("http://user:pass@foo.com/");
   req.Start();
   base::RunLoop().Run();
 
   EXPECT_EQ(std::string("http://foo.com/"), d.data_received());
 }
 
 TEST_F(URLRequestTestHTTP, NoFragmentInReferrer) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
-  URLRequest req(
-      test_server_.GetURL("echoheader?Referer"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("echoheader?Referer"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.SetReferrer("http://foo.com/test#fragment");
   req.Start();
   base::RunLoop().Run();
 
   EXPECT_EQ(std::string("http://foo.com/test"), d.data_received());
 }
 
 TEST_F(URLRequestTestHTTP, EmptyReferrerAfterValidReferrer) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
-  URLRequest req(
-      test_server_.GetURL("echoheader?Referer"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("echoheader?Referer"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.SetReferrer("http://foo.com/test#fragment");
   req.SetReferrer("");
   req.Start();
   base::RunLoop().Run();
 
   EXPECT_EQ(std::string("None"), d.data_received());
 }
 
 TEST_F(URLRequestTestHTTP, CancelRedirect) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
     d.set_cancel_in_received_redirect(true);
-    URLRequest req(
-        test_server_.GetURL("files/redirect-test.html"), &d, &default_context_);
+    URLRequest req(test_server_.GetURL("files/redirect-test.html"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_EQ(0, d.bytes_received());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(URLRequestStatus::CANCELED, req.status().status());
   }
 }
 
 TEST_F(URLRequestTestHTTP, DeferredRedirect) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
     d.set_quit_on_redirect(true);
     GURL test_url(test_server_.GetURL("files/redirect-test.html"));
-    URLRequest req(test_url, &d, &default_context_);
+    URLRequest req(test_url,
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
 
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.received_redirect_count());
 
     req.FollowDeferredRedirect();
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
@@ skipping 13 matching lines @@
   }
 }
 
 TEST_F(URLRequestTestHTTP, DeferredRedirect_GetFullRequestHeaders) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
     d.set_quit_on_redirect(true);
     GURL test_url(test_server_.GetURL("files/redirect-test.html"));
-    URLRequest req(test_url, &d, &default_context_);
+    URLRequest req(test_url,
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
 
     EXPECT_FALSE(d.have_full_request_headers());
 
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.received_redirect_count());
     EXPECT_TRUE(d.have_full_request_headers());
     CheckFullRequestHeaders(d.full_request_headers(), test_url);
     d.ClearFullRequestHeaders();
@@ skipping 20 matching lines @@
     EXPECT_EQ(contents, d.data_received());
   }
 }
 
 TEST_F(URLRequestTestHTTP, CancelDeferredRedirect) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
     d.set_quit_on_redirect(true);
-    URLRequest req(
-        test_server_.GetURL("files/redirect-test.html"), &d, &default_context_);
+    URLRequest req(test_server_.GetURL("files/redirect-test.html"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.received_redirect_count());
 
     req.Cancel();
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_EQ(0, d.bytes_received());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(URLRequestStatus::CANCELED, req.status().status());
   }
 }
 
 TEST_F(URLRequestTestHTTP, VaryHeader) {
   ASSERT_TRUE(test_server_.Start());
 
   // Populate the cache.
   {
     TestDelegate d;
-    URLRequest req(
-        test_server_.GetURL("echoheadercache?foo"), &d, &default_context_);
+    URLRequest req(test_server_.GetURL("echoheadercache?foo"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
     HttpRequestHeaders headers;
     headers.SetHeader("foo", "1");
     req.SetExtraRequestHeaders(headers);
     req.Start();
     base::RunLoop().Run();
 
     LoadTimingInfo load_timing_info;
     req.GetLoadTimingInfo(&load_timing_info);
     TestLoadTimingNotReused(load_timing_info, CONNECT_TIMING_HAS_DNS_TIMES);
   }
 
   // Expect a cache hit.
   {
     TestDelegate d;
-    URLRequest req(
-        test_server_.GetURL("echoheadercache?foo"), &d, &default_context_);
+    URLRequest req(test_server_.GetURL("echoheadercache?foo"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
     HttpRequestHeaders headers;
     headers.SetHeader("foo", "1");
     req.SetExtraRequestHeaders(headers);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_TRUE(req.was_cached());
 
     LoadTimingInfo load_timing_info;
     req.GetLoadTimingInfo(&load_timing_info);
     TestLoadTimingCacheHitNoNetwork(load_timing_info);
   }
 
   // Expect a cache miss.
   {
     TestDelegate d;
-    URLRequest req(
-        test_server_.GetURL("echoheadercache?foo"), &d, &default_context_);
+    URLRequest req(test_server_.GetURL("echoheadercache?foo"),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
     HttpRequestHeaders headers;
     headers.SetHeader("foo", "2");
     req.SetExtraRequestHeaders(headers);
     req.Start();
     base::RunLoop().Run();
 
     EXPECT_FALSE(req.was_cached());
 
     LoadTimingInfo load_timing_info;
     req.GetLoadTimingInfo(&load_timing_info);
     TestLoadTimingNotReused(load_timing_info, CONNECT_TIMING_HAS_DNS_TIMES);
   }
 }
 
 TEST_F(URLRequestTestHTTP, BasicAuth) {
   ASSERT_TRUE(test_server_.Start());
 
   // populate the cache
   {
     TestDelegate d;
     d.set_credentials(AuthCredentials(kUser, kSecret));
 
-    URLRequest r(test_server_.GetURL("auth-basic"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("auth-basic"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
 
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("user/secret") != std::string::npos);
   }
 
   // repeat request with end-to-end validation.  since auth-basic results in a
   // cachable page, we expect this test to result in a 304.  in which case, the
   // response should be fetched from the cache.
   {
     TestDelegate d;
     d.set_credentials(AuthCredentials(kUser, kSecret));
 
-    URLRequest r(test_server_.GetURL("auth-basic"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("auth-basic"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.set_load_flags(LOAD_VALIDATE_CACHE);
     r.Start();
 
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("user/secret") != std::string::npos);
 
     // Should be the same cached document.
     EXPECT_TRUE(r.was_cached());
   }
@@ skipping 11 matching lines @@
   // Verify that when the transaction is restarted, it includes the new cookie.
   {
     TestNetworkDelegate network_delegate;  // Must outlive URLRequest.
     TestURLRequestContext context(true);
     context.set_network_delegate(&network_delegate);
     context.Init();
 
     TestDelegate d;
     d.set_credentials(AuthCredentials(kUser, kSecret));
 
-    URLRequest r(url_requiring_auth, &d, &context);
+    URLRequest r(
+        url_requiring_auth, DEFAULT_PRIORITY, &d, &context, &network_delegate);
     r.Start();
 
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("user/secret") != std::string::npos);
 
     // Make sure we sent the cookie in the restarted transaction.
     EXPECT_TRUE(d.data_received().find("Cookie: got_challenged=true")
         != std::string::npos);
   }
 
   // Same test as above, except this time the restart is initiated earlier
   // (without user intervention since identity is embedded in the URL).
   {
     TestNetworkDelegate network_delegate;  // Must outlive URLRequest.
     TestURLRequestContext context(true);
     context.set_network_delegate(&network_delegate);
     context.Init();
 
     TestDelegate d;
 
     GURL::Replacements replacements;
     std::string username("user2");
     std::string password("secret");
     replacements.SetUsernameStr(username);
     replacements.SetPasswordStr(password);
     GURL url_with_identity = url_requiring_auth.ReplaceComponents(replacements);
 
-    URLRequest r(url_with_identity, &d, &context);
+    URLRequest r(
+        url_with_identity, DEFAULT_PRIORITY, &d, &context, &network_delegate);
     r.Start();
 
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("user2/secret") != std::string::npos);
 
     // Make sure we sent the cookie in the restarted transaction.
     EXPECT_TRUE(d.data_received().find("Cookie: got_challenged=true")
         != std::string::npos);
   }
 }
 
 // Tests that load timing works as expected with auth and the cache.
 TEST_F(URLRequestTestHTTP, BasicAuthLoadTiming) {
   ASSERT_TRUE(test_server_.Start());
 
   // populate the cache
   {
     TestDelegate d;
     d.set_credentials(AuthCredentials(kUser, kSecret));
 
-    URLRequest r(test_server_.GetURL("auth-basic"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("auth-basic"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
 
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("user/secret") != std::string::npos);
 
     LoadTimingInfo load_timing_info_before_auth;
     EXPECT_TRUE(default_network_delegate_.GetLoadTimingInfoBeforeAuth(
         &load_timing_info_before_auth));
     TestLoadTimingNotReused(load_timing_info_before_auth,
@@ skipping 10 matching lines @@
               load_timing_info.connect_timing.connect_start);
   }
 
   // Repeat request with end-to-end validation.  Since auth-basic results in a
   // cachable page, we expect this test to result in a 304.  In which case, the
   // response should be fetched from the cache.
   {
     TestDelegate d;
     d.set_credentials(AuthCredentials(kUser, kSecret));
 
-    URLRequest r(test_server_.GetURL("auth-basic"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("auth-basic"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.set_load_flags(LOAD_VALIDATE_CACHE);
     r.Start();
 
     base::RunLoop().Run();
 
     EXPECT_TRUE(d.data_received().find("user/secret") != std::string::npos);
 
     // Should be the same cached document.
     EXPECT_TRUE(r.was_cached());
 
     // Since there was a request that went over the wire, the load timing
     // information should include connection times.
     LoadTimingInfo load_timing_info;
     r.GetLoadTimingInfo(&load_timing_info);
     TestLoadTimingNotReused(load_timing_info, CONNECT_TIMING_HAS_DNS_TIMES);
   }
 }
 
 // In this test, we do a POST which the server will 302 redirect.
 // The subsequent transaction should use GET, and should not send the
 // Content-Type header.
 // http://code.google.com/p/chromium/issues/detail?id=843
 TEST_F(URLRequestTestHTTP, Post302RedirectGet) {
   ASSERT_TRUE(test_server_.Start());
 
   const char kData[] = "hello world";
 
   TestDelegate d;
-  URLRequest req(
-      test_server_.GetURL("files/redirect-to-echoall"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("files/redirect-to-echoall"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.set_method("POST");
   req.set_upload(make_scoped_ptr(CreateSimpleUploadData(kData)));
 
   // Set headers (some of which are specific to the POST).
   HttpRequestHeaders headers;
   headers.AddHeadersFromString(
     "Content-Type: multipart/form-data; "
     "boundary=----WebKitFormBoundaryAADeAA+NAAWMAAwZ\r\n"
     "Accept: text/xml,application/xml,application/xhtml+xml,text/html;q=0.9,"
     "text/plain;q=0.8,image/png,*/*;q=0.5\r\n"
@@ skipping 65 matching lines @@
   HTTPRedirectMethodTest(url, "PUT", "PUT", true);
   HTTPRedirectMethodTest(url, "HEAD", "HEAD", false);
 }
 
 TEST_F(URLRequestTestHTTP, InterceptPost302RedirectGet) {
   ASSERT_TRUE(test_server_.Start());
 
   const char kData[] = "hello world";
 
   TestDelegate d;
-  URLRequest req(test_server_.GetURL("empty.html"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("empty.html"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.set_method("POST");
   req.set_upload(make_scoped_ptr(CreateSimpleUploadData(kData)));
   HttpRequestHeaders headers;
   headers.SetHeader(HttpRequestHeaders::kContentLength,
                     base::UintToString(arraysize(kData) - 1));
   req.SetExtraRequestHeaders(headers);
 
   URLRequestRedirectJob* job = new URLRequestRedirectJob(
       &req, &default_network_delegate_, test_server_.GetURL("echo"),
       URLRequestRedirectJob::REDIRECT_302_FOUND);
   AddTestInterceptor()->set_main_intercept_job(job);
 
   req.Start();
   base::RunLoop().Run();
   EXPECT_EQ("GET", req.method());
 }
 
 TEST_F(URLRequestTestHTTP, InterceptPost307RedirectPost) {
   ASSERT_TRUE(test_server_.Start());
 
   const char kData[] = "hello world";
 
   TestDelegate d;
-  URLRequest req(test_server_.GetURL("empty.html"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("empty.html"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   req.set_method("POST");
   req.set_upload(make_scoped_ptr(CreateSimpleUploadData(kData)));
   HttpRequestHeaders headers;
   headers.SetHeader(HttpRequestHeaders::kContentLength,
                     base::UintToString(arraysize(kData) - 1));
   req.SetExtraRequestHeaders(headers);
 
   URLRequestRedirectJob* job = new URLRequestRedirectJob(
       &req, &default_network_delegate_, test_server_.GetURL("echo"),
       URLRequestRedirectJob::REDIRECT_307_TEMPORARY_REDIRECT);
@@ skipping 10 matching lines @@
   ASSERT_TRUE(test_server_.Start());
 
   StaticHttpUserAgentSettings settings("en", EmptyString());
   TestNetworkDelegate network_delegate;  // Must outlive URLRequests.
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.set_http_user_agent_settings(&settings);
   context.Init();
 
   TestDelegate d;
-  URLRequest req(
-      test_server_.GetURL("echoheader?Accept-Language"), &d, &context);
+  URLRequest req(test_server_.GetURL("echoheader?Accept-Language"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
   req.Start();
   base::RunLoop().Run();
   EXPECT_EQ("en", d.data_received());
 }
 
 // Check that an empty A-L header is not sent. http://crbug.com/77365.
 TEST_F(URLRequestTestHTTP, EmptyAcceptLanguage) {
   ASSERT_TRUE(test_server_.Start());
 
   StaticHttpUserAgentSettings settings(EmptyString(), EmptyString());
   TestNetworkDelegate network_delegate;  // Must outlive URLRequests.
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.Init();
   // We override the language after initialization because empty entries
   // get overridden by Init().
   context.set_http_user_agent_settings(&settings);
 
   TestDelegate d;
-  URLRequest req(
-      test_server_.GetURL("echoheader?Accept-Language"), &d, &context);
+  URLRequest req(test_server_.GetURL("echoheader?Accept-Language"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context,
+                 &network_delegate);
   req.Start();
   base::RunLoop().Run();
   EXPECT_EQ("None", d.data_received());
 }
 
 // Check that if request overrides the A-L header, the default is not appended.
 // See http://crbug.com/20894
 TEST_F(URLRequestTestHTTP, OverrideAcceptLanguage) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   URLRequest req(test_server_.GetURL("echoheader?Accept-Language"),
+                 DEFAULT_PRIORITY,
                  &d,
-                 &default_context_);
+                 &default_context_,
+                 &default_network_delegate_);
   HttpRequestHeaders headers;
   headers.SetHeader(HttpRequestHeaders::kAcceptLanguage, "ru");
   req.SetExtraRequestHeaders(headers);
   req.Start();
   base::RunLoop().Run();
   EXPECT_EQ(std::string("ru"), d.data_received());
 }
 
 // Check that default A-E header is sent.
 TEST_F(URLRequestTestHTTP, DefaultAcceptEncoding) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   URLRequest req(test_server_.GetURL("echoheader?Accept-Encoding"),
+                 DEFAULT_PRIORITY,
                  &d,
-                 &default_context_);
+                 &default_context_,
+                 &default_network_delegate_);
   HttpRequestHeaders headers;
   req.SetExtraRequestHeaders(headers);
   req.Start();
   base::RunLoop().Run();
   EXPECT_TRUE(ContainsString(d.data_received(), "gzip"));
 }
 
 // Check that if request overrides the A-E header, the default is not appended.
 // See http://crbug.com/47381
 TEST_F(URLRequestTestHTTP, OverrideAcceptEncoding) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   URLRequest req(test_server_.GetURL("echoheader?Accept-Encoding"),
+                 DEFAULT_PRIORITY,
                  &d,
-                 &default_context_);
+                 &default_context_,
+                 &default_network_delegate_);
   HttpRequestHeaders headers;
   headers.SetHeader(HttpRequestHeaders::kAcceptEncoding, "identity");
   req.SetExtraRequestHeaders(headers);
   req.Start();
   base::RunLoop().Run();
   EXPECT_FALSE(ContainsString(d.data_received(), "gzip"));
   EXPECT_TRUE(ContainsString(d.data_received(), "identity"));
 }
 
 // Check that setting the A-C header sends the proper header.
 TEST_F(URLRequestTestHTTP, SetAcceptCharset) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   URLRequest req(test_server_.GetURL("echoheader?Accept-Charset"),
+                 DEFAULT_PRIORITY,
                  &d,
-                 &default_context_);
+                 &default_context_,
+                 &default_network_delegate_);
   HttpRequestHeaders headers;
   headers.SetHeader(HttpRequestHeaders::kAcceptCharset, "koi-8r");
   req.SetExtraRequestHeaders(headers);
   req.Start();
   base::RunLoop().Run();
   EXPECT_EQ(std::string("koi-8r"), d.data_received());
 }
 
 // Check that default User-Agent header is sent.
 TEST_F(URLRequestTestHTTP, DefaultUserAgent) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   URLRequest req(test_server_.GetURL("echoheader?User-Agent"),
+                 DEFAULT_PRIORITY,
                  &d,
-                 &default_context_);
+                 &default_context_,
+                 &default_network_delegate_);
   req.Start();
   base::RunLoop().Run();
   EXPECT_EQ(req.context()->GetUserAgent(req.url()), d.data_received());
 }
 
 // Check that if request overrides the User-Agent header,
 // the default is not appended.
 TEST_F(URLRequestTestHTTP, OverrideUserAgent) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   URLRequest req(test_server_.GetURL("echoheader?User-Agent"),
+                 DEFAULT_PRIORITY,
                  &d,
-                 &default_context_);
+                 &default_context_,
+                 &default_network_delegate_);
   HttpRequestHeaders headers;
   headers.SetHeader(HttpRequestHeaders::kUserAgent, "Lynx (textmode)");
   req.SetExtraRequestHeaders(headers);
   req.Start();
   base::RunLoop().Run();
   // If the net tests are being run with ChromeFrame then we need to allow for
   // the 'chromeframe' suffix which is added to the user agent before the
   // closing parentheses.
   EXPECT_TRUE(StartsWithASCII(d.data_received(), "Lynx (textmode", true));
 }
@@ skipping 14 matching lines @@
 
   struct {
     const char* request;
     const char* expected_response;
   } tests[] = { { "echoheader?Accept-Language", "None" },
                 { "echoheader?Accept-Charset", "None" },
                 { "echoheader?User-Agent", "" } };
 
   for (size_t i = 0; i < ARRAYSIZE_UNSAFE(tests); i++) {
     TestDelegate d;
-    URLRequest req(test_server_.GetURL(tests[i].request), &d, &context);
+    URLRequest req(test_server_.GetURL(tests[i].request),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &context,
+                   &network_delegate);
     req.Start();
     base::RunLoop().Run();
     EXPECT_EQ(tests[i].expected_response, d.data_received())
         << " Request = \"" << tests[i].request << "\"";
   }
 }
 
 // Make sure that URLRequest passes on its priority updates to
 // newly-created jobs after the first one.
 TEST_F(URLRequestTestHTTP, SetSubsequentJobPriority) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
-  URLRequest req(test_server_.GetURL("empty.html"), &d, &default_context_);
+  URLRequest req(test_server_.GetURL("empty.html"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
   EXPECT_EQ(DEFAULT_PRIORITY, req.priority());
 
   scoped_refptr<URLRequestRedirectJob> redirect_job =
       new URLRequestRedirectJob(
           &req, &default_network_delegate_, test_server_.GetURL("echo"),
           URLRequestRedirectJob::REDIRECT_302_FOUND);
   AddTestInterceptor()->set_main_intercept_job(redirect_job.get());
 
   req.SetPriority(LOW);
   req.Start();
@@ skipping 23 matching lines @@
 
 TEST_F(HTTPSRequestTest, HTTPSGetTest) {
   SpawnedTestServer test_server(
       SpawnedTestServer::TYPE_HTTPS,
       SpawnedTestServer::kLocalhost,
       base::FilePath(FILE_PATH_LITERAL("net/data/ssl")));
   ASSERT_TRUE(test_server.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server.GetURL(std::string()), &d, &default_context_);
+    URLRequest r(test_server.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_NE(0, d.bytes_received());
     CheckSSLInfo(r.ssl_info());
     EXPECT_EQ(test_server.host_port_pair().host(),
@@ skipping 10 matching lines @@
       SpawnedTestServer::TYPE_HTTPS,
       ssl_options,
       base::FilePath(FILE_PATH_LITERAL("net/data/ssl")));
   ASSERT_TRUE(test_server.Start());
 
   bool err_allowed = true;
   for (int i = 0; i < 2 ; i++, err_allowed = !err_allowed) {
     TestDelegate d;
     {
       d.set_allow_certificate_errors(err_allowed);
-      URLRequest r(test_server.GetURL(std::string()), &d, &default_context_);
+      URLRequest r(test_server.GetURL(std::string()),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
 
       r.Start();
       EXPECT_TRUE(r.is_pending());
 
       base::RunLoop().Run();
 
       EXPECT_EQ(1, d.response_started_count());
       EXPECT_FALSE(d.received_data_before_response());
       EXPECT_TRUE(d.have_certificate_errors());
       if (err_allowed) {
@@ skipping 15 matching lines @@
       base::FilePath(FILE_PATH_LITERAL("net/data/ssl")));
   ASSERT_TRUE(test_server.Start());
 
   // Iterate from false to true, just so that we do the opposite of the
   // previous test in order to increase test coverage.
   bool err_allowed = false;
   for (int i = 0; i < 2 ; i++, err_allowed = !err_allowed) {
     TestDelegate d;
     {
       d.set_allow_certificate_errors(err_allowed);
-      URLRequest r(test_server.GetURL(std::string()), &d, &default_context_);
+      URLRequest r(test_server.GetURL(std::string()),
+                   DEFAULT_PRIORITY,
+                   &d,
+                   &default_context_,
+                   &default_network_delegate_);
 
       r.Start();
       EXPECT_TRUE(r.is_pending());
 
       base::RunLoop().Run();
 
       EXPECT_EQ(1, d.response_started_count());
       EXPECT_FALSE(d.received_data_before_response());
       EXPECT_TRUE(d.have_certificate_errors());
       if (err_allowed) {
@@ skipping 24 matching lines @@
   SpawnedTestServer test_server(
       SpawnedTestServer::TYPE_HTTPS,
       ssl_options,
       base::FilePath(FILE_PATH_LITERAL("net/data/ssl")));
   ASSERT_TRUE(test_server.Start());
 
   TestDelegate d;
   TestURLRequestContext context(true);
   context.Init();
   d.set_allow_certificate_errors(true);
-  URLRequest r(test_server.GetURL(std::string()), &d, &context);
+  URLRequest r(
+      test_server.GetURL(std::string()), DEFAULT_PRIORITY, &d, &context, NULL);
   r.Start();
 
   base::RunLoop().Run();
 
   EXPECT_EQ(1, d.response_started_count());
   EXPECT_NE(0, d.bytes_received());
   EXPECT_EQ(static_cast<int>(SSL_CONNECTION_VERSION_TLS1),
             SSLConnectionStatusToVersion(r.ssl_info().connection_status));
   EXPECT_TRUE(r.ssl_info().connection_status & SSL_CONNECTION_VERSION_FALLBACK);
 }
@@ skipping 20 matching lines @@
   TestURLRequestContext context(true);
   context.set_network_delegate(&network_delegate);
   context.set_host_resolver(&host_resolver);
   TransportSecurityState transport_security_state;
   context.set_transport_security_state(&transport_security_state);
   context.Init();
 
   TestDelegate d;
   URLRequest r(GURL(base::StringPrintf("https://www.google.com:%d",
                                        test_server.host_port_pair().port())),
+               DEFAULT_PRIORITY,
                &d,
-               &context);
+               &context,
+               &network_delegate);
 
   r.Start();
   EXPECT_TRUE(r.is_pending());
 
   base::RunLoop().Run();
 
   EXPECT_EQ(1, d.response_started_count());
   EXPECT_FALSE(d.received_data_before_response());
   EXPECT_TRUE(d.have_certificate_errors());
   EXPECT_TRUE(d.certificate_errors_are_fatal());
@@ skipping 26 matching lines @@
   TransportSecurityState transport_security_state;
   TransportSecurityState::DomainState domain_state;
   EXPECT_TRUE(transport_security_state.GetDomainState("www.google.com", true,
                                                       &domain_state));
   context.set_transport_security_state(&transport_security_state);
   context.Init();
 
   TestDelegate d;
   URLRequest r(GURL(base::StringPrintf("https://www.google.com:%d",
                                        test_server.host_port_pair().port())),
+               DEFAULT_PRIORITY,
                &d,
-               &context);
+               &context,
+               &network_delegate);
 
   r.Start();
   EXPECT_TRUE(r.is_pending());
 
   base::RunLoop().Run();
 
   EXPECT_EQ(1, d.response_started_count());
   EXPECT_FALSE(d.received_data_before_response());
   EXPECT_TRUE(d.have_certificate_errors());
   EXPECT_TRUE(d.certificate_errors_are_fatal());
@@ skipping 49 matching lines @@
   context.set_network_delegate(&network_delegate);
   context.Init();
 
   TestDelegate d;
   // Navigating to https://www.somewhere.com instead of https://127.0.0.1 will
   // cause a certificate error.  Ignore the error.
   d.set_allow_certificate_errors(true);
 
   URLRequest req(GURL(base::StringPrintf("http://www.somewhere.com:%d/echo",
                                          test_server.host_port_pair().port())),
+                 DEFAULT_PRIORITY,
                  &d,
-                 &context);
+                 &context,
+                 &network_delegate);
   req.set_method("POST");
   req.set_upload(make_scoped_ptr(CreateSimpleUploadData(kData)));
 
   req.Start();
   base::RunLoop().Run();
 
   EXPECT_EQ("https", req.url().scheme());
   EXPECT_EQ("POST", req.method());
   EXPECT_EQ(kData, d.data_received());
 
@@ skipping 11 matching lines @@
   SpawnedTestServer test_server(
       SpawnedTestServer::TYPE_HTTPS,
       ssl_options,
       base::FilePath(FILE_PATH_LITERAL("net/data/ssl")));
   ASSERT_TRUE(test_server.Start());
 
   TestDelegate d;
   TestURLRequestContext context(true);
   context.Init();
   d.set_allow_certificate_errors(true);
-  URLRequest r(test_server.GetURL(std::string()), &d, &context);
+  URLRequest r(
+      test_server.GetURL(std::string()), DEFAULT_PRIORITY, &d, &context, NULL);
   r.Start();
 
   base::RunLoop().Run();
 
   EXPECT_EQ(1, d.response_started_count());
   EXPECT_NE(0, d.bytes_received());
   EXPECT_EQ(static_cast<int>(SSL_CONNECTION_VERSION_SSL3),
             SSLConnectionStatusToVersion(r.ssl_info().connection_status));
   EXPECT_TRUE(r.ssl_info().connection_status & SSL_CONNECTION_VERSION_FALLBACK);
 }
@@ skipping 28 matching lines @@
   SpawnedTestServer::SSLOptions ssl_options;
   ssl_options.request_client_certificate = true;
   SpawnedTestServer test_server(
       SpawnedTestServer::TYPE_HTTPS,
       ssl_options,
       base::FilePath(FILE_PATH_LITERAL("net/data/ssl")));
   ASSERT_TRUE(test_server.Start());
 
   SSLClientAuthTestDelegate d;
   {
-    URLRequest r(test_server.GetURL(std::string()), &d, &default_context_);
+    URLRequest r(test_server.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.on_certificate_requested_count());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(0, d.bytes_received());
 
@@ skipping 18 matching lines @@
   SpawnedTestServer test_server(
       SpawnedTestServer::TYPE_HTTPS,
       ssl_options,
       base::FilePath(FILE_PATH_LITERAL("net/data/ssl")));
   ASSERT_TRUE(test_server.Start());
 
   SSLClientSocket::ClearSessionCache();
 
   {
     TestDelegate d;
-    URLRequest r(
-        test_server.GetURL("ssl-session-cache"), &d, &default_context_);
+    URLRequest r(test_server.GetURL("ssl-session-cache"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
   }
 
   reinterpret_cast<HttpCache*>(default_context_.http_transaction_factory())->
     CloseAllConnections();
 
   {
     TestDelegate d;
-    URLRequest r(
-        test_server.GetURL("ssl-session-cache"), &d, &default_context_);
+    URLRequest r(test_server.GetURL("ssl-session-cache"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     // The response will look like;
     //   insert abc
     //   lookup abc
     //   insert xyz
@@ skipping 31 matching lines @@
   SpawnedTestServer test_server(
       SpawnedTestServer::TYPE_HTTPS,
       ssl_options,
       base::FilePath(FILE_PATH_LITERAL("net/data/ssl")));
   ASSERT_TRUE(test_server.Start());
 
   SSLClientSocket::ClearSessionCache();
 
   {
     TestDelegate d;
-    URLRequest r(
-        test_server.GetURL("ssl-session-cache"), &d, &default_context_);
+    URLRequest r(test_server.GetURL("ssl-session-cache"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
   }
 
   // Now create a new HttpCache with a different ssl_session_cache_shard value.
@@ skipping 10 matching lines @@
   params.ssl_session_cache_shard = "alternate";
 
   scoped_ptr<net::HttpCache> cache(new net::HttpCache(
       new net::HttpNetworkSession(params),
       net::HttpCache::DefaultBackend::InMemory(0)));
 
   default_context_.set_http_transaction_factory(cache.get());
 
   {
     TestDelegate d;
-    URLRequest r(
-        test_server.GetURL("ssl-session-cache"), &d, &default_context_);
+    URLRequest r(test_server.GetURL("ssl-session-cache"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
 
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     // The response will look like;
     //   insert abc
     //   insert xyz
     //
@@ skipping 97 matching lines @@
     // We always overwrite out_cert_status.
     *out_cert_status = 0;
     SpawnedTestServer test_server(
         SpawnedTestServer::TYPE_HTTPS,
         ssl_options,
         base::FilePath(FILE_PATH_LITERAL("net/data/ssl")));
     ASSERT_TRUE(test_server.Start());
 
     TestDelegate d;
     d.set_allow_certificate_errors(true);
-    URLRequest r(test_server.GetURL(std::string()), &d, &context_);
+    URLRequest r(test_server.GetURL(std::string()),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &context_,
+                 NULL);
     r.Start();
 
     base::RunLoop().Run();
 
     EXPECT_EQ(1, d.response_started_count());
     *out_cert_status = r.ssl_info().cert_status;
   }
 
   virtual ~HTTPSOCSPTest() {
 #if defined(USE_NSS) || defined(OS_IOS)
@@ skipping 434 matching lines @@
   FtpNetworkLayer ftp_transaction_factory(default_context_.host_resolver());
 
   GURL url("ftp://127.0.0.1:7");
   job_factory.SetProtocolHandler(
       "ftp",
       new FtpProtocolHandler(&ftp_transaction_factory));
   default_context_.set_job_factory(&job_factory);
 
   TestDelegate d;
   {
-    URLRequest r(url, &d, &default_context_);
+    URLRequest r(url,
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(URLRequestStatus::FAILED, r.status().status());
     EXPECT_EQ(ERR_UNSAFE_PORT, r.status().error());
   }
 }
 
 // Flaky, see http://crbug.com/25045.
 TEST_F(URLRequestTestFTP, DISABLED_FTPDirectoryListing) {
   ASSERT_TRUE(test_server_.Start());
 
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL("/"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("/"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_LT(0, d.bytes_received());
     EXPECT_EQ(test_server_.host_port_pair().host(),
               r.GetSocketAddress().host());
     EXPECT_EQ(test_server_.host_port_pair().port(),
               r.GetSocketAddress().port());
   }
 }
 
 // Flaky, see http://crbug.com/25045.
 TEST_F(URLRequestTestFTP, DISABLED_FTPGetTestAnonymous) {
   ASSERT_TRUE(test_server_.Start());
 
   base::FilePath app_path;
   PathService::Get(base::DIR_SOURCE_ROOT, &app_path);
   app_path = app_path.AppendASCII("LICENSE");
   TestDelegate d;
   {
-    URLRequest r(test_server_.GetURL("/LICENSE"), &d, &default_context_);
+    URLRequest r(test_server_.GetURL("/LICENSE"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     int64 file_size = 0;
     file_util::GetFileSize(app_path, &file_size);
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(1, d.response_started_count());
@@ skipping 10 matching lines @@
 TEST_F(URLRequestTestFTP, DISABLED_FTPGetTest) {
   ASSERT_TRUE(test_server_.Start());
 
   base::FilePath app_path;
   PathService::Get(base::DIR_SOURCE_ROOT, &app_path);
   app_path = app_path.AppendASCII("LICENSE");
   TestDelegate d;
   {
     URLRequest r(
         test_server_.GetURLWithUserAndPassword("/LICENSE", "chrome", "chrome"),
+        DEFAULT_PRIORITY,
         &d,
-        &default_context_);
+        &default_context_,
+        &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     int64 file_size = 0;
     file_util::GetFileSize(app_path, &file_size);
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(test_server_.host_port_pair().host(),
@@ skipping 12 matching lines @@
 
 // Flaky, see http://crbug.com/25045.
 TEST_F(URLRequestTestFTP, DISABLED_FTPCheckWrongPassword) {
   ASSERT_TRUE(test_server_.Start());
 
   base::FilePath app_path;
   PathService::Get(base::DIR_SOURCE_ROOT, &app_path);
   app_path = app_path.AppendASCII("LICENSE");
   TestDelegate d;
   {
-    URLRequest r(
-        test_server_.GetURLWithUserAndPassword("/LICENSE",
-                                               "chrome",
-                                               "wrong_password"),
-        &d,
-        &default_context_);
+    URLRequest r(test_server_.GetURLWithUserAndPassword(
+                     "/LICENSE", "chrome", "wrong_password"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     int64 file_size = 0;
     file_util::GetFileSize(app_path, &file_size);
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(d.bytes_received(), 0);
   }
 }
 
 // Flaky, see http://crbug.com/25045.
 TEST_F(URLRequestTestFTP, DISABLED_FTPCheckWrongPasswordRestart) {
   ASSERT_TRUE(test_server_.Start());
 
   base::FilePath app_path;
   PathService::Get(base::DIR_SOURCE_ROOT, &app_path);
   app_path = app_path.AppendASCII("LICENSE");
   TestDelegate d;
   // Set correct login credentials. The delegate will be asked for them when
   // the initial login with wrong credentials will fail.
   d.set_credentials(AuthCredentials(kChrome, kChrome));
   {
-    URLRequest r(
-        test_server_.GetURLWithUserAndPassword("/LICENSE",
-                                               "chrome",
-                                               "wrong_password"),
-        &d,
-        &default_context_);
+    URLRequest r(test_server_.GetURLWithUserAndPassword(
+                     "/LICENSE", "chrome", "wrong_password"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     int64 file_size = 0;
     file_util::GetFileSize(app_path, &file_size);
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(d.bytes_received(), static_cast<int>(file_size));
   }
 }
 
 // Flaky, see http://crbug.com/25045.
 TEST_F(URLRequestTestFTP, DISABLED_FTPCheckWrongUser) {
   ASSERT_TRUE(test_server_.Start());
 
   base::FilePath app_path;
   PathService::Get(base::DIR_SOURCE_ROOT, &app_path);
   app_path = app_path.AppendASCII("LICENSE");
   TestDelegate d;
   {
-    URLRequest r(
-        test_server_.GetURLWithUserAndPassword("/LICENSE",
-                                               "wrong_user",
-                                               "chrome"),
-        &d,
-        &default_context_);
+    URLRequest r(test_server_.GetURLWithUserAndPassword(
+                     "/LICENSE", "wrong_user", "chrome"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     int64 file_size = 0;
     file_util::GetFileSize(app_path, &file_size);
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(d.bytes_received(), 0);
   }
 }
 
 // Flaky, see http://crbug.com/25045.
 TEST_F(URLRequestTestFTP, DISABLED_FTPCheckWrongUserRestart) {
   ASSERT_TRUE(test_server_.Start());
 
   base::FilePath app_path;
   PathService::Get(base::DIR_SOURCE_ROOT, &app_path);
   app_path = app_path.AppendASCII("LICENSE");
   TestDelegate d;
   // Set correct login credentials. The delegate will be asked for them when
   // the initial login with wrong credentials will fail.
   d.set_credentials(AuthCredentials(kChrome, kChrome));
   {
-    URLRequest r(
-        test_server_.GetURLWithUserAndPassword("/LICENSE",
-                                               "wrong_user",
-                                               "chrome"),
-        &d,
-        &default_context_);
+    URLRequest r(test_server_.GetURLWithUserAndPassword(
+                     "/LICENSE", "wrong_user", "chrome"),
+                 DEFAULT_PRIORITY,
+                 &d,
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     int64 file_size = 0;
     file_util::GetFileSize(app_path, &file_size);
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(1, d.response_started_count());
     EXPECT_FALSE(d.received_data_before_response());
     EXPECT_EQ(d.bytes_received(), static_cast<int>(file_size));
   }
 }
 
 // Flaky, see http://crbug.com/25045.
 TEST_F(URLRequestTestFTP, DISABLED_FTPCacheURLCredentials) {
   ASSERT_TRUE(test_server_.Start());
 
   base::FilePath app_path;
   PathService::Get(base::DIR_SOURCE_ROOT, &app_path);
   app_path = app_path.AppendASCII("LICENSE");
 
   scoped_ptr<TestDelegate> d(new TestDelegate);
   {
     // Pass correct login identity in the URL.
     URLRequest r(
-        test_server_.GetURLWithUserAndPassword("/LICENSE",
-                                               "chrome",
-                                               "chrome"),
+        test_server_.GetURLWithUserAndPassword("/LICENSE", "chrome", "chrome"),
+        DEFAULT_PRIORITY,
         d.get(),
-        &default_context_);
+        &default_context_,
+        &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     int64 file_size = 0;
     file_util::GetFileSize(app_path, &file_size);
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(1, d->response_started_count());
     EXPECT_FALSE(d->received_data_before_response());
     EXPECT_EQ(d->bytes_received(), static_cast<int>(file_size));
   }
 
   d.reset(new TestDelegate);
   {
     // This request should use cached identity from previous request.
-    URLRequest r(test_server_.GetURL("/LICENSE"), d.get(), &default_context_);
+    URLRequest r(test_server_.GetURL("/LICENSE"),
+                 DEFAULT_PRIORITY,
+                 d.get(),
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     int64 file_size = 0;
     file_util::GetFileSize(app_path, &file_size);
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(1, d->response_started_count());
     EXPECT_FALSE(d->received_data_before_response());
     EXPECT_EQ(d->bytes_received(), static_cast<int>(file_size));
   }
 }
 
 // Flaky, see http://crbug.com/25045.
 TEST_F(URLRequestTestFTP, DISABLED_FTPCacheLoginBoxCredentials) {
   ASSERT_TRUE(test_server_.Start());
 
   base::FilePath app_path;
   PathService::Get(base::DIR_SOURCE_ROOT, &app_path);
   app_path = app_path.AppendASCII("LICENSE");
 
   scoped_ptr<TestDelegate> d(new TestDelegate);
   // Set correct login credentials. The delegate will be asked for them when
   // the initial login with wrong credentials will fail.
   d->set_credentials(AuthCredentials(kChrome, kChrome));
   {
-    URLRequest r(
-        test_server_.GetURLWithUserAndPassword("/LICENSE",
-                                               "chrome",
-                                               "wrong_password"),
-        d.get(),
-        &default_context_);
+    URLRequest r(test_server_.GetURLWithUserAndPassword(
+                     "/LICENSE", "chrome", "wrong_password"),
+                 DEFAULT_PRIORITY,
+                 d.get(),
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     int64 file_size = 0;
     file_util::GetFileSize(app_path, &file_size);
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(1, d->response_started_count());
     EXPECT_FALSE(d->received_data_before_response());
     EXPECT_EQ(d->bytes_received(), static_cast<int>(file_size));
   }
 
   // Use a new delegate without explicit credentials. The cached ones should be
   // used.
   d.reset(new TestDelegate);
   {
     // Don't pass wrong credentials in the URL, they would override valid cached
     // ones.
-    URLRequest r(test_server_.GetURL("/LICENSE"), d.get(), &default_context_);
+    URLRequest r(test_server_.GetURL("/LICENSE"),
+                 DEFAULT_PRIORITY,
+                 d.get(),
+                 &default_context_,
+                 &default_network_delegate_);
     r.Start();
     EXPECT_TRUE(r.is_pending());
 
     base::RunLoop().Run();
 
     int64 file_size = 0;
     file_util::GetFileSize(app_path, &file_size);
 
     EXPECT_FALSE(r.is_pending());
     EXPECT_EQ(1, d->response_started_count());
     EXPECT_FALSE(d->received_data_before_response());
     EXPECT_EQ(d->bytes_received(), static_cast<int>(file_size));
   }
 }
 #endif  // !defined(DISABLE_FTP_SUPPORT)
 
 }  // namespace net