chiark
/
gitweb
/
~ianmdlvl
/
elogind.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
mount: constify MountParameters
[elogind.git]
/
src
/
udev
/
udevd.c
diff --git
a/src/udev/udevd.c
b/src/udev/udevd.c
index 95c646802918ee8da6083069a6881da2f8acfc5c..ab2b4ba61136d1865fb50f0b3425a282dc535615 100644
(file)
--- a/
src/udev/udevd.c
+++ b/
src/udev/udevd.c
@@
-54,12
+54,6
@@
#include "dev-setup.h"
#include "fileio.h"
#include "dev-setup.h"
#include "fileio.h"
-void udev_main_log(struct udev *udev, int priority,
- const char *file, int line, const char *fn,
- const char *format, va_list args) {
- log_metav(priority, file, line, fn, format, args);
-}
-
static struct udev_rules *rules;
static struct udev_ctrl *udev_ctrl;
static struct udev_monitor *monitor;
static struct udev_rules *rules;
static struct udev_ctrl *udev_ctrl;
static struct udev_monitor *monitor;
@@
-81,6
+75,7
@@
static sigset_t sigmask_orig;
static UDEV_LIST(event_list);
static UDEV_LIST(worker_list);
static char *udev_cgroup;
static UDEV_LIST(event_list);
static UDEV_LIST(worker_list);
static char *udev_cgroup;
+static struct udev_list properties_list;
static bool udev_exit;
enum event_state {
static bool udev_exit;
enum event_state {
@@
-225,14
+220,14
@@
static void worker_new(struct event *event) {
sigfillset(&mask);
fd_signal = signalfd(-1, &mask, SFD_NONBLOCK|SFD_CLOEXEC);
if (fd_signal < 0) {
sigfillset(&mask);
fd_signal = signalfd(-1, &mask, SFD_NONBLOCK|SFD_CLOEXEC);
if (fd_signal < 0) {
- log_error
(
"error creating signalfd %m");
+ log_error
_errno(errno,
"error creating signalfd %m");
rc = 2;
goto out;
}
fd_ep = epoll_create1(EPOLL_CLOEXEC);
if (fd_ep < 0) {
rc = 2;
goto out;
}
fd_ep = epoll_create1(EPOLL_CLOEXEC);
if (fd_ep < 0) {
- log_error
(
"error creating epoll fd: %m");
+ log_error
_errno(errno,
"error creating epoll fd: %m");
rc = 3;
goto out;
}
rc = 3;
goto out;
}
@@
-248,7
+243,7
@@
static void worker_new(struct event *event) {
if (epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_signal, &ep_signal) < 0 ||
epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_monitor, &ep_monitor) < 0) {
if (epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_signal, &ep_signal) < 0 ||
epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_monitor, &ep_monitor) < 0) {
- log_error
(
"fail to add fds to epoll: %m");
+ log_error
_errno(errno,
"fail to add fds to epoll: %m");
rc = 4;
goto out;
}
rc = 4;
goto out;
}
@@
-298,7
+293,7
@@
static void worker_new(struct event *event) {
if (d) {
fd_lock = open(udev_device_get_devnode(d), O_RDONLY|O_CLOEXEC|O_NOFOLLOW|O_NONBLOCK);
if (fd_lock >= 0 && flock(fd_lock, LOCK_SH|LOCK_NB) < 0) {
if (d) {
fd_lock = open(udev_device_get_devnode(d), O_RDONLY|O_CLOEXEC|O_NOFOLLOW|O_NONBLOCK);
if (fd_lock >= 0 && flock(fd_lock, LOCK_SH|LOCK_NB) < 0) {
- log_debug
(
"Unable to flock(%s), skipping event handling: %m", udev_device_get_devnode(d));
+ log_debug
_errno(errno,
"Unable to flock(%s), skipping event handling: %m", udev_device_get_devnode(d));
err = -EWOULDBLOCK;
fd_lock = safe_close(fd_lock);
goto skip;
err = -EWOULDBLOCK;
fd_lock = safe_close(fd_lock);
goto skip;
@@
-310,9
+305,15
@@
static void worker_new(struct event *event) {
udev_event->rtnl = rtnl;
/* apply rules, create node, symlinks */
udev_event->rtnl = rtnl;
/* apply rules, create node, symlinks */
- udev_event_execute_rules(udev_event, arg_event_timeout_usec, arg_event_timeout_warn_usec, rules, &sigmask_orig);
+ udev_event_execute_rules(udev_event,
+ arg_event_timeout_usec, arg_event_timeout_warn_usec,
+ &properties_list,
+ rules,
+ &sigmask_orig);
- udev_event_execute_run(udev_event, arg_event_timeout_usec, arg_event_timeout_warn_usec, &sigmask_orig);
+ udev_event_execute_run(udev_event,
+ arg_event_timeout_usec, arg_event_timeout_warn_usec,
+ &sigmask_orig);
/* in case rtnl was initialized */
rtnl = sd_rtnl_ref(udev_event->rtnl);
/* in case rtnl was initialized */
rtnl = sd_rtnl_ref(udev_event->rtnl);
@@
-357,7
+358,7
@@
skip:
if (fdcount < 0) {
if (errno == EINTR)
continue;
if (fdcount < 0) {
if (errno == EINTR)
continue;
- log_error
(
"failed to poll: %m");
+ log_error
_errno(errno,
"failed to poll: %m");
goto out;
}
goto out;
}
@@
-397,7
+398,7
@@
out:
udev_monitor_unref(worker_monitor);
event->state = EVENT_QUEUED;
free(worker);
udev_monitor_unref(worker_monitor);
event->state = EVENT_QUEUED;
free(worker);
- log_error
(
"fork of child failed: %m");
+ log_error
_errno(errno,
"fork of child failed: %m");
break;
default:
/* close monitor, but keep address around */
break;
default:
/* close monitor, but keep address around */
@@
-428,7
+429,7
@@
static void event_run(struct event *event) {
count = udev_monitor_send_device(monitor, worker->monitor, event->dev);
if (count < 0) {
count = udev_monitor_send_device(monitor, worker->monitor, event->dev);
if (count < 0) {
- log_error
(
"worker [%u] did not accept message %zi (%m), kill it", worker->pid, count);
+ log_error
_errno(errno,
"worker [%u] did not accept message %zi (%m), kill it", worker->pid, count);
kill(worker->pid, SIGKILL);
worker->state = WORKER_KILLED;
continue;
kill(worker->pid, SIGKILL);
worker->state = WORKER_KILLED;
continue;
@@
-644,7
+645,6
@@
static struct udev_ctrl_connection *handle_ctrl_msg(struct udev_ctrl *uctrl) {
if (i >= 0) {
log_debug("udevd message (SET_LOG_LEVEL) received, log_priority=%i", i);
log_set_max_level(i);
if (i >= 0) {
log_debug("udevd message (SET_LOG_LEVEL) received, log_priority=%i", i);
log_set_max_level(i);
- udev_set_log_priority(udev, i);
worker_kill(udev);
}
worker_kill(udev);
}
@@
-677,10
+677,10
@@
static struct udev_ctrl_connection *handle_ctrl_msg(struct udev_ctrl *uctrl) {
val = &val[1];
if (val[0] == '\0') {
log_debug("udevd message (ENV) received, unset '%s'", key);
val = &val[1];
if (val[0] == '\0') {
log_debug("udevd message (ENV) received, unset '%s'", key);
- udev_
add_property(udev
, key, NULL);
+ udev_
list_entry_add(&properties_list
, key, NULL);
} else {
log_debug("udevd message (ENV) received, set '%s=%s'", key, val);
} else {
log_debug("udevd message (ENV) received, set '%s=%s'", key, val);
- udev_
add_property(udev
, key, val);
+ udev_
list_entry_add(&properties_list
, key, val);
}
} else {
log_error("wrong key format '%s'", key);
}
} else {
log_error("wrong key format '%s'", key);
@@
-949,7
+949,7
@@
static int systemd_fds(struct udev *udev, int *rctrl, int *rnetlink) {
}
/*
}
/*
- * read the kernel commandline, in case we need to get into debug mode
+ * read the kernel command
line, in case we need to get into debug mode
* udev.log-priority=<level> syslog priority
* udev.children-max=<number of workers> events are fully serialized if set to 1
* udev.exec-delay=<number of seconds> delay execution of every executed program
* udev.log-priority=<level> syslog priority
* udev.children-max=<number of workers> events are fully serialized if set to 1
* udev.exec-delay=<number of seconds> delay execution of every executed program
@@
-961,13
+961,13
@@
static void kernel_cmdline_options(struct udev *udev) {
int r;
r = proc_cmdline(&line);
int r;
r = proc_cmdline(&line);
- if (r < 0)
- log_warning("Failed to read /proc/cmdline, ignoring: %s", strerror(-r));
- if (r <= 0)
+ if (r < 0) {
+ log_warning_errno(r, "Failed to read /proc/cmdline, ignoring: %m");
return;
return;
+ }
FOREACH_WORD_QUOTED(word, l, line, state) {
FOREACH_WORD_QUOTED(word, l, line, state) {
- char *s, *opt;
+ char *s, *opt
, *value
;
s = strndup(word, l);
if (!s)
s = strndup(word, l);
if (!s)
@@
-979,24
+979,23
@@
static void kernel_cmdline_options(struct udev *udev) {
else
opt = s;
else
opt = s;
- if (
startswith(opt, "udev.log-priority="
)) {
+ if (
(value = startswith(opt, "udev.log-priority=")
)) {
int prio;
int prio;
- prio = util_log_priority(
opt + 18
);
+ prio = util_log_priority(
value
);
log_set_max_level(prio);
log_set_max_level(prio);
- udev_set_log_priority(udev, prio);
- } else if (startswith(opt, "udev.children-max=")) {
- r = safe_atoi(opt + 18, &arg_children_max);
+ } else if ((value = startswith(opt, "udev.children-max="))) {
+ r = safe_atoi(value, &arg_children_max);
if (r < 0)
if (r < 0)
- log_warning("Invalid udev.children-max ignored: %s",
opt + 18
);
- } else if (
startswith(opt, "udev.exec-delay="
)) {
- r = safe_atoi(
opt + 16
, &arg_exec_delay);
+ log_warning("Invalid udev.children-max ignored: %s",
value
);
+ } else if (
(value = startswith(opt, "udev.exec-delay=")
)) {
+ r = safe_atoi(
value
, &arg_exec_delay);
if (r < 0)
if (r < 0)
- log_warning("Invalid udev.exec-delay ignored: %s",
opt + 16
);
- } else if (
startswith(opt, "udev.event-timeout="
)) {
- r = safe_atou64(
opt + 16
, &arg_event_timeout_usec);
+ log_warning("Invalid udev.exec-delay ignored: %s",
value
);
+ } else if (
(value = startswith(opt, "udev.event-timeout=")
)) {
+ r = safe_atou64(
value
, &arg_event_timeout_usec);
if (r < 0) {
if (r < 0) {
- log_warning("Invalid udev.event-timeout ignored: %s",
opt + 16
);
+ log_warning("Invalid udev.event-timeout ignored: %s",
value
);
break;
}
arg_event_timeout_usec *= USEC_PER_SEC;
break;
}
arg_event_timeout_usec *= USEC_PER_SEC;
@@
-1060,7
+1059,7
@@
static int parse_argv(int argc, char *argv[]) {
case 't':
r = safe_atou64(optarg, &arg_event_timeout_usec);
if (r < 0)
case 't':
r = safe_atou64(optarg, &arg_event_timeout_usec);
if (r < 0)
- log_warning("Invali
g
--event-timeout ignored: %s", optarg);
+ log_warning("Invali
d
--event-timeout ignored: %s", optarg);
else {
arg_event_timeout_usec *= USEC_PER_SEC;
arg_event_timeout_warn_usec = (arg_event_timeout_usec / 3) ? : 1;
else {
arg_event_timeout_usec *= USEC_PER_SEC;
arg_event_timeout_warn_usec = (arg_event_timeout_usec / 3) ? : 1;
@@
-1120,32
+1119,42
@@
int main(int argc, char *argv[]) {
log_parse_environment();
log_open();
log_parse_environment();
log_open();
- udev_set_log_fn(udev, udev_main_log);
- log_set_max_level(udev_get_log_priority(udev));
-
r = parse_argv(argc, argv);
if (r <= 0)
goto exit;
kernel_cmdline_options(udev);
r = parse_argv(argc, argv);
if (r <= 0)
goto exit;
kernel_cmdline_options(udev);
- if (arg_debug)
{
+ if (arg_debug)
log_set_max_level(LOG_DEBUG);
log_set_max_level(LOG_DEBUG);
- udev_set_log_priority(udev, LOG_DEBUG);
- }
if (getuid() != 0) {
log_error("root privileges required");
goto exit;
}
if (getuid() != 0) {
log_error("root privileges required");
goto exit;
}
- label_init("/dev");
+ r = mac_selinux_init("/dev");
+ if (r < 0) {
+ log_error_errno(r, "could not initialize labelling: %m");
+ goto exit;
+ }
/* set umask before creating any file/directory */
/* set umask before creating any file/directory */
- chdir("/");
+ r = chdir("/");
+ if (r < 0) {
+ log_error_errno(errno, "could not change dir to /: %m");
+ goto exit;
+ }
+
umask(022);
umask(022);
- mkdir("/run/udev", 0755);
+ udev_list_init(udev, &properties_list, true);
+
+ r = mkdir("/run/udev", 0755);
+ if (r < 0 && errno != EEXIST) {
+ log_error_errno(errno, "could not create /run/udev: %m");
+ goto exit;
+ }
dev_setup(NULL);
dev_setup(NULL);
@@
-1202,6
+1211,8
@@
int main(int argc, char *argv[]) {
goto exit;
}
fd_netlink = udev_monitor_get_fd(monitor);
goto exit;
}
fd_netlink = udev_monitor_get_fd(monitor);
+
+ udev_monitor_set_receive_buffer_size(monitor, 128 * 1024 * 1024);
}
if (udev_monitor_enable_receiving(monitor) < 0) {
}
if (udev_monitor_enable_receiving(monitor) < 0) {
@@
-1216,9
+1227,7
@@
int main(int argc, char *argv[]) {
goto exit;
}
goto exit;
}
- udev_monitor_set_receive_buffer_size(monitor, 128 * 1024 * 1024);
-
- log_info("starting version " VERSION "\n");
+ log_info("starting version " VERSION);
udev_builtin_init(udev);
udev_builtin_init(udev);
@@
-1230,7
+1239,7
@@
int main(int argc, char *argv[]) {
rc = udev_rules_apply_static_dev_perms(rules);
if (rc < 0)
rc = udev_rules_apply_static_dev_perms(rules);
if (rc < 0)
- log_error
("failed to apply permissions on static device nodes - %s", strerror(-rc)
);
+ log_error
_errno(rc, "failed to apply permissions on static device nodes - %m"
);
if (arg_daemonize) {
pid_t pid;
if (arg_daemonize) {
pid_t pid;
@@
-1240,7
+1249,7
@@
int main(int argc, char *argv[]) {
case 0:
break;
case -1:
case 0:
break;
case -1:
- log_error
(
"fork of daemon failed: %m");
+ log_error
_errno(errno,
"fork of daemon failed: %m");
rc = 4;
goto exit;
default:
rc = 4;
goto exit;
default:
@@
-1303,7
+1312,7
@@
int main(int argc, char *argv[]) {
fd_ep = epoll_create1(EPOLL_CLOEXEC);
if (fd_ep < 0) {
fd_ep = epoll_create1(EPOLL_CLOEXEC);
if (fd_ep < 0) {
- log_error
(
"error creating epoll fd: %m");
+ log_error
_errno(errno,
"error creating epoll fd: %m");
goto exit;
}
if (epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_ctrl, &ep_ctrl) < 0 ||
goto exit;
}
if (epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_ctrl, &ep_ctrl) < 0 ||
@@
-1311,7
+1320,7
@@
int main(int argc, char *argv[]) {
epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_signal, &ep_signal) < 0 ||
epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_netlink, &ep_netlink) < 0 ||
epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_worker, &ep_worker) < 0) {
epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_signal, &ep_signal) < 0 ||
epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_netlink, &ep_netlink) < 0 ||
epoll_ctl(fd_ep, EPOLL_CTL_ADD, fd_worker, &ep_worker) < 0) {
- log_error
(
"fail to add fds to epoll: %m");
+ log_error
_errno(errno,
"fail to add fds to epoll: %m");
goto exit;
}
goto exit;
}
@@
-1529,7
+1538,8
@@
exit_daemonize:
udev_monitor_unref(monitor);
udev_ctrl_connection_unref(ctrl_conn);
udev_ctrl_unref(udev_ctrl);
udev_monitor_unref(monitor);
udev_ctrl_connection_unref(ctrl_conn);
udev_ctrl_unref(udev_ctrl);
- label_finish();
+ udev_list_cleanup(&properties_list);
+ mac_selinux_finish();
udev_unref(udev);
log_close();
return rc;
udev_unref(udev);
log_close();
return rc;