fix more
This commit is contained in:
parent
bb83ed2469
commit
e75ab5b298
|
@ -624,7 +624,7 @@ static int32_t tsdbCommitInfoBuild(STsdb *tsdb) {
|
||||||
|
|
||||||
int64_t minKey, maxKey;
|
int64_t minKey, maxKey;
|
||||||
tsdbFidKeyRange(fset->fid, tsdb->keepCfg.days, tsdb->keepCfg.precision, &minKey, &maxKey);
|
tsdbFidKeyRange(fset->fid, tsdb->keepCfg.days, tsdb->keepCfg.precision, &minKey, &maxKey);
|
||||||
tRBTreeIterCreate(tsdb->imem->tbDataTree, 1);
|
iter = tRBTreeIterCreate(tsdb->imem->tbDataTree, 1);
|
||||||
for (SRBTreeNode *node = tRBTreeIterNext(&iter); node; node = tRBTreeIterNext(&iter)) {
|
for (SRBTreeNode *node = tRBTreeIterNext(&iter); node; node = tRBTreeIterNext(&iter)) {
|
||||||
STbData *pTbData = TCONTAINER_OF(node, STbData, rbtn);
|
STbData *pTbData = TCONTAINER_OF(node, STbData, rbtn);
|
||||||
for (SDelData *pDelData = pTbData->pHead; pDelData; pDelData = pDelData->pNext) {
|
for (SDelData *pDelData = pTbData->pHead; pDelData; pDelData = pDelData->pNext) {
|
||||||
|
|
|
@ -1181,7 +1181,7 @@ int32_t tsdbBeginTaskOnFileSet(STsdb *tsdb, int32_t fid, STFileSet **fset) {
|
||||||
int16_t sttTrigger = tsdb->pVnode->config.sttTrigger;
|
int16_t sttTrigger = tsdb->pVnode->config.sttTrigger;
|
||||||
|
|
||||||
tsdbFSGetFSet(tsdb->pFS, fid, fset);
|
tsdbFSGetFSet(tsdb->pFS, fid, fset);
|
||||||
if (sttTrigger == 1 && fset) {
|
if (sttTrigger == 1 && (*fset)) {
|
||||||
for (;;) {
|
for (;;) {
|
||||||
if ((*fset)->taskRunning) {
|
if ((*fset)->taskRunning) {
|
||||||
(*fset)->numWaitTask++;
|
(*fset)->numWaitTask++;
|
||||||
|
|
Loading…
Reference in New Issue