#include <stddef.h>

#include <limits.h>

#include <stdlib.h>

#include <stdbool.h>

#include <string.h>

#include <stdio.h>

#include <fcntl.h>

#include <ctype.h>

#include <unistd.h>

#include <errno.h>

#include <dirent.h>

#include <fnmatch.h>

#include <time.h>

#include "udev.h"

#include "path-util.h"

#include "conf-files.h"

#include "strbuf.h"

#include "strv.h"

#include "util.h"

#define PREALLOC_TOKEN 2048

struct uid_gid {

unsigned int name_off;

union {

uid_t uid;

gid_t gid;

};

};

static const char* const rules_dirs[] = {

"/etc/udev/rules.d",

"/run/udev/rules.d",

UDEVLIBEXECDIR "/rules.d",

NULL};

struct udev_rules {

struct udev *udev;

usec_t dirs_ts_usec;

int resolve_names;

/* every key in the rules file becomes a token */

struct token *tokens;

unsigned int token_cur;

unsigned int token_max;

/* all key strings are copied and de-duplicated in a single continuous string buffer */

struct strbuf *strbuf;

/* during rule parsing, uid/gid lookup results are cached */

struct uid_gid *uids;

unsigned int uids_cur;

unsigned int uids_max;

struct uid_gid *gids;

unsigned int gids_cur;

unsigned int gids_max;

};

static char *rules_str(struct udev_rules *rules, unsigned int off) {

return rules->strbuf->buf + off;

}

static unsigned int rules_add_string(struct udev_rules *rules, const char *s) {

return strbuf_add_string(rules->strbuf, s, strlen(s));

}

enum operation_type {

OP_UNSET,

OP_MATCH,

OP_NOMATCH,

OP_MATCH_MAX,

OP_ADD,

OP_ASSIGN,

OP_ASSIGN_FINAL,

};

enum string_glob_type {

GL_UNSET,

GL_PLAIN, /* no special chars */

GL_GLOB, /* shell globs ?,*,[] */

GL_SPLIT, /* multi-value A|B */

GL_SPLIT_GLOB, /* multi-value with glob A*|B* */

GL_SOMETHING, /* commonly used "?*" */

};

enum string_subst_type {

SB_UNSET,

SB_NONE,

SB_FORMAT,

SB_SUBSYS,

};

enum token_type {

TK_UNSET,

TK_RULE,

TK_M_ACTION, /* val */

TK_M_DEVPATH, /* val */

TK_M_KERNEL, /* val */

TK_M_DEVLINK, /* val */

TK_M_NAME, /* val */

TK_M_ENV, /* val, attr */

TK_M_TAG, /* val */

TK_M_SUBSYSTEM, /* val */

TK_M_DRIVER, /* val */

TK_M_WAITFOR, /* val */

TK_M_ATTR, /* val, attr */

TK_M_PARENTS_MIN,

TK_M_KERNELS, /* val */

TK_M_SUBSYSTEMS, /* val */

TK_M_DRIVERS, /* val */

TK_M_ATTRS, /* val, attr */

TK_M_TAGS, /* val */

TK_M_PARENTS_MAX,

TK_M_TEST, /* val, mode_t */

TK_M_PROGRAM, /* val */

TK_M_IMPORT_FILE, /* val */

TK_M_IMPORT_PROG, /* val */

TK_M_IMPORT_BUILTIN, /* val */

TK_M_IMPORT_DB, /* val */

TK_M_IMPORT_CMDLINE, /* val */

TK_M_IMPORT_PARENT, /* val */

TK_M_RESULT, /* val */

TK_M_MAX,

TK_A_STRING_ESCAPE_NONE,

TK_A_STRING_ESCAPE_REPLACE,

TK_A_DB_PERSIST,

TK_A_INOTIFY_WATCH, /* int */

TK_A_DEVLINK_PRIO, /* int */

TK_A_OWNER, /* val */

TK_A_GROUP, /* val */

TK_A_MODE, /* val */

TK_A_OWNER_ID, /* uid_t */

TK_A_GROUP_ID, /* gid_t */

TK_A_MODE_ID, /* mode_t */

TK_A_TAG, /* val */

TK_A_STATIC_NODE, /* val */

TK_A_SECLABEL, /* val, attr */

TK_A_ENV, /* val, attr */

TK_A_NAME, /* val */

TK_A_DEVLINK, /* val */

TK_A_ATTR, /* val, attr */

TK_A_RUN_BUILTIN, /* val, bool */

TK_A_RUN_PROGRAM, /* val, bool */

TK_A_GOTO, /* size_t */

TK_END,

};

struct token {

union {

unsigned char type; /* same in rule and key */

struct {

enum token_type type:8;

bool can_set_name:1;

bool has_static_node:1;

unsigned int unused:6;

unsigned short token_count;

unsigned int label_off;

unsigned short filename_off;

unsigned short filename_line;

} rule;

struct {

enum token_type type:8;

enum operation_type op:8;

enum string_glob_type glob:8;

enum string_subst_type subst:4;

enum string_subst_type attrsubst:4;

unsigned int value_off;

union {

unsigned int attr_off;

unsigned int rule_goto;

mode_t mode;

uid_t uid;

gid_t gid;

int devlink_prio;

int watch;

enum udev_builtin_cmd builtin_cmd;

};

} key;

};

};

#define MAX_TK 64

struct rule_tmp {

struct udev_rules *rules;

struct token rule;

struct token token[MAX_TK];

unsigned int token_cur;

};

#ifdef DEBUG

static const char *operation_str(enum operation_type type) {

static const char *operation_strs[] = {

[OP_UNSET] = "UNSET",

[OP_MATCH] = "match",

[OP_NOMATCH] = "nomatch",

[OP_MATCH_MAX] = "MATCH_MAX",

[OP_ADD] = "add",

[OP_ASSIGN] = "assign",

[OP_ASSIGN_FINAL] = "assign-final",

} ;

return operation_strs[type];

}

static const char *string_glob_str(enum string_glob_type type) {

static const char *string_glob_strs[] = {

[GL_UNSET] = "UNSET",

[GL_PLAIN] = "plain",

[GL_GLOB] = "glob",

[GL_SPLIT] = "split",

[GL_SPLIT_GLOB] = "split-glob",

[GL_SOMETHING] = "split-glob",

};

return string_glob_strs[type];

}

static const char *token_str(enum token_type type) {

static const char *token_strs[] = {

[TK_UNSET] = "UNSET",

[TK_RULE] = "RULE",

[TK_M_ACTION] = "M ACTION",

[TK_M_DEVPATH] = "M DEVPATH",

[TK_M_KERNEL] = "M KERNEL",

[TK_M_DEVLINK] = "M DEVLINK",

[TK_M_NAME] = "M NAME",

[TK_M_ENV] = "M ENV",

[TK_M_TAG] = "M TAG",

[TK_M_SUBSYSTEM] = "M SUBSYSTEM",

[TK_M_DRIVER] = "M DRIVER",

[TK_M_WAITFOR] = "M WAITFOR",

[TK_M_ATTR] = "M ATTR",

[TK_M_PARENTS_MIN] = "M PARENTS_MIN",

[TK_M_KERNELS] = "M KERNELS",

[TK_M_SUBSYSTEMS] = "M SUBSYSTEMS",

[TK_M_DRIVERS] = "M DRIVERS",

[TK_M_ATTRS] = "M ATTRS",

[TK_M_TAGS] = "M TAGS",

[TK_M_PARENTS_MAX] = "M PARENTS_MAX",

[TK_M_TEST] = "M TEST",

[TK_M_PROGRAM] = "M PROGRAM",

[TK_M_IMPORT_FILE] = "M IMPORT_FILE",

[TK_M_IMPORT_PROG] = "M IMPORT_PROG",

[TK_M_IMPORT_BUILTIN] = "M IMPORT_BUILTIN",

[TK_M_IMPORT_DB] = "M IMPORT_DB",

[TK_M_IMPORT_CMDLINE] = "M IMPORT_CMDLINE",

[TK_M_IMPORT_PARENT] = "M IMPORT_PARENT",

[TK_M_RESULT] = "M RESULT",

[TK_M_MAX] = "M MAX",

[TK_A_STRING_ESCAPE_NONE] = "A STRING_ESCAPE_NONE",

[TK_A_STRING_ESCAPE_REPLACE] = "A STRING_ESCAPE_REPLACE",

[TK_A_DB_PERSIST] = "A DB_PERSIST",

[TK_A_INOTIFY_WATCH] = "A INOTIFY_WATCH",

[TK_A_DEVLINK_PRIO] = "A DEVLINK_PRIO",

[TK_A_OWNER] = "A OWNER",

[TK_A_GROUP] = "A GROUP",

[TK_A_MODE] = "A MODE",

[TK_A_OWNER_ID] = "A OWNER_ID",

[TK_A_GROUP_ID] = "A GROUP_ID",

[TK_A_STATIC_NODE] = "A STATIC_NODE",

[TK_A_SECLABEL] = "A SECLABEL",

[TK_A_MODE_ID] = "A MODE_ID",

[TK_A_ENV] = "A ENV",

[TK_A_TAG] = "A ENV",

[TK_A_NAME] = "A NAME",

[TK_A_DEVLINK] = "A DEVLINK",

[TK_A_ATTR] = "A ATTR",

[TK_A_RUN_BUILTIN] = "A RUN_BUILTIN",

[TK_A_RUN_PROGRAM] = "A RUN_PROGRAM",

[TK_A_GOTO] = "A GOTO",

[TK_END] = "END",

};

return token_strs[type];

}

