X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=TD2%2Fclient%2FThreadClientReceive.java;h=74f09c3aff782035c325c2ee2944975479d0107f;hb=6b300998692af2dca53cf1fe97305d27b56430b0;hp=42f5d918dec13672e1acdbefcb1cc233e108a656;hpb=58312685472236da9be0138c9b5b450ca13387b1;p=TD_SR.git

diff --git a/TD2/client/ThreadClientReceive.java b/TD2/client/ThreadClientReceive.java
index 42f5d91..74f09c3 100644
--- a/TD2/client/ThreadClientReceive.java
+++ b/TD2/client/ThreadClientReceive.java
@@ -1,35 +1,27 @@
-import java.util.concurrent.ThreadLocalRandom;
+import java.io.*;
 
 public class ThreadClientReceive implements Runnable {
     private SocketClient client;
-    private String msg = new String();
 
     ThreadClientReceive(SocketClient c) {
         client = c;
     }
 
-    /**
-     * @return the msg
-     */
-    public String getMsg() {
-    	return msg;
-    }
-
     public void run() {
-        while (true) {
-            try {
-                msg = client.receiveMsg();
-                System.out.println (Thread.currentThread().getName() + " a recu " + msg);
-                try {
-    				Thread.sleep(ThreadLocalRandom.current().nextInt(101));
-    			}
-    			catch (InterruptedException e) {
-    				System.err.println("InterruptedException: " + e);
-    			}
-            }
-            catch (Exception e) {
-                System.err.println("Exception: " + e);
+        try {
+            boolean end = false;
+            //FIXME: not exiting properly randomly from that loop!
+            while (!end) {
+                String rline = client.receiveMsg();
+                if (rline.equals(".")) {
+                    end = true;
+                }
+                System.out.println(Thread.currentThread().getName() + " a recu " + rline);
             }
         }
+        catch (IOException e) {
+            System.err.println("IOException: " + e);
+            e.printStackTrace();
+        }
     }
 }