| // 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. |
| |
| #include "components/sync_driver/glue/browser_thread_model_worker.h" |
| |
| #include "base/bind.h" |
| #include "base/single_thread_task_runner.h" |
| #include "base/synchronization/waitable_event.h" |
| |
| using base::SingleThreadTaskRunner; |
| using base::WaitableEvent; |
| |
| namespace browser_sync { |
| |
| BrowserThreadModelWorker::BrowserThreadModelWorker( |
| const scoped_refptr<SingleThreadTaskRunner>& runner, |
| syncer::ModelSafeGroup group, |
| syncer::WorkerLoopDestructionObserver* observer) |
| : ModelSafeWorker(observer), runner_(runner), group_(group) {} |
| |
| syncer::SyncerError BrowserThreadModelWorker::DoWorkAndWaitUntilDoneImpl( |
| const syncer::WorkCallback& work) { |
| syncer::SyncerError error = syncer::UNSET; |
| if (runner_->BelongsToCurrentThread()) { |
| DLOG(WARNING) << "Already on thread " << runner_; |
| return work.Run(); |
| } |
| |
| if (!runner_->PostTask( |
| FROM_HERE, |
| base::Bind(&BrowserThreadModelWorker::CallDoWorkAndSignalTask, this, |
| work, work_done_or_stopped(), &error))) { |
| DLOG(WARNING) << "Failed to post task to runner " << runner_; |
| error = syncer::CANNOT_DO_WORK; |
| return error; |
| } |
| work_done_or_stopped()->Wait(); |
| return error; |
| } |
| |
| syncer::ModelSafeGroup BrowserThreadModelWorker::GetModelSafeGroup() { |
| return group_; |
| } |
| |
| BrowserThreadModelWorker::~BrowserThreadModelWorker() {} |
| |
| void BrowserThreadModelWorker::RegisterForLoopDestruction() { |
| if (runner_->BelongsToCurrentThread()) { |
| SetWorkingLoopToCurrent(); |
| } else { |
| runner_->PostTask( |
| FROM_HERE, |
| Bind(&BrowserThreadModelWorker::RegisterForLoopDestruction, this)); |
| } |
| } |
| |
| void BrowserThreadModelWorker::CallDoWorkAndSignalTask( |
| const syncer::WorkCallback& work, |
| WaitableEvent* done, |
| syncer::SyncerError* error) { |
| DCHECK(runner_->BelongsToCurrentThread()); |
| if (!IsStopped()) |
| *error = work.Run(); |
| done->Signal(); |
| } |
| |
| } // namespace browser_sync |