Author: toad
Date: 2008-06-18 19:41:03 +0000 (Wed, 18 Jun 2008)
New Revision: 20457
Modified:
branches/db4o/freenet/src/freenet/client/FECQueue.java
branches/db4o/freenet/src/freenet/node/NodeClientCore.java
Log:
Start the FEC queue. Start the database thread. Move stuff around slightly.
Modified: branches/db4o/freenet/src/freenet/client/FECQueue.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/FECQueue.java 2008-06-18
19:33:33 UTC (rev 20456)
+++ branches/db4o/freenet/src/freenet/client/FECQueue.java 2008-06-18
19:41:03 UTC (rev 20457)
@@ -40,7 +40,7 @@
private transient int fecPoolCounter;
/** Called after creating or deserializing the FECQueue. Initialises
all the transient fields. */
- void init(int priorities, int maxCacheSize, DBJobRunner dbJobRunner,
Executor exec, ClientContext clientContext) {
+ public void init(int priorities, int maxCacheSize, DBJobRunner
dbJobRunner, Executor exec, ClientContext clientContext) {
this.priorities = priorities;
this.maxPersistentQueueCacheSize = maxCacheSize;
this.databaseJobRunner = dbJobRunner;
Modified: branches/db4o/freenet/src/freenet/node/NodeClientCore.java
===================================================================
--- branches/db4o/freenet/src/freenet/node/NodeClientCore.java 2008-06-18
19:33:33 UTC (rev 20456)
+++ branches/db4o/freenet/src/freenet/node/NodeClientCore.java 2008-06-18
19:41:03 UTC (rev 20457)
@@ -370,6 +370,7 @@
toadletContainer.removeStartupToadlet();
}
+ fecQueue.init(RequestStarter.NUMBER_OF_PRIORITY_CLASSES, 100,
clientContext.jobRunner, node.executor, clientContext);
}
private static String l10n(String key) {
@@ -428,11 +429,13 @@
}, NativeThread.NORM_PRIORITY, false);
persister.start();
+
+ datastoreCheckerExecutor.start(node.executor, "Datastore
checker");
+ clientDatabaseExecutor.start(node.executor, "Client database
access thread");
if(fcpServer != null)
fcpServer.maybeStart();
if(tmci != null)
tmci.start();
- datastoreCheckerExecutor.start(node.executor, "Datastore
checker");
node.executor.execute(new PrioRunnable() {
public void run() {
