alartigu/ChatApp-AL-NM
1
0
포크 0
코드 이슈 풀 리퀘스트 릴리즈 위키 활동

TCP fini Historique KO

소스 검색
This commit is contained in:
Nabzzz 2020-12-14 12:47:04 +01:00
부모 9010fe3f23
커밋 2eb1862b9c
4개의 변경된 파일과 18개의 추가작업 그리고 14개의 파일을 삭제
Show stats Download patch file Download diff file Expand all files Collapse all files

BIN
Implementation/src/RunnerTCPEcoute.class
파일 보기

Binary file not shown.

BIN
Implementation/src/RunnerTCPEnvoi.class
파일 보기

Binary file not shown.

BIN
Implementation/src/TCPEchange.class
파일 보기

Binary file not shown.

32
Implementation/src/TCPEchange.java
파일 보기

@ -36,7 +36,7 @@ public class TCPEchange {
}catch(InterruptedException e) {
System.out.println("Un thread s'est arrete brusquement");
}
System.out.println("Tout s'est passé crème");
System.out.println("Tout s'est passe creme");
app.getHist(User2.getPseudo()).afficher10derniers();
}
@ -126,23 +126,27 @@ class RunnerTCPEnvoi implements Runnable {
}
MessageHorodate mh = new MessageHorodate(Destinataire,app.getMe(),msg,1);
if(msg.equals("--STOP--")) {
mh = new MessageHorodate(Destinataire,app.getMe(),msg,0);
mh = new MessageHorodate(Destinataire,app.getMe(),msg,0); // ENVOYER JUSTE --STOP-- SUFFIT
out.println(mh);
out.flush();
break;
}
while(!app.isHistoriqueAvailable()) {
/* while(!app.isHistoriqueAvailable()) {
try{wait();
}catch(InterruptedException e) {}
}
app.setHistoriqueAvailable(false);
Historique h = app.getHist(Destinataire.getPseudo());
h.addMessage(mh);
}*/
//app.setHistoriqueAvailable(false);
synchronized( this.app.getMapHistorique()) {
Historique h = app.getHist(Destinataire.getPseudo());
h.addMessage(mh);
app.majHistorique(h);
}
// on update la liste des historiques de app
app.majHistorique(h);
//app.majHistorique2(mh.toString(),Destinataire.getPseudo());
app.setHistoriqueAvailable(false);
notifyAll();
//app.setHistoriqueAvailable(false);
//notifyAll();
out.println(mh);
System.out.println("Envoi d'un mesage");
out.flush();
@ -201,17 +205,17 @@ class RunnerTCPEcoute implements Runnable {
MessageHorodate mh = MessageHorodate.stringToMessageHorodate(msg);
System.out.println("Type du message:"+mh.getType());
if(mh.getType()==1) {
while(!app.isHistoriqueAvailable()) {
/*while(!app.isHistoriqueAvailable()) {
try{wait();
}catch(InterruptedException e) {}
}
app.setHistoriqueAvailable(false);
app.setHistoriqueAvailable(false);*/
System.out.println("Historique mis à jour lors de la reception");
Historique h = app.getHist(mh.getSource().getPseudo());
h.addMessage(mh);
app.majHistorique(h);
app.setHistoriqueAvailable(true);
notifyAll();
//app.setHistoriqueAvailable(true);
//notifyAll();
//app.majHistorique2(mh,mh.getSource().getPseudo());
}
else if(mh.getType()==0) {