chiark / gitweb /
kdbus: update kdbus.h from upstream
[elogind.git] / src / libudev / libudev-queue.c
1 /***
2   This file is part of systemd.
3
4   Copyright 2008-2012 Kay Sievers <kay@vrfy.org>
5   Copyright 2009 Alan Jenkins <alan-jenkins@tuffmail.co.uk>
6
7   systemd is free software; you can redistribute it and/or modify it
8   under the terms of the GNU Lesser General Public License as published by
9   the Free Software Foundation; either version 2.1 of the License, or
10   (at your option) any later version.
11
12   systemd is distributed in the hope that it will be useful, but
13   WITHOUT ANY WARRANTY; without even the implied warranty of
14   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15   Lesser General Public License for more details.
16
17   You should have received a copy of the GNU Lesser General Public License
18   along with systemd; If not, see <http://www.gnu.org/licenses/>.
19 ***/
20
21 #include <stdio.h>
22 #include <stdlib.h>
23 #include <stddef.h>
24 #include <unistd.h>
25 #include <errno.h>
26 #include <string.h>
27 #include <dirent.h>
28 #include <fcntl.h>
29 #include <limits.h>
30 #include <sys/stat.h>
31
32 #include "libudev.h"
33 #include "libudev-private.h"
34
35 /**
36  * SECTION:libudev-queue
37  * @short_description: access to currently active events
38  *
39  * The udev daemon processes events asynchronously. All events which do not have
40  * interdependencies run in parallel. This exports the current state of the
41  * event processing queue, and the current event sequence numbers from the kernel
42  * and the udev daemon.
43  */
44
45 /**
46  * udev_queue:
47  *
48  * Opaque object representing the current event queue in the udev daemon.
49  */
50 struct udev_queue {
51         struct udev *udev;
52         int refcount;
53         struct udev_list queue_list;
54 };
55
56 /**
57  * udev_queue_new:
58  * @udev: udev library context
59  *
60  * The initial refcount is 1, and needs to be decremented to
61  * release the resources of the udev queue context.
62  *
63  * Returns: the udev queue context, or #NULL on error.
64  **/
65 _public_ struct udev_queue *udev_queue_new(struct udev *udev)
66 {
67         struct udev_queue *udev_queue;
68
69         if (udev == NULL)
70                 return NULL;
71
72         udev_queue = calloc(1, sizeof(struct udev_queue));
73         if (udev_queue == NULL)
74                 return NULL;
75         udev_queue->refcount = 1;
76         udev_queue->udev = udev;
77         udev_list_init(udev, &udev_queue->queue_list, false);
78         return udev_queue;
79 }
80
81 /**
82  * udev_queue_ref:
83  * @udev_queue: udev queue context
84  *
85  * Take a reference of a udev queue context.
86  *
87  * Returns: the same udev queue context.
88  **/
89 _public_ struct udev_queue *udev_queue_ref(struct udev_queue *udev_queue)
90 {
91         if (udev_queue == NULL)
92                 return NULL;
93         udev_queue->refcount++;
94         return udev_queue;
95 }
96
97 /**
98  * udev_queue_unref:
99  * @udev_queue: udev queue context
100  *
101  * Drop a reference of a udev queue context. If the refcount reaches zero,
102  * the resources of the queue context will be released.
103  *
104  * Returns: the passed queue context if it has still an active reference, or #NULL otherwise.
105  **/
106 _public_ struct udev_queue *udev_queue_unref(struct udev_queue *udev_queue)
107 {
108         if (udev_queue == NULL)
109                 return NULL;
110         udev_queue->refcount--;
111         if (udev_queue->refcount > 0)
112                 return udev_queue;
113         udev_list_cleanup(&udev_queue->queue_list);
114         free(udev_queue);
115         return NULL;
116 }
117
118 /**
119  * udev_queue_get_udev:
120  * @udev_queue: udev queue context
121  *
122  * Retrieve the udev library context the queue context was created with.
123  *
124  * Returns: the udev library context.
125  **/
126 _public_ struct udev *udev_queue_get_udev(struct udev_queue *udev_queue)
127 {
128         if (udev_queue == NULL)
129                 return NULL;
130         return udev_queue->udev;
131 }
132
133 unsigned long long int udev_get_kernel_seqnum(struct udev *udev)
134 {
135         unsigned long long int seqnum;
136         int fd;
137         char buf[32];
138         ssize_t len;
139
140         fd = open("/sys/kernel/uevent_seqnum", O_RDONLY|O_CLOEXEC);
141         if (fd < 0)
142                 return 0;
143         len = read(fd, buf, sizeof(buf));
144         close(fd);
145         if (len <= 2)
146                 return 0;
147         buf[len-1] = '\0';
148         seqnum = strtoull(buf, NULL, 10);
149         return seqnum;
150 }
151
152 /**
153  * udev_queue_get_kernel_seqnum:
154  * @udev_queue: udev queue context
155  *
156  * Get the current kernel event sequence number.
157  *
158  * Returns: the sequence number.
159  **/
160 _public_ unsigned long long int udev_queue_get_kernel_seqnum(struct udev_queue *udev_queue)
161 {
162         unsigned long long int seqnum;
163
164         if (udev_queue == NULL)
165                 return -EINVAL;
166
167         seqnum = udev_get_kernel_seqnum(udev_queue->udev);
168         return seqnum;
169 }
170
171 int udev_queue_read_seqnum(FILE *queue_file, unsigned long long int *seqnum)
172 {
173         if (fread(seqnum, sizeof(unsigned long long int), 1, queue_file) != 1)
174                 return -1;
175
176         return 0;
177 }
178
179 ssize_t udev_queue_skip_devpath(FILE *queue_file)
180 {
181         unsigned short int len;
182
183         if (fread(&len, sizeof(unsigned short int), 1, queue_file) == 1) {
184                 char *devpath = alloca(len);
185
186                 /* use fread to skip, fseek might drop buffered data */
187                 if (fread(devpath, 1, len, queue_file) == len)
188                         return len;
189         }
190
191         return -1;
192 }
193
194 ssize_t udev_queue_read_devpath(FILE *queue_file, char *devpath, size_t size)
195 {
196         unsigned short int read_bytes = 0;
197         unsigned short int len;
198
199         if (fread(&len, sizeof(unsigned short int), 1, queue_file) != 1)
200                 return -1;
201
202         read_bytes = (len < size - 1) ? len : size - 1;
203         if (fread(devpath, 1, read_bytes, queue_file) != read_bytes)
204                 return -1;
205         devpath[read_bytes] = '\0';
206
207         /* if devpath was too long, skip unread characters */
208         if (read_bytes != len) {
209                 unsigned short int skip_bytes = len - read_bytes;
210                 char *buf = alloca(skip_bytes);
211
212                 if (fread(buf, 1, skip_bytes, queue_file) != skip_bytes)
213                         return -1;
214         }
215
216         return read_bytes;
217 }
218
219 static FILE *open_queue_file(struct udev_queue *udev_queue, unsigned long long int *seqnum_start)
220 {
221         FILE *queue_file;
222
223         queue_file = fopen("/run/udev/queue.bin", "re");
224         if (queue_file == NULL)
225                 return NULL;
226
227         if (udev_queue_read_seqnum(queue_file, seqnum_start) < 0) {
228                 udev_err(udev_queue->udev, "corrupt queue file\n");
229                 fclose(queue_file);
230                 return NULL;
231         }
232
233         return queue_file;
234 }
235
236 /**
237  * udev_queue_get_udev_seqnum:
238  * @udev_queue: udev queue context
239  *
240  * Get the last known udev event sequence number.
241  *
242  * Returns: the sequence number.
243  **/
244 _public_ unsigned long long int udev_queue_get_udev_seqnum(struct udev_queue *udev_queue)
245 {
246         unsigned long long int seqnum_udev;
247         FILE *queue_file;
248
249         queue_file = open_queue_file(udev_queue, &seqnum_udev);
250         if (queue_file == NULL)
251                 return 0;
252
253         for (;;) {
254                 unsigned long long int seqnum;
255                 ssize_t devpath_len;
256
257                 if (udev_queue_read_seqnum(queue_file, &seqnum) < 0)
258                         break;
259                 devpath_len = udev_queue_skip_devpath(queue_file);
260                 if (devpath_len < 0)
261                         break;
262                 if (devpath_len > 0)
263                         seqnum_udev = seqnum;
264         }
265
266         fclose(queue_file);
267         return seqnum_udev;
268 }
269
270 /**
271  * udev_queue_get_udev_is_active:
272  * @udev_queue: udev queue context
273  *
274  * Check if udev is active on the system.
275  *
276  * Returns: a flag indicating if udev is active.
277  **/
278 _public_ int udev_queue_get_udev_is_active(struct udev_queue *udev_queue)
279 {
280         unsigned long long int seqnum_start;
281         FILE *queue_file;
282
283         queue_file = open_queue_file(udev_queue, &seqnum_start);
284         if (queue_file == NULL)
285                 return 0;
286
287         fclose(queue_file);
288         return 1;
289 }
290
291 /**
292  * udev_queue_get_queue_is_empty:
293  * @udev_queue: udev queue context
294  *
295  * Check if udev is currently processing any events.
296  *
297  * Returns: a flag indicating if udev is currently handling events.
298  **/
299 _public_ int udev_queue_get_queue_is_empty(struct udev_queue *udev_queue)
300 {
301         unsigned long long int seqnum_kernel;
302         unsigned long long int seqnum_udev = 0;
303         int queued = 0;
304         int is_empty = 0;
305         FILE *queue_file;
306
307         if (udev_queue == NULL)
308                 return -EINVAL;
309         queue_file = open_queue_file(udev_queue, &seqnum_udev);
310         if (queue_file == NULL)
311                 return 1;
312
313         for (;;) {
314                 unsigned long long int seqnum;
315                 ssize_t devpath_len;
316
317                 if (udev_queue_read_seqnum(queue_file, &seqnum) < 0)
318                         break;
319                 devpath_len = udev_queue_skip_devpath(queue_file);
320                 if (devpath_len < 0)
321                         break;
322
323                 if (devpath_len > 0) {
324                         queued++;
325                         seqnum_udev = seqnum;
326                 } else {
327                         queued--;
328                 }
329         }
330
331         if (queued > 0)
332                 goto out;
333
334         seqnum_kernel = udev_queue_get_kernel_seqnum(udev_queue);
335         if (seqnum_udev < seqnum_kernel)
336                 goto out;
337
338         is_empty = 1;
339
340 out:
341         fclose(queue_file);
342         return is_empty;
343 }
344
345 /**
346  * udev_queue_get_seqnum_sequence_is_finished:
347  * @udev_queue: udev queue context
348  * @start: first event sequence number
349  * @end: last event sequence number
350  *
351  * Check if udev is currently processing any events in a given sequence number range.
352  *
353  * Returns: a flag indicating if any of the sequence numbers in the given range is currently active.
354  **/
355 _public_ int udev_queue_get_seqnum_sequence_is_finished(struct udev_queue *udev_queue,
356                                                unsigned long long int start, unsigned long long int end)
357 {
358         unsigned long long int seqnum;
359         ssize_t devpath_len;
360         int unfinished;
361         FILE *queue_file;
362
363         if (udev_queue == NULL)
364                 return -EINVAL;
365         queue_file = open_queue_file(udev_queue, &seqnum);
366         if (queue_file == NULL)
367                 return 1;
368         if (start < seqnum)
369                 start = seqnum;
370         if (start > end) {
371                 fclose(queue_file);
372                 return 1;
373         }
374         if (end - start > INT_MAX - 1) {
375                 fclose(queue_file);
376                 return -EOVERFLOW;
377         }
378
379         /*
380          * we might start with 0, and handle the initial seqnum
381          * only when we find an entry in the queue file
382          **/
383         unfinished = end - start;
384
385         do {
386                 if (udev_queue_read_seqnum(queue_file, &seqnum) < 0)
387                         break;
388                 devpath_len = udev_queue_skip_devpath(queue_file);
389                 if (devpath_len < 0)
390                         break;
391
392                 /*
393                  * we might start with an empty or re-build queue file, where
394                  * the initial seqnum is not recorded as finished
395                  */
396                 if (start == seqnum && devpath_len > 0)
397                         unfinished++;
398
399                 if (devpath_len == 0) {
400                         if (seqnum >= start && seqnum <= end)
401                                 unfinished--;
402                 }
403         } while (unfinished > 0);
404
405         fclose(queue_file);
406
407         return (unfinished == 0);
408 }
409
410 /**
411  * udev_queue_get_seqnum_is_finished:
412  * @udev_queue: udev queue context
413  * @seqnum: sequence number
414  *
415  * Check if udev is currently processing a given sequence number.
416  *
417  * Returns: a flag indicating if the given sequence number is currently active.
418  **/
419 _public_ int udev_queue_get_seqnum_is_finished(struct udev_queue *udev_queue, unsigned long long int seqnum)
420 {
421         if (!udev_queue_get_seqnum_sequence_is_finished(udev_queue, seqnum, seqnum))
422                 return 0;
423
424         return 1;
425 }
426
427 /**
428  * udev_queue_get_queued_list_entry:
429  * @udev_queue: udev queue context
430  *
431  * Get the first entry of the list of queued events.
432  *
433  * Returns: a udev_list_entry.
434  **/
435 _public_ struct udev_list_entry *udev_queue_get_queued_list_entry(struct udev_queue *udev_queue)
436 {
437         unsigned long long int seqnum;
438         FILE *queue_file;
439
440         if (udev_queue == NULL)
441                 return NULL;
442         udev_list_cleanup(&udev_queue->queue_list);
443
444         queue_file = open_queue_file(udev_queue, &seqnum);
445         if (queue_file == NULL)
446                 return NULL;
447
448         for (;;) {
449                 char syspath[UTIL_PATH_SIZE];
450                 char *s;
451                 size_t l;
452                 ssize_t len;
453                 char seqnum_str[32];
454                 struct udev_list_entry *list_entry;
455
456                 if (udev_queue_read_seqnum(queue_file, &seqnum) < 0)
457                         break;
458                 snprintf(seqnum_str, sizeof(seqnum_str), "%llu", seqnum);
459
460                 s = syspath;
461                 l = strpcpy(&s, sizeof(syspath), "/sys");
462                 len = udev_queue_read_devpath(queue_file, s, l);
463                 if (len < 0)
464                         break;
465
466                 if (len > 0) {
467                         udev_list_entry_add(&udev_queue->queue_list, syspath, seqnum_str);
468                 } else {
469                         udev_list_entry_foreach(list_entry, udev_list_get_entry(&udev_queue->queue_list)) {
470                                 if (streq(seqnum_str, udev_list_entry_get_value(list_entry))) {
471                                         udev_list_entry_delete(list_entry);
472                                         break;
473                                 }
474                         }
475                 }
476         }
477         fclose(queue_file);
478
479         return udev_list_get_entry(&udev_queue->queue_list);
480 }