mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2025-02-24 07:07:43 +01:00
Code Issues Projects Releases Packages Wiki Activity

Improve logging of initial data requests

Browse source
This commit is contained in:
chimp1984 2020-08-28 09:39:33 -05:00
parent c218b28755
commit 5f7cfd2dc8
No known key found for this signature in database
GPG key ID: 9801B4EC591F90E3
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
p2p/src/main/java/bisq/network/p2p/peers/getdata/RequestDataHandler.java
View file

@ -55,6 +55,7 @@ class RequestDataHandler implements MessageListener {
private static final long TIMEOUT = 180; private static final long TIMEOUT = 180;
private NodeAddress peersNodeAddress; private NodeAddress peersNodeAddress;
private String getDataRequestType;
/* /*
*/ */
@ -138,7 +139,8 @@ class RequestDataHandler implements MessageListener {
TIMEOUT); TIMEOUT);
} }
log.info("We send a {} to peer {}. ", getDataRequest.getClass().getSimpleName(), nodeAddress); getDataRequestType = getDataRequest.getClass().getSimpleName();
log.info("We send a {} to peer {}. ", getDataRequestType, nodeAddress);
networkNode.addMessageListener(this); networkNode.addMessageListener(this);
SettableFuture<Connection> future = networkNode.sendMessage(nodeAddress, getDataRequest); SettableFuture<Connection> future = networkNode.sendMessage(nodeAddress, getDataRequest);
//noinspection UnstableApiUsage //noinspection UnstableApiUsage
@ -259,8 +261,9 @@ class RequestDataHandler implements MessageListener {
StringBuilder sb = new StringBuilder(); StringBuilder sb = new StringBuilder();
sb.append("\n#################################################################\n"); sb.append("\n#################################################################\n");
sb.append("Connected to node: " + peersNodeAddress.getFullAddress() + "\n"); sb.append("Connected to node: " + peersNodeAddress.getFullAddress() + "\n");
final int items = dataSet.size() + persistableNetworkPayloadSet.size(); int items = dataSet.size() + persistableNetworkPayloadSet.size();
sb.append("Received ").append(items).append(" instances\n"); sb.append("Received ").append(items).append(" instances from a ")
.append(getDataRequestType).append("\n");
payloadByClassName.forEach((key, value) -> sb.append(key) payloadByClassName.forEach((key, value) -> sb.append(key)
.append(": ") .append(": ")
.append(value.size()) .append(value.size())