From 0b096647f0e0043a09cb4b078d7d873ce06e9133 Mon Sep 17 00:00:00 2001 From: Shuduo Sang Date: Fri, 29 May 2020 11:38:16 +0800 Subject: [PATCH] fix resource leak in dnodeVWrite.c [TD-445] --- src/dnode/src/dnodeVWrite.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/dnode/src/dnodeVWrite.c b/src/dnode/src/dnodeVWrite.c index bbddfa0927..20c50c5f8c 100644 --- a/src/dnode/src/dnodeVWrite.c +++ b/src/dnode/src/dnodeVWrite.c @@ -129,7 +129,10 @@ void *dnodeAllocateVnodeWqueue(void *pVnode) { if (pWorker->qset == NULL) { pWorker->qset = taosOpenQset(); - if (pWorker->qset == NULL) return NULL; + if (pWorker->qset == NULL) { + taosCloseQueue(queue); + return NULL; + } taosAddIntoQset(pWorker->qset, queue, pVnode); pWorker->qall = taosAllocateQall();