signals already configured by posix

nanomsg · Dec 26, 2023 · b8a08ce · b8a08ce
1 parent b6d8f8b
commit b8a08ce
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/src/platform/posix/posix_socketpair.c b/src/platform/posix/posix_socketpair.c
@@ -26,6 +26,12 @@ nni_socket_pair(int *fds)
 		return (nni_plat_errno(errno));
 	}
 
+#ifdef SO_NOSIGPIPE
+	int set = 1;
+	setsockopt(fds[0], SOL_SOCKET, SO_NOSIGPIPE, (void *)&set, sizeof(int));
+	setsockopt(fds[1], SOL_SOCKET, SO_NOSIGPIPE, (void *)&set, sizeof(int));
+#endif
+
 	return (0);
 }
 #else

diff --git a/src/sp/transport/fdconn/fdc_test.c b/src/sp/transport/fdconn/fdc_test.c
@@ -52,7 +52,6 @@ test_fdc_accept(void)
 
 	NUTS_PASS(nng_socket_pair(fds));
 	// make sure we won't have to deal with SIGPIPE - EPIPE is better
-	signal(SIGPIPE, SIG_IGN);
 	NUTS_OPEN(s1);
 	NUTS_OPEN(s2);
 	NUTS_PASS(nng_listener_create(&l, s1, "fdconn://"));
@@ -72,8 +71,6 @@ test_fdc_exchange(void)
 	int fds[2];
 
 	NUTS_PASS(nng_socket_pair(fds));
-	// make sure we won't have to deal with SIGPIPE - EPIPE is better
-	signal(SIGPIPE, SIG_IGN);
 	NUTS_OPEN(s1);
 	NUTS_OPEN(s2);
 	NUTS_PASS(nng_listener_create(&l1, s1, "fdconn://"));
@@ -105,6 +102,7 @@ test_fdc_recv_max(void)
 	size_t       sz;
 	int fds[2];
 
+
 	NUTS_PASS(nng_socket_pair(fds));
 
 	NUTS_OPEN(s0);