import java.io.* ;
import fr.dgac.ivy.* ;

public class ProbeBench {

  public ProbeBench(int test) throws IvyException {
    switch (test) {
      case 1: test1(); break;
    }
  }

  /*
   * Tests if the Probe exits on a die message
   */
  public void test1() throws IvyException {
    Probe p = new Probe(new BufferedReader(new InputStreamReader(System.in)),true,false,true);
    Ivy bus1 = new Ivy("ProbeTest","ProbeTest ready",null);
    bus1.start(Ivy.getDomain(null));
    System.out.println("starting the probe");
    p.start(bus1);
    System.out.println("sleeping 5 seconds");
    try { Thread.sleep(5000); } catch (InterruptedException ie) { }

    Ivy bus2 = new Ivy("ProbeKiller","ProbeKiller ready",null);
    bus2.start(Ivy.getDomain(null));
    System.out.println("starting the probe killer");
    new DieSender(bus2,"ProbeTest");
    System.out.println("sleeping 5 seconds");
    try { Thread.sleep(5000); } catch (InterruptedException ie) { }
    bus2.stop();
    try { System.in.close(); } catch (java.io.IOException ioe ) { }
    System.out.println("I should leave now");
  }

  public static void main(String[] args) throws IvyException {
    new ProbeBench(1);
  }

}