Remove MessageLoop destruction observer from hid_connection_linux.cc

device/hid/hid_service_linux.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 "device/hid/hid_service_linux.h"
 
 #include <fcntl.h>
 #include <stdint.h>
 
 #include <limits>
 #include <memory>
 #include <string>
 #include <utility>
 
 #include "base/bind.h"
 #include "base/files/file.h"
 #include "base/files/file_path.h"
 #include "base/files/file_util.h"
+#include "base/files/scoped_file.h"
 #include "base/location.h"
 #include "base/macros.h"
 #include "base/memory/ptr_util.h"
 #include "base/scoped_observer.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/strings/string_split.h"
 #include "base/threading/thread_restrictions.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "build/build_config.h"
 #include "components/device_event_log/device_event_log.h"
@@ skipping 16 matching lines @@
 const char kHIDID[] = "HID_ID";
 const char kHIDName[] = "HID_NAME";
 const char kHIDUnique[] = "HID_UNIQ";
 const char kSysfsReportDescriptorKey[] = "report_descriptor";
 
 }  // namespace
 
 struct HidServiceLinux::ConnectParams {
   ConnectParams(scoped_refptr<HidDeviceInfoLinux> device_info,
                 const ConnectCallback& callback,
-                scoped_refptr<base::SingleThreadTaskRunner> task_runner,
-                scoped_refptr<base::SingleThreadTaskRunner> file_task_runner)
-      : device_info(device_info),
+                scoped_refptr<base::SequencedTaskRunner> task_runner,
+                scoped_refptr<base::SequencedTaskRunner> blocking_task_runner)
+      : device_info(std::move(device_info)),
         callback(callback),
-        task_runner(task_runner),
-        file_task_runner(file_task_runner) {}
+        task_runner(std::move(task_runner)),
+        blocking_task_runner(std::move(blocking_task_runner)) {}
   ~ConnectParams() {}
 
   scoped_refptr<HidDeviceInfoLinux> device_info;
   ConnectCallback callback;
-  scoped_refptr<base::SingleThreadTaskRunner> task_runner;
-  scoped_refptr<base::SingleThreadTaskRunner> file_task_runner;
-  base::File device_file;
+  scoped_refptr<base::SequencedTaskRunner> task_runner;
+  scoped_refptr<base::SequencedTaskRunner> blocking_task_runner;
+  base::ScopedFD fd;
 };
 
 class HidServiceLinux::FileThreadHelper : public DeviceMonitorLinux::Observer {
  public:
   FileThreadHelper(base::WeakPtr<HidServiceLinux> service,
-                   scoped_refptr<base::SingleThreadTaskRunner> task_runner)
+                   scoped_refptr<base::SequencedTaskRunner> task_runner)
       : observer_(this), service_(service), task_runner_(task_runner) {
     thread_checker_.DetachFromThread();
   }
 
   ~FileThreadHelper() override {
     DCHECK(thread_checker_.CalledOnValidThread());
   }
 
   void Start() {
     base::ThreadRestrictions::AssertIOAllowed();
@@ skipping 101 matching lines @@
           FROM_HERE, base::Bind(&HidServiceLinux::RemoveDevice, service_,
                                 std::string(device_path)));
     }
   }
 
   base::ThreadChecker thread_checker_;
   ScopedObserver<DeviceMonitorLinux, DeviceMonitorLinux::Observer> observer_;
 
   // This weak pointer is only valid when checked on this task runner.
   base::WeakPtr<HidServiceLinux> service_;
-  scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
+  scoped_refptr<base::SequencedTaskRunner> task_runner_;
 
   DISALLOW_COPY_AND_ASSIGN(FileThreadHelper);
 };
 
 HidServiceLinux::HidServiceLinux(
-    scoped_refptr<base::SingleThreadTaskRunner> file_task_runner)
-    : file_task_runner_(std::move(file_task_runner)), weak_factory_(this) {
-  task_runner_ = base::ThreadTaskRunnerHandle::Get();
+    scoped_refptr<base::SequencedTaskRunner> blocking_task_runner)
+    : task_runner_(base::ThreadTaskRunnerHandle::Get()),
+      blocking_task_runner_(std::move(blocking_task_runner)),
+      weak_factory_(this) {
   helper_ = base::MakeUnique<FileThreadHelper>(weak_factory_.GetWeakPtr(),
                                                task_runner_);
-  file_task_runner_->PostTask(
+  blocking_task_runner_->PostTask(
       FROM_HERE,
       base::Bind(&FileThreadHelper::Start, base::Unretained(helper_.get())));
 }
 
 HidServiceLinux::~HidServiceLinux() {
   DCHECK(!helper_);
 }
 
 void HidServiceLinux::Shutdown() {
   const bool did_post_task =
-      file_task_runner_->DeleteSoon(FROM_HERE, helper_.release());
+      blocking_task_runner_->DeleteSoon(FROM_HERE, helper_.release());
   DCHECK(did_post_task);
   HidService::Shutdown();
 }
 
 void HidServiceLinux::Connect(const HidDeviceId& device_id,
                               const ConnectCallback& callback) {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   const auto& map_entry = devices().find(device_id);
   if (map_entry == devices().end()) {
     task_runner_->PostTask(FROM_HERE, base::Bind(callback, nullptr));
     return;
   }
   scoped_refptr<HidDeviceInfoLinux> device_info =
       static_cast<HidDeviceInfoLinux*>(map_entry->second.get());
 
   std::unique_ptr<ConnectParams> params(new ConnectParams(
-      device_info, callback, task_runner_, file_task_runner_));
+      device_info, callback, task_runner_, blocking_task_runner_));
 
 #if defined(OS_CHROMEOS)
   chromeos::PermissionBrokerClient* client =
       chromeos::DBusThreadManager::Get()->GetPermissionBrokerClient();
   DCHECK(client) << "Could not get permission broker client.";
   chromeos::PermissionBrokerClient::ErrorCallback error_callback =
       base::Bind(&HidServiceLinux::OnPathOpenError,
                  params->device_info->device_node(), params->callback);
   client->OpenPath(
       device_info->device_node(),
       base::Bind(&HidServiceLinux::OnPathOpenComplete, base::Passed(&params)),
       error_callback);
 #else
