windows compatibility ultimate pack

Author: kelvich

Makefile

@@ -1,7 +1,7 @@
 
 EXTENSION = multimaster
 DATA = multimaster--1.0.sql
-OBJS = multimaster.o arbiter.o bytebuf.o bgwpool.o pglogical_output.o pglogical_proto.o pglogical_receiver.o pglogical_apply.o pglogical_hooks.o pglogical_config.o pglogical_relid_map.o ddd.o bkb.o spill.o referee.o state.o
+OBJS = multimaster.o arbiter.o bytebuf.o bgwpool.o pglogical_output.o pglogical_proto.o pglogical_receiver.o pglogical_apply.o pglogical_hooks.o pglogical_config.o pglogical_relid_map.o ddd.o bkb.o spill.o state.o
 MODULE_big = multimaster
 
 PG_CPPFLAGS = -I$(libpq_srcdir)

arbiter.c

@@ -5,12 +5,20 @@
  *
  */
 
+
+#ifdef WIN32
+#include <winsock2.h>
+#include <ws2tcpip.h>
+#endif
+
 #include <unistd.h>
 #include <sys/time.h>
 #include <sys/types.h>
 #include <sys/socket.h>
 #include <netinet/in.h>
+#ifdef HAVE_NETINET_TCP_H
 #include <netinet/tcp.h>
+#endif
 #include <arpa/inet.h>
 #include <errno.h>
 #include <netdb.h>
@@ -70,7 +78,7 @@
 
 #if USE_EPOLL
 #include <sys/epoll.h>
-#else
+#elif HAVE_SYS_SELECT_H
 #include <sys/select.h>
 #endif
 
@@ -461,8 +469,7 @@ static int MtmConnectSocket(int node, int port)
 		MTM_ELOG(LOG, "Arbiter failed to create socket: %s", strerror(errno));
 		goto Error;
 	}
-	rc = pg_fcntl(sd, F_SETFL, O_NONBLOCK, MtmUseRDMA);
-	if (rc < 0) {
+	if (pg_set_noblock(sd, MtmUseRDMA)) {
 		MTM_ELOG(LOG, "Arbiter failed to switch socket to non-blocking mode: %s", strerror(errno));
 		goto Error;
 	}
@@ -630,8 +637,8 @@ static void MtmAcceptOneConnection()
 	} else { 	
 		MtmHandshakeMessage req;
 		MtmArbiterMessage resp;		
-		int rc = pg_fcntl(fd, F_SETFL, O_NONBLOCK, MtmUseRDMA);
-		if (rc < 0) {
+		int rc;
+		if (pg_set_noblock(fd,MtmUseRDMA)) {
 			MTM_ELOG(ERROR, "Arbiter failed to switch socket to non-blocking mode: %s", strerror(errno));
 		}
 		rc = MtmReadSocket(fd, &req, sizeof req);

pglogical_receiver.c

@@ -38,7 +38,6 @@
 #include "replication/origin.h"
 #include "utils/portal.h"
 #include "tcop/pquery.h"
-#include "libpq-int.h"
 
 #include "multimaster.h"
 #include "spill.h"