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

[t...@freenetproject.org]

Author: toad
Date: 2008-06-25 19:59:58 +0000 (Wed, 25 Jun 2008)
New Revision: 20712

Modified:
   branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java
Log:
Activation

Modified: 
branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java
===================================================================
--- 
branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java    
    2008-06-25 19:59:37 UTC (rev 20711)
+++ 
branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java    
    2008-06-25 19:59:58 UTC (rev 20712)
@@ -605,6 +605,10 @@
        }

        public void onSuccess(ClientPutState state, ObjectContainer container, 
ClientContext context) {
+               if(persistent) {
+                       container.activate(parent, 1);
+                       container.activate(parent.parent, 1);
+               }
                if (parent.parent.isCancelled()) {
                        parent.cancel(container, context);
                        return;
@@ -615,6 +619,11 @@
        }

        public void onFailure(InsertException e, ClientPutState state, 
ObjectContainer container, ClientContext context) {
+               if(persistent) {
+                       container.activate(parent, 1);
+                       container.activate(parent.parent, 1);
+                       container.activate(errors, 1);
+               }
                if (parent.parent.isCancelled()) {
                        parent.cancel(container, context);
                        return;
@@ -663,6 +672,8 @@
                                return blocksCompleted;
                        }
                        checkBlockInserters[x] = null;
+                       if(persistent)
+                               container.activate(checkBlocks[x], 1);
                        checkBlocks[x].free();
                        checkBlocks[x] = null;
                } else {
@@ -673,6 +684,8 @@
                        }
                        dataBlockInserters[x] = null;
                        if (encoded) {
+                               if(persistent)
+                                       container.activate(dataBlocks[x], 1);
                                dataBlocks[x].free();
                                dataBlocks[x] = null;
                        }