rm log

olenheim · olenheim · commit 01320f161548 · 2018-06-08T21:23:19.000+08:00
diff --git a/src/main/java/org/tron/core/net/node/NodeImpl.java b/src/main/java/org/tron/core/net/node/NodeImpl.java
@@ -239,10 +239,6 @@ public boolean offer(BlockId blockId) {
 
   private HashMap<Sha256Hash, Long> advObjWeRequested = new HashMap<>();
 
-  //private ConcurrentHashMap<Sha256Hash, InventoryType> advObjToFetch = new ConcurrentHashMap<>();
-
-  //private ConcurrentLinkedQueue<PriorItem> advObjToFetch = new ConcurrentLinkedQueue<PriorItem>();
-
   private ConcurrentHashMap<Sha256Hash, PriorItem> advObjToFetch = new ConcurrentHashMap<Sha256Hash, PriorItem>();
 
   private ExecutorService broadPool = Executors.newFixedThreadPool(2, new ThreadFactory() {
@@ -710,9 +706,8 @@ private void onHandleInventoryMessage(PeerConnection peer, InventoryMessage msg)
         peer.getAdvObjSpreadToUs().put(id, System.currentTimeMillis());
         if (!requested[0]) {
           if (!badAdvObj.containsKey(id)) {
-            if (!advObjToFetch.contains(id)) {
+            if (!advObjToFetch.containsKey(id)) {
               fetchWaterLine.increase();
-              logger.info("water line:" + fetchWaterLine.totalCount());
               this.advObjToFetch.put(id, new PriorItem(new Item(id, msg.getInventoryType()),
                   fetchSequenceCounter.incrementAndGet()));
             } else {
