fix(query): release reader's lock if not composed block

This commit is contained in:
Minglei Jin 2023-01-31 15:04:48 +08:00
parent 251fdd35ba
commit 0257c4a90b
1 changed files with 6 additions and 1 deletions

View File

@ -628,7 +628,12 @@ static int32_t tsdbReleaseReader(STsdbReader* pReader) {
return code;
}
void tsdbReleaseDataBlock(STsdbReader* pReader) { tsdbReleaseReader(pReader); }
void tsdbReleaseDataBlock(STsdbReader* pReader) {
SReaderStatus* pStatus = &pReader->status;
if (!pStatus->composedDataBlock) {
tsdbReleaseReader(pReader);
}
}
static int32_t tsdbReaderCreate(SVnode* pVnode, SQueryTableDataCond* pCond, STsdbReader** ppReader, int32_t capacity,
SSDataBlock* pResBlock, const char* idstr) {