1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
// Copyright (c) 2012 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/udev_linux/udev_linux.h"
#include <stddef.h>
#include "base/message_loop/message_loop.h"
namespace device {
UdevLinux::UdevLinux(const std::vector<UdevMonitorFilter>& filters,
const UdevNotificationCallback& callback)
: udev_(udev_new()),
monitor_(udev_monitor_new_from_netlink(udev_.get(), "udev")),
monitor_fd_(-1),
callback_(callback) {
CHECK(udev_);
CHECK(monitor_);
CHECK_EQ(base::MessageLoop::TYPE_IO, base::MessageLoop::current()->type());
for (const UdevMonitorFilter& filter : filters) {
const int ret = udev_monitor_filter_add_match_subsystem_devtype(
monitor_.get(), filter.subsystem, filter.devtype);
CHECK_EQ(0, ret);
}
const int ret = udev_monitor_enable_receiving(monitor_.get());
CHECK_EQ(0, ret);
monitor_fd_ = udev_monitor_get_fd(monitor_.get());
CHECK_GE(monitor_fd_, 0);
bool success = base::MessageLoopForIO::current()->WatchFileDescriptor(
monitor_fd_, true, base::MessageLoopForIO::WATCH_READ, &monitor_watcher_,
this);
CHECK(success);
}
UdevLinux::~UdevLinux() {
monitor_watcher_.StopWatchingFileDescriptor();
}
udev* UdevLinux::udev_handle() {
return udev_.get();
}
void UdevLinux::OnFileCanReadWithoutBlocking(int fd) {
// Events occur when devices attached to the system are added, removed, or
// change state. udev_monitor_receive_device() will return a device object
// representing the device which changed and what type of change occured.
DCHECK_EQ(monitor_fd_, fd);
ScopedUdevDevicePtr dev(udev_monitor_receive_device(monitor_.get()));
if (!dev)
return;
callback_.Run(dev.get());
}
void UdevLinux::OnFileCanWriteWithoutBlocking(int fd) {}
} // namespace device
|
