Skip to content

Commit cebe2e8

Browse files
authored
Merge pull request #2320 from tronprotocol/p2p_adv_t
optimization block msg process msg
2 parents 8e4f24c + 94094d1 commit cebe2e8

File tree

1 file changed

+13
-6
lines changed

1 file changed

+13
-6
lines changed

src/main/java/org/tron/core/net/messagehandler/BlockMsgHandler.java

+13-6
Original file line numberDiff line numberDiff line change
@@ -60,13 +60,20 @@ public void processMessage(PeerConnection peer, TronMessage msg) throws P2pExcep
6060
syncService.processBlock(peer, blockMessage);
6161
} else {
6262
Long time = peer.getAdvInvRequest().remove(new Item(blockId, InventoryType.BLOCK));
63-
long cost = time == null ? 0 : System.currentTimeMillis() - time;
64-
logger.info("Receive block {}, witness: {} from {}, fetch cost {}ms",
65-
blockId.getString(),
66-
Hex.toHexString(blockMessage.getBlockCapsule().getWitnessAddress().toByteArray()),
67-
peer.getInetAddress(),
68-
cost);
63+
long now = System.currentTimeMillis();
64+
long delay = now - tronNetDelegate.getHeadBlockTimeStamp() - BLOCK_PRODUCED_INTERVAL;
65+
long interval = blockId.getNum() - tronNetDelegate.getHeadBlockId().getNum();
6966
processBlock(peer, blockMessage.getBlockCapsule());
67+
logger.info(
68+
"Receive block/interval {}/{} from {} fetch/delay {}/{}ms, txs/process {}/{}ms, witness: {}",
69+
blockId.getNum(),
70+
interval,
71+
peer.getInetAddress(),
72+
time == null ? 0 : now - time,
73+
delay,
74+
((BlockMessage) msg).getBlockCapsule().getTransactions().size(),
75+
System.currentTimeMillis() - now,
76+
Hex.toHexString(blockMessage.getBlockCapsule().getWitnessAddress().toByteArray()));
7077
}
7178
}
7279

0 commit comments

Comments
 (0)