X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.specs%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fprocess%2FSlcExecution.java;h=7a81facf612b1c6529ef8a2fdd825d4c9057ef17;hb=b376cfc0c90c738d1ee4d01643dd215cb1d202c8;hp=a52fea533f2c33cb37aac045443ec8e3dd884bae;hpb=fb3193e4e860ef199a47cd18fa536e37a0a1d82b;p=gpl%2Fargeo-slc.git diff --git a/runtime/org.argeo.slc.specs/src/main/java/org/argeo/slc/process/SlcExecution.java b/runtime/org.argeo.slc.specs/src/main/java/org/argeo/slc/process/SlcExecution.java index a52fea533..7a81facf6 100644 --- a/runtime/org.argeo.slc.specs/src/main/java/org/argeo/slc/process/SlcExecution.java +++ b/runtime/org.argeo.slc.specs/src/main/java/org/argeo/slc/process/SlcExecution.java @@ -1,11 +1,15 @@ package org.argeo.slc.process; +import java.io.Serializable; import java.util.ArrayList; +import java.util.Date; import java.util.List; import java.util.Map; import java.util.TreeMap; -public class SlcExecution { +public class SlcExecution implements Serializable { + private static final long serialVersionUID = 1L; + public final static String STATUS_NONE = "DEFAULT"; public final static String STATUS_SCHEDULED = "SCHEDULED"; public final static String STATUS_RUNNING = "RUNNING"; public final static String STATUS_FINISHED = "FINISHED"; @@ -18,10 +22,20 @@ public class SlcExecution { private String host; private String user; private String type; - private String status; + private String status = STATUS_NONE; private Map attributes = new TreeMap(); + /** TODO: Synchronize */ private List steps = new ArrayList(); + private List realizedFlows = new ArrayList(); + + public List getRealizedFlows() { + return realizedFlows; + } + + public void setRealizedFlows(List realizedFlows) { + this.realizedFlows = realizedFlows; + } public List getSteps() { return steps; @@ -72,10 +86,12 @@ public class SlcExecution { } public SlcExecutionStep currentStep() { - if (steps.size() > 0) - return steps.get(steps.size() - 1); - else - return null; + synchronized (steps) { + if (steps.size() > 0) + return steps.get(steps.size() - 1); + else + return null; + } } @Override @@ -106,4 +122,25 @@ public class SlcExecution { buf.append(" attributes=").append(attributes); return buf.toString(); } + + public Date getStartDate() { + synchronized (steps) { + if (steps.size() == 0) + return null; + else + return steps.get(0).getBegin(); + } + } + + public Date getEndDate() { + if (!status.equals(STATUS_FINISHED) && !status.equals(STATUS_ERROR)) + return null; + + synchronized (steps) { + if (steps.size() == 0) + return null; + else + return steps.get(steps.size() - 1).getBegin(); + } + } }