Examples of org.jamesii.core.experiments.TaskConfiguration

org.jamesii.core.experiments.TaskConfiguration
This class represents the a single task configuration. I.e., it describes which model to compute with which parameters, how often to replicate it, how to detect when a computation task can be stopped, and where to store the data in. If more than one execution of this configuration is necessary (as determined by {@link TaskConfiguration#getReplicationCriterionFactory()}), the configuration can be used to create the corresponding number of {@link SimulationRunConfiguration} . @author Roland Ewald @author Jan HimmelspachDate: 05.06.2007

    repInfo.quarantine(optionIndex);


    // :REGISTRY:
    if (SimSystem.getRegistry() instanceof AlgoSelectionRegistry) {


      TaskConfiguration src = repInfo.getTaskConfig();


      // Avoid copying all observers etc., just the basics for reproducibility
      TaskConfiguration shallowCopy =
          new TaskConfiguration(src.getConfigNumber(),
              src.getModelReaderParams(), src.getParameters(),
              src.getExecParams());


      // TODO: this operation is not guaranteed to identify all components
      // that actually have been used (-> a selection tree) - this would be

View Full Code Here

    while (!isStopping()) {
      // the iteration of the replications happens sequentially!
      // therefore, the waiting happens after the replications all jobs have
      // been initiated.
      while (!isIdle() && !isPausing()) {
        TaskConfiguration task = getTodoList().remove(0);
        try {
          executeConfiguration(task);
        } catch (Throwable t) { // NOSONAR:{robustness_otherwise_deadlock_possible}
          SimSystem
              .report(

View Full Code Here

   *          the nodes
   * 
   * @return the failure description
   */
  protected FailureDescription fd(SelectedFactoryNode... nodes) {
    return new FailureDescription(newTree(nodes), new TaskConfiguration(),
        new RuntimeException(ERROR_MSG));
  }

View Full Code Here

    SimpleSerializationTest<JamesSimDataProvider<String>> {


  @Override
  public JamesSimDataProvider<String> getTestObject() {
    IComputationTaskConfiguration simRunConfig =
        (new TaskConfiguration())
            .newComputationTaskConfiguration(new ComputationTaskIDObject(2L));
    RunInformation runInfo = new RunInformation(simRunConfig);
    runInfo.setExpID(UniqueIDGenerator.createUniqueID());
    runInfo.setDataStorageFactory(DummyDataStorageFactory.class);
    runInfo.setDataStorageParams(new ParameterBlock());

View Full Code Here

   * Test init simulation. As implemented for now, this will still cause an NPE
   * in another thread (so this test does not fail), since no model is
   * specified.
   */
  public void testInitComputationTask() {
    TaskConfiguration config = new TaskConfiguration();
    IInitializedComputationTask initSim = null;
    SimulationRunConfiguration srConfig =
        (SimulationRunConfiguration) config
            .newComputationTaskConfiguration(new ComputationTaskIDObject());
    initSim =
        ComputationTaskHandler.initComputationTask(srConfig, null,
            new RunInformation(srConfig), null);
    assertNotNull(initSim);

View Full Code Here


  /**
   * Test run simulation.
   */
  public void testRunComputationTask() {
    TaskConfiguration config = new TaskConfiguration();
    IInitializedComputationTask initSim = null;
    SimulationRunConfiguration srConfig =
        (SimulationRunConfiguration) config
            .newComputationTaskConfiguration(new ComputationTaskIDObject());
    initSim =
        ComputationTaskHandler.initComputationTask(srConfig, null,
            new RunInformation(srConfig), null);
    assertNotNull(initSim);

View Full Code Here

    // set the pausing flag true
    setPausing(true);
    // iterate the configurations
    Iterator<TaskConfiguration> it = getTaskConfigurationIterator();
    while (it.hasNext()) {
      TaskConfiguration config = it.next();
      // cancel each configuration
      if (getExperimentController(config) == expController) {
        cancelConfiguration(config);
      }
    }

View Full Code Here


        // System.out.println("Finishing a job!");


        ComputationTaskExecutionJob job = quad.getE1();
        ComputationTaskRuntimeInformation compTaskRTI = quad.getE2();
        TaskConfiguration taskConfig = quad.getE3();
        RunInformation results = quad.getE4();


        // if we have a data storage attached we will inform the storage that no
        // more data for this computation task will be written


        if (taskConfig.hasDataStorage()) {
          taskConfig.createPlainDataStorage().computationTaskDone(
              results.getComputationTaskID().getId());
        }


        // get the run information for the task configuration
        List<RunInformation> runInfo = getRunInfos().get(taskConfig);

View Full Code Here

        // model,
        // new SimulationConfiguration(1, null, null, parameters
        // .getParameterBlock())).getSimulation();


      } else { // if we don't use a server we create a simulation on our own
        TaskConfiguration config =
            new TaskConfiguration(1, null, null, parameters.getParameterBlock());
        SimulationRunConfiguration srConfig =
            (SimulationRunConfiguration) config
                .newComputationTaskConfiguration(new ComputationTaskIDObject());
        simulation = new SimulationRun("SimRun", model, srConfig, null);
      }
      if (simulation == null) {
        SimSystem.report(Level.SEVERE, "Simulation creation failed!!!");

View Full Code Here

   * Create a configuration based on the parameters.
   * 
   * @return
   */
  private IComputationTaskConfiguration createConfiguration() {
    TaskConfiguration config =
        new TaskConfiguration(1, null, null, parameters.getParameterBlock());
    ParameterBlock pb = new ParameterBlock();
    pb.addSubBlock(SimTimeStopFactory.SIMEND, stopTime);
    config
        .setComputationTaskStopFactory(new ParameterizedFactory<ComputationTaskStopPolicyFactory<?>>(
            new SimTimeStopFactory(), pb));
    return config
        .newComputationTaskConfiguration(new ComputationTaskIDObject());
  }

View Full Code Here

0 1

TOP

Related Classes of org.jamesii.core.experiments.TaskConfiguration

org.jamesii.asf.registry.failuredetection.TestFailureDetection

org.jamesii.core.data.storage.IDataStorage

org.jamesii.core.experiments.instrumentation.computation.IComputationInstrumenter

org.jamesii.core.experiments.instrumentation.model.IModelInstrumenter

org.jamesii.core.experiments.optimization.functions.FunctionOptimization

org.jamesii.core.experiments.taskrunner.AbstractTaskRunner

org.jamesii.core.experiments.taskrunner.parallel.ParallelComputationTaskRunner

org.jamesii.core.experiments.taskrunner.parallel.ParallelComputationTaskRunner$JobDoneThread

org.jamesii.core.experiments.taskrunner.TestComputationTaskHandler

org.jamesii.core.parameters.ParameterBlock

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.