echelon/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Transports: Log tweaks

Browse Source
This commit is contained in:
zzz
2018-12-11 11:35:45 +00:00
parent 0f6f8f90c9
commit a63d2dccb2
3 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
router/java/src/net/i2p/router/transport/TransportImpl.java
View File

@ -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

2
router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java
View File

@ -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();
}
}

2
router/java/src/net/i2p/router/transport/udp/UDPTransport.java
View File

@ -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");
}
}