{

ereport(ERROR,

(errcode(ERRCODE_OBJECT_IN_USE),

errmsg("replicationidentifier %d is already active for PID %d",

errmsg("replicationorigin %d is already active for PID %d",

curstate->roident,curstate->acquired_by)));

}

DESCR("reset the transaction's origin lsn and timestamp");

DATA(insert OID = 6012 ( pg_replication_origin_advance PGNSP PGUID 12 1 0 0 0 f f f f t f v u 2 0 2278 "25 3220" _null_ _null_ _null_ _null_ _null_ pg_replication_origin_advance _null_ _null_ _null_ ));

DESCR("advance replicationidentifier to specific location");

DESCR("advance replicationorigin to specific location");

DATA(insert OID = 6013 ( pg_replication_origin_progress PGNSP PGUID 12 1 0 0 0 f f f f t f v u 2 0 3220 "25 16" _null_ _null_ _null_ _null_ _null_ pg_replication_origin_progress _null_ _null_ _null_ ));

DESCR("get an individual replication origin's replication progress");