Changeset 3138

Show
Ignore:
Timestamp:
03/02/10 11:28:24 (2 years ago)
Author:
romain.reuillon
Message:

Netlogo task, debug grouping

Location:
trunk/openmole
Files:
52 added
2 removed
19 modified
6 copied
3 moved

Legend:

Unmodified
Added
Removed

  • trunk/openmole/core/org.openmole.core.workflow.implementation/src/main/java/org/openmole/core/workflow/implementation/execution/local/LocalExecuter.java

    r3134 r3138  
    4848            while (!stop) { 
    4949                LocalExecutionJob executionJob = null; 
    50                 IProgress progress = new Progress(); 
    51                 Activator.getEventDispatcher().registerListener(progress, new LocalExecuterAdapter(this)); 
    52  
     50            
    5351                try { 
    5452                    executionJob = localEnvironment.takeNextjob(); 
    … …  
    5957                    for(IMoleJob moleJob : job.getMoleJobs()) { 
    6058                        LOGGER.finer("New job group taken for execution: " + moleJob); 
     59                        IProgress progress = new Progress(); 
     60                        Activator.getEventDispatcher().registerListener(progress, new LocalExecuterAdapter(this)); 
    6161 
    6262                        moleJob.perform(localEnvironment.getRealEnvironment(), executionContext, progress); 

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

    r3134 r3138  
    2424import org.openmole.core.workflow.implementation.mole.execution.ExecutionContext; 
    2525import java.util.Collection; 
     26import java.util.HashMap; 
    2627import java.util.HashSet; 
    2728import java.util.LinkedList; 
     29import java.util.Map; 
    2830import java.util.Queue; 
    2931import java.util.Set; 
    … …  
    3840import org.openmole.core.workflow.model.job.IContext; 
    3941import org.openmole.core.workflow.model.capsule.IGenericTaskCapsule; 
    40 import org.openmole.core.workflow.model.job.ITicket; 
    4142import org.openmole.misc.tools.IVisitor; 
    4243import org.openmole.core.workflow.implementation.execution.local.LocalExecutionEnvironment; 
    4344import org.openmole.core.workflow.implementation.mole.execution.FixedEnvironmentStrategy; 
    44 import org.openmole.core.workflow.implementation.mole.execution.SubMoleExecution; 
     45import org.openmole.core.workflow.model.capsule.IExplorationTaskCapsule; 
     46import org.openmole.core.workflow.model.job.IMoleJobGroupingStrategy; 
    4547import org.openmole.core.workflow.model.mole.IMole; 
    4648import org.openmole.core.workflow.model.mole.execution.IEnvironmentSelectionStrategy; 
    … …  
    5153import org.openmole.core.workflow.model.task.IMoleTask; 
    5254import org.openmole.core.workflow.model.transition.ITransition; 
     55import org.openmole.misc.tools.Duo; 
    5356 
    5457/** 
    … …  
    5962 
    6063    private IGenericTaskCapsule<?, ?> root; 
     64    private Map<IGenericTaskCapsule<?, ?>, Duo<IMoleJobGroupingStrategy, IExplorationTaskCapsule>> groupers = new HashMap<IGenericTaskCapsule<?, ?>, Duo<IMoleJobGroupingStrategy, IExplorationTaskCapsule>>(); 
    6165 
    6266    public Mole(IGenericTaskCapsule<?, ?> root) { 
    … …  
    110114        IContext rootContext = new Context(); 
    111115 
    112         ILocalFileCache localFileCache = new LocalFileCache(); 
    113         IExecutionContext exec = new ExecutionContext(localFileCache, strategy); 
     116        IExecutionContext exec = new ExecutionContext(fileCache, strategy); 
    114117 
    115118        return createExecution(rootContext, exec); 
    … …  
    217220    } 
    218221 
     222    public Duo<IMoleJobGroupingStrategy, IExplorationTaskCapsule> getMoleJobGroupingStrategy(IGenericTaskCapsule key) { 
     223        return groupers.get(key); 
     224    } 
     225 
     226    @Override 
     227    public void setMoleJobGroupingStrategy(IGenericTaskCapsule forCapsule, IMoleJobGroupingStrategy strategy, IExplorationTaskCapsule explorationTaskCapsule) { 
     228        groupers.put(forCapsule, new Duo<IMoleJobGroupingStrategy, IExplorationTaskCapsule>(strategy, explorationTaskCapsule)); 
     229    } 
     230 
     231 
     232 
    219233} 

  • trunk/openmole/core/org.openmole.core.workflow.implementation/src/main/java/org/openmole/core/workflow/implementation/mole/execution/MoleExecution.java

    r3134 r3138  
    2828import java.util.logging.Level; 
    2929import java.util.logging.Logger; 
    30 import org.openmole.core.workflow.implementation.execution.jobgroup.JobCategorizer; 
    3130 
    3231import org.openmole.misc.exception.InternalProcessingError; 
    … …  
    4140import org.openmole.core.workflow.implementation.job.JobBuild; 
    4241import org.openmole.core.workflow.implementation.job.MoleJobId; 
     42import org.openmole.core.workflow.implementation.mole.Mole; 
    4343import org.openmole.core.workflow.implementation.tools.LevelComputing; 
    4444import org.openmole.core.workflow.implementation.tools.RegistryWithTicket; 
    4545import org.openmole.core.workflow.model.capsule.IExplorationTaskCapsule; 
    46 import org.openmole.core.workflow.model.execution.batch.IJobGroupingStrategy; 
     46import org.openmole.core.workflow.model.job.IMoleJobGroupingStrategy; 
    4747import org.openmole.core.workflow.model.mole.execution.ISubMoleExecution; 
    4848import org.openmole.core.workflow.model.job.IContext; 
    … …  
    6464    private static final Logger LOGGER = Logger.getLogger(MoleExecution.class.getName()); 
    6565     
    66     IMole mole; 
     66    Mole mole; 
    6767    BlockingQueue<Trio<IJob, IEnvironment<?>, IGenericTaskCapsule<?, ?>>> jobs = new LinkedBlockingQueue<Trio<IJob, IEnvironment<?>, IGenericTaskCapsule<?, ?>>>(); 
    6868    Map<IMoleJob, ISubMoleExecution> inProgress = Collections.synchronizedMap(new TreeMap<IMoleJob, ISubMoleExecution>()); 
    … …  
    7272    IExecutionContext executionContext; 
    7373 
    74     Map<IGenericTaskCapsule<?, ?>, Duo<IJobGroupingStrategy, IExplorationTaskCapsule>> groupers = new HashMap<IGenericTaskCapsule<?, ?>, Duo<IJobGroupingStrategy, IExplorationTaskCapsule>>(); 
    7574    IRegistryWithTicket<IGenericTaskCapsule, JobCategorizer> categorizers = new RegistryWithTicket<IGenericTaskCapsule, JobCategorizer>(); 
    7675 
    … …  
    7877    //transient Semaphore oneJobFinished; 
    7978 
    80     public MoleExecution(IMole mole, IContext rootContext, IExecutionContext executionContext) throws InternalProcessingError, UserBadDataError { 
     79    public MoleExecution(Mole mole, IContext rootContext, IExecutionContext executionContext) throws InternalProcessingError, UserBadDataError { 
    8180        this.mole = mole; 
    8281        this.localCommunication = new LocalCommunication(); 
    … …  
    101100 
    102101    @Override 
    103     public synchronized void submit(IMoleJob job, IGenericTaskCapsule<?, ?> capsule, IExecutionContext execution, ISubMoleExecution subMole) throws UserBadDataError, InternalProcessingError { 
     102    public synchronized void submit(IMoleJob job, IGenericTaskCapsule<?, ?> capsule, IExecutionContext execution, ISubMoleExecution subMole) throws InternalProcessingError { 
    104103        ExecutionInfoRegistry.GetInstance().register(job, this); 
    105104        Activator.getEventDispatcher().registerListener(job, getLevel(), new MoleExecutionAdapter(this), MoleJob.stateChanged); 
    … …  
    119118    } 
    120119 
    121     private synchronized JobBuild group(IMoleJob job, IGenericTaskCapsule<?, ?> capsule) throws UserBadDataError, InternalProcessingError { 
    122         if (groupers.containsKey(capsule)) { 
    123             Duo<IJobGroupingStrategy, IExplorationTaskCapsule> strategy = groupers.get(capsule); 
     120    private synchronized JobBuild group(IMoleJob job, IGenericTaskCapsule<?, ?> capsule) throws InternalProcessingError { 
     121         Duo<IMoleJobGroupingStrategy, IExplorationTaskCapsule> strategy = mole.getMoleJobGroupingStrategy(capsule); 
     122         
     123        if (strategy != null) { 
     124            
    124125            LevelComputing levelComputing = LevelComputing.getLevelComputing(this); 
    125126 
    … …  
    127128            Integer levelOfCapsule = levelComputing.getLevel(capsule); 
    128129 
    129             if (levelOfExploration >= levelOfCapsule) { 
    130                 throw new UserBadDataError("Level of the exploration capsule is higher or the same than the one of the capsule, can't group."); 
     130            if (levelOfExploration != levelOfCapsule - 1) { 
     131                LOGGER.warning("The exploration capsule is not just under the capsule to group on, can't group."); 
     132                return new JobBuild(job); 
    131133            } 
    132134 
    … …  
    158160            return group; 
    159161        } else { 
    160             JobBuild group = new JobBuild(1); 
    161             group.addJob(job); 
    162             return group; 
    163         } 
    164     } 
     162            return new JobBuild(job); 
     163        } 
     164    } 
     165 
     166 
    165167 
    166168    @Override 

  • trunk/openmole/core/org.openmole.core.workflow.implementation/src/main/java/org/openmole/core/workflow/implementation/resource/FileResource.java

    r3134 r3138  
    2626import org.openmole.core.workflow.model.execution.IEnvironment; 
    2727 
    28 import org.openmole.core.workflow.model.resource.IFileResource; 
    2928import org.openmole.core.workflow.model.resource.ILocalFileCache; 
    3029import org.openmole.core.workflow.model.resource.IResource; 

  • trunk/openmole/core/org.openmole.core.workflow.implementation/src/main/java/org/openmole/core/workflow/implementation/task/GenericTask.java

    r3134 r3138  
    8888                    vars.add(var); 
    8989                } else { 
    90                     Logger.getLogger(Logger.GLOBAL_LOGGER_NAME).log(Level.WARNING, "Variable " + p.getName() + " of type " + p.getType().getName() + " has been found but type doesn't match : " + var.getType() + " in task " + getName() + "."); 
     90                    Logger.getLogger(Logger.GLOBAL_LOGGER_NAME).log(Level.WARNING, "Variable " + p.getName() + " of type " + p.getType().getName() + " has been found but type doesn't match : " + var.getType().getName() + " in task " + getName() + "."); 
    9191                } 
    9292            } else { 
    … …  
    261261    } 
    262262 
     263    public Iterable<Data<?>> getUserInput() { 
     264        return input; 
     265    } 
     266 
     267    public Iterable<Data<?>> getUserOutput() { 
     268        return output; 
     269    } 
     270 
    263271    private void verifyNotDuplicate(Iterable<Data<?>> data, String place) { 
    264272        Set<String> processed = new HashSet<String>(); 

  • trunk/openmole/core/org.openmole.core.workflow.implementation/src/main/java/org/openmole/core/workflow/implementation/tools/LevelComputing.java

    r3034 r3138  
    6060 
    6161    //TODO derecurisivate 
     62    @Override 
    6263    public int getLevel(IGenericTaskCapsule<?, ?> capsule) { 
    6364 

  • trunk/openmole/core/org.openmole.core.workflow.implementation/src/main/java/org/openmole/core/workflow/implementation/transition/TransitionFactory.java

    r3034 r3138  
    1616 */ 
    1717 
    18 package org.openmole.core.workflow.implementation.mole; 
     18package org.openmole.core.workflow.implementation.transition; 
    1919 
    2020import org.apache.commons.lang.ArrayUtils; 
    2121import org.openmole.core.workflow.implementation.capsule.TaskCapsule; 
    22 import org.openmole.core.workflow.implementation.transition.AggregationTransition; 
    23 import org.openmole.core.workflow.implementation.transition.ExplorationTransition; 
    24 import org.openmole.core.workflow.implementation.transition.SingleTransition; 
     22import org.openmole.core.workflow.implementation.mole.PuzzleFirst; 
     23import org.openmole.core.workflow.implementation.mole.PuzzleFirstAndLast; 
     24import org.openmole.core.workflow.implementation.mole.PuzzleLast; 
    2525import org.openmole.core.workflow.model.capsule.ITaskCapsule; 
    2626import org.openmole.core.workflow.model.capsule.IExplorationTaskCapsule; 

  • trunk/openmole/core/org.openmole.core.workflow.methods/src/main/java/org/openmole/core/workflow/methods/libraries/Library.java

    r3034 r3138  
    1717 *  MA  02110-1301  USA 
    1818 */ 
    19 package org.openmole.core.workflow.model.libraries; 
     19package org.openmole.core.workflow.methods.libraries; 
    2020 
    21 import org.openmole.core.workflow.model.libraries.Platform.Type; 
     21import org.openmole.core.workflow.methods.libraries.Platform.Type; 
    2222 
    2323import java.net.URI; 

  • trunk/openmole/core/org.openmole.core.workflow.methods/src/main/java/org/openmole/core/workflow/methods/libraries/MethodDeclaration.java

    r3058 r3138  
    1717 *  MA  02110-1301  USA 
    1818 */ 
    19 package org.openmole.core.workflow.model.libraries; 
     19package org.openmole.core.workflow.methods.libraries; 
    2020 
    2121import java.util.ArrayList; 

  • trunk/openmole/core/org.openmole.core.workflow.methods/src/main/java/org/openmole/core/workflow/methods/libraries/MethodDomain.java

    r3058 r3138  
    1717 *  MA  02110-1301  USA 
    1818 */ 
    19 package org.openmole.core.workflow.implementation.plan; 
     19package org.openmole.core.workflow.methods.libraries; 
    2020 
    2121import java.util.Iterator; 
    … …  
    2323import org.openmole.misc.exception.InternalProcessingError; 
    2424import org.openmole.misc.exception.UserBadDataError; 
    25 import org.openmole.core.workflow.model.libraries.Library; 
    26 import org.openmole.core.workflow.model.libraries.MethodDeclaration; 
    27 import org.openmole.core.workflow.model.libraries.MethodInstance; 
    28 import org.openmole.core.workflow.model.libraries.Platform; 
     25import org.openmole.core.workflow.methods.libraries.Library; 
     26import org.openmole.core.workflow.methods.libraries.MethodDeclaration; 
     27import org.openmole.core.workflow.methods.libraries.MethodInstance; 
     28import org.openmole.core.workflow.methods.libraries.Platform; 
    2929import org.openmole.core.workflow.model.plan.IDomain; 
    3030import org.openmole.core.workflow.model.job.IContext; 

  • trunk/openmole/core/org.openmole.core.workflow.methods/src/main/java/org/openmole/core/workflow/methods/libraries/MethodInstance.java

    r3058 r3138  
    1717 *  MA  02110-1301  USA 
    1818 */ 
    19 package org.openmole.core.workflow.model.libraries; 
     19package org.openmole.core.workflow.methods.libraries; 
    2020 
    2121import java.net.URI; 
    … …  
    2323import org.openmole.misc.exception.InternalProcessingError; 
    2424import org.openmole.core.workflow.model.data.Prototype; 
    25 import org.openmole.core.workflow.model.libraries.Platform.Type; 
     25import org.openmole.core.workflow.methods.libraries.Platform.Type; 
    2626import org.openmole.misc.tools.CachedArrayList; 
    2727 

  • trunk/openmole/core/org.openmole.core.workflow.methods/src/main/java/org/openmole/core/workflow/methods/libraries/ParameterDeclaration.java

    r3034 r3138  
    1717 *  MA  02110-1301  USA 
    1818 */ 
    19 package org.openmole.core.workflow.model.libraries; 
     19package org.openmole.core.workflow.methods.libraries; 
    2020 
    2121import org.openmole.core.workflow.model.data.Prototype; 

  • trunk/openmole/core/org.openmole.core.workflow.methods/src/main/java/org/openmole/core/workflow/methods/libraries/ParameterInstance.java

    r3034 r3138  
    1717 *  MA  02110-1301  USA 
    1818 */ 
    19 package org.openmole.core.workflow.model.libraries; 
     19package org.openmole.core.workflow.methods.libraries; 
    2020 
    2121public class ParameterInstance { 

  • trunk/openmole/core/org.openmole.core.workflow.methods/src/main/java/org/openmole/core/workflow/methods/libraries/Platform.java

    r3034 r3138  
    1 package org.openmole.core.workflow.model.libraries; 
     1package org.openmole.core.workflow.methods.libraries; 
    22 
    33import org.openmole.core.workflow.model.job.IContext; 

  • trunk/openmole/core/org.openmole.core.workflow.methods/src/main/java/org/openmole/core/workflow/methods/libraries/PlatformDakota.java

    r3034 r3138  
    3636import org.apache.commons.httpclient.methods.multipart.StringPart; 
    3737import org.apache.commons.httpclient.params.HttpMethodParams; 
    38 import org.openmole.core.workflow.model.libraries.Library; 
    39 import org.openmole.core.workflow.model.libraries.MethodInstance; 
    40 import org.openmole.core.workflow.model.libraries.Platform; 
    4138import org.openmole.core.workflow.model.job.IContext; 
    4239 

  • trunk/openmole/core/org.openmole.core.workflow.methods/src/main/java/org/openmole/core/workflow/methods/libraries/PlatformJava.java

    r3058 r3138  
    1919package org.openmole.core.workflow.methods.libraries; 
    2020 
    21 import org.openmole.core.workflow.model.libraries.Library; 
    22 import org.openmole.core.workflow.model.libraries.MethodInstance; 
    23 import org.openmole.core.workflow.model.libraries.Platform; 
    2421import org.openmole.core.workflow.model.job.IContext; 
    2522 

  • trunk/openmole/core/org.openmole.core.workflow.methods/src/main/java/org/openmole/core/workflow/methods/libraries/PlatformLHSDRV.java

    r3034 r3138  
    2727import org.apache.commons.httpclient.methods.PostMethod; 
    2828import org.apache.commons.httpclient.params.HttpMethodParams; 
    29 import org.openmole.core.workflow.model.libraries.Library; 
    30 import org.openmole.core.workflow.model.libraries.MethodInstance; 
    31 import org.openmole.core.workflow.model.libraries.Platform; 
    3229import org.openmole.core.workflow.model.job.IContext; 
    3330 

  • trunk/openmole/core/org.openmole.core.workflow.methods/src/main/java/org/openmole/core/workflow/methods/libraries/PlatformR.java

    r3034 r3138  
    2121import org.openmole.core.workflow.methods.r.RConnectionInfo; 
    2222import org.openmole.core.workflow.methods.r.RConnectionManager; 
    23 import org.openmole.core.workflow.model.libraries.Library; 
    24 import org.openmole.core.workflow.model.libraries.MethodInstance; 
    25 import org.openmole.core.workflow.model.libraries.Platform; 
    2623import org.openmole.core.workflow.model.job.IContext; 
    2724 

  • trunk/openmole/core/org.openmole.core.workflow.model/src/main/java/org/openmole/core/workflow/model/capsule/IGenericTaskCapsule.java

    r3134 r3138  
    2121import org.openmole.core.workflow.model.data.IDataChannel; 
    2222import org.openmole.core.workflow.model.job.ITicket; 
    23 import org.openmole.core.workflow.model.mole.execution.IExecutionContext; 
    2423 
    2524import org.openmole.misc.exception.InternalProcessingError; 

  • trunk/openmole/core/org.openmole.core.workflow.model/src/main/java/org/openmole/core/workflow/model/execution/batch/IMoleJobCategory.java

    r3134 r3138  
    1818package org.openmole.core.workflow.model.execution.batch; 
    1919 
    20 public interface IMoleJobCategory extends Comparable { 
    21    
     20public interface IMoleJobCategory { 
     21    boolean equals(IMoleJobCategory category); 
     22    int hash(); 
    2223} 

  • trunk/openmole/core/org.openmole.core.workflow.model/src/main/java/org/openmole/core/workflow/model/job/IMoleJobGroupingStrategy.java

    r3134 r3138  
    1616 */ 
    1717 
    18 package org.openmole.core.workflow.model.execution.batch; 
     18package org.openmole.core.workflow.model.job; 
    1919 
     20import org.openmole.core.workflow.model.execution.batch.IMoleJobCategory; 
    2021import org.openmole.core.workflow.model.plan.IFactorValues; 
    2122 
    22 public interface IJobGroupingStrategy { 
     23public interface IMoleJobGroupingStrategy { 
    2324  IMoleJobCategory getCategory(IFactorValues values); 
    2425} 

  • trunk/openmole/core/org.openmole.core.workflow.model/src/main/java/org/openmole/core/workflow/model/mole/IMole.java

    r3058 r3138  
    1818package org.openmole.core.workflow.model.mole; 
    1919 
     20import org.openmole.core.workflow.model.capsule.IExplorationTaskCapsule; 
    2021import org.openmole.core.workflow.model.capsule.IGenericTaskCapsule; 
    2122import org.openmole.misc.exception.InternalProcessingError; 
    2223import org.openmole.misc.exception.UserBadDataError; 
    2324import org.openmole.core.workflow.model.job.IContext; 
     25import org.openmole.core.workflow.model.job.IMoleJobGroupingStrategy; 
    2426import org.openmole.misc.tools.IVisitable; 
    2527import org.openmole.core.workflow.model.mole.execution.IEnvironmentSelectionStrategy; 
    … …  
    2729import org.openmole.core.workflow.model.mole.execution.IMoleExecution; 
    2830import org.openmole.core.workflow.model.resource.IResource; 
     31import org.openmole.misc.tools.Duo; 
    2932 
    3033public interface IMole extends IVisitable<IGenericTaskCapsule> { 
    … …  
    5053    void setRoot(IGenericTaskCapsule<?, ?> root); 
    5154 
     55    public void setMoleJobGroupingStrategy(IGenericTaskCapsule forCapsule, IMoleJobGroupingStrategy strategy, IExplorationTaskCapsule explorationTaskCapsule); 
     56 
    5257} 

  • trunk/openmole/misc/org.openmole.misc.pluginmanager/src/main/java/org/openmole/misc/pluginmanager/internal/PluginManager.java

    r3082 r3138  
    232232        ExportedPackage[] exportedPackages = Activator.getPackageAdmin().getExportedPackages(b); 
    233233 
    234         for (ExportedPackage exportedPackage : exportedPackages) { 
    235             for (Bundle ib : exportedPackage.getImportingBundles()) { 
    236                 ret.add(ib); 
    237             } 
    238         } 
     234        if(exportedPackages != null) { 
     235            for (ExportedPackage exportedPackage : exportedPackages) { 
     236                for (Bundle ib : exportedPackage.getImportingBundles()) { 
     237                    ret.add(ib); 
     238                } 
     239            } 
     240        } 
     241 
    239242        return ret; 
    240243    } 

  • trunk/openmole/plugins

    • Property svn:ignore set to
      .pom.xml.swp

  • trunk/openmole/plugins/jars/pom.xml

    r3095 r3138  
    4141            <scope>runtime</scope> 
    4242        </dependency> 
    43  
     43        <dependency> 
     44            <groupId>${project.groupId}</groupId> 
     45            <artifactId>org.openmole.plugin.molejobgroupingstrategy.onfactor</artifactId> 
     46            <version>${project.version}</version> 
     47            <scope>runtime</scope> 
     48        </dependency> 
     49        <dependency> 
     50            <groupId>${project.groupId}</groupId> 
     51            <artifactId>org.openmole.plugin.task.netlogotask</artifactId> 
     52            <version>${project.version}</version> 
     53            <scope>runtime</scope> 
     54        </dependency> 
    4455    </dependencies> 
    4556 

  • trunk/openmole/plugins/org.openmole.plugin.specializedhellotask/src/main/java/org/openmole/plugin/specializedhellotask/SpecializedHelloTask.java

    r3058 r3138  
    66package org.openmole.plugin.specializedhellotask; 
    77 
     8import java.math.BigDecimal; 
     9import org.openmole.core.workflow.model.data.Data; 
     10import org.openmole.core.workflow.model.data.Prototype; 
    811import org.openmole.misc.exception.InternalProcessingError; 
    912import org.openmole.misc.exception.UserBadDataError; 
    … …  
    1215import org.openmole.core.workflow.model.job.IContext; 
    1316import org.openmole.core.workflow.model.mole.execution.IExecutionContext; 
     17import org.openmole.core.workflow.model.task.annotations.Output; 
    1418 
    1519/** 
    … …  
    1822 */ 
    1923public class SpecializedHelloTask extends HelloTask { 
     24 
     25    @Output 
     26    Data<BigDecimal> hello = new Data<BigDecimal>("hello", BigDecimal.class); 
    2027 
    2128    public SpecializedHelloTask(String name) throws UserBadDataError, InternalProcessingError { 
    … …  
    2633    protected void process(IContext context, IExecutionContext executionContext, IProgress progress) throws UserBadDataError, InternalProcessingError, InterruptedException { 
    2734        super.process(context, executionContext, progress); 
     35 
    2836        System.out.println("Specialized"); 
     37 
     38        context.setValue(hello.getPrototype(), new BigDecimal(20.0)); 
    2939    } 
    3040     

  • trunk/openmole/plugins/pom.xml

    r3039 r3138  
    2121  <module>org.openmole.plugin.environmentprovider.jsaga</module> 
    2222  <module>org.openmole.plugin.environmentprovider.glite</module> 
     23  <module>org.openmole.plugin.molejobgroupingstrategy.onfactor</module> 
     24  <module>org.openmole.plugin.task.netlogotask</module> 
    2325  <module>jars</module> 
    2426    </modules> 

  • trunk/openmole/pom.xml

    r3108 r3138  
    550550                        <Import-Package>${import.packages}</Import-Package> 
    551551                        <Export-Package>${export.packages}</Export-Package> 
     552      <Embed-Dependency>${embed-dep}</Embed-Dependency> 
     553                        <Embed-Transitive>${embed-transitive}</Embed-Transitive> 
    552554                        <!--<Embed-Dependency>true</Embed-Dependency>--> 
    553555                        <!--<Embed-Transitive>true</Embed-Transitive>--> 

logo cemagref

logo iscpif

logo lifegrid

logo region auvergne

logo patres project