[Sync] Propagate XMPP auth errors to SyncNotifierObservers

jingle/notifier/listener/xmpp_push_client.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 "jingle/notifier/listener/xmpp_push_client.h"
 
 #include "base/logging.h"
 #include "base/message_loop_proxy.h"
 #include "jingle/notifier/base/notifier_options_util.h"
 #include "jingle/notifier/listener/push_client_observer.h"
@@ skipping 40 matching lines @@
   std::vector<Notification> notifications_to_send;
   notifications_to_send.swap(pending_notifications_to_send_);
   for (std::vector<Notification>::const_iterator it =
            notifications_to_send.begin();
        it != notifications_to_send.end(); ++it) {
     DVLOG(1) << "Push: Sending pending notification " << it->ToString();
     SendNotification(*it);
   }
 }
 
-void XmppPushClient::OnDisconnect() {
+void XmppPushClient::OnTransientDisconnection() {
   DCHECK(non_thread_safe_.CalledOnValidThread());
   base_task_.reset();
   FOR_EACH_OBSERVER(PushClientObserver, observers_,
-                    OnNotificationStateChange(false));
+                    OnNotificationsDisabled(TRANSIENT_NOTIFICATION_ERROR));
+}
+
+void XmppPushClient::OnCredentialsRejected() {
+  DCHECK(non_thread_safe_.CalledOnValidThread());
+  base_task_.reset();
+  FOR_EACH_OBSERVER(
+      PushClientObserver, observers_,
+      OnNotificationsDisabled(NOTIFICATION_CREDENTIALS_REJECTED));
 }
 
 void XmppPushClient::OnNotificationReceived(
     const Notification& notification) {
   DCHECK(non_thread_safe_.CalledOnValidThread());
   FOR_EACH_OBSERVER(PushClientObserver, observers_,
                     OnIncomingNotification(notification));
 }
 
 void XmppPushClient::OnSubscribed() {
   DCHECK(non_thread_safe_.CalledOnValidThread());
   FOR_EACH_OBSERVER(PushClientObserver, observers_,
-                    OnNotificationStateChange(true));
+                    OnNotificationsEnabled());
 }
 
 void XmppPushClient::OnSubscriptionError() {
   DCHECK(non_thread_safe_.CalledOnValidThread());
   FOR_EACH_OBSERVER(PushClientObserver, observers_,
-                    OnNotificationStateChange(false));
+                    OnNotificationsDisabled(TRANSIENT_NOTIFICATION_ERROR));
 }
 
 void XmppPushClient::AddObserver(PushClientObserver* observer) {
   DCHECK(non_thread_safe_.CalledOnValidThread());
   observers_.AddObserver(observer);
 }
 
 void XmppPushClient::RemoveObserver(PushClientObserver* observer) {
   DCHECK(non_thread_safe_.CalledOnValidThread());
   observers_.RemoveObserver(observer);
@@ skipping 34 matching lines @@
     pending_notifications_to_send_.push_back(notification);
     return;
   }
   // Owned by |base_task_|.
   PushNotificationsSendUpdateTask* task =
       new PushNotificationsSendUpdateTask(base_task_, notification);
   task->Start();
 }
 
 }  // namespace notifier