mirrors/bitcoinj
1
0
Fork 0
mirror of https://github.com/bitcoinj/bitcoinj.git synced 2025-01-18 21:32:35 +01:00
Code Issues Packages Projects Releases Wiki Activity

Payment channels: log connection failures in NioClient

Browse Source
This commit is contained in:
Mike Hearn 2015-03-22 16:27:29 +01:00
parent 2fd565c366
commit 16f953c6c1
1 changed files with 19 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
core/src/main/java/org/bitcoinj/net/NioClient.java
View File

@ -17,14 +17,20 @@
package org.bitcoinj.net;
import java.io.IOException;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import com.google.common.base.*;
import com.google.common.util.concurrent.*;
import org.slf4j.*;
import java.io.*;
import java.net.*;
import java.nio.*;
/**
* Creates a simple connection to a server using a {@link StreamParser} to process data.
*/
public class NioClient implements MessageWriteTarget {
private static final Logger log = LoggerFactory.getLogger(NioClient.class);
private final Handler handler;
private final NioClientManager manager = new NioClientManager();
@ -96,7 +102,16 @@ public class NioClient implements MessageWriteTarget {
manager.startAsync();
manager.awaitRunning();
handler = new Handler(parser, connectTimeoutMillis);
manager.openConnection(serverAddress, handler);
Futures.addCallback(manager.openConnection(serverAddress, handler), new FutureCallback<SocketAddress>() {
@Override
public void onSuccess(SocketAddress result) {
}
@Override
public void onFailure(Throwable t) {
log.error("Connect to {} failed: {}", serverAddress, Throwables.getRootCause(t));
}
});
}
@Override