fix invalid retr3
This commit is contained in:
parent
a32c0f47ce
commit
20b505a482
|
@ -24,10 +24,8 @@ static inline void dmBuildMnodeRedirectRsp(SDnode *pDnode, SRpcMsg *pMsg) {
|
||||||
SEpSet epSet = {0};
|
SEpSet epSet = {0};
|
||||||
dmGetMnodeEpSetForRedirect(&pDnode->data, pMsg, &epSet);
|
dmGetMnodeEpSetForRedirect(&pDnode->data, pMsg, &epSet);
|
||||||
|
|
||||||
if (epSet.numOfEps == 0) {
|
if (epSet.numOfEps <= 1) {
|
||||||
pMsg->code = TSDB_CODE_MNODE_NOT_FOUND;
|
pMsg->pCont = NULL;
|
||||||
return;
|
|
||||||
} else if (epSet.numOfEps == 1) {
|
|
||||||
pMsg->code = TSDB_CODE_MNODE_NOT_FOUND;
|
pMsg->code = TSDB_CODE_MNODE_NOT_FOUND;
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue