aboutsummaryrefslogtreecommitdiff
path: root/src/backend/libpq/pqcomprim.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/backend/libpq/pqcomprim.c')
-rw-r--r--src/backend/libpq/pqcomprim.c3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/backend/libpq/pqcomprim.c b/src/backend/libpq/pqcomprim.c
index 8c08adb3fd4..6d5897e747a 100644
--- a/src/backend/libpq/pqcomprim.c
+++ b/src/backend/libpq/pqcomprim.c
@@ -1,6 +1,7 @@
#include <stdlib.h>
#include <stdio.h>
#include <sys/types.h>
+#include <sys/socket.h>
#include <netinet/in.h>
#include "postgres.h"
@@ -146,7 +147,7 @@ pqGetNBytes(char *s, size_t len)
int bytesDone = 0;
do {
- int r = recv(MyProcPort->sock, s+bytesDone, len-bytesDone, MSG_WAITALL);
+ int r = recv(MyProcPort->sock, s+bytesDone, len-bytesDone, 0);
if (r == 0 || r == -1) {
if (errno != EINTR)
return EOF; /* All other than signal-interrupted is error */