Author: toad
Date: 2009-02-25 18:25:45 +0000 (Wed, 25 Feb 2009)
New Revision: 25816
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
Log:
Slightly better
Modified:
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
2009-02-25 18:24:20 UTC (rev 25815)
+++ branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
2009-02-25 18:25:45 UTC (rev 25816)
@@ -733,6 +733,7 @@
if((!isSSKScheduler) && (!isInsertScheduler)) {
Logger.minor(this, "Scheduling CHK fetches...");
}
+ boolean addedMore = false;
while(true) {
SendableRequest request =
schedCore.removeFirstInner(fuzz, random, offeredKeys, starter, schedTransient,
false, true, Short.MAX_VALUE, Integer.MAX_VALUE, context, container);
if(request == null) {
@@ -745,16 +746,16 @@
nextQueueFillRequestStarterQueue = System.currentTimeMillis() +
WAIT_AFTER_NOTHING_TO_START;
}
}
- if(added) starter.wakeUp();
+ if(addedMore) starter.wakeUp();
return;
}
boolean full = addToStarterQueue(request, container);
container.deactivate(request, 1);
- boolean wasAdded = added;
if(!added) starter.wakeUp();
+ else addedMore = true;
added = true;
if(full) {
- if(wasAdded) starter.wakeUp();
+ if(addedMore) starter.wakeUp();
return;
}
}
_______________________________________________
cvs mailing list
[email protected]
http://emu.freenetproject.org/cgi-bin/mailman/listinfo/cvs
