database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复执行检查点时batch double write文件的恢复起始位置计算错误的问题。

Browse Source
This commit is contained in:
April01xxx
2024-11-15 12:10:20 +08:00
parent 0b7220f465
commit 32a99d1c40
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/gausskernel/storage/access/transam/double_write.cpp
View File

@ -785,9 +785,11 @@ static bool dw_batch_file_recycle(dw_batch_file_context *cxt, uint16 pages_to_wr
if (trunc_file) {
Assert(AmStartupProcess() || AmCheckpointerProcess() || AmBootstrapProcess() || !IsUnderPostmaster);
/*
* Record min flush position for truncate because flush lock is not held during smgrsync.
* Record min flush position and # pages that have been flushed to dw
* file for truncate because flush lock is not held during smgrsync.
*/
min_idx = get_dw_page_min_idx(cxt->id);
last_flush_page = cxt->flush_page;
LWLockRelease(cxt->flush_lock);
} else {
Assert(AmStartupProcess() || AmPageWriterProcess());
@ -827,8 +829,8 @@ static bool dw_batch_file_recycle(dw_batch_file_context *cxt, uint16 pages_to_wr
*/
if (trunc_file) {
if (min_idx == 0) {
file_head->start += cxt->flush_page;
cxt->flush_page = 0;
file_head->start += last_flush_page;
cxt->flush_page -= last_flush_page;
} else {
last_flush_page = min_idx - file_head->start;
file_head->start = min_idx;