version 1.55, 2012/06/19 09:34:54
|
version 1.57, 2012/06/19 10:14:56
|
Line 867 instruction_read(struct_processus *s_eta
|
Line 867 instruction_read(struct_processus *s_eta
|
logical1 indicateur_48; |
logical1 indicateur_48; |
logical1 presence_chaine; |
logical1 presence_chaine; |
logical1 presence_indicateur; |
logical1 presence_indicateur; |
|
logical1 trame_complete; |
|
|
socklen_t longueur_adresse; |
socklen_t longueur_adresse; |
|
|
Line 2214 printf("L=%d\n", longueur_enregistrement
|
Line 2215 printf("L=%d\n", longueur_enregistrement
|
longueur_effective = 0; |
longueur_effective = 0; |
tampon_lecture = NULL; |
tampon_lecture = NULL; |
|
|
|
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
|
|
trame_complete = d_faux; |
|
position_initiale = 0; |
|
position_finale = 0; |
|
|
do |
do |
{ |
{ |
presence_indicateur = d_faux; |
presence_indicateur = d_faux; |
|
|
if ((tampon_lecture = realloc(tampon_lecture, |
if ((tampon_lecture = realloc(tampon_lecture, |
(longueur_effective + longueur_questure) |
(longueur_effective + longueur_questure + 1) |
* sizeof(unsigned char))) == NULL) |
* sizeof(unsigned char))) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
Line 2237 printf("L=%d\n", longueur_enregistrement
|
Line 2245 printf("L=%d\n", longueur_enregistrement
|
return; |
return; |
} |
} |
|
|
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
|
|
if ((*((struct_socket *) (*s_objet_argument_1).objet)) |
if ((*((struct_socket *) (*s_objet_argument_1).objet)) |
.domaine == PF_UNIX) |
.domaine == PF_UNIX) |
{ |
{ |
longueur_adresse = sizeof(adresse_unix); |
longueur_adresse = sizeof(adresse_unix); |
ios = recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket, |
do |
tampon_lecture + longueur_effective, |
{ |
longueur_questure, |
ios = recvfrom((*((struct_socket *) |
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
(*s_objet_argument_1).objet)).socket, |
&adresse_unix, &longueur_adresse); |
tampon_lecture + longueur_effective, |
|
longueur_questure, |
|
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
|
&adresse_unix, &longueur_adresse); |
|
} while((ios == -1) && (errno == EINTR)); |
} |
} |
else if ((*((struct_socket *) (*s_objet_argument_1).objet)) |
else if ((*((struct_socket *) (*s_objet_argument_1).objet)) |
.domaine == PF_INET) |
.domaine == PF_INET) |
{ |
{ |
longueur_adresse = sizeof(adresse_ipv4); |
longueur_adresse = sizeof(adresse_ipv4); |
ios = recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket, |
do |
tampon_lecture + longueur_effective, |
{ |
longueur_questure, |
ios = recvfrom((*((struct_socket *) |
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
(*s_objet_argument_1).objet)).socket, |
&adresse_ipv4, &longueur_adresse); |
tampon_lecture + longueur_effective, |
|
longueur_questure, |
|
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
|
&adresse_ipv4, &longueur_adresse); |
|
} while((ios == -1) && (errno == EINTR)); |
} |
} |
else if ((*((struct_socket *) (*s_objet_argument_1).objet)) |
else if ((*((struct_socket *) (*s_objet_argument_1).objet)) |
.domaine == PF_INET6) |
.domaine == PF_INET6) |
{ |
{ |
# ifdef IPV6 |
# ifdef IPV6 |
longueur_adresse = sizeof(adresse_ipv6); |
longueur_adresse = sizeof(adresse_ipv6); |
ios = recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket, |
do |
tampon_lecture + longueur_effective, |
{ |
longueur_questure, |
ios = recvfrom((*((struct_socket *) |
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
(*s_objet_argument_1).objet)).socket, |
&adresse_ipv6, &longueur_adresse); |
tampon_lecture + longueur_effective, |
|
longueur_questure, |
|
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
|
&adresse_ipv6, &longueur_adresse); |
|
} while((ios == -1) && (errno == EINTR)); |
# else |
# else |
if ((*s_etat_processus).langue == 'F') |
if ((*s_etat_processus).langue == 'F') |
{ |
{ |
Line 2318 printf("L=%d\n", longueur_enregistrement
|
Line 2335 printf("L=%d\n", longueur_enregistrement
|
INCR_GRANULARITE(attente.tv_nsec); |
INCR_GRANULARITE(attente.tv_nsec); |
scrutation_injection(s_etat_processus); |
scrutation_injection(s_etat_processus); |
} |
} |
|
else |
|
{ |
|
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
} |
|
|
if ((*s_etat_processus).var_volatile_requete_arret == -1) |
if ((*s_etat_processus).var_volatile_requete_arret == -1) |
{ |
{ |
Line 2380 printf("L=%d\n", longueur_enregistrement
|
Line 2402 printf("L=%d\n", longueur_enregistrement
|
if (niveau == 0) |
if (niveau == 0) |
{ |
{ |
presence_indicateur = d_vrai; |
presence_indicateur = d_vrai; |
|
trame_complete = d_vrai; |
break; |
break; |
} |
} |
|
|
Line 2394 printf("L=%d\n", longueur_enregistrement
|
Line 2417 printf("L=%d\n", longueur_enregistrement
|
.domaine == PF_UNIX) |
.domaine == PF_UNIX) |
{ |
{ |
longueur_adresse = sizeof(adresse_unix); |
longueur_adresse = sizeof(adresse_unix); |
ios = recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket, |
do |
poubelle, position_finale |
{ |
- ancienne_longueur_effective, |
ios = recvfrom((*((struct_socket *) |
MSG_DONTWAIT, (struct sockaddr *) |
(*s_objet_argument_1).objet)).socket, |
&adresse_unix, &longueur_adresse); |
poubelle, position_finale |
|
- ancienne_longueur_effective, |
|
MSG_DONTWAIT, (struct sockaddr *) |
|
&adresse_unix, &longueur_adresse); |
|
} |
|
while((ios == -1) && (errno == EINTR)); |
} |
} |
else if ((*((struct_socket *) (*s_objet_argument_1) |
else if ((*((struct_socket *) (*s_objet_argument_1) |
.objet)).domaine == PF_INET) |
.objet)).domaine == PF_INET) |
{ |
{ |
longueur_adresse = sizeof(adresse_ipv4); |
longueur_adresse = sizeof(adresse_ipv4); |
ios = recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket, |
do |
poubelle, position_finale |
{ |
- ancienne_longueur_effective, |
ios = recvfrom((*((struct_socket *) |
MSG_DONTWAIT, (struct sockaddr *) |
(*s_objet_argument_1).objet)).socket, |
&adresse_ipv4, &longueur_adresse); |
poubelle, position_finale |
|
- ancienne_longueur_effective, |
|
MSG_DONTWAIT, (struct sockaddr *) |
|
&adresse_ipv4, &longueur_adresse); |
|
} |
|
while((ios == -1) && (errno == EINTR)); |
} |
} |
else if ((*((struct_socket *) (*s_objet_argument_1) |
else if ((*((struct_socket *) (*s_objet_argument_1) |
.objet)) .domaine == PF_INET6) |
.objet)) .domaine == PF_INET6) |
{ |
{ |
# ifdef IPV6 |
# ifdef IPV6 |
longueur_adresse = sizeof(adresse_ipv6); |
longueur_adresse = sizeof(adresse_ipv6); |
ios = recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket, |
do |
poubelle, position_finale |
{ |
- ancienne_longueur_effective, |
ios = recvfrom((*((struct_socket *) |
MSG_DONTWAIT, (struct sockaddr *) |
(*s_objet_argument_1).objet)).socket, |
&adresse_ipv6, &longueur_adresse); |
poubelle, position_finale |
|
- ancienne_longueur_effective, |
|
MSG_DONTWAIT, (struct sockaddr *) |
|
&adresse_ipv6, &longueur_adresse); |
|
} |
|
while((ios == -1) && (errno == EINTR)); |
# else |
# else |
if ((*s_etat_processus).langue == 'F') |
if ((*s_etat_processus).langue == 'F') |
{ |
{ |
Line 2509 printf("L=%d\n", longueur_enregistrement
|
Line 2547 printf("L=%d\n", longueur_enregistrement
|
d_ex_erreur_acces_fichier; |
d_ex_erreur_acces_fichier; |
return; |
return; |
} |
} |
} while(presence_indicateur == d_faux); |
} while(trame_complete == d_faux); |
|
|
tampon_lecture[++position_finale] = d_code_fin_chaine; |
tampon_lecture[++position_finale] = d_code_fin_chaine; |
tampon = (*s_etat_processus).instruction_courante; |
tampon = (*s_etat_processus).instruction_courante; |
Line 2526 printf("L=%d\n", longueur_enregistrement
|
Line 2564 printf("L=%d\n", longueur_enregistrement
|
(*s_etat_processus).instruction_courante = tampon; |
(*s_etat_processus).instruction_courante = tampon; |
free(tampon_lecture); |
free(tampon_lecture); |
|
|
|
if (indicateur_48 == d_vrai) |
|
{ |
|
sf(s_etat_processus, 48); |
|
} |
|
else |
|
{ |
|
cf(s_etat_processus, 48); |
|
} |
|
|
|
if ((*s_etat_processus).var_volatile_requete_arret == -1) |
|
{ |
|
(*s_etat_processus).erreur_execution = d_ex; |
|
} |
|
|
liberation(s_etat_processus, s_objet_argument_1); |
liberation(s_etat_processus, s_objet_argument_1); |
return; |
return; |
} |
} |