Commit759aefc

committed

[Issue#103] select oldest backup with valid start_lsn and tli to determine oldest lsn for WAL purge

1 parent961293c commit759aefcCopy full SHA for 759aefc

File tree

+10

-6

lines changed

+10

-6

lines changed

Lines changed: 10 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -622,6 +622,7 @@ do_retention_wal(void)`
`622`	`622`	`XLogRecPtroldest_lsn=InvalidXLogRecPtr;`
`623`	`623`	`TimeLineIDoldest_tli=0;`
`624`	`624`	`boolbackup_list_is_empty= false;`
	`625`	`+inti;`
`625`	`626`
`626`	`627`	`/* Get list of backups. */`
`627`	`628`	`backup_list=catalog_get_backup_list(INVALID_BACKUP_ID);`
`@@ -630,14 +631,17 @@ do_retention_wal(void)`
`630`	`631`	`backup_list_is_empty= true;`
`631`	`632`
`632`	`633`	`/* Save LSN and Timeline to remove unnecessary WAL segments */`
`633`		`-if (!backup_list_is_empty)`
	`634`	`+for (i= (int)parray_num(backup_list)-1;i >=0;i--)`
`634`	`635`	`{`
`635`		`-pgBackup*backup=NULL;`
`636`		`-/* Get LSN and TLI of oldest alive backup */`
`637`		`-backup= (pgBackup*)parray_get(backup_list,parray_num(backup_list)-1);`
	`636`	`+pgBackupbackup= (pgBackup)parray_get(backup_list,parray_num(backup_list)-1);`
`638`	`637`
`639`		`-oldest_tli=backup->tli;`
`640`		`-oldest_lsn=backup->start_lsn;`
	`638`	`+/* Get LSN and TLI of the oldest backup with valid start_lsn and tli */`
	`639`	`+if (backup->tli>0&& !XLogRecPtrIsInvalid(backup->start_lsn))`
	`640`	`+{`
	`641`	`+oldest_tli=backup->tli;`
	`642`	`+oldest_lsn=backup->start_lsn;`
	`643`	`+break;`
	`644`	`+}`
`641`	`645`	`}`
`642`	`646`
`643`	`647`	`/* Be paranoid */`

Comments

(0)