TD-1645

f949b732 · 陶建辉(Jeff) · 30284cbe · f949b732
隐藏空白更改
内联并排

Showing with 8 addition and 1 deletion

src/rpc/src/rpcTcp.c src/rpc/src/rpcTcp.c +8 -1

未找到文件。
--- a/src/rpc/src/rpcTcp.c
+++ b/src/rpc/src/rpcTcp.c
@@ -205,7 +205,14 @@ void taosStopTcpServer(void *handle) {

  if (pServerObj == NULL) return;
  if(pServerObj->fd >=0) shutdown(pServerObj->fd, SHUT_RD);
-  if (taosCheckPthreadValid(pServerObj->thread)) pthread_join(pServerObj->thread, NULL);
+
+  if (taosCheckPthreadValid(pServerObj->thread)) {
+    if (pServerObj->thread == pthread_self()) {
+      pthread_detach(pthread_self());
+    } else {
+      pthread_join(pServerObj->thread, NULL);
+    }
+  }

  tDebug("%s TCP server is stopped", pServerObj->label);
 }