From bffba8e4405ed19187d8555bccd65a6e9b690f1d Mon Sep 17 00:00:00 2001
From: xsren <285808407@qq.com>
Date: Thu, 19 Sep 2024 10:22:25 +0800
Subject: [PATCH] fix: deak lock

---
 source/libs/function/src/tudf.c | 4 ++--
 source/libs/function/src/udfd.c | 3 ++-
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/source/libs/function/src/tudf.c b/source/libs/function/src/tudf.c
index c2cd8b8c3d..6145d9f03f 100644
--- a/source/libs/function/src/tudf.c
+++ b/source/libs/function/src/tudf.c
@@ -1091,7 +1091,7 @@ int32_t acquireUdfFuncHandle(char *udfName, UdfcFuncHandle *pHandle) {
         taosArrayRemove(gUdfcProxy.udfStubs, stubIndex);
       }
     } else {
-      fnInfo("udf handle expired for %s, will setup udf. move it to expired list", udfName);
+      fnDebug("udf handle expired for %s, will setup udf. move it to expired list", udfName);
       if (taosArrayPush(gUdfcProxy.expiredUdfStubs, foundStub) == NULL) {
         fnError("acquireUdfFuncHandle: failed to push udf stub to array");
       } else {
@@ -1718,7 +1718,7 @@ int32_t udfcQueueUvTask(SClientUvTaskNode *uvTask) {
   }
 
   uv_sem_wait(&uvTask->taskSem);
-  fnInfo("udfc uvTask finished. uvTask:%" PRId64 "-%d-%p", uvTask->seqNum, uvTask->type, uvTask);
+  fnDebug("udfc uvTask finished. uvTask:%" PRId64 "-%d-%p", uvTask->seqNum, uvTask->type, uvTask);
   uv_sem_destroy(&uvTask->taskSem);
 
   return 0;
diff --git a/source/libs/function/src/udfd.c b/source/libs/function/src/udfd.c
index cd54c03a68..72eaae9451 100644
--- a/source/libs/function/src/udfd.c
+++ b/source/libs/function/src/udfd.c
@@ -918,7 +918,8 @@ void udfdProcessTeardownRequest(SUvUdfWork *uvUdf, SUdfRequest *request) {
     unloadUdf = true;
     code = taosHashRemove(global.udfsHash, udf->name, strlen(udf->name));
     if (code != 0) {
-      fnError("udf name %s remove from hash failed", udf->name);
+      fnError("udf name %s remove from hash failed, err:%0x %s", udf->name, code, tstrerror(code));
+      uv_mutex_unlock(&global.udfsMutex);
       goto _send;
     }
   }