Lines Matching refs:relstate_lsn
277 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
282 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
289 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
437 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
445 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
446 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
824 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
830 &relstate_lsn, true); in LogicalRepSyncTableStart()
835 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
873 MyLogicalRepWorker->relstate_lsn = InvalidXLogRecPtr; in LogicalRepSyncTableStart()
881 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
946 MyLogicalRepWorker->relstate_lsn = *origin_startpos; in LogicalRepSyncTableStart()
962 if (*origin_startpos >= MyLogicalRepWorker->relstate_lsn) in LogicalRepSyncTableStart()