2 files changed, 17 insertions, 22 deletions

diff --git a/main.c b/main.c
index f148250..1b50dd6 100644
--- a/main.c
+++ b/main.c
@@ -567,8 +567,8 @@ static bool run_key_handler(const char *key, unsigned int mask)
 	if (pfd.writefd < 0)
 		return false;
 	if ((pfs = fdopen(pfd.writefd, "w")) == NULL) {
-		close(pfd.writefd);
 		error(0, errno, "open pipe");
+		close(pfd.writefd);
 		return false;
 	}
 
diff --git a/util.c b/util.c
index e9c899b..c207e60 100644
--- a/util.c
+++ b/util.c
@@ -233,8 +233,7 @@ spawn_t spawn(const char *cmd, char *const argv[], unsigned int flags)
 {
 	pid_t pid;
 	spawn_t status = { -1, -1, -1 };
-	int pfd_read[2] = { -1, -1 };
-	int pfd_write[2] = { -1, -1 };
+	int pfd_read[2] = { -1, -1 }, pfd_write[2] = { -1, -1 };
 	const bool r = flags & X_READ;
 	const bool w = flags & X_WRITE;
 
@@ -247,16 +246,18 @@ spawn_t spawn(const char *cmd, char *const argv[], unsigned int flags)
 	}
 
 	if (w && pipe(pfd_write) < 0) {
+		error(0, errno, "pipe: %s", cmd);
 		if (r) {
 			close(pfd_read[0]);
 			close(pfd_read[1]);
 		}
-		error(0, errno, "pipe: %s", cmd);
 		return status;
 	}
 
-	if ((pid = fork()) == 0) {
-		bool err = (r && dup2(pfd_read[1], 1) < 0) || (w && dup2(pfd_write[0], 0) < 0);
+	if ((pid = fork()) == 0) { /* in child */
+		if ((r && dup2(pfd_read[1], 1) < 0) || (w && dup2(pfd_write[0], 0) < 0))
+			error(EXIT_FAILURE, errno, "dup2: %s", cmd);
+
 		if (r) {
 			close(pfd_read[0]);
 			close(pfd_read[1]);
@@ -265,29 +266,23 @@ spawn_t spawn(const char *cmd, char *const argv[], unsigned int flags)
 			close(pfd_write[0]);
 			close(pfd_write[1]);
 		}
-
-		if (err)
-			error(EXIT_FAILURE, errno, "dup2: %s", cmd);
 		execv(cmd, argv);
 		error(EXIT_FAILURE, errno, "exec: %s", cmd);
-	}
-
-	if (r)
-		close(pfd_read[1]);
-	if (w)
-		close(pfd_write[0]);
-
-	if (pid < 0) {
+	} else if (pid < 0) { /* fork failed */
+		error(0, errno, "fork: %s", cmd);
 		if (r)
 			close(pfd_read[0]);
 		if (w)
 			close(pfd_write[1]);
-		error(0, errno, "fork: %s", cmd);
-		return status;
+	} else { /* in parent */
+		status.pid = pid;
+		status.readfd = pfd_read[0];
+		status.writefd = pfd_write[1];
 	}
 
-	status.pid = pid;
-	status.readfd = pfd_read[0];
-	status.writefd = pfd_write[1];
+	if (r)
+		close(pfd_read[1]);
+	if (w)
+		close(pfd_write[0]);
 	return status;
 }