version 1.51, 2012/03/01 10:14:09
|
version 1.65, 2013/02/26 19:56:18
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.7 |
RPL/2 (R) version 4.1.12 |
Copyright (C) 1989-2012 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 29
|
Line 29
|
================================================================================ |
================================================================================ |
Entrées : structure sur l'état du processus |
Entrées : structure sur l'état du processus |
-------------------------------------------------------------------------------- |
-------------------------------------------------------------------------------- |
Sorties : Néant |
Sorties : néant |
-------------------------------------------------------------------------------- |
-------------------------------------------------------------------------------- |
Effets de bord : néant |
Effets de bord : néant |
================================================================================ |
================================================================================ |
Line 48 sequenceur(struct_processus *s_etat_proc
|
Line 48 sequenceur(struct_processus *s_etat_proc
|
logical1 drapeau_fin; |
logical1 drapeau_fin; |
logical1 drapeau_then; |
logical1 drapeau_then; |
logical1 erreur; |
logical1 erreur; |
|
logical1 presence_compteur; |
|
|
static logical1 completion_valide = d_faux; |
static logical1 completion_valide = d_faux; |
|
|
Line 79 sequenceur(struct_processus *s_etat_proc
|
Line 80 sequenceur(struct_processus *s_etat_proc
|
{ |
{ |
if ((*s_etat_processus).langue == 'F') |
if ((*s_etat_processus).langue == 'F') |
{ |
{ |
printf("[%d] Exécution récursive de niveau %lu\n", |
printf("[%d] Exécution récursive de niveau %lu\n", |
(int) getpid(), (*s_etat_processus).niveau_recursivite); |
(int) getpid(), (*s_etat_processus).niveau_recursivite); |
} |
} |
else |
else |
Line 92 sequenceur(struct_processus *s_etat_proc
|
Line 93 sequenceur(struct_processus *s_etat_proc
|
{ |
{ |
if ((*s_etat_processus).langue == 'F') |
if ((*s_etat_processus).langue == 'F') |
{ |
{ |
printf("[%d] Exécution\n", (int) getpid()); |
printf("[%d] Exécution\n", (int) getpid()); |
} |
} |
else |
else |
{ |
{ |
Line 348 sequenceur(struct_processus *s_etat_proc
|
Line 349 sequenceur(struct_processus *s_etat_proc
|
|
|
if ((*s_etat_processus).langue == 'F') |
if ((*s_etat_processus).langue == 'F') |
{ |
{ |
printf("+++Erreur : Défaut d'argument\n"); |
printf("+++Erreur : Défaut d'argument\n"); |
} |
} |
else |
else |
{ |
{ |
Line 581 sequenceur(struct_processus *s_etat_proc
|
Line 582 sequenceur(struct_processus *s_etat_proc
|
{ |
{ |
if ((*s_etat_processus).langue == 'F') |
if ((*s_etat_processus).langue == 'F') |
{ |
{ |
printf("[%d] Empilement de la variable " |
printf("[%d] Évaluation de la variable " |
"partagée %s de type %d\n", |
"partagée %s de type %d\n", |
(int) getpid(), (*s_etat_processus) |
(int) getpid(), (*s_etat_processus) |
.instruction_courante, |
.instruction_courante, |
Line 603 sequenceur(struct_processus *s_etat_proc
|
Line 604 sequenceur(struct_processus *s_etat_proc
|
fflush(stdout); |
fflush(stdout); |
} |
} |
|
|
if (pthread_mutex_lock(&((*(*s_etat_processus) |
|
.s_liste_variables_partagees).mutex)) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_processus; |
|
return(d_erreur); |
|
} |
|
|
|
if (recherche_variable_partagee(s_etat_processus, |
if (recherche_variable_partagee(s_etat_processus, |
(*(*s_etat_processus) |
(*(*s_etat_processus) |
.pointeur_variable_courante).nom, |
.pointeur_variable_courante).nom, |
(*(*s_etat_processus) |
(*(*s_etat_processus) |
.pointeur_variable_courante).variable_partagee, |
.pointeur_variable_courante).variable_partagee, |
'P') == d_vrai) |
'P') != NULL) |
{ |
{ |
// La variable existe. |
// La variable existe. |
|
|
if ((s_objet = copie_objet(s_etat_processus, |
if ((s_objet = copie_objet(s_etat_processus, |
(*(*s_etat_processus) |
(*(*s_etat_processus) |
.s_liste_variables_partagees) |
.pointeur_variable_partagee_courante) |
.table[(*(*s_etat_processus) |
.objet, 'P')) == NULL) |
.s_liste_variables_partagees) |
|
.position_variable].objet, 'P')) |
|
== NULL) |
|
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
d_es_allocation_memoire; |
d_es_allocation_memoire; |
Line 634 sequenceur(struct_processus *s_etat_proc
|
Line 624 sequenceur(struct_processus *s_etat_proc
|
} |
} |
|
|
if (pthread_mutex_unlock(&((*(*s_etat_processus) |
if (pthread_mutex_unlock(&((*(*s_etat_processus) |
.s_liste_variables_partagees).mutex)) |
.pointeur_variable_partagee_courante) |
!= 0) |
.mutex)) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
d_es_processus; |
d_es_processus; |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
if (empilement(s_etat_processus, |
if (evaluation(s_etat_processus, s_objet, 'E') |
&((*s_etat_processus).l_base_pile), |
== d_erreur) |
s_objet) == d_erreur) |
|
{ |
{ |
(*s_etat_processus).erreur_systeme = |
liberation(s_etat_processus, s_objet); |
d_es_allocation_memoire; |
|
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
|
liberation(s_etat_processus, s_objet); |
} |
} |
else |
else |
{ |
{ |
// La variable n'existe plus. |
// La variable n'existe plus. |
|
|
(*s_etat_processus).erreur_systeme = d_es; |
|
|
|
if (pthread_mutex_unlock(&((*(*s_etat_processus) |
|
.s_liste_variables_partagees).mutex)) |
|
!= 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_processus; |
|
return(d_erreur); |
|
} |
|
|
|
recherche_type(s_etat_processus); |
|
} |
} |
} |
} |
|
|
Line 760 sequenceur(struct_processus *s_etat_proc
|
Line 737 sequenceur(struct_processus *s_etat_proc
|
{ |
{ |
if ((*s_etat_processus).langue == 'F') |
if ((*s_etat_processus).langue == 'F') |
{ |
{ |
printf("[%d] Empilement de la variable " |
printf("[%d] Évaluation de la variable " |
"%s de type %d\n", |
"%s de type %d\n", |
(int) getpid(), |
(int) getpid(), |
(*s_etat_processus) |
(*s_etat_processus) |
Line 793 sequenceur(struct_processus *s_etat_proc
|
Line 770 sequenceur(struct_processus *s_etat_proc
|
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
if (empilement(s_etat_processus, |
if (evaluation(s_etat_processus, s_objet, 'E') |
&((*s_etat_processus).l_base_pile), |
== d_erreur) |
s_objet) == d_erreur) |
|
{ |
{ |
(*s_etat_processus).erreur_systeme = |
liberation(s_etat_processus, s_objet); |
d_es_allocation_memoire; |
|
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
|
liberation(s_etat_processus, s_objet); |
} |
} |
} |
} |
else |
else |
Line 1016 sequenceur(struct_processus *s_etat_proc
|
Line 993 sequenceur(struct_processus *s_etat_proc
|
{ |
{ |
if (strncmp(getenv("LANG"), "fr", 2) == 0) |
if (strncmp(getenv("LANG"), "fr", 2) == 0) |
{ |
{ |
printf("[%d] Arrêt\n", (int) getpid()); |
printf("[%d] Arrêt\n", (int) getpid()); |
} |
} |
else |
else |
{ |
{ |
Line 1229 sequenceur(struct_processus *s_etat_proc
|
Line 1206 sequenceur(struct_processus *s_etat_proc
|
(strcmp(instruction_majuscule, "DO") == 0) || |
(strcmp(instruction_majuscule, "DO") == 0) || |
(strcmp(instruction_majuscule, "WHILE") == 0) || |
(strcmp(instruction_majuscule, "WHILE") == 0) || |
(strcmp(instruction_majuscule, "FOR") == 0) || |
(strcmp(instruction_majuscule, "FOR") == 0) || |
|
(strcmp(instruction_majuscule, "FORALL") == 0) |
|
|| |
(strcmp(instruction_majuscule, "START") == 0) || |
(strcmp(instruction_majuscule, "START") == 0) || |
(strcmp(instruction_majuscule, "SELECT") == 0) |
(strcmp(instruction_majuscule, "SELECT") == 0) |
|
|| |
|
(strcmp(instruction_majuscule, "CRITICAL") == 0) |
|| (strcmp(instruction_majuscule, "CASE") == 0) |
|| (strcmp(instruction_majuscule, "CASE") == 0) |
|| (strcmp(instruction_majuscule, "<<") == 0)) |
|| (strcmp(instruction_majuscule, "<<") == 0)) |
{ |
{ |
Line 1238 sequenceur(struct_processus *s_etat_proc
|
Line 1219 sequenceur(struct_processus *s_etat_proc
|
{ |
{ |
analyse(s_etat_processus, NULL); |
analyse(s_etat_processus, NULL); |
} |
} |
|
else if ((strcmp(instruction_majuscule, "FOR") == 0) |
|
|| (strcmp(instruction_majuscule, "FORALL") |
|
== 0) || (strcmp(instruction_majuscule, |
|
"START") == 0)) |
|
{ |
|
empilement_pile_systeme(s_etat_processus); |
|
|
|
if ((*s_etat_processus).erreur_systeme != d_es) |
|
{ |
|
return(d_erreur); |
|
} |
|
|
|
(*(*s_etat_processus).l_base_pile_systeme) |
|
.type_cloture = 'L'; |
|
} |
else |
else |
{ |
{ |
empilement_pile_systeme(s_etat_processus); |
empilement_pile_systeme(s_etat_processus); |
Line 1270 sequenceur(struct_processus *s_etat_proc
|
Line 1266 sequenceur(struct_processus *s_etat_proc
|
return(d_absence_erreur); |
return(d_absence_erreur); |
} |
} |
} |
} |
|
else if (((strcmp(instruction_majuscule, "NEXT") |
|
== 0) || (strcmp(instruction_majuscule, |
|
"STEP") == 0)) && ((*(*s_etat_processus) |
|
.l_base_pile_systeme).type_cloture != 'L')) |
|
{ |
|
/* |
|
* Libération des compteurs de boucle. |
|
*/ |
|
|
|
presence_compteur = (((*(*s_etat_processus) |
|
.l_base_pile_systeme).type_cloture |
|
== 'F') || ((*(*s_etat_processus) |
|
.l_base_pile_systeme).type_cloture |
|
== 'A')) ? d_vrai : d_faux; |
|
|
|
if (((*(*s_etat_processus).l_base_pile_systeme) |
|
.type_cloture != 'S') && |
|
(presence_compteur == d_faux)) |
|
{ |
|
return(d_erreur); |
|
} |
|
|
|
if (presence_compteur == d_vrai) |
|
{ |
|
if (recherche_variable(s_etat_processus, |
|
(*(*s_etat_processus) |
|
.l_base_pile_systeme).nom_variable) |
|
== d_faux) |
|
{ |
|
return(d_erreur); |
|
} |
|
|
|
if ((*(*s_etat_processus) |
|
.pointeur_variable_courante).objet |
|
== NULL) |
|
{ |
|
return(d_erreur); |
|
} |
|
|
|
(*s_etat_processus).niveau_courant--; |
|
|
|
if (retrait_variables_par_niveau( |
|
s_etat_processus) == d_erreur) |
|
{ |
|
return(d_erreur); |
|
} |
|
} |
|
|
|
depilement_pile_systeme(s_etat_processus); |
|
|
|
if ((*s_etat_processus).erreur_systeme != d_es) |
|
{ |
|
return(d_erreur); |
|
} |
|
} |
else |
else |
{ |
{ |
|
// Traitement spécifique pour la fin |
|
// d'une section critique |
|
|
|
if ((*s_etat_processus).l_base_pile_systeme |
|
== NULL) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_processus; |
|
return(d_erreur); |
|
} |
|
|
|
if ((*(*s_etat_processus).l_base_pile_systeme) |
|
.type_cloture == 'Q') |
|
{ |
|
if (pthread_mutex_unlock( |
|
&mutex_sections_critiques) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = |
|
d_es_processus; |
|
return(d_erreur); |
|
} |
|
|
|
(*s_etat_processus).sections_critiques--; |
|
} |
|
|
depilement_pile_systeme(s_etat_processus); |
depilement_pile_systeme(s_etat_processus); |
|
|
if ((*s_etat_processus).erreur_systeme != d_es) |
if ((*s_etat_processus).erreur_systeme != d_es) |
Line 1312 sequenceur(struct_processus *s_etat_proc
|
Line 1388 sequenceur(struct_processus *s_etat_proc
|
(strcmp(instruction_majuscule, "DO") == 0) || |
(strcmp(instruction_majuscule, "DO") == 0) || |
(strcmp(instruction_majuscule, "WHILE") == 0) || |
(strcmp(instruction_majuscule, "WHILE") == 0) || |
(strcmp(instruction_majuscule, "FOR") == 0) || |
(strcmp(instruction_majuscule, "FOR") == 0) || |
|
(strcmp(instruction_majuscule, "FORALL") == 0) || |
(strcmp(instruction_majuscule, "START") == 0) || |
(strcmp(instruction_majuscule, "START") == 0) || |
(strcmp(instruction_majuscule, "SELECT") == 0) |
(strcmp(instruction_majuscule, "SELECT") == 0) |
|
|| (strcmp(instruction_majuscule, "CRITICAL") == 0) |
|| (strcmp(instruction_majuscule, "CASE") == 0) |
|| (strcmp(instruction_majuscule, "CASE") == 0) |
|| (strcmp(instruction_majuscule, "<<") == 0)) |
|| (strcmp(instruction_majuscule, "<<") == 0)) |
{ |
{ |