sharpetronics/PostgreSQL
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-10-31 00:03:57 -04:00
Code Issues Projects Releases Wiki Activity

Revert "Reduce checkpoints and WAL traffic on low activity database server"

Browse Source 
This reverts commit 18fb9d8d21a28caddb72c7ffbdd7b96d52ff9724.  Per
discussion, it does not seem like a good idea to allow committed changes to
go un-checkpointed indefinitely, as could happen in a low-traffic server;
that makes us entirely reliant on the WAL stream with no redundancy that
might aid data recovery in case of disk failure.

This re-introduces the original problem of hot-standby setups generating a
small continuing stream of WAL traffic even when idle, but there are other
ways to address that without compromising crash recovery, so we'll revisit
that issue in a future release cycle.
This commit is contained in:
Tom Lane 2012-06-13 18:17:09 -04:00
parent 8b23db944b
commit b8b69d8990
1 changed files with 13 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -7646,10 +7646,6 @@ CreateCheckPoint(int flags)
uint32 freespace; uint32 freespace;
uint32 _logId; uint32 _logId;
uint32 _logSeg; uint32 _logSeg;
uint32 redo_logId;
uint32 redo_logSeg;
uint32 insert_logId;
uint32 insert_logSeg;
TransactionId *inCommitXids; TransactionId *inCommitXids;
int nInCommit; int nInCommit;
@ -7726,8 +7722,8 @@ CreateCheckPoint(int flags)
LWLockAcquire(WALInsertLock, LW_EXCLUSIVE); LWLockAcquire(WALInsertLock, LW_EXCLUSIVE);
/* /*
* If this isn't a shutdown or forced checkpoint, and we have not switched * If this isn't a shutdown or forced checkpoint, and we have not inserted
* to the next WAL file since the start of the last checkpoint, skip the * any XLOG records since the start of the last checkpoint, skip the
* checkpoint. The idea here is to avoid inserting duplicate checkpoints * checkpoint. The idea here is to avoid inserting duplicate checkpoints
* when the system is idle. That wastes log space, and more importantly it * when the system is idle. That wastes log space, and more importantly it
* exposes us to possible loss of both current and previous checkpoint * exposes us to possible loss of both current and previous checkpoint
@ -7735,11 +7731,10 @@ CreateCheckPoint(int flags)
* (Perhaps it'd make even more sense to checkpoint only when the previous * (Perhaps it'd make even more sense to checkpoint only when the previous
* checkpoint record is in a different xlog page?) * checkpoint record is in a different xlog page?)
* *
* While holding the WALInsertLock we find the current WAL insertion point * We have to make two tests to determine that nothing has happened since
* and compare that with the starting point of the last checkpoint, which * the start of the last checkpoint: current insertion point must match
* is the redo pointer. We use the redo pointer because the start and end * the end of the last checkpoint record, and its redo pointer must point
* points of a checkpoint can be hundreds of files apart on large systems * to itself.
* when checkpoint writes are spread out over time.
*/ */
if ((flags & (CHECKPOINT_IS_SHUTDOWN | CHECKPOINT_END_OF_RECOVERY | if ((flags & (CHECKPOINT_IS_SHUTDOWN | CHECKPOINT_END_OF_RECOVERY |
CHECKPOINT_FORCE)) == 0) CHECKPOINT_FORCE)) == 0)
@ -7747,10 +7742,13 @@ CreateCheckPoint(int flags)
XLogRecPtr curInsert; XLogRecPtr curInsert;
INSERT_RECPTR(curInsert, Insert, Insert->curridx); INSERT_RECPTR(curInsert, Insert, Insert->curridx);
XLByteToSeg(curInsert, insert_logId, insert_logSeg); if (curInsert.xlogid == ControlFile->checkPoint.xlogid &&
XLByteToSeg(ControlFile->checkPointCopy.redo, redo_logId, redo_logSeg); curInsert.xrecoff == ControlFile->checkPoint.xrecoff +
if (insert_logId == redo_logId && MAXALIGN(SizeOfXLogRecord + sizeof(CheckPoint)) &&
insert_logSeg == redo_logSeg) ControlFile->checkPoint.xlogid ==
ControlFile->checkPointCopy.redo.xlogid &&
ControlFile->checkPoint.xrecoff ==
ControlFile->checkPointCopy.redo.xrecoff)
{ {
LWLockRelease(WALInsertLock); LWLockRelease(WALInsertLock);
LWLockRelease(CheckpointLock); LWLockRelease(CheckpointLock);