[Sync] Move //components/sync_driver to //components/sync/driver.

components/sync_driver/glue/ui_model_worker_unittest.cc

-// Copyright (c) 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/ui_model_worker.h"
-
-#include <memory>
-
-#include "base/bind.h"
-#include "base/bind_helpers.h"
-#include "base/callback.h"
-#include "base/location.h"
-#include "base/macros.h"
-#include "base/memory/ref_counted.h"
-#include "base/run_loop.h"
-#include "base/single_thread_task_runner.h"
-#include "base/synchronization/waitable_event.h"
-#include "base/threading/thread.h"
-#include "base/threading/thread_task_runner_handle.h"
-#include "testing/gtest/include/gtest/gtest.h"
-
-using browser_sync::UIModelWorker;
-using syncer::SyncerError;
-
-class UIModelWorkerVisitor {
- public:
-  UIModelWorkerVisitor(base::WaitableEvent* was_run,
-                       bool quit_loop)
-     : quit_loop_when_run_(quit_loop),
-       was_run_(was_run) { }
-  virtual ~UIModelWorkerVisitor() { }
-
-  virtual syncer::SyncerError DoWork() {
-    was_run_->Signal();
-    if (quit_loop_when_run_)
-      base::MessageLoop::current()->QuitWhenIdle();
-    return syncer::SYNCER_OK;
-  }
-
- private:
-  bool quit_loop_when_run_;
-  base::WaitableEvent* was_run_;
-  DISALLOW_COPY_AND_ASSIGN(UIModelWorkerVisitor);
-};
-
-// A faux-syncer that only interacts with its model safe worker.
-class Syncer {
- public:
-  explicit Syncer(UIModelWorker* worker) : worker_(worker) {}
-  ~Syncer() {}
-
-  void SyncShare(UIModelWorkerVisitor* visitor) {
-    // We wait until the callback is executed. So it is safe to use Unretained.
-    syncer::WorkCallback c = base::Bind(&UIModelWorkerVisitor::DoWork,
-                                       base::Unretained(visitor));
-    worker_->DoWorkAndWaitUntilDone(c);
-  }
- private:
-  scoped_refptr<UIModelWorker> worker_;
-  DISALLOW_COPY_AND_ASSIGN(Syncer);
-};
-
-class SyncUIModelWorkerTest : public testing::Test {
- public:
-  SyncUIModelWorkerTest() : faux_syncer_thread_("FauxSyncerThread"),
-                            faux_core_thread_("FauxCoreThread") { }
-
-  void SetUp() override {
-    faux_syncer_thread_.Start();
-    bmw_ = new UIModelWorker(base::ThreadTaskRunnerHandle::Get(), nullptr);
-    syncer_.reset(new Syncer(bmw_.get()));
-  }
-
-  Syncer* syncer() { return syncer_.get(); }
-  UIModelWorker* bmw() { return bmw_.get(); }
-  base::Thread* core_thread() { return &faux_core_thread_; }
-  base::Thread* syncer_thread() { return &faux_syncer_thread_; }
- private:
-  base::MessageLoop faux_ui_loop_;
-  base::Thread faux_syncer_thread_;
-  base::Thread faux_core_thread_;
-  scoped_refptr<UIModelWorker> bmw_;
-  std::unique_ptr<Syncer> syncer_;
-};
-
-TEST_F(SyncUIModelWorkerTest, ScheduledWorkRunsOnUILoop) {
-  base::WaitableEvent v_was_run(
-      base::WaitableEvent::ResetPolicy::AUTOMATIC,
-      base::WaitableEvent::InitialState::NOT_SIGNALED);
-  std::unique_ptr<UIModelWorkerVisitor> v(
-      new UIModelWorkerVisitor(&v_was_run, true));
-
-  syncer_thread()->task_runner()->PostTask(
-      FROM_HERE,
-      base::Bind(&Syncer::SyncShare, base::Unretained(syncer()), v.get()));
-
-  // We are on the UI thread, so run our loop to process the
-  // (hopefully) scheduled task from a SyncShare invocation.
-  base::RunLoop().Run();
-  syncer_thread()->Stop();
-}