#include <linux/sockios.h>
#include "udev.h"
-#include "udev-rules.h"
struct udev_event *udev_event_new(struct udev_device *dev)
{
struct udev_event *event;
- event = malloc(sizeof(struct udev_event));
+ event = calloc(1, sizeof(struct udev_event));
if (event == NULL)
return NULL;
- memset(event, 0x00, sizeof(struct udev_event));
-
event->dev = dev;
event->udev = udev_device_get_udev(dev);
udev_list_init(&event->run_list);
event->mode = 0660;
- util_strlcpy(event->owner, "0", sizeof(event->owner));
- util_strlcpy(event->group, "0", sizeof(event->group));
-
dbg(event->udev, "allocated event %p\n", event);
return event;
}
void udev_event_unref(struct udev_event *event)
{
- udev_list_cleanup(event->udev, &event->run_list);
+ if (event == NULL)
+ return;
+ udev_list_cleanup_entries(event->udev, &event->run_list);
+ free(event->tmp_node);
+ free(event->program_result);
+ free(event->name);
dbg(event->udev, "free event %p\n", event);
free(event);
}
-static void kernel_log(struct ifreq ifr)
+/* extract possible {attr} and move str behind it */
+static char *get_format_attribute(struct udev *udev, char **str)
+{
+ char *pos;
+ char *attr = NULL;
+
+ if (*str[0] == '{') {
+ pos = strchr(*str, '}');
+ if (pos == NULL) {
+ err(udev, "missing closing brace for format\n");
+ return NULL;
+ }
+ pos[0] = '\0';
+ attr = *str+1;
+ *str = pos+1;
+ dbg(udev, "attribute='%s', str='%s'\n", attr, *str);
+ }
+ return attr;
+}
+
+/* extract possible format length and move str behind it*/
+static int get_format_len(struct udev *udev, char **str)
+{
+ int num;
+ char *tail;
+
+ if (isdigit(*str[0])) {
+ num = (int) strtoul(*str, &tail, 10);
+ if (num > 0) {
+ *str = tail;
+ dbg(udev, "format length=%i\n", num);
+ return num;
+ } else {
+ err(udev, "format parsing error '%s'\n", *str);
+ }
+ }
+ return -1;
+}
+
+void udev_event_apply_format(struct udev_event *event, char *string, size_t maxsize)
+{
+ struct udev_device *dev = event->dev;
+ char temp[UTIL_PATH_SIZE];
+ char temp2[UTIL_PATH_SIZE];
+ char *head, *tail, *cpos, *attr, *rest;
+ int len;
+ int i;
+ int count;
+ enum subst_type {
+ SUBST_UNKNOWN,
+ SUBST_DEVPATH,
+ SUBST_KERNEL,
+ SUBST_KERNEL_NUMBER,
+ SUBST_ID,
+ SUBST_DRIVER,
+ SUBST_MAJOR,
+ SUBST_MINOR,
+ SUBST_RESULT,
+ SUBST_ATTR,
+ SUBST_PARENT,
+ SUBST_TEMP_NODE,
+ SUBST_NAME,
+ SUBST_LINKS,
+ SUBST_ROOT,
+ SUBST_SYS,
+ SUBST_ENV,
+ };
+ static const struct subst_map {
+ char *name;
+ char fmt;
+ enum subst_type type;
+ } map[] = {
+ { .name = "devpath", .fmt = 'p', .type = SUBST_DEVPATH },
+ { .name = "number", .fmt = 'n', .type = SUBST_KERNEL_NUMBER },
+ { .name = "kernel", .fmt = 'k', .type = SUBST_KERNEL },
+ { .name = "id", .fmt = 'b', .type = SUBST_ID },
+ { .name = "driver", .fmt = 'd', .type = SUBST_DRIVER },
+ { .name = "major", .fmt = 'M', .type = SUBST_MAJOR },
+ { .name = "minor", .fmt = 'm', .type = SUBST_MINOR },
+ { .name = "result", .fmt = 'c', .type = SUBST_RESULT },
+ { .name = "attr", .fmt = 's', .type = SUBST_ATTR },
+ { .name = "sysfs", .fmt = 's', .type = SUBST_ATTR },
+ { .name = "parent", .fmt = 'P', .type = SUBST_PARENT },
+ { .name = "tempnode", .fmt = 'N', .type = SUBST_TEMP_NODE },
+ { .name = "name", .fmt = 'D', .type = SUBST_NAME },
+ { .name = "links", .fmt = 'L', .type = SUBST_LINKS },
+ { .name = "root", .fmt = 'r', .type = SUBST_ROOT },
+ { .name = "sys", .fmt = 'S', .type = SUBST_SYS },
+ { .name = "env", .fmt = 'E', .type = SUBST_ENV },
+ { NULL, '\0', 0 }
+ };
+ enum subst_type type;
+ const struct subst_map *subst;
+
+ head = string;
+ while (1) {
+ len = -1;
+ while (head[0] != '\0') {
+ if (head[0] == '$') {
+ /* substitute named variable */
+ if (head[1] == '\0')
+ break;
+ if (head[1] == '$') {
+ util_strlcpy(temp, head+2, sizeof(temp));
+ util_strlcpy(head+1, temp, maxsize);
+ head++;
+ continue;
+ }
+ head[0] = '\0';
+ for (subst = map; subst->name; subst++) {
+ if (strncasecmp(&head[1], subst->name, strlen(subst->name)) == 0) {
+ type = subst->type;
+ tail = head + strlen(subst->name)+1;
+ dbg(event->udev, "will substitute format name '%s'\n", subst->name);
+ goto found;
+ }
+ }
+ head[0] = '$';
+ err(event->udev, "unknown format variable '%s'\n", head);
+ } else if (head[0] == '%') {
+ /* substitute format char */
+ if (head[1] == '\0')
+ break;
+ if (head[1] == '%') {
+ util_strlcpy(temp, head+2, sizeof(temp));
+ util_strlcpy(head+1, temp, maxsize);
+ head++;
+ continue;
+ }
+ head[0] = '\0';
+ tail = head+1;
+ len = get_format_len(event->udev, &tail);
+ for (subst = map; subst->name; subst++) {
+ if (tail[0] == subst->fmt) {
+ type = subst->type;
+ tail++;
+ dbg(event->udev, "will substitute format char '%c'\n", subst->fmt);
+ goto found;
+ }
+ }
+ head[0] = '%';
+ err(event->udev, "unknown format char '%c'\n", tail[0]);
+ }
+ head++;
+ }
+ break;
+found:
+ attr = get_format_attribute(event->udev, &tail);
+ util_strlcpy(temp, tail, sizeof(temp));
+ dbg(event->udev, "format=%i, string='%s', tail='%s'\n", type ,string, tail);
+
+ switch (type) {
+ case SUBST_DEVPATH:
+ util_strlcat(string, udev_device_get_devpath(dev), maxsize);
+ dbg(event->udev, "substitute devpath '%s'\n", udev_device_get_devpath(dev));
+ break;
+ case SUBST_KERNEL:
+ util_strlcat(string, udev_device_get_sysname(dev), maxsize);
+ dbg(event->udev, "substitute kernel name '%s'\n", udev_device_get_sysname(dev));
+ break;
+ case SUBST_KERNEL_NUMBER:
+ if (udev_device_get_sysnum(dev) == NULL)
+ break;
+ util_strlcat(string, udev_device_get_sysnum(dev), maxsize);
+ dbg(event->udev, "substitute kernel number '%s'\n", udev_device_get_sysnum(dev));
+ break;
+ case SUBST_ID:
+ if (event->dev_parent != NULL) {
+ util_strlcat(string, udev_device_get_sysname(event->dev_parent), maxsize);
+ dbg(event->udev, "substitute id '%s'\n", udev_device_get_sysname(event->dev_parent));
+ }
+ break;
+ case SUBST_DRIVER:
+ if (event->dev_parent != NULL) {
+ const char *driver = udev_device_get_driver(event->dev_parent);
+
+ if (driver == NULL)
+ break;
+ util_strlcat(string, driver, maxsize);
+ dbg(event->udev, "substitute driver '%s'\n", driver);
+ }
+ break;
+ case SUBST_MAJOR:
+ sprintf(temp2, "%d", major(udev_device_get_devnum(dev)));
+ util_strlcat(string, temp2, maxsize);
+ dbg(event->udev, "substitute major number '%s'\n", temp2);
+ break;
+ case SUBST_MINOR:
+ sprintf(temp2, "%d", minor(udev_device_get_devnum(dev)));
+ util_strlcat(string, temp2, maxsize);
+ dbg(event->udev, "substitute minor number '%s'\n", temp2);
+ break;
+ case SUBST_RESULT:
+ if (event->program_result == NULL)
+ break;
+ /* get part part of the result string */
+ i = 0;
+ if (attr != NULL)
+ i = strtoul(attr, &rest, 10);
+ if (i > 0) {
+ char result[UTIL_PATH_SIZE];
+
+ dbg(event->udev, "request part #%d of result string\n", i);
+ util_strlcpy(result, event->program_result, sizeof(result));
+ cpos = result;
+ while (--i) {
+ while (cpos[0] != '\0' && !isspace(cpos[0]))
+ cpos++;
+ while (isspace(cpos[0]))
+ cpos++;
+ }
+ if (i > 0) {
+ err(event->udev, "requested part of result string not found\n");
+ break;
+ }
+ util_strlcpy(temp2, cpos, sizeof(temp2));
+ /* %{2+}c copies the whole string from the second part on */
+ if (rest[0] != '+') {
+ cpos = strchr(temp2, ' ');
+ if (cpos)
+ cpos[0] = '\0';
+ }
+ util_strlcat(string, temp2, maxsize);
+ dbg(event->udev, "substitute part of result string '%s'\n", temp2);
+ } else {
+ util_strlcat(string, event->program_result, maxsize);
+ dbg(event->udev, "substitute result string '%s'\n", event->program_result);
+ }
+ break;
+ case SUBST_ATTR:
+ if (attr == NULL)
+ err(event->udev, "missing file parameter for attr\n");
+ else {
+ const char *val;
+ char value[UTIL_NAME_SIZE] = "";
+ size_t size;
+
+ util_resolve_subsys_kernel(event->udev, attr, value, sizeof(value), 1);
+
+ val = udev_device_get_sysattr_value(event->dev, attr);
+ if (val != NULL)
+ util_strlcpy(value, val, sizeof(value));
+
+ /* try the current device, other matches may have selected */
+ if (value[0] == '\0' && event->dev_parent != NULL && event->dev_parent != event->dev) {
+ val = udev_device_get_sysattr_value(event->dev_parent, attr);
+ if (val != NULL)
+ util_strlcpy(value, val, sizeof(value));
+ }
+
+ if (value[0]=='\0')
+ break;
+
+ /* strip trailing whitespace, and replace unwanted characters */
+ size = strlen(value);
+ while (size > 0 && isspace(value[--size]))
+ value[size] = '\0';
+ count = util_replace_chars(value, ALLOWED_CHARS_INPUT);
+ if (count > 0)
+ info(event->udev, "%i character(s) replaced\n" , count);
+ util_strlcat(string, value, maxsize);
+ dbg(event->udev, "substitute sysfs value '%s'\n", value);
+ }
+ break;
+ case SUBST_PARENT:
+ {
+ struct udev_device *dev_parent;
+ const char *devnode;
+
+ dev_parent = udev_device_get_parent(event->dev);
+ if (dev_parent == NULL)
+ break;
+ devnode = udev_device_get_devnode(dev_parent);
+ if (devnode != NULL) {
+ size_t devlen = strlen(udev_get_dev_path(event->udev))+1;
+
+ util_strlcat(string, &devnode[devlen], maxsize);
+ dbg(event->udev, "found parent '%s', got node name '%s'\n",
+ udev_device_get_syspath(dev_parent), &devnode[devlen]);
+ }
+ }
+ break;
+ case SUBST_TEMP_NODE:
+ {
+ dev_t devnum;
+ struct stat statbuf;
+ char filename[UTIL_PATH_SIZE];
+ const char *devtype;
+
+ if (event->tmp_node != NULL) {
+ util_strlcat(string, event->tmp_node, maxsize);
+ dbg(event->udev, "return existing temporary node\n");
+ break;
+ }
+ devnum = udev_device_get_devnum(dev);
+ if (major(udev_device_get_devnum(dev) == 0))
+ break;
+ if (strcmp(udev_device_get_subsystem(dev), "block") == 0)
+ devtype = "block";
+ else
+ devtype = "char";
+ snprintf(filename, sizeof(filename), "%s/%s/%u:%u",
+ udev_get_dev_path(event->udev), devtype,
+ major(udev_device_get_devnum(dev)),
+ minor(udev_device_get_devnum(dev)));
+ if (stat(filename, &statbuf) == 0 && statbuf.st_rdev == devnum) {
+ util_strlcat(string, filename, maxsize);
+ dbg(event->udev, "return existing temporary node\n");
+ break;
+ }
+ dbg(event->udev, "create temporary node\n");
+ asprintf(&event->tmp_node, "%s/.tmp-%s-%u:%u",
+ udev_get_dev_path(event->udev), devtype,
+ major(udev_device_get_devnum(dev)),
+ minor(udev_device_get_devnum(dev)));
+ if (event->tmp_node == NULL)
+ break;
+ udev_node_mknod(dev, event->tmp_node, makedev(0, 0), 0600, 0, 0);
+ util_strlcat(string, event->tmp_node, maxsize);
+ }
+ break;
+ case SUBST_NAME:
+ if (event->name != NULL) {
+ util_strlcat(string, event->name, maxsize);
+ dbg(event->udev, "substitute name '%s'\n", event->name);
+ } else {
+ util_strlcat(string, udev_device_get_sysname(dev), maxsize);
+ dbg(event->udev, "substitute sysname '%s'\n", udev_device_get_sysname(dev));
+ }
+ break;
+ case SUBST_LINKS:
+ {
+ struct udev_list_entry *list_entry;
+
+ list_entry = udev_device_get_properties_list_entry(dev);
+ util_strlcpy(string, udev_list_entry_get_name(list_entry), maxsize);
+ udev_list_entry_foreach(list_entry, udev_list_entry_get_next(list_entry)) {
+ util_strlcat(string, " ", maxsize);
+ util_strlcat(string, udev_list_entry_get_name(list_entry), maxsize);
+ }
+ }
+ break;
+ case SUBST_ROOT:
+ util_strlcat(string, udev_get_dev_path(event->udev), maxsize);
+ dbg(event->udev, "substitute udev_root '%s'\n", udev_get_dev_path(event->udev));
+ break;
+ case SUBST_SYS:
+ util_strlcat(string, udev_get_sys_path(event->udev), maxsize);
+ dbg(event->udev, "substitute sys_path '%s'\n", udev_get_sys_path(event->udev));
+ break;
+ case SUBST_ENV:
+ if (attr == NULL) {
+ dbg(event->udev, "missing attribute\n");
+ break;
+ } else {
+ struct udev_list_entry *list_entry;
+ const char *value;
+
+ list_entry = udev_device_get_properties_list_entry(event->dev);
+ list_entry = udev_list_entry_get_by_name(list_entry, attr);
+ if (list_entry == NULL)
+ break;
+ value = udev_list_entry_get_value(list_entry);
+ dbg(event->udev, "substitute env '%s=%s'\n", attr, value);
+ util_strlcat(string, value, maxsize);
+ break;
+ }
+ default:
+ err(event->udev, "unknown substitution type=%i\n", type);
+ break;
+ }
+ /* possibly truncate to format-char specified length */
+ if (len >= 0 && len < (int)strlen(head)) {
+ head[len] = '\0';
+ dbg(event->udev, "truncate to %i chars, subtitution string becomes '%s'\n", len, head);
+ }
+ util_strlcat(string, temp, maxsize);
+ }
+}
+
+static void rename_netif_kernel_log(struct ifreq ifr)
{
int klog;
FILE *f;
util_strlcpy(ifr.ifr_newname, event->name, IFNAMSIZ);
err = ioctl(sk, SIOCSIFNAME, &ifr);
if (err == 0)
- kernel_log(ifr);
+ rename_netif_kernel_log(ifr);
else {
int loop;
while (loop--) {
err = ioctl(sk, SIOCSIFNAME, &ifr);
if (err == 0) {
- kernel_log(ifr);
+ rename_netif_kernel_log(ifr);
break;
}
usleep(1000 * 1000 / 20);
}
}
-
exit:
close(sk);
return err;
}
-int udev_event_run(struct udev_event *event, struct udev_rules *rules)
+int udev_event_execute_rules(struct udev_event *event, struct udev_rules *rules)
{
struct udev_device *dev = event->dev;
int err = 0;
dbg(event->udev, "device node add '%s'\n", udev_device_get_devpath(dev));
- udev_rules_get_name(rules, event);
+ udev_rules_apply_to_event(rules, event);
+ if (event->tmp_node != NULL) {
+ dbg(event->udev, "removing temporary device node\n");
+ util_unlink_secure(event->udev, event->tmp_node);
+ free(event->tmp_node);
+ event->tmp_node = NULL;
+ }
+
if (event->ignore_device) {
info(event->udev, "device event will be ignored\n");
goto exit;
}
- if (event->name[0] == '\0') {
+ if (event->name != NULL && event->name[0] == '\0') {
info(event->udev, "device node creation supressed\n");
goto exit;
}
+ if (event->name == NULL) {
+ info(event->udev, "no node name set, will use kernel name '%s'\n",
+ udev_device_get_sysname(event->dev));
+ event->name = strdup(udev_device_get_sysname(event->dev));
+ if (event->name == NULL)
+ goto exit;
+ }
+
/* set device node name */
util_strlcpy(filename, udev_get_dev_path(event->udev), sizeof(filename));
util_strlcat(filename, "/", sizeof(filename));
/* read current database entry; cleanup, if it is known device */
dev_old = udev_device_new_from_syspath(event->udev, udev_device_get_syspath(dev));
if (dev_old != NULL) {
- info(event->udev, "device '%s' already in database, updating\n",
- udev_device_get_devpath(dev));
- udev_node_update_old_links(dev, dev_old, event->test);
+ if (udev_device_get_devnode(dev_old) != NULL) {
+ info(event->udev, "device node '%s' already in database, updating\n",
+ udev_device_get_devnode(dev_old));
+ udev_node_update_old_links(dev, dev_old, event->test);
+ }
udev_device_unref(dev_old);
}
udev_device_update_db(dev);
- err = udev_node_add(dev, event->mode, event->owner, event->group, event->test);
+ err = udev_node_add(dev, event->mode, event->uid, event->gid, event->test);
if (err != 0)
goto exit;
if (strcmp(udev_device_get_subsystem(dev), "net") == 0 && strcmp(udev_device_get_action(dev), "add") == 0) {
dbg(event->udev, "netif add '%s'\n", udev_device_get_devpath(dev));
- udev_rules_get_name(rules, event);
+ udev_rules_apply_to_event(rules, event);
if (event->ignore_device) {
info(event->udev, "device event will be ignored\n");
goto exit;
}
- if (event->name[0] == '\0') {
- info(event->udev, "device renaming supressed\n");
+ if (event->name == NULL)
goto exit;
- }
/* look if we want to change the name of the netif */
if (strcmp(event->name, udev_device_get_sysname(dev)) != 0) {
udev_device_set_devnode(dev, devnode);
}
- udev_rules_get_run(rules, event);
+ udev_rules_apply_to_event(rules, event);
if (event->ignore_device) {
info(event->udev, "device event will be ignored\n");
goto exit;
}
/* default devices */
- udev_rules_get_run(rules, event);
+ udev_rules_apply_to_event(rules, event);
if (event->ignore_device)
info(event->udev, "device event will be ignored\n");
exit:
return err;
}
+
+int udev_event_execute_run(struct udev_event *event)
+{
+ struct udev_list_entry *list_entry;
+ int err = 0;
+
+ dbg(event->udev, "executing run list\n");
+ udev_list_entry_foreach(list_entry, udev_list_get_entry(&event->run_list)) {
+ const char *cmd = udev_list_entry_get_name(list_entry);
+
+ if (strncmp(cmd, "socket:", strlen("socket:")) == 0) {
+ struct udev_monitor *monitor;
+
+ monitor = udev_monitor_new_from_socket(event->udev, &cmd[strlen("socket:")]);
+ if (monitor == NULL)
+ continue;
+ udev_monitor_send_device(monitor, event->dev);
+ udev_monitor_unref(monitor);
+ } else {
+ char program[UTIL_PATH_SIZE];
+ char **envp;
+
+ util_strlcpy(program, cmd, sizeof(program));
+ udev_event_apply_format(event, program, sizeof(program));
+ envp = udev_device_get_properties_envp(event->dev);
+ if (util_run_program(event->udev, program, envp, NULL, 0, NULL) != 0) {
+ if (!udev_list_entry_get_flag(list_entry))
+ err = -1;
+ }
+ }
+ }
+ return err;
+}
~ianmdlvl / elogind.git / blobdiff