Author: toad
Date: 2009-02-04 23:07:51 +0000 (Wed, 04 Feb 2009)
New Revision: 25573
Modified:
branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java
Log:
Activate and store blocks
Modified:
branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java
===================================================================
---
branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java
2009-02-04 22:52:05 UTC (rev 25572)
+++
branches/db4o/freenet/src/freenet/client/async/SplitFileInserterSegment.java
2009-02-04 23:07:51 UTC (rev 25573)
@@ -970,7 +970,9 @@
checkFinished[checkNum] = true;
checkFailed[checkNum] = true;
blocksCompleted++;
+ if(persistent)
container.activate(blocks, 2);
blocks.remove(new
Integer(blockNum));
+ if(persistent)
container.store(blocks);
if(checkBlocks[checkNum] !=
null) {
if(persistent)
container.activate(checkBlocks[checkNum], 1);
checkBlocks[checkNum].free();
@@ -990,7 +992,9 @@
checkFailed[checkNum] = false; //
Treating as succeeded
blocksCompleted++;
blocksSucceeded++;
+ if(persistent)
container.activate(blocks, 2);
blocks.remove(new Integer(blockNum));
+ if(persistent) container.store(blocks);
if(checkBlocks[checkNum] != null) {
if(persistent)
container.activate(checkBlocks[checkNum], 1);
checkBlocks[checkNum].free();
@@ -1028,7 +1032,9 @@
dataFinished[blockNum] = true;
dataFailed[blockNum] = true;
blocksCompleted++;
+ if(persistent)
container.activate(blocks, 2);
blocks.remove(new
Integer(blockNum));
+ if(persistent)
container.store(blocks);
if(dataBlocks[blockNum] !=
null) {
if(persistent)
container.activate(dataBlocks[blockNum], 1);
dataBlocks[blockNum].free();
@@ -1048,7 +1054,9 @@
dataFailed[blockNum] = false; //
Treating as succeeded
blocksCompleted++;
blocksSucceeded++;
+ if(persistent)
container.activate(blocks, 2);
blocks.remove(new Integer(blockNum));
+ if(persistent) container.store(blocks);
if(dataBlocks[blockNum] != null &&
encoded) {
if(persistent)
container.activate(dataBlocks[blockNum], 1);
dataBlocks[blockNum].free();
@@ -1096,7 +1104,9 @@
checkFailed[checkNum] = false;
blocksCompleted++;
blocksSucceeded++;
+ if(persistent)
container.activate(blocks, 2);
blocks.remove(new Integer(blockNum));
+ if(persistent) container.store(blocks);
} else {
if(checkFailed[checkNum])
Logger.error(this, "Got
onSuccess() but block has already failed! Check block "+checkNum+" on "+this);
@@ -1119,7 +1129,9 @@
dataFailed[blockNum] = false;
blocksCompleted++;
blocksSucceeded++;
+ if(persistent)
container.activate(blocks, 2);
blocks.remove(new Integer(blockNum));
+ if(persistent) container.store(blocks);
} else {
if(dataFailed[blockNum])
Logger.error(this, "Got
onSuccess() but block has already failed! Data block "+blockNum+" on "+this);
_______________________________________________
cvs mailing list
[email protected]
http://emu.freenetproject.org/cgi-bin/mailman/listinfo/cvs