static void dump_token(struct udev_rules *rules, struct token *token) {

enum token_type type = token->type;

enum operation_type op = token->key.op;

enum string_glob_type glob = token->key.glob;

const char *value = str(rules, token->key.value_off);

const char *attr = &rules->buf[token->key.attr_off];

switch (type) {

case TK_RULE:

{

const char *tks_ptr = (char *)rules->tokens;

const char *tk_ptr = (char *)token;

unsigned int idx = (tk_ptr - tks_ptr) / sizeof(struct token);

log_debug("* RULE %s:%u, token: %u, count: %u, label: '%s'",

&rules->buf[token->rule.filename_off], token->rule.filename_line,

idx, token->rule.token_count,

&rules->buf[token->rule.label_off]);

break;

}

case TK_M_ACTION:

case TK_M_DEVPATH:

case TK_M_KERNEL:

case TK_M_SUBSYSTEM:

case TK_M_DRIVER:

case TK_M_WAITFOR:

case TK_M_DEVLINK:

case TK_M_NAME:

case TK_M_KERNELS:

case TK_M_SUBSYSTEMS:

case TK_M_DRIVERS:

case TK_M_TAGS:

case TK_M_PROGRAM:

case TK_M_IMPORT_FILE:

case TK_M_IMPORT_PROG:

case TK_M_IMPORT_DB:

case TK_M_IMPORT_CMDLINE:

case TK_M_IMPORT_PARENT:

case TK_M_RESULT:

case TK_A_NAME:

case TK_A_DEVLINK:

case TK_A_OWNER:

case TK_A_GROUP:

case TK_A_MODE:

case TK_A_RUN_BUILTIN:

case TK_A_RUN_PROGRAM:

log_debug("%s %s '%s'(%s)",

token_str(type), operation_str(op), value, string_glob_str(glob));

break;

case TK_M_IMPORT_BUILTIN:

log_debug("%s %i '%s'", token_str(type), token->key.builtin_cmd, value);

break;

case TK_M_ATTR:

case TK_M_ATTRS:

case TK_M_ENV:

case TK_A_ATTR:

case TK_A_ENV:

log_debug("%s %s '%s' '%s'(%s)",

token_str(type), operation_str(op), attr, value, string_glob_str(glob));

break;

case TK_M_TAG:

case TK_A_TAG:

log_debug("%s %s '%s'", token_str(type), operation_str(op), value);

break;

case TK_A_STRING_ESCAPE_NONE:

case TK_A_STRING_ESCAPE_REPLACE:

case TK_A_DB_PERSIST:

log_debug("%s", token_str(type));

break;

case TK_M_TEST:

log_debug("%s %s '%s'(%s) %#o",

token_str(type), operation_str(op), value, string_glob_str(glob), token->key.mode);

break;

case TK_A_INOTIFY_WATCH:

log_debug("%s %u", token_str(type), token->key.watch);

break;

case TK_A_DEVLINK_PRIO:

log_debug("%s %u", token_str(type), token->key.devlink_prio);

break;

case TK_A_OWNER_ID:

log_debug("%s %s %u", token_str(type), operation_str(op), token->key.uid);

break;

case TK_A_GROUP_ID:

log_debug("%s %s %u", token_str(type), operation_str(op), token->key.gid);

break;

case TK_A_MODE_ID:

log_debug("%s %s %#o", token_str(type), operation_str(op), token->key.mode);

break;

case TK_A_STATIC_NODE:

log_debug("%s '%s'", token_str(type), value);

break;

case TK_A_SECLABEL:

log_debug("%s %s '%s' '%s'", token_str(type), operation_str(op), attr, value);

break;

case TK_A_GOTO:

log_debug("%s '%s' %u", token_str(type), value, token->key.rule_goto);

break;

case TK_END:

log_debug("* %s", token_str(type));

break;

case TK_M_PARENTS_MIN:

case TK_M_PARENTS_MAX:

case TK_M_MAX:

case TK_UNSET:

log_debug("unknown type %u", type);

break;

}

}

static void dump_rules(struct udev_rules *rules) {

unsigned int i;

log_debug("dumping %u (%zu bytes) tokens, %u (%zu bytes) strings",

rules->token_cur,

rules->token_cur * sizeof(struct token),

rules->buf_count,

rules->buf_cur);

for (i = 0; i < rules->token_cur; i++)

dump_token(rules, &rules->tokens[i]);

}

#else

static inline void dump_token(struct udev_rules *rules, struct token *token) {}

static inline void dump_rules(struct udev_rules *rules) {}

#endif /* DEBUG */

static int add_token(struct udev_rules *rules, struct token *token) {

/* grow buffer if needed */

if (rules->token_cur+1 >= rules->token_max) {

struct token *tokens;

unsigned int add;

/* double the buffer size */

add = rules->token_max;

if (add < 8)

add = 8;

tokens = realloc(rules->tokens, (rules->token_max + add ) * sizeof(struct token));

if (tokens == NULL)

return -1;

rules->tokens = tokens;

rules->token_max += add;

}

memcpy(&rules->tokens[rules->token_cur], token, sizeof(struct token));

rules->token_cur++;

return 0;

}

static uid_t add_uid(struct udev_rules *rules, const char *owner) {

unsigned int i;

uid_t uid;

unsigned int off;

/* lookup, if we know it already */

for (i = 0; i < rules->uids_cur; i++) {

off = rules->uids[i].name_off;

if (streq(rules_str(rules, off), owner)) {

uid = rules->uids[i].uid;

return uid;

}

}

uid = util_lookup_user(rules->udev, owner);

/* grow buffer if needed */

if (rules->uids_cur+1 >= rules->uids_max) {

struct uid_gid *uids;

unsigned int add;

/* double the buffer size */

add = rules->uids_max;

if (add < 1)

add = 8;

uids = realloc(rules->uids, (rules->uids_max + add ) * sizeof(struct uid_gid));

if (uids == NULL)

return uid;

rules->uids = uids;

rules->uids_max += add;

}

rules->uids[rules->uids_cur].uid = uid;

off = rules_add_string(rules, owner);

if (off <= 0)

return uid;

rules->uids[rules->uids_cur].name_off = off;

rules->uids_cur++;

return uid;

}

static gid_t add_gid(struct udev_rules *rules, const char *group) {

unsigned int i;

gid_t gid;

unsigned int off;

/* lookup, if we know it already */

for (i = 0; i < rules->gids_cur; i++) {

off = rules->gids[i].name_off;

if (streq(rules_str(rules, off), group)) {

gid = rules->gids[i].gid;

return gid;

}

}

gid = util_lookup_group(rules->udev, group);

/* grow buffer if needed */

if (rules->gids_cur+1 >= rules->gids_max) {

struct uid_gid *gids;

unsigned int add;

/* double the buffer size */

add = rules->gids_max;

if (add < 1)

add = 8;

gids = realloc(rules->gids, (rules->gids_max + add ) * sizeof(struct uid_gid));

if (gids == NULL)

return gid;

rules->gids = gids;

rules->gids_max += add;

}

rules->gids[rules->gids_cur].gid = gid;

off = rules_add_string(rules, group);

if (off <= 0)

return gid;

rules->gids[rules->gids_cur].name_off = off;

rules->gids_cur++;

return gid;

}

static int import_property_from_string(struct udev_device *dev, char *line) {

char *key;

char *val;

size_t len;

struct udev_list_entry *entry;

/* find key */

key = line;

while (isspace(key[0]))

key++;

/* comment or empty line */

if (key[0] == '#' || key[0] == '\0')

return -1;

/* split key/value */

val = strchr(key, '=');

if (val == NULL)

return -1;

val[0] = '\0';

val++;

/* find value */

while (isspace(val[0]))

val++;

/* terminate key */

len = strlen(key);

if (len == 0)

return -1;

while (isspace(key[len-1]))

len--;

key[len] = '\0';

/* terminate value */

len = strlen(val);

if (len == 0)

return -1;

while (isspace(val[len-1]))

len--;

val[len] = '\0';

if (len == 0)

return -1;

/* unquote */

if (val[0] == '"' || val[0] == '\'') {

if (val[len-1] != val[0]) {

log_debug("inconsistent quoting: '%s', skip", line);

return -1;

}

val[len-1] = '\0';

val++;

}

entry = udev_device_add_property(dev, key, val);

/* store in db, skip private keys */

if (key[0] != '.')

udev_list_entry_set_num(entry, true);

return 0;

}

static int import_file_into_properties(struct udev_device *dev, const char *filename) {

FILE *f;

char line[UTIL_LINE_SIZE];

f = fopen(filename, "re");

if (f == NULL)

return -1;

while (fgets(line, sizeof(line), f) != NULL)

import_property_from_string(dev, line);

fclose(f);

return 0;

}

static int import_program_into_properties(struct udev_event *event,

usec_t timeout_usec,

const char *program, const sigset_t *sigmask) {

struct udev_device *dev = event->dev;

char **envp;

char result[UTIL_LINE_SIZE];

char *line;

int err;

envp = udev_device_get_properties_envp(dev);

err = udev_event_spawn(event, timeout_usec, program, envp, sigmask, result, sizeof(result));

if (err < 0)

return err;

line = result;

while (line != NULL) {

char *pos;

pos = strchr(line, '\n');

if (pos != NULL) {

pos[0] = '\0';

pos = &pos[1];

}

import_property_from_string(dev, line);

line = pos;

}

return 0;

}

static int import_parent_into_properties(struct udev_device *dev, const char *filter) {

struct udev_device *dev_parent;

struct udev_list_entry *list_entry;

dev_parent = udev_device_get_parent(dev);

if (dev_parent == NULL)

return -1;

udev_list_entry_foreach(list_entry, udev_device_get_properties_list_entry(dev_parent)) {

const char *key = udev_list_entry_get_name(list_entry);

const char *val = udev_list_entry_get_value(list_entry);

if (fnmatch(filter, key, 0) == 0) {

struct udev_list_entry *entry;

entry = udev_device_add_property(dev, key, val);

/* store in db, skip private keys */

if (key[0] != '.')

udev_list_entry_set_num(entry, true);

}

}

return 0;

}

#define WAIT_LOOP_PER_SECOND 50

static int wait_for_file(struct udev_device *dev, const char *file, int timeout) {

char filepath[UTIL_PATH_SIZE];

char devicepath[UTIL_PATH_SIZE];

struct stat stats;

int loop = timeout * WAIT_LOOP_PER_SECOND;

/* a relative path is a device attribute */

devicepath[0] = '\0';

if (file[0] != '/') {

strscpyl(devicepath, sizeof(devicepath), udev_device_get_syspath(dev), NULL);

strscpyl(filepath, sizeof(filepath), devicepath, "/", file, NULL);

file = filepath;

}

while (--loop) {

const struct timespec duration = { 0, 1000 * 1000 * 1000 / WAIT_LOOP_PER_SECOND };

/* lookup file */

if (stat(file, &stats) == 0) {

log_debug("file '%s' appeared after %i loops", file, (timeout * WAIT_LOOP_PER_SECOND) - loop-1);

return 0;

}

/* make sure, the device did not disappear in the meantime */

if (devicepath[0] != '\0' && stat(devicepath, &stats) != 0) {

log_debug("device disappeared while waiting for '%s'", file);

return -2;

}

log_debug("wait for '%s' for %i mseconds", file, 1000 / WAIT_LOOP_PER_SECOND);

nanosleep(&duration, NULL);

}

log_debug("waiting for '%s' failed", file);

return -1;

}

static int attr_subst_subdir(char *attr, size_t len) {

bool found = false;

if (strstr(attr, "/*/")) {

char *pos;

char dirname[UTIL_PATH_SIZE];

const char *tail;

DIR *dir;

strscpy(dirname, sizeof(dirname), attr);

pos = strstr(dirname, "/*/");

if (pos == NULL)

return -1;

pos[0] = '\0';

tail = &pos[2];

dir = opendir(dirname);

if (dir != NULL) {

struct dirent *dent;

for (dent = readdir(dir); dent != NULL; dent = readdir(dir)) {

struct stat stats;

if (dent->d_name[0] == '.')

continue;

strscpyl(attr, len, dirname, "/", dent->d_name, tail, NULL);

if (stat(attr, &stats) == 0) {

found = true;

break;

}

}

closedir(dir);

}

}

return found;

}

static int get_key(struct udev *udev, char **line, char **key, enum operation_type *op, char **value) {

char *linepos;

char *temp;

linepos = *line;

if (linepos == NULL || linepos[0] == '\0')

return -1;

/* skip whitespace */

while (isspace(linepos[0]) || linepos[0] == ',')

linepos++;

/* get the key */

if (linepos[0] == '\0')

return -1;

*key = linepos;

for (;;) {

linepos++;

if (linepos[0] == '\0')

return -1;

if (isspace(linepos[0]))

break;

if (linepos[0] == '=')

break;

if ((linepos[0] == '+') || (linepos[0] == '!') || (linepos[0] == ':'))

if (linepos[1] == '=')

break;

}

/* remember end of key */

temp = linepos;

/* skip whitespace after key */

while (isspace(linepos[0]))

linepos++;

if (linepos[0] == '\0')

return -1;

/* get operation type */

if (linepos[0] == '=' && linepos[1] == '=') {

*op = OP_MATCH;

linepos += 2;

} else if (linepos[0] == '!' && linepos[1] == '=') {

*op = OP_NOMATCH;

linepos += 2;

} else if (linepos[0] == '+' && linepos[1] == '=') {

*op = OP_ADD;

linepos += 2;

} else if (linepos[0] == '=') {

*op = OP_ASSIGN;

linepos++;

} else if (linepos[0] == ':' && linepos[1] == '=') {

*op = OP_ASSIGN_FINAL;

linepos += 2;

} else

return -1;

/* terminate key */

temp[0] = '\0';

/* skip whitespace after operator */

while (isspace(linepos[0]))

linepos++;

if (linepos[0] == '\0')

return -1;

/* get the value */

if (linepos[0] == '"')

linepos++;

else

return -1;

*value = linepos;

/* terminate */

temp = strchr(linepos, '"');

if (!temp)

return -1;

temp[0] = '\0';

temp++;

/* move line to next key */

*line = temp;

return 0;

}

static const char *get_key_attribute(struct udev *udev, char *str) {

char *pos;

char *attr;

attr = strchr(str, '{');

if (attr != NULL) {

attr++;

pos = strchr(attr, '}');

if (pos == NULL) {

log_error("missing closing brace for format");

return NULL;

}

pos[0] = '\0';

return attr;

}

return NULL;

}

