petits sauts mémoires à régler dans le message à envoyer. Boite aux lettres gère reception/emission

header/puit.h

@@ -2,10 +2,12 @@
 #define HEADER_PUIT
 
 #include "tsock.h"
+#include "bal.h"
 
 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);
+void receptionEmetteur(int sock, int tailleMessagePrevu, int * tailleMessageRecu, int emetteur, int recepteur, struct listeBAL *boiteAuxLettres);
 
 #endif

header/source.h

@@ -6,6 +6,7 @@ int launchSource(int nombreMessage,int tailleMessage,int isTCP,int port,char * i
 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 modeRecepteur(int recepteur,int sock,struct sockaddr_in * socketStruct,int tailleSocketStruct);
 void printAndVerif(char * sendingMessage,int tailleMessage,int longueurEmis, int count);
 
 #endif

header/tsock.h

@@ -21,7 +21,7 @@ void getNonOtpArgs(char ** argv, int argc, int * portNumber, char * ipAddress[])
 void formatText(char * actualMessage, int num, int tailleMessage, char messageChar);
 int exitMax(int var,int tailleMax);
 
-char * formatTextParam(int numEmetteur, int numRecepteur, int tailleMessage, int nbMessage);
+char * formatTextParam(int modeParam, int numEmetteur, int numRecepteur, int tailleMessage, int nbMessage);
 char * formatTextMessage(char * message, int tailleMessage);
 int convertion(int nbr,char *numbuffer);
 int gestionOffset(char *actualMessage,int encadrementHaut,int encadrementBas,int nbr);

src/puit.c

@@ -1,5 +1,4 @@
 #include "../header/puit.h"
-#include "../header/bal.h"
 
 int launchPuit(int nombreMessage,int tailleMessage,int isTCP,int port,char * ipAddress,int isBAL)
 {
@@ -45,25 +44,43 @@ int modeBoiteAuxLettres(struct sockaddr_in socketStruct, int socketType, int por
     {
         n=1;
         oldSock = initSocket(socketType,&socketStruct,port,ipAddress);
+        printf("\n---init Socket !---\n");
         listen(oldSock,5);
         sock = accept(oldSock,(struct sockaddr *)&socketStruct,(socklen_t * restrict)&longueurRecu);
         while(n>0)
         {
             n = read(sock,paramRecu,16);
             recuperationParam(paramRecu,&param,&emetteur,&recepteur,&tailleMessage,&nbMessage);
-            char * messageRecu = malloc(sizeof(char)*tailleMessage);
+            switch(param)
-            n = read(sock,messageRecu,tailleMessage);
-            if(n>0)
             {
-                nouveauMessage(&boiteAuxLettres,emetteur,recepteur,messageRecu);
+                case 1:
-                afficheListeBAL(boiteAuxLettres);
+                    printf("Renvoi de la boite aux lettres en mode recepteur.");
+                    break;
+                case 2:
+                    printf("Reception de messages en mode emission.");
+                    receptionEmetteur(sock,tailleMessage,&n,emetteur,recepteur,&boiteAuxLettres);
+                    break;
+                default:
+                    printf("Message non reconnu.");
+                    break;
             }
         }
+        afficheListeBAL(boiteAuxLettres);
         close(sock);
         close(oldSock);
     }
 }
 
+void receptionEmetteur(int sock, int tailleMessagePrevu, int * tailleMessageRecu, int emetteur, int recepteur, struct listeBAL *boiteAuxLettres)
+{
+    char * messageRecu = malloc(sizeof(char)*tailleMessagePrevu);
+    *tailleMessageRecu = read(sock,messageRecu,tailleMessagePrevu);
+    if(*tailleMessageRecu>0)
+    {
+        nouveauMessage(boiteAuxLettres,emetteur,recepteur,messageRecu);
+    }
+}
+
 int receiveMultipleData(int nombreMessages, int tailleMessage, int sock, struct sockaddr_in socketStruct, int isTCP)
 {
     char messageRecu[tailleMessage+1];

src/source.c

@@ -15,6 +15,8 @@ int launchSource(int nombreMessage,int tailleMessage,int isTCP,int port,char * i
     if(recepteur != -1)
     {
         printf("Mode Recepteur, recois : %d\n",recepteur);
+        connectTCP(sock,socketSource,sizeof(socketSource));
+        modeRecepteur(recepteur,sock,&socketSource,sizeof(socketSource));
         return 0;
     }
     if(emetteur != -1)
@@ -73,7 +75,8 @@ void modeEmetteur(int emetteur,int nombreMessage,int tailleMessage,int sock,stru
     char sendingMessage[tailleMessage],*paramMessage,*actualMessage,messageChar='a';
     for(int i=0;i<nombreMessage;i++)
     {
-        paramMessage = formatTextParam(1,emetteur,tailleMessage+1,nombreMessage);
+        //paramMessage = 2 pour un emetteur, 1 pour un recepteur
+        paramMessage = formatTextParam(2,1,emetteur,tailleMessage+1,nombreMessage);
         longueurEmis = write(sock,paramMessage,16);
         printAndVerif(paramMessage,16,longueurEmis,i);
 
@@ -85,6 +88,15 @@ void modeEmetteur(int emetteur,int nombreMessage,int tailleMessage,int sock,stru
     }
 }
 
+void modeRecepteur(int recepteur,int sock,struct sockaddr_in * socketStruct,int tailleSocketStruct)
+{
+    int longueurEmis;
+    char *paramMessage;
+    paramMessage = formatTextParam(1,recepteur,1,0,0);
+    longueurEmis = write(sock,paramMessage,16);
+    printAndVerif(paramMessage,16,longueurEmis,0);
+}
+
 void printAndVerif(char * sendingMessage,int tailleMessage,int longueurEmis, int count)
 {
     if(longueurEmis == -1)

src/tsock.c

@@ -84,13 +84,11 @@ int exitMax(int var,int tailleMax){
 int testProtocol(void)
 {
     char * msg,*msg2;
-    msg=formatTextParam(7, 8, 64, 1);
+    msg=formatTextParam(0,7, 8, 64, 1);
     printf("%s\n",msg);
     msg2=formatTextMessage("aaaaaa",6);
     printf("%s\n",msg2);
-    
     //recuperationParam(msg);
-    
     return 0;
 }
 
@@ -114,10 +112,10 @@ int int2String(char *msgParam, int offset)
     return atoi(buffEntier);
 }
 
-char * formatTextParam(int numEmetteur, int numRecepteur, int tailleMessage, int nbMessage)
+char * formatTextParam(int modeParam, int numEmetteur, int numRecepteur, int tailleMessage, int nbMessage)
 {
     char * actualMessage = malloc(sizeof(char)*16);
-    actualMessage[0]='1';
+    actualMessage[0]=modeParam+0x30;
     gestionOffset(actualMessage, 4,1,numEmetteur);
     gestionOffset(actualMessage, 8,5,numRecepteur);
     gestionOffset(actualMessage, 12,9,tailleMessage);