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

[t...@freenetproject.org]

Author: toad
Date: 2008-10-08 19:44:29 +0000 (Wed, 08 Oct 2008)
New Revision: 22967

Modified:
   branches/db4o/freenet/src/freenet/client/async/SimpleManifestPutter.java
Log:
This seems to fix the toadstash-site insert (persistent).


Modified: 
branches/db4o/freenet/src/freenet/client/async/SimpleManifestPutter.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/SimpleManifestPutter.java    
2008-10-08 17:44:14 UTC (rev 22966)
+++ branches/db4o/freenet/src/freenet/client/async/SimpleManifestPutter.java    
2008-10-08 19:44:29 UTC (rev 22967)
@@ -109,7 +109,7 @@
                        if(logMINOR) Logger.minor(this, "Completed "+this);
                        if(persistent) {
                                container.activate(SimpleManifestPutter.this, 
1);
-                               container.activate(runningPutHandlers, 1);
+                               container.activate(runningPutHandlers, 2);
                        }
                        SimpleManifestPutter.this.onFetchable(this, container);
                        synchronized(SimpleManifestPutter.this) {
@@ -117,6 +117,19 @@
                                if(persistent)
                                        container.store(runningPutHandlers);
                                if(!runningPutHandlers.isEmpty()) {
+                                       if(logMINOR) {
+                                               Logger.minor(this, "Running put 
handlers: "+runningPutHandlers.size());
+//                                             for(Object o : 
runningPutHandlers) {
+//                                                     boolean activated = 
true;
+//                                                     if(persistent) {
+//                                                             activated = 
container.ext().isActive(o);
+//                                                             if(!activated) 
container.activate(o, 1);
+//                                                     }
+//                                                     Logger.minor(this, 
"Still running: "+o);
+//                                                     if(!activated)
+//                                                             
container.deactivate(o, 1);
+//                                             }
+                                       }
                                        return;
                                }
                        }