提交 69767f17 编写于 作者: A Alex Duan

[TS-238]<feature>(tsdb): fixed no tables after tag filter no response

上级 54282b6f
...@@ -1146,15 +1146,6 @@ int32_t tsdbTableGroupInfo(STableGroupInfo* pTableGroup, int32_t * ptids) { ...@@ -1146,15 +1146,6 @@ int32_t tsdbTableGroupInfo(STableGroupInfo* pTableGroup, int32_t * ptids) {
int32_t tsdbInsertControlData(STsdbRepo* pRepo, SSubmitBlk* pBlock, SShellSubmitRspMsg *pRsp, tsem_t** ppSem) { int32_t tsdbInsertControlData(STsdbRepo* pRepo, SSubmitBlk* pBlock, SShellSubmitRspMsg *pRsp, tsem_t** ppSem) {
int32_t ret = TSDB_CODE_SUCCESS; int32_t ret = TSDB_CODE_SUCCESS;
SControlData* pCtlData = (SControlData* )pBlock->data; SControlData* pCtlData = (SControlData* )pBlock->data;
// INIT SEM FOR ASYNC WAIT COMMIT RESULT
if (ppSem) {
*ppSem = (tsem_t* )tmalloc(sizeof(tsem_t));
ret = tsem_init(*ppSem, 0, 0);
if(ret != 0) {
return TAOS_SYSTEM_ERROR(ret);
}
}
// anti-serialize // anti-serialize
pCtlData->command = htonl(pCtlData->command); pCtlData->command = htonl(pCtlData->command);
...@@ -1186,7 +1177,16 @@ int32_t tsdbInsertControlData(STsdbRepo* pRepo, SSubmitBlk* pBlock, SShellSubmit ...@@ -1186,7 +1177,16 @@ int32_t tsdbInsertControlData(STsdbRepo* pRepo, SSubmitBlk* pBlock, SShellSubmit
// single table // single table
tnum = 1; tnum = 1;
} }
// INIT SEM FOR ASYNC WAIT COMMIT RESULT
if (ppSem) {
*ppSem = (tsem_t* )tmalloc(sizeof(tsem_t));
ret = tsem_init(*ppSem, 0, 0);
if(ret != 0) {
return TAOS_SYSTEM_ERROR(ret);
}
}
// server data set // server data set
size_t nsize = sizeof(SControlDataInfo) + tnum * sizeof(int32_t); size_t nsize = sizeof(SControlDataInfo) + tnum * sizeof(int32_t);
SControlDataInfo* pNew = (SControlDataInfo* )tmalloc(nsize); SControlDataInfo* pNew = (SControlDataInfo* )tmalloc(nsize);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册