refactor: do some internal refactor.
This commit is contained in:
parent
e1719f8de4
commit
2f65886d01
|
@ -117,10 +117,10 @@ int32_t tqScanWalInFuture(STQ* pTq, int32_t numOfTasks, int32_t idleDuration) {
|
||||||
if (code) {
|
if (code) {
|
||||||
tqError("vgId:%d failed to get tmr ctrl during sched scan wal", vgId);
|
tqError("vgId:%d failed to get tmr ctrl during sched scan wal", vgId);
|
||||||
taosMemoryFree(pParam);
|
taosMemoryFree(pParam);
|
||||||
return code;
|
} else {
|
||||||
|
streamTmrStart(doStartScanWal, idleDuration, pParam, pTimer, &pMeta->scanInfo.scanTimer, vgId, "scan-wal-fut");
|
||||||
}
|
}
|
||||||
|
|
||||||
streamTmrStart(doStartScanWal, idleDuration, pParam, pTimer, &pMeta->scanInfo.scanTimer, vgId, "scan-wal-fut");
|
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue