Changeset 2baee74


Ignore:
Timestamp:
May 5, 2010 4:51:54 PM (10 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
9ac5fb4
Parents:
16bec08f
Message:
  • Replace size() ⇐ 0 with isEmpty() everywhere, ditto > 0 → !isEmpty()
Files:
90 edited

Legend:

Unmodified
Added
Removed
  • android/src/net/i2p/router/I2PAndroid.java

    r16bec08f r2baee74  
    7070        // from routerconsole ContextHelper
    7171        List contexts = RouterContext.listContexts();
    72         if ( (contexts == null) || (contexts.size() <= 0) )
     72        if ( (contexts == null) || (contexts.isEmpty()) )
    7373            throw new IllegalStateException("No contexts. This is usually because the router is either starting up or shutting down.");
    7474        RouterContext ctx = (RouterContext)contexts.get(0);
  • apps/i2psnark/java/src/org/klomp/snark/I2PSnarkUtil.java

    r16bec08f r2baee74  
    356356            rv.add(tok.nextToken());
    357357       
    358         if (rv.size() <= 0)
     358        if (rv.isEmpty())
    359359            return null;
    360360        return rv;
  • apps/i2psnark/java/src/org/klomp/snark/PeerConnectionOut.java

    r16bec08f r2baee74  
    143143                          }
    144144                      }
    145                     if (m == null && sendQueue.size() > 0) {
     145                    if (m == null && !sendQueue.isEmpty()) {
    146146                      m = (Message)sendQueue.remove(0);
    147147                      SimpleTimer.getInstance().removeEvent(m.expireEvent);
  • apps/i2psnark/java/src/org/klomp/snark/PeerCoordinator.java

    r16bec08f r2baee74  
    273273      }
    274274
    275     while (removed.size() > 0) {
     275    while (!removed.isEmpty()) {
    276276        Peer peer = (Peer)removed.remove(0);
    277277        peer.disconnect();
     
    429429          }
    430430
    431         while (uploaders < maxUploaders && interested.size() > 0)
     431        while (uploaders < maxUploaders && !interested.isEmpty())
    432432          {
    433433            Peer peer = (Peer)interested.remove(0);
  • apps/i2psnark/java/src/org/klomp/snark/TrackerClient.java

    r16bec08f r2baee74  
    164164    }
    165165
    166     if (tlist.size() <= 0) {
     166    if (tlist.isEmpty()) {
    167167        // FIXME really need to get this message to the gui
    168168        stop = true;
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelClient.java

    r16bec08f r2baee74  
    5555        }
    5656
    57         if (dests.size() <= 0) {
     57        if (dests.isEmpty()) {
    5858            l.log("No target destinations found");
    5959            notifyEvent("openClientResult", "error");
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelClientBase.java

    r16bec08f r2baee74  
    642642                try {
    643643                    synchronized (_waitingSockets) {
    644                         if (_waitingSockets.size() <= 0)
     644                        if (_waitingSockets.isEmpty())
    645645                            _waitingSockets.wait();
    646646                        else
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelIRCClient.java

    r16bec08f r2baee74  
    6262        }
    6363
    64         if (dests.size() <= 0) {
     64        if (dests.isEmpty()) {
    6565            l.log("No target destinations found");
    6666            notifyEvent("openClientResult", "error");
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/TunnelControllerGroup.java

    r16bec08f r2baee74  
    330330            if (owners != null) {
    331331                owners.remove(controller);
    332                 if (owners.size() <= 0) {
     332                if (owners.isEmpty()) {
    333333                    if (_log.shouldLog(Log.INFO))
    334334                        _log.info("After releasing session " + session + " by " + controller + ", no more owners remain");
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS4aServer.java

    r16bec08f r2baee74  
    225225            } else {
    226226                List<String> proxies = t.getProxies(connPort);
    227                 if (proxies == null || proxies.size() <= 0) {
     227                if (proxies == null || proxies.isEmpty()) {
    228228                    String err = "No outproxy configured for port " + connPort + " and no default configured either - host: " + connHostName;
    229229                    _log.error(err);
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS5Server.java

    r16bec08f r2baee74  
    333333            } else {
    334334                List<String> proxies = t.getProxies(connPort);
    335                 if (proxies == null || proxies.size() <= 0) {
     335                if (proxies == null || proxies.isEmpty()) {
    336336                    String err = "No outproxy configured for port " + connPort + " and no default configured either";
    337337                    _log.error(err);
  • apps/jetty/java/src/org/mortbay/http/HttpContext.java

    r16bec08f r2baee74  
    13021302        List scss= _constraintMap.getMatches(pathInContext);
    13031303        String pattern=null;
    1304         if (scss != null && scss.size() > 0)
     1304        if (scss != null && !scss.isEmpty())
    13051305        {
    13061306            Object constraints= null;
  • apps/ministreaming/java/src/net/i2p/client/streaming/I2PServerSocketImpl.java

    r16bec08f r2baee74  
    7070       
    7171        while ( (ret == null) && (!closing) ){
    72             while (pendingSockets.size() <= 0) {
     72            while (pendingSockets.isEmpty()) {
    7373                if (closing) throw new ConnectException("I2PServerSocket closed");
    7474                try {
     
    7979            }
    8080            synchronized (pendingSockets) {
    81                 if (pendingSockets.size() > 0) {
     81                if (!pendingSockets.isEmpty()) {
    8282                    ret = (I2PSocket)pendingSockets.remove(0);
    8383                }
  • apps/routerconsole/java/src/net/i2p/router/web/ConfigClientsHelper.java

    r16bec08f r2baee74  
    8989                String val = props.getProperty(name);
    9090                Properties appProps = PluginStarter.pluginProperties(_context, app);
    91                 if (appProps.size() <= 0)
     91                if (appProps.isEmpty())
    9292                    continue;
    9393                StringBuilder desc = new StringBuilder(256);
  • apps/routerconsole/java/src/net/i2p/router/web/ConfigStatsHelper.java

    r16bec08f r2baee74  
    7171     */
    7272    public boolean hasMoreStats() {
    73         if (_stats.size() <= 0)
     73        if (_stats.isEmpty())
    7474            return false;
    7575        _currentIsGraphed = false;
  • apps/routerconsole/java/src/net/i2p/router/web/ConfigTunnelsHelper.java

    r16bec08f r2baee74  
    164164        // And let's not display them at all unless they have contents, which should be rare.
    165165        Properties props = in.getUnknownOptions();
    166         if (props.size() > 0) {
     166        if (!props.isEmpty()) {
    167167            buf.append("<tr><td align=\"right\" class=\"mediumtags\">" + _("Inbound options") + ":</td>\n" +
    168168                       "<td colspan=\"2\" align=\"center\"><input name=\"").append(index);
     
    177177        }
    178178        props = out.getUnknownOptions();
    179         if (props.size() > 0) {
     179        if (!props.isEmpty()) {
    180180            buf.append("<tr><td align=\"right\" class=\"mediumtags\">" + _("Outbound options") + ":</td>\n" +
    181181                       "<td colspan=\"2\" align=\"center\"><input name=\"").append(index);
  • apps/routerconsole/java/src/net/i2p/router/web/ContextHelper.java

    r16bec08f r2baee74  
    77
    88class ContextHelper {
     9
     10    /** @throws IllegalStateException if no context available */
    911    public static RouterContext getContext(String contextId) {
    1012        List contexts = RouterContext.listContexts();
    11         if ( (contexts == null) || (contexts.size() <= 0) )
     13        if ( (contexts == null) || (contexts.isEmpty()) )
    1214            throw new IllegalStateException("No contexts. This is usually because the router is either starting up or shutting down.");
    1315        if ( (contextId == null) || (contextId.trim().length() <= 0) )
  • apps/routerconsole/java/src/net/i2p/router/web/NetDbRenderer.java

    r16bec08f r2baee74  
    186186        // versions table
    187187        List<String> versionList = new ArrayList(versions.objects());
    188         if (versionList.size() > 0) {
     188        if (!versionList.isEmpty()) {
    189189            Collections.sort(versionList, Collections.reverseOrder(new VersionComparator()));
    190190            buf.append("<table>\n");
     
    218218        // country table
    219219        List<String> countryList = new ArrayList(countries.objects());
    220         if (countryList.size() > 0) {
     220        if (!countryList.isEmpty()) {
    221221            Collections.sort(countryList, new CountryComparator());
    222222            buf.append("<table>\n");
  • apps/routerconsole/java/src/net/i2p/router/web/NewsFetcher.java

    r16bec08f r2baee74  
    323323            } else {
    324324                List contexts = RouterContext.listContexts();
    325                 if (contexts.size() > 0)
     325                if (!contexts.isEmpty())
    326326                    handler = new UpdateHandler((RouterContext)contexts.get(0));
    327327                else
  • apps/routerconsole/java/src/net/i2p/router/web/ShitlistRenderer.java

    r16bec08f r2baee74  
    5959                buf.append(_("Banned until restart or in {0}", expireString));
    6060            Set transports = entry.transports;
    61             if ( (transports != null) && (transports.size() > 0) )
     61            if ( (transports != null) && (!transports.isEmpty()) )
    6262                buf.append(" on the following transport: ").append(transports);
    6363            if (entry.cause != null) {
  • apps/routerconsole/java/src/net/i2p/router/web/SummaryHelper.java

    r16bec08f r2baee74  
    374374        StringBuilder buf = new StringBuilder(512);
    375375        buf.append("<h3><a href=\"/i2ptunnel/index.jsp\" target=\"_blank\" title=\"").append(_("Add/remove/edit &amp; control your client and server tunnels")).append("\">").append(_("Local Destinations")).append("</a></h3><hr><div class=\"tunnels\">");
    376         if (clients.size() > 0) {
     376        if (!clients.isEmpty()) {
    377377            Collections.sort(clients, new AlphaComparator());
    378378            buf.append("<table>");
  • apps/routerconsole/java/src/net/i2p/router/web/TunnelRenderer.java

    r16bec08f r2baee74  
    202202        if (in != null) {
    203203            List pending = in.listPending();
    204             if (pending.size() > 0)
     204            if (!pending.isEmpty()) {
    205205                out.write("<div class=\"statusnotes\"><center><b>" + _("Build in progress") + ": " + pending.size() + " " + _("inbound") + "</b></center></div>\n");
    206             live += pending.size();
     206                live += pending.size();
     207            }
    207208        }
    208209        if (outPool != null) {
    209210            List pending = outPool.listPending();
    210             if (pending.size() > 0)
     211            if (!pending.isEmpty()) {
    211212                out.write("<div class=\"statusnotes\"><center><b>" + _("Build in progress") + ": " + pending.size() + " " + _("outbound") + "</b></center></div>\n");
    212             live += pending.size();
     213                live += pending.size();
     214            }
    213215        }
    214216        if (live <= 0)
  • apps/sam/java/src/net/i2p/sam/SAMStreamSession.java

    r16bec08f r2baee74  
    740740                try {
    741741                    synchronized (_data) {
    742                         if (_data.size() > 0) {
     742                        if (!_data.isEmpty()) {
    743743                            data = (ByteArray)_data.remove(0);
    744744                        } else if (_shuttingDownGracefully) {
  • apps/sam/java/src/net/i2p/sam/SAMv1Handler.java

    r16bec08f r2baee74  
    309309
    310310        if (opcode.equals("GENERATE")) {
    311             if (props.size() > 0) {
     311            if (!props.isEmpty()) {
    312312                _log.debug("Properties specified in DEST GENERATE message");
    313313                return false;
  • apps/sam/java/src/net/i2p/sam/SAMv2StreamSession.java

    r16bec08f r2baee74  
    372372                                                        synchronized ( _data )
    373373                                                        {
    374                                                                 if ( _data.size() > 0 )
     374                                                                if ( !_data.isEmpty() )
    375375                                                                {
    376376                                                                        int formerSize = _dataSize ;
  • apps/streaming/java/src/net/i2p/client/streaming/Connection.java

    r16bec08f r2baee74  
    450450            _outboundPackets.notifyAll();
    451451        }
    452         if ((acked != null) && (acked.size() > 0) )
     452        if ((acked != null) && (!acked.isEmpty()) )
    453453            _ackSinceCongestion = true;
    454454        return acked;
  • apps/streaming/java/src/net/i2p/client/streaming/ConnectionPacketHandler.java

    r16bec08f r2baee74  
    254254            return false;
    255255       
    256         if ( (acked != null) && (acked.size() > 0) ) {
     256        if ( (acked != null) && (!acked.isEmpty()) ) {
    257257            if (_log.shouldLog(Log.DEBUG))
    258258                _log.debug(acked.size() + " of our packets acked with " + packet);
  • apps/streaming/java/src/net/i2p/client/streaming/MessageInputStream.java

    r16bec08f r2baee74  
    284284        synchronized (_dataLock) {
    285285            for (int i = 0; i < length; i++) {
    286                 if ( (_readyDataBlocks.size() <= 0) && (i == 0) ) {
     286                if ( (_readyDataBlocks.isEmpty()) && (i == 0) ) {
    287287                    // ok, we havent found anything, so lets block until we get
    288288                    // at least one byte
    289289                   
    290                     while (_readyDataBlocks.size() <= 0) {
     290                    while (_readyDataBlocks.isEmpty()) {
    291291                        if (_locallyClosed)
    292292                            throw new IOException("Already closed, you wanker");
    293293                       
    294                         if ( (_notYetReadyBlocks.size() <= 0) && (_closeReceived) ) {
     294                        if ( (_notYetReadyBlocks.isEmpty()) && (_closeReceived) ) {
    295295                            if (_log.shouldLog(Log.INFO))
    296296                                _log.info("read(...," + offset + ", " + length + ")[" + i
     
    323323                                return i;
    324324                            }
    325                             if (_readyDataBlocks.size() <= 0) {
     325                            if (_readyDataBlocks.isEmpty()) {
    326326                                if ( (_readTimeout > 0) && (expiration < System.currentTimeMillis()) ) {
    327327                                    if (_log.shouldLog(Log.INFO))
     
    335335                    // we looped a few times then got data, so this pass doesnt count
    336336                    i--;
    337                 } else if (_readyDataBlocks.size() <= 0) {
     337                } else if (_readyDataBlocks.isEmpty()) {
    338338                    if (_log.shouldLog(Log.DEBUG))
    339339                        _log.debug("read(...," + offset+", " + length+ ")[" + i
  • apps/streaming/java/src/net/i2p/client/streaming/PacketLocal.java

    r16bec08f r2baee74  
    7171     */
    7272    public void setTagsSent(Set tags) {
    73         if (tags != null && tags.size() > 0)
     73        if (tags != null && !tags.isEmpty())
    7474            _log.error("Who is sending tags thru the streaming lib? " + tags.size());
    75         if ( (_tagsSent != null) && (_tagsSent.size() > 0) && (tags.size() > 0) ) {
     75        if ( (_tagsSent != null) && (!_tagsSent.isEmpty()) && (!tags.isEmpty()) ) {
    7676            //int old = _tagsSent.size();
    7777            //_tagsSent.addAll(tags);
     
    161161            buf.append(" rtt ").append(con.getOptions().getRTT());
    162162       
    163         if ( (_tagsSent != null) && (_tagsSent.size() > 0) )
     163        if ( (_tagsSent != null) && (!_tagsSent.isEmpty()) )
    164164            buf.append(" with tags");
    165165
  • apps/susidns/src/java/src/i2p/susi/dns/AddressbookBean.java

    r16bec08f r2baee74  
    7474        public boolean isNotEmpty()
    7575        {
    76                 return addressbook != null && addressbook.size() > 0;
     76                return addressbook != null && !addressbook.isEmpty();
    7777        }
    7878        public AddressbookBean()
     
    9090                long currentTime = System.currentTimeMillis();
    9191               
    92                 if( properties.size() > 0 &&  currentTime - configLastLoaded < 10000 )
     92                if( !properties.isEmpty() &&  currentTime - configLastLoaded < 10000 )
    9393                        return;
    9494               
  • apps/susidns/src/java/src/i2p/susi/dns/SubscriptionsBean.java

    r16bec08f r2baee74  
    5050                long currentTime = System.currentTimeMillis();
    5151               
    52                 if( properties.size() > 0 &&  currentTime - configLastLoaded < 10000 )
     52                if( !properties.isEmpty() &&  currentTime - configLastLoaded < 10000 )
    5353                        return;
    5454               
  • apps/susimail/src/src/i2p/susi/webmail/WebMail.java

    r16bec08f r2baee74  
    14121412                        recipients.add( sender );
    14131413               
    1414                 if( recipients.size() == 0 ) {
     1414                if( recipients.isEmpty() ) {
    14151415                        ok = false;
    14161416                        sessionObject.error += "No recipients found.<br>";
     
    14431443                        String boundary = "_="+(int)(Math.random()*Integer.MAX_VALUE)+""+(int)(Math.random()*Integer.MAX_VALUE);
    14441444                        boolean multipart = false;
    1445                         if( sessionObject.attachments != null && sessionObject.attachments.size() > 0 ) {
     1445                        if( sessionObject.attachments != null && !sessionObject.attachments.isEmpty() ) {
    14461446                                multipart = true;
    14471447                                body.append( "\r\nMIME-Version: 1.0\r\nContent-type: multipart/mixed; boundary=\"" + boundary + "\"\r\n\r\n" );
     
    15161516                out.println( button( SEND, "Send" ) +
    15171517                                button( CANCEL, "Cancel" ) + spacer +
    1518                                 (sessionObject.attachments != null && sessionObject.attachments.size() > 0 ? button( DELETE_ATTACHMENT, "Delete Attachment" ) : button2( DELETE_ATTACHMENT, "Delete Attachment" ) ) + spacer +
     1518                                (sessionObject.attachments != null && (!sessionObject.attachments.isEmpty()) ? button( DELETE_ATTACHMENT, "Delete Attachment" ) : button2( DELETE_ATTACHMENT, "Delete Attachment" ) ) + spacer +
    15191519                                button( RELOAD, "Reload Config" ) + spacer +
    15201520                                button( LOGOUT, "Logout" ) );
     
    15511551                                "<tr><td align=\"right\">New Attachment:</td><td align=\"left\"><input type=\"file\" size=\"50%\" name=\"" + NEW_FILENAME + "\" value=\"\"><input type=\"submit\" name=\"" + NEW_UPLOAD + "\" value=\"Upload File\"></td></tr>" );
    15521552               
    1553                 if( sessionObject.attachments != null && sessionObject.attachments.size() > 0 ) {
     1553                if( sessionObject.attachments != null && !sessionObject.attachments.isEmpty() ) {
    15541554                        boolean wroteHeader = false;
    15551555                        for( Iterator it = sessionObject.attachments.iterator(); it.hasNext(); ) {
  • core/java/src/net/i2p/client/I2PSessionImpl.java

    r16bec08f r2baee74  
    452452                Integer size = null;
    453453                synchronized (AvailabilityNotifier.this) {
    454                     if (_pendingIds.size() <= 0) {
     454                    if (_pendingIds.isEmpty()) {
    455455                        try {
    456456                            AvailabilityNotifier.this.wait();
     
    458458                        }
    459459                    }
    460                     if (_pendingIds.size() > 0) {
     460                    if (!_pendingIds.isEmpty()) {
    461461                        msgId = (Long)_pendingIds.remove(0);
    462462                        size = (Integer)_pendingSizes.remove(0);
  • core/java/src/net/i2p/client/I2PSessionImpl2.java

    r16bec08f r2baee74  
    237237            long availTimeLeft = _context.sessionKeyManager().getAvailableTimeLeft(dest.getPublicKey(), key);
    238238       
    239             if ( (tagsSent == null) || (tagsSent.size() <= 0) ) {
     239            if ( (tagsSent == null) || (tagsSent.isEmpty()) ) {
    240240                if (oldTags < NUM_TAGS) {
    241241                    sentTags = createNewTags(NUM_TAGS);
     
    262262                newKey = _context.keyGenerator().generateSessionKey();
    263263       
    264             if ( (tagsSent != null) && (tagsSent.size() > 0) ) {
     264            if ( (tagsSent != null) && (!tagsSent.isEmpty()) ) {
    265265                if (sentTags == null)
    266266                    sentTags = new HashSet();
  • core/java/src/net/i2p/client/naming/EepGetNamingService.java

    r16bec08f r2baee74  
    7373
    7474        List URLs = getURLs();
    75         if (URLs.size() == 0)
     75        if (URLs.isEmpty())
    7676            return null;
    7777
  • core/java/src/net/i2p/crypto/CryptixAESKeyCache.java

    r16bec08f r2baee74  
    3232    public final KeyCacheEntry acquireKey() {
    3333        synchronized (_availableKeys) {
    34             if (_availableKeys.size() > 0)
     34            if (!_availableKeys.isEmpty())
    3535                return (KeyCacheEntry)_availableKeys.remove(0);
    3636        }
  • core/java/src/net/i2p/crypto/DHSessionKeyBuilder.java

    r16bec08f r2baee74  
    115115        DHSessionKeyBuilder builder = null;
    116116        synchronized (_builders) {
    117             if (_builders.size() > 0) {
     117            if (!_builders.isEmpty()) {
    118118                builder = (DHSessionKeyBuilder) _builders.remove(0);
    119119                if (_log.shouldLog(Log.DEBUG)) _log.debug("Removing a builder.  # left = " + _builders.size());
  • core/java/src/net/i2p/crypto/ElGamalAESEngine.java

    r16bec08f r2baee74  
    105105            if (decrypted != null) {
    106106                _context.statManager().updateFrequency("crypto.elGamalAES.decryptExistingSession");
    107                 if ( (foundTags.size() > 0) && (_log.shouldLog(Log.DEBUG)) )
     107                if ( (!foundTags.isEmpty()) && (_log.shouldLog(Log.DEBUG)) )
    108108                    _log.debug(id + ": ElG/AES decrypt success with " + st + ": found tags: " + foundTags);
    109109                wasExisting = true;
     
    119119            if (decrypted != null) {
    120120                _context.statManager().updateFrequency("crypto.elGamalAES.decryptNewSession");
    121                 if ( (foundTags.size() > 0) && (_log.shouldLog(Log.DEBUG)) )
     121                if ( (!foundTags.isEmpty()) && (_log.shouldLog(Log.DEBUG)) )
    122122                    _log.debug("ElG decrypt success: found tags: " + foundTags);
    123123            } else {
     
    132132        }
    133133
    134         if (foundTags.size() > 0) {
     134        if (!foundTags.isEmpty()) {
    135135            if (foundKey.getData() != null) {
    136136                if (_log.shouldLog(Log.DEBUG))
  • core/java/src/net/i2p/crypto/HMAC256Generator.java

    r16bec08f r2baee74  
    2323    protected I2PHMac acquire() {
    2424        synchronized (_available) {
    25             if (_available.size() > 0)
     25            if (!_available.isEmpty())
    2626                return (I2PHMac)_available.remove(0);
    2727        }
  • core/java/src/net/i2p/crypto/HMACGenerator.java

    r16bec08f r2baee74  
    9090    protected I2PHMac acquire() {
    9191        synchronized (_available) {
    92             if (_available.size() > 0)
     92            if (!_available.isEmpty())
    9393                return (I2PHMac)_available.remove(0);
    9494        }
     
    109109        byte rv[] = null;
    110110        synchronized (_availableTmp) {
    111             if (_availableTmp.size() > 0)
     111            if (!_availableTmp.isEmpty())
    112112                rv = (byte[])_availableTmp.remove(0);
    113113        }
  • core/java/src/net/i2p/crypto/SHA256Generator.java

    r16bec08f r2baee74  
    5353        Sha256Standalone rv = null;
    5454        synchronized (_digestsGnu) {
    55             if (_digestsGnu.size() > 0)
     55            if (!_digestsGnu.isEmpty())
    5656                rv = (Sha256Standalone)_digestsGnu.remove(0);
    5757        }
  • core/java/src/net/i2p/crypto/TransientSessionKeyManager.java

    r16bec08f r2baee74  
    308308        if (_log.shouldLog(Log.DEBUG)) {
    309309            //_log.debug("Tags delivered to set " + set + " on session " + sess);
    310             if (sessionTags.size() > 0)
     310            if (!sessionTags.isEmpty())
    311311                _log.debug("Tags delivered: " + sessionTags.size() + " for key: " + key + ": " + sessionTags);
    312312        }
     
    416416            clearExcess(overage);
    417417
    418         if ( (sessionTags.size() <= 0) && (_log.shouldLog(Log.DEBUG)) )
     418        if ( (sessionTags.isEmpty()) && (_log.shouldLog(Log.DEBUG)) )
    419419            _log.debug("Received 0 tags for key " + key);
    420420        //if (false) aggressiveExpire();
     
    786786            _lastUsed = now;
    787787            synchronized (_tagSets) {
    788                 while (_tagSets.size() > 0) {
     788                while (!_tagSets.isEmpty()) {
    789789                    TagSet set = _tagSets.get(0);
    790790                    if (set.getDate() + SESSION_TAG_DURATION_MS > now) {
     
    831831                for (Iterator<TagSet> iter = _tagSets.iterator(); iter.hasNext();) {
    832832                    TagSet set = iter.next();
    833                     if ( (set.getDate() > last) && (set.getTags().size() > 0) )
     833                    if ( (set.getDate() > last) && (!set.getTags().isEmpty()) )
    834834                        last = set.getDate();
    835835                }
  • core/java/src/net/i2p/crypto/YKGenerator.java

    r16bec08f r2baee74  
    111111        if (true) {
    112112            synchronized (_values) {
    113                 if (_values.size() > 0) {
     113                if (!_values.isEmpty()) {
    114114                    if (_log.shouldLog(Log.DEBUG))
    115115                        _log.debug("Sufficient precalculated YK values - fetch the existing");
  • core/java/src/net/i2p/data/LeaseSet.java

    r16bec08f r2baee74  
    202202     */
    203203    public long getEarliestLeaseDate() {
    204         if (_leases.size() <= 0)
     204        if (_leases.isEmpty())
    205205            return -1;
    206206        return _firstExpiration;
  • core/java/src/net/i2p/stat/BufferedStatLog.java

    r16bec08f r2baee74  
    9595                    while (tok.hasMoreTokens())
    9696                        _statFilters.add(tok.nextToken().trim());
    97                     _filtersSpecified = _statFilters.size() > 0;
     97                    _filtersSpecified = !_statFilters.isEmpty();
    9898                }
    9999            }
  • core/java/src/net/i2p/util/Executor.java

    r16bec08f r2baee74  
    2121            SimpleTimer.TimedEvent evt = null;
    2222            synchronized (_readyEvents) {
    23                 if (_readyEvents.size() <= 0)
     23                if (_readyEvents.isEmpty())
    2424                    try { _readyEvents.wait(); } catch (InterruptedException ie) {}
    25                 if (_readyEvents.size() > 0)
     25                if (!_readyEvents.isEmpty())
    2626                    evt = (SimpleTimer.TimedEvent)_readyEvents.remove(0);
    2727            }
  • core/java/src/net/i2p/util/SimpleTimer.java

    r16bec08f r2baee74  
    181181                        Object nextEvent = null;
    182182                        while(runn.getAnswer()) {
    183                             if(_events.size() <= 0) {
     183                            if(_events.isEmpty()) {
    184184                                break;
    185185                            }
     
    197197                            }
    198198                        }
    199                         if (eventsToFire.size() <= 0) {
     199                        if (eventsToFire.isEmpty()) {
    200200                            if (nextEventDelay != -1) {
    201201                                if (_log.shouldLog(Log.DEBUG))
  • core/java/src/org/bouncycastle/crypto/macs/I2PHMac.java

    r16bec08f r2baee74  
    173173        byte rv[] = null;
    174174        synchronized (_tmpBuf[sz == 32 ? 0 : 1]) {
    175             if (_tmpBuf[sz == 32 ? 0 : 1].size() > 0)
     175            if (!_tmpBuf[sz == 32 ? 0 : 1].isEmpty())
    176176                rv = (byte[])_tmpBuf[sz == 32 ? 0 : 1].remove(0);
    177177        }
  • router/java/src/net/i2p/data/i2np/DatabaseLookupMessage.java

    r16bec08f r2baee74  
    206206            out[curIndex++] = DataHelper.BOOLEAN_FALSE;
    207207        }
    208         if ( (_dontIncludePeers == null) || (_dontIncludePeers.size() <= 0) ) {
     208        if ( (_dontIncludePeers == null) || (_dontIncludePeers.isEmpty()) ) {
    209209            out[curIndex++] = 0x0;
    210210            out[curIndex++] = 0x0;
  • router/java/src/net/i2p/router/Blocklist.java

    r16bec08f r2baee74  
    473473        if (pinfo == null) return rv;
    474474        Set<RouterAddress> paddr = pinfo.getAddresses();
    475         if (paddr == null || paddr.size() == 0)
     475        if (paddr == null || paddr.isEmpty())
    476476            return rv;
    477477        String oldphost = null;
     
    774774        Set<Integer> singles = new TreeSet();
    775775        singles.addAll(_singleIPBlocklist);
    776         if (singles.size() > 0) {
     776        if (!singles.isEmpty()) {
    777777            out.write("<table><tr><td><b>Transient IPs</b></td></tr>");
    778778            for (Iterator<Integer> iter = singles.iterator(); iter.hasNext(); ) {
  • router/java/src/net/i2p/router/InNetMessagePool.java

    r16bec08f r2baee74  
    357357            Hash from = null;
    358358            synchronized (_pendingDataMessages) {
    359                 if (_pendingDataMessages.size() > 0) {
     359                if (!_pendingDataMessages.isEmpty()) {
    360360                    msg = (I2NPMessage)_pendingDataMessages.remove(0);
    361361                    from = (Hash)_pendingDataMessagesFrom.remove(0);
     
    380380            int remaining = 0;
    381381            synchronized (_pendingGatewayMessages) {
    382                 if (_pendingGatewayMessages.size() > 0)
     382                if (!_pendingGatewayMessages.isEmpty())
    383383                    msg = (I2NPMessage)_pendingGatewayMessages.remove(0);
    384384                remaining = _pendingGatewayMessages.size();
     
    398398                try {
    399399                    synchronized (_pendingGatewayMessages) {
    400                         if (_pendingGatewayMessages.size() <= 0)
     400                        if (_pendingGatewayMessages.isEmpty())
    401401                            _pendingGatewayMessages.wait();
    402402                        else
     
    429429                try {
    430430                    synchronized (_pendingDataMessages) {
    431                         if (_pendingDataMessages.size() <= 0) {
     431                        if (_pendingDataMessages.isEmpty()) {
    432432                            _pendingDataMessages.wait();
    433433                        } else {
  • router/java/src/net/i2p/router/JobQueue.java

    r16bec08f r2baee74  
    384384            // we're still starting up [serially] and we've got at least one runner,
    385385            // so dont do anything
    386             if ( (_queueRunners.size() > 0) && (!_allowParallelOperation) ) return;
     386            if ( (!_queueRunners.isEmpty()) && (!_allowParallelOperation) ) return;
    387387
    388388            // we've already enabled parallel operation, so grow to however many are
  • router/java/src/net/i2p/router/Shitlist.java

    r16bec08f r2baee74  
    211211        } else {
    212212            e.transports.remove(transport);
    213             if (e.transports.size() <= 0)
     213            if (e.transports.isEmpty())
    214214                fully = true;
    215215            else
  • router/java/src/net/i2p/router/message/OutboundClientMessageOneShotJob.java

    r16bec08f r2baee74  
    364364        }
    365365       
    366         if (leases.size() <= 0) {
     366        if (leases.isEmpty()) {
    367367            if (_log.shouldLog(Log.INFO))
    368368                _log.info(getJobId() + ": No leases found from: " + _leaseSet);
     
    537537        if (wantACK) {
    538538            TagSetHandle tsh = null;
    539             if ( (sessKey != null) && (tags != null) && (tags.size() > 0) ) {
     539            if ( (sessKey != null) && (tags != null) && (!tags.isEmpty()) ) {
    540540                if (_leaseSet != null) {
    541541                    SessionKeyManager skm = getContext().clientManager().getClientSessionKeyManager(_from.calculateHash());
  • router/java/src/net/i2p/router/networkdb/kademlia/FloodOnlySearchJob.java

    r16bec08f r2baee74  
    9494                             getContext().routingKeyGenerator().getLastChanged() > getContext().clock().now() - 30*60*1000;
    9595
    96         if (floodfillPeers.size() <= 0) {
     96        if (floodfillPeers.isEmpty()) {
    9797            // ask anybody, they may not return the answer but they will return a few ff peers we can go look up,
    9898            // so this situation should be temporary
     
    100100                _log.warn("Running netDb searches against the floodfill peers, but we don't know any");
    101101            floodfillPeers = new ArrayList(_facade.getAllRouters());
    102             if (floodfillPeers.size() <= 0) {
     102            if (floodfillPeers.isEmpty()) {
    103103                if (_log.shouldLog(Log.ERROR))
    104104                    _log.error("We don't know any peers at all");
     
    257257        getContext().statManager().addRateData("netDb.successTime", System.currentTimeMillis()-_created, System.currentTimeMillis()-_created);
    258258        synchronized (_onFind) {
    259             while (_onFind.size() > 0)
     259            while (!_onFind.isEmpty())
    260260                getContext().jobQueue().addJob((Job)_onFind.remove(0));
    261261        }
  • router/java/src/net/i2p/router/networkdb/kademlia/FloodSearchJob.java

    r16bec08f r2baee74  
    9797                    _onFailed.clear();
    9898                }
    99                 while (removed.size() > 0)
     99                while (!removed.isEmpty())
    100100                    getContext().jobQueue().addJob(removed.remove(0));
    101101                getContext().messageRegistry().unregisterPending(out);
     
    141141                _onFailed.clear();
    142142            }
    143             while (removed.size() > 0)
     143            while (!removed.isEmpty())
    144144                getContext().jobQueue().addJob(removed.remove(0));
    145145        }
     
    156156            _onFind.clear();
    157157        }
    158         while (removed.size() > 0)
     158        while (!removed.isEmpty())
    159159            getContext().jobQueue().addJob(removed.remove(0));
    160160    }
  • router/java/src/net/i2p/router/networkdb/kademlia/FloodfillMonitorJob.java

    r16bec08f r2baee74  
    8484        long now = getContext().clock().now();
    8585        // We know none at all! Must be our turn...
    86         if (floodfillPeers == null || floodfillPeers.size() <= 0) {
     86        if (floodfillPeers == null || floodfillPeers.isEmpty()) {
    8787            _lastChanged = now;
    8888            return true;
  • router/java/src/net/i2p/router/networkdb/kademlia/FloodfillNetworkDatabaseFacade.java

    r16bec08f r2baee74  
    306306        if (onFind != null) {
    307307            synchronized (onFind) {
    308                 if (onFind.size() > 0)
     308                if (!onFind.isEmpty())
    309309                    find = onFind.remove(0);
    310310            }
     
    312312        if (onFailed != null) {
    313313            synchronized (onFailed) {
    314                 if (onFailed.size() > 0)
     314                if (!onFailed.isEmpty())
    315315                    fail = onFailed.remove(0);
    316316            }
  • router/java/src/net/i2p/router/networkdb/kademlia/FloodfillPeerSelector.java

    r16bec08f r2baee74  
    314314            // are we corrupting _sorted here?
    315315            for (int i = rv.size(); i < howMany; i++) {
    316                 if (_sorted.size() <= 0)
     316                if (_sorted.isEmpty())
    317317                    break;
    318318                Hash entry = _sorted.first();
  • router/java/src/net/i2p/router/networkdb/kademlia/FloodfillVerifyStoreJob.java

    r16bec08f r2baee74  
    139139        FloodfillPeerSelector sel = (FloodfillPeerSelector)_facade.getPeerSelector();
    140140        List<Hash> peers = sel.selectFloodfillParticipants(rkey, 1, _ignore, _facade.getKBuckets());
    141         if (peers.size() > 0)
     141        if (!peers.isEmpty())
    142142            return peers.get(0);
    143143       
  • router/java/src/net/i2p/router/networkdb/kademlia/KademliaNetworkDatabaseFacade.java

    r16bec08f r2baee74  
    726726            return "Peer " + key.toBase64() + " published " + DataHelper.formatDuration(age) + " ago";
    727727        } else if (upLongEnough && !routerInfo.isCurrent(ROUTER_INFO_EXPIRATION_SHORT)) {
    728             if (routerInfo.getAddresses().size() <= 0)
     728            if (routerInfo.getAddresses().isEmpty())
    729729                return "Peer " + key.toBase64() + " published > 90m ago with no addresses";
    730730            RouterAddress ra = routerInfo.getTargetAddress("SSU");
  • router/java/src/net/i2p/router/networkdb/kademlia/MessageWrapper.java

    r16bec08f r2baee74  
    7070        TagSetHandle tsh = null;
    7171        PublicKey sentTo = to.getIdentity().getPublicKey();
    72         if (sentTags.size() > 0)
     72        if (!sentTags.isEmpty())
    7373            tsh = skm.tagsDelivered(sentTo, sentKey, sentTags);
    7474        if (_log.shouldLog(Log.DEBUG))
  • router/java/src/net/i2p/router/networkdb/kademlia/PeerSelector.java

    r16bec08f r2baee74  
    141141            List<Hash> rv = new ArrayList(howMany);
    142142            for (int i = 0; i < howMany; i++) {
    143                 if (_sorted.size() <= 0)
     143                if (_sorted.isEmpty())
    144144                    break;
    145145                rv.add(_sorted.remove(_sorted.firstKey()));
  • router/java/src/net/i2p/router/networkdb/kademlia/SearchJob.java

    r16bec08f r2baee74  
    266266            //boolean onlyFloodfill = onlyQueryFloodfillPeers(getContext());
    267267            boolean onlyFloodfill = true;
    268             if (_floodfillPeersExhausted && onlyFloodfill && _state.getPending().size() <= 0) {
     268            if (_floodfillPeersExhausted && onlyFloodfill && _state.getPending().isEmpty()) {
    269269                if (_log.shouldLog(Log.WARN))
    270270                    _log.warn(getJobId() + ": no non-floodfill peers left, and no more pending.  Searched: "
     
    274274            }
    275275            List closestHashes = getClosestRouters(_state.getTarget(), toCheck, attempted);
    276             if ( (closestHashes == null) || (closestHashes.size() <= 0) ) {
    277                 if (_state.getPending().size() <= 0) {
     276            if ( (closestHashes == null) || (closestHashes.isEmpty()) ) {
     277                if (_state.getPending().isEmpty()) {
    278278                    // we tried to find some peers, but there weren't any and no one else is going to answer
    279279                    if (_log.shouldLog(Log.INFO))
     
    747747        List deferred = null;
    748748        synchronized (_deferredSearches) {
    749             if (_deferredSearches.size() > 0) {
     749            if (!_deferredSearches.isEmpty()) {
    750750                deferred = new ArrayList(_deferredSearches);
    751751                _deferredSearches.clear();
  • router/java/src/net/i2p/router/networkdb/kademlia/StoreJob.java

    r16bec08f r2baee74  
    152152        //    closestHashes = getClosestRouters(_state.getTarget(), toCheck, _state.getAttempted());
    153153        closestHashes = getClosestFloodfillRouters(_state.getTarget(), toCheck, _state.getAttempted());
    154         if ( (closestHashes == null) || (closestHashes.size() <= 0) ) {
    155             if (_state.getPending().size() <= 0) {
     154        if ( (closestHashes == null) || (closestHashes.isEmpty()) ) {
     155            if (_state.getPending().isEmpty()) {
    156156                if (_log.shouldLog(Log.INFO))
    157157                    _log.info(getJobId() + ": No more peers left and none pending");
  • router/java/src/net/i2p/router/networkdb/reseed/Reseeder.java

    r16bec08f r2baee74  
    286286
    287287    /** translate */
    288     public String _(String key) {
     288    private String _(String key) {
    289289        return Translate.getString(key, _context, BUNDLE_NAME);
    290290    }
    291291
    292292    /** translate */
    293     public String _(String s, Object o, Object o2) {
     293    private String _(String s, Object o, Object o2) {
    294294        return Translate.getString(s, o, o2, _context, BUNDLE_NAME);
    295295    }
  • router/java/src/net/i2p/router/peermanager/PeerManager.java

    r16bec08f r2baee74  
    227227        synchronized (_capabilitiesByPeer) {
    228228            List peers = locked_getPeers(capability);
    229             if ( (peers != null) && (peers.size() > 0) ) {
     229            if ( (peers != null) && (!peers.isEmpty()) ) {
    230230                index = index % peers.size();
    231231                return (Hash)peers.get(index);
  • router/java/src/net/i2p/router/transport/CommSystemFacadeImpl.java

    r16bec08f r2baee74  
    9292        Vector skews = _manager.getClockSkews();
    9393        if (skews == null ||
    94             skews.size() <= 0 ||
     94            skews.isEmpty() ||
    9595            (skews.size() < 5 && _context.clock().getUpdatedSuccessfully())) {
    9696            return _context.clock().getOffset();
  • router/java/src/net/i2p/router/transport/FIFOBandwidthLimiter.java

    r16bec08f r2baee74  
    444444     */
    445445    private final void locked_satisfyInboundUnlimited(List<Request> satisfied) {
    446         while (_pendingInboundRequests.size() > 0) {
     446        while (!_pendingInboundRequests.isEmpty()) {
    447447            SimpleRequest req = (SimpleRequest)_pendingInboundRequests.remove(0);
    448448            int allocated = req.getPendingInboundRequested();
     
    559559     */
    560560    private final void locked_satisfyOutboundUnlimited(List<Request> satisfied) {
    561         while (_pendingOutboundRequests.size() > 0) {
     561        while (!_pendingOutboundRequests.isEmpty()) {
    562562            SimpleRequest req = (SimpleRequest)_pendingOutboundRequests.remove(0);
    563563            int allocated = req.getPendingOutboundRequested();
  • router/java/src/net/i2p/router/transport/OutboundMessageRegistry.java

    r16bec08f r2baee74  
    186186                    List l = (List)old;
    187187                    l.remove(msg);
    188                     if (l.size() > 0) {
     188                    if (!l.isEmpty()) {
    189189                        _selectorToMessage.put(sel, l);
    190190                        stillActive = true;
     
    222222                }
    223223            }
    224             if (removing.size() > 0) {
     224            if (!removing.isEmpty()) {
    225225                for (int i = 0; i < removing.size(); i++) {
    226226                    MessageSelector sel = (MessageSelector)removing.get(i);
  • router/java/src/net/i2p/router/transport/TransportImpl.java

    r16bec08f r2baee74  
    148148        OutNetMessage msg = null;
    149149        synchronized (_sendPool) {
    150             if (_sendPool.size() <= 0) return null;
     150            if (_sendPool.isEmpty()) return null;
    151151            msg = (OutNetMessage)_sendPool.remove(0); // use priority queues later
    152152        }
  • router/java/src/net/i2p/router/transport/TransportManager.java

    r16bec08f r2baee74  
    8585        if (enableNTCP(_context))
    8686            addTransport(new NTCPTransport(_context));
    87         if (_transports.size() <= 0)
     87        if (_transports.isEmpty())
    8888            _log.log(Log.CRIT, "No transports are enabled");
    8989    }
     
    224224      */
    225225    public boolean haveHighOutboundCapacity() {
    226         if (_transports.size() <= 0)
     226        if (_transports.isEmpty())
    227227            return false;
    228228        for (int i = 0; i < _transports.size(); i++) {
     
    256256        for (int i = 0; i < _transports.size(); i++) {
    257257            Vector tempSkews = _transports.get(i).getClockSkews();
    258             if ((tempSkews == null) || (tempSkews.size() <= 0)) continue;
     258            if ((tempSkews == null) || (tempSkews.isEmpty())) continue;
    259259            skews.addAll(tempSkews);
    260260        }
     
    374374    public TransportBid getBid(OutNetMessage msg) {
    375375        List<TransportBid> bids = getBids(msg);
    376         if ( (bids == null) || (bids.size() <= 0) )
     376        if ( (bids == null) || (bids.isEmpty()) )
    377377            return null;
    378378        else
  • router/java/src/net/i2p/router/transport/UPnP.java

    r16bec08f r2baee74  
    392392        private void listSubServices(Device dev, StringBuilder sb) {
    393393                ServiceList sl = dev.getServiceList();
    394                 if (sl.size() <= 0)
     394                if (sl.isEmpty())
    395395                        return;
    396396                sb.append("<ul>\n");
     
    441441               
    442442                DeviceList dl = dev.getDeviceList();
    443                 if (dl.size() <= 0)
     443                if (dl.isEmpty())
    444444                        return;
    445445                sb.append("<ul>\n");
  • router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java

    r16bec08f r2baee74  
    488488            }
    489489                //throw new RuntimeException("We should not be preparing a write while we still have one pending");
    490             if (_outbound.size() > 0) {
     490            if (!_outbound.isEmpty()) {
    491491                msg = (OutNetMessage)_outbound.remove(0);
    492492                _currentOutbound = msg;
     
    712712    private PrepBuffer acquireBuf() {
    713713        synchronized (_bufs) {
    714             if (_bufs.size() > 0) {
     714            if (!_bufs.isEmpty()) {
    715715                PrepBuffer b = (PrepBuffer)_bufs.remove(0);
    716716                b.acquired();
  • router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java

    r16bec08f r2baee74  
    560560        for (int i = 0; expired != null && i < expired.size(); i++)
    561561            ((NTCPConnection)expired.get(i)).close();
    562         if ( (expired != null) && (expired.size() > 0) )
     562        if ( (expired != null) && (!expired.isEmpty()) )
    563563            _context.statManager().addRateData("ntcp.outboundEstablishFailed", expired.size(), 0);
    564564    }
     
    764764        }
    765765
    766         if (peers.size() > 0) {
     766        if (!peers.isEmpty()) {
    767767//            buf.append("<tr> <td colspan=\"11\"><hr></td></tr>\n");
    768768            buf.append("<tr class=\"tablefooter\"><td align=\"center\"><b>").append(peers.size()).append(' ').append(_("peers")).append("</b></td><td>&nbsp;</td><td>&nbsp;");
    769769            buf.append("</td><td align=\"center\"><b>").append(formatRate(bpsRecv/1024)).append("/").append(formatRate(bpsSend/1024)).append("</b>");
    770770            buf.append("</td><td align=\"center\"><b>").append(DataHelper.formatDuration(totalUptime/peers.size()));
    771             buf.append("</b></td><td align=\"center\"><b>").append(peers.size() > 0 ? DataHelper.formatDuration(offsetTotal*1000/peers.size()) : "0ms");
     771            buf.append("</b></td><td align=\"center\"><b>").append((!peers.isEmpty()) ? DataHelper.formatDuration(offsetTotal*1000/peers.size()) : "0ms");
    772772            buf.append("</b></td><td align=\"center\"><b>").append(totalSend).append("</b></td><td align=\"center\"><b>").append(totalRecv);
    773773            buf.append("</b></td><td>&nbsp;</td><td>&nbsp;</td></tr>\n");
  • router/java/src/net/i2p/router/transport/ntcp/Reader.java

    r16bec08f r2baee74  
    4141    }
    4242    public void stopReading() {
    43         while (_runners.size() > 0) {
     43        while (!_runners.isEmpty()) {
    4444            Runner r = _runners.remove(0);
    4545            r.stop();
     
    9191                            _liveReads.remove(con);
    9292                            con = null;
    93                             if (_pendingConnections.size() <= 0) {
     93                            if (_pendingConnections.isEmpty()) {
    9494                                _pendingConnections.wait();
    9595                            } else {
  • router/java/src/net/i2p/router/transport/ntcp/Writer.java

    r16bec08f r2baee74  
    4040    }
    4141    public void stopWriting() {
    42         while (_runners.size() > 0) {
     42        while (!_runners.isEmpty()) {
    4343            Runner r = _runners.remove(0);
    4444            r.stop();
     
    9696                            _liveWrites.remove(con);
    9797                            con = null;
    98                             if (_pendingConnections.size() <= 0) {
     98                            if (_pendingConnections.isEmpty()) {
    9999                                if (_log.shouldLog(Log.DEBUG))
    100100                                    _log.debug("Done writing, but nothing pending, so wait");
  • router/java/src/net/i2p/router/transport/udp/EstablishmentManager.java

    r16bec08f r2baee74  
    360360    private int locked_admitQueued() {
    361361        int admitted = 0;
    362         while ( (_queuedOutbound.size() > 0) && (_outboundStates.size() < getMaxConcurrentEstablish()) ) {
     362        while ( (!_queuedOutbound.isEmpty()) && (_outboundStates.size() < getMaxConcurrentEstablish()) ) {
    363363            // ok, active shrunk, lets let some queued in.  duplicate the synchronized
    364364            // section from the add(
     
    367367            List queued = (List)_queuedOutbound.remove(to);
    368368
    369             if (queued.size() <= 0)
     369            if (queued.isEmpty())
    370370                continue;
    371371           
  • router/java/src/net/i2p/router/transport/udp/PacketBuilder.java

    r16bec08f r2baee74  
    132132        }
    133133
    134         if ( (partialACKsRemaining != null) && (partialACKsRemaining.size() > 0) ) {
     134        if ( (partialACKsRemaining != null) && (!partialACKsRemaining.isEmpty()) ) {
    135135            int origNumRemaining = partialACKsRemaining.size();
    136136            int numPartialOffset = off;
  • router/java/src/net/i2p/router/transport/udp/PeerState.java

    r16bec08f r2baee74  
    750750            if (_currentACKs.isEmpty())
    751751                _wantACKSendSince = -1;
    752             if (alwaysIncludeRetransmissions || rv.size() > 0) {
     752            if (alwaysIncludeRetransmissions || !rv.isEmpty()) {
    753753                // now repeat by putting in some old ACKs
    754754                // randomly selected from the Resend queue.
  • router/java/src/net/i2p/router/transport/udp/UDPFlooder.java

    r16bec08f r2baee74  
    6767            try {
    6868                synchronized (_peers) {
    69                     if (_peers.size() <= 0)
     69                    if (_peers.isEmpty())
    7070                        _peers.wait();
    7171                }
  • router/java/src/net/i2p/router/transport/udp/UDPSender.java

    r16bec08f r2baee74  
    107107                    // clear out any too-old packets
    108108                    UDPPacket head = null;
    109                     if (_outboundQueue.size() > 0) {
     109                    if (!_outboundQueue.isEmpty()) {
    110110                        head = (UDPPacket)_outboundQueue.get(0);
    111111                        while (head.getLifetime() > MAX_HEAD_LIFETIME) {
    112112                            _outboundQueue.remove(0);
    113113                            removed++;
    114                             if (_outboundQueue.size() > 0)
     114                            if (!_outboundQueue.isEmpty())
    115115                                head = (UDPPacket)_outboundQueue.get(0);
    116116                            else
  • router/java/src/net/i2p/router/tunnel/BatchedPreprocessor.java

    r16bec08f r2baee74  
    138138       
    139139        // loop until the queue is empty
    140         while (pending.size() > 0) {
     140        while (!pending.isEmpty()) {
    141141            int allocated = 0;
    142142            long beforePendingLoop = System.currentTimeMillis();
     
    253253                    }
    254254
    255                     if (pending.size() > 0) {
     255                    if (!pending.isEmpty()) {
    256256                        // rare
    257257                        _pendingSince = _context.clock().now();
  • router/java/src/net/i2p/router/tunnel/PumpedTunnelGateway.java

    r16bec08f r2baee74  
    8686    void pump(List<Pending> queueBuf) {
    8787        synchronized (_prequeue) {
    88             if (_prequeue.size() > 0) {
     88            if (!_prequeue.isEmpty()) {
    8989                queueBuf.addAll(_prequeue);
    9090                _prequeue.clear();
  • router/java/src/net/i2p/router/tunnel/TrivialPreprocessor.java

    r16bec08f r2baee74  
    6060            buf.append("Trivial preprocessing of ").append(pending.size()).append(" ");
    6161        }
    62         while (pending.size() > 0) {
     62        while (!pending.isEmpty()) {
    6363            TunnelGateway.Pending msg = pending.remove(0);
    6464            long beforePreproc = System.currentTimeMillis();
  • router/java/src/net/i2p/router/tunnel/TunnelDispatcher.java

    r16bec08f r2baee74  
    650650
    651651       List<HopConfig> partTunnels = listParticipatingTunnels();
    652        if ((partTunnels == null) || (partTunnels.size() == 0)) {
     652       if ((partTunnels == null) || (partTunnels.isEmpty())) {
    653653           if (_log.shouldLog(Log.ERROR))
    654654               _log.error("Not dropping tunnel, since partTunnels was null or had 0 items!");
     
    746746            boolean noTunnels;
    747747            synchronized (LeaveTunnel.this) {
    748                 noTunnels = _configs.size() <= 0;
     748                noTunnels = _configs.isEmpty();
    749749                _configs.add(cfg);
    750750                _times.add(dropTime);
     
    778778            while (true) {
    779779                synchronized (LeaveTunnel.this) {
    780                     if (_configs.size() <= 0)
     780                    if (_configs.isEmpty())
    781781                        return;
    782782                    nextTime = _times.get(0);
     
    784784                        cur = _configs.remove(0);
    785785                        _times.remove(0);
    786                         if (_times.size() > 0)
     786                        if (!_times.isEmpty())
    787787                            nextTime = _times.get(0);
    788788                        else
  • router/java/src/net/i2p/router/tunnel/TunnelGateway.java

    r16bec08f r2baee74  
    295295                //    System.out.println("foo!");
    296296                afterChecked = _context.clock().now();
    297                 if (_queue.size() > 0) {
     297                if (!_queue.isEmpty()) {
    298298                    if ( (remaining > 0) && (_log.shouldLog(Log.DEBUG)) )
    299299                        _log.debug("Remaining before delayed flush preprocessing: " + _queue);
  • router/java/src/net/i2p/router/tunnel/pool/BuildExecutor.java

    r16bec08f r2baee74  
    299299                    }
    300300                } else {
    301                     if ( (allowed > 0) && (wanted.size() > 0) ) {
     301                    if ( (allowed > 0) && (!wanted.isEmpty()) ) {
    302302                        Collections.shuffle(wanted, _context.random());
    303303                        Collections.sort(wanted, new TunnelPoolComparator());
     
    308308                            allowed = 2;
    309309                       
    310                         for (int i = 0; (i < allowed) && (wanted.size() > 0); i++) {
     310                        for (int i = 0; (i < allowed) && (!wanted.isEmpty()); i++) {
    311311                            TunnelPool pool = wanted.remove(0);
    312312                            //if (pool.countWantedTunnels() <= 0)
  • router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java

    r16bec08f r2baee74  
    140140                            break;
    141141                        }
    142                     } while (_inboundBuildMessages.size() > 0);
     142                    } while (!_inboundBuildMessages.isEmpty());
    143143                   
    144144                    if (dropExpired > 0)
     
    147147                    // now pull off the oldest requests first (we're doing a tail-drop
    148148                    // when adding)
    149                     for (int i = 0; i < toHandle && _inboundBuildMessages.size() > 0; i++)
     149                    for (int i = 0; i < toHandle && !_inboundBuildMessages.isEmpty(); i++)
    150150                        handled.add(_inboundBuildMessages.remove(0));
    151151                //}
  • router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java

    r16bec08f r2baee74  
    153153            _lastSelected = null;
    154154
    155             if (_tunnels.size() <= 0) {
     155            if (_tunnels.isEmpty()) {
    156156                if (_log.shouldLog(Log.WARN))
    157157                    _log.warn(toString() + ": No tunnels to select from");
     
    484484                _log.warn(toString() + ": Not enough tunnels (" + _tunnels.size() + ", wanted " + wanted + ")");
    485485            // see comment below
    486             if (_tunnels.size() <= 0)
     486            if (_tunnels.isEmpty())
    487487                return null;
    488488        }
     
    539539            if (_log.shouldLog(Log.WARN))
    540540                _log.warn(toString() + ": Not enough leases (" + leases.size() + ", wanted " + wanted + ")");
    541             if (leases.size() <= 0)
     541            if (leases.isEmpty())
    542542                return null;
    543543        }
     
    859859        if (!forceZeroHop) {
    860860            peers = _peerSelector.selectPeers(_context, settings);
    861             if ( (peers == null) || (peers.size() <= 0) ) {
     861            if ( (peers == null) || (peers.isEmpty()) ) {
    862862                // no inbound or outbound tunnels to send the request through, and
    863863                // the pool is refusing 0 hop tunnels
Note: See TracChangeset for help on using the changeset viewer.