From 1bbb79f5b16fa1fada4a49302597300ed9f09e2f Mon Sep 17 00:00:00 2001 From: zzz <zzz@mail.i2p> Date: Thu, 13 Mar 2014 12:17:34 +0000 Subject: [PATCH] log tweaks --- .../java/src/net/i2p/router/networkdb/kademlia/StoreJob.java | 5 +++-- .../java/src/net/i2p/router/transport/udp/UDPTransport.java | 4 ++-- router/java/src/net/i2p/router/tunnel/FragmentedMessage.java | 4 ++-- 3 files changed, 7 insertions(+), 6 deletions(-) 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 bd45f19247..b38ad14899 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 3a2f001c2e..cacd091a64 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 e257e326ff..c692b2b205 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) { -- GitLab