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

!1475 修复日志量少的时候，极致RTO lsn推进慢的问题

Browse Source 
Merge pull request !1475 from 陈栋/issue1
This commit is contained in:
opengauss-bot
2022-01-18 11:08:45 +00:00
committed by Gitee
parent 3fe1bf4cb7 52c4e269aa
commit ad762fd052
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/gausskernel/storage/access/transam/xlog.cpp
View File

@ -16540,6 +16540,8 @@ int ParallelXLogReadWorkBufRead(XLogReaderState *xlogreader, XLogRecPtr targetPa
XLByteAdvance(RecPtr, reqLen);
XLogRecPtr expectedRecPtr = CalcExpectLsn(RecPtr);
uint64 waitXLogCount = 0;
const uint64 pushLsnCount = 2;
pg_atomic_write_u64(&extreme_rto::g_dispatcher->rtoXlogBufState.expectLsn, expectedRecPtr);
for (;;) {
@ -16582,6 +16584,7 @@ int ParallelXLogReadWorkBufRead(XLogReaderState *xlogreader, XLogRecPtr targetPa
/* just make sure source info is correct... */
t_thrd.xlog_cxt.readSource = XLOG_FROM_STREAM;
t_thrd.xlog_cxt.XLogReceiptSource = XLOG_FROM_STREAM;
waitXLogCount = 0;
if ((targetPagePtr / XLOG_BLCKSZ) != (t_thrd.xlog_cxt.receivedUpto / XLOG_BLCKSZ)) {
t_thrd.xlog_cxt.readLen = XLOG_BLCKSZ;
} else {
@ -16614,7 +16617,8 @@ int ParallelXLogReadWorkBufRead(XLogReaderState *xlogreader, XLogRecPtr targetPa
*/
WaitLatch(&t_thrd.shemem_ptr_cxt.XLogCtl->recoveryWakeupLatch, WL_LATCH_SET | WL_TIMEOUT, 1000L);
ResetLatch(&t_thrd.shemem_ptr_cxt.XLogCtl->recoveryWakeupLatch);
extreme_rto::PushToWorkerLsn(false);
extreme_rto::PushToWorkerLsn(waitXLogCount == pushLsnCount);
++waitXLogCount;
}
RedoInterruptCallBack();