création de multiples fonctions pour gérer les envois et les receptions. Affichage plus optimisé

README.md

@@ -1,2 +1,6 @@
 # tsock
 Using C's standard UDP/TCP Library, send and receive data through the Internet.
+Pour compiler :
+```
+gcc -Wall src/*.c -o main
+```

header/puit.h

@@ -0,0 +1,8 @@
+#ifndef HEADER_PUIT
+#define HEADER_PUIT
+
+#include "tsock.h"
+int launchPuit(int nombreMessage);
+int receiveMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in socketStruct);
+
+#endif

header/source.h

@@ -0,0 +1,8 @@
+#ifndef HEADER_SOURCE
+#define HEADER_SOURCE
+#include "tsock.h"
+
+int launchSource(int nombreMessage);
+int sendMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in socketStruct);
+
+#endif

header/tsock.h

@@ -13,10 +13,8 @@
 
 void setNbMessage(int * nb, int source);
 void printInfo(int nb, int source);
-void initSocketAddr(struct sockaddr_in *socketServerTemp, int source);
+void initStructSocket(struct sockaddr_in *socketServerTemp, int source);
-void creationSocket(int *socketTemp, struct sockaddr_in *socketTempStruct);
 
-#define _OE_SOCKETS
 #define PORT_NUM    9000
 
 #endif

puit.c

@@ -1,26 +0,0 @@
-#include "puit.h"
-
-int launchPuit(void)
-{
-    int sock;
-    char buffer[1024];
-    struct sockaddr_in socketPuit;
-
-    creationSocket(&sock,&socketPuit);
-    initSocketAddr(&socketPuit,0);
-
-	if (bind(sock, (const struct sockaddr *)&socketPuit, sizeof(socketPuit)) < 0 )
-	{
-		perror("bind failed");
-		exit(EXIT_FAILURE);
-	}
-
-    int n;
-    unsigned int lg_socketPuit = sizeof(socketPuit);
-
-    n = recvfrom(sock, (char *)buffer, 1024, 0, (struct sockaddr*) &socketPuit,&lg_socketPuit);
-    buffer[n] = '\0';
-    printf("Server : %s\n", buffer);
-    close(sock);
-    return 0;
-}

puit.h

@@ -1,7 +0,0 @@
-#ifndef HEADER_PUIT
-#define HEADER_PUIT
-
-#include "tsock.h"
-int launchPuit(void);
-
-#endif

source.c

@@ -1,20 +0,0 @@
-#include "source.h"
-
-int launchSource(void)
-{
-    int sock;
-    int lg_emis;
-    struct hostent *hp;
-    struct sockaddr_in socketSource;
-    if((sock=socket(AF_INET,SOCK_DGRAM,0)) == -1)
-    {
-        printf("échec création du socket\n");
-        exit(1);
-    }
-    memset(&socketSource, 0, sizeof(socketSource));
-    initSocketAddr(&socketSource,1);
-    lg_emis=sendto(sock, "aaaaa", 6, 0, (struct sockaddr*)&socketSource, sizeof(socketSource));
-    printf("lgemis = %d\n",lg_emis);
-    close(sock);
-    return 0;
-}

source.h

@@ -1,7 +0,0 @@
-#ifndef HEADER_SOURCE
-#define HEADER_SOURCE
-
-#include "tsock.h"
-int launchSource(void);
-
-#endif

src/main.c

@@ -1,6 +1,6 @@
-#include "tsock.h"
+#include "../header/tsock.h"
-#include "puit.h"
+#include "../header/puit.h"
-#include "source.h"
+#include "../header/source.h"
 
 int main (int argc, char **argv)
 {
@@ -45,11 +45,11 @@ int main (int argc, char **argv)
 	if(source)
 	{
 		printf("Source : %d\n",nb_message);
-		launchSource();
+		launchSource(nb_message);
 	}
 	else
 	{
 		printf("Puit : %d\n",nb_message);
-		launchPuit();
+		launchPuit(nb_message);
 	}
 }

src/puit.c

