natas_hw
/
paho
mirror of https://github.com/eclipse/paho.mqtt.c
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Alternative SIGPIPE handling #1346 #1386

This commit is contained in:
Ian Craggs 2025-01-04 17:25:06 +00:00
parent 91230623e5
commit be9e26257e
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/Socket.c
View File

@ -129,6 +129,22 @@ int Socket_error(char* aString, SOCKET sock)
return err;
}
#if !defined(_WIN32) && !defined(_WIN64)
void SIGPIPE_ignore()
{
#if defined(PAHO_IGNORE_WITH_SIGNAL)
if (signal(SIGPIPE, SIG_IGN) == SIG_ERR)
Log(LOG_ERROR, -1, "Failed to ignore SIG_PIPE, errno %d", errno);
#else
struct sigaction action;
if (sigaction(SIGPIPE, NULL, &action) != 0) /* get current action */
Log(LOG_ERROR, -1, "sigaction failed to get SIG_PIPE action8, errno %d", errno);
action.sa_handler = SIG_IGN;
if (sigaction(SIGPIPE, &action, NULL) != 0)
Log(LOG_ERROR, -1, "sigaction failed to ignore SIG_PIPE, errno %d", errno);
#endif
}
#endif
/**
* Initialize the socket module
@ -143,7 +159,7 @@ void Socket_outInitialize(void)
WSAStartup(winsockVer, &wsd);
#else
FUNC_ENTRY;
signal(SIGPIPE, SIG_IGN);
SIGPIPE_ignore();
#endif
SocketBuffer_initialize();