#3527

Committed 12 Nov 2024 08:50PM UTC coverage: 60.819% (+0.6%) from 60.225%

Build # #3527

Build Type

push

travis-ci

Committed by GitHub

Commit Message

Merge pull request #28730 from taosdata/doc/analysis

Run Details

118574 of 249004 branches covered (47.62%)

Branch coverage included in aggregate %.

199137 of 273386 relevant lines covered (72.84%)

15792295.89 hits per line

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

55.28

/source/common/src/tmisce.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/>.
 */

#define _DEFAULT_SOURCE
#include "tmisce.h"
#include "tdatablock.h"
#include "tglobal.h"
#include "tjson.h"

int32_t taosGetFqdnPortFromEp(const char* ep, SEp* pEp) {
  pEp->port = 0;
  memset(pEp->fqdn, 0, TSDB_FQDN_LEN);
  strncpy(pEp->fqdn, ep, TSDB_FQDN_LEN - 1);

  char* temp = strchr(pEp->fqdn, ':');
  if (temp) {
    *temp = 0;
    pEp->port = atoi(temp + 1);
  }

  if (pEp->port == 0) {
    pEp->port = tsServerPort;
  }

  if (pEp->port <= 0) {
    return TSDB_CODE_INVALID_PARA;
  }

  return 0;
}

int32_t addEpIntoEpSet(SEpSet* pEpSet, const char* fqdn, uint16_t port) {
  if (pEpSet == NULL || fqdn == NULL || strlen(fqdn) == 0) {
    return TSDB_CODE_INVALID_PARA;
  }

  int32_t index = pEpSet->numOfEps;
  if (index >= sizeof(pEpSet->eps) / sizeof(pEpSet->eps[0])) {
    return TSDB_CODE_OUT_OF_RANGE;
  }
  tstrncpy(pEpSet->eps[index].fqdn, fqdn, tListLen(pEpSet->eps[index].fqdn));
  pEpSet->eps[index].port = port;
  pEpSet->numOfEps += 1;
  return 0;
}

bool isEpsetEqual(const SEpSet* s1, const SEpSet* s2) {
  if (s1->numOfEps != s2->numOfEps || s1->inUse != s2->inUse) {
    return false;
  }

  for (int32_t i = 0; i < s1->numOfEps; i++) {
    if (s1->eps[i].port != s2->eps[i].port || strncmp(s1->eps[i].fqdn, s2->eps[i].fqdn, TSDB_FQDN_LEN) != 0)
      return false;
  }
  return true;
}

void epsetAssign(SEpSet* pDst, const SEpSet* pSrc) {
  if (pSrc == NULL || pDst == NULL) {
    return;
  }

  pDst->inUse = pSrc->inUse;
  pDst->numOfEps = pSrc->numOfEps;
  for (int32_t i = 0; i < pSrc->numOfEps; ++i) {
    pDst->eps[i].port = pSrc->eps[i].port;
    tstrncpy(pDst->eps[i].fqdn, pSrc->eps[i].fqdn, tListLen(pSrc->eps[i].fqdn));
  }
}

void epAssign(SEp* pDst, SEp* pSrc) {
  if (pSrc == NULL || pDst == NULL) {
    return;
  }
  memset(pDst->fqdn, 0, tListLen(pSrc->fqdn));
  tstrncpy(pDst->fqdn, pSrc->fqdn, tListLen(pSrc->fqdn));
  pDst->port = pSrc->port;
}

void epsetSort(SEpSet* pDst) {
  if (pDst->numOfEps <= 1) {
    return;
  }
  int validIdx = false;
  SEp ep = {0};
  if (pDst->inUse >= 0 && pDst->inUse < pDst->numOfEps) {
    validIdx = true;
    epAssign(&ep, &pDst->eps[pDst->inUse]);
  }

  for (int i = 0; i < pDst->numOfEps - 1; i++) {
    for (int j = 0; j < pDst->numOfEps - 1 - i; j++) {
      SEp* f = &pDst->eps[j];
      SEp* s = &pDst->eps[j + 1];
      int  cmp = strncmp(f->fqdn, s->fqdn, sizeof(f->fqdn));
      if (cmp > 0 || (cmp == 0 && f->port > s->port)) {
        SEp ep1 = {0};
        epAssign(&ep1, f);
        epAssign(f, s);
        epAssign(s, &ep1);
      }
    }
  }
  if (validIdx == true)
    for (int i = 0; i < pDst->numOfEps; i++) {
      int cmp = strncmp(ep.fqdn, pDst->eps[i].fqdn, sizeof(ep.fqdn));
      if (cmp == 0 && ep.port == pDst->eps[i].port) {
        pDst->inUse = i;
        break;
      }
    }
}

