Changeset 021375b for router


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

NTCP: More now() calls out of loops

Location:
router/java/src/net/i2p/router/transport/ntcp
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • 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.