enh: adjust sync append entry msg

2022-11-12 16:43:44 +08:00 · 2022-11-12 16:43:44 +08:00 · 437daf8c90
parent 2dfc970572
commit 437daf8c90
1 changed files with 1 additions and 0 deletions
--- a/source/libs/sync/src/syncReplication.c
+++ b/source/libs/sync/src/syncReplication.c
@ -180,6 +180,7 @@ int32_t syncNodeMaybeSendAppendEntries(SSyncNode* pSyncNode, const SRaftId* dest
    int16_t port;
    syncUtilU642Addr(destRaftId->addr, host, sizeof(host), &port);
    sNTrace(pSyncNode, "do not repcate to %s:%d for index:%" PRId64, host, port, pMsg->prevLogIndex + 1);
+    rpcFreeCont(pRpcMsg->pCont);
  }

  return ret;