Router: Add a job which can clean up the subdbs periodically

i2p · Sep 7, 2023 · e2e6cb5 · e2e6cb5
1 parent 76fd9ab
commit e2e6cb5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/...a/src/net/i2p/router/CleanupNetDbJob.java → ...i2p/router/networkdb/CleanupNetDbJob.java b/...a/src/net/i2p/router/CleanupNetDbJob.java → ...i2p/router/networkdb/CleanupNetDbJob.java
diff --git a/router/java/src/net/i2p/router/networkdb/kademlia/FloodfillNetworkDatabaseSegmentor.java b/router/java/src/net/i2p/router/networkdb/kademlia/FloodfillNetworkDatabaseSegmentor.java
@@ -19,6 +19,7 @@
 import net.i2p.data.router.RouterInfo;
 import net.i2p.router.Job;
 import net.i2p.router.RouterContext;
+import net.i2p.router.networkdb.CleanupNetDbJob;
 import net.i2p.router.networkdb.reseed.ReseedChecker;
 import net.i2p.util.Log;
 
@@ -36,6 +37,7 @@ public FloodfillNetworkDatabaseSegmentor(RouterContext context) {
             _context = context;
         FloodfillNetworkDatabaseFacade subdb = new FloodfillNetworkDatabaseFacade(_context, MAIN_DBID);
         _subDBs.put(MAIN_DBID, subdb);
+        _context.jobQueue().addJob(new CleanupNetDbJob(_context));
     }
 
     /*
@@ -112,7 +114,7 @@ public synchronized void shutdown() {
         }
     }
 
-    public synchronized void remove(String dbid){
+    private synchronized void remove(String dbid) {
         if (dbid != null)
             if (dbid.endsWith(".i2p"))
                 dbid = "clients_" + dbid;