xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix sync coredump

This commit is contained in:
Hongze Cheng 2021-01-22 11:44:53 +08:00
parent 3b0c58848f
commit 5dd39e7d6e
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/tsdb/src/tsdbSync.c
View File

@ -179,6 +179,11 @@ static int32_t tsdbSyncRecvMeta(SSyncH *pSynch) {
// No meta file, do nothing (rm local meta file) // No meta file, do nothing (rm local meta file)
if (pSynch->pmf == NULL) { if (pSynch->pmf == NULL) {
if (pLMFile == NULL) {
pSynch->mfChanged = false;
} else {
pSynch->mfChanged = true;
}
tsdbInfo("vgId:%d, metafile not exist in remote, no need to recv", REPO_ID(pRepo)); tsdbInfo("vgId:%d, metafile not exist in remote, no need to recv", REPO_ID(pRepo));
return 0; return 0;
} }
@ -219,6 +224,7 @@ static int32_t tsdbSyncRecvMeta(SSyncH *pSynch) {
tsdbCloseMFile(&mf); tsdbCloseMFile(&mf);
tsdbUpdateMFile(REPO_FS(pRepo), &mf); tsdbUpdateMFile(REPO_FS(pRepo), &mf);
} else { } else {
pSynch->mfChanged = false;
tsdbInfo("vgId:%d, metafile is same, no need to recv", REPO_ID(pRepo)); tsdbInfo("vgId:%d, metafile is same, no need to recv", REPO_ID(pRepo));
if (tsdbSendDecision(pSynch, false) < 0) { if (tsdbSendDecision(pSynch, false) < 0) {
tsdbError("vgId:%d, failed to send decision while recv metafile since %s", REPO_ID(pRepo), tstrerror(terrno)); tsdbError("vgId:%d, failed to send decision while recv metafile since %s", REPO_ID(pRepo), tstrerror(terrno));