logging: moved some log-cluttering DHT messages to level 'fine'

pull/615/head
okybaca 12 months ago
parent 1c5fca9a58
commit 553c859703

@ -215,7 +215,7 @@ public class DHTSelection {
/* Even if the peer is not a robinson and has the required minimum age, it may have an empty or disabled RWI */ /* Even if the peer is not a robinson and has the required minimum age, it may have an empty or disabled RWI */
continue; continue;
} }
if (RemoteSearch.log.isInfo()) RemoteSearch.log.info("selectPeers/DHTorder: " + seed.hash + ":" + seed.getName() + "/ score " + c); if (RemoteSearch.log.isFine()) RemoteSearch.log.fine("selectPeers/DHTorder: " + seed.hash + ":" + seed.getName() + "/ score " + c);
seeds.add(seed); seeds.add(seed);
c--; c--;
} }

@ -281,7 +281,7 @@ public class Dispatcher implements WorkflowTask<Transmission.Chunk> {
for (Seed target: targets[vertical]) { for (Seed target: targets[vertical]) {
Transmission.Chunk entry = this.transmissionBuffer.get(target.hash); // if this is not null, the entry is extended here Transmission.Chunk entry = this.transmissionBuffer.get(target.hash); // if this is not null, the entry is extended here
if (entry == null) entry = transmission.newChunk(target); else { if (entry == null) entry = transmission.newChunk(target); else {
log.info("extending chunk for peer " + entry.dhtTarget().hash + " containing " + entry.containersSize() + " references with " + verticalContainer.size() + " more entries"); log.fine("extending chunk for peer " + entry.dhtTarget().hash + " containing " + entry.containersSize() + " references with " + verticalContainer.size() + " more entries");
} }
try { try {
entry.add(verticalContainer); entry.add(verticalContainer);

@ -4110,7 +4110,7 @@ public final class Switchboard extends serverSwitch {
final long kbytesUp = ConnectionInfo.getActiveUpbytes() / 1024; final long kbytesUp = ConnectionInfo.getActiveUpbytes() / 1024;
// accumulate RWIs to transmission buffer // accumulate RWIs to transmission buffer
if ( this.dhtDispatcher.bufferSize() > this.peers.scheme.verticalPartitions() ) { if ( this.dhtDispatcher.bufferSize() > this.peers.scheme.verticalPartitions() ) {
this.log.info("dhtTransferJob: no selection, too many entries in transmission buffer: " this.log.fine("dhtTransferJob: no selection, too many entries in transmission buffer: "
+ this.dhtDispatcher.bufferSize()); + this.dhtDispatcher.bufferSize());
} else if ( MemoryControl.available() < 1024 * 1024 * 25 ) { } else if ( MemoryControl.available() < 1024 * 1024 * 25 ) {
this.log.info("dhtTransferJob: no selection, too less memory available : " this.log.info("dhtTransferJob: no selection, too less memory available : "
@ -4148,7 +4148,7 @@ public final class Switchboard extends serverSwitch {
this.dhtMaxReferenceCount, this.dhtMaxReferenceCount,
5000); 5000);
hasDoneSomething = hasDoneSomething | enqueued; hasDoneSomething = hasDoneSomething | enqueued;
this.log.info("dhtTransferJob: result from enqueueing: " + ((enqueued) ? "true" : "false")); this.log.fine("dhtTransferJob: result from enqueueing: " + ((enqueued) ? "true" : "false"));
} }
// check if we can deliver entries to other peers // check if we can deliver entries to other peers
@ -4166,7 +4166,7 @@ public final class Switchboard extends serverSwitch {
} else { } else {
final boolean dequeued = this.dhtDispatcher.dequeueContainer(); final boolean dequeued = this.dhtDispatcher.dequeueContainer();
hasDoneSomething = hasDoneSomething | dequeued; hasDoneSomething = hasDoneSomething | dequeued;
this.log.info("dhtTransferJob: result from dequeueing: " + ((dequeued) ? "true" : "false")); this.log.fine("dhtTransferJob: result from dequeueing: " + ((dequeued) ? "true" : "false"));
} }
return hasDoneSomething; return hasDoneSomething;
} }

Loading…
Cancel
Save