AGentooCat/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Packages Projects Releases Wiki Activity

NetDB: Only rewrite blind cache at shutdown if changed

Browse Source
This commit is contained in:
zzz
2021-02-06 11:35:39 -05:00
parent ce3db7ed9f
commit 745a9f083b
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
router/java/src/net/i2p/router/networkdb/kademlia/BlindCache.java
View File

@@ -41,6 +41,7 @@ class BlindCache {
private final ConcurrentHashMap<SigningPublicKey, BlindData> _reverseCache;
// dest hash
private final ConcurrentHashMap<Hash, BlindData> _hashCache;
private boolean _changed;
private static final String PERSIST_FILE = "router.blindcache.dat";
@@ -58,7 +59,8 @@ class BlindCache {
* May be restarted by calling startup() again.
*/
public synchronized void shutdown() {
store();
if (_changed)
store();
_cache.clear();
_reverseCache.clear();
_hashCache.clear();
@@ -173,8 +175,11 @@ class BlindCache {
*/
public void addToCache(BlindData bd) {
storeInCache(bd);
if (bd.getSecret() != null || bd.getAuthPrivKey() != null)
if (bd.getSecret() != null || bd.getAuthPrivKey() != null) {
store();
} else {
synchronized(this) { _changed = true; }
}
}
/**
@@ -313,6 +318,7 @@ class BlindCache {
log.warn("Error reading cache entry: " + line, dfe);
}
}
_changed = false;
} catch (IOException ioe) {
if (log.shouldLog(Log.WARN) && file.exists())
log.warn("Error reading the blinding cache file", ioe);
@@ -339,6 +345,7 @@ class BlindCache {
}
if (out.checkError())
throw new IOException("Failed write to " + file);
_changed = false;
} catch (IOException ioe) {
if (log.shouldLog(Log.WARN))
log.warn("Error writing the blinding cache File", ioe);