Clarify SLC project structure.

[gpl/argeo-slc.git] / org.argeo.slc.runtime / src / org / argeo / slc / runtime / ProcessThreadGroup.java

diff --git a/org.argeo.slc.runtime/src/org/argeo/slc/runtime/ProcessThreadGroup.java b/org.argeo.slc.runtime/src/org/argeo/slc/runtime/ProcessThreadGroup.java
deleted file mode 100644 (file)
index 79f38d7..0000000
--- a/org.argeo.slc.runtime/src/org/argeo/slc/runtime/ProcessThreadGroup.java
+++ /dev/null
@@ -1,53 +0,0 @@
-package org.argeo.slc.runtime;
-
-import java.util.concurrent.ArrayBlockingQueue;
-import java.util.concurrent.BlockingQueue;
-
-import org.argeo.slc.execution.ExecutionProcess;
-import org.argeo.slc.execution.ExecutionStep;
-
-/** The thread group attached to a given {@link SlcExecution}. */
-public class ProcessThreadGroup extends ThreadGroup {
-//     private final Authentication authentication;
-       private final static Integer STEPS_BUFFER_CAPACITY = 5000;
-
-       private BlockingQueue<ExecutionStep> steps = new ArrayBlockingQueue<ExecutionStep>(
-                       STEPS_BUFFER_CAPACITY);
-
-       private Boolean hadAnError = false;
-
-       public ProcessThreadGroup(ExecutionProcess executionProcess) {
-               super("SLC Process #" + executionProcess.getUuid() + " thread group");
-//             this.authentication = SecurityContextHolder.getContext()
-//                             .getAuthentication();
-       }
-
-//     public Authentication getAuthentication() {
-//             return authentication;
-//     }
-
-       public void dispatchAddStep(ExecutionStep step) {
-               // ExecutionProcess slcProcess = processThread.getProcess();
-               // List<ExecutionStep> steps = new ArrayList<ExecutionStep>();
-               // steps.add(step);
-               // TODO clarify why we don't dispatch steps, must be a reason
-               // dispatchAddSteps(steps);
-               // slcProcess.addSteps(steps);
-               if (step.getType().equals(ExecutionStep.ERROR))
-                       hadAnError = true;
-               this.steps.add(step);
-       }
-
-       // public void dispatchAddSteps(List<ExecutionStep> steps) {
-       // ExecutionProcess slcProcess = processThread.getProcess();
-       // executionModulesManager.dispatchAddSteps(slcProcess, steps);
-       // }
-
-       public BlockingQueue<ExecutionStep> getSteps() {
-               return steps;
-       }
-
-       public Boolean hadAnError() {
-               return hadAnError;
-       }
-}