Author: toad
Date: 2008-06-24 15:55:53 +0000 (Tue, 24 Jun 2008)
New Revision: 20649
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
Log:
Avoid an NPE maybe (activation)
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
2008-06-24 15:43:05 UTC (rev 20648)
+++ branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
2008-06-24 15:55:53 UTC (rev 20649)
@@ -176,8 +176,10 @@
schedCore.queueRegister(getter,
databaseExecutor, selectorContainer);
final Object[] keyTokens =
getter.sendableKeys(selectorContainer);
final ClientKey[] keys = new
ClientKey[keyTokens.length];
- for(int i=0;i<keyTokens.length;i++)
+ for(int i=0;i<keyTokens.length;i++) {
keys[i] = getter.getKey(keyTokens[i],
selectorContainer);
+ selectorContainer.activate(keys[i], 5);
+ }
datastoreCheckerExecutor.execute(new Runnable()
{
public void run() {
@@ -193,8 +195,10 @@
schedCore.queueRegister(getter,
databaseExecutor, container);
final Object[] keyTokens =
getter.sendableKeys(container);
final ClientKey[] keys = new
ClientKey[keyTokens.length];
- for(int
i=0;i<keyTokens.length;i++)
- keys[i] =
getter.getKey(keyTokens[i], container);
+ for(int
i=0;i<keyTokens.length;i++) {
+ keys[i] =
getter.getKey(keyTokens[i], selectorContainer);
+
container.activate(keys[i], 5);
+ }
datastoreCheckerExecutor.execute(new Runnable() {
public void run() {
