Created fakes for HID-detection screen testing. Initial browsertest added.

chrome/browser/chromeos/device/input_service_proxy.cc

 // Copyright 2014 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/chromeos/device/input_service_proxy.h"
 
 #include "base/bind_helpers.h"
 #include "base/task_runner_util.h"
 #include "content/public/browser/browser_thread.h"
 
 using content::BrowserThread;
 using device::InputServiceLinux;
 
 typedef device::InputServiceLinux::InputDeviceInfo InputDeviceInfo;
 
 namespace chromeos {
 
+// static
+BrowserThread::ID InputServiceProxy::thread_identifier_ = BrowserThread::FILE;
+
 class InputServiceProxy::ServiceObserver : public InputServiceLinux::Observer {
  public:
   ServiceObserver() { DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); }
   ~ServiceObserver() override { DCHECK(CalledOnValidThread()); }
 
   void Initialize(const base::WeakPtr<InputServiceProxy>& proxy) {
     DCHECK(CalledOnValidThread());
     InputServiceLinux::GetInstance()->AddObserver(this);
     proxy_ = proxy;
   }
@@ skipping 38 matching lines @@
   void OnInputDeviceRemoved(const std::string& id) override {
     DCHECK(CalledOnValidThread());
     BrowserThread::PostTask(
         BrowserThread::UI,
         FROM_HERE,
         base::Bind(&InputServiceProxy::OnDeviceRemoved, proxy_, id));
   }
 
  private:
   bool CalledOnValidThread() const {
-    return BrowserThread::CurrentlyOn(BrowserThread::FILE);
+    return BrowserThread::CurrentlyOn(InputServiceProxy::thread_identifier_);
   }
 
   base::WeakPtr<InputServiceProxy> proxy_;
 
   DISALLOW_COPY_AND_ASSIGN(ServiceObserver);
 };
 
 InputServiceProxy::InputServiceProxy()
-    : service_observer_(new ServiceObserver()), weak_factory_(this) {
+    : service_observer_(new ServiceObserver()),
+      task_runner_(BrowserThread::GetMessageLoopProxyForThread(
+          thread_identifier_)),
+      weak_factory_(this) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-  BrowserThread::PostTask(
-      BrowserThread::FILE,
+  task_runner_->PostTask(
       FROM_HERE,
       base::Bind(&InputServiceProxy::ServiceObserver::Initialize,
                  base::Unretained(service_observer_.get()),
                  weak_factory_.GetWeakPtr()));
 }
 
 InputServiceProxy::~InputServiceProxy() {
   DCHECK(thread_checker_.CalledOnValidThread());
-  BrowserThread::PostTask(
-      BrowserThread::FILE,
+  task_runner_->PostTask(
       FROM_HERE,
       base::Bind(&InputServiceProxy::ServiceObserver::Shutdown,
                  base::Unretained(service_observer_.release())));
 }
 
 // static
 void InputServiceProxy::WarmUp() {
   content::BrowserThread::PostTask(
-      content::BrowserThread::FILE,
+      thread_identifier_,
       FROM_HERE,
       base::Bind(base::IgnoreResult(&InputServiceLinux::GetInstance)));
 }
 
 void InputServiceProxy::AddObserver(Observer* observer) {
   DCHECK(thread_checker_.CalledOnValidThread());
   if (observer)
     observers_.AddObserver(observer);
 }
 
 void InputServiceProxy::RemoveObserver(Observer* observer) {
   DCHECK(thread_checker_.CalledOnValidThread());
   if (observer)
     observers_.RemoveObserver(observer);
 }
 
 void InputServiceProxy::GetDevices(const GetDevicesCallback& callback) {
   DCHECK(thread_checker_.CalledOnValidThread());
-  BrowserThread::PostTaskAndReplyWithResult(
-      BrowserThread::FILE,
+  base::PostTaskAndReplyWithResult(
+      task_runner_.get(),
       FROM_HERE,
       base::Bind(&InputServiceProxy::ServiceObserver::GetDevices,
                  base::Unretained(service_observer_.get())),
       callback);
 }
 
 void InputServiceProxy::GetDeviceInfo(const std::string& id,
                                       const GetDeviceInfoCallback& callback) {
   DCHECK(thread_checker_.CalledOnValidThread());
-  BrowserThread::PostTask(
-      BrowserThread::FILE,
+  task_runner_->PostTask(
       FROM_HERE,
       base::Bind(&InputServiceProxy::ServiceObserver::GetDeviceInfo,
                  base::Unretained(service_observer_.release()),
                  id,
                  callback));
 }
 
+// static
+void InputServiceProxy::SetThreadIdForTesting(BrowserThread::ID thread_id) {
+  InputServiceProxy::thread_identifier_ = thread_id;
+}
+
 void InputServiceProxy::OnDeviceAdded(
     const InputServiceLinux::InputDeviceInfo& info) {
   DCHECK(thread_checker_.CalledOnValidThread());
   FOR_EACH_OBSERVER(Observer, observers_, OnInputDeviceAdded(info));
 }
 
 void InputServiceProxy::OnDeviceRemoved(const std::string& id) {
   DCHECK(thread_checker_.CalledOnValidThread());
   FOR_EACH_OBSERVER(Observer, observers_, OnInputDeviceRemoved(id));
 }
 
 }  // namespace chromeos