Method replicate

src/remote/server/server.cpp:3831–3862

void rem_port::replicate(P_REPLICATE* repl, PACKET* sendL)
{
	LocalStatus ls;
	CheckStatusWrapper status_vector(&ls);

	Rdb* rdb = this->port_context;
	if (bad_db(&status_vector, rdb))
	{
		this->send_response(sendL, 0, 0, &status_vector, false);
		return;
	}

	if (!this->port_replicator)
	{
		this->port_replicator = rdb->rdb_iface->createReplicator(&status_vector);
		check(&status_vector);
		fb_assert(this->port_replicator);
	}

	if (repl->p_repl_data.cstr_length)
	{
		this->port_replicator->process(&status_vector,
			repl->p_repl_data.cstr_length, repl->p_repl_data.cstr_address);
	}
	else
	{
		this->port_replicator->close(&status_vector);
		this->port_replicator = NULL;
	}

	this->send_response(sendL, 0, 0, &status_vector, false);
}


ISC_STATUS rem_port::execute_statement(P_OP op, P_SQLDATA* sqldata, PACKET* sendL)