commit - e5792992e5d6e73bb379bbfcd69ae2e66afe359d
commit + 7fec5f4ad5baecf5bab9d872a925055270b2cf53
blob - 4e94e74827b4a318903802c2324b5b653b29e5bd
blob + 0d1b70abc84b7ffd073e85521770b144812ebcfe
--- gotd/gotd.c
+++ gotd/gotd.c
@@ -720,6 +720,7 @@ recv_packfile(struct gotd_client *client)
 	memset(&ipipe, 0, sizeof(ipipe));
 	ipipe.client_id = client->id;
 
+	/* Send pack pipe end 0 to repo_write. */
 	if (gotd_imsg_compose_event(&client->repo_write->iev,
 	    GOTD_IMSG_PACKFILE_PIPE, PROC_GOTD, pipe[0],
 	        &ipipe, sizeof(ipipe)) == -1) {
@@ -729,9 +730,9 @@ recv_packfile(struct gotd_client *client)
 	}
 	pipe[0] = -1;
 
-	if (gotd_imsg_compose_event(&client->repo_write->iev,
-	    GOTD_IMSG_PACKFILE_PIPE, PROC_GOTD, pipe[1],
-	        &ipipe, sizeof(ipipe)) == -1)
+	/* Send pack pipe end 1 to gotsh(1) (expects just an fd, no data). */
+	if (gotd_imsg_compose_event(&client->iev,
+	    GOTD_IMSG_PACKFILE_PIPE, PROC_GOTD, pipe[1], NULL, 0) == -1)
 		err = got_error_from_errno("imsg compose PACKFILE_PIPE");
 	pipe[1] = -1;
 
@@ -2041,7 +2042,7 @@ main(int argc, char **argv)
 		exit(0);
 	case PROC_REPO_WRITE:
 #ifndef PROFILE
-		if (pledge("stdio rpath sendfd recvfd", NULL) == -1)
+		if (pledge("stdio rpath recvfd", NULL) == -1)
 			err(1, "pledge");
 #endif
 		repo_write_main(title, pack_fds, temp_fds);
