提交 d6e8a0ed 编写于 作者: dengyihao's avatar dengyihao

stop srv gracefully

上级 e864b0a1
...@@ -646,6 +646,7 @@ void destroyWorkThrd(SWorkThrdObj* pThrd) { ...@@ -646,6 +646,7 @@ void destroyWorkThrd(SWorkThrdObj* pThrd) {
if (pThrd == NULL) { if (pThrd == NULL) {
return; return;
} }
uv_stop(pThrd->loop);
pthread_join(pThrd->thread, NULL); pthread_join(pThrd->thread, NULL);
// free(srv->pipe[i]); // free(srv->pipe[i]);
free(pThrd->loop); free(pThrd->loop);
...@@ -658,6 +659,7 @@ void taosCloseServer(void* arg) { ...@@ -658,6 +659,7 @@ void taosCloseServer(void* arg) {
for (int i = 0; i < srv->numOfThreads; i++) { for (int i = 0; i < srv->numOfThreads; i++) {
destroyWorkThrd(srv->pThreadObj[i]); destroyWorkThrd(srv->pThreadObj[i]);
} }
uv_stop(srv->loop);
free(srv->loop); free(srv->loop);
free(srv->pipe); free(srv->pipe);
free(srv->pThreadObj); free(srv->pThreadObj);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册