sync: beginnings of MessageLoop based SyncerThread

chrome/browser/sync/engine/mock_model_safe_workers.h

Index: chrome/browser/sync/engine/mock_model_safe_workers.h
diff --git a/chrome/browser/sync/engine/mock_model_safe_workers.h b/chrome/browser/sync/engine/mock_model_safe_workers.h
index 3d0aa8a70f87edc0ac8591bd9108503fb574e880..c26ab58b932f7f1e68d32515da4e7fb9cc0a18df 100644
--- a/chrome/browser/sync/engine/mock_model_safe_workers.h
+++ b/chrome/browser/sync/engine/mock_model_safe_workers.h
@@ -6,6 +6,7 @@
 #define CHROME_BROWSER_SYNC_ENGINE_MOCK_MODEL_SAFE_WORKERS_H_
 #pragma once
 
+#include "base/scoped_vector.h"

[akalin, 2011/01/20 00:47:57]

needed?

[tim (not reviewing), 2011/01/25 03:23:05]

Done.

 #include "chrome/browser/sync/engine/model_safe_worker.h"
 
 namespace browser_sync {
@@ -22,6 +23,32 @@ class MockDBModelWorker : public ModelSafeWorker {
   virtual bool CurrentThreadIsWorkThread() { return true; }
 };
 
+class MockModelSafeWorkerRegistrar : public ModelSafeWorkerRegistrar {
+ public:
+  virtual ~MockModelSafeWorkerRegistrar() {}
+  static MockModelSafeWorkerRegistrar* PassiveBookmarks() {
+    ModelSafeRoutingInfo routes;
+    routes[syncable::BOOKMARKS] = GROUP_PASSIVE;
+    MockModelSafeWorkerRegistrar* m = new MockModelSafeWorkerRegistrar(routes);
+    m->passive_worker_ = new ModelSafeWorker();
+    return m;
+  }
+  virtual void GetWorkers(std::vector<ModelSafeWorker*>* out) {
+    if (passive_worker_.get())
+      out->push_back(passive_worker_.get());
+  }
+
+  virtual void GetModelSafeRoutingInfo(ModelSafeRoutingInfo* out) {
+    *out = routes_;
+  }
+ private:
+  explicit MockModelSafeWorkerRegistrar(const ModelSafeRoutingInfo& routes) {
+    routes_ = routes;
+  }
+  scoped_refptr<ModelSafeWorker> passive_worker_;
+  ModelSafeRoutingInfo routes_;
+};
+
 }  // namespace browser_sync
 
 #endif  // CHROME_BROWSER_SYNC_ENGINE_MOCK_MODEL_SAFE_WORKERS_H_