#3533

Committed 20 Nov 2024 07:11AM UTC coverage: 58.848% (-1.9%) from 60.78%

Build # #3533

Build Type

push

travis-ci

Committed by

web-flow

Commit Message

Merge pull request #28823 from taosdata/fix/3.0/TD-32587

fix:[TD-32587]fix stmt segmentation fault

Run Details

115578 of 252434 branches covered (45.79%)

Branch coverage included in aggregate %.

1 of 4 new or added lines in 1 file covered. (25.0%)

8038 existing lines in 233 files now uncovered.

194926 of 275199 relevant lines covered (70.83%)

1494459.59 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

73.45

/source/dnode/vnode/src/vnd/vnodeCfg.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 "tglobal.h"
#include "tutil.h"
#include "vnd.h"

const SVnodeCfg vnodeCfgDefault = {.vgId = -1,
                                   .dbname = "",
                                   .dbId = 0,
                                   .szPage = 4096,
                                   .szCache = 256,
                                   .cacheLast = 3,
                                   .cacheLastSize = 8,
                                   .szBuf = 96 * 1024 * 1024,
                                   .isHeap = false,
                                   .isWeak = 0,
                                   .tsdbCfg = {.precision = TSDB_TIME_PRECISION_MILLI,
                                               .update = 1,
                                               .compression = 2,
                                               .slLevel = 5,
                                               .days = 14400,
                                               .minRows = 100,
                                               .maxRows = 4096,
                                               .keep2 = 5256000,
                                               .keep0 = 5256000,
                                               .keep1 = 5256000,
                                               .keepTimeOffset = TSDB_DEFAULT_KEEP_TIME_OFFSET},
                                   .walCfg =
                                       {
                                           .vgId = -1,
                                           .fsyncPeriod = 0,
                                           .retentionPeriod = -1,
                                           .rollPeriod = 0,
                                           .segSize = 0,
                                           .committed = 0,
                                           .retentionSize = -1,
                                           .level = TAOS_WAL_WRITE,
                                           .clearFiles = 0,
                                       },
                                   .hashBegin = 0,
                                   .hashEnd = 0,
                                   .hashMethod = 0,
                                   .sttTrigger = TSDB_DEFAULT_SST_TRIGGER,
                                   .s3ChunkSize = TSDB_DEFAULT_S3_CHUNK_SIZE,
                                   .s3KeepLocal = TSDB_DEFAULT_S3_KEEP_LOCAL,
                                   .s3Compact = TSDB_DEFAULT_S3_COMPACT,
                                   .tsdbPageSize = TSDB_DEFAULT_PAGE_SIZE};

int vnodeCheckCfg(const SVnodeCfg *pCfg) {
  // TODO
  return 0;
}

const char *vnodeRoleToStr(ESyncRole role) {
  switch (role) {
    case TAOS_SYNC_ROLE_VOTER:
      return "true";
    case TAOS_SYNC_ROLE_LEARNER:
      return "false";
    default:
      return "unknown";
  }
}

const ESyncRole vnodeStrToRole(char *str) {
  if (strcmp(str, "true") == 0) {
    return TAOS_SYNC_ROLE_VOTER;
  }
  if (strcmp(str, "false") == 0) {
    return TAOS_SYNC_ROLE_LEARNER;
  }

  return TAOS_SYNC_ROLE_ERROR;
}

