I2P Address: [http://git.idk.i2p]

Skip to content
Snippets Groups Projects
Commit dca5e988 authored by zzz's avatar zzz
Browse files

finals

parent 67beebf8
No related branches found
No related tags found
No related merge requests found
...@@ -42,7 +42,6 @@ import net.i2p.util.SecureFileOutputStream; ...@@ -42,7 +42,6 @@ import net.i2p.util.SecureFileOutputStream;
* *
*/ */
class PersistentDataStore extends TransientDataStore { class PersistentDataStore extends TransientDataStore {
private final Log _log;
private final File _dbDir; private final File _dbDir;
private final KademliaNetworkDatabaseFacade _facade; private final KademliaNetworkDatabaseFacade _facade;
private final Writer _writer; private final Writer _writer;
...@@ -60,7 +59,6 @@ class PersistentDataStore extends TransientDataStore { ...@@ -60,7 +59,6 @@ class PersistentDataStore extends TransientDataStore {
*/ */
public PersistentDataStore(RouterContext ctx, String dbDir, KademliaNetworkDatabaseFacade facade) throws IOException { public PersistentDataStore(RouterContext ctx, String dbDir, KademliaNetworkDatabaseFacade facade) throws IOException {
super(ctx); super(ctx);
_log = ctx.logManager().getLog(PersistentDataStore.class);
_flat = ctx.getBooleanProperty(PROP_FLAT); _flat = ctx.getBooleanProperty(PROP_FLAT);
_dbDir = getDbDir(dbDir); _dbDir = getDbDir(dbDir);
_facade = facade; _facade = facade;
......
...@@ -22,14 +22,17 @@ import net.i2p.data.RouterInfo; ...@@ -22,14 +22,17 @@ import net.i2p.data.RouterInfo;
import net.i2p.router.RouterContext; import net.i2p.router.RouterContext;
import net.i2p.util.Log; import net.i2p.util.Log;
/**
* Stores in-memory only. See extension.
*/
class TransientDataStore implements DataStore { class TransientDataStore implements DataStore {
private Log _log; protected final Log _log;
private ConcurrentHashMap<Hash, DatabaseEntry> _data; private final ConcurrentHashMap<Hash, DatabaseEntry> _data;
protected RouterContext _context; protected final RouterContext _context;
public TransientDataStore(RouterContext ctx) { public TransientDataStore(RouterContext ctx) {
_context = ctx; _context = ctx;
_log = ctx.logManager().getLog(TransientDataStore.class); _log = ctx.logManager().getLog(getClass());
_data = new ConcurrentHashMap(1024); _data = new ConcurrentHashMap(1024);
if (_log.shouldLog(Log.INFO)) if (_log.shouldLog(Log.INFO))
_log.info("Data Store initialized"); _log.info("Data Store initialized");
...@@ -191,7 +194,7 @@ class TransientDataStore implements DataStore { ...@@ -191,7 +194,7 @@ class TransientDataStore implements DataStore {
public DatabaseEntry remove(Hash key) { public DatabaseEntry remove(Hash key) {
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
_log.debug("Removing key " + key.toBase64()); _log.debug("Removing key " + key);
return _data.remove(key); return _data.remove(key);
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment