efiyo/lanemu-mirror
1
0
Fork 0
mirror of https://gitlab.com/Monsterovich/lanemu.git synced 2024-07-07 06:01:16 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

Ignore adding blocked peer in doPeerChecks

Browse source
This commit is contained in:
Nikolay Borodin 2024-03-18 13:38:08 +02:00
parent 130f0a99b1
commit cb609712e9
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/org/p2pvpn/network/bittorrent/DHT.java
View file

@ -479,9 +479,7 @@ public class DHT implements Runnable {
}
}
if (!ipAdded) {
doPeerChecks(remotePeer, addr);
if (!ipAdded && doPeerChecks(remotePeer, addr)) {
connectionManager.getConnector().addIP(addr.getAddress(),
addr.getPort(), null, "BitTorrent DHT", "", false);
}
@ -507,8 +505,12 @@ public class DHT implements Runnable {
*
* @param remotePeer The Contact information.
* @param address The InetSocketAddress sent by this contact.
*
* @return false if the peer was blocked, otherwise returns true
*/
private void doPeerChecks(Contact remotePeer, InetSocketAddress address) {
private boolean doPeerChecks(Contact remotePeer, InetSocketAddress address) {
boolean result = true;
if (maliciousPeerCounts.size() > SUSPICIOUS_PEERS_MAX) {
maliciousPeerCounts.clear();
maliciousPeerAddresses.clear();
@ -526,6 +528,8 @@ public class DHT implements Runnable {
maliciousPeers.add(remotePeer);
maliciousPeerCounts.remove(remotePeer);
result = false;
Vector<InetSocketAddress> addrToRemove = new Vector<InetSocketAddress>();
for (InetSocketAddress maliciousPeerAddr : maliciousPeerAddresses.keySet()) {
if (maliciousPeerAddresses.get(maliciousPeerAddr).equals(remotePeer)) {
@ -553,6 +557,8 @@ public class DHT implements Runnable {
lastRemotePeer = remotePeer;
lastAddress = address;
return result;
}
/**