Method doRollback

src/jrd/extds/InternalDS.cpp:369–422

}

void InternalTransaction::doRollback(FbStatusVector* status, thread_db* tdbb, bool retain)
{
	fb_assert(m_transaction);

	if (m_connection.isBroken())
	{
		m_transaction.clear();
		return;
	}

	if (m_scope == traCommon && m_IntConnection.isCurrent())
	{
		if (!retain) {
			m_transaction = NULL;	// release and nullify
		}
		return;
	}

	ISC_STATUS err = 0;
	{
		EngineCallbackGuard guard(tdbb, *this, FB_FUNCTION);
		if (retain)
			m_transaction->rollbackRetaining(status);
		else
			m_transaction->rollback(status);

		if (status->getState() & IStatus::STATE_ERRORS)
			err = status->getErrors()[1];

		if (err == isc_cancelled)
		{
			FbLocalStatus temp;
			JAttachment* jAtt = m_IntConnection.getJrdAtt();
			jAtt->cancelOperation(&temp, fb_cancel_disable);

			status->init();
			if (retain)
				m_transaction->rollbackRetaining(status);
			else
				m_transaction->rollback(status);

			err = (status->getState() & IStatus::STATE_ERRORS) ?
				status->getErrors()[1] : 0;

			jAtt->cancelOperation(&temp, fb_cancel_enable);
		}
	}

	if ((!err || err == isc_att_shutdown || err == isc_shutdown) && !retain)
	{
		m_transaction.clear();
		status->init();
	}
}


// InternalStatement