X-Git-Url: https://git.archive.openwrt.org/?p=project%2Fprocd.git;a=blobdiff_plain;f=hotplug.c;h=21efcf573cc3de3cb050553a733f54087bea102a;hp=ac54da4a3f3a05ab9c8448a4666a47a768ba00ac;hb=ba0cb9c1ecc72e6b726deaf91193d24b2a85814a;hpb=8e728e62d2c7875dc9291797bff8e19a7340405f

diff --git a/hotplug.c b/hotplug.c
index ac54da4..21efcf5 100644
--- a/hotplug.c
+++ b/hotplug.c
@@ -66,8 +66,21 @@ static char *hotplug_msg_find_var(struct blob_attr *msg, const char *name)
 	return NULL;
 }
 
+static void mkdir_p(char *dir)
+{
+	char *l = strrchr(dir, '/');
+
+	if (l) {
+		*l = '\0';
+		mkdir_p(dir);
+		*l = '/';
+		mkdir(dir, 0755);
+	}
+}
+
 static void handle_makedev(struct blob_attr *msg, struct blob_attr *data)
 {
+	unsigned int oldumask = umask(0);
 	static struct blobmsg_policy mkdev_policy[2] = {
 		{ .type = BLOBMSG_TYPE_STRING },
 		{ .type = BLOBMSG_TYPE_STRING },
@@ -80,12 +93,19 @@ static void handle_makedev(struct blob_attr *msg, struct blob_attr *data)
 	blobmsg_parse_array(mkdev_policy, 2, tb, blobmsg_data(data), blobmsg_data_len(data));
 	if (tb[0] && tb[1] && minor && major && subsystem) {
 		mode_t m = S_IFCHR;
+		char *d = strdup(blobmsg_get_string(tb[0]));
+
+		d = dirname(d);
+		mkdir_p(d);
+		free(d);
+
 		if (!strcmp(subsystem, "block"))
 			m = S_IFBLK;
 		mknod(blobmsg_get_string(tb[0]),
 				m | strtoul(blobmsg_data(tb[1]), NULL, 8),
 				makedev(atoi(major), atoi(minor)));
 	}
+	umask(oldumask);
 }
 
 static void handle_rm(struct blob_attr *msg, struct blob_attr *data)
@@ -434,3 +454,9 @@ void hotplug(char *rules)
 	queue_proc.cb = queue_proc_cb;
 	uloop_fd_add(&hotplug_fd, ULOOP_READ);
 }
+
+void hotplug_shutdown(void)
+{
+	uloop_fd_delete(&hotplug_fd);
+	close(hotplug_fd.fd);
+}