Author: nextgens
Date: 2007-03-28 15:35:15 +0000 (Wed, 28 Mar 2007)
New Revision: 12411

Modified:
   trunk/freenet/src/freenet/node/RequestSender.java
Log:
Sync. fix

Modified: trunk/freenet/src/freenet/node/RequestSender.java
===================================================================
--- trunk/freenet/src/freenet/node/RequestSender.java   2007-03-28 12:29:21 UTC 
(rev 12410)
+++ trunk/freenet/src/freenet/node/RequestSender.java   2007-03-28 15:35:15 UTC 
(rev 12411)
@@ -541,9 +541,10 @@
                }

                private void _realRun() {
-                       short current = mask; // If any bits are set already, 
we ignore those states.
-               
+                       short current;
                        synchronized (cb) {
+                               current = mask; // If any bits are set already, 
we ignore those states.
+                               
                                if(hasForwardedRejectedOverload)
                                        current |= WAIT_REJECTED_OVERLOAD;

@@ -552,13 +553,11 @@

                        if(status != NOT_FINISHED)
                                current |= WAIT_FINISHED;
-       
-                               }
-                       
-               if(current != mask)
-                       cb.onStatusChange(current);
-               else
-                       node.ps.queueTimedJob(this, 10000);
+
+                       if(current == mask)
+                               node.ps.queueTimedJob(this, 10000);
+                       }
+               cb.onStatusChange(current);
                }
        };



Reply via email to