From dcd16684a066a2c6e96463102c2d328846676e91 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Tue, 29 Nov 2022 17:53:24 +0800
Subject: [PATCH] fix invalid param

---
 source/libs/transport/src/trans.c    | 3 +++
 source/libs/transport/src/transCli.c | 2 +-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/source/libs/transport/src/trans.c b/source/libs/transport/src/trans.c
index 415a8766e3..c6a5cfdc95 100644
--- a/source/libs/transport/src/trans.c
+++ b/source/libs/transport/src/trans.c
@@ -63,6 +63,9 @@ void* rpcOpen(const SRpcInit* pInit) {
   pRpc->destroyFp = pInit->dfp;
 
   pRpc->numOfThreads = pInit->numOfThreads > TSDB_MAX_RPC_THREADS ? TSDB_MAX_RPC_THREADS : pInit->numOfThreads;
+  if (pRpc->numOfThreads <= 0) {
+    pRpc->numOfThreads = 1;
+  }
 
   uint32_t ip = 0;
   if (pInit->connType == TAOS_CONN_SERVER) {
diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c
index c967701930..725f352e5c 100644
--- a/source/libs/transport/src/transCli.c
+++ b/source/libs/transport/src/transCli.c
@@ -1476,7 +1476,7 @@ bool cliGenRetryRule(SCliConn* pConn, STransMsg* pResp, SCliMsg* pMsg) {
   STransConnCtx* pCtx = pMsg->ctx;
   int32_t        code = pResp->code;
 
-  bool retry = pTransInst->retry(code, pResp->msgType - 1);
+  bool retry = pTransInst->retry != NULL ? pTransInst->retry(code, pResp->msgType - 1) : false;
   if (retry == false) {
     return false;
   }
-- 
GitLab