2 files changed, 107 insertions, 0 deletions
diff --git a/src/Waiter.java b/src/Waiter.java
new file mode 100644
index 0000000..c4eb29b
--- /dev/null
+++ b/src/Waiter.java
@@ -0,0 +1,52 @@
+/**
+ * @author	Yannick Jestin
+ * @author	<a href="http://www.tls.cena.fr/products/ivy/">http://www.tls.cena.fr/products/ivy/</a>
+ *
+ *  CHANGELOG:
+ *  1.2.4:
+ */
+
+package fr.dgac.ivy ;
+import java.util.*;
+
+class Waiter implements Runnable, IvyMessageListener {
+    private static final int INCREMENT = 100;
+    int timeout;
+    private IvyClient received=null;
+    private boolean forever=false;
+    private Thread t;
+
+    public Waiter(int timeout) {
+      this.timeout=timeout;
+      if (timeout<=0) forever=true;
+      t=new Thread(this);
+    }
+
+    public IvyClient waitFor() {
+      t.start();
+      try { t.join(); } catch (InterruptedException ie) { return null; }
+      return received;
+    }
+
+    public void run() {
+      boolean encore=true;
+      // System.out.println("DEV Waiter start");
+      while (encore) {
+	try {
+	  t.sleep(INCREMENT);
+	  if (!forever) {
+	    timeout-=INCREMENT;
+	    if (timeout<=0) encore=false;
+	  }
+	} catch (InterruptedException ie) {
+	  break;
+	}
+      }
+      // System.out.println("DEV Waiter stop");
+    }
+
+    public void receive(IvyClient ic, String[] args) {
+      received=ic;
+      t.interrupt();
+    }
+  }
diff --git a/src/WaiterClient.java b/src/WaiterClient.java
new file mode 100644
index 0000000..931a048
--- /dev/null
+++ b/src/WaiterClient.java
@@ -0,0 +1,55 @@
+/**
+ * @author	Yannick Jestin
+ * @author	<a href="http://www.tls.cena.fr/products/ivy/">http://www.tls.cena.fr/products/ivy/</a>
+ *
+ *  CHANGELOG:
+ *  1.2.4:
+ */
+
+package fr.dgac.ivy ;
+import java.util.*;
+
+class WaiterClient extends IvyApplicationAdapter implements Runnable {
+    private static final int INCREMENT = 100;
+    int timeout;
+    private IvyClient received=null;
+    private boolean forever=false;
+    private Thread t;
+    String name;
+
+    WaiterClient(String n,int timeout) {
+      this.timeout=timeout;
+      name=n;
+      if (timeout<=0) forever=true;
+      t=new Thread(this);
+    }
+
+    IvyClient waitForClient() {
+      t.start();
+      try { t.join(); } catch (InterruptedException ie) { return null; }
+      return received;
+    }
+
+    public void run() {
+      boolean encore=true;
+      // System.out.println("DEV WaiterClient start");
+      while (encore) {
+	try {
+	  t.sleep(INCREMENT);
+	  if (!forever) {
+	    timeout-=INCREMENT;
+	    if (timeout<=0) encore=false;
+	  }
+	} catch (InterruptedException ie) {
+	  break;
+	}
+      }
+      // System.out.println("DEV WaiterClient stop");
+    }
+
+    public void connect(fr.dgac.ivy.IvyClient client)  {
+      if (name.compareTo(client.getApplicationName())!=0) return;
+      received=client;
+      t.interrupt();
+    }
+  }