version 1.56, 2012/06/19 09:59:34
|
version 1.58, 2012/06/21 16:07:25
|
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 2070 printf("L=%d\n", longueur_enregistrement
|
Line 2071 printf("L=%d\n", longueur_enregistrement
|
return; |
return; |
} |
} |
|
|
if ((tampon_lecture = malloc((longueur_enregistrement + 1) |
if ((tampon_lecture = malloc((longueur_enregistrement) |
* sizeof(unsigned char))) == NULL) |
* sizeof(unsigned char))) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
Line 2080 printf("L=%d\n", longueur_enregistrement
|
Line 2081 printf("L=%d\n", longueur_enregistrement
|
|
|
longueur_effective = fread(tampon_lecture, |
longueur_effective = fread(tampon_lecture, |
(size_t) sizeof(unsigned char), |
(size_t) sizeof(unsigned char), |
(size_t) longueur_enregistrement, |
(size_t) longueur_enregistrement - 1, |
(*descripteur).descripteur_c); |
(*descripteur).descripteur_c); |
|
|
if ((s_objet_resultat = allocation(s_etat_processus, LST)) |
if ((s_objet_resultat = allocation(s_etat_processus, LST)) |
Line 2110 printf("L=%d\n", longueur_enregistrement
|
Line 2111 printf("L=%d\n", longueur_enregistrement
|
return; |
return; |
} |
} |
|
|
longueur_enregistrement = 1; |
if ((((*(*((struct_liste_chainee *) (*s_objet_resultat).objet)) |
|
.donnee)).objet = analyse_flux(s_etat_processus, |
for(i = 0; i < longueur_effective; i++) |
tampon_lecture, longueur_enregistrement - 1)) == NULL) |
{ |
|
if (isprint(tampon_lecture[i]) != 0) |
|
{ |
|
longueur_enregistrement += 4; |
|
} |
|
else |
|
{ |
|
longueur_enregistrement++; |
|
} |
|
} |
|
|
|
if ((tampon = malloc(longueur_enregistrement * |
|
sizeof(unsigned char))) == NULL) |
|
{ |
{ |
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
return; |
} |
} |
|
|
ptr = tampon; |
|
|
|
for(i = 0; i < longueur_effective; i++) |
|
{ |
|
if (isprint(tampon_lecture[i]) != 0) |
|
{ |
|
(*ptr) = tampon_lecture[i]; |
|
ptr++; |
|
} |
|
else |
|
{ |
|
(*ptr) = '\\'; |
|
ptr++; |
|
(*ptr) = 'x'; |
|
ptr++; |
|
sprintf(ptr, "%02X", tampon_lecture[i]); |
|
ptr += 2; |
|
} |
|
} |
|
|
|
(*ptr) = d_code_fin_chaine; |
|
free(tampon_lecture); |
free(tampon_lecture); |
((*(*((struct_liste_chainee *) (*s_objet_resultat).objet)) |
|
.donnee)).objet = tampon; |
|
|
|
if (empilement(s_etat_processus, |
if (empilement(s_etat_processus, |
&((*s_etat_processus).l_base_pile), |
&((*s_etat_processus).l_base_pile), |
Line 2217 printf("L=%d\n", longueur_enregistrement
|
Line 2180 printf("L=%d\n", longueur_enregistrement
|
attente.tv_sec = 0; |
attente.tv_sec = 0; |
attente.tv_nsec = GRANULARITE_us * 1000; |
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 2244 printf("L=%d\n", longueur_enregistrement
|
Line 2211 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 |
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 2385 printf("L=%d\n", longueur_enregistrement
|
Line 2364 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 2399 printf("L=%d\n", longueur_enregistrement
|
Line 2379 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 2514 printf("L=%d\n", longueur_enregistrement
|
Line 2509 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 2531 printf("L=%d\n", longueur_enregistrement
|
Line 2526 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; |
} |
} |