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

[t...@freenetproject.org]

Author: toad
Date: 2008-06-28 17:32:53 +0000 (Sat, 28 Jun 2008)
New Revision: 20850

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

Modified: 
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java  
2008-06-28 17:24:07 UTC (rev 20849)
+++ branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java  
2008-06-28 17:32:53 UTC (rev 20850)
@@ -745,8 +745,11 @@
                        public void run(ObjectContainer container, 
ClientContext context) {
                                container.activate(get, 1);
                                get.onFailure(e, keyNum, selectorContainer, 
clientContext);
-                               if(get.persistent())
+                               if(get.persistent()) {
+                                       if(logMINOR)
+                                               Logger.minor(this, "Deleting 
"+req);
                                        
selectorContainer.delete((PersistentChosenRequest)req);
+                               }
                        }

                }, NativeThread.NORM_PRIORITY, false);
@@ -758,8 +761,11 @@
                        public void run(ObjectContainer container, 
ClientContext context) {
                                container.activate(put, 1);
                                put.onFailure(e, keyNum, selectorContainer, 
clientContext);
-                               if(put.persistent())
+                               if(put.persistent()) {
+                                       if(logMINOR)
+                                               Logger.minor(this, "Deleting 
"+req);
                                        
selectorContainer.delete((PersistentChosenRequest)req);
+                               }
                        }

                }, NativeThread.NORM_PRIORITY, false);
@@ -771,8 +777,11 @@
                        public void run(ObjectContainer container, 
ClientContext context) {
                                container.activate(put, 1);
                                put.onSuccess(keyNum, selectorContainer, 
clientContext);
-                               if(put.persistent())
+                               if(put.persistent()) {
+                                       if(logMINOR)
+                                               Logger.minor(this, "Deleting 
"+req);
                                        
selectorContainer.delete((PersistentChosenRequest)req);
+                               }
                        }

                }, NativeThread.NORM_PRIORITY, false);