From bad373038709dcd295fbc3ff86b7fa715de6f530 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 21 Feb 2024 18:25:35 +0800 Subject: [PATCH] fix(stream): set the vgId in hb rsp msg. --- source/dnode/mnode/impl/src/mndStreamHb.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/source/dnode/mnode/impl/src/mndStreamHb.c b/source/dnode/mnode/impl/src/mndStreamHb.c index f9727d4fd7..fe8a287eaf 100644 --- a/source/dnode/mnode/impl/src/mndStreamHb.c +++ b/source/dnode/mnode/impl/src/mndStreamHb.c @@ -17,7 +17,7 @@ #include "mndTrans.h" typedef struct { - int8_t placeholder; // placeholder + SMsgHead head; } SMStreamHbRspMsg; typedef struct SFailedCheckpointInfo { @@ -359,6 +359,9 @@ int32_t mndProcessStreamHb(SRpcMsg *pReq) { { SRpcMsg rsp = {.code = 0, .info = pReq->info, .contLen = sizeof(SMStreamHbRspMsg)}; rsp.pCont = rpcMallocCont(rsp.contLen); + SMsgHead* pHead = rsp.pCont; + pHead->vgId = htonl(req.vgId); + tmsgSendRsp(&rsp); pReq->info.handle = NULL; // disable auto rsp