Qortal/qortal
1
0
Fork 0
mirror of https://github.com/Qortal/qortal.git synced 2025-05-14 05:37:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

improve pruning log messages

Browse Source
This commit is contained in:
Jürg Schulthess 2025-05-13 08:11:39 +02:00
parent 6ac0b56fa5
commit c9ed42b93c
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/org/qortal/network/RNSNetwork.java
View File

@ -676,7 +676,7 @@ public class RNSNetwork {
//}
}
public List<RNSPeer> getNonActiveIncommingPeers() {
public List<RNSPeer> getNonActiveIncomingPeers() {
var ips = getIncomingPeers();
List<RNSPeer> result = Collections.synchronizedList(new ArrayList<>());
Link pl;
@ -700,9 +700,10 @@ public class RNSNetwork {
var initiatorPeerList = getImmutableLinkedPeers();
var initiatorActivePeerList = getActiveImmutableLinkedPeers();
var incomingPeerList = getImmutableIncomingPeers();
log.info("number of links (linkedPeers (active) / incomingPeers before prunig: {} ({}), {}",
var numActiveIncomingPeers = incomingPeerList.size() - getNonActiveIncomingPeers().size();
log.info("number of links (linkedPeers (active) / incomingPeers (active) before prunig: {} ({}), {} ({})",
initiatorPeerList.size(), getActiveImmutableLinkedPeers().size(),
incomingPeerList.size());
incomingPeerList.size(), numActiveIncomingPeers);
for (RNSPeer p: initiatorActivePeerList) {
var pLink = p.getOrInitPeerLink();
p.pingRemote();
@ -730,7 +731,7 @@ public class RNSNetwork {
}
}
// prune non-initiator peers
List<RNSPeer> inaps = getNonActiveIncommingPeers();
List<RNSPeer> inaps = getNonActiveIncomingPeers();
for (RNSPeer p: inaps) {
var pLink = p.getPeerLink();
if (nonNull(pLink)) {
@ -742,10 +743,10 @@ public class RNSNetwork {
initiatorPeerList = getImmutableLinkedPeers();
initiatorActivePeerList = getActiveImmutableLinkedPeers();
incomingPeerList = getImmutableIncomingPeers();
log.info("number of links (linkedPeers (active) / incomingPeers after prunig: {} ({}), {}",
numActiveIncomingPeers = incomingPeerList.size() - getNonActiveIncomingPeers().size();
log.info("number of links (linkedPeers (active) / incomingPeers (active) after prunig: {} ({}), {} ({})",
initiatorPeerList.size(), getActiveImmutableLinkedPeers().size(),
incomingPeerList.size());
maybeAnnounce(getBaseDestination());
incomingPeerList.size(), numActiveIncomingPeers);
}
public void maybeAnnounce(Destination d) {