Skip to content

Commit a82003c

Browse files
committed
optimize chain inventory message processing logic
1 parent 5a70a07 commit a82003c

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

framework/src/main/java/org/tron/core/net/messagehandler/ChainInventoryMsgHandler.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,14 +80,15 @@ public void processMessage(PeerConnection peer, TronMessage msg) throws P2pExcep
8080
} catch (NoSuchElementException e) {
8181
logger.warn("Process ChainInventoryMessage failed, peer {}, isDisconnect:{}",
8282
peer.getInetAddress(), peer.isDisconnect());
83+
peer.setFetchAble(true);
8384
return;
8485
}
8586
}
8687

88+
peer.setFetchAble(true);
8789
if ((chainInventoryMessage.getRemainNum() == 0 && !peer.getSyncBlockToFetch().isEmpty())
8890
|| (chainInventoryMessage.getRemainNum() != 0
8991
&& peer.getSyncBlockToFetch().size() > NetConstants.SYNC_FETCH_BATCH_NUM)) {
90-
peer.setFetchAble(true);
9192
syncService.setFetchFlag(true);
9293
} else {
9394
syncService.syncNext(peer);

0 commit comments

Comments
 (0)