Changeset 32566a4


Ignore:
Timestamp:
May 27, 2009 3:47:49 PM (11 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
be480d5
Parents:
2f1d6e3f
Message:

remove some unused UDP stats and test code

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

Legend:

Unmodified
Added
Removed
  • router/java/src/net/i2p/router/transport/udp/OutboundMessageFragments.java

    r2f1d6e3f r32566a4  
    6464        _context.statManager().createRateStat("udp.sendPiggyback", "How many acks were piggybacked on a data packet (time == message lifetime)", "udp", new long[] { 60*1000, 10*60*1000, 60*60*1000, 24*60*60*1000 });
    6565        _context.statManager().createRateStat("udp.sendPiggybackPartial", "How many partial acks were piggybacked on a data packet (time == message lifetime)", "udp", new long[] { 60*1000, 10*60*1000, 60*60*1000, 24*60*60*1000 });
    66         _context.statManager().createRateStat("udp.activeDelay", "How often we wait blocking on the active queue", "udp", new long[] { 60*1000, 10*60*1000, 60*60*1000, 24*60*60*1000 });
    6766        _context.statManager().createRateStat("udp.packetsRetransmitted", "Lifetime of packets during their retransmission (period == packets transmitted, lifetime)", "udp", new long[] { 60*1000, 10*60*1000, 60*60*1000, 24*60*60*1000 });
    6867        _context.statManager().createRateStat("udp.peerPacketsRetransmitted", "How many packets have been retransmitted to the peer (lifetime) when a burst of packets are retransmitted (period == packets transmitted, lifetime)", "udp", new long[] { 60*1000, 10*60*1000, 60*60*1000, 24*60*60*1000 });
  • router/java/src/net/i2p/router/transport/udp/UDPPacket.java

    r2f1d6e3f r32566a4  
    7676
    7777    private UDPPacket(I2PAppContext ctx, boolean inbound) {
    78         ctx.statManager().createRateStat("udp.packetsLiveInbound", "Number of live inbound packets in memory", "udp", new long[] { 60*1000, 5*60*1000 });
    79         ctx.statManager().createRateStat("udp.packetsLiveOutbound", "Number of live outbound packets in memory", "udp", new long[] { 60*1000, 5*60*1000 });
    80         ctx.statManager().createRateStat("udp.packetsLivePendingRecvInbound", "Number of live inbound packets not yet handled by the PacketHandler", "udp", new long[] { 60*1000, 5*60*1000 });
    81         ctx.statManager().createRateStat("udp.packetsLivePendingHandleInbound", "Number of live inbound packets not yet handled fully by the PacketHandler", "udp", new long[] { 60*1000, 5*60*1000 });
    8278        ctx.statManager().createRateStat("udp.fetchRemoteSlow", "How long it takes to grab the remote ip info", "udp", new long[] { 60*1000 });
    8379        // the data buffer is clobbered on init(..), but we need it to bootstrap
  • router/java/src/net/i2p/router/transport/udp/UDPReceiver.java

    r2f1d6e3f r32566a4  
    4545        _context.statManager().createRateStat("udp.receiveRemaining", "How many packets are left sitting on the receiver's queue", "udp", new long[] { 60*1000, 10*60*1000, 60*60*1000 });
    4646        _context.statManager().createRateStat("udp.droppedInbound", "How many packet are queued up but not yet received when we drop", "udp", new long[] { 60*1000, 10*60*1000, 60*60*1000 });
    47         _context.statManager().createRateStat("udp.droppedInboundProbabalistically", "How many packet we drop probabalistically (to simulate failures)", "udp", new long[] { 60*1000, 5*60*1000, 10*60*1000, 60*60*1000 });
    48         _context.statManager().createRateStat("udp.acceptedInboundProbabalistically", "How many packet we accept probabalistically (to simulate failures)", "udp", new long[] { 60*1000, 5*60*1000, 10*60*1000, 60*60*1000 });
    4947        _context.statManager().createRateStat("udp.receiveHolePunch", "How often we receive a NAT hole punch", "udp", new long[] { 60*1000, 5*60*1000, 10*60*1000, 60*60*1000 });
    5048        _context.statManager().createRateStat("udp.ignorePacketFromDroplist", "Packet lifetime for those dropped on the drop list", "udp", new long[] { 60*1000, 10*60*1000, 60*60*1000 });
     
    5250   
    5351    public void startup() {
    54         adjustDropProbability();
     52        //adjustDropProbability();
    5553        _keepRunning = true;
    5654        I2PThread t = new I2PThread(_runner, _name + "." + _id);
     
    6765    }
    6866   
     67/*********
    6968    private void adjustDropProbability() {
    7069        String p = _context.getProperty("i2np.udp.dropProbability");
     
    7877        }
    7978    }
     79**********/
    8080   
    8181    /**
     
    9191    private static final long MAX_QUEUE_PERIOD = 2*1000;
    9292   
     93/*********
    9394    private static int ARTIFICIAL_DROP_PROBABILITY = 0; // 4
    9495   
    9596    private static final int ARTIFICIAL_DELAY = 0; // 200;
    9697    private static final int ARTIFICIAL_DELAY_BASE = 0; //600;
     98**********/
    9799   
    98100    private int receive(UDPPacket packet) {
     101/*********
    99102        //adjustDropProbability();
    100103       
     
    102105            // the first check is to let the compiler optimize away this
    103106            // random block on the live system when the probability is == 0
     107            // (not if it isn't final jr)
    104108            int v = _context.random().nextInt(100);
    105109            if (v <= ARTIFICIAL_DROP_PROBABILITY) {
     
    120124            return -1;
    121125        }
     126**********/
    122127       
    123128        return doReceive(packet);
Note: See TracChangeset for help on using the changeset viewer.