refact

source/dnode/vnode/src/inc/tsdbHealth.h

-/*
- * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
- *
- * This program is free software: you can use, redistribute, and/or modify
- * it under the terms of the GNU Affero General Public License, version 3
- * or later ("AGPL"), as published by the Free Software Foundation.
- *
- * This program is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE.
- *
- * You should have received a copy of the GNU Affero General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- */
-
-#ifndef _TD_TSDB_HEALTH_H_
-#define _TD_TSDB_HEALTH_H_
-
-#if 0
-
-bool tsdbUrgeQueryFree(STsdbRepo* pRepo);
-int32_t tsdbInsertNewBlock(STsdbRepo* pRepo);
-
-bool tsdbIdleMemEnough();
-bool tsdbAllowNewBlock(STsdbRepo* pRepo);
-
-#endif
-
-#endif /* _TD_TSDB_BUFFER_H_ */

source/dnode/vnode/src/tsdb/tsdbHealth.c

-/*
- * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
- *
- * This program is free software: you can use, redistribute, and/or modify
- * it under the terms of the GNU Affero General Public License, version 3
- * or later ("AGPL"), as published by the Free Software Foundation.
- *
- * This program is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE.
- *
- * You should have received a copy of the GNU Affero General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- */
-
-// #include "os.h"
-// #include "tmsg.h"
-// #include "tarray.h"
-// #include "query.h"
-// #include "tglobal.h"
-// #include "tlist.h"
-// #include "tsdbint.h"
-// #include "tsdbBuffer.h"
-// #include "tsdbLog.h"
-// #include "tsdbHealth.h"
-// #include "ttimer.h"
-// #include "tthread.h"
-
-
-// // return malloc new block count 
-// int32_t tsdbInsertNewBlock(STsdbRepo * pRepo) {
-//   STsdbBufPool *pPool = pRepo->pPool;
-//   int32_t cnt = 0;
-
-//   if(tsdbAllowNewBlock(pRepo)) {
-//     STsdbBufBlock *pBufBlock = tsdbNewBufBlock(pPool->bufBlockSize);
-//     if (pBufBlock) {
-//         if (tdListAppend(pPool->bufBlockList, (void *)(&pBufBlock)) < 0) {
-//           // append error
-//           tsdbFreeBufBlock(pBufBlock);
-//         } else {
-//           pPool->nElasticBlocks ++;
-//           cnt ++ ;
-//         }
-//     }
-//  } 
-//  return cnt;
-// }
-
-// // switch anther thread to run
-// void* cbKillQueryFree(void* param) {
-//   STsdbRepo* pRepo =  (STsdbRepo*)param;
-//   // vnode
-//   if(pRepo->appH.notifyStatus) {
-//     pRepo->appH.notifyStatus(pRepo->appH.appH, TSDB_STATUS_COMMIT_NOBLOCK, TSDB_CODE_SUCCESS);
-//   }
-
-//   // free 
-//   if(pRepo->pthread){
-//     void* p = pRepo->pthread;
-//     pRepo->pthread = NULL;
-//     free(p);
-//   }
-
-//   return NULL;
-// }
-
-// // return true do free , false do nothing
-// bool tsdbUrgeQueryFree(STsdbRepo * pRepo) {
-//   // check previous running
-//   if(pRepo->pthread && taosThreadRunning(pRepo->pthread)) {
-//     tsdbWarn("vgId:%d pre urge thread is runing. nBlocks=%d nElasticBlocks=%d", REPO_ID(pRepo), pRepo->pPool->nBufBlocks, pRepo->pPool->nElasticBlocks);
-//     return false;
-//   }
-//   // create new
-//   pRepo->pthread = taosCreateThread(cbKillQueryFree, pRepo);
-//   if(pRepo->pthread == NULL) {
-//     tsdbError("vgId:%d create urge thread error.", REPO_ID(pRepo));
-//     return false;
-//   }
-//   return true;
-// }
-
-// bool tsdbAllowNewBlock(STsdbRepo* pRepo) {
-//   int32_t nMaxElastic = pRepo->config.totalBlocks/3;
-//   STsdbBufPool* pPool = pRepo->pPool;
-//   if(pPool->nElasticBlocks >= nMaxElastic) {
-//     tsdbWarn("vgId:%d tsdbAllowNewBlock return fasle. nElasticBlock(%d) >= MaxElasticBlocks(%d)", REPO_ID(pRepo), pPool->nElasticBlocks, nMaxElastic);
-//     return false;
-//   }
-//   return true;
-// }
-
-// bool tsdbNoProblem(STsdbRepo* pRepo) {
-//   if(listNEles(pRepo->pPool->bufBlockList) == 0) 
-//      return false;
-//   return true;
-// }
\ No newline at end of file