From 6ed96211af9b166019e4795b3524849fb670d5fe Mon Sep 17 00:00:00 2001
From: Ruben Faelens <faelens@kth.se>
Date: Fri, 9 Mar 2018 10:30:40 +0100
Subject: [PATCH] Ignore SIGPIPE in send() and recv(), so RServe exits
 correctly when receiving EPIPE

This solution is intended to solve issue #100. The method is very similar
to what is being done in the internal R http server (see Rhttpd.c).
It should therefore not cause any issues in other parts of R.
---
 src/Rserv.c | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/src/Rserv.c b/src/Rserv.c
index f69f3cd..9d711de 100644
--- a/src/Rserv.c
+++ b/src/Rserv.c
@@ -3012,6 +3012,22 @@ extern char Rserve_oc_prefix;
 
 #define COMPUTE_OC_PREFIX '@'
 
+#ifdef FORKED
+extern int R_ignore_SIGPIPE; // see src/main/main.c::handlePipe in R
+int server_recv(args_t *arg, void *buf, rlen_t len) {
+	R_ignore_SIGPIPE = 1;
+	int result = recv(arg->s, buf, len, 0);
+	R_ignore_SIGPIPE = 0;
+	return result;
+}
+
+int server_send(args_t *arg, const void *buf, rlen_t len) {
+        R_ignore_SIGPIPE = 1;
+	int result = send(arg->s, buf, len, 0);
+        R_ignore_SIGPIPE = 0;
+	return result;
+}
+#else
 int server_recv(args_t *arg, void *buf, rlen_t len) {
 	return recv(arg->s, buf, len, 0);
 }
@@ -3019,6 +3035,7 @@ int server_recv(args_t *arg, void *buf, rlen_t len) {
 int server_send(args_t *arg, const void *buf, rlen_t len) {
 	return send(arg->s, buf, len, 0);
 }
+#endif
 
 SEXP Rserve_kill_compute(SEXP sSig) {
 	int sig = asInteger(sSig);