diff --git a/consensus/clique/src/main/java/tech/pegasys/pantheon/consensus/clique/CliqueVoteTallyUpdater.java b/consensus/clique/src/main/java/tech/pegasys/pantheon/consensus/clique/CliqueVoteTallyUpdater.java index 385feb84b4..dd7ce79698 100644 --- a/consensus/clique/src/main/java/tech/pegasys/pantheon/consensus/clique/CliqueVoteTallyUpdater.java +++ b/consensus/clique/src/main/java/tech/pegasys/pantheon/consensus/clique/CliqueVoteTallyUpdater.java @@ -40,7 +40,7 @@ public class CliqueVoteTallyUpdater { public VoteTally buildVoteTallyFromBlockchain(final Blockchain blockchain) { final long chainHeadBlockNumber = blockchain.getChainHeadBlockNumber(); final long epochBlockNumber = epochManager.getLastEpochBlock(chainHeadBlockNumber); - LOG.info("Loading validator voting state starting from block {}", epochBlockNumber); + LOG.debug("Loading validator voting state starting from block {}", epochBlockNumber); final BlockHeader epochBlock = blockchain.getBlockHeader(epochBlockNumber).get(); final List
initialValidators = CliqueExtraData.decode(epochBlock.getExtraData()).getValidators(); diff --git a/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/manager/EthServer.java b/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/manager/EthServer.java index 3971a1f9be..934d91b426 100644 --- a/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/manager/EthServer.java +++ b/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/manager/EthServer.java @@ -65,7 +65,7 @@ class EthServer { } private void handleGetBlockHeaders(final EthMessage message) { - LOG.info("Responding to GET_BLOCK_HEADERS request"); + LOG.trace("Responding to GET_BLOCK_HEADERS request"); try { final MessageData response = constructGetHeadersResponse(blockchain, message.getData(), requestLimit); @@ -78,7 +78,7 @@ class EthServer { } private void handleGetBlockBodies(final EthMessage message) { - LOG.info("Responding to GET_BLOCK_BODIES request"); + LOG.trace("Responding to GET_BLOCK_BODIES request"); try { final MessageData response = constructGetBodiesResponse(blockchain, message.getData(), requestLimit); @@ -91,7 +91,7 @@ class EthServer { } private void handleGetReceipts(final EthMessage message) { - LOG.info("Responding to GET_RECEIPTS request"); + LOG.trace("Responding to GET_RECEIPTS request"); try { final MessageData response = constructGetReceiptsResponse(blockchain, message.getData(), requestLimit); @@ -104,7 +104,7 @@ class EthServer { } private void handleGetNodeData(final EthMessage message) { - LOG.info("Responding to GET_NODE_DATA request"); + LOG.trace("Responding to GET_NODE_DATA request"); try { final MessageData response = constructGetNodeDataResponse(message.getData(), requestLimit); message.getPeer().send(response); diff --git a/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/sync/TrailingPeerLimiter.java b/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/sync/TrailingPeerLimiter.java index 14fc354c17..32259ac5ba 100644 --- a/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/sync/TrailingPeerLimiter.java +++ b/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/sync/TrailingPeerLimiter.java @@ -67,7 +67,7 @@ public class TrailingPeerLimiter implements BlockAddedObserver { while (!trailingPeers.isEmpty() && trailingPeers.size() > maxTrailingPeers) { final EthPeer peerToDisconnect = trailingPeers.remove(0); - LOG.info("Enforcing trailing peers limit by disconnecting {}", peerToDisconnect); + LOG.debug("Enforcing trailing peers limit by disconnecting {}", peerToDisconnect); peerToDisconnect.disconnect(DisconnectReason.TOO_MANY_PEERS); } } diff --git a/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/sync/tasks/DownloadHeaderSequenceTask.java b/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/sync/tasks/DownloadHeaderSequenceTask.java index 4ab347a6eb..528fe6eb9f 100644 --- a/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/sync/tasks/DownloadHeaderSequenceTask.java +++ b/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/sync/tasks/DownloadHeaderSequenceTask.java @@ -178,7 +178,7 @@ public class DownloadHeaderSequenceTask extends AbstractRetryingPeerTask {}", request.getMethod()); + LOG.debug("JSON-RPC request -> {}", request.getMethod()); // Find method handler final JsonRpcMethod method = jsonRpcMethods.get(request.getMethod()); if (method == null) { diff --git a/ethereum/jsonrpc/src/main/java/tech/pegasys/pantheon/ethereum/jsonrpc/websocket/WebSocketRequestHandler.java b/ethereum/jsonrpc/src/main/java/tech/pegasys/pantheon/ethereum/jsonrpc/websocket/WebSocketRequestHandler.java index 524b944538..70af1ca18b 100644 --- a/ethereum/jsonrpc/src/main/java/tech/pegasys/pantheon/ethereum/jsonrpc/websocket/WebSocketRequestHandler.java +++ b/ethereum/jsonrpc/src/main/java/tech/pegasys/pantheon/ethereum/jsonrpc/websocket/WebSocketRequestHandler.java @@ -56,7 +56,7 @@ public class WebSocketRequestHandler { } final JsonRpcMethod method = methods.get(request.getMethod()); try { - LOG.info("WS-RPC request -> {}", request.getMethod()); + LOG.debug("WS-RPC request -> {}", request.getMethod()); request.setConnectionId(id); future.complete(method.response(request)); } catch (final Exception e) { diff --git a/ethereum/jsonrpc/src/main/java/tech/pegasys/pantheon/ethereum/jsonrpc/websocket/subscription/SubscriptionManager.java b/ethereum/jsonrpc/src/main/java/tech/pegasys/pantheon/ethereum/jsonrpc/websocket/subscription/SubscriptionManager.java index 935d7cf969..4b419824a3 100644 --- a/ethereum/jsonrpc/src/main/java/tech/pegasys/pantheon/ethereum/jsonrpc/websocket/subscription/SubscriptionManager.java +++ b/ethereum/jsonrpc/src/main/java/tech/pegasys/pantheon/ethereum/jsonrpc/websocket/subscription/SubscriptionManager.java @@ -56,7 +56,7 @@ public class SubscriptionManager extends AbstractVerticle { } public Long subscribe(final SubscribeRequest request) { - LOG.info("Subscribe request {}", request); + LOG.debug("Subscribe request {}", request); final long subscriptionId = subscriptionCounter.incrementAndGet(); final Subscription subscription = subscriptionBuilder.build(subscriptionId, request); diff --git a/ethereum/p2p/src/main/java/tech/pegasys/pantheon/ethereum/p2p/NetworkRunner.java b/ethereum/p2p/src/main/java/tech/pegasys/pantheon/ethereum/p2p/NetworkRunner.java index 6473664763..d9e0cbb01d 100644 --- a/ethereum/p2p/src/main/java/tech/pegasys/pantheon/ethereum/p2p/NetworkRunner.java +++ b/ethereum/p2p/src/main/java/tech/pegasys/pantheon/ethereum/p2p/NetworkRunner.java @@ -120,7 +120,7 @@ public class NetworkRunner implements AutoCloseable { final int code = message.getData().getCode(); if (!protocol.isValidMessageCode(cap.getVersion(), code)) { // Handle invalid messsages by disconnecting - LOG.info( + LOG.debug( "Invalid message code ({}-{}, {}) received from peer, disconnecting from:", cap.getName(), cap.getVersion(), diff --git a/ethereum/p2p/src/main/java/tech/pegasys/pantheon/ethereum/p2p/netty/AbstractHandshakeHandler.java b/ethereum/p2p/src/main/java/tech/pegasys/pantheon/ethereum/p2p/netty/AbstractHandshakeHandler.java index 31e3fa4ac9..97ebd34b2d 100644 --- a/ethereum/p2p/src/main/java/tech/pegasys/pantheon/ethereum/p2p/netty/AbstractHandshakeHandler.java +++ b/ethereum/p2p/src/main/java/tech/pegasys/pantheon/ethereum/p2p/netty/AbstractHandshakeHandler.java @@ -82,7 +82,7 @@ abstract class AbstractHandshakeHandler extends SimpleChannelInboundHandler