Author: toad
Date: 2008-07-22 15:54:16 +0000 (Tue, 22 Jul 2008)
New Revision: 21310
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientContext.java
Log:
Activation/deactivation
Modified: branches/db4o/freenet/src/freenet/client/async/ClientContext.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/ClientContext.java
2008-07-22 15:53:39 UTC (rev 21309)
+++ branches/db4o/freenet/src/freenet/client/async/ClientContext.java
2008-07-22 15:54:16 UTC (rev 21310)
@@ -88,11 +88,13 @@
jobRunner.queue(new DBJob() {
public void run(ObjectContainer container,
ClientContext context) {
+ container.activate(inserter, 1);
try {
inserter.start(earlyEncode,
false, container, context);
} catch (InsertException e) {
inserter.client.onFailure(e,
inserter, container);
}
+ container.deactivate(inserter, 1);
}
}, NativeThread.NORM_PRIORITY, false);
@@ -106,11 +108,13 @@
jobRunner.queue(new DBJob() {
public void run(ObjectContainer container,
ClientContext context) {
+ container.activate(getter, 1);
try {
getter.start(container,
context);
} catch (FetchException e) {
getter.clientCallback.onFailure(e, getter, container);
}
+ container.deactivate(getter, 1);
}
}, NativeThread.NORM_PRIORITY, false);
@@ -124,11 +128,13 @@
jobRunner.queue(new DBJob() {
public void run(ObjectContainer container,
ClientContext context) {
+ container.activate(inserter, 1);
try {
inserter.start(container,
context);
} catch (InsertException e) {
inserter.cb.onFailure(e,
inserter, container);
}
+ container.deactivate(inserter, 1);
}
}, NativeThread.NORM_PRIORITY, false);
