private final ThreadGroup processThreadGroup;
private final List<RealizedFlow> flowsToProcess = new ArrayList<RealizedFlow>();
+ private Boolean hadAnError = false;
+
public ProcessThread(
AbstractExecutionModulesManager executionModulesManager,
SlcExecution slcExecution) {
}
}
- slcProcess.setStatus(SlcExecution.STATUS_FINISHED);
+ if (hadAnError)
+ slcProcess.setStatus(SlcExecution.STATUS_ERROR);
+ else
+ slcProcess.setStatus(SlcExecution.STATUS_FINISHED);
dispatchUpdateStatus(slcProcess, SlcExecution.STATUS_RUNNING,
- SlcExecution.STATUS_FINISHED);
+ slcProcess.getStatus());
}
protected void dispatchUpdateStatus(SlcExecution slcExecution,
}
}
+ public void notifyError() {
+ hadAnError = true;
+ }
+
public synchronized void flowCompleted() {
notifyAll();
}