Changeset 57fee62


Ignore:
Timestamp:
Aug 6, 2018 3:13:41 PM (20 months ago)
Author:
slumlord <slumlord@…>
Branches:
master
Children:
5a6ee17f
Parents:
7084c86
Message:

Fix PeerState?

File:
1 edited

Legend:

Unmodified
Added
Removed
  • router/java/src/net/i2p/router/transport/udp/PeerState.java

    r7084c86 r57fee62  
    1717import net.i2p.router.OutNetMessage;
    1818import net.i2p.router.RouterContext;
    19 import net.i2p.router.util.CachedIteratorAbstractCollection;
     19import net.i2p.router.util.CachedIteratorCollection;
    2020import net.i2p.router.util.PriBlockingQueue;
    2121import net.i2p.util.Log;
     
    209209     *  although there could be some that have not been sent yet.
    210210     */
    211     private final CachedIteratorAbstractCollection<OutboundMessageState> _outboundMessages;
     211    private final CachedIteratorCollection<OutboundMessageState> _outboundMessages;
    212212
    213213    /**
     
    369369        _rttDeviation = _rtt;
    370370        _inboundMessages = new HashMap<Long, InboundMessageState>(8);
    371         _outboundMessages = new CachedIteratorAbstractCollection<OutboundMessageState>();
     371        _outboundMessages = new CachedIteratorCollection<OutboundMessageState>();
    372372        //_outboundQueue = new CoDelPriorityBlockingQueue(ctx, "UDP-PeerState", 32);
    373373        _outboundQueue = new PriBlockingQueue<OutboundMessageState>(ctx, "UDP-PeerState", 32);
     
    15851585                    if (_retransmitter == state)
    15861586                        _retransmitter = null;
    1587                     _log.debug("CachedIteratorAbstractCollection: sendFailed update" + state);
     1587                    _log.debug("CachedIteratorCollection: sendFailed update" + state);
    15881588                    _context.statManager().addRateData("udp.sendFailed", state.getPushCount());
    15891589                    if (failed == null) failed = new ArrayList<OutboundMessageState>(4);
     
    15931593                    if (state == _retransmitter)
    15941594                        _retransmitter = null;
    1595                     _log.debug("CachedIteratorAbstractCollection: sendAggressiveFailed update" + state);
     1595                    _log.debug("CachedIteratorCollection: sendAggressiveFailed update" + state);
    15961596                    _context.statManager().addRateData("udp.sendAggressiveFailed", state.getPushCount());
    15971597                    if (failed == null) failed = new ArrayList<OutboundMessageState>(4);
Note: See TracChangeset for help on using the changeset viewer.