Index: sync/notifier/gcm_network_channel.h |
diff --git a/sync/notifier/gcm_network_channel.h b/sync/notifier/gcm_network_channel.h |
deleted file mode 100644 |
index 5f86ce768d35e70af24e788f552c3be3642acaed..0000000000000000000000000000000000000000 |
--- a/sync/notifier/gcm_network_channel.h |
+++ /dev/null |
@@ -1,135 +0,0 @@ |
-// 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. |
- |
-#ifndef SYNC_NOTIFIER_GCM_NETWORK_CHANNEL_H_ |
-#define SYNC_NOTIFIER_GCM_NETWORK_CHANNEL_H_ |
- |
-#include <string> |
- |
-#include "base/basictypes.h" |
-#include "base/compiler_specific.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "base/threading/non_thread_safe.h" |
-#include "net/base/backoff_entry.h" |
-#include "net/base/network_change_notifier.h" |
-#include "net/url_request/url_fetcher_delegate.h" |
-#include "sync/base/sync_export.h" |
-#include "sync/notifier/gcm_network_channel_delegate.h" |
-#include "sync/notifier/sync_system_resources.h" |
-#include "url/gurl.h" |
- |
-class GoogleServiceAuthError; |
- |
-namespace syncer { |
-class GCMNetworkChannel; |
- |
-// POD with copy of some statuses for debugging purposes. |
-struct GCMNetworkChannelDiagnostic { |
- explicit GCMNetworkChannelDiagnostic(GCMNetworkChannel* parent); |
- |
- // Collect all the internal variables in a single readable dictionary. |
- scoped_ptr<base::DictionaryValue> CollectDebugData() const; |
- |
- // TODO(pavely): Move this toString to a more appropiate place in GCMClient. |
- std::string GCMClientResultToString( |
- const gcm::GCMClient::Result result) const; |
- |
- GCMNetworkChannel* parent_; |
- bool last_message_empty_echo_token_; |
- base::Time last_message_received_time_; |
- int last_post_response_code_; |
- std::string registration_id_; |
- gcm::GCMClient::Result registration_result_; |
- int sent_messages_count_; |
-}; |
- |
-// GCMNetworkChannel is an implementation of SyncNetworkChannel that routes |
-// messages through GCMService. |
-class SYNC_EXPORT_PRIVATE GCMNetworkChannel |
- : public SyncNetworkChannel, |
- public net::URLFetcherDelegate, |
- public net::NetworkChangeNotifier::NetworkChangeObserver, |
- public base::NonThreadSafe { |
- public: |
- GCMNetworkChannel( |
- scoped_refptr<net::URLRequestContextGetter> request_context_getter, |
- scoped_ptr<GCMNetworkChannelDelegate> delegate); |
- |
- virtual ~GCMNetworkChannel(); |
- |
- // invalidation::NetworkChannel implementation. |
- virtual void SendMessage(const std::string& message) OVERRIDE; |
- virtual void SetMessageReceiver( |
- invalidation::MessageCallback* incoming_receiver) OVERRIDE; |
- |
- // SyncNetworkChannel implementation. |
- virtual void UpdateCredentials(const std::string& email, |
- const std::string& token) OVERRIDE; |
- virtual int GetInvalidationClientType() OVERRIDE; |
- virtual void RequestDetailedStatus( |
- base::Callback<void(const base::DictionaryValue&)> callback) OVERRIDE; |
- |
- // URLFetcherDelegate implementation. |
- virtual void OnURLFetchComplete(const net::URLFetcher* source) OVERRIDE; |
- |
- // NetworkChangeObserver implementation. |
- virtual void OnNetworkChanged( |
- net::NetworkChangeNotifier::ConnectionType connection_type) OVERRIDE; |
- |
- protected: |
- void ResetRegisterBackoffEntryForTest( |
- const net::BackoffEntry::Policy* policy); |
- |
- virtual GURL BuildUrl(const std::string& registration_id); |
- |
- private: |
- friend class GCMNetworkChannelTest; |
- void Register(); |
- void OnRegisterComplete(const std::string& registration_id, |
- gcm::GCMClient::Result result); |
- void RequestAccessToken(); |
- void OnGetTokenComplete(const GoogleServiceAuthError& error, |
- const std::string& token); |
- void OnIncomingMessage(const std::string& message, |
- const std::string& echo_token); |
- |
- // Base64 encoding/decoding with URL safe alphabet. |
- // http://tools.ietf.org/html/rfc4648#page-7 |
- static void Base64EncodeURLSafe(const std::string& input, |
- std::string* output); |
- static bool Base64DecodeURLSafe(const std::string& input, |
- std::string* output); |
- |
- scoped_refptr<net::URLRequestContextGetter> request_context_getter_; |
- scoped_ptr<GCMNetworkChannelDelegate> delegate_; |
- |
- // Message is saved until all conditions are met: there is valid |
- // registration_id and access_token. |
- std::string cached_message_; |
- |
- // Access token is saved because in case of auth failure from server we need |
- // to invalidate it. |
- std::string access_token_; |
- |
- // GCM registration_id is requested one at startup and never refreshed until |
- // next restart. |
- std::string registration_id_; |
- scoped_ptr<net::BackoffEntry> register_backoff_entry_; |
- |
- scoped_ptr<net::URLFetcher> fetcher_; |
- |
- // cacheinvalidation client receives echo_token with incoming message from |
- // GCM and shuld include it in headers with outgoing message over http. |
- std::string echo_token_; |
- |
- GCMNetworkChannelDiagnostic diagnostic_info_; |
- |
- base::WeakPtrFactory<GCMNetworkChannel> weak_factory_; |
- |
- DISALLOW_COPY_AND_ASSIGN(GCMNetworkChannel); |
-}; |
- |
-} // namespace syncer |
- |
-#endif // SYNC_NOTIFIER_GCM_NETWORK_CHANNEL_H_ |