fix(sync): delete duplicate code
This commit is contained in:
parent
fa185deef9
commit
3f4ba9a792
|
@ -2558,10 +2558,6 @@ int32_t syncNodeOnHeartbeatReplyOld(SSyncNode* ths, const SRpcMsg* pRpcMsg) {
|
||||||
char tbuf[40] = {0};
|
char tbuf[40] = {0};
|
||||||
TRACE_TO_STR(trace, tbuf);
|
TRACE_TO_STR(trace, tbuf);
|
||||||
|
|
||||||
const STraceId* trace = &pRpcMsg->info.traceId;
|
|
||||||
char tbuf[40] = {0};
|
|
||||||
TRACE_TO_STR(trace, tbuf);
|
|
||||||
|
|
||||||
int64_t tsMs = taosGetTimestampMs();
|
int64_t tsMs = taosGetTimestampMs();
|
||||||
int64_t timeDiff = tsMs - pMsg->timeStamp;
|
int64_t timeDiff = tsMs - pMsg->timeStamp;
|
||||||
syncLogRecvHeartbeatReply(ths, pMsg, timeDiff, tbuf);
|
syncLogRecvHeartbeatReply(ths, pMsg, timeDiff, tbuf);
|
||||||
|
|
Loading…
Reference in New Issue