Changeset 20effe3


Ignore:
Timestamp:
Oct 19, 2008 10:09:14 PM (12 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
0e0459f
Parents:
8a756a6
Message:

Big findbugs cleanup

Files:
77 edited

Legend:

Unmodified
Added
Removed
  • apps/addressbook/java/src/addressbook/ConfigParser.java

    r8a756a6 r20effe3  
    108108        BufferedReader input = new BufferedReader(new InputStreamReader(
    109109                fileStream));
    110         return ConfigParser.parse(input);
     110        Map rv = ConfigParser.parse(input);
     111        try {
     112            fileStream.close();
     113        } catch (IOException ioe) {}
     114        return rv;
    111115    }
    112116
     
    139143     */
    140144    public static Map parse(File file, Map map) {
    141         Map result = new HashMap();
     145        Map result;
    142146        try {
    143147            result = ConfigParser.parse(file);
     
    189193        BufferedReader input = new BufferedReader(new InputStreamReader(
    190194                fileStream));
    191         return ConfigParser.parseSubscriptions(input);
     195        List rv = ConfigParser.parseSubscriptions(input);
     196        try {
     197            fileStream.close();
     198        } catch (IOException ioe) {}
     199        return rv;
    192200    }
    193201
     
    219227     */
    220228    public static List parseSubscriptions(File file, List list) {
    221         List result = new LinkedList();
     229        List result;
    222230        try {
    223231            result = ConfigParser.parseSubscriptions(file);
  • apps/addressbook/java/src/addressbook/Daemon.java

    r8a756a6 r20effe3  
    126126    public void run(String[] args) {
    127127        String settingsLocation = "config.txt";
    128         Map settings = new HashMap();
    129128        String home;
    130129        if (args.length > 0) {
     
    158157        File settingsFile = new File(homeFile, settingsLocation);
    159158       
    160         settings = ConfigParser.parse(settingsFile, defaultSettings);
     159        Map settings = ConfigParser.parse(settingsFile, defaultSettings);
    161160        // wait
    162161        try {
  • apps/addressbook/java/src/addressbook/Log.java

    r8a756a6 r20effe3  
    5555     */
    5656    public void append(String entry) {
     57        BufferedWriter bw = null;
    5758        try {
    58             BufferedWriter bw = new BufferedWriter(new FileWriter(this.file,
     59            bw = new BufferedWriter(new FileWriter(this.file,
    5960                    true));
    6061            String timestamp = new Date().toString();
    6162            bw.write(timestamp + " -- " + entry);
    6263            bw.newLine();
    63             bw.close();
    6464        } catch (IOException exp) {
     65        } finally {
     66            if (bw != null)
     67                try { bw.close(); } catch (IOException ioe) {}
    6568        }
    6669    }
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnel.java

    r8a756a6 r20effe3  
    347347                l.log("unknown host");
    348348                _log.error(getPrefix() + "Error resolving " + args[0], uhe);
    349                 notifyEvent("serverTaskId", new Integer(-1));
     349                notifyEvent("serverTaskId", Integer.valueOf(-1));
    350350                return;
    351351            }
     
    356356                l.log("invalid port");
    357357                _log.error(getPrefix() + "Port specified is not valid: " + args[1], nfe);
    358                 notifyEvent("serverTaskId", new Integer(-1));
     358                notifyEvent("serverTaskId", Integer.valueOf(-1));
    359359                return;
    360360            }
     
    364364                l.log("private key file does not exist");
    365365                _log.error(getPrefix() + "Private key file does not exist or is not readable: " + args[2]);
    366                 notifyEvent("serverTaskId", new Integer(-1));
     366                notifyEvent("serverTaskId", Integer.valueOf(-1));
    367367                return;
    368368            }
     
    371371            serv.startRunning();
    372372            addtask(serv);
    373             notifyEvent("serverTaskId", new Integer(serv.getId()));
     373            notifyEvent("serverTaskId", Integer.valueOf(serv.getId()));
    374374            return;
    375375        } else {
    376376            l.log("server <host> <port> <privkeyfile>");
    377377            l.log("  creates a server that sends all incoming data\n" + "  of its destination to host:port.");
    378             notifyEvent("serverTaskId", new Integer(-1));
     378            notifyEvent("serverTaskId", Integer.valueOf(-1));
    379379        }
    380380    }
     
    402402                l.log("unknown host");
    403403                _log.error(getPrefix() + "Error resolving " + args[0], uhe);
    404                 notifyEvent("serverTaskId", new Integer(-1));
     404                notifyEvent("serverTaskId", Integer.valueOf(-1));
    405405                return;
    406406            }
     
    411411                l.log("invalid port");
    412412                _log.error(getPrefix() + "Port specified is not valid: " + args[1], nfe);
    413                 notifyEvent("serverTaskId", new Integer(-1));
     413                notifyEvent("serverTaskId", Integer.valueOf(-1));
    414414                return;
    415415            }
     
    421421                l.log("private key file does not exist");
    422422                _log.error(getPrefix() + "Private key file does not exist or is not readable: " + args[3]);
    423                 notifyEvent("serverTaskId", new Integer(-1));
     423                notifyEvent("serverTaskId", Integer.valueOf(-1));
    424424                return;
    425425            }
     
    428428            serv.startRunning();
    429429            addtask(serv);
    430             notifyEvent("serverTaskId", new Integer(serv.getId()));
     430            notifyEvent("serverTaskId", Integer.valueOf(serv.getId()));
    431431            return;
    432432        } else {
     
    435435                  + "  of its destination to host:port., filtering the HTTP\n"
    436436                  + "  headers so it looks like the request is to the spoofed host.");
    437             notifyEvent("serverTaskId", new Integer(-1));
     437            notifyEvent("serverTaskId", Integer.valueOf(-1));
    438438        }
    439439    }
     
    459459                l.log("unknown host");
    460460                _log.error(getPrefix() + "Error resolving " + args[0], uhe);
    461                 notifyEvent("serverTaskId", new Integer(-1));
     461                notifyEvent("serverTaskId", Integer.valueOf(-1));
    462462                return;
    463463            }
     
    468468                l.log("invalid port");
    469469                _log.error(getPrefix() + "Port specified is not valid: " + args[1], nfe);
    470                 notifyEvent("serverTaskId", new Integer(-1));
     470                notifyEvent("serverTaskId", Integer.valueOf(-1));
    471471                return;
    472472            }
     
    476476            serv.startRunning();
    477477            addtask(serv);
    478             notifyEvent("serverTaskId", new Integer(serv.getId()));
     478            notifyEvent("serverTaskId", Integer.valueOf(serv.getId()));
    479479        } else {
    480480            l.log("textserver <host> <port> <privkey>");
    481481            l.log("  creates a server that sends all incoming data\n" + "  of its destination to host:port.");
    482             notifyEvent("textserverTaskId", new Integer(-1));
     482            notifyEvent("textserverTaskId", Integer.valueOf(-1));
    483483        }
    484484    }
     
    508508                l.log("invalid port");
    509509                _log.error(getPrefix() + "Port specified is not valid: " + args[0], nfe);
    510                 notifyEvent("clientTaskId", new Integer(-1));
     510                notifyEvent("clientTaskId", Integer.valueOf(-1));
    511511                return;
    512512            }
     
    516516                task = new I2PTunnelClient(portNum, args[1], l, ownDest, (EventDispatcher) this, this);
    517517                addtask(task);
    518                 notifyEvent("clientTaskId", new Integer(task.getId()));
     518                notifyEvent("clientTaskId", Integer.valueOf(task.getId()));
    519519            } catch (IllegalArgumentException iae) {
    520520                _log.error(getPrefix() + "Invalid I2PTunnel config to create a client [" + host + ":"+ port + "]", iae);
    521521                l.log("Invalid I2PTunnel configuration [" + host + ":" + port + "]");
    522                 notifyEvent("clientTaskId", new Integer(-1));
     522                notifyEvent("clientTaskId", Integer.valueOf(-1));
    523523            }
    524524        } else {
     
    529529                  + "  randomlyl. sharedClient indicates if this client shares \n"
    530530                  + "   with other clients (true of false)");
    531             notifyEvent("clientTaskId", new Integer(-1));
     531            notifyEvent("clientTaskId", Integer.valueOf(-1));
    532532        }
    533533    }
     
    551551                l.log("invalid port");
    552552                _log.error(getPrefix() + "Port specified is not valid: " + args[0], nfe);
    553                 notifyEvent("httpclientTaskId", new Integer(-1));
     553                notifyEvent("httpclientTaskId", Integer.valueOf(-1));
    554554                return;
    555555            }
     
    583583                task = new I2PTunnelHTTPClient(port, l, ownDest, proxy, (EventDispatcher) this, this);
    584584                addtask(task);
    585                 notifyEvent("httpclientTaskId", new Integer(task.getId()));
     585                notifyEvent("httpclientTaskId", Integer.valueOf(task.getId()));
    586586            } catch (IllegalArgumentException iae) {
    587587                _log.error(getPrefix() + "Invalid I2PTunnel config to create an httpclient [" + host + ":"+ port + "]", iae);
    588588                l.log("Invalid I2PTunnel configuration [" + host + ":" + port + "]");
    589                 notifyEvent("httpclientTaskId", new Integer(-1));
     589                notifyEvent("httpclientTaskId", Integer.valueOf(-1));
    590590            }
    591591        } else {
     
    596596            l.log("  when trying to access an address out of the .i2p domain");
    597597            l.log("  (the default proxy is squid.i2p).");
    598             notifyEvent("httpclientTaskId", new Integer(-1));
     598            notifyEvent("httpclientTaskId", Integer.valueOf(-1));
    599599        }
    600600    }
     
    618618                l.log("invalid port");
    619619                _log.error(getPrefix() + "Port specified is not valid: " + args[0], nfe);
    620                 notifyEvent("ircclientTaskId", new Integer(-1));
     620                notifyEvent("ircclientTaskId", Integer.valueOf(-1));
    621621                return;
    622622            }
     
    640640                task = new I2PTunnelIRCClient(port, args[1],l, ownDest, (EventDispatcher) this, this);
    641641                addtask(task);
    642                 notifyEvent("ircclientTaskId", new Integer(task.getId()));
     642                notifyEvent("ircclientTaskId", Integer.valueOf(task.getId()));
    643643            } catch (IllegalArgumentException iae) {
    644644                _log.error(getPrefix() + "Invalid I2PTunnel config to create an ircclient [" + host + ":"+ port + "]", iae);
    645645                l.log("Invalid I2PTunnel configuration [" + host + ":" + port + "]");
    646                 notifyEvent("ircclientTaskId", new Integer(-1));
     646                notifyEvent("ircclientTaskId", Integer.valueOf(-1));
    647647            }
    648648        } else {
     
    650650            l.log("  creates a client that filter IRC protocol.");
    651651            l.log("  <sharedClient> (optional) indicates if this client shares tunnels with other clients (true of false)");
    652             notifyEvent("ircclientTaskId", new Integer(-1));
     652            notifyEvent("ircclientTaskId", Integer.valueOf(-1));
    653653        }
    654654    }
     
    673673                l.log("invalid port");
    674674                _log.error(getPrefix() + "Port specified is not valid: " + args[0], nfe);
    675                 notifyEvent("sockstunnelTaskId", new Integer(-1));
     675                notifyEvent("sockstunnelTaskId", Integer.valueOf(-1));
    676676                return;
    677677            }
     
    680680            task = new I2PSOCKSTunnel(port, l, ownDest, (EventDispatcher) this, this);
    681681            addtask(task);
    682             notifyEvent("sockstunnelTaskId", new Integer(task.getId()));
     682            notifyEvent("sockstunnelTaskId", Integer.valueOf(task.getId()));
    683683        } else {
    684684            l.log("sockstunnel <port>");
    685685            l.log("  creates a tunnel that distributes SOCKS requests.");
    686             notifyEvent("sockstunnelTaskId", new Integer(-1));
     686            notifyEvent("sockstunnelTaskId", Integer.valueOf(-1));
    687687        }
    688688    }
     
    968968            notifyEvent("lookupResult", "invalidUsage");
    969969        } else {
    970             String target = args[0];
    971970            try {
    972971                Destination dest = destFromName(args[0]);
     
    999998            task = new I2Ping(allargs, l, false, (EventDispatcher) this, this);
    1000999            addtask(task);
    1001             notifyEvent("pingTaskId", new Integer(task.getId()));
     1000            notifyEvent("pingTaskId", Integer.valueOf(task.getId()));
    10021001        } else {
    10031002            l.log("ping <opts> <dest>");
     
    10051004            l.log("ping <opts> -l <destlistfile>");
    10061005            l.log("   Tests communication with peers.\n" + "   opts can be -ns (nosync) or not.");
    1007             notifyEvent("pingTaskId", new Integer(-1));
     1006            notifyEvent("pingTaskId", Integer.valueOf(-1));
    10081007        }
    10091008    }
     
    10841083        try {
    10851084            l.log("Generating new keys...");
    1086             ByteArrayOutputStream priv = new ByteArrayOutputStream(), pub = new ByteArrayOutputStream();
    10871085            I2PClient client = I2PClientFactory.createClient();
    10881086            Destination d = client.createDestination(writeTo);
     
    11081106    public static void showKey(InputStream readFrom, OutputStream pubDest, Logging l) {
    11091107        try {
    1110             I2PClient client = I2PClientFactory.createClient();
    11111108            Destination d = new Destination();
    11121109            d.readBytes(readFrom);
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelClientBase.java

    r8a756a6 r20effe3  
    218218    protected static I2PSocketManager buildSocketManager(I2PTunnel tunnel) {
    219219        Properties props = new Properties();
    220         if (tunnel == null)
    221             props.putAll(System.getProperties());
    222         else
    223             props.putAll(tunnel.getClientOptions());
     220        props.putAll(tunnel.getClientOptions());
    224221        int portNum = 7654;
    225222        if (tunnel.port != null) {
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelRunner.java

    r8a756a6 r20effe3  
    217217        if (sockList != null) {
    218218            synchronized (slock) {
    219                 boolean removed = sockList.remove(i2ps);
    220                 //System.out.println("Removal of i2psocket " + i2ps + " successful? "
    221                 //                   + removed + " remaining: " + sockList.size());
     219                sockList.remove(i2ps);
    222220            }
    223221        }
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelServer.java

    r8a756a6 r20effe3  
    7171        else
    7272            _usePool = DEFAULT_USE_POOL;
     73        FileInputStream fis = null;
    7374        try {
    74             init(host, port, new FileInputStream(privkey), privkeyname, l);
     75            fis = new FileInputStream(privkey);
     76            init(host, port, fis, privkeyname, l);
    7577        } catch (IOException ioe) {
    7678            _log.error("Error starting server", ioe);
    7779            notifyEvent("openServerResult", "error");
     80        } finally {
     81            if (fis != null)
     82                try { fis.close(); } catch (IOException ioe) {}
    7883        }
    7984    }
     
    9398        this.remoteHost = host;
    9499        this.remotePort = port;
    95         I2PClient client = I2PClientFactory.createClient();
    96100        Properties props = new Properties();
    97101        props.putAll(getTunnel().getClientOptions());
  • apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketImpl.java

    r8a756a6 r20effe3  
    385385            }
    386386            if (read.length > len) throw new RuntimeException("BUG");
    387             if ( (inStreamClosed) && ( (read == null) || (read.length <= 0) ) )
     387            if ( (inStreamClosed) && (read.length <= 0) )
    388388                return -1;
    389389           
  • apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketManagerFactory.java

    r8a756a6 r20effe3  
    7676        ByteArrayOutputStream keyStream = new ByteArrayOutputStream(512);
    7777        try {
    78             Destination dest = client.createDestination(keyStream);
     78            client.createDestination(keyStream);
    7979            ByteArrayInputStream in = new ByteArrayInputStream(keyStream.toByteArray());
    8080            return createManager(in, i2cpHost, i2cpPort, opts);
  • apps/ministreaming/java/src/net/i2p/client/streaming/StreamSinkClient.java

    r8a756a6 r20effe3  
    7272            return;
    7373        } finally {
    74             if (fis == null) try { fis.close(); } catch (IOException ioe) {}
     74            if (fis != null) try { fis.close(); } catch (IOException ioe) {}
    7575        }
    7676
  • apps/routerconsole/java/src/net/i2p/router/web/ReseedHandler.java

    r8a756a6 r20effe3  
    227227        /* Since we don't return a value, we should always throw an exception if something fails. */
    228228        private void fetchSeed(String seedURL, String peer) throws Exception {
    229             Log log = I2PAppContext.getGlobalContext().logManager().getLog(ReseedHandler.class);
    230229            URL url = new URL(seedURL + (seedURL.endsWith("/") ? "" : "/") + "routerInfo-" + peer + ".dat");
    231230
  • apps/routerconsole/java/src/net/i2p/router/web/SummaryListener.java

    r8a756a6 r20effe3  
    157157        long end = ctx.clock().now() - 60*1000;
    158158        long start = end - 60*1000*SummaryListener.PERIODS;
    159         long begin = System.currentTimeMillis();
    160159        try {
    161160            RrdGraphDefTemplate template = new RrdGraphDefTemplate(filename);
  • apps/streaming/java/src/net/i2p/client/streaming/ConnectionPacketHandler.java

    r8a756a6 r20effe3  
    262262        }
    263263
    264         if (packet != null)
    265             return adjustWindow(con, isNew, packet.getSequenceNum(), numResends, (acked != null ? acked.size() : 0), choke);
    266         else
    267             return adjustWindow(con, false, -1, numResends, (acked != null ? acked.size() : 0), choke);
     264        return adjustWindow(con, isNew, packet.getSequenceNum(), numResends, (acked != null ? acked.size() : 0), choke);
    268265    }
    269266   
  • apps/streaming/java/src/net/i2p/client/streaming/PacketLocal.java

    r8a756a6 r20effe3  
    178178            throw new IllegalStateException("Cannot wait for accept with no connection");
    179179        long before = _context.clock().now();
    180         long expiration = before+maxWaitMs;
    181180        int queued = _connection.getUnackedPacketsSent();
    182181        int window = _connection.getOptions().getWindowSize();
  • apps/streaming/java/src/net/i2p/client/streaming/SchedulerClosing.java

    r8a756a6 r20effe3  
    3535   
    3636    public boolean accept(Connection con) {
     37        if (con == null)
     38            return false;
    3739        long timeSinceClose = _context.clock().now() - con.getCloseSentOn();
    38         boolean ok = (con != null) &&
    39                      (!con.getResetSent()) &&
     40        boolean ok = (!con.getResetSent()) &&
    4041                     (!con.getResetReceived()) &&
    4142                     ( (con.getCloseSentOn() > 0) || (con.getCloseReceivedOn() > 0) ) &&
  • apps/susidns/src/java/src/i2p/susi/dns/AddressbookBean.java

    r8a756a6 r20effe3  
    8686                        return;
    8787               
     88                FileInputStream fis = null;
    8889                try {
    8990                        properties.clear();
    90                         properties.load( new FileInputStream( ConfigBean.configFileName ) );
     91                        fis = new FileInputStream( ConfigBean.configFileName );
     92                        properties.load( fis );
    9193                        // added in 0.5, for compatibility with 0.4 config.txt
    9294                        if( properties.getProperty(PRIVATE_BOOK) == null)
     
    9698                catch (Exception e) {
    9799                        Debug.debug( e.getClass().getName() + ": " + e.getMessage() );
     100                } finally {
     101                        if (fis != null)
     102                                try { fis.close(); } catch (IOException ioe) {}
    98103                }       
    99104        }
     
    144149               
    145150                String message = "";
    146                
     151                FileInputStream fis = null;
    147152                try {
    148                         addressbook.load( new FileInputStream( getFileName() ) );
     153                        fis =  new FileInputStream( getFileName() );
     154                        addressbook.load( fis );
    149155                        LinkedList list = new LinkedList();
    150156                        Enumeration e = addressbook.keys();
     
    183189                catch (Exception e) {
    184190                        Debug.debug( e.getClass().getName() + ": " + e.getMessage() );
    185                 }
    186                
     191                } finally {
     192                        if (fis != null)
     193                                try { fis.close(); } catch (IOException ioe) {}
     194                }
    187195                if( message.length() > 0 )
    188196                        message = "<p>" + message + "</p>";
     
    244252                String filename = properties.getProperty( getBook() + "_addressbook" );
    245253               
    246                 addressbook.store( new FileOutputStream( ConfigBean.addressbookPrefix + filename  ), null );
     254                FileOutputStream fos = new FileOutputStream( ConfigBean.addressbookPrefix + filename  );
     255                addressbook.store( fos, null );
     256                try {
     257                        fos.close();
     258                } catch (IOException ioe) {}
    247259        }
    248260        public String getFilter() {
  • apps/susidns/src/java/src/i2p/susi/dns/ConfigBean.java

    r8a756a6 r20effe3  
    3939         * as this is not provided as constant in addressbook, we define it here
    4040         */
    41         public static String addressbookPrefix = "addressbook/";
    42         public static String configFileName = addressbookPrefix + "config.txt";
     41        public static final String addressbookPrefix = "addressbook/";
     42        public static final String configFileName = addressbookPrefix + "config.txt";
    4343       
    4444        private String action, config;
     
    8181                if( file != null && file.isFile() ) {
    8282                        StringBuffer buf = new StringBuffer();
     83                        BufferedReader br = null;
    8384                        try {
    84                                 BufferedReader br = new BufferedReader( new FileReader( file ) );
     85                                br = new BufferedReader( new FileReader( file ) );
    8586                                String line;
    8687                                while( ( line = br.readLine() ) != null ) {
     
    9697                                // TODO Auto-generated catch block
    9798                                e.printStackTrace();
     99                        } finally {
     100                                if (br != null)
     101                                        try { br.close(); } catch (IOException ioe) {}
    98102                        }
    99103                }
  • apps/susidns/src/java/src/i2p/susi/dns/SubscriptionsBean.java

    r8a756a6 r20effe3  
    3838{
    3939        private String action, fileName, content, serial, lastSerial;
    40         private boolean saved;
    4140       
    4241        Properties properties;
     
    5453                        return;
    5554               
     55                FileInputStream fis = null;
    5656                try {
    5757                        properties.clear();
    58                         properties.load( new FileInputStream( ConfigBean.configFileName ) );
     58                        fis = new FileInputStream( ConfigBean.configFileName );
     59                        properties.load( fis );
    5960                        configLastLoaded = currentTime;
    6061                }
    6162                catch (Exception e) {
    6263                        Debug.debug( e.getClass().getName() + ": " + e.getMessage() );
     64                } finally {
     65                        if (fis != null)
     66                                try { fis.close(); } catch (IOException ioe) {}
    6367                }       
    6468        }
     
    8488                if( file != null && file.isFile() ) {
    8589                        StringBuffer buf = new StringBuffer();
     90                        BufferedReader br = null;
    8691                        try {
    87                                 BufferedReader br = new BufferedReader( new FileReader( file ) );
     92                                br = new BufferedReader( new FileReader( file ) );
    8893                                String line;
    8994                                while( ( line = br.readLine() ) != null ) {
     
    9297                                }
    9398                                content = buf.toString();
    94                                 saved = true;
    9599                        } catch (FileNotFoundException e) {
    96100                                // TODO Auto-generated catch block
     
    99103                                // TODO Auto-generated catch block
    100104                                e.printStackTrace();
     105                        } finally {
     106                                if (br != null)
     107                                        try { br.close(); } catch (IOException ioe) {}
    101108                        }
    102109                }
     
    111118                        out.flush();
    112119                        out.close();
    113                         saved = true;
    114120                } catch (FileNotFoundException e) {
    115121                        // TODO Auto-generated catch block
     
    149155        public void setContent(String content) {
    150156                this.content = content;
    151                 this.saved = false;
    152157               
    153158                /*
  • apps/susimail/src/src/i2p/susi/util/Config.java

    r8a756a6 r20effe3  
    2727
    2828import java.io.FileInputStream;
     29import java.io.IOException;
    2930import java.util.Properties;
    3031
     
    7980                        Debug.debug( Debug.DEBUG, "Could not open WEB-INF/classes/susimail.properties (possibly in jar), reason: " + e.getMessage() );
    8081                }
     82                FileInputStream fis = null;
    8183                try {
    82                         config.load( new FileInputStream( "susimail.config" ) );
     84                        fis = new FileInputStream( "susimail.config" );
     85                        config.load( fis );
    8386                } catch (Exception e) {
    8487                        Debug.debug( Debug.DEBUG, "Could not open susimail.config, reason: " + e.getMessage() );
     88                } finally {
     89                        if (fis != null)
     90                                try { fis.close(); } catch (IOException ioe) {}
    8591                }
    8692        }
  • apps/susimail/src/src/i2p/susi/webmail/MailCache.java

    r8a756a6 r20effe3  
    3737       
    3838        private POP3MailBox mailbox;
    39         private String error;
    4039        private Hashtable mails;
    4140        private Object synchronizer;
  • apps/susimail/src/src/i2p/susi/webmail/MailPart.java

    r8a756a6 r20effe3  
    7777                        e.printStackTrace();
    7878                }
     79                if (decodedHeaders == null)
     80                        return;
    7981                headerLines = new String( decodedHeaders.content, decodedHeaders.offset, decodedHeaders.length ).split( "\r\n" );
    8082
  • apps/susimail/src/src/i2p/susi/webmail/RequestWrapper.java

    r8a756a6 r20effe3  
    9898                                String[] partNames = multiPartRequest.getPartNames();
    9999                                for( int i = 0; i < partNames.length; i++ )
    100                                         cachedParameterNames.put( partNames[i], new Integer( i ) );
     100                                        cachedParameterNames.put( partNames[i], Integer.valueOf( i ) );
    101101                        }
    102102                        return cachedParameterNames.keys();
  • apps/susimail/src/src/i2p/susi/webmail/WebMail.java

    r8a756a6 r20effe3  
    557557        {
    558558                if( sessionObject.state == STATE_AUTH ) {
    559                         String login = request.getParameter( LOGIN );
    560559                        String user = request.getParameter( USER );
    561560                        String pass = request.getParameter( PASS );
     
    13311330                        }
    13321331                        if( content != null ) {
     1332                                ZipOutputStream zip = null;
    13331333                                try {
    1334                                         ZipOutputStream zip = new ZipOutputStream( response.getOutputStream() );
     1334                                        zip = new ZipOutputStream( response.getOutputStream() );
    13351335                                        String name;
    13361336                                        if( part.filename != null )
     
    13511351                                        // TODO Auto-generated catch block
    13521352                                        e.printStackTrace();
     1353                                } finally {
     1354                                        if ( zip != null)
     1355                                                try { zip.close(); } catch (IOException ioe) {}
    13531356                                }
    13541357                        }
  • apps/susimail/src/src/i2p/susi/webmail/encoding/EncodingFactory.java

    r8a756a6 r20effe3  
    3636public class EncodingFactory {
    3737       
    38         public static String CONFIG_ENCODING = "encodings";
     38        public static final String CONFIG_ENCODING = "encodings";
    3939       
    4040        private static Hashtable encodings = null;
  • apps/susimail/src/src/i2p/susi/webmail/pop3/POP3MailBox.java

    r8a756a6 r20effe3  
    103103                synchronized( synchronizer ) {
    104104                        Debug.debug(Debug.DEBUG, "getHeader(" + id + ")");
    105                         Integer idObj = new Integer(id);
     105                        Integer idObj = Integer.valueOf(id);
    106106                        ReadBuffer header = null;
    107107                        if (id >= 1 && id <= mails) {
     
    156156                synchronized( synchronizer ) {
    157157                        Debug.debug(Debug.DEBUG, "getBody(" + id + ")");
    158                         Integer idObj = new Integer(id);
     158                        Integer idObj = Integer.valueOf(id);
    159159                        ReadBuffer body = null;
    160160                        if (id >= 1 && id <= mails) {
     
    237237                         * find value in hashtable
    238238                         */
    239                         Integer resultObj = (Integer) sizes.get(new Integer(id));
     239                        Integer resultObj = (Integer) sizes.get(Integer.valueOf(id));
    240240                        if (resultObj != null)
    241241                                result = resultObj.intValue();
     
    278278                        readBuffer = sendCmdNa( "UIDL", DEFAULT_BUFSIZE );
    279279                        if( readBuffer != null ) {
    280                                 String[] lines = new String( readBuffer.toString() ).split( "\r\n" );
     280                                String[] lines = readBuffer.toString().split( "\r\n" );
    281281                               
    282282                                for( int i = 0; i < lines.length; i++ ) {
     
    286286                                                        int n = Integer.parseInt( lines[i].substring( 0, j ) );
    287287                                                        String uidl = lines[i].substring( j+1 );
    288                                                         uidlToID.put( uidl, new Integer( n ) );
     288                                                        uidlToID.put( uidl, Integer.valueOf( n ) );
    289289                                                        uidlList.add( n-1, uidl );
    290290                                                }
     
    320320                                                int key = Integer.parseInt(lines[i].substring(0, j));
    321321                                                int value =     Integer.parseInt(lines[i].substring(j + 1));
    322                                                 sizes.put(new Integer(key), new Integer(value));
     322                                                sizes.put(Integer.valueOf(key), Integer.valueOf(value));
    323323                                        }
    324324                                }
     
    390390                                }
    391391                                else {
    392                                         lastError = new String( lastLine );
     392                                        lastError = lastLine;
    393393                                        close();
    394394                                }
  • apps/systray/java/src/net/i2p/apps/systray/ConfigFile.java

    r8a756a6 r20effe3  
    5555
    5656        FileInputStream fileInputStream = null;
    57 
     57        boolean rv = true;
    5858        try {
    5959            fileInputStream = new FileInputStream(_configFile);
    6060            _properties.load(fileInputStream);
    6161        } catch (Exception e) {
    62             return false;
     62            rv = false;
    6363        }
    6464        try {
     
    6767            // No worries.
    6868        }
    69         return true;
     69        return rv;
    7070    }
    7171
     
    7373
    7474        FileOutputStream fileOutputStream = null;
    75 
     75        boolean rv = true;
    7676        try {
    7777            fileOutputStream = new FileOutputStream(_configFile);
    7878            _properties.store(fileOutputStream, null);
    7979        } catch (Exception e) {
    80             return false;
     80            rv = false;
    8181        }
    8282        try {
     
    8585            // No worries.
    8686        }
    87         return true;
     87        return rv;
    8888    }
    8989}
  • apps/systray/java/src/net/i2p/apps/systray/UrlLauncher.java

    r8a756a6 r20effe3  
    8686                } catch (Exception e) {
    8787                    // Defaults to IE.
     88                } finally {
     89                    if (bufferedReader != null)
     90                        try { bufferedReader.close(); } catch (IOException ioe) {}
    8891                }
    89 
    9092                if (_shellCommand.executeSilentAndWaitTimed(browserString + " " + url, 5))
    9193                    return true;
  • core/java/src/freenet/support/CPUInformation/CPUID.java

    r8a756a6 r20effe3  
    165165    }
    166166    protected static class VIAC3Impl extends CPUIDCPUInfo implements CPUInfo {
    167         public boolean isC3Compatible() { return true; }
     167        public boolean IsC3Compatible() { return true; }
    168168        public String getCPUModelString() { return "VIA C3"; }
    169169    }
  • core/java/src/gnu/crypto/prng/AsyncFortunaStandalone.java

    r8a756a6 r20effe3  
    151151          }
    152152        generator.nextBytes(buf);
    153         long now = System.currentTimeMillis();
    154         long diff = now-lastRefill;
    155         lastRefill = now;
    156         long refillTime = now-start;
     153        //long now = System.currentTimeMillis();
     154        //long diff = now-lastRefill;
     155        //lastRefill = now;
     156        //long refillTime = now-start;
    157157        //System.out.println("Refilling " + (++refillCount) + " after " + diff + " for the PRNG took " + refillTime);
    158158    }
  • core/java/src/net/i2p/client/I2PClientImpl.java

    r8a756a6 r20effe3  
    4949        Destination d = new Destination();
    5050        d.setCertificate(cert);
    51         PublicKey publicKey = new PublicKey();
    5251        Object keypair[] = KeyGenerator.getInstance().generatePKIKeypair();
    53         publicKey = (PublicKey) keypair[0];
     52        PublicKey publicKey = (PublicKey) keypair[0];
    5453        PrivateKey privateKey = (PrivateKey) keypair[1];
    5554        Object signingKeys[] = KeyGenerator.getInstance().generateSigningKeypair();
  • core/java/src/net/i2p/client/I2PSessionImpl.java

    r8a756a6 r20effe3  
    409409            synchronized (AvailabilityNotifier.this) {
    410410                _pendingIds.add(new Long(msgId));
    411                 _pendingSizes.add(new Integer(size));
     411                _pendingSizes.add(Integer.valueOf(size));
    412412                AvailabilityNotifier.this.notifyAll();
    413413            }
  • core/java/src/net/i2p/client/I2PSessionImpl2.java

    r8a756a6 r20effe3  
    221221            state.waitFor(MessageStatusMessage.STATUS_SEND_ACCEPTED,
    222222                          _context.clock().now() + getTimeout());
    223         long afterWaitFor = _context.clock().now();
    224         long inRemovingSync = 0;
     223        //long afterWaitFor = _context.clock().now();
     224        //long inRemovingSync = 0;
    225225        synchronized (_sendingStates) {
    226             inRemovingSync = _context.clock().now();
     226            //inRemovingSync = _context.clock().now();
    227227            _sendingStates.remove(state);
    228228        }
  • core/java/src/net/i2p/client/MessagePayloadMessageHandler.java

    r8a756a6 r20effe3  
    3636            MessagePayloadMessage msg = (MessagePayloadMessage) message;
    3737            long id = msg.getMessageId();
    38             Payload payload = decryptPayload(msg, session);
     38            decryptPayload(msg, session);
    3939            session.addNewMessage(msg);
    4040
  • core/java/src/net/i2p/client/MessageState.java

    r8a756a6 r20effe3  
    5151    public void receive(int status) {
    5252        synchronized (_receivedStatus) {
    53             _receivedStatus.add(new Integer(status));
     53            _receivedStatus.add(Integer.valueOf(status));
    5454            _receivedStatus.notifyAll();
    5555        }
  • core/java/src/net/i2p/crypto/ElGamalAESEngine.java

    r8a756a6 r20effe3  
    449449        System.arraycopy(aesEncr, 0, rv, elgEncr.length, aesEncr.length);
    450450        //_log.debug("Return length: " + rv.length);
    451         long finish = _context.clock().now();
     451        //long finish = _context.clock().now();
    452452        //if (_log.shouldLog(Log.DEBUG))
    453453        //    _log.debug("after the elgEngine.encrypt took a total of " + (finish - after) + "ms");
  • core/java/src/net/i2p/crypto/ElGamalEngine.java

    r8a756a6 r20effe3  
    103103        System.arraycopy(data, 0, d2, 1+Hash.HASH_LENGTH, data.length);
    104104       
    105         long t0 = _context.clock().now();
     105        //long t0 = _context.clock().now();
    106106        BigInteger m = new NativeBigInteger(1, d2);
    107         long t1 = _context.clock().now();
     107        //long t1 = _context.clock().now();
    108108        if (m.compareTo(CryptoConstants.elgp) >= 0)
    109109            throw new IllegalArgumentException("ARGH.  Data cannot be larger than the ElGamal prime.  FIXME");
    110         long t2 = _context.clock().now();
     110        //long t2 = _context.clock().now();
    111111        BigInteger aalpha = new NativeBigInteger(1, publicKey.getData());
    112         long t3 = _context.clock().now();
     112        //long t3 = _context.clock().now();
    113113        BigInteger yk[] = getNextYK();
    114114        BigInteger k = yk[1];
    115115        BigInteger y = yk[0];
    116116
    117         long t7 = _context.clock().now();
     117        //long t7 = _context.clock().now();
    118118        BigInteger d = aalpha.modPow(k, CryptoConstants.elgp);
    119         long t8 = _context.clock().now();
     119        //long t8 = _context.clock().now();
    120120        d = d.multiply(m);
    121         long t9 = _context.clock().now();
     121        //long t9 = _context.clock().now();
    122122        d = d.mod(CryptoConstants.elgp);
    123         long t10 = _context.clock().now();
     123        //long t10 = _context.clock().now();
    124124
    125125        byte[] ybytes = y.toByteArray();
  • core/java/src/net/i2p/data/Base64.java

    r8a756a6 r20effe3  
    4848    }
    4949    public static String encode(byte[] source) {
    50         return (source != null ? encode(source, 0, (source != null ? source.length : 0)) : "");
     50        return (source != null ? encode(source, 0, source.length) : "");
    5151    }
    5252    public static String encode(byte[] source, int off, int len) {
     
    5454    }
    5555    public static String encode(byte[] source, boolean useStandardAlphabet) {
    56         return (source != null ? encode(source, 0, (source != null ? source.length : 0), useStandardAlphabet) : "");
     56        return (source != null ? encode(source, 0, source.length, useStandardAlphabet) : "");
    5757    }
    5858    public static String encode(byte[] source, int off, int len, boolean useStandardAlphabet) {
     
    242242     * @since 1.3
    243243     */
     244/***** unused
    244245    private static byte[] encode3to4(byte[] threeBytes) {
    245246        return encode3to4(threeBytes, 3);
    246247    } // end encodeToBytes
     248******/
    247249
    248250    /**
     
    380382     * @since 1.4
    381383     */
     384/***** unused
    382385    private static String encodeBytes(byte[] source) {
    383386        return encodeBytes(source, false); // don't add newlines
    384387    } // end encodeBytes
     388******/
    385389
    386390    /**
     
    436440     * @since 1.4
    437441     */
     442/***** unused
    438443    private static String encodeBytes(byte[] source, int off, int len) {
    439444        return encodeBytes(source, off, len, true);
    440445    } // end encodeBytes
     446******/
    441447
    442448    private static String encodeBytes(byte[] source, int off, int len, boolean breakLines) {
     
    456462     */
    457463    private static void encodeBytes(byte[] source, int off, int len, boolean breakLines, StringBuffer out, byte alpha[]) {
    458         int len43 = len * 4 / 3;
     464        //int len43 = len * 4 / 3;
    459465        //byte[] outBuff = new byte[(len43) // Main 4:3
    460466        //                          + ((len % 3) > 0 ? 4 : 0) // Account for padding
     
    495501     * @since 1.3
    496502     */
     503/***** unused
    497504    private static String encodeString(String s) {
    498505        return encodeString(s, true);
    499506    } // end encodeString
     507******/
    500508
    501509    /**
     
    526534     * @since 1.3
    527535     */
     536/***** unused
    528537    private static byte[] decode4to3(byte[] fourBytes) {
    529538        byte[] outBuff1 = new byte[3];
     
    536545        return outBuff2;
    537546    }
     547******/
    538548
    539549    /**
  • core/java/src/net/i2p/data/DataHelper.java

    r8a756a6 r20effe3  
    672672    public final static byte[] xor(byte lhs[], byte rhs[]) {
    673673        if ((lhs == null) || (rhs == null) || (lhs.length != rhs.length)) return null;
    674         byte rv[] = new byte[lhs.length];
    675        
    676674        byte diff[] = new byte[lhs.length];
    677675        xor(lhs, 0, rhs, 0, diff, 0, lhs.length);
     
    822820            tm.put(struct.calculateHash().toString(), struct);
    823821        }
    824         for (Iterator iter = tm.keySet().iterator(); iter.hasNext();) {
    825             Object k = iter.next();
    826             rv.add(tm.get(k));
     822        for (Iterator iter = tm.values().iterator(); iter.hasNext();) {
     823            rv.add(iter.next());
    827824        }
    828825        return rv;
  • core/java/src/net/i2p/data/LeaseSet.java

    r8a756a6 r20effe3  
    225225
    226226    private byte[] getBytes() {
     227        if ((_destination == null) || (_encryptionKey == null) || (_signingKey == null) || (_leases == null))
     228            return null;
    227229        int len = PublicKey.KEYSIZE_BYTES  // dest
    228230                + SigningPublicKey.KEYSIZE_BYTES // dest
     
    234236        ByteArrayOutputStream out = new ByteArrayOutputStream(len);
    235237        try {
    236             if ((_destination == null) || (_encryptionKey == null) || (_signingKey == null) || (_leases == null))
    237                 return null;
    238 
    239238            _destination.writeBytes(out);
    240239            _encryptionKey.writeBytes(out);
  • core/java/src/net/i2p/stat/Frequency.java

    r8a756a6 r20effe3  
    7777            if ((duration <= 0) || (_count <= 0)) return 0;
    7878           
    79             return duration / _count;
     79            return duration / (double) _count;
    8080        }
    8181    }
  • core/java/src/net/i2p/time/NtpClient.java

    r8a756a6 r20effe3  
    114114            NtpMessage msg = new NtpMessage(packet.getData());
    115115
    116             double roundTripDelay = (destinationTimestamp-msg.originateTimestamp) -
    117                                     (msg.receiveTimestamp-msg.transmitTimestamp);
     116            //double roundTripDelay = (destinationTimestamp-msg.originateTimestamp) -
     117            //                        (msg.receiveTimestamp-msg.transmitTimestamp);
    118118            double localClockOffset = ((msg.receiveTimestamp - msg.originateTimestamp) +
    119119                                       (msg.transmitTimestamp - destinationTimestamp)) / 2;
  • core/java/src/net/i2p/util/ByteCache.java

    r8a756a6 r20effe3  
    2525     */
    2626    public static ByteCache getInstance(int cacheSize, int size) {
    27         Integer sz = new Integer(size);
     27        Integer sz = Integer.valueOf(size);
    2828        ByteCache cache = null;
    2929        synchronized (_caches) {
  • core/java/src/net/i2p/util/EepGet.java

    r8a756a6 r20effe3  
    509509                    if ( (_actualURL.indexOf('?') < 0) && (query.length() > 0) )
    510510                        _actualURL = _actualURL + "?" + query;
    511                     else
    512                         _actualURL = _actualURL;
    513511                }
    514512            } catch (MalformedURLException mue) {
     
    773771            return -1;
    774772        }
    775         String protocol = tok.nextToken(); // ignored
     773        tok.nextToken(); // ignored (protocol)
    776774        if (!tok.hasMoreTokens()) {
    777775            if (_log.shouldLog(Log.WARN))
     
    875873        timeout.setSocket(_proxy);
    876874       
    877         _proxyOut.write(DataHelper.getUTF8(req.toString()));
     875        _proxyOut.write(DataHelper.getUTF8(req));
    878876        _proxyOut.flush();
    879877       
  • core/java/src/net/i2p/util/EepPost.java

    r8a756a6 r20effe3  
    163163   
    164164    private void sendFile(OutputStream out, String separator, String field, File file) throws IOException {
    165         long len = file.length();
     165        //long len = file.length();
    166166        out.write(("--" + separator + CRLF).getBytes());
    167167        out.write(("Content-Disposition: form-data; name=\"" + field + "\"; filename=\"" + file.getName() + "\"" + CRLF).getBytes());
  • history.txt

    r8a756a6 r20effe3  
     12008-10-20 zzz
     2    * configclients.jsp: Handle clients with no args
     3    * index.jsp: Add readme_nl.html (thanks mathiasdm!),
     4      readme_sv.html (thanks hottuna!)
     5    * Big findbugs cleanup
     6    * Client: Prevent a race causing session reconnect
     7    * FloodfillMonitor:
     8       - Don't become ff if clock skew is high
     9       - Rebuild routerinfo immediately when ff status changes
     10    * FloodOnlySearchJob: Recover better if the floodfills
     11      you know are no longer floodfill or are gone
     12    * Installer: Bump min JRE to 1.5
     13    * ShellCommand: Fix main()
     14
    1152008-10-14 zzz
    216    * index.jsp: Add multilanguage support for readme.html;
  • router/java/src/net/i2p/data/i2np/I2NPMessageHandler.java

    r8a756a6 r20effe3  
    8787     */
    8888    public I2NPMessage readMessage(byte data[]) throws IOException, I2NPMessageException {
    89         int offset = readMessage(data, 0);
     89        readMessage(data, 0);
    9090        return lastRead();
    9191    }
  • router/java/src/net/i2p/data/i2np/I2NPMessageImpl.java

    r8a756a6 r20effe3  
    4242    /** unsynchronized as its pretty much read only (except at startup) */
    4343    private static final Map _builders = new HashMap(8);
    44     public static final void registerBuilder(Builder builder, int type) { _builders.put(new Integer(type), builder); }
     44    public static final void registerBuilder(Builder builder, int type) { _builders.put(Integer.valueOf(type), builder); }
    4545    /** interface for extending the types of messages handled */
    4646    public interface Builder {
     
    104104                _log.debug("Reading bytes: type = " + type + " / uniqueId : " + _uniqueId + " / expiration : " + _expiration);
    105105            readMessage(buffer, 0, size, type);
    106             long time = _context.clock().now() - start;
     106            //long time = _context.clock().now() - start;
    107107            //if (time > 50)
    108108            //    _context.statManager().addRateData("i2np.readTime", time, time);
     
    149149        readMessage(data, cur, size, type);
    150150        cur += size;
    151         long time = _context.clock().now() - start;
     151        //long time = _context.clock().now() - start;
    152152        //if (time > 50)
    153153        //    _context.statManager().addRateData("i2np.readTime", time, time);
     
    229229            System.arraycopy(h.getData(), 0, buffer, off, CHECKSUM_LENGTH);
    230230
    231             long time = _context.clock().now() - start;
     231            //long time = _context.clock().now() - start;
    232232            //if (time > 50)
    233233            //    _context.statManager().addRateData("i2np.writeTime", time, time);
     
    371371                return new TunnelBuildReplyMessage(context);
    372372            default:
    373                 Builder builder = (Builder)_builders.get(new Integer(type));
     373                Builder builder = (Builder)_builders.get(Integer.valueOf(type));
    374374                if (builder == null)
    375375                    return null;
  • router/java/src/net/i2p/data/i2np/TunnelGatewayMessage.java

    r8a756a6 r20effe3  
    9696            throw new I2NPMessageException("Invalid tunnel Id " + _tunnelId);
    9797       
    98         int size = (int)DataHelper.fromLong(data, curIndex, 2);
     98        DataHelper.fromLong(data, curIndex, 2);
    9999        curIndex += 2;
    100100        curIndex = handler.readMessage(data, curIndex);
  • router/java/src/net/i2p/router/InNetMessagePool.java

    r8a756a6 r20effe3  
    210210                        if (_log.shouldLog(Log.WARN))
    211211                            _log.warn("Message expiring on "
    212                                       + (messageBody != null ? (messageBody.getMessageExpiration()+"") : " [unknown]")
     212                                      + messageBody.getMessageExpiration()
    213213                                      + " was not handled by a HandlerJobBuilder - DROPPING: " + messageBody,
    214214                                      new Exception("f00!"));
  • router/java/src/net/i2p/router/JobQueue.java

    r8a756a6 r20effe3  
    370370                for (int i = _queueRunners.size(); i < numThreads; i++) {
    371371                    JobQueueRunner runner = new JobQueueRunner(_context, i);
    372                     _queueRunners.put(new Integer(i), runner);
     372                    _queueRunners.put(Integer.valueOf(i), runner);
    373373                    Thread t = new I2PThread(runner);
    374374                    t.setName("JobQueue"+(_runnerId++));
     
    391391    }
    392392       
    393     void removeRunner(int id) { _queueRunners.remove(new Integer(id)); }
     393    void removeRunner(int id) { _queueRunners.remove(Integer.valueOf(id)); }
    394394   
    395395    /**
  • router/java/src/net/i2p/router/Router.java

    r8a756a6 r20effe3  
    290290        }
    291291        Properties props = new Properties();
    292         FileInputStream fis = null;
    293292        try {
    294293            File f = new File(filename);
     
    304303            if (log != null)
    305304                log.error("Error loading the router configuration from " + filename, ioe);
    306         } finally {
    307             if (fis != null) try { fis.close(); } catch (IOException ioe) {}
    308305        }
    309306        return props;
  • router/java/src/net/i2p/router/RouterVersion.java

    r8a756a6 r20effe3  
    1818    public final static String ID = "$Revision: 1.548 $ $Date: 2008-06-07 23:00:00 $";
    1919    public final static String VERSION = "0.6.4";
    20     public final static long BUILD = 5;
     20    public final static long BUILD = 6;
    2121    public static void main(String args[]) {
    2222        System.out.println("I2P Router version: " + VERSION + "-" + BUILD);
  • router/java/src/net/i2p/router/RouterWatchdog.java

    r8a756a6 r20effe3  
    5353    private void dumpStatus() {
    5454        if (_log.shouldLog(Log.ERROR)) {
     55            /*
    5556            Job cur = _context.jobQueue().getLastJob();
    56             /*
    5757            if (cur != null)
    5858                _log.error("Most recent job: " + cur);
  • router/java/src/net/i2p/router/StatisticsManager.java

    r8a756a6 r20effe3  
    215215    }
    216216   
    217     private void includeRate(String rateName, Properties stats) {
    218         includeRate(rateName, stats, null);
    219     }
    220217    private void includeRate(String rateName, Properties stats, long selectedPeriods[]) {
    221218        includeRate(rateName, stats, selectedPeriods, false);
     
    273270            if (numPeriods > 0) {
    274271                double avgFrequency = rate.getLifetimeEventCount() / (double)numPeriods;
    275                 double peakFrequency = rate.getExtremeEventCount();
    276272                buf.append(num(avgFrequency)).append(';');
    277273                buf.append(num(rate.getExtremeEventCount())).append(';');
  • router/java/src/net/i2p/router/SubmitMessageHistoryJob.java

    r8a756a6 r20effe3  
    8585            }
    8686            long size = dataFile.length();
    87             int expectedSend = 512; // 512 for HTTP overhead
    88             if (size > 0)
    89                 expectedSend += (int)size/10; // compression
    9087            FileInputStream fin = new FileInputStream(dataFile);
    9188            BandwidthLimitedInputStream in = new BandwidthLimitedInputStream(getContext(), fin, null, true);
  • router/java/src/net/i2p/router/message/GarlicMessageParser.java

    r8a756a6 r20effe3  
    6262   
    6363    private CloveSet readCloveSet(byte data[]) throws DataFormatException {
    64         Set cloves = new HashSet();
    6564        int offset = 0;
    6665       
  • router/java/src/net/i2p/router/networkdb/kademlia/ExpireRoutersJob.java

    r8a756a6 r20effe3  
    7070        Set possible = getNotInUse();
    7171        Set expiring = new HashSet(16);
    72         long earliestPublishDate = getContext().clock().now() - EXPIRE_DELAY;
    7372       
    7473        for (Iterator iter = possible.iterator(); iter.hasNext(); ) {
  • router/java/src/net/i2p/router/networkdb/kademlia/KBucketImpl.java

    r8a756a6 r20effe3  
    5959        _local.prepareCache();
    6060        if (_log.shouldLog(Log.DEBUG))
    61             _log.debug("Local hash reset to " + (local == null ? "null" : DataHelper.toHexString(local.getData())));
     61            _log.debug("Local hash reset to " + DataHelper.toHexString(local.getData()));
    6262    }
    6363   
  • router/java/src/net/i2p/router/networkdb/kademlia/KademliaNetworkDatabaseFacade.java

    r8a756a6 r20effe3  
    778778       
    779779        if (o == null) {
    780             boolean removed = _kb.remove(dbEntry);
     780            _kb.remove(dbEntry);
    781781            _context.peerManager().removeCapabilities(dbEntry);
    782782            // if we dont know the key, lets make sure it isn't a now-dead peer
     
    10551055                    Integer val = (Integer)routerVersions.get(routerVersion);
    10561056                    if (val == null)
    1057                         routerVersions.put(routerVersion, new Integer(1));
     1057                        routerVersions.put(routerVersion, Integer.valueOf(1));
    10581058                    else
    1059                         routerVersions.put(routerVersion, new Integer(val.intValue() + 1));
     1059                        routerVersions.put(routerVersion, Integer.valueOf(val.intValue() + 1));
    10601060                }
    10611061            }
  • router/java/src/net/i2p/router/networkdb/kademlia/SearchJob.java

    r8a756a6 r20effe3  
    285285                        if (_log.shouldLog(Log.WARN))
    286286                            _log.warn(getJobId() + ": Error selecting closest hash that wasnt a router! "
    287                                       + peer + " : " + (ds == null ? "null" : ds.getClass().getName()));
     287                                      + peer + " : " + ds.getClass().getName());
    288288                        _state.replyTimeout(peer);
    289289                    } else {
     
    376376        getContext().statManager().addRateData("netDb.searchMessageCount", 1, 0);
    377377
    378         if (_isLease || true) // always send searches out tunnels
     378        //if (_isLease || true) // always send searches out tunnels
    379379            sendLeaseSearch(router);
    380         else
    381             sendRouterSearch(router);
     380        //else
     381        //    sendRouterSearch(router);
    382382    }
    383383   
  • router/java/src/net/i2p/router/networkdb/kademlia/StoreJob.java

    r8a756a6 r20effe3  
    309309        }
    310310        TunnelId replyTunnelId = replyTunnel.getReceiveTunnelId(0);
    311         if (replyTunnel == null) {
    312             _log.warn("No reply inbound tunnels available!");
    313             return;
    314         }
    315311        msg.setReplyToken(token);
    316312        msg.setReplyTunnel(replyTunnelId);
  • router/java/src/net/i2p/router/peermanager/ReliabilityCalculator.java

    r8a756a6 r20effe3  
    6868        val -= profile.getCommError().getRate(24*60*60*1000).getCurrentEventCount() * 1;
    6969       
    70         long now = _context.clock().now();
     70        //long now = _context.clock().now();
    7171       
    7272        long timeSinceRejection = 61*60*1000; // now - profile.getTunnelHistory().getLastRejected();
  • router/java/src/net/i2p/router/startup/CreateRouterInfoJob.java

    r8a756a6 r20effe3  
    4242        _log.debug("Creating the new router info");
    4343        // create a new router info and store it where LoadRouterInfoJob looks
    44         RouterInfo info = createRouterInfo();
     44        createRouterInfo();
    4545        getContext().jobQueue().addJob(_next);
    4646    }
  • router/java/src/net/i2p/router/transport/OutboundMessageRegistry.java

    r8a756a6 r20effe3  
    6464        ArrayList matchedSelectors = null;
    6565        ArrayList removedSelectors = null;
    66         long beforeSync = _context.clock().now();
    6766        synchronized (_selectors) {
    6867            for (int i = 0; i < _selectors.size(); i++) {
  • router/java/src/net/i2p/router/transport/udp/EstablishmentManager.java

    r8a756a6 r20effe3  
    169169                    List queued = (List)_queuedOutbound.get(to);
    170170                    if (queued == null) {
     171                        queued = new ArrayList(1);
    171172                        if (_queuedOutbound.size() > MAX_QUEUED_OUTBOUND) {
    172173                            rejected = true;
    173174                        } else {
    174                             queued = new ArrayList(1);
    175175                            _queuedOutbound.put(to, queued);
    176176                        }
     
    337337    PeerState receiveData(OutboundEstablishState state) {
    338338        state.dataReceived();
    339         int active = 0;
    340         int admitted = 0;
    341         int remaining = 0;
     339        //int active = 0;
     340        //int admitted = 0;
     341        //int remaining = 0;
    342342        synchronized (_outboundStates) {
    343             active = _outboundStates.size();
     343            //active = _outboundStates.size();
    344344            _outboundStates.remove(state.getRemoteHostId());
    345345            if (_queuedOutbound.size() > 0) {
     
    351351                }
    352352               
    353                 admitted = locked_admitQueued();
    354             }
    355             remaining = _queuedOutbound.size();
     353                //admitted = locked_admitQueued();
     354            }
     355            //remaining = _queuedOutbound.size();
    356356        }
    357357        //if (admitted > 0)
     
    599599
    600600    private void sendRequest(OutboundEstablishState state) {
    601         long now = _context.clock().now();
    602601        if (_log.shouldLog(Log.DEBUG))
    603602            _log.debug("Send request to: " + state.getRemoteHostId().toString());
     
    704703   
    705704    private void sendConfirmation(OutboundEstablishState state) {
    706         long now = _context.clock().now();
    707705        boolean valid = state.validateSessionCreated();
    708706        if (!valid) // validate clears fields on failure
     
    842840        long nextSendTime = -1;
    843841        OutboundEstablishState outboundState = null;
    844         int admitted = 0;
    845         int remaining = 0;
    846         int active = 0;
     842        //int admitted = 0;
     843        //int remaining = 0;
     844        //int active = 0;
    847845        synchronized (_outboundStates) {
    848             active = _outboundStates.size();
     846            //active = _outboundStates.size();
    849847            //if (_log.shouldLog(Log.DEBUG))
    850848            //    _log.debug("# outbound states: " + _outboundStates.size());
     
    892890            }
    893891           
    894             admitted = locked_admitQueued();   
    895             remaining = _queuedOutbound.size();
     892            //admitted = locked_admitQueued();   
     893            //remaining = _queuedOutbound.size();
    896894        }
    897895
  • router/java/src/net/i2p/router/transport/udp/PeerState.java

    r8a756a6 r20effe3  
    904904    /** we are resending a packet, so lets jack up the rto */
    905905    public void messageRetransmitted(int packets) {
    906         long now = _context.clock().now();
    907         if (true || _retransmissionPeriodStart + 1000 <= now) {
     906        //long now = _context.clock().now();
     907        //if (true || _retransmissionPeriodStart + 1000 <= now) {
    908908            _packetsRetransmitted += packets;
     909        /*****
    909910        } else {
    910911            _packetRetransmissionRate = (int)((float)(0.9f*_packetRetransmissionRate) + (float)(0.1f*_packetsRetransmitted));
     
    914915            _packetsRetransmitted = packets;
    915916        }
     917        *****/
    916918        congestionOccurred();
    917919        _context.statManager().addRateData("udp.congestedRTO", _rto, _rttDeviation);
     
    920922    }
    921923    public void packetsTransmitted(int packets) {
    922         long now = _context.clock().now();
     924        //long now = _context.clock().now();
    923925        _packetsTransmitted += packets;
    924926        //_packetsPeriodTransmitted += packets;
     927        /*****
    925928        if (false && _retransmissionPeriodStart + 1000 <= now) {
    926929            _packetRetransmissionRate = (int)((float)(0.9f*_packetRetransmissionRate) + (float)(0.1f*_packetsRetransmitted));
     
    929932            _packetsRetransmitted = 0;
    930933        }
     934        *****/
    931935    }
    932936    /** how long does it usually take to get a message ACKed? */
  • router/java/src/net/i2p/router/transport/udp/UDPReceiver.java

    r8a756a6 r20effe3  
    3535        _context = ctx;
    3636        _log = ctx.logManager().getLog(UDPReceiver.class);
    37         _id = ++_id;
     37        _id++;
    3838        _name = name;
    3939        _inboundQueue = new ArrayList(128);
  • router/java/src/net/i2p/router/transport/udp/UDPSender.java

    r8a756a6 r20effe3  
    102102     */
    103103    public int add(UDPPacket packet, int blockTime) {
    104         long expiration = _context.clock().now() + blockTime;
     104        //long expiration = _context.clock().now() + blockTime;
    105105        int remaining = -1;
    106106        long lifetime = -1;
     
    108108        int removed = 0;
    109109        while ( (_keepRunning) && (remaining < 0) ) {
    110             try {
     110            //try {
    111111                synchronized (_outboundQueue) {
    112112                    // clear out any too-old packets
     
    124124                    }
    125125                   
    126                     if (true || (_outboundQueue.size() < MAX_QUEUED)) {
     126                    //if (true || (_outboundQueue.size() < MAX_QUEUED)) {
    127127                        lifetime = packet.getLifetime();
    128128                        _outboundQueue.add(packet);
     
    130130                        remaining = _outboundQueue.size();
    131131                        _outboundQueue.notifyAll();
     132                    /*****
    132133                    } else {
    133134                        long remainingTime = expiration - _context.clock().now();
     
    140141                        lifetime = packet.getLifetime();
    141142                    }
    142                 }
    143             } catch (InterruptedException ie) {}
     143                    *****/
     144                }
     145            //} catch (InterruptedException ie) {}
    144146        }
    145147        _context.statManager().addRateData("udp.sendQueueSize", remaining, lifetime);
  • router/java/src/net/i2p/router/tunnel/BuildMessageGenerator.java

    r8a756a6 r20effe3  
    2424    // cached, rather than creating lots of temporary Integer objects whenever we build a tunnel
    2525    public static final Integer ORDER[] = new Integer[TunnelBuildMessage.RECORD_COUNT];
    26     static { for (int i = 0; i < ORDER.length; i++) ORDER[i] = new Integer(i); }
     26    static { for (int i = 0; i < ORDER.length; i++) ORDER[i] = Integer.valueOf(i); }
    2727   
    2828    /** return null if it is unable to find a router's public key (etc) */
  • router/java/src/net/i2p/router/tunnel/FragmentHandler.java

    r8a756a6 r20effe3  
    363363   
    364364    private void receiveComplete(FragmentedMessage msg) {
     365        if (msg == null)
     366            return;
    365367        _completed++;
    366368        String stringified = null;
     
    371373            // toByteArray destroys the contents of the message completely
    372374            byte data[] = msg.toByteArray();
    373             if (msg == null)
    374                 return;
    375375            if (_log.shouldLog(Log.DEBUG))
    376376                _log.debug("RECV(" + data.length + "): " + Base64.encode(data) 
  • router/java/src/net/i2p/router/tunnel/InboundEndpointProcessor.java

    r8a756a6 r20effe3  
    7878        if (_context instanceof RouterContext)
    7979            ctx = (RouterContext)_context;
    80         if ( (ctx != null) && (_config != null) && (_config.getLength() > 0) ) {
     80        if ( (ctx != null) && (_config.getLength() > 0) ) {
    8181            int rtt = 0; // dunno... may not be related to an rtt
    8282            if (_log.shouldLog(Log.DEBUG))
  • router/java/src/net/i2p/router/tunnel/PumpedTunnelGateway.java

    r8a756a6 r20effe3  
    6161    public void add(I2NPMessage msg, Hash toRouter, TunnelId toTunnel) {
    6262        _messagesSent++;
    63         long startAdd = System.currentTimeMillis();
    6463        Pending cur = new PendingImpl(msg, toRouter, toTunnel);
    6564        long beforeLock = System.currentTimeMillis();
    66         long afterAdded = -1;
    6765        synchronized (_prequeue) {
    6866            _prequeue.add(cur);
    69             afterAdded = System.currentTimeMillis();
    7067        }
    7168        _pumper.wantsPumping(this);
  • router/java/src/net/i2p/router/tunnel/TunnelDispatcher.java

    r8a756a6 r20effe3  
    511511                               + msg, new Exception("cause"));
    512512            }
    513             long tid1 = (outboundTunnel != null ? outboundTunnel.getTunnelId() : -1);
     513            long tid1 = outboundTunnel.getTunnelId();
    514514            long tid2 = (targetTunnel != null ? targetTunnel.getTunnelId() : -1);
    515515            _context.messageHistory().tunnelDispatched(msg.getUniqueId(), tid1, tid2, targetPeer, "outbound gateway");
  • router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java

    r8a756a6 r20effe3  
    246246            for (int i = 0; i < cfg.getLength(); i++) {
    247247                Hash peer = cfg.getPeer(i);
    248                 int record = order.indexOf(new Integer(i));
     248                int record = order.indexOf(Integer.valueOf(i));
    249249                if (record < 0) {
    250250                    _log.error("Bad status index " + i);
     
    484484        long recvDelay = System.currentTimeMillis()-state.recvTime;
    485485        if (response == 0) {
    486             float pDrop = recvDelay / (BuildRequestor.REQUEST_TIMEOUT*3);
     486            float pDrop = ((float) recvDelay) / (float) (BuildRequestor.REQUEST_TIMEOUT*3);
    487487            pDrop = (float)Math.pow(pDrop, 16);
    488488            if (_context.random().nextFloat() < pDrop) { // || (proactiveDrops > MAX_PROACTIVE_DROPS) ) ) {
     
    649649                           null);//new Exception("source"));
    650650            if (cfg != null) {
    651                 BuildEndMessageState state = new BuildEndMessageState(cfg, receivedMessage, from, fromHash);
     651                BuildEndMessageState state = new BuildEndMessageState(cfg, receivedMessage);
    652652                if (HANDLE_REPLIES_INLINE) {
    653653                    handleRequestAsInboundEndpoint(state);
     
    738738                           + (fromHash != null ? fromHash.toBase64() : from != null ? from.calculateHash().toBase64() : "a tunnel"));
    739739            if (HANDLE_REPLIES_INLINE) {
    740                 handleReply(new BuildReplyMessageState(receivedMessage, from, fromHash));
     740                handleReply(new BuildReplyMessageState(receivedMessage));
    741741            } else {
    742742                synchronized (_inboundBuildReplyMessages) {
    743                     _inboundBuildReplyMessages.add(new BuildReplyMessageState(receivedMessage, from, fromHash));
     743                    _inboundBuildReplyMessages.add(new BuildReplyMessageState(receivedMessage));
    744744                }
    745745                _exec.repoll();
     
    765765    private class BuildReplyMessageState {
    766766        TunnelBuildReplyMessage msg;
    767         RouterIdentity from;
    768         Hash fromHash;
    769767        long recvTime;
    770         public BuildReplyMessageState(I2NPMessage m, RouterIdentity f, Hash h) {
     768        public BuildReplyMessageState(I2NPMessage m) {
    771769            msg = (TunnelBuildReplyMessage)m;
    772             from = f;
    773             fromHash = h;
    774770            recvTime = System.currentTimeMillis();
    775771        }
     
    779775        TunnelBuildMessage msg;
    780776        PooledTunnelCreatorConfig cfg;
    781         RouterIdentity from;
    782         Hash fromHash;
    783777        long recvTime;
    784         public BuildEndMessageState(PooledTunnelCreatorConfig c, I2NPMessage m, RouterIdentity f, Hash h) {
     778        public BuildEndMessageState(PooledTunnelCreatorConfig c, I2NPMessage m) {
    785779            cfg = c;
    786780            msg = (TunnelBuildMessage)m;
    787             from = f;
    788             fromHash = h;
    789781            recvTime = System.currentTimeMillis();
    790782        }
  • router/java/src/net/i2p/router/tunnel/pool/BuildRequestor.java

    r8a756a6 r20effe3  
    2626    static {
    2727        for (int i = 0; i < BuildMessageGenerator.ORDER.length; i++)
    28             ORDER.add(new Integer(i));
     28            ORDER.add(Integer.valueOf(i));
    2929    }
    3030    private static final int PRIORITY = 500;
  • router/java/src/net/i2p/router/tunnel/pool/TunnelPeerSelector.java

    r8a756a6 r20effe3  
    104104        List rv = new ArrayList();
    105105        StringTokenizer tok = new StringTokenizer(peers, ",");
    106         Hash h = new Hash();
    107106        while (tok.hasMoreTokens()) {
    108107            String peerStr = tok.nextToken();
     
    308307        String excludeCaps = ctx.getProperty("router.excludePeerCaps",
    309308                                             String.valueOf(Router.CAPABILITY_BW12));
    310         Set peers = new HashSet();
    311309        if (excludeCaps != null) {
    312310            char excl[] = excludeCaps.toCharArray();
     
    343341        if (val != null) {
    344342            long uptimeMs = 0;
    345             if (val != null) {
    346343                long factor = 1;
    347344                if (val.endsWith("ms")) {
     
    363360                try { uptimeMs = Long.parseLong(val); } catch (NumberFormatException nfe) {}
    364361                uptimeMs *= factor;
    365             } else {
    366                 // not publishing an uptime, so exclude it
    367                 return true;
    368             }
    369362
    370363            long infoAge = ctx.clock().now() - peer.getPublished();
     
    392385            }
    393386        } else {
    394             // not publishing stats, so exclude it
     387            // not publishing an uptime, so exclude it
    395388            return true;
    396389        }
  • router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java

    r8a756a6 r20effe3  
    337337        if (_log.shouldLog(Log.WARN))
    338338            _log.warn(toString() + ": Tunnel failed: " + cfg);
    339         int remaining = 0;
    340339        LeaseSet ls = null;
    341340        synchronized (_tunnels) {
     
    343342            if (_settings.isInbound() && (_settings.getDestination() != null) )
    344343                ls = locked_buildNewLeaseSet();
    345             remaining = _tunnels.size();
    346344            if (_lastSelected == cfg) {
    347345                _lastSelected = null;
     
    404402        if (_log.shouldLog(Log.DEBUG))
    405403            _log.debug(toString() + ": refreshing leaseSet on tunnel expiration (but prior to grace timeout)");
    406         int remaining = 0;
    407404        LeaseSet ls = null;
    408405        if (_settings.isInbound() && (_settings.getDestination() != null) ) {
    409406            synchronized (_tunnels) {
    410407                ls = locked_buildNewLeaseSet();
    411                 remaining = _tunnels.size();
    412408            }
    413409            if (ls != null) {
Note: See TracChangeset for help on using the changeset viewer.