|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Packet | |
---|---|
net.i2p.client.streaming | Implements a TCP-like (reliable, authenticated, in order) set of sockets for communicating over the IP-like (unreliable, unauthenticated, unordered) I2P messages. |
Uses of Packet in net.i2p.client.streaming |
---|
Subclasses of Packet in net.i2p.client.streaming | |
---|---|
class |
PacketLocal
coordinate local attributes about a packet - send time, ack time, number of retries, etc. |
Methods in net.i2p.client.streaming with parameters of type Packet | |
---|---|
(package private) void |
PacketHandler.displayPacket(Packet packet,
String prefix,
String suffix)
|
Connection |
ConnectionManager.receiveConnection(Packet synPacket)
Create a new connection based on the SYN packet we received. |
void |
ConnectionHandler.receiveNewSyn(Packet packet)
Non-SYN packets with a zero SendStreamID may also be queued here so that they don't get thrown away while the SYN packet before it is queued. |
(package private) void |
PacketHandler.receivePacket(Packet packet)
private boolean choke(Packet packet) { if (true) return true; //if ( (_dropped == 0) && true ) { //&& (_manager.getSent() <= 0) ) { // _dropped++; // return false; //} if (true) { // artificial choke: 2% random drop and a 0-5s // random tiered delay from 0-30s if (_context.random().nextInt(100) >= 98) { displayPacket(packet, "DROP", null); return false; } else { // if (true) return true; // no lag, just drop // int delay = _context.random().nextInt(5*1000); int delay = _context.random().nextInt(1*1000); int delayFactor = _context.random().nextInt(100); if (delayFactor > 80) { if (delayFactor > 98) delay *= 5; else if (delayFactor > 95) delay *= 4; else if (delayFactor > 90) delay *= 3; else delay *= 2; } if (_context.random().nextInt(100) >= 20) delay = _lastDelay; _lastDelay = delay; SimpleTimer.getInstance().addEvent(new Reinject(packet, delay), delay); return false; } } else { return true; } } private class Reinject implements SimpleTimer.TimedEvent { private Packet _packet; private int _delay; public Reinject(Packet packet, int delay) { _packet = packet; _delay = delay; } public void timeReached() { _log.debug("Reinjecting after " + _delay + ": " + _packet); receivePacketDirect(_packet); } } |
(package private) void |
ConnectionPacketHandler.receivePacket(Packet packet,
Connection con)
distribute a packet to the connection specified |
(package private) void |
PacketHandler.receivePacketDirect(Packet packet,
boolean queueIfNoConn)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |