test/he3pg
1
0
Fork 0
mirror of https://gitee.com/he3db/he3pg.git synced 2024-12-02 04:07:34 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

auto vacuum stop failed

Browse Source 
Code Source From: Self Code
Description:  【Optional】
Jira:  #【Optional】
市场项目编号（名称）：【Optional】
This commit is contained in:
shenzhengntu 2023-06-15 12:24:41 +08:00
parent b1f7353e14
commit 371bca48a7
2 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -14742,11 +14742,15 @@ producerXLogParallelBatchRead(XLogReaderState *xlogreader, XLogRecPtr startPtr,
maxFlushedUpto = readedUpto + 8 * 16 * 1024;
} else {
//reConnect to master
if (consumerFailedNum >= 8 && ring_buffer_is_empty(gRingBufferManger)) {
if (!XLogRecPtrIsInvalid(reStartPtr)) {
readedUpto = reStartPtr;
consumerFailedNum = 0;
ReConnectPrimaryDB();
if (consumerFailedNum >= 8) {
if (ring_buffer_is_empty(gRingBufferManger)) {
if (!XLogRecPtrIsInvalid(reStartPtr)) {
readedUpto = reStartPtr;
maxFlushedUpto = reStartPtr;
consumerFailedNum = 0;
failedCount = 0;
ReConnectPrimaryDB();
}
}
} else {
if (readedUpto < flushedUpto) {

3
src/backend/storage/smgr/smgr.c
View File

@ -802,7 +802,8 @@ smgrtruncatelsn(SMgrRelation reln, ForkNumber *forknum, int nforks, BlockNumber
do {
sleep(1);
minApplyLsn = He3DBQueryMinLsnFromAllStanby();
printf("====pushlsn=%lx==lsn==%lx==\n",minApplyLsn,lsn);
elog(LOG,"====pushlsn=%lx==lsn==%lx==\n",minApplyLsn,lsn);
CHECK_FOR_INTERRUPTS();
} while(minApplyLsn<lsn);
flag = true;
}