1
0
mirror of https://github.com/systemd/systemd.git synced 2025-01-11 09:18:07 +03:00

remove 'udevadm trigger --type=failed' and SYSFS, ID, BUS keys

This commit is contained in:
Kay Sievers 2011-10-06 00:45:06 +02:00
parent a13d90aec6
commit 289a1821a4
12 changed files with 16 additions and 201 deletions

5
NEWS
View File

@ -11,6 +11,11 @@ Systemd systems will take care of mounting fusectl and configfs
now. Non-systemd systems need to ship their own rule if they now. Non-systemd systems need to ship their own rule if they
need these filesystems auto-mounted. need these filesystems auto-mounted.
The long deprecated keys: SYSFS, ID, BUS have been removed.
The support for 'udevadm trigger --type=failed, and the
RUN{fail_event_on_error} attribute was removed.
udev 173 udev 173
======== ========
Bugfixes. Bugfixes.

6
TODO
View File

@ -1,3 +1,5 @@
- validate the two hex chars in replace_chars \x
- test (now fixed) /dev/tape/ links - test (now fixed) /dev/tape/ links
- /run/udev/control socket - /run/udev/control socket
@ -11,10 +13,6 @@
- move udevadm -> --bindir - move udevadm -> --bindir
- remove deprecated trigger --type=failed logic
- remove deprecated BUS=, SYSFS{}=, ID= keys
- kill tabs? - kill tabs?
- warn about RUN+="socket:" - warn about RUN+="socket:"

View File

@ -116,7 +116,6 @@ udev_queue_get_queue_is_empty
udev_queue_get_seqnum_is_finished udev_queue_get_seqnum_is_finished
udev_queue_get_seqnum_sequence_is_finished udev_queue_get_seqnum_sequence_is_finished
udev_queue_get_queued_list_entry udev_queue_get_queued_list_entry
udev_queue_get_failed_list_entry
udev_queue_get_kernel_seqnum udev_queue_get_kernel_seqnum
udev_queue_get_udev_seqnum udev_queue_get_udev_seqnum
</SECTION> </SECTION>

View File