void updateEpSet_s(SCorEpSet* pEpSet, SEpSet* pNewEpSet) {
  taosCorBeginWrite(&pEpSet->version);
  pEpSet->epSet = *pNewEpSet;
  taosCorEndWrite(&pEpSet->version);
}

SEpSet getEpSet_s(SCorEpSet* pEpSet) {
  SEpSet ep = {0};
  taosCorBeginRead(&pEpSet->version);
  ep = pEpSet->epSet;
  taosCorEndRead(&pEpSet->version);

  return ep;
}

int32_t epsetToStr(const SEpSet* pEpSet, char* pBuf, int32_t cap) {
  int32_t ret = 0;
  int32_t nwrite = 0;

  nwrite = snprintf(pBuf + nwrite, cap, "epset:{");
  if (nwrite <= 0 || nwrite >= cap) {
    return TSDB_CODE_OUT_OF_BUFFER;
  }
  cap -= nwrite;

  for (int _i = 0; (_i < pEpSet->numOfEps) && (cap > 0); _i++) {
    if (_i == pEpSet->numOfEps - 1) {
      ret = snprintf(pBuf + nwrite, cap, "%d. %s:%d", _i, pEpSet->eps[_i].fqdn, pEpSet->eps[_i].port);
    } else {
      ret = snprintf(pBuf + nwrite, cap, "%d. %s:%d, ", _i, pEpSet->eps[_i].fqdn, pEpSet->eps[_i].port);
    }

    if (ret <= 0 || ret >= cap) {
      return TSDB_CODE_OUT_OF_BUFFER;
    }

    nwrite += ret;
    cap -= ret;
  }

  if (cap <= 0) {
    return TSDB_CODE_OUT_OF_BUFFER;
  }

  ret = snprintf(pBuf + nwrite, cap, "}, inUse:%d", pEpSet->inUse);
  if (ret <= 0 || ret >= cap) {
    return TSDB_CODE_OUT_OF_BUFFER;
  } else {
    return TSDB_CODE_SUCCESS;
  }
}

int32_t taosGenCrashJsonMsg(int signum, char** pMsg, int64_t clusterId, int64_t startTime) {
  int32_t code = 0;
  SJson*  pJson = tjsonCreateObject();
  if (pJson == NULL) return terrno;

  char tmp[4096] = {0};

  TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "reportVersion", 1), NULL, _exit);

  TAOS_CHECK_GOTO(tjsonAddIntegerToObject(pJson, "clusterId", clusterId), NULL, _exit);
  TAOS_CHECK_GOTO(tjsonAddIntegerToObject(pJson, "startTime", startTime), NULL, _exit);

  // Do NOT invoke the taosGetFqdn here.
  // this function may be invoked when memory exception occurs,so we should assume that it is running in a memory locked
  // environment. The lock operation by taosGetFqdn may cause this program deadlock.
  TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "fqdn", tsLocalFqdn), NULL, _exit);

  TAOS_CHECK_GOTO(tjsonAddIntegerToObject(pJson, "pid", taosGetPId()), NULL, _exit);

  code = taosGetAppName(tmp, NULL);
  if (code != 0) {
    TAOS_CHECK_GOTO(code, NULL, _exit);
  }
  TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "appName", tmp), NULL, _exit);

  if (taosGetOsReleaseName(tmp, NULL, NULL, sizeof(tmp)) == 0) {
    TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "os", tmp), NULL, _exit);
  } else {
    // do nothing
  }

  float numOfCores = 0;
  if (taosGetCpuInfo(tmp, sizeof(tmp), &numOfCores) == 0) {
    TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "cpuModel", tmp), NULL, _exit);
    TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfCpu", numOfCores), NULL, _exit);
  } else {
    TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfCpu", tsNumOfCores), NULL, _exit);
  }

  int32_t nBytes = snprintf(tmp, sizeof(tmp), "%" PRId64 " kB", tsTotalMemoryKB);
  if (nBytes <= 9 || nBytes >= sizeof(tmp)) {
    TAOS_CHECK_GOTO(TSDB_CODE_OUT_OF_RANGE, NULL, _exit);
  }
  TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "memory", tmp), NULL, _exit);

  TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "version", td_version), NULL, _exit);
  TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "buildInfo", td_buildinfo), NULL, _exit);
  TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "gitInfo", td_gitinfo), NULL, _exit);

  TAOS_CHECK_GOTO(tjsonAddIntegerToObject(pJson, "crashSig", signum), NULL, _exit);
  TAOS_CHECK_GOTO(tjsonAddIntegerToObject(pJson, "crashTs", taosGetTimestampUs()), NULL, _exit);