static int rule_add_key(struct rule_tmp *rule_tmp, enum token_type type,

enum operation_type op,

const char *value, const void *data) {

struct token *token = &rule_tmp->token[rule_tmp->token_cur];

const char *attr = NULL;

memzero(token, sizeof(struct token));

switch (type) {

case TK_M_ACTION:

case TK_M_DEVPATH:

case TK_M_KERNEL:

case TK_M_SUBSYSTEM:

case TK_M_DRIVER:

case TK_M_WAITFOR:

case TK_M_DEVLINK:

case TK_M_NAME:

case TK_M_KERNELS:

case TK_M_SUBSYSTEMS:

case TK_M_DRIVERS:

case TK_M_TAGS:

case TK_M_PROGRAM:

case TK_M_IMPORT_FILE:

case TK_M_IMPORT_PROG:

case TK_M_IMPORT_DB:

case TK_M_IMPORT_CMDLINE:

case TK_M_IMPORT_PARENT:

case TK_M_RESULT:

case TK_A_OWNER:

case TK_A_GROUP:

case TK_A_MODE:

case TK_A_DEVLINK:

case TK_A_NAME:

case TK_A_GOTO:

case TK_M_TAG:

case TK_A_TAG:

case TK_A_STATIC_NODE:

token->key.value_off = rules_add_string(rule_tmp->rules, value);

break;

case TK_M_IMPORT_BUILTIN:

token->key.value_off = rules_add_string(rule_tmp->rules, value);

token->key.builtin_cmd = *(enum udev_builtin_cmd *)data;

break;

case TK_M_ENV:

case TK_M_ATTR:

case TK_M_ATTRS:

case TK_A_ATTR:

case TK_A_ENV:

case TK_A_SECLABEL:

attr = data;

token->key.value_off = rules_add_string(rule_tmp->rules, value);

token->key.attr_off = rules_add_string(rule_tmp->rules, attr);

break;

case TK_M_TEST:

token->key.value_off = rules_add_string(rule_tmp->rules, value);

if (data != NULL)

token->key.mode = *(mode_t *)data;

break;

case TK_A_STRING_ESCAPE_NONE:

case TK_A_STRING_ESCAPE_REPLACE:

case TK_A_DB_PERSIST:

break;

case TK_A_RUN_BUILTIN:

case TK_A_RUN_PROGRAM:

token->key.builtin_cmd = *(enum udev_builtin_cmd *)data;

token->key.value_off = rules_add_string(rule_tmp->rules, value);

break;

case TK_A_INOTIFY_WATCH:

case TK_A_DEVLINK_PRIO:

token->key.devlink_prio = *(int *)data;

break;

case TK_A_OWNER_ID:

token->key.uid = *(uid_t *)data;

break;

case TK_A_GROUP_ID:

token->key.gid = *(gid_t *)data;

break;

case TK_A_MODE_ID:

token->key.mode = *(mode_t *)data;

break;

case TK_RULE:

case TK_M_PARENTS_MIN:

case TK_M_PARENTS_MAX:

case TK_M_MAX:

case TK_END:

case TK_UNSET:

log_error("wrong type %u", type);

return -1;

}

if (value != NULL && type < TK_M_MAX) {

/* check if we need to split or call fnmatch() while matching rules */

enum string_glob_type glob;

int has_split;

int has_glob;

has_split = (strchr(value, '|') != NULL);

has_glob = string_is_glob(value);

if (has_split && has_glob) {

glob = GL_SPLIT_GLOB;

} else if (has_split) {

glob = GL_SPLIT;

} else if (has_glob) {

if (streq(value, "?*"))

glob = GL_SOMETHING;

else

glob = GL_GLOB;

} else {

glob = GL_PLAIN;

}

token->key.glob = glob;

}

if (value != NULL && type > TK_M_MAX) {

/* check if assigned value has substitution chars */

if (value[0] == '[')

token->key.subst = SB_SUBSYS;

else if (strchr(value, '%') != NULL || strchr(value, '$') != NULL)

token->key.subst = SB_FORMAT;

else

token->key.subst = SB_NONE;

}

if (attr != NULL) {

/* check if property/attribute name has substitution chars */

if (attr[0] == '[')

token->key.attrsubst = SB_SUBSYS;

else if (strchr(attr, '%') != NULL || strchr(attr, '$') != NULL)

token->key.attrsubst = SB_FORMAT;

else

token->key.attrsubst = SB_NONE;

}

token->key.type = type;

token->key.op = op;

rule_tmp->token_cur++;

if (rule_tmp->token_cur >= ELEMENTSOF(rule_tmp->token)) {

log_error("temporary rule array too small");

return -1;

}

return 0;

}

static int sort_token(struct udev_rules *rules, struct rule_tmp *rule_tmp) {

unsigned int i;

unsigned int start = 0;

unsigned int end = rule_tmp->token_cur;

for (i = 0; i < rule_tmp->token_cur; i++) {

enum token_type next_val = TK_UNSET;

unsigned int next_idx = 0;

unsigned int j;

/* find smallest value */

for (j = start; j < end; j++) {

if (rule_tmp->token[j].type == TK_UNSET)

continue;

if (next_val == TK_UNSET || rule_tmp->token[j].type < next_val) {

next_val = rule_tmp->token[j].type;

next_idx = j;

}

}

/* add token and mark done */

if (add_token(rules, &rule_tmp->token[next_idx]) != 0)

return -1;

rule_tmp->token[next_idx].type = TK_UNSET;

/* shrink range */

if (next_idx == start)

start++;

if (next_idx+1 == end)

end--;

}

return 0;

}

