import eduni.simjava.*;
import eduni.simjava.distributions.*;

class Source extends Sim_entity {
  private Sim_port out;
  private Sim_negexp_obj delay;

  Source(String name, double mean) {
    super(name);
    out = new Sim_port("Out");
    add_port(out);
    delay = new Sim_negexp_obj("Delay", mean);
    add_generator(delay);
  }

  public void body() {
    while (Sim_system.running()) {
      sim_schedule(out, 0.0, 0);
      sim_pause(delay.sample());
    }
  }
}

class Sink extends Sim_entity {
  private Sim_port in, out1, out2;
  private Sim_normal_obj delay;
  private Sim_random_obj prob;
  private Sim_stat stat;

  Sink(String name, double mean, double var) {
    super(name);
    in = new Sim_port("In");
    out1 = new Sim_port("Out1");
    out2 = new Sim_port("Out2");
    add_port(in);
    add_port(out1);
    add_port(out2);
    delay = new Sim_normal_obj("Delay", mean, var);
    prob = new Sim_random_obj("Probability");
    add_generator(delay);
    add_generator(prob);
    stat = new Sim_stat();
    stat.add_measure(Sim_stat.THROUGHPUT);
    stat.add_measure(Sim_stat.RESIDENCE_TIME);
    stat.add_measure("Thread use", Sim_stat.STATE_BASED, false);
    stat.calc_proportions("Thread use", new double[] { 0, 1, 2, 3, 4});
    set_stat(stat);
  }

  public void body() {
    while (Sim_system.running()) {
      Sim_event e = new Sim_event();
      sim_get_next(e);
      double before = Sim_system.sim_clock();
      sim_process(delay.sample());
      sim_completed(e);
      double p = prob.sample();
      if (p < 0.15) {
        stat.update("Thread use", 1, before, Sim_system.sim_clock());
      } else if (p < 0.75) {
        stat.update("Thread use", 2, before, Sim_system.sim_clock());
      } else {
        stat.update("Thread use", 3, before, Sim_system.sim_clock());
      }
      p = prob.sample();
      if (p < 0.60) {
        sim_schedule(out1, 0.0, 1);
      } else {
        sim_schedule(out2, 0.0, 1);
      }
    }
  }
}

class Disk extends Sim_entity {
  private Sim_port in;
  private Sim_normal_obj delay;
  private Sim_stat stat;

  Disk(String name, double mean, double var) {
    super(name);
    in = new Sim_port("In");
    add_port(in);
    delay = new Sim_normal_obj("Delay", mean, var);
    add_generator(delay);
    stat = new Sim_stat();
    stat.add_measure(Sim_stat.UTILISATION);
    set_stat(stat);
  }

  public void body() {
    while (Sim_system.running()) {
      Sim_event e = new Sim_event();
      sim_get_next(e);
      sim_process(delay.sample());
      sim_completed(e);
    }
  }
}

public class ProcessorSubsystem4 {
  public static void main(String[] args) {
    Sim_system.initialise();
    Source source = new Source("Source", 150.45);
    Sink processor = new Sink("Processor", 110.5, 90.5);
    Disk disk1 = new Disk("Disk1", 130.0, 65.0);
    Disk disk2 = new Disk("Disk2", 350.5, 200.5);
    Sim_system.link_ports("Source", "Out", "Processor", "In");
    Sim_system.link_ports("Processor", "Out1", "Disk1", "In");
    Sim_system.link_ports("Processor", "Out2", "Disk2", "In");
    Sim_system.set_transient_condition(Sim_system.TIME_ELAPSED, 100000);
    Sim_system.set_termination_condition(Sim_system.EVENTS_COMPLETED, "Processor", 0, 100, false);
    Sim_system.set_output_analysis(Sim_system.IND_REPLICATIONS, 5, 0.95);
    Sim_system.run();
  }
}