bfu/3MICTCP
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Connexion commentée

Browse source
This commit is contained in:
Newglear 2022-04-06 18:09:16 +02:00
parent 8275deb66e
commit 4406108f8a
1 changed files with 25 additions and 24 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/mictcp.c
View file

@ -157,7 +157,7 @@ int mic_tcp_send (int mic_sock, char* mesg, int mesg_size)
pdu.payload.size=mesg_size; pdu.payload.size=mesg_size;
mic_tcp_pdu mem = pdu; mic_tcp_pdu mem = pdu;
printf("%d\n",pdu.header.seq_num); //printf("%d\n",pdu.header.seq_num);
if((sent=IP_send(pdu,sock.addr))==-1){ if((sent=IP_send(pdu,sock.addr))==-1){
printf("Erreur d'envoi du pdu"); printf("Erreur d'envoi du pdu");
exit(1); exit(1);
@ -258,10 +258,8 @@ int mic_tcp_close (int socket)
void process_received_PDU(mic_tcp_pdu pdu, mic_tcp_sock_addr addr) void process_received_PDU(mic_tcp_pdu pdu, mic_tcp_sock_addr addr)
{ {
printf("[MIC-TCP] Appel de la fonction: "); printf(__FUNCTION__); printf("\n"); printf("[MIC-TCP] Appel de la fonction: "); printf(__FUNCTION__); printf("\n");
sock.state = CONNECTED;
if (sock.state == CONNECTED){
printf("Paquet recu \n"); printf("Paquet recu \n");
printf("ACK NUM %d\n",pdu.header.ack); printf("ACK NUM %d\n",pdu.header.seq_num);
mic_tcp_pdu ack; mic_tcp_pdu ack;
if(pdu.header.seq_num == PA){ if(pdu.header.seq_num == PA){
@ -270,16 +268,19 @@ void process_received_PDU(mic_tcp_pdu pdu, mic_tcp_sock_addr addr)
}else{ }else{
printf("Paquet Ack perdu\n"); printf("Paquet Ack perdu\n");
} }
printf("avant send\n");
ack.header.ack=1; ack.header.ack=1;
ack.header.ack_num=PA; ack.header.ack_num=PA;
ack.payload.data ="";
ack.payload.size=0;
if (IP_send(ack,addr)==-1) if (IP_send(ack,addr)==-1)
{ {
printf("Erreur d'envoi du pdu"); printf("Erreur d'envoi du pdu");
exit(1); exit(1);
} }
printf("Ack envoyé \n"); //printf("Ack envoyé \n");
}else{ /*
printf("Je me connecte\n");
int test=0; int test=0;
int sent= -1; int sent= -1;
int max = 20; int max = 20;
@ -328,8 +329,8 @@ void process_received_PDU(mic_tcp_pdu pdu, mic_tcp_sock_addr addr)
} }
printf("Connected\n"); printf("Connected\n");
pthread_cond_broadcast(&cond); pthread_cond_broadcast(&cond);
sock.state = CONNECTED; sock.state = CONNECTED;*/
}
} }