seedlingattempt/godot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #111114 from bruvzg/sigpipe_ign

Browse Source 
Suppress SIGPIPE when writing to a pipe.
This commit is contained in:
Thaddeus Crews
2025-11-25 09:52:27 -06:00
parent 4dbac6eaea 3245230a40
commit 0da802cdd7
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
drivers/unix/file_access_unix_pipe.cpp
View File

@ -41,6 +41,11 @@
#include <sys/types.h> #include <sys/types.h>
#include <unistd.h> #include <unistd.h>
#include <cerrno> #include <cerrno>
#include <csignal>
#ifndef sighandler_t
typedef typeof(void(int)) *sighandler_t;
#endif
Error FileAccessUnixPipe::open_existing(int p_rfd, int p_wfd, bool p_blocking) { Error FileAccessUnixPipe::open_existing(int p_rfd, int p_wfd, bool p_blocking) {
// Open pipe using handles created by pipe(fd) call in the OS.execute_with_pipe. // Open pipe using handles created by pipe(fd) call in the OS.execute_with_pipe.
@ -165,7 +170,11 @@ bool FileAccessUnixPipe::store_buffer(const uint8_t *p_src, uint64_t p_length) {
ERR_FAIL_COND_V_MSG(fd[1] < 0, false, "Pipe must be opened before use."); ERR_FAIL_COND_V_MSG(fd[1] < 0, false, "Pipe must be opened before use.");
ERR_FAIL_COND_V(!p_src && p_length > 0, false); ERR_FAIL_COND_V(!p_src && p_length > 0, false);
if (::write(fd[1], p_src, p_length) != (ssize_t)p_length) { sighandler_t sig_pipe = signal(SIGPIPE, SIG_IGN);
ssize_t ret = ::write(fd[1], p_src, p_length);
signal(SIGPIPE, sig_pipe);
if (ret != (ssize_t)p_length) {
last_error = ERR_FILE_CANT_WRITE; last_error = ERR_FILE_CANT_WRITE;
return false; return false;
} else { } else {