forked from I2P_Developers/i2p.i2p
javadoc, log, comment, and su3file help tweaks
This commit is contained in:
@ -29,6 +29,7 @@ class OutboundTunnelEndpoint {
|
||||
_handler = new RouterFragmentHandler(ctx, new DefragmentedHandler());
|
||||
_outDistributor = new OutboundMessageDistributor(ctx, OutNetMessage.PRIORITY_PARTICIPATING);
|
||||
}
|
||||
|
||||
public void dispatch(TunnelDataMessage msg, Hash recvFrom) {
|
||||
_config.incrementProcessedMessages();
|
||||
boolean ok = _processor.process(msg.getData(), 0, msg.getData().length, recvFrom);
|
||||
@ -66,4 +67,10 @@ class OutboundTunnelEndpoint {
|
||||
_outDistributor.distribute(msg, toRouter, toTunnel);
|
||||
}
|
||||
}
|
||||
|
||||
/** @since 0.9.8 */
|
||||
@Override
|
||||
public String toString() {
|
||||
return "OBEP " + _config.getReceiveTunnel();
|
||||
}
|
||||
}
|
||||
|
@ -44,4 +44,10 @@ class ThrottledPumpedTunnelGateway extends PumpedTunnelGateway {
|
||||
}
|
||||
add(new PendingGatewayMessage(msg, toRouter, toTunnel));
|
||||
}
|
||||
|
||||
/** @since 0.9.8 */
|
||||
@Override
|
||||
public String toString() {
|
||||
return "IBGW " + _config.getReceiveTunnel();
|
||||
}
|
||||
}
|
||||
|
@ -491,11 +491,11 @@ public class TunnelDispatcher implements Service {
|
||||
boolean removed = (null != _participatingConfig.remove(recvId));
|
||||
if (removed) {
|
||||
if (_log.shouldLog(Log.DEBUG))
|
||||
_log.debug("removing " + cfg, new Exception());
|
||||
_log.debug("removing " + cfg /* , new Exception() */ );
|
||||
} else {
|
||||
// this is normal, this can get called twice
|
||||
if (_log.shouldLog(Log.DEBUG))
|
||||
_log.debug("Participating tunnel, but no longer listed in participatingConfig? " + cfg, new Exception());
|
||||
_log.debug("Participating tunnel, but no longer listed in participatingConfig? " + cfg /* , new Exception() */ );
|
||||
}
|
||||
|
||||
removed = (null != _participants.remove(recvId));
|
||||
|
Reference in New Issue
Block a user