mirror/RetroArch
1
0
Fork 0
mirror of https://github.com/libretro/RetroArch synced 2025-04-10 06:44:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

netplay_buf should use O_NOSIGNAL to avoid SIGPIPE

Browse Source
This commit is contained in:
Gregor Richards 2017-01-15 10:59:25 -05:00
parent 1a12381bfc
commit e9e7878b5c
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
network/netplay/netplay_buf.c
View File

@ -186,14 +186,14 @@ bool netplay_send_flush(struct socket_buffer *sbuf, int sockfd, bool block)
/* Usual case: Everything's in order */ /* Usual case: Everything's in order */
if (block) if (block)
{ {
if (!socket_send_all_blocking(sockfd, sbuf->data + sbuf->start, buf_used(sbuf), false)) if (!socket_send_all_blocking(sockfd, sbuf->data + sbuf->start, buf_used(sbuf), true))
return false; return false;
sbuf->start = sbuf->end = 0; sbuf->start = sbuf->end = 0;
} }
else else
{ {
sent = socket_send_all_nonblocking(sockfd, sbuf->data + sbuf->start, buf_used(sbuf), false); sent = socket_send_all_nonblocking(sockfd, sbuf->data + sbuf->start, buf_used(sbuf), true);
if (sent < 0) if (sent < 0)
return false; return false;
sbuf->start += sent; sbuf->start += sent;
@ -209,7 +209,7 @@ bool netplay_send_flush(struct socket_buffer *sbuf, int sockfd, bool block)
/* Unusual case: Buffer overlaps break */ /* Unusual case: Buffer overlaps break */
if (block) if (block)
{ {
if (!socket_send_all_blocking(sockfd, sbuf->data + sbuf->start, sbuf->bufsz - sbuf->start, false)) if (!socket_send_all_blocking(sockfd, sbuf->data + sbuf->start, sbuf->bufsz - sbuf->start, true))
return false; return false;
sbuf->start = 0; sbuf->start = 0;
return netplay_send_flush(sbuf, sockfd, true); return netplay_send_flush(sbuf, sockfd, true);
@ -217,7 +217,7 @@ bool netplay_send_flush(struct socket_buffer *sbuf, int sockfd, bool block)
} }
else else
{ {
sent = socket_send_all_nonblocking(sockfd, sbuf->data + sbuf->start, sbuf->bufsz - sbuf->start, false); sent = socket_send_all_nonblocking(sockfd, sbuf->data + sbuf->start, sbuf->bufsz - sbuf->start, true);
if (sent < 0) if (sent < 0)
return false; return false;
sbuf->start += sent; sbuf->start += sent;