| Index: device/core/device_monitor_linux.cc
|
| diff --git a/device/core/device_monitor_linux.cc b/device/core/device_monitor_linux.cc
|
| deleted file mode 100644
|
| index 73841611c9a8d4cd12530ef205361dc2a7b07f4f..0000000000000000000000000000000000000000
|
| --- a/device/core/device_monitor_linux.cc
|
| +++ /dev/null
|
| @@ -1,138 +0,0 @@
|
| -// 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/core/device_monitor_linux.h"
|
| -
|
| -#include <memory>
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/lazy_instance.h"
|
| -#include "base/logging.h"
|
| -#include "base/threading/thread_restrictions.h"
|
| -#include "device/udev_linux/udev.h"
|
| -
|
| -namespace device {
|
| -
|
| -namespace {
|
| -
|
| -const char kUdevName[] = "udev";
|
| -const char kUdevActionAdd[] = "add";
|
| -const char kUdevActionRemove[] = "remove";
|
| -
|
| -// The instance will be reset when message loop destroys.
|
| -base::LazyInstance<std::unique_ptr<DeviceMonitorLinux>>::Leaky
|
| - g_device_monitor_linux_ptr = LAZY_INSTANCE_INITIALIZER;
|
| -
|
| -} // namespace
|
| -
|
| -DeviceMonitorLinux::DeviceMonitorLinux() : monitor_fd_(-1) {
|
| - base::ThreadRestrictions::AssertIOAllowed();
|
| - base::MessageLoop::current()->AddDestructionObserver(this);
|
| -
|
| - udev_.reset(udev_new());
|
| - if (!udev_) {
|
| - LOG(ERROR) << "Failed to create udev.";
|
| - return;
|
| - }
|
| - monitor_.reset(udev_monitor_new_from_netlink(udev_.get(), kUdevName));
|
| - if (!monitor_) {
|
| - LOG(ERROR) << "Failed to create udev monitor.";
|
| - return;
|
| - }
|
| -
|
| - int ret = udev_monitor_enable_receiving(monitor_.get());
|
| - if (ret != 0) {
|
| - LOG(ERROR) << "Failed to start udev monitoring.";
|
| - return;
|
| - }
|
| -
|
| - monitor_fd_ = udev_monitor_get_fd(monitor_.get());
|
| - if (monitor_fd_ <= 0) {
|
| - LOG(ERROR) << "Failed to start udev monitoring.";
|
| - return;
|
| - }
|
| -
|
| - monitor_watch_controller_ = base::FileDescriptorWatcher::WatchReadable(
|
| - monitor_fd_,
|
| - base::Bind(&DeviceMonitorLinux::OnMonitorCanReadWithoutBlocking,
|
| - base::Unretained(this)));
|
| -}
|
| -
|
| -// static
|
| -DeviceMonitorLinux* DeviceMonitorLinux::GetInstance() {
|
| - if (!g_device_monitor_linux_ptr.Get().get())
|
| - g_device_monitor_linux_ptr.Get().reset(new DeviceMonitorLinux());
|
| - return g_device_monitor_linux_ptr.Get().get();
|
| -}
|
| -
|
| -void DeviceMonitorLinux::AddObserver(Observer* observer) {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - observers_.AddObserver(observer);
|
| -}
|
| -
|
| -void DeviceMonitorLinux::RemoveObserver(Observer* observer) {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - observers_.RemoveObserver(observer);
|
| -}
|
| -
|
| -ScopedUdevDevicePtr DeviceMonitorLinux::GetDeviceFromPath(
|
| - const std::string& path) {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - ScopedUdevDevicePtr device(
|
| - udev_device_new_from_syspath(udev_.get(), path.c_str()));
|
| - return device;
|
| -}
|
| -
|
| -void DeviceMonitorLinux::Enumerate(const EnumerateCallback& callback) {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - ScopedUdevEnumeratePtr enumerate(udev_enumerate_new(udev_.get()));
|
| -
|
| - if (!enumerate) {
|
| - LOG(ERROR) << "Failed to enumerate devices.";
|
| - return;
|
| - }
|
| -
|
| - if (udev_enumerate_scan_devices(enumerate.get()) != 0) {
|
| - LOG(ERROR) << "Failed to enumerate devices.";
|
| - return;
|
| - }
|
| -
|
| - // This list is managed by |enumerate|.
|
| - udev_list_entry* devices = udev_enumerate_get_list_entry(enumerate.get());
|
| - for (udev_list_entry* i = devices; i != nullptr;
|
| - i = udev_list_entry_get_next(i)) {
|
| - ScopedUdevDevicePtr device(
|
| - udev_device_new_from_syspath(udev_.get(), udev_list_entry_get_name(i)));
|
| - if (device)
|
| - callback.Run(device.get());
|
| - }
|
| -}
|
| -
|
| -void DeviceMonitorLinux::WillDestroyCurrentMessageLoop() {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - FOR_EACH_OBSERVER(Observer, observers_, WillDestroyMonitorMessageLoop());
|
| - g_device_monitor_linux_ptr.Get().reset(nullptr);
|
| -}
|
| -
|
| -DeviceMonitorLinux::~DeviceMonitorLinux() {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - base::MessageLoop::current()->RemoveDestructionObserver(this);
|
| - close(monitor_fd_);
|
| -}
|
| -
|
| -void DeviceMonitorLinux::OnMonitorCanReadWithoutBlocking() {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| -
|
| - ScopedUdevDevicePtr device(udev_monitor_receive_device(monitor_.get()));
|
| - if (!device)
|
| - return;
|
| -
|
| - std::string action(udev_device_get_action(device.get()));
|
| - if (action == kUdevActionAdd)
|
| - FOR_EACH_OBSERVER(Observer, observers_, OnDeviceAdded(device.get()));
|
| - else if (action == kUdevActionRemove)
|
| - FOR_EACH_OBSERVER(Observer, observers_, OnDeviceRemoved(device.get()));
|
| -}
|
| -
|
| -} // namespace device
|
|
|