diff options
author | rockot@chromium.org <rockot@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2014-01-31 20:13:23 +0000 |
---|---|---|
committer | rockot@chromium.org <rockot@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2014-01-31 20:13:23 +0000 |
commit | 125724f2dd1b339cc6dc3f3bcf2b0d565765471f (patch) | |
tree | b6b1f0d2bd292f39161de8317338edb6076fd848 /device/hid/hid_service_linux.cc | |
parent | 64e3d73b60bbe5d3e7808c444ae1e1e392981a41 (diff) | |
download | chromium_src-125724f2dd1b339cc6dc3f3bcf2b0d565765471f.zip chromium_src-125724f2dd1b339cc6dc3f3bcf2b0d565765471f.tar.gz chromium_src-125724f2dd1b339cc6dc3f3bcf2b0d565765471f.tar.bz2 |
HID backend.
This is a continuation of https://codereview.chromium.org/143883005.
[ps#1 here is (post-revert) ps#12 there.]
BUG=290428
TBR=miket@chromium.org
Review URL: https://codereview.chromium.org/150773004
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@248250 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'device/hid/hid_service_linux.cc')
-rw-r--r-- | device/hid/hid_service_linux.cc | 211 |
1 files changed, 211 insertions, 0 deletions
diff --git a/device/hid/hid_service_linux.cc b/device/hid/hid_service_linux.cc new file mode 100644 index 0000000..f02a550 --- /dev/null +++ b/device/hid/hid_service_linux.cc @@ -0,0 +1,211 @@ +// Copyright (c) 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 <libudev.h> +#include <string> +#include <vector> + +#include "base/basictypes.h" +#include "base/bind.h" +#include "base/callback.h" +#include "base/logging.h" +#include "base/memory/scoped_vector.h" +#include "base/platform_file.h" +#include "base/strings/string_number_conversions.h" +#include "base/strings/string_piece.h" +#include "base/strings/string_split.h" +#include "base/threading/thread_restrictions.h" +#include "device/hid/hid_connection.h" +#include "device/hid/hid_connection_linux.h" +#include "device/hid/hid_device_info.h" +#include "device/hid/hid_service_linux.h" + +namespace device { + +namespace { + +const char kUdevName[] = "udev"; +const char kUdevActionAdd[] = "add"; +const char kUdevActionRemove[] = "remove"; +const char kHIDSubSystem[] = "hid"; + +const char kHIDID[] = "HID_ID"; +const char kHIDName[] = "HID_NAME"; +const char kHIDUnique[] = "HID_UNIQ"; + +} // namespace + +HidServiceLinux::HidServiceLinux() { + 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_filter_add_match_subsystem_devtype( + monitor_.get(), + kHIDSubSystem, + NULL); + if (ret != 0) { + LOG(ERROR) << "Failed to add udev monitor filter."; + return; + } + + 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; + } + + if (!base::MessageLoopForIO::current()->WatchFileDescriptor( + monitor_fd_, + true, + base::MessageLoopForIO::WATCH_READ, + &monitor_watcher_, + this)) + return; + + Enumerate(); +} + +HidServiceLinux::~HidServiceLinux() { + monitor_watcher_.StopWatchingFileDescriptor(); + close(monitor_fd_); +} + +void HidServiceLinux::Enumerate() { + scoped_ptr<udev_enumerate, UdevEnumerateDeleter> enumerate( + udev_enumerate_new(udev_.get())); + + if (!enumerate) { + LOG(ERROR) << "Failed to enumerate devices."; + return; + } + + if (udev_enumerate_add_match_subsystem(enumerate.get(), kHIDSubSystem)) { + 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 != NULL; + i = udev_list_entry_get_next(i)) { + ScopedUdevDevicePtr hid_dev( + udev_device_new_from_syspath(udev_.get(), udev_list_entry_get_name(i))); + if (hid_dev) { + PlatformDeviceAdd(hid_dev.get()); + } + } + + initialized_ = true; +} + +void HidServiceLinux::PlatformDeviceAdd(udev_device* device) { + if (!device) + return; + + const char* device_id = udev_device_get_syspath(device); + if (!device_id) + return; + + + HidDeviceInfo device_info; + device_info.device_id = device_id; + + uint32 int_property = 0; + const char* str_property = NULL; + + const char* hid_id = udev_device_get_property_value(device, kHIDID); + if (!hid_id) + return; + + std::vector<std::string> parts; + base::SplitString(hid_id, ':', &parts); + if (parts.size() != 3) { + return; + } + + if (HexStringToUInt(base::StringPiece(parts[1]), &int_property)) { + device_info.vendor_id = int_property; + } + + if (HexStringToUInt(base::StringPiece(parts[2]), &int_property)) { + device_info.product_id = int_property; + } + + str_property = udev_device_get_property_value(device, kHIDUnique); + if (str_property != NULL) + device_info.serial_number = str_property; + + str_property = udev_device_get_property_value(device, kHIDName); + if (str_property != NULL) + device_info.product_name = str_property; + + AddDevice(device_info); +} + +void HidServiceLinux::PlatformDeviceRemove(udev_device* raw_dev) { + // The returned the device is not referenced. + udev_device* hid_dev = + udev_device_get_parent_with_subsystem_devtype(raw_dev, "hid", NULL); + + if (!hid_dev) + return; + + const char* device_id = NULL; + device_id = udev_device_get_syspath(hid_dev); + if (device_id == NULL) + return; + + RemoveDevice(device_id); +} + +scoped_refptr<HidConnection> HidServiceLinux::Connect(std::string device_id) { + if (!ContainsKey(devices_, device_id)) + return NULL; + ScopedUdevDevicePtr hid_device( + udev_device_new_from_syspath(udev_.get(), device_id.c_str())); + if (hid_device) { + scoped_refptr<HidConnectionLinux> connection = + new HidConnectionLinux(devices_[device_id], hid_device.Pass()); + if (connection->initialized()) + return connection; + } + return NULL; +} + +void HidServiceLinux::OnFileCanReadWithoutBlocking(int fd) { + DCHECK_EQ(monitor_fd_, fd); + + ScopedUdevDevicePtr dev(udev_monitor_receive_device(monitor_.get())); + if (!dev) + return; + + std::string action(udev_device_get_action(dev.get())); + if (action == kUdevActionAdd) { + PlatformDeviceAdd(dev.get()); + } else if (action == kUdevActionRemove) { + PlatformDeviceRemove(dev.get()); + } +} + +void HidServiceLinux::OnFileCanWriteWithoutBlocking(int fd) {} + +} // namespace dev |