shaba/systemd
1
0
Fork 0
mirror of https://github.com/systemd/systemd.git synced 2025-02-04 21:47:31 +03:00
Code

sd-device-monitor: introduce sd_device_monitor_filter_add_match_sysattr()

Browse Source
This commit is contained in:
Yu Watanabe 2021-02-21 09:33:04 +09:00
parent ac790e8bfc
commit d9b030b673
3 changed files with 31 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/libsystemd/libsystemd.sym
View File

@ -751,3 +751,8 @@ global:
sd_device_new_from_stat_rdev;
sd_device_trigger;
} LIBSYSTEMD_247;
LIBSYSTEMD_249 {
global:
sd_device_monitor_filter_add_match_sysattr;
} LIBSYSTEMD_248;

26
src/libsystemd/sd-device/device-monitor.c
View File

@ -37,6 +37,8 @@ struct sd_device_monitor {
Hashmap *subsystem_filter;
Set *tag_filter;
Hashmap *match_sysattr_filter;
Hashmap *nomatch_sysattr_filter;
bool filter_uptodate;
sd_event *event;
@ -336,6 +338,8 @@ static sd_device_monitor *device_monitor_free(sd_device_monitor *m) {
hashmap_free(m->subsystem_filter);
set_free(m->tag_filter);
hashmap_free(m->match_sysattr_filter);
hashmap_free(m->nomatch_sysattr_filter);
return mfree(m);
}
@ -397,7 +401,10 @@ static int passes_filter(sd_device_monitor *m, sd_device *device) {
if (r <= 0)
return r;
return check_tag_filter(m, device);
if (!check_tag_filter(m, device))
return false;
return device_match_sysattr(device, m->match_sysattr_filter, m->nomatch_sysattr_filter);
}
int device_monitor_receive_device(sd_device_monitor *m, sd_device **ret) {
@ -760,6 +767,21 @@ _public_ int sd_device_monitor_filter_add_match_tag(sd_device_monitor *m, const
return r;
}
_public_ int sd_device_monitor_filter_add_match_sysattr(sd_device_monitor *m, const char *sysattr, const char *value, int match) {
Hashmap **hashmap;
assert_return(m, -EINVAL);
assert_return(sysattr, -EINVAL);
if (match)
hashmap = &m->match_sysattr_filter;
else
hashmap = &m->nomatch_sysattr_filter;
/* TODO: unset m->filter_uptodate on success when we support this filter on BPF. */
return hashmap_put_strdup_full(hashmap, &trivial_hash_ops_free_free, sysattr, value);
}
_public_ int sd_device_monitor_filter_remove(sd_device_monitor *m) {
static const struct sock_fprog filter = { 0, NULL };
@ -767,6 +789,8 @@ _public_ int sd_device_monitor_filter_remove(sd_device_monitor *m) {
m->subsystem_filter = hashmap_free(m->subsystem_filter);
m->tag_filter = set_free(m->tag_filter);
m->match_sysattr_filter = hashmap_free(m->match_sysattr_filter);
m->nomatch_sysattr_filter = hashmap_free(m->nomatch_sysattr_filter);
if (setsockopt(m->sock, SOL_SOCKET, SO_DETACH_FILTER, &filter, sizeof(filter)) < 0)
return -errno;

1
src/systemd/sd-device.h
View File

@ -136,6 +136,7 @@ int sd_device_monitor_stop(sd_device_monitor *m);
int sd_device_monitor_filter_add_match_subsystem_devtype(sd_device_monitor *m, const char *subsystem, const char *devtype);
int sd_device_monitor_filter_add_match_tag(sd_device_monitor *m, const char *tag);
int sd_device_monitor_filter_add_match_sysattr(sd_device_monitor *m, const char *sysattr, const char *value, int match);
int sd_device_monitor_filter_update(sd_device_monitor *m);
int sd_device_monitor_filter_remove(sd_device_monitor *m);