Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1684)

Unified Diff: device/core/device_monitor_linux.cc

Issue 2417043002: Move device/core files to device/base directory. (Closed)
Patch Set: Fix ChromeOS build Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « device/core/device_monitor_linux.h ('k') | device/core/device_monitor_win.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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
« no previous file with comments | « device/core/device_monitor_linux.h ('k') | device/core/device_monitor_win.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698