database/postgres
database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-05-02 11:44:50 +03:00
Code

Don't delete unarchived WAL files during crash recovery.

Browse Source 
Bug reported by Jehan-Guillaume (ioguix) de Rorthais. This was introduced
with the change to keep WAL files restored from archive in pg_xlog, in 9.2.
This commit is contained in:
Heikki Linnakangas 2013-02-15 17:25:16 +02:00
parent 7b058a2dc8
commit fea934653c
1 changed files with 29 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/backend/access/transam/xlog.c
View File

@ -418,6 +418,7 @@ typedef struct XLogCtlData
* recovery. Protected by info_lck. * recovery. Protected by info_lck.
*/ */
bool SharedRecoveryInProgress; bool SharedRecoveryInProgress;
bool SharedInArchiveRecovery;
/* /*
* SharedHotStandbyActive indicates if we're still in crash or archive * SharedHotStandbyActive indicates if we're still in crash or archive
@ -622,6 +623,7 @@ static void XLogArchiveCleanup(const char *xlog);
static void readRecoveryCommandFile(void); static void readRecoveryCommandFile(void);
static void exitArchiveRecovery(TimeLineID endTLI, static void exitArchiveRecovery(TimeLineID endTLI,
uint32 endLogId, uint32 endLogSeg); uint32 endLogId, uint32 endLogSeg);
static bool ArchiveRecoveryInProgress(void);
static bool recoveryStopsHere(XLogRecord *record, bool *includeThis); static bool recoveryStopsHere(XLogRecord *record, bool *includeThis);
static void recoveryPausesHere(void); static void recoveryPausesHere(void);
static void SetLatestXTime(TimestampTz xtime); static void SetLatestXTime(TimestampTz xtime);
@ -3571,7 +3573,7 @@ RemoveOldXlogFiles(uint32 log, uint32 seg, XLogRecPtr endptr)
strspn(xlde->d_name, "0123456789ABCDEF") == 24 && strspn(xlde->d_name, "0123456789ABCDEF") == 24 &&
strcmp(xlde->d_name + 8, lastoff + 8) <= 0) strcmp(xlde->d_name + 8, lastoff + 8) <= 0)
{ {
if (RecoveryInProgress() || XLogArchiveCheckDone(xlde->d_name)) if (ArchiveRecoveryInProgress() || XLogArchiveCheckDone(xlde->d_name))
{ {
snprintf(path, MAXPGPATH, XLOGDIR "/%s", xlde->d_name); snprintf(path, MAXPGPATH, XLOGDIR "/%s", xlde->d_name);
@ -5289,6 +5291,7 @@ XLOGShmemInit(void)
*/ */
XLogCtl->XLogCacheBlck = XLOGbuffers - 1; XLogCtl->XLogCacheBlck = XLOGbuffers - 1;
XLogCtl->SharedRecoveryInProgress = true; XLogCtl->SharedRecoveryInProgress = true;
XLogCtl->SharedInArchiveRecovery = false;
XLogCtl->SharedHotStandbyActive = false; XLogCtl->SharedHotStandbyActive = false;
XLogCtl->WalWriterSleeping = false; XLogCtl->WalWriterSleeping = false;
XLogCtl->Insert.currpage = (XLogPageHeader) (XLogCtl->pages); XLogCtl->Insert.currpage = (XLogPageHeader) (XLogCtl->pages);
@ -5680,6 +5683,7 @@ readRecoveryCommandFile(void)
/* Enable fetching from archive recovery area */ /* Enable fetching from archive recovery area */
InArchiveRecovery = true; InArchiveRecovery = true;
XLogCtl->SharedInArchiveRecovery = true;
/* /*
* If user specified recovery_target_timeline, validate it or compute the * If user specified recovery_target_timeline, validate it or compute the
@ -5718,11 +5722,16 @@ exitArchiveRecovery(TimeLineID endTLI, uint32 endLogId, uint32 endLogSeg)
{ {
char recoveryPath[MAXPGPATH]; char recoveryPath[MAXPGPATH];
char xlogpath[MAXPGPATH]; char xlogpath[MAXPGPATH];
/* use volatile pointer to prevent code rearrangement */
volatile XLogCtlData *xlogctl = XLogCtl;
/* /*
* We are no longer in archive recovery state. * We are no longer in archive recovery state.
*/ */
InArchiveRecovery = false; InArchiveRecovery = false;
SpinLockAcquire(&xlogctl->info_lck);
xlogctl->SharedInArchiveRecovery = false;
SpinLockRelease(&xlogctl->info_lck);
/* /*
* Update min recovery point one last time. * Update min recovery point one last time.
@ -7314,6 +7323,25 @@ RecoveryInProgress(void)
} }
} }
/*
* Are we currently in archive recovery? In the startup process, you can just
* check InArchiveRecovery variable instead.
*/
static bool
ArchiveRecoveryInProgress()
{
bool result;
/* use volatile pointer to prevent code rearrangement */
volatile XLogCtlData *xlogctl = XLogCtl;
/* spinlock is essential on machines with weak memory ordering! */
SpinLockAcquire(&xlogctl->info_lck);
result = xlogctl->SharedInArchiveRecovery;
SpinLockRelease(&xlogctl->info_lck);
return result;
}
/* /*
* Is HotStandby active yet? This is only important in special backends * Is HotStandby active yet? This is only important in special backends
* since normal backends won't ever be able to connect until this returns * since normal backends won't ever be able to connect until this returns