Organisation, création des librairies et des Makefiles

Souheib Khinache
1 parent 685f1984
Showing 305 changed files with 337 additions and 78 deletions Show diff stats
Makefile
Network/.sender.c.swp
Network/Makefile
Network/libpcap-1.9.0/CHANGES
Network/libpcap-1.9.0/CMakeLists.txt
Network/libpcap-1.9.0/CONTRIBUTING.md
Network/libpcap-1.9.0/CREDITS
Network/libpcap-1.9.0/ChmodBPF/StartupParameters.plist
Network/libpcap-1.9.0/INSTALL.md
Network/libpcap-1.9.0/LICENSE
Network/libpcap-1.9.0/Makefile-devel-adds
Network/libpcap-1.9.0/Makefile.in
Network/libpcap-1.9.0/README.md
Network/libpcap-1.9.0/TODO
Network/libpcap-1.9.0/VERSION
Network/libpcap-1.9.0/Win32/Prj/wpcap.sln
Network/libpcap-1.9.0/Win32/Prj/wpcap.vcxproj
Network/libpcap-1.9.0/Win32/Prj/wpcap.vcxproj.filters
Network/libpcap-1.9.0/aclocal.m4
Network/libpcap-1.9.0/arcnet.h
@@ -2,29 +2,39 @@
 # Makefile pour generer la bibliotheque de fonctions de communication
 #
  
-all : sniffer sender
+CC=gcc
+CFLAGS=-W -Wall -Wextra
+CLIBS=ar -rcs
+LIB=libnet.a
+LDIR=../libs/
+LIBS=$(LDIR)libnet.a $(LDIR)libthrd.a
+IDIR=../includes/
+LDFLAGS=-lpthread -lpcap
  
-sniffer: sniffer.c
-	gcc -o sniffer sniffer.c -lpcap
  
-sender: sender.c
-	gcc -o sender sender.c
  
-#all: libnet.a
+all: $(LIB)
  
-#
-# La cible de nettoyage
-#
+$(LIB): sender.o sniffer.o tcpserver.o
+	rm -f $@
+	$(CLIBS) $(LDIR)$@ $^
+	ranlib $(LDIR)$@ 
+	
+
+tcpserver.o: tcpserver.c
+	$(CC) -o $@ -c $^ -I$(IDIR) $(CFLAGS) 
+
+sniffer.o: sniffer.c
+	$(CC) -o $@ -c $^ $(CFLAGS)
+
+sender.o: sender.c
+	$(CC) -o $@ -c $^ $(CFLAGS)
  
-#clean: 
-#	rm -f core *.o libnet.a
  
 #
-# Les cibles pour la bibliotheque
+# La cible de nettoyage
 #
  
-#libnet.o: libnet.c libnet.h
+clean: 
+	rm -f *.o $(LDIR)$(LIB) ../bin/test
  
-#libcom.a: libnet.o
-#	rm -f $@
-#	$(CLIB) $@ $+
@@ -9,11 +9,9 @@
  
  
  
-int initialized=0;
-int sock_id;
-
 int initializeSocketUDP(char* service)
 {
+	int sock_id;
 	struct addrinfo precisions, *resultat=NULL, *origine; // On stocke dans précisions nos besoins pour le socket, dans resultat l'adresse qui respectera les reqêtes
  
 	memset(&precisions, 0, sizeof precisions);
@@ -50,12 +48,10 @@ int initializeSocketUDP(char* service)
  
  
 	freeaddrinfo(origine);
-
-	initialized=1;
+	return sock_id;
 }
  
  
-
 int sendUDPBroadcast(char* message, int port)
 {
 	static struct sockaddr_in addrUDP;
@@ -65,17 +61,20 @@ int sendUDPBroadcast(char* message, int port)
 	struct in_addr tmpadd={0xffffffff};	
 	addrUDP.sin_addr=tmpadd;
  
-	if(initialized!=1)
-	{
-		printf("Initialize via Broadcast\n");
-		char tmp_str[15];
-		sprintf(tmp_str, "%d", port);
-		initializeSocketUDP( tmp_str );
-	}
+	char tmp_str[15];
+	sprintf(tmp_str, "%d", port);
+	int sock_id=initializeSocketUDP( tmp_str );
  
-	if(sendto(sock_id, message, sizeof(message), 0, (struct sockaddr*) &addrUDP, sizeof(addrUDP)) < 0) { fprintf(stderr, "Erreur sendto\n"); return(-1);} 
+	printf("Initialize via Broadcast %d\n", sock_id);
+
+	if(sendto(sock_id, message, sizeof(message), 0, (struct sockaddr*) &addrUDP, sizeof(addrUDP)) < 0) { fprintf(stderr, "Erreur sendto\n"); return(-1);}
+       	
+	close(sock_id);	
+	return 0;
 }
  
