diff --git a/ethereum/p2p/src/test/java/org/hyperledger/besu/ethereum/p2p/network/P2PNetworkTest.java b/ethereum/p2p/src/test/java/org/hyperledger/besu/ethereum/p2p/network/P2PNetworkTest.java index 9c6de517830..5edb629d807 100644 --- a/ethereum/p2p/src/test/java/org/hyperledger/besu/ethereum/p2p/network/P2PNetworkTest.java +++ b/ethereum/p2p/src/test/java/org/hyperledger/besu/ethereum/p2p/network/P2PNetworkTest.java @@ -210,9 +210,9 @@ public void rejectIncomingConnectionFromDenylistedPeer() throws Exception { // Check connection is made, and then a disconnect is registered at remote Assertions.assertThat(connectFuture.get(5L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) .isEqualTo(localId); - Assertions.assertThat(peerFuture.get(5L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) + Assertions.assertThat(peerFuture.get(30L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) .isEqualTo(localId); - assertThat(reasonFuture.get(5L, TimeUnit.SECONDS)) + assertThat(reasonFuture.get(30L, TimeUnit.SECONDS)) .isEqualByComparingTo(DisconnectReason.UNKNOWN); } } @@ -261,9 +261,9 @@ public void rejectIncomingConnectionFromDisallowedPeer() throws Exception { final Bytes localId = localEnode.getNodeId(); Assertions.assertThat(connectFuture.get(5L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) .isEqualTo(localId); - Assertions.assertThat(peerFuture.get(5L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) + Assertions.assertThat(peerFuture.get(30L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) .isEqualTo(localId); - assertThat(reasonFuture.get(5L, TimeUnit.SECONDS)) + assertThat(reasonFuture.get(30L, TimeUnit.SECONDS)) .isEqualByComparingTo(DisconnectReason.UNKNOWN); } } diff --git a/ethereum/p2p/src/test/java/org/hyperledger/besu/ethereum/p2p/network/P2PPlainNetworkTest.java b/ethereum/p2p/src/test/java/org/hyperledger/besu/ethereum/p2p/network/P2PPlainNetworkTest.java index e1837ad22fa..d62c7d6769b 100644 --- a/ethereum/p2p/src/test/java/org/hyperledger/besu/ethereum/p2p/network/P2PPlainNetworkTest.java +++ b/ethereum/p2p/src/test/java/org/hyperledger/besu/ethereum/p2p/network/P2PPlainNetworkTest.java @@ -256,9 +256,9 @@ public void rejectIncomingConnectionFromDenylistedPeer() throws Exception { // Check connection is made, and then a disconnect is registered at remote Assertions.assertThat(connectFuture.get(5L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) .isEqualTo(localId); - Assertions.assertThat(peerFuture.get(5L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) + Assertions.assertThat(peerFuture.get(30L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) .isEqualTo(localId); - assertThat(reasonFuture.get(5L, TimeUnit.SECONDS)) + assertThat(reasonFuture.get(30L, TimeUnit.SECONDS)) .isEqualByComparingTo(DisconnectReason.UNKNOWN); } } @@ -307,9 +307,9 @@ public void rejectIncomingConnectionFromDisallowedPeer() throws Exception { final Bytes localId = localEnode.getNodeId(); Assertions.assertThat(connectFuture.get(5L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) .isEqualTo(localId); - Assertions.assertThat(peerFuture.get(5L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) + Assertions.assertThat(peerFuture.get(30L, TimeUnit.SECONDS).getPeerInfo().getNodeId()) .isEqualTo(localId); - assertThat(reasonFuture.get(5L, TimeUnit.SECONDS)) + assertThat(reasonFuture.get(30L, TimeUnit.SECONDS)) .isEqualByComparingTo(DisconnectReason.UNKNOWN); } }