version 1.48, 2013/03/20 22:24:37
|
version 1.64, 2015/09/18 13:41:17
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.13 |
RPL/2 (R) version 4.1.23 |
Copyright (C) 1989-2013 Dr. BERTRAND Joël |
Copyright (C) 1989-2015 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
|
|
Line 109 instruction_recv(struct_processus *s_eta
|
Line 109 instruction_recv(struct_processus *s_eta
|
* de la structure présente dans la pile opérationnelle. |
* de la structure présente dans la pile opérationnelle. |
*/ |
*/ |
|
|
if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0) |
if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) |
|
!= 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme_processus_fils = |
(*s_etat_processus).erreur_systeme_processus_fils = |
d_es_processus; |
d_es_processus; |
Line 207 instruction_recv(struct_processus *s_eta
|
Line 208 instruction_recv(struct_processus *s_eta
|
|
|
if (nombre_donnees == -1) |
if (nombre_donnees == -1) |
{ |
{ |
if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) |
if (pthread_mutex_unlock(&((*s_etat_processus) |
|
.mutex_pile_processus)) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme_processus_fils = |
(*s_etat_processus).erreur_systeme_processus_fils = |
d_es_processus; |
d_es_processus; |
Line 223 instruction_recv(struct_processus *s_eta
|
Line 225 instruction_recv(struct_processus *s_eta
|
* On empile une valeur nulle |
* On empile une valeur nulle |
*/ |
*/ |
|
|
if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) |
if (pthread_mutex_unlock(&((*s_etat_processus) |
|
.mutex_pile_processus)) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme_processus_fils = |
(*s_etat_processus).erreur_systeme_processus_fils = |
d_es_processus; |
d_es_processus; |
Line 309 instruction_recv(struct_processus *s_eta
|
Line 312 instruction_recv(struct_processus *s_eta
|
profilage(s_etat_processus, NULL); |
profilage(s_etat_processus, NULL); |
} |
} |
|
|
pthread_mutex_unlock(&((*s_etat_processus).mutex)); |
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |
return; |
return; |
} |
} |
|
|
Line 360 instruction_recv(struct_processus *s_eta
|
Line 363 instruction_recv(struct_processus *s_eta
|
= registre_stop; |
= registre_stop; |
} |
} |
|
|
pthread_mutex_unlock(&((*s_etat_processus).mutex)); |
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |
|
|
if ((*s_etat_processus).profilage == d_vrai) |
if ((*s_etat_processus).profilage == d_vrai) |
{ |
{ |
Line 424 instruction_recv(struct_processus *s_eta
|
Line 427 instruction_recv(struct_processus *s_eta
|
|
|
if (sigaction(SIGPIPE, ®istre, NULL) != 0) |
if (sigaction(SIGPIPE, ®istre, NULL) != 0) |
{ |
{ |
pthread_mutex_unlock(&((*s_etat_processus).mutex)); |
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |
|
|
(*s_etat_processus).erreur_systeme = d_es_signal; |
(*s_etat_processus).erreur_systeme = d_es_signal; |
return; |
return; |
} |
} |
|
|
if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) |
if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) |
|
!= 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme_processus_fils = |
(*s_etat_processus).erreur_systeme_processus_fils = |
d_es_processus; |
d_es_processus; |
Line 793 instruction_rdate(struct_processus *s_et
|
Line 797 instruction_rdate(struct_processus *s_et
|
if ((*s_objet_argument).type == INT) |
if ((*s_objet_argument).type == INT) |
{ |
{ |
gettimeofday(&horodatage, NULL); |
gettimeofday(&horodatage, NULL); |
horodatage.tv_sec += (*((integer8 *) (*s_objet_argument).objet)); |
horodatage.tv_sec += (time_t) (*((integer8 *) |
|
(*s_objet_argument).objet)); |
|
|
if (horodatage.tv_sec < 0) |
if (horodatage.tv_sec < 0) |
{ |
{ |
Line 1315 instruction_rdgn(struct_processus *s_eta
|
Line 1320 instruction_rdgn(struct_processus *s_eta
|
premier = j; |
premier = j; |
} |
} |
|
|
for(i = 0; i < (long) nombre_types; i++) |
for(i = 0; i < nombre_types; i++) |
{ |
{ |
printf(" - %s\n", types_generateurs[i]); |
printf(" - %s\n", types_generateurs[i]); |
free(types_generateurs[i]); |
free(types_generateurs[i]); |
Line 1347 instruction_rdgn(struct_processus *s_eta
|
Line 1352 instruction_rdgn(struct_processus *s_eta
|
|
|
if ((*s_objet_argument).type == CHN) |
if ((*s_objet_argument).type == CHN) |
{ |
{ |
if ((requete = conversion_majuscule((unsigned char *) |
if ((requete = conversion_majuscule(s_etat_processus, (unsigned char *) |
(*s_objet_argument).objet)) == NULL) |
(*s_objet_argument).objet)) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
Line 1383 instruction_rdgn(struct_processus *s_eta
|
Line 1388 instruction_rdgn(struct_processus *s_eta
|
else |
else |
{ |
{ |
if (((*s_objet_resultat).objet = conversion_majuscule( |
if (((*s_objet_resultat).objet = conversion_majuscule( |
(unsigned char *) gsl_rng_name( |
s_etat_processus, (unsigned char *) gsl_rng_name( |
(*s_etat_processus).generateur_aleatoire))) == NULL) |
(*s_etat_processus).generateur_aleatoire))) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
Line 1637 instruction_recode(struct_processus *s_e
|
Line 1642 instruction_recode(struct_processus *s_e
|
((*s_objet_argument_2).type == CHN) && |
((*s_objet_argument_2).type == CHN) && |
((*s_objet_argument_3).type == CHN)) |
((*s_objet_argument_3).type == CHN)) |
{ |
{ |
if ((encodage_source = conversion_majuscule((unsigned char *) |
if ((encodage_source = conversion_majuscule(s_etat_processus, |
(*s_objet_argument_2).objet)) == NULL) |
(unsigned char *) (*s_objet_argument_2).objet)) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
return; |
return; |
} |
} |
|
|
if ((encodage_destination = conversion_majuscule((unsigned char *) |
if ((encodage_destination = conversion_majuscule(s_etat_processus, |
(*s_objet_argument_1).objet)) == NULL) |
(unsigned char *) (*s_objet_argument_1).objet)) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
return; |
return; |