Ecosystem/haveno
Ecosystem/haveno
2
1
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2024-12-22 19:49:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix concurrent modification exception in peer manager

Browse source
This commit is contained in:
woodser 2024-01-04 20:10:25 -05:00
parent 497de47965
commit 59b2a1121b
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
p2p/src/main/java/haveno/network/p2p/peers/PeerManager.java
View file

@ -774,7 +774,9 @@ public final class PeerManager implements ConnectionListener, PersistedDataHost
// If not found in connection we look up if we got the Capabilities set from any of the // If not found in connection we look up if we got the Capabilities set from any of the
// reported or persisted peers // reported or persisted peers
Set<Peer> persistedAndReported = new HashSet<>(getPersistedPeers()); Set<Peer> persistedAndReported = new HashSet<>(getPersistedPeers());
persistedAndReported.addAll(getReportedPeers()); synchronized (reportedPeers) {
persistedAndReported.addAll(reportedPeers);
}
Optional<Peer> candidate = persistedAndReported.stream() Optional<Peer> candidate = persistedAndReported.stream()
.filter(peer -> peer.getNodeAddress().equals(peersNodeAddress)) .filter(peer -> peer.getNodeAddress().equals(peersNodeAddress))
.filter(peer -> !peer.getCapabilities().isEmpty()) .filter(peer -> !peer.getCapabilities().isEmpty())