diff --git a/router/java/src/net/i2p/router/transport/TransportImpl.java b/router/java/src/net/i2p/router/transport/TransportImpl.java index 1fcf0439c5..422254fa51 100644 --- a/router/java/src/net/i2p/router/transport/TransportImpl.java +++ b/router/java/src/net/i2p/router/transport/TransportImpl.java @@ -450,12 +450,9 @@ public abstract class TransportImpl implements Transport { * @param remoteIdentHash may be null, calculated from remoteIdent if null */ public void messageReceived(I2NPMessage inMsg, RouterIdentity remoteIdent, Hash remoteIdentHash, long msToReceive, int bytesReceived) { - //if (true) - // _log.error("(not error) I2NP message received: " + inMsg.getUniqueId() + " after " + msToReceive); - int level = Log.INFO; - if (msToReceive > 5000) - level = Log.WARN; + //if (msToReceive > 5000) + // level = Log.WARN; if (_log.shouldLog(level)) { StringBuilder buf = new StringBuilder(128); buf.append("Message received: ").append(inMsg.getClass().getSimpleName()); @@ -470,10 +467,6 @@ public abstract class TransportImpl implements Transport { } else { buf.append("[unknown]"); } - buf.append(" and forwarding to listener: "); - if (_listener != null) - buf.append(_listener); - _log.log(level, buf.toString()); } @@ -519,6 +512,9 @@ public abstract class TransportImpl implements Transport { /** * What address are we currently listening to? * Replaces getCurrentAddress() + * + * Note: An address without a host is considered IPv4. + * * @param ipv6 true for IPv6 only; false for IPv4 only * @return first matching address or null * @since IPv6 diff --git a/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java b/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java index cf43fb8a5c..a77bccbdb4 100644 --- a/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java +++ b/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java @@ -648,6 +648,8 @@ public class NTCPTransport extends TransportImpl { public void forceDisconnect(Hash peer) { NTCPConnection con = _conByIdent.remove(peer); if (con != null) { + if (_log.shouldWarn()) + _log.warn("Force disconnect of " + peer, new Exception("I did it")); con.close(); } } diff --git a/router/java/src/net/i2p/router/transport/udp/UDPTransport.java b/router/java/src/net/i2p/router/transport/udp/UDPTransport.java index 78ec3121b9..4071879422 100644 --- a/router/java/src/net/i2p/router/transport/udp/UDPTransport.java +++ b/router/java/src/net/i2p/router/transport/udp/UDPTransport.java @@ -2687,6 +2687,8 @@ public class UDPTransport extends TransportImpl implements TimedWeightedPriority public void forceDisconnect(Hash peer) { PeerState ps = _peersByIdent.get(peer); if (ps != null) { + if (_log.shouldWarn()) + _log.warn("Force disconnect of " + peer, new Exception("I did it")); dropPeer(ps, true, "router"); } }