feat: we can now handle the arrival of new clients using a poll; cant handle the disconnects though

achemin1
1 parent 8d4694b6
Showing 3 changed files with 40 additions and 1 deletions Show diff stats
server.c
server.h
virtual_bridge.c
@@ -7,6 +7,7 @@
 #include <sys/un.h>
 #include <netdb.h>
 #include <netinet/tcp.h>
+#include <poll.h>
 #include "server.h"
@@ -103,3 +104,39 @@ int serv_gestionClient(int s){
 	return 0;
 }
+
+
+int boucleServeur2(int ecoute)
+{
+	//initialisation tableau de socket
+        //int dialogue;
+	struct pollfd descripteurs[1024];
+	descripteurs[0].fd=ecoute;
+	//initialiser POLLIN
+	for (int i=0;i<1024;i++)
+	{
+		descripteurs[i].events=POLLIN;
+	}
+	int LongueurPoll = 1;
+
+        while(1){
+
+		//poll
+		
+
+		//if (ecoute est active){
+		        /* Attente d'une connexion */
+		        int dialogue=accept(ecoute,NULL,NULL);
+			if(dialogue<0) return -1;
+
+			//if longueurPoll <1024 //TODO A GERER
+			descripteurs[LongueurPoll].fd = dialogue;
+			LongueurPoll ++;
+			printf("Nouveau LongueurPoll : %i\n", LongueurPoll);
+
+		        /* Passage de la socket de dialogue a la fonction de traitement */
+		        //if(traitement(dialogue)<0){ shutdown(ecoute,SHUT_RDWR); return 0;}
+		//}
+        }
+	
+}
@@ -7,4 +7,6 @@ int boucleServeur(int ecoute,int (*traitement)(int));
 int serv_printf(int s);
 int serv_gestionClient(int s);
+int boucleServeur2(int ecoute);
+
 #endif
@@ -31,7 +31,7 @@ if(argc!=2){
 // Initialisation du serveur
 	int socket = initialisationServeur(service,1024);//1024 est la taille de la file dattente  de listen
 // Traitement des connexions et des messages
-	int ret = boucleServeur(socket, serv_gestionClient);
+	int ret = boucleServeur2(socket);
 	printf("Finish %i\n",ret);