Function getReplicator

src/jrd/replication/Publisher.cpp:97–171

	}

	IReplicatedSession* getReplicator(thread_db* tdbb)
	{
		const auto attachment = tdbb->getAttachment();

		// Disable replication for system attachments

		if (attachment->isSystem())
			return nullptr;

		// Check whether replication is allowed for this session

		if (!(attachment->att_flags & ATT_replicating))
			return nullptr;

		// Check whether replication is configured and enabled for this database

		const auto dbb = tdbb->getDatabase();
		if (!dbb->isReplicating(tdbb))
		{
			attachment->att_flags &= ~ATT_replicating;
			attachment->att_replicator = nullptr;
			return nullptr;
		}

		const auto config = dbb->replConfig();
		fb_assert(config);

		// Create a replicator object, unless it already exists

		if (!attachment->att_replicator)
		{
			if (config->pluginName.empty())
			{
				auto& pool = *attachment->att_pool;
				const auto manager = dbb->replManager(true);
				const auto& guid = dbb->dbb_guid;
				const auto& userName = attachment->getUserName();

				attachment->att_replicator = FB_NEW Replicator(pool, manager, guid, userName);
			}
			else
			{
				GetPlugins<IReplicatedSession> plugins(IPluginManager::TYPE_REPLICATOR,
													   config->pluginName.c_str());
				if (!plugins.hasData())
				{
					string msg;
					msg.printf(NO_PLUGIN_ERROR, config->pluginName.c_str());
					logPrimaryError(dbb->dbb_filename, msg);

					return nullptr;
				}

				attachment->att_replicator = plugins.plugin();
			}

			FbLocalStatus status;
			const bool replicating =