Package mgui.pipelines
Class PipelineState
java.lang.Object
mgui.pipelines.PipelineState
public class PipelineState
extends java.lang.Object
Represents the state of a pipeline.
- Since:
- 1.0
- Version:
- 1.0
- Author:
- Andrew Reid
-
Nested Class Summary
Nested Classes Modifier and Type Class Description classPipelineState.ErrorStreamListener -
Field Summary
Fields Modifier and Type Field Description protected foxtrot.WorkerThreadcurrent_worker_threadjava.lang.Throwableexceptionbooleanfail_on_exceptionjava.lang.Stringinput_filejava.lang.Stringoutput_fileInterfacePipelinepipelinejava.lang.Stringroot_dirbooleantaskInterruptedinttemp_countjava.lang.Stringtemp_inputjava.lang.Stringtemp_output -
Constructor Summary
Constructors Constructor Description PipelineState(InterfacePipeline pipeline)Construct a new pipeline state for the given pipeline. -
Method Summary
Modifier and Type Method Description booleandeleteTempFiles()voidexceptionEncountered(java.lang.Throwable exception)java.lang.StringgetTempInputPath()java.lang.StringgetTempOutputPath()booleanisTaskFailed()booleanisTaskInterrupted()voidreset()voidsetCurrentWorkerThread(foxtrot.WorkerThread thread)voidsetTaskFailed(boolean value)voidsetTaskInterrupted(boolean value)booleanstopExecution()Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Field Details
-
output_file
public java.lang.String output_file -
root_dir
public java.lang.String root_dir -
input_file
public java.lang.String input_file -
temp_input
public java.lang.String temp_input -
temp_output
public java.lang.String temp_output -
temp_count
public int temp_count -
fail_on_exception
public boolean fail_on_exception -
taskInterrupted
public boolean taskInterrupted -
pipeline
-
current_worker_thread
protected foxtrot.WorkerThread current_worker_thread -
exception
public java.lang.Throwable exception
-
-
Constructor Details
-
PipelineState
Construct a new pipeline state for the given pipeline.- Parameters:
pipeline-
-
-
Method Details
-
reset
public void reset() -
stopExecution
public boolean stopExecution() -
setCurrentWorkerThread
public void setCurrentWorkerThread(foxtrot.WorkerThread thread) -
getTempInputPath
public java.lang.String getTempInputPath() -
getTempOutputPath
public java.lang.String getTempOutputPath() -
deleteTempFiles
public boolean deleteTempFiles() -
isTaskInterrupted
public boolean isTaskInterrupted() -
isTaskFailed
public boolean isTaskFailed() -
setTaskInterrupted
public void setTaskInterrupted(boolean value) -
setTaskFailed
public void setTaskFailed(boolean value) -
exceptionEncountered
public void exceptionEncountered(java.lang.Throwable exception)
-