fet(net): olve the problem of reporting 'no need sync'

Author: xxo1shine

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

@@ -39,6 +39,8 @@ public void processMessage(PeerConnection peer, TronMessage msg) throws P2pExcep
 
     check(peer, chainInventoryMessage);
 
+    peer.setFetchAble(false);
+
     peer.setNeedSyncFromPeer(true);
 
     peer.setSyncChainRequested(null);
@@ -85,6 +87,7 @@ public void processMessage(PeerConnection peer, TronMessage msg) throws P2pExcep
     if ((chainInventoryMessage.getRemainNum() == 0 && !peer.getSyncBlockToFetch().isEmpty())
         || (chainInventoryMessage.getRemainNum() != 0
         && peer.getSyncBlockToFetch().size() > NetConstants.SYNC_FETCH_BATCH_NUM)) {
+      peer.setFetchAble(true);
       syncService.setFetchFlag(true);
     } else {
       syncService.syncNext(peer);

framework/src/main/java/org/tron/core/net/peer/PeerConnection.java

@@ -67,6 +67,10 @@ public class PeerConnection {
   @Setter
   private volatile boolean isRelayPeer;
 
+  @Setter
+  @Getter
+  private volatile boolean fetchAble;
+
   @Getter
   @Setter
   private ByteString address;

framework/src/main/java/org/tron/core/net/service/sync/SyncService.java

@@ -50,7 +50,8 @@ public class SyncService {
   private Map<BlockMessage, PeerConnection> blockJustReceived = new ConcurrentHashMap<>();
 
   private long blockCacheTimeout = Args.getInstance().getBlockCacheTimeout();
-  private Cache<BlockId, PeerConnection> requestBlockIds = CacheBuilder.newBuilder().maximumSize(10_000)
+  private Cache<BlockId, PeerConnection> requestBlockIds = CacheBuilder.newBuilder()
+      .maximumSize(10_000)
       .expireAfterWrite(blockCacheTimeout, TimeUnit.MINUTES).initialCapacity(10_000)
       .recordStats().build();
 
@@ -206,6 +207,7 @@ private void startFetchSyncBlock() {
     HashMap<PeerConnection, List<BlockId>> send = new HashMap<>();
     tronNetDelegate.getActivePeer().stream()
         .filter(peer -> peer.isNeedSyncFromPeer() && peer.isIdle())
+        .filter(peer -> peer.isFetchAble())
         .forEach(peer -> {
           if (!send.containsKey(peer)) {
             send.put(peer, new LinkedList<>());