query(fix): return new error code except connect msg

source/client/src/clientImpl.c

@@ -1425,24 +1425,18 @@ void processMsgFromServer(void* parent, SRpcMsg* pMsg, SEpSet* pEpSet) {
   }
 
   // pMsg is response msg
-  switch (pMsg->msgType) {
-    case TDMT_VND_BATCH_META + 1:
-    case TDMT_VND_SUBMIT + 1:
-    case TDMT_SCH_QUERY + 1:
-    case TDMT_SCH_MERGE_QUERY + 1:
-      // uniform to one error code: TSDB_CODE_RPC_SOMENODE_NOT_CONNECTED
-      if (pMsg->code == TSDB_CODE_RPC_SOMENODE_BROKEN_LINK) {
-        pMsg->code = TSDB_CODE_RPC_SOMENODE_NOT_CONNECTED;
-      }
-      break;
-    default:
-      // restore origin code
-      if (pMsg->code == TSDB_CODE_RPC_SOMENODE_NOT_CONNECTED) {
-        pMsg->code = TSDB_CODE_RPC_NETWORK_UNAVAIL;
-      } else if (pMsg->code == TSDB_CODE_RPC_SOMENODE_BROKEN_LINK) {
-        pMsg->code = TSDB_CODE_RPC_BROKEN_LINK;
-      }
-      break;
+  if (pMsg->msgType != TDMT_MND_CONNECT + 1) {
+    // uniform to one error code: TSDB_CODE_RPC_SOMENODE_NOT_CONNECTED
+    if (pMsg->code == TSDB_CODE_RPC_SOMENODE_BROKEN_LINK) {
+      pMsg->code = TSDB_CODE_RPC_SOMENODE_NOT_CONNECTED;
+    }
+  } else {
+    // restore origin code
+    if (pMsg->code == TSDB_CODE_RPC_SOMENODE_NOT_CONNECTED) {
+      pMsg->code = TSDB_CODE_RPC_NETWORK_UNAVAIL;
+    } else if (pMsg->code == TSDB_CODE_RPC_SOMENODE_BROKEN_LINK) {
+      pMsg->code = TSDB_CODE_RPC_BROKEN_LINK;
+    }
   }
 
   AsyncArg* arg = taosMemoryCalloc(1, sizeof(AsyncArg));