Author: toad
Date: 2008-06-25 15:09:40 +0000 (Wed, 25 Jun 2008)
New Revision: 20682
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerBase.java
Log:
Activation
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerBase.java
===================================================================
---
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerBase.java
2008-06-25 15:08:34 UTC (rev 20681)
+++
branches/db4o/freenet/src/freenet/client/async/ClientRequestSchedulerBase.java
2008-06-25 15:09:40 UTC (rev 20682)
@@ -263,6 +263,7 @@
}
// Client
SectoredRandomGrabArrayWithInt clientGrabber =
(SectoredRandomGrabArrayWithInt) prio.get(rc);
+ if(persistent()) container.activate(clientGrabber, 1);
if(clientGrabber == null) {
clientGrabber = new SectoredRandomGrabArrayWithInt(rc,
persistent(), container);
prio.add(clientGrabber, container);
@@ -273,6 +274,7 @@
synchronized(clientGrabber) {
// Request
SectoredRandomGrabArrayWithObject requestGrabber =
(SectoredRandomGrabArrayWithObject) clientGrabber.getGrabber(client);
+ if(persistent()) container.activate(requestGrabber, 1);
if(requestGrabber == null) {
requestGrabber = new
SectoredRandomGrabArrayWithObject(client, persistent(), container);
if(logMINOR)
