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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
// copyright 2012–2021 nick black
#include <assert.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <libudev.h>
#include "zfs.h"
#include "udev.h"
#include "pthread.h"
#include "growlight.h"
static struct udev *udev;
struct udev_monitor *udmon;
int udev_event(const glightui *gui){
struct udev_device *dev;
while( (dev = udev_monitor_receive_device(udmon)) ){
const char *subsys = udev_device_get_subsystem(dev);
verbf("udev: %s %s %s %s %s %s %s\n",
udev_device_get_devpath(dev), subsys,
udev_device_get_devtype(dev), udev_device_get_syspath(dev),
udev_device_get_sysname(dev), udev_device_get_sysnum(dev),
udev_device_get_devnode(dev));
if(strcmp(subsys, "bdi") == 0){
scan_zpools(gui);
}else{
rescan_device(udev_device_get_sysname(dev));
}
}
return 0;
}
int monitor_udev(void){
int r;
if((udev = udev_new()) == NULL){
diag("Couldn't get udev instance (%s?)\n", strerror(errno));
return -1;
}
if((udmon = udev_monitor_new_from_netlink(udev, "udev")) == NULL){
diag("Couldn't get udev monitor (%s?)\n", strerror(errno));
udev_unref(udev);
return -1;
}
if(udev_monitor_filter_add_match_subsystem_devtype(udmon, "bdi", NULL)){
diag("Warning: couldn't watch bdi events\n");
}
if(udev_monitor_filter_add_match_subsystem_devtype(udmon, "block", NULL)){
diag("Couldn't watch block events\n");
udev_monitor_unref(udmon);
udev_unref(udev);
return -1;
}
if(udev_monitor_enable_receiving(udmon)){
diag("Couldn't enable udev\n");
udev_monitor_unref(udmon);
udev_unref(udev);
return -1;
}
if((r = udev_monitor_get_fd(udmon)) < 0){
diag("Couldn't get udev fd\n");
udev_monitor_unref(udmon);
udev_unref(udev);
return -1;
}
return r;
}
int shutdown_udev(void){
diag("Shutting down udev monitor...\n");
udev_monitor_unref(udmon);
udev_unref(udev);
udmon = NULL;
udev = NULL;
return 0;
}
|
