15
15
#include <unistd.h>
16
16
17
17
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 );
20
19
21
20
int
22
21
do_delete (time_t backup_id )
@@ -108,7 +107,7 @@ do_delete(time_t backup_id)
108
107
}
109
108
}
110
109
111
- delete_walfiles (oldest_lsn , oldest_tli , true );
110
+ delete_walfiles (oldest_lsn , oldest_tli );
112
111
}
113
112
114
113
/* cleanup */
@@ -200,7 +199,7 @@ do_retention_purge(void)
200
199
}
201
200
202
201
/* Purge WAL files */
203
- delete_walfiles (oldest_lsn , oldest_tli , true );
202
+ delete_walfiles (oldest_lsn , oldest_tli );
204
203
205
204
/* Cleanup */
206
205
parray_walk (backup_list , pgBackupFree );
@@ -280,13 +279,16 @@ pgBackupDeleteFiles(pgBackup *backup)
280
279
}
281
280
282
281
/*
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).
284
284
*
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.
287
289
*/
288
290
static void
289
- delete_walfiles (XLogRecPtr oldest_lsn , TimeLineID oldest_tli , bool delete_all )
291
+ delete_walfiles (XLogRecPtr oldest_lsn , TimeLineID oldest_tli )
290
292
{
291
293
XLogSegNo targetSegNo ;
292
294
char oldestSegmentNeeded [MAXFNAMELEN ];
@@ -297,9 +299,6 @@ delete_walfiles(XLogRecPtr oldest_lsn, TimeLineID oldest_tli, bool delete_all)
297
299
char min_wal_file [MAXPGPATH ];
298
300
int rc ;
299
301
300
- if (XLogRecPtrIsInvalid (oldest_lsn ) && !delete_all )
301
- return ;
302
-
303
302
max_wal_file [0 ] = '\0' ;
304
303
min_wal_file [0 ] = '\0' ;
305
304
0 commit comments