| OLD | NEW |
| 1 // Copyright 2012 The Chromium Authors. All rights reserved. | 1 // Copyright 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 // | 4 // |
| 5 // Simple system resources class that uses the current message loop | 5 // Simple system resources class that uses the current message loop |
| 6 // for scheduling. Assumes the current message loop is already | 6 // for scheduling. Assumes the current message loop is already |
| 7 // running. | 7 // running. |
| 8 | 8 |
| 9 #ifndef SYNC_NOTIFIER_SYNC_SYSTEM_RESOURCES_H_ | 9 #ifndef SYNC_NOTIFIER_SYNC_SYSTEM_RESOURCES_H_ |
| 10 #define SYNC_NOTIFIER_SYNC_SYSTEM_RESOURCES_H_ | 10 #define SYNC_NOTIFIER_SYNC_SYSTEM_RESOURCES_H_ |
| (...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 58 invalidation::Closure* task) OVERRIDE; | 58 invalidation::Closure* task) OVERRIDE; |
| 59 | 59 |
| 60 virtual bool IsRunningOnThread() const OVERRIDE; | 60 virtual bool IsRunningOnThread() const OVERRIDE; |
| 61 | 61 |
| 62 virtual invalidation::Time GetCurrentTime() const OVERRIDE; | 62 virtual invalidation::Time GetCurrentTime() const OVERRIDE; |
| 63 | 63 |
| 64 virtual void SetSystemResources( | 64 virtual void SetSystemResources( |
| 65 invalidation::SystemResources* resources) OVERRIDE; | 65 invalidation::SystemResources* resources) OVERRIDE; |
| 66 | 66 |
| 67 private: | 67 private: |
| 68 base::WeakPtrFactory<SyncInvalidationScheduler> weak_factory_; | 68 // Runs the task, deletes it, and removes it from |posted_tasks_|. |
| 69 void RunPostedTask(invalidation::Closure* task); |
| 70 |
| 69 // Holds all posted tasks that have not yet been run. | 71 // Holds all posted tasks that have not yet been run. |
| 70 std::set<invalidation::Closure*> posted_tasks_; | 72 std::set<invalidation::Closure*> posted_tasks_; |
| 71 | 73 |
| 72 const base::MessageLoop* created_on_loop_; | 74 const base::MessageLoop* created_on_loop_; |
| 73 bool is_started_; | 75 bool is_started_; |
| 74 bool is_stopped_; | 76 bool is_stopped_; |
| 75 | 77 |
| 76 // Runs the task, deletes it, and removes it from |posted_tasks_|. | 78 base::WeakPtrFactory<SyncInvalidationScheduler> weak_factory_; |
| 77 void RunPostedTask(invalidation::Closure* task); | |
| 78 }; | 79 }; |
| 79 | 80 |
| 80 class SyncStorage : public invalidation::Storage { | 81 class SyncStorage : public invalidation::Storage { |
| 81 public: | 82 public: |
| 82 SyncStorage(StateWriter* state_writer, invalidation::Scheduler* scheduler); | 83 SyncStorage(StateWriter* state_writer, invalidation::Scheduler* scheduler); |
| 83 | 84 |
| 84 virtual ~SyncStorage(); | 85 virtual ~SyncStorage(); |
| 85 | 86 |
| 86 void SetInitialState(const std::string& value) { | 87 void SetInitialState(const std::string& value) { |
| 87 cached_state_ = value; | 88 cached_state_ = value; |
| (...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 143 scoped_ptr<SyncLogger> logger_; | 144 scoped_ptr<SyncLogger> logger_; |
| 144 scoped_ptr<SyncInvalidationScheduler> internal_scheduler_; | 145 scoped_ptr<SyncInvalidationScheduler> internal_scheduler_; |
| 145 scoped_ptr<SyncInvalidationScheduler> listener_scheduler_; | 146 scoped_ptr<SyncInvalidationScheduler> listener_scheduler_; |
| 146 scoped_ptr<SyncStorage> storage_; | 147 scoped_ptr<SyncStorage> storage_; |
| 147 PushClientChannel push_client_channel_; | 148 PushClientChannel push_client_channel_; |
| 148 }; | 149 }; |
| 149 | 150 |
| 150 } // namespace syncer | 151 } // namespace syncer |
| 151 | 152 |
| 152 #endif // SYNC_NOTIFIER_SYNC_SYSTEM_RESOURCES_H_ | 153 #endif // SYNC_NOTIFIER_SYNC_SYSTEM_RESOURCES_H_ |
| OLD | NEW |