xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

[td-1373]

This commit is contained in:
Haojun Liao 2020-10-22 15:53:25 +08:00
parent d3522fecf4
commit ad499c5541
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/query/src/qTsbuf.c
View File

@ -979,7 +979,7 @@ int32_t tsBufGetNumOfVnodes(STSBuf* pTSBuf) {
} }
void tsBufGetVnodeIdList(STSBuf* pTSBuf, int32_t* num, int32_t** vnodeId) { void tsBufGetVnodeIdList(STSBuf* pTSBuf, int32_t* num, int32_t** vnodeId) {
int32_t size = tsBugGetNumOfVnodes(pTSBuf); int32_t size = tsBufGetNumOfVnodes(pTSBuf);
if (num != NULL) { if (num != NULL) {
*num = size; *num = size;
} }
@ -989,7 +989,7 @@ void tsBufGetVnodeIdList(STSBuf* pTSBuf, int32_t* num, int32_t** vnodeId) {
return; return;
} }
(*vnodeId) = malloc(tsBugGetNumOfVnodes(pTSBuf) * sizeof(int32_t)); (*vnodeId) = malloc(tsBufGetNumOfVnodes(pTSBuf) * sizeof(int32_t));
for(int32_t i = 0; i < size; ++i) { for(int32_t i = 0; i < size; ++i) {
(*vnodeId)[i] = pTSBuf->pData[i].info.vnode; (*vnodeId)[i] = pTSBuf->pData[i].info.vnode;