Method clear

src/jrd/tpc.cpp:432–486

}

void TipCache::StatusBlockData::clear(thread_db* tdbb)
{
	// memory could be already released at tpc_block_blocking_ast
	PathName fName;
	if (memory)
	{
		// wait for all initializing processes (PR)
		acceptAst = false;

		TraNumber oldest;
		if (cache->m_tpcHeader)
			oldest = cache->m_tpcHeader->getHeader()->oldest_transaction.load(std::memory_order_relaxed);
		else
		{
			Database* dbb = tdbb->getDatabase();
			if (dbb->dbb_flags & DBB_shared)
				oldest = dbb->dbb_oldest_transaction;
			else
			{
				WIN window(HEADER_PAGE_NUMBER);
				const Ods::header_page* header_page = (Ods::header_page*) CCH_FETCH(tdbb, &window, LCK_read, pag_header);
				oldest = Ods::getOIT(header_page);
				CCH_RELEASE(tdbb, &window);
			}
		}

		if (blockNumber < oldest / cache->m_transactionsPerBlock &&			// old block => send AST
			!LCK_convert(tdbb, &existenceLock, LCK_SW, LCK_WAIT))
		{
			ERR_bugcheck_msg("Unable to convert TPC lock (SW)");
		}

		fName = memory->getMapFileName();
		delete memory;
		memory = NULL;
	}

	if (fName.hasData())
	{
		// Here file is removed from SharedMemory created with skipLock parameter
		// set to true. That means internal file lock is turned off.
		// Appropriate locking is performed by existenceLock using LM.
		// This should be in sync with SharedMemory constructor called
		// in TipCache::StatusBlockData constructor.
		if (LCK_lock(tdbb, &existenceLock, LCK_EX, LCK_NO_WAIT))
			SharedMemoryBase::unlinkFile(fName.c_str());
		else
		{
			tdbb->tdbb_status_vector->init();
			return;
		}
	}

	LCK_release(tdbb, &existenceLock);
}

TipCache::TransactionStatusBlock* TipCache::createTransactionStatusBlock(ULONG blockSize, TpcBlockNumber blockNumber)
{