int vnodeEncodeConfig(const void *pObj, SJson *pJson) {
  const SVnodeCfg *pCfg = (SVnodeCfg *)pObj;

  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vgId", pCfg->vgId));
  TAOS_CHECK_RETURN(tjsonAddStringToObject(pJson, "dbname", pCfg->dbname));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "dbId", pCfg->dbId));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "szPage", pCfg->szPage));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "szCache", pCfg->szCache));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "cacheLast", pCfg->cacheLast));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "cacheLastSize", pCfg->cacheLastSize));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "szBuf", pCfg->szBuf));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "isHeap", pCfg->isHeap));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "isWeak", pCfg->isWeak));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "isTsma", pCfg->isTsma));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "isRsma", pCfg->isRsma));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "precision", pCfg->tsdbCfg.precision));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "update", pCfg->tsdbCfg.update));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "compression", pCfg->tsdbCfg.compression));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "slLevel", pCfg->tsdbCfg.slLevel));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "daysPerFile", pCfg->tsdbCfg.days));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "minRows", pCfg->tsdbCfg.minRows));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "maxRows", pCfg->tsdbCfg.maxRows));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "keep0", pCfg->tsdbCfg.keep0));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "keep1", pCfg->tsdbCfg.keep1));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "keep2", pCfg->tsdbCfg.keep2));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "keepTimeOffset", pCfg->tsdbCfg.keepTimeOffset));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "s3ChunkSize", pCfg->s3ChunkSize));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "s3KeepLocal", pCfg->s3KeepLocal));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "s3Compact", pCfg->s3Compact));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "tsdbPageSize", pCfg->tsdbPageSize));
  if (pCfg->tsdbCfg.retentions[0].keep > 0) {
    int32_t nRetention = 1;
    if (pCfg->tsdbCfg.retentions[1].freq > 0) {
      ++nRetention;
      if (pCfg->tsdbCfg.retentions[2].freq > 0) {
        ++nRetention;
      }
    }
    SJson *pNodeRetentions = tjsonCreateArray();
    if (pNodeRetentions == NULL) {
      return terrno;
    }
    TAOS_CHECK_RETURN(tjsonAddItemToObject(pJson, "retentions", pNodeRetentions));
    for (int32_t i = 0; i < nRetention; ++i) {
      SJson            *pNodeRetention = tjsonCreateObject();
      const SRetention *pRetention = pCfg->tsdbCfg.retentions + i;
      TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pNodeRetention, "freq", pRetention->freq));
      TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pNodeRetention, "freqUnit", pRetention->freqUnit));
      TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pNodeRetention, "keep", pRetention->keep));
      TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pNodeRetention, "keepUnit", pRetention->keepUnit));
      TAOS_CHECK_RETURN(tjsonAddItemToArray(pNodeRetentions, pNodeRetention));
    }
  }
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "tsdb.encryptAlgorithm", pCfg->tsdbCfg.encryptAlgorithm));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.vgId", pCfg->walCfg.vgId));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.fsyncPeriod", pCfg->walCfg.fsyncPeriod));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.retentionPeriod", pCfg->walCfg.retentionPeriod));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.rollPeriod", pCfg->walCfg.rollPeriod));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.retentionSize", pCfg->walCfg.retentionSize));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.segSize", pCfg->walCfg.segSize));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.level", pCfg->walCfg.level));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.clearFiles", pCfg->walCfg.clearFiles));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.encryptAlgorithm", pCfg->walCfg.encryptAlgorithm));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "tdbEncryptAlgorithm", pCfg->tdbEncryptAlgorithm));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "sstTrigger", pCfg->sttTrigger));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashBegin", pCfg->hashBegin));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashEnd", pCfg->hashEnd));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashChange", pCfg->hashChange));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashMethod", pCfg->hashMethod));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashPrefix", pCfg->hashPrefix));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashSuffix", pCfg->hashSuffix));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "syncCfg.replicaNum", pCfg->syncCfg.replicaNum));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "syncCfg.myIndex", pCfg->syncCfg.myIndex));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "syncCfg.changeVersion", pCfg->syncCfg.changeVersion));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vndStats.stables", pCfg->vndStats.numOfSTables));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vndStats.ctables", pCfg->vndStats.numOfCTables));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vndStats.ntables", pCfg->vndStats.numOfNTables));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vndStats.timeseries", pCfg->vndStats.numOfTimeSeries));
  TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vndStats.ntimeseries", pCfg->vndStats.numOfNTimeSeries));

  SJson *nodeInfo = tjsonCreateArray();
  if (nodeInfo == NULL) {
    return terrno;
  }
  TAOS_CHECK_RETURN(tjsonAddItemToObject(pJson, "syncCfg.nodeInfo", nodeInfo));
  vDebug("vgId:%d, encode config, replicas:%d totalReplicas:%d selfIndex:%d changeVersion:%d", pCfg->vgId,
         pCfg->syncCfg.replicaNum, pCfg->syncCfg.totalReplicaNum, pCfg->syncCfg.myIndex, pCfg->syncCfg.changeVersion);
  for (int i = 0; i < pCfg->syncCfg.totalReplicaNum; ++i) {
    SJson *info = tjsonCreateObject();
    if (info == NULL) {
      return terrno;
    }

    SNodeInfo *pNode = (SNodeInfo *)&pCfg->syncCfg.nodeInfo[i];
    TAOS_CHECK_RETURN(tjsonAddIntegerToObject(info, "nodePort", pNode->nodePort));
    TAOS_CHECK_RETURN(tjsonAddStringToObject(info, "nodeFqdn", pNode->nodeFqdn));
    TAOS_CHECK_RETURN(tjsonAddIntegerToObject(info, "nodeId", pNode->nodeId));
    TAOS_CHECK_RETURN(tjsonAddIntegerToObject(info, "clusterId", pNode->clusterId));
    TAOS_CHECK_RETURN(tjsonAddStringToObject(info, "isReplica", vnodeRoleToStr(pNode->nodeRole)));
    TAOS_CHECK_RETURN(tjsonAddItemToArray(nodeInfo, info));
    vDebug("vgId:%d, encode config, replica:%d ep:%s:%u dnode:%d", pCfg->vgId, i, pNode->nodeFqdn, pNode->nodePort,
           pNode->nodeId);
  }

  return 0;
}

