On Fri, Nov 10, 2023 at 7:26 PM vignesh C <vignes...@gmail.com> wrote: > > Thanks for the comments, the attached v13 version patch has the > changes for the same. >
+ + ReplicationOriginNameForLogicalRep(subid, InvalidOid, originname, sizeof(originname)); + originid = replorigin_by_name(originname, false); + replorigin_advance(originid, sublsn, InvalidXLogRecPtr, + false /* backward */ , + false /* WAL log */ ); This seems to update the origin state only in memory. Is it sufficient to use this here? Anyway, I think using this requires us to first acquire RowExclusiveLock on pg_replication_origin something the patch is doing for some other system table. -- With Regards, Amit Kapila.
