From 8e92224db5274f8a028f28f830b52e78ee88fda2 Mon Sep 17 00:00:00 2001
From: jestin
Date: Tue, 22 Nov 2005 12:16:36 +0000
Subject: See changes inside. major change in multibus error handling. I
 reintroduced bugs ..

---
 src/WaiterClient.java | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

(limited to 'src/WaiterClient.java')

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");
     }
-- 
cgit v1.1