@ -165,7 +165,6 @@ struct udev_queue_export *udev_queue_export_unref(struct udev_queue_export *udev
void udev_queue_export_cleanup(struct udev_queue_export *udev_queue_export); void udev_queue_export_cleanup(struct udev_queue_export *udev_queue_export);
int udev_queue_export_device_queued(struct udev_queue_export *udev_queue_export, struct udev_device *udev_device); int udev_queue_export_device_queued(struct udev_queue_export *udev_queue_export, struct udev_device *udev_device);
int udev_queue_export_device_finished(struct udev_queue_export *udev_queue_export, struct udev_device *udev_device); int udev_queue_export_device_finished(struct udev_queue_export *udev_queue_export, struct udev_device *udev_device);
int udev_queue_export_device_failed(struct udev_queue_export *udev_queue_export, struct udev_device *udev_device);
/* libudev-util.c */ /* libudev-util.c */
#define UTIL_PATH_SIZE 1024 #define UTIL_PATH_SIZE 1024

View File

@ -56,7 +56,6 @@ static int rebuild_queue_file(struct udev_queue_export *udev_queue_export);
struct udev_queue_export { struct udev_queue_export {
struct udev *udev; struct udev *udev;
int failed_count; /* number of failed events exported */
int queued_count; /* number of unfinished events exported in queue file */ int queued_count; /* number of unfinished events exported in queue file */
FILE *queue_file; FILE *queue_file;
unsigned long long int seqnum_max; /* earliest sequence number in queue file */ unsigned long long int seqnum_max; /* earliest sequence number in queue file */
@ -328,7 +327,6 @@ write_error:
enum device_state { enum device_state {
DEVICE_QUEUED, DEVICE_QUEUED,
DEVICE_FINISHED, DEVICE_FINISHED,
DEVICE_FAILED,
}; };
static inline size_t queue_record_size(size_t devpath_len) static inline size_t queue_record_size(size_t devpath_len)
@ -394,47 +392,9 @@ static int update_queue(struct udev_queue_export *udev_queue_export,
return err; return err;
} }
static void update_failed(struct udev_queue_export *udev_queue_export,
struct udev_device *udev_device, enum device_state state)
{
struct udev *udev = udev_device_get_udev(udev_device);
char filename[UTIL_PATH_SIZE];
if (state != DEVICE_FAILED && udev_queue_export->failed_count == 0)
return;
/* location of failed file */
util_strscpyl(filename, sizeof(filename), udev_get_run_path(udev), "/failed/",
udev_device_get_subsystem(udev_device), ":", udev_device_get_sysname(udev_device), NULL);
switch (state) {
case DEVICE_FAILED:
/* record event in the failed directory */
udev_queue_export->failed_count++;
util_create_path(udev, filename);
symlink(udev_device_get_devpath(udev_device), filename);
break;
case DEVICE_QUEUED:
/* delete failed file */
if (unlink(filename) == 0) {
util_delete_path(udev, filename);
udev_queue_export->failed_count--;
}
break;
case DEVICE_FINISHED:
break;
}
return;
}
static int update(struct udev_queue_export *udev_queue_export, static int update(struct udev_queue_export *udev_queue_export,
struct udev_device *udev_device, enum device_state state) struct udev_device *udev_device, enum device_state state)
{ {
update_failed(udev_queue_export, udev_device, state);
if (update_queue(udev_queue_export, udev_device, state) != 0) if (update_queue(udev_queue_export, udev_device, state) != 0)
return -1; return -1;
@ -450,8 +410,3 @@ int udev_queue_export_device_finished(struct udev_queue_export *udev_queue_expor
{ {
return update(udev_queue_export, udev_device, DEVICE_FINISHED); return update(udev_queue_export, udev_device, DEVICE_FINISHED);
} }
int udev_queue_export_device_failed(struct udev_queue_export *udev_queue_export, struct udev_device *udev_device)
{
return update(udev_queue_export, udev_device, DEVICE_FAILED);
}

View File

@ -43,7 +43,6 @@ struct udev_queue {
struct udev *udev; struct udev *udev;
int refcount; int refcount;
struct udev_list queue_list; struct udev_list queue_list;
struct udev_list failed_list;
}; };
/** /**
@ -68,7 +67,6 @@ UDEV_EXPORT struct udev_queue *udev_queue_new(struct udev *udev)
udev_queue->refcount = 1; udev_queue->refcount = 1;
udev_queue->udev = udev; udev_queue->udev = udev;
udev_list_init(udev, &udev_queue->queue_list, false); udev_list_init(udev, &udev_queue->queue_list, false);
udev_list_init(udev, &udev_queue->failed_list, false);
return udev_queue; return udev_queue;
} }
@ -103,7 +101,6 @@ UDEV_EXPORT void udev_queue_unref(struct udev_queue *udev_queue)
if (udev_queue->refcount > 0) if (udev_queue->refcount > 0)
return; return;
udev_list_cleanup(&udev_queue->queue_list); udev_list_cleanup(&udev_queue->queue_list);
udev_list_cleanup(&udev_queue->failed_list);
free(udev_queue); free(udev_queue);
} }
@ -469,47 +466,9 @@ UDEV_EXPORT struct udev_list_entry *udev_queue_get_queued_list_entry(struct udev
return udev_list_get_entry(&udev_queue->queue_list); return udev_list_get_entry(&udev_queue->queue_list);
} }
/** struct udev_list_entry *udev_queue_get_failed_list_entry(struct udev_queue *udev_queue);
* udev_queue_get_failed_list_entry:
* @udev_queue: udev queue context
*
* Returns: the first entry of the list of recorded failed events.
**/
UDEV_EXPORT struct udev_list_entry *udev_queue_get_failed_list_entry(struct udev_queue *udev_queue) UDEV_EXPORT struct udev_list_entry *udev_queue_get_failed_list_entry(struct udev_queue *udev_queue)
{ {
char path[UTIL_PATH_SIZE]; errno = ENOSYS;
DIR *dir; return NULL;
struct dirent *dent;
if (udev_queue == NULL)
return NULL;
udev_list_cleanup(&udev_queue->failed_list);
util_strscpyl(path, sizeof(path), udev_get_run_path(udev_queue->udev), "/failed", NULL);
dir = opendir(path);
if (dir == NULL)
return NULL;
for (dent = readdir(dir); dent != NULL; dent = readdir(dir)) {
char filename[UTIL_PATH_SIZE];
char syspath[UTIL_PATH_SIZE];
char *s;
size_t l;
ssize_t len;
struct stat statbuf;
if (dent->d_name[0] == '.')
continue;
s = syspath;
l = util_strpcpyl(&s, sizeof(syspath), udev_get_sys_path(udev_queue->udev), NULL);
len = readlinkat(dirfd(dir), dent->d_name, s, l);
if (len <= 0 || (size_t)len == l)
continue;
s[len] = '\0';
dbg(udev_queue->udev, "found '%s' [%s]\n", syspath, dent->d_name);
util_strscpyl(filename, sizeof(filename), syspath, "/uevent", NULL);
if (stat(filename, &statbuf) != 0)
continue;
udev_list_entry_add(&udev_queue->failed_list, syspath, NULL);
}
closedir(dir);
return udev_list_get_entry(&udev_queue->failed_list);
} }

View File

@ -173,7 +173,6 @@ int udev_queue_get_seqnum_is_finished(struct udev_queue *udev_queue, unsigned lo
int udev_queue_get_seqnum_sequence_is_finished(struct udev_queue *udev_queue, int udev_queue_get_seqnum_sequence_is_finished(struct udev_queue *udev_queue,
unsigned long long int start, unsigned long long int end); unsigned long long int start, unsigned long long int end);
struct udev_list_entry *udev_queue_get_queued_list_entry(struct udev_queue *udev_queue); struct udev_list_entry *udev_queue_get_queued_list_entry(struct udev_queue *udev_queue);
struct udev_list_entry *udev_queue_get_failed_list_entry(struct udev_queue *udev_queue);
#ifdef __cplusplus #ifdef __cplusplus
} /* extern "C" */ } /* extern "C" */

View File

@ -323,10 +323,6 @@ static int test_queue(struct udev *udev)
udev_list_entry_foreach(list_entry, udev_queue_get_queued_list_entry(udev_queue)) udev_list_entry_foreach(list_entry, udev_queue_get_queued_list_entry(udev_queue))
printf("queued: '%s' [%s]\n", udev_list_entry_get_name(list_entry), udev_list_entry_get_value(list_entry)); printf("queued: '%s' [%s]\n", udev_list_entry_get_name(list_entry), udev_list_entry_get_value(list_entry));
printf("\n"); printf("\n");
printf("get failed list\n");
udev_list_entry_foreach(list_entry, udev_queue_get_failed_list_entry(udev_queue))
printf("failed: '%s'\n", udev_list_entry_get_name(list_entry));
printf("\n");
list_entry = udev_queue_get_queued_list_entry(udev_queue); list_entry = udev_queue_get_queued_list_entry(udev_queue);
if (list_entry != NULL) { if (list_entry != NULL) {

View File

@ -14,7 +14,7 @@
# After creation and removal the result is checked against the # After creation and removal the result is checked against the
# expected value and the result is printed. # expected value and the result is printed.
# #
# Copyright (C) 2004-2008 Kay Sievers <kay.sievers@vrfy.org> # Copyright (C) 2004-2011 Kay Sievers <kay.sievers@vrfy.org>
# Copyright (C) 2004 Leann Ogasawara <ogasawara@osdl.org> # Copyright (C) 2004 Leann Ogasawara <ogasawara@osdl.org>
use warnings; use warnings;

View File

@ -198,7 +198,6 @@ struct token {
union { union {
unsigned int attr_off; unsigned int attr_off;
int devlink_unique; int devlink_unique;
int fail_on_error;
unsigned int rule_goto; unsigned int rule_goto;
mode_t mode; mode_t mode;
uid_t uid; uid_t uid;
@ -1066,7 +1065,6 @@ static int rule_add_key(struct rule_tmp *rule_tmp, enum token_type type,
break; break;
case TK_A_RUN: case TK_A_RUN:
token->key.value_off = add_string(rule_tmp->rules, value); token->key.value_off = add_string(rule_tmp->rules, value);
token->key.fail_on_error = *(int *)data;
break; break;
case TK_A_INOTIFY_WATCH: case TK_A_INOTIFY_WATCH:
case TK_A_DEVLINK_PRIO: case TK_A_DEVLINK_PRIO:
@ -1191,9 +1189,6 @@ static int add_rule(struct udev_rules *rules, char *line,
char *linepos; char *linepos;
char *attr; char *attr;
struct rule_tmp rule_tmp; struct rule_tmp rule_tmp;
bool bus_warn = false;
bool sysfs_warn = false;
bool id_warn = false;
memset(&rule_tmp, 0x00, sizeof(struct rule_tmp)); memset(&rule_tmp, 0x00, sizeof(struct rule_tmp));
rule_tmp.rules = rules; rule_tmp.rules = rules;
@ -1287,21 +1282,6 @@ static int add_rule(struct udev_rules *rules, char *line,
continue; continue;
} }
if (strcmp(key, "ID") == 0) {
if (!id_warn) {
id_warn = true;
err(rules->udev, "ID= will be removed in a future udev version, "
"please use KERNEL= to match the event device, or KERNELS= "
"to match a parent device, in %s:%u\n", filename, lineno);
}
if (op > OP_MATCH_MAX) {
err(rules->udev, "invalid KERNELS operation\n");
goto invalid;
}
rule_add_key(&rule_tmp, TK_M_KERNELS, op, value, NULL);
continue;
}
if (strcmp(key, "SUBSYSTEMS") == 0) { if (strcmp(key, "SUBSYSTEMS") == 0) {
if (op > OP_MATCH_MAX) { if (op > OP_MATCH_MAX) {
err(rules->udev, "invalid SUBSYSTEMS operation\n"); err(rules->udev, "invalid SUBSYSTEMS operation\n");
@ -1311,21 +1291,6 @@ static int add_rule(struct udev_rules *rules, char *line,
continue; continue;
} }
if (strcmp(key, "BUS") == 0) {
if (!bus_warn) {
bus_warn = true;
err(rules->udev, "BUS= will be removed in a future udev version, "
"please use SUBSYSTEM= to match the event device, or SUBSYSTEMS= "
"to match a parent device, in %s:%u\n", filename, lineno);
}
if (op > OP_MATCH_MAX) {
err(rules->udev, "invalid SUBSYSTEMS operation\n");
goto invalid;
}
rule_add_key(&rule_tmp, TK_M_SUBSYSTEMS, op, value, NULL);
continue;
}
if (strcmp(key, "DRIVERS") == 0) { if (strcmp(key, "DRIVERS") == 0) {
if (op > OP_MATCH_MAX) { if (op > OP_MATCH_MAX) {
err(rules->udev, "invalid DRIVERS operation\n"); err(rules->udev, "invalid DRIVERS operation\n");
@ -1364,26 +1329,6 @@ static int add_rule(struct udev_rules *rules, char *line,
continue; continue;
} }
if (strncmp(key, "SYSFS{", sizeof("SYSFS{")-1) == 0) {
if (!sysfs_warn) {
sysfs_warn = true;
err(rules->udev, "SYSFS{}= will be removed in a future udev version, "
"please use ATTR{}= to match the event device, or ATTRS{}= "
"to match a parent device, in %s:%u\n", filename, lineno);
}
if (op > OP_MATCH_MAX) {
err(rules->udev, "invalid ATTRS operation\n");
goto invalid;
}
attr = get_key_attribute(rules->udev, key + sizeof("ATTRS")-1);
if (attr == NULL) {
err(rules->udev, "error parsing ATTRS attribute\n");
goto invalid;
}
rule_add_key(&rule_tmp, TK_M_ATTRS, op, value, attr);
continue;
}
if (strncmp(key, "ENV{", sizeof("ENV{")-1) == 0) { if (strncmp(key, "ENV{", sizeof("ENV{")-1) == 0) {
attr = get_key_attribute(rules->udev, key + sizeof("ENV")-1); attr = get_key_attribute(rules->udev, key + sizeof("ENV")-1);
if (attr == NULL) { if (attr == NULL) {
@ -1509,13 +1454,8 @@ static int add_rule(struct udev_rules *rules, char *line,
continue; continue;
} }
if (strncmp(key, "RUN", sizeof("RUN")-1) == 0) { if (strcmp(key, "RUN") == 0) {
int flag = 0; rule_add_key(&rule_tmp, TK_A_RUN, op, value, NULL);
attr = get_key_attribute(rules->udev, key + sizeof("RUN")-1);
if (attr != NULL && strstr(attr, "fail_event_on_error"))
flag = 1;
rule_add_key(&rule_tmp, TK_A_RUN, op, value, &flag);
continue; continue;
} }
@ -2706,17 +2646,13 @@ int udev_rules_apply_to_event(struct udev_rules *rules, struct udev_event *event
break; break;
} }
case TK_A_RUN: { case TK_A_RUN: {
struct udev_list_entry *list_entry;
if (cur->key.op == OP_ASSIGN || cur->key.op == OP_ASSIGN_FINAL) if (cur->key.op == OP_ASSIGN || cur->key.op == OP_ASSIGN_FINAL)
udev_list_cleanup(&event->run_list); udev_list_cleanup(&event->run_list);
info(event->udev, "RUN '%s' %s:%u\n", info(event->udev, "RUN '%s' %s:%u\n",
&rules->buf[cur->key.value_off], &rules->buf[cur->key.value_off],
&rules->buf[rule->rule.filename_off], &rules->buf[rule->rule.filename_off],
rule->rule.filename_line); rule->rule.filename_line);
list_entry = udev_list_entry_add(&event->run_list, &rules->buf[cur->key.value_off], NULL); udev_list_entry_add(&event->run_list, &rules->buf[cur->key.value_off], NULL);
if (cur->key.fail_on_error)
udev_list_entry_set_num(list_entry, true);
break; break;
} }
case TK_A_GOTO: case TK_A_GOTO:

View File

@ -61,20 +61,6 @@ static void exec_list(struct udev_enumerate *udev_enumerate, const char *action)
} }
} }
static int scan_failed(struct udev_enumerate *udev_enumerate)
{
struct udev *udev = udev_enumerate_get_udev(udev_enumerate);
struct udev_queue *udev_queue;
struct udev_list_entry *list_entry;
udev_queue = udev_queue_new(udev);
if (udev_queue == NULL)
return -1;
udev_list_entry_foreach(list_entry, udev_queue_get_failed_list_entry(udev_queue))
udev_enumerate_add_syspath(udev_enumerate, udev_list_entry_get_name(list_entry));
return 0;
}
static const char *keyval(const char *str, const char **val, char *buf, size_t size) static const char *keyval(const char *str, const char **val, char *buf, size_t size)
{ {
char *pos; char *pos;
@ -110,7 +96,6 @@ static int adm_trigger(struct udev *udev, int argc, char *argv[])
enum { enum {
TYPE_DEVICES, TYPE_DEVICES,
TYPE_SUBSYSTEMS, TYPE_SUBSYSTEMS,
TYPE_FAILED,
} device_type = TYPE_DEVICES; } device_type = TYPE_DEVICES;
const char *action = "change"; const char *action = "change";
struct udev_enumerate *udev_enumerate; struct udev_enumerate *udev_enumerate;
@ -145,8 +130,6 @@ static int adm_trigger(struct udev *udev, int argc, char *argv[])
device_type = TYPE_DEVICES; device_type = TYPE_DEVICES;
} else if (strcmp(optarg, "subsystems") == 0) { } else if (strcmp(optarg, "subsystems") == 0) {
device_type = TYPE_SUBSYSTEMS; device_type = TYPE_SUBSYSTEMS;
} else if (strcmp(optarg, "failed") == 0) {
device_type = TYPE_FAILED;
} else { } else {
err(udev, "unknown type --type=%s\n", optarg); err(udev, "unknown type --type=%s\n", optarg);
rc = 2; rc = 2;
@ -208,8 +191,6 @@ static int adm_trigger(struct udev *udev, int argc, char *argv[])
" --type= type of events to trigger\n" " --type= type of events to trigger\n"
" devices sys devices (default)\n" " devices sys devices (default)\n"
" subsystems sys subsystems and drivers\n" " subsystems sys subsystems and drivers\n"
" failed trigger only the events which have been\n"
" marked as failed during a previous run\n"
" --action=<action> event action value, default is \"change\"\n" " --action=<action> event action value, default is \"change\"\n"
" --subsystem-match=<subsystem> trigger devices from a matching subsystem\n" " --subsystem-match=<subsystem> trigger devices from a matching subsystem\n"
" --subsystem-nomatch=<subsystem> exclude devices from a matching subsystem\n" " --subsystem-nomatch=<subsystem> exclude devices from a matching subsystem\n"
@ -228,11 +209,6 @@ static int adm_trigger(struct udev *udev, int argc, char *argv[])
} }
switch (device_type) { switch (device_type) {
case TYPE_FAILED:
err(udev, "--type=failed is deprecated and will be removed from a future udev release.\n");
scan_failed(udev_enumerate);
exec_list(udev_enumerate, action);
goto exit;
case TYPE_SUBSYSTEMS: case TYPE_SUBSYSTEMS:
udev_enumerate_scan_subsystems(udev_enumerate); udev_enumerate_scan_subsystems(udev_enumerate);
exec_list(udev_enumerate, action); exec_list(udev_enumerate, action);

View File

@ -155,11 +155,7 @@ static void event_queue_delete(struct event *event, bool export)
udev_list_node_remove(&event->node); udev_list_node_remove(&event->node);
if (export) { if (export) {
/* mark as failed, if "add" event returns non-zero */ udev_queue_export_device_finished(udev_queue_export, event->dev);
if (event->exitcode != 0 && strcmp(udev_device_get_action(event->dev), "remove") != 0)
udev_queue_export_device_failed(udev_queue_export, event->dev);
else
udev_queue_export_device_finished(udev_queue_export, event->dev);
info(event->udev, "seq %llu done with %i\n", udev_device_get_seqnum(event->dev), event->exitcode); info(event->udev, "seq %llu done with %i\n", udev_device_get_seqnum(event->dev), event->exitcode);
} }
udev_device_unref(event->dev); udev_device_unref(event->dev);
@ -284,7 +280,6 @@ static void worker_new(struct event *event)
for (;;) { for (;;) {
struct udev_event *udev_event; struct udev_event *udev_event;
struct worker_message msg; struct worker_message msg;
int failed = 0;
int err; int err;
info(udev, "seq %llu running\n", udev_device_get_seqnum(dev)); info(udev, "seq %llu running\n", udev_device_get_seqnum(dev));
@ -304,7 +299,7 @@ static void worker_new(struct event *event)
err = udev_event_execute_rules(udev_event, rules, &sigmask_orig); err = udev_event_execute_rules(udev_event, rules, &sigmask_orig);
if (err == 0) if (err == 0)
failed = udev_event_execute_run(udev_event, &sigmask_orig); udev_event_execute_run(udev_event, &sigmask_orig);
/* apply/restore inotify watch */ /* apply/restore inotify watch */
if (err == 0 && udev_event->inotify_watch) { if (err == 0 && udev_event->inotify_watch) {
@ -319,8 +314,6 @@ static void worker_new(struct event *event)
memset(&msg, 0, sizeof(struct worker_message)); memset(&msg, 0, sizeof(struct worker_message));
if (err != 0) if (err != 0)
msg.exitcode = err; msg.exitcode = err;
else if (failed != 0)
msg.exitcode = failed;
msg.pid = getpid(); msg.pid = getpid();
send(worker_watch[WRITE_END], &msg, sizeof(struct worker_message), 0); send(worker_watch[WRITE_END], &msg, sizeof(struct worker_message), 0);