| 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 #ifndef SYNC_INTERNAL_API_PUBLIC_ENGINE_MODEL_SAFE_WORKER_H_ | 5 #ifndef SYNC_INTERNAL_API_PUBLIC_ENGINE_MODEL_SAFE_WORKER_H_ |
| 6 #define SYNC_INTERNAL_API_PUBLIC_ENGINE_MODEL_SAFE_WORKER_H_ | 6 #define SYNC_INTERNAL_API_PUBLIC_ENGINE_MODEL_SAFE_WORKER_H_ |
| 7 | 7 |
| 8 #include <map> | 8 #include <map> |
| 9 #include <string> | 9 #include <string> |
| 10 #include <vector> | 10 #include <vector> |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 59 // only knows how to do one thing, and that is take some work (in a fully | 59 // only knows how to do one thing, and that is take some work (in a fully |
| 60 // pre-bound callback) and have it performed (as in Run()) from a thread which | 60 // pre-bound callback) and have it performed (as in Run()) from a thread which |
| 61 // is guaranteed to be "model-safe", where "safe" refers to not allowing us to | 61 // is guaranteed to be "model-safe", where "safe" refers to not allowing us to |
| 62 // cause an embedding application model to fall out of sync with the | 62 // cause an embedding application model to fall out of sync with the |
| 63 // syncable::Directory due to a race. Each ModelSafeWorker is affiliated with | 63 // syncable::Directory due to a race. Each ModelSafeWorker is affiliated with |
| 64 // a thread and does actual work on that thread. On the destruction of that | 64 // a thread and does actual work on that thread. On the destruction of that |
| 65 // thread, the affiliated worker is effectively disabled to do more | 65 // thread, the affiliated worker is effectively disabled to do more |
| 66 // work and will notify its observer. | 66 // work and will notify its observer. |
| 67 class SYNC_EXPORT ModelSafeWorker | 67 class SYNC_EXPORT ModelSafeWorker |
| 68 : public base::RefCountedThreadSafe<ModelSafeWorker>, | 68 : public base::RefCountedThreadSafe<ModelSafeWorker>, |
| 69 public MessageLoop::DestructionObserver { | 69 public base::MessageLoop::DestructionObserver { |
| 70 public: | 70 public: |
| 71 // Subclass should implement to observe destruction of the loop where | 71 // Subclass should implement to observe destruction of the loop where |
| 72 // it actually does work. | 72 // it actually does work. |
| 73 virtual void RegisterForLoopDestruction() = 0; | 73 virtual void RegisterForLoopDestruction() = 0; |
| 74 | 74 |
| 75 // If not stopped, call DoWorkAndWaitUntilDoneImpl() to do work. Otherwise | 75 // If not stopped, call DoWorkAndWaitUntilDoneImpl() to do work. Otherwise |
| 76 // return CANNOT_DO_WORK. | 76 // return CANNOT_DO_WORK. |
| 77 SyncerError DoWorkAndWaitUntilDone(const WorkCallback& work); | 77 SyncerError DoWorkAndWaitUntilDone(const WorkCallback& work); |
| 78 | 78 |
| 79 // Soft stop worker by setting stopped_ flag. Called when sync is disabled | 79 // Soft stop worker by setting stopped_ flag. Called when sync is disabled |
| (...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 139 SYNC_EXPORT ModelTypeSet GetRoutingInfoTypes( | 139 SYNC_EXPORT ModelTypeSet GetRoutingInfoTypes( |
| 140 const ModelSafeRoutingInfo& routing_info); | 140 const ModelSafeRoutingInfo& routing_info); |
| 141 | 141 |
| 142 SYNC_EXPORT ModelSafeGroup GetGroupForModelType( | 142 SYNC_EXPORT ModelSafeGroup GetGroupForModelType( |
| 143 const ModelType type, | 143 const ModelType type, |
| 144 const ModelSafeRoutingInfo& routes); | 144 const ModelSafeRoutingInfo& routes); |
| 145 | 145 |
| 146 } // namespace syncer | 146 } // namespace syncer |
| 147 | 147 |
| 148 #endif // SYNC_INTERNAL_API_PUBLIC_ENGINE_MODEL_SAFE_WORKER_H_ | 148 #endif // SYNC_INTERNAL_API_PUBLIC_ENGINE_MODEL_SAFE_WORKER_H_ |
| OLD | NEW |