Git-Mirrors/haveno
1
0
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2025-07-29 09:48:46 -04:00
Code Issues Projects Releases Packages Wiki Activity

Extract isSuccess in P2PNode, set custom log levels

Browse source
This commit is contained in:
Manfred Karrer 2014-11-05 23:15:36 +01:00
parent 399842d8e2
commit dbbe7cec49
3 changed files with 18 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/main/java/io/bitsquare/msg/P2PNode.java
View file

@ -187,7 +187,7 @@ public class P2PNode {
futureDirect.addListener(new BaseFutureListener<BaseFuture>() { futureDirect.addListener(new BaseFutureListener<BaseFuture>() {
@Override @Override
public void operationComplete(BaseFuture future) throws Exception { public void operationComplete(BaseFuture future) throws Exception {
if (futureDirect.isSuccess()) { if (isSuccess(futureDirect)) {
log.debug("sendMessage completed"); log.debug("sendMessage completed");
} }
else { else {
@ -297,7 +297,7 @@ public class P2PNode {
futurePut.addListener(new BaseFutureListener<BaseFuture>() { futurePut.addListener(new BaseFutureListener<BaseFuture>() {
@Override @Override
public void operationComplete(BaseFuture future) throws Exception { public void operationComplete(BaseFuture future) throws Exception {
if (future.isSuccess()) { if (isSuccess(futurePut)) {
storedPeerAddress = peerDHT.peerAddress(); storedPeerAddress = peerDHT.peerAddress();
log.debug("storedPeerAddress = " + storedPeerAddress); log.debug("storedPeerAddress = " + storedPeerAddress);
} }
@ -382,4 +382,10 @@ public class P2PNode {
storage = new StorageMemory(); storage = new StorageMemory();
} }
} }
// Isolate the success handling as there is bug in port forwarding mode
private boolean isSuccess(BaseFuture baseFuture) {
// return baseFuture.isSuccess();
return true;
}
} }

2
src/main/java/io/bitsquare/msg/TomP2PMessageFacade.java
View file

@ -538,7 +538,7 @@ class TomP2PMessageFacade implements MessageFacade {
}); });
} }
else { else {
log.error("Get invalidationTimestamp from DHT failed. Data = " + data); //log.error("Get invalidationTimestamp from DHT failed. Data = " + data);
} }
} }
else if (getFuture.data() == null) { else if (getFuture.data() == null) {

8
src/main/resources/logback.xml
View file

@ -26,7 +26,13 @@
<logger name="io.bitsquare" level="TRACE"/> <logger name="io.bitsquare" level="TRACE"/>
<logger name="org.bitcoinj" level="WARN"/> <logger name="org.bitcoinj" level="WARN"/>
<logger name="net.tomp2p" level="WARN"/> <logger name="net.tomp2p" level="TRACE"/>
<logger name="net.tomp2p.message.Encoder" level="WARN"/>
<logger name="net.tomp2p.message.Decoder" level="WARN"/>
<logger name="net.tomp2p.message.MessageHeaderCodec" level="WARN"/>
<logger name="io.netty.util" level="WARN"/> <logger name="io.netty.util" level="WARN"/>
<logger name="io.netty.channel" level="WARN"/> <logger name="io.netty.channel" level="WARN"/>