summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorYu Watanabe <watanabe.yu+github@gmail.com>2022-03-13 13:22:57 +0100
committerLennart Poettering <lennart@poettering.net>2022-03-24 16:19:36 +0100
commit4029328014be9350ca9fc0774ad936c8b5e50ff2 (patch)
tree3bad3cc36cb49cb4d315f32033c48adf4b81e8b2
parentudev: use sd_event_source_disable_unref() (diff)
downloadsystemd-4029328014be9350ca9fc0774ad936c8b5e50ff2.tar.xz
systemd-4029328014be9350ca9fc0774ad936c8b5e50ff2.zip
udev: remove /run/udev/queue in on_post()
When the last queued event is processed, information about subsequent events may be already queued in the netlink socket of sd-device-monitor. In that case, previously we once removed /run/udev/queue and touch the file soon later, and `udevadm settle` mistakenly considered all events are processed. To mitigate such situation, this makes /run/udev/queue removed in on_post().
-rw-r--r--src/udev/udevd.c14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/udev/udevd.c b/src/udev/udevd.c
index 6bb9eeb4bb..8389c39f65 100644
--- a/src/udev/udevd.c
+++ b/src/udev/udevd.c
@@ -171,12 +171,6 @@ static Event *event_free(Event *event) {
if (event->worker)
event->worker->event = NULL;
- /* only clean up the queue from the process that created it */
- if (LIST_IS_EMPTY(event->manager->events) &&
- event->manager->pid == getpid_cached())
- if (unlink("/run/udev/queue") < 0 && errno != ENOENT)
- log_warning_errno(errno, "Failed to unlink /run/udev/queue, ignoring: %m");
-
return mfree(event);
}
@@ -1480,7 +1474,13 @@ static int on_post(sd_event_source *s, void *userdata) {
if (!LIST_IS_EMPTY(manager->events))
return 1;
- /* There are no pending events. Let's cleanup idle process. */
+ /* There are no queued events. Let's remove /run/udev/queue and clean up the idle processes. */
+
+ if (unlink("/run/udev/queue") < 0) {
+ if (errno != ENOENT)
+ log_warning_errno(errno, "Failed to unlink /run/udev/queue, ignoring: %m");
+ } else
+ log_debug("No events are queued, removing /run/udev/queue.");
if (!hashmap_isempty(manager->workers)) {
/* There are idle workers */