mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2024-11-19 09:52:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

Refactoring: Rearrange method (moved method)

Browse Source
This commit is contained in:
chimp1984 2020-10-01 15:12:15 -05:00
parent 62836d79f5
commit 58efb62b84
No known key found for this signature in database
GPG Key ID: 9801B4EC591F90E3
1 changed files with 29 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
p2p/src/main/java/bisq/network/p2p/storage/P2PDataStorage.java
View File

@ -223,36 +223,6 @@ public class P2PDataStorage implements MessageListener, ConnectionListener, Pers
return excludedKeys;
}
/**
* Generic function that can be used to filter a Map<ByteArray, ProtectedStorageEntry || PersistableNetworkPayload>
* by a given set of keys and peer capabilities.
*/
static private <T extends NetworkPayload> Set<T> filterKnownHashes(
Map<ByteArray, T> mapToFilter,
Function<T, ? extends NetworkPayload> objToPayloadFunction,
Set<ByteArray> knownHashes,
Capabilities peerCapabilities,
int maxEntries,
AtomicBoolean wasTruncated) {
AtomicInteger limit = new AtomicInteger(maxEntries);
Set<T> filteredResults = mapToFilter.entrySet().stream()
.filter(e -> !knownHashes.contains(e.getKey()))
.filter(e -> limit.decrementAndGet() >= 0)
.map(Map.Entry::getValue)
.filter(networkPayload -> shouldTransmitPayloadToPeer(peerCapabilities,
objToPayloadFunction.apply(networkPayload)))
.collect(Collectors.toSet());
if (limit.get() < 0) {
wasTruncated.set(true);
}
return filteredResults;
}
/**
* Returns a GetDataResponse object that contains the Payloads known locally, but not remotely.
*/
@ -345,6 +315,35 @@ public class P2PDataStorage implements MessageListener, ConnectionListener, Pers
return map;
}
/**
* Generic function that can be used to filter a Map<ByteArray, ProtectedStorageEntry || PersistableNetworkPayload>
* by a given set of keys and peer capabilities.
*/
static private <T extends NetworkPayload> Set<T> filterKnownHashes(
Map<ByteArray, T> mapToFilter,
Function<T, ? extends NetworkPayload> objToPayloadFunction,
Set<ByteArray> knownHashes,
Capabilities peerCapabilities,
int maxEntries,
AtomicBoolean wasTruncated) {
AtomicInteger limit = new AtomicInteger(maxEntries);
Set<T> filteredResults = mapToFilter.entrySet().stream()
.filter(e -> !knownHashes.contains(e.getKey()))
.filter(e -> limit.decrementAndGet() >= 0)
.map(Map.Entry::getValue)
.filter(networkPayload -> shouldTransmitPayloadToPeer(peerCapabilities,
objToPayloadFunction.apply(networkPayload)))
.collect(Collectors.toSet());
if (limit.get() < 0) {
wasTruncated.set(true);
}
return filteredResults;
}
private Set<byte[]> getKeysAsByteSet(Map<ByteArray, ? extends PersistablePayload> map) {
return map.keySet().stream()
.map(e -> e.bytes)