[TD-2337]/<fix>: fix *Ref is not there* when unable to establish connection

[TD-2337]/<fix>: fix Ref is not there when unable to establish connection
7aa282c5 · stephenkgu · e9632baf · 7aa282c5
隐藏空白更改
内联并排

Showing with 11 addition and 9 deletion

src/client/src/tscSql.c src/client/src/tscSql.c +11 -9

未找到文件。
--- a/src/client/src/tscSql.c
+++ b/src/client/src/tscSql.c
@@ -292,16 +292,18 @@ void taos_close(TAOS *taos) {
  pObj->signature = NULL;
  taosTmrStopA(&(pObj->pTimer));
-  SSqlObj* pHb = (SSqlObj*)taosAcquireRef(tscObjRef, pObj->hbrid);
+  if (pObj->hbrid > 0) {
-  if (pHb != NULL) {
+    SSqlObj* pHb = (SSqlObj*)taosAcquireRef(tscObjRef, pObj->hbrid);
-    if (pHb->rpcRid > 0) {  // wait for rsp from dnode
+    if (pHb != NULL) {
-      rpcCancelRequest(pHb->rpcRid);
+      if (pHb->rpcRid > 0) {  // wait for rsp from dnode
-      pHb->rpcRid = -1;
+        rpcCancelRequest(pHb->rpcRid);
-    }
+        pHb->rpcRid = -1;
+      }
-    tscDebug("%p HB is freed", pHb);
+      tscDebug("%p HB is freed", pHb);
-    taos_free_result(pHb);
+      taos_free_result(pHb);
-    taosReleaseRef(tscObjRef, pHb->self);
+      taosReleaseRef(tscObjRef, pHb->self);
+    }
  }
  int32_t ref = T_REF_DEC(pObj);