Skip to content

Commit 777ab09

Browse files
committed
Remove delete_all from delete_walfiles()
1 parent 0dba271 commit 777ab09

File tree

1 file changed

+10
-11
lines changed

1 file changed

+10
-11
lines changed

delete.c

Lines changed: 10 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -15,8 +15,7 @@
1515
#include <unistd.h>
1616

1717
static int pgBackupDeleteFiles(pgBackup *backup);
18-
static void delete_walfiles(XLogRecPtr oldest_lsn, TimeLineID oldest_tli,
19-
bool delete_all);
18+
static void delete_walfiles(XLogRecPtr oldest_lsn, TimeLineID oldest_tli);
2019

2120
int
2221
do_delete(time_t backup_id)
@@ -108,7 +107,7 @@ do_delete(time_t backup_id)
108107
}
109108
}
110109

111-
delete_walfiles(oldest_lsn, oldest_tli, true);
110+
delete_walfiles(oldest_lsn, oldest_tli);
112111
}
113112

114113
/* cleanup */
@@ -200,7 +199,7 @@ do_retention_purge(void)
200199
}
201200

202201
/* Purge WAL files */
203-
delete_walfiles(oldest_lsn, oldest_tli, true);
202+
delete_walfiles(oldest_lsn, oldest_tli);
204203

205204
/* Cleanup */
206205
parray_walk(backup_list, pgBackupFree);
@@ -280,13 +279,16 @@ pgBackupDeleteFiles(pgBackup *backup)
280279
}
281280

282281
/*
283-
* Delete WAL segments up to oldest_lsn.
282+
* Deletes WAL segments up to oldest_lsn or all WAL segments (if all backups
283+
* was deleted and so oldest_lsn is invalid).
284284
*
285-
* If oldest_lsn is invalid function exists. But if delete_all is true then
286-
* WAL segements will be deleted anyway.
285+
* oldest_lsn - if valid, function deletes WAL segments, which contain lsn
286+
* older than oldest_lsn. If it is invalid function deletes all WAL segments.
287+
* oldest_tli - is used to construct oldest WAL segment in addition to
288+
* oldest_lsn.
287289
*/
288290
static void
289-
delete_walfiles(XLogRecPtr oldest_lsn, TimeLineID oldest_tli, bool delete_all)
291+
delete_walfiles(XLogRecPtr oldest_lsn, TimeLineID oldest_tli)
290292
{
291293
XLogSegNo targetSegNo;
292294
char oldestSegmentNeeded[MAXFNAMELEN];
@@ -297,9 +299,6 @@ delete_walfiles(XLogRecPtr oldest_lsn, TimeLineID oldest_tli, bool delete_all)
297299
char min_wal_file[MAXPGPATH];
298300
int rc;
299301

300-
if (XLogRecPtrIsInvalid(oldest_lsn) && !delete_all)
301-
return;
302-
303302
max_wal_file[0] = '\0';
304303
min_wal_file[0] = '\0';
305304

0 commit comments

Comments
 (0)