static int add_rule(struct udev_rules *rules, char *line,

const char *filename, unsigned int filename_off, unsigned int lineno) {

char *linepos;

const char *attr;

struct rule_tmp rule_tmp;

memzero(&rule_tmp, sizeof(struct rule_tmp));

rule_tmp.rules = rules;

rule_tmp.rule.type = TK_RULE;

/* the offset in the rule is limited to unsigned short */

if (filename_off < USHRT_MAX)

rule_tmp.rule.rule.filename_off = filename_off;

rule_tmp.rule.rule.filename_line = lineno;

linepos = line;

for (;;) {

char *key;

char *value;

enum operation_type op;

if (get_key(rules->udev, &linepos, &key, &op, &value) != 0) {

/* Avoid erroring on trailing whitespace. This is probably rare

while (isblank(*linepos))

linepos++;

/* If we aren't at the end of the line, this is a parsing error.

if (*linepos != '\n') {

char buf[2] = {linepos[1]};

_cleanup_free_ char *tmp;

tmp = cescape(buf);

log_error("invalid key/value pair in file %s on line %u,"

"starting at character %tu ('%s')\n",

filename, lineno, linepos - line + 1, tmp);

if (linepos[1] == '#')

log_error("hint: comments can only start at beginning of line");

}

break;

}

if (streq(key, "ACTION")) {

if (op > OP_MATCH_MAX) {

log_error("invalid ACTION operation");

goto invalid;

}

rule_add_key(&rule_tmp, TK_M_ACTION, op, value, NULL);

continue;

}

if (streq(key, "DEVPATH")) {

if (op > OP_MATCH_MAX) {

log_error("invalid DEVPATH operation");

goto invalid;

}

rule_add_key(&rule_tmp, TK_M_DEVPATH, op, value, NULL);

continue;

}

if (streq(key, "KERNEL")) {

if (op > OP_MATCH_MAX) {

log_error("invalid KERNEL operation");

goto invalid;

}

rule_add_key(&rule_tmp, TK_M_KERNEL, op, value, NULL);

continue;

}

if (streq(key, "SUBSYSTEM")) {

if (op > OP_MATCH_MAX) {

log_error("invalid SUBSYSTEM operation");

goto invalid;

}

/* bus, class, subsystem events should all be the same */

if (streq(value, "subsystem") ||

streq(value, "bus") ||

streq(value, "class")) {

if (streq(value, "bus") || streq(value, "class"))

log_error("'%s' must be specified as 'subsystem' "

"please fix it in %s:%u", value, filename, lineno);

rule_add_key(&rule_tmp, TK_M_SUBSYSTEM, op, "subsystem|class|bus", NULL);

} else

rule_add_key(&rule_tmp, TK_M_SUBSYSTEM, op, value, NULL);

continue;

}

if (streq(key, "DRIVER")) {

if (op > OP_MATCH_MAX) {

log_error("invalid DRIVER operation");

goto invalid;

}

rule_add_key(&rule_tmp, TK_M_DRIVER, op, value, NULL);

continue;

}

if (startswith(key, "ATTR{")) {

attr = get_key_attribute(rules->udev, key + strlen("ATTR"));

if (attr == NULL) {

log_error("error parsing ATTR attribute");

goto invalid;

}

if (op < OP_MATCH_MAX) {

rule_add_key(&rule_tmp, TK_M_ATTR, op, value, attr);

} else {

rule_add_key(&rule_tmp, TK_A_ATTR, op, value, attr);

}

continue;

}

if (startswith(key, "SECLABEL{")) {

attr = get_key_attribute(rules->udev, key + strlen("SECLABEL"));

if (!attr) {

log_error("error parsing SECLABEL attribute");

goto invalid;

}

rule_add_key(&rule_tmp, TK_A_SECLABEL, op, value, attr);

continue;

}

if (streq(key, "KERNELS")) {

if (op > OP_MATCH_MAX) {

log_error("invalid KERNELS operation");

goto invalid;

}

rule_add_key(&rule_tmp, TK_M_KERNELS, op, value, NULL);

continue;

}

if (streq(key, "SUBSYSTEMS")) {

if (op > OP_MATCH_MAX) {

log_error("invalid SUBSYSTEMS operation");

goto invalid;

}

rule_add_key(&rule_tmp, TK_M_SUBSYSTEMS, op, value, NULL);

continue;

}

if (streq(key, "DRIVERS")) {

if (op > OP_MATCH_MAX) {

log_error("invalid DRIVERS operation");

goto invalid;

}

rule_add_key(&rule_tmp, TK_M_DRIVERS, op, value, NULL);

continue;

}

if (startswith(key, "ATTRS{")) {

if (op > OP_MATCH_MAX) {

log_error("invalid ATTRS operation");

goto invalid;

}

attr = get_key_attribute(rules->udev, key + strlen("ATTRS"));

if (attr == NULL) {

log_error("error parsing ATTRS attribute");

goto invalid;

}

if (startswith(attr, "device/"))

log_error("the 'device' link may not be available in a future kernel, "

"please fix it in %s:%u", filename, lineno);

else if (strstr(attr, "../") != NULL)

log_error("do not reference parent sysfs directories directly, "

"it may break with a future kernel, please fix it in %s:%u", filename, lineno);

rule_add_key(&rule_tmp, TK_M_ATTRS, op, value, attr);

continue;

}

if (streq(key, "TAGS")) {

if (op > OP_MATCH_MAX) {

log_error("invalid TAGS operation");

goto invalid;

}

rule_add_key(&rule_tmp, TK_M_TAGS, op, value, NULL);

continue;

}

if (startswith(key, "ENV{")) {

attr = get_key_attribute(rules->udev, key + strlen("ENV"));

if (attr == NULL) {

log_error("error parsing ENV attribute");

goto invalid;

}

if (op < OP_MATCH_MAX) {

if (rule_add_key(&rule_tmp, TK_M_ENV, op, value, attr) != 0)

goto invalid;

} else {

static const char *blacklist[] = {

"ACTION",

"SUBSYSTEM",

"DEVTYPE",

"MAJOR",

"MINOR",

"DRIVER",

"IFINDEX",

"DEVNAME",

"DEVLINKS",

"DEVPATH",

"TAGS",

};

unsigned int i;

for (i = 0; i < ELEMENTSOF(blacklist); i++) {

if (!streq(attr, blacklist[i]))

continue;

log_error("invalid ENV attribute, '%s' can not be set %s:%u", attr, filename, lineno);

goto invalid;

}

if (rule_add_key(&rule_tmp, TK_A_ENV, op, value, attr) != 0)

goto invalid;

}

continue;

}

if (streq(key, "TAG")) {

if (op < OP_MATCH_MAX)

rule_add_key(&rule_tmp, TK_M_TAG, op, value, NULL);

else

rule_add_key(&rule_tmp, TK_A_TAG, op, value, NULL);

continue;

}

if (streq(key, "PROGRAM")) {

rule_add_key(&rule_tmp, TK_M_PROGRAM, op, value, NULL);

continue;

}

if (streq(key, "RESULT")) {

if (op > OP_MATCH_MAX) {

log_error("invalid RESULT operation");

goto invalid;

}

rule_add_key(&rule_tmp, TK_M_RESULT, op, value, NULL);

continue;

}

if (startswith(key, "IMPORT")) {

attr = get_key_attribute(rules->udev, key + strlen("IMPORT"));

if (attr == NULL) {

log_error("IMPORT{} type missing, ignoring IMPORT %s:%u", filename, lineno);

continue;

}

if (streq(attr, "program")) {

/* find known built-in command */

if (value[0] != '/') {

enum udev_builtin_cmd cmd;

cmd = udev_builtin_lookup(value);

if (cmd < UDEV_BUILTIN_MAX) {

log_debug("IMPORT found builtin '%s', replacing %s:%u",

value, filename, lineno);

rule_add_key(&rule_tmp, TK_M_IMPORT_BUILTIN, op, value, &cmd);

continue;

}

}

rule_add_key(&rule_tmp, TK_M_IMPORT_PROG, op, value, NULL);

} else if (streq(attr, "builtin")) {

enum udev_builtin_cmd cmd = udev_builtin_lookup(value);

if (cmd < UDEV_BUILTIN_MAX)

rule_add_key(&rule_tmp, TK_M_IMPORT_BUILTIN, op, value, &cmd);

else

log_error("IMPORT{builtin}: '%s' unknown %s:%u", value, filename, lineno);

} else if (streq(attr, "file")) {

rule_add_key(&rule_tmp, TK_M_IMPORT_FILE, op, value, NULL);

} else if (streq(attr, "db")) {

rule_add_key(&rule_tmp, TK_M_IMPORT_DB, op, value, NULL);

} else if (streq(attr, "cmdline")) {

rule_add_key(&rule_tmp, TK_M_IMPORT_CMDLINE, op, value, NULL);

} else if (streq(attr, "parent")) {

rule_add_key(&rule_tmp, TK_M_IMPORT_PARENT, op, value, NULL);

} else

log_error("IMPORT{} unknown type, ignoring IMPORT %s:%u", filename, lineno);

continue;

}

if (startswith(key, "TEST")) {

mode_t mode = 0;

if (op > OP_MATCH_MAX) {

log_error("invalid TEST operation");

goto invalid;

}

attr = get_key_attribute(rules->udev, key + strlen("TEST"));

if (attr != NULL) {

mode = strtol(attr, NULL, 8);

rule_add_key(&rule_tmp, TK_M_TEST, op, value, &mode);

} else {

rule_add_key(&rule_tmp, TK_M_TEST, op, value, NULL);

}

continue;

}

if (startswith(key, "RUN")) {

attr = get_key_attribute(rules->udev, key + strlen("RUN"));

if (attr == NULL)

attr = "program";

if (streq(attr, "builtin")) {

enum udev_builtin_cmd cmd = udev_builtin_lookup(value);

if (cmd < UDEV_BUILTIN_MAX)

rule_add_key(&rule_tmp, TK_A_RUN_BUILTIN, op, value, &cmd);

else

log_error("IMPORT{builtin}: '%s' unknown %s:%u", value, filename, lineno);

} else if (streq(attr, "program")) {

enum udev_builtin_cmd cmd = UDEV_BUILTIN_MAX;

rule_add_key(&rule_tmp, TK_A_RUN_PROGRAM, op, value, &cmd);

} else {

log_error("RUN{} unknown type, ignoring RUN %s:%u", filename, lineno);

}

continue;

}

if (streq(key, "WAIT_FOR") || streq(key, "WAIT_FOR_SYSFS")) {

rule_add_key(&rule_tmp, TK_M_WAITFOR, 0, value, NULL);

continue;

}

if (streq(key, "LABEL")) {

rule_tmp.rule.rule.label_off = rules_add_string(rules, value);

continue;

}

if (streq(key, "GOTO")) {

rule_add_key(&rule_tmp, TK_A_GOTO, 0, value, NULL);

continue;

}

if (startswith(key, "NAME")) {

if (op < OP_MATCH_MAX) {

rule_add_key(&rule_tmp, TK_M_NAME, op, value, NULL);

} else {

if (streq(value, "%k")) {

log_error("NAME=\"%%k\" is ignored, because it breaks kernel supplied names, "

"please remove it from %s:%u\n", filename, lineno);

continue;

}

if (value[0] == '\0') {

log_debug("NAME=\"\" is ignored, because udev will not delete any device nodes, "

"please remove it from %s:%u\n", filename, lineno);

continue;

}

rule_add_key(&rule_tmp, TK_A_NAME, op, value, NULL);

}

rule_tmp.rule.rule.can_set_name = true;

continue;

}

if (streq(key, "SYMLINK")) {

if (op < OP_MATCH_MAX)

rule_add_key(&rule_tmp, TK_M_DEVLINK, op, value, NULL);

else

rule_add_key(&rule_tmp, TK_A_DEVLINK, op, value, NULL);

rule_tmp.rule.rule.can_set_name = true;

continue;

}

if (streq(key, "OWNER")) {

uid_t uid;

char *endptr;

uid = strtoul(value, &endptr, 10);

if (endptr[0] == '\0') {

rule_add_key(&rule_tmp, TK_A_OWNER_ID, op, NULL, &uid);

} else if ((rules->resolve_names > 0) && strchr("$%", value[0]) == NULL) {

uid = add_uid(rules, value);

rule_add_key(&rule_tmp, TK_A_OWNER_ID, op, NULL, &uid);

} else if (rules->resolve_names >= 0) {

rule_add_key(&rule_tmp, TK_A_OWNER, op, value, NULL);

}

rule_tmp.rule.rule.can_set_name = true;

continue;

}

if (streq(key, "GROUP")) {

gid_t gid;

char *endptr;

gid = strtoul(value, &endptr, 10);

if (endptr[0] == '\0') {

rule_add_key(&rule_tmp, TK_A_GROUP_ID, op, NULL, &gid);

} else if ((rules->resolve_names > 0) && strchr("$%", value[0]) == NULL) {

gid = add_gid(rules, value);

rule_add_key(&rule_tmp, TK_A_GROUP_ID, op, NULL, &gid);

} else if (rules->resolve_names >= 0) {

rule_add_key(&rule_tmp, TK_A_GROUP, op, value, NULL);

}

rule_tmp.rule.rule.can_set_name = true;

continue;

}

if (streq(key, "MODE")) {

mode_t mode;

char *endptr;

mode = strtol(value, &endptr, 8);

if (endptr[0] == '\0')

rule_add_key(&rule_tmp, TK_A_MODE_ID, op, NULL, &mode);

else

rule_add_key(&rule_tmp, TK_A_MODE, op, value, NULL);

rule_tmp.rule.rule.can_set_name = true;

continue;

}

if (streq(key, "OPTIONS")) {

const char *pos;

pos = strstr(value, "link_priority=");

if (pos != NULL) {

int prio = atoi(&pos[strlen("link_priority=")]);

rule_add_key(&rule_tmp, TK_A_DEVLINK_PRIO, op, NULL, &prio);

}

if (pos != NULL) {

pos = &pos[strlen("string_escape=")];

if (startswith(pos, "none"))

rule_add_key(&rule_tmp, TK_A_STRING_ESCAPE_NONE, op, NULL, NULL);

else if (startswith(pos, "replace"))

rule_add_key(&rule_tmp, TK_A_STRING_ESCAPE_REPLACE, op, NULL, NULL);

}

pos = strstr(value, "db_persist");

if (pos != NULL)

rule_add_key(&rule_tmp, TK_A_DB_PERSIST, op, NULL, NULL);

pos = strstr(value, "nowatch");

if (pos != NULL) {

const int off = 0;

rule_add_key(&rule_tmp, TK_A_INOTIFY_WATCH, op, NULL, &off);

} else {

pos = strstr(value, "watch");

if (pos != NULL) {

const int on = 1;

rule_add_key(&rule_tmp, TK_A_INOTIFY_WATCH, op, NULL, &on);

}

}

pos = strstr(value, "static_node=");

if (pos != NULL) {

rule_add_key(&rule_tmp, TK_A_STATIC_NODE, op, &pos[strlen("static_node=")], NULL);

rule_tmp.rule.rule.has_static_node = true;

}

continue;

}

log_error("unknown key '%s' in %s:%u", key, filename, lineno);

goto invalid;

}

/* add rule token */

rule_tmp.rule.rule.token_count = 1 + rule_tmp.token_cur;

if (add_token(rules, &rule_tmp.rule) != 0)

goto invalid;

/* add tokens to list, sorted by type */

if (sort_token(rules, &rule_tmp) != 0)

goto invalid;

return 0;

invalid:

log_error("invalid rule '%s:%u'", filename, lineno);

return -1;

}

