X-Git-Url: https://git.piment-noir.org/?p=TD_SR.git;a=blobdiff_plain;f=TD2%2Fserver%2FBroadcastThreadService.java;h=cd971c252356d34b4821c6e170ec81aa462d6c46;hp=daf753f665ab16d9e798dcbc45428ce2b0732774;hb=da31e6daf7553c6b38ca83c428dd02a3aa8af853;hpb=c4aaaecaa30716d0bc52f859f799880e5a37b027 diff --git a/TD2/server/BroadcastThreadService.java b/TD2/server/BroadcastThreadService.java index daf753f..cd971c2 100644 --- a/TD2/server/BroadcastThreadService.java +++ b/TD2/server/BroadcastThreadService.java @@ -34,6 +34,12 @@ public class BroadcastThreadService implements Runnable { } } + /** + * Be careful, this function must be thread-safe + * @param clientSocket [description] + * @param sharedList [description] + * @throws IOException [description] + */ public void doService(Socket clientSocket, ArrayList sharedList) throws IOException { BufferedReader in; in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); @@ -44,7 +50,7 @@ public class BroadcastThreadService implements Runnable { String theLine = in.readLine(); if (theLine.equals(".")) { end = true; // le thread de service doit terminer - break; // do not broadcast the dot that will close clients threads + break; // do not broadcast the dot that will close all clients threads } broadcastMsg(theLine); }