mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2024-11-19 01:41:11 +01:00
Code Issues Packages Projects Releases Wiki Activity

Refactoring: Rename INITIAL_DATA_REQUEST to INITIAL_DATA_EXCHANGE

Browse Source
This commit is contained in:
chimp1984 2021-01-05 20:40:37 -05:00
parent 15cd42de0c
commit 809484e65d
No known key found for this signature in database
GPG Key ID: 9801B4EC591F90E3
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
p2p/src/main/java/bisq/network/p2p/network/Connection.java
View File

@ -861,7 +861,7 @@ public class Connection implements HasCapabilities, Runnable, MessageListener {
statistic.updateLastActivityTimestamp();
if (networkEnvelope instanceof GetDataRequest)
setPeerType(PeerType.INITIAL_DATA_REQUEST);
setPeerType(PeerType.INITIAL_DATA_EXCHANGE);
// First a seed node gets a message from a peer (PreliminaryDataRequest using
// AnonymousMessage interface) which does not have its hidden service

2
p2p/src/main/java/bisq/network/p2p/network/PeerType.java
View File

@ -21,5 +21,5 @@ public enum PeerType {
SEED_NODE,
PEER,
DIRECT_MSG_PEER,
INITIAL_DATA_REQUEST
INITIAL_DATA_EXCHANGE
}

2
p2p/src/main/java/bisq/network/p2p/peers/PeerManager.java
View File

@ -536,7 +536,7 @@ public final class PeerManager implements ConnectionListener, PersistedDataHost
"of type DIRECT_MSG_PEER or INITIAL_DATA_REQUEST.", maxConnectionsNonDirect);
candidates = allConnections.stream()
.filter(e -> e.getPeerType() != PeerType.DIRECT_MSG_PEER &&
e.getPeerType() != PeerType.INITIAL_DATA_REQUEST)
e.getPeerType() != PeerType.INITIAL_DATA_EXCHANGE)
.collect(Collectors.toList());
if (candidates.isEmpty()) {

2
p2p/src/test/java/bisq/network/p2p/peers/PeerManagerTest.java
View File

@ -159,7 +159,7 @@ public class PeerManagerTest {
assertEquals(maxConnectionsNonDirect + 1, node.getNetworkNode().getAllConnections().size());
List<Connection> sortedPeerConnections = node.getNetworkNode().getAllConnections().stream()
.filter(e -> e.getPeerType() != PeerType.DIRECT_MSG_PEER &&
e.getPeerType() != PeerType.INITIAL_DATA_REQUEST)
e.getPeerType() != PeerType.INITIAL_DATA_EXCHANGE)
.sorted(Comparator.comparingLong(o -> o.getStatistic().getLastActivityTimestamp()))
.collect(Collectors.toList());
Connection oldestConnection = sortedPeerConnections.remove(0);