Git-Mirrors/haveno
1
0
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2025-06-16 02:49:43 -04:00
Code Issues Projects Releases Packages Wiki Activity

Fix bug in relay mode

Browse source
This commit is contained in:
Manfred Karrer 2014-10-24 14:18:10 +02:00
parent f8df890a47
commit f75c5340d2
1 changed files with 4 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/test/java/io/bitsquare/msg/BasicUsecasesInWANTest.java
View file

@ -241,10 +241,12 @@ No future set beforehand, probably an early shutdown / timeout, or use setFailed
FutureNAT futureNAT = peerNAT.startSetupPortforwarding(futureDiscover); FutureNAT futureNAT = peerNAT.startSetupPortforwarding(futureDiscover);
futureNAT.awaitUninterruptibly(); futureNAT.awaitUninterruptibly();
if (futureNAT.isSuccess()) { if (futureNAT.isSuccess()) {
log.info("Automatic port forwarding is setup. Address = " +
futureNAT.peerAddress());
FutureDiscover futureDiscover2 = peer.discover().peerAddress(masterNodeAddress).start(); FutureDiscover futureDiscover2 = peer.discover().peerAddress(masterNodeAddress).start();
futureDiscover2.awaitUninterruptibly(); futureDiscover2.awaitUninterruptibly();
if (futureDiscover2.isSuccess()) { if (futureDiscover2.isSuccess()) {
log.info("Discover with direct connection successful. Address = " + futureDiscover2 log.info("Discover with automatic port forwarding successful. Address = " + futureDiscover2
.peerAddress()); .peerAddress());
log.info("Automatic port forwarding is setup. Address = " + log.info("Automatic port forwarding is setup. Address = " +
@ -261,10 +263,7 @@ No future set beforehand, probably an early shutdown / timeout, or use setFailed
FutureRelayNAT futureRelayNAT = peerNAT.startRelay(futureDiscover, futureNAT); FutureRelayNAT futureRelayNAT = peerNAT.startRelay(futureDiscover, futureNAT);
futureRelayNAT.awaitUninterruptibly(); futureRelayNAT.awaitUninterruptibly();
if (futureRelayNAT.isSuccess()) { if (futureRelayNAT.isSuccess()) {
log.info("Bootstrap using relay successful. Address = " + log.info("Bootstrap using relay successful. Address = " + peer.peerAddress());
peer.peerAddress());
futureRelayNAT.shutdown();
peer.shutdown().awaitUninterruptibly();
return peerDHT; return peerDHT;
} }
else { else {