log tweaks

This commit is contained in:
zzz
2014-03-13 12:17:34 +00:00
parent 84e6991374
commit 1bbb79f5b1
3 changed files with 7 additions and 6 deletions

View File

@ -551,6 +551,7 @@ class StoreJob extends JobImpl {
} }
public String getName() { return "Kademlia Store Send Success"; } public String getName() { return "Kademlia Store Send Success"; }
public void runJob() { public void runJob() {
Hash hash = _peer.getIdentity().getHash(); Hash hash = _peer.getIdentity().getHash();
MessageWrapper.WrappedMessage wm = _state.getPendingMessage(hash); MessageWrapper.WrappedMessage wm = _state.getPendingMessage(hash);
@ -565,8 +566,8 @@ class StoreJob extends JobImpl {
getContext().statManager().addRateData("netDb.ackTime", howLong, howLong); getContext().statManager().addRateData("netDb.ackTime", howLong, howLong);
if ( (_sendThrough != null) && (_msgSize > 0) ) { if ( (_sendThrough != null) && (_msgSize > 0) ) {
if (_log.shouldLog(Log.WARN)) if (_log.shouldLog(Log.INFO))
_log.warn("sent a " + _msgSize + "byte netDb message through tunnel " + _sendThrough + " after " + howLong); _log.info("sent a " + _msgSize + " byte netDb message through tunnel " + _sendThrough + " after " + howLong);
for (int i = 0; i < _sendThrough.getLength(); i++) for (int i = 0; i < _sendThrough.getLength(); i++)
getContext().profileManager().tunnelDataPushed(_sendThrough.getPeer(i), howLong, _msgSize); getContext().profileManager().tunnelDataPushed(_sendThrough.getPeer(i), howLong, _msgSize);
_sendThrough.incrementVerifiedBytesTransferred(_msgSize); _sendThrough.incrementVerifiedBytesTransferred(_msgSize);

View File

@ -2908,8 +2908,8 @@ public class UDPTransport extends TransportImpl implements TimedWeightedPriority
} }
if (!_expireBuffer.isEmpty()) { if (!_expireBuffer.isEmpty()) {
if (_log.shouldLog(Log.WARN)) if (_log.shouldLog(Log.INFO))
_log.warn("Expiring " + _expireBuffer.size() + " peers"); _log.info("Expiring " + _expireBuffer.size() + " peers");
for (PeerState peer : _expireBuffer) { for (PeerState peer : _expireBuffer) {
sendDestroy(peer); sendDestroy(peer);
dropPeer(peer, false, "idle too long"); dropPeer(peer, false, "idle too long");

View File

@ -57,8 +57,8 @@ class FragmentedMessage {
*/ */
public boolean receive(int fragmentNum, byte payload[], int offset, int length, boolean isLast) { public boolean receive(int fragmentNum, byte payload[], int offset, int length, boolean isLast) {
if (fragmentNum <= 0 || fragmentNum >= MAX_FRAGMENTS) { if (fragmentNum <= 0 || fragmentNum >= MAX_FRAGMENTS) {
if (_log.shouldLog(Log.ERROR)) if (_log.shouldLog(Log.WARN))
_log.error("Fragment # == " + fragmentNum + " for messageId " + _messageId); _log.warn("Bad followon fragment # == " + fragmentNum + " for messageId " + _messageId);
return false; return false;
} }
if (length <= 0 || length > MAX_FRAGMENT_SIZE) { if (length <= 0 || length > MAX_FRAGMENT_SIZE) {