提交 d65f5e7f 编写于 作者: A Alex Duan

feat(rpc): remove unuse variant

上级 f80597a1
...@@ -133,7 +133,6 @@ typedef struct SRpcConn { ...@@ -133,7 +133,6 @@ typedef struct SRpcConn {
int64_t lockedBy; // lock for connection int64_t lockedBy; // lock for connection
SRpcReqContext *pContext; // request context SRpcReqContext *pContext; // request context
int64_t rid; // probe msg use rid get pContext int64_t rid; // probe msg use rid get pContext
int64_t lastLiveTime; // last alive time with ms
} SRpcConn; } SRpcConn;
int tsRpcMaxUdpSize = 15000; // bytes int tsRpcMaxUdpSize = 15000; // bytes
...@@ -1123,7 +1122,6 @@ static void rpcProcessProbeMsg(SRecvInfo *pRecv, SRpcConn *pConn) { ...@@ -1123,7 +1122,6 @@ static void rpcProcessProbeMsg(SRecvInfo *pRecv, SRpcConn *pConn) {
} else if (pHead->msgType == TSDB_MSG_TYPE_PROBE_CONN_RSP) { } else if (pHead->msgType == TSDB_MSG_TYPE_PROBE_CONN_RSP) {
if(pConn) { if(pConn) {
rpcLockConn(pConn); rpcLockConn(pConn);
pConn->lastLiveTime = taosGetTimestampMs();
// get req content // get req content
SRpcReqContext *pContext = taosAcquireRef(tsRpcRefId, pConn->rid); SRpcReqContext *pContext = taosAcquireRef(tsRpcRefId, pConn->rid);
...@@ -1802,7 +1800,6 @@ bool doRpcSendProbe(SRpcConn *pConn) { ...@@ -1802,7 +1800,6 @@ bool doRpcSendProbe(SRpcConn *pConn) {
pHead->code = htonl(code); pHead->code = htonl(code);
bool ret = rpcSendMsgToPeer(pConn, msg, sizeof(SRpcHead) + sizeof(int32_t)); bool ret = rpcSendMsgToPeer(pConn, msg, sizeof(SRpcHead) + sizeof(int32_t));
pConn->lastLiveTime = taosGetTimestampMs();
return ret; return ret;
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册