| 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_
|
|
|