|
|
|
@ -60,19 +60,21 @@ public class DefaultPeerSelectorTest { |
|
|
|
|
@Test |
|
|
|
|
public void testGetPeerButNoPeerMatchesFilter() { |
|
|
|
|
EthPeer protocol1With5ReputationPeer = |
|
|
|
|
createTestPeer(Set.of(Capability.create("capability1", 1)), "protocol1", 5); |
|
|
|
|
createTestPeer(Set.of(Capability.create("capability1", 1)), "protocol1", 5); |
|
|
|
|
peerSelector.addPeer(protocol1With5ReputationPeer); |
|
|
|
|
EthPeer protocol1With4ReputationPeer = |
|
|
|
|
createTestPeer(Set.of(Capability.create("capability1", 1)), "protocol1", 4); |
|
|
|
|
createTestPeer(Set.of(Capability.create("capability1", 1)), "protocol1", 4); |
|
|
|
|
peerSelector.addPeer(protocol1With4ReputationPeer); |
|
|
|
|
EthPeer protocol2With50ReputationPeer = |
|
|
|
|
createTestPeer(Set.of(Capability.create("capability1", 1)), "protocol2", 50); |
|
|
|
|
createTestPeer(Set.of(Capability.create("capability1", 1)), "protocol2", 50); |
|
|
|
|
peerSelector.addPeer(protocol2With50ReputationPeer); |
|
|
|
|
EthPeer protocol2With4ReputationPeer = |
|
|
|
|
createTestPeer(Set.of(Capability.create("capability1", 1)), "protocol2", 4); |
|
|
|
|
createTestPeer(Set.of(Capability.create("capability1", 1)), "protocol2", 4); |
|
|
|
|
peerSelector.addPeer(protocol2With4ReputationPeer); |
|
|
|
|
|
|
|
|
|
Assertions.assertThrows(NoAvailablePeerException.class, () -> peerSelector.getPeer((p) -> p.getProtocolName().equals("fake protocol"))); |
|
|
|
|
Assertions.assertThrows( |
|
|
|
|
NoAvailablePeerException.class, |
|
|
|
|
() -> peerSelector.getPeer((p) -> p.getProtocolName().equals("fake protocol"))); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private EthPeer createTestPeer( |
|
|
|
|