net.i2p.router.tunnel
public class TunnelParticipant extends Object
Constructor and Description |
---|
TunnelParticipant(RouterContext ctx,
HopConfig config,
HopProcessor processor) |
TunnelParticipant(RouterContext ctx,
InboundEndpointProcessor inEndProc) |
Modifier and Type | Method and Description |
---|---|
void |
dispatch(TunnelDataMessage msg,
Hash recvFrom) |
int |
getCompleteCount()
private void incrementThroughput(Hash prev) {
if (true) return;
long now = System.currentTimeMillis();
long timeSince = now - _lastCoallesced;
if (timeSince >= 60*1000) {
int amount = 1024 * _periodMessagesTransferred;
int normalized = (int)((double)amount * 60d*1000d / (double)timeSince);
_periodMessagesTransferred = 0;
_lastCoallesced = now;
_context.profileManager().tunnelDataPushed1m(prev, normalized);
} else {
_periodMessagesTransferred++;
}
}
|
int |
getFailedCount() |
String |
toString() |
public TunnelParticipant(RouterContext ctx, HopConfig config, HopProcessor processor)
public TunnelParticipant(RouterContext ctx, InboundEndpointProcessor inEndProc)
public void dispatch(TunnelDataMessage msg, Hash recvFrom)
public int getCompleteCount()
public int getFailedCount()