提交 5609bfc4 编写于 作者: A Alex Duan

feat(rpc): probe msg sendmsgtosever always return ok

上级 7ac8dc9e
...@@ -400,7 +400,7 @@ void tscProcessActivityTimer(void *handle, void *tmrId) { ...@@ -400,7 +400,7 @@ void tscProcessActivityTimer(void *handle, void *tmrId) {
// call check if have query doing // call check if have query doing
if(pObj->sqlList) { if(pObj->sqlList) {
// have queries executing // have queries executing
//checkBrokenQueries(pObj); checkBrokenQueries(pObj);
} }
} }
...@@ -449,12 +449,12 @@ int tscSendMsgToServer(SSqlObj *pSql) { ...@@ -449,12 +449,12 @@ int tscSendMsgToServer(SSqlObj *pSql) {
if(rpcSendRequest(pObj->pRpcObj->pDnodeConn, &pSql->epSet, &rpcMsg, &pSql->rpcRid)) { if(rpcSendRequest(pObj->pRpcObj->pDnodeConn, &pSql->epSet, &rpcMsg, &pSql->rpcRid)) {
if(pSql->cmd.command != TSDB_SQL_HB) if(pSql->cmd.command < TSDB_SQL_HB)
rpcSaveSendInfo(pSql->rpcRid, &pSql->pPrevContext); rpcSaveSendInfo(pSql->rpcRid, &pSql->pPrevContext);
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }
return TSDB_CODE_FAILED; return TSDB_CODE_SUCCESS;
} }
// handle three situation // handle three situation
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册