Author: toad
Date: 2008-06-26 19:02:35 +0000 (Thu, 26 Jun 2008)
New Revision: 20778
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerCore.java
Log:
RegisterMe's are created by queueRegister.
If we already have one we don't need to call it; if we don't (if it's a new
request), we need to delete it when done.
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerCore.java
===================================================================
---
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerCore.java
2008-06-26 18:52:04 UTC (rev 20777)
+++
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerCore.java
2008-06-26 19:02:35 UTC (rev 20778)
@@ -544,12 +544,13 @@
}
}
- public void queueRegister(SendableRequest req,
PrioritizedSerialExecutor databaseExecutor, ObjectContainer container) {
+ public RegisterMe queueRegister(SendableRequest req,
PrioritizedSerialExecutor databaseExecutor, ObjectContainer container) {
if(!databaseExecutor.onThread()) {
throw new IllegalStateException("Not on database
thread!");
}
RegisterMe reg = new RegisterMe(req,
req.getPriorityClass(container), this);
container.set(reg);
+ return reg;
}
public boolean hasKey(Key key) {