int vnodeDecodeConfig(const SJson *pJson, void *pObj) {
  SVnodeCfg *pCfg = (SVnodeCfg *)pObj;

  int32_t code;
  tjsonGetNumberValue(pJson, "vgId", pCfg->vgId, code);
  if (code) return code;
  if ((code = tjsonGetStringValue(pJson, "dbname", pCfg->dbname))) return code;
  tjsonGetNumberValue(pJson, "dbId", pCfg->dbId, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "szPage", pCfg->szPage, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "szCache", pCfg->szCache, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "cacheLast", pCfg->cacheLast, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "cacheLastSize", pCfg->cacheLastSize, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "szBuf", pCfg->szBuf, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "isHeap", pCfg->isHeap, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "isWeak", pCfg->isWeak, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "isTsma", pCfg->isTsma, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "isRsma", pCfg->isRsma, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "precision", pCfg->tsdbCfg.precision, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "update", pCfg->tsdbCfg.update, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "compression", pCfg->tsdbCfg.compression, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "slLevel", pCfg->tsdbCfg.slLevel, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "daysPerFile", pCfg->tsdbCfg.days, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "minRows", pCfg->tsdbCfg.minRows, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "maxRows", pCfg->tsdbCfg.maxRows, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "keep0", pCfg->tsdbCfg.keep0, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "keep1", pCfg->tsdbCfg.keep1, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "keep2", pCfg->tsdbCfg.keep2, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "keepTimeOffset", pCfg->tsdbCfg.keepTimeOffset, code);
  if (code) return code;
  SJson  *pNodeRetentions = tjsonGetObjectItem(pJson, "retentions");
  int32_t nRetention = tjsonGetArraySize(pNodeRetentions);
  if (nRetention > TSDB_RETENTION_MAX) {
    nRetention = TSDB_RETENTION_MAX;
  }
  for (int32_t i = 0; i < nRetention; ++i) {
    SJson *pNodeRetention = tjsonGetArrayItem(pNodeRetentions, i);
    tjsonGetNumberValue(pNodeRetention, "freq", (pCfg->tsdbCfg.retentions)[i].freq, code);
    if (code) return code;
    tjsonGetNumberValue(pNodeRetention, "freqUnit", (pCfg->tsdbCfg.retentions)[i].freqUnit, code);
    if (code) return code;
    tjsonGetNumberValue(pNodeRetention, "keep", (pCfg->tsdbCfg.retentions)[i].keep, code);
    if (code) return code;
    tjsonGetNumberValue(pNodeRetention, "keepUnit", (pCfg->tsdbCfg.retentions)[i].keepUnit, code);
    if (code) return code;
  }
  tjsonGetNumberValue(pJson, "tsdb.encryptAlgorithm", pCfg->tsdbCfg.encryptAlgorithm, code);
  if (code) return code;
#if defined(TD_ENTERPRISE)
  if (pCfg->tsdbCfg.encryptAlgorithm == DND_CA_SM4) {
    if (tsEncryptKey[0] == 0) {
      return terrno = TSDB_CODE_DNODE_INVALID_ENCRYPTKEY;
    } else {
      strncpy(pCfg->tsdbCfg.encryptKey, tsEncryptKey, ENCRYPT_KEY_LEN);
    }
  }
#endif
  tjsonGetNumberValue(pJson, "wal.vgId", pCfg->walCfg.vgId, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "wal.fsyncPeriod", pCfg->walCfg.fsyncPeriod, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "wal.retentionPeriod", pCfg->walCfg.retentionPeriod, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "wal.rollPeriod", pCfg->walCfg.rollPeriod, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "wal.retentionSize", pCfg->walCfg.retentionSize, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "wal.segSize", pCfg->walCfg.segSize, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "wal.level", pCfg->walCfg.level, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "wal.clearFiles", pCfg->walCfg.clearFiles, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "wal.encryptAlgorithm", pCfg->walCfg.encryptAlgorithm, code);
  if (code) return code;
#if defined(TD_ENTERPRISE)
  if (pCfg->walCfg.encryptAlgorithm == DND_CA_SM4) {
    if (tsEncryptKey[0] == 0) {
      return terrno = TSDB_CODE_DNODE_INVALID_ENCRYPTKEY;
    } else {
      strncpy(pCfg->walCfg.encryptKey, tsEncryptKey, ENCRYPT_KEY_LEN);
    }
  }
#endif
  tjsonGetNumberValue(pJson, "tdbEncryptAlgorithm", pCfg->tdbEncryptAlgorithm, code);
  if (code) return code;
#if defined(TD_ENTERPRISE)
  if (pCfg->tdbEncryptAlgorithm == DND_CA_SM4) {
    if (tsEncryptKey[0] == 0) {
      return terrno = TSDB_CODE_DNODE_INVALID_ENCRYPTKEY;
    } else {
      strncpy(pCfg->tdbEncryptKey, tsEncryptKey, ENCRYPT_KEY_LEN);
    }
  }
#endif
  tjsonGetNumberValue(pJson, "sstTrigger", pCfg->sttTrigger, code);
  if (code < 0) pCfg->sttTrigger = TSDB_DEFAULT_SST_TRIGGER;
  tjsonGetNumberValue(pJson, "hashBegin", pCfg->hashBegin, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "hashEnd", pCfg->hashEnd, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "hashChange", pCfg->hashChange, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "hashMethod", pCfg->hashMethod, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "hashPrefix", pCfg->hashPrefix, code);
  if (code < 0) pCfg->hashPrefix = TSDB_DEFAULT_HASH_PREFIX;
  tjsonGetNumberValue(pJson, "hashSuffix", pCfg->hashSuffix, code);
  if (code < 0) pCfg->hashSuffix = TSDB_DEFAULT_HASH_SUFFIX;

  tjsonGetNumberValue(pJson, "syncCfg.replicaNum", pCfg->syncCfg.replicaNum, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "syncCfg.myIndex", pCfg->syncCfg.myIndex, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "syncCfg.changeVersion", pCfg->syncCfg.changeVersion, code);
  if (code) return code;

  tjsonGetNumberValue(pJson, "vndStats.stables", pCfg->vndStats.numOfSTables, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "vndStats.ctables", pCfg->vndStats.numOfCTables, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "vndStats.ntables", pCfg->vndStats.numOfNTables, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "vndStats.timeseries", pCfg->vndStats.numOfTimeSeries, code);
  if (code) return code;
  tjsonGetNumberValue(pJson, "vndStats.ntimeseries", pCfg->vndStats.numOfNTimeSeries, code);
  if (code) return code;

  SJson *nodeInfo = tjsonGetObjectItem(pJson, "syncCfg.nodeInfo");
  int    arraySize = tjsonGetArraySize(nodeInfo);
  pCfg->syncCfg.totalReplicaNum = arraySize;

  vDebug("vgId:%d, decode config, replicas:%d totalReplicas:%d selfIndex:%d", pCfg->vgId, pCfg->syncCfg.replicaNum,
         pCfg->syncCfg.totalReplicaNum, pCfg->syncCfg.myIndex);
  for (int i = 0; i < arraySize; ++i) {
    SJson     *info = tjsonGetArrayItem(nodeInfo, i);
    SNodeInfo *pNode = &pCfg->syncCfg.nodeInfo[i];
    if (info == NULL) return -1;
    tjsonGetNumberValue(info, "nodePort", pNode->nodePort, code);
    if (code) return code;
    code = tjsonGetStringValue(info, "nodeFqdn", pNode->nodeFqdn);
    tjsonGetNumberValue(info, "nodeId", pNode->nodeId, code);
    if (code) return code;
    tjsonGetNumberValue(info, "clusterId", pNode->clusterId, code);
    if (code) return code;
    char role[10] = {0};
    code = tjsonGetStringValue(info, "isReplica", role);
    if (code) return code;
    if (strlen(role) != 0) {
      pNode->nodeRole = vnodeStrToRole(role);
    } else {
      pNode->nodeRole = TAOS_SYNC_ROLE_VOTER;
    }
    vDebug("vgId:%d, decode config, replica:%d ep:%s:%u dnode:%d", pCfg->vgId, i, pNode->nodeFqdn, pNode->nodePort,
           pNode->nodeId);
  }

  tjsonGetNumberValue(pJson, "tsdbPageSize", pCfg->tsdbPageSize, code);
  if (code < 0 || pCfg->tsdbPageSize < TSDB_MIN_PAGESIZE_PER_VNODE * 1024) {
    pCfg->tsdbPageSize = TSDB_DEFAULT_TSDB_PAGESIZE * 1024;
  }

  tjsonGetNumberValue(pJson, "s3ChunkSize", pCfg->s3ChunkSize, code);
  if (code < 0 || pCfg->s3ChunkSize < TSDB_MIN_S3_CHUNK_SIZE) {
    pCfg->s3ChunkSize = TSDB_DEFAULT_S3_CHUNK_SIZE;
  }
  tjsonGetNumberValue(pJson, "s3KeepLocal", pCfg->s3KeepLocal, code);
  if (code < 0 || pCfg->s3KeepLocal < TSDB_MIN_S3_KEEP_LOCAL) {
    pCfg->s3KeepLocal = TSDB_DEFAULT_S3_KEEP_LOCAL;
  }
  tjsonGetNumberValue(pJson, "s3Compact", pCfg->s3Compact, code);
  if (code < 0) {
    pCfg->s3Compact = TSDB_DEFAULT_S3_COMPACT;
  }

  return 0;
}

