Lines Matching refs:relstate_lsn
284 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
289 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
296 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
444 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
452 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
453 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
813 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
819 &relstate_lsn, true); in LogicalRepSyncTableStart()
824 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
862 MyLogicalRepWorker->relstate_lsn = InvalidXLogRecPtr; in LogicalRepSyncTableStart()
870 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
935 MyLogicalRepWorker->relstate_lsn = *origin_startpos; in LogicalRepSyncTableStart()
951 if (*origin_startpos >= MyLogicalRepWorker->relstate_lsn) in LogicalRepSyncTableStart()