X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=TD2%2Fserver%2FBroadcastThreadService.java;h=9ea5cdd5f90af52d4ee7ba2b23286f2bc61512f4;hb=92d3f605b46c717c1f8dc7aa30dd25db518b7582;hp=7a39e7a72f4ba3384973baf9a5d717a10460f998;hpb=b349a9de18d621c97723b3c1f0873aed30c3f32b;p=TD_SR.git diff --git a/TD2/server/BroadcastThreadService.java b/TD2/server/BroadcastThreadService.java index 7a39e7a..9ea5cdd 100644 --- a/TD2/server/BroadcastThreadService.java +++ b/TD2/server/BroadcastThreadService.java @@ -43,9 +43,9 @@ public class BroadcastThreadService implements Runnable { * @throws IOException [description] */ public void doService(Socket clientSocket, ArrayList sharedList) throws IOException { + PrintWriter OWriter = new PrintWriter(clientSocket.getOutputStream()); BufferedReader in; in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); - PrintWriter OWriter = new PrintWriter(clientSocket.getOutputStream()); sharedList.add(OWriter); boolean end = false; while (!end) { @@ -54,13 +54,14 @@ public class BroadcastThreadService implements Runnable { end = true; // le thread de service doit terminer break; // do not broadcast the dot that will close all clients threads } + System.out.println("Broadcasting the message \"" + theLine + "\" received from " + clientSocket.toString()); broadcastMsg(theLine); } sharedList.remove(OWriter); - if (in != null) - in.close(); if (OWriter != null) OWriter.close(); + if (in != null) + in.close(); System.out.println("Fin du thread repondant au client, port " + clientSocket.getPort()); }