int vnodeValidateTableHash(SVnode *pVnode, char *tableFName) {
  uint32_t hashValue = 0;

  switch (pVnode->config.hashMethod) {
    default:
      hashValue = taosGetTbHashVal(tableFName, strlen(tableFName), pVnode->config.hashMethod, pVnode->config.hashPrefix,
                                   pVnode->config.hashSuffix);
      break;
  }

  if (hashValue < pVnode->config.hashBegin || hashValue > pVnode->config.hashEnd) {
    return terrno = TSDB_CODE_VND_HASH_MISMATCH;
  }

  return 0;
}

1	/*
2	* Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
3	*
4	* This program is free software: you can use, redistribute, and/or modify
5	* it under the terms of the GNU Affero General Public License, version 3
6	* or later ("AGPL"), as published by the Free Software Foundation.
7	*
8	* This program is distributed in the hope that it will be useful, but WITHOUT
9	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
10	* FITNESS FOR A PARTICULAR PURPOSE.
11	*
12	* You should have received a copy of the GNU Affero General Public License
13	* along with this program. If not, see <http://www.gnu.org/licenses/>.
14	*/
15
16	#include "tglobal.h"
17	#include "tutil.h"
18	#include "vnd.h"
19
20	const SVnodeCfg vnodeCfgDefault = {.vgId = -1,
21	.dbname = "",
22	.dbId = 0,
23	.szPage = 4096,
24	.szCache = 256,
25	.cacheLast = 3,
26	.cacheLastSize = 8,
27	.szBuf = 96 * 1024 * 1024,
28	.isHeap = false,
29	.isWeak = 0,
30	.tsdbCfg = {.precision = TSDB_TIME_PRECISION_MILLI,
31	.update = 1,
32	.compression = 2,
33	.slLevel = 5,
34	.days = 14400,
35	.minRows = 100,
36	.maxRows = 4096,
37	.keep2 = 5256000,
38	.keep0 = 5256000,
39	.keep1 = 5256000,
40	.keepTimeOffset = TSDB_DEFAULT_KEEP_TIME_OFFSET},
41	.walCfg =
42	{
43	.vgId = -1,
44	.fsyncPeriod = 0,
45	.retentionPeriod = -1,
46	.rollPeriod = 0,
47	.segSize = 0,
48	.committed = 0,
49	.retentionSize = -1,
50	.level = TAOS_WAL_WRITE,
51	.clearFiles = 0,
52	},
53	.hashBegin = 0,
54	.hashEnd = 0,
55	.hashMethod = 0,
56	.sttTrigger = TSDB_DEFAULT_SST_TRIGGER,
57	.s3ChunkSize = TSDB_DEFAULT_S3_CHUNK_SIZE,
58	.s3KeepLocal = TSDB_DEFAULT_S3_KEEP_LOCAL,
59	.s3Compact = TSDB_DEFAULT_S3_COMPACT,
60	.tsdbPageSize = TSDB_DEFAULT_PAGE_SIZE};
61
62	int vnodeCheckCfg(const SVnodeCfg *pCfg) {	5,249✔
63	// TODO
64	return 0;	5,249✔
65	}
66
67	const char *vnodeRoleToStr(ESyncRole role) {	17,261✔
68	switch (role) {	17,261!
69	case TAOS_SYNC_ROLE_VOTER:	17,086✔
70	return "true";	17,086✔
71	case TAOS_SYNC_ROLE_LEARNER:	175✔
72	return "false";	175✔
73	default:	×
74	return "unknown";	×
75	}
76	}
77
78	const ESyncRole vnodeStrToRole(char *str) {	10,952✔
79	if (strcmp(str, "true") == 0) {	10,952✔
80	return TAOS_SYNC_ROLE_VOTER;	10,677✔
81	}
82	if (strcmp(str, "false") == 0) {	275!
83	return TAOS_SYNC_ROLE_LEARNER;	279✔
84	}
85
UNCOV 86	return TAOS_SYNC_ROLE_ERROR;	×
87	}
88
89	int vnodeEncodeConfig(const void pObj, SJson pJson) {	13,311✔
90	const SVnodeCfg pCfg = (SVnodeCfg )pObj;	13,311✔
91
92	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vgId", pCfg->vgId));	13,311!
93	TAOS_CHECK_RETURN(tjsonAddStringToObject(pJson, "dbname", pCfg->dbname));	13,312!
94	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "dbId", pCfg->dbId));	13,311!
95	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "szPage", pCfg->szPage));	13,312!
96	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "szCache", pCfg->szCache));	13,313!
97	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "cacheLast", pCfg->cacheLast));	13,314!
98	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "cacheLastSize", pCfg->cacheLastSize));	13,315!
99	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "szBuf", pCfg->szBuf));	13,315!
100	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "isHeap", pCfg->isHeap));	13,312!
101	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "isWeak", pCfg->isWeak));	13,315!
102	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "isTsma", pCfg->isTsma));	13,315!
103	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "isRsma", pCfg->isRsma));	13,315!
104	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "precision", pCfg->tsdbCfg.precision));	13,315!
105	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "update", pCfg->tsdbCfg.update));	13,314!
106	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "compression", pCfg->tsdbCfg.compression));	13,315!
107	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "slLevel", pCfg->tsdbCfg.slLevel));	13,315!
108	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "daysPerFile", pCfg->tsdbCfg.days));	13,315!
109	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "minRows", pCfg->tsdbCfg.minRows));	13,314!
110	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "maxRows", pCfg->tsdbCfg.maxRows));	13,314!
111	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "keep0", pCfg->tsdbCfg.keep0));	13,313!
112	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "keep1", pCfg->tsdbCfg.keep1));	13,314!
113	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "keep2", pCfg->tsdbCfg.keep2));	13,315!
114	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "keepTimeOffset", pCfg->tsdbCfg.keepTimeOffset));	13,313!
115	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "s3ChunkSize", pCfg->s3ChunkSize));	13,314!
116	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "s3KeepLocal", pCfg->s3KeepLocal));	13,314!
117	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "s3Compact", pCfg->s3Compact));	13,315!
118	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "tsdbPageSize", pCfg->tsdbPageSize));	13,313!
119	if (pCfg->tsdbCfg.retentions[0].keep > 0) {	13,314✔
120	int32_t nRetention = 1;	21✔
121	if (pCfg->tsdbCfg.retentions[1].freq > 0) {	21!
122	++nRetention;	21✔
123	if (pCfg->tsdbCfg.retentions[2].freq > 0) {	21!
124	++nRetention;	21✔
125	}
126	}
127	SJson *pNodeRetentions = tjsonCreateArray();	21✔
128	if (pNodeRetentions == NULL) {	21!
129	return terrno;	×
130	}
131	TAOS_CHECK_RETURN(tjsonAddItemToObject(pJson, "retentions", pNodeRetentions));	21!
132	for (int32_t i = 0; i < nRetention; ++i) {	84✔
133	SJson *pNodeRetention = tjsonCreateObject();	63✔
134	const SRetention *pRetention = pCfg->tsdbCfg.retentions + i;	63✔
135	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pNodeRetention, "freq", pRetention->freq));	63!
136	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pNodeRetention, "freqUnit", pRetention->freqUnit));	63!
137	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pNodeRetention, "keep", pRetention->keep));	63!
138	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pNodeRetention, "keepUnit", pRetention->keepUnit));	63!
139	TAOS_CHECK_RETURN(tjsonAddItemToArray(pNodeRetentions, pNodeRetention));	63!
140	}
141	}
142	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "tsdb.encryptAlgorithm", pCfg->tsdbCfg.encryptAlgorithm));	13,314!
143	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.vgId", pCfg->walCfg.vgId));	13,313!
144	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.fsyncPeriod", pCfg->walCfg.fsyncPeriod));	13,315!
145	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.retentionPeriod", pCfg->walCfg.retentionPeriod));	13,315!
146	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.rollPeriod", pCfg->walCfg.rollPeriod));	13,314!
147	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.retentionSize", pCfg->walCfg.retentionSize));	13,312!
148	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.segSize", pCfg->walCfg.segSize));	13,315!
149	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.level", pCfg->walCfg.level));	13,315!
150	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.clearFiles", pCfg->walCfg.clearFiles));	13,313!
151	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "wal.encryptAlgorithm", pCfg->walCfg.encryptAlgorithm));	13,315!
152	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "tdbEncryptAlgorithm", pCfg->tdbEncryptAlgorithm));	13,314!
153	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "sstTrigger", pCfg->sttTrigger));	13,315!
154	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashBegin", pCfg->hashBegin));	13,314!
155	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashEnd", pCfg->hashEnd));	13,313!
156	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashChange", pCfg->hashChange));	13,315!
157	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashMethod", pCfg->hashMethod));	13,313!
158	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashPrefix", pCfg->hashPrefix));	13,314!
159	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "hashSuffix", pCfg->hashSuffix));	13,313!
160	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "syncCfg.replicaNum", pCfg->syncCfg.replicaNum));	13,314!
161	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "syncCfg.myIndex", pCfg->syncCfg.myIndex));	13,313!
162	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "syncCfg.changeVersion", pCfg->syncCfg.changeVersion));	13,314!
163	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vndStats.stables", pCfg->vndStats.numOfSTables));	13,312!
164	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vndStats.ctables", pCfg->vndStats.numOfCTables));	13,315!
165	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vndStats.ntables", pCfg->vndStats.numOfNTables));	13,314!
166	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vndStats.timeseries", pCfg->vndStats.numOfTimeSeries));	13,312!
167	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(pJson, "vndStats.ntimeseries", pCfg->vndStats.numOfNTimeSeries));	13,313!
168
169	SJson *nodeInfo = tjsonCreateArray();	13,314✔
170	if (nodeInfo == NULL) {	13,314!
171	return terrno;	×
172	}
173	TAOS_CHECK_RETURN(tjsonAddItemToObject(pJson, "syncCfg.nodeInfo", nodeInfo));	13,314!
174	vDebug("vgId:%d, encode config, replicas:%d totalReplicas:%d selfIndex:%d changeVersion:%d", pCfg->vgId,	13,314✔
175	pCfg->syncCfg.replicaNum, pCfg->syncCfg.totalReplicaNum, pCfg->syncCfg.myIndex, pCfg->syncCfg.changeVersion);
176	for (int i = 0; i < pCfg->syncCfg.totalReplicaNum; ++i) {	30,571✔
177	SJson *info = tjsonCreateObject();	17,257✔
178	if (info == NULL) {	17,261!
179	return terrno;	×
180	}
181
182	SNodeInfo pNode = (SNodeInfo )&pCfg->syncCfg.nodeInfo[i];	17,261✔
183	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(info, "nodePort", pNode->nodePort));	17,261!
184	TAOS_CHECK_RETURN(tjsonAddStringToObject(info, "nodeFqdn", pNode->nodeFqdn));	17,262!
185	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(info, "nodeId", pNode->nodeId));	17,262!
186	TAOS_CHECK_RETURN(tjsonAddIntegerToObject(info, "clusterId", pNode->clusterId));	17,261!
187	TAOS_CHECK_RETURN(tjsonAddStringToObject(info, "isReplica", vnodeRoleToStr(pNode->nodeRole)));	17,262!
188	TAOS_CHECK_RETURN(tjsonAddItemToArray(nodeInfo, info));	17,260!
189	vDebug("vgId:%d, encode config, replica:%d ep:%s:%u dnode:%d", pCfg->vgId, i, pNode->nodeFqdn, pNode->nodePort,	17,259✔
190	pNode->nodeId);
191	}
192
193	return 0;	13,314✔
194	}
195
196	int vnodeDecodeConfig(const SJson pJson, void pObj) {	7,059✔
197	SVnodeCfg pCfg = (SVnodeCfg )pObj;	7,059✔
198
199	int32_t code;
200	tjsonGetNumberValue(pJson, "vgId", pCfg->vgId, code);	7,059✔
201	if (code) return code;	7,057!
202	if ((code = tjsonGetStringValue(pJson, "dbname", pCfg->dbname))) return code;	7,057!
203	tjsonGetNumberValue(pJson, "dbId", pCfg->dbId, code);	7,061✔
204	if (code) return code;	7,067!
205	tjsonGetNumberValue(pJson, "szPage", pCfg->szPage, code);	7,067✔
206	if (code) return code;	7,066!
207	tjsonGetNumberValue(pJson, "szCache", pCfg->szCache, code);	7,066✔
208	if (code) return code;	7,065!
209	tjsonGetNumberValue(pJson, "cacheLast", pCfg->cacheLast, code);	7,065✔
210	if (code) return code;	7,068!
211	tjsonGetNumberValue(pJson, "cacheLastSize", pCfg->cacheLastSize, code);	7,068✔
212	if (code) return code;	7,070!
213	tjsonGetNumberValue(pJson, "szBuf", pCfg->szBuf, code);	7,070✔
214	if (code) return code;	7,067!
215	tjsonGetNumberValue(pJson, "isHeap", pCfg->isHeap, code);	7,067✔
216	if (code) return code;	7,068!
217	tjsonGetNumberValue(pJson, "isWeak", pCfg->isWeak, code);	7,068✔
218	if (code) return code;	7,064!
219	tjsonGetNumberValue(pJson, "isTsma", pCfg->isTsma, code);	7,064✔
220	if (code) return code;	7,066!
221	tjsonGetNumberValue(pJson, "isRsma", pCfg->isRsma, code);	7,066✔
222	if (code) return code;	7,067!
223	tjsonGetNumberValue(pJson, "precision", pCfg->tsdbCfg.precision, code);	7,067✔
224	if (code) return code;	7,070!
225	tjsonGetNumberValue(pJson, "update", pCfg->tsdbCfg.update, code);	7,070✔
226	if (code) return code;	7,068!
227	tjsonGetNumberValue(pJson, "compression", pCfg->tsdbCfg.compression, code);	7,068✔
228	if (code) return code;	7,067!
229	tjsonGetNumberValue(pJson, "slLevel", pCfg->tsdbCfg.slLevel, code);	7,067✔
230	if (code) return code;	7,065!
231	tjsonGetNumberValue(pJson, "daysPerFile", pCfg->tsdbCfg.days, code);	7,065✔
232	if (code) return code;	7,069!
233	tjsonGetNumberValue(pJson, "minRows", pCfg->tsdbCfg.minRows, code);	7,069✔
234	if (code) return code;	7,065!
235	tjsonGetNumberValue(pJson, "maxRows", pCfg->tsdbCfg.maxRows, code);	7,065✔
236	if (code) return code;	7,067!
237	tjsonGetNumberValue(pJson, "keep0", pCfg->tsdbCfg.keep0, code);	7,067✔
238	if (code) return code;	7,069!
239	tjsonGetNumberValue(pJson, "keep1", pCfg->tsdbCfg.keep1, code);	7,069✔
240	if (code) return code;	7,069!
241	tjsonGetNumberValue(pJson, "keep2", pCfg->tsdbCfg.keep2, code);	7,069✔
242	if (code) return code;	7,068!
243	tjsonGetNumberValue(pJson, "keepTimeOffset", pCfg->tsdbCfg.keepTimeOffset, code);	7,068✔
244	if (code) return code;	7,069!
245	SJson *pNodeRetentions = tjsonGetObjectItem(pJson, "retentions");	7,069✔
246	int32_t nRetention = tjsonGetArraySize(pNodeRetentions);	7,066✔
247	if (nRetention > TSDB_RETENTION_MAX) {	7,064!
248	nRetention = TSDB_RETENTION_MAX;	×
249	}
250	for (int32_t i = 0; i < nRetention; ++i) {	7,115✔
251	SJson *pNodeRetention = tjsonGetArrayItem(pNodeRetentions, i);	51✔
252	tjsonGetNumberValue(pNodeRetention, "freq", (pCfg->tsdbCfg.retentions)[i].freq, code);	51✔
253	if (code) return code;	51!
254	tjsonGetNumberValue(pNodeRetention, "freqUnit", (pCfg->tsdbCfg.retentions)[i].freqUnit, code);	51✔
255	if (code) return code;	51!
256	tjsonGetNumberValue(pNodeRetention, "keep", (pCfg->tsdbCfg.retentions)[i].keep, code);	51✔
257	if (code) return code;	51!
258	tjsonGetNumberValue(pNodeRetention, "keepUnit", (pCfg->tsdbCfg.retentions)[i].keepUnit, code);	51✔
259	if (code) return code;	51!
260	}
261	tjsonGetNumberValue(pJson, "tsdb.encryptAlgorithm", pCfg->tsdbCfg.encryptAlgorithm, code);	7,064✔
262	if (code) return code;	7,068!
263	#if defined(TD_ENTERPRISE)
264	if (pCfg->tsdbCfg.encryptAlgorithm == DND_CA_SM4) {	7,068✔
265	if (tsEncryptKey[0] == 0) {	1!
266	return terrno = TSDB_CODE_DNODE_INVALID_ENCRYPTKEY;	×
267	} else {
268	strncpy(pCfg->tsdbCfg.encryptKey, tsEncryptKey, ENCRYPT_KEY_LEN);	1✔
269	}
270	}
271	#endif
272	tjsonGetNumberValue(pJson, "wal.vgId", pCfg->walCfg.vgId, code);	7,068✔
273	if (code) return code;	7,068!
274	tjsonGetNumberValue(pJson, "wal.fsyncPeriod", pCfg->walCfg.fsyncPeriod, code);	7,068✔
275	if (code) return code;	7,068!
276	tjsonGetNumberValue(pJson, "wal.retentionPeriod", pCfg->walCfg.retentionPeriod, code);	7,068✔
277	if (code) return code;	7,070!
278	tjsonGetNumberValue(pJson, "wal.rollPeriod", pCfg->walCfg.rollPeriod, code);	7,070✔
279	if (code) return code;	7,069!
280	tjsonGetNumberValue(pJson, "wal.retentionSize", pCfg->walCfg.retentionSize, code);	7,069✔
281	if (code) return code;	7,070!
282	tjsonGetNumberValue(pJson, "wal.segSize", pCfg->walCfg.segSize, code);	7,070✔
283	if (code) return code;	7,069!
284	tjsonGetNumberValue(pJson, "wal.level", pCfg->walCfg.level, code);	7,069✔
285	if (code) return code;	7,069!
286	tjsonGetNumberValue(pJson, "wal.clearFiles", pCfg->walCfg.clearFiles, code);	7,069✔
287	if (code) return code;	7,069!
288	tjsonGetNumberValue(pJson, "wal.encryptAlgorithm", pCfg->walCfg.encryptAlgorithm, code);	7,069✔
289	if (code) return code;	7,070!
290	#if defined(TD_ENTERPRISE)
291	if (pCfg->walCfg.encryptAlgorithm == DND_CA_SM4) {	7,070✔
292	if (tsEncryptKey[0] == 0) {	1!
293	return terrno = TSDB_CODE_DNODE_INVALID_ENCRYPTKEY;	×
294	} else {
295	strncpy(pCfg->walCfg.encryptKey, tsEncryptKey, ENCRYPT_KEY_LEN);	1✔
296	}
297	}
298	#endif
299	tjsonGetNumberValue(pJson, "tdbEncryptAlgorithm", pCfg->tdbEncryptAlgorithm, code);	7,070✔
300	if (code) return code;	7,068!
301	#if defined(TD_ENTERPRISE)
302	if (pCfg->tdbEncryptAlgorithm == DND_CA_SM4) {	7,068✔
303	if (tsEncryptKey[0] == 0) {	1!
304	return terrno = TSDB_CODE_DNODE_INVALID_ENCRYPTKEY;	×
305	} else {
306	strncpy(pCfg->tdbEncryptKey, tsEncryptKey, ENCRYPT_KEY_LEN);	1✔
307	}
308	}
309	#endif
310	tjsonGetNumberValue(pJson, "sstTrigger", pCfg->sttTrigger, code);	7,068✔
311	if (code < 0) pCfg->sttTrigger = TSDB_DEFAULT_SST_TRIGGER;	7,070!
312	tjsonGetNumberValue(pJson, "hashBegin", pCfg->hashBegin, code);	7,070✔
313	if (code) return code;	7,070!
314	tjsonGetNumberValue(pJson, "hashEnd", pCfg->hashEnd, code);	7,070✔
315	if (code) return code;	7,068!
316	tjsonGetNumberValue(pJson, "hashChange", pCfg->hashChange, code);	7,068✔
317	if (code) return code;	7,068!
318	tjsonGetNumberValue(pJson, "hashMethod", pCfg->hashMethod, code);	7,068✔
319	if (code) return code;	7,068!
320	tjsonGetNumberValue(pJson, "hashPrefix", pCfg->hashPrefix, code);	7,068✔
321	if (code < 0) pCfg->hashPrefix = TSDB_DEFAULT_HASH_PREFIX;	7,069!
322	tjsonGetNumberValue(pJson, "hashSuffix", pCfg->hashSuffix, code);	7,069✔
323	if (code < 0) pCfg->hashSuffix = TSDB_DEFAULT_HASH_SUFFIX;	7,070!
324
325	tjsonGetNumberValue(pJson, "syncCfg.replicaNum", pCfg->syncCfg.replicaNum, code);	7,070✔
326	if (code) return code;	7,068!
327	tjsonGetNumberValue(pJson, "syncCfg.myIndex", pCfg->syncCfg.myIndex, code);	7,068✔
328	if (code) return code;	7,070!
329	tjsonGetNumberValue(pJson, "syncCfg.changeVersion", pCfg->syncCfg.changeVersion, code);	7,070✔
330	if (code) return code;	7,069!
331
332	tjsonGetNumberValue(pJson, "vndStats.stables", pCfg->vndStats.numOfSTables, code);	7,069✔
333	if (code) return code;	7,070!
334	tjsonGetNumberValue(pJson, "vndStats.ctables", pCfg->vndStats.numOfCTables, code);	7,070✔
335	if (code) return code;	7,069!
336	tjsonGetNumberValue(pJson, "vndStats.ntables", pCfg->vndStats.numOfNTables, code);	7,069✔
337	if (code) return code;	7,069!
338	tjsonGetNumberValue(pJson, "vndStats.timeseries", pCfg->vndStats.numOfTimeSeries, code);	7,069✔
339	if (code) return code;	7,070!
340	tjsonGetNumberValue(pJson, "vndStats.ntimeseries", pCfg->vndStats.numOfNTimeSeries, code);	7,070✔
341	if (code) return code;	7,070!
342
343	SJson *nodeInfo = tjsonGetObjectItem(pJson, "syncCfg.nodeInfo");	7,070✔
344	int arraySize = tjsonGetArraySize(nodeInfo);	7,070✔
345	pCfg->syncCfg.totalReplicaNum = arraySize;	7,070✔
346
347	vDebug("vgId:%d, decode config, replicas:%d totalReplicas:%d selfIndex:%d", pCfg->vgId, pCfg->syncCfg.replicaNum,	7,070✔
348	pCfg->syncCfg.totalReplicaNum, pCfg->syncCfg.myIndex);
349	for (int i = 0; i < arraySize; ++i) {	18,024✔
350	SJson *info = tjsonGetArrayItem(nodeInfo, i);	10,953✔
351	SNodeInfo *pNode = &pCfg->syncCfg.nodeInfo[i];	10,963✔
352	if (info == NULL) return -1;	10,963!
353	tjsonGetNumberValue(info, "nodePort", pNode->nodePort, code);	10,963✔
354	if (code) return code;	10,964!
355	code = tjsonGetStringValue(info, "nodeFqdn", pNode->nodeFqdn);	10,964✔
356	tjsonGetNumberValue(info, "nodeId", pNode->nodeId, code);	10,962✔
357	if (code) return code;	10,961!
358	tjsonGetNumberValue(info, "clusterId", pNode->clusterId, code);	10,961✔
359	if (code) return code;	10,963!
360	char role[10] = {0};	10,963✔
361	code = tjsonGetStringValue(info, "isReplica", role);	10,963✔
362	if (code) return code;	10,963!
363	if (strlen(role) != 0) {	10,963!
364	pNode->nodeRole = vnodeStrToRole(role);	10,963✔
365	} else {
UNCOV 366	pNode->nodeRole = TAOS_SYNC_ROLE_VOTER;	×
367	}
368	vDebug("vgId:%d, decode config, replica:%d ep:%s:%u dnode:%d", pCfg->vgId, i, pNode->nodeFqdn, pNode->nodePort,	10,953✔
369	pNode->nodeId);
370	}
371
372	tjsonGetNumberValue(pJson, "tsdbPageSize", pCfg->tsdbPageSize, code);	7,071✔
373	if (code < 0 \|\| pCfg->tsdbPageSize < TSDB_MIN_PAGESIZE_PER_VNODE * 1024) {	7,069!
374	pCfg->tsdbPageSize = TSDB_DEFAULT_TSDB_PAGESIZE * 1024;	×
375	}
376
377	tjsonGetNumberValue(pJson, "s3ChunkSize", pCfg->s3ChunkSize, code);	7,069✔
378	if (code < 0 \|\| pCfg->s3ChunkSize < TSDB_MIN_S3_CHUNK_SIZE) {	7,070!
379	pCfg->s3ChunkSize = TSDB_DEFAULT_S3_CHUNK_SIZE;	×
380	}
381	tjsonGetNumberValue(pJson, "s3KeepLocal", pCfg->s3KeepLocal, code);	7,070✔
382	if (code < 0 \|\| pCfg->s3KeepLocal < TSDB_MIN_S3_KEEP_LOCAL) {	7,070!
383	pCfg->s3KeepLocal = TSDB_DEFAULT_S3_KEEP_LOCAL;	×
384	}
385	tjsonGetNumberValue(pJson, "s3Compact", pCfg->s3Compact, code);	7,070✔
386	if (code < 0) {	7,069!
387	pCfg->s3Compact = TSDB_DEFAULT_S3_COMPACT;	×
388	}
389
390	return 0;	7,069✔
391	}
392
393	int vnodeValidateTableHash(SVnode pVnode, char tableFName) {	53,865✔
394	uint32_t hashValue = 0;	53,865✔
395
396	switch (pVnode->config.hashMethod) {	53,865✔
397	default:
398	hashValue = taosGetTbHashVal(tableFName, strlen(tableFName), pVnode->config.hashMethod, pVnode->config.hashPrefix,	107,724✔
399	pVnode->config.hashSuffix);	53,865✔
400	break;	53,859✔
401	}
402
403	if (hashValue < pVnode->config.hashBegin \|\| hashValue > pVnode->config.hashEnd) {	53,859✔
404	return terrno = TSDB_CODE_VND_HASH_MISMATCH;	103✔
405	}
406
407	return 0;	53,756✔
408	}

taosdata / TDengine / #3533

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous