Author: toad
Date: 2008-07-19 19:20:23 +0000 (Sat, 19 Jul 2008)
New Revision: 21267
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerCore.java
branches/db4o/freenet/src/freenet/node/NodeClientCore.java
Log:
Load InsertCompressor once, not once per scheduler
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerCore.java
===================================================================
---
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerCore.java
2008-07-19 18:46:37 UTC (rev 21266)
+++
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerCore.java
2008-07-19 19:20:23 UTC (rev 21267)
@@ -125,7 +125,6 @@
else
keysFetching = null;
this.sched = sched;
- InsertCompressor.load(container, context);
this.initTime = System.currentTimeMillis();
// We DO NOT want to rerun the query after consuming the
initial set...
preRegisterMeRunner = new DBJob() {
Modified: branches/db4o/freenet/src/freenet/node/NodeClientCore.java
===================================================================
--- branches/db4o/freenet/src/freenet/node/NodeClientCore.java 2008-07-19
18:46:37 UTC (rev 21266)
+++ branches/db4o/freenet/src/freenet/node/NodeClientCore.java 2008-07-19
19:20:23 UTC (rev 21267)
@@ -19,6 +19,7 @@
import freenet.client.async.DBJob;
import freenet.client.async.DBJobRunner;
import freenet.client.async.HealingQueue;
+import freenet.client.async.InsertCompressor;
import freenet.client.async.SimpleHealingQueue;
import freenet.client.async.USKManager;
import freenet.client.async.USKManagerPersistent;
@@ -238,6 +239,7 @@
clientContext = new ClientContext(this);
requestStarters = new RequestStarterGroup(node, this,
portNumber, random, config, throttleFS, clientContext);
clientContext.init(requestStarters);
+ InsertCompressor.load(container, clientContext);
// Downloads directory
