Changeset 1db58de


Ignore:
Timestamp:
Mar 25, 2012 10:16:03 PM (8 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
764a7f2
Parents:
f13956d
Message:

remove unused local variables (eclipse)

Files:
55 edited

Legend:

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

    rf13956d r1db58de  
    401401        private boolean is64ok(String data) {
    402402                try {
    403                         Destination x = new Destination(data);
     403                        new Destination(data);
    404404                        return true;
    405405                } catch (Exception e) {
  • apps/i2psnark/java/src/org/klomp/snark/PeerCheckerTask.java

    rf13956d r1db58de  
    6060        Peer worstDownloader = null;
    6161
    62         int peers = 0;
    6362        int uploaders = 0;
    64         int downloaders = 0;
    6563        int removedCount = 0;
    6664
     
    8583              }
    8684
    87             peers++;
    88 
    8985            if (!peer.isChoking())
    9086              uploaders++;
    91             if (!peer.isChoked() && peer.isInteresting())
    92               downloaders++;
    9387
    9488            long upload = peer.getUploaded();
  • apps/i2psnark/java/src/org/klomp/snark/Snark.java

    rf13956d r1db58de  
    316316    debug("My peer id: " + PeerID.idencode(id), Snark.INFO);
    317317
    318     int port;
    319     IOException lastException = null;
    320318/*
    321319 * Don't start a tunnel if the torrent isn't going to be started.
  • apps/i2psnark/java/src/org/klomp/snark/TrackerClient.java

    rf13956d r1db58de  
    199199
    200200    boolean completed = (left == 0);
    201     int sleptTime = 0;
    202 
    203201    try
    204202      {
     
    259257           
    260258            // *** loop once for each tracker
    261             // Only do a request when necessary.
    262             sleptTime = 0;
    263259            int maxSeenPeers = 0;
    264260            for (Iterator iter = trackers.iterator(); iter.hasNext(); ) {
     
    309305                          if(coordinator.addPeer(cur) && it.hasNext()) {
    310306                            int delay = (DELAY_MUL * r.nextInt(10)) + DELAY_MIN;
    311                             sleptTime += delay;
    312307                            try { Thread.sleep(delay); } catch (InterruptedException ie) {}
    313308                          }
  • apps/i2psnark/java/src/org/klomp/snark/web/I2PSnarkServlet.java

    rf13956d r1db58de  
    496496        //}
    497497        if ("Add".equals(action)) {
    498             String newFile = req.getParameter("newFile");
    499498            String newURL = req.getParameter("newURL");
    500499         /******
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelConnectClient.java

    rf13956d r1db58de  
    177177            String line, method = null, host = null, destination = null, restofline = null;
    178178            StringBuilder newRequest = new StringBuilder();
    179             int ahelper = 0;
    180179            String authorization = null;
    181180            while (true) {
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java

    rf13956d r1db58de  
    321321
    322322    protected void clientConnectionRun(Socket s) {
    323         InputStream in = null;
    324323        OutputStream out = null;
    325324
     
    942941            byte[] data = newRequest.toString().getBytes("ISO-8859-1");
    943942            Runnable onTimeout = new OnTimeout(s, s.getOutputStream(), targetRequest, usingWWWProxy, currentProxy, requestId);
    944             I2PTunnelRunner runner = new I2PTunnelHTTPClientRunner(s, i2ps, sockLock, data, mySockets, onTimeout);
     943            new I2PTunnelHTTPClientRunner(s, i2ps, sockLock, data, mySockets, onTimeout);
    945944        } catch (SocketException ex) {
    946945            if (_log.shouldLog(Log.INFO))
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS4aServer.java

    rf13956d r1db58de  
    132132
    133133    protected void confirmConnection() throws SOCKSException {
    134         DataInputStream in;
    135134        DataOutputStream out;
    136135        try {
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS5Server.java

    rf13956d r1db58de  
    9898    private void init(DataInputStream in, DataOutputStream out) throws IOException, SOCKSException {
    9999        int nMethods = in.readUnsignedByte();
    100         boolean methodOk = false;
    101100        int method = Method.NO_ACCEPTABLE_METHODS;
    102101
     
    248247
    249248    protected void confirmConnection() throws SOCKSException {
    250         DataInputStream in;
    251249        DataOutputStream out;
    252250        try {
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udpTunnel/I2PTunnelUDPClientBase.java

    rf13956d r1db58de  
    9292        // create i2pclient and destination
    9393        I2PClient client = I2PClientFactory.createClient();
    94         Destination destN;
    9594        byte[] key;
    9695        try {
    9796            ByteArrayOutputStream out = new ByteArrayOutputStream(512);
    98             destN = client.createDestination(out);
     97            client.createDestination(out);
    9998            key = out.toByteArray();
    10099        } catch(Exception exc) {
  • apps/routerconsole/java/src/net/i2p/router/web/ConfigClientsHandler.java

    rf13956d r1db58de  
    263263        Properties props = RouterConsoleRunner.webAppProperties();
    264264        Set keys = props.keySet();
    265         int cur = 0;
    266265        for (Iterator iter = keys.iterator(); iter.hasNext(); ) {
    267266            String name = (String)iter.next();
     
    280279        Properties props = PluginStarter.pluginProperties();
    281280        Set keys = props.keySet();
    282         int cur = 0;
    283281        for (Iterator iter = keys.iterator(); iter.hasNext(); ) {
    284282            String name = (String)iter.next();
  • apps/routerconsole/java/src/net/i2p/router/web/ProfileOrganizerRenderer.java

    rf13956d r1db58de  
    6868        int reliable = 0;
    6969        int integrated = 0;
    70         int failing = 0;
    7170        StringBuilder buf = new StringBuilder(16*1024);
    7271        buf.append("<h2>").append(_("Peer Profiles")).append("</h2>\n<p>");
     
    102101                reliable++;
    103102            } else if (_organizer.isFailing(peer)) {
    104                 failing++;
    105103            } else {
    106104                tier = 3;
  • apps/routerconsole/java/src/net/i2p/router/web/StatsGenerator.java

    rf13956d r1db58de  
    208208            if (numPeriods > 0) {
    209209                double avgFrequency = curRate.getLifetimeEventCount() / (double)numPeriods;
    210                 double peakFrequency = curRate.getExtremeEventCount();
    211210                buf.append(" (").append(_("Average event count")).append(": ");
    212211                buf.append(num(avgFrequency));
  • apps/routerconsole/java/src/net/i2p/router/web/SummaryListener.java

    rf13956d r1db58de  
    142142                def.addDatasource(_name, "GAUGE", heartbeat, Double.NaN, Double.NaN);
    143143                def.addDatasource(_eventName, "GAUGE", heartbeat, 0, Double.NaN);
    144                 int steps = 1;
    145144                if (_isPersistent) {
    146145                    _rows = (int) Math.max(MIN_ROWS, Math.min(MAX_ROWS, THREE_MONTHS / period));
  • apps/sam/java/src/net/i2p/sam/SAMUtils.java

    rf13956d r1db58de  
    152152     */
    153153    public static Properties parseParams(StringTokenizer tok) throws SAMException {
    154         int pos, nprops = 0, ntoks = tok.countTokens();
     154        int pos, ntoks = tok.countTokens();
    155155        String token, param;
    156156        Properties props = new Properties();
     
    176176            props.setProperty(param, value.toString());
    177177            value.setLength(0);
    178             nprops += 1;
    179178        }
    180179
  • apps/streaming/java/src/net/i2p/client/streaming/Connection.java

    rf13956d r1db58de  
    308308        }
    309309       
    310         boolean ackOnly = false;
    311                
    312310        if ( (packet.getSequenceNum() == 0) && (!packet.isFlagSet(Packet.FLAG_SYNCHRONIZE)) ) {
    313             ackOnly = true;
    314311            //if (_log.shouldLog(Log.DEBUG))
    315312            //    _log.debug("No resend for " + packet);
  • apps/streaming/java/src/net/i2p/client/streaming/MessageInputStream.java

    rf13956d r1db58de  
    336336                    byte rv = cur.getData()[cur.getOffset()+_readyDataBlockIndex];
    337337                    _readyDataBlockIndex++;
    338                     boolean removed = false;
    339338                    if (cur.getValid() <= _readyDataBlockIndex) {
    340339                        _readyDataBlockIndex = 0;
    341340                        _readyDataBlocks.remove(0);
    342                         removed = true;
    343341                    }
    344342                    _readTotal++;
  • apps/streaming/java/src/net/i2p/client/streaming/Packet.java

    rf13956d r1db58de  
    271271    }
    272272    public ByteArray acquirePayload() {
    273         ByteArray old = _payload;
    274273        _payload = new ByteArray(new byte[Packet.MAX_PAYLOAD_SIZE]);
    275274        return _payload;
  • apps/susimail/src/src/i2p/susi/webmail/encoding/Base64.java

    rf13956d r1db58de  
    153153
    154154        private static byte decodeByte( byte b ) throws DecodingException {
    155                 byte a = b;
    156155                if( b >= 'A' && b <= 'Z' )
    157156                        b -= 'A';
  • apps/susimail/src/src/i2p/susi/webmail/encoding/QuotedPrintable.java

    rf13956d r1db58de  
    7171        private String encode( InputStream in ) throws EncodingException, IOException {
    7272                StringBuilder out = new StringBuilder();
    73                 int l = 0;
    7473                int read = 0, buffered = 0, tmp[] = new int[BUFSIZE];
    7574                while( true ) {
     
    8988                        if( c > 32 && c < 127 && c != 61 ) {
    9089                                out.append( (char)c );
    91                                 l++;
    9290                        }
    9391                        else if( ( c == 32 || c == 9 ) ) {
     
    9795                                         */
    9896                                        out.append( c == 32 ? "=20" : "=09" );
    99                                         l += 3;
    10097                                }
    10198                                else {
    10299                                        out.append( (char)c );
    103                                         l++;
    104100                                }
    105101                        }
     
    109105                                for( int j = 1; j < BUFSIZE; j++ )
    110106                                        tmp[j-1] = tmp[j];
    111                                 l = 0;
    112107                        }
    113108                        else {
     
    116111                                }
    117112                                out.append( HexTable.table[ c ] );
    118                                 l += 3;
    119113                        }
    120114                }
  • core/java/src/net/i2p/client/MessageState.java

    rf13956d r1db58de  
    101101
    102102    public void waitFor(int status, long expiration) {
    103         long checkTime = -1;
     103        //long checkTime = -1;
    104104        boolean found = false;
    105105        while (!found) {
     
    113113            found = false;
    114114            synchronized (_receivedStatus) {
    115                 long beforeCheck = _context.clock().now();
     115                //long beforeCheck = _context.clock().now();
    116116                if (locked_isSuccess(status) || locked_isFailure(status)) {
    117117                    if (_log.shouldLog(Log.DEBUG))
     
    119119                    found = true;
    120120                }
    121                 checkTime = _context.clock().now() - beforeCheck;
     121                //checkTime = _context.clock().now() - beforeCheck;
    122122                if (!found) {
    123123                    if (timeToWait > 5000) {
  • core/java/src/net/i2p/client/MessageStatusMessageHandler.java

    rf13956d r1db58de  
    2828   
    2929    public void handleMessage(I2CPMessage message, I2PSessionImpl session) {
    30         boolean skipStatus = true;
    3130        if (_log.shouldLog(Log.DEBUG))
    3231            _log.debug("Handle message " + message);
  • core/java/src/net/i2p/client/datagram/I2PDatagramDissector.java

    rf13956d r1db58de  
    6262    public void loadI2PDatagram(byte[] dgram) throws DataFormatException {
    6363        ByteArrayInputStream dgStream = new ByteArrayInputStream(dgram);
    64         byte[] rxTrimmedPayload;
    65        
    6664        // set invalid(very important!)
    6765        this.valid = false;
  • core/java/src/net/i2p/crypto/CryptixRijndael_Algorithm.java

    rf13956d r1db58de  
    9090
    9191    static {
    92         long time = Clock.getInstance().now();
    93 
    9492        if (_RDEBUG && _debuglevel > 6) {
    9593            System.out.println("Algorithm Name: Rijndael ver 0.1");
  • core/java/src/net/i2p/crypto/ElGamalAESEngine.java

    rf13956d r1db58de  
    319319        try {
    320320            SessionKey newKey = null;
    321             Hash readHash = null;
    322321            List tags = null;
    323322
  • core/java/src/net/i2p/data/Base64.java

    rf13956d r1db58de  
    521521        //                          + (breakLines ? (len43 / MAX_LINE_LENGTH) : 0)]; // New lines     
    522522        int d = 0;
    523         int e = 0;
    524523        int len2 = len - 2;
    525524        int lineLength = 0;
    526         for (; d < len2; d += 3, e += 4) {
     525        for (; d < len2; d += 3) {
    527526            //encode3to4(source, d + off, 3, outBuff, e);
    528527            encode3to4(source, d + off, 3, out, alpha);
     
    532531                //outBuff[e + 4] = NEW_LINE;
    533532                out.append('\n');
    534                 e++;
    535533                lineLength = 0;
    536534            } // end if: end of line
     
    540538            //encode3to4(source, d + off, len - d, outBuff, e);
    541539            encode3to4(source, d + off, len - d, out, alpha);
    542             e += 4;
    543540        } // end if: some padding needed
    544541
  • core/java/src/net/i2p/util/FileUtil.java

    rf13956d r1db58de  
    213213                    try {
    214214                        InputStream in = zip.getInputStream(entry);
    215                         int read = 0;
    216                         while ( (read = in.read(buf)) != -1) {
     215                        while ( (in.read(buf)) != -1) {
    217216                            // throw the data away
    218217                        }
  • core/java/src/net/i2p/util/LogManager.java

    rf13956d r1db58de  
    334334        _rotationLimit = -1;
    335335        try {
    336             String str = config.getProperty(PROP_ROTATIONLIMIT);
    337336            _rotationLimit = Integer.parseInt(config.getProperty(PROP_ROTATIONLIMIT, DEFAULT_ROTATIONLIMIT));
    338337        } catch (NumberFormatException nfe) {
     
    522521        List<LogLimit> limits = getLimits(log);
    523522        LogLimit max = null;
    524         LogLimit notMax = null;
    525523        if (limits != null) {
    526524            for (LogLimit cur : limits) {
     
    529527                else {
    530528                    if (cur.getRootName().length() > max.getRootName().length()) {
    531                         notMax = max;
    532529                        max = cur;
    533530                    }
  • core/java/src/net/i2p/util/ShellCommand.java

    rf13956d r1db58de  
    104104        public void run() {
    105105
    106             String streamData;
    107 
    108106            try {
    109                 while ((streamData = bufferedReader.readLine()) != null) {
     107                while ((bufferedReader.readLine()) != null) {
    110108                    // Just like a Hoover.
    111109                }
  • core/java/src/net/metanotion/io/block/index/BSkipSpan.java

    rf13956d r1db58de  
    165165                                bf.log.error("Flushing with no entries?" + this, new Exception());
    166166
    167                         int ksz, vsz;
    168167                        int curPage = this.page;
    169168                        int[] curNextPage = new int[1];
  • core/java/src/net/metanotion/io/block/index/IBSkipIterator.java

    rf13956d r1db58de  
    9292        @Override
    9393        public Comparable nextKey() {
    94                 Comparable c;
    9594                if(index < ss.nKeys) {
    9695                        if (ss.keys == null) {
  • core/java/src/net/metanotion/util/skiplist/SkipIterator.java

    rf13956d r1db58de  
    8585         */
    8686        public Comparable nextKey() {
    87                 Comparable c;
    8887                if(index < ss.nKeys) { return ss.keys[index]; }
    8988                throw new NoSuchElementException();
  • router/java/src/net/i2p/router/JobQueueRunner.java

    rf13956d r1db58de  
    4141        //_state = 2;
    4242        long lastActive = _context.clock().now();
    43         long jobNum = 0;
    4443        while ( (_keepRunning) && (_context.jobQueue().isAlive()) ) {
    4544            //_state = 3;
     
    7069                }
    7170
    72                 long betweenJobs = now - lastActive;
    7371                _currentJob = job;
    7472                _lastJob = null;
     
    118116                _currentJob = null;
    119117                _lastEnd = lastActive;
    120                 jobNum++;
    121118                //_state = 15;
    122119               
  • router/java/src/net/i2p/router/networkdb/kademlia/ExpireRoutersJob.java

    rf13956d r1db58de  
    7272                // One issue is this will queue a ton of floodfill queries the first time it is run
    7373                // after the 1h router startup grace period.
    74                 RouterInfo ri = _facade.lookupRouterInfoLocally(key);
     74                _facade.lookupRouterInfoLocally(key);
    7575            }
    7676        }
  • router/java/src/net/i2p/router/networkdb/kademlia/KBucketImpl.java

    rf13956d r1db58de  
    392392            boolean ok = bucket.shouldContain(rnd);
    393393            if (!ok) {
    394                 byte diff[] = bucket.getLocal().cachedXor(rnd);
     394                //byte diff[] = bucket.getLocal().cachedXor(rnd);
    395395                //BigInteger dv = new BigInteger(1, diff);
    396396                //log.error("WTF! bucket doesn't want: \n" + toString(rnd.getData())
     
    428428            boolean ok = bucket.shouldContain(rnd);
    429429            if (!ok) {
    430                 byte diff[] = bucket.getLocal().cachedXor(rnd);
     430                //byte diff[] = bucket.getLocal().cachedXor(rnd);
    431431                //BigInteger dv = new BigInteger(1, diff);
    432432                //log.error("WTF! bucket doesn't want: \n" + toString(rnd.getData())
  • router/java/src/net/i2p/router/networkdb/kademlia/LocalHash.java

    rf13956d r1db58de  
    6868       
    6969        if (distance == null) {
    70             // not cached, lets cache it
    71             int cached = 0;
    7270            synchronized (_xorCache) {
    7371                int toRemove = _xorCache.size() + 1 - MAX_CACHED_XOR;
     
    8482                distance = DataHelper.xor(key.getData(), getData());
    8583                _xorCache.put(key, distance);
    86                 cached = _xorCache.size();
    8784            }
    8885          /****
  • router/java/src/net/i2p/router/networkdb/kademlia/SearchJob.java

    rf13956d r1db58de  
    654654
    655655        if (outTunnel != null) {
    656             TunnelId targetTunnelId = null; // not needed
    657             Job onSend = null; // not wanted
    658            
    659656            if (_log.shouldLog(Log.DEBUG))
    660657                _log.debug("resending leaseSet out to " + to + " through " + outTunnel + ": " + msg);
  • router/java/src/net/i2p/router/peermanager/PeerProfile.java

    rf13956d r1db58de  
    626626       
    627627        int i = 0;
    628         int j = 0;
    629628        try {
    630629            for (; i < numExpanded; i++)
  • router/java/src/net/i2p/router/startup/LoadRouterInfoJob.java

    rf13956d r1db58de  
    5656        String routerInfoFile = getContext().getProperty(Router.PROP_INFO_FILENAME, Router.PROP_INFO_FILENAME_DEFAULT);
    5757        RouterInfo info = null;
    58         boolean failedRead = false;
    59        
    60        
    6158        String keyFilename = getContext().getProperty(Router.PROP_KEYS_FILENAME, Router.PROP_KEYS_FILENAME_DEFAULT);
    6259       
  • router/java/src/net/i2p/router/startup/RebuildRouterInfoJob.java

    rf13956d r1db58de  
    7979    void rebuildRouterInfo(boolean alreadyRunning) {
    8080        _log.debug("Rebuilding the new router info");
    81         boolean fullRebuild = false;
    8281        RouterInfo info = null;
    8382        String infoFilename = getContext().getProperty(Router.PROP_INFO_FILENAME, Router.PROP_INFO_FILENAME_DEFAULT);
     
    159158            CreateRouterInfoJob j = new CreateRouterInfoJob(getContext(), null);
    160159            info = j.createRouterInfo();
    161             fullRebuild = true;
    162160        }
    163161       
  • router/java/src/net/i2p/router/transport/TransportImpl.java

    rf13956d r1db58de  
    293293
    294294        if (log) {
     295            /*
    295296            String type = msg.getMessageType();
    296297            // the udp transport logs some further details
    297             /*
    298298            _context.messageHistory().sendMessage(type, msg.getMessageId(),
    299299                                                  msg.getExpiration(),
  • router/java/src/net/i2p/router/transport/TransportManager.java

    rf13956d r1db58de  
    150150        _log.debug("Starting up the transport manager");
    151151        for (Transport t : _transports.values()) {
    152             RouterAddress addr = t.startListening();
     152            t.startListening();
    153153            if (_log.shouldLog(Log.DEBUG))
    154154                _log.debug("Transport " + t.getStyle() + " started");
  • router/java/src/net/i2p/router/transport/UPnPManager.java

    rf13956d r1db58de  
    121121
    122122            DetectedIP[] ips = _upnp.getAddress();
    123             byte[] detected = null;
    124123            if (ips != null) {
    125124                for (DetectedIP ip : ips) {
  • router/java/src/net/i2p/router/transport/ntcp/EventPumper.java

    rf13956d r1db58de  
    502502
    503503            SelectionKey ckey = chan.register(_selector, SelectionKey.OP_READ);
    504             NTCPConnection con = new NTCPConnection(_context, _transport, chan, ckey);
     504            new NTCPConnection(_context, _transport, chan, ckey);
    505505            //if (_log.shouldLog(Log.DEBUG))
    506506            //    _log.debug("new NTCP connection established: " +con);
  • router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java

    rf13956d r1db58de  
    738738        long offsetTotal = 0;
    739739
    740         int bpsIn = 0;
    741         int bpsOut = 0;
    742         long uptimeMsTotal = 0;
    743         long sendTotal = 0;
    744         long recvTotal = 0;
    745         int numPeers = 0;
    746740        float bpsSend = 0;
    747741        float bpsRecv = 0;
  • router/java/src/net/i2p/router/transport/udp/ACKSender.java

    rf13956d r1db58de  
    179179                    if (_log.shouldLog(Log.INFO))
    180180                        _log.info("Sending ACK for " + ackBitfields);
    181                     boolean ok = peer.allocateSendingBytes(ack.getPacket().getLength(), true);
     181                    peer.allocateSendingBytes(ack.getPacket().getLength(), true);
    182182                    // ignore whether its ok or not, its a bloody ack.  this should be fixed, probably.
    183183                    _transport.send(ack);
  • router/java/src/net/i2p/router/transport/udp/EstablishmentManager.java

    rf13956d r1db58de  
    497497        if (state.complete()) return;
    498498       
    499         long now = _context.clock().now();
    500499        RouterIdentity remote = state.getConfirmedIdentity();
    501500        PeerState peer = new PeerState(_context, _transport,
     
    10771076            if (delay > 1000)
    10781077                delay = 1000;
    1079             boolean interrupted = false;
    10801078            try {
    10811079                synchronized (_activityLock) {
     
    10881086                }
    10891087            } catch (InterruptedException ie) {
    1090                 interrupted = true;
    10911088            }
    10921089            // if (_log.shouldLog(Log.DEBUG))
  • router/java/src/net/i2p/router/transport/udp/InboundMessageFragments.java

    rf13956d r1db58de  
    119119            }
    120120           
    121             int size = data.readMessageFragmentSize(i);
    122121            InboundMessageState state = null;
    123122            boolean messageComplete = false;
  • router/java/src/net/i2p/router/transport/udp/MessageReceiver.java

    rf13956d r1db58de  
    116116            int expired = 0;
    117117            long expiredLifetime = 0;
    118             int remaining = 0;
    119118            try {
    120119                    while (message == null) {
  • router/java/src/net/i2p/router/transport/udp/PacketBuilder.java

    rf13956d r1db58de  
    227227
    228228        StringBuilder msg = null;
    229         boolean acksIncluded = false;
    230229        if (_log.shouldLog(Log.INFO)) {
    231230            msg = new StringBuilder(128);
  • router/java/src/net/i2p/router/transport/udp/UDPTransport.java

    rf13956d r1db58de  
    15631563        long now = _context.clock().now();
    15641564        int active = 0;
    1565         int inactive = 0;
    1566             for (Iterator<PeerState> iter = _peersByIdent.values().iterator(); iter.hasNext(); ) {
     1565        for (Iterator<PeerState> iter = _peersByIdent.values().iterator(); iter.hasNext(); ) {
    15671566                PeerState peer = iter.next();
    1568                 if (now-peer.getLastReceiveTime() > 5*60*1000)
    1569                     inactive++;
    1570                 else
     1567                if (now-peer.getLastReceiveTime() <= 5*60*1000)
    15711568                    active++;
    15721569            }
     
    15781575        long now = _context.clock().now();
    15791576        int active = 0;
    1580         int inactive = 0;
    1581             for (Iterator<PeerState> iter = _peersByIdent.values().iterator(); iter.hasNext(); ) {
     1577        for (Iterator<PeerState> iter = _peersByIdent.values().iterator(); iter.hasNext(); ) {
    15821578                PeerState peer = iter.next();
    1583                 if (now-peer.getLastSendFullyTime() > 1*60*1000)
    1584                     inactive++;
    1585                 else
     1579                if (now-peer.getLastSendFullyTime() <= 1*60*1000)
    15861580                    active++;
    15871581            }
     
    20902084            buf.append("<td class=\"cells\" align=\"right\">");
    20912085            long skew = peer.getClockSkew();
    2092             buf.append(DataHelper.formatDuration2(peer.getClockSkew()));
     2086            buf.append(DataHelper.formatDuration2(skew));
    20932087            buf.append("</td>");
    2094             offsetTotal = offsetTotal + peer.getClockSkew();
     2088            offsetTotal = offsetTotal + skew;
    20952089
    20962090            long sendWindow = peer.getSendWindowBytes();
     
    21562150            buf.append("</td>");
    21572151           
    2158             double recvDupPct = (double)peer.getPacketsReceivedDuplicate()/(double)peer.getPacketsReceived();
    21592152            buf.append("<td class=\"cells\" align=\"right\">");
    21602153            buf.append(dupRecv); //formatPct(recvDupPct));
  • router/java/src/net/i2p/router/tunnel/TrivialPreprocessor.java

    rf13956d r1db58de  
    158158    protected int writeFirstFragment(TunnelGateway.Pending msg, byte target[], int offset) {
    159159        boolean fragmented = false;
    160         int origOffset = offset;
    161        
    162160        int instructionsLength = getInstructionsSize(msg);
    163161        int payloadLength = msg.getData().length - msg.getOffset();
  • router/java/src/net/i2p/router/tunnel/pool/BuildExecutor.java

    rf13956d r1db58de  
    285285        List<TunnelPool> pools = new ArrayList(8);
    286286       
    287         //long loopBegin = 0;
    288         //long afterBuildZeroHop = 0;
    289         long afterBuildReal = 0;
    290         long afterHandleInbound = 0;
    291                
    292287        while (_isRunning && !_manager.isShutdown()){
    293288            //loopBegin = System.currentTimeMillis();
     
    384379                }
    385380               
    386                 afterBuildReal = System.currentTimeMillis();
    387381               
    388382                //if (_log.shouldLog(Log.DEBUG))
  • router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java

    rf13956d r1db58de  
    203203        long replyMessageId = state.msg.getUniqueId();
    204204        PooledTunnelCreatorConfig cfg = _exec.removeFromBuilding(replyMessageId);
    205         StringBuilder buf = null;
    206        
    207205        if (cfg == null) {
    208206            // cannot handle - not pending... took too long?
  • router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java

    rf13956d r1db58de  
    904904        int fallback = 0;
    905905        synchronized (_tunnels) {
    906             boolean enough = _tunnels.size() > wanted;
    907906            for (int i = 0; i < _tunnels.size(); i++) {
    908907                TunnelInfo info = _tunnels.get(i);
Note: See TracChangeset for help on using the changeset viewer.