refactor retry

source/libs/transport/src/transCli.c

@@ -1426,12 +1426,16 @@ bool cliResetEpset(STransConnCtx* pCtx, STransMsg* pResp, bool hasEpSet) {
     }
   } else {
     SEpSet  epSet;
-
-    // assert(pResp->contLen == sizeof(epSet));
     int32_t valid = tDeserializeSEpSet(pResp->pCont, pResp->contLen, &epSet);
     if (valid < 0) {
-      // assert(0);
+      tDebug("get invalid epset, epset equal, continue");
+      if (pCtx->epsetRetryCnt >= pCtx->epSet.numOfEps) {
+        noDelay = false;
+      } else {
+        EPSET_FORWARD_INUSE(&pCtx->epSet);
+        noDelay = true;
       }
+    } else {
       if (!transEpSetIsEqual(&pCtx->epSet, &epSet)) {
         tDebug("epset not equal, retry new epset");
         pCtx->epSet = epSet;
@@ -1441,6 +1445,7 @@ bool cliResetEpset(STransConnCtx* pCtx, STransMsg* pResp, bool hasEpSet) {
       }
       noDelay = false;
     }
+  }
   return noDelay;
 }
 bool cliGenRetryRule(SCliConn* pConn, STransMsg* pResp, SCliMsg* pMsg) {