Skip to content

Commit ffbb69e

Browse files
committed
add DisConnectCause
1 parent 7bdae32 commit ffbb69e

1 file changed

Lines changed: 6 additions & 6 deletions

File tree

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ private void disconnectRandom() {
8181
if (!peers.isEmpty()) {
8282
int index = new Random().nextInt(peers.size());
8383
disconnectFromPeer(peers.get(index), ReasonCode.RANDOM_ELIMINATION,
84-
DisConnectCause.RANDOM_ELIMINATION);
84+
DisconnectCause.RANDOM_ELIMINATION);
8585
}
8686
}
8787
}
@@ -101,7 +101,7 @@ private void disconnectLan() {
101101
.collect(Collectors.toList());
102102
Optional<PeerConnection> one = getEarliestPeer(peers);
103103
one.ifPresent(
104-
peer -> disconnectFromPeer(peer, ReasonCode.BAD_PROTOCOL, DisConnectCause.LAN_NODE));
104+
peer -> disconnectFromPeer(peer, ReasonCode.BAD_PROTOCOL, DisconnectCause.LAN_NODE));
105105
}
106106
}
107107

@@ -121,7 +121,7 @@ private void disconnectIsolated2() {
121121

122122
Optional<PeerConnection> one = getEarliestPeer(peers);
123123
one.ifPresent(peer -> disconnectFromPeer(peer, ReasonCode.BAD_PROTOCOL,
124-
DisConnectCause.ISOLATE2_ACTIVE));
124+
DisconnectCause.ISOLATE2_ACTIVE));
125125
}
126126

127127
//disconnect from some passive nodes, make sure retention nodes' num <= 0.8 * maxConnection,
@@ -147,7 +147,7 @@ private void disconnectIsolated2() {
147147
logger.info("All peer Size:{}, plan size:{}, candidate size:{}, real size:{}", peerSize,
148148
disconnectSize, candidateSize, peers.size());
149149
peers.forEach(peer -> disconnectFromPeer(peer, ReasonCode.BAD_PROTOCOL,
150-
DisConnectCause.ISOLATE2_PASSIVE));
150+
DisconnectCause.ISOLATE2_PASSIVE));
151151
}
152152
}
153153

@@ -180,14 +180,14 @@ private boolean isIsolateLand2() {
180180
}
181181

182182
private void disconnectFromPeer(PeerConnection peer, ReasonCode reasonCode,
183-
DisConnectCause cause) {
183+
DisconnectCause cause) {
184184
int inactiveSeconds = (int) ((System.currentTimeMillis() - peer.getLastActiveTime()) / 1000);
185185
logger.info("Disconnect from peer {}, inactive seconds {}, cause: {}",
186186
peer.getInetSocketAddress(), inactiveSeconds, cause);
187187
peer.disconnect(reasonCode);
188188
}
189189

190-
private enum DisConnectCause {
190+
private enum DisconnectCause {
191191
RANDOM_ELIMINATION,
192192
LAN_NODE,
193193
ISOLATE2_ACTIVE,

0 commit comments

Comments
 (0)