Changeset 57fee62
- Timestamp:
- Aug 6, 2018 3:13:41 PM (3 years ago)
- Branches:
- master
- Children:
- 5a6ee17f
- Parents:
- 7084c86
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
router/java/src/net/i2p/router/transport/udp/PeerState.java
r7084c86 r57fee62 17 17 import net.i2p.router.OutNetMessage; 18 18 import net.i2p.router.RouterContext; 19 import net.i2p.router.util.CachedIterator AbstractCollection;19 import net.i2p.router.util.CachedIteratorCollection; 20 20 import net.i2p.router.util.PriBlockingQueue; 21 21 import net.i2p.util.Log; … … 209 209 * although there could be some that have not been sent yet. 210 210 */ 211 private final CachedIterator AbstractCollection<OutboundMessageState> _outboundMessages;211 private final CachedIteratorCollection<OutboundMessageState> _outboundMessages; 212 212 213 213 /** … … 369 369 _rttDeviation = _rtt; 370 370 _inboundMessages = new HashMap<Long, InboundMessageState>(8); 371 _outboundMessages = new CachedIterator AbstractCollection<OutboundMessageState>();371 _outboundMessages = new CachedIteratorCollection<OutboundMessageState>(); 372 372 //_outboundQueue = new CoDelPriorityBlockingQueue(ctx, "UDP-PeerState", 32); 373 373 _outboundQueue = new PriBlockingQueue<OutboundMessageState>(ctx, "UDP-PeerState", 32); … … 1585 1585 if (_retransmitter == state) 1586 1586 _retransmitter = null; 1587 _log.debug("CachedIterator AbstractCollection: sendFailed update" + state);1587 _log.debug("CachedIteratorCollection: sendFailed update" + state); 1588 1588 _context.statManager().addRateData("udp.sendFailed", state.getPushCount()); 1589 1589 if (failed == null) failed = new ArrayList<OutboundMessageState>(4); … … 1593 1593 if (state == _retransmitter) 1594 1594 _retransmitter = null; 1595 _log.debug("CachedIterator AbstractCollection: sendAggressiveFailed update" + state);1595 _log.debug("CachedIteratorCollection: sendAggressiveFailed update" + state); 1596 1596 _context.statManager().addRateData("udp.sendAggressiveFailed", state.getPushCount()); 1597 1597 if (failed == null) failed = new ArrayList<OutboundMessageState>(4);
Note: See TracChangeset
for help on using the changeset viewer.