-  file_task_runner_->PostTask(FROM_HERE,
-                              base::Bind(&HidServiceLinux::OpenOnBlockingThread,
-                                         base::Passed(&params)));
+  blocking_task_runner_->PostTask(
+      FROM_HERE, base::Bind(&HidServiceLinux::OpenOnBlockingThread,
+                            base::Passed(&params)));
 #endif  // defined(OS_CHROMEOS)
 }
 
 #if defined(OS_CHROMEOS)
 
 // static
 void HidServiceLinux::OnPathOpenComplete(std::unique_ptr<ConnectParams> params,
                                          base::ScopedFD fd) {
-  scoped_refptr<base::SingleThreadTaskRunner> file_task_runner =
-      params->file_task_runner;
-  params->device_file = base::File(fd.release());
-  file_task_runner->PostTask(FROM_HERE, base::Bind(&HidServiceLinux::FinishOpen,
-                                                   base::Passed(&params)));
+  scoped_refptr<base::SequencedTaskRunner> blocking_task_runner =
+      params->blocking_task_runner;
+  params->fd = std::move(fd);
+  blocking_task_runner->PostTask(
+      FROM_HERE,
+      base::Bind(&HidServiceLinux::FinishOpen, base::Passed(&params)));
 }
 
 // static
 void HidServiceLinux::OnPathOpenError(const std::string& device_path,
                                       const ConnectCallback& callback,
                                       const std::string& error_name,
                                       const std::string& error_message) {
   HID_LOG(EVENT) << "Permission broker failed to open '" << device_path
                  << "': " << error_name << ": " << error_message;
   callback.Run(nullptr);
 }
 
 #else
 
 // static
 void HidServiceLinux::OpenOnBlockingThread(
     std::unique_ptr<ConnectParams> params) {
   base::ThreadRestrictions::AssertIOAllowed();
-  scoped_refptr<base::SingleThreadTaskRunner> task_runner = params->task_runner;
+  scoped_refptr<base::SequencedTaskRunner> task_runner = params->task_runner;
 
   base::FilePath device_path(params->device_info->device_node());
-  base::File& device_file = params->device_file;
+  base::File device_file;
   int flags =
       base::File::FLAG_OPEN | base::File::FLAG_READ | base::File::FLAG_WRITE;
   device_file.Initialize(device_path, flags);
   if (!device_file.IsValid()) {
     base::File::Error file_error = device_file.error_details();
 
     if (file_error == base::File::FILE_ERROR_ACCESS_DENIED) {
       HID_LOG(EVENT)
           << "Access denied opening device read-write, trying read-only.";
       flags = base::File::FLAG_OPEN | base::File::FLAG_READ;
       device_file.Initialize(device_path, flags);
     }
   }
   if (!device_file.IsValid()) {
     HID_LOG(EVENT) << "Failed to open '" << params->device_info->device_node()
                    << "': "
                    << base::File::ErrorToString(device_file.error_details());
     task_runner->PostTask(FROM_HERE, base::Bind(params->callback, nullptr));
     return;
   }
-
+  params->fd.reset(device_file.TakePlatformFile());
   FinishOpen(std::move(params));
 }
 
 #endif  // defined(OS_CHROMEOS)
 
 // static
 void HidServiceLinux::FinishOpen(std::unique_ptr<ConnectParams> params) {
   base::ThreadRestrictions::AssertIOAllowed();
-  scoped_refptr<base::SingleThreadTaskRunner> task_runner = params->task_runner;
+  scoped_refptr<base::SequencedTaskRunner> task_runner = params->task_runner;
 
-  if (!base::SetNonBlocking(params->device_file.GetPlatformFile())) {
+  if (!base::SetNonBlocking(params->fd.get())) {
     HID_PLOG(ERROR) << "Failed to set the non-blocking flag on the device fd";
     task_runner->PostTask(FROM_HERE, base::Bind(params->callback, nullptr));
     return;
   }
 
   task_runner->PostTask(
       FROM_HERE,
       base::Bind(&HidServiceLinux::CreateConnection, base::Passed(&params)));
 }
 
 // static
 void HidServiceLinux::CreateConnection(std::unique_ptr<ConnectParams> params) {
-  DCHECK(params->device_file.IsValid());
+  DCHECK(params->fd.is_valid());
   params->callback.Run(make_scoped_refptr(new HidConnectionLinux(
-      params->device_info, std::move(params->device_file),
-      params->file_task_runner)));
+      std::move(params->device_info), std::move(params->fd),
+      std::move(params->blocking_task_runner))));
 }
 
 }  // namespace device