version 1.72, 2013/03/10 17:01:05
|
version 1.76, 2013/03/20 22:24:37
|
Line 96 instruction_r_vers_b(struct_processus *s
|
Line 96 instruction_r_vers_b(struct_processus *s
|
} |
} |
else |
else |
{ |
{ |
(*((logical8 *) (*s_objet_resultat).objet)) = (*((integer8 *) |
(*((logical8 *) (*s_objet_resultat).objet)) = (logical8) |
(*s_objet_argument).objet)); |
(*((integer8 *) (*s_objet_argument).objet)); |
} |
} |
} |
} |
else |
else |
Line 1051 instruction_read(struct_processus *s_eta
|
Line 1051 instruction_read(struct_processus *s_eta
|
* Fichiers séquentiels |
* Fichiers séquentiels |
*/ |
*/ |
|
|
longueur_questure = 256; |
longueur_questure = 4096; |
|
|
if ((tampon_lecture = malloc(longueur_questure * |
if ((tampon_lecture = malloc(((size_t) longueur_questure) * |
sizeof(unsigned char))) == NULL) |
sizeof(unsigned char))) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
Line 1072 instruction_read(struct_processus *s_eta
|
Line 1072 instruction_read(struct_processus *s_eta
|
|
|
do |
do |
{ |
{ |
longueur_effective = fread(tampon_lecture, |
longueur_effective = (integer8) fread(tampon_lecture, |
(size_t) sizeof(unsigned char), longueur_questure, |
sizeof(unsigned char), (size_t) longueur_questure, |
(*descripteur).descripteur_c); |
(*descripteur).descripteur_c); |
|
|
pointeur = 0; |
pointeur = 0; |
Line 1123 instruction_read(struct_processus *s_eta
|
Line 1123 instruction_read(struct_processus *s_eta
|
|
|
do |
do |
{ |
{ |
longueur_effective = fread(tampon_lecture, |
longueur_effective = (integer8) fread(tampon_lecture, |
(size_t) sizeof(unsigned char), longueur_questure, |
sizeof(unsigned char), (size_t) longueur_questure, |
(*descripteur).descripteur_c); |
(*descripteur).descripteur_c); |
|
|
pointeur = 0; |
pointeur = 0; |
Line 1192 instruction_read(struct_processus *s_eta
|
Line 1192 instruction_read(struct_processus *s_eta
|
free(tampon_lecture); |
free(tampon_lecture); |
longueur_enregistrement = position_finale - position_initiale; |
longueur_enregistrement = position_finale - position_initiale; |
|
|
if ((tampon_lecture = malloc((longueur_enregistrement + 1) * |
if ((tampon_lecture = malloc(((size_t) |
|
(longueur_enregistrement + 1)) * |
sizeof(unsigned char))) == NULL) |
sizeof(unsigned char))) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
Line 1210 instruction_read(struct_processus *s_eta
|
Line 1211 instruction_read(struct_processus *s_eta
|
return; |
return; |
} |
} |
|
|
longueur_effective = fread(tampon_lecture, |
longueur_effective = (integer8) fread(tampon_lecture, |
(size_t) sizeof(unsigned char), |
sizeof(unsigned char), (size_t) longueur_enregistrement, |
(size_t) longueur_enregistrement, |
|
(*descripteur).descripteur_c); |
(*descripteur).descripteur_c); |
|
|
if (longueur_effective != longueur_enregistrement) |
if (longueur_effective != longueur_enregistrement) |
Line 1302 instruction_read(struct_processus *s_eta
|
Line 1302 instruction_read(struct_processus *s_eta
|
} |
} |
|
|
if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, |
if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, |
commande, strlen(commande), &ppStmt, &queue) |
commande, (int) strlen(commande), &ppStmt, &queue) |
!= SQLITE_OK) |
!= SQLITE_OK) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_erreur_fichier; |
(*s_etat_processus).erreur_systeme = d_es_erreur_fichier; |
Line 1473 instruction_read(struct_processus *s_eta
|
Line 1473 instruction_read(struct_processus *s_eta
|
} |
} |
|
|
if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, |
if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, |
commande, strlen(commande), &ppStmt, &queue) |
commande, (int) strlen(commande), &ppStmt, &queue) |
!= SQLITE_OK) |
!= SQLITE_OK) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_erreur_fichier; |
(*s_etat_processus).erreur_systeme = d_es_erreur_fichier; |
Line 1547 instruction_read(struct_processus *s_eta
|
Line 1547 instruction_read(struct_processus *s_eta
|
} |
} |
|
|
if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, |
if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, |
commande, strlen(commande), &ppStmt, &queue) |
commande, (int) strlen(commande), &ppStmt, &queue) |
!= SQLITE_OK) |
!= SQLITE_OK) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_erreur_fichier; |
(*s_etat_processus).erreur_systeme = d_es_erreur_fichier; |
Line 1640 instruction_read(struct_processus *s_eta
|
Line 1640 instruction_read(struct_processus *s_eta
|
} |
} |
|
|
if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, |
if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, |
commande, strlen(commande), &ppStmt, &queue) |
commande, (int) strlen(commande), &ppStmt, &queue) |
!= SQLITE_OK) |
!= SQLITE_OK) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_erreur_fichier; |
(*s_etat_processus).erreur_systeme = d_es_erreur_fichier; |
Line 2028 instruction_read(struct_processus *s_eta
|
Line 2028 instruction_read(struct_processus *s_eta
|
return; |
return; |
} |
} |
|
|
longueur = strlen(format_chaine); |
longueur = (integer8) strlen(format_chaine); |
|
|
if (format_chaine[longueur - 1] != ')') |
if (format_chaine[longueur - 1] != ')') |
{ |
{ |
Line 2090 instruction_read(struct_processus *s_eta
|
Line 2090 instruction_read(struct_processus *s_eta
|
longueur_enregistrement = longueur; |
longueur_enregistrement = longueur; |
} |
} |
|
|
if ((tampon_lecture = malloc((longueur_enregistrement) |
if ((tampon_lecture = malloc(((size_t) |
* sizeof(unsigned char))) == NULL) |
longueur_enregistrement) * sizeof(unsigned char))) |
|
== NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
d_es_allocation_memoire; |
d_es_allocation_memoire; |
return; |
return; |
} |
} |
|
|
longueur_effective = fread(tampon_lecture, |
longueur_effective = (integer8) fread(tampon_lecture, |
(size_t) sizeof(unsigned char), |
sizeof(unsigned char), |
(size_t) longueur_enregistrement, |
(size_t) longueur_enregistrement, |
(*descripteur).descripteur_c); |
(*descripteur).descripteur_c); |
|
|
Line 2233 instruction_read(struct_processus *s_eta
|
Line 2234 instruction_read(struct_processus *s_eta
|
presence_indicateur = d_faux; |
presence_indicateur = d_faux; |
|
|
if ((tampon_lecture = realloc(tampon_lecture, |
if ((tampon_lecture = realloc(tampon_lecture, |
(longueur_effective + longueur_questure + 1) |
((size_t) (longueur_effective + longueur_questure + 1)) |
* sizeof(unsigned char))) == NULL) |
* sizeof(unsigned char))) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
Line 2258 instruction_read(struct_processus *s_eta
|
Line 2259 instruction_read(struct_processus *s_eta
|
|
|
do |
do |
{ |
{ |
ios = recvfrom((*((struct_socket *) |
ios = (int) recvfrom((*((struct_socket *) |
(*s_objet_argument_1).objet)).socket, |
(*s_objet_argument_1).objet)).socket, |
tampon_lecture, |
tampon_lecture, (size_t) (longueur_effective + |
longueur_effective + longueur_questure, |
longueur_questure), |
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
&adresse_unix, &longueur_adresse); |
&adresse_unix, &longueur_adresse); |
} while((ios == -1) && (errno == EINTR)); |
} while((ios == -1) && (errno == EINTR)); |
Line 2273 instruction_read(struct_processus *s_eta
|
Line 2274 instruction_read(struct_processus *s_eta
|
|
|
do |
do |
{ |
{ |
ios = recvfrom((*((struct_socket *) |
ios = (int) recvfrom((*((struct_socket *) |
(*s_objet_argument_1).objet)).socket, |
(*s_objet_argument_1).objet)).socket, |
tampon_lecture, |
tampon_lecture, (size_t) (longueur_effective + |
longueur_effective + longueur_questure, |
longueur_questure), |
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
&adresse_ipv4, &longueur_adresse); |
&adresse_ipv4, &longueur_adresse); |
} while((ios == -1) && (errno == EINTR)); |
} while((ios == -1) && (errno == EINTR)); |
Line 2289 instruction_read(struct_processus *s_eta
|
Line 2290 instruction_read(struct_processus *s_eta
|
|
|
do |
do |
{ |
{ |
ios = recvfrom((*((struct_socket *) |
ios = (int) recvfrom((*((struct_socket *) |
(*s_objet_argument_1).objet)).socket, |
(*s_objet_argument_1).objet)).socket, |
tampon_lecture, |
tampon_lecture, (size_t) (longueur_effective + |
longueur_effective + longueur_questure, |
longueur_questure), |
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *) |
&adresse_ipv6, &longueur_adresse); |
&adresse_ipv6, &longueur_adresse); |
} while((ios == -1) && (errno == EINTR)); |
} while((ios == -1) && (errno == EINTR)); |
Line 2335 instruction_read(struct_processus *s_eta
|
Line 2336 instruction_read(struct_processus *s_eta
|
return; |
return; |
} |
} |
|
|
if (ios < 0) |
if (ios <= 0) |
{ |
{ |
nanosleep(&attente, NULL); |
nanosleep(&attente, NULL); |
INCR_GRANULARITE(attente.tv_nsec); |
INCR_GRANULARITE(attente.tv_nsec); |
scrutation_injection(s_etat_processus); |
|
} |
} |
else |
else |
{ |
{ |
Line 2347 instruction_read(struct_processus *s_eta
|
Line 2347 instruction_read(struct_processus *s_eta
|
attente.tv_nsec = GRANULARITE_us * 1000; |
attente.tv_nsec = GRANULARITE_us * 1000; |
} |
} |
|
|
|
scrutation_injection(s_etat_processus); |
|
|
if ((*s_etat_processus).var_volatile_requete_arret == -1) |
if ((*s_etat_processus).var_volatile_requete_arret == -1) |
{ |
{ |
if (ios >= 0) |
if (ios >= 0) |
{ |
{ |
longueur_effective += ios; |
longueur_effective = ios; |
} |
} |
|
|
break; |
break; |
Line 2361 instruction_read(struct_processus *s_eta
|
Line 2363 instruction_read(struct_processus *s_eta
|
|
|
if (ios >= 0) |
if (ios >= 0) |
{ |
{ |
longueur_effective += ios; |
longueur_effective = ios; |
position_initiale = 0; |
position_initiale = 0; |
presence_indicateur = d_faux; |
presence_indicateur = d_faux; |
|
|
Line 2443 instruction_read(struct_processus *s_eta
|
Line 2445 instruction_read(struct_processus *s_eta
|
longueur_adresse = sizeof(adresse_unix); |
longueur_adresse = sizeof(adresse_unix); |
recvfrom((*((struct_socket *) |
recvfrom((*((struct_socket *) |
(*s_objet_argument_1).objet)).socket, |
(*s_objet_argument_1).objet)).socket, |
tampon_lecture, longueur_effective, |
tampon_lecture, |
|
(size_t) longueur_effective, |
0, (struct sockaddr *) |
0, (struct sockaddr *) |
&adresse_unix, &longueur_adresse); |
&adresse_unix, &longueur_adresse); |
} while((ios == -1) && (errno == EINTR)); |
} while((ios == -1) && (errno == EINTR)); |
Line 2456 instruction_read(struct_processus *s_eta
|
Line 2459 instruction_read(struct_processus *s_eta
|
longueur_adresse = sizeof(adresse_ipv4); |
longueur_adresse = sizeof(adresse_ipv4); |
recvfrom((*((struct_socket *) |
recvfrom((*((struct_socket *) |
(*s_objet_argument_1).objet)).socket, |
(*s_objet_argument_1).objet)).socket, |
tampon_lecture, longueur_effective, |
tampon_lecture, |
|
(size_t) longueur_effective, |
0, (struct sockaddr *) |
0, (struct sockaddr *) |
&adresse_ipv4, &longueur_adresse); |
&adresse_ipv4, &longueur_adresse); |
} while((ios == -1) && (errno == EINTR)); |
} while((ios == -1) && (errno == EINTR)); |
Line 2470 instruction_read(struct_processus *s_eta
|
Line 2474 instruction_read(struct_processus *s_eta
|
longueur_adresse = sizeof(adresse_ipv6); |
longueur_adresse = sizeof(adresse_ipv6); |
recvfrom((*((struct_socket *) |
recvfrom((*((struct_socket *) |
(*s_objet_argument_1).objet)).socket, |
(*s_objet_argument_1).objet)).socket, |
tampon_lecture, longueur_effective, |
tampon_lecture, |
|
(size_t) longueur_effective, |
0, (struct sockaddr *) |
0, (struct sockaddr *) |
&adresse_ipv6, &longueur_adresse); |
&adresse_ipv6, &longueur_adresse); |
} while((ios == -1) && (errno == EINTR)); |
} while((ios == -1) && (errno == EINTR)); |
Line 2835 instruction_read(struct_processus *s_eta
|
Line 2840 instruction_read(struct_processus *s_eta
|
longueur_adresse = 0; |
longueur_adresse = 0; |
recvfrom((*((struct_socket *) |
recvfrom((*((struct_socket *) |
(*s_objet_argument_1).objet)).socket, tampon_lecture, |
(*s_objet_argument_1).objet)).socket, tampon_lecture, |
position_finale, MSG_DONTWAIT, |
(size_t) position_finale, MSG_DONTWAIT, |
NULL, &longueur_adresse); |
NULL, &longueur_adresse); |
} |
} |
|
|
Line 2849 instruction_read(struct_processus *s_eta
|
Line 2854 instruction_read(struct_processus *s_eta
|
} |
} |
else if ((*((struct_socket *) (*s_objet_argument_1).objet)).binaire |
else if ((*((struct_socket *) (*s_objet_argument_1).objet)).binaire |
== 'Y') |
== 'Y') |
{ // UNFORMATTED |
{ // socket non formatée |
|
longueur_questure = 4096; |
|
longueur_effective = 0; |
|
tampon_lecture = NULL; |
|
|
|
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
|
|
trame_complete = d_faux; |
|
position_initiale = 0; |
|
position_finale = 0; |
|
|
|
do |
|
{ |
|
presence_indicateur = d_faux; |
|
|
|
if ((tampon_lecture = realloc(tampon_lecture, |
|
((size_t) (longueur_effective + longueur_questure) + 1) |
|
* sizeof(unsigned char))) == NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
# ifndef SEMAPHORES_NOMMES |
|
if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) |
|
# else |
|
if (sem_post((*s_etat_processus).semaphore_fork) != 0) |
|
# endif |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if ((*((struct_socket *) (*s_objet_argument_1).objet)) |
|
.domaine == PF_UNIX) |
|
{ |
|
longueur_adresse = sizeof(adresse_unix); |
|
|
|
do |
|
{ |
|
ios = (int) recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket, |
|
tampon_lecture, (size_t) |
|
(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)) |
|
.domaine == PF_INET) |
|
{ |
|
longueur_adresse = sizeof(adresse_ipv4); |
|
|
|
do |
|
{ |
|
ios = (int) recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket, |
|
tampon_lecture, (size_t) |
|
(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)) |
|
.domaine == PF_INET6) |
|
{ |
|
# ifdef IPV6 |
|
longueur_adresse = sizeof(adresse_ipv6); |
|
|
|
do |
|
{ |
|
ios = (int) recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket, |
|
tampon_lecture, (size_t) |
|
(longueur_effective + longueur_questure), |
|
MSG_PEEK | MSG_DONTWAIT, (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 |
|
{ |
|
printf("+++Warning : IPv6 support " |
|
"unavailable\n"); |
|
} |
|
|
|
longueur_adresse = 0; |
|
longueur_effective = 0; |
|
ios = 0; |
|
# endif |
|
} |
|
else |
|
{ |
|
free(tampon_lecture); |
|
liberation(s_etat_processus, s_objet_argument_1); |
|
|
|
# ifndef SEMAPHORES_NOMMES |
|
while(sem_wait(&((*s_etat_processus) |
|
.semaphore_fork)) != 0) |
|
# else |
|
while(sem_wait((*s_etat_processus) |
|
.semaphore_fork) != 0) |
|
# endif |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_processus; |
|
} |
|
|
|
(*s_etat_processus).erreur_execution = |
|
d_ex_erreur_acces_fichier; |
|
return; |
|
} |
|
|
|
if (ios <= 0) |
|
{ |
|
nanosleep(&attente, NULL); |
|
INCR_GRANULARITE(attente.tv_nsec); |
|
} |
|
else |
|
{ |
|
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
} |
|
|
|
scrutation_injection(s_etat_processus); |
|
|
|
if ((*s_etat_processus).var_volatile_requete_arret == -1) |
|
{ |
|
if (ios >= 0) |
|
{ |
|
longueur_effective += ios; |
|
} |
|
|
|
break; |
|
} |
|
|
|
// Une donnée a été reçue. |
|
|
|
if (ios == (longueur_effective + longueur_questure)) |
|
{ |
|
longueur_effective = ios; |
|
position_initiale = 0; |
|
presence_indicateur = d_faux; |
|
} |
|
else if (ios > 0) |
|
{ |
|
// On retire une trame du buffer. |
|
|
|
if ((*((struct_socket *) (*s_objet_argument_1).objet)) |
|
.domaine == PF_UNIX) |
|
{ |
|
do |
|
{ |
|
longueur_adresse = sizeof(adresse_unix); |
|
recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket, |
|
tampon_lecture, (size_t) longueur_effective, |
|
0, (struct sockaddr *) |
|
&adresse_unix, &longueur_adresse); |
|
} while((ios == -1) && (errno == EINTR)); |
|
} |
|
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 |
|
{ |
|
printf("+++Warning : IPv6 support " |
|
"unavailable\n"); |
|
} |
|
# endif |
|
} |
|
|
|
longueur_effective = ios; |
|
trame_complete = d_vrai; |
|
} |
|
|
|
# ifndef SEMAPHORES_NOMMES |
|
while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) |
|
# else |
|
while(sem_wait((*s_etat_processus).semaphore_fork) != 0) |
|
# endif |
|
{ |
|
if (errno == EINTR) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
} |
|
|
|
if ((*s_etat_processus).var_volatile_requete_arret == -1) |
|
{ |
|
|
|
/* |
|
* Si le père tue le processus courant grâce au signal |
|
* SIGFSTOP, on ne renvoie pas d'erreur. Ce fonctionnement |
|
* correspond à l'utilisation de STOP sur le processus |
|
* en cours. La variable longueur_effective vaut '-1'. |
|
*/ |
|
|
|
free(tampon_lecture); |
|
liberation(s_etat_processus, s_objet_argument_1); |
|
return; |
|
} |
|
|
|
if (longueur_effective == -1) |
|
{ |
|
free(tampon_lecture); |
|
liberation(s_etat_processus, s_objet_argument_1); |
|
|
|
(*s_etat_processus).erreur_execution = |
|
d_ex_erreur_acces_fichier; |
|
return; |
|
} |
|
} while(trame_complete == d_faux); |
|
|
|
/* |
|
* Création de la liste de sortie |
|
*/ |
|
|
|
ptr = tampon_lecture; |
|
|
|
if ((s_objet_type = lecture_fichier_non_formate(s_etat_processus, |
|
&ptr, longueur_effective, d_faux)) == NULL) |
|
{ |
|
free(tampon_lecture); |
|
|
|
(*s_etat_processus).erreur_execution = d_ex_syntaxe; |
|
return; |
|
} |
|
|
|
if ((s_objet_resultat = allocation(s_etat_processus, LST)) |
|
== NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
if (((*s_objet_resultat).objet = |
|
allocation_maillon(s_etat_processus)) == NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
(*((struct_liste_chainee *) (*s_objet_resultat).objet)) |
|
.donnee = s_objet_type; |
|
|
|
if (((*((struct_liste_chainee *) (*s_objet_resultat).objet)) |
|
.suivant = allocation_maillon(s_etat_processus)) == NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
(*(*((struct_liste_chainee *) (*s_objet_resultat).objet)).suivant) |
|
.suivant = NULL; |
|
|
|
if ((s_objet_adresse = allocation(s_etat_processus, LST)) |
|
== NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
(*(*((struct_liste_chainee *) (*s_objet_resultat).objet)).suivant) |
|
.donnee = s_objet_adresse; |
|
|
|
/* |
|
* Les informations concernant la cible sont valides si |
|
* la socket est non connectée et des domaines INET ou INET6. |
|
* Dans tous les autres cas, on renvoie une liste vide. |
|
*/ |
|
|
|
if (((*((struct_socket *) (*s_objet_argument_1).objet)).domaine |
|
== PF_UNIX) || (strcmp((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).type, "STREAM") == 0) || |
|
(strcmp((*((struct_socket *) (*s_objet_argument_1).objet)) |
|
.type, "SEQUENTIAL DATAGRAM") == 0)) |
|
{ |
|
(*s_objet_adresse).objet = NULL; |
|
} |
|
else if ((*((struct_socket *) (*s_objet_argument_1).objet)) |
|
.domaine == PF_INET) |
|
{ |
|
if (((*s_objet_adresse).objet = |
|
allocation_maillon(s_etat_processus)) == NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
if (((*((struct_liste_chainee *) (*s_objet_adresse).objet)) |
|
.donnee = allocation(s_etat_processus, VIN)) == NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
(*((struct_vecteur *) (*(*((struct_liste_chainee *) |
|
(*s_objet_adresse).objet)).donnee).objet)).taille = 4; |
|
|
|
if (((*((struct_vecteur *) (*(*((struct_liste_chainee *) |
|
(*s_objet_adresse).objet)).donnee).objet)).tableau = |
|
malloc(4 * sizeof(integer8))) == NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
((integer8 *) (*((struct_vecteur *) |
|
(*(*((struct_liste_chainee *) (*s_objet_adresse) |
|
.objet)).donnee).objet)).tableau)[0] = |
|
(ntohl(adresse_ipv4.sin_addr.s_addr) >> 24) & 0xFF; |
|
((integer8 *) (*((struct_vecteur *) |
|
(*(*((struct_liste_chainee *) (*s_objet_adresse) |
|
.objet)).donnee).objet)).tableau)[1] = |
|
(ntohl(adresse_ipv4.sin_addr.s_addr) >> 16) & 0xFF; |
|
((integer8 *) (*((struct_vecteur *) |
|
(*(*((struct_liste_chainee *) (*s_objet_adresse) |
|
.objet)).donnee).objet)).tableau)[2] = |
|
(ntohl(adresse_ipv4.sin_addr.s_addr) >> 8) & 0xFF; |
|
((integer8 *) (*((struct_vecteur *) |
|
(*(*((struct_liste_chainee *) (*s_objet_adresse) |
|
.objet)).donnee).objet)).tableau)[3] = |
|
ntohl(adresse_ipv4.sin_addr.s_addr) & 0xFF; |
|
|
|
if (((*((struct_liste_chainee *) (*s_objet_adresse).objet)) |
|
.suivant = allocation_maillon(s_etat_processus)) |
|
== NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
if (((*(*((struct_liste_chainee *) (*s_objet_adresse).objet)) |
|
.suivant).donnee = allocation(s_etat_processus, INT)) |
|
== NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
(*((integer8 *) (*(*(*((struct_liste_chainee *) |
|
(*s_objet_adresse).objet)).suivant).donnee).objet)) = |
|
(integer8) ntohs(adresse_ipv4.sin_port); |
|
|
|
(*(*((struct_liste_chainee *) (*s_objet_adresse).objet)) |
|
.suivant).suivant = NULL; |
|
} |
|
else if ((*((struct_socket *) (*s_objet_argument_1).objet)) |
|
.domaine == PF_INET6) |
|
{ |
|
# ifdef IPV6 |
|
if (((*s_objet_adresse).objet = |
|
allocation_maillon(s_etat_processus)) == NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
if (((*((struct_liste_chainee *) (*s_objet_adresse).objet)) |
|
.donnee = allocation(s_etat_processus, VIN)) == NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
(*((struct_vecteur *) (*(*((struct_liste_chainee *) |
|
(*s_objet_adresse).objet)).donnee).objet)).taille = 16; |
|
|
|
if (((*((struct_vecteur *) (*(*((struct_liste_chainee *) |
|
(*s_objet_adresse).objet)).donnee).objet)).tableau = |
|
malloc(16 * sizeof(integer8))) == NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
for(i = 0; i < 16; i++) |
|
{ |
|
((integer8 *) (*((struct_vecteur *) |
|
(*(*((struct_liste_chainee *) (*s_objet_adresse) |
|
.objet)).donnee).objet)).tableau)[0] = |
|
adresse_ipv6.sin6_addr.s6_addr[i]; |
|
} |
|
|
|
if (((*((struct_liste_chainee *) (*s_objet_adresse).objet)) |
|
.suivant = allocation_maillon(s_etat_processus)) |
|
== NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
if (((*(*((struct_liste_chainee *) (*s_objet_adresse).objet)) |
|
.suivant).donnee = allocation(s_etat_processus, INT)) |
|
== NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_allocation_memoire; |
|
return; |
|
} |
|
|
|
(*((integer8 *) (*(*(*((struct_liste_chainee *) |
|
(*s_objet_adresse).objet)).suivant).donnee).objet)) = |
|
(integer8) ntohs(adresse_ipv6.sin6_port); |
|
|
|
(*(*((struct_liste_chainee *) (*s_objet_adresse).objet)) |
|
.suivant).suivant = NULL; |
|
# else |
|
if ((*s_etat_processus).langue == 'F') |
|
{ |
|
printf("+++Attention : Support du protocole" |
|
" IPv6 indisponible\n"); |
|
} |
|
else |
|
{ |
|
printf("+++Warning : IPv6 support " |
|
"unavailable\n"); |
|
} |
|
# endif |
|
} |
|
else |
|
{ |
|
longueur_adresse = 0; |
|
recvfrom((*((struct_socket *) |
|
(*s_objet_argument_1).objet)).socket, tampon_lecture, |
|
(size_t) position_finale, MSG_DONTWAIT, |
|
NULL, &longueur_adresse); |
|
} |
|
|
|
free(tampon_lecture); |
|
|
|
if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile), |
|
s_objet_resultat) == d_erreur) |
|
{ |
|
return; |
|
} |
} |
} |
else |
else |
{ // FLOW |
{ // FLOW |
|
#if 0 |
longueur_questure = 256; |
longueur_questure = 256; |
|
|
do |
do |
Line 3302 instruction_read(struct_processus *s_eta
|
Line 3789 instruction_read(struct_processus *s_eta
|
{ |
{ |
return; |
return; |
} |
} |
|
#endif |
} |
} |
} |
} |
else |
else |