Line data Source code
1 : /* SPDX-License-Identifier: LGPL-2.1+ */
2 :
3 : #include <stdbool.h>
4 : #include <unistd.h>
5 :
6 : #include "sd-device.h"
7 : #include "sd-event.h"
8 :
9 : #include "device-monitor-private.h"
10 : #include "device-private.h"
11 : #include "device-util.h"
12 : #include "macro.h"
13 : #include "string-util.h"
14 : #include "tests.h"
15 : #include "util.h"
16 : #include "virt.h"
17 :
18 0 : static int monitor_handler(sd_device_monitor *m, sd_device *d, void *userdata) {
19 0 : const char *s, *syspath = userdata;
20 :
21 0 : assert_se(sd_device_get_syspath(d, &s) >= 0);
22 0 : assert_se(streq(s, syspath));
23 :
24 0 : return sd_event_exit(sd_device_monitor_get_event(m), 100);
25 : }
26 :
27 0 : static int test_receive_device_fail(void) {
28 0 : _cleanup_(sd_device_monitor_unrefp) sd_device_monitor *monitor_server = NULL, *monitor_client = NULL;
29 0 : _cleanup_(sd_device_unrefp) sd_device *loopback = NULL;
30 : const char *syspath;
31 : int r;
32 :
33 0 : log_info("/* %s */", __func__);
34 :
35 : /* Try to send device with invalid action and without seqnum. */
36 0 : assert_se(sd_device_new_from_syspath(&loopback, "/sys/class/net/lo") >= 0);
37 0 : assert_se(device_add_property(loopback, "ACTION", "hoge") >= 0);
38 :
39 0 : assert_se(sd_device_get_syspath(loopback, &syspath) >= 0);
40 :
41 0 : assert_se(device_monitor_new_full(&monitor_server, MONITOR_GROUP_NONE, -1) >= 0);
42 0 : assert_se(sd_device_monitor_start(monitor_server, NULL, NULL) >= 0);
43 0 : assert_se(sd_event_source_set_description(sd_device_monitor_get_event_source(monitor_server), "sender") >= 0);
44 :
45 0 : assert_se(device_monitor_new_full(&monitor_client, MONITOR_GROUP_NONE, -1) >= 0);
46 0 : assert_se(device_monitor_allow_unicast_sender(monitor_client, monitor_server) >= 0);
47 0 : assert_se(sd_device_monitor_start(monitor_client, monitor_handler, (void *) syspath) >= 0);
48 0 : assert_se(sd_event_source_set_description(sd_device_monitor_get_event_source(monitor_client), "receiver") >= 0);
49 :
50 : /* Do not use assert_se() here. */
51 0 : r = device_monitor_send_device(monitor_server, monitor_client, loopback);
52 0 : if (r < 0)
53 0 : return log_error_errno(r, "Failed to send loopback device: %m");
54 :
55 0 : assert_se(sd_event_run(sd_device_monitor_get_event(monitor_client), 0) >= 0);
56 :
57 0 : return 0;
58 : }
59 :
60 0 : static void test_send_receive_one(sd_device *device, bool subsystem_filter, bool tag_filter, bool use_bpf) {
61 0 : _cleanup_(sd_device_monitor_unrefp) sd_device_monitor *monitor_server = NULL, *monitor_client = NULL;
62 0 : const char *syspath, *subsystem, *tag, *devtype = NULL;
63 :
64 0 : log_device_info(device, "/* %s(subsystem_filter=%s, tag_filter=%s, use_bpf=%s) */", __func__,
65 : true_false(subsystem_filter), true_false(tag_filter), true_false(use_bpf));
66 :
67 0 : assert_se(sd_device_get_syspath(device, &syspath) >= 0);
68 :
69 0 : assert_se(device_monitor_new_full(&monitor_server, MONITOR_GROUP_NONE, -1) >= 0);
70 0 : assert_se(sd_device_monitor_start(monitor_server, NULL, NULL) >= 0);
71 0 : assert_se(sd_event_source_set_description(sd_device_monitor_get_event_source(monitor_server), "sender") >= 0);
72 :
73 0 : assert_se(device_monitor_new_full(&monitor_client, MONITOR_GROUP_NONE, -1) >= 0);
74 0 : assert_se(device_monitor_allow_unicast_sender(monitor_client, monitor_server) >= 0);
75 0 : assert_se(sd_device_monitor_start(monitor_client, monitor_handler, (void *) syspath) >= 0);
76 0 : assert_se(sd_event_source_set_description(sd_device_monitor_get_event_source(monitor_client), "receiver") >= 0);
77 :
78 0 : if (subsystem_filter) {
79 0 : assert_se(sd_device_get_subsystem(device, &subsystem) >= 0);
80 0 : (void) sd_device_get_devtype(device, &devtype);
81 0 : assert_se(sd_device_monitor_filter_add_match_subsystem_devtype(monitor_client, subsystem, devtype) >= 0);
82 : }
83 :
84 0 : if (tag_filter)
85 0 : FOREACH_DEVICE_TAG(device, tag)
86 0 : assert_se(sd_device_monitor_filter_add_match_tag(monitor_client, tag) >= 0);
87 :
88 0 : if ((subsystem_filter || tag_filter) && use_bpf)
89 0 : assert_se(sd_device_monitor_filter_update(monitor_client) >= 0);
90 :
91 0 : assert_se(device_monitor_send_device(monitor_server, monitor_client, device) >= 0);
92 0 : assert_se(sd_event_loop(sd_device_monitor_get_event(monitor_client)) == 100);
93 0 : }
94 :
95 0 : static void test_subsystem_filter(sd_device *device) {
96 0 : _cleanup_(sd_device_monitor_unrefp) sd_device_monitor *monitor_server = NULL, *monitor_client = NULL;
97 0 : _cleanup_(sd_device_enumerator_unrefp) sd_device_enumerator *e = NULL;
98 : const char *syspath, *subsystem, *p, *s;
99 : sd_device *d;
100 :
101 0 : log_info("/* %s */", __func__);
102 :
103 0 : assert_se(sd_device_get_syspath(device, &syspath) >= 0);
104 0 : assert_se(sd_device_get_subsystem(device, &subsystem) >= 0);
105 :
106 0 : assert_se(device_monitor_new_full(&monitor_server, MONITOR_GROUP_NONE, -1) >= 0);
107 0 : assert_se(sd_device_monitor_start(monitor_server, NULL, NULL) >= 0);
108 0 : assert_se(sd_event_source_set_description(sd_device_monitor_get_event_source(monitor_server), "sender") >= 0);
109 :
110 0 : assert_se(device_monitor_new_full(&monitor_client, MONITOR_GROUP_NONE, -1) >= 0);
111 0 : assert_se(device_monitor_allow_unicast_sender(monitor_client, monitor_server) >= 0);
112 0 : assert_se(sd_device_monitor_filter_add_match_subsystem_devtype(monitor_client, subsystem, NULL) >= 0);
113 0 : assert_se(sd_device_monitor_start(monitor_client, monitor_handler, (void *) syspath) >= 0);
114 0 : assert_se(sd_event_source_set_description(sd_device_monitor_get_event_source(monitor_client), "receiver") >= 0);
115 :
116 0 : assert_se(sd_device_enumerator_new(&e) >= 0);
117 0 : assert_se(sd_device_enumerator_add_match_subsystem(e, subsystem, false) >= 0);
118 0 : FOREACH_DEVICE(e, d) {
119 0 : assert_se(sd_device_get_syspath(d, &p) >= 0);
120 0 : assert_se(sd_device_get_subsystem(d, &s) >= 0);
121 :
122 0 : log_info("Sending device subsystem:%s syspath:%s", s, p);
123 0 : assert_se(device_monitor_send_device(monitor_server, monitor_client, d) >= 0);
124 : }
125 :
126 0 : log_info("Sending device subsystem:%s syspath:%s", subsystem, syspath);
127 0 : assert_se(device_monitor_send_device(monitor_server, monitor_client, device) >= 0);
128 0 : assert_se(sd_event_loop(sd_device_monitor_get_event(monitor_client)) == 100);
129 0 : }
130 :
131 0 : static void test_sd_device_monitor_filter_remove(sd_device *device) {
132 0 : _cleanup_(sd_device_monitor_unrefp) sd_device_monitor *monitor_server = NULL, *monitor_client = NULL;
133 : const char *syspath;
134 :
135 0 : log_device_info(device, "/* %s */", __func__);
136 :
137 0 : assert_se(sd_device_get_syspath(device, &syspath) >= 0);
138 :
139 0 : assert_se(device_monitor_new_full(&monitor_server, MONITOR_GROUP_NONE, -1) >= 0);
140 0 : assert_se(sd_device_monitor_start(monitor_server, NULL, NULL) >= 0);
141 0 : assert_se(sd_event_source_set_description(sd_device_monitor_get_event_source(monitor_server), "sender") >= 0);
142 :
143 0 : assert_se(device_monitor_new_full(&monitor_client, MONITOR_GROUP_NONE, -1) >= 0);
144 0 : assert_se(device_monitor_allow_unicast_sender(monitor_client, monitor_server) >= 0);
145 0 : assert_se(sd_device_monitor_start(monitor_client, monitor_handler, (void *) syspath) >= 0);
146 0 : assert_se(sd_event_source_set_description(sd_device_monitor_get_event_source(monitor_client), "receiver") >= 0);
147 :
148 0 : assert_se(sd_device_monitor_filter_add_match_subsystem_devtype(monitor_client, "hoge", NULL) >= 0);
149 0 : assert_se(sd_device_monitor_filter_update(monitor_client) >= 0);
150 :
151 0 : assert_se(device_monitor_send_device(monitor_server, monitor_client, device) >= 0);
152 0 : assert_se(sd_event_run(sd_device_monitor_get_event(monitor_client), 0) >= 0);
153 :
154 0 : assert_se(sd_device_monitor_filter_remove(monitor_client) >= 0);
155 :
156 0 : assert_se(device_monitor_send_device(monitor_server, monitor_client, device) >= 0);
157 0 : assert_se(sd_event_loop(sd_device_monitor_get_event(monitor_client)) == 100);
158 0 : }
159 :
160 0 : static void test_device_copy_properties(sd_device *device) {
161 0 : _cleanup_(sd_device_unrefp) sd_device *copy = NULL;
162 :
163 0 : assert_se(device_shallow_clone(device, ©) >= 0);
164 0 : assert_se(device_copy_properties(copy, device) >= 0);
165 :
166 0 : test_send_receive_one(copy, false, false, false);
167 0 : }
168 :
169 1 : int main(int argc, char *argv[]) {
170 1 : _cleanup_(sd_device_unrefp) sd_device *loopback = NULL, *sda = NULL;
171 : int r;
172 :
173 1 : test_setup_logging(LOG_INFO);
174 :
175 1 : if (getuid() != 0)
176 1 : return log_tests_skipped("not root");
177 :
178 0 : r = test_receive_device_fail();
179 0 : if (r < 0) {
180 0 : assert_se(r == -EPERM && detect_container() > 0);
181 0 : return log_tests_skipped("Running in container? Skipping remaining tests");
182 : }
183 :
184 0 : assert_se(sd_device_new_from_syspath(&loopback, "/sys/class/net/lo") >= 0);
185 0 : assert_se(device_add_property(loopback, "ACTION", "add") >= 0);
186 0 : assert_se(device_add_property(loopback, "SEQNUM", "10") >= 0);
187 :
188 0 : test_send_receive_one(loopback, false, false, false);
189 0 : test_send_receive_one(loopback, true, false, false);
190 0 : test_send_receive_one(loopback, false, true, false);
191 0 : test_send_receive_one(loopback, true, true, false);
192 0 : test_send_receive_one(loopback, true, false, true);
193 0 : test_send_receive_one(loopback, false, true, true);
194 0 : test_send_receive_one(loopback, true, true, true);
195 :
196 0 : test_subsystem_filter(loopback);
197 0 : test_sd_device_monitor_filter_remove(loopback);
198 0 : test_device_copy_properties(loopback);
199 :
200 0 : r = sd_device_new_from_subsystem_sysname(&sda, "block", "sda");
201 0 : if (r < 0) {
202 0 : log_info_errno(r, "Failed to create sd_device for sda, skipping remaining tests: %m");
203 0 : return 0;
204 : }
205 :
206 0 : assert_se(device_add_property(sda, "ACTION", "change") >= 0);
207 0 : assert_se(device_add_property(sda, "SEQNUM", "11") >= 0);
208 :
209 0 : test_send_receive_one(sda, false, false, false);
210 0 : test_send_receive_one(sda, true, false, false);
211 0 : test_send_receive_one(sda, false, true, false);
212 0 : test_send_receive_one(sda, true, true, false);
213 0 : test_send_receive_one(sda, true, false, true);
214 0 : test_send_receive_one(sda, false, true, true);
215 0 : test_send_receive_one(sda, true, true, true);
216 :
217 0 : return 0;
218 : }
|
