Changeset 2cddf14


Ignore:
Timestamp:
Sep 4, 2012 12:27:04 AM (8 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
9286d6a
Parents:
8575437
Message:

log tweaks

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

Legend:

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

    r8575437 r2cddf14  
    44import java.util.concurrent.LinkedBlockingQueue;
    55import java.util.concurrent.TimeUnit;
     6import java.util.concurrent.atomic.AtomicLong;
    67
    78import net.i2p.I2PAppContext;
     
    4344    private long _now;
    4445
     46    /** debugging */
     47    private static final AtomicLong __id = new AtomicLong();
     48    private final long _id;
     49
    4550    /**
    4651     *  Quote:
     
    7782        ctx.statManager().createRequiredRateStat(STAT_DROP, "queue delay of dropped items", "Router", RATES);
    7883        ctx.statManager().createRequiredRateStat(STAT_DELAY, "average queue delay", "Router", RATES);
     84        _id = __id.incrementAndGet();
    7985    }
    8086
     
    277283        _context.statManager().addRateData(STAT_DROP, delay);
    278284        if (_log.shouldLog(Log.WARN))
    279             _log.warn(_name + " dropped item with delay " + delay + ", " +
     285            _log.warn("CDQ #" + _id + ' ' + _name + " dropped item with delay " + delay + ", " +
    280286                      DataHelper.formatDuration(_context.clock().now() - _first_above_time) + " since first above, " +
     287                      DataHelper.formatDuration(_context.clock().now() - _drop_next) + " since drop next, " +
    281288                      (_count+1) + " dropped in this phase, " +
    282289                      size() + " remaining in queue: " + entry);
  • router/java/src/net/i2p/router/util/CoDelPriorityBlockingQueue.java

    r8575437 r2cddf14  
    4848    private int _lastDroppedPriority;
    4949
     50    /** debugging */
     51    static final AtomicLong __id = new AtomicLong();
     52    private final long _id;
     53
    5054    /**
    5155     *  Quote:
     
    8892        }
    8993        ctx.statManager().createRequiredRateStat(STAT_DELAY, "average queue delay", "Router", RATES);
     94        _id = __id.incrementAndGet();
    9095    }
    9196
     
    297302        _context.statManager().addRateData(STAT_DROP + entry.getPriority(), delay);
    298303        if (_log.shouldLog(Log.WARN))
    299             _log.warn(_name + " dropped item with delay " + delay + ", priority " +
     304            _log.warn("CDPQ #" + _id + ' ' + _name + " dropped item with delay " + delay + ", priority " +
    300305                      entry.getPriority() + ", seq " +
    301306                      entry.getSeqNum() + ", " +
    302307                      DataHelper.formatDuration(_context.clock().now() - _first_above_time) + " since first above, " +
     308                      DataHelper.formatDuration(_context.clock().now() - _drop_next) + " since drop next, " +
    303309                      (_count+1) + " dropped in this phase, " +
    304310                      size() + " remaining in queue: " + entry);
Note: See TracChangeset for help on using the changeset viewer.