contacts: Defer updates when offline.

chrome/browser/chromeos/contacts/google_contact_store.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 "chrome/browser/chromeos/contacts/google_contact_store.h"
 
 #include <algorithm>
 
 #include "base/bind.h"
 #include "base/file_path.h"
@@ skipping 56 matching lines @@
 
 void GoogleContactStore::TestAPI::SetGDataService(
     gdata::GDataContactsServiceInterface* service) {
   store_->gdata_service_for_testing_.reset(service);
 }
 
 void GoogleContactStore::TestAPI::DoUpdate() {
   store_->UpdateContacts();
 }
 
+void GoogleContactStore::TestAPI::NotifyAboutNetworkStateChange(bool online) {
+  net::NetworkChangeNotifier::ConnectionType type =
+      online ?
+      net::NetworkChangeNotifier::CONNECTION_UNKNOWN :
+      net::NetworkChangeNotifier::CONNECTION_NONE;
+  store_->OnConnectionTypeChanged(type);
+}
+
 GoogleContactStore::GoogleContactStore(Profile* profile)
     : profile_(profile),
       contacts_deleter_(&contacts_),
       db_(new ContactDatabase),
       update_delay_on_next_failure_(
           base::TimeDelta::FromSeconds(kUpdateFailureInitialRetrySec)),
+      is_online_(true),
+      should_update_when_online_(false),
       ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  net::NetworkChangeNotifier::AddConnectionTypeObserver(this);
+  is_online_ = !net::NetworkChangeNotifier::IsOffline();
 }
 
 GoogleContactStore::~GoogleContactStore() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   weak_ptr_factory_.InvalidateWeakPtrs();
+  net::NetworkChangeNotifier::RemoveConnectionTypeObserver(this);
   DestroyDatabase();
 }
 
 void GoogleContactStore::Init() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   FilePath db_path = profile_->GetPath().Append(kDatabaseDirectoryName);
   VLOG(1) << "Initializing contact database \"" << db_path.value() << "\" for "
           << profile_->GetProfileName();
   db_->Init(db_path,
             base::Bind(&GoogleContactStore::OnDatabaseInitialized,
@@ skipping 22 matching lines @@
   DCHECK(observer);
   observers_.AddObserver(observer);
 }
 
 void GoogleContactStore::RemoveObserver(ContactStoreObserver* observer) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   DCHECK(observer);
   observers_.RemoveObserver(observer);
 }
 
+void GoogleContactStore::OnConnectionTypeChanged(
+    net::NetworkChangeNotifier::ConnectionType type) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  bool was_online = is_online_;
+  is_online_ = (type != net::NetworkChangeNotifier::CONNECTION_NONE);
+  if (!was_online && is_online_ && should_update_when_online_) {
+    should_update_when_online_ = false;
+    UpdateContacts();
+  }
+}
+
 base::Time GoogleContactStore::GetCurrentTime() const {
   return !current_time_for_testing_.is_null() ?
          current_time_for_testing_ :
          base::Time::Now();
 }
 
 void GoogleContactStore::DestroyDatabase() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   if (db_) {
     db_->DestroyOnUIThread();
     db_ = NULL;
   }
 }
 
 void GoogleContactStore::UpdateContacts() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+
+  // If we're offline, defer the update.
+  if (!is_online_) {
+    VLOG(1) << "Deferring contact update due to offline state";
+    should_update_when_online_ = true;
+    return;
+  }
+
   base::Time min_update_time;
   base::TimeDelta time_since_last_update =
       last_successful_update_start_time_.is_null() ?
       base::TimeDelta() :
       GetCurrentTime() - last_successful_update_start_time_;
 
   if (!last_contact_update_time_.is_null() &&
       time_since_last_update <
       base::TimeDelta::FromDays(kForceFullUpdateDays)) {
     // TODO(derat): I'm adding one millisecond to the last update time here as I
@@ skipping 210 matching lines @@
   return gdata::util::IsGDataAvailable(profile);
 }
 
 ContactStore* GoogleContactStoreFactory::CreateContactStore(Profile* profile) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   DCHECK(CanCreateContactStoreForProfile(profile));
   return new GoogleContactStore(profile);
 }
 
 }  // namespace contacts