Method finalizeTpc

src/jrd/tpc.cpp:137–196

}

void TipCache::finalizeTpc(thread_db* tdbb)
{
	// check for finalizeTpc() called more than once
	if (!m_lock.hasData())
		return;

	// To avoid race conditions, this function might only
	// be called during database shutdown when AST delivery is already disabled

	// wait for all initializing processes (PR)
	if (!LCK_convert(tdbb, m_lock, LCK_SW, LCK_WAIT))
		ERR_bugcheck_msg("Unable to convert TPC lock (SW)");

	// Release locks and deallocate all shared memory structures
	if (m_blocks_memory.getFirst())
	{
		do
		{
			StatusBlockData* cur = m_blocks_memory.current();
			delete cur;
		} while (m_blocks_memory.getNext());
	}

	PathName nmSnap, nmHdr;
	if (m_snapshots)
	{
		nmSnap = m_snapshots->getMapFileName();
		delete m_snapshots;
		m_snapshots = NULL;
	}

	if (m_tpcHeader)
	{
		nmHdr = m_tpcHeader->getMapFileName();
		delete m_tpcHeader;
		m_tpcHeader = NULL;
	}

	m_blocks_memory.clear();
	m_transactionsPerBlock = 0;

    if (nmSnap.hasData() || nmHdr.hasData())
    {
    	if (LCK_lock(tdbb, m_lock, LCK_EX, LCK_NO_WAIT))
		{
			if (nmSnap.hasData())
				SharedMemoryBase::unlinkFile(nmSnap.c_str());
			if (nmHdr.hasData())
				SharedMemoryBase::unlinkFile(nmHdr.c_str());

			LCK_release(tdbb, m_lock);
		}
		else
			tdbb->tdbb_status_vector->init();
	}
	else
		LCK_release(tdbb, m_lock);