Changeset de184ed1


Ignore:
Timestamp:
Dec 9, 2013 7:51:39 PM (6 years ago)
Author:
str4d <str4d@…>
Branches:
master
Children:
a4114b9
Parents:
f8a54bde (diff), c180292 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.
Message:

propagate from branch 'i2p.i2p.str4d.cleanup' (head 736423cc308e964bab55068e625f8a1852932ec5)

to branch 'i2p.i2p' (head 0ac335d5dc4ccaeb113af4fb5c0e993a6f42fdbe)

Files:
1 added
1 deleted
111 edited

Legend:

Unmodified
Added
Removed
  • apps/BOB/src/net/i2p/BOB/Lifted.java

    rf8a54bde rde184ed1  
    1616package net.i2p.BOB;
    1717
    18 import java.util.Enumeration;
     18import java.util.Map;
    1919import java.util.Properties;
    2020
     
    4040         **/
    4141        public static void copyProperties(Properties src_prop, Properties dest_prop) {
    42                 for (Enumeration propertyNames = src_prop.propertyNames();
    43                         propertyNames.hasMoreElements();) {
    44                         Object key = propertyNames.nextElement();
    45                         dest_prop.put(key, src_prop.get(key));
     42                for (Map.Entry<Object, Object> e : src_prop.entrySet()) {
     43                        dest_prop.put((String)e.getKey(), (String)e.getValue());
    4644                }
    4745        }
  • apps/desktopgui/src/net/i2p/desktopgui/Main.java

    rf8a54bde rde184ed1  
    88import javax.swing.UIManager;
    99import javax.swing.UnsupportedLookAndFeelException;
    10 import java.awt.GraphicsEnvironment;
    11 
    12 import net.i2p.I2PAppContext;
    1310import net.i2p.desktopgui.router.RouterManager;
    1411import net.i2p.desktopgui.util.*;
  • apps/desktopgui/src/net/i2p/desktopgui/TrayManager.java

    rf8a54bde rde184ed1  
    22
    33import java.awt.AWTException;
    4 import java.awt.Desktop;
    54import java.awt.Image;
    6 import java.awt.MenuItem;
    75import java.awt.PopupMenu;
    86import java.awt.SystemTray;
    97import java.awt.Toolkit;
    108import java.awt.TrayIcon;
    11 import java.awt.Desktop.Action;
    12 import java.awt.event.ActionEvent;
    13 import java.awt.event.ActionListener;
    14 import java.io.IOException;
    15 import java.net.URI;
    16 import java.net.URISyntaxException;
    179import java.net.URL;
    18 
    19 import javax.swing.SwingWorker;
    2010
    2111import net.i2p.desktopgui.i18n.DesktopguiTranslator;
    2212import net.i2p.desktopgui.router.RouterManager;
    23 import net.i2p.desktopgui.util.BrowseException;
    24 import net.i2p.desktopgui.util.ConfigurationManager;
    25 import net.i2p.desktopgui.util.I2PDesktop;
    2613import net.i2p.util.Log;
    2714
  • apps/desktopgui/src/net/i2p/desktopgui/gui/DesktopguiConfigurationFrame.java

    rf8a54bde rde184ed1  
    3333     * always regenerated by the Form Editor.
    3434     */
    35     @SuppressWarnings("unchecked")
    3635    // <editor-fold defaultstate="collapsed" desc="Generated Code">//GEN-BEGIN:initComponents
    3736    private void initComponents() {
     
    116115        }
    117116        try {
    118             RouterManager.getRouterContext().setProperty(property, value);
     117            RouterManager.getRouterContext().router().saveConfig(property, value);
    119118        } catch (Exception ex) {
    120119            Logger.getLogger(DesktopguiConfigurationFrame.class.getName()).log(Level.SEVERE, null, ex);
  • apps/desktopgui/src/net/i2p/desktopgui/router/RouterManager.java

    rf8a54bde rde184ed1  
    66
    77import net.i2p.I2PAppContext;
    8 import net.i2p.desktopgui.i18n.DesktopguiTranslator;
    9 import net.i2p.desktopgui.util.ConfigurationManager;
    108import net.i2p.router.Router;
    119import net.i2p.router.RouterContext;
  • apps/desktopgui/src/net/i2p/desktopgui/util/I2PDesktop.java

    rf8a54bde rde184ed1  
    22
    33import java.awt.Desktop;
    4 import java.awt.TrayIcon;
    54import java.awt.Desktop.Action;
    6 import java.io.IOException;
    75import java.net.URI;
    8 import java.net.URISyntaxException;
    9 
    10 import net.i2p.desktopgui.router.RouterManager;
    116import net.i2p.util.Log;
    127
  • apps/i2psnark/java/src/org/klomp/snark/MetaInfo.java

    rf8a54bde rde184ed1  
    157157        this.announce_list = null;
    158158    } else {
    159         this.announce_list = new ArrayList();
     159        this.announce_list = new ArrayList<List<String>>();
    160160        List<BEValue> bl1 = val.getList();
    161161        for (BEValue bev : bl1) {
    162162            List<BEValue> bl2 = bev.getList();
    163             List<String> sl2 = new ArrayList();           
     163            List<String> sl2 = new ArrayList<String>();           
    164164            for (BEValue bev2 : bl2) {
    165165                sl2.add(bev2.getString());
     
    260260          throw new InvalidBEncodingException("zero size files list");
    261261
    262         List<List<String>> m_files = new ArrayList(size);
    263         List<List<String>> m_files_utf8 = new ArrayList(size);
    264         List<Long> m_lengths = new ArrayList(size);
     262        List<List<String>> m_files = new ArrayList<List<String>>(size);
     263        List<List<String>> m_files_utf8 = new ArrayList<List<String>>(size);
     264        List<Long> m_lengths = new ArrayList<Long>(size);
    265265        long l = 0;
    266266        for (int i = 0; i < list.size(); i++)
     
    288288              throw new InvalidBEncodingException("zero size file path list");
    289289
    290             List<String> file = new ArrayList(path_length);
     290            List<String> file = new ArrayList<String>(path_length);
    291291            Iterator<BEValue> it = path_list.iterator();
    292292            while (it.hasNext()) {
     
    311311                path_length = path_list.size();
    312312                if (path_length > 0) {
    313                     file = new ArrayList(path_length);
     313                    file = new ArrayList<String>(path_length);
    314314                    it = path_list.iterator();
    315315                    while (it.hasNext())
     
    574574  public MetaInfo reannounce(String announce) throws InvalidBEncodingException
    575575  {
    576         Map<String, BEValue> m = new HashMap();
     576        Map<String, BEValue> m = new HashMap<String, BEValue>();
    577577        if (announce != null)
    578578            m.put("announce", new BEValue(DataHelper.getUTF8(announce)));
    579         Map info = createInfoMap();
     579        Map<String, BEValue> info = createInfoMap();
    580580        m.put("info", new BEValue(info));
    581581        return new MetaInfo(m);
     
    587587  public synchronized byte[] getTorrentData()
    588588  {
    589         Map m = new HashMap();
     589        Map<String, Object> m = new HashMap<String, Object>();
    590590        if (announce != null)
    591591            m.put("announce", announce);
    592592        if (announce_list != null)
    593593            m.put("announce-list", announce_list);
    594         Map info = createInfoMap();
     594        Map<String, BEValue> info = createInfoMap();
    595595        m.put("info", info);
    596596        // don't save this locally, we should only do this once
     
    616616        _log.warn("Creating new infomap", new Exception());
    617617    // otherwise we must create it
    618     Map info = new HashMap();
    619     info.put("name", name);
     618    Map<String, BEValue> info = new HashMap<String, BEValue>();
     619    info.put("name", new BEValue(DataHelper.getUTF8(name)));
    620620    if (name_utf8 != null)
    621         info.put("name.utf-8", name_utf8);
     621        info.put("name.utf-8", new BEValue(DataHelper.getUTF8(name_utf8)));
    622622    // BEP 27
    623623    if (privateTorrent)
    624         info.put("private", "1");
    625 
    626     info.put("piece length", Integer.valueOf(piece_length));
    627     info.put("pieces", piece_hashes);
     624        info.put("private", new BEValue(DataHelper.getUTF8("1")));
     625
     626    info.put("piece length", new BEValue(Integer.valueOf(piece_length)));
     627    info.put("pieces", new BEValue(piece_hashes));
    628628    if (files == null)
    629       info.put("length", Long.valueOf(length));
     629      info.put("length", new BEValue(Long.valueOf(length)));
    630630    else
    631631      {
    632         List l = new ArrayList();
     632        List<BEValue> l = new ArrayList<BEValue>();
    633633        for (int i = 0; i < files.size(); i++)
    634634          {
    635             Map file = new HashMap();
    636             file.put("path", files.get(i));
    637             if ( (files_utf8 != null) && (files_utf8.size() > i) )
    638                 file.put("path.utf-8", files_utf8.get(i));
    639             file.put("length", lengths.get(i));
    640             l.add(file);
     635            Map<String, BEValue> file = new HashMap<String, BEValue>();
     636            List<String> fi = files.get(i);
     637            List<BEValue> befiles = new ArrayList<BEValue>(fi.size());
     638            for (int j = 0; j < fi.size(); j++) {
     639                befiles.add(new BEValue(DataHelper.getUTF8(fi.get(j))));
     640            }
     641            file.put("path", new BEValue(befiles));
     642            if ( (files_utf8 != null) && (files_utf8.size() > i) ) {
     643                List<String> fiu = files_utf8.get(i);
     644                List<BEValue> beufiles = new ArrayList<BEValue>(fiu.size());
     645                for (int j = 0; j < fiu.size(); j++) {
     646                    beufiles.add(new BEValue(DataHelper.getUTF8(fiu.get(j))));
     647                }
     648                file.put("path.utf-8", new BEValue(beufiles));
     649            }
     650            file.put("length", new BEValue(lengths.get(i)));
     651            l.add(new BEValue(file));
    641652          }
    642         info.put("files", l);
     653        info.put("files", new BEValue(l));
    643654      }
    644655
  • apps/i2psnark/java/src/org/klomp/snark/PartialPiece.java

    rf8a54bde rde184ed1  
    3232 * @since 0.8.2
    3333 */
    34 class PartialPiece implements Comparable {
     34class PartialPiece implements Comparable<PartialPiece> {
    3535
    3636    // we store the piece so we can use it in compareTo()
     
    296296     *  then highest downloaded first
    297297     */
    298     public int compareTo(Object o) throws ClassCastException {
    299         PartialPiece opp = (PartialPiece)o;
     298    public int compareTo(PartialPiece opp) {
    300299        int d = this.piece.compareTo(opp.piece);
    301300        if (d != 0)
  • apps/i2psnark/java/src/org/klomp/snark/Peer.java

    rf8a54bde rde184ed1  
    4040import org.klomp.snark.bencode.BEValue;
    4141
    42 public class Peer implements Comparable
     42public class Peer implements Comparable<Peer>
    4343{
    4444  private final Log _log = I2PAppContext.getGlobalContext().logManager().getLog(Peer.class);
     
    195195   * @deprecated unused?
    196196   */
    197   public int compareTo(Object o)
     197  public int compareTo(Peer o)
    198198  {
    199199    Peer p = (Peer)o;
  • apps/i2psnark/java/src/org/klomp/snark/PeerID.java

    rf8a54bde rde184ed1  
    4343 *  Equality is now determined solely by the dest hash.
    4444 */
    45 class PeerID implements Comparable
     45class PeerID implements Comparable<PeerID>
    4646{
    4747  private byte[] id;
     
    7777   * port.
    7878   */
    79   public PeerID(Map m)
     79  public PeerID(Map<String, BEValue> m)
    8080    throws InvalidBEncodingException, UnknownHostException
    8181  {
    82     BEValue bevalue = (BEValue)m.get("peer id");
     82    BEValue bevalue = m.get("peer id");
    8383    if (bevalue == null)
    8484      throw new InvalidBEncodingException("peer id missing");
    8585    id = bevalue.getBytes();
    8686
    87     bevalue = (BEValue)m.get("ip");
     87    bevalue = m.get("ip");
    8888    if (bevalue == null)
    8989      throw new InvalidBEncodingException("ip missing");
     
    196196   * @deprecated unused? and will NPE now that address can be null?
    197197   */
    198   public int compareTo(Object o)
    199   {
    200     PeerID pid = (PeerID)o;
    201 
     198  public int compareTo(PeerID pid)
     199  {
    202200    int result = port - pid.port;
    203201    if (result != 0)
  • apps/i2psnark/java/src/org/klomp/snark/Piece.java

    rf8a54bde rde184ed1  
    88 * Caller must synchronize on many of these methods.
    99 */
    10 class Piece implements Comparable {
     10class Piece implements Comparable<Piece> {
    1111
    1212    private final int id;
     
    2727     *  then rarest first
    2828     */
    29     public int compareTo(Object o) throws ClassCastException {
    30         int pdiff = ((Piece)o).priority - this.priority;   // reverse
     29    public int compareTo(Piece op) {
     30        int pdiff = op.priority - this.priority;   // reverse
    3131        if (pdiff != 0)
    3232            return pdiff;
    33         return this.peers.size() - ((Piece)o).peers.size();
     33        return this.peers.size() - op.peers.size();
    3434    }
    3535   
  • apps/i2psnark/java/src/org/klomp/snark/SnarkManager.java

    rf8a54bde rde184ed1  
    425425        int i2cpPort = getInt(PROP_I2CP_PORT, 7654);
    426426        String opts = _config.getProperty(PROP_I2CP_OPTS);
    427         Map i2cpOpts = new HashMap();
     427        Map<String, String> i2cpOpts = new HashMap<String, String>();
    428428        if (opts != null) {
    429429            StringTokenizer tok = new StringTokenizer(opts, " ");
     
    16531653    private void monitorTorrents(File dir) {
    16541654        String fileNames[] = dir.list(TorrentFilenameFilter.instance());
    1655         List<String> foundNames = new ArrayList(0);
     1655        List<String> foundNames = new ArrayList<String>(0);
    16561656        if (fileNames != null) {
    16571657            for (int i = 0; i < fileNames.length; i++) {
     
    17391739     */
    17401740    public List<Tracker> getSortedTrackers() {
    1741         List<Tracker> rv = new ArrayList(_trackerMap.values());
     1741        List<Tracker> rv = new ArrayList<Tracker>(_trackerMap.values());
    17421742        Collections.sort(rv, new IgnoreCaseComparator());
    17431743        return rv;
  • apps/i2psnark/java/src/org/klomp/snark/bencode/BDecoder.java

    rf8a54bde rde184ed1  
    282282    indicator = 0;
    283283
    284     List result = new ArrayList();
     284    List<BEValue> result = new ArrayList<BEValue>();
    285285    c = getNextIndicator();
    286286    while (c != 'e')
     
    309309    indicator = 0;
    310310
    311     Map result = new HashMap();
     311    Map<String, BEValue> result = new HashMap<String, BEValue>();
    312312    c = getNextIndicator();
    313313    while (c != 'e')
  • apps/i2psnark/java/src/org/klomp/snark/bencode/BEValue.java

    rf8a54bde rde184ed1  
    5050  }
    5151
    52   public BEValue(List value)
    53   {
    54     this.value = value;
    55   }
    56 
    57   public BEValue(Map value)
     52  public BEValue(List<BEValue> value)
     53  {
     54    this.value = value;
     55  }
     56
     57  public BEValue(Map<String, BEValue> value)
    5858  {
    5959    this.value = value;
     
    143143   * throw a InvalidBEncodingException.
    144144   */
     145  @SuppressWarnings("unchecked")
    145146  public List<BEValue> getList() throws InvalidBEncodingException
    146147  {
    147148    try
    148149      {
    149         return (List)value;
     150        return (List<BEValue>)value;
    150151      }
    151152    catch (ClassCastException cce)
     
    160161   * a Map, otherwise it will throw a InvalidBEncodingException.
    161162   */
     163  @SuppressWarnings("unchecked")
    162164  public Map<String, BEValue> getMap() throws InvalidBEncodingException
    163165  {
    164166    try
    165167      {
    166         return (Map)value;
     168        return (Map<String, BEValue>)value;
    167169      }
    168170    catch (ClassCastException cce)
  • apps/i2psnark/java/src/org/klomp/snark/bencode/BEncoder.java

    rf8a54bde rde184ed1  
    6060      bencode((Number)o, out);
    6161    else if (o instanceof List)
    62       bencode((List)o, out);
     62      bencode((List<?>)o, out);
    6363    else if (o instanceof Map)
    64       bencode((Map<String, Object>)o, out);
     64      bencode((Map<?, ?>)o, out);
    6565    else if (o instanceof BEValue)
    6666      bencode(((BEValue)o).getValue(), out);
     
    111111  }
    112112
    113   public static byte[] bencode(List l)
     113  public static byte[] bencode(List<?> l)
    114114  {
    115115    try
     
    125125  }
    126126
    127   public static void bencode(List l, OutputStream out) throws IOException
     127  public static void bencode(List<?> l, OutputStream out) throws IOException
    128128  {
    129129    out.write('l');
    130     Iterator it = l.iterator();
     130    Iterator<?> it = l.iterator();
    131131    while (it.hasNext())
    132132      bencode(it.next(), out);
     
    176176    // Keys must be sorted. XXX - But is this the correct order?
    177177    Set<String> s = m.keySet();
    178     List<String> l = new ArrayList(s);
     178    List<String> l = new ArrayList<String>(s);
    179179    Collections.sort(l);
    180180
  • apps/i2psnark/java/src/org/klomp/snark/dht/PersistDHT.java

    rf8a54bde rde184ed1  
    3838        Log log = I2PAppContext.getGlobalContext().logManager().getLog(PersistDHT.class);
    3939        int count = 0;
    40         FileInputStream in = null;
     40        BufferedReader br = null;
    4141        try {
    42             in = new FileInputStream(file);
    43             BufferedReader br = new BufferedReader(new InputStreamReader(in, "ISO-8859-1"));
     42            br = new BufferedReader(new InputStreamReader(
     43                        new FileInputStream(file), "ISO-8859-1"));
    4444            String line = null;
    4545            while ( (line = br.readLine()) != null) {
     
    6262                log.warn("Error reading the DHT File", ioe);
    6363        } finally {
    64             if (in != null) try { in.close(); } catch (IOException ioe) {}
     64            if (br != null) try { br.close(); } catch (IOException ioe) {}
    6565        }
    6666        if (log.shouldLog(Log.INFO))
  • apps/i2psnark/java/src/org/klomp/snark/web/BasicServlet.java

    rf8a54bde rde184ed1  
    2828
    2929import javax.servlet.ServletConfig;
    30 import javax.servlet.ServletContext;
    3130import javax.servlet.ServletException;
    3231import javax.servlet.UnavailableException;
     
    326325
    327326        // see if there are any range headers
    328         Enumeration reqRanges = request.getHeaders("Range");
     327        Enumeration<?> reqRanges = request.getHeaders("Range");
    329328
    330329        if (reqRanges == null || !reqRanges.hasMoreElements()) {
  • apps/i2psnark/java/src/org/klomp/snark/web/I2PSnarkServlet.java

    rf8a54bde rde184ed1  
    22
    33import java.io.File;
    4 import java.io.FileInputStream;
    54import java.io.IOException;
    65import java.io.PrintWriter;
    7 import java.io.UnsupportedEncodingException;
    8 import java.net.URI;
    9 import java.net.URISyntaxException;
    106import java.text.Collator;
    117import java.text.DecimalFormat;
     
    1713import java.util.Date;
    1814import java.util.Enumeration;
    19 import java.util.Iterator;
    2015import java.util.List;
    2116import java.util.Locale;
     
    2722import javax.servlet.ServletConfig;
    2823import javax.servlet.ServletException;
    29 import javax.servlet.http.HttpServlet;
    3024import javax.servlet.http.HttpServletRequest;
    3125import javax.servlet.http.HttpServletResponse;
    3226
    33 import net.i2p.I2PAppContext;
    3427import net.i2p.data.Base64;
    3528import net.i2p.data.DataHelper;
    36 import net.i2p.util.I2PAppThread;
    3729import net.i2p.util.Log;
    3830
     
    209201                } else {
    210202                    String base = addPaths(req.getRequestURI(), "/");
    211                     String listing = getListHTML(resource, base, true, method.equals("POST") ? req.getParameterMap() : null);
     203                    @SuppressWarnings("unchecked") // TODO-Java6: Remove cast, return type is correct
     204                    String listing = getListHTML(resource, base, true, method.equals("POST") ? (Map<String, String[]>) req.getParameterMap() : null);
    212205                    if (method.equals("POST")) {
    213206                        // P-R-G
     
    685678        if (action == null) {
    686679            // http://www.onenaught.com/posts/382/firefox-4-change-input-type-image-only-submits-x-and-y-not-name
    687             Map params = req.getParameterMap();
     680            @SuppressWarnings("unchecked") // TODO-Java6: Remove cast, return type is correct
     681            Map<String, String[]> params = req.getParameterMap();
    688682            for (Object o : params.keySet()) {
    689683                String key = (String) o;
     
    759753                byte infoHash[] = Base64.decode(torrent);
    760754                if ( (infoHash != null) && (infoHash.length == 20) ) { // valid sha1
    761                     for (Iterator iter = _manager.listTorrentFiles().iterator(); iter.hasNext(); ) {
    762                         String name = (String)iter.next();
     755                    for (String name : _manager.listTorrentFiles() ) {
    763756                        Snark snark = _manager.getTorrent(name);
    764757                        if ( (snark != null) && (DataHelper.eq(infoHash, snark.getInfoHash())) ) {
     
    782775                byte infoHash[] = Base64.decode(torrent);
    783776                if ( (infoHash != null) && (infoHash.length == 20) ) { // valid sha1
    784                     for (Iterator iter = _manager.listTorrentFiles().iterator(); iter.hasNext(); ) {
    785                         String name = (String)iter.next();
     777                    for (String name : _manager.listTorrentFiles() ) {
    786778                        Snark snark = _manager.getTorrent(name);
    787779                        if ( (snark != null) && (DataHelper.eq(infoHash, snark.getInfoHash())) ) {
     
    810802                byte infoHash[] = Base64.decode(torrent);
    811803                if ( (infoHash != null) && (infoHash.length == 20) ) { // valid sha1
    812                     for (Iterator iter = _manager.listTorrentFiles().iterator(); iter.hasNext(); ) {
    813                         String name = (String)iter.next();
     804                    for (String name : _manager.listTorrentFiles() ) {
    814805                        Snark snark = _manager.getTorrent(name);
    815806                        if ( (snark != null) && (DataHelper.eq(infoHash, snark.getInfoHash())) ) {
     
    850841                            }
    851842                            // step 2 make Set of dirs with reverse sort
    852                             Set<File> dirs = new TreeSet(Collections.reverseOrder());
     843                            Set<File> dirs = new TreeSet<File>(Collections.reverseOrder());
    853844                            for (List<String> list : files) {
    854845                                for (int i = 1; i < list.size(); i++) {
     
    923914                        announceURL = null;
    924915                    _lastAnnounceURL = announceURL;
    925                     List<String> backupURLs = new ArrayList();
    926                     Enumeration e = req.getParameterNames();
     916                    List<String> backupURLs = new ArrayList<String>();
     917                    Enumeration<?> e = req.getParameterNames();
    927918                    while (e.hasMoreElements()) {
    928919                         Object o = e.nextElement();
     
    956947                            return;
    957948                        }
    958                         announceList = new ArrayList(backupURLs.size());
     949                        announceList = new ArrayList<List<String>>(backupURLs.size());
    959950                        for (String url : backupURLs) {
    960951                            announceList.add(Collections.singletonList(url));
     
    10181009            boolean changed = false;
    10191010            Map<String, Tracker> trackers = _manager.getTrackerMap();
    1020             List<String> removed = new ArrayList();
    1021             List<String> open = new ArrayList();
    1022             List<String> priv = new ArrayList();
    1023             Enumeration e = req.getParameterNames();
     1011            List<String> removed = new ArrayList<String>();
     1012            List<String> open = new ArrayList<String>();
     1013            List<String> priv = new ArrayList<String>();
     1014            Enumeration<?> e = req.getParameterNames();
    10241015            while (e.hasMoreElements()) {
    10251016                 Object o = e.nextElement();
     
    10461037
    10471038            open.removeAll(removed);
    1048             List<String> oldOpen = new ArrayList(_manager.util().getOpenTrackers());
     1039            List<String> oldOpen = new ArrayList<String>(_manager.util().getOpenTrackers());
    10491040            Collections.sort(oldOpen);
    10501041            Collections.sort(open);
     
    10551046            // open trumps private
    10561047            priv.removeAll(open);
    1057             List<String> oldPriv = new ArrayList(_manager.getPrivateTrackers());
     1048            List<String> oldPriv = new ArrayList<String>(_manager.getPrivateTrackers());
    10581049            Collections.sort(oldPriv);
    10591050            Collections.sort(priv);
     
    10751066                    // open trumps private
    10761067                    if (req.getParameter("_add_open_") != null) {
    1077                         List newOpen = new ArrayList(_manager.util().getOpenTrackers());
     1068                        List<String> newOpen = new ArrayList<String>(_manager.util().getOpenTrackers());
    10781069                        newOpen.add(aurl);
    10791070                        _manager.saveOpenTrackers(newOpen);
    10801071                    } else if (req.getParameter("_add_private_") != null) {
    1081                         List newPriv = new ArrayList(_manager.getPrivateTrackers());
     1072                        List<String> newPriv = new ArrayList<String>(_manager.getPrivateTrackers());
    10821073                        newPriv.add(aurl);
    10831074                        _manager.savePrivateTrackers(newPriv);
     
    11421133
    11431134    private List<Snark> getSortedSnarks(HttpServletRequest req) {
    1144         ArrayList<Snark> rv = new ArrayList(_manager.getTorrents());
     1135        ArrayList<Snark> rv = new ArrayList<Snark>(_manager.getTorrents());
    11451136        Collections.sort(rv, new TorrentNameComparator());
    11461137        return rv;
     
    19171908        //          + _manager.util().getEepProxyPort() + "\" size=\"5\" maxlength=\"5\" /><br>\n");
    19181909
    1919         Map<String, String> options = new TreeMap(_manager.util().getI2CPOptions());
     1910        Map<String, String> options = new TreeMap<String, String>(_manager.util().getI2CPOptions());
    19201911        out.write("<tr><td>");
    19211912        out.write(_("Inbound Settings"));
     
    22132204     * @since 0.7.14
    22142205     */
    2215     private String getListHTML(File r, String base, boolean parent, Map postParams)
     2206    private String getListHTML(File r, String base, boolean parent, Map<String, String[]> postParams)
    22162207        throws IOException
    22172208    {
     
    23892380                   .append(formatSize(needed));
    23902381            if (meta != null) {
    2391                 List files = meta.getFiles();
     2382                List<List<String>> files = meta.getFiles();
    23922383                int fileCount = files != null ? files.size() : 1;
    23932384                buf.append("&nbsp;<img alt=\"\" border=\"0\" src=\"" + _imgPath + "file.png\" >&nbsp;<b>")
     
    26492640
    26502641    /** @since 0.8.1 */
    2651     private void savePriorities(Snark snark, Map postParams) {
     2642    private void savePriorities(Snark snark, Map<String, String[]> postParams) {
    26522643        Storage storage = snark.getStorage();
    26532644        if (storage == null)
    26542645            return;
    2655         Set<Map.Entry> entries = postParams.entrySet();
    2656         for (Map.Entry entry : entries) {
    2657             String key = (String)entry.getKey();
     2646        for (Map.Entry<String, String[]> entry : postParams.entrySet()) {
     2647            String key = entry.getKey();
    26582648            if (key.startsWith("pri.")) {
    26592649                try {
    26602650                    String file = key.substring(4);
    2661                     String val = ((String[])entry.getValue())[0];   // jetty arrays
     2651                    String val = entry.getValue()[0];   // jetty arrays
    26622652                    int pri = Integer.parseInt(val);
    26632653                    storage.setPriority(file, pri);
  • apps/i2psnark/java/src/org/klomp/snark/web/InclusiveByteRange.java

    rf8a54bde rde184ed1  
    7474     * @return List of satisfiable ranges
    7575     */
    76     public static List<InclusiveByteRange> satisfiableRanges(Enumeration headers, long size)
     76    public static List<InclusiveByteRange> satisfiableRanges(Enumeration<?> headers, long size)
    7777    {
    7878        List<InclusiveByteRange> satRanges = null;
     
    129129                        {
    130130                            if (satRanges == null)
    131                                 satRanges = new ArrayList(4);
     131                                satRanges = new ArrayList<InclusiveByteRange>(4);
    132132                            InclusiveByteRange range = new InclusiveByteRange(first,last);
    133133                            satRanges.add(range);
  • apps/i2psnark/java/src/org/klomp/snark/web/MimeTypes.java

    rf8a54bde rde184ed1  
    2121import java.util.ResourceBundle;
    2222import java.util.concurrent.ConcurrentHashMap;
    23 
    24 import javax.servlet.ServletContext;
    2523
    2624
     
    4947
    5048    public MimeTypes() {
    51         _mimeMap = new ConcurrentHashMap();
     49        _mimeMap = new ConcurrentHashMap<String, String>();
    5250    }
    5351
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnel.java

    rf8a54bde rde184ed1  
    367367     */
    368368    public void setClientOptions(Properties opts) {
    369         for (Iterator iter = _clientOptions.keySet().iterator(); iter.hasNext();) {
     369        for (Iterator<Object> iter = _clientOptions.keySet().iterator(); iter.hasNext();) {
    370370            Object key = iter.next();
    371371            if (!opts.containsKey(key))
     
    16681668    void routerDisconnected() {
    16691669        _log.error(getPrefix() + "Router disconnected - firing notification events");
    1670             for (Iterator<ConnectionEventListener> iter = listeners.iterator(); iter.hasNext();) {
    1671                 ConnectionEventListener lsnr = iter.next();
     1670            for (ConnectionEventListener lsnr : listeners) {
    16721671                if (lsnr != null) lsnr.routerDisconnected();
    16731672            }
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelServer.java

    rf8a54bde rde184ed1  
    1717import java.net.SocketTimeoutException;
    1818import java.security.GeneralSecurityException;
    19 import java.util.Iterator;
    2019import java.util.Map;
    2120import java.util.Properties;
     
    321320            if (!forced && sockMgr.listSockets().size() != 0) {
    322321                l.log("There are still active connections!");
    323                 for (Iterator<I2PSocket> it = sockMgr.listSockets().iterator(); it.hasNext();) {
    324                     l.log("->" + it.next());
     322                for (I2PSocket skt : sockMgr.listSockets()) {
     323                    l.log("->" + skt);
    325324                }
    326325                return false;
     
    366365    private void buildSocketMap(Properties props) {
    367366        _socketMap.clear();
    368         for (Map.Entry e : props.entrySet()) {
     367        for (Map.Entry<Object, Object> e : props.entrySet()) {
    369368            String key = (String) e.getKey();
    370369            if (key.startsWith("targetForPort.")) {
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/TunnelController.java

    rf8a54bde rde184ed1  
    414414    public Properties getClientOptionProps() {
    415415        Properties opts = new Properties();
    416         for (Map.Entry e : _config.entrySet()) {
     416        for (Map.Entry<Object, Object> e : _config.entrySet()) {
    417417            String key = (String) e.getKey();
    418418            if (key.startsWith("option.")) {
     
    472472    public void setConfig(Properties config, String prefix) {
    473473        Properties props = new Properties();
    474         for (Map.Entry e : config.entrySet()) {
     474        for (Map.Entry<Object, Object> e : config.entrySet()) {
    475475            String key = (String) e.getKey();
    476476            if (key.startsWith(prefix)) {
     
    517517    public Properties getConfig(String prefix) {
    518518        Properties rv = new Properties();
    519         for (Map.Entry e : _config.entrySet()) {
     519        for (Map.Entry<Object, Object> e : _config.entrySet()) {
    520520            String key = (String) e.getKey();
    521521            String val = (String) e.getValue();
     
    539539    public String getClientOptions() {
    540540        StringBuilder opts = new StringBuilder(64);
    541         for (Map.Entry e : _config.entrySet()) {
     541        for (Map.Entry<Object, Object> e : _config.entrySet()) {
    542542            String key = (String) e.getKey();
    543543            if (key.startsWith("option.")) {
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/I2PSOCKSTunnel.java

    rf8a54bde rde184ed1  
    7171        Properties opts = getTunnel().getClientOptions();
    7272        proxies = new HashMap<String, List<String>>(1);
    73         for (Map.Entry e : opts.entrySet()) {
     73        for (Map.Entry<Object, Object> e : opts.entrySet()) {
    7474           String prop = (String)e.getKey();
    7575           if ((!prop.startsWith(PROP_PROXY_PREFIX)) || prop.length() <= PROP_PROXY_PREFIX.length())
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/web/EditBean.java

    rf8a54bde rde184ed1  
    374374                                 "connectclient".equals(tun.getType());
    375375            Map<String, String> sorted = new TreeMap<String, String>();
    376             for (Map.Entry e : opts.entrySet()) {
     376            for (Map.Entry<Object, Object> e : opts.entrySet()) {
    377377                String key = (String)e.getKey();
    378378                if (_noShowSet.contains(key))
  • apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketManagerFactory.java

    rf8a54bde rde184ed1  
    66import java.io.InputStream;
    77import java.lang.reflect.Constructor;
    8 import java.util.Iterator;
    98import java.util.Map;
    109import java.util.Properties;
     
    203202            opts = new Properties();
    204203        Properties syscopy = (Properties) System.getProperties().clone();
    205         for (Map.Entry e : syscopy.entrySet()) {
     204        for (Map.Entry<Object, Object> e : syscopy.entrySet()) {
    206205            String name = (String) e.getKey();
    207206            if (!opts.containsKey(name))
  • apps/routerconsole/java/src/net/i2p/router/update/ConsoleUpdateManager.java

    rf8a54bde rde184ed1  
    15361536
    15371537    /** debug */
    1538     private static void toString(StringBuilder buf, Collection col) {
     1538    private static void toString(StringBuilder buf, Collection<?> col) {
    15391539        List<String> list = new ArrayList<String>(col.size());
    15401540        for (Object o : col) {
     
    15501550    private static void toString(StringBuilder buf, Map<?, ?> map) {
    15511551        List<String> list = new ArrayList<String>(map.size());
    1552         for (Map.Entry entry : map.entrySet()) {
     1552        for (Map.Entry<?, ?> entry : map.entrySet()) {
    15531553            String key = entry.getKey().toString();
    15541554            String val = entry.getValue().toString();
  • apps/routerconsole/java/src/net/i2p/router/web/ConfigClientsHelper.java

    rf8a54bde rde184ed1  
    44import java.util.ArrayList;
    55import java.util.Date;
    6 import java.util.Iterator;
    76import java.util.List;
    87import java.util.Properties;
     
    140139        Properties props = RouterConsoleRunner.webAppProperties(_context);
    141140        Set<String> keys = new TreeSet(props.keySet());
    142         for (Iterator<String> iter = keys.iterator(); iter.hasNext(); ) {
    143             String name = iter.next();
     141        for (String name : keys) {
    144142            if (name.startsWith(RouterConsoleRunner.PREFIX) && name.endsWith(RouterConsoleRunner.ENABLED)) {
    145143                String app = name.substring(RouterConsoleRunner.PREFIX.length(), name.lastIndexOf(RouterConsoleRunner.ENABLED));
     
    166164        Properties props = PluginStarter.pluginProperties();
    167165        Set<String> keys = new TreeSet(props.keySet());
    168         for (Iterator<String> iter = keys.iterator(); iter.hasNext(); ) {
    169             String name = iter.next();
     166        for (String name : keys) {
    170167            if (name.startsWith(PluginStarter.PREFIX) && name.endsWith(PluginStarter.ENABLED)) {
    171168                String app = name.substring(PluginStarter.PREFIX.length(), name.lastIndexOf(PluginStarter.ENABLED));
  • apps/routerconsole/java/src/net/i2p/router/web/NetDbRenderer.java

    rf8a54bde rde184ed1  
    419419            if (!((style.equals("SSU") && cost == 5) || (style.equals("NTCP") && cost == 10)))
    420420                buf.append('[').append(_("cost")).append('=').append("" + cost).append("] ");
    421             Map p = addr.getOptionsMap();
    422             for (Map.Entry e : (Set<Map.Entry>) p.entrySet()) {
     421            Map<Object, Object> p = addr.getOptionsMap();
     422            for (Map.Entry<Object, Object> e : p.entrySet()) {
    423423                String name = (String) e.getKey();
    424424                String val = (String) e.getValue();
     
    429429        if (full) {
    430430            buf.append("<tr><td>" + _("Stats") + ": <br><code>");
    431             Map p = info.getOptionsMap();
    432             for (Map.Entry e : (Set<Map.Entry>) p.entrySet()) {
     431            Map<Object, Object> p = info.getOptionsMap();
     432            for (Map.Entry<Object, Object> e : p.entrySet()) {
    433433                String key = (String) e.getKey();
    434434                String val = (String) e.getValue();
  • apps/routerconsole/java/src/net/i2p/router/web/PluginStarter.java

    rf8a54bde rde184ed1  
    833833    private static void addPath(URL u) throws Exception {
    834834        URLClassLoader urlClassLoader = (URLClassLoader) ClassLoader.getSystemClassLoader();
    835         Class urlClass = URLClassLoader.class;
     835        Class<URLClassLoader> urlClass = URLClassLoader.class;
    836836        Method method = urlClass.getDeclaredMethod("addURL", new Class[]{URL.class});
    837837        method.setAccessible(true);
  • apps/routerconsole/java/src/net/i2p/router/web/ProfileOrganizerRenderer.java

    rf8a54bde rde184ed1  
    55import java.text.DecimalFormat;
    66import java.util.Comparator;
    7 import java.util.Iterator;
    87import java.util.Set;
    98import java.util.TreeSet;
     
    4645        int older = 0;
    4746        int standard = 0;
    48         for (Iterator<Hash> iter = peers.iterator(); iter.hasNext();) {
    49             Hash peer = iter.next();
     47        for (Hash peer : peers) {
    5048            if (_organizer.getUs().equals(peer)) continue;
    5149            PeerProfile prof = _organizer.getProfile(peer);
     
    9593                   buf.append("</tr>");
    9694        int prevTier = 1;
    97         for (Iterator<PeerProfile> iter = order.iterator(); iter.hasNext();) {
    98             PeerProfile prof = iter.next();
     95        for (PeerProfile prof : order) {
    9996            Hash peer = prof.getPeer();
    10097           
     
    218215        buf.append("</tr>");
    219216        RateAverages ra = RateAverages.getTemp();
    220         for (Iterator<PeerProfile> iter = order.iterator(); iter.hasNext();) {
    221             PeerProfile prof = iter.next();
     217        for (PeerProfile prof : order) {
    222218            Hash peer = prof.getPeer();
    223219
  • apps/routerconsole/java/src/net/i2p/router/web/SummaryHelper.java

    rf8a54bde rde184ed1  
    88import java.util.Collections;
    99import java.util.Comparator;
    10 import java.util.Iterator;
    1110import java.util.List;
    1211import java.util.Map;
     
    418417            buf.append("<table>");
    419418           
    420             for (Iterator<Destination> iter = clients.iterator(); iter.hasNext(); ) {
    421                 Destination client = iter.next();
     419            for (Destination client : clients) {
    422420                String name = getName(client);
    423421                Hash h = client.calculateHash();
  • apps/sam/java/src/net/i2p/sam/SAMBridge.java

    rf8a54bde rde184ed1  
    2121import java.util.Arrays;
    2222import java.util.HashMap;
    23 import java.util.Iterator;
    2423import java.util.Map;
    2524import java.util.Properties;
     
    215214        synchronized (nameToPrivKeys) {
    216215            nameToPrivKeys.clear();
    217             FileInputStream in = null;
     216            BufferedReader br = null;
    218217            try {
    219                 in = new FileInputStream(persistFilename);
    220                 BufferedReader reader = new BufferedReader(new InputStreamReader(in));
     218                br = new BufferedReader(new InputStreamReader(
     219                        new FileInputStream(persistFilename)));
    221220                String line = null;
    222                 while ( (line = reader.readLine()) != null) {
     221                while ( (line = br.readLine()) != null) {
    223222                    int eq = line.indexOf('=');
    224223                    String name = line.substring(0, eq);
     
    231230                _log.error("Unable to read the keys from " + persistFilename, ioe);
    232231            } finally {
    233                 if (in != null) try { in.close(); } catch (IOException ioe) {}
     232                if (br != null) try { br.close(); } catch (IOException ioe) {}
    234233            }
    235234        }
     
    245244            try {
    246245                out = new FileOutputStream(persistFilename);
    247                 for (Iterator iter = nameToPrivKeys.keySet().iterator(); iter.hasNext(); ) {
    248                     String name = (String)iter.next();
    249                     String privKeys = nameToPrivKeys.get(name);
     246                for (Map.Entry<String, String> entry : nameToPrivKeys.entrySet()) {
     247                    String name = entry.getKey();
     248                    String privKeys = entry.getValue();
    250249                    out.write(name.getBytes());
    251250                    out.write('=');
  • apps/sam/java/src/net/i2p/sam/SAMStreamSession.java

    rf8a54bde rde184ed1  
    382382    private void removeAllSocketHandlers() {
    383383        Integer id;
    384         Set keySet;
    385         Iterator iter;
     384        Set<Integer> keySet;
     385        Iterator<Integer> iter;
    386386
    387387        synchronized (handlersMapLock) {
     
    390390           
    391391            while (iter.hasNext()) {
    392                  id = (Integer)iter.next();
     392                 id = iter.next();
    393393                 handlersMap.get(id).stopRunning();
    394394                 sendersMap.get(id).shutDownGracefully();
  • apps/sam/java/src/net/i2p/sam/SAMUtils.java

    rf8a54bde rde184ed1  
    1212import java.io.IOException;
    1313import java.io.OutputStream;
    14 import java.util.Enumeration;
     14import java.util.Map;
    1515import java.util.Properties;
    1616import java.util.StringTokenizer;
     
    189189    /* Dump a Properties object in an human-readable form */
    190190    private static String dumpProperties(Properties props) {
    191         Enumeration names = props.propertyNames();
    192191        StringBuilder builder = new StringBuilder();
    193192        String key, val;
    194193        boolean firstIter = true;
    195194       
    196         while (names.hasMoreElements()) {
    197             key = (String)names.nextElement();
    198             val = props.getProperty(key);
     195        for (Map.Entry<Object, Object> entry : props.entrySet()) {
     196            key = (String) entry.getKey();
     197            val = (String) entry.getValue();
    199198           
    200199            if (!firstIter) {
  • apps/sam/java/src/net/i2p/sam/SAMv3StreamSession.java

    rf8a54bde rde184ed1  
    99 */
    1010
    11 import java.io.ByteArrayInputStream;
    1211import java.io.IOException;
    1312import java.io.InterruptedIOException;
     
    1716
    1817import net.i2p.I2PException;
    19 import net.i2p.client.I2PClient;
    2018import net.i2p.client.streaming.I2PServerSocket;
    2119import net.i2p.client.streaming.I2PSocket;
    22 import net.i2p.client.streaming.I2PSocketManagerFactory;
    2320import net.i2p.client.streaming.I2PSocketOptions;
    24 import net.i2p.data.Base64;
    2521import net.i2p.data.DataFormatException;
    2622import net.i2p.data.Destination;
  • apps/streaming/java/src/net/i2p/client/streaming/Connection.java

    rf8a54bde rde184ed1  
    1616import net.i2p.data.Destination;
    1717import net.i2p.util.Log;
    18 import net.i2p.util.SimpleScheduler;
    1918import net.i2p.util.SimpleTimer;
    2019import net.i2p.util.SimpleTimer2;
     
    126125        _outputStream = new MessageOutputStream(_context, timer, _receiver, (opts == null ? Packet.MAX_PAYLOAD_SIZE : opts.getMaxMessageSize()));
    127126        _timer = timer;
    128         _outboundPackets = new TreeMap();
     127        _outboundPackets = new TreeMap<Long, PacketLocal>();
    129128        if (opts != null) {
    130129            _localPort = opts.getLocalPort();
     
    470469                    if (!nacked) { // aka ACKed
    471470                        if (acked == null)
    472                             acked = new ArrayList(8);
     471                            acked = new ArrayList<PacketLocal>(8);
    473472                        PacketLocal ackedPacket = e.getValue();
    474473                        ackedPacket.ackReceived();
  • apps/streaming/java/src/net/i2p/client/streaming/ConnectionHandler.java

    rf8a54bde rde184ed1  
    77import net.i2p.data.Destination;
    88import net.i2p.util.Log;
    9 import net.i2p.util.SimpleScheduler;
    109import net.i2p.util.SimpleTimer;
    1110
  • apps/streaming/java/src/net/i2p/client/streaming/ConnectionOptions.java

    rf8a54bde rde184ed1  
    768768        Set<Hash> accessList, blackList;
    769769        if (accessListEnabled)
    770             accessList = new HashSet();
     770            accessList = new HashSet<Hash>();
    771771        else
    772             accessList = Collections.EMPTY_SET;
     772            accessList = Collections.emptySet();
    773773        if (blackListEnabled)
    774             blackList = new HashSet();
     774            blackList = new HashSet<Hash>();
    775775        else
    776             blackList = Collections.EMPTY_SET;
     776            blackList = Collections.emptySet();
    777777        if (accessListEnabled || blackListEnabled) {
    778778            String hashes = opts.getProperty(PROP_ACCESS_LIST);
  • apps/streaming/java/src/net/i2p/client/streaming/ConnectionPacketHandler.java

    rf8a54bde rde184ed1  
    88import net.i2p.data.Destination;
    99import net.i2p.util.Log;
    10 import net.i2p.util.SimpleScheduler;
    1110import net.i2p.util.SimpleTimer;
    1211
  • apps/streaming/java/src/net/i2p/client/streaming/MessageHandler.java

    rf8a54bde rde184ed1  
    11package net.i2p.client.streaming;
    22
    3 import java.util.Iterator;
    43import java.util.Set;
    54import java.util.concurrent.CopyOnWriteArraySet;
     
    98import net.i2p.client.I2PSessionException;
    109import net.i2p.client.I2PSessionMuxedListener;
     10import net.i2p.client.streaming.I2PSocketManager.DisconnectListener;
    1111import net.i2p.util.Log;
    1212
     
    2626        _manager = mgr;
    2727        _context = ctx;
    28         _listeners = new CopyOnWriteArraySet();
     28        _listeners = new CopyOnWriteArraySet<DisconnectListener>();
    2929        _log = ctx.logManager().getLog(MessageHandler.class);
    3030        _context.statManager().createRateStat("stream.packetReceiveFailure", "When do we fail to decrypt or otherwise receive a packet sent to us?", "Stream", new long[] { 60*60*1000, 24*60*60*1000 });
     
    9494        _manager.disconnectAllHard();
    9595       
    96         for (Iterator<I2PSocketManager.DisconnectListener> iter = _listeners.iterator(); iter.hasNext(); ) {
    97             I2PSocketManager.DisconnectListener lsnr = iter.next();
     96        for (I2PSocketManager.DisconnectListener lsnr : _listeners) {
    9897            lsnr.sessionDisconnected();
    9998        }
  • apps/streaming/java/src/net/i2p/client/streaming/MessageInputStream.java

    rf8a54bde rde184ed1  
    55import java.io.InterruptedIOException;
    66import java.util.ArrayList;
    7 import java.util.Arrays;
    87import java.util.HashMap;
    98import java.util.List;
     
    6463    public MessageInputStream(I2PAppContext ctx) {
    6564        _log = ctx.logManager().getLog(MessageInputStream.class);
    66         _readyDataBlocks = new ArrayList(4);
     65        _readyDataBlocks = new ArrayList<ByteArray>(4);
    6766        _highestReadyBlockId = -1;
    6867        _highestBlockId = -1;
    6968        _readTimeout = -1;
    70         _notYetReadyBlocks = new HashMap(4);
     69        _notYetReadyBlocks = new HashMap<Long, ByteArray>(4);
    7170        _dataLock = new Object();
    7271        //_cache = ByteCache.getInstance(128, Packet.MAX_PAYLOAD_SIZE);
     
    111110            } else {
    112111                if (ids == null)
    113                     ids = new ArrayList(4);
     112                    ids = new ArrayList<Long>(4);
    114113                ids.add(l);
    115114            }
  • apps/streaming/java/src/net/i2p/client/streaming/PacketHandler.java

    rf8a54bde rde184ed1  
    33import java.text.SimpleDateFormat;
    44import java.util.Date;
    5 import java.util.Set;
    6 
    75import net.i2p.I2PAppContext;
    86import net.i2p.I2PException;
  • apps/streaming/java/src/net/i2p/client/streaming/PacketLocal.java

    rf8a54bde rde184ed1  
    99import net.i2p.data.Destination;
    1010import net.i2p.data.SessionKey;
     11import net.i2p.data.SessionTag;
    1112import net.i2p.util.Log;
    1213import net.i2p.util.SimpleTimer2;
     
    6970     * @deprecated should always return null or an empty set
    7071     */
    71     public Set getTagsSent() { return Collections.EMPTY_SET; }
     72    public Set<SessionTag> getTagsSent() { return Collections.emptySet(); }
    7273
    7374    /**
    7475     * @deprecated I2PSession throws out the tags
    7576     */
    76     public void setTagsSent(Set tags) {
     77    public void setTagsSent(Set<SessionTag> tags) {
    7778        if (tags != null && !tags.isEmpty())
    7879            _log.error("Who is sending tags thru the streaming lib? " + tags.size());
  • apps/streaming/java/src/net/i2p/client/streaming/PcapWriter.java

    rf8a54bde rde184ed1  
    1010import net.i2p.data.DataFormatException;
    1111import net.i2p.data.DataHelper;
    12 import net.i2p.data.Hash;
    1312
    1413/**
  • apps/streaming/java/src/net/i2p/client/streaming/SchedulerChooser.java

    rf8a54bde rde184ed1  
    3737    }
    3838   
    39     private List createSchedulers() {
    40         List rv = new ArrayList(8);
     39    private List<TaskScheduler> createSchedulers() {
     40        List<TaskScheduler> rv = new ArrayList<TaskScheduler>(8);
    4141        rv.add(new SchedulerHardDisconnected(_context));
    4242        rv.add(new SchedulerPreconnect(_context));
  • apps/streaming/java/src/net/i2p/client/streaming/SchedulerImpl.java

    rf8a54bde rde184ed1  
    33import net.i2p.I2PAppContext;
    44import net.i2p.util.Log;
    5 import net.i2p.util.SimpleScheduler;
    65
    76/**
  • apps/streaming/java/test/junit/net/i2p/client/streaming/ConnectInactivityTest.java

    rf8a54bde rde184ed1  
    77
    88import net.i2p.I2PAppContext;
    9 import net.i2p.client.I2PClient;
    109import net.i2p.client.I2PSession;
    1110import net.i2p.util.Log;
  • apps/streaming/java/test/junit/net/i2p/client/streaming/ConnectTest.java

    rf8a54bde rde184ed1  
    77
    88import net.i2p.I2PAppContext;
    9 import net.i2p.client.I2PClient;
    109import net.i2p.client.I2PSession;
    1110import net.i2p.util.Log;
  • apps/streaming/java/test/junit/net/i2p/client/streaming/ConnectTimeoutTest.java

    rf8a54bde rde184ed1  
    77
    88import net.i2p.I2PAppContext;
    9 import net.i2p.client.I2PClient;
    109import net.i2p.client.I2PClientFactory;
    1110import net.i2p.client.I2PSession;
  • apps/streaming/java/test/junit/net/i2p/client/streaming/EchoLargeTest.java

    rf8a54bde rde184ed1  
    1010import net.i2p.I2PAppContext;
    1111import net.i2p.client.I2PSession;
    12 import net.i2p.data.Base64;
    1312import net.i2p.util.Log;
    1413
  • apps/streaming/java/test/junit/net/i2p/client/streaming/MessageInputStreamTest.java

    rf8a54bde rde184ed1  
    6060       
    6161        MessageInputStream in = new MessageInputStream(_context);
    62         ArrayList order = new ArrayList(32);
     62        ArrayList<Integer> order = new ArrayList<Integer>(32);
    6363        for (int i = 0; i < orig.length / 1024; i++)
    6464            order.add(new Integer(i));
     
    9393        MessageInputStream in = new MessageInputStream(_context);
    9494        for (int n = 0; n < 3; n++) {
    95             ArrayList order = new ArrayList(32);
     95            ArrayList<Integer> order = new ArrayList<Integer>(32);
    9696            for (int i = 0; i < orig.length / 1024; i++)
    9797                order.add(new Integer(i));
     
    127127       
    128128        MessageInputStream in = new MessageInputStream(_context);
    129         ArrayList order = new ArrayList(32);
     129        ArrayList<Integer> order = new ArrayList<Integer>(32);
    130130        for (int i = 0; i < orig.length / 1024; i++)
    131131            order.add(new Integer(i));
  • apps/susidns/src/java/src/i2p/susi/dns/AddressbookBean.java

    rf8a54bde rde184ed1  
    3131import java.util.Arrays;
    3232import java.util.Comparator;
    33 import java.util.Enumeration;
    3433import java.util.LinkedList;
    3534import java.util.Locale;
     35import java.util.Map;
    3636import java.util.Properties;
    3737
     
    152152                        addressbook.load( fis );
    153153                        LinkedList<AddressBean> list = new LinkedList<AddressBean>();
    154                         Enumeration e = addressbook.keys();
    155                         while( e.hasMoreElements() ) {
    156                                 String name = (String)e.nextElement();
    157                                 String destination = addressbook.getProperty( name );
     154                        for( Map.Entry<Object, Object> entry : addressbook.entrySet() ) {
     155                                String name = (String) entry.getKey();
     156                                String destination = (String) entry.getValue();
    158157                                if( filter != null && filter.length() > 0 ) {
    159158                                        if( filter.compareTo( "0-9" ) == 0 ) {
  • apps/susidns/src/java/src/i2p/susi/dns/ConfigBean.java

    rf8a54bde rde184ed1  
    8989                                Properties props = new OrderedProperties();
    9090                                DataHelper.loadProps(props, file);
    91                                 for (Map.Entry e : props.entrySet()) {
     91                                for (Map.Entry<Object, Object> e : props.entrySet()) {
    9292                                        buf.append((String) e.getKey()).append('=')
    9393                                           .append((String) e.getValue()).append('\n');
  • apps/susimail/src/src/i2p/susi/util/Folder.java

    rf8a54bde rde184ed1  
    4242 * @author susi
    4343 */
    44 public class Folder {
     44public class Folder<O extends Object> {
    4545       
    4646        public static final String PAGESIZE = "pager.pagesize";
     
    5151
    5252        private int pages, pageSize, currentPage;
    53         private Object[] unsortedElements, elements;
    54         private Hashtable sorter;
     53        private O[] unsortedElements, elements;
     54        private Hashtable<String, Comparator<O>> sorter;
    5555        private boolean sortingDirection;
    56         Comparator currentSorter;
     56        Comparator<O> currentSorter;
    5757       
    5858        public Folder()
     
    6262                currentPage = 1;
    6363                unsortedElements = null;
    64                 sorter = new Hashtable();
     64                sorter = new Hashtable<String, Comparator<O>>();
    6565                sortingDirection = UP;
    6666                currentSorter = null;
     
    130130         * @return Copy of source.
    131131         */
    132         private Object[] copyArray( Object[] source )
     132        @SuppressWarnings("unchecked")
     133        private O[] copyArray( O[] source )
    133134        {
    134135                Object[] destination = new Object[source.length];
    135136                for( int i = 0; i < source.length; i++ )
    136137                        destination[i] = source[i];
    137                 return destination;
     138                return (O[])destination;
    138139        }
    139140        /**
     
    172173         * Set the array of objects the folder should manage.
    173174         *
    174          * @param elements Array of Objects.
    175          */
    176         public void setElements( Object[] elements )
     175         * @param elements Array of Os.
     176         */
     177        public void setElements( O[] elements )
    177178        {
    178179                this.unsortedElements = elements;
     
    188189         * @return Iterator containing the elements on the current page.
    189190         */
    190         public Iterator currentPageIterator()
    191         {
    192                 ArrayList list = new ArrayList();
     191        public Iterator<O> currentPageIterator()
     192        {
     193                ArrayList<O> list = new ArrayList<O>();
    193194                if( elements != null ) {
    194195                        int pageSize = getPageSize();
     
    250251         * @param sorter a Comparator to sort the Array given by @link setElements()
    251252         */
    252         public void addSorter( String id, Comparator sorter )
     253        public void addSorter( String id, Comparator<O> sorter )
    253254        {
    254255                this.sorter.put( id, sorter );
     
    264265        public void sortBy( String id )
    265266        {
    266                 currentSorter = (Comparator)sorter.get( id );
     267                currentSorter = sorter.get( id );
    267268                sort();
    268269        }
     
    274275         * @return Element on the current page on the given position.
    275276         */
    276         public Object getElementAtPosXonCurrentPage( int x )
    277         {
    278                 Object result = null;
     277        public O getElementAtPosXonCurrentPage( int x )
     278        {
     279                O result = null;
    279280                if( elements != null ) {
    280281                        int pageSize = getPageSize();
     
    307308         * @return First element.
    308309         */
    309         public Object getFirstElement()
     310        public O getFirstElement()
    310311        {
    311312                /*
     
    320321         * @return Last element.
    321322         */
    322         public Object getLastElement()
     323        public O getLastElement()
    323324        {
    324325                /*
     
    334335         * @return index
    335336         */
    336         private int getIndexOf( Object element )
     337        private int getIndexOf( O element )
    337338        {
    338339                if( elements != null ) {
     
    351352         * @return The next element
    352353         */
    353         public Object getNextElement( Object element )
    354         {
    355                 Object result = null;
     354        public O getNextElement( O element )
     355        {
     356                O result = null;
    356357               
    357358                int i = getIndexOf( element );
     
    372373         * @return The previous element
    373374         */
    374         public Object getPreviousElement( Object element )
    375         {
    376                 Object result = null;
     375        public O getPreviousElement( O element )
     376        {
     377                O result = null;
    377378               
    378379                int i = getIndexOf( element );
     
    391392         * @return Element at index i
    392393         */
    393         private Object getElement( int i )
    394         {
    395                 Object result = null;
     394        private O getElement( int i )
     395        {
     396                O result = null;
    396397               
    397398                if( elements != null ) {
     
    425426         * @param element
    426427         */
    427         public boolean isLastElement( Object element )
     428        public boolean isLastElement( O element )
    428429        {
    429430                if( elements == null )
     
    438439         * @param element
    439440         */
    440         public boolean isFirstElement( Object element )
     441        public boolean isFirstElement( O element )
    441442        {
    442443                if( elements == null )
  • apps/susimail/src/src/i2p/susi/webmail/Mail.java

    rf8a54bde rde184ed1  
    3737import java.util.ArrayList;
    3838import java.util.Date;
    39 import java.util.Iterator;
    4039import java.util.Locale;
    4140
     
    144143        public static void appendRecipients( StringBuilder buf, ArrayList<String> recipients, String prefix )
    145144        {
    146                 for( Iterator<String> it = recipients.iterator(); it.hasNext(); ) {
     145                for( String recipient : recipients ) {
    147146                        buf.append( prefix );
    148147                        prefix ="\t";
    149                         buf.append( it.next() );
     148                        buf.append( recipient );
    150149                        buf.append( "\r\n" );
    151150                }
  • apps/susimail/src/src/i2p/susi/webmail/RequestWrapper.java

    rf8a54bde rde184ed1  
    103103         * @return List of request parameter names
    104104         */
     105        @SuppressWarnings("unchecked") // TODO-Java6: Remove, type is correct
    105106        public Enumeration<String> getParameterNames() {
    106107                if( multiPartRequest != null ) {
  • apps/susimail/src/src/i2p/susi/webmail/WebMail.java

    rf8a54bde rde184ed1  
    5050import java.util.Enumeration;
    5151import java.util.Iterator;
    52 import java.util.ListIterator;
    5352import java.util.Locale;
    5453import java.util.zip.ZipEntry;
     
    317316                POP3MailBox mailbox;
    318317                MailCache mailCache;
    319                 Folder folder;
     318                Folder<String> folder;
    320319                String user, pass, host, error, info;
    321320                String replyTo, replyCC;
     
    414413                        if( mailPart.type.compareTo( "multipart/alternative" ) == 0 ) {
    415414                                MailPart chosen = null;
    416                                 for( ListIterator li = mailPart.parts.listIterator(); li.hasNext(); ) {
    417                                         MailPart subPart = (MailPart)li.next();
     415                                for( MailPart subPart : mailPart.parts ) {
    418416                                        if( subPart.type != null && subPart.type.compareTo( "text/plain" ) == 0 )
    419417                                                chosen = subPart;
     
    424422                                }
    425423                        }
    426                         for( ListIterator li = mailPart.parts.listIterator(); li.hasNext(); ) {
    427                                 MailPart part = (MailPart)li.next();
     424                        for( MailPart part : mailPart.parts ) {
    428425                                showPart( out, part, level + 1, html );
    429426                        }
    430427                }
    431428                else if( mailPart.message ) {
    432                         for( ListIterator li = mailPart.parts.listIterator(); li.hasNext(); ) {
    433                                 MailPart part = (MailPart)li.next();
     429                        for( MailPart part : mailPart.parts ) {
    434430                                showPart( out, part, level + 1, html );
    435                         }                       
     431                        }
    436432                }
    437433                else {
     
    628624                                                sessionObject.state = STATE_LIST;
    629625                                                sessionObject.mailCache = new MailCache( sessionObject.mailbox );
    630                                                 sessionObject.folder = new Folder();
     626                                                sessionObject.folder = new Folder<String>();
    631627                                                sessionObject.folder.setElements( sessionObject.mailbox.getUIDLs() );
    632628                                                sessionObject.folder.addSorter( SORT_ID, new IDSorter( sessionObject.mailCache ) );
     
    10531049               
    10541050                if( part.multipart || part.message ) {
    1055                         for( Iterator it = part.parts.iterator(); it.hasNext(); ) {
    1056                                 MailPart subPart = getMailPartFromHashCode( (MailPart)it.next(), hashCode );
     1051                        for( MailPart p : part.parts ) {
     1052                                MailPart subPart = getMailPartFromHashCode( p, hashCode );
    10571053                                if( subPart != null )
    10581054                                        return subPart;
     
    12761272                        if( sessionObject.state == STATE_LIST ) {
    12771273                                processFolderButtons( sessionObject, request );
    1278                                 for( Iterator it = sessionObject.folder.currentPageIterator(); it != null && it.hasNext(); ) {
     1274                                for( Iterator<String> it = sessionObject.folder.currentPageIterator(); it != null && it.hasNext(); ) {
    12791275                                        String uidl = (String)it.next();
    12801276                                        Mail mail = sessionObject.mailCache.getMail( uidl, MailCache.FETCH_HEADER );
     
    15261522
    15271523                        if( multipart ) {
    1528                                 for( Iterator it = sessionObject.attachments.iterator(); it.hasNext(); ) {
    1529                                         Attachment attachment = (Attachment)it.next();
     1524                                for( Attachment attachment : sessionObject.attachments ) {
    15301525                                        body.append( "\r\n--" + boundary + "\r\nContent-type: " + attachment.getContentType() + "\r\nContent-Disposition: attachment; filename=\"" + attachment.getFileName() + "\"\r\nContent-Transfer-Encoding: " + attachment.getTransferEncoding() + "\r\n\r\n" );
    15311526                                        body.append( attachment.getData() );
     
    16211616                if( sessionObject.attachments != null && !sessionObject.attachments.isEmpty() ) {
    16221617                        boolean wroteHeader = false;
    1623                         for( Iterator it = sessionObject.attachments.iterator(); it.hasNext(); ) {
     1618                        for( Attachment attachment : sessionObject.attachments ) {
    16241619                                if( !wroteHeader ) {
    16251620                                        out.println( "<tr><td colspan=\"2\" align=\"center\">" + _("Attachments:") + "</td></tr>" );
    16261621                                        wroteHeader = true;
    16271622                                }
    1628                                 Attachment attachment = (Attachment)it.next();
    16291623                                out.println( "<tr><td colspan=\"2\" align=\"center\"><input type=\"checkbox\" class=\"optbox\" name=\"check" + attachment.hashCode() + "\" value=\"1\">&nbsp;" + attachment.getFileName() + "</td></tr>");
    16301624                        }
     
    16881682                int bg = 0;
    16891683                int i = 0;
    1690                 for( Iterator it = sessionObject.folder.currentPageIterator(); it != null && it.hasNext(); ) {
     1684                for( Iterator<String> it = sessionObject.folder.currentPageIterator(); it != null && it.hasNext(); ) {
    16911685                        String uidl = (String)it.next();
    16921686                        Mail mail = sessionObject.mailCache.getMail( uidl, MailCache.FETCH_HEADER );
  • apps/susimail/src/src/i2p/susi/webmail/encoding/Base64.java

    rf8a54bde rde184ed1  
    2929import java.io.IOException;
    3030import java.io.InputStream;
    31 import java.io.StringBufferInputStream;
    3231
    3332/**
     
    5958        public String encode(String str) throws EncodingException {
    6059                try {
    61                         return encode( new StringBufferInputStream( str ) );
     60                        return encode( new ByteArrayInputStream( str.getBytes() ) );
    6261                }catch (IOException e) {
    6362                        throw new EncodingException( e.getMessage() );
  • apps/susimail/src/src/i2p/susi/webmail/encoding/EncodingFactory.java

    rf8a54bde rde184ed1  
    4747                        for( int i = 0; i < classNames.length; i++ ) {
    4848                                try {
    49                                         Class c = Class.forName( classNames[i] );
     49                                        Class<?> c = Class.forName( classNames[i] );
    5050                                        Encoding e = (Encoding)c.newInstance();
    5151                                        encodings.put( e.getName(), e );
  • apps/susimail/src/src/i2p/susi/webmail/encoding/HeaderLine.java

    rf8a54bde rde184ed1  
    3030import java.io.IOException;
    3131import java.io.InputStream;
    32 import java.io.StringBufferInputStream;
    3332
    3433/**
     
    4847        public String encode(String text) throws EncodingException {
    4948                try {
    50                         return encode( new StringBufferInputStream( text ) );
     49                        return encode( new ByteArrayInputStream( text.getBytes() ) );
    5150                } catch (IOException e) {
    5251                        throw new EncodingException( "IOException occured." );
  • apps/susimail/src/src/i2p/susi/webmail/encoding/QuotedPrintable.java

    rf8a54bde rde184ed1  
    3030import java.io.IOException;
    3131import java.io.InputStream;
    32 import java.io.StringBufferInputStream;
    3332
    3433/**
     
    5857        public String encode(String text) throws EncodingException {
    5958                try {
    60                         return encode( new StringBufferInputStream( text ) );
     59                        return encode( new ByteArrayInputStream( text.getBytes() ) );
    6160                }catch (IOException e) {
    6261                        throw new EncodingException( "IOException occured." );
  • apps/susimail/src/src/i2p/susi/webmail/pop3/POP3MailBox.java

    rf8a54bde rde184ed1  
    6060        private Object synchronizer = null;
    6161
    62         private Object[] uidls = null;
    63 
    6462        /**
    6563         * @param host
     
    276274                        uidlToID.clear();
    277275                        uidlList.clear();
    278                         uidls = null;
    279276                       
    280277                        readBuffer = sendCmdNa( "UIDL", DEFAULT_BUFSIZE );
     
    296293                                        }
    297294                                }
    298                                 uidls = uidlList.toArray();
    299295                        }
    300296                        else {
     
    351347                uidlToID.clear();
    352348                sizes.clear();
    353                 uidls = null;
    354349                mails = 0;
    355350        }
     
    650645        {
    651646                int result = -1;
    652                 Integer intObject = (Integer)uidlToID.get( uidl );
     647                Integer intObject = uidlToID.get( uidl );
    653648                if( intObject != null ) {
    654649                        result = intObject.intValue();
     
    663658        public String getUIDLfromID( int id )
    664659        {
    665                 return (String)uidlList.get( id );
     660                return uidlList.get( id );
    666661        }
    667662        /**
     
    669664         * @return A list of the available UIDLs.
    670665         */
    671         public Object[] getUIDLs()
    672         {
    673                 return uidls;
     666        public String[] getUIDLs()
     667        {
     668                return uidlList.toArray(new String[uidlList.size()]);
    674669        }
    675670        /**
  • core/java/src/net/i2p/I2PAppContext.java

    rf8a54bde rde184ed1  
    122122    private final File _appDir;
    123123    private volatile File _tmpDir;
     124    private final Random _tmpDirRand = new Random();
    124125    // split up big lock on this to avoid deadlocks
    125126    private final Object _lock1 = new Object(), _lock2 = new Object(), _lock3 = new Object(), _lock4 = new Object(),
     
    404405                // our random() probably isn't warmed up yet
    405406                byte[] rand = new byte[6];
    406                 (new Random()).nextBytes(rand);
     407                _tmpDirRand.nextBytes(rand);
    407408                String f = "i2p-" + Base64.encode(rand) + ".tmp";
    408409                _tmpDir = new SecureDirectory(d, f);
     
    536537     * @return set of Strings containing the names of defined system properties
    537538     */
    538     public Set<String> getPropertyNames() {
     539    @SuppressWarnings({ "unchecked", "rawtypes" })
     540        public Set<String> getPropertyNames() {
    539541        // clone to avoid ConcurrentModificationException
    540         Set names = new HashSet(((Properties) System.getProperties().clone()).keySet());
     542        Set<String> names = new HashSet<String>((Set<String>) (Set) ((Properties) System.getProperties().clone()).keySet()); // TODO-Java6: s/keySet()/stringPropertyNames()/
    541543        if (_overrideProps != null)
    542             names.addAll(_overrideProps.keySet());
     544            names.addAll((Set<String>) (Set) _overrideProps.keySet()); // TODO-Java6: s/keySet()/stringPropertyNames()/
    543545        return names;
    544546    }
  • core/java/src/net/i2p/client/I2PSessionImpl.java

    rf8a54bde rde184ed1  
    1919import java.security.GeneralSecurityException;
    2020import java.util.ArrayList;
    21 import java.util.Iterator;
    2221import java.util.List;
    2322import java.util.Map;
     
    289288    private Properties filter(Properties options) {
    290289        Properties rv = new Properties();
    291         for (Iterator iter = options.keySet().iterator(); iter.hasNext();) {
    292             String key = (String) iter.next();
     290        for (Object oKey : options.keySet()) { // TODO-Java6: s/keySet()/stringPropertyNames()/
     291            String key = (String) oKey;
    293292            if (key.startsWith("java.") ||
    294293                key.startsWith("user.") ||
  • core/java/src/net/i2p/client/naming/MetaNamingService.java

    rf8a54bde rde184ed1  
    3939        while (tok.hasMoreTokens()) {
    4040            try {
    41                 Class cls = Class.forName(tok.nextToken());
    42                 Constructor con = cls.getConstructor(new Class[] { I2PAppContext.class });
     41                Class<?> cls = Class.forName(tok.nextToken());
     42                Constructor<?> con = cls.getConstructor(new Class[] { I2PAppContext.class });
    4343                addNamingService((NamingService)con.newInstance(new Object[] { context }), false);
    4444            } catch (Exception ex) {
  • core/java/src/net/i2p/client/naming/NamingService.java

    rf8a54bde rde184ed1  
    463463        String impl = context.getProperty(PROP_IMPL, DEFAULT_IMPL);
    464464        try {
    465             Class cls = Class.forName(impl);
    466             Constructor con = cls.getConstructor(new Class[] { I2PAppContext.class });
     465            Class<?> cls = Class.forName(impl);
     466            Constructor<?> con = cls.getConstructor(new Class[] { I2PAppContext.class });
    467467            instance = (NamingService)con.newInstance(new Object[] { context });
    468468        } catch (Exception ex) {
  • core/java/src/net/i2p/crypto/ECConstants.java

    rf8a54bde rde184ed1  
    4242        if (Security.getProvider("BC") == null) {
    4343            try {
    44                 Class cls = Class.forName("org.bouncycastle.jce.provider.BouncyCastleProvider");
    45                 Constructor con = cls.getConstructor(new Class[0]);
     44                Class<?> cls = Class.forName("org.bouncycastle.jce.provider.BouncyCastleProvider");
     45                Constructor<?> con = cls.getConstructor(new Class[0]);
    4646                Provider bc = (Provider)con.newInstance(new Object[0]);
    4747                Security.addProvider(bc);
  • core/java/src/net/i2p/crypto/TransientSessionKeyManager.java

    rf8a54bde rde184ed1  
    542542            // drop both old and tagSet tags
    543543            synchronized (_inboundTagSets) {
    544                 for (Iterator<SessionTag> iter = old.getTags().iterator(); iter.hasNext(); ) {
    545                     SessionTag tag = iter.next();
     544                for (SessionTag tag : old.getTags()) {
    546545                    _inboundTagSets.remove(tag);
    547546                }
    548                 for (Iterator<SessionTag> iter = sessionTags.iterator(); iter.hasNext(); ) {
    549                     SessionTag tag = iter.next();
     547                for (SessionTag tag : sessionTags) {
    550548                    _inboundTagSets.remove(tag);
    551549                }
     
    735733                       "<td><b># Sets:</b> ").append(sets.size()).append("</td></tr>" +
    736734                       "<tr><td colspan=\"2\"><ul>");
    737             for (Iterator<TagSet> siter = sets.iterator(); siter.hasNext();) {
    738                 TagSet ts = siter.next();
     735            for (TagSet ts : sets) {
    739736                int size = ts.getTags().size();
    740737                total += size;
     
    10511048            long last = 0;
    10521049            synchronized (_tagSets) {
    1053                 for (Iterator<TagSet> iter = _tagSets.iterator(); iter.hasNext();) {
    1054                     TagSet set = iter.next();
     1050                for (TagSet set : _tagSets) {
    10551051                    if ( (set.getDate() > last) && (!set.getTags().isEmpty()) )
    10561052                        last = set.getDate();
  • core/java/src/net/i2p/data/DataHelper.java

    rf8a54bde rde184ed1  
    227227            }
    228228            ByteArrayOutputStream baos = new ByteArrayOutputStream(p.size() * 64);
    229             for (Map.Entry entry : p.entrySet()) {
     229            for (Map.Entry<Object, Object> entry : p.entrySet()) {
    230230                String key = (String) entry.getKey();
    231231                String val = (String) entry.getValue();
     
    274274            p.putAll(props);
    275275            ByteArrayOutputStream baos = new ByteArrayOutputStream(p.size() * 64);
    276             for (Map.Entry entry : p.entrySet()) {
     276            for (Map.Entry<Object, Object> entry : p.entrySet()) {
    277277                String key = (String) entry.getKey();
    278278                String val = (String) entry.getValue();
     
    368368     */
    369369    public static String toString(Properties options) {
    370         return toString((Map) options);
     370        return toString((Map<?, ?>) options);
    371371    }
    372372
     
    379379        StringBuilder buf = new StringBuilder();
    380380        if (options != null) {
    381             for (Map.Entry entry : options.entrySet()) {
     381            for (Map.Entry<?, ?> entry : options.entrySet()) {
    382382                String key = (String) entry.getKey();
    383383                String val = (String) entry.getValue();
     
    471471            out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(new SecureFileOutputStream(file), "UTF-8")));
    472472            out.println("# NOTE: This I2P config file must use UTF-8 encoding");
    473             for (Map.Entry entry : props.entrySet()) {
     473            for (Map.Entry<Object, Object> entry : props.entrySet()) {
    474474                String name = (String) entry.getKey();
    475475                String val = (String) entry.getValue();
     
    498498     *
    499499     */
    500     public static String toString(Collection col) {
     500    public static String toString(Collection<?> col) {
    501501        StringBuilder buf = new StringBuilder();
    502502        if (col != null) {
    503             for (Iterator iter = col.iterator(); iter.hasNext();) {
     503            for (Iterator<?> iter = col.iterator(); iter.hasNext();) {
    504504                Object o = iter.next();
    505505                buf.append("[").append(o).append("]");
     
    965965     *
    966966     */
    967     public final static boolean eq(Collection lhs, Collection rhs) {
     967    public final static boolean eq(Collection<?> lhs, Collection<?> rhs) {
    968968        if ((lhs == null) && (rhs == null)) return true;
    969969        if ((lhs == null) || (rhs == null)) return false;
    970970        if (lhs.size() != rhs.size()) return false;
    971         Iterator liter = lhs.iterator();
    972         Iterator riter = rhs.iterator();
     971        Iterator<?> liter = lhs.iterator();
     972        Iterator<?> riter = rhs.iterator();
    973973        while ((liter.hasNext()) && (riter.hasNext()))
    974974            if (!(eq(liter.next(), riter.next()))) return false;
     
    11331133     *
    11341134     */
    1135     public static int hashCode(Collection col) {
     1135    public static int hashCode(Collection<?> col) {
    11361136        if (col == null) return 0;
    11371137        int c = 0;
    1138         for (Iterator iter = col.iterator(); iter.hasNext();)
     1138        for (Iterator<?> iter = col.iterator(); iter.hasNext();)
    11391139            c = 7 * c + hashCode(iter.next());
    11401140        return c;
  • core/java/src/net/i2p/data/PrivateKeyFile.java

    rf8a54bde rde184ed1  
    77import java.io.FileOutputStream;
    88import java.io.IOException;
    9 import java.util.Iterator;
    109import java.util.Map;
    1110import java.util.Properties;
     
    403402                    }
    404403                   
    405                     for (Iterator iter = hosts.entrySet().iterator(); iter.hasNext(); )  {
    406                         Map.Entry entry = (Map.Entry)iter.next();
     404                    for (Map.Entry<Object, Object> entry : hosts.entrySet())  {
    407405                        String s = (String) entry.getValue();
    408406                        Destination signer = new Destination(s);
  • core/java/src/net/i2p/data/RouterAddress.java

    rf8a54bde rde184ed1  
    158158     * @since 0.8.13
    159159     */
    160     public Map getOptionsMap() {
     160    public Map<Object, Object> getOptionsMap() {
    161161        return Collections.unmodifiableMap(_options);
    162162    }
     
    325325        //buf.append("\n\tExpiration: ").append(_expiration);
    326326            buf.append("\n\tOptions (").append(_options.size()).append("):");
    327             for (Map.Entry e : _options.entrySet()) {
     327            for (Map.Entry<Object, Object> e : _options.entrySet()) {
    328328                String key = (String) e.getKey();
    329329                String val = (String) e.getValue();
  • core/java/src/net/i2p/data/RouterInfo.java

    rf8a54bde rde184ed1  
    245245     * @since 0.8.13
    246246     */
    247     public Map getOptionsMap() {
     247    public Map<Object, Object> getOptionsMap() {
    248248        return Collections.unmodifiableMap(_options);
    249249    }
     
    627627        }
    628628        buf.append("\n\tOptions (").append(_options.size()).append("):");
    629         for (Map.Entry e : _options.entrySet()) {
     629        for (Map.Entry<Object, Object> e : _options.entrySet()) {
    630630            String key = (String) e.getKey();
    631631            String val = (String) e.getValue();
  • core/java/src/net/i2p/data/i2cp/SessionConfig.java

    rf8a54bde rde184ed1  
    226226        Properties sorted = new OrderedProperties();
    227227        sorted.putAll(_options);
    228         for (Map.Entry e : sorted.entrySet()) {
     228        for (Map.Entry<Object, Object> e : sorted.entrySet()) {
    229229            String key = (String) e.getKey();
    230230            String val = (String) e.getValue();
  • core/java/src/net/i2p/stat/StatManager.java

    rf8a54bde rde184ed1  
    33import java.util.HashMap;
    44import java.util.HashSet;
    5 import java.util.Iterator;
    65import java.util.Map;
    76import java.util.Set;
     
    6463    public void setStatLog(StatLog log) {
    6564        _statLog = log;
    66             for (Iterator<RateStat> iter = _rateStats.values().iterator(); iter.hasNext(); ) {
    67                 RateStat rs = iter.next();
     65            for (RateStat rs : _rateStats.values()) {
    6866                rs.setStatLog(log);
    6967            }
     
    169167                }
    170168        }
    171             for (Iterator<RateStat> iter = _rateStats.values().iterator(); iter.hasNext();) {
    172                 RateStat stat = iter.next();
     169            for (RateStat stat : _rateStats.values()) {
    173170                if (stat != null) {
    174171                    stat.coalesceStats();
  • core/java/src/net/i2p/util/Clock.java

    rf8a54bde rde184ed1  
    6969     */
    7070    public synchronized void setOffset(long offsetMs, boolean force) {
    71         if (false) return;
    7271        long delta = offsetMs - _offset;
    7372        if (!force) {
     
    114113     * @return the current delta from System.currentTimeMillis() in milliseconds
    115114     */
    116     public long getOffset() {
     115    public synchronized long getOffset() {
    117116        return _offset;
    118117    }
  • core/java/src/net/i2p/util/EepGet.java

    rf8a54bde rde184ed1  
    385385                            buf.append(" KBps");
    386386                            System.out.println(buf.toString());
     387                            fmt.close();
    387388                        }
    388389                        _lastComplete = now;
  • core/java/src/net/i2p/util/FileUtil.java

    rf8a54bde rde184ed1  
    296296        if (!_failedOracle) {
    297297            try {
    298                 Class p200 = Class.forName("java.util.jar.Pack200", true, ClassLoader.getSystemClassLoader());
     298                Class<?> p200 = Class.forName("java.util.jar.Pack200", true, ClassLoader.getSystemClassLoader());
    299299                Method newUnpacker = p200.getMethod("newUnpacker", (Class[]) null);
    300300                Object unpacker = newUnpacker.invoke(null,(Object[])  null);
     
    317317        if (!_failedApache) {
    318318            try {
    319                 Class p200 = Class.forName("org.apache.harmony.unpack200.Archive", true, ClassLoader.getSystemClassLoader());
    320                 Constructor newUnpacker = p200.getConstructor(new Class[] {InputStream.class, JarOutputStream.class});
     319                Class<?> p200 = Class.forName("org.apache.harmony.unpack200.Archive", true, ClassLoader.getSystemClassLoader());
     320                Constructor<?> newUnpacker = p200.getConstructor(new Class[] {InputStream.class, JarOutputStream.class});
    321321                Object unpacker = newUnpacker.newInstance(new Object[] {in, out});
    322322                Method unpack = unpacker.getClass().getMethod("unpack", (Class[]) null);
  • core/java/src/net/i2p/util/Log.java

    rf8a54bde rde184ed1  
    2626 */
    2727public class Log {
    28     private final Class _class;
     28    private final Class<?> _class;
    2929    private final String _className;
    3030    private final String _name;
     
    7676     *  Use I2PAppContext.getGlobalContext().logManager().getLog(cls)
    7777     */
    78     public Log(Class cls) {
     78    public Log(Class<?> cls) {
    7979        this(I2PAppContext.getGlobalContext().logManager(), cls, null);
    8080        _manager.addLog(this);
     
    9090    }
    9191
    92     Log(LogManager manager, Class cls) {
     92    Log(LogManager manager, Class<?> cls) {
    9393        this(manager, cls, null);
    9494    }
     
    9898    }
    9999
    100     Log(LogManager manager, Class cls, String name) {
     100    Log(LogManager manager, Class<?> cls, String name) {
    101101        _manager = manager;
    102102        _class = cls;
     
    230230    public Object getScope() { return _scope; }
    231231
    232     static String getScope(String name, Class cls) {
     232    static String getScope(String name, Class<?> cls) {
    233233        if ( (name == null) && (cls == null) ) return "f00";
    234234        if (cls == null) return name;
     
    240240        private final String _scopeCache;
    241241
    242         public LogScope(String name, Class cls) {
     242        public LogScope(String name, Class<?> cls) {
    243243            _scopeCache = getScope(name, cls);
    244244        }
  • core/java/src/net/i2p/util/LogManager.java

    rf8a54bde rde184ed1  
    167167    }
    168168
    169     public Log getLog(Class cls) { return getLog(cls, null); }
     169    public Log getLog(Class<?> cls) { return getLog(cls, null); }
    170170    public Log getLog(String name) { return getLog(null, name); }
    171     public Log getLog(Class cls, String name) {
     171    public Log getLog(Class<?> cls, String name) {
    172172        String scope = Log.getScope(name, cls);
    173173        boolean isNew = false;
     
    187187    /** now used by ConfigLogingHelper */
    188188    public List<Log> getLogs() {
    189         return new ArrayList(_logs.values());
     189        return new ArrayList<Log>(_logs.values());
    190190    }
    191191
     
    408408        _limits.clear();
    409409        if (config != null) {
    410             for (Map.Entry e : config.entrySet()) {
     410            for (Map.Entry<Object, Object> e : config.entrySet()) {
    411411                String key = (String) e.getKey();
    412412
  • core/java/src/net/i2p/util/LogRecord.java

    rf8a54bde rde184ed1  
    1616class LogRecord {
    1717    private final long _date;
    18     private final Class _source;
     18    private final Class<?> _source;
    1919    private final String _name;
    2020    private final String _threadName;
     
    2323    private final Throwable _throwable;
    2424
    25     public LogRecord(Class src, String name, String threadName, int priority, String msg, Throwable t) {
     25    public LogRecord(Class<?> src, String name, String threadName, int priority, String msg, Throwable t) {
    2626        _date = Clock.getInstance().now();
    2727        _source = src;
     
    3737    }
    3838
    39     public Class getSource() {
     39    public Class<?> getSource() {
    4040        return _source;
    4141    }
  • core/java/src/net/i2p/util/OrderedProperties.java

    rf8a54bde rde184ed1  
    3636
    3737    @Override
    38     public Set keySet() {
    39         return Collections.unmodifiableSortedSet(new TreeSet(super.keySet()));
     38    public Set<Object> keySet() {
     39        return Collections.unmodifiableSortedSet(new TreeSet<Object>(super.keySet()));
    4040    }
    4141
    4242    @Override
    4343    public Set<Map.Entry<Object, Object>> entrySet() {
    44         TreeSet<Map.Entry<Object, Object>> rv = new TreeSet(new EntryComparator());
     44        TreeSet<Map.Entry<Object, Object>> rv = new TreeSet<Map.Entry<Object, Object>>(new EntryComparator());
    4545        rv.addAll(super.entrySet());
    4646        return Collections.unmodifiableSortedSet(rv);
    4747    }
    4848
    49     private static class EntryComparator implements Comparator<Map.Entry> {
    50          public int compare(Map.Entry l, Map.Entry r) {
     49    private static class EntryComparator implements Comparator<Map.Entry<Object, Object>> {
     50         public int compare(Map.Entry<Object, Object> l, Map.Entry<Object, Object> r) {
    5151             return ((String)l.getKey()).compareTo(((String)r.getKey()));
    5252        }
  • core/java/src/net/i2p/util/SimpleTimer.java

    rf8a54bde rde184ed1  
    33import java.util.ArrayList;
    44import java.util.HashMap;
    5 import java.util.Iterator;
    65import java.util.List;
    76import java.util.Map;
     
    156155            if ( (_events.size() != _eventTimes.size()) ) {
    157156                _log.error("Skewed events: " + _events.size() + " for " + _eventTimes.size());
    158                 for (Iterator<TimedEvent> iter = _eventTimes.keySet().iterator(); iter.hasNext(); ) {
    159                     TimedEvent evt = iter.next();
     157                for (TimedEvent evt : _eventTimes.keySet()) {
    160158                    Long when = _eventTimes.get(evt);
    161159                    TimedEvent cur = _events.get(when);
  • core/java/src/net/i2p/util/SystemVersion.java

    rf8a54bde rde184ed1  
    4848        if (_isAndroid) {
    4949            try {
    50                 Class ver = Class.forName("android.os.Build.VERSION", true, ClassLoader.getSystemClassLoader());
     50                Class<?> ver = Class.forName("android.os.Build.VERSION", true, ClassLoader.getSystemClassLoader());
    5151                Field field = ver.getField("SDK_INT");
    5252                sdk = field.getInt(null);
  • core/java/test/junit/net/i2p/client/naming/BlockfileNamingServiceTest.java

    rf8a54bde rde184ed1  
    1212import java.util.List;
    1313import java.util.Properties;
     14import java.util.Set;
    1415
    1516import net.i2p.I2PAppContext;
     
    2324    File hostsTxt, routerDir;
    2425
    25     public void setUp() throws Exception {
     26    @SuppressWarnings({ "unchecked", "rawtypes" })
     27        public void setUp() throws Exception {
    2628        I2PAppContext ctx = new I2PAppContext();
    2729        routerDir = ctx.getRouterDir();
     
    3234        assertNotNull("test classpath not set correctly",is);
    3335        DataHelper.loadProps(props, is, true);
    34         _names = new ArrayList(props.keySet());
     36        _names = new ArrayList<String>((Set<String>) (Set) props.keySet());  // TODO-Java6: s/keySet()/stringPropertyNames()/
    3537        Collections.shuffle(_names);
    3638        is.close();
  • core/java/test/junit/net/i2p/stat/SimpleStatDumper.java

    rf8a54bde rde184ed1  
    22
    33import java.util.Arrays;
    4 import java.util.Iterator;
    54import java.util.Set;
    65import java.util.TreeSet;
     
    2322    private static void dumpFrequencies(I2PAppContext ctx, StringBuilder buf) {
    2423        Set<String> frequencies = new TreeSet<String>(ctx.statManager().getFrequencyNames());
    25         for (Iterator<String> iter = frequencies.iterator(); iter.hasNext();) {
    26             String name = iter.next();
     24        for (String name : frequencies) {
    2725            FrequencyStat freq = ctx.statManager().getFrequency(name);
    2826            buf.append('\n');
     
    4341    private static void dumpRates(I2PAppContext ctx, StringBuilder buf) {
    4442        Set<String> rates = new TreeSet<String>(ctx.statManager().getRateNames());
    45         for (Iterator<String> iter = rates.iterator(); iter.hasNext();) {
    46             String name = iter.next();
     43        for (String name : rates) {
    4744            RateStat rate = ctx.statManager().getRate(name);
    4845            buf.append('\n');
  • router/java/src/net/i2p/router/Blocklist.java

    rf8a54bde rde184ed1  
    138138                }
    139139            }
    140             for (Iterator<Hash> iter = _peerBlocklist.keySet().iterator(); iter.hasNext(); ) {
    141                 Hash peer = iter.next();
     140            for (Hash peer : _peerBlocklist.keySet()) {
    142141                String reason;
    143142                String comment = _peerBlocklist.get(peer);
     
    216215        int peercount = 0;
    217216        long ipcount = 0;
    218         FileInputStream in = null;
     217        BufferedReader br = null;
    219218        try {
    220             in = new FileInputStream(BLFile);
    221             BufferedReader br = new BufferedReader(new InputStreamReader(in, "UTF-8"));
     219            br = new BufferedReader(new InputStreamReader(
     220                    new FileInputStream(BLFile), "UTF-8"));
    222221            String buf = null;
    223222            while ((buf = br.readLine()) != null && count < maxSize) {
     
    248247            return;
    249248        } finally {
    250             if (in != null) try { in.close(); } catch (IOException ioe) {}
     249            if (br != null) try { br.close(); } catch (IOException ioe) {}
    251250        }
    252251
     
    406405        if ( (!BLFile.exists()) || (BLFile.length() <= 0) ) return 0;
    407406        int lines = 0;
    408         FileInputStream in = null;
     407        BufferedReader br = null;
    409408        try {
    410             in = new FileInputStream(BLFile);
    411             BufferedReader br = new BufferedReader(new InputStreamReader(in, "ISO-8859-1"));
     409            br = new BufferedReader(new InputStreamReader(
     410                    new FileInputStream(BLFile), "ISO-8859-1"));
    412411            while (br.readLine() != null) {
    413412                lines++;
     
    418417            return 0;
    419418        } finally {
    420             if (in != null) try { in.close(); } catch (IOException ioe) {}
     419            if (br != null) try { br.close(); } catch (IOException ioe) {}
    421420        }
    422421        return lines;
     
    771770            byte ip[] = iter.next();
    772771            int ipint = toInt(ip);
    773             FileInputStream in = null;
     772            BufferedReader br = null;
    774773            try {
    775                 in = new FileInputStream(BLFile);
    776                 BufferedReader br = new BufferedReader(new InputStreamReader(in, "UTF-8"));
     774                br = new BufferedReader(new InputStreamReader(
     775                        new FileInputStream(BLFile), "UTF-8"));
    777776                String buf = null;
    778777                // assume the file is unsorted, so go through the whole thing
     
    783782                    }
    784783                    if (match(ipint, toEntry(e.ip1, e.ip2))) {
    785                         try { in.close(); } catch (IOException ioe) {}
     784                        try { br.close(); } catch (IOException ioe) {}
    786785                        String reason = _x("IP banned by blocklist.txt entry {0}");
    787786                        // only one translate parameter for now
     
    802801                    _log.warn("Error reading the BLFile", ioe);
    803802            } finally {
    804                 if (in != null) try { in.close(); } catch (IOException ioe) {}
     803                if (br != null) try { br.close(); } catch (IOException ioe) {}
    805804            }
    806805        }
  • router/java/src/net/i2p/router/ClientTunnelSettings.java

    rf8a54bde rde184ed1  
    99 */
    1010
    11 import java.util.Iterator;
     11import java.util.Map;
    1212import java.util.Properties;
    1313
     
    5050        buf.append("Client tunnel settings:\n");
    5151        buf.append("====================================\n");
    52         for (Iterator iter = p.keySet().iterator(); iter.hasNext(); ) {
    53             String name = (String)iter.next();
    54             String val  = p.getProperty(name);
     52        for (Map.Entry<Object, Object> entry : p.entrySet()) {
     53            String name = (String) entry.getKey();
     54            String val  = (String) entry.getValue();
    5555            buf.append(name).append(" = [").append(val).append("]\n");
    5656        }
  • router/java/src/net/i2p/router/JobQueue.java

    rf8a54bde rde184ed1  
    278278        if (!_allowParallelOperation) return false; // dont drop during startup [duh]
    279279        if (numReady > _maxWaitingJobs) {
    280             Class cls = job.getClass();
     280            Class<? extends Job> cls = job.getClass();
    281281            // lets not try to drop too many tunnel messages...
    282282            //if (cls == HandleTunnelMessageJob.class)
  • router/java/src/net/i2p/router/MultiRouter.java

    rf8a54bde rde184ed1  
    6868        if (!scan.hasNextInt()) {
    6969            usage();
     70            scan.close();
    7071            return;
    7172        }
     
    7374        if (nbrRouters < 0) {
    7475            usage();
     76            scan.close();
    7577            return;
    7678        }
     79        scan.close();
    7780       
    7881        _out = System.out;
  • router/java/src/net/i2p/router/OutNetMessage.java

    rf8a54bde rde184ed1  
    152152            synchronized (this) {
    153153                locked_initTimestamps();
    154                 return (Map<String, Long>)_timestamps.clone();
     154                return new HashMap<String, Long>(_timestamps);
    155155            }
    156156        }
  • router/java/src/net/i2p/router/PersistentKeyRing.java

    rf8a54bde rde184ed1  
    33import java.io.IOException;
    44import java.io.Writer;
    5 
    6 import java.util.Iterator;
    75
    86import net.i2p.data.DataFormatException;
     
    4442
    4543    private void addFromProperties() {
    46         for (Iterator iter = _ctx.getPropertyNames().iterator(); iter.hasNext(); ) {
    47             String prop = (String) iter.next();
     44        for (String prop : _ctx.getPropertyNames()) {
    4845            if (!prop.startsWith(PROP_PFX))
    4946                continue;
  • router/java/src/net/i2p/router/TunnelPoolSettings.java

    rf8a54bde rde184ed1  
    202202     */
    203203    public void readFromProperties(String prefix, Map<Object, Object> props) {
    204         for (Map.Entry e : props.entrySet()) {
     204        for (Map.Entry<Object, Object> e : props.entrySet()) {
    205205            String name = (String) e.getKey();
    206206            String value = (String) e.getValue();
     
    251251        if (!_isInbound)
    252252            props.setProperty(prefix + PROP_PRIORITY, Integer.toString(_priority));
    253         for (Map.Entry e : _unknownOptions.entrySet()) {
     253        for (Map.Entry<Object, Object> e : _unknownOptions.entrySet()) {
    254254            String name = (String) e.getKey();
    255255            String val = (String) e.getValue();
     
    265265        buf.append("Tunnel pool settings:\n");
    266266        buf.append("====================================\n");
    267         for (Map.Entry e : p.entrySet()) {
     267        for (Map.Entry<Object, Object> e : p.entrySet()) {
    268268            String name = (String) e.getKey();
    269269            String val = (String) e.getValue();
  • router/java/src/net/i2p/router/client/ClientManager.java

    rf8a54bde rde184ed1  
    1313import java.util.Collections;
    1414import java.util.HashSet;
    15 import java.util.Iterator;
    1615import java.util.Map;
    1716import java.util.Set;
     
    126125        Set<ClientConnectionRunner> runners = new HashSet<ClientConnectionRunner>();
    127126        synchronized (_runners) {
    128             for (Iterator<ClientConnectionRunner> iter = _runners.values().iterator(); iter.hasNext();) {
    129                 ClientConnectionRunner runner = iter.next();
     127            for (ClientConnectionRunner runner : _runners.values()) {
    130128                runners.add(runner);
    131129            }
    132130        }
    133131        synchronized (_pendingRunners) {
    134             for (Iterator<ClientConnectionRunner> iter = _pendingRunners.iterator(); iter.hasNext();) {
    135                 ClientConnectionRunner runner = iter.next();
     132            for (ClientConnectionRunner runner : _pendingRunners) {
    136133                runners.add(runner);
    137134            }
    138135        }
    139         for (Iterator<ClientConnectionRunner> iter = runners.iterator(); iter.hasNext(); ) {
    140             ClientConnectionRunner runner = iter.next();
     136        for (ClientConnectionRunner runner : runners) {
    141137            runner.disconnectClient(msg, Log.WARN);
    142138        }
  • router/java/src/net/i2p/router/networkdb/kademlia/FloodOnlySearchJob.java

    rf8a54bde rde184ed1  
    44import java.util.Collections;
    55import java.util.HashSet;
    6 import java.util.Iterator;
    76import java.util.List;
    87
     
    217216        }
    218217        synchronized(_unheardFrom) {
    219             for (Iterator<Hash> iter = _unheardFrom.iterator(); iter.hasNext(); )
    220                 getContext().profileManager().dbLookupFailed(iter.next());
     218            for (Hash h : _unheardFrom)
     219                getContext().profileManager().dbLookupFailed(h);
    221220        }
    222221        _facade.complete(_key);
  • router/java/src/net/i2p/router/networkdb/kademlia/IterativeSearchJob.java

    rf8a54bde rde184ed1  
    384384            tries = _unheardFrom.size() + _failedPeers.size();
    385385            // blame the unheard-from (others already blamed in failed() above)
    386             for (Iterator<Hash> iter = _unheardFrom.iterator(); iter.hasNext(); )
    387                 getContext().profileManager().dbLookupFailed(iter.next());
     386            for (Hash h : _unheardFrom)
     387                getContext().profileManager().dbLookupFailed(h);
    388388        }
    389389        long time = System.currentTimeMillis() - _created;
  • router/java/src/net/i2p/router/networkdb/kademlia/SearchState.java

    rf8a54bde rde184ed1  
    4545    public Set<Hash> getPending() {
    4646        synchronized (_pendingPeers) {
    47             return (Set<Hash>)_pendingPeers.clone();
     47            return new HashSet<Hash>(_pendingPeers);
    4848        }
    4949    }
    5050    public Set<Hash> getAttempted() {
    5151        synchronized (_attemptedPeers) {
    52             return (Set<Hash>)_attemptedPeers.clone();
     52            return new HashSet<Hash>(_attemptedPeers);
    5353        }
    5454    }
     
    7979    public Set<Hash> getSuccessful() {
    8080        synchronized (_successfulPeers) {
    81             return (Set<Hash>)_successfulPeers.clone();
     81            return new HashSet<Hash>(_successfulPeers);
    8282        }
    8383    }
    8484    public Set<Hash> getFailed() {
    8585        synchronized (_failedPeers) {
    86             return (Set<Hash>)_failedPeers.clone();
     86            return new HashSet<Hash>(_failedPeers);
    8787        }
    8888    }
     
    156156    }
    157157   
    158     public Set<Hash> getRepliedPeers() { synchronized (_repliedPeers) { return (Set<Hash>)_repliedPeers.clone(); } }
     158    public Set<Hash> getRepliedPeers() { synchronized (_repliedPeers) { return new HashSet<Hash>(_repliedPeers); } }
    159159   
    160160    public void replyTimeout(Hash peer) {
  • router/java/src/net/i2p/router/networkdb/kademlia/StoreJob.java

    rf8a54bde rde184ed1  
    1010
    1111import java.util.ArrayList;
    12 import java.util.Iterator;
    1312import java.util.List;
    1413import java.util.Set;
     
    158157            if (_log.shouldLog(Log.INFO))
    159158                _log.info(getJobId() + ": Continue sending key " + _state.getTarget() + " after " + _state.getAttempted().size() + " tries to " + closestHashes);
    160             for (Iterator<Hash> iter = closestHashes.iterator(); iter.hasNext(); ) {
    161                 Hash peer = iter.next();
     159            for (Hash peer : closestHashes) {
    162160                DatabaseEntry ds = _facade.getDataStore().get(peer);
    163161                if ( (ds == null) || !(ds.getType() == DatabaseEntry.KEY_TYPE_ROUTERINFO) ) {
  • router/java/src/net/i2p/router/networkdb/kademlia/StoreState.java

    rf8a54bde rde184ed1  
    55import java.util.HashMap;
    66import java.util.HashSet;
    7 import java.util.Iterator;
    87import java.util.Map;
    98import java.util.Set;
     
    5958    public Set<Hash> getPending() {
    6059        synchronized (_pendingPeers) {
    61             return (Set<Hash>)_pendingPeers.clone();
     60            return new HashSet<Hash>(_pendingPeers);
    6261        }
    6362    }
    6463    public Set<Hash> getAttempted() {
    6564        synchronized (_attemptedPeers) {
    66             return (Set<Hash>)_attemptedPeers.clone();
     65            return new HashSet<Hash>(_attemptedPeers);
    6766        }
    6867    }
    6968    public Set<Hash> getSuccessful() {
    7069        synchronized (_successfulPeers) {
    71             return (Set<Hash>)_successfulPeers.clone();
     70            return new HashSet<Hash>(_successfulPeers);
    7271        }
    7372    }
     
    8382    public Set<Hash> getFailed() {
    8483        synchronized (_failedPeers) {
    85             return (Set<Hash>)_failedPeers.clone();
     84            return new HashSet<Hash>(_failedPeers);
    8685        }
    8786    }
     
    125124        synchronized (_pendingPeers) {
    126125            _pendingPeers.addAll(pending);
    127             for (Iterator<Hash> iter = pending.iterator(); iter.hasNext(); )
    128                 _pendingPeerTimes.put(iter.next(), Long.valueOf(_context.clock().now()));
     126            for (Hash peer : pending)
     127                _pendingPeerTimes.put(peer, Long.valueOf(_context.clock().now()));
    129128        }
    130129        synchronized (_attemptedPeers) {
     
    192191        synchronized (_attemptedPeers) {
    193192            buf.append(_attemptedPeers.size()).append(' ');
    194             for (Iterator<Hash> iter = _attemptedPeers.iterator(); iter.hasNext(); ) {
    195                 Hash peer = iter.next();
     193            for (Hash peer : _attemptedPeers) {
    196194                buf.append(peer.toBase64()).append(" ");
    197195            }
     
    200198        synchronized (_pendingPeers) {
    201199            buf.append(_pendingPeers.size()).append(' ');
    202             for (Iterator<Hash> iter = _pendingPeers.iterator(); iter.hasNext(); ) {
    203                 Hash peer = iter.next();
     200            for (Hash peer : _pendingPeers) {
    204201                buf.append(peer.toBase64()).append(" ");
    205202            }
     
    208205        synchronized (_failedPeers) {
    209206            buf.append(_failedPeers.size()).append(' ');
    210             for (Iterator<Hash> iter = _failedPeers.iterator(); iter.hasNext(); ) {
    211                 Hash peer = iter.next();
     207            for (Hash peer : _failedPeers) {
    212208                buf.append(peer.toBase64()).append(" ");
    213209            }
     
    216212        synchronized (_successfulPeers) {
    217213            buf.append(_successfulPeers.size()).append(' ');
    218             for (Iterator<Hash> iter = _successfulPeers.iterator(); iter.hasNext(); ) {
    219                 Hash peer = iter.next();
     214            for (Hash peer : _successfulPeers) {
    220215                buf.append(peer.toBase64()).append(" ");
    221216            }
  • router/java/src/net/i2p/router/peermanager/ProfileOrganizer.java

    rf8a54bde rde184ed1  
    237237        getReadLock();
    238238        try {
    239             for (Iterator<PeerProfile> iter = _failingPeers.values().iterator(); iter.hasNext(); ) {
    240                 PeerProfile profile = iter.next();
     239            for (PeerProfile profile : _failingPeers.values()) {
    241240                if (profile.getLastSendSuccessful() >= hideBefore)
    242241                    activePeers++;
     
    244243                    activePeers++;
    245244            }
    246             for (Iterator<PeerProfile> iter = _notFailingPeers.values().iterator(); iter.hasNext(); ) {
    247                 PeerProfile profile = iter.next();
     245            for (PeerProfile profile : _notFailingPeers.values()) {
    248246                if (profile.getLastSendSuccessful() >= hideBefore)
    249247                    activePeers++;
     
    540538            getReadLock();
    541539            try {
    542                 for (Iterator<Hash> iter = _notFailingPeers.keySet().iterator(); iter.hasNext(); ) {
    543                     Hash peer = iter.next();
     540                for (Hash peer : _notFailingPeers.keySet()) {
    544541                    if (!_context.commSystem().isEstablished(peer))
    545542                        exclude.add(peer);
     
    568565            getReadLock();
    569566            try {
    570                 for (Iterator<Map.Entry<Hash, PeerProfile>> iter = _notFailingPeers.entrySet().iterator(); iter.hasNext(); ) {
    571                     Map.Entry<Hash, PeerProfile> e = iter.next();
     567                for (Map.Entry<Hash, PeerProfile> e : _notFailingPeers.entrySet()) {
    572568                    if (_context.commSystem().isEstablished(e.getKey()))
    573569                        activePeers.put(e.getKey(), e.getValue());
     
    667663        } finally { releaseReadLock(); }
    668664        List<Hash> l = new ArrayList<Hash>(count / 4);
    669         for (Iterator<Hash> iter = n.iterator(); iter.hasNext(); ) {
    670             Hash peer = iter.next();
     665        for (Hash peer : n) {
    671666            if (_context.commSystem().wasUnreachable(peer))
    672667                l.add(peer);
     
    718713            int count = _notFailingPeers.size();
    719714            List<Hash> l = new ArrayList<Hash>(count / 128);
    720             for (Iterator<PeerProfile> iter = _notFailingPeers.values().iterator(); iter.hasNext(); ) {
    721                 PeerProfile prof = iter.next();
     715            for (PeerProfile prof : _notFailingPeers.values()) {
    722716                if (prof.getTunnelHistory().getLastRejectedBandwidth() > cutoff)
    723717                    l.add(prof.getPeer());
     
    780774            getReadLock();
    781775            try {
    782                 for (Iterator<PeerProfile> iter = _strictCapacityOrder.iterator(); iter.hasNext(); ) {
    783                     PeerProfile prof = iter.next();
     776                for (PeerProfile prof : _strictCapacityOrder) {
    784777                    if ( (expireOlderThan > 0) && (prof.getLastSendSuccessful() <= expireOlderThan) ) {
    785778                        continue;
     
    888881            if (_log.shouldLog(Log.INFO))
    889882                _log.info("Need to explicitly promote " + numToPromote + " peers to the fast group");
    890             for (Iterator<PeerProfile> iter = _strictCapacityOrder.iterator(); iter.hasNext(); ) {
    891                 PeerProfile cur = iter.next();
     883            for (PeerProfile cur : _strictCapacityOrder) {
    892884                if ( (!_fastPeers.containsKey(cur.getPeer())) && (!cur.getIsFailing()) ) {
    893885                    if (!isSelectable(cur.getPeer())) {
     
    991983        if (needToUnfail > 0) {
    992984            int unfailed = 0;
    993             for (Iterator<PeerProfile> iter = _strictCapacityOrder.iterator(); iter.hasNext(); ) {
    994                 PeerProfile best = iter.next();
     985            for (PeerProfile best : _strictCapacityOrder) {
    995986                if ( (best.getIsActive()) && (best.getIsFailing()) ) {
    996987                    if (_log.shouldLog(Log.WARN))
     
    10231014        double totalIntegration = 0;
    10241015        Set<PeerProfile> reordered = new TreeSet<PeerProfile>(_comp);
    1025         for (Iterator<PeerProfile> iter = allPeers.iterator(); iter.hasNext(); ) {
    1026             PeerProfile profile = iter.next();
    1027            
     1016        for (PeerProfile profile : allPeers) {
    10281017            if (_us.equals(profile.getPeer())) continue;
    10291018           
     
    10731062        double thresholdAtLowest = CapacityCalculator.GROWTH_FACTOR;
    10741063        int cur = 0;
    1075         for (Iterator<PeerProfile> iter = reordered.iterator(); iter.hasNext(); ) {
    1076             PeerProfile profile = iter.next();
     1064        for (PeerProfile profile : reordered) {
    10771065            double val = profile.getCapacityValue();
    10781066            if (val > meanCapacity)
     
    11651153        double total = 0;
    11661154        int count = 0;
    1167         for (Iterator<PeerProfile> iter = reordered.iterator(); iter.hasNext(); ) {
    1168             PeerProfile profile = iter.next();
     1155        for (PeerProfile profile : reordered) {
    11691156            if (profile.getCapacityValue() >= _thresholdCapacityValue) {
    11701157                // duplicates being clobbered is fine by us
     
    15251512        fmt.setPositivePrefix("+");
    15261513       
    1527         for (Iterator<Hash> iter = organizer.selectAllPeers().iterator(); iter.hasNext(); ) {
    1528             Hash peer = iter.next();
     1514        for (Hash peer : organizer.selectAllPeers()) {
    15291515            PeerProfile profile = organizer.getProfile(peer);
    15301516            if (!profile.getIsActive()) {
  • router/java/src/net/i2p/router/startup/LoadClientAppsJob.java

    rf8a54bde rde184ed1  
    198198        if (args == null)
    199199            args = new String[0];
    200         Class cls = Class.forName(className, true, cl);
     200        Class<?> cls = Class.forName(className, true, cl);
    201201        Method method = cls.getMethod("main", new Class[] { String[].class });
    202202        method.invoke(cls, new Object[] { args });
     
    265265        public void run() {
    266266            try {
    267                 Class cls = Class.forName(_className, true, _cl);
     267                Class<?> cls = Class.forName(_className, true, _cl);
    268268                if (isRouterApp(cls)) {
    269                     Constructor con = cls.getConstructor(RouterContext.class, ClientAppManager.class, String[].class);
     269                    Constructor<?> con = cls.getConstructor(RouterContext.class, ClientAppManager.class, String[].class);
    270270                    RouterAppManager mgr = _ctx.clientAppManager();
    271271                    Object[] conArgs = new Object[] {_ctx, _ctx.clientAppManager(), _args};
     
    273273                    mgr.addAndStart(app, _args);
    274274                } else if (isClientApp(cls)) {
    275                     Constructor con = cls.getConstructor(I2PAppContext.class, ClientAppManager.class, String[].class);
     275                    Constructor<?> con = cls.getConstructor(I2PAppContext.class, ClientAppManager.class, String[].class);
    276276                    RouterAppManager mgr = _ctx.clientAppManager();
    277277                    Object[] conArgs = new Object[] {_ctx, _ctx.clientAppManager(), _args};
     
    289289        }
    290290
    291         private static boolean isRouterApp(Class cls) {
     291        private static boolean isRouterApp(Class<?> cls) {
    292292            return isInterface(cls, RouterApp.class);
    293293        }
    294294
    295         private static boolean isClientApp(Class cls) {
     295        private static boolean isClientApp(Class<?> cls) {
    296296            return isInterface(cls, ClientApp.class);
    297297        }
    298298
    299         private static boolean isInterface(Class cls, Class intfc) {
     299        private static boolean isInterface(Class<?> cls, Class<?> intfc) {
    300300            try {
    301                 Class[] intfcs = cls.getInterfaces();
     301                Class<?>[] intfcs = cls.getInterfaces();
    302302                for (int i = 0; i < intfcs.length; i++) {
    303303                    if (intfcs[i] == intfc)
  • router/java/src/net/i2p/router/transport/CommSystemFacadeImpl.java

    rf8a54bde rde184ed1  
    1313import java.util.ArrayList;
    1414import java.util.Collections;
    15 import java.util.Iterator;
    1615import java.util.List;
    1716import java.util.Locale;
     
    234233    private class QueueAll implements SimpleTimer.TimedEvent {
    235234        public void timeReached() {
    236             for (Iterator<Hash> iter = _context.netDb().getAllRouters().iterator(); iter.hasNext(); ) {
    237                 RouterInfo ri = _context.netDb().lookupRouterInfoLocally(iter.next());
     235            for (Hash h : _context.netDb().getAllRouters()) {
     236                RouterInfo ri = _context.netDb().lookupRouterInfoLocally(h);
    238237                if (ri == null)
    239238                    continue;
  • router/java/src/net/i2p/router/transport/GeoIP.java

    rf8a54bde rde184ed1  
    195195            return;
    196196        }
    197         FileInputStream in = null;
     197        BufferedReader br = null;
    198198        try {
    199             in = new FileInputStream(geoFile);
    200             BufferedReader br = new BufferedReader(new InputStreamReader(in, "UTF-8"));
     199            br = new BufferedReader(new InputStreamReader(
     200                    new FileInputStream(geoFile), "UTF-8"));
    201201            String line = null;
    202202            while ( (line = br.readLine()) != null) {
     
    216216                _log.error("Error reading the Country File", ioe);
    217217        } finally {
    218             if (in != null) try { in.close(); } catch (IOException ioe) {}
     218            if (br != null) try { br.close(); } catch (IOException ioe) {}
    219219        }
    220220    }
     
    257257        int idx = 0;
    258258        long start = _context.clock().now();
    259         FileInputStream in = null;
     259        BufferedReader br = null;
    260260        try {
    261             in = new FileInputStream(geoFile);
    262261            String buf = null;
    263             BufferedReader br = new BufferedReader(new InputStreamReader(in, "ISO-8859-1"));
     262            br = new BufferedReader(new InputStreamReader(
     263                    new FileInputStream(geoFile), "ISO-8859-1"));
    264264            while ((buf = br.readLine()) != null && idx < search.length) {
    265265                try {
     
    289289                _log.error("Error reading the geoFile", ioe);
    290290        } finally {
    291             if (in != null) try { in.close(); } catch (IOException ioe) {}
     291            if (br != null) try { br.close(); } catch (IOException ioe) {}
    292292        }
    293293
  • router/java/src/net/i2p/router/transport/GeoIPv6.java

    rf8a54bde rde184ed1  
    159159            int count = 0;
    160160            InputStream in = null;
     161            BufferedReader br = null;
    161162            try {
    162163                in = new BufferedInputStream(new FileInputStream(geoFile));
     
    164165                    in = new GZIPInputStream(in);
    165166                String buf = null;
    166                 BufferedReader br = new BufferedReader(new InputStreamReader(in, "ISO-8859-1"));
     167                br = new BufferedReader(new InputStreamReader(in, "ISO-8859-1"));
    167168                while ((buf = br.readLine()) != null) {
    168169                    try {
     
    192193            } finally {
    193194                if (in != null) try { in.close(); } catch (IOException ioe) {}
     195                if (br != null) try { br.close(); } catch (IOException ioe) {}
    194196            }
    195197        }
  • router/java/src/net/i2p/router/transport/UPnP.java

    rf8a54bde rde184ed1  
    281281        private void discoverService() {
    282282                synchronized (lock) {
    283                         for (Iterator iter = _router.getDeviceList().iterator();iter.hasNext();) {
    284                                 Device current = (Device)iter.next();
     283                        for (Device current : _router.getDeviceList()) {
    285284                                if (!current.getDeviceType().equals(WAN_DEVICE))
    286285                                        continue;
  • router/java/src/net/i2p/router/transport/ntcp/NTCPSendFinisher.java

    rf8a54bde rde184ed1  
    7070             // use unbounded queue, so maximumPoolSize and keepAliveTime have no effect
    7171             super(num, num, 1000, TimeUnit.MILLISECONDS,
    72                    new LinkedBlockingQueue(), new CustomThreadFactory());
     72                   new LinkedBlockingQueue<Runnable>(), new CustomThreadFactory());
    7373        }
    7474    }
  • router/java/src/net/i2p/router/transport/udp/UDPTransport.java

    rf8a54bde rde184ed1  
    21152115        long now = _context.clock().now();
    21162116        int active = 0;
    2117         for (Iterator<PeerState> iter = _peersByIdent.values().iterator(); iter.hasNext(); ) {
    2118                 PeerState peer = iter.next();
     2117        for (PeerState peer : _peersByIdent.values()) {
    21192118                if (now-peer.getLastReceiveTime() <= 5*60*1000)
    21202119                    active++;
     
    21272126        long now = _context.clock().now();
    21282127        int active = 0;
    2129         for (Iterator<PeerState> iter = _peersByIdent.values().iterator(); iter.hasNext(); ) {
    2130                 PeerState peer = iter.next();
     2128        for (PeerState peer : _peersByIdent.values()) {
    21312129                if (now-peer.getLastSendFullyTime() <= 1*60*1000)
    21322130                    active++;
  • router/java/src/net/i2p/router/tunnel/pool/ExploratoryPeerSelector.java

    rf8a54bde rde184ed1  
    2525    }
    2626
    27     public List<Hash> selectPeers(TunnelPoolSettings settings) {
     27        public List<Hash> selectPeers(TunnelPoolSettings settings) {
    2828        Log l = ctx.logManager().getLog(getClass());
    2929        int length = getLength(settings);
     
    3535       
    3636        if (false && shouldSelectExplicit(settings)) {
    37             List rv = selectExplicit(settings, length);
     37            List<Hash> rv = selectExplicit(settings, length);
    3838            if (l.shouldLog(Log.DEBUG))
    3939                l.debug("Explicit peers selected: " + rv);
  • router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java

    rf8a54bde rde184ed1  
    77import java.util.Iterator;
    88import java.util.List;
    9 import java.util.Map;
     9import java.util.Properties;
    1010import java.util.TreeSet;
    1111
     
    124124        } else {
    125125            if (_settings.isExploratory()) {
    126                 Map props = _context.router().getConfigMap();
     126                Properties props = new Properties();
     127                props.putAll(_context.router().getConfigMap());
    127128                if (_settings.isInbound())
    128129                    _settings.readFromProperties(TunnelPoolSettings.PREFIX_INBOUND_EXPLORATORY, props);
  • router/java/src/net/i2p/router/util/EventLog.java

    rf8a54bde rde184ed1  
    44import java.io.File;
    55import java.io.FileInputStream;
    6 import java.io.InputStream;
    76import java.io.InputStreamReader;
    87import java.io.IOException;
     
    117116        }
    118117        rv = new TreeMap<Long, String>();
    119         InputStream in = null;
     118        BufferedReader br = null;
    120119        try {
    121             in = new FileInputStream(_file);
    122             BufferedReader br = new BufferedReader(new InputStreamReader(in, "UTF-8"));
     120            br = new BufferedReader(new InputStreamReader(
     121                    new FileInputStream(_file), "UTF-8"));
    123122            String line = null;
    124123            while ( (line = br.readLine()) != null) {
     
    142141        } catch (IOException ioe) {
    143142        } finally {
    144             if (in != null) try { in.close(); } catch (IOException ioe) {}
     143            if (br != null) try { br.close(); } catch (IOException ioe) {}
    145144        }
    146145        return rv;
  • router/java/src/net/i2p/router/util/PriBlockingQueue.java

    rf8a54bde rde184ed1  
    3535     */
    3636    public PriBlockingQueue(I2PAppContext ctx, String name, int initialCapacity) {
    37         super(initialCapacity, new PriorityComparator());
     37        super(initialCapacity, new PriorityComparator<E>());
    3838        _context = ctx;
    3939        _log = ctx.logManager().getLog(PriorityBlockingQueue.class);
Note: See TracChangeset for help on using the changeset viewer.