Method initReplica

src/remote/server/ReplServer.cpp:377–424

		}

		FB_UINT64 initReplica()
		{
			if (m_connected)
				return m_sequence;

			ClumpletWriter dpb(ClumpletReader::dpbList, MAX_DPB_SIZE);

			dpb.insertByte(isc_dpb_no_db_triggers, 1);
			dpb.insertString(isc_dpb_user_name, DBA_USER_NAME);
			dpb.insertString(isc_dpb_config, ParsedList::getNonLoopbackProviders(m_config->dbName));

#ifndef NO_DATABASE
			DispatcherPtr provider;
			FbLocalStatus localStatus;

			const auto att =
				provider->attachDatabase(&localStatus, m_config->dbName.c_str(),
										 dpb.getBufferLength(), dpb.getBuffer());
			localStatus.check();
			m_attachment = att;

			const auto repl = m_attachment->createReplicator(&localStatus);
			localStatus.check();
			m_replicator = repl;

			fb_assert(!m_sequence);

			RefPtr<ITransaction> transaction(REF_NO_INCR,
				m_attachment->startTransaction(&localStatus, 0, NULL));
			localStatus.check();

			const char* sql =
				"select rdb$get_context('SYSTEM', 'REPLICATION_SEQUENCE') from rdb$database";

			FB_MESSAGE(Result, CheckStatusWrapper,
				(FB_BIGINT, sequence)
			) result(&localStatus, fb_get_master_interface());

			m_attachment->execute(&localStatus, transaction, 0, sql, SQL_DIALECT_V6,
								  NULL, NULL, result.getMetadata(), result.getData());
			localStatus.check();

			m_sequence = result->sequence;
#endif
			m_connected = true;

			return m_sequence;
		}

		void shutdown()
		{