crowetic/qortal
1
0
Fork 0
forked from Qortal/qortal
Code Pull Requests Activity

Don't propagate new transactions back to sending peer. Added small inter-peer delay when doing network broadcast.

Browse Source
This commit is contained in:
catbref 2019-06-06 17:29:29 +01:00
parent c2e8392f05
commit 1d7bda5d46
2 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/qora/controller/Controller.java
View File

@ -744,7 +744,7 @@ public class Controller extends Thread {
break; break;
// Broadcast signatures that are new to us // Broadcast signatures that are new to us
Network.getInstance().broadcast(broadcastPeer -> new TransactionSignaturesMessage(newSignatures)); Network.getInstance().broadcast(broadcastPeer -> broadcastPeer == peer ? null : new TransactionSignaturesMessage(newSignatures));
break; break;
} }

10
src/main/java/org/qora/network/Network.java
View File

@ -13,6 +13,7 @@ import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.Collections; import java.util.Collections;
import java.util.List; import java.util.List;
import java.util.Random;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.RejectedExecutionException;
@ -781,7 +782,16 @@ public class Network extends Thread {
public void run() { public void run() {
Thread.currentThread().setName("Network Broadcast"); Thread.currentThread().setName("Network Broadcast");
Random random = new Random();
for (Peer peer : targetPeers) { for (Peer peer : targetPeers) {
// Very short sleep to reduce strain, improve multithreading and catch interrupts
try {
Thread.sleep(random.nextInt(20) + 20);
} catch (InterruptedException e) {
return;
}
Message message = peerMessageBuilder.apply(peer); Message message = peerMessageBuilder.apply(peer);
if (message == null) if (message == null)