+
+
 int sendUDPUnicast(char* address, char* message, int port)
 {
 	static struct sockaddr_in addrUDP;
@@ -84,26 +83,25 @@ int sendUDPUnicast(char* address, char* message, int port)
  
 	inet_aton(address, &(addrUDP.sin_addr)); // Converti l'écriture string de format a.b.c.d en format Internet
  
-	
-
-	if(initialized!=1)
-	{
-		printf("Initialize via Unicast\n");
-		char tmp_str[15];
-		sprintf(tmp_str, "%d", port);
-		initializeSocketUDP( tmp_str );
-	}
+	char tmp_str[15];
+	sprintf(tmp_str, "%d", port);
+	int sock_id=initializeSocketUDP( tmp_str );
+	printf("Initialize via Unicast %d\n", sock_id);
  
 	if(sendto(sock_id, message, sizeof(message), 0, (struct sockaddr*) &addrUDP, sizeof(addrUDP)) < 0 ) { fprintf(stderr, "Error sendto\n"); return(-1); }
+	
+	close(sock_id);
+	return 0;
 }
  
  
-
+/*
  
 int main(void)
 {
 	sendUDPBroadcast("Broadwesh", 2020);
-	sendUDPUnicast("255.255.255.255", "Uniwesh", 2020);
+	sendUDPUnicast("192.168.43.174", "Uniwesh", 2020);
 	return(1);
-	close(sock_id);
 }
+
+*/
@@ -7,7 +7,7 @@
  
 #define SZ_DEV 10
  
-
+/*
 // Fonction lors de la detection d'un paquet
 void arp_detect(u_char *args, const struct pcap_pkthdr *header, const u_char *packet)
 {
@@ -18,8 +18,8 @@ void arp_detect(u_char *args, const struct pcap_pkthdr *header, const u_char *pa
 	if(num==10) { loop++; num=0; printf("10 paquets ARP ont été reçus !\n");}
 }
  
-
-
+*/
+/*
  
 int main(int argc, char *argv[])
 {	
@@ -55,10 +55,10 @@ int main(int argc, char *argv[])
 	printf("Device: %s\n", dev);
  
  
-	// Permet d'obtenir l'adresse ip de l'interface demandée
+	// Permet d'obtenir l'adresse ip de l'interface demandée*/
 	/* pcap permet de lister les interfaces et obtenir les adresses ip de ces dernières
 	 * On utilise la fonction pcap_findalldevs 
-	 */
+	 *//*
  
 	pcap_if_t* interfaces;
 	if(pcap_findalldevs(&interfaces, buf_err)!=0) { printf("%s\n", buf_err); return(EXIT_FAILURE); }
@@ -142,3 +142,5 @@ int main(int argc, char *argv[])
  
 	return(0);
 }
+
+*/
@@ -0,0 +1,78 @@
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <string.h>
+#include <netdb.h>
+#include <arpa/inet.h>
+#include "libthrd.h"
+
+
+
+int initialisationServeur(char* service)
+{
+	int sock_fd;
+
+	struct addrinfo precisions, *resultat=NULL, *origine; // On stocke dans précisions nos besoins pour le socket, dans resultat l'adresse qui respectera les reqêtes
+
+	memset(&precisions, 0, sizeof precisions);
+	precisions.ai_family = AF_UNSPEC;
+	precisions.ai_socktype = SOCK_STREAM;
+	precisions.ai_flags = AI_PASSIVE;
+	
+	if(getaddrinfo(NULL, service, &precisions, &origine)<0) { fprintf(stderr, "Erreur getaddrinfo\n"); return(-1); }
+	
+	int n=0;
+	
+	for(struct addrinfo* i=origine; i!=NULL && resultat==NULL; i=i->ai_next)
+	{
+		printf("%d - ", n);
+		if(i->ai_family==AF_INET)
+		{
+			resultat=i;
+			printf("Test : %d", origine->ai_addrlen);
+		}
+
+		printf("\n");	
+		n++;
+	}
+
+	struct sockaddr_in* test=(struct sockaddr_in*)(resultat->ai_addr);
+	printf("Addr : %x\n", test->sin_addr.s_addr);
+	if((sock_fd=socket(resultat->ai_family, resultat->ai_socktype, resultat->ai_protocol))<0) { fprintf(stderr, "Erreur socket\n"); return(-1); }
+
+	int val=1;
+	
+	if(setsockopt(sock_fd, SOL_SOCKET, SO_REUSEADDR|SO_BROADCAST, &val, sizeof(val))<0) { fprintf(stderr, "Erreur setsockopt\n"); return(-1); }
+
+
+
+	if(bind(sock_fd, resultat->ai_addr, resultat->ai_addrlen)) { fprintf(stderr, "Erreur bind\n"); return(-1); }
+
+	if(listen(sock_fd, 20) < 0) { fprintf(stderr, "Error listen server socket\n"); return (-1); }
+	
+	freeaddrinfo(origine);
+	
+	return sock_fd;
+}
+
+
+
+
+int boucleServeur(int socket, void(* fctConnex)(int))
+{
+	int sock_dial;
+
+	printf("------- Début boucle serveur TCP -------\n\n");
+	
+	while(1)	
+	{
+		printf("-- boucle --\n");
+		if((sock_dial=accept(socket, NULL, NULL)) < 0){ fprintf(stderr, "Error accept dialogue\n"); return -1; }
+		printf("Dialogue ACCEPTED\n");
+
+		lanceThread((void*)fctConnex, (void*)&sock_dial, sizeof(sock_dial));
+	}
+}
+
@@ -53,16 +53,25 @@ int connexionServeur(char* host, char* service)
  
 int main(void)
 {
+
+	char buffer[100];
 	int sock_fd = connexionServeur("localhost", "2020");
 	if(sock_fd<0) { fprintf(stderr, "Erreur connexionServeur\n"); return(-1); }
  
 	FILE* sockfd_stream = fdopen(sock_fd, "a+");
  
-	while(1)
+	printf("State sock : %p\n", sockfd_stream);
+
+	for(int i=0; i<10; i++)
 	{
-		fprintf(sockfd_stream, "YES !!! ");	
-	}
+		fprintf(sockfd_stream, "YES !!!\n");	
+	
+		//fprintf(sockfd_stream, "EXIT\n");
  
+		fgets(buffer, 100, sockfd_stream);
+	}
+	fprintf(sockfd_stream, "EXIT\n");
+	fclose(sockfd_stream);	
 	shutdown(sock_fd, SHUT_RDWR);
  
  
@@ -9,10 +9,7 @@
 #include <arpa/inet.h>
 #include <pthread.h>
  
-#define BUFF_SIZE 100
-
-
-
+#define BUFF_SIZE 1000
  
  
 int initialisationServeur(char* service)
@@ -62,8 +59,10 @@ int initialisationServeur(char* service)
 	return sock_fd;
 }
  
+
 void* reponseConnexion(void* sock)
 {
+	
 	printf("Connected\n");
 	char buffer[BUFF_SIZE];
  
@@ -81,10 +80,11 @@ void* reponseConnexion(void* sock)
 		fprintf(sockdial_stream, "Ceci est une réponse du serveur TCP.\n");
  
 	}
-	
+
+	strcpy(buffer, "START");	
 	printf("Fin de la connexion\n");
 	fclose(sockdial_stream);
-
+	pthread_exit(NULL);
 }
  
  
@@ -116,6 +116,7 @@ int boucleServeur(int socket, void(* fctConnex)(int))
 	}
 }
  
+
 void argPortParsing(int argc, char* argv[], char* port)
 {
 	struct option port_arg={"port", 1, NULL, 'p'};
@@ -131,10 +132,11 @@ void argPortParsing(int argc, char* argv[], char* port)
 	}
 	else
 	{
-		printf("La syntaxe doit être ./sioux -p <port> ou ./sioux --port <port>");
+		printf("La syntaxe doit être de la forme ./sioux -p <port> ou ./sioux --port <port>\n\n");
 	}
 }
  
+
 int main(int argc, char* argv[])
 {
 	char port[10]="80";
@@ -147,6 +149,7 @@ int main(int argc, char* argv[])
  
  
 	boucleServeur(sock_fd, (void*)&reponseConnexion);
+
 	return 0;
 }
  
