提交 8a123982 编写于 作者: A Alex Duan

[TS-238]<feature>: bug readyToCommit sem post twice

上级 225ad78f
......@@ -195,6 +195,7 @@ static void *tsdbLoopCommit(void *arg) {
} else if (req == COMMIT_BOTH_REQ) {
SControlDataInfo* pCtlDataInfo = (SControlDataInfo* )param;
if(!pCtlDataInfo->memNull) {
tsdbInfo(":SDEL vgId=%d commit mem before delete data. mem=%p imem=%p \n", REPO_ID(pRepo), pRepo->mem, pRepo->imem);
tsdbCommitData(pRepo, false);
}
tsdbCommitControl(pRepo, param);
......
......@@ -185,7 +185,6 @@ static void tsdbEndDeleteTrans(STsdbRepo *pRepo, int eno) {
}
pRepo->deleteState = TSDB_NO_DELETE;
tsdbInfo(":SDEL vgId:%d end delete transaction, %s", REPO_ID(pRepo), (eno == TSDB_CODE_SUCCESS) ? "succeed" : "failed");
tsem_post(&(pRepo->readyToCommit));
}
static int tsdbDeleteTSData(STsdbRepo *pRepo, SControlDataInfo* pCtlInfo, SArray* pArray, SArray* pAffectTables) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册