Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(76)

Side by Side Diff: sync/notifier/gcm_network_channel.h

Issue 294123004: Move some sync/notifier to components/invalidation (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Rebase Created 6 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « sync/notifier/fake_invalidator_unittest.cc ('k') | sync/notifier/gcm_network_channel.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
(Empty)
1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #ifndef SYNC_NOTIFIER_GCM_NETWORK_CHANNEL_H_
6 #define SYNC_NOTIFIER_GCM_NETWORK_CHANNEL_H_
7
8 #include <string>
9
10 #include "base/basictypes.h"
11 #include "base/compiler_specific.h"
12 #include "base/memory/scoped_ptr.h"
13 #include "base/threading/non_thread_safe.h"
14 #include "net/base/backoff_entry.h"
15 #include "net/base/network_change_notifier.h"
16 #include "net/url_request/url_fetcher_delegate.h"
17 #include "sync/base/sync_export.h"
18 #include "sync/notifier/gcm_network_channel_delegate.h"
19 #include "sync/notifier/sync_system_resources.h"
20 #include "url/gurl.h"
21
22 class GoogleServiceAuthError;
23
24 namespace syncer {
25 class GCMNetworkChannel;
26
27 // POD with copy of some statuses for debugging purposes.
28 struct GCMNetworkChannelDiagnostic {
29 explicit GCMNetworkChannelDiagnostic(GCMNetworkChannel* parent);
30
31 // Collect all the internal variables in a single readable dictionary.
32 scoped_ptr<base::DictionaryValue> CollectDebugData() const;
33
34 // TODO(pavely): Move this toString to a more appropiate place in GCMClient.
35 std::string GCMClientResultToString(
36 const gcm::GCMClient::Result result) const;
37
38 GCMNetworkChannel* parent_;
39 bool last_message_empty_echo_token_;
40 base::Time last_message_received_time_;
41 int last_post_response_code_;
42 std::string registration_id_;
43 gcm::GCMClient::Result registration_result_;
44 int sent_messages_count_;
45 };
46
47 // GCMNetworkChannel is an implementation of SyncNetworkChannel that routes
48 // messages through GCMService.
49 class SYNC_EXPORT_PRIVATE GCMNetworkChannel
50 : public SyncNetworkChannel,
51 public net::URLFetcherDelegate,
52 public net::NetworkChangeNotifier::NetworkChangeObserver,
53 public base::NonThreadSafe {
54 public:
55 GCMNetworkChannel(
56 scoped_refptr<net::URLRequestContextGetter> request_context_getter,
57 scoped_ptr<GCMNetworkChannelDelegate> delegate);
58
59 virtual ~GCMNetworkChannel();
60
61 // invalidation::NetworkChannel implementation.
62 virtual void SendMessage(const std::string& message) OVERRIDE;
63 virtual void SetMessageReceiver(
64 invalidation::MessageCallback* incoming_receiver) OVERRIDE;
65
66 // SyncNetworkChannel implementation.
67 virtual void UpdateCredentials(const std::string& email,
68 const std::string& token) OVERRIDE;
69 virtual int GetInvalidationClientType() OVERRIDE;
70 virtual void RequestDetailedStatus(
71 base::Callback<void(const base::DictionaryValue&)> callback) OVERRIDE;
72
73 // URLFetcherDelegate implementation.
74 virtual void OnURLFetchComplete(const net::URLFetcher* source) OVERRIDE;
75
76 // NetworkChangeObserver implementation.
77 virtual void OnNetworkChanged(
78 net::NetworkChangeNotifier::ConnectionType connection_type) OVERRIDE;
79
80 protected:
81 void ResetRegisterBackoffEntryForTest(
82 const net::BackoffEntry::Policy* policy);
83
84 virtual GURL BuildUrl(const std::string& registration_id);
85
86 private:
87 friend class GCMNetworkChannelTest;
88 void Register();
89 void OnRegisterComplete(const std::string& registration_id,
90 gcm::GCMClient::Result result);
91 void RequestAccessToken();
92 void OnGetTokenComplete(const GoogleServiceAuthError& error,
93 const std::string& token);
94 void OnIncomingMessage(const std::string& message,
95 const std::string& echo_token);
96
97 // Base64 encoding/decoding with URL safe alphabet.
98 // http://tools.ietf.org/html/rfc4648#page-7
99 static void Base64EncodeURLSafe(const std::string& input,
100 std::string* output);
101 static bool Base64DecodeURLSafe(const std::string& input,
102 std::string* output);
103
104 scoped_refptr<net::URLRequestContextGetter> request_context_getter_;
105 scoped_ptr<GCMNetworkChannelDelegate> delegate_;
106
107 // Message is saved until all conditions are met: there is valid
108 // registration_id and access_token.
109 std::string cached_message_;
110
111 // Access token is saved because in case of auth failure from server we need
112 // to invalidate it.
113 std::string access_token_;
114
115 // GCM registration_id is requested one at startup and never refreshed until
116 // next restart.
117 std::string registration_id_;
118 scoped_ptr<net::BackoffEntry> register_backoff_entry_;
119
120 scoped_ptr<net::URLFetcher> fetcher_;
121
122 // cacheinvalidation client receives echo_token with incoming message from
123 // GCM and shuld include it in headers with outgoing message over http.
124 std::string echo_token_;
125
126 GCMNetworkChannelDiagnostic diagnostic_info_;
127
128 base::WeakPtrFactory<GCMNetworkChannel> weak_factory_;
129
130 DISALLOW_COPY_AND_ASSIGN(GCMNetworkChannel);
131 };
132
133 } // namespace syncer
134
135 #endif // SYNC_NOTIFIER_GCM_NETWORK_CHANNEL_H_
OLDNEW
« no previous file with comments | « sync/notifier/fake_invalidator_unittest.cc ('k') | sync/notifier/gcm_network_channel.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698