From 9796483609304405b19f8ca770cac1152f175895 Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Wed, 20 Sep 2023 15:42:25 +0800 Subject: [PATCH] enh: support async fetch for sync request --- source/client/src/clientImpl.c | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/source/client/src/clientImpl.c b/source/client/src/clientImpl.c index c78ba4c4a0..7d0b1dddd6 100644 --- a/source/client/src/clientImpl.c +++ b/source/client/src/clientImpl.c @@ -2553,6 +2553,14 @@ static void fetchCallback(void* pResult, void* param, int32_t code) { } void taosAsyncFetchImpl(SRequestObj* pRequest, __taos_async_fn_t fp, void* param) { + if (pRequest->syncQuery) { + if (pRequest->body.param) { + tsem_destroy(&((SSyncQueryParam *)pRequest->body.param)->sem); + } + taosMemoryFree(pRequest->body.param); + } + + pRequest->syncQuery = false; pRequest->body.fetchFp = fp; pRequest->body.param = param;