Changeset e9cc851


Ignore:
Timestamp:
Aug 13, 2012 3:08:06 PM (8 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
16a46b3
Parents:
cfcafd2
Message:

comparator cleanups

Location:
router/java/src/net/i2p/router/transport
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java

    rcfcafd2 re9cc851  
    99import java.text.DecimalFormat;
    1010import java.text.NumberFormat;
     11import java.util.Collections;
    1112import java.util.Comparator;
    1213import java.util.HashMap;
     
    849850        }
    850851        if (sortFlags < 0)
    851             rv = new InverseComparator(rv);
     852            rv = Collections.reverseOrder(rv);
    852853        return rv;
    853854    }
     855
    854856    private static class AlphaComparator extends PeerComparator {
    855857        private static final AlphaComparator _instance = new AlphaComparator();
    856858        public static final AlphaComparator instance() { return _instance; }
    857859    }
    858     private static class InverseComparator implements Comparator {
    859         private Comparator _comp;
    860         public InverseComparator(Comparator comp) { _comp = comp; }
    861         public int compare(Object lhs, Object rhs) {
    862             return -1 * _comp.compare(lhs, rhs);
    863         }
    864     }
     860
    865861    private static class PeerComparator implements Comparator {
    866862        public int compare(Object lhs, Object rhs) {
  • router/java/src/net/i2p/router/transport/udp/UDPTransport.java

    rcfcafd2 re9cc851  
    77import java.text.DecimalFormat;
    88import java.util.ArrayList;
     9import java.util.Collections;
    910import java.util.Comparator;
    1011import java.util.HashMap;
     
    17421743        }
    17431744        if (sortFlags < 0)
    1744             rv = new InverseComparator(rv);
     1745            rv = Collections.reverseOrder(rv);
    17451746        return rv;
    17461747    }
     
    17791780        @Override
    17801781        public int compare(PeerState l, PeerState r) {
    1781             long rv = l.getReceiveBps() - r.getReceiveBps();
     1782            int rv = l.getReceiveBps() - r.getReceiveBps();
    17821783            if (rv == 0) // fallback on alpha
    17831784                return super.compare(l, r);
    17841785            else
    1785                 return (int)rv;
     1786                return rv;
    17861787        }
    17871788    }
     
    17911792        @Override
    17921793        public int compare(PeerState l, PeerState r) {
    1793             long rv = l.getSendBps() - r.getSendBps();
     1794            int rv = l.getSendBps() - r.getSendBps();
    17941795            if (rv == 0) // fallback on alpha
    17951796                return super.compare(l, r);
    17961797            else
    1797                 return (int)rv;
     1798                return rv;
    17981799        }
    17991800    }
     
    18271828        @Override
    18281829        public int compare(PeerState l, PeerState r) {
    1829             long rv = l.getSendWindowBytes() - r.getSendWindowBytes();
     1830            int rv = l.getSendWindowBytes() - r.getSendWindowBytes();
    18301831            if (rv == 0) // fallback on alpha
    18311832                return super.compare(l, r);
    18321833            else
    1833                 return (int)rv;
     1834                return rv;
    18341835        }
    18351836    }
     
    18391840        @Override
    18401841        public int compare(PeerState l, PeerState r) {
    1841             long rv = l.getSlowStartThreshold() - r.getSlowStartThreshold();
     1842            int rv = l.getSlowStartThreshold() - r.getSlowStartThreshold();
    18421843            if (rv == 0) // fallback on alpha
    18431844                return super.compare(l, r);
    18441845            else
    1845                 return (int)rv;
     1846                return rv;
    18461847        }
    18471848    }
     
    18511852        @Override
    18521853        public int compare(PeerState l, PeerState r) {
    1853             long rv = l.getRTT() - r.getRTT();
     1854            int rv = l.getRTT() - r.getRTT();
    18541855            if (rv == 0) // fallback on alpha
    18551856                return super.compare(l, r);
    18561857            else
    1857                 return (int)rv;
     1858                return rv;
    18581859        }
    18591860    }
     
    18751876        @Override
    18761877        public int compare(PeerState l, PeerState r) {
    1877             long rv = l.getRTO() - r.getRTO();
     1878            int rv = l.getRTO() - r.getRTO();
    18781879            if (rv == 0) // fallback on alpha
    18791880                return super.compare(l, r);
    18801881            else
    1881                 return (int)rv;
     1882                return rv;
    18821883        }
    18831884    }
     
    18871888        @Override
    18881889        public int compare(PeerState l, PeerState r) {
    1889             long rv = l.getMTU() - r.getMTU();
     1890            int rv = l.getMTU() - r.getMTU();
    18901891            if (rv == 0) // fallback on alpha
    18911892                return super.compare(l, r);
    18921893            else
    1893                 return (int)rv;
     1894                return rv;
    18941895        }
    18951896    }
     
    19491950    }
    19501951
    1951     private static class InverseComparator implements Comparator {
    1952         private final Comparator _comp;
    1953         public InverseComparator(Comparator comp) { _comp = comp; }
    1954         public int compare(Object lhs, Object rhs) {
    1955             return -1 * _comp.compare(lhs, rhs);
    1956         }
    1957     }
    1958    
    19591952    private static void appendSortLinks(StringBuilder buf, String urlBase, int sortFlags, String descr, int ascending) {
    19601953        if (ascending == FLAG_ALPHA) {  // 0
Note: See TracChangeset for help on using the changeset viewer.