X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=udevd.c;h=e227a64d71de32ee82a29f85ed6def978e33709f;hb=5bd4c5d72aa69c8d0b722630fd88e29c4a42662a;hp=d26d53fe0b79d8b9fb61f97e61d186d85ee9d0d8;hpb=f1ff8d7b4ad1f95385d42c3fa1b2a997b9e6d5f5;p=elogind.git

diff --git a/udevd.c b/udevd.c
index d26d53fe0..e227a64d7 100644
--- a/udevd.c
+++ b/udevd.c
@@ -58,7 +58,6 @@ static pid_t sid;
 static int signal_pipe[2] = {-1, -1};
 static volatile int sigchilds_waiting;
 static volatile int run_msg_q;
-static volatile int sig_flag;
 static volatile int udev_exit;
 static int init_phase = 1;
 static int run_exec_q;
@@ -132,15 +131,6 @@ static void msg_queue_insert(struct uevent_msg *msg)
 			init_phase = 0;
 	}
 
-	/* don't delay messages with timeout set */
-	if (msg->timeout) {
-		info("seq %llu with timeout %u seconds will be execute without queuing, '%s' '%s'",
-		     msg->seqnum, msg->timeout, msg->action, msg->devpath);
-		list_add(&msg->node, &exec_list);
-		run_exec_q = 1;
-		return;
-	}
-
 	/* sort message by sequence number into list */
 	list_for_each_entry_reverse(loop_msg, &msg_list, node) {
 		if (loop_msg->seqnum < msg->seqnum)
@@ -205,7 +195,7 @@ static int running_processes(void)
 	if (f == -1)
 		return -1;
 
-	len = read(f, buf, sizeof(buf));
+	len = read(f, buf, sizeof(buf)-1);
 	close(f);
 
 	if (len <= 0)
@@ -254,7 +244,7 @@ static int running_processes_in_session(pid_t session, int limit)
 		if (f == -1)
 			continue;
 
-		len = read(f, line, sizeof(line));
+		len = read(f, line, sizeof(line)-1);
 		close(f);
 
 		if (len <= 0)
@@ -440,7 +430,7 @@ recheck:
 	/* set timeout for remaining queued events */
 	if (!list_empty(&msg_list)) {
 		struct itimerval itv = {{0, 0}, {timeout - msg_age, 0}};
-		dbg("next event expires in %li seconds", timeout - msg_age);
+		info("next event expires in %li seconds", timeout - msg_age);
 		setitimer(ITIMER_REAL, &itv, NULL);
 	}
 }