@@ -0,0 +1,34 @@
+#
+# Makefile pour generer la bibliotheque de fonctions de communication
+#
+
+CC=gcc
+CFLAGS=-W -Wall -Wextra
+CLIBS=ar -rcs
+LIB=libthrd.a
+LDIR=../libs/
+IDIR=../includes/
+LDFLAGS=-lpthread
+
+
+
+all: $(LIB)
+
+$(LIB): threadSocket.o
+	rm -f $@
+	$(CLIBS) $(LDIR)$@ $^
+	ranlib $(LDIR)$@ 
+	rm -f *.o
+	
+threadSocket.o: threadSocket.c
+	$(CC) -o $@ -c $^ $(CFLAGS) $(LDFLAGS)
+
+
+#
+# La cible de nettoyage
+#
+
+clean: 
+	rm -f *.o $(LDIR)$(LIB)
+
+
@@ -0,0 +1,49 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <pthread.h>
+#include <string.h>
+#include <unistd.h>
+
+#define BUFF_SIZE 1000
+
+void* reponseConnexion(void* sock)
+{
+	
+	printf("Connected\n");
+	char buffer[BUFF_SIZE];
+	
+	FILE* sockdial_stream = fdopen(*((int*)(sock)), "a+");
+	
+	printf("Sock : %d // Stream : %p \n", *((int*)(sock)), sockdial_stream);
+
+	while(strcmp(buffer, "EXIT\n")!=0)
+	{
+		printf("WAIT\n");
+		fgets(buffer, BUFF_SIZE, sockdial_stream);
+	
+		printf("Le message reçu : %s", buffer);
+
+		fprintf(sockdial_stream, "Ceci est une réponse du serveur TCP.\n");
+
+	}
+
+	strcpy(buffer, "START");	
+	printf("Fin de la connexion\n");
+	fclose(sockdial_stream);
+	pthread_exit(NULL);
+}
+
+
+int lanceThread(void(* fonction) (void *), void* arg, int size)
+{
+	pthread_t thr_id;
+	printf("%d \n",size);	
+	if(pthread_create(&thr_id, NULL, (void*)fonction, arg )!=0) { fprintf(stderr, "Le thread n'a pas pu être créé.\n"); return -1; }
+	
+	pthread_detach(thr_id);
+
+	return 0;
+}
+
+
+
@@ -1,21 +0,0 @@
-#include <stdio.h>
-#include <stdlib.h>
-#include <pthread.h>
-
-
-int lanceThread(void(* fonction) (void *), void* arg, int size)
-{
-	pthread_t thr_id;
-
-	if(pthread_create(&thr_id, NULL, fonction, arg)!=0) { fprintf(stderr, "Le thread n'a pas pu être créé.\n"); return -1; }
-	
-	pthread_detach(thr_id);
-
-	
-
-}
-
-int main(void)
-{
-	
-}
@@ -0,0 +1,29 @@
+
+CC=gcc
+CFLAGS=-W -Wall -Wextra
+CLIBS=ar -rcs
+LIB=libnet.a
+LDIR=../libs/
+LIBS=$(LDIR)libnet.a $(LDIR)libthrd.a
+IDIR=../includes/
+LDFLAGS=-lpthread -lpcap
+
+
+
+all: test
+
+test: test.c
+	cd ../Threads/ && make
+	cd ../Network/ && make
+	$(CC) -o $@ $< -I$(IDIR) $(LDIR)libnet.a $(LDIR)libthrd.a $(CFLAGS) $(LDFLAGS) 
+	rm -f *.o
+
+#
+# La cible de nettoyage
+#
+
+clean: 
+	cd ../Threads/ && make clean
+	cd ../Network/ && make clean
+	rm -f *.o test
+
@@ -0,0 +1,46 @@
+#include <stdlib.h>
+#include <stdio.h>
+#include <getopt.h>
+#include <string.h>
+#include "libnet.h"
+
+
+void argPortParsing(int argc, char* argv[], char* port)
+{
+	struct option port_arg={"port", 1, NULL, 'p'};
+	char opt;
+	int longindex;
+
+	while( (opt=getopt_long(argc, argv, "p:", &port_arg, &longindex)) !='p' && opt!=-1) {}
+
+	if(opt=='p') 
+	{
+		strcpy(port, optarg);
+		printf("%s\n", optarg);
+	}
+	else
+	{
+		printf("La syntaxe doit être de la forme %s -p <port> ou %s --port <port>\n\n", argv[0], argv[0]);
+	}
+}
+
+
+int main(int argc, char* argv[])
+{
+	char port[10]="80";
+	argPortParsing(argc, argv, port);
+	
+
+	int sock_fd=initialisationServeur(port);
+
+	if( sock_fd==-1 ) { fprintf(stderr, "Initialisation du serveur impossible\n"); return -1; }
+
+
+	boucleServeur(sock_fd, (void*)&reponseConnexion);
+
+
+	sendUDPBroadcast("BroadWesh", 2020);
+
+	return 0;
+}
+
@@ -0,0 +1,13 @@
+#ifndef __LIBNET_H__
+#define __LIBNET_H__
+
+int boucleServeur(int socket, void(* fctConnex)(int));
+int lanceThread(void(* fonction) (void *), void* arg, int size);
+void* reponseConnexion(void* sock);
+int initialisationServeur(char* service);
+int initializeSocketUDP(char* service);
+int sendUDPBroadcast(char* message, int port);
+int sendUDPUnicast(char* address, char* message, int port);
+
+
+#endif
@@ -0,0 +1,9 @@
+#ifndef __LIBTHRD_H__
+#define __LIBTHRD_H__
+
+void* reponseConnexion(void* sock);
+
+int lanceThread(void(* fonction) (void *), void* arg, int size);
+
+
+#endif