enh(rpc): fix hb problem

source/dnode/vnode/src/vnd/vnodeQuery.c

@@ -22,21 +22,21 @@ int vnodeQueryOpen(SVnode *pVnode) {
 void vnodeQueryClose(SVnode *pVnode) { qWorkerDestroy((void **)&pVnode->pQuery); }
 
 int vnodeGetTableMeta(SVnode *pVnode, SRpcMsg *pMsg) {
-  STbCfg         *pTbCfg = NULL;
-  STbCfg         *pStbCfg = NULL;
+  STbCfg *        pTbCfg = NULL;
+  STbCfg *        pStbCfg = NULL;
   tb_uid_t        uid;
   int32_t         nCols;
   int32_t         nTagCols;
   SSchemaWrapper *pSW = NULL;
-  STableMetaRsp  *pTbMetaMsg = NULL;
+  STableMetaRsp * pTbMetaMsg = NULL;
   STableMetaRsp   metaRsp = {0};
-  SSchema        *pTagSchema;
+  SSchema *       pTagSchema;
   SRpcMsg         rpcMsg;
   int             msgLen = 0;
   int32_t         code = 0;
   char            tableFName[TSDB_TABLE_FNAME_LEN];
   int32_t         rspLen = 0;
-  void           *pRsp = NULL;
+  void *          pRsp = NULL;
 
   STableInfoReq infoReq = {0};
   if (tDeserializeSTableInfoReq(pMsg->pCont, pMsg->contLen, &infoReq) != 0) {
@@ -142,6 +142,7 @@ _exit:
 
   rpcMsg.handle = pMsg->handle;
   rpcMsg.ahandle = pMsg->ahandle;
+  rpcMsg.refId = pMsg->refId;
   rpcMsg.pCont = pRsp;
   rpcMsg.contLen = rspLen;
   rpcMsg.code = code;

source/libs/transport/src/transSrv.c

@@ -1017,9 +1017,11 @@ void transReleaseSrvHandle(void* handle) {
   uvReleaseExHandle(refId);
   return;
 _return1:
+  tTrace("server handle %p failed to send to release handle", exh);
   uvReleaseExHandle(refId);
   return;
 _return2:
+  tTrace("server handle %p failed to send to release handle", exh);
   return;
 }
 void transSendResponse(const STransMsg* msg) {
@@ -1041,10 +1043,12 @@ void transSendResponse(const STransMsg* msg) {
   uvReleaseExHandle(refId);
   return;
 _return1:
+  tTrace("server handle %p failed to send resp", exh);
   rpcFreeCont(msg->pCont);
   uvReleaseExHandle(refId);
   return;
 _return2:
+  tTrace("server handle %p failed to send resp", exh);
   rpcFreeCont(msg->pCont);
   return;
 }
@@ -1067,10 +1071,12 @@ void transRegisterMsg(const STransMsg* msg) {
   uvReleaseExHandle(refId);
   return;
 _return1:
+  tTrace("server handle %p failed to send to register brokenlink", exh);
   rpcFreeCont(msg->pCont);
   uvReleaseExHandle(refId);
   return;
 _return2:
+  tTrace("server handle %p failed to send to register brokenlink", exh);
   rpcFreeCont(msg->pCont);
 }