Function start_sweeper

src/jrd/tra.cpp:2817–2869

static void start_sweeper(thread_db* tdbb)
{
/**************************************
 *
 *	s t a r t _ s w e e p e r
 *
 **************************************
 *
 * Functional description
 *	Start a thread to sweep the database.
 *
 **************************************/
	SET_TDBB(tdbb);
	Database* const dbb = tdbb->getDatabase();
	bool started = false;

	if (!dbb->allowSweepThread(tdbb))
		return;

	TRA_update_counters(tdbb, dbb);

	try
	{
		MutexLockGuard g(swThrMutex, FB_FUNCTION);
		if (sweepDown)
			return;

		// perform housekeeping
		auto& swThr(sweepThreads());
		for (unsigned n = 0; n < swThr.getCount(); )
		{
			if (swThr[n]->tryWait())
			{
				delete swThr[n];
				swThr.remove(n);
			}
			else
				++n;
		}

		AutoPtr<SweepSync> sweepSync(FB_NEW SweepSync(*getDefaultMemoryPool(), SweepParameter::runSweep));
		SweepParameter* swPar = FB_NEW SweepParameter(dbb);
		sweepSync->run(swPar);
		started = true;
		sweepThreads().add(sweepSync.release());
	}
	catch (const Exception&)
	{
		if (!started)
			dbb->clearSweepStarting();
		throw;
	}
}


static void transaction_flush(thread_db* tdbb, USHORT flush_flag, TraNumber tra_number)