static int parse_file(struct udev_rules *rules, const char *filename) {

FILE *f;

unsigned int first_token;

unsigned int filename_off;

char line[UTIL_LINE_SIZE];

int line_nr = 0;

unsigned int i;

f = fopen(filename, "re");

if (!f) {

if (errno == ENOENT)

return 0;

else

return -errno;

}

if (null_or_empty_fd(fileno(f))) {

log_debug("Skipping empty file: %s", filename);

return 0;

} else

log_debug("Reading rules file: %s", filename);

first_token = rules->token_cur;

filename_off = rules_add_string(rules, filename);

while (fgets(line, sizeof(line), f) != NULL) {

char *key;

size_t len;

/* skip whitespace */

line_nr++;

key = line;

while (isspace(key[0]))

key++;

/* comment */

if (key[0] == '#')

continue;

len = strlen(line);

if (len < 3)

continue;

/* continue reading if backslash+newline is found */

while (line[len-2] == '\\') {

if (fgets(&line[len-2], (sizeof(line)-len)+2, f) == NULL)

break;

if (strlen(&line[len-2]) < 2)

break;

line_nr++;

len = strlen(line);

}

if (len+1 >= sizeof(line)) {

log_error("line too long '%s':%u, ignored", filename, line_nr);

continue;

}

add_rule(rules, key, filename, filename_off, line_nr);

}

fclose(f);

/* link GOTOs to LABEL rules in this file to be able to fast-forward */

for (i = first_token+1; i < rules->token_cur; i++) {

if (rules->tokens[i].type == TK_A_GOTO) {

char *label = rules_str(rules, rules->tokens[i].key.value_off);

unsigned int j;

for (j = i+1; j < rules->token_cur; j++) {

if (rules->tokens[j].type != TK_RULE)

continue;

if (rules->tokens[j].rule.label_off == 0)

continue;

if (!streq(label, rules_str(rules, rules->tokens[j].rule.label_off)))

continue;

rules->tokens[i].key.rule_goto = j;

break;

}

if (rules->tokens[i].key.rule_goto == 0)

log_error("GOTO '%s' has no matching label in: '%s'", label, filename);

}

}

return 0;

}

struct udev_rules *udev_rules_new(struct udev *udev, int resolve_names) {

struct udev_rules *rules;

struct udev_list file_list;

struct token end_token;

char **files, **f;

int r;

rules = new0(struct udev_rules, 1);

if (rules == NULL)

return NULL;

rules->udev = udev;

rules->resolve_names = resolve_names;

udev_list_init(udev, &file_list, true);

/* init token array and string buffer */

rules->tokens = malloc(PREALLOC_TOKEN * sizeof(struct token));

if (rules->tokens == NULL)

return udev_rules_unref(rules);

rules->token_max = PREALLOC_TOKEN;

rules->strbuf = strbuf_new();

if (!rules->strbuf)

return udev_rules_unref(rules);

udev_rules_check_timestamp(rules);

r = conf_files_list_strv(&files, ".rules", NULL, rules_dirs);

if (r < 0) {

log_error("failed to enumerate rules files: %s", strerror(-r));

return udev_rules_unref(rules);

}

/*

STRV_FOREACH(f, files)

rules_add_string(rules, *f);

STRV_FOREACH(f, files)

parse_file(rules, *f);

strv_free(files);

memzero(&end_token, sizeof(struct token));

end_token.type = TK_END;

add_token(rules, &end_token);

log_debug("rules contain %zu bytes tokens (%u * %zu bytes), %zu bytes strings",

rules->token_max * sizeof(struct token), rules->token_max, sizeof(struct token), rules->strbuf->len);

/* cleanup temporary strbuf data */

log_debug("%zu strings (%zu bytes), %zu de-duplicated (%zu bytes), %zu trie nodes used",

rules->strbuf->in_count, rules->strbuf->in_len,

rules->strbuf->dedup_count, rules->strbuf->dedup_len, rules->strbuf->nodes_count);

strbuf_complete(rules->strbuf);

/* cleanup uid/gid cache */

free(rules->uids);

rules->uids = NULL;

rules->uids_cur = 0;

rules->uids_max = 0;

free(rules->gids);

rules->gids = NULL;

rules->gids_cur = 0;

rules->gids_max = 0;

dump_rules(rules);

return rules;

}

struct udev_rules *udev_rules_unref(struct udev_rules *rules) {

if (rules == NULL)

return NULL;

free(rules->tokens);

strbuf_cleanup(rules->strbuf);

free(rules->uids);

free(rules->gids);

free(rules);

return NULL;

}

bool udev_rules_check_timestamp(struct udev_rules *rules) {

if (!rules)

return false;

return paths_check_timestamp(rules_dirs, &rules->dirs_ts_usec, true);

}

static int match_key(struct udev_rules *rules, struct token *token, const char *val) {

char *key_value = rules_str(rules, token->key.value_off);

char *pos;

bool match = false;

if (val == NULL)

val = "";

switch (token->key.glob) {

case GL_PLAIN:

match = (streq(key_value, val));

break;

case GL_GLOB:

match = (fnmatch(key_value, val, 0) == 0);

break;

case GL_SPLIT:

{

const char *s;

size_t len;

s = rules_str(rules, token->key.value_off);

len = strlen(val);

for (;;) {

const char *next;

next = strchr(s, '|');

if (next != NULL) {

size_t matchlen = (size_t)(next - s);

match = (matchlen == len && strneq(s, val, matchlen));

if (match)

break;

} else {

match = (streq(s, val));

break;

}

s = &next[1];

}

break;

}

case GL_SPLIT_GLOB:

{

char value[UTIL_PATH_SIZE];

strscpy(value, sizeof(value), rules_str(rules, token->key.value_off));

key_value = value;

while (key_value != NULL) {

pos = strchr(key_value, '|');

if (pos != NULL) {

pos[0] = '\0';

pos = &pos[1];

}

match = (fnmatch(key_value, val, 0) == 0);

if (match)

break;

key_value = pos;

}

break;

}

case GL_SOMETHING:

match = (val[0] != '\0');

break;

case GL_UNSET:

return -1;

}

if (match && (token->key.op == OP_MATCH))

return 0;

if (!match && (token->key.op == OP_NOMATCH))

return 0;

return -1;

}

