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

Log when we remove expired entries

Browse Source
This commit is contained in:
chimp1984 2020-11-04 12:02:38 -05:00
parent 012c54cf02
commit f10d2318f3
No known key found for this signature in database
GPG Key ID: 9801B4EC591F90E3
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -511,10 +511,12 @@ public class P2PDataStorage implements MessageListener, ConnectionListener, Pers
// Batch processing can cause performance issues, so do all of the removes first, then update the listeners
// to let them know about the removes.
if (log.isDebugEnabled()) {
toRemoveList.forEach(toRemoveItem -> {
log.debug("We found an expired data entry. We remove the protectedData:\n\t" +
log.debug("We found an expired data entry. We remove the protectedData:\n\t{}",
Utilities.toTruncatedString(toRemoveItem.getValue()));
});
}
removeFromMapAndDataStore(toRemoveList);
if (sequenceNumberMap.size() > this.maxSequenceNumberMapSizeBeforePurge) {
@ -937,6 +939,8 @@ public class P2PDataStorage implements MessageListener, ConnectionListener, Pers
if (entriesToRemoveWithPayloadHash.isEmpty())
return;
log.info("Remove {} expired data entries", entriesToRemoveWithPayloadHash.size());
ArrayList<ProtectedStorageEntry> entriesForSignal = new ArrayList<>(entriesToRemoveWithPayloadHash.size());
entriesToRemoveWithPayloadHash.forEach(entryToRemoveWithPayloadHash -> {
ByteArray hashOfPayload = entryToRemoveWithPayloadHash.getKey();