INSA/tsock
1
0
Fork 0
mirror of https://github.com/yoboujon/tsock.git synced 2025-06-08 14:00:50 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

mode emetteur fonctionnel.

Browse source
This commit is contained in:
Yohan Boujon 2023-01-18 10:27:17 +01:00
parent e7eb70a134
commit 1aff7d3ee6
3 changed files with 57 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
header/source.h
View file

@ -2,7 +2,10 @@
#define HEADER_SOURCE #define HEADER_SOURCE
#include "tsock.h" #include "tsock.h"
int launchSource(int nombreMessage,int tailleMessage,int isTCP,int port,char * ipAddress); int launchSource(int nombreMessage,int tailleMessage,int isTCP,int port,char * ipAddress,int emetteur,int recepteur);
int sendMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in * socketStruct, int sizeSocketStruct, int isTCP); int sendMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in * socketStruct, int sizeSocketStruct, int isTCP);
void connectTCP(int sock, struct sockaddr_in socketStruct, int tailleSocket);
void modeEmetteur(int emetteur,int nombreMessage,int tailleMessage,int sock,struct sockaddr_in * socketStruct,int tailleSocketStruct);
void printAndVerif(char * sendingMessage,int tailleMessage,int longueurEmis, int count);
#endif #endif

2
src/main.c
View file

@ -94,7 +94,7 @@ int main (int argc, char **argv)
if(source) if(source)
{ {
//printf("Source : %d\n",nb_message); //printf("Source : %d\n",nb_message);
launchSource(nb_message,tailleMessage,tcp,port,ipAddress); launchSource(nb_message,tailleMessage,tcp,port,ipAddress,emetteur,recepteur);
} }
else else
{ {

63
src/source.c
View file

@ -1,6 +1,6 @@
#include "../header/source.h" #include "../header/source.h"
int launchSource(int nombreMessage,int tailleMessage,int isTCP,int port,char * ipAddress) int launchSource(int nombreMessage,int tailleMessage,int isTCP,int port,char * ipAddress,int emetteur,int recepteur)
{ {
struct sockaddr_in socketSource; struct sockaddr_in socketSource;
int sock,socketType; int sock,socketType;
@ -12,14 +12,21 @@ int launchSource(int nombreMessage,int tailleMessage,int isTCP,int port,char * i
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }
initStructSocket(&socketSource,1,port,ipAddress); initStructSocket(&socketSource,1,port,ipAddress);
if(recepteur != -1)
{
printf("Mode Recepteur, recois : %d\n",recepteur);
return 0;
}
if(emetteur != -1)
{
printf("Mode Emetteur, envois : %d\n",emetteur);
connectTCP(sock,socketSource,sizeof(socketSource));
modeEmetteur(emetteur,nombreMessage,tailleMessage,sock,&socketSource,sizeof(socketSource));
return 0;
}
if(isTCP) if(isTCP)
{ {
int connectStatus; connectTCP(sock,socketSource,sizeof(socketSource));
if((connectStatus = connect(sock,(struct sockaddr *)&socketSource,(socklen_t)sizeof(socketSource))) == -1)
{
perror("[tsock] : fonction connect() : echec connexion\n");
exit(EXIT_FAILURE);
};
sendMultipleData(nombreMessage,tailleMessage,sock,&socketSource,sizeof(socketSource),isTCP); sendMultipleData(nombreMessage,tailleMessage,sock,&socketSource,sizeof(socketSource),isTCP);
} }
else else
@ -30,11 +37,19 @@ int launchSource(int nombreMessage,int tailleMessage,int isTCP,int port,char * i
return 0; return 0;
} }
void connectTCP(int sock, struct sockaddr_in socketStruct, int tailleSocket)
{
if(connect(sock,(struct sockaddr *)&socketStruct,(socklen_t)tailleSocket) == -1)
{
perror("[tsock] : fonction connect() : echec connexion\n");
exit(EXIT_FAILURE);
};
}
int sendMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in * socketStruct, int sizeSocketStruct, int isTCP) int sendMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in * socketStruct, int sizeSocketStruct, int isTCP)
{ {
int longueurEmis; int longueurEmis;
char messageChar='a'; char sendingMessage[tailleMessage],messageChar='a';
char sendingMessage[tailleMessage];
for(int i=0;i<nombreMessages;i++) for(int i=0;i<nombreMessages;i++)
{ {
formatText(sendingMessage,i,tailleMessage,messageChar); formatText(sendingMessage,i,tailleMessage,messageChar);
@ -46,15 +61,35 @@ int sendMultipleData(int nombreMessages, int tailleMessage, int sock, struct soc
{ {
longueurEmis = sendto(sock,sendingMessage,tailleMessage,0,(struct sockaddr*)socketStruct, sizeSocketStruct); longueurEmis = sendto(sock,sendingMessage,tailleMessage,0,(struct sockaddr*)socketStruct, sizeSocketStruct);
} }
printAndVerif(sendingMessage,tailleMessage,longueurEmis,i);
messageChar>='z'?messageChar='a':messageChar++;
}
return 0;
}
void modeEmetteur(int emetteur,int nombreMessage,int tailleMessage,int sock,struct sockaddr_in * socketStruct,int tailleSocketStruct)
{
int longueurEmis;
char sendingMessage[tailleMessage],*paramMessage,*actualMessage,messageChar='a';
for(int i=0;i<nombreMessage;i++)
{
paramMessage = formatTextParam(1,emetteur,tailleMessage+1,nombreMessage);
longueurEmis = write(sock,paramMessage,16);
printAndVerif(paramMessage,16,longueurEmis,i);
memset(sendingMessage, messageChar, tailleMessage);
actualMessage = formatTextMessage(sendingMessage,tailleMessage+1);
longueurEmis = write(sock,actualMessage,tailleMessage+1);
printAndVerif(actualMessage,tailleMessage+1,longueurEmis,i);
}
}
void printAndVerif(char * sendingMessage,int tailleMessage,int longueurEmis, int count)
{
if(longueurEmis == -1) if(longueurEmis == -1)
{ {
perror("[tsock] : fonction sendto()/write() : echec d'envoi\n"); perror("[tsock] : fonction sendto()/write() : echec d'envoi\n");
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }
sendingMessage[tailleMessage]='\0'; printf("Source\tEnvoi n°%d (%d) :\t[%s]\n",count+1,longueurEmis,sendingMessage);
printf("Source\tEnvoi n°%d (%d) :\t[%s]\n",i+1,longueurEmis,sendingMessage);
messageChar>='z'?messageChar='a':messageChar++;
}
return 0;
} }