提交 4801003d 编写于 作者: A Alex Duan

fix(rpc): only submit and query return

上级 69d54ded
......@@ -1516,7 +1516,9 @@ static void rpcProcessConnError(void *param, void *id) {
rpcMsg.contLen = 0;
if( pContext->numOfTry >= pContext->epSet.numOfEps && rpcMsg.code == TSDB_CODE_RPC_NETWORK_UNAVAIL) {
rpcMsg.code = TSDB_CODE_RPC_VGROUP_NOT_REACHED;
if(pContext->msgType == TSDB_MSG_TYPE_SUBMIT || pContext->msgType == TSDB_MSG_TYPE_QUERY) {
rpcMsg.code = TSDB_CODE_RPC_VGROUP_NOT_REACHED;
}
}
tWarn("%s %p, connection error. notify client query over. numOfTry=%d msgType=%d", pRpc->label, pContext->ahandle, pContext->numOfTry, pContext->msgType);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册