Skip to content

Commit b41826f

Browse files
committed
fix(net):fix the issue of fast forwarding service
1 parent 1450156 commit b41826f

2 files changed

Lines changed: 2 additions & 1 deletion

File tree

framework/src/main/java/org/tron/core/net/TronNetService.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -139,6 +139,7 @@ private P2pConfig getConfig() {
139139
config.setActiveNodes(parameter.getActiveNodes());
140140
config.setTrustNodes(parameter.getPassiveNodes());
141141
config.getActiveNodes().forEach(n -> config.getTrustNodes().add(n.getAddress()));
142+
parameter.getFastForwardNodes().forEach(f -> config.getTrustNodes().add(f.getAddress()));
142143
int maxConnections = parameter.getMaxConnections();
143144
int minConnections = parameter.getMinConnections();
144145
int minActiveConnections = parameter.getMinActiveConnections();

framework/src/main/java/org/tron/core/net/peer/PeerConnection.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ public class PeerConnection {
147147

148148
public void setChannel(Channel channel) {
149149
this.channel = channel;
150-
if (relayNodes.contains(channel.getInetSocketAddress())) {
150+
if (relayNodes.stream().anyMatch(n -> n.getAddress().equals(channel.getInetAddress()))) {
151151
this.isRelayPeer = true;
152152
}
153153
this.nodeStatistics = TronStatsManager.getNodeStatistics(channel.getInetAddress());

0 commit comments

Comments
 (0)