Changeset 021375b


Ignore:
Timestamp:
Dec 20, 2018 10:58:30 AM (19 months ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
18b7d97
Parents:
8a06027
Message:

NTCP: More now() calls out of loops

Files:
4 edited

Legend:

Unmodified
Added
Removed
  • apps/routerconsole/java/src/net/i2p/router/web/helpers/PeerHelper.java

    r8a06027 r021375b  
    289289        out.write(buf.toString());
    290290        buf.setLength(0);
     291        long now = _context.clock().now();
    291292        for (NTCPConnection con : peers) {
    292293            buf.append("<tr><td class=\"cells\" align=\"left\" nowrap>");
     
    307308            buf.append("</td><td class=\"cells peeripv6\" align=\"center\">").append(con.getVersion());
    308309            buf.append("</td><td class=\"cells\" align=\"center\"><span class=\"right\">");
    309             buf.append(DataHelper.formatDuration2(con.getTimeSinceReceive()));
    310             buf.append("</span>").append(THINSP).append("<span class=\"left\">").append(DataHelper.formatDuration2(con.getTimeSinceSend()));
     310            buf.append(DataHelper.formatDuration2(con.getTimeSinceReceive(now)));
     311            buf.append("</span>").append(THINSP).append("<span class=\"left\">").append(DataHelper.formatDuration2(con.getTimeSinceSend(now)));
    311312            buf.append("</span></td><td class=\"cells\" align=\"center\"><span class=\"right\">");
    312             if (con.getTimeSinceReceive() < 2*60*1000) {
     313            if (con.getTimeSinceReceive(now) < 2*60*1000) {
    313314                float r = con.getRecvRate();
    314315                buf.append(formatRate(r / 1000));
     
    318319            }
    319320            buf.append("</span>").append(THINSP).append("<span class=\"left\">");
    320             if (con.getTimeSinceSend() < 2*60*1000) {
     321            if (con.getTimeSinceSend(now) < 2*60*1000) {
    321322                float r = con.getSendRate();
    322323                buf.append(formatRate(r / 1000));
  • router/java/src/net/i2p/router/transport/ntcp/EventPumper.java

    r8a06027 r021375b  
    263263                                if ((!key.isValid()) &&
    264264                                    (!((SocketChannel)key.channel()).isConnectionPending()) &&
    265                                     con.getTimeSinceCreated() > 2 * NTCPTransport.ESTABLISH_TIMEOUT) {
     265                                    con.getTimeSinceCreated(now) > 2 * NTCPTransport.ESTABLISH_TIMEOUT) {
    266266                                    if (_log.shouldLog(Log.INFO))
    267267                                        _log.info("Removing invalid key for " + con);
     
    294294                                }
    295295
    296                                 if ( con.getTimeSinceSend() > expire &&
    297                                      con.getTimeSinceReceive() > expire) {
     296                                if ( con.getTimeSinceSend(now) > expire &&
     297                                     con.getTimeSinceReceive(now) > expire) {
    298298                                    // we haven't sent or received anything in a really long time, so lets just close 'er up
    299299                                    con.sendTerminationAndClose();
  • router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java

    r8a06027 r021375b  
    417417    public long getTimeSinceSend() { return _context.clock().now()-_lastSendTime; }
    418418   
     419    /**
     420     * @return milliseconds
     421     * @since 0.9.38
     422     */
    419423    public long getTimeSinceSend(long now) { return now - _lastSendTime; }
    420424
     
    422426    public long getTimeSinceReceive() { return _context.clock().now()-_lastReceiveTime; }
    423427   
     428    /**
     429     * @return milliseconds
     430     * @since 0.9.38
     431     */
    424432    public long getTimeSinceReceive(long now) { return now - _lastReceiveTime; }
    425433
    426434    /** @return milliseconds */
    427435    public long getTimeSinceCreated() { return _context.clock().now()-_created; }
     436
     437    /**
     438     * @return milliseconds
     439     * @since 0.9.38
     440     */
     441    public long getTimeSinceCreated(long now) { return now -_created; }
    428442
    429443    /**
  • router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java

    r8a06027 r021375b  
    708708     */
    709709    public int countActivePeers() {
    710         final long now = _context.clock().now();
     710        final long now = _context.clock().now();
    711711        int active = 0;
    712712        for (NTCPConnection con : _conByIdent.values()) {
     
    725725     */
    726726    public int countActiveSendPeers() {
     727        final long now = _context.clock().now();
    727728        int active = 0;
    728729        for (NTCPConnection con : _conByIdent.values()) {
    729730            // con initializes times at construction,
    730731            // so check message count also
    731             if (con.getMessagesSent() > 0 && con.getTimeSinceSend() <= 60*1000) {
     732            if (con.getMessagesSent() > 0 && con.getTimeSinceSend(now) <= 60*1000) {
    732733                active++;
    733734            }
     
    11051106    void expireTimedOut() {
    11061107        int expired = 0;
     1108        final long now = _context.clock().now();
    11071109
    11081110            for (Iterator<NTCPConnection> iter = _establishing.iterator(); iter.hasNext(); ) {
     
    11101112                if (con.isClosed() || con.isEstablished()) {
    11111113                    iter.remove();
    1112                 } else if (con.getTimeSinceCreated() > ESTABLISH_TIMEOUT) {
     1114                } else if (con.getTimeSinceCreated(now) > ESTABLISH_TIMEOUT) {
    11131115                    iter.remove();
    11141116                    con.close();
Note: See TracChangeset for help on using the changeset viewer.