[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 OnPushClientStateChange(
+      notifier::PushClientState push_client_state) 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::OnPushClientStateChange(
+    notifier::PushClientState push_client_state) {
   DCHECK(MessageLoop::current() == backend_->core_thread_.message_loop());
-  notifications_enabled_ = notification_enabled;
+  notifications_enabled_ = (push_client_state == notifier::NOTIFICATIONS_ON);
   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
   // 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::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);
 }