diff options
author | jestin | 2005-11-22 12:16:36 +0000 |
---|---|---|
committer | jestin | 2005-11-22 12:16:36 +0000 |
commit | 8e92224db5274f8a028f28f830b52e78ee88fda2 (patch) | |
tree | 2d4281a99d94329bce5b23af65377243cccbd98e /src/WaiterClient.java | |
parent | 5d466ac8508cf202bd025bc9d813b07fc47ac44b (diff) | |
download | ivy-java-8e92224db5274f8a028f28f830b52e78ee88fda2.zip ivy-java-8e92224db5274f8a028f28f830b52e78ee88fda2.tar.gz ivy-java-8e92224db5274f8a028f28f830b52e78ee88fda2.tar.bz2 ivy-java-8e92224db5274f8a028f28f830b52e78ee88fda2.tar.xz |
See changes inside.
major change in multibus error handling. I reintroduced bugs ..
Diffstat (limited to 'src/WaiterClient.java')
-rw-r--r-- | src/WaiterClient.java | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/src/WaiterClient.java b/src/WaiterClient.java index f9e1d06..34fd188 100644 --- a/src/WaiterClient.java +++ b/src/WaiterClient.java @@ -3,11 +3,12 @@ * @author <a href="http://www.tls.cena.fr/products/ivy/">http://www.tls.cena.fr/products/ivy/</a> * * CHANGELOG: - * 1.2.4: + * 1.2.8: + * added a test during the waiting loop */ package fr.dgac.ivy ; -import java.util.*; +import java.util.Hashtable; class WaiterClient extends IvyApplicationAdapter implements Runnable { private static final int INCREMENT = 100; @@ -16,9 +17,11 @@ class WaiterClient extends IvyApplicationAdapter implements Runnable { private boolean forever=false; private Thread t; String name; + Hashtable clients; - WaiterClient(String n,int timeout) { + WaiterClient(String n,int timeout,Hashtable clients) { this.timeout=timeout; + this.clients=clients; name=n; if (timeout<=0) forever=true; t=new Thread(this); @@ -43,6 +46,7 @@ class WaiterClient extends IvyApplicationAdapter implements Runnable { } catch (InterruptedException ie) { break; } + if ((received=Ivy.alreadyThere(clients,name))!=null) break; } // System.out.println("DEV WaiterClient stop"); } |