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

[t...@freenetproject.org]

Author: toad
Date: 2008-07-12 20:43:22 +0000 (Sat, 12 Jul 2008)
New Revision: 21119

Modified:
   branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java
Log:
Deactivate SBI's after registering.
Also minor activation.

Modified: 
branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java
===================================================================
--- 
branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java    
    2008-07-12 20:41:48 UTC (rev 21118)
+++ 
branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java    
    2008-07-12 20:43:22 UTC (rev 21119)
@@ -430,6 +430,7 @@
                                                blockInsertContext, this, 
false, CHKBlock.DATA_LENGTH,
                                                i, getCHKOnly, false, false, 
parent.token, container, context, persistent);
                                dataBlockInserters[i].schedule(container, 
context);
+                               container.deactivate(dataBlockInserters[i], 1);
                                fin = false;
                        } else {
                                parent.parent.completedBlock(true, container, 
context);
@@ -462,6 +463,7 @@
                                                        false, 
CHKBlock.DATA_LENGTH, i + dataBlocks.length,
                                                        getCHKOnly, false, 
false, parent.token, container, context, persistent);
                                        
checkBlockInserters[i].schedule(container, context);
+                                       
container.deactivate(checkBlockInserters[i], 1);
                                        fin = false;
                                } else
                                        parent.parent.completedBlock(true, 
container, context);
@@ -513,6 +515,7 @@
                                                i + dataBlocks.length, 
getCHKOnly, false, false,
                                                parent.token, container, 
context, persistent);
                                checkBlockInserters[i].schedule(container, 
context);
+                               container.deactivate(checkBlockInserters[i], 1);
                        }
                } catch (Throwable t) {
                        Logger.error(this, "Caught " + t + " while encoding " + 
this, t);
@@ -538,6 +541,7 @@
                synchronized (this) {
                        for (int i = 0; i < dataBlockInserters.length; i++) {
                                if (dataBlockInserters[i] == null && 
dataBlocks[i] != null) {
+                                       container.activate(dataBlocks[i], 1);
                                        dataBlocks[i].free();
                                        dataBlocks[i] = null;
                                }