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

Change removeFromMapAndDataStore to signal listeners at the end in a batch

Browse Source 
All current users still call this one-at-a-time. But, it gives the ability
for the expire code path to remove in a batch.
This commit is contained in:
Julian Knutsen 2019-11-16 11:42:33 -08:00
parent 4f08588717
commit 489b25aa13
No known key found for this signature in database
GPG Key ID: D85F536DB3615B2D
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -651,12 +651,17 @@ public class P2PDataStorage implements MessageListener, ConnectionListener, Pers
private void removeFromMapAndDataStore(
Collection<Map.Entry<ByteArray, ProtectedStorageEntry>> entriesToRemoveWithPayloadHash) {
if (entriesToRemoveWithPayloadHash.isEmpty())
return;
ArrayList<ProtectedStorageEntry> entriesForSignal = new ArrayList<>(entriesToRemoveWithPayloadHash.size());
entriesToRemoveWithPayloadHash.forEach(entryToRemoveWithPayloadHash -> {
ByteArray hashOfPayload = entryToRemoveWithPayloadHash.getKey();
ProtectedStorageEntry protectedStorageEntry = entryToRemoveWithPayloadHash.getValue();
map.remove(hashOfPayload);
hashMapChangedListeners.forEach(e -> e.onRemoved(Collections.singletonList(protectedStorageEntry)));
entriesForSignal.add(protectedStorageEntry);
ProtectedStoragePayload protectedStoragePayload = protectedStorageEntry.getProtectedStoragePayload();
if (protectedStoragePayload instanceof PersistablePayload) {
@ -669,6 +674,8 @@ public class P2PDataStorage implements MessageListener, ConnectionListener, Pers
}
}
});
hashMapChangedListeners.forEach(e -> e.onRemoved(entriesForSignal));
}
private boolean hasSequenceNrIncreased(int newSequenceNumber, ByteArray hashOfData) {