external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

PQputCopyData's return value 0 should be considered fail (#7152)

pull/7162/head
zhjwpku 2023-08-29 17:19:18 +08:00 committed by GitHub
parent d5d1684c45
commit d97f786296
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/backend/distributed/connection/remote_commands.c
View File

@ -716,14 +716,14 @@ PutRemoteCopyData(MultiConnection *connection, const char *buffer, int nbytes)
Assert(PQisnonblocking(pgConn)); Assert(PQisnonblocking(pgConn));
int copyState = PQputCopyData(pgConn, buffer, nbytes); int copyState = PQputCopyData(pgConn, buffer, nbytes);
if (copyState == -1) if (copyState <= 0)
{ {
return false; return false;
} }
/* /*
* PQputCopyData may have queued up part of the data even if it managed * PQputCopyData may have queued up part of the data even if it managed
* to send some of it succesfully. We provide back pressure by waiting * to send some of it successfully. We provide back pressure by waiting
* until the socket is writable to prevent the internal libpq buffers * until the socket is writable to prevent the internal libpq buffers
* from growing excessively. * from growing excessively.
* *