Skip to content

Commit d40b613

Browse files
authored
Merge branch 'REL_17_4_WASM' into REL_17_4_WASM-pglite
2 parents da677ad + 383cbeb commit d40b613

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

src/backend/libpq/pqcomm.c

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -931,7 +931,7 @@ pq_recvbuf(void)
931931
querylen -= got;
932932
PqRecvLength += got;
933933
if (querylen<=0) {
934-
puts("# 931: could close fp early here " __FILE__);
934+
PDEBUG("# 931: could close fp early here " __FILE__);
935935
queryfp = NULL;
936936
}
937937
if (got>0)
@@ -1041,7 +1041,9 @@ pq_getbyte_if_available(unsigned char *c)
10411041
*c = PqRecvBuffer[PqRecvPointer++];
10421042
return 1;
10431043
}
1044-
puts("# 1028: pq_getbyte_if_available N/I in " __FILE__ ); abort();
1044+
#if defined(__EMSCRIPTEN__) || (__wasi__)
1045+
puts("# 1044: pq_getbyte_if_available N/I in " __FILE__ ); abort();
1046+
#else
10451047
/* Put the socket into non-blocking mode */
10461048
socket_set_nonblocking(true);
10471049

@@ -1078,7 +1080,7 @@ puts("# 1028: pq_getbyte_if_available N/I in " __FILE__ ); abort();
10781080
/* EOF detected */
10791081
r = EOF;
10801082
}
1081-
1083+
#endif
10821084
return r;
10831085
}
10841086

@@ -1175,7 +1177,7 @@ pq_recvbuf_fill(FILE* fp, int packetlen) {
11751177
queryfp = fp;
11761178
querylen = packetlen - got;
11771179
PqRecvLength = got;
1178-
puts("# 1160: input overflow");
1180+
PDEBUG("# 1178: input overflow");
11791181
} else {
11801182
fread( PqRecvBuffer, packetlen, 1, fp);
11811183
PqRecvLength = packetlen;
@@ -2202,4 +2204,4 @@ pq_check_connection(void)
22022204
}
22032205

22042206
return true;
2205-
}
2207+
}

0 commit comments

Comments
 (0)