diff options
author | Runxi Yu <me@runxiyu.org> | 2025-02-18 08:33:32 +0800 |
---|---|---|
committer | Runxi Yu <me@runxiyu.org> | 2025-02-18 08:33:32 +0800 |
commit | 7b08b7b712c51a99e1b76483c4c202488d987da4 (patch) | |
tree | b6d159aea98f1858d0f4271fa4c9c54cd74eff62 /git_hooks_client | |
parent | repo_index.html: Move the repo description before the clone URLs (diff) | |
download | forge-7b08b7b712c51a99e1b76483c4c202488d987da4.tar.gz forge-7b08b7b712c51a99e1b76483c4c202488d987da4.tar.zst forge-7b08b7b712c51a99e1b76483c4c202488d987da4.zip |
hooks: Fix the race condition that causes EPIPE
The hooks handler in the main daemon didn't wait for the hook client to
write fully, and sometimes prematurely closes the connection, causing
the hook client's splice to return EPIPE (or SIGPIPE if the signal
handler wasn't installed).
To remedy this, we call shutdown(sock, SHUT_WR) in the client, so that
attempts to read on the server side return EOF. Then we can simply use
io.Copy(&buf, conn) on the server side to fetch all of the data into a
buffer.
Diffstat (limited to '')
-rw-r--r-- | git_hooks_client/git_hooks_client.c | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/git_hooks_client/git_hooks_client.c b/git_hooks_client/git_hooks_client.c index e00ab3a..6471aa8 100644 --- a/git_hooks_client/git_hooks_client.c +++ b/git_hooks_client/git_hooks_client.c @@ -163,6 +163,16 @@ int main(int argc, char *argv[]) { } /* + * The sending part of the UNIX socket should be shut down, to let + * io.Copy on the Go side return. + */ + if (shutdown(sock, SHUT_WR) == -1) { + perror("shutdown internal socket"); + close(sock); + return EXIT_FAILURE; + } + + /* * The first byte of the response from the UNIX domain socket is the * status code. We read it and record it as our return value. */ |