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

[t...@freenetproject.org]

Author: toad
Date: 2008-07-22 16:08:51 +0000 (Tue, 22 Jul 2008)
New Revision: 21317

Modified:
   branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
Log:
Deactivation

Modified: 
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java  
2008-07-22 16:05:47 UTC (rev 21316)
+++ branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java  
2008-07-22 16:08:51 UTC (rev 21317)
@@ -1007,6 +1007,7 @@
                                if(logMINOR)
                                        Logger.minor(this, "Deleting "+req);
                                
selectorContainer.delete((PersistentChosenRequest)req);
+                               container.deactivate(get, 1);
                        }

                }, prio, false);
@@ -1025,6 +1026,7 @@
                                if(logMINOR)
                                        Logger.minor(this, "Deleting "+req);
                                
selectorContainer.delete((PersistentChosenRequest)req);
+                               container.deactivate(put, 1);
                        }

                }, NativeThread.NORM_PRIORITY, false);
@@ -1043,6 +1045,7 @@
                                if(logMINOR)
                                        Logger.minor(this, "Deleting "+req);
                                
selectorContainer.delete((PersistentChosenRequest)req);
+                               container.deactivate(put, 1);
                        }

                }, NativeThread.NORM_PRIORITY+1, false);
@@ -1075,6 +1078,7 @@
                                                container.delete(req);
                                                return;
                                        }
+                                       container.deactivate(req.request, 1);
                                        addToStarterQueue(req);
                                }