Kill URLRequestJobTracker.

chrome/browser/profiles/profile_manager.cc

 // Copyright (c) 2011 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 <set>
 
 #include "chrome/browser/profiles/profile_manager.h"
 
 #include "base/command_line.h"
 #include "base/file_path.h"
@@ skipping 14 matching lines @@
 #include "chrome/common/logging_chrome.h"
 #include "chrome/common/pref_names.h"
 #include "content/browser/browser_thread.h"
 #include "content/common/notification_service.h"
 #include "content/common/notification_type.h"
 #include "grit/generated_resources.h"
 #include "net/http/http_transaction_factory.h"
 #include "net/url_request/url_request_context.h"
 #include "net/url_request/url_request_context_getter.h"
 #include "net/url_request/url_request_job.h"
-#include "net/url_request/url_request_job_tracker.h"
 
 #if defined(OS_CHROMEOS)
 #include "chrome/browser/chromeos/cros/cros_library.h"
 #include "chrome/browser/chromeos/cros/cryptohome_library.h"
 #endif
 
-namespace {
-
-void SuspendURLRequestJobs() {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
-  for (net::URLRequestJobTracker::JobIterator i =
-           net::g_url_request_job_tracker.begin();
-       i != net::g_url_request_job_tracker.end(); ++i)
-    (*i)->Kill();
-}
-
-void SuspendRequestContext(
-    net::URLRequestContextGetter* request_context_getter) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
-
-  scoped_refptr<net::URLRequestContext> request_context =
-      request_context_getter->GetURLRequestContext();
-
-  request_context->http_transaction_factory()->Suspend(true);
-}
-
-void ResumeRequestContext(
-    net::URLRequestContextGetter* request_context_getter) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
-
-  scoped_refptr<net::URLRequestContext> request_context =
-      request_context_getter->GetURLRequestContext();
-  request_context->http_transaction_factory()->Suspend(false);
-}
-
-}  // namespace
-
-
 bool ProfileManagerObserver::DeleteAfterCreation() {
     return false;
 }
 
 // The NewProfileLauncher class is created when to wait for a multi-profile
 // to be created asynchronously. Upon completion of profile creation, the
 // NPL takes care of launching a new browser window and signing the user
 // in to their Google account.
 class NewProfileLauncher : public ProfileManagerObserver {
  public:
@@ skipping 20 matching lines @@
 
 // static
 Profile* ProfileManager::GetDefaultProfile() {
   FilePath user_data_dir;
   PathService::Get(chrome::DIR_USER_DATA, &user_data_dir);
   ProfileManager* profile_manager = g_browser_process->profile_manager();
   return profile_manager->GetDefaultProfile(user_data_dir);
 }
 
 ProfileManager::ProfileManager() : logged_in_(false) {
-  base::SystemMonitor::Get()->AddObserver(this);
   BrowserList::AddObserver(this);
 #if defined(OS_CHROMEOS)
   registrar_.Add(
       this,
       NotificationType::LOGIN_USER_CHANGED,
       NotificationService::AllSources());
 #endif
 }
 
 ProfileManager::~ProfileManager() {
-  base::SystemMonitor* system_monitor = base::SystemMonitor::Get();
-  if (system_monitor)
-    system_monitor->RemoveObserver(this);
   BrowserList::RemoveObserver(this);
 }
 
 FilePath ProfileManager::GetDefaultProfileDir(
     const FilePath& user_data_dir) {
   FilePath default_profile_dir(user_data_dir);
   default_profile_dir =
       default_profile_dir.AppendASCII(chrome::kNotSignedInProfile);
   return default_profile_dir;
 }
@@ skipping 202 matching lines @@
   ProfilesInfoMap::iterator new_elem =
       (profiles_info_.insert(std::make_pair(profile->GetPath(), info))).first;
   return info;
 }
 
 Profile* ProfileManager::GetProfileByPath(const FilePath& path) const {
   ProfilesInfoMap::const_iterator iter = profiles_info_.find(path);
   return (iter == profiles_info_.end()) ? NULL : iter->second->profile.get();
 }
 
-void ProfileManager::OnSuspend() {
-  DCHECK(CalledOnValidThread());
-
-  bool posted = BrowserThread::PostTask(
-      BrowserThread::IO, FROM_HERE,
-      NewRunnableFunction(&SuspendURLRequestJobs));
-  DCHECK(posted);
-
-  scoped_refptr<net::URLRequestContextGetter> request_context;
-  std::vector<Profile*> profiles(GetLoadedProfiles());
-  for (size_t i = 0; i < profiles.size(); ++i) {
-    request_context = profiles[i]->GetRequestContext();
-    posted = BrowserThread::PostTask(
-        BrowserThread::IO, FROM_HERE,
-        NewRunnableFunction(&SuspendRequestContext, request_context));
-    DCHECK(posted);
-    request_context = profiles[i]->GetRequestContextForMedia();
-    posted = BrowserThread::PostTask(
-        BrowserThread::IO, FROM_HERE,
-        NewRunnableFunction(&SuspendRequestContext, request_context));
-    DCHECK(posted);
-  }
-}
-
-void ProfileManager::OnResume() {
-  DCHECK(CalledOnValidThread());
-
-  scoped_refptr<net::URLRequestContextGetter> request_context;
-  std::vector<Profile*> profiles(GetLoadedProfiles());
-  for (size_t i = 0; i < profiles.size(); ++i) {
-    request_context = profiles[i]->GetRequestContext();
-    bool posted = BrowserThread::PostTask(
-        BrowserThread::IO, FROM_HERE,
-        NewRunnableFunction(&ResumeRequestContext, request_context));
-    DCHECK(posted);
-    request_context = profiles[i]->GetRequestContextForMedia();
-    posted = BrowserThread::PostTask(
-        BrowserThread::IO, FROM_HERE,
-        NewRunnableFunction(&ResumeRequestContext, request_context));
-    DCHECK(posted);
-  }
-}
-
 void ProfileManager::Observe(
     NotificationType type,
     const NotificationSource& source,
     const NotificationDetails& details) {
 #if defined(OS_CHROMEOS)
   if (type == NotificationType::LOGIN_USER_CHANGED) {
     const CommandLine& command_line = *CommandLine::ForCurrentProcess();
     if (!command_line.HasSwitch(switches::kTestType)) {
       // This will fail when running on non cros os.
       // TODO(davemoore) Need to mock this enough to enable testing.
@@ skipping 99 matching lines @@
   NewProfileLauncher* launcher = new NewProfileLauncher();
   profile_manager->CreateProfileAsync(new_path, launcher);
 }
 
 // static
 void ProfileManager::RegisterPrefs(PrefService* prefs) {
   prefs->RegisterStringPref(prefs::kProfileLastUsed, "");
   prefs->RegisterDictionaryPref(prefs::kProfileDirectoryMap);
   prefs->RegisterIntegerPref(prefs::kProfilesNumCreated, 1);
 }