Lines Matching refs:relstate_lsn
292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn, in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
871 MyLogicalRepWorker->relstate_lsn = InvalidXLogRecPtr; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn, in LogicalRepSyncTableStart()
945 MyLogicalRepWorker->relstate_lsn = *origin_startpos; in LogicalRepSyncTableStart()
961 if (*origin_startpos >= MyLogicalRepWorker->relstate_lsn) in LogicalRepSyncTableStart()