[freenet-cvs] r21251 - branches/db4o/freenet/src/freenet/client/async

[t...@freenetproject.org]

Author: toad
Date: 2008-07-19 17:03:10 +0000 (Sat, 19 Jul 2008)
New Revision: 21251

Modified:
   branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
Log:
>= not <=

Modified: 
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java  
2008-07-19 16:48:15 UTC (rev 21250)
+++ branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java  
2008-07-19 17:03:10 UTC (rev 21251)
@@ -164,7 +164,7 @@
                        if(onDatabaseThread) {
                                if(regmeOnly) {
                                        long bootID = 0;
-                                       boolean queueFull = 
jobRunner.getQueueSize(NativeThread.NORM_PRIORITY) <= QUEUE_THRESHOLD;
+                                       boolean queueFull = 
jobRunner.getQueueSize(NativeThread.NORM_PRIORITY) >= QUEUE_THRESHOLD;
                                        if(!queueFull)
                                                bootID = this.node.bootID;
                                        final RegisterMe regme = new 
RegisterMe(null, null, req, req.getPriorityClass(selectorContainer), schedCore, 
null, bootID);
@@ -271,7 +271,7 @@
                                boolean queueFull = false;
                                if(reg == null) {
                                        long bootID = 0;
-                                       queueFull = 
jobRunner.getQueueSize(NativeThread.NORM_PRIORITY) <= QUEUE_THRESHOLD;
+                                       queueFull = 
jobRunner.getQueueSize(NativeThread.NORM_PRIORITY) >= QUEUE_THRESHOLD;
                                        if(!queueFull)
                                                bootID = this.node.bootID;