fix breakpoint coredump
This commit is contained in:
parent
d099fa7a91
commit
17e6e1d303
|
@ -840,7 +840,7 @@ static void rpcProcessBrokenLink(SRpcConn *pConn) {
|
||||||
rpcMsg.handle = pConn;
|
rpcMsg.handle = pConn;
|
||||||
rpcMsg.msgType = pConn->inType;
|
rpcMsg.msgType = pConn->inType;
|
||||||
rpcMsg.code = TSDB_CODE_NETWORK_UNAVAIL;
|
rpcMsg.code = TSDB_CODE_NETWORK_UNAVAIL;
|
||||||
(*(pRpc->cfp))(&rpcMsg);
|
// (*(pRpc->cfp))(&rpcMsg);
|
||||||
}
|
}
|
||||||
|
|
||||||
rpcCloseConn(pConn);
|
rpcCloseConn(pConn);
|
||||||
|
@ -1169,7 +1169,7 @@ static void rpcProcessIdleTimer(void *param, void *tmrId) {
|
||||||
rpcMsg.handle = pConn;
|
rpcMsg.handle = pConn;
|
||||||
rpcMsg.msgType = pConn->inType;
|
rpcMsg.msgType = pConn->inType;
|
||||||
rpcMsg.code = TSDB_CODE_NETWORK_UNAVAIL;
|
rpcMsg.code = TSDB_CODE_NETWORK_UNAVAIL;
|
||||||
(*(pRpc->cfp))(&rpcMsg);
|
// (*(pRpc->cfp))(&rpcMsg);
|
||||||
}
|
}
|
||||||
rpcCloseConn(pConn);
|
rpcCloseConn(pConn);
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Reference in New Issue