| Index: components/sync_driver/glue/browser_thread_model_worker.cc
|
| diff --git a/components/sync_driver/glue/browser_thread_model_worker.cc b/components/sync_driver/glue/browser_thread_model_worker.cc
|
| deleted file mode 100644
|
| index faf53fc4a3ec8f32371569e697d1f33169f1311e..0000000000000000000000000000000000000000
|
| --- a/components/sync_driver/glue/browser_thread_model_worker.cc
|
| +++ /dev/null
|
| @@ -1,68 +0,0 @@
|
| -// 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
|
|
|