enh(rpc):add auth

This commit is contained in:
yihaoDeng 2022-04-21 20:28:37 +08:00
parent b7cb019d69
commit fa14caffcd
1 changed files with 4 additions and 2 deletions

View File

@ -886,9 +886,11 @@ void cliAppCb(SCliConn* pConn, STransMsg* transMsg) {
STrans* pTransInst = pThrd->pTransInst;
if (transMsg->code == TSDB_CODE_RPC_REDIRECT && pTransInst->retry != NULL) {
// impl retry
SMEpSet emsg = {0};
tDeserializeSMEpSet(transMsg->pCont, transMsg->contLen, &emsg);
pTransInst->retry(pTransInst, transMsg, &(emsg.epSet));
} else {
(*pTransInst->cfp)(pTransInst->parent, transMsg, NULL);
pTransInst->cfp(pTransInst->parent, transMsg, NULL);
}
}