Author: toad
Date: 2008-07-11 16:35:55 +0000 (Fri, 11 Jul 2008)
New Revision: 21070
Modified:
branches/db4o/freenet/src/freenet/client/async/SingleFileFetcher.java
branches/db4o/freenet/src/freenet/client/async/SplitFileFetcher.java
Log:
Notify here instead
Modified: branches/db4o/freenet/src/freenet/client/async/SingleFileFetcher.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/SingleFileFetcher.java
2008-07-11 16:34:58 UTC (rev 21069)
+++ branches/db4o/freenet/src/freenet/client/async/SingleFileFetcher.java
2008-07-11 16:35:55 UTC (rev 21070)
@@ -595,7 +595,7 @@
}
SplitFileFetcher sf = new
SplitFileFetcher(metadata, rcb, parent, ctx,
- decompressors, clientMetadata,
actx, recursionLevel, returnBucket, token, container);
+ decompressors, clientMetadata,
actx, recursionLevel, returnBucket, token, container, context);
parent.onTransition(this, sf, container);
sf.schedule(container, context, false);
rcb.onBlockSetFinished(this, container,
context);
Modified: branches/db4o/freenet/src/freenet/client/async/SplitFileFetcher.java
===================================================================
--- branches/db4o/freenet/src/freenet/client/async/SplitFileFetcher.java
2008-07-11 16:34:58 UTC (rev 21069)
+++ branches/db4o/freenet/src/freenet/client/async/SplitFileFetcher.java
2008-07-11 16:35:55 UTC (rev 21070)
@@ -72,7 +72,7 @@
public SplitFileFetcher(Metadata metadata, GetCompletionCallback rcb,
ClientRequester parent2,
FetchContext newCtx, ArrayList decompressors2,
ClientMetadata clientMetadata,
- ArchiveContext actx, int recursionLevel, Bucket
returnBucket, long token2, ObjectContainer container) throws FetchException,
MetadataParseException {
+ ArchiveContext actx, int recursionLevel, Bucket
returnBucket, long token2, ObjectContainer container, ClientContext context)
throws FetchException, MetadataParseException {
this.persistent = parent2.persistent();
this.hashCode = super.hashCode();
this.finished = false;
@@ -183,6 +183,7 @@
this.token = token2;
parent.addBlocks(splitfileDataBlocks.length +
splitfileCheckBlocks.length, container);
parent.addMustSucceedBlocks(splitfileDataBlocks.length,
container);
+ parent.notifyClients(container, context);
}
/** Return the final status of the fetch. Throws an exception, or
returns a