Skip to content

GitLab

Commit 28fccdf2 authored by pernelle's avatar pernelle
Browse files

Finish 2020.2

parents 8842061a c336519e
Hide whitespace changes
Inline Side-by-side
communCOL3-TP1.c
View file @ 28fccdf2
......@@ -115,8 +115,31 @@ int connexionServeurCOL3(const char *adresse_serveur,int port, const char *token
int sock;
/* resolution adresse destination */
static struct addrinfo addrHint = {.ai_socktype=SOCK_STREAM, .ai_protocol=0, .ai_family=AF_UNSPEC, .ai_flags=(AI_ADDRCONFIG|AI_V4MAPPED)};
struct addrinfo* addrInfo;
char sport[10];
int e;
sprintf(sport,"%d",port);
if (e = getaddrinfo(adresse_serveur, sport, &addrHint, &addrInfo)){
if (errno != 0) perror("Unable to resolve host");
else fprintf(stderr, "getaddrinfo error : %s\n", gai_strerror(e));
exit(EXIT_FAILURE);
}
if (addrInfo == NULL){
fprintf(stderr,"Unable to resolve host: %s:%s\n", adresse_serveur, sport);
exit(EXIT_FAILURE);
}
struct sockaddr addr = *(addrInfo->ai_addr);
/* creation socket */
sock = socket(addrInfo->ai_family, addrInfo->ai_socktype, addrInfo->ai_protocol);
/* nettoyage */
freeaddrinfo(addrInfo);
/* creation socket en mode connecté */
sock = socket(AF_INET, SOCK_STREAM, 0);
/* sock = socket(AF_INET, SOCK_STREAM, 0); */
if (sock == INVALID_SOCKET) {
if (!NCURSE) {
printf("%s"," --> creation de la socket [NOK] \n");
......@@ -138,7 +161,7 @@ int connexionServeurCOL3(const char *adresse_serveur,int port, const char *token
}
/* lancement de la demande de connexion */
if( connect(sock,(struct sockaddr *) &sin, sizeof(struct sockaddr)) == SOCKET_ERROR){
if( connect(sock, &addr, sizeof(struct sockaddr)) == SOCKET_ERROR){
printf("%s"," --> connection TCP au serveur COL3 [NOK] \n");
return(INVALID_SOCKET);
} else {
......@@ -164,6 +187,7 @@ int connexionServeurCOL3(const char *adresse_serveur,int port, const char *token
======================================================*/
/**
DEPRECATED
cette fonction envoi un message (msgresponse) par la socket (sock)
entrées :
......@@ -174,37 +198,92 @@ int connexionServeurCOL3(const char *adresse_serveur,int port, const char *token
*/
void envoiMessageCOL3(int sock, const char * msgresponse) {
if (send(sock, msgresponse, strlen(msgresponse), 0) < 0) {
if (!NCURSE) printf("%s %s %s"," --> socket[lireMessageCOL3] : envoi msg = {",msgresponse,"} [NOK] \n");
if (!NCURSE) printf("%s %s %s"," --> socket[envoiMessageCOL3] : envoi msg = {",msgresponse,"} [NOK] \n");
}
else {
if (!NCURSE) printf("%s %s %s"," --> socket[lireMessageCOL3] : envoi msg = {",msgresponse,"} [OK]\n");
if (!NCURSE) printf("%s %s %s"," --> socket[envoiMessageCOL3] : envoi msg = {",msgresponse,"} [OK]\n");
}
}
/**
cette fonction envoi un message (msgresponse) par la socket (sock)
entrées :
- sock : numéro de la socket
- msgresponse : chaine à envoyé
- logFmag : indique si on affiche les log
p.pernelle - 2020
*/
int envoiMessageCOL3_s(int sock, const char * msgresponse, int logFlag) {
struct sockaddr_in addresIPClient ;
int longAdresseIPClient= sizeof(addresIPClient);
int ret =-1 ;
if (getpeername(sock,&addresIPClient,&longAdresseIPClient) == -1)
{
if (logFlag) printf(" --> socket[envoiMessageCOL3_s] : socket %d non connectée | envoi [NOK] \n",sock);
}
else
{
if (send(sock, msgresponse, strlen(msgresponse), 0) < 0) {
if (logFlag) printf(" --> socket[envoiMessageCOL3_s] : envoi [NOK] | socket %d | msg = %s \n",sock,msgresponse);
}
else {
if (logFlag) printf(" --> socket[envoiMessageCOL3_s] : envoi [OK] | socket %d vers IP = %s | msg = %s \n",sock,inet_ntoa(addresIPClient.sin_addr),msgresponse);
ret=1;
}
}
return ret;
}
/**
/**
DEPRECATED
cette fonction envoi une structure (mastructure) par la socket (sock)
p.pernelle / d.wayntal - 2018
*/
void envoiStructureCOL3(int sock, void * mastructure,int taille) {
if (send(sock, (char *) mastructure, taille, 0) < 0) {
perror("envoi message [NOK]");
if (!NCURSE) printf("%s"," --> socket[envoiStructureCOL3] : envoi [NOK] \n");
}
else {
if (!NCURSE) printf("%s %d %s","--> envoi stucture de taille =",taille,"\n");
if (!NCURSE) printf("%s %d %s"," --> socket[envoiStructureCOL3] : envoi taille = ",taille," [OK]\n");
}
}
/**
* cette fonction envoi une structure (mastructure) par la socket (sock) de façon securisée
* retourne -1 en cas d'echec
* retourne 1 en cas de succes
*
* p.pernelle - 2020
*/
int envoiStructureCOL3_s(int sock, void * mastructure,int taille,int logFlag) {
struct sockaddr_in addresIPClient ;
int longAdresseIPClient= sizeof(addresIPClient);
int ret =-1 ;
if (getpeername(sock,&addresIPClient,&longAdresseIPClient) == -1)
{
if (logFlag) printf(" --> socket[envoiStructureCOL3_s] : socket %d non connectée | envoi [NOK] \n",sock);
}
else
{
if (send(sock, (char *) mastructure, taille, 0) < 0) {
if (logFlag) printf(" --> socket[envoiStructureCOL3_s] : envoi [NOK] | socket %d \n",sock);
}
else {
if (logFlag) printf(" --> socket[envoiStructureCOL3_s] : envoi [OK] | socket %d vers IP = %s | taille = %d \n",sock,inet_ntoa(addresIPClient.sin_addr),taille);
ret=1;
}
}
return ret;
}
/* ===========================================================
......@@ -228,20 +307,62 @@ void lireMessageCOL3(int sock, char * msgrecu) {
if (!NCURSE) printf("%s %d %s"," --> socket[lireMessageCOL3] : en attente reception message (MAX=",TAILLE_MAX_MSG,") ...\n");
/* attente en reception d'un message emis par le serveur */
if((nbrecu = recv(sock, temp, sizeof(temp), 0)) < 0) {
if (!NCURSE) printf("%s"," --> socket[lireMessageCOL3] : reception message [NOK] \n");
}
temp[nbrecu] = '\0';
strcpy(msgrecu,temp);
if (!NCURSE) printf("%s %d %s %s %s "," --> socket[lireMessageCOL3] : reception message [OK] : nbrecu = ",nbrecu," msg = {",msgrecu,"}\n");
if((nbrecu = recv(sock, temp, sizeof(temp), 0)) <= 0) {
if (!NCURSE) printf("%s %d %s"," --> socket[lireMessageCOL3] : reception message [NOK] : nbrecu = ",nbrecu," \n");
strcpy(msgrecu,"");
}
else
{
temp[nbrecu] = '\0';
strcpy(msgrecu,temp);
if (!NCURSE) printf("%s %d %s %s %s "," --> socket[lireMessageCOL3] : reception message [OK] : nbrecu = ",nbrecu," msg = {",msgrecu,"}\n");
}
}
/**
cette fonction lit un message en TCP (msgrecu) sur la socket (sock)
entrées :
- sock : numéro de la socket
- msgrecu : chaine recue
p.pernelle - 2020
*/
int lireMessageCOL3_s(int sock, char * msgrecu,int logFlag) {
struct sockaddr_in addresIPClient ;
int longAdresseIPClient= sizeof(addresIPClient);
int ret =-1 ;
int nbrecu = 0;
char temp[TAILLE_MAX_MSG];
if (getpeername(sock,&addresIPClient,&longAdresseIPClient) == -1)
{
if (logFlag) printf(" --> socket[lireMessageCOL3_s] : socket %d non connectée | lecture [NOK] \n",sock);
}
else
{
/* attente en reception d'un message emis par le serveur */
if((nbrecu = recv(sock, temp, sizeof(temp), 0)) <= 0) {
if (logFlag) printf(" --> socket[lireMessageCOL3_s] : reception message [NOK] | nbrecu = %d \n",nbrecu);
strcpy(msgrecu,"");
}
else
{
temp[nbrecu] = '\0';
strcpy(msgrecu,temp);
if (logFlag) printf(" --> socket[lireMessageCOL3_s] : reception message [NOK] | nbrecu = %d | msg = {%s} \n",nbrecu,temp);
ret =1;
}
}
return ret;
}
/**
DEPRECATED
cette fonction lit une structure (lessitesdumonde) sur la socket (sock) et
retourne le nb octet recu
......@@ -272,8 +393,42 @@ int lireSitesDuMondeCOL3(int sock, capacite_clan * messites) {
/**
cette fonction lit une structure (mastructure) sur la socket (sock) et
retourne le nb octet recu (version securisé)
p.pernelle / d.wayntal - 2020
*/
int lireStructureCOL3_s(int sock, void * mastructure, int taille, int logFlag) {
struct sockaddr_in addresIPClient ;
int longAdresseIPClient= sizeof(addresIPClient);
int nbrecu = 0, nbtotal=0 ;
if (getpeername(sock,&addresIPClient,&longAdresseIPClient) == -1)
{
if (logFlag) printf(" --> socket[lireStructureCOL3_s] : socket %d non connectée | lecture [NOK] \n",sock);
nbrecu=-1;
}
else
{
if (logFlag) printf(" --> socket[lireStructureCOL3_s] encours | attendu taille = %d ...\n",taille);
while (nbtotal<taille && (nbrecu != -1))
{
nbrecu = recv(sock, ((char *) mastructure)+nbtotal, taille, 0);
if (nbrecu<= 0) {
if (logFlag) printf(" --> socket[lireStructureCOL3_s] : [NOK] | nbrecu = %d \n",nbrecu);
nbrecu=-1;
}
else nbtotal+=nbrecu;
}
if ((nbrecu == -1) && (logFlag)) printf(" --> socket[lireStructureCOL3_s] : socket %d non connectée | lecture [NOK] \n",sock);
if ((nbrecu != -1) && (logFlag)) printf(" --> socket[lireStructureCOL3_s] : [OK] | nbrecu = %d \n",nbrecu);
}
return nbrecu;
}
......@@ -479,12 +634,14 @@ void afficheSiteExtractionClan(capacite_clan capa) {
for (i=0;i<MAX_SITE_EXTRACTION;i++)
{
if(capa.sitesAccessibles[i].idSite != 0)
printf("%s %d %s %s %s %d %s %d %s %d %s %d %s",
printf("%s %d %s %s %s %d %s %d %s %d %s %d %s %d %s %d %s",
"site[",i,"] : nom = ",capa.sitesAccessibles[i].nomSite,
"ID=",capa.sitesAccessibles[i].idSite,
"long. = ",capa.sitesAccessibles[i].longitude,
"lat. = ",capa.sitesAccessibles[i].latitude,
"mat. = ",capa.sitesAccessibles[i].matiere,
"Q. = ",capa.sitesAccessibles[i].quantite,
"Tps. = ",capa.sitesAccessibles[i].duree,
"\n");
}
}
......@@ -506,16 +663,16 @@ int estDemandeConforme(type_demande demande, const char * msg){
char** splitmessage;
char demandeatester[20];
int ret=0;
int i;
int i,nbelement;
//printf("%s %d %s","--> test (estDemandeConforme) demande =", (int) demande,"\n");
strcpy(demandeatester,"");
splitmessage=split(msg,MSG_DELIMINTER,1);
//for(i=0;splitmessage[i]!=NULL;i++)
for(i=0;splitmessage[i]!=NULL;i++)
//{
// printf("%s %s %s","--> test (estDemandeConforme) split =", splitmessage[i],"\n");
//}
nbelement=i;
//printf("%s %d %s","--> test (estDemandeConforme) demande =", (int) demande,"\n");
switch (demande)
{
......@@ -528,9 +685,9 @@ int estDemandeConforme(type_demande demande, const char * msg){
case mondev : strcpy(demandeatester,MSG_GTK_MONDE_OK); break;
default : strcpy(demandeatester,"[NOK]");
}
//printf("%s %s %s","--> test (estDemandeConforme) demande à tester =", demandeatester,"\n");
//printf("%s %s %s %d %s","--> test (estDemandeConforme) demande à tester =", demandeatester,"nb element =",nbelement,"\n");
for(i=0;splitmessage[i]!=NULL;i++) {
if (( (strcmp(splitmessage[i],demandeatester)==0) && (strcmp(splitmessage[i+1],MSG_QUEST)==0) )
if (( (strcmp(splitmessage[i],demandeatester)==0) && (i+1<=nbelement) && (strcmp(splitmessage[i+1],MSG_QUEST)==0) )
|| ( (strcmp(splitmessage[i],demandeatester)==0) && (demande==bataillev) )
|| ( (strcmp(splitmessage[i],demandeatester)==0) && (demande==mondev) ))
{
......@@ -557,10 +714,14 @@ int estReponseConforme(type_demande demande, const char * valeurReponse, const c
int ret=0;
int i;
char demandeatester[20];
int nbelement=0;
//printf("--> lance le split pour tester le nom de clan recu ...\n");
splitmessage=split(msg,MSG_DELIMINTER,1);
for(i=0;splitmessage[i]!=NULL;i++)
nbelement=i;
switch (demande)
{
case nom : strcpy(demandeatester,MSG_CLAN); break;
......@@ -574,7 +735,7 @@ int estReponseConforme(type_demande demande, const char * valeurReponse, const c
for(i=0;splitmessage[i]!=NULL;i++) {
//printf("%s %s","\n -----SPLIT=",splitmessage[i]);
if ( (strcmp(splitmessage[i],demandeatester)==0) && (strcmp(splitmessage[i+1],MSG_QUEST)!=0) )
if ( (strcmp(splitmessage[i],demandeatester)==0) && (i+1<=nbelement) && (strcmp(splitmessage[i+1],MSG_QUEST)!=0) )
{
ret = 1;
......
communCOL3-TP1.h
View file @ 28fccdf2
......@@ -83,8 +83,7 @@ typedef enum {bois=0, salpetre=1, charbon=2, soufre=3, fer=4, chanvre=5} matiere
/* type de chariot et capacite */
typedef enum {lourd=12, leger=5} type_chariot;
/* type de balise (BLO= Baliste LOurde, BLE=Baliste LEgere) */
typedef enum {BLO=1,BLE=0} type_baliste;
/* type de demande envoyé entre client et serveur */
typedef enum {nom=0, statutarmee=1, fichierarmee=2, chariot=3, sites=4 , mondev=5, bataillev=6} type_demande;
......@@ -153,6 +152,7 @@ int connexionServeurCOL3(const char *adresse_serveur,int port, const char *token
======================================================*/
/**
DEPRECATED
cette fonction envoi un message (msgresponse) par la socket (sock)
entrées :
......@@ -163,12 +163,32 @@ int connexionServeurCOL3(const char *adresse_serveur,int port, const char *token
*/
void envoiMessageCOL3(int sock, const char * msgresponse);
/**
cette fonction envoi un message (msgresponse) par la socket (sock)
entrées :
- sock : numéro de la socket
- msgresponse : chaine à envoyé
- logFmag : indique si on affiche les log
p.pernelle - 2020
*/
int envoiMessageCOL3_s(int sock, const char * msgresponse, int logFlag);
/**
DEPRECATED
cette fonction envoi une structure (mastructure) par la socket (sock)
p.pernelle / d.wayntal - 2018
*/
void envoiStructureCOL3(int sock, void * mastructure,int taille);
/**
* cette fonction envoi une structure (mastructure) par la socket (sock) de façon securisée
* retourne -1 en cas d'echec
* retourne 1 en cas de succes
*
* p.pernelle - 2020
*/
int envoiStructureCOL3_s(int sock, void * mastructure,int taille,int logFlag);
/* ===========================================================
les fonctions de lecture de données depuis le serveur
......@@ -184,6 +204,17 @@ void envoiStructureCOL3(int sock, void * mastructure,int taille);
p.pernelle / d.wayntal - 2019
*/
void lireMessageCOL3(int sock, char * msgrecu);
/**
cette fonction lit un message en TCP (msgrecu) sur la socket (sock)
entrées :
- sock : numéro de la socket
- msgrecu : chaine recue
p.pernelle - 2020
*/
int lireMessageCOL3_s(int sock, char * msgrecu,int logFlag);
/**
cette fonction lit une structure (lessitesdumonde) sur la socket (sock) et
retourne le nb octet recu
......@@ -192,6 +223,13 @@ void lireMessageCOL3(int sock, char * msgrecu);
*/
int lireSitesDuMondeCOL3(int sock, capacite_clan * messites);
/**
cette fonction lit une structure (mastructure) sur la socket (sock) et
retourne le nb octet recu (version securisé)
p.pernelle / d.wayntal - 2020
*/
int lireStructureCOL3_s(int sock, void * mastructure, int taille, int logFlag);
/* ===================================================
les fonctions de conversion
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment