Method initialize

src/jrd/tpc.cpp:50–79

}

bool TipCache::GlobalTpcInitializer::initialize(SharedMemoryBase* sm, bool initFlag)
{
	GlobalTpcHeader* header = static_cast<GlobalTpcHeader*>(sm->sh_mem_header);

	if (!initFlag)
	{
		if (!checkHeader(header, false))
			return false;

		m_cache->initTransactionsPerBlock(header->tpc_block_size);
		m_cache->mapInventoryPages(header);
		return true;
	}

	thread_db* tdbb = JRD_get_thread_data();
	Database* dbb = tdbb->getDatabase();

	// Initialize the shared data header
	initHeader(header);

	header->latest_commit_number.store(CN_PREHISTORIC, std::memory_order_relaxed);
	header->latest_statement_id.store(0, std::memory_order_relaxed);
	header->monitor_generation.store(0, std::memory_order_relaxed);
	header->tpc_block_size = dbb->dbb_config->getTipCacheBlockSize();

	m_cache->initTransactionsPerBlock(header->tpc_block_size);
	m_cache->loadInventoryPages(tdbb, header);

	return true;
}

bool TipCache::SnapshotsInitializer::initialize(SharedMemoryBase* sm, bool initFlag)
{