From 4e8a37ed982fcb129d9f338de06c6772c8f49871 Mon Sep 17 00:00:00 2001 From: stephenkgu Date: Mon, 28 Dec 2020 02:45:11 +0800 Subject: [PATCH] rpcMain/fix: fix version checking with rpcSendReqHead --- src/rpc/src/rpcMain.c | 1 + 1 file changed, 1 insertion(+) diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c index a9346f55d3..fbc59d8ddf 100644 --- a/src/rpc/src/rpcMain.c +++ b/src/rpc/src/rpcMain.c @@ -1216,6 +1216,7 @@ static void rpcSendReqHead(SRpcConn *pConn) { pHead = (SRpcHead *)msg; pHead->version = 1; pHead->msgType = pConn->outType; + pHead->msgVer = htonl(tsVersion >> 8); pHead->spi = pConn->spi; pHead->encrypt = 0; pHead->tranId = pConn->outTranId;