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

on shutdown, consume any response before sending shutdown packet

pull/4271/head
Nils Dijk 2020-10-23 15:57:27 +02:00
parent 8aca59fa32
commit e06cf9a822
No known key found for this signature in database
GPG Key ID: CA1177EF9434F241
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/backend/distributed/connection/connection_management.c
View File

@ -616,7 +616,17 @@ ShutdownConnection(MultiConnection *connection)
if (PQstatus(connection->pgConn) == CONNECTION_OK && if (PQstatus(connection->pgConn) == CONNECTION_OK &&
PQtransactionStatus(connection->pgConn) == PQTRANS_ACTIVE) PQtransactionStatus(connection->pgConn) == PQTRANS_ACTIVE)
{ {
SendCancelationRequest(connection); bool sentCancel = SendCancelationRequest(connection);
if (sentCancel)
{
/*
* If we have sent a cancelation we need to wait and consume the response to
* make sure the cancelation is processed. In case of network delay
* cancelation might hit other backend/query. Poolers might introduce out of
* order delivery.
*/
ClearResultsDiscardWarnings(connection, false);
}
} }
CitusPQFinish(connection); CitusPQFinish(connection);
} }