Merge pull request #432 from tronprotocol/sync_get_lost_block

Sync: modify get lost block logic

Author: zhaohong

src/main/java/org/tron/core/net/node/NodeDelegate.java

@@ -21,7 +21,7 @@ LinkedList<Sha256Hash> handleBlock(BlockCapsule block, boolean syncMode)
 
   void handleTransaction(TransactionCapsule trx) throws BadTransactionException;
 
-  LinkedList<BlockId> getLostBlockIds(List<BlockId> blockChainSummary) throws UnReachBlockException;
+  LinkedList<BlockId> getLostBlockIds(List<BlockId> blockChainSummary);
 
   Deque<BlockId> getBlockChainSummary(BlockId beginBLockId, Deque<BlockId> blockIds)
       throws UnLinkedBlockException;

src/main/java/org/tron/core/net/node/NodeDelegateImpl.java

@@ -92,8 +92,7 @@ public void handleTransaction(TransactionCapsule trx) throws BadTransactionExcep
   }
 
   @Override
-  public LinkedList<BlockId> getLostBlockIds(List<BlockId> blockChainSummary)
-      throws UnReachBlockException {
+  public LinkedList<BlockId> getLostBlockIds(List<BlockId> blockChainSummary) {
     //todo: return the remain block count.
     //todo: return the blocks it should be have.
     if (dbManager.getHeadBlockNum() == 0) {
@@ -115,9 +114,11 @@ public LinkedList<BlockId> getLostBlockIds(List<BlockId> blockChainSummary)
       //todo: find a block we all know between the summary and my db.
       Collections.reverse(blockChainSummary);
       unForkedBlockId = blockChainSummary.stream()
-          .filter(blockId -> containBlockInMainChain(blockId))
-          .findFirst()
-          .orElseThrow(UnReachBlockException::new);
+              .filter(blockId -> containBlockInMainChain(blockId))
+              .findFirst().orElse(null);
+      if (unForkedBlockId == null){
+        return new LinkedList<>();
+      }
       //todo: can not find any same block form peer's summary and my db.
     }
 

src/main/java/org/tron/core/net/node/NodeImpl.java

@@ -730,13 +730,8 @@ private void onHandleSyncBlockChainMessage(PeerConnection peer, SyncBlockChainMe
     LinkedList<BlockId> blockIds;
     List<BlockId> summaryChainIds = syncMsg.getBlockIds();
     long remainNum = 0;
-    try {
-      blockIds = del.getLostBlockIds(summaryChainIds);
-    } catch (UnReachBlockException e) {
-      //TODO: disconnect this peer casue this peer can not switch
-      logger.debug(e.getMessage(), e);
-      return;
-    }
+
+    blockIds = del.getLostBlockIds(summaryChainIds);
 
     if (blockIds.isEmpty()) {
       peer.setNeedSyncFromUs(false);