src/chrome/browser/signin/signin_names_io_thread.cc

   1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "chrome/browser/signin/signin_names_io_thread.h"
   6
   7 #include "base/logging.h"
   8 #include "base/strings/utf_string_conversions.h"
   9 #include "chrome/browser/browser_process.h"
  10 #include "chrome/browser/chrome_notification_types.h"
  11 #include "chrome/browser/profiles/profile_info_cache.h"
  12 #include "chrome/browser/profiles/profile_manager.h"
  13 #include "components/signin/core/browser/signin_manager.h"
  14 #include "content/public/browser/browser_thread.h"
  15
  16 SigninNamesOnIOThread::SigninNamesOnIOThread() : resources_released_(false) {
  17   CheckOnUIThread();
  18
  19   SigninManagerFactory::GetInstance()->AddObserver(this);
  20
  21   // Get list of profiles and record the email addresses of any connected
  22   // accounts.
  23   if (g_browser_process) {
  24     ProfileManager* manager = g_browser_process->profile_manager();
  25     if (manager) {
  26       const ProfileInfoCache& cache = manager->GetProfileInfoCache();
  27       for (size_t i = 0; i < cache.GetNumberOfProfiles(); ++i) {
  28         base::string16 email = cache.GetUserNameOfProfileAtIndex(i);
  29         if (!email.empty())
  30           emails_.insert(email);
  31       }
  32     }
  33   }
  34 }
  35
  36 SigninNamesOnIOThread::~SigninNamesOnIOThread() {
  37   CheckOnIOThread();
  38   DCHECK(resources_released_) << "Must call ReleaseResourcesOnUIThread() first";
  39   DCHECK(!observed_managers_.size())
  40       << "Shouldn't be observing any SigninManagers";
  41 }
  42
  43 const SigninNamesOnIOThread::EmailSet&
  44     SigninNamesOnIOThread::GetEmails() const {
  45   CheckOnIOThread();
  46   return emails_;
  47 }
  48
  49 void SigninNamesOnIOThread::ReleaseResourcesOnUIThread() {
  50   CheckOnUIThread();
  51   DCHECK(!resources_released_);
  52   SigninManagerFactory::GetInstance()->RemoveObserver(this);
  53
  54   for (std::set<SigninManagerBase*>::iterator i = observed_managers_.begin();
  55        i != observed_managers_.end();
  56        ++i) {
  57     (*i)->RemoveObserver(this);
  58   }
  59   observed_managers_.clear();
  60
  61   resources_released_ = true;
  62 }
  63
  64 void SigninNamesOnIOThread::SigninManagerCreated(SigninManagerBase* manager) {
  65   manager->AddObserver(this);
  66   observed_managers_.insert(manager);
  67 }
  68
  69 void SigninNamesOnIOThread::SigninManagerShutdown(SigninManagerBase* manager) {
  70   manager->RemoveObserver(this);
  71   observed_managers_.erase(manager);
  72 }
  73
  74 void SigninNamesOnIOThread::GoogleSigninSucceeded(const std::string& username,
  75                                                   const std::string& password) {
  76   PostTaskToIOThread(true, base::UTF8ToUTF16(username));
  77 }
  78
  79 void SigninNamesOnIOThread::GoogleSignedOut(const std::string& username) {
  80   PostTaskToIOThread(false, base::UTF8ToUTF16(username));
  81 }
  82
  83 void SigninNamesOnIOThread::CheckOnIOThread() const {
  84   DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
  85 }
  86
  87 void SigninNamesOnIOThread::CheckOnUIThread() const {
  88   DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
  89 }
  90
  91 void SigninNamesOnIOThread::PostTaskToIOThread(bool add,
  92                                                const base::string16& email) {
  93   if (content::BrowserThread::CurrentlyOn(content::BrowserThread::IO)) {
  94     UpdateOnIOThread(add, email);
  95   } else {
  96     bool may_run = content::BrowserThread::PostTask(
  97         content::BrowserThread::IO,
  98         FROM_HERE,
  99         base::Bind(&SigninNamesOnIOThread::UpdateOnIOThread,
 100                    base::Unretained(this),
 101                    add,
 102                    email));
 103     DCHECK(may_run);
 104   }
 105 }
 106
 107 void SigninNamesOnIOThread::UpdateOnIOThread(bool add,
 108                                              const base::string16& email) {
 109   CheckOnIOThread();
 110   if (add) {
 111     emails_.insert(email);
 112   } else {
 113     emails_.erase(email);
 114   }
 115 }