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 logs, optimize stream

Browse source
This commit is contained in:
chimp1984 2021-01-01 14:06:16 -05:00
parent 15b8f64d91
commit 0aeaa5386c
No known key found for this signature in database
GPG key ID: 9801B4EC591F90E3
1 changed files with 7 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
p2p/src/main/java/bisq/network/p2p/peers/getdata/messages/GetDataResponse.java
View file

@ -27,8 +27,8 @@ import bisq.common.app.Capabilities;
import bisq.common.app.Version;
import bisq.common.proto.network.NetworkEnvelope;
import bisq.common.proto.network.NetworkProtoResolver;
import bisq.common.util.Utilities;
import java.util.HashSet;
import java.util.Set;
import java.util.stream.Collectors;
@ -107,24 +107,18 @@ public final class GetDataResponse extends NetworkEnvelope implements SupportedC
protobuf.NetworkEnvelope proto = getNetworkEnvelopeBuilder()
.setGetDataResponse(builder)
.build();
log.info("Sending a GetDataResponse with {} kB", proto.getSerializedSize() / 1000d);
log.info("Sending a GetDataResponse with {}", Utilities.readableFileSize(proto.getSerializedSize()));
return proto;
}
public static GetDataResponse fromProto(protobuf.GetDataResponse proto,
NetworkProtoResolver resolver,
int messageVersion) {
log.info("Received a GetDataResponse with {} kB", proto.getSerializedSize() / 1000d);
Set<ProtectedStorageEntry> dataSet = new HashSet<>(
proto.getDataSetList().stream()
.map(entry -> (ProtectedStorageEntry) resolver.fromProto(entry))
.collect(Collectors.toSet()));
Set<PersistableNetworkPayload> persistableNetworkPayloadSet = new HashSet<>(
proto.getPersistableNetworkPayloadItemsList().stream()
.map(e -> (PersistableNetworkPayload) resolver.fromProto(e))
.collect(Collectors.toSet()));
log.info("Received a GetDataResponse with {}", Utilities.readableFileSize(proto.getSerializedSize()));
Set<ProtectedStorageEntry> dataSet = proto.getDataSetList().stream()
.map(entry -> (ProtectedStorageEntry) resolver.fromProto(entry)).collect(Collectors.toSet());
Set<PersistableNetworkPayload> persistableNetworkPayloadSet = proto.getPersistableNetworkPayloadItemsList().stream()
.map(e -> (PersistableNetworkPayload) resolver.fromProto(e)).collect(Collectors.toSet());
return new GetDataResponse(dataSet,
persistableNetworkPayloadSet,
proto.getRequestNonce(),