Fix inadvertent build-breaking upward dependency from modules to engine

* modules//ProcessorChain.java
    send updates to ChainStatusReceiver interface
* engine//ToeThread.java
    implement ChainStatusReceiver interface
This commit is contained in:
gojomo committed 2009-10-06 01:01:32 +00:00
1 parent 92da7ab8cc
commit 6769cdb2dc
2 files changed
+13 -5

No files matched your search

@@ -34,6 +34,8 @@ import java.util.logging.Logger;
import org.archive.io.SinkHandlerLogThread;
import org.archive.modules.CrawlURI;
import org.archive.modules.Processor;
import org.archive.modules.ProcessorChain.ChainStatusReceiver;
import org.archive.modules.fetcher.HostResolver;
import org.archive.spring.KeyedProperties;
import org.archive.util.ArchiveUtils;
@@ -53,7 +55,7 @@ import com.sleepycat.util.RuntimeExceptionWrapper;
*/
public class ToeThread extends Thread
implements RecorderMarker, MultiReporter, ProgressStatisticsReporter,
HostResolver, SinkHandlerLogThread {
HostResolver, SinkHandlerLogThread, ChainStatusReceiver {
public enum Step {
NASCENT, ABOUT_TO_GET_URI, FINISHED,
@@ -221,6 +223,10 @@ implements RecorderMarker, MultiReporter, ProgressStatisticsReporter,
atStepSince = System.currentTimeMillis();
currentProcessorName = procName != null ? procName : "";
}
public void atProcessor(Processor proc) {
setStep(Step.ABOUT_TO_BEGIN_PROCESSOR, proc.getName());
}
private void seriousError(Error err) {
// try to prevent timeslicing until we have a chance to deal with OOM