From a20845ec69a81cf4a066ac90eb90826f0cab7406 Mon Sep 17 00:00:00 2001 From: Yihao Deng Date: Mon, 22 Jan 2024 01:04:06 +0000 Subject: [PATCH] refactor retry --- source/dnode/mnode/impl/src/mndMnode.c | 2 +- source/libs/sync/src/syncMain.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndMnode.c b/source/dnode/mnode/impl/src/mndMnode.c index 1068a2c5b3..385f20d39e 100644 --- a/source/dnode/mnode/impl/src/mndMnode.c +++ b/source/dnode/mnode/impl/src/mndMnode.c @@ -252,7 +252,7 @@ void mndGetMnodeEpSet(SMnode *pMnode, SEpSet *pEpSet) { pEpSet->inUse = pEpSet->numOfEps; } else { pEpSet->inUse = (pEpSet->numOfEps + 1) % totalMnodes; - pEpSet->inUse = 0; + //pEpSet->inUse = 0; } } if (pObj->pDnode != NULL) { diff --git a/source/libs/sync/src/syncMain.c b/source/libs/sync/src/syncMain.c index 89a41806cd..c0a4a6a73f 100644 --- a/source/libs/sync/src/syncMain.c +++ b/source/libs/sync/src/syncMain.c @@ -589,7 +589,7 @@ void syncGetRetryEpSet(int64_t rid, SEpSet* pEpSet) { } if (pEpSet->numOfEps > 0) { pEpSet->inUse = (pSyncNode->raftCfg.cfg.myIndex + 1) % pEpSet->numOfEps; - pEpSet->inUse = 0; + // pEpSet->inUse = 0; } sInfo("vgId:%d, sync get retry epset numOfEps:%d inUse:%d", pSyncNode->vgId, pEpSet->numOfEps, pEpSet->inUse);