Author: toad
Date: 2008-07-12 16:44:19 +0000 (Sat, 12 Jul 2008)
New Revision: 21111
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
Log:
Don't wait until restart!
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
2008-07-12 16:40:21 UTC (rev 21110)
+++ branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
2008-07-12 16:44:19 UTC (rev 21111)
@@ -161,10 +161,18 @@
if(persistent) {
if(onDatabaseThread) {
if(regmeOnly) {
- RegisterMe regme = new RegisterMe(null,
null, req, req.getPriorityClass(selectorContainer), schedCore, null);
+ final RegisterMe regme = new
RegisterMe(null, null, req, req.getPriorityClass(selectorContainer), schedCore,
null);
selectorContainer.set(regme);
if(logMINOR)
Logger.minor(this, "Added
insert RegisterMe: "+regme);
+ jobRunner.queue(new DBJob() {
+
+ public void run(ObjectContainer
container, ClientContext context) {
+ container.delete(regme);
+ registerInsert(req,
true, false, true);
+ }
+
+ }, NativeThread.NORM_PRIORITY, false);
}
schedCore.innerRegister(req, random,
selectorContainer);
} else {
