more portable way to switch socket to nonblock mode

Author: kelvich

contrib/mmts/arbiter.c

@@ -16,6 +16,7 @@
 #include <errno.h>
 #include <netdb.h>
 #include <time.h>
+#include <fcntl.h>
 
 #include "postgres.h"
 #include "fmgr.h"
@@ -380,10 +381,11 @@ static int MtmConnectSocket(char const* host, int port, int max_attempts)
     while (1) {
 		int rc = -1;
 
-		sd = socket(AF_INET, SOCK_STREAM|SOCK_NONBLOCK, 0);
+		sd = socket(AF_INET, SOCK_STREAM, 0);
 		if (sd < 0) {
 			elog(ERROR, "Arbiter failed to create socket: %d", errno);
 		}
+		fcntl(sd, F_SETFL, O_NONBLOCK);
 		busy_socket = sd;
 		for (i = 0; i < n_addrs; ++i) {
 			memcpy(&sock_inet.sin_addr, &addrs[i], sizeof sock_inet.sin_addr);

contrib/raftable/raftable.c

@@ -28,6 +28,7 @@
 #include <arpa/inet.h>
 
 #include <unistd.h>
+#include <fcntl.h>
 #include <time.h>
 
 void _PG_init(void);
@@ -194,12 +195,13 @@ static bool connect_leader(timeout_t *timeout)
 	{
 		int one = 1;
 
-		sd = socket(a->ai_family, SOCK_STREAM | SOCK_NONBLOCK, 0);
+		sd = socket(a->ai_family, SOCK_STREAM, 0);
 		if (sd == -1)
 		{
 			elog(WARNING, "failed to create a socket: %s", strerror(errno));
 			continue;
 		}
+		fcntl(sd, F_SETFL, O_NONBLOCK);
 		setsockopt(sd, IPPROTO_TCP, TCP_NODELAY, &one, sizeof(one));
 
 		if (connect(sd, a->ai_addr, a->ai_addrlen) == -1)