Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(6404)

Unified Diff: chrome/browser/sync/glue/browser_thread_model_worker.cc

Issue 7891054: Add GROUP_FILE ModelSafeGroup (Closed) Base URL: http://git.chromium.org/git/chromium.git@trunk
Patch Set: Fix worker count in unittest Created 9 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: chrome/browser/sync/glue/browser_thread_model_worker.cc
diff --git a/chrome/browser/sync/glue/browser_thread_model_worker.cc b/chrome/browser/sync/glue/browser_thread_model_worker.cc
new file mode 100644
index 0000000000000000000000000000000000000000..49bdfb8b01176a08436e4522262e84667a007b8c
--- /dev/null
+++ b/chrome/browser/sync/glue/browser_thread_model_worker.cc
@@ -0,0 +1,52 @@
+// Copyright (c) 2011 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.
+
+#include "chrome/browser/sync/glue/browser_thread_model_worker.h"
+
+#include "base/synchronization/waitable_event.h"
+#include "content/browser/browser_thread.h"
+
+using base::WaitableEvent;
+
+namespace browser_sync {
+
+BrowserThreadModelWorker::BrowserThreadModelWorker(
+ BrowserThread::ID thread, ModelSafeGroup group)
+ : thread_(thread), group_(group) {}
+
+BrowserThreadModelWorker::~BrowserThreadModelWorker() {}
+
+void BrowserThreadModelWorker::DoWorkAndWaitUntilDone(Callback0::Type* work) {
+ if (BrowserThread::CurrentlyOn(thread_)) {
+ DLOG(WARNING) << "Already on thread " << thread_;
+ work->Run();
+ return;
+ }
+ WaitableEvent done(false, false);
+ if (!BrowserThread::PostTask(
+ thread_,
+ FROM_HERE,
+ NewRunnableMethod(
+ this,
+ &BrowserThreadModelWorker::CallDoWorkAndSignalTask,
+ work,
+ &done))) {
+ NOTREACHED() << "Failed to post task to thread " << thread_;
+ return;
+ }
+ done.Wait();
+}
+
+void BrowserThreadModelWorker::CallDoWorkAndSignalTask(
+ Callback0::Type* work, WaitableEvent* done) {
+ DCHECK(BrowserThread::CurrentlyOn(thread_));
+ work->Run();
+ done->Signal();
+}
+
+ModelSafeGroup BrowserThreadModelWorker::GetModelSafeGroup() {
+ return group_;
+}
+
+} // namespace browser_sync

Powered by Google App Engine
This is Rietveld 408576698