Changeset 871f046


Ignore:
Timestamp:
Sep 8, 2012 12:23:43 PM (8 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
33de6be
Parents:
aef021d
Message:

adjust target and interval, and backlogged indication

Location:
router/java/src/net/i2p/router/util
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • router/java/src/net/i2p/router/util/CoDelBlockingQueue.java

    raef021d r871f046  
    5454     *  above 5 ms there is very little or no improvement in utilization.
    5555     *
     56     *  I2P: Raise to 15 due to multithreading environment
     57     *
    5658     *  Maybe need to make configurable per-instance.
    5759     */
    58     private static final long TARGET = 5;
     60    private static final long TARGET = 15;
    5961
    6062    /**
     
    180182        if (e == null)
    181183            return false;
    182         return _context.clock().now() - e.getEnqueueTime() >= BACKLOG_TIME ||
     184        return _dropping ||
     185               _context.clock().now() - e.getEnqueueTime() >= BACKLOG_TIME ||
    183186               remainingCapacity() < _capacity / 4;
    184187    }
  • router/java/src/net/i2p/router/util/CoDelPriorityBlockingQueue.java

    raef021d r871f046  
    5757     *  above 5 ms there is very little or no improvement in utilization.
    5858     *
     59     *  I2P: Raise to 15 due to multithreading environment
     60     *
    5961     *  Maybe need to make configurable per-instance.
    6062     */
    61     private static final long TARGET = 5;
     63    private static final long TARGET = 15;
    6264
    6365    /**
     
    6567     *  A setting of 100 ms works well across a range of RTTs from 10 ms to 1 second
    6668     *
     69     *  I2P: Raise to 300 due to longer end-to-end RTTs
     70     *
    6771     *  Maybe need to make configurable per-instance.
    6872     */
    69     private static final long INTERVAL = 100;
     73    private static final long INTERVAL = 300;
    7074    //private static final int MAXPACKET = 512;
    7175
     
    165169        if (e == null)
    166170            return false;
    167         return _context.clock().now() - e.getEnqueueTime() >= BACKLOG_TIME ||
     171        return _dropping ||
     172               _context.clock().now() - e.getEnqueueTime() >= BACKLOG_TIME ||
    168173               size() >= BACKLOG_SIZE;
    169174    }
Note: See TracChangeset for help on using the changeset viewer.