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

better style triall

pull/6259/head
Onder Kalaci 2022-08-30 12:29:21 +03:00
parent f1d347d762
commit 45f882ef9f
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -565,7 +565,7 @@ EnsureAndGetHealthyConnections(dlist_head *connections, bool checkTransactionSta
bool inRemoteTrasaction = bool inRemoteTrasaction =
transaction->transactionState != REMOTE_TRANS_NOT_STARTED; transaction->transactionState != REMOTE_TRANS_NOT_STARTED;
if (inRemoteTrasaction && checkTransactionState) if (checkTransactionState && inRemoteTrasaction)
{ {
PGTransactionStatusType status = PQtransactionStatus(connection->pgConn); PGTransactionStatusType status = PQtransactionStatus(connection->pgConn);
@ -580,7 +580,8 @@ EnsureAndGetHealthyConnections(dlist_head *connections, bool checkTransactionSta
{ {
healthyConnections = lappend(healthyConnections, connection); healthyConnections = lappend(healthyConnections, connection);
} }
else if (inRemoteTrasaction && checkTransactionState && else if (checkTransactionState && inRemoteTrasaction &&
transaction->transactionFailed &&
(transaction->transactionCritical || (transaction->transactionCritical ||
!dlist_is_empty(&connection->referencedPlacements))) !dlist_is_empty(&connection->referencedPlacements)))
{ {