udevd: track exit status of event process

Signed-off-by: Kay Sievers <kay.sievers@suse.de>

diff --git a/udevd.c b/udevd.c
index 3fd3bfe6adbf61e67f95bf8173975469064836f6..b7b306131ee5e490f065a4d0a828e84bff8eeb15 100644 (file)
--- a/udevd.c
+++ b/udevd.c
@@ -122,13 +122,15 @@ static int udev_event_process(struct uevent_msg *msg)
                        if (strncmp(name_loop->name, "socket:", strlen("socket:")) == 0)
                                pass_env_to_socket(&name_loop->name[strlen("socket:")], msg->devpath, msg->action);
                        else
-                               run_program(name_loop->name, udev.subsystem, NULL, 0, NULL, (udev_log_priority >= LOG_INFO));
+                               if (run_program(name_loop->name, udev.subsystem, NULL, 0, NULL,
+                                               (udev_log_priority >= LOG_INFO)))
+                                       retval = -1;
                }
        }
 
        udev_cleanup_device(&udev);
 
-       return 0;
+       return retval;
 }
 
 static void msg_queue_delete(struct uevent_msg *msg)
@@ -140,6 +142,7 @@ static void msg_queue_delete(struct uevent_msg *msg)
 static void udev_event_run(struct uevent_msg *msg)
 {
        pid_t pid;
+       int retval;
 
        pid = fork();
        switch (pid) {
@@ -155,10 +158,12 @@ static void udev_event_run(struct uevent_msg *msg)
 
                logging_init("udevd-event");
                setpriority(PRIO_PROCESS, 0, UDEV_PRIORITY);
-               udev_event_process(msg);
+               retval = udev_event_process(msg);
                info("seq %llu finished", msg->seqnum);
 
                logging_close();
+               if (retval)
+                       exit(1);
                exit(0);
        case -1:
                err("fork of child failed: %s", strerror(errno));
@@ -427,7 +432,7 @@ static struct uevent_msg *get_msg_from_envbuf(const char *buf, int buf_size)
        msg->envp[i] = NULL;
 
        if (!msg->devpath) {
-               info("DEVPATH missing, ingnore message");
+               info("DEVPATH missing, ignore message");
                free(msg);
                return NULL;
        }
@@ -597,14 +602,16 @@ static void asmlinkage sig_handler(int signum)
        write(signal_pipe[WRITE_END], "", 1);
 }
 
-static void udev_done(int pid)
+static void udev_done(int pid, int exitstatus)
 {
        /* find msg associated with pid and delete it */
        struct uevent_msg *msg;
 
        list_for_each_entry(msg, &running_list, node) {
                if (msg->pid == pid) {
-                       info("seq %llu, pid [%d] exit, %ld seconds old", msg->seqnum, msg->pid, time(NULL) - msg->queue_time);
+                       info("seq %llu, pid [%d] exit with %i, %ld seconds old", msg->seqnum, msg->pid,
+                            exitstatus, time(NULL) - msg->queue_time);
+                       msg->exitstatus = exitstatus;
                        msg_queue_delete(msg);
 
                        /* there may be events waiting with the same devpath */
@@ -617,12 +624,17 @@ static void udev_done(int pid)
 static void reap_sigchilds(void)
 {
        pid_t pid;
+       int status;
 
        while (1) {
-               pid = waitpid(-1, NULL, WNOHANG);
+               pid = waitpid(-1, &status, WNOHANG);
                if (pid <= 0)
                        break;
-               udev_done(pid);
+               if (WIFEXITED(status))
+                       status = WEXITSTATUS(status);
+               else
+                       status = 0;
+               udev_done(pid, status);
        }
 }
 

diff --git a/udevd.h b/udevd.h
index 91c8e6503d392100cebef2052aa5a62883aa03d2..4040942ac9a5af59dca1da5a2a2de832a9f939b9 100644 (file)
--- a/udevd.h
+++ b/udevd.h
@@ -61,6 +61,7 @@ struct uevent_msg {
        enum udevd_msg_type type;
        struct list_head node;
        pid_t pid;
+       int exitstatus;
        time_t queue_time;
        char *action;
        char *devpath;