fix bug

2327cbb9 · dapan1121 · b1e781b1 · 2327cbb9
隐藏空白更改
内联并排

Showing with 2 addition and 2 deletion

src/cq/src/cqMain.c src/cq/src/cqMain.c +2 -2

未找到文件。
--- a/src/cq/src/cqMain.c
+++ b/src/cq/src/cqMain.c
@@ -305,9 +305,9 @@ void cqDrop(void *handle) {
    pObj->tmrId = 0;
  }

-  taosReleaseRef(cqObjRef, pObj->rid);
-
  pthread_mutex_unlock(&pContext->mutex);
+
+  taosReleaseRef(cqObjRef, pObj->rid);
 }

 static void doCreateStream(void *param, TAOS_RES *result, int32_t code) {