@@ -523,31 +513,31 @@ static struct uevent_msg *get_udevd_msg(void)
 	size = recvmsg(udevd_sock, &smsg, 0);
 	if (size <  0) {
 		if (errno != EINTR)
-			dbg("unable to receive udevd message");
+			err("unable to receive udevd message");
 		return NULL;
 	}
 	cmsg = CMSG_FIRSTHDR(&smsg);
 	cred = (struct ucred *) CMSG_DATA(cmsg);
 
 	if (cmsg == NULL || cmsg->cmsg_type != SCM_CREDENTIALS) {
-		info("no sender credentials received, message ignored");
+		err("no sender credentials received, message ignored");
 		return NULL;
 	}
 
 	if (cred->uid != 0) {
-		info("sender uid=%i, message ignored", cred->uid);
+		err("sender uid=%i, message ignored", cred->uid);
 		return NULL;
 	}
 
 	if (strncmp(usend_msg.magic, UDEV_MAGIC, sizeof(UDEV_MAGIC)) != 0 ) {
-		info("message magic '%s' doesn't match, ignore it", usend_msg.magic);
+		err("message magic '%s' doesn't match, ignore it", usend_msg.magic);
 		return NULL;
 	}
 
 	switch (usend_msg.type) {
 	case UDEVD_UEVENT_UDEVSEND:
 	case UDEVD_UEVENT_INITSEND:
-		dbg("udevd event message received");
+		info("udevd event message received");
 		envbuf_size = size - offsetof(struct udevd_msg, envbuf);
 		dbg("envbuf_size=%i", envbuf_size);
 		msg = get_msg_from_envbuf(usend_msg.envbuf, envbuf_size);
@@ -594,7 +584,7 @@ static struct uevent_msg *get_netlink_msg(void)
 	size = recv(uevent_netlink_sock, &buffer, sizeof(buffer), 0);
 	if (size <  0) {
 		if (errno != EINTR)
-			dbg("unable to receive udevd message");
+			err("unable to receive udevd message");
 		return NULL;
 	}
 
@@ -613,20 +603,20 @@ static struct uevent_msg *get_netlink_msg(void)
 	/* validate message */
 	pos = strchr(buffer, '@');
 	if (pos == NULL) {
-		dbg("invalid uevent '%s'", buffer);
+		err("invalid uevent '%s'", buffer);
 		free(msg);
 		return NULL;
 	}
 	pos[0] = '\0';
 
 	if (msg->action == NULL) {
-		dbg("no ACTION in payload found, skip event '%s'", buffer);
+		err("no ACTION in payload found, skip event '%s'", buffer);
 		free(msg);
 		return NULL;
 	}
 
 	if (strcmp(msg->action, buffer) != 0) {
-		dbg("ACTION in payload does not match uevent, skip event '%s'", buffer);
+		err("ACTION in payload does not match uevent, skip event '%s'", buffer);
 		free(msg);
 		return NULL;
 	}
@@ -636,8 +626,6 @@ static struct uevent_msg *get_netlink_msg(void)
 
 static void asmlinkage sig_handler(int signum)
 {
-	int rc;
-
 	switch (signum) {
 		case SIGINT:
 		case SIGTERM:
@@ -653,14 +641,8 @@ static void asmlinkage sig_handler(int signum)
 			break;
 	}
 
-	/* if pipe is empty, write to pipe to force select to return,
-	 * which will wakeup our mainloop
-	 */
-	if (!sig_flag) {
-		rc = write(signal_pipe[1], &signum, sizeof(signum));
-		if (rc >= 0)
-			sig_flag = 1;
-	}
+	/* write to pipe, which will wakeup select() in our mainloop */
+	write(signal_pipe[WRITE_END], "", 1);
 }
 
 static void udev_done(int pid)
@@ -672,7 +654,10 @@ static void udev_done(int pid)
 	list_for_each_entry(msg, &running_list, node) {
 		if (msg->pid == pid) {
 			sysinfo(&info);
-			info("seq %llu exit, %ld seconds old", msg->seqnum, info.uptime - msg->queue_time);
+			if (msg->queue_time)
+				info("seq %llu, pid [%d] exit, %ld seconds old", msg->seqnum, msg->pid, info.uptime - msg->queue_time);
+			else
+				info("seq 0, pid [%d] exit", msg->pid);
 			msg_queue_delete(msg);
 
 			/* we want to run the exec queue manager since there may
@@ -747,7 +732,7 @@ static int init_uevent_netlink_sock(void)
 
 	uevent_netlink_sock = socket(PF_NETLINK, SOCK_DGRAM, NETLINK_KOBJECT_UEVENT);
 	if (uevent_netlink_sock == -1) {
-		dbg("error getting socket, %s", strerror(errno));
+		err("error getting socket, %s", strerror(errno));
 		return -1;
 	}
 
@@ -757,7 +742,7 @@ static int init_uevent_netlink_sock(void)
 	retval = bind(uevent_netlink_sock, (struct sockaddr *) &snl,
 		      sizeof(struct sockaddr_nl));
 	if (retval < 0) {
-		dbg("bind failed, %s", strerror(errno));
+		err("bind failed, %s", strerror(errno));
 		close(uevent_netlink_sock);
 		uevent_netlink_sock = -1;
 		return -1;
@@ -952,11 +937,10 @@ int main(int argc, char *argv[], char *envp[])
 			if (msg) {
 				/* discard kernel messages if netlink is active */
 				if (uevent_netlink_active && msg->type == UDEVD_UEVENT_UDEVSEND && msg->seqnum != 0) {
-					dbg("skip uevent_helper message, netlink is active");
+					info("skip uevent_helper message with SEQNUM, netlink is active");
 					free(msg);
-					continue;
-				}
-				msg_queue_insert(msg);
+				} else
+					msg_queue_insert(msg);
 			}
 		}
 
@@ -974,16 +958,10 @@ int main(int argc, char *argv[], char *envp[])
 		}
 
 		/* received a signal, clear our notification pipe */
-		if (FD_ISSET(signal_pipe[0], &readfds)) {
-			int sig;
-			ssize_t rlen;
-
-			while(1) {
-				rlen = read(signal_pipe[0], &sig, sizeof(sig));
-				if (rlen <= 0)
-					break;
-			}
-			sig_flag = 0;
+		if (FD_ISSET(signal_pipe[READ_END], &readfds)) {
+			char buf[256];
+
+			read(signal_pipe[READ_END], &buf, sizeof(buf));
 		}
 
 		/* forked child have returned */