Author: toad
Date: 2008-07-23 12:44:00 +0000 (Wed, 23 Jul 2008)
New Revision: 21336
Modified:
branches/db4o/freenet/src/freenet/node/fcp/FCPConnectionHandler.java
Log:
Activate/deactivate requesters in dbjobs
Modified: branches/db4o/freenet/src/freenet/node/fcp/FCPConnectionHandler.java
===================================================================
--- branches/db4o/freenet/src/freenet/node/fcp/FCPConnectionHandler.java
2008-07-23 12:40:00 UTC (rev 21335)
+++ branches/db4o/freenet/src/freenet/node/fcp/FCPConnectionHandler.java
2008-07-23 12:44:00 UTC (rev 21336)
@@ -247,6 +247,7 @@
return;
}
getter.start(container, context);
+
container.deactivate(getter, 1);
}
},
NativeThread.HIGH_PRIORITY-1, false); // user wants a response soon... but
doesn't want it to block the queue page etc
@@ -304,6 +305,7 @@
server.core.clientContext.jobRunner.queue(new DBJob() {
public void run(ObjectContainer
container, ClientContext context) {
+
container.activate(putter, 1);
try {
putter.register(container, false, false);
} catch
(IdentifierCollisionException e) {
@@ -313,6 +315,7 @@
return;
}
putter.start(container,
context);
+
container.deactivate(putter, 1);
}
}, NativeThread.HIGH_PRIORITY-1,
false); // user wants a response soon... but doesn't want it to block the queue
page etc
@@ -368,6 +371,7 @@
server.core.clientContext.jobRunner.queue(new
DBJob() {
public void run(ObjectContainer
container, ClientContext context) {
+ container.activate(putter, 1);
try {
putter.register(container, false, false);
} catch
(IdentifierCollisionException e) {
@@ -377,6 +381,7 @@
return;
}
putter.start(container,
context);
+ container.deactivate(putter, 1);
}
}, NativeThread.HIGH_PRIORITY-1, false); //
user wants a response soon... but doesn't want it to block the queue page etc
