diff --git a/src/bin/pg_dump/parallel.c b/src/bin/pg_dump/parallel.c
index caedbb8..edc8e42 100644
--- a/src/bin/pg_dump/parallel.c
+++ b/src/bin/pg_dump/parallel.c
@@ -36,7 +36,7 @@
 #ifdef WIN32
 static unsigned int tMasterThreadId = 0;
 static HANDLE termEvent = INVALID_HANDLE_VALUE;
-static int	pgpipe(int handles[2]);
+static int	pgpipe(pgsocket handles[2]);
 static int	piperead(int s, char *buf, int len);
 
 /*
@@ -527,7 +527,7 @@ ParallelBackupStart(ArchiveHandle *AH, RestoreOptions *ropt)
 #else
 		pid_t		pid;
 #endif
-		int			pipeMW[2],
+		pgsocket		pipeMW[2],
 					pipeWM[2];
 
 		if (pgpipe(pipeMW) < 0 || pgpipe(pipeWM) < 0)
@@ -1323,7 +1323,7 @@ readMessageFromPipe(int fd)
  * with recv/send.
  */
 static int
-pgpipe(int handles[2])
+pgpipe(pgsocket handles[2])
 {
 	SOCKET		s;
 	struct sockaddr_in serv_addr;