提交 20d812fd 编写于 作者: C Cary Xu

chore: code optimization for rsma

上级 c5b5699c
...@@ -89,18 +89,18 @@ int32_t smaBegin(SSma *pSma) { ...@@ -89,18 +89,18 @@ int32_t smaBegin(SSma *pSma) {
if ((code = tsdbBegin(VND_RSMA1(pVnode))) < 0) { if ((code = tsdbBegin(VND_RSMA1(pVnode))) < 0) {
smaError("vgId:%d, failed to begin rsma1 since %s", TD_VID(pVnode), tstrerror(code)); smaError("vgId:%d, failed to begin rsma1 since %s", TD_VID(pVnode), tstrerror(code));
return TSDB_CODE_FAILED; return code;
} }
if ((code = tsdbBegin(VND_RSMA2(pVnode))) < 0) { if ((code = tsdbBegin(VND_RSMA2(pVnode))) < 0) {
smaError("vgId:%d, failed to begin rsma2 since %s", TD_VID(pVnode), tstrerror(code)); smaError("vgId:%d, failed to begin rsma2 since %s", TD_VID(pVnode), tstrerror(code));
return TSDB_CODE_FAILED; return code;
} }
// set trigger stat // set trigger stat
SSmaEnv *pSmaEnv = SMA_RSMA_ENV(pSma); SSmaEnv *pSmaEnv = SMA_RSMA_ENV(pSma);
if (!pSmaEnv) { if (!pSmaEnv) {
return TSDB_CODE_SUCCESS; return code;
} }
SRSmaStat *pRSmaStat = (SRSmaStat *)SMA_ENV_STAT(pSmaEnv); SRSmaStat *pRSmaStat = (SRSmaStat *)SMA_ENV_STAT(pSmaEnv);
int8_t rsmaTriggerStat = int8_t rsmaTriggerStat =
...@@ -121,7 +121,7 @@ int32_t smaBegin(SSma *pSma) { ...@@ -121,7 +121,7 @@ int32_t smaBegin(SSma *pSma) {
break; break;
} }
} }
return TSDB_CODE_SUCCESS; return code;
} }
int32_t smaFinishCommit(SSma *pSma) { int32_t smaFinishCommit(SSma *pSma) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册