X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=udevsend.c;h=8cabe9039bcf061a708260511dd9bd8e4b18c424;hb=cfd0fc66054cb7eab4989d214e4f8552dc2bf0b8;hp=29d5bc155e969976ff004b5afeb70d7ba5e8944e;hpb=0b3dfb3d72e1df5f38ecb9669e37e5e77d958343;p=elogind.git

diff --git a/udevsend.c b/udevsend.c
index 29d5bc155..8cabe9039 100644
--- a/udevsend.c
+++ b/udevsend.c
@@ -54,52 +54,15 @@ void log_message (int priority, const char *format, ...)
 }
 #endif
 
-static int start_daemon(void)
-{
-	pid_t pid;
-	pid_t child_pid;
-	char *const argv[] = { "udevd", NULL };
-	char *const envp[] = { NULL };
-
-	pid = fork();
-	switch (pid) {
-	case 0:
-		/* helper child */
-		child_pid = fork();
-		switch (child_pid) {
-		case 0:
-			/* daemon with empty environment */
-			close(sock);
-			execve(UDEVD_BIN, argv, envp);
-			err("exec of daemon failed");
-			_exit(1);
-		case -1:
-			err("fork of daemon failed");
-			return -1;
-		default:
-			exit(0);
-		}
-		break;
-	case -1:
-		err("fork of helper failed");
-		return -1;
-	default:
-		waitpid(pid, NULL, 0);
-	}
-	return 0;
-}
-
 int main(int argc, char *argv[], char *envp[])
 {
 	static struct udevd_msg usend_msg;
 	int usend_msg_len;
 	int i;
-	int loop;
 	struct sockaddr_un saddr;
 	socklen_t addrlen;
 	int bufpos = 0;
-	int retval = 1;
-	int started_daemon = 0;
+	int retval = 0;
 	const char *subsystem = NULL;
 
 	logging_init("udevsend");
@@ -109,8 +72,9 @@ int main(int argc, char *argv[], char *envp[])
 	dbg("version %s", UDEV_VERSION);
 
 	sock = socket(AF_LOCAL, SOCK_DGRAM, 0);
-	if (sock == -1) {
-		err("error getting socket");
+	if (sock < 0) {
+		err("error getting socket: %s", strerror(errno));
+		retval = 1;
 		goto exit;
 	}
 
@@ -134,7 +98,8 @@ int main(int argc, char *argv[], char *envp[])
 
 		/* prevent loops in the scripts we execute */
 		if (strncmp(key, "UDEVD_EVENT=", 12) == 0) {
-			dbg("seems that the event source is not the kernel, just exit");
+			err("event loop, already passed through the daemon, exit");
+			retval = 2;
 			goto exit;
 		}
 
@@ -151,42 +116,13 @@ int main(int argc, char *argv[], char *envp[])
 		strcpy(&usend_msg.envbuf[bufpos], key);
 		bufpos += keylen + 1;
 	}
-	/* older kernels passed the SUBSYSTEM only as the first argument */
-	if (!subsystem && argc == 2) {
-		bufpos += sprintf(&usend_msg.envbuf[bufpos], "SUBSYSTEM=%s", argv[1]) + 1;
-		dbg("add 'SUBSYSTEM=%s' to env[%i] buffer from argv", argv[1], i);
-	}
 
 	usend_msg_len = offsetof(struct udevd_msg, envbuf) + bufpos;
 	dbg("usend_msg_len=%i", usend_msg_len);
 
-	/* If we can't send, try to start daemon and resend message */
-	loop = UDEVSEND_WAIT_MAX_SECONDS * UDEVSEND_WAIT_LOOP_PER_SECOND;
-	while (--loop) {
-		retval = sendto(sock, &usend_msg, usend_msg_len, 0, (struct sockaddr *)&saddr, addrlen);
-		if (retval != -1) {
-			retval = 0;
-			goto exit;
-		}
-
-		if (errno != ECONNREFUSED) {
-			err("error sending message (%s)", strerror(errno));
-			goto exit;
-		}
-
-		if (!started_daemon) {
-			info("try to start udevd daemon");
-			retval = start_daemon();
-			if (retval) {
-				dbg("error starting daemon");
-				goto exit;
-			}
-			dbg("udevd daemon started");
-			started_daemon = 1;
-		} else {
-			dbg("retry to connect %d", UDEVSEND_WAIT_MAX_SECONDS * UDEVSEND_WAIT_LOOP_PER_SECOND - loop);
-			usleep(1000 * 1000 / UDEVSEND_WAIT_LOOP_PER_SECOND);
-		}
+	if (sendto(sock, &usend_msg, usend_msg_len, 0, (struct sockaddr *)&saddr, addrlen) < 0) {
+		retval = 3;
+		err("error sending message: %s", strerror(errno));
 	}
 
 exit:
@@ -194,6 +130,5 @@ exit:
 		close(sock);
 
 	logging_close();
-
 	return retval;
 }