Method initializeTpc

src/jrd/tpc.cpp:228–282

}

void TipCache::initializeTpc(thread_db *tdbb)
{
	Database* dbb = tdbb->getDatabase();

	// Initialization can only be called on a TipCache that is not initialized
	fb_assert(!m_transactionsPerBlock);

	m_lock = FB_NEW_RPT(*dbb->dbb_permanent, 0) Lock(tdbb, 0, LCK_tpc_init);

	// wait for finalizers (SW) locks
	if (!LCK_lock(tdbb, m_lock, LCK_PR, LCK_WAIT))
		ERR_bugcheck_msg("Unable to obtain TPC lock (PR)");

	string fileName;
	fileName.printf(TPC_HDR_FILE, dbb->getUniqueFileId().c_str());

	try
	{
		m_tpcHeader = FB_NEW_POOL(*dbb->dbb_permanent) SharedMemory<GlobalTpcHeader>(
			fileName.c_str(), sizeof(GlobalTpcHeader), &globalTpcInitializer);

		const auto* header = m_tpcHeader->getHeader();
		globalTpcInitializer.checkHeader(header);
	}
	catch (const Exception& ex)
	{
		iscLogException("TPC: Cannot initialize the shared memory region (header)", ex);

		LCK_convert(tdbb, m_lock, LCK_SR, LCK_WAIT);	// never fails
		finalizeTpc(tdbb);
		throw;
	}

	try
	{
		fileName.printf(SNAPSHOTS_FILE, dbb->getUniqueFileId().c_str());
		m_snapshots = FB_NEW_POOL(*dbb->dbb_permanent) SharedMemory<SnapshotList>(
			fileName.c_str(), dbb->dbb_config->getSnapshotsMemSize(), &snapshotsInitializer);

		const auto* header = m_snapshots->getHeader();
		snapshotsInitializer.checkHeader(header);
	}
	catch (const Exception& ex)
	{
		iscLogException("TPC: Cannot initialize the shared memory region (snapshots)", ex);

		LCK_convert(tdbb, m_lock, LCK_SR, LCK_WAIT);	// never fails
		finalizeTpc(tdbb);
		throw;
	}

	fb_assert(m_snapshots->getHeader()->mhb_version == TPC_VERSION);

	LCK_convert(tdbb, m_lock, LCK_SR, LCK_WAIT);	// never fails
}

void TipCache::initTransactionsPerBlock(ULONG blockSize)
{