Function replicate

src/remote/server/ReplServer.cpp:600–636

	enum ActionType { REPLICATE, REPLAY, FAST_FORWARD };

	void replicate(Target* target,
				   TransactionList& transactions,
				   FB_UINT64 sequence, ULONG offset,
				   ULONG length, const UCHAR* data,
				   ActionType action)
	{
		const Block* const header = (Block*) data;

		const auto traNumber = header->traNumber;

		if (action == REPLICATE ||
			(action == REPLAY && (!traNumber || transactions.exist(traNumber))))
		{
			target->replicate(sequence, offset, length, data);
		}

		if (header->flags & BLOCK_END_TRANS)
		{
			if (traNumber)
			{
				FB_SIZE_T pos;
				if (transactions.find(traNumber, pos))
					transactions.remove(pos);
			}
			else if (action != REPLAY)
			{
				transactions.clear();
			}
		}
		else if (header->flags & BLOCK_BEGIN_TRANS)
		{
			fb_assert(traNumber);

			if (action != REPLAY && !transactions.exist(traNumber))
				transactions.add(ActiveTransaction(traNumber, sequence));
		}
	}

	enum ProcessStatus { PROCESS_SUSPEND, PROCESS_CONTINUE, PROCESS_ERROR, PROCESS_SHUTDOWN };