static int match_attr(struct udev_rules *rules, struct udev_device *dev, struct udev_event *event, struct token *cur) {

const char *name;

char nbuf[UTIL_NAME_SIZE];

const char *value;

char vbuf[UTIL_NAME_SIZE];

size_t len;

name = rules_str(rules, cur->key.attr_off);

switch (cur->key.attrsubst) {

case SB_FORMAT:

udev_event_apply_format(event, name, nbuf, sizeof(nbuf));

name = nbuf;

/* fall through */

case SB_NONE:

value = udev_device_get_sysattr_value(dev, name);

if (value == NULL)

return -1;

break;

case SB_SUBSYS:

if (util_resolve_subsys_kernel(event->udev, name, vbuf, sizeof(vbuf), 1) != 0)

return -1;

value = vbuf;

break;

default:

return -1;

}

/* remove trailing whitespace, if not asked to match for it */

len = strlen(value);

if (len > 0 && isspace(value[len-1])) {

const char *key_value;

size_t klen;

key_value = rules_str(rules, cur->key.value_off);

klen = strlen(key_value);

if (klen > 0 && !isspace(key_value[klen-1])) {

if (value != vbuf) {

strscpy(vbuf, sizeof(vbuf), value);

value = vbuf;

}

while (len > 0 && isspace(vbuf[--len]))

vbuf[len] = '\0';

}

}

return match_key(rules, cur, value);

}

enum escape_type {

ESCAPE_UNSET,

ESCAPE_NONE,

ESCAPE_REPLACE,

};

