Qortal/altcoinj
1
0
Fork 1
mirror of https://github.com/Qortal/altcoinj.git synced 2025-07-31 20:11:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

NioClientManager: change logging levels

Browse Source
This commit is contained in:
Mike Hearn
2014-12-18 14:01:47 +01:00
parent 2967e07c8b
commit 4a4691596b
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
core/src/main/java/org/bitcoinj/net/NioClientManager.java
View File

@@ -69,7 +69,7 @@ public class NioClientManager extends AbstractExecutionThreadService implements
parser.connectionOpened(); parser.connectionOpened();
data.future.set(data.address); data.future.set(data.address);
} else { } else {
log.error("Failed to connect to {}", sc.socket().getRemoteSocketAddress()); log.warn("Failed to connect to {}", sc.socket().getRemoteSocketAddress());
handler.closeConnection(); // Failed to connect for some reason handler.closeConnection(); // Failed to connect for some reason
data.future.setException(new ConnectException("Unknown reason")); data.future.setException(new ConnectException("Unknown reason"));
data.future = null; data.future = null;
@@ -79,7 +79,7 @@ public class NioClientManager extends AbstractExecutionThreadService implements
// may cause this. Otherwise it may be any arbitrary kind of connection failure. // may cause this. Otherwise it may be any arbitrary kind of connection failure.
// Calling sc.socket().getRemoteSocketAddress() here throws an exception, so we can only log the error itself // Calling sc.socket().getRemoteSocketAddress() here throws an exception, so we can only log the error itself
Throwable cause = Throwables.getRootCause(e); Throwable cause = Throwables.getRootCause(e);
log.error("Failed to connect with exception: {}: {}", cause.getClass().getName(), cause.getMessage()); log.warn("Failed to connect with exception: {}: {}", cause.getClass().getName(), cause.getMessage());
handler.closeConnection(); handler.closeConnection();
data.future.setException(cause); data.future.setException(cause);
data.future = null; data.future = null;
@@ -111,7 +111,7 @@ public class NioClientManager extends AbstractExecutionThreadService implements
SelectionKey key = conn.sc.register(selector, SelectionKey.OP_CONNECT); SelectionKey key = conn.sc.register(selector, SelectionKey.OP_CONNECT);
key.attach(conn); key.attach(conn);
} catch (ClosedChannelException e) { } catch (ClosedChannelException e) {
log.info("SocketChannel was closed before it could be registered"); log.warn("SocketChannel was closed before it could be registered");
} }
} }
@@ -125,14 +125,14 @@ public class NioClientManager extends AbstractExecutionThreadService implements
} }
} }
} catch (Exception e) { } catch (Exception e) {
log.error("Error trying to open/read from connection: ", e); log.warn("Error trying to open/read from connection: ", e);
} finally { } finally {
// Go through and close everything, without letting IOExceptions get in our way // Go through and close everything, without letting IOExceptions get in our way
for (SelectionKey key : selector.keys()) { for (SelectionKey key : selector.keys()) {
try { try {
key.channel().close(); key.channel().close();
} catch (IOException e) { } catch (IOException e) {
log.error("Error closing channel", e); log.warn("Error closing channel", e);
} }
key.cancel(); key.cancel();
if (key.attachment() instanceof ConnectionHandler) if (key.attachment() instanceof ConnectionHandler)
@@ -141,7 +141,7 @@ public class NioClientManager extends AbstractExecutionThreadService implements
try { try {
selector.close(); selector.close();
} catch (IOException e) { } catch (IOException e) {
log.error("Error closing client manager selector", e); log.warn("Error closing client manager selector", e);
} }
} }
} }