diff --git a/.idea/compiler.xml b/.idea/compiler.xml index 46d39593e..96cc43efa 100644 --- a/.idea/compiler.xml +++ b/.idea/compiler.xml @@ -1,41 +1,22 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/modules.xml b/.idea/modules.xml index 12768205c..3e5d2de7a 100644 --- a/.idea/modules.xml +++ b/.idea/modules.xml @@ -2,78 +2,25 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - diff --git a/.mtn-ignore b/.mtn-ignore index ff66b9d01..41aa1db6e 100644 --- a/.mtn-ignore +++ b/.mtn-ignore @@ -71,6 +71,5 @@ sloccount.sc /.project$ /.settings # IDEA -^.idea$ \.iml$ diff --git a/router/java/src/net/i2p/router/transport/udp/PeerState.java b/router/java/src/net/i2p/router/transport/udp/PeerState.java index cb4e13b35..9d8e136a1 100644 --- a/router/java/src/net/i2p/router/transport/udp/PeerState.java +++ b/router/java/src/net/i2p/router/transport/udp/PeerState.java @@ -17,9 +17,8 @@ import net.i2p.data.Hash; import net.i2p.data.SessionKey; import net.i2p.router.OutNetMessage; import net.i2p.router.RouterContext; -//import net.i2p.router.util.CachedIteratorArrayList; -import net.i2p.router.util.CachedIteratorCollection; -//import net.i2p.router.util.CoDelPriorityBlockingQueue; +import net.i2p.router.util.CachedIteratorArrayList; +import net.i2p.router.util.CoDelPriorityBlockingQueue; import net.i2p.router.util.PriBlockingQueue; import net.i2p.util.Log; import net.i2p.util.ConcurrentHashSet; @@ -211,7 +210,7 @@ public class PeerState { * Mostly messages that have been transmitted and are awaiting acknowledgement, * although there could be some that have not been sent yet. */ - private final CachedIteratorCollection _outboundMessages; + private final List _outboundMessages; /** * Priority queue of messages that have not yet been sent. @@ -371,7 +370,7 @@ public class PeerState { _rtt = INIT_RTT; _rttDeviation = _rtt; _inboundMessages = new HashMap(8); - _outboundMessages = new CachedIteratorCollection(); + _outboundMessages = new CachedIteratorArrayList(32); //_outboundQueue = new CoDelPriorityBlockingQueue(ctx, "UDP-PeerState", 32); _outboundQueue = new PriBlockingQueue(ctx, "UDP-PeerState", 32); // all createRateStat() moved to EstablishmentManager