From 69767f173f2534b2d61ba2ddb1098cac4be3e0b6 Mon Sep 17 00:00:00 2001 From: Alex Duan <417921451@qq.com> Date: Fri, 8 Apr 2022 11:27:51 +0800 Subject: [PATCH] [TS-238](tsdb): fixed no tables after tag filter no response --- src/tsdb/src/tsdbMemTable.c | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/src/tsdb/src/tsdbMemTable.c b/src/tsdb/src/tsdbMemTable.c index 13db0258cb..b3b43fd5cf 100644 --- a/src/tsdb/src/tsdbMemTable.c +++ b/src/tsdb/src/tsdbMemTable.c @@ -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 ret = TSDB_CODE_SUCCESS; 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 pCtlData->command = htonl(pCtlData->command); @@ -1186,7 +1177,16 @@ int32_t tsdbInsertControlData(STsdbRepo* pRepo, SSubmitBlk* pBlock, SShellSubmit // single table 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 size_t nsize = sizeof(SControlDataInfo) + tnum * sizeof(int32_t); SControlDataInfo* pNew = (SControlDataInfo* )tmalloc(nsize); -- GitLab