int udev_rules_apply_to_event(struct udev_rules *rules,

struct udev_event *event,

usec_t timeout_usec,

const sigset_t *sigmask) {

struct token *cur;

struct token *rule;

enum escape_type esc = ESCAPE_UNSET;

bool can_set_name;

if (rules->tokens == NULL)

return -1;

can_set_name = ((!streq(udev_device_get_action(event->dev), "remove")) &&

(major(udev_device_get_devnum(event->dev)) > 0 ||

udev_device_get_ifindex(event->dev) > 0));

/* loop through token list, match, run actions or forward to next rule */

cur = &rules->tokens[0];

rule = cur;

for (;;) {

dump_token(rules, cur);

switch (cur->type) {

case TK_RULE:

/* current rule */

rule = cur;

/* possibly skip rules which want to set NAME, SYMLINK, OWNER, GROUP, MODE */

if (!can_set_name && rule->rule.can_set_name)

goto nomatch;

esc = ESCAPE_UNSET;

break;

case TK_M_ACTION:

if (match_key(rules, cur, udev_device_get_action(event->dev)) != 0)

goto nomatch;

break;

case TK_M_DEVPATH:

if (match_key(rules, cur, udev_device_get_devpath(event->dev)) != 0)

goto nomatch;

break;

case TK_M_KERNEL:

if (match_key(rules, cur, udev_device_get_sysname(event->dev)) != 0)

goto nomatch;

break;

case TK_M_DEVLINK: {

struct udev_list_entry *list_entry;

bool match = false;

udev_list_entry_foreach(list_entry, udev_device_get_devlinks_list_entry(event->dev)) {

const char *devlink;

devlink = udev_list_entry_get_name(list_entry) + strlen("/dev/");

if (match_key(rules, cur, devlink) == 0) {

match = true;

break;

}

}

if (!match)

goto nomatch;

break;

}

case TK_M_NAME:

if (match_key(rules, cur, event->name) != 0)

goto nomatch;

break;

case TK_M_ENV: {

const char *key_name = rules_str(rules, cur->key.attr_off);

const char *value;

value = udev_device_get_property_value(event->dev, key_name);

if (value == NULL)

value = "";

if (match_key(rules, cur, value))

goto nomatch;

break;

}

case TK_M_TAG: {

struct udev_list_entry *list_entry;

bool match = false;

udev_list_entry_foreach(list_entry, udev_device_get_tags_list_entry(event->dev)) {

if (streq(rules_str(rules, cur->key.value_off), udev_list_entry_get_name(list_entry))) {

match = true;

break;

}

}

if (!match && (cur->key.op != OP_NOMATCH))

goto nomatch;

break;

}

case TK_M_SUBSYSTEM:

if (match_key(rules, cur, udev_device_get_subsystem(event->dev)) != 0)

goto nomatch;

break;

case TK_M_DRIVER:

if (match_key(rules, cur, udev_device_get_driver(event->dev)) != 0)

goto nomatch;

break;

case TK_M_WAITFOR: {

char filename[UTIL_PATH_SIZE];

int found;

udev_event_apply_format(event, rules_str(rules, cur->key.value_off), filename, sizeof(filename));

found = (wait_for_file(event->dev, filename, 10) == 0);

if (!found && (cur->key.op != OP_NOMATCH))

goto nomatch;

break;

}

case TK_M_ATTR:

if (match_attr(rules, event->dev, event, cur) != 0)

goto nomatch;

break;

case TK_M_KERNELS:

case TK_M_SUBSYSTEMS:

case TK_M_DRIVERS:

case TK_M_ATTRS:

case TK_M_TAGS: {

struct token *next;

/* get whole sequence of parent matches */

next = cur;

while (next->type > TK_M_PARENTS_MIN && next->type < TK_M_PARENTS_MAX)

next++;

/* loop over parents */

event->dev_parent = event->dev;

for (;;) {

struct token *key;

/* loop over sequence of parent match keys */

for (key = cur; key < next; key++ ) {

dump_token(rules, key);

switch(key->type) {

case TK_M_KERNELS:

if (match_key(rules, key, udev_device_get_sysname(event->dev_parent)) != 0)

goto try_parent;

break;

case TK_M_SUBSYSTEMS:

if (match_key(rules, key, udev_device_get_subsystem(event->dev_parent)) != 0)

goto try_parent;

break;

case TK_M_DRIVERS:

if (match_key(rules, key, udev_device_get_driver(event->dev_parent)) != 0)

goto try_parent;

break;

case TK_M_ATTRS:

if (match_attr(rules, event->dev_parent, event, key) != 0)

goto try_parent;

break;

case TK_M_TAGS: {

bool match = udev_device_has_tag(event->dev_parent, rules_str(rules, cur->key.value_off));

if (match && key->key.op == OP_NOMATCH)

goto try_parent;

if (!match && key->key.op == OP_MATCH)

goto try_parent;

break;

}

default:

goto nomatch;

}

}

break;

try_parent:

event->dev_parent = udev_device_get_parent(event->dev_parent);

if (event->dev_parent == NULL)

goto nomatch;

}

/* move behind our sequence of parent match keys */

cur = next;

continue;

}

case TK_M_TEST: {

char filename[UTIL_PATH_SIZE];

struct stat statbuf;

int match;

udev_event_apply_format(event, rules_str(rules, cur->key.value_off), filename, sizeof(filename));

if (util_resolve_subsys_kernel(event->udev, filename, filename, sizeof(filename), 0) != 0) {

if (filename[0] != '/') {

char tmp[UTIL_PATH_SIZE];

strscpy(tmp, sizeof(tmp), filename);

strscpyl(filename, sizeof(filename),

udev_device_get_syspath(event->dev), "/", tmp, NULL);

}

}

attr_subst_subdir(filename, sizeof(filename));

match = (stat(filename, &statbuf) == 0);

if (match && cur->key.mode > 0)

match = ((statbuf.st_mode & cur->key.mode) > 0);

if (match && cur->key.op == OP_NOMATCH)

goto nomatch;

if (!match && cur->key.op == OP_MATCH)

goto nomatch;

break;

}

case TK_M_PROGRAM: {

char program[UTIL_PATH_SIZE];

char **envp;

char result[UTIL_LINE_SIZE];

free(event->program_result);

event->program_result = NULL;

udev_event_apply_format(event, rules_str(rules, cur->key.value_off), program, sizeof(program));

envp = udev_device_get_properties_envp(event->dev);

log_debug("PROGRAM '%s' %s:%u",

program,

rules_str(rules, rule->rule.filename_off),

rule->rule.filename_line);

if (udev_event_spawn(event, timeout_usec, program, envp, sigmask, result, sizeof(result)) < 0) {

if (cur->key.op != OP_NOMATCH)

goto nomatch;

} else {

int count;

util_remove_trailing_chars(result, '\n');

if (esc == ESCAPE_UNSET || esc == ESCAPE_REPLACE) {

count = util_replace_chars(result, UDEV_ALLOWED_CHARS_INPUT);

if (count > 0)

log_debug("%i character(s) replaced" , count);

}

event->program_result = strdup(result);

if (cur->key.op == OP_NOMATCH)

goto nomatch;

}

break;

}

case TK_M_IMPORT_FILE: {

char import[UTIL_PATH_SIZE];

udev_event_apply_format(event, rules_str(rules, cur->key.value_off), import, sizeof(import));

if (import_file_into_properties(event->dev, import) != 0)

if (cur->key.op != OP_NOMATCH)

goto nomatch;

break;

}

case TK_M_IMPORT_PROG: {

char import[UTIL_PATH_SIZE];

udev_event_apply_format(event, rules_str(rules, cur->key.value_off), import, sizeof(import));

log_debug("IMPORT '%s' %s:%u",

import,

rules_str(rules, rule->rule.filename_off),

rule->rule.filename_line);

if (import_program_into_properties(event, timeout_usec, import, sigmask) != 0)

if (cur->key.op != OP_NOMATCH)

goto nomatch;

break;

}

case TK_M_IMPORT_BUILTIN: {

char command[UTIL_PATH_SIZE];

if (udev_builtin_run_once(cur->key.builtin_cmd)) {

/* check if we ran already */

if (event->builtin_run & (1 << cur->key.builtin_cmd)) {

log_debug("IMPORT builtin skip '%s' %s:%u",

udev_builtin_name(cur->key.builtin_cmd),

rules_str(rules, rule->rule.filename_off),

rule->rule.filename_line);

/* return the result from earlier run */

if (event->builtin_ret & (1 << cur->key.builtin_cmd))

if (cur->key.op != OP_NOMATCH)

goto nomatch;

break;

}

/* mark as ran */

event->builtin_run |= (1 << cur->key.builtin_cmd);

}

udev_event_apply_format(event, rules_str(rules, cur->key.value_off), command, sizeof(command));

log_debug("IMPORT builtin '%s' %s:%u",

udev_builtin_name(cur->key.builtin_cmd),

rules_str(rules, rule->rule.filename_off),

rule->rule.filename_line);

if (udev_builtin_run(event->dev, cur->key.builtin_cmd, command, false) != 0) {

/* remember failure */

log_debug("IMPORT builtin '%s' returned non-zero",

udev_builtin_name(cur->key.builtin_cmd));

event->builtin_ret |= (1 << cur->key.builtin_cmd);

if (cur->key.op != OP_NOMATCH)

goto nomatch;

}

break;

}

case TK_M_IMPORT_DB: {

const char *key = rules_str(rules, cur->key.value_off);

const char *value;

value = udev_device_get_property_value(event->dev_db, key);

if (value != NULL) {

struct udev_list_entry *entry;

entry = udev_device_add_property(event->dev, key, value);

udev_list_entry_set_num(entry, true);

} else {

if (cur->key.op != OP_NOMATCH)

goto nomatch;

}

break;

}

case TK_M_IMPORT_CMDLINE: {

FILE *f;

bool imported = false;

f = fopen("/proc/cmdline", "re");

if (f != NULL) {

char cmdline[4096];

if (fgets(cmdline, sizeof(cmdline), f) != NULL) {

const char *key = rules_str(rules, cur->key.value_off);

char *pos;

pos = strstr(cmdline, key);

if (pos != NULL) {

struct udev_list_entry *entry;

pos += strlen(key);

if (pos[0] == '\0' || isspace(pos[0])) {

/* we import simple flags as 'FLAG=1' */

entry = udev_device_add_property(event->dev, key, "1");

udev_list_entry_set_num(entry, true);

imported = true;

} else if (pos[0] == '=') {

const char *value;

pos++;

value = pos;

while (pos[0] != '\0' && !isspace(pos[0]))

pos++;

pos[0] = '\0';

entry = udev_device_add_property(event->dev, key, value);

udev_list_entry_set_num(entry, true);

imported = true;

}

}

}

fclose(f);

}

if (!imported && cur->key.op != OP_NOMATCH)

goto nomatch;

break;

}

case TK_M_IMPORT_PARENT: {

char import[UTIL_PATH_SIZE];

udev_event_apply_format(event, rules_str(rules, cur->key.value_off), import, sizeof(import));

if (import_parent_into_properties(event->dev, import) != 0)

if (cur->key.op != OP_NOMATCH)

goto nomatch;

break;

}

case TK_M_RESULT:

if (match_key(rules, cur, event->program_result) != 0)

goto nomatch;

break;

case TK_A_STRING_ESCAPE_NONE:

esc = ESCAPE_NONE;

break;

case TK_A_STRING_ESCAPE_REPLACE:

esc = ESCAPE_REPLACE;

break;

case TK_A_DB_PERSIST:

udev_device_set_db_persist(event->dev);

break;

case TK_A_INOTIFY_WATCH:

if (event->inotify_watch_final)

break;

if (cur->key.op == OP_ASSIGN_FINAL)

event->inotify_watch_final = true;

event->inotify_watch = cur->key.watch;

break;

case TK_A_DEVLINK_PRIO:

udev_device_set_devlink_priority(event->dev, cur->key.devlink_prio);

break;

case TK_A_OWNER: {

char owner[UTIL_NAME_SIZE];

if (event->owner_final)

break;

if (cur->key.op == OP_ASSIGN_FINAL)

event->owner_final = true;

udev_event_apply_format(event, rules_str(rules, cur->key.value_off), owner, sizeof(owner));

event->owner_set = true;

event->uid = util_lookup_user(event->udev, owner);

log_debug("OWNER %u %s:%u",

event->uid,

rules_str(rules, rule->rule.filename_off),

rule->rule.filename_line);

break;

}

case TK_A_GROUP: {

char group[UTIL_NAME_SIZE];

if (event->group_final)

break;

if (cur->key.op == OP_ASSIGN_FINAL)

event->group_final = true;

udev_event_apply_format(event, rules_str(rules, cur->key.value_off), group, sizeof(group));

event->group_set = true;

event->gid = util_lookup_group(event->udev, group);

log_debug("GROUP %u %s:%u",

event->gid,

rules_str(rules, rule->rule.filename_off),

rule->rule.filename_line);

break;

}

case TK_A_MODE: {

char mode_str[UTIL_NAME_SIZE];

mode_t mode;

char *endptr;

if (event->mode_final)

break;

udev_event_apply_format(event, rules_str(rules, cur->key.value_off), mode_str, sizeof(mode_str));

mode = strtol(mode_str, &endptr, 8);

if (endptr[0] != '\0') {

log_error("ignoring invalid mode '%s'", mode_str);

break;

}

if (cur->key.op == OP_ASSIGN_FINAL)

event->mode_final = true;

event->mode_set = true;

event->mode = mode;

log_debug("MODE %#o %s:%u",

event->mode,

rules_str(rules, rule->rule.filename_off),

rule->rule.filename_line);

break;

}

case TK_A_OWNER_ID:

if (event->owner_final)

break;

if (cur->key.op == OP_ASSIGN_FINAL)

event->owner_final = true;

event->owner_set = true;

event->uid = cur->key.uid;

log_debug("OWNER %u %s:%u",

event->uid,

rules_str(rules, rule->rule.filename_off),

rule->rule.filename_line);

break;

case TK_A_GROUP_ID:

if (event->group_final)

break;

if (cur->key.op == OP_ASSIGN_FINAL)

event->group_final = true;

event->group_set = true;

event->gid = cur->key.gid;

log_debug("GROUP %u %s:%u",

event->gid,

rules_str(rules, rule->rule.filename_off),

rule->rule.filename_line);

break;

case TK_A_MODE_ID:

if (event->mode_final)

break;

if (cur->key.op == OP_ASSIGN_FINAL)

event->mode_final = true;

event->mode_set = true;

event->mode = cur->key.mode;

log_debug("MODE %#o %s:%u",

event->mode,

rules_str(rules, rule->rule.filename_off),

rule->rule.filename_line);

break;

case TK_A_SECLABEL: {

const char *name, *label;

name = rules_str(rules, cur->key.attr_off);

label = rules_str(rules, cur->key.value_off);

if (cur->key.op == OP_ASSIGN || cur->key.op == OP_ASSIGN_FINAL)

udev_list_cleanup(&event->seclabel_list);

udev_list_entry_add(&event->seclabel_list, name, label);

log_debug("SECLABEL{%s}='%s' %s:%u",

name, label,

rules_str(rules, rule->rule.filename_off),

rule->rule.filename_line);

break;

}

case TK_A_ENV: {

const char *name = rules_str(rules, cur->key.attr_off);

char *value = rules_str(rules, cur->key.value_off);

char value_new[UTIL_NAME_SIZE];

const char *value_old = NULL;

struct udev_list_entry *entry;

if (value[0] == '\0') {

if (cur->key.op == OP_ADD)

break;

udev_device_add_property(event->dev, name, NULL);

break;

}

if (cur->key.op == OP_ADD)

value_old = udev_device_get_property_value(event->dev, name);

if (value_old) {

char temp[UTIL_NAME_SIZE];

/* append value separated by space */

udev_event_apply_format(event, value, temp, sizeof(temp));

strscpyl(value_new, sizeof(value_new), value_old, " ", temp, NULL);

} else

udev_event_apply_format(event, value, value_new, sizeof(value_new));

entry = udev_device_add_property(event->dev, name, value_new);

/* store in db, skip private keys */

if (name[0] != '.')

udev_list_entry_set_num(entry, true);

break;

}

case TK_A_TAG: {