blob - abe192c382dbe1bb870697cc6a10af15525c2cdf
blob + d3eea29f69ea054358d900dc3bf36054a5252946
--- gotd/repo_write.c
+++ gotd/repo_write.c
@@ -82,7 +82,7 @@ struct repo_write_client {
 	STAILQ_ENTRY(repo_write_client)	 entry;
 	uint32_t			 id;
 	int				 fd;
-	int				 pack_pipe[2];
+	int				 pack_pipe;
 	struct got_pack			 pack;
 	uint8_t				 pack_sha1[SHA1_DIGEST_LENGTH];
 	int				 packidx_fd;
@@ -107,8 +107,7 @@ add_client(struct repo_write_client *client, uint32_t 
 
 	client->id = client_id;
 	client->fd = fd;
-	client->pack_pipe[0] = -1;
-	client->pack_pipe[1] = -1;
+	client->pack_pipe = -1;
 	client->packidx_fd = -1;
 	STAILQ_INIT(&client->ref_updates);
 	client->nref_updates = 0;
@@ -929,8 +928,7 @@ recv_packfile(struct repo_write_client **client, struc
 	if (*client == NULL || STAILQ_EMPTY(&(*client)->ref_updates))
 		return got_error(GOT_ERR_CLIENT_ID);
 
-	if ((*client)->pack_pipe[0] == -1 ||
-	    (*client)->pack_pipe[1] == -1 ||
+	if ((*client)->pack_pipe == -1 ||
 	    (*client)->packidx_fd == -1)
 		return got_error(GOT_ERR_PRIVSEP_NO_FD);
 
@@ -969,22 +967,13 @@ recv_packfile(struct repo_write_client **client, struc
 		tempfiles[i] = f;
 	}
 
-	/* Send pack file pipe to gotsh(1). */
-	if (imsg_compose(&ibuf, GOTD_IMSG_RECV_PACKFILE, PROC_REPO_WRITE,
-	    repo_write.pid, (*client)->pack_pipe[1], NULL, 0) == -1) {
-		(*client)->pack_pipe[1] = -1;
-		err = got_error_from_errno("imsg_compose ACK");
-		if (err)	
-			goto done;
-	}
-	(*client)->pack_pipe[1] = -1;
 	err = gotd_imsg_flush(&ibuf);
 	if (err)
 		goto done;
 
 	log_debug("receiving pack data");
 	unpack_err = recv_packdata(&pack_filesize, (*client)->pack_sha1,
-	    (*client)->pack_pipe[0], pack->fd);
+	    (*client)->pack_pipe, pack->fd);
 	if (ireq.report_status) {
 		err = report_pack_status(*client, unpack_err);
 		if (err) {
@@ -1018,9 +1007,9 @@ recv_packfile(struct repo_write_client **client, struc
 	if (lseek((*client)->packidx_fd, 0L, SEEK_SET) == -1)
 		err = got_error_from_errno("lseek");
 done:
-	if (close((*client)->pack_pipe[0]) == -1 && err == NULL)
+	if (close((*client)->pack_pipe) == -1 && err == NULL)
 		err = got_error_from_errno("close");
-	(*client)->pack_pipe[0] = -1;
+	(*client)->pack_pipe = -1;
 	for (i = 0; i < nitems(repo_tempfiles); i++) {
 		struct repo_tempfile *t = &repo_tempfiles[i];
 		if (t->idx != -1)
@@ -1192,7 +1181,7 @@ recv_disconnect(struct imsg *imsg)
 	const struct got_error *err = NULL;
 	struct gotd_imsg_disconnect idisconnect;
 	size_t datalen;
-	int client_fd = -1, pipe0 = -1, pipe1 = - 1, idxfd = -1;
+	int client_fd = -1, pack_pipe = -1, idxfd = -1;
 	struct repo_write_client *client = NULL;
 	uint64_t slot;
 
@@ -1219,15 +1208,12 @@ recv_disconnect(struct imsg *imsg)
 	}
 	err = got_pack_close(&client->pack);
 	client_fd = client->fd;
-	pipe0 = client->pack_pipe[0];
-	pipe1 = client->pack_pipe[1];
+	pack_pipe = client->pack_pipe;
 	idxfd = client->packidx_fd;
 	free(client);
 	if (client_fd != -1 && close(client_fd) == -1)
 		err = got_error_from_errno("close");
-	if (pipe0 != -1 && close(pipe0) == -1 && err == NULL)
-		err = got_error_from_errno("close");
-	if (pipe1 != -1 && close(pipe1) == -1 && err == NULL)
+	if (pack_pipe != -1 && close(pack_pipe) == -1 && err == NULL)
 		err = got_error_from_errno("close");
 	if (idxfd != -1 && close(idxfd) == -1 && err == NULL)
 		err = got_error_from_errno("close");
@@ -1254,14 +1240,10 @@ receive_pack_pipe(struct repo_write_client **client, s
 	*client = find_client(ireq.client_id);
 	if (*client == NULL)
 		return got_error(GOT_ERR_CLIENT_ID);
-	if ((*client)->pack_pipe[1] != -1)
+	if ((*client)->pack_pipe != -1)
 		return got_error(GOT_ERR_PRIVSEP_MSG);
 
-	if ((*client)->pack_pipe[0] == -1)
-		(*client)->pack_pipe[0] = imsg->fd;
-	else
-		(*client)->pack_pipe[1] = imsg->fd;
-
+	(*client)->pack_pipe = imsg->fd;
 	return NULL;
 }
 
blob - 87e9f9ab41e1449492b4a1ca2485a8fba48bfbee
blob + 07ef39056b1ae8681d10c81839b68eb97c9a1146
--- lib/serve.c
+++ lib/serve.c
@@ -1381,7 +1381,7 @@ serve_write(int infd, int outfd, int gotd_sock, const 
 		case GOTD_IMSG_ERROR:
 			err = gotd_imsg_recv_error(NULL, &imsg);
 			goto done;
-		case GOTD_IMSG_RECV_PACKFILE:
+		case GOTD_IMSG_PACKFILE_PIPE:
 			err = recv_packfile(&imsg, infd);
 			if (err) {
 				if (err->code != GOT_ERR_EOF)