#ifdef _TD_DARWIN_64
  taosLogTraceToBuf(tmp, sizeof(tmp), 4);
#elif !defined(WINDOWS)
  taosLogTraceToBuf(tmp, sizeof(tmp), 3);
#else
  taosLogTraceToBuf(tmp, sizeof(tmp), 8);
#endif

  TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "stackInfo", tmp), NULL, _exit);

  char* pCont = tjsonToString(pJson);
  if (pCont == NULL) {
    code = terrno;
    TAOS_CHECK_GOTO(code, NULL, _exit);
    goto _exit;
  }

  tjsonDelete(pJson);
  *pMsg = pCont;
  pJson = NULL;
_exit:
  tjsonDelete(pJson);
  TAOS_RETURN(code);
}

int32_t dumpConfToDataBlock(SSDataBlock* pBlock, int32_t startCol) {
  int32_t  code = 0;
  SConfig* pConf = taosGetCfg();
  if (pConf == NULL) {
    return TSDB_CODE_INVALID_CFG;
  }

  int32_t      numOfRows = 0;
  int32_t      col = startCol;
  SConfigItem* pItem = NULL;
  SConfigIter* pIter = NULL;

  int8_t locked = 0;

  TAOS_CHECK_GOTO(blockDataEnsureCapacity(pBlock, cfgGetSize(pConf)), NULL, _exit);

  TAOS_CHECK_GOTO(cfgCreateIter(pConf, &pIter), NULL, _exit);

  cfgLock(pConf);
  locked = 1;

  while ((pItem = cfgNextIter(pIter)) != NULL) {
    col = startCol;

    // GRANT_CFG_SKIP;
    char name[TSDB_CONFIG_OPTION_LEN + VARSTR_HEADER_SIZE] = {0};
    STR_WITH_MAXSIZE_TO_VARSTR(name, pItem->name, TSDB_CONFIG_OPTION_LEN + VARSTR_HEADER_SIZE);

    SColumnInfoData* pColInfo = taosArrayGet(pBlock->pDataBlock, col++);
    if (pColInfo == NULL) {
      code = terrno;
      TAOS_CHECK_GOTO(code, NULL, _exit);
    }

    TAOS_CHECK_GOTO(colDataSetVal(pColInfo, numOfRows, name, false), NULL, _exit);

    char    value[TSDB_CONFIG_VALUE_LEN + VARSTR_HEADER_SIZE] = {0};
    int32_t valueLen = 0;
    TAOS_CHECK_GOTO(cfgDumpItemValue(pItem, &value[VARSTR_HEADER_SIZE], TSDB_CONFIG_VALUE_LEN, &valueLen), NULL, _exit);
    varDataSetLen(value, valueLen);

    pColInfo = taosArrayGet(pBlock->pDataBlock, col++);
    if (pColInfo == NULL) {
      code = terrno;
      TAOS_CHECK_GOTO(code, NULL, _exit);
    }

    TAOS_CHECK_GOTO(colDataSetVal(pColInfo, numOfRows, value, false), NULL, _exit);

    char scope[TSDB_CONFIG_SCOPE_LEN + VARSTR_HEADER_SIZE] = {0};
    TAOS_CHECK_GOTO(cfgDumpItemScope(pItem, &scope[VARSTR_HEADER_SIZE], TSDB_CONFIG_SCOPE_LEN, &valueLen), NULL, _exit);
    varDataSetLen(scope, valueLen);

    pColInfo = taosArrayGet(pBlock->pDataBlock, col++);
    if (pColInfo == NULL) {
      code = terrno;
      TAOS_CHECK_GOTO(code, NULL, _exit);
    }
    TAOS_CHECK_GOTO(colDataSetVal(pColInfo, numOfRows, scope, false), NULL, _exit);

    numOfRows++;
  }
  pBlock->info.rows = numOfRows;
_exit:
  if (locked) cfgUnLock(pConf);
  cfgDestroyIter(pIter);
  TAOS_RETURN(code);
}

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	#define _DEFAULT_SOURCE
17	#include "tmisce.h"
18	#include "tdatablock.h"
19	#include "tglobal.h"
20	#include "tjson.h"
21
22	int32_t taosGetFqdnPortFromEp(const char* ep, SEp* pEp) {	40,668✔
23	pEp->port = 0;	40,668✔
24	memset(pEp->fqdn, 0, TSDB_FQDN_LEN);	40,668✔
25	strncpy(pEp->fqdn, ep, TSDB_FQDN_LEN - 1);	40,668✔
26
27	char* temp = strchr(pEp->fqdn, ':');	40,668✔
28	if (temp) {	40,668✔
29	*temp = 0;	32,233✔
30	pEp->port = atoi(temp + 1);	32,233✔
31	}
32
33	if (pEp->port == 0) {	40,668✔
34	pEp->port = tsServerPort;	8,436✔
35	}
36
37	if (pEp->port <= 0) {	40,668!
38	return TSDB_CODE_INVALID_PARA;	×
39	}
40
41	return 0;	40,668✔
42	}
43
44	int32_t addEpIntoEpSet(SEpSet* pEpSet, const char* fqdn, uint16_t port) {	1,107,829✔
45	if (pEpSet == NULL \|\| fqdn == NULL \|\| strlen(fqdn) == 0) {	1,107,829!
46	return TSDB_CODE_INVALID_PARA;	×
47	}
48
49	int32_t index = pEpSet->numOfEps;	1,107,848✔
50	if (index >= sizeof(pEpSet->eps) / sizeof(pEpSet->eps[0])) {	1,107,848!
51	return TSDB_CODE_OUT_OF_RANGE;	×
52	}
53	tstrncpy(pEpSet->eps[index].fqdn, fqdn, tListLen(pEpSet->eps[index].fqdn));	1,107,848✔
54	pEpSet->eps[index].port = port;	1,107,848✔
55	pEpSet->numOfEps += 1;	1,107,848✔
56	return 0;	1,107,848✔
57	}
58
59	bool isEpsetEqual(const SEpSet* s1, const SEpSet* s2) {	77,951✔
60	if (s1->numOfEps != s2->numOfEps \|\| s1->inUse != s2->inUse) {	77,951✔
61	return false;	2,573✔
62	}
63
64	for (int32_t i = 0; i < s1->numOfEps; i++) {	154,623✔
65	if (s1->eps[i].port != s2->eps[i].port \|\| strncmp(s1->eps[i].fqdn, s2->eps[i].fqdn, TSDB_FQDN_LEN) != 0)	79,534✔
66	return false;	289✔
67	}
68	return true;	75,089✔
69	}
70
71	void epsetAssign(SEpSet* pDst, const SEpSet* pSrc) {	57,799✔
72	if (pSrc == NULL \|\| pDst == NULL) {	57,799!
73	return;	×
74	}
75
76	pDst->inUse = pSrc->inUse;	57,799✔
77	pDst->numOfEps = pSrc->numOfEps;	57,799✔
78	for (int32_t i = 0; i < pSrc->numOfEps; ++i) {	116,986✔
79	pDst->eps[i].port = pSrc->eps[i].port;	59,187✔
80	tstrncpy(pDst->eps[i].fqdn, pSrc->eps[i].fqdn, tListLen(pSrc->eps[i].fqdn));	59,187✔
81	}
82	}
83
84	void epAssign(SEp* pDst, SEp* pSrc) {	202,578✔
85	if (pSrc == NULL \|\| pDst == NULL) {	202,578!
86	return;	×
87	}
88	memset(pDst->fqdn, 0, tListLen(pSrc->fqdn));	202,578✔
89	tstrncpy(pDst->fqdn, pSrc->fqdn, tListLen(pSrc->fqdn));	202,578✔
90	pDst->port = pSrc->port;	202,578✔
91	}
92
93	void epsetSort(SEpSet* pDst) {	1,092,076✔
94	if (pDst->numOfEps <= 1) {	1,092,076✔
95	return;	987,456✔
96	}
97	int validIdx = false;	104,620✔
98	SEp ep = {0};	104,620✔
99	if (pDst->inUse >= 0 && pDst->inUse < pDst->numOfEps) {	104,620!
100	validIdx = true;	104,625✔
101	epAssign(&ep, &pDst->eps[pDst->inUse]);	104,625✔
102	}
103
104	for (int i = 0; i < pDst->numOfEps - 1; i++) {	276,187✔
105	for (int j = 0; j < pDst->numOfEps - 1 - i; j++) {	416,209✔
106	SEp* f = &pDst->eps[j];	244,647✔
107	SEp* s = &pDst->eps[j + 1];	244,647✔
108	int cmp = strncmp(f->fqdn, s->fqdn, sizeof(f->fqdn));	244,647✔
109	if (cmp > 0 \|\| (cmp == 0 && f->port > s->port)) {	244,647!
110	SEp ep1 = {0};	32,651✔
111	epAssign(&ep1, f);	32,651✔
112	epAssign(f, s);	32,651✔
113	epAssign(s, &ep1);	32,651✔
114	}
115	}
116	}
117	if (validIdx == true)	104,625!
118	for (int i = 0; i < pDst->numOfEps; i++) {	155,765!
119	int cmp = strncmp(ep.fqdn, pDst->eps[i].fqdn, sizeof(ep.fqdn));	155,765✔
120	if (cmp == 0 && ep.port == pDst->eps[i].port) {	155,765!
121	pDst->inUse = i;	104,625✔
122	break;	104,625✔
123	}
124	}
125	}
126
127	void updateEpSet_s(SCorEpSet* pEpSet, SEpSet* pNewEpSet) {	2,648✔
128	taosCorBeginWrite(&pEpSet->version);	2,648!
129	pEpSet->epSet = *pNewEpSet;	2,648✔
130	taosCorEndWrite(&pEpSet->version);	2,648✔
131	}	2,648✔
132
133	SEpSet getEpSet_s(SCorEpSet* pEpSet) {	31,303,822✔
134	SEpSet ep = {0};	31,303,822✔
135	taosCorBeginRead(&pEpSet->version);	31,294,553!
136	ep = pEpSet->epSet;	31,624,432✔
137	taosCorEndRead(&pEpSet->version);	31,624,432!
138
139	return ep;	31,610,196✔
140	}
141
142	int32_t epsetToStr(const SEpSet* pEpSet, char* pBuf, int32_t cap) {	396,132✔
143	int32_t ret = 0;	396,132✔
144	int32_t nwrite = 0;	396,132✔
145
146	nwrite = snprintf(pBuf + nwrite, cap, "epset:{");	396,132✔
147	if (nwrite <= 0 \|\| nwrite >= cap) {	396,132!
148	return TSDB_CODE_OUT_OF_BUFFER;	×
149	}
150	cap -= nwrite;	396,132✔
151
152	for (int _i = 0; (_i < pEpSet->numOfEps) && (cap > 0); _i++) {	942,541!
153	if (_i == pEpSet->numOfEps - 1) {	546,413✔
154	ret = snprintf(pBuf + nwrite, cap, "%d. %s:%d", _i, pEpSet->eps[_i].fqdn, pEpSet->eps[_i].port);	396,112✔
155	} else {
156	ret = snprintf(pBuf + nwrite, cap, "%d. %s:%d, ", _i, pEpSet->eps[_i].fqdn, pEpSet->eps[_i].port);	150,301✔
157	}
158
159	if (ret <= 0 \|\| ret >= cap) {	546,413!
160	return TSDB_CODE_OUT_OF_BUFFER;	4✔
161	}
162
163	nwrite += ret;	546,409✔
164	cap -= ret;	546,409✔
165	}
166
167	if (cap <= 0) {	396,128!
168	return TSDB_CODE_OUT_OF_BUFFER;	×
169	}
170
171	ret = snprintf(pBuf + nwrite, cap, "}, inUse:%d", pEpSet->inUse);	396,128✔
172	if (ret <= 0 \|\| ret >= cap) {	396,128!
173	return TSDB_CODE_OUT_OF_BUFFER;	×
174	} else {
175	return TSDB_CODE_SUCCESS;	396,131✔
176	}
177	}
178
179	int32_t taosGenCrashJsonMsg(int signum, char** pMsg, int64_t clusterId, int64_t startTime) {	×
180	int32_t code = 0;	×
181	SJson* pJson = tjsonCreateObject();	×
182	if (pJson == NULL) return terrno;	×
183
184	char tmp[4096] = {0};	×
185
186	TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "reportVersion", 1), NULL, _exit);	×
187
188	TAOS_CHECK_GOTO(tjsonAddIntegerToObject(pJson, "clusterId", clusterId), NULL, _exit);	×
189	TAOS_CHECK_GOTO(tjsonAddIntegerToObject(pJson, "startTime", startTime), NULL, _exit);	×
190
191	// Do NOT invoke the taosGetFqdn here.
192	// this function may be invoked when memory exception occurs,so we should assume that it is running in a memory locked
193	// environment. The lock operation by taosGetFqdn may cause this program deadlock.
194	TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "fqdn", tsLocalFqdn), NULL, _exit);	×
195
196	TAOS_CHECK_GOTO(tjsonAddIntegerToObject(pJson, "pid", taosGetPId()), NULL, _exit);	×
197
198	code = taosGetAppName(tmp, NULL);	×
199	if (code != 0) {	×
200	TAOS_CHECK_GOTO(code, NULL, _exit);	×
201	}
202	TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "appName", tmp), NULL, _exit);	×
203
204	if (taosGetOsReleaseName(tmp, NULL, NULL, sizeof(tmp)) == 0) {	×
205	TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "os", tmp), NULL, _exit);	×
206	} else {
207	// do nothing
208	}
209
210	float numOfCores = 0;	×
211	if (taosGetCpuInfo(tmp, sizeof(tmp), &numOfCores) == 0) {	×
212	TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "cpuModel", tmp), NULL, _exit);	×
213	TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfCpu", numOfCores), NULL, _exit);	×
214	} else {
215	TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfCpu", tsNumOfCores), NULL, _exit);	×
216	}
217
218	int32_t nBytes = snprintf(tmp, sizeof(tmp), "%" PRId64 " kB", tsTotalMemoryKB);	×
219	if (nBytes <= 9 \|\| nBytes >= sizeof(tmp)) {	×
220	TAOS_CHECK_GOTO(TSDB_CODE_OUT_OF_RANGE, NULL, _exit);	×
221	}
222	TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "memory", tmp), NULL, _exit);	×
223
224	TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "version", td_version), NULL, _exit);	×
225	TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "buildInfo", td_buildinfo), NULL, _exit);	×
226	TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "gitInfo", td_gitinfo), NULL, _exit);	×
227
228	TAOS_CHECK_GOTO(tjsonAddIntegerToObject(pJson, "crashSig", signum), NULL, _exit);	×
229	TAOS_CHECK_GOTO(tjsonAddIntegerToObject(pJson, "crashTs", taosGetTimestampUs()), NULL, _exit);	×
230
231	#ifdef _TD_DARWIN_64
232	taosLogTraceToBuf(tmp, sizeof(tmp), 4);
233	#elif !defined(WINDOWS)
234	taosLogTraceToBuf(tmp, sizeof(tmp), 3);	×
235	#else
236	taosLogTraceToBuf(tmp, sizeof(tmp), 8);
237	#endif
238
239	TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "stackInfo", tmp), NULL, _exit);	×
240
241	char* pCont = tjsonToString(pJson);	×
242	if (pCont == NULL) {	×
243	code = terrno;	×
244	TAOS_CHECK_GOTO(code, NULL, _exit);	×
245	goto _exit;	×
246	}
247
248	tjsonDelete(pJson);	×
249	*pMsg = pCont;	×
250	pJson = NULL;	×
251	_exit:	×
252	tjsonDelete(pJson);	×
253	TAOS_RETURN(code);	×
254	}
255
256	int32_t dumpConfToDataBlock(SSDataBlock* pBlock, int32_t startCol) {	541✔
257	int32_t code = 0;	541✔
258	SConfig* pConf = taosGetCfg();	541✔
259	if (pConf == NULL) {	541!
260	return TSDB_CODE_INVALID_CFG;	×
261	}
262
263	int32_t numOfRows = 0;	541✔
264	int32_t col = startCol;	541✔
265	SConfigItem* pItem = NULL;	541✔
266	SConfigIter* pIter = NULL;	541✔
267
268	int8_t locked = 0;	541✔
269
270	TAOS_CHECK_GOTO(blockDataEnsureCapacity(pBlock, cfgGetSize(pConf)), NULL, _exit);	541!
271
272	TAOS_CHECK_GOTO(cfgCreateIter(pConf, &pIter), NULL, _exit);	541!
273
274	cfgLock(pConf);	541✔
275	locked = 1;	541✔
276
277	while ((pItem = cfgNextIter(pIter)) != NULL) {	56,369✔
278	col = startCol;	55,828✔
279
280	// GRANT_CFG_SKIP;
281	char name[TSDB_CONFIG_OPTION_LEN + VARSTR_HEADER_SIZE] = {0};	55,828✔
282	STR_WITH_MAXSIZE_TO_VARSTR(name, pItem->name, TSDB_CONFIG_OPTION_LEN + VARSTR_HEADER_SIZE);	55,828✔
283
284	SColumnInfoData* pColInfo = taosArrayGet(pBlock->pDataBlock, col++);	55,828✔
285	if (pColInfo == NULL) {	55,828!
286	code = terrno;	×
287	TAOS_CHECK_GOTO(code, NULL, _exit);	×
288	}
289
290	TAOS_CHECK_GOTO(colDataSetVal(pColInfo, numOfRows, name, false), NULL, _exit);	55,828!
291
292	char value[TSDB_CONFIG_VALUE_LEN + VARSTR_HEADER_SIZE] = {0};	55,828✔
293	int32_t valueLen = 0;	55,828✔
294	TAOS_CHECK_GOTO(cfgDumpItemValue(pItem, &value[VARSTR_HEADER_SIZE], TSDB_CONFIG_VALUE_LEN, &valueLen), NULL, _exit);	55,828!
295	varDataSetLen(value, valueLen);	55,828✔
296
297	pColInfo = taosArrayGet(pBlock->pDataBlock, col++);	55,828✔
298	if (pColInfo == NULL) {	55,828!
299	code = terrno;	×
300	TAOS_CHECK_GOTO(code, NULL, _exit);	×
301	}
302
303	TAOS_CHECK_GOTO(colDataSetVal(pColInfo, numOfRows, value, false), NULL, _exit);	55,828!
304
305	char scope[TSDB_CONFIG_SCOPE_LEN + VARSTR_HEADER_SIZE] = {0};	55,828✔
306	TAOS_CHECK_GOTO(cfgDumpItemScope(pItem, &scope[VARSTR_HEADER_SIZE], TSDB_CONFIG_SCOPE_LEN, &valueLen), NULL, _exit);	55,828!
307	varDataSetLen(scope, valueLen);	55,828✔
308
309	pColInfo = taosArrayGet(pBlock->pDataBlock, col++);	55,828✔
310	if (pColInfo == NULL) {	55,828!
311	code = terrno;	×
312	TAOS_CHECK_GOTO(code, NULL, _exit);	×
313	}
314	TAOS_CHECK_GOTO(colDataSetVal(pColInfo, numOfRows, scope, false), NULL, _exit);	55,828!
315
316	numOfRows++;	55,828✔
317	}
318	pBlock->info.rows = numOfRows;	541✔
319	_exit:	541✔
320	if (locked) cfgUnLock(pConf);	541!
321	cfgDestroyIter(pIter);	541✔
322	TAOS_RETURN(code);	541✔
323	}

taosdata / TDengine / #3527

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