Skip to content

Commit f32a471

Browse files
committed
Limit checkpointer requests queue size
If the number of sync requests is big enough, the palloc() call in AbsorbSyncRequests() will attempt to allocate more than 1 GB of memory, resulting in failure. This can lead to an infinite loop in the checkpointer process, as it repeatedly fails to absorb the pending requests. This commit limits the checkpointer requests queue size to 10M items. In addition to preventing the palloc() failure, this change helps to avoid long queue processing time. Also, this commit is for backpathing only. The master branch receives a more invasive yet comprehensive fix for this problem. Discussion: https://postgr.es/m/db4534f83a22a29ab5ee2566ad86ca92%40postgrespro.ru Backpatch-through: 13
1 parent 1ccb385 commit f32a471

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/backend/postmaster/checkpointer.c

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,6 +140,9 @@ static CheckpointerShmemStruct *CheckpointerShmem;
140140
/* interval for calling AbsorbSyncRequests in CheckpointWriteDelay */
141141
#define WRITES_PER_ABSORB 1000
142142

143+
/* Max number of requests the checkpointer request queue can hold */
144+
#define MAX_CHECKPOINT_REQUESTS 10000000
145+
143146
/*
144147
* GUC parameters
145148
*/
@@ -876,7 +879,7 @@ CheckpointerShmemInit(void)
876879
*/
877880
MemSet(CheckpointerShmem, 0, size);
878881
SpinLockInit(&CheckpointerShmem->ckpt_lck);
879-
CheckpointerShmem->max_requests = NBuffers;
882+
CheckpointerShmem->max_requests = Min(NBuffers, MAX_CHECKPOINT_REQUESTS);
880883
ConditionVariableInit(&CheckpointerShmem->start_cv);
881884
ConditionVariableInit(&CheckpointerShmem->done_cv);
882885
}

0 commit comments

Comments
 (0)