Method setState

src/jrd/tpc.cpp:607–672

}

CommitNumber TipCache::setState(TraNumber number, int state)
{
	// Can only be called on initialized TipCache
	fb_assert(m_tpcHeader);
	GlobalTpcHeader* header = m_tpcHeader->getHeader();

	TpcBlockNumber blockNumber = number / m_transactionsPerBlock;
	ULONG offset = number % m_transactionsPerBlock;

	Sync sync(&m_sync_status, FB_FUNCTION);
	TransactionStatusBlock* block = getTransactionStatusBlock(header, blockNumber, sync);

	// This should not really happen
	if (!block)
		ERR_bugcheck_msg("TPC: Attempt to change state of old transaction");

	std::atomic<CommitNumber>* statePtr = block->data + offset;
	CommitNumber oldStateCn = statePtr->load(std::memory_order_relaxed);
	switch (state)
	{
		case tra_committed:
		{
			if (oldStateCn == CN_DEAD)
				ERR_bugcheck_msg("TPC: Attempt to commit dead transaction");

			// If transaction is already committed - do nothing
			if (oldStateCn >= CN_PREHISTORIC && oldStateCn <= CN_MAX_NUMBER)
				return oldStateCn;

			// We verified for all other cases, transaction must either be Active or in Limbo
			fb_assert(oldStateCn == CN_ACTIVE || oldStateCn == CN_LIMBO);

			// Generate new commit number
			CommitNumber newCommitNumber = header->latest_commit_number++ + 1;

			statePtr->store(newCommitNumber, std::memory_order_relaxed);
			return newCommitNumber;
		}

		case tra_limbo:
			if (oldStateCn == CN_LIMBO)
				return CN_LIMBO;

			if (oldStateCn != CN_ACTIVE)
				ERR_bugcheck_msg("TPC: Attempt to mark inactive transaction to be in limbo");

			statePtr->store(CN_LIMBO, std::memory_order_relaxed);

			return CN_LIMBO;

		case tra_dead:
			if (oldStateCn == CN_DEAD)
				return CN_DEAD;

			if (oldStateCn != CN_ACTIVE && oldStateCn != CN_LIMBO)
				ERR_bugcheck_msg("TPC: Attempt to mark inactive transaction to be dead");

			statePtr->store(CN_DEAD, std::memory_order_relaxed);