fix the sonar error

lvs007 · lvs007 · commit 38815ff395d1 · 2020-07-24T17:59:37.000+08:00
diff --git a/framework/src/main/java/org/tron/core/net/message/PbftCommitMessage.java b/framework/src/main/java/org/tron/core/net/message/PbftCommitMessage.java
@@ -32,11 +32,6 @@ public Class<?> getAnswerMessage() {
     return null;
   }
 
-  @Override
-  public boolean equals(Object obj) {
-    return super.equals(obj);
-  }
-
   @Override
   public int hashCode() {
     return super.hashCode();
diff --git a/framework/src/main/java/org/tron/core/net/messagehandler/FetchInvDataMsgHandler.java b/framework/src/main/java/org/tron/core/net/messagehandler/FetchInvDataMsgHandler.java
@@ -2,8 +2,11 @@
 
 import static org.tron.core.config.Parameter.ChainConstant.BLOCK_PRODUCED_INTERVAL;
 
+import com.google.common.cache.Cache;
+import com.google.common.cache.CacheBuilder;
 import com.google.common.collect.Lists;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -38,7 +41,8 @@
 @Component
 public class FetchInvDataMsgHandler implements TronMsgHandler {
 
-  private static long latestEpoch = 0;
+  private volatile Cache<Long, Boolean> epochCache = CacheBuilder.newBuilder().initialCapacity(100)
+      .maximumSize(1000).expireAfterWrite(1, TimeUnit.HOURS).build();
 
   private static final int MAX_SIZE = 1_000_000;
   @Autowired
@@ -116,8 +120,8 @@ private void sendPbftCommitMessage(PeerConnection peer, BlockCapsule blockCapsul
         epoch =
             (blockCapsule.getTimeStamp() / maintenanceTimeInterval + 1) * maintenanceTimeInterval;
       }
-      if (epoch > latestEpoch) {
-        latestEpoch = epoch;
+      if (epochCache.getIfPresent(epoch) == null) {
+        epochCache.put(epoch, true);
         PbftSignCapsule srl = tronNetDelegate.getSRLPbftCommitData(epoch);
         if (srl != null) {
           peer.sendMessage(new PbftCommitMessage(srl));
diff --git a/framework/src/main/java/org/tron/core/net/messagehandler/PbftDataSyncHandler.java b/framework/src/main/java/org/tron/core/net/messagehandler/PbftDataSyncHandler.java
@@ -90,15 +90,12 @@ private void processPBFTCommitMessage(PbftCommitMessage pbftCommitMessage) {
           chainBaseManager.getWitnesses())) {
         return;
       }
-      if (raw.getDataType() == DataType.BLOCK) {
-        if (pbftSignDataStore.getBlockSignData(raw.getViewN()) == null) {
-          pbftSignDataStore
-              .putBlockSignData(raw.getViewN(), pbftCommitMessage.getPbftSignCapsule());
-        }
-      } else if (raw.getDataType() == DataType.SRL) {
-        if (pbftSignDataStore.getSrSignData(raw.getEpoch()) == null) {
-          pbftSignDataStore.putSrSignData(raw.getEpoch(), pbftCommitMessage.getPbftSignCapsule());
-        }
+      if (raw.getDataType() == DataType.BLOCK
+          && pbftSignDataStore.getBlockSignData(raw.getViewN()) == null) {
+        pbftSignDataStore.putBlockSignData(raw.getViewN(), pbftCommitMessage.getPbftSignCapsule());
+      } else if (raw.getDataType() == DataType.SRL
+          && pbftSignDataStore.getSrSignData(raw.getEpoch()) == null) {
+        pbftSignDataStore.putSrSignData(raw.getEpoch(), pbftCommitMessage.getPbftSignCapsule());
       }
     } catch (InvalidProtocolBufferException e) {
       logger.error("", e);
@@ -141,11 +138,11 @@ public boolean validPbftSign(Raw raw, List<ByteString> srSignList,
 
   private class ValidPbftSignTask implements Callable<Boolean> {
 
-    long viewN;
-    Set<ByteString> srSignSet;
-    byte[] dataHash;
-    Set<ByteString> srSet;
-    ByteString sign;
+    private long viewN;
+    private Set<ByteString> srSignSet;
+    private byte[] dataHash;
+    private Set<ByteString> srSet;
+    private ByteString sign;
 
     ValidPbftSignTask(long viewN, Set<ByteString> srSignSet,
         byte[] dataHash, Set<ByteString> srSet, ByteString sign) {
