sort epset
This commit is contained in:
parent
62e6b5ca31
commit
2479df3b1e
|
@ -223,7 +223,7 @@ int32_t dmWriteEps(SDnodeData *pData) {
|
||||||
|
|
||||||
terrno = TSDB_CODE_OUT_OF_MEMORY;
|
terrno = TSDB_CODE_OUT_OF_MEMORY;
|
||||||
|
|
||||||
if((code == dmInitDndInfo(pData)) != 0) goto _OVER;
|
if ((code == dmInitDndInfo(pData)) != 0) goto _OVER;
|
||||||
pJson = tjsonCreateObject();
|
pJson = tjsonCreateObject();
|
||||||
if (pJson == NULL) goto _OVER;
|
if (pJson == NULL) goto _OVER;
|
||||||
pData->engineVer = tsVersion;
|
pData->engineVer = tsVersion;
|
||||||
|
@ -289,6 +289,7 @@ static void dmResetEps(SDnodeData *pData, SArray *dnodeEps) {
|
||||||
pData->mnodeEps.eps[mIndex] = pDnodeEp->ep;
|
pData->mnodeEps.eps[mIndex] = pDnodeEp->ep;
|
||||||
mIndex++;
|
mIndex++;
|
||||||
}
|
}
|
||||||
|
epsetSort(&pData->mnodeEps);
|
||||||
|
|
||||||
for (int32_t i = 0; i < numOfEps; i++) {
|
for (int32_t i = 0; i < numOfEps; i++) {
|
||||||
SDnodeEp *pDnodeEp = taosArrayGet(dnodeEps, i);
|
SDnodeEp *pDnodeEp = taosArrayGet(dnodeEps, i);
|
||||||
|
|
|
@ -877,6 +877,7 @@ SEpSet mndGetVgroupEpset(SMnode *pMnode, const SVgObj *pVgroup) {
|
||||||
addEpIntoEpSet(&epset, pDnode->fqdn, pDnode->port);
|
addEpIntoEpSet(&epset, pDnode->fqdn, pDnode->port);
|
||||||
mndReleaseDnode(pMnode, pDnode);
|
mndReleaseDnode(pMnode, pDnode);
|
||||||
}
|
}
|
||||||
|
epsetSort(&epset);
|
||||||
|
|
||||||
return epset;
|
return epset;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue