feat : now detects and handle the disconnects oh clients

achemin1
1 parent 19fd5674
Showing 1 changed file with 23 additions and 4 deletions Show diff stats
server.c
+#define _GNU_SOURCE
 #include <sys/types.h>
 #include <sys/socket.h>
 #include <stdlib.h>
@@ -105,6 +106,16 @@ int serv_gestionClient(int s){
 }
  
  
+void removeSocket(struct pollfd descr[], int i, int length){
+	for (int j=i;j<length-1;j++)
+	{
+		descr[j]=descr[j+1];	
+
+	}
+
+
+}
+
  
 int boucleServeur2(int ecoute)
 {
@@ -115,14 +126,15 @@ int boucleServeur2(int ecoute)
 	//initialiser POLLIN
 	for (int i=0;i<1024;i++)
 	{
-		descripteurs[i].events=POLLIN;
+		descripteurs[i].events=POLLIN|POLLRDHUP|POLLERR;
 	}
 	int LongueurPoll = 1;
  
         while(1){
  
+
 		//poll
-		int nb = poll(descripteurs, 1024, -1);
+		int nb = poll(descripteurs, LongueurPoll, -1);
  
 		if(nb<0){ perror("main.poll"); exit(EXIT_FAILURE); }
  
@@ -141,14 +153,21 @@ int boucleServeur2(int ecoute)
 		}
  
 		for(int i = 0; i < LongueurPoll-1; i++){
-			if( (descripteurs[i+1].revents&POLLIN) !=0){ //A lire
+			if( (descripteurs[i+1].revents&POLLRDHUP) !=0){
+				printf("|%i$ Deconnection\n", i+1);
+
+				//FONCTION ENLEVER UN SOCKET
+				removeSocket(descripteurs,i+1,LongueurPoll );
+				LongueurPoll --;
+			}
+			else if( (descripteurs[i+1].revents&POLLIN) !=0){ //A lire
 				//printf("Gestion Client %i \n", i+1);
+
 				FILE* f = fdopen(descripteurs[i+1].fd, "a+");
  
 				char ligne[MAX_LIGNE];
 				fgets(ligne,MAX_LIGNE,f);
 				printf(">%i$ %s\n", i+1, ligne);
-sleep(1);
  
 			}
 		}