AlphaX/qortal
1
0
Fork 0
forked from Qortal/qortal
Code Issues Pull Requests Projects Releases Wiki Activity

Immediately close socketChannels after accepting peers we won't use

Browse Source
This commit is contained in:
catbref 2020-03-16 16:07:17 +00:00
parent 12f9ecaaca
commit 4a4678b331
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/org/qortal/network/Network.java
View File

@ -481,18 +481,20 @@ public class Network {
try { try {
if (now == null) { if (now == null) {
LOGGER.debug(String.format("Connection discarded from peer %s due to lack of NTP sync", socketChannel.getRemoteAddress())); LOGGER.debug(() -> String.format("Connection discarded from peer %s due to lack of NTP sync", PeerAddress.fromSocket(socketChannel.socket())));
socketChannel.close();
return; return;
} }
synchronized (this.connectedPeers) { synchronized (this.connectedPeers) {
if (connectedPeers.size() >= maxPeers) { if (connectedPeers.size() >= maxPeers) {
// We have enough peers // We have enough peers
LOGGER.debug(String.format("Connection discarded from peer %s", socketChannel.getRemoteAddress())); LOGGER.debug(() -> String.format("Connection discarded from peer %s", PeerAddress.fromSocket(socketChannel.socket())));
socketChannel.close();
return; return;
} }
LOGGER.debug(String.format("Connection accepted from peer %s", socketChannel.getRemoteAddress())); LOGGER.debug(() -> String.format("Connection accepted from peer %s", PeerAddress.fromSocket(socketChannel.socket())));
newPeer = new Peer(socketChannel); newPeer = new Peer(socketChannel);
this.connectedPeers.add(newPeer); this.connectedPeers.add(newPeer);