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

Relax assertion on transaction rollback failure (#2052) 

In case a failure happens when a transaction is rollbacked,
we used to hit an assertion for ensuring there is no pending
activity on the connection. However, that's not true after the
changes in #2031. Thus, we've replaced the assertion with a more
generic function call to consume any pending activity, if exists.
pull/1997/head
Önder Kalacı 2018-04-26 20:39:03 +03:00 committed by Hadi Moshayedi
parent 24659a97dc
commit ebb8f902c8
1 changed files with 19 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
src/backend/distributed/transaction/remote_transaction.c
View File

@ -418,34 +418,30 @@ void
FinishRemoteTransactionAbort(MultiConnection *connection)
{
RemoteTransaction *transaction = &connection->remoteTransaction;
PGresult *result = NULL;
const bool dontRaiseErrors = false;
const bool isNotCommit = false;
const bool raiseErrors = false;
result = GetRemoteCommandResult(connection, dontRaiseErrors);
if (!IsResponseOK(result))
if (transaction->transactionState == REMOTE_TRANS_2PC_ABORTING)
{
ReportResultError(connection, result, WARNING);
MarkRemoteTransactionFailed(connection, dontRaiseErrors);
PGresult *result = GetRemoteCommandResult(connection, raiseErrors);
if (!IsResponseOK(result))
{
const bool isCommit = false;
WarnAboutLeakedPreparedTransaction(connection, isCommit);
}
if (transaction->transactionState == REMOTE_TRANS_2PC_ABORTING)
{
WarnAboutLeakedPreparedTransaction(connection, isNotCommit);
}
else
{
ereport(WARNING,
(errmsg("failed to abort 1PC transaction \"%s\" on %s:%d",
transaction->preparedName, connection->hostname,
connection->port)));
}
PQclear(result);
}
PQclear(result);
result = GetRemoteCommandResult(connection, dontRaiseErrors);
Assert(!result);
/*
* Try to consume results of any in-progress commands. In the 1PC case
* this is also where we consume the result of the ROLLBACK.
*
* If we don't succeed the connection will be in a bad state, so we close it.
*/
if (!ClearResults(connection, raiseErrors))
{
ShutdownConnection(connection);
}
transaction->transactionState = REMOTE_TRANS_ABORTED;
}