Ajout threads

Speedclocker
1 parent 8d95b38e
Showing 4 changed files with 48 additions and 6 deletions Show diff stats
Sioux/sioux
Sioux/sioux.c
Sioux/sioux.o
Sioux/threadsSocket.c
@@ -7,9 +7,14 @@
 #include <string.h>
 #include <netdb.h>
 #include <arpa/inet.h>
+#include <pthread.h>
 #define BUFF_SIZE 100
+
+
+
+
 int initialisationServeur(char* service)
 {
 	int sock_fd;
@@ -57,15 +62,18 @@ int initialisationServeur(char* service)
 	return sock_fd;
 }
-void reponseConnexion(int sock)
+void* reponseConnexion(void* sock)
 {
 	printf("Connected\n");
 	char buffer[BUFF_SIZE];
-	FILE* sockdial_stream = fdopen(sock, "a+");
+	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);
@@ -79,6 +87,19 @@ void reponseConnexion(int sock)
 }
+
+int lanceThread(void(* fonction) (void *), void* arg, int size)
+{
+	pthread_t thr_id;
+	
+	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;
+}
+
+
 int boucleServeur(int socket, void(* fctConnex)(int))
 {
 	int sock_dial;
@@ -90,8 +111,8 @@ int boucleServeur(int socket, void(* fctConnex)(int))
 		printf("-- boucle --\n");
 		if((sock_dial=accept(socket, NULL, NULL)) < 0){ fprintf(stderr, "Error accept dialogue\n"); return -1; }
 		printf("Dialogue ACCEPTED\n");
-	
-		fctConnex(sock_dial);
+
+		lanceThread((void*)fctConnex, (void*)&sock_dial, sizeof(sock_dial));
 	}
 }
@@ -122,10 +143,10 @@ int main(int argc, char* argv[])
 	int sock_fd=initialisationServeur(port);
-	if( sock_fd==-1 ) { fprintf(stderr, "Initialisaiton du serveur impossible\n"); return -1; }
+	if( sock_fd==-1 ) { fprintf(stderr, "Initialisation du serveur impossible\n"); return -1; }
-	boucleServeur(sock_fd, reponseConnexion);
+	boucleServeur(sock_fd, (void*)&reponseConnexion);
 	return 0;
 }
@@ -0,0 +1,21 @@
+#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)
+{
+	
+}