Skip to content

Commit 0fc9acb

Browse files
committed
remove the condition of peer.isDisconnect
1 parent 0acc84b commit 0fc9acb

1 file changed

Lines changed: 0 additions & 4 deletions

File tree

framework/src/main/java/org/tron/core/net/service/effective/ResilienceService.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,6 @@ private void disconnectRandom() {
7474
if (peerSize >= CommonParameter.getInstance().getMaxConnections()) {
7575
long now = System.currentTimeMillis();
7676
List<PeerConnection> peers = tronNetDelegate.getActivePeer().stream()
77-
.filter(peer -> !peer.isDisconnect())
7877
.filter(peer -> now - peer.getLastActiveTime() >= inactiveThreshold)
7978
.filter(peer -> !peer.getChannel().isTrustPeer())
8079
.collect(Collectors.toList());
@@ -95,7 +94,6 @@ private void disconnectLan() {
9594
if (peerSize >= CommonParameter.getInstance().getMinConnections()) {
9695
long now = System.currentTimeMillis();
9796
List<PeerConnection> peers = tronNetDelegate.getActivePeer().stream()
98-
.filter(peer -> !peer.isDisconnect())
9997
.filter(peer -> now - peer.getLastActiveTime() >= inactiveThreshold)
10098
.filter(peer -> !peer.getChannel().isTrustPeer())
10199
.collect(Collectors.toList());
@@ -114,7 +112,6 @@ private void disconnectIsolated2() {
114112
//disconnect from the node whose lastActiveTime is smallest
115113
if (peerSize >= CommonParameter.getInstance().getMinActiveConnections()) {
116114
List<PeerConnection> peers = tronNetDelegate.getActivePeer().stream()
117-
.filter(peer -> !peer.isDisconnect())
118115
.filter(peer -> !peer.getChannel().isTrustPeer())
119116
.filter(peer -> peer.getChannel().isActive())
120117
.collect(Collectors.toList());
@@ -131,7 +128,6 @@ private void disconnectIsolated2() {
131128
if (peerSize > threshold) {
132129
int disconnectSize = peerSize - threshold;
133130
List<PeerConnection> peers = tronNetDelegate.getActivePeer().stream()
134-
.filter(peer -> !peer.isDisconnect())
135131
.filter(peer -> !peer.getChannel().isTrustPeer())
136132
.filter(peer -> !peer.getChannel().isActive())
137133
.collect(Collectors.toList());

0 commit comments

Comments
 (0)