Index: sync/notifier/sync_system_resources.h |
diff --git a/sync/notifier/sync_system_resources.h b/sync/notifier/sync_system_resources.h |
deleted file mode 100644 |
index b618dc9c4fff19b19724cf8ef0340357424a9238..0000000000000000000000000000000000000000 |
--- a/sync/notifier/sync_system_resources.h |
+++ /dev/null |
@@ -1,241 +0,0 @@ |
-// Copyright 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. |
-// |
-// Simple system resources class that uses the current message loop |
-// for scheduling. Assumes the current message loop is already |
-// running. |
- |
-#ifndef SYNC_NOTIFIER_SYNC_SYSTEM_RESOURCES_H_ |
-#define SYNC_NOTIFIER_SYNC_SYSTEM_RESOURCES_H_ |
- |
-#include <set> |
-#include <string> |
-#include <vector> |
- |
-#include "base/compiler_specific.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "base/memory/weak_ptr.h" |
-#include "base/message_loop/message_loop.h" |
-#include "base/threading/non_thread_safe.h" |
-#include "base/values.h" |
-#include "google/cacheinvalidation/include/system-resources.h" |
-#include "jingle/notifier/base/notifier_options.h" |
-#include "sync/base/sync_export.h" |
-#include "sync/notifier/invalidator_state.h" |
-#include "sync/notifier/state_writer.h" |
- |
-namespace syncer { |
- |
-class GCMNetworkChannelDelegate; |
- |
-class SyncLogger : public invalidation::Logger { |
- public: |
- SyncLogger(); |
- |
- virtual ~SyncLogger(); |
- |
- // invalidation::Logger implementation. |
- virtual void Log(LogLevel level, const char* file, int line, |
- const char* format, ...) OVERRIDE; |
- |
- virtual void SetSystemResources( |
- invalidation::SystemResources* resources) OVERRIDE; |
-}; |
- |
-class SyncInvalidationScheduler : public invalidation::Scheduler { |
- public: |
- SyncInvalidationScheduler(); |
- |
- virtual ~SyncInvalidationScheduler(); |
- |
- // Start and stop the scheduler. |
- void Start(); |
- void Stop(); |
- |
- // invalidation::Scheduler implementation. |
- virtual void Schedule(invalidation::TimeDelta delay, |
- invalidation::Closure* task) OVERRIDE; |
- |
- virtual bool IsRunningOnThread() const OVERRIDE; |
- |
- virtual invalidation::Time GetCurrentTime() const OVERRIDE; |
- |
- virtual void SetSystemResources( |
- invalidation::SystemResources* resources) OVERRIDE; |
- |
- private: |
- // Runs the task, deletes it, and removes it from |posted_tasks_|. |
- void RunPostedTask(invalidation::Closure* task); |
- |
- // Holds all posted tasks that have not yet been run. |
- std::set<invalidation::Closure*> posted_tasks_; |
- |
- const base::MessageLoop* created_on_loop_; |
- bool is_started_; |
- bool is_stopped_; |
- |
- base::WeakPtrFactory<SyncInvalidationScheduler> weak_factory_; |
-}; |
- |
-// SyncNetworkChannel implements common tasks needed to interact with |
-// invalidation library: |
-// - registering message and network status callbacks |
-// - notifying observers about network channel state change |
-// Implementation of particular network protocol should implement |
-// SendMessage and call NotifyStateChange and DeliverIncomingMessage. |
-class SYNC_EXPORT_PRIVATE SyncNetworkChannel |
- : public NON_EXPORTED_BASE(invalidation::NetworkChannel) { |
- public: |
- class Observer { |
- public: |
- // Called when network channel state changes. Possible states are: |
- // - INVALIDATIONS_ENABLED : connection is established and working |
- // - TRANSIENT_INVALIDATION_ERROR : no network, connection lost, etc. |
- // - INVALIDATION_CREDENTIALS_REJECTED : Issues with auth token |
- virtual void OnNetworkChannelStateChanged( |
- InvalidatorState invalidator_state) = 0; |
- }; |
- |
- SyncNetworkChannel(); |
- |
- virtual ~SyncNetworkChannel(); |
- |
- // invalidation::NetworkChannel implementation. |
- // SyncNetworkChannel doesn't implement SendMessage. It is responsibility of |
- // subclass to implement it. |
- virtual void SetMessageReceiver( |
- invalidation::MessageCallback* incoming_receiver) OVERRIDE; |
- virtual void AddNetworkStatusReceiver( |
- invalidation::NetworkStatusCallback* network_status_receiver) OVERRIDE; |
- virtual void SetSystemResources( |
- invalidation::SystemResources* resources) OVERRIDE; |
- |
- // Subclass should implement UpdateCredentials to pass new token to channel |
- // library. |
- virtual void UpdateCredentials(const std::string& email, |
- const std::string& token) = 0; |
- |
- // Return value from GetInvalidationClientType will be passed to |
- // invalidation::CreateInvalidationClient. Subclass should return one of the |
- // values from ipc::invalidation::ClientType enum from types.proto. |
- virtual int GetInvalidationClientType() = 0; |
- |
- // Subclass should implement RequestDetailedStatus to provide debugging |
- // information. |
- virtual void RequestDetailedStatus( |
- base::Callback<void(const base::DictionaryValue&)> callback) = 0; |
- |
- // Classes interested in network channel state changes should implement |
- // SyncNetworkChannel::Observer and register here. |
- void AddObserver(Observer* observer); |
- void RemoveObserver(Observer* observer); |
- |
- // Helper functions that know how to construct network channels from channel |
- // specific parameters. |
- static scoped_ptr<SyncNetworkChannel> CreatePushClientChannel( |
- const notifier::NotifierOptions& notifier_options); |
- static scoped_ptr<SyncNetworkChannel> CreateGCMNetworkChannel( |
- scoped_refptr<net::URLRequestContextGetter> request_context_getter, |
- scoped_ptr<GCMNetworkChannelDelegate> delegate); |
- |
- // Get the count of how many valid received messages were received. |
- int GetReceivedMessagesCount() const; |
- |
- protected: |
- // Subclass should notify about connection state through NotifyStateChange. |
- void NotifyStateChange(InvalidatorState invalidator_state); |
- // Subclass should call DeliverIncomingMessage for message to reach |
- // invalidations library. |
- bool DeliverIncomingMessage(const std::string& message); |
- |
- private: |
- typedef std::vector<invalidation::NetworkStatusCallback*> |
- NetworkStatusReceiverList; |
- |
- // Callbacks into invalidation library |
- scoped_ptr<invalidation::MessageCallback> incoming_receiver_; |
- NetworkStatusReceiverList network_status_receivers_; |
- |
- // Last channel state for new network status receivers. |
- InvalidatorState invalidator_state_; |
- |
- int received_messages_count_; |
- |
- ObserverList<Observer> observers_; |
-}; |
- |
-class SyncStorage : public invalidation::Storage { |
- public: |
- SyncStorage(StateWriter* state_writer, invalidation::Scheduler* scheduler); |
- |
- virtual ~SyncStorage(); |
- |
- void SetInitialState(const std::string& value) { |
- cached_state_ = value; |
- } |
- |
- // invalidation::Storage implementation. |
- virtual void WriteKey(const std::string& key, const std::string& value, |
- invalidation::WriteKeyCallback* done) OVERRIDE; |
- |
- virtual void ReadKey(const std::string& key, |
- invalidation::ReadKeyCallback* done) OVERRIDE; |
- |
- virtual void DeleteKey(const std::string& key, |
- invalidation::DeleteKeyCallback* done) OVERRIDE; |
- |
- virtual void ReadAllKeys( |
- invalidation::ReadAllKeysCallback* key_callback) OVERRIDE; |
- |
- virtual void SetSystemResources( |
- invalidation::SystemResources* resources) OVERRIDE; |
- |
- private: |
- // Runs the given storage callback with SUCCESS status and deletes it. |
- void RunAndDeleteWriteKeyCallback( |
- invalidation::WriteKeyCallback* callback); |
- |
- // Runs the given callback with the given value and deletes it. |
- void RunAndDeleteReadKeyCallback( |
- invalidation::ReadKeyCallback* callback, const std::string& value); |
- |
- StateWriter* state_writer_; |
- invalidation::Scheduler* scheduler_; |
- std::string cached_state_; |
-}; |
- |
-class SYNC_EXPORT_PRIVATE SyncSystemResources |
- : public NON_EXPORTED_BASE(invalidation::SystemResources) { |
- public: |
- SyncSystemResources(SyncNetworkChannel* sync_network_channel, |
- StateWriter* state_writer); |
- |
- virtual ~SyncSystemResources(); |
- |
- // invalidation::SystemResources implementation. |
- virtual void Start() OVERRIDE; |
- virtual void Stop() OVERRIDE; |
- virtual bool IsStarted() const OVERRIDE; |
- virtual void set_platform(const std::string& platform); |
- virtual std::string platform() const OVERRIDE; |
- virtual SyncLogger* logger() OVERRIDE; |
- virtual SyncStorage* storage() OVERRIDE; |
- virtual SyncNetworkChannel* network() OVERRIDE; |
- virtual SyncInvalidationScheduler* internal_scheduler() OVERRIDE; |
- virtual SyncInvalidationScheduler* listener_scheduler() OVERRIDE; |
- |
- private: |
- bool is_started_; |
- std::string platform_; |
- scoped_ptr<SyncLogger> logger_; |
- scoped_ptr<SyncInvalidationScheduler> internal_scheduler_; |
- scoped_ptr<SyncInvalidationScheduler> listener_scheduler_; |
- scoped_ptr<SyncStorage> storage_; |
- // sync_network_channel_ is owned by SyncInvalidationListener. |
- SyncNetworkChannel* sync_network_channel_; |
-}; |
- |
-} // namespace syncer |
- |
-#endif // SYNC_NOTIFIER_SYNC_SYSTEM_RESOURCES_H_ |