Method create

src/jrd/replication/Applier.cpp:228–271

Applier* Applier::create(thread_db* tdbb)
{
	const auto dbb = tdbb->getDatabase();

	if (!dbb->isReplica())
		raiseError("Database is not in the replica mode");

	const auto attachment = tdbb->getAttachment();

	if (!attachment->locksmith(tdbb, REPLICATE_INTO_DATABASE))
		status_exception::raise(Arg::Gds(isc_miss_prvlg) << "REPLICATE_INTO_DATABASE");

	Request* request = nullptr;
	const auto req_pool = attachment->createPool();

	try
	{
		Jrd::ContextPoolHolder context(tdbb, req_pool);
		AutoPtr<CompilerScratch> csb(FB_NEW_POOL(*req_pool) CompilerScratch(*req_pool));

		request = Statement::makeRequest(tdbb, csb, true);
		request->validateTimeStamp();
		request->req_attachment = attachment;
	}
	catch (const Exception&)
	{
		if (request)
			CMP_release(tdbb, request);
		else
			attachment->deletePool(req_pool);

		throw;
	}

	const auto config = dbb->replConfig();
	const bool cascade = (config && config->cascadeReplication);

	const auto applier = FB_NEW_POOL(*attachment->att_pool)
		Applier(*attachment->att_pool, dbb->dbb_filename, request, cascade);

	attachment->att_repl_appliers.add(applier);

	return applier;
}

void Applier::shutdown(thread_db* tdbb)
{