diff --git a/router/java/src/net/i2p/router/networkdb/kademlia/StoreJob.java b/router/java/src/net/i2p/router/networkdb/kademlia/StoreJob.java index bd45f192478534d59e76db7af96a98aa7e20a42a..b38ad1489941fefc012492b6ab091694956f7ea2 100644 --- a/router/java/src/net/i2p/router/networkdb/kademlia/StoreJob.java +++ b/router/java/src/net/i2p/router/networkdb/kademlia/StoreJob.java @@ -551,6 +551,7 @@ class StoreJob extends JobImpl { } public String getName() { return "Kademlia Store Send Success"; } + public void runJob() { Hash hash = _peer.getIdentity().getHash(); MessageWrapper.WrappedMessage wm = _state.getPendingMessage(hash); @@ -565,8 +566,8 @@ class StoreJob extends JobImpl { getContext().statManager().addRateData("netDb.ackTime", howLong, howLong); if ( (_sendThrough != null) && (_msgSize > 0) ) { - if (_log.shouldLog(Log.WARN)) - _log.warn("sent a " + _msgSize + "byte netDb message through tunnel " + _sendThrough + " after " + howLong); + if (_log.shouldLog(Log.INFO)) + _log.info("sent a " + _msgSize + " byte netDb message through tunnel " + _sendThrough + " after " + howLong); for (int i = 0; i < _sendThrough.getLength(); i++) getContext().profileManager().tunnelDataPushed(_sendThrough.getPeer(i), howLong, _msgSize); _sendThrough.incrementVerifiedBytesTransferred(_msgSize); 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 3a2f001c2e84dc3622c61b50ac29c69eeadee439..cacd091a64ceb46312f31ccbe356361e03aa9667 100644 --- a/router/java/src/net/i2p/router/transport/udp/UDPTransport.java +++ b/router/java/src/net/i2p/router/transport/udp/UDPTransport.java @@ -2908,8 +2908,8 @@ public class UDPTransport extends TransportImpl implements TimedWeightedPriority } if (!_expireBuffer.isEmpty()) { - if (_log.shouldLog(Log.WARN)) - _log.warn("Expiring " + _expireBuffer.size() + " peers"); + if (_log.shouldLog(Log.INFO)) + _log.info("Expiring " + _expireBuffer.size() + " peers"); for (PeerState peer : _expireBuffer) { sendDestroy(peer); dropPeer(peer, false, "idle too long"); diff --git a/router/java/src/net/i2p/router/tunnel/FragmentedMessage.java b/router/java/src/net/i2p/router/tunnel/FragmentedMessage.java index e257e326ffbdf6c22f33b42ee5a23be201744f5d..c692b2b205717c115431d20bcb0e47e30c5c7c1c 100644 --- a/router/java/src/net/i2p/router/tunnel/FragmentedMessage.java +++ b/router/java/src/net/i2p/router/tunnel/FragmentedMessage.java @@ -57,8 +57,8 @@ class FragmentedMessage { */ public boolean receive(int fragmentNum, byte payload[], int offset, int length, boolean isLast) { if (fragmentNum <= 0 || fragmentNum >= MAX_FRAGMENTS) { - if (_log.shouldLog(Log.ERROR)) - _log.error("Fragment # == " + fragmentNum + " for messageId " + _messageId); + if (_log.shouldLog(Log.WARN)) + _log.warn("Bad followon fragment # == " + fragmentNum + " for messageId " + _messageId); return false; } if (length <= 0 || length > MAX_FRAGMENT_SIZE) {