Implement THROTTLED priority semantics.

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 <memory>
 #include <utility>
 
 #include "base/memory/ptr_util.h"
 #include "build/build_config.h"
 
@@ skipping 7873 matching lines @@
   std::unique_ptr<URLRequest> req(
       default_context_.CreateRequest(test_url, DEFAULT_PRIORITY, &d));
   req->SetLoadFlags(LOAD_ONLY_FROM_CACHE);
 
   req->Start();
   base::RunLoop().Run();
 
   EXPECT_FALSE(req->response_info().network_accessed);
 }
 
-// Test that a single job with a throttled priority completes
+// Test that a single job with a THROTTLED priority completes
 // correctly in the absence of contention.
 TEST_F(URLRequestTestHTTP, ThrottledPriority) {
   ASSERT_TRUE(http_test_server()->Start());
 
   TestDelegate d;
   GURL test_url(http_test_server()->GetURL("/"));
   std::unique_ptr<URLRequest> req(
       default_context_.CreateRequest(test_url, THROTTLED, &d));
   req->Start();
   base::RunLoop().Run();
 
   EXPECT_TRUE(req->status().is_success());
 }
 
+// Test that three jobs with THROTTLED priorities complete
+// correctly in the absence of contention (the completion of the
+// first one will unthrottle the third, but there is no visibility
+// to that at this level).
+TEST_F(URLRequestTestHTTP, MultiThrottledPriority) {
+  ASSERT_TRUE(http_test_server()->Start());
+
+  TestDelegate d;
+  GURL test_url(http_test_server()->GetURL("/"));
+  std::unique_ptr<URLRequest> req1(
+      default_context_.CreateRequest(test_url, THROTTLED, &d));
+  std::unique_ptr<URLRequest> req2(
+      default_context_.CreateRequest(test_url, THROTTLED, &d));
+  std::unique_ptr<URLRequest> req3(
+      default_context_.CreateRequest(test_url, THROTTLED, &d));
+  req1->Start();
+  req2->Start();
+  req3->Start();
+  base::RunLoop().Run();
+
+  EXPECT_TRUE(req1->status().is_success());
+  EXPECT_TRUE(req2->status().is_success());
+  EXPECT_TRUE(req3->status().is_success());
+}
+
 class URLRequestInterceptorTestHTTP : public URLRequestTestHTTP {
  public:
   // TODO(bengr): Merge this with the URLRequestInterceptorHTTPTest fixture,
   // ideally remove the dependency on URLRequestTestJob, and maybe move these
   // tests into the factory tests.
   URLRequestInterceptorTestHTTP() : URLRequestTestHTTP(), interceptor_(NULL) {
   }
 
   void SetUpFactory() override {
     interceptor_ = new MockURLRequestInterceptor();
@@ skipping 2195 matching lines @@
   AddTestInterceptor()->set_main_intercept_job(std::move(job));
 
   req->Start();
   req->Cancel();
   base::RunLoop().RunUntilIdle();
   EXPECT_EQ(URLRequestStatus::CANCELED, req->status().status());
   EXPECT_EQ(0, d.received_redirect_count());
 }
 
 }  // namespace net