Tests sur le TCP

This commit is contained in:
Nabil Moukhlis 2020-12-07 20:10:40 +01:00
parent cfca7b6f5a
commit dda0ef459e
6 changed files with 12 additions and 8 deletions

Binary file not shown.

View file

@ -46,6 +46,8 @@ public class Historique {
} }
public void afficher10derniers() { public void afficher10derniers() {
System.out.println("Demarrage de l'affichage partiel de l'historique");
System.out.println("Il y a actuellement " + HistoriqueHorodate.size() +" elements dans l'historique");
int n =10; int n =10;
if(HistoriqueHorodate.size()<=10) { if(HistoriqueHorodate.size()<=10) {
n = HistoriqueHorodate.size(); n = HistoriqueHorodate.size();

Binary file not shown.

View file

@ -5,6 +5,7 @@ import java.io.OutputStream;
import java.net.DatagramSocket; import java.net.DatagramSocket;
import java.net.ServerSocket; import java.net.ServerSocket;
import java.net.Socket; import java.net.Socket;
import java.net.SocketException;
import java.util.Scanner; import java.util.Scanner;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
@ -159,7 +160,6 @@ class RunnerTCPEcoute implements Runnable {
break; break;
} }
} }
} }
else if(line.split(":")[0].equals("Source")) { else if(line.split(":")[0].equals("Source")) {
@ -180,14 +180,16 @@ class RunnerTCPEcoute implements Runnable {
} }
System.out.println("Finishing thread"); in.close();
app.getHist(u2.getPseudo()).afficher10derniers(); link.close();
in.close();
link.close();
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); //e.printStackTrace();
} finally {
System.out.println("Finishing thread");
System.out.println("Affichage de l'histo");
app.getHist(u2.getPseudo()).afficher10derniers();
} }
} }