Git-Mirrors/haveno
1
0
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2025-07-28 17:34:11 -04:00
Code Issues Projects Releases Packages Wiki Activity

Move implicit purge removal period to declared constant

Browse source
This commit is contained in:
Ivan Vilata-i-Balaguer 2016-04-15 08:59:03 +02:00
parent 7a7b33fc76
commit 45b1314099
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
network/src/main/java/io/bitsquare/p2p/storage/P2PDataStorage.java
View file

@ -40,6 +40,8 @@ import java.util.concurrent.TimeUnit;
// Run in UserThread // Run in UserThread
public class P2PDataStorage implements MessageListener, ConnectionListener { public class P2PDataStorage implements MessageListener, ConnectionListener {
private static final Logger log = LoggerFactory.getLogger(P2PDataStorage.class); private static final Logger log = LoggerFactory.getLogger(P2PDataStorage.class);
/** How many days to keep an entry before it is purged. */
public static final int PURGE_AGE_DAYS = 10;
@VisibleForTesting @VisibleForTesting
public static int CHECK_TTL_INTERVAL_SEC = Timer.STRESS_TEST ? 5 : 60; public static int CHECK_TTL_INTERVAL_SEC = Timer.STRESS_TEST ? 5 : 60;
@ -495,10 +497,10 @@ public class P2PDataStorage implements MessageListener, ConnectionListener {
return new ByteArray(Hash.getHash(data)); return new ByteArray(Hash.getHash(data));
} }
// Get a new map with entries older than 10 days purged from the given map. // Get a new map with entries older than PURGE_AGE_DAYS purged from the given map.
private HashMap<ByteArray, MapValue> getPurgedSequenceNumberMap(HashMap<ByteArray, MapValue> persisted) { private HashMap<ByteArray, MapValue> getPurgedSequenceNumberMap(HashMap<ByteArray, MapValue> persisted) {
HashMap<ByteArray, MapValue> purged = new HashMap<>(); HashMap<ByteArray, MapValue> purged = new HashMap<>();
long maxAgeTs = System.currentTimeMillis() - TimeUnit.DAYS.toMillis(10); long maxAgeTs = System.currentTimeMillis() - TimeUnit.DAYS.toMillis(PURGE_AGE_DAYS);
persisted.entrySet().stream().forEach(entry -> { persisted.entrySet().stream().forEach(entry -> {
if (entry.getValue().timeStamp > maxAgeTs) if (entry.getValue().timeStamp > maxAgeTs)
purged.put(entry.getKey(), entry.getValue()); purged.put(entry.getKey(), entry.getValue());