[freenet-cvs] r17962 - in trunk/freenet/src/freenet: client/async node

[t...@freenetproject.org]

Author: toad
Date: 2008-02-15 20:30:00 +0000 (Fri, 15 Feb 2008)
New Revision: 17962

Modified:
   trunk/freenet/src/freenet/client/async/ClientRequestScheduler.java
   trunk/freenet/src/freenet/node/RequestStarter.java
Log:
Use an explicit wakeUp() method.

Modified: trunk/freenet/src/freenet/client/async/ClientRequestScheduler.java
===================================================================
--- trunk/freenet/src/freenet/client/async/ClientRequestScheduler.java  
2008-02-15 20:00:48 UTC (rev 17961)
+++ trunk/freenet/src/freenet/client/async/ClientRequestScheduler.java  
2008-02-15 20:30:00 UTC (rev 17962)
@@ -257,9 +257,7 @@
                        }
                }
                innerRegister(req);
-               synchronized(starter) {
-                       starter.notifyAll();
-               }
+               starter.wakeUp();
        }

        private void addPendingKey(ClientKey key, SendableGet getter) {
@@ -564,9 +562,7 @@
                        req.unregister();
                        innerRegister(req);
                }
-               synchronized(starter) {
-                       starter.notifyAll();
-               }
+               starter.wakeUp();
        }

        public String getChoosenPriorityScheduler() {
@@ -647,9 +643,7 @@
                if(logMINOR)
                        Logger.minor(this, "Priority: "+priority);
                offeredKeys[priority].queueKey(key);
-               synchronized(starter) {
-                       starter.notifyAll();
-               }
+               starter.wakeUp();
        }

        public void dequeueOfferedKey(Key key) {

Modified: trunk/freenet/src/freenet/node/RequestStarter.java
===================================================================
--- trunk/freenet/src/freenet/node/RequestStarter.java  2008-02-15 20:00:48 UTC 
(rev 17961)
+++ trunk/freenet/src/freenet/node/RequestStarter.java  2008-02-15 20:30:00 UTC 
(rev 17962)
@@ -214,4 +214,10 @@

        }

+       public void wakeUp() {
+               synchronized(this) {
+                       notifyAll();
+               }
+       }
+
 }