Changeset 5ec6dca6


Ignore:
Timestamp:
Aug 23, 2005 10:43:51 PM (15 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
346faa3
Parents:
1a6b49c
git-author:
jrandom <jrandom> (08/23/05 22:43:51)
git-committer:
zzz <zzz@…> (08/23/05 22:43:51)
Message:

2005-08-23 jrandom

  • Removed the concept of "no bandwidth limit" - if none is specified, its 16KBps in/out.
  • Include ack packets in the per-peer cwin throttle (they were part of the bandwidth limit though).
  • Tweak the SSU cwin operation to get more accurrate estimates under congestions.
  • SSU improvements to resend more efficiently.
  • Added a basic scheduler to eepget to fetch multiple files sequentially.
Location:
router/java/src/net/i2p/router/transport/udp
Files:
2 edited

Legend:

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

    r1a6b49c r5ec6dca6  
    110110                    if (_log.shouldLog(Log.INFO))
    111111                        _log.info("Sending ACK for " + ackBitfields);
     112                    boolean ok = peer.allocateSendingBytes(ack.getPacket().getLength(), true);
     113                    // ignore whether its ok or not, its a bloody ack.  this should be fixed, probably.
    112114                    _transport.send(ack);
    113115                   
  • router/java/src/net/i2p/router/transport/udp/UDPTransport.java

    r1a6b49c r5ec6dca6  
    885885            buf.append("KBps/");
    886886            buf.append(formatKBps(peer.getSendBps()));
    887             buf.append("KBps</td>");
     887            buf.append("KBps ");
     888            //buf.append(formatKBps(peer.getReceiveACKBps()));
     889            //buf.append("KBps/");
     890            //buf.append(formatKBps(peer.getSendACKBps()));
     891            //buf.append("KBps ");
     892            buf.append("</td>");
    888893
    889894            buf.append("<td>");
     
    924929            buf.append("</td>");
    925930           
    926             double sendLostPct = (double)peer.getPacketsRetransmitted()/(double)PeerState.RETRANSMISSION_PERIOD_WIDTH;
     931            double sent = (double)peer.getPacketsPeriodTransmitted();
     932            double sendLostPct = 0;
     933            if (sent > 0)
     934                sendLostPct = (double)peer.getPacketsRetransmitted()/(sent);
     935           
    927936            buf.append("<td>");
    928937            //buf.append(formatPct(sendLostPct));
    929             buf.append(peer.getPacketRetransmissionRate());
     938            buf.append(peer.getPacketsRetransmitted()); // + "/" + peer.getPacketsPeriodRetransmitted() + "/" + sent);
     939            //buf.append(peer.getPacketRetransmissionRate());
    930940            buf.append("</td>");
    931941           
Note: See TracChangeset for help on using the changeset viewer.