Changeset 3138 for trunk/openmole/core/org.openmole.core.workflow.implementation/src/main/java/org/openmole/core/workflow/implementation/mole/Mole.java

Timestamp:

03/02/10 11:28:24 (2 years ago)

Author:

romain.reuillon

Message:

Netlogo task, debug grouping

Files:

• trunk/openmole/core/org.openmole.core.workflow.implementation/src/main/java/org/openmole/core/workflow/implementation/mole/Mole.java (modified) (6 diffs)

trunk/openmole/core/org.openmole.core.workflow.implementation/src/main/java/org/openmole/core/workflow/implementation/mole/Mole.java

@@ -24 +24 @@
 import org.openmole.core.workflow.implementation.mole.execution.ExecutionContext;
 import java.util.Collection;
+import java.util.HashMap;
 import java.util.HashSet;
 import java.util.LinkedList;
+import java.util.Map;
 import java.util.Queue;
 import java.util.Set;
@@ -38 +40 @@
 import org.openmole.core.workflow.model.job.IContext;
 import org.openmole.core.workflow.model.capsule.IGenericTaskCapsule;
-import org.openmole.core.workflow.model.job.ITicket;
 import org.openmole.misc.tools.IVisitor;
 import org.openmole.core.workflow.implementation.execution.local.LocalExecutionEnvironment;
 import org.openmole.core.workflow.implementation.mole.execution.FixedEnvironmentStrategy;
-import org.openmole.core.workflow.implementation.mole.execution.SubMoleExecution;
+import org.openmole.core.workflow.model.capsule.IExplorationTaskCapsule;
+import org.openmole.core.workflow.model.job.IMoleJobGroupingStrategy;
 import org.openmole.core.workflow.model.mole.IMole;
 import org.openmole.core.workflow.model.mole.execution.IEnvironmentSelectionStrategy;
@@ -51 +53 @@
 import org.openmole.core.workflow.model.task.IMoleTask;
 import org.openmole.core.workflow.model.transition.ITransition;
+import org.openmole.misc.tools.Duo;
 
 /**
@@ -59 +62 @@
 
     private IGenericTaskCapsule<?, ?> root;
+    private Map<IGenericTaskCapsule<?, ?>, Duo<IMoleJobGroupingStrategy, IExplorationTaskCapsule>> groupers = new HashMap<IGenericTaskCapsule<?, ?>, Duo<IMoleJobGroupingStrategy, IExplorationTaskCapsule>>();
 
     public Mole(IGenericTaskCapsule<?, ?> root) {
@@ -110 +114 @@
         IContext rootContext = new Context();
 
-        ILocalFileCache localFileCache = new LocalFileCache();
-        IExecutionContext exec = new ExecutionContext(localFileCache, strategy);
+        IExecutionContext exec = new ExecutionContext(fileCache, strategy);
 
         return createExecution(rootContext, exec);
@@ -217 +220 @@
     }
 
+    public Duo<IMoleJobGroupingStrategy, IExplorationTaskCapsule> getMoleJobGroupingStrategy(IGenericTaskCapsule key) {
+        return groupers.get(key);
+    }
+
+    @Override
+    public void setMoleJobGroupingStrategy(IGenericTaskCapsule forCapsule, IMoleJobGroupingStrategy strategy, IExplorationTaskCapsule explorationTaskCapsule) {
+        groupers.put(forCapsule, new Duo<IMoleJobGroupingStrategy, IExplorationTaskCapsule>(strategy, explorationTaskCapsule));
+    }
+
+
+
 }