Make URLRequestThrottlerManager a member of URLRequestContext.

content/common/net/url_fetcher_core.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 "content/common/net/url_fetcher_core.h"
 
 #include "base/bind.h"
 #include "base/file_util_proxy.h"
 #include "base/logging.h"
 #include "base/message_loop_proxy.h"
 #include "base/metrics/histogram.h"
 #include "base/stl_util.h"
 #include "base/tracked_objects.h"
 #include "content/public/common/url_fetcher_delegate.h"
 #include "net/base/io_buffer.h"
 #include "net/base/load_flags.h"
 #include "net/base/net_errors.h"
 #include "net/http/http_response_headers.h"
+#include "net/url_request/url_request_context.h"
 #include "net/url_request/url_request_context_getter.h"
 #include "net/url_request/url_request_throttler_manager.h"
 
 namespace content {
 
 static const int kBufferSize = 4096;
 static const int kUploadProgressTimerInterval = 100;
 
 URLFetcherCore::Registry::Registry() {}
 URLFetcherCore::Registry::~Registry() {}
@@ skipping 571 matching lines @@
   return write_complete;
 }
 
 void URLFetcherCore::OnReadCompleted(net::URLRequest* request,
                                      int bytes_read) {
   DCHECK(request == request_);
   DCHECK(io_message_loop_proxy_->BelongsToCurrentThread());
 
   url_ = request->url();
   url_throttler_entry_ =
-      net::URLRequestThrottlerManager::GetInstance()->RegisterRequestUrl(url_);
+      request->context()->throttler_manager()->RegisterRequestUrl(url_);
 
   bool waiting_on_write = false;
   do {
     if (!request_->status().is_success() || bytes_read <= 0)
       break;
 
     current_response_bytes_ += bytes_read;
     InformDelegateDownloadProgress();
     InformDelegateDownloadDataIfNecessary(bytes_read);
 
@@ skipping 166 matching lines @@
 
   request_->Start();
 }
 
 void URLFetcherCore::StartURLRequestWhenAppropriate() {
   DCHECK(io_message_loop_proxy_->BelongsToCurrentThread());
 
   if (was_cancelled_)
     return;
 
+  DCHECK(request_context_getter_);
+
   if (original_url_throttler_entry_ == NULL) {
     original_url_throttler_entry_ =
-        net::URLRequestThrottlerManager::GetInstance()->RegisterRequestUrl(
-            original_url_);
+        request_context_getter_->GetURLRequestContext()->
+            throttler_manager()->RegisterRequestUrl(original_url_);
   }
 
   int64 delay = original_url_throttler_entry_->ReserveSendingTimeForNextRequest(
       GetBackoffReleaseTime());
   if (delay == 0) {
     StartURLRequest();
   } else {
     MessageLoop::current()->PostDelayedTask(
         FROM_HERE, base::Bind(&URLFetcherCore::StartURLRequest, this),
         base::TimeDelta::FromMilliseconds(delay));
@@ skipping 130 matching lines @@
       original_url_throttler_entry_ != url_throttler_entry_) {
     destination_url_backoff =
         url_throttler_entry_->GetExponentialBackoffReleaseTime();
   }
 
   return original_url_backoff > destination_url_backoff ?
       original_url_backoff : destination_url_backoff;
 }
 
 }  // namespace content