version 1.78, 2013/04/01 15:29:37
|
version 1.81, 2013/09/06 10:30:55
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.14 |
RPL/2 (R) version 4.1.16 |
Copyright (C) 1989-2013 Dr. BERTRAND Joël |
Copyright (C) 1989-2013 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
Line 883 instruction_read(struct_processus *s_eta
|
Line 883 instruction_read(struct_processus *s_eta
|
struct sockaddr_in6 adresse_ipv6; |
struct sockaddr_in6 adresse_ipv6; |
# endif |
# endif |
|
|
struct pollfd poll_fd; |
|
|
|
struct timespec attente; |
struct timespec attente; |
|
|
struct_descripteur_fichier *descripteur; |
struct_descripteur_fichier *descripteur; |
Line 2498 instruction_read(struct_processus *s_eta
|
Line 2496 instruction_read(struct_processus *s_eta
|
} |
} |
else |
else |
{ |
{ |
// Installation d'un timeout pour sortir de |
// Si on a lu toute une trame et qu'on n'a pas |
// l'instruction dans le cas où la transmission serait |
// réussi à en trouver la structure, on remonte |
// invalide et que la trame reçue serait erronée. |
// une erreur de syntaxe. |
|
|
poll_fd.fd = (*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket; |
|
poll_fd.events = POLLIN; |
|
|
|
while((ios = poll(&poll_fd, 1, 10000)) <= 0) |
if (longueur_effective == ios) |
{ |
{ |
// La fin de la trame n'est pas atteinte. |
if ((*((struct_socket *) (*s_objet_argument_1) |
|
.objet)).domaine == PF_UNIX) |
switch(ios) |
|
{ |
{ |
case EINTR: |
do |
{ |
{ |
if ((*s_etat_processus) |
longueur_adresse = sizeof(adresse_unix); |
.var_volatile_requete_arret == -1) |
recvfrom((*((struct_socket *) |
{ |
(*s_objet_argument_1).objet)) |
liberation(s_etat_processus, |
.socket, tampon_lecture, |
s_objet_argument_1); |
(size_t) longueur_effective, |
free(tampon_lecture); |
0, (struct sockaddr *) |
return; |
&adresse_unix, &longueur_adresse); |
} |
} while((ios == -1) && (errno == EINTR)); |
|
} |
break; |
else if ((*((struct_socket *) (*s_objet_argument_1) |
|
.objet)).domaine == PF_INET) |
|
{ |
|
do |
|
{ |
|
longueur_adresse = sizeof(adresse_ipv4); |
|
recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)) |
|
.socket, tampon_lecture, |
|
(size_t) longueur_effective, |
|
0, (struct sockaddr *) |
|
&adresse_ipv4, &longueur_adresse); |
|
} while((ios == -1) && (errno == EINTR)); |
|
} |
|
else if ((*((struct_socket *) (*s_objet_argument_1) |
|
.objet)) .domaine == PF_INET6) |
|
{ |
|
# ifdef IPV6 |
|
do |
|
{ |
|
longueur_adresse = sizeof(adresse_ipv6); |
|
recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)) |
|
.socket, tampon_lecture, |
|
(size_t) longueur_effective, |
|
0, (struct sockaddr *) |
|
&adresse_ipv6, &longueur_adresse); |
|
} while((ios == -1) && (errno == EINTR)); |
|
# else |
|
if ((*s_etat_processus).langue == 'F') |
|
{ |
|
printf("+++Attention : Support du protocole" |
|
" IPv6 indisponible\n"); |
} |
} |
|
else |
case 0: |
|
{ |
{ |
liberation(s_etat_processus, |
printf("+++Warning : IPv6 support " |
s_objet_argument_1); |
"unavailable\n"); |
free(tampon_lecture); |
|
|
|
(*s_etat_processus).erreur_execution = |
|
d_ex_fin_de_fichier_atteinte; |
|
return; |
|
} |
} |
|
|
|
# endif |
} |
} |
|
|
|
liberation(s_etat_processus, s_objet_argument_1); |
|
free(tampon_lecture); |
|
|
|
(*s_etat_processus).erreur_execution = d_ex_syntaxe; |
|
return; |
} |
} |
} |
} |
} |
} |