We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0fc9acb commit 0f7c7f4Copy full SHA for 0f7c7f4
1 file changed
framework/src/main/java/org/tron/core/net/service/effective/ResilienceService.java
@@ -76,6 +76,7 @@ private void disconnectRandom() {
76
List<PeerConnection> peers = tronNetDelegate.getActivePeer().stream()
77
.filter(peer -> now - peer.getLastActiveTime() >= inactiveThreshold)
78
.filter(peer -> !peer.getChannel().isTrustPeer())
79
+ .filter(peer -> !peer.isNeedSyncFromUs() && !peer.isNeedSyncFromPeer())
80
.collect(Collectors.toList());
81
if (!peers.isEmpty()) {
82
int index = new Random().nextInt(peers.size());
0 commit comments