Changeset 57fee62

Timestamp:

Aug 6, 2018 3:13:41 PM (20 months ago)

Author:

slumlord <slumlord@…>

Branches:

master

Children:

5a6ee17f

Parents:

7084c86

Message:

Fix PeerState?

File:

• router/java/src/net/i2p/router/transport/udp/PeerState.java (modified) (5 diffs)

router/java/src/net/i2p/router/transport/udp/PeerState.java

@@ -17 +17 @@
 import net.i2p.router.OutNetMessage;
 import net.i2p.router.RouterContext;
-import net.i2p.router.util.CachedIteratorAbstractCollection;
+import net.i2p.router.util.CachedIteratorCollection;
 import net.i2p.router.util.PriBlockingQueue;
 import net.i2p.util.Log;
@@ -209 +209 @@
      *  although there could be some that have not been sent yet.
      */
-    private final CachedIteratorAbstractCollection<OutboundMessageState> _outboundMessages;
+    private final CachedIteratorCollection<OutboundMessageState> _outboundMessages;
 
     /**
@@ -369 +369 @@
         _rttDeviation = _rtt;
         _inboundMessages = new HashMap<Long, InboundMessageState>(8);
-        _outboundMessages = new CachedIteratorAbstractCollection<OutboundMessageState>();
+        _outboundMessages = new CachedIteratorCollection<OutboundMessageState>();
         //_outboundQueue = new CoDelPriorityBlockingQueue(ctx, "UDP-PeerState", 32);
         _outboundQueue = new PriBlockingQueue<OutboundMessageState>(ctx, "UDP-PeerState", 32);
@@ -1585 +1585 @@
                     if (_retransmitter == state)
                         _retransmitter = null;
-                    _log.debug("CachedIteratorAbstractCollection: sendFailed update" + state);
+                    _log.debug("CachedIteratorCollection: sendFailed update" + state);
                     _context.statManager().addRateData("udp.sendFailed", state.getPushCount());
                     if (failed == null) failed = new ArrayList<OutboundMessageState>(4);
@@ -1593 +1593 @@
                     if (state == _retransmitter)
                         _retransmitter = null;
-                    _log.debug("CachedIteratorAbstractCollection: sendAggressiveFailed update" + state);
+                    _log.debug("CachedIteratorCollection: sendAggressiveFailed update" + state);
                     _context.statManager().addRateData("udp.sendAggressiveFailed", state.getPushCount());
                     if (failed == null) failed = new ArrayList<OutboundMessageState>(4);