[Sync] Propagate XMPP auth errors to SyncNotifierObservers

chrome/service/cloud_print/cloud_print_proxy_backend.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/service/cloud_print/cloud_print_proxy_backend.h"
 
 #include <map>
 #include <vector>
 
 #include "base/bind.h"
@@ skipping 70 matching lines @@
       const std::string& access_token,
       const std::string& robot_oauth_refresh_token,
       const std::string& robot_email,
       const std::string& user_email) OVERRIDE;
   virtual void OnInvalidCredentials() OVERRIDE;
 
   // CloudPrintConnector::Client implementation.
   virtual void OnAuthFailed() OVERRIDE;
 
   // notifier::PushClientObserver implementation.
-  virtual void OnNotificationStateChange(
-      bool notifications_enabled) OVERRIDE;
+  virtual void OnNotificationsEnabled() OVERRIDE;
+  virtual void OnNotificationsDisabled(
+      notifier::NotificationsDisabledReason reason) OVERRIDE;
   virtual void OnIncomingNotification(
       const notifier::Notification& notification) OVERRIDE;
 
  private:
   friend class base::RefCountedThreadSafe<Core>;
 
   virtual ~Core() {}
 
   void CreateAuthAndConnector();
   void DestroyAuthAndConnector();
@@ skipping 390 matching lines @@
   backend_->frontend_->OnPrintSystemUnavailable();
 }
 
 void CloudPrintProxyBackend::Core::NotifyUnregisterPrinters(
     const std::string& auth_token,
     const std::list<std::string>& printer_ids) {
   DCHECK(MessageLoop::current() == backend_->frontend_loop_);
   backend_->frontend_->OnUnregisterPrinters(auth_token, printer_ids);
 }
 
-void CloudPrintProxyBackend::Core::OnNotificationStateChange(
-    bool notification_enabled) {
+void CloudPrintProxyBackend::Core::OnNotificationsEnabled() {
   DCHECK(MessageLoop::current() == backend_->core_thread_.message_loop());
-  notifications_enabled_ = notification_enabled;
-  if (notifications_enabled_) {
-    notifications_enabled_since_ = base::TimeTicks::Now();
-    VLOG(1) << "Notifications for connector " << proxy_id_
-            << " were enabled at "
-            << notifications_enabled_since_.ToInternalValue();
-  } else {
-    LOG(ERROR) << "Notifications for connector " << proxy_id_ << " disabled.";
-    notifications_enabled_since_ = base::TimeTicks();
-  }
-  // A state change means one of two cases.
-  // Case 1: We just lost notifications. This this case we want to schedule a
-  // job poll if enable_job_poll_ is true.
-  // Case 2: Notifications just got re-enabled. In this case we want to schedule
+  notifications_enabled_ = true;
+  notifications_enabled_since_ = base::TimeTicks::Now();
+  VLOG(1) << "Notifications for connector " << proxy_id_
+          << " were enabled at "
+          << notifications_enabled_since_.ToInternalValue();
+  // Notifications just got re-enabled. In this case we want to schedule
   // a poll once for jobs we might have missed when we were dark.
   // Note that ScheduleJobPoll will not schedule again if a job poll task is
   // already scheduled.
-  if (enable_job_poll_ || notifications_enabled_)
+  ScheduleJobPoll();
+}
+
+void CloudPrintProxyBackend::Core::OnNotificationsDisabled(
+    notifier::NotificationsDisabledReason reason) {
+  DCHECK(MessageLoop::current() == backend_->core_thread_.message_loop());
+  notifications_enabled_ = false;
+  LOG(ERROR) << "Notifications for connector " << proxy_id_ << " disabled.";
+  notifications_enabled_since_ = base::TimeTicks();
+  // We just lost notifications. This this case we want to schedule a
+  // job poll if enable_job_poll_ is true.
+  if (enable_job_poll_)
     ScheduleJobPoll();
 }
 
 
 void CloudPrintProxyBackend::Core::OnIncomingNotification(
     const notifier::Notification& notification) {
   DCHECK(MessageLoop::current() == backend_->core_thread_.message_loop());
   VLOG(1) << "CP_CONNECTOR: Incoming notification.";
   if (0 == base::strcasecmp(kCloudPrintPushNotificationsSource,
                             notification.channel.c_str()))
     HandlePrinterNotification(notification.data);
 }