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

Merge pull request #12 from yoboujon/yohan

Browse source 
Yohan
This commit is contained in:
sparis1206 2023-01-18 10:33:18 +01:00 • committed by GitHub
commit 6c1451c544
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
5 changed files with 85 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
header/puit.h
View file

@ -6,5 +6,6 @@
int launchPuit(int nombreMessage,int tailleMessage,int isTCP,int port,char * ipAddress,int isBAL);
int initSocket(int socketType, struct sockaddr_in * socketStruct, int port, char * ipAddress);
int receiveMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in socketStruct, int isTCP);
int modeBoiteAuxLettres(struct sockaddr_in socketStruct, int socketType, int port, char * ipAddress);
#endif

5
header/source.h
View file

@ -2,7 +2,10 @@
#define HEADER_SOURCE
#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);
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

2
src/main.c
View file

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

28
src/puit.c
View file

@ -5,12 +5,13 @@ int launchPuit(int nombreMessage,int tailleMessage,int isTCP,int port,char * ipA
int sock,socketType;
struct sockaddr_in socketPuit;
socketType = (isTCP) ? SOCK_STREAM : SOCK_DGRAM;
sock = initSocket(socketType,&socketPuit,port,ipAddress);
if(isBAL)
{
printf("Mode Boîte aux Lettres\n");
modeBoiteAuxLettres(socketPuit,socketType,port,ipAddress);
return 0;
}
sock = initSocket(socketType,&socketPuit,port,ipAddress);
receiveMultipleData(nombreMessage,tailleMessage,sock,socketPuit,isTCP);
close(sock);
return 0;
@ -33,6 +34,31 @@ int initSocket(int socketType, struct sockaddr_in * socketStruct, int port, char
return sockReturn;
}
int modeBoiteAuxLettres(struct sockaddr_in socketStruct, int socketType, int port, char * ipAddress)
{
char messageRecu[30+1];
int n, i=1, longueurRecu = sizeof(socketStruct),sock,oldSock;
while(1)
{
n=1;
oldSock = initSocket(socketType,&socketStruct,port,ipAddress);
listen(oldSock,5);
sock = accept(oldSock,(struct sockaddr *)&socketStruct,(socklen_t * restrict)&longueurRecu);
while(n>0)
{
n = read(sock,messageRecu,30);
messageRecu[n] = '\0';
if(n>0)
{
printf("Puit\tReception n°%d (%d) :\t[%s]\n",i,n,messageRecu);
i++;
}
}
close(sock);
close(oldSock);
}
}
int receiveMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in socketStruct, int isTCP)
{
char messageRecu[tailleMessage+1];

63
src/source.c
View file

@ -1,6 +1,6 @@
#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;
int sock,socketType;
@ -12,14 +12,21 @@ int launchSource(int nombreMessage,int tailleMessage,int isTCP,int port,char * i
exit(EXIT_FAILURE);
}
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)
{
int connectStatus;
if((connectStatus = connect(sock,(struct sockaddr *)&socketSource,(socklen_t)sizeof(socketSource))) == -1)
{
perror("[tsock] : fonction connect() : echec connexion\n");
exit(EXIT_FAILURE);
};
connectTCP(sock,socketSource,sizeof(socketSource));
sendMultipleData(nombreMessage,tailleMessage,sock,&socketSource,sizeof(socketSource),isTCP);
}
else
@ -30,11 +37,19 @@ int launchSource(int nombreMessage,int tailleMessage,int isTCP,int port,char * i
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 longueurEmis;
char messageChar='a';
char sendingMessage[tailleMessage];
char sendingMessage[tailleMessage],messageChar='a';
for(int i=0;i<nombreMessages;i++)
{
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);
}
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)
{
perror("[tsock] : fonction sendto()/write() : echec d'envoi\n");
exit(EXIT_FAILURE);
}
sendingMessage[tailleMessage]='\0';
printf("Source\tEnvoi n°%d (%d) :\t[%s]\n",i+1,longueurEmis,sendingMessage);
messageChar>='z'?messageChar='a':messageChar++;
}
return 0;
printf("Source\tEnvoi n°%d (%d) :\t[%s]\n",count+1,longueurEmis,sendingMessage);
}