feat: server listening to 1 client

achemin1
1 parent 562c94d1
Showing 8 changed files with 306 additions and 0 deletions Show diff stats
Makefile
README.md
libnet.c
libnet.h
server.c
server.h
virtual_bridge.c
virtual_client.c
@@ -0,0 +1,32 @@
+#
+# Makefile pour generer les executables du pont virtuel
+#
+
+OBJS_SWITCH=libnet.o virtual_bridge.o server.o
+OBJS_CLIENT=libnet.o virtual_client.o
+
+CFLAGS += -Wall -DDEBUG
+
+all: virtual_bridge virtual_client
+
+#
+# La cible de nettoyage
+#
+
+clean:
+	rm -f core *.o virtual_bridge virtual_client
+
+#
+# Les cibles
+#
+
+virtual_bridge:	$(OBJS_SWITCH)
+	$(CC) $(CFLAGS) -o $@ $(OBJS_SWITCH)
+virtual_client:	$(OBJS_CLIENT)
+	$(CC) $(CFLAGS) -o $@ $(OBJS_CLIENT)
+
+
+libnet.o: libnet.c libnet.h
+virtual_bridge.o: virtual_bridge.c libnet.h server.h
+virtual_client.o: virtual_client.c libnet.h
+server.o: server.c
@@ -0,0 +1,9 @@
+# Test serveur :
+
+On lance, sur 80 ça renvoie -1
+Mais sur un autre, ça écoute
+
+On le voit avec la commande 
+netstat -lt
+  -l : listen
+  -t : tcp
@@ -0,0 +1,53 @@
+/** fichier libnet.c **/
+
+/************************************************************/
+/** Ce fichier contient des fonctions reseau.              **/
+/************************************************************/
+
+/**** Fichiers d'inclusion ****/
+
+#include <unistd.h>
+#include <string.h>
+#include <fcntl.h>
+
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <sys/ioctl.h>
+#include <linux/if.h>
+#include <linux/if_tun.h>
+
+#include "libnet.h"
+
+/**** Constantes ****/
+
+#define TAP_PRINCIPAL	"/dev/net/tun"
+
+/**** Variables globales *****/
+
+/**** Fonctions de gestion des sockets ****/
+
+/**** Fonctions de gestion des interfaces virtuelles ****/
+
+/** Ouverture d'une interface Ethernet virtuelle **/
+
+int creationInterfaceVirtuelle(char *nom)
+{
+struct ifreq interface;
+int fd,erreur;
+
+/* Ouverture du peripherique principal */
+if((fd=open(TAP_PRINCIPAL,O_RDWR))<0) return fd;
+
+/* Preparation de la structure */
+memset(&interface,0,sizeof(interface));
+interface.ifr_flags=IFF_TAP|IFF_NO_PI;
+if(nom!=NULL) strncpy(interface.ifr_name,nom,IFNAMSIZ);
+
+/* Creation de l'interface */
+if((erreur=ioctl(fd,TUNSETIFF,(void *)&interface))<0){ close(fd); return erreur; }
+
+/* Recuperation du nom de l'interface */
+if(nom!=NULL) strcpy(nom,interface.ifr_name);
+
+return fd;
+}
@@ -0,0 +1,19 @@
+/** fichier libnet.h **/
+
+/******************************************************************/
+/** Ce fichier decrit les structures et les constantes utilisees **/
+/** par les fonctions reseau.                                    **/
+/******************************************************************/
+
+/**** Constantes ****/
+
+/** Nombre maximum de connexions tamponnees pour le serveur **/
+
+#define MAX_CONNEXIONS	32
+
+/**** Fonctions ****/
+
+int connexionServeur(char *hote,char *service);
+int initialisationServeur(char *service,int connexions);
+int read_fixed(int descripteur,unsigned char *array,int size);
+int creationInterfaceVirtuelle(char *nom);
@@ -0,0 +1,105 @@
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+#include <netinet/in.h>
+#include <sys/un.h>
+#include <netdb.h>
+#include <netinet/tcp.h>
+#include "server.h"
+
+
+#define MAX_LIGNE 512
+
+
+int initialisationServeur(char *service,int connexions){
+	struct addrinfo precisions;
+	struct addrinfo *resultat;
+	struct addrinfo *origine;
+	int statut;
+	int s;
+
+	/* Construction de la structure adresse */
+	memset(&precisions,0,sizeof precisions);
+	precisions.ai_family=AF_UNSPEC;
+	precisions.ai_socktype=SOCK_STREAM;
+	precisions.ai_flags=AI_PASSIVE;
+	statut=getaddrinfo(NULL,service,&precisions,&origine);
+	if(statut<0){ perror("initialisationServeur.getaddrinfo"); exit(EXIT_FAILURE); }
+	struct addrinfo *p;
+	for(p=origine,resultat=origine;p!=NULL;p=p->ai_next)
+	  if(p->ai_family==AF_INET6){ resultat=p; break; }
+
+	/* Creation d'une socket */
+	s=socket(resultat->ai_family,resultat->ai_socktype,resultat->ai_protocol);
+	if(s<0){ perror("initialisationServeur.socket"); exit(EXIT_FAILURE); }
+
+	/* Options utiles */
+	int vrai=1;
+	if(setsockopt(s,SOL_SOCKET,SO_REUSEADDR,&vrai,sizeof(vrai))<0){
+	  perror("initialisationServeur.setsockopt (REUSEADDR)");
+	  exit(EXIT_FAILURE);
+	  }
+	if(setsockopt(s,IPPROTO_TCP,TCP_NODELAY,&vrai,sizeof(vrai))<0){
+	  perror("initialisationServeur.setsockopt (NODELAY)");
+	  exit(EXIT_FAILURE);
+	  }
+
+	/* Specification de l'adresse de la socket */
+	statut=bind(s,resultat->ai_addr,resultat->ai_addrlen);
+	if(statut<0) return -1;
+
+	/* Liberation de la structure d'informations */
+	freeaddrinfo(origine);
+
+	/* Taille de la queue d'attente */
+	statut=listen(s,connexions);
+	if(statut<0) return -1;
+
+	return s;
+
+}
+
+
+int boucleServeur(int ecoute,int (*traitement)(int))
+{
+	int dialogue;
+	while(1){
+
+	    /* Attente d'une connexion */
+	    if((dialogue=accept(ecoute,NULL,NULL))<0) return -1;
+
+	    /* Passage de la socket de dialogue a la fonction de traitement */
+	    if(traitement(dialogue)<0){ shutdown(ecoute,SHUT_RDWR); return 0;}
+
+        }
+}
+
+
+int serv_printf(int s){
+	printf("Hello %i\n", s);
+	return 0;
+}
+
+
+int serv_gestionClient(int s){
+
+	/* Obtient une structure de fichier */
+	FILE *dialogue=fdopen(s,"a+");
+	if(dialogue==NULL){ perror("gestionClient.fdopen"); exit(EXIT_FAILURE); }
+
+	/* Echo */
+	char ligne[MAX_LIGNE];
+	while(fgets(ligne,MAX_LIGNE,dialogue)!=NULL){
+	  	#ifdef DEBUG
+			printf("> %s", ligne);
+		#endif
+		fprintf(dialogue,"> %s",ligne);
+	}
+
+	/* Termine la connexion */
+	fclose(dialogue);
+	return 0;
+}
+
@@ -0,0 +1,10 @@
+#ifndef SERVER_H
+#define SERVER_H
+
+int initialisationServeur(char *service,int connexions);
+int boucleServeur(int ecoute,int (*traitement)(int));
+
+int serv_printf(int s);
+int serv_gestionClient(int s);
+
+#endif
@@ -0,0 +1,39 @@
+/**** Fichier principal pour le pont virtuel ****/
+
+/** Fichiers d'inclusion **/
+
+#include <stdio.h>
+#include <stdlib.h>
+
+#include <sys/types.h>
+#include <sys/socket.h>
+#include "server.h"
+#include "libnet.h"
+
+/** Quelques constantes **/
+
+/** Variables globales **/
+
+/** Fonctions **/
+
+/* Fonction principale */
+int main(int argc,char *argv[]){
+// Analyse des arguments
+if(argc!=2){
+  fprintf(stderr,"Syntaxe : bridge <port>\n");
+  exit(-1);
+  }
+	char *service=argv[1];
+	#ifdef DEBUG
+	fprintf(stdout,"Port : %s\n",service);
+#endif
+
+// 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);
+
+	printf("Finish %i\n",ret);
+
+return 0;
+}
@@ -0,0 +1,39 @@
+/**** Fichier principal pour le client du pont virtuel ****/
+
+/** Fichiers d'inclusion **/
+
+#include <stdio.h>
+#include <stdlib.h>
+
+#include <sys/types.h>
+#include <sys/socket.h>
+
+#include "libnet.h"
+
+/** Quelques constantes **/
+
+/** Variables globales */
+
+/** Fonctions **/
+
+/* Fonction principale */
+int main(int argc,char *argv[]){
+// Analyse des arguments
+if(argc!=3){
+  fprintf(stderr,"Syntaxe : client <serveur> <port>\n");
+  exit(-1);
+  }
+char *serveur=argv[1];
+char *service=argv[2];
+#ifdef DEBUG
+fprintf(stdout,"Pont sur %s port %s\n",serveur,service);
+#endif
+
+// Connexion au serveur
+
+// Ouverture de l'interface reseau
+
+// Communication avec le serveur
+
+return 0;
+}