Changeset 3e889d2


Ignore:
Timestamp:
Mar 25, 2012 8:42:41 PM (8 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
522ae4eb
Parents:
ed134249
Message:

remove unnecessary casts (eclipse)

Files:
59 edited

Legend:

Unmodified
Added
Removed
  • apps/i2psnark/java/src/org/klomp/snark/MetaInfo.java

    red134249 r3e889d2  
    219219              throw new InvalidBEncodingException("Huge total length");
    220220
    221             val = (BEValue)desc.get("path");
     221            val = desc.get("path");
    222222            if (val == null)
    223223              throw new InvalidBEncodingException("Missing path list");
     
    245245            m_files.add(Collections.unmodifiableList(file));
    246246           
    247             val = (BEValue)desc.get("path.utf-8");
     247            val = desc.get("path.utf-8");
    248248            if (val != null) {
    249249                path_list = val.getList();
  • apps/i2psnark/java/src/org/klomp/snark/PeerConnectionOut.java

    red134249 r3e889d2  
    144144                      }
    145145                    if (m == null && !sendQueue.isEmpty()) {
    146                       m = (Message)sendQueue.remove(0);
     146                      m = sendQueue.remove(0);
    147147                      //SimpleTimer.getInstance().removeEvent(m.expireEvent);
    148148                    }
  • apps/i2psnark/java/src/org/klomp/snark/SnarkManager.java

    red134249 r3e889d2  
    663663        Snark torrent = null;
    664664        synchronized (_snarks) {
    665             torrent = (Snark)_snarks.get(filename);
     665            torrent = _snarks.get(filename);
    666666        }
    667667        // don't hold the _snarks lock while verifying the torrent
     
    11331133        synchronized (_snarks) {
    11341134            if (shouldRemove)
    1135                 torrent = (Snark)_snarks.remove(filename);
     1135                torrent = _snarks.remove(filename);
    11361136            else
    1137                 torrent = (Snark)_snarks.get(filename);
     1137                torrent = _snarks.get(filename);
    11381138            remaining = _snarks.size();
    11391139        }
  • apps/i2psnark/java/src/org/klomp/snark/Storage.java

    red134249 r3e889d2  
    878878    // First check if the piece is correct.
    879879    // Copy the array first to be paranoid.
    880     byte[] bs = (byte[]) ba.clone();
     880    byte[] bs = ba.clone();
    881881    int length = bs.length;
    882882    boolean correctHash = metainfo.checkPiece(piece, bs, 0, length);
  • apps/i2psnark/java/src/org/klomp/snark/web/I2PSnarkServlet.java

    red134249 r3e889d2  
    303303            out.write("<div class=\"snarkMessages\"><ul>");
    304304            for (int i = msgs.size()-1; i >= 0; i--) {
    305                 String msg = (String)msgs.get(i);
     305                String msg = msgs.get(i);
    306306                out.write("<li>" + msg + "</li>\n");
    307307            }
     
    11771177                float pct;
    11781178                if (isValid) {
    1179                     pct = (float) (100.0 * (float) peer.completed() / meta.getPieces());
     1179                    pct = (float) (100.0 * peer.completed() / meta.getPieces());
    11801180                    if (pct == 100.0)
    11811181                        out.write(_("Seed"));
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnel.java

    red134249 r3e889d2  
    396396                throw new IllegalArgumentException(getPrefix() + "Cannot open private key file " + args[2]);
    397397            }
    398             I2PTunnelServer serv = new I2PTunnelServer(serverHost, portNum, privKeyFile, args[2], l, (EventDispatcher) this, this);
     398            I2PTunnelServer serv = new I2PTunnelServer(serverHost, portNum, privKeyFile, args[2], l, this, this);
    399399            serv.setReadTimeout(readTimeout);
    400400            serv.startRunning();
     
    447447                throw new IllegalArgumentException(getPrefix() + "Cannot open private key file " + args[2]);
    448448            }
    449             I2PTunnelServer serv = new I2PTunnelIRCServer(serverHost, portNum, privKeyFile, args[2], l, (EventDispatcher) this, this);
     449            I2PTunnelServer serv = new I2PTunnelIRCServer(serverHost, portNum, privKeyFile, args[2], l, this, this);
    450450            serv.setReadTimeout(readTimeout);
    451451            serv.startRunning();
     
    508508                throw new IllegalArgumentException(getPrefix() + "Cannot open private key file " + args[3]);
    509509            }
    510             I2PTunnelHTTPServer serv = new I2PTunnelHTTPServer(serverHost, portNum, privKeyFile, args[3], spoofedHost, l, (EventDispatcher) this, this);
     510            I2PTunnelHTTPServer serv = new I2PTunnelHTTPServer(serverHost, portNum, privKeyFile, args[3], spoofedHost, l, this, this);
    511511            serv.setReadTimeout(readTimeout);
    512512            serv.startRunning();
     
    584584            }
    585585
    586             I2PTunnelHTTPBidirServer serv = new I2PTunnelHTTPBidirServer(serverHost, portNum, port2Num, privKeyFile, args[3], spoofedHost, l, (EventDispatcher) this, this);
     586            I2PTunnelHTTPBidirServer serv = new I2PTunnelHTTPBidirServer(serverHost, portNum, port2Num, privKeyFile, args[3], spoofedHost, l, this, this);
    587587            serv.setReadTimeout(readTimeout);
    588588            serv.startRunning();
     
    638638                throw new IllegalArgumentException(getPrefix() + "Bad port " + args[1]);
    639639
    640             I2PTunnelServer serv = new I2PTunnelServer(serverHost, portNum, args[2], l, (EventDispatcher) this, this);
     640            I2PTunnelServer serv = new I2PTunnelServer(serverHost, portNum, args[2], l, this, this);
    641641            serv.setReadTimeout(readTimeout);
    642642            serv.startRunning();
     
    686686                if (args.length >= 4)
    687687                    privateKeyFile = args[3];
    688                 task = new I2PTunnelClient(portNum, args[1], l, ownDest, (EventDispatcher) this, this, privateKeyFile);
     688                task = new I2PTunnelClient(portNum, args[1], l, ownDest, this, this, privateKeyFile);
    689689                addtask(task);
    690690                notifyEvent("clientTaskId", Integer.valueOf(task.getId()));
     
    762762            ownDest = !isShared;
    763763            try {
    764                 task = new I2PTunnelHTTPClient(clientPort, l, ownDest, proxy, (EventDispatcher) this, this);
     764                task = new I2PTunnelHTTPClient(clientPort, l, ownDest, proxy, this, this);
    765765                addtask(task);
    766766                notifyEvent("httpclientTaskId", Integer.valueOf(task.getId()));
     
    831831            ownDest = !isShared;
    832832            try {
    833                 task = new I2PTunnelConnectClient(_port, l, ownDest, proxy, (EventDispatcher) this, this);
     833                task = new I2PTunnelConnectClient(_port, l, ownDest, proxy, this, this);
    834834                addtask(task);
    835835            } catch (IllegalArgumentException iae) {
     
    896896                if (args.length >= 4)
    897897                    privateKeyFile = args[3];
    898                 task = new I2PTunnelIRCClient(_port, args[1], l, ownDest, (EventDispatcher) this, this, privateKeyFile);
     898                task = new I2PTunnelIRCClient(_port, args[1], l, ownDest, this, this, privateKeyFile);
    899899                addtask(task);
    900900                notifyEvent("ircclientTaskId", Integer.valueOf(task.getId()));
     
    950950            ownDest = !isShared;
    951951            try {
    952                 I2PTunnelTask task = new I2PSOCKSTunnel(_port, l, ownDest, (EventDispatcher) this, this, null);
     952                I2PTunnelTask task = new I2PSOCKSTunnel(_port, l, ownDest, this, this, null);
    953953                addtask(task);
    954954                notifyEvent("sockstunnelTaskId", Integer.valueOf(task.getId()));
     
    997997                privateKeyFile = args[2];
    998998            try {
    999                 I2PTunnelTask task = new I2PSOCKSIRCTunnel(_port, l, ownDest, (EventDispatcher) this, this, privateKeyFile);
     999                I2PTunnelTask task = new I2PSOCKSIRCTunnel(_port, l, ownDest, this, this, privateKeyFile);
    10001000                addtask(task);
    10011001                notifyEvent("sockstunnelTaskId", Integer.valueOf(task.getId()));
     
    10461046
    10471047            try {
    1048                 StreamrConsumer task = new StreamrConsumer(_host, _port, args[2], l, (EventDispatcher) this, this);
     1048                StreamrConsumer task = new StreamrConsumer(_host, _port, args[2], l, this, this);
    10491049                task.startRunning();
    10501050                addtask(task);
     
    10951095            }
    10961096
    1097             StreamrProducer task = new StreamrProducer(_port, privKeyFile, args[1], l, (EventDispatcher) this, this);
     1097            StreamrProducer task = new StreamrProducer(_port, privKeyFile, args[1], l, this, this);
    10981098            task.startRunning();
    10991099            addtask(task);
     
    14121412            I2PTunnelTask task;
    14131413            // pings always use the main destination
    1414             task = new I2Ping(allargs, l, false, (EventDispatcher) this, this);
     1414            task = new I2Ping(allargs, l, false, this, this);
    14151415            addtask(task);
    14161416            notifyEvent("pingTaskId", Integer.valueOf(task.getId()));
  • apps/routerconsole/java/src/net/i2p/router/web/ConfigTunnelsHelper.java

    red134249 r3e889d2  
    177177            for (Iterator iter = props.keySet().iterator(); iter.hasNext(); ) {
    178178                String prop = (String)iter.next();
    179                 String val = (String)props.getProperty(prop);
     179                String val = props.getProperty(prop);
    180180                buf.append(prop).append('=').append(val).append(' ');
    181181            }
     
    190190            for (Iterator iter = props.keySet().iterator(); iter.hasNext(); ) {
    191191                String prop = (String)iter.next();
    192                 String val = (String)props.getProperty(prop);
     192                String val = props.getProperty(prop);
    193193                buf.append(prop).append('=').append(val).append(' ');
    194194            }
  • apps/routerconsole/java/src/net/i2p/router/web/PluginUpdateHandler.java

    red134249 r3e889d2  
    162162            buf.append("<b>").append(_("Downloading plugin")).append(' ');
    163163            double pct = ((double)alreadyTransferred + (double)currentWrite) /
    164                          ((double)alreadyTransferred + (double)currentWrite + (double)bytesRemaining);
     164                         ((double)alreadyTransferred + (double)currentWrite + bytesRemaining);
    165165            synchronized (_pct) {
    166166                buf.append(_pct.format(pct));
  • apps/routerconsole/java/src/net/i2p/router/web/SummaryListener.java

    red134249 r3e889d2  
    7474            try {
    7575                _sample.setTime(when);
    76                 double val = eventCount > 0 ? (totalValue / (double)eventCount) : 0d;
     76                double val = eventCount > 0 ? (totalValue / eventCount) : 0d;
    7777                _sample.setValue(_name, val);
    7878                _sample.setValue(_eventName, eventCount);
  • apps/routerconsole/java/src/net/i2p/router/web/TunnelRenderer.java

    red134249 r3e889d2  
    119119            if (lifetime > 10*60)
    120120                lifetime = 10*60;
    121             int bps = 1024 * (int) cfg.getProcessedMessagesCount() / lifetime;
     121            int bps = 1024 * cfg.getProcessedMessagesCount() / lifetime;
    122122            out.write("<td class=\"cells\" align=\"center\">" + bps + " Bps</td>");
    123123            if (cfg.getSendTo() == null)
     
    140140    private static class TunnelComparator implements Comparator<HopConfig> {
    141141         public int compare(HopConfig l, HopConfig r) {
    142              return (int) (r.getProcessedMessagesCount() - l.getProcessedMessagesCount());
     142             return (r.getProcessedMessagesCount() - l.getProcessedMessagesCount());
    143143        }
    144144    }
  • apps/routerconsole/java/src/net/i2p/router/web/UpdateHandler.java

    red134249 r3e889d2  
    237237            buf.append("<b>").append(_("Updating")).append("</b> ");
    238238            double pct = ((double)alreadyTransferred + (double)currentWrite) /
    239                          ((double)alreadyTransferred + (double)currentWrite + (double)bytesRemaining);
     239                         ((double)alreadyTransferred + (double)currentWrite + bytesRemaining);
    240240            synchronized (_pct) {
    241241                buf.append(_pct.format(pct));
  • apps/sam/java/src/net/i2p/sam/SAMBridge.java

    red134249 r3e889d2  
    110110    public Destination getDestination(String name) {
    111111        synchronized (nameToPrivKeys) {
    112             String val = (String)nameToPrivKeys.get(name);
     112            String val = nameToPrivKeys.get(name);
    113113            if (val == null) return null;
    114114            try {
     
    134134    public String getKeystream(String name) {
    135135        synchronized (nameToPrivKeys) {
    136             String val = (String)nameToPrivKeys.get(name);
     136            String val = nameToPrivKeys.get(name);
    137137            if (val == null) return null;
    138138            return val;
     
    192192                for (Iterator iter = nameToPrivKeys.keySet().iterator(); iter.hasNext(); ) {
    193193                    String name = (String)iter.next();
    194                     String privKeys = (String)nameToPrivKeys.get(name);
     194                    String privKeys = nameToPrivKeys.get(name);
    195195                    out.write(name.getBytes());
    196196                    out.write('=');
  • apps/sam/java/src/net/i2p/sam/SAMHandlerFactory.java

    red134249 r3e889d2  
    145145        if ((minMinor >= 10) || (maxMinor >= 10)) return null ;
    146146       
    147         float fminVer = (float) minMajor + (float) minMinor / 10 ;
    148         float fmaxVer = (float) maxMajor + (float) maxMinor / 10 ;
     147        float fminVer = minMajor + (float) minMinor / 10 ;
     148        float fmaxVer = maxMajor + (float) maxMinor / 10 ;
    149149       
    150150
  • apps/sam/java/src/net/i2p/sam/SAMStreamSession.java

    red134249 r3e889d2  
    345345    protected SAMStreamSessionSocketReader getSocketReader ( int id ) {
    346346        synchronized (handlersMapLock) {
    347             return (SAMStreamSessionSocketReader)handlersMap.get(new Integer(id));
     347            return handlersMap.get(new Integer(id));
    348348        }
    349349    }
    350350    private StreamSender getSender(int id) {
    351351        synchronized (handlersMapLock) {
    352             return (StreamSender)sendersMap.get(new Integer(id));
     352            return sendersMap.get(new Integer(id));
    353353        }
    354354    }
     
    376376
    377377        synchronized (handlersMapLock) {
    378             reader = (SAMStreamSessionSocketReader)handlersMap.remove(new Integer(id));
    379             sender = (StreamSender)sendersMap.remove(new Integer(id));
     378            reader = handlersMap.remove(new Integer(id));
     379            sender = sendersMap.remove(new Integer(id));
    380380        }
    381381
     
    403403            while (iter.hasNext()) {
    404404                 id = (Integer)iter.next();
    405                  ((SAMStreamSessionSocketReader)handlersMap.get(id)).stopRunning();
    406                  ((StreamSender)sendersMap.get(id)).shutDownGracefully();
     405                 handlersMap.get(id).stopRunning();
     406                 sendersMap.get(id).shutDownGracefully();
    407407            }
    408408            handlersMap.clear();
     
    741741                    synchronized (_data) {
    742742                        if (!_data.isEmpty()) {
    743                             data = (ByteArray)_data.remove(0);
     743                            data = _data.remove(0);
    744744                        } else if (_shuttingDownGracefully) {
    745745                            /* No data left and shutting down gracefully?
  • apps/sam/java/src/net/i2p/sam/SAMv2StreamSession.java

    red134249 r3e889d2  
    375375                                                                {
    376376                                                                        int formerSize = _dataSize ;
    377                                                                         data = ( ByteArray ) _data.remove ( 0 );
     377                                                                        data = _data.remove ( 0 );
    378378                                                                        _dataSize -= data.getValid();
    379379
  • apps/sam/java/src/net/i2p/sam/client/SAMEventHandler.java

    red134249 r3e889d2  
    117117            try {
    118118                synchronized (_namingReplyLock) {
    119                     String val = (String)_namingReplies.remove(name);
     119                    String val = _namingReplies.remove(name);
    120120                    if (val == null) {
    121121                        _namingReplyLock.wait();
  • apps/sam/java/src/net/i2p/sam/client/SAMStreamSend.java

    red134249 r3e889d2  
    8282            Sender sender = null;
    8383            synchronized (_remotePeers) {
    84                 sender = (Sender)_remotePeers.remove(new Integer(id));
     84                sender = _remotePeers.remove(new Integer(id));
    8585            }
    8686            if (sender != null) {
  • apps/sam/java/src/net/i2p/sam/client/SAMStreamSink.java

    red134249 r3e889d2  
    8484            Sink sink = null;
    8585            synchronized (_remotePeers) {
    86                 sink = (Sink)_remotePeers.remove(new Integer(id));
     86                sink = _remotePeers.remove(new Integer(id));
    8787            }
    8888            if (sink != null) {
     
    9797            Sink sink = null;
    9898            synchronized (_remotePeers) {
    99                 sink = (Sink)_remotePeers.get(new Integer(id));
     99                sink = _remotePeers.get(new Integer(id));
    100100            }
    101101            if (sink != null) {
  • apps/susimail/src/src/i2p/susi/webmail/WebMail.java

    red134249 r3e889d2  
    15331533                                button( LOGOUT, _("Logout") ) );
    15341534
    1535                 String from = (String)request.getParameter( NEW_FROM );
     1535                String from = request.getParameter( NEW_FROM );
    15361536                String fixed = Config.getProperty( CONFIG_SENDER_FIXED, "true" );
    15371537               
  • core/java/src/gnu/crypto/hash/Sha256Standalone.java

    red134249 r3e889d2  
    126126      this.h7 = md.h7;
    127127      this.count = md.count;
    128       this.buffer = (byte[]) md.buffer.clone();
     128      this.buffer = md.buffer.clone();
    129129   }
    130130
  • core/java/src/gnu/crypto/prng/AsyncFortunaStandalone.java

    red134249 r3e889d2  
    7878    public void seed(byte val[]) {
    7979        Map props = new HashMap(1);
    80         props.put(SEED, (Object)val);
     80        props.put(SEED, val);
    8181        init(props);
    8282        //fillBlock();
  • core/java/src/gnu/crypto/prng/FortunaStandalone.java

    red134249 r3e889d2  
    133133  public void seed(byte val[]) {
    134134      Map props = new HashMap(1);
    135       props.put(SEED, (Object)val);
     135      props.put(SEED, val);
    136136      init(props);
    137137      fillBlock();
  • core/java/src/gnu/crypto/prng/RandomEventStandalone.java

    red134249 r3e889d2  
    6363    if (data.length == 0 || data.length > 32)
    6464      throw new IllegalArgumentException("random events take between 1 and 32 bytes of data");
    65     this.data = (byte[]) data.clone();
     65    this.data = data.clone();
    6666  }
    6767
  • core/java/src/net/i2p/crypto/SHA1.java

    red134249 r3e889d2  
    140140    public Object clone() throws CloneNotSupportedException {
    141141        SHA1 that = (SHA1)super.clone();
    142         that.pad = (byte[])this.pad.clone();
     142        that.pad = this.pad.clone();
    143143        return that;
    144144    }
  • core/java/src/net/i2p/crypto/TransientSessionKeyManager.java

    red134249 r3e889d2  
    505505            }
    506506            for (int i = 0; i < removed.size(); i++) {
    507                 TagSet cur = (TagSet)removed.get(i);
     507                TagSet cur = removed.get(i);
    508508                for (Iterator<SessionTag> iter = cur.getTags().iterator(); iter.hasNext(); ) {
    509509                    SessionTag tag = iter.next();
     
    534534        //if (false) aggressiveExpire();
    535535        synchronized (_inboundTagSets) {
    536             TagSet tagSet = (TagSet) _inboundTagSets.remove(tag);
     536            TagSet tagSet = _inboundTagSets.remove(tag);
    537537            if (tagSet == null) {
    538538                if (_log.shouldLog(Log.DEBUG))
  • core/java/src/net/i2p/data/LeaseSet.java

    red134249 r3e889d2  
    176176    public Lease getLease(int index) {
    177177        if (isEncrypted())
    178             return (Lease) _decryptedLeases.get(index);
     178            return _decryptedLeases.get(index);
    179179        else
    180             return (Lease) _leases.get(index);
     180            return _leases.get(index);
    181181    }
    182182
     
    398398        ByteArrayOutputStream baos = new ByteArrayOutputStream(datalen);
    399399        for (int i = 0; i < size; i++) {
    400             ((Lease)_leases.get(i)).getGateway().writeBytes(baos);
    401             ((Lease)_leases.get(i)).getTunnelId().writeBytes(baos);
     400            _leases.get(i).getGateway().writeBytes(baos);
     401            _leases.get(i).getTunnelId().writeBytes(baos);
    402402        }
    403403        // pad out to multiple of 16 with random data before encryption
     
    416416        // add the padded lease...
    417417        Lease padLease = new Lease();
    418         padLease.setEndDate(((Lease)_leases.get(0)).getEndDate());
     418        padLease.setEndDate(_leases.get(0).getEndDate());
    419419        _leases.add(padLease);
    420420        // ...and replace all the gateways and tunnel ids
     
    423423            Hash h = new Hash();
    424424            h.readBytes(bais);
    425             ((Lease)_leases.get(i)).setGateway(h);
     425            _leases.get(i).setGateway(h);
    426426            TunnelId t = new TunnelId();
    427427            t.readBytes(bais);
    428             ((Lease)_leases.get(i)).setTunnelId(t);
     428            _leases.get(i).setTunnelId(t);
    429429        }
    430430    }
     
    445445        ByteArrayOutputStream baos = new ByteArrayOutputStream(datalen);
    446446        for (int i = 0; i < size; i++) {
    447             ((Lease)_leases.get(i)).getGateway().writeBytes(baos);
    448             ((Lease)_leases.get(i)).getTunnelId().writeBytes(baos);
     447            _leases.get(i).getGateway().writeBytes(baos);
     448            _leases.get(i).getTunnelId().writeBytes(baos);
    449449        }
    450450        byte[] iv = new byte[IV_LEN];
     
    465465            t.readBytes(bais);
    466466            l.setTunnelId(t);
    467             l.setEndDate(((Lease)_leases.get(i)).getEndDate());
     467            l.setEndDate(_leases.get(i).getEndDate());
    468468            _decryptedLeases.add(l);
    469469        }
  • core/java/src/net/i2p/stat/Rate.java

    red134249 r3e889d2  
    522522    @Override
    523523    public int hashCode() {
    524         return DataHelper.hashCode(_stat) ^ ((int)_period) ^ ((int) _creationDate);
     524        return DataHelper.hashCode(_stat) ^ _period ^ ((int) _creationDate);
    525525    }
    526526
  • core/java/src/net/i2p/time/NtpMessage.java

    red134249 r3e889d2  
    294294        p[0] = (byte) (leapIndicator << 6 | version << 3 | mode);
    295295        p[1] = (byte) stratum;
    296         p[2] = (byte) pollInterval;
    297         p[3] = (byte) precision;
     296        p[2] = pollInterval;
     297        p[3] = precision;
    298298       
    299299        // root delay is a signed 16.16-bit FP, in Java an int is 32-bits
     
    359359            return (short) (128 + (b & 0x7f));
    360360        else
    361             return (short) b;
     361            return b;
    362362    }
    363363   
     
    394394           
    395395            // Subtract captured value from remaining total
    396             timestamp = timestamp - (double) (unsignedByteToShort(array[pointer+i]) * base);
     396            timestamp = timestamp - (unsignedByteToShort(array[pointer+i]) * base);
    397397        }
    398398       
  • core/java/src/net/i2p/time/Timestamper.java

    red134249 r3e889d2  
    8787    public String getServer(int index) {
    8888        synchronized (_servers) {
    89             return (String)_servers.get(index);
     89            return _servers.get(index);
    9090        }
    9191    }
     
    306306        StringTokenizer tok = new StringTokenizer(serverList, ", ");
    307307        while (tok.hasMoreTokens()) {
    308             String val = (String)tok.nextToken();
     308            String val = tok.nextToken();
    309309            val = val.trim();
    310310            if (val.length() > 0)
  • core/java/src/net/i2p/util/BufferedRandomSource.java

    red134249 r3e889d2  
    185185    }
    186186   
    187     private static final double DOUBLE_DENOMENATOR = (double)(1L << 53);
     187    private static final double DOUBLE_DENOMENATOR = (1L << 53);
    188188    /** defined per javadoc ( ((nextBits(26)<<27) + nextBits(27)) / (1 << 53)) */
    189189    @Override
    190190    public final double nextDouble() {
    191         long top = (((long)nextBits(26) << 27) + nextBits(27));
     191        long top = ((nextBits(26) << 27) + nextBits(27));
    192192        return top / DOUBLE_DENOMENATOR;
    193193    }
    194     private static final float FLOAT_DENOMENATOR = (float)(1 << 24);
     194    private static final float FLOAT_DENOMENATOR = (1 << 24);
    195195    /** defined per javadoc (nextBits(24) / ((float)(1 << 24)) ) */
    196196    @Override
  • core/java/src/net/i2p/util/EepGet.java

    red134249 r3e889d2  
    363363                            if ( bytesRemaining > 0 ) {
    364364                                double pct = 100 * ((double)_written + _previousWritten) /
    365                                              ((double)alreadyTransferred + (double)currentWrite + (double)bytesRemaining);
     365                                             ((double)alreadyTransferred + (double)currentWrite + bytesRemaining);
    366366                                fmt.format("%4.1f", Double.valueOf(pct));
    367367                                buf.append("%: ");
     
    370370                            buf.append(" @ ");
    371371                            double lineKBytes = ((double)_markSize * (double)_lineSize)/1024.0d;
    372                             double kbps = lineKBytes/((double)timeToSend/1000.0d);
     372                            double kbps = lineKBytes/(timeToSend/1000.0d);
    373373                            fmt.format("%7.2f", Double.valueOf(kbps));
    374374                            buf.append(" KBps");
     
    376376                            buf.append(" / ");
    377377                            long lifetime = _context.clock().now() - _startedOn;
    378                             double lifetimeKBps = (1000.0d*(double)(_written)/((double)lifetime*1024.0d));
     378                            double lifetimeKBps = (1000.0d*(_written)/(lifetime*1024.0d));
    379379                            fmt.format("%7.2f", Double.valueOf(lifetimeKBps));
    380380                            buf.append(" KBps");
     
    416416                StringBuilder buf = new StringBuilder(50);
    417417                buf.append("== Transfer rate: ");
    418                 double kbps = (1000.0d*(double)(transferred)/((double)timeToSend*1024.0d));
     418                double kbps = (1000.0d*(transferred)/(timeToSend*1024.0d));
    419419                synchronized (_kbps) {
    420420                    buf.append(_kbps.format(kbps));
     
    441441            long timeToSend = _context.clock().now() - _startedOn;
    442442            System.out.println("== Transfer time: " + DataHelper.formatDuration(timeToSend));
    443             double kbps = (timeToSend > 0 ? (1000.0d*(double)(bytesTransferred)/((double)timeToSend*1024.0d)) : 0);
     443            double kbps = (timeToSend > 0 ? (1000.0d*(bytesTransferred)/(timeToSend*1024.0d)) : 0);
    444444            StringBuilder buf = new StringBuilder(50);
    445445            buf.append("== Transfer rate: ");
  • core/java/src/net/i2p/util/EepHead.java

    red134249 r3e889d2  
    173173            // 404, etc - transferFailed is called after all attempts fail, by fetch() above
    174174            for (int i = 0; i < _listeners.size(); i++)
    175                 ((StatusListener)_listeners.get(i)).attemptFailed(_url, 0, 0, _currentAttempt, _numRetries, new Exception("Attempt failed"));
     175                _listeners.get(i).attemptFailed(_url, 0, 0, _currentAttempt, _numRetries, new Exception("Attempt failed"));
    176176        } else {
    177177            for (int i = 0; i < _listeners.size(); i++)
    178                 ((StatusListener)_listeners.get(i)).transferComplete(
     178                _listeners.get(i).transferComplete(
    179179                        0, 0, 0, _url, "dummy", false);
    180180        }
  • core/java/src/net/i2p/util/EepPost.java

    red134249 r3e889d2  
    219219        StringBuilder sep = new StringBuilder(48);
    220220        for (int i = 0; i < separator.length; i++)
    221             sep.append((char)((int)'a' + (int)(separator[i]&0x0F))).append((char)((int)'a' + (int)((separator[i] >>> 4) & 0x0F)));
     221            sep.append((char)('a' + (separator[i]&0x0F))).append((char)('a' + ((separator[i] >>> 4) & 0x0F)));
    222222        return sep.toString();
    223223    }
  • core/java/src/net/i2p/util/NativeBigInteger.java

    red134249 r3e889d2  
    410410                               + "ms each)");
    411411            System.out.println("java run time:   \t" + javaTime + "ms (" + (javaTime / (runsProcessed + 1)) + "ms each)");
    412             System.out.println("native = " + ((totalTime * 100.0d) / (double) javaTime) + "% of pure java time");
     412            System.out.println("native = " + ((totalTime * 100.0d) / javaTime) + "% of pure java time");
    413413        } else {
    414414            System.out.println("java run time: \t" + javaTime + "ms (" + (javaTime / (runsProcessed + 1)) + "ms each)");
  • core/java/src/net/i2p/util/SimpleTimer.java

    red134249 r3e889d2  
    129129        synchronized (_events) {
    130130            // remove the old scheduled position, then reinsert it
    131             Long oldTime = (Long)_eventTimes.get(event);
     131            Long oldTime = _eventTimes.get(event);
    132132            if (oldTime != null) {
    133133                if (useEarliestTime) {
     
    156156                for (Iterator iter = _eventTimes.keySet().iterator(); iter.hasNext(); ) {
    157157                    TimedEvent evt = (TimedEvent)iter.next();
    158                     Long when = (Long)_eventTimes.get(evt);
    159                     TimedEvent cur = (TimedEvent)_events.get(when);
     158                    Long when = _eventTimes.get(evt);
     159                    TimedEvent cur = _events.get(when);
    160160                    if (cur != evt) {
    161161                        _log.error("event " + evt + " @ " + when + ": " + cur);
     
    183183        if (evt == null) return false;
    184184        synchronized (_events) {
    185             Long when = (Long)_eventTimes.remove(evt);
     185            Long when = _eventTimes.remove(evt);
    186186            if (when != null)
    187187                _events.remove(when);
     
    223223                                break;
    224224                            }
    225                             Long when = (Long)_events.firstKey();
     225                            Long when = _events.firstKey();
    226226                            if (when.longValue() <= now) {
    227                                 TimedEvent evt = (TimedEvent)_events.remove(when);
     227                                TimedEvent evt = _events.remove(when);
    228228                                if (evt != null) {                           
    229229                                    _eventTimes.remove(evt);
  • core/java/src/net/metanotion/io/block/BlockFile.java

    red134249 r3e889d2  
    326326                if (page < METAINDEX_PAGE)
    327327                        throw new IOException("Negative page or superblock access attempt: " + page);
    328                 file.seek((((long)page) - 1L) * PAGESIZE );
     328                file.seek((page - 1L) * PAGESIZE );
    329329        }
    330330
  • core/java/src/net/metanotion/io/data/IntBytes.java

    red134249 r3e889d2  
    4343
    4444        public Object construct(byte[] b) {
    45                 int v = (((int)(b[0] & 0xff) << 24) |
    46                                  ((int)(b[1] & 0xff) << 16) |
    47                                  ((int)(b[2] & 0xff) <<  8) |
    48                                  ((int)(b[3] & 0xff)));
     45                int v = (((b[0] & 0xff) << 24) |
     46                                 ((b[1] & 0xff) << 16) |
     47                                 ((b[2] & 0xff) <<  8) |
     48                                 (b[3] & 0xff));
    4949                return new Integer(v);
    5050        }
  • core/java/src/net/metanotion/io/data/LongBytes.java

    red134249 r3e889d2  
    5454                                 ((long)(b[5] & 0xff) << 16) |
    5555                                 ((long)(b[6] & 0xff) <<  8) |
    56                                  ((long)(b[7] & 0xff)));
     56                                 (b[7] & 0xff));
    5757                return new Long(v);
    5858        }
  • core/java/src/org/xlattice/crypto/filters/BloomSHA1.java

    red134249 r3e889d2  
    297297        // (1 - e(-kN/M))^k
    298298        return java.lang.Math.pow (
    299                 (1l - java.lang.Math.exp(0d- ((double)k) * (long)n / (long)filterBits)), (long)k);
     299                (1l - java.lang.Math.exp(0d- ((double)k) * (long)n / filterBits)), k);
    300300    }
    301301
  • core/java/test/net/i2p/crypto/HMACSHA256Bench.java

    red134249 r3e889d2  
    110110   
    111111    private static void display(int times, long before, long after, int len, String name) {
    112         double rate = ((double)times)/(((double)after-(double)before)/1000.0d);
    113         double kbps = ((double)len/1024.0d)*((double)times)/(((double)after-(double)before)/1000.0d);
     112        double rate = times/(((double)after-(double)before)/1000.0d);
     113        double kbps = (len/1024.0d)*times/(((double)after-(double)before)/1000.0d);
    114114        System.out.println(name + " HMAC pulled " + kbps + "KBps or " + rate + " calcs per second");
    115115    }
  • router/java/src/net/i2p/router/Blocklist.java

    red134249 r3e889d2  
    124124                Hash peer = iter.next();
    125125                String reason;
    126                 String comment = (String) _peerBlocklist.get(peer);
     126                String comment = _peerBlocklist.get(peer);
    127127                if (comment != null)
    128128                    reason = _x("Banned by router hash: {0}");
  • router/java/src/net/i2p/router/Router.java

    red134249 r3e889d2  
    562562        int bwLim = Math.min(_context.bandwidthLimiter().getInboundKBytesPerSecond(),
    563563                             _context.bandwidthLimiter().getOutboundKBytesPerSecond());
    564         bwLim = (int)(((float)bwLim) * getSharePercentage());
     564        bwLim = (int)(bwLim * getSharePercentage());
    565565        if (_log.shouldLog(Log.INFO))
    566566            _log.info("Adding capabilities w/ bw limit @ " + bwLim, new Exception("caps"));
  • router/java/src/net/i2p/router/RouterThrottleImpl.java

    red134249 r3e889d2  
    382382        long overage = Math.max(used1mIn - (maxKBpsIn*1024), used1mOut - (maxKBpsOut*1024));
    383383        if ( (overage > 0) &&
    384              ((overage/(float)(maxKBps*1024f)) > _context.random().nextFloat()) ) {
     384             ((overage/(maxKBps*1024f)) > _context.random().nextFloat()) ) {
    385385            if (_log.shouldLog(Log.WARN)) _log.warn("Reject tunnel, 1m rate (" + overage + " over) indicates overload.");
    386386            setTunnelStatus(LIMIT_STR);
  • router/java/src/net/i2p/router/StatisticsManager.java

    red134249 r3e889d2  
    214214                buf.append(num(avgFrequency)).append(';');
    215215                buf.append(num(rate.getExtremeEventCount())).append(';');
    216                 buf.append(num((double)rate.getLifetimeEventCount())).append(';');
     216                buf.append(num(rate.getLifetimeEventCount())).append(';');
    217217            }
    218218        }
  • router/java/src/net/i2p/router/networkdb/kademlia/KademliaNetworkDatabaseFacade.java

    red134249 r3e889d2  
    569569        RepublishLeaseSetJob j = null;
    570570        synchronized (_publishingLeaseSets) {
    571             j = (RepublishLeaseSetJob)_publishingLeaseSets.get(h);
     571            j = _publishingLeaseSets.get(h);
    572572            if (j == null) {
    573573                j = new RepublishLeaseSetJob(_context, this, h);
     
    921921        SearchJob searchJob = null;
    922922        synchronized (_activeRequests) {
    923             searchJob = (SearchJob)_activeRequests.get(key);
     923            searchJob = _activeRequests.get(key);
    924924            if (searchJob == null) {
    925925                searchJob = new SearchJob(_context, this, key, onFindJob, onFailedLookupJob,
  • router/java/src/net/i2p/router/peermanager/PeerProfile.java

    red134249 r3e889d2  
    286286        // weighted since we want to let the average grow quickly and shrink slowly
    287287        if (ms < _tunnelTestResponseTimeAvg)
    288             _tunnelTestResponseTimeAvg = 0.95*_tunnelTestResponseTimeAvg + .05*(double)ms;
     288            _tunnelTestResponseTimeAvg = 0.95*_tunnelTestResponseTimeAvg + .05*ms;
    289289        else
    290             _tunnelTestResponseTimeAvg = 0.75*_tunnelTestResponseTimeAvg + .25*(double)ms;
     290            _tunnelTestResponseTimeAvg = 0.75*_tunnelTestResponseTimeAvg + .25*ms;
    291291       
    292292        if (_log.shouldLog(Log.INFO))
     
    308308        for (int i = 0; i < THROUGHPUT_COUNT; i++)
    309309            rv += _peakThroughput[i];
    310         rv /= (60d*1024d*(double)THROUGHPUT_COUNT);
     310        rv /= (60d*1024d*THROUGHPUT_COUNT);
    311311        return rv;
    312312    }
     
    339339        for (int i = 0; i < THROUGHPUT_COUNT; i++)
    340340            rv += _peakTunnelThroughput[i];
    341         rv /= (10d*60d*1024d*(double)THROUGHPUT_COUNT);
     341        rv /= (10d*60d*1024d*THROUGHPUT_COUNT);
    342342        return rv;
    343343    }
     
    382382        for (int i = 0; i < THROUGHPUT_COUNT; i++)
    383383            rv += _peakTunnel1mThroughput[i];
    384         rv /= (60d*1024d*(double)THROUGHPUT_COUNT);
     384        rv /= (60d*1024d*THROUGHPUT_COUNT);
    385385        return rv;
    386386    }
  • router/java/src/net/i2p/router/peermanager/ProfileOrganizer.java

    red134249 r3e889d2  
    614614                for (int i = 0; i < _notFailingPeersList.size() && selected.size() < needed; i++) {
    615615                    int curIndex = (i+start) % _notFailingPeersList.size();
    616                     Hash cur = (Hash)_notFailingPeersList.get(curIndex);
     616                    Hash cur = _notFailingPeersList.get(curIndex);
    617617                    if (matches.contains(cur) ||
    618618                        (exclude != null && exclude.contains(cur))) {
  • router/java/src/net/i2p/router/transport/FIFOBandwidthLimiter.java

    red134249 r3e889d2  
    374374
    375375            if (_sendBps <= 0)
    376                 _sendBps = ((float)sent*1000f)/(float)time;
     376                _sendBps = (sent*1000f)/time;
    377377            else
    378                 _sendBps = (0.9f)*_sendBps + (0.1f)*((float)sent*1000f)/(float)time;
     378                _sendBps = (0.9f)*_sendBps + (0.1f)*(sent*1000f)/time;
    379379            if (_recvBps <= 0)
    380                 _recvBps = ((float)recv*1000f)/(float)time;
     380                _recvBps = (recv*1000f)/time;
    381381            else
    382                 _recvBps = (0.9f)*_recvBps + (0.1f)*((float)recv*1000)/(float)time;
     382                _recvBps = (0.9f)*_recvBps + (0.1f)*((float)recv*1000)/time;
    383383
    384384            // warning, getStatLog() can be null
     
    396396            //    _sendBps15s = (0.045f)*((float)sent*15*1000f)/(float)time;
    397397            //else
    398                 _sendBps15s = (0.955f)*_sendBps15s + (0.045f)*((float)sent*1000f)/(float)time;
     398                _sendBps15s = (0.955f)*_sendBps15s + (0.045f)*(sent*1000f)/time;
    399399
    400400            //if (_recvBps15s <= 0)
    401401            //    _recvBps15s = (0.045f)*((float)recv*15*1000f)/(float)time;
    402402            //else
    403                 _recvBps15s = (0.955f)*_recvBps15s + (0.045f)*((float)recv*1000)/(float)time;
     403                _recvBps15s = (0.955f)*_recvBps15s + (0.045f)*((float)recv*1000)/time;
    404404
    405405            // warning, getStatLog() can be null
  • router/java/src/net/i2p/router/transport/GeoIP.java

    red134249 r3e889d2  
    357357        for (int i = 0; i < 4; i++)
    358358            rv |= (ip[i] & 0xff) << ((3-i)*8);
    359         return ((long) rv) & 0xffffffffl;
     359        return rv & 0xffffffffl;
    360360    }
    361361
  • router/java/src/net/i2p/router/transport/OutboundMessageRegistry.java

    red134249 r3e889d2  
    272272                //    MessageSelector sel = iter.next();
    273273                for (int i = 0; i < _selectors.size(); i++) {
    274                     MessageSelector sel = (MessageSelector)_selectors.get(i);
     274                    MessageSelector sel = _selectors.get(i);
    275275                    long expiration = sel.getExpiration();
    276276                    if (expiration <= now) {
  • router/java/src/net/i2p/router/transport/TransportImpl.java

    red134249 r3e889d2  
    508508        long now = _context.clock().now();
    509509        synchronized (_unreachableEntries) {
    510             Long when = (Long)_unreachableEntries.get(peer);
     510            Long when = _unreachableEntries.get(peer);
    511511            if (when == null) return false;
    512512            if (when.longValue() + UNREACHABLE_PERIOD < now) {
     
    544544                for (Iterator iter = _unreachableEntries.keySet().iterator(); iter.hasNext(); ) {
    545545                    Hash peer = (Hash)iter.next();
    546                     Long when = (Long)_unreachableEntries.get(peer);
     546                    Long when = _unreachableEntries.get(peer);
    547547                    if (when.longValue() + UNREACHABLE_PERIOD < now)
    548548                        iter.remove();
  • router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java

    red134249 r3e889d2  
    10001000            _lastRateUpdated = now;
    10011001
    1002             _sendBps = (0.9f)*_sendBps + (0.1f)*((float)sent*1000f)/(float)time;
    1003             _recvBps = (0.9f)*_recvBps + (0.1f)*((float)recv*1000)/(float)time;
     1002            _sendBps = (0.9f)*_sendBps + (0.1f)*(sent*1000f)/time;
     1003            _recvBps = (0.9f)*_recvBps + (0.1f)*((float)recv*1000)/time;
    10041004
    10051005            // Maintain an approximate average with a 15-second halflife
  • router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java

    red134249 r3e889d2  
    164164        NTCPConnection old = null;
    165165        synchronized (_conLock) {
    166             old = (NTCPConnection)_conByIdent.put(con.getRemotePeer().calculateHash(), con);
     166            old = _conByIdent.put(con.getRemotePeer().calculateHash(), con);
    167167        }
    168168        if (old != null) {
     
    182182            boolean isNew = false;
    183183            synchronized (_conLock) {
    184                 con = (NTCPConnection)_conByIdent.get(ih);
     184                con = _conByIdent.get(ih);
    185185                if (con == null) {
    186186                    isNew = true;
     
    357357    public boolean isEstablished(Hash dest) {
    358358        synchronized (_conLock) {
    359             NTCPConnection con = (NTCPConnection)_conByIdent.get(dest);
     359            NTCPConnection con = _conByIdent.get(dest);
    360360            return (con != null) && con.isEstablished() && !con.isClosed();
    361361        }
     
    365365    public boolean isBacklogged(Hash dest) {
    366366        synchronized (_conLock) {
    367             NTCPConnection con = (NTCPConnection)_conByIdent.get(dest);
     367            NTCPConnection con = _conByIdent.get(dest);
    368368            return (con != null) && con.isEstablished() && con.tooBacklogged();
    369369        }
     
    375375            RouterIdentity ident = con.getRemotePeer();
    376376            if (ident != null)
    377                 removed = (NTCPConnection)_conByIdent.remove(ident.calculateHash());
     377                removed = _conByIdent.remove(ident.calculateHash());
    378378        }
    379379        if ( (removed != null) && (removed != con) ) {// multiple cons, close 'em both
  • router/java/src/net/i2p/router/transport/udp/PacketBuilder.java

    red134249 r3e889d2  
    460460        int partialACKCount = 0;
    461461        for (int i = 0; i < ackBitfields.size(); i++) {
    462             if (((ACKBitfield)ackBitfields.get(i)).receivedComplete())
     462            if (ackBitfields.get(i).receivedComplete())
    463463                fullACKCount++;
    464464            else
     
    497497            off++;
    498498            for (int i = 0; i < ackBitfields.size(); i++) {
    499                 ACKBitfield bitfield = (ACKBitfield)ackBitfields.get(i);
     499                ACKBitfield bitfield = ackBitfields.get(i);
    500500                if (bitfield.receivedComplete()) continue;
    501501                DataHelper.toLong(data, off, 4, bitfield.getMessageId());
  • router/java/src/net/i2p/router/transport/udp/PeerState.java

    red134249 r3e889d2  
    482482     */
    483483    public void adjustClockSkew(long skew) {
    484         _clockSkew = (long) (0.9*(float)_clockSkew + 0.1*(float)(skew - (_rtt / 2)));
     484        _clockSkew = (long) (0.9*_clockSkew + 0.1*(skew - (_rtt / 2)));
    485485    }
    486486
     
    543543            _sendWindowBytesRemaining = _sendWindowBytes;
    544544            _sendBytes += size;
    545             _sendBps = (int)(0.9f*(float)_sendBps + 0.1f*((float)_sendBytes * (1000f/(float)duration)));
     545            _sendBps = (int)(0.9f*_sendBps + 0.1f*(_sendBytes * (1000f/duration)));
    546546            //if (isForACK) {
    547547            //    _sendACKBytes += size;
     
    629629        long duration = now - _receivePeriodBegin;
    630630        if (duration >= 1000) {
    631             _receiveBps = (int)(0.9f*(float)_receiveBps + 0.1f*((float)_receiveBytes * (1000f/(float)duration)));
     631            _receiveBps = (int)(0.9f*_receiveBps + 0.1f*(_receiveBytes * (1000f/duration)));
    632632            //if (isForACK)
    633633            //    _receiveACKBps = (int)(0.9f*(float)_receiveACKBps + 0.1f*((float)_receiveACKBytes * (1000f/(float)duration)));
     
    10091009        float scale = 0.1f;
    10101010        if (_sendBps > 0)
    1011             scale = ((float)lifetime) / (float)((float)lifetime + (float)_sendBps);
     1011            scale = lifetime / ((float)lifetime + (float)_sendBps);
    10121012        if (scale < 0.001f) scale = 0.001f;
    10131013       
    1014         _rtt = (int)(((float)_rtt)*(1.0f-scale) + (scale)*(float)lifetime);
     1014        _rtt = (int)(_rtt*(1.0f-scale) + (scale)*lifetime);
    10151015        _rto = _rtt + (_rttDeviation<<2);
    10161016        if (_log.shouldLog(Log.DEBUG))
  • router/java/src/net/i2p/router/transport/udp/UDPPacketReader.java

    red134249 r3e889d2  
    332332                off += size;
    333333            }
    334             return (int)_message[off];
     334            return _message[off];
    335335        }
    336336       
     
    460460                buf.append(" frag# ").append(fragNum);
    461461                buf.append(" isLast? ").append(isLast);
    462                 buf.append(" info ").append((int)_message[off-1]);
     462                buf.append(" info ").append(_message[off-1]);
    463463                int size = ((int)DataHelper.fromLong(_message, off, 2)) & 0x3FFF;
    464464                buf.append(" with ").append(size).append(" bytes");
  • router/java/src/net/i2p/router/tunnel/TrivialPreprocessor.java

    red134249 r3e889d2  
    243243       
    244244        if (_log.shouldLog(Log.DEBUG))
    245             _log.debug("CONTROL: " + Integer.toHexString((int)target[offset]) + "/"
     245            _log.debug("CONTROL: " + Integer.toHexString(target[offset]) + "/"
    246246                       + Base64.encode(target, offset, 1) + " at offset " + offset);
    247247
  • router/java/src/net/i2p/router/tunnel/TunnelCreatorConfig.java

    red134249 r3e889d2  
    137137        if (timeSince >= 60*1000) {
    138138            long tot = _peakThroughputCurrentTotal;
    139             double normalized = (double)tot * 60d*1000d / (double)timeSince;
     139            double normalized = tot * 60d*1000d / timeSince;
    140140            _peakThroughputLastCoallesce = now;
    141141            _peakThroughputCurrentTotal = 0;
     
    159159        for (int i = 0; i < THROUGHPUT_COUNT; i++)
    160160            rv += _peakThroughput[i];
    161         rv /= (60d*1024d*(double)THROUGHPUT_COUNT);
     161        rv /= (60d*1024d*THROUGHPUT_COUNT);
    162162        return rv;
    163163    }
  • router/java/src/net/i2p/router/tunnel/pool/BuildRequestor.java

    red134249 r3e889d2  
    276276       
    277277        for (int i = 0; i < msg.getRecordCount(); i++) {
    278             int hop = ((Integer)order.get(i)).intValue();
     278            int hop = order.get(i).intValue();
    279279            PublicKey key = null;
    280280   
Note: See TracChangeset for help on using the changeset viewer.