add version check in rpc

source/dnode/mgmt/node_mgmt/src/dmTransport.c

@@ -77,6 +77,7 @@ static void dmProcessRpcMsg(SDnode *pDnode, SRpcMsg *pRpc, SEpSet *pEpSet) {
   int32_t svrVer = 0;
   taosVersionStrToInt(version, &svrVer);
   if (0 != taosCheckVersionCompatible(pRpc->info.cliVer, svrVer, 3)) {
+    dError("msg ver: %d, curr ver: %d", pRpc->info.cliVer, svrVer);
     goto _OVER;
   }
 

source/libs/transport/src/transCli.c

@@ -391,6 +391,7 @@ void cliHandleResp(SCliConn* conn) {
   transMsg.info.ahandle = NULL;
   transMsg.info.traceId = pHead->traceId;
   transMsg.info.hasEpSet = pHead->hasEpSet;
+  transMsg.info.cliVer = pHead->compatibilityVer;
 
   SCliMsg*       pMsg = NULL;
   STransConnCtx* pCtx = NULL;

source/libs/transport/src/transSvr.c

@@ -196,6 +196,7 @@ static bool uvHandleReq(SSvrConn* pConn) {
     tError("%s conn %p recv invalid packet, failed to decompress", transLabel(pTransInst), pConn);
     return false;
   }
+  tDebug("head version: %d 2", pHead->version);
 
   pHead->code = htonl(pHead->code);
   pHead->msgLen = htonl(pHead->msgLen);
@@ -411,7 +412,7 @@ static int uvPrepareSendData(SSvrMsg* smsg, uv_buf_t* wb) {
   pHead->traceId = pMsg->info.traceId;
   pHead->hasEpSet = pMsg->info.hasEpSet;
   pHead->magicNum = htonl(TRANS_MAGIC_NUM);
-  pHead->compatibilityVer = 0;
+  pHead->compatibilityVer = ((STrans*)pConn->pTransInst)->compatibilityVer;
   pHead->version = TRANS_VER;
 
   // handle invalid drop_task resp, TD-20098