Merge branch 'main' into yohan

This commit is contained in:
yoboujon 2023-01-13 11:06:31 +01:00 committed by GitHub
commit 43c725aec5
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 19 additions and 7 deletions

View file

@ -2,7 +2,7 @@
#define HEADER_PUIT #define HEADER_PUIT
#include "tsock.h" #include "tsock.h"
int launchPuit(int nombreMessage,int isTCP); int launchPuit(int nombreMessage,int TailleMessage,int isTCP);
int receiveMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in socketStruct); int receiveMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in socketStruct);
int exitMax(int var,int tailleMax);
#endif #endif

View file

@ -8,7 +8,7 @@ int main (int argc, char **argv)
char *ipAddress; char *ipAddress;
extern char *optarg; extern char *optarg;
extern int optind; extern int optind;
int source = -1, nb_message = -1, c, tcp=1, port=9000; /* Nb de messages à envoyer ou à recevoir, par défaut : 10 en émission, infini en réception */ int source = -1, nb_message = -1, c, tcp=1, port=9000, tailleMessage; /* Nb de messages à envoyer ou à recevoir, par défaut : 10 en émission, infini en réception */
while ((c = getopt(argc, argv, "pn:su")) != -1) { while ((c = getopt(argc, argv, "pn:su")) != -1) {
switch (c) { switch (c) {
case 'p': case 'p':
@ -25,6 +25,10 @@ int main (int argc, char **argv)
} }
source = 1; source = 1;
break; break;
case 'l':
tailleMessage =atoi(optarg);
exitMax(tailleMessage,1500);
break;
case 'n': case 'n':
nb_message = atoi(optarg); nb_message = atoi(optarg);
break; break;
@ -54,6 +58,6 @@ int main (int argc, char **argv)
else else
{ {
//printf("Puit : %d\n",nb_message); //printf("Puit : %d\n",nb_message);
launchPuit(nb_message,tcp); launchPuit(nb_message,tailleMessage,tcp);
} }
} }

View file

@ -1,6 +1,6 @@
#include "../header/puit.h" #include "../header/puit.h"
int launchPuit(int nombreMessage,int isTCP) int launchPuit(int nombreMessage,int tailleMessage,int isTCP)
{ {
int sock; int sock;
struct sockaddr_in socketPuit; struct sockaddr_in socketPuit;
@ -16,7 +16,7 @@ int launchPuit(int nombreMessage,int isTCP)
perror("[tsock] : fonction bind() : echec du lien avec socket serveur.\n"); perror("[tsock] : fonction bind() : echec du lien avec socket serveur.\n");
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }
receiveMultipleData(nombreMessage,30,sock,socketPuit); receiveMultipleData(nombreMessage,tailleMessage,sock,socketPuit);
close(sock); close(sock);
return 0; return 0;
} }
@ -46,3 +46,11 @@ int receiveMultipleData(int nombreMessages, int tailleMessage, int sock, struct
} }
return 0; return 0;
} }
int exitMax(int var,int tailleMax){
if(var>1500){
printf("-l doit être <1500 \n");
exit(EXIT_FAILURE);
}
return 0;
}