Notify SyncNetworkChannel about GCM connection state

components/invalidation/gcm_network_channel.cc

 // Copyright 2014 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 "base/base64.h"
 #include "base/i18n/time_formatting.h"
 #include "base/metrics/histogram.h"
 #include "base/sha1.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/strings/string_util.h"
@@ skipping 92 matching lines @@
 
 GCMNetworkChannel::GCMNetworkChannel(
     scoped_refptr<net::URLRequestContextGetter> request_context_getter,
     scoped_ptr<GCMNetworkChannelDelegate> delegate)
     : request_context_getter_(request_context_getter),
       delegate_(delegate.Pass()),
       register_backoff_entry_(new net::BackoffEntry(&kRegisterBackoffPolicy)),
       diagnostic_info_(this),
       weak_factory_(this) {
   net::NetworkChangeNotifier::AddNetworkChangeObserver(this);
-  delegate_->Initialize();
+  delegate_->Initialize(base::Bind(&GCMNetworkChannel::OnConnectionStateChanged,
+                                   weak_factory_.GetWeakPtr()));
   Register();
 }
 
 GCMNetworkChannel::~GCMNetworkChannel() {
   net::NetworkChangeNotifier::RemoveNetworkChangeObserver(this);
 }
 
 void GCMNetworkChannel::Register() {
   delegate_->Register(base::Bind(&GCMNetworkChannel::OnRegisterComplete,
                                  weak_factory_.GetWeakPtr()));
@@ skipping 152 matching lines @@
   }
   DVLOG(2) << "Deliver incoming message";
   RecordIncomingMessageStatus(INCOMING_MESSAGE_SUCCESS);
   DeliverIncomingMessage(android_message.message());
 #else
   // This code shouldn't be invoked on Android.
   NOTREACHED();
 #endif
 }
 
+void GCMNetworkChannel::OnConnectionStateChanged(
+    GCMNetworkChannelDelegate::ConnectionState connection_state) {
+  switch (connection_state) {
+    case GCMNetworkChannelDelegate::CONNECTION_STATE_OFFLINE: {
+      NotifyStateChange(TRANSIENT_INVALIDATION_ERROR);
+      break;
+    }
+    case GCMNetworkChannelDelegate::CONNECTION_STATE_ONLINE: {
+      NotifyStateChange(INVALIDATIONS_ENABLED);
+      break;
+    }
+    default: {
+      NOTREACHED();
+      break;
+    }
+  }
+}
+
 void GCMNetworkChannel::OnNetworkChanged(
     net::NetworkChangeNotifier::ConnectionType connection_type) {
   // Network connection is restored. Let's notify cacheinvalidations so it has
   // chance to retry.
   if (connection_type != net::NetworkChangeNotifier::CONNECTION_NONE)
     NotifyStateChange(INVALIDATIONS_ENABLED);
 }
 
 GURL GCMNetworkChannel::BuildUrl(const std::string& registration_id) {
   DCHECK(!registration_id.empty());
@@ skipping 125 matching lines @@
     ENUM_CASE(gcm::GCMClient::NOT_SIGNED_IN);
     ENUM_CASE(gcm::GCMClient::INVALID_PARAMETER);
     ENUM_CASE(gcm::GCMClient::ASYNC_OPERATION_PENDING);
     ENUM_CASE(gcm::GCMClient::GCM_DISABLED);
   }
   NOTREACHED();
   return "";
 }
 
 }  // namespace syncer