Method syncTransactionStatus

src/Transaction/CnchProxyTransaction.cpp:117–126

}

void CnchProxyTransaction::syncTransactionStatus(bool throw_on_missmatch)
{
    /// Call when remote query is done and when precommit the explicit transaction
    auto expected_status = remote_client->getTransactionStatus(txn_record.txnID().toUInt64());
    if (throw_on_missmatch && expected_status != txn_record.status())
    {
        throw Exception("Transaction " + txn_record.txnID().toString() + " status is not consistent with remote server, expected " + String(txnStatusToString(expected_status)) + ", got " + String(txnStatusToString(txn_record.status())), ErrorCodes::LOGICAL_ERROR);
    }
    setStatus(expected_status);
}

void CnchProxyTransaction::setTransactionStatus(CnchTransactionStatus status)
{