Method bgWriter

src/jrd/replication/Manager.cpp:341–401

}

void Manager::bgWriter()
{
	try
	{
		// Signal about our startup

		m_startupSemaphore.release();

		// Loop to replicate queued changes

		while (!m_shutdown)
		{
			MutexLockGuard guard(m_queueMutex, FB_FUNCTION);

			for (auto& buffer : m_queue)
			{
				if (buffer)
				{
					const auto length = (ULONG) buffer->getCount();
					fb_assert(length);

					if (m_changeLog)
						m_changeLog->write(length, buffer->begin(), false);

					for (auto iter : m_replicas)
					{
						if (iter->status.isSuccess())
							iter->replicator->process(&iter->status, length, buffer->begin());
					}

					m_queueSize -= length;
					releaseBuffer(buffer);
					buffer = nullptr;
				}
			}

			guard.release();

			if (m_shutdown)
				break;

			m_signalled = false;
			m_workingSemaphore.tryEnter(1);
		}
	}
	catch (const Exception& ex)
	{
		iscLogException("Error in replicator thread", ex);
	}

	// Signal about our exit

	try
	{
		m_cleanupSemaphore.release();
	}
	catch (const Firebird::Exception& ex)
	{