support more fail-fast msgtype

f8fff96b · dengyihao · 6635691f · f8fff96b
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/dnode/mgmt/node_mgmt/src/dmTransport.c source/dnode/mgmt/node_mgmt/src/dmTransport.c +1 -1

未找到文件。
--- a/source/dnode/mgmt/node_mgmt/src/dmTransport.c
+++ b/source/dnode/mgmt/node_mgmt/src/dmTransport.c
@@ -50,7 +50,7 @@ int32_t dmProcessNodeMsg(SMgmtWrapper *pWrapper, SRpcMsg *pMsg) {

 static bool dmFailFastFp(tmsg_t msgType) {
  // add more msg type later
-  return msgType == TDMT_SYNC_HEARTBEAT;
+  return msgType == TDMT_SYNC_HEARTBEAT || msgType == TDMT_SYNC_APPEND_ENTRIES;
 }

 static void dmProcessRpcMsg(SDnode *pDnode, SRpcMsg *pRpc, SEpSet *pEpSet) {