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

[t...@freenetproject.org]

Author: toad
Date: 2008-06-26 15:08:25 +0000 (Thu, 26 Jun 2008)
New Revision: 20745

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

Modified: 
branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java  
2008-06-26 14:59:49 UTC (rev 20744)
+++ branches/db4o/freenet/src/freenet/client/async/ClientRequestScheduler.java  
2008-06-26 15:08:25 UTC (rev 20745)
@@ -702,6 +702,7 @@
                jobRunner.queue(new DBJob() {

                        public void run(ObjectContainer container, 
ClientContext context) {
+                               container.activate(get, 1);
                                get.onFailure(e, keyNum, 
ClientRequestScheduler.this, selectorContainer, clientContext);
                                if(get.persistent())
                                        
selectorContainer.delete((PersistentChosenRequest)req);
@@ -714,6 +715,7 @@
                jobRunner.queue(new DBJob() {

                        public void run(ObjectContainer container, 
ClientContext context) {
+                               container.activate(put, 1);
                                put.onFailure(e, keyNum, selectorContainer, 
clientContext);
                                if(put.persistent())
                                        
selectorContainer.delete((PersistentChosenRequest)req);
@@ -726,6 +728,7 @@
                jobRunner.queue(new DBJob() {

                        public void run(ObjectContainer container, 
ClientContext context) {
+                               container.activate(put, 1);
                                put.onSuccess(keyNum, selectorContainer, 
clientContext);
                                if(put.persistent())
                                        
selectorContainer.delete((PersistentChosenRequest)req);