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

修复备机归档线bug

Browse Source
This commit is contained in:
luozihao
2021-05-18 14:31:44 +08:00
parent ac50df8c84
commit df782b8171
2 changed files with 13 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/gausskernel/process/postmaster/pgarch.cpp
View File

@ -127,6 +127,7 @@ static void initLastTaskLsn();
static bool SendArchiveThreadStatusInternal(bool is_archive_activited);
static void SendArchiveThreadStatus(bool status);
static bool NotifyPrimaryArchiverActived(ThreadId* last_walrcv_pid, bool* sent_archive_status);
static void NotifyPrimaryArchiverShutdown(bool sent_archive_status);
static void ChangeArchiveTaskStatus2Done();
AlarmCheckResult DataInstArchChecker(Alarm* alarm, AlarmAdditionalParam* additionalParam)
@ -368,6 +369,7 @@ static void pgarch_MainLoop(void)
t_thrd.arch.got_SIGHUP = false;
ProcessConfigFile(PGC_SIGHUP);
if (!XLogArchivingActive()) {
NotifyPrimaryArchiverShutdown(sent_archive_status);
ereport(LOG, (errmsg("PgArchiver exit")));
return;
}
@ -511,9 +513,7 @@ static void pgarch_MainLoop(void)
* in the loop, the sent_archive_status will be set to true. We don't need to send the archive status when
* the sent_archive_status is false, so we don't need to check the version number in this step.
*/
if (sent_archive_status) {
SendArchiveThreadStatus(ARCHIVE_OFF);
}
NotifyPrimaryArchiverShutdown(sent_archive_status);
}
/*
@ -1224,6 +1224,13 @@ static bool NotifyPrimaryArchiverActived(ThreadId* last_walrcv_pid, bool* sent_a
return false;
}
static void NotifyPrimaryArchiverShutdown(bool sent_archive_status)
{
if (sent_archive_status) {
SendArchiveThreadStatus(ARCHIVE_OFF);
}
}
static void ChangeArchiveTaskStatus2Done()
{
if (IsServerModeStandby()) {

4
src/gausskernel/storage/replication/walrcvwriter.cpp
View File

@ -152,14 +152,14 @@ static void XLogWalRcvWrite(WalRcvCtlBlock *walrcb, char *buf, Size nbytes, XLog
errmsg("could not close log file %s: %m",
XLogFileNameP(t_thrd.xlog_cxt.ThisTimeLineID, recvSegNo))));
#ifdef ENABLE_MULTIPLE_NODES
/*
* Create .done file forcibly to prevent the restored segment from
* being archived again later.
*/
XLogFileName(xlogfname, recvFileTLI, recvSegNo);
if (!u_sess->attr.attr_common.XLogArchiveMode) {
XLogArchiveForceDone(xlogfname);
}
#endif
}
recvFile = -1;