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;
// }