Commit044b319

committed

Fix some comments related to logical repslot advancing

confirmed_flush is part of a replication slot's information, but notconfirmed_lsn.Author: Kyotaro HoriguchiDiscussion:https://postgr.es/m/20191226.175919.17237335658671970.horikyota.ntt@gmail.comBackpatch-through: 11

1 parent1ab41a3 commit044b319Copy full SHA for 044b319

File tree

-4

lines changed

-4

lines changed

Lines changed: 4 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -378,8 +378,8 @@ pg_physical_replication_slot_advance(XLogRecPtr moveto)`
`378`	`378`	`/*`
`379`	`379`	`* Helper function for advancing our logical replication slot forward.`
`380`	`380`	`*`
`381`		`- * The slot's restart_lsn is used as start point for reading records,`
`382`		`- *while confirmed_lsn is used as base point for the decoding context.`
	`381`	`+ * The slot's restart_lsn is used as start point for reading records, while`
	`382`	`+ *confirmed_flush is used as base point for the decoding context.`
`383`	`383`	`*`
`384`	`384`	`* We cannot just do LogicalConfirmReceivedLocation to update confirmed_flush,`
`385`	`385`	`* because we need to digest WAL to advance restart_lsn allowing to recycle`
`@@ -549,8 +549,8 @@ pg_replication_slot_advance(PG_FUNCTION_ARGS)`
`549`	`549`	`/*`
`550`	`550`	`* Check if the slot is not moving backwards. Physical slots rely simply`
`551`	`551`	`* on restart_lsn as a minimum point, while logical slots have confirmed`
`552`		`- * consumption up toconfirmed_lsn, meaning that in both cases data older`
`553`		`- * than that is not available anymore.`
	`552`	`+ * consumption up toconfirmed_flush, meaning that in both cases data`
	`553`	`+ *olderthan that is not available anymore.`
`554`	`554`	`*/`
`555`	`555`	`if (OidIsValid(MyReplicationSlot->data.database))`
`556`	`556`	`minlsn=MyReplicationSlot->data.confirmed_flush;`

Comments

(0)