Method lockState

src/jrd/replication/ChangeLog.cpp:438–472

}

void ChangeLog::lockState()
{
	m_localMutex.enter(FB_FUNCTION);
	m_sharedMemory->mutexLock();

	// Reattach if someone has just deleted the shared file

	while (m_sharedMemory->getHeader()->isDeleted())
	{
		// Shared memory must be empty at this point
		fb_assert(!m_sharedMemory->getHeader()->pidLower);
		fb_assert(!m_sharedMemory->getHeader()->pidUpper);

		m_sharedMemory->mutexUnlock();
		m_sharedMemory.reset();

		Thread::yield();

		initSharedFile();
		m_sharedMemory->mutexLock();
	}

	try
	{
		const auto state = m_sharedMemory->getHeader();

		if (m_segments.isEmpty() || state->generation != m_generation)
			initSegments();
	}
	catch (const Exception&)
	{
		unlockState();
		throw;
	}
}

void ChangeLog::unlockState()
{