aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/Waiter.java52
-rw-r--r--src/WaiterClient.java55
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();
+ }
+ }