From d6e8a0ede17931eb5643f7fbd59a6ebfa1da04fb Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 26 Jan 2022 19:19:49 +0800 Subject: [PATCH] stop srv gracefully --- source/libs/transport/src/transSrv.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/source/libs/transport/src/transSrv.c b/source/libs/transport/src/transSrv.c index a5ee1f1c63..802f2cac9d 100644 --- a/source/libs/transport/src/transSrv.c +++ b/source/libs/transport/src/transSrv.c @@ -646,6 +646,7 @@ void destroyWorkThrd(SWorkThrdObj* pThrd) { if (pThrd == NULL) { return; } + uv_stop(pThrd->loop); pthread_join(pThrd->thread, NULL); // free(srv->pipe[i]); free(pThrd->loop); @@ -658,6 +659,7 @@ void taosCloseServer(void* arg) { for (int i = 0; i < srv->numOfThreads; i++) { destroyWorkThrd(srv->pThreadObj[i]); } + uv_stop(srv->loop); free(srv->loop); free(srv->pipe); free(srv->pThreadObj);