@@ -0,0 +1,48 @@
+#include "../header/puit.h"
+
+int launchPuit(int nombreMessage)
+{
+    int sock;
+    struct sockaddr_in socketPuit;
+
+    if((sock=socket(AF_INET,SOCK_DGRAM,0)) == -1)
+    {
+        perror("[tsock] : fonction socket() : echec creation du socket\n");
+        exit(EXIT_FAILURE);
+    }
+    initStructSocket(&socketPuit,0);
+	if (bind(sock, (const struct sockaddr *)&socketPuit, sizeof(socketPuit)) < 0 )
+	{
+		perror("[tsock] : fonction bind() : echec du lien avec socket serveur.\n");
+		exit(EXIT_FAILURE);
+	}
+    receiveMultipleData(nombreMessage,30,sock,socketPuit);
+    close(sock);
+    return 0;
+}
+
+int receiveMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in socketStruct)
+{
+    char messageRecu[tailleMessage+1];
+    int n, longueurRecu = sizeof(socketStruct);
+    if(nombreMessages < 0)
+    {
+        int i=1;
+        while(1)
+        {
+            n = recvfrom(sock, (char *)messageRecu, tailleMessage, 0, (struct sockaddr*) &socketStruct,(socklen_t *__restrict__)&longueurRecu);
+            messageRecu[n] = '\0';
+            printf("Puit\tReception n°%d (%d) :\t[%s]\n",i,tailleMessage,messageRecu);
+            i++;
+        }
+    }
+    else{
+        for(int i=0;i<nombreMessages;i++)
+        {
+            n = recvfrom(sock, (char *)messageRecu, tailleMessage, 0, (struct sockaddr*) &socketStruct,(socklen_t *__restrict__)&longueurRecu);
+            messageRecu[n] = '\0';
+            printf("Puit\tReception n°%d (%d) :\t[%s]\n",i+1,tailleMessage,messageRecu);
+        }
+    }
+    return 0;
+}

src/source.c

@@ -0,0 +1,32 @@
+#include "../header/source.h"
+
+int launchSource(int nombreMessage)
+{
+    int sock;
+    struct sockaddr_in socketSource;
+
+    if((sock=socket(AF_INET,SOCK_DGRAM,0)) == -1)
+    {
+        perror("[tsock] : fonction socket() : echec creation du socket\n");
+        exit(EXIT_FAILURE);
+    }
+    initStructSocket(&socketSource,1);
+    sendMultipleData(nombreMessage,30,sock,socketSource);
+    close(sock);
+    return 0;
+}
+
+int sendMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in socketStruct)
+{
+    int longueurEmis;
+    char messageChar='a';
+    char sendingMessage[tailleMessage];
+    for(int i=0;i<nombreMessages;i++)
+    {
+        memset(sendingMessage, messageChar, tailleMessage*sizeof(char));
+        longueurEmis=sendto(sock, sendingMessage, tailleMessage, 0, (struct sockaddr*)&socketStruct, sizeof(socketStruct));
+        printf("Source\tEnvoi n°%d (%d) :\t[%s]\n",i+1,longueurEmis,sendingMessage);
+        messageChar++;
+    }
+    return 0;
+}

src/tsock.c

@@ -1,4 +1,4 @@
-#include "tsock.h"
+#include "../header/tsock.h"
 
 void setNbMessage(int * nb, int source)
 {
@@ -21,8 +21,9 @@ void printInfo(int nb, int source)
 	}
 }
 
-void initSocketAddr(struct sockaddr_in *socketTempStruct, int source)
+void initStructSocket(struct sockaddr_in *socketTempStruct, int source)
 {   
+    memset(socketTempStruct, 0, sizeof(*socketTempStruct));
     socketTempStruct->sin_family=AF_INET;
     socketTempStruct->sin_port=htons(PORT_NUM);
     if(source)
@@ -41,13 +42,3 @@ void initSocketAddr(struct sockaddr_in *socketTempStruct, int source)
 
     }
 }
-
-void creationSocket(int *socketTemp, struct sockaddr_in *socketTempStruct)
-{
-    if((*socketTemp=socket(AF_INET,SOCK_DGRAM,0)) == -1)
-    {
-        printf("échec création du socket\n");
-        exit(1);
-    }
-    memset(socketTempStruct, 0, sizeof(*socketTempStruct));
-}