mirror of
https://github.com/ChronosX88/Influence-P2P.git
synced 2024-11-25 16:32:19 +00:00
Increased count of pings
This commit is contained in:
parent
71f09b9571
commit
21a50bba5a
@ -20,11 +20,10 @@ public class P2PUtils {
|
|||||||
|
|
||||||
public static boolean ping(PeerAddress recipientPeerAddress) {
|
public static boolean ping(PeerAddress recipientPeerAddress) {
|
||||||
// For connection opening
|
// For connection opening
|
||||||
for (int i = 0; i < 2; i++) {
|
for (int i = 0; i < 5; i++) {
|
||||||
peerDHT
|
peerDHT
|
||||||
.peer()
|
.peer()
|
||||||
.ping()
|
.ping()
|
||||||
.tcpPing(true)
|
|
||||||
.peerAddress(recipientPeerAddress)
|
.peerAddress(recipientPeerAddress)
|
||||||
.start()
|
.start()
|
||||||
.awaitUninterruptibly();
|
.awaitUninterruptibly();
|
||||||
@ -33,7 +32,6 @@ public class P2PUtils {
|
|||||||
FuturePing ping = peerDHT
|
FuturePing ping = peerDHT
|
||||||
.peer()
|
.peer()
|
||||||
.ping()
|
.ping()
|
||||||
.tcpPing(true)
|
|
||||||
.peerAddress(recipientPeerAddress)
|
.peerAddress(recipientPeerAddress)
|
||||||
.start()
|
.start()
|
||||||
.awaitUninterruptibly();
|
.awaitUninterruptibly();
|
||||||
|
Loading…
Reference in New Issue
Block a user