ajout de commentaires dans TCPEchanges

Implementation/src/TCPEchange.java

@@ -20,17 +20,27 @@ import java.io.InputStreamReader;
 */
 public class TCPEchange {
 	
+	/**
+	* <p>
+	* Equivalent a un handshake. 
+	* L'utilisateur associé a app souhaite entamé une discussion avec User2
+	* @param app L'app associé à l'utilisateur qui souhaite entamé la discussion 
+	* @param User2 Le destinataire
+	* </p>
+	*/
 	public static void demarrerSession(ChatApp app,Utilisateur User2 ) throws IOException {
 		System.out.println("Demmarrage d'une session de clavardage");
 		Socket s = new Socket(User2.getIp(),5000);
 		System.out.println("Socket de demarrage d'une session cree");
 		ExecutorService exec = Executors.newFixedThreadPool(1000);
+		// On lance un thread d'ecoute pour recevoir les messages de USER2
 		exec.submit(new RunnerTCPEcoute(s,app));
+		// On lance un thread d'envoi pour continuer d'envoyer des messages avec USER2
     	exec.submit(new RunnerTCPEnvoi(s,app,User2,false));
 		
 	}
 	
-	public static void envoiTCP(ChatApp app,Utilisateur User2, String Msg, int type ) {
+	/*public static void envoiTCP(ChatApp app,Utilisateur User2, String Msg, int type ) {
 		// On cree un messagehorodate
 		MessageHorodate mh =  new MessageHorodate(app.getMe(), User2, Msg, type);
 		if( type == 1 ) {
@@ -50,21 +60,27 @@ public class TCPEchange {
         } catch (Exception e) {
             e.printStackTrace();
         }
-	}
+	}*/
 	
+	
+	/**
+	* <p>
+	* Méthode pour qu'un objet de la classe ChatApp soit constamment en écoute de potentielles connexions
+	* @param app L'utilisateur en écoute de potentielles communications
+	* </p>
+	*/
 	public static void ecouteTCP(ChatApp app) {
 		ServerSocket ss = null;
 		ExecutorService exec = Executors.newFixedThreadPool(1000);
 		System.out.println("Ecoute TCP activee");
 		try {
-			ss = new ServerSocket(5000);
+			ss = new ServerSocket(5000); // On ecoute sur le port 5000
 			System.out.println("Socket d'ecoute cree");
-	        while(true) {
+	        while(true) { // Ecoute en boucle 
 	        	System.out.println("Attente Session de clavardage");
-	        	Socket link = ss.accept();
-	        	exec.submit(new RunnerTCPEcoute(link,app));
+	        	Socket link = ss.accept(); // Blocante
+	        	exec.submit(new RunnerTCPEcoute(link,app)); // On crée un thread qui va gerer la connexion recu
 	        	System.out.println("L'ecoute TCP continue apres le premier thread demarre");
-	        	//exec.submit(new RunnerTCPEnvoi(link,app,app.getMe()));
 	            }
 	        } 
 		catch (Exception e) {
@@ -74,7 +90,12 @@ public class TCPEchange {
 }
 
 
-//ENVOI
+/**
+* <p>
+* Classe representant les threads s'occupant de l'envoie de messages en utilisant le protocole TCP. 
+* Cette classe implemente l'interface Runnable.
+* </p>
+*/
 class RunnerTCPEnvoi implements Runnable {
 	private Socket link;
 	private ChatApp app ;
@@ -84,30 +105,38 @@ class RunnerTCPEnvoi implements Runnable {
     final Scanner sc=new Scanner(System.in);
     private boolean bonjourEnvoye = false;
 
+    /**
+    * <p>
+    * Constructeur de la classe RunnerTCPEnvoi
+    * @param link 
+    * @param app Un objet ChatApp dont l'utilisateur associé souhaite entame une discussion
+    * @param user2 Destinataire
+    * @param bonjour Boolean true si c'est le debut d'une connexion, false sinon
+    * </p>
+    */
     public RunnerTCPEnvoi(Socket link,ChatApp app, Utilisateur user2, boolean bonjour ) throws IOException {
-    	
         this.link = link;
         this.app = app;
         this.Destinataire = user2;
         this.out = new PrintWriter(link.getOutputStream());
         this.in = new BufferedReader (new InputStreamReader (link.getInputStream()));
-        this.bonjourEnvoye = bonjour;
-        //this.run();
+        this.bonjourEnvoye = bonjour; 
     }
+    
     @Override
     public void run() {
     System.out.println("Creation d'un thread d'envoi");
     String msg;
     
     while(true){
-    	if(!bonjourEnvoye) {
+    	if(!bonjourEnvoye) { // bonjourEnvoye est a false si c'est le debut d'une communication
     		MessageHorodate mh = new MessageHorodate(Destinataire,app.getMe(),"Bonjour",2);
     		bonjourEnvoye = true;
     		System.out.println("Envoi d'un bonjour");
     		out.println(mh);
             out.flush();
     	}
-    	else {
+    	else { // Nous sommes dans le cas ou la connexion a deja ete etablie
         msg = sc.nextLine();
         MessageHorodate mh = new MessageHorodate(Destinataire,app.getMe(),msg,1);
         if(msg.equals("--STOP--")) {
@@ -116,8 +145,7 @@ class RunnerTCPEnvoi implements Runnable {
         	out.flush();
         	break;
         }
-        
-        out.println(mh);
+        out.println(mh); // Envoi du message
         System.out.println("Envoi d'un mesage");
         out.flush();
     	}
@@ -132,14 +160,29 @@ class RunnerTCPEnvoi implements Runnable {
 }
 }
 
-// Reception
+
+
+/**
+* <p>
+* Classe representant les threads s'occupant de la reception de messages en utilisant le protocole TCP. 
+* Cette classe implemente l'interface Runnable.
+* </p>
+*/
 class RunnerTCPEcoute implements Runnable {
 		final Socket link;
 		private ChatApp app ;
 		private Utilisateur u2;
+		
+		/**
+		    * <p>
+		    * Constructeur de la classe RunnerTCPEnvoi
+		    * @param link 
+		    * @param app Un objet ChatApp dont l'utilisateur associé souhaite entame une discussion
+		    * </p>
+		    */
 	    public RunnerTCPEcoute(Socket link,ChatApp app ) {
-	        this.link = link;
-	        this.app = app;
+	        this.link = link; // fait le lien entre l'utilisateur associé a app et un autre utilisateur
+	        this.app = app; // Source 
 	    }
 
 	    @Override