version 1.22, 2010/08/09 13:53:06
|
version 1.78, 2013/12/03 09:36:16
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.0.18 |
RPL/2 (R) version 4.1.17 |
Copyright (C) 1989-2010 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 44 sequenceur(struct_processus *s_etat_proc
|
Line 44 sequenceur(struct_processus *s_etat_proc
|
struct_objet *s_objet_evaluation; |
struct_objet *s_objet_evaluation; |
struct_objet *s_sous_objet; |
struct_objet *s_sous_objet; |
|
|
|
integer8 niveau; |
|
integer8 position_courante; |
|
|
logical1 drapeau_appel_definition; |
logical1 drapeau_appel_definition; |
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 60 sequenceur(struct_processus *s_etat_proc
|
Line 64 sequenceur(struct_processus *s_etat_proc
|
unsigned char *message; |
unsigned char *message; |
unsigned char *registre; |
unsigned char *registre; |
unsigned char *tampon; |
unsigned char *tampon; |
unsigned char tampon_retour; |
|
unsigned char *t_ligne; |
unsigned char *t_ligne; |
|
|
unsigned long i; |
Keymap ancien_keymap; |
unsigned long j; |
Keymap nouveau_keymap; |
unsigned long niveau; |
|
unsigned long position_courante; |
|
|
|
(*s_etat_processus).retour_routine_evaluation = 'N'; |
(*s_etat_processus).retour_routine_evaluation = 'N'; |
|
|
Line 78 sequenceur(struct_processus *s_etat_proc
|
Line 79 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 %lld\n", |
(int) getpid(), (*s_etat_processus).niveau_recursivite); |
(int) getpid(), (*s_etat_processus).niveau_recursivite); |
} |
} |
else |
else |
{ |
{ |
printf("[%d] %lu level recursive execution\n", |
printf("[%d] %lld level recursive execution\n", |
(int) getpid(), (*s_etat_processus).niveau_recursivite); |
(int) getpid(), (*s_etat_processus).niveau_recursivite); |
} |
} |
} |
} |
Line 109 sequenceur(struct_processus *s_etat_proc
|
Line 110 sequenceur(struct_processus *s_etat_proc
|
-------------------------------------------------------------------------------- |
-------------------------------------------------------------------------------- |
*/ |
*/ |
|
|
i = 0; |
|
j = 0; |
|
|
|
do |
do |
{ |
{ |
drapeau_appel_definition = d_faux; |
drapeau_appel_definition = d_faux; |
Line 182 sequenceur(struct_processus *s_etat_proc
|
Line 180 sequenceur(struct_processus *s_etat_proc
|
flockfile(stdin); |
flockfile(stdin); |
flockfile(stdout); |
flockfile(stdout); |
|
|
|
ancien_keymap = rl_get_keymap(); |
|
nouveau_keymap = rl_copy_keymap(ancien_keymap); |
|
rl_set_keymap(nouveau_keymap); |
|
|
|
rl_bind_key(NEWLINE, readline_analyse_syntaxique); |
|
rl_bind_key(RETURN, readline_analyse_syntaxique); |
|
rl_bind_key(CTRL('g'), readline_effacement); |
|
rl_done = 0; |
|
|
ligne = readline("RPL/2> "); |
ligne = readline("RPL/2> "); |
|
|
|
rl_set_keymap(ancien_keymap); |
|
rl_free(nouveau_keymap); |
|
|
funlockfile(stdin); |
funlockfile(stdin); |
funlockfile(stdout); |
funlockfile(stdout); |
|
|
Line 199 sequenceur(struct_processus *s_etat_proc
|
Line 209 sequenceur(struct_processus *s_etat_proc
|
(*s_etat_processus).localisation, d_locale)) |
(*s_etat_processus).localisation, d_locale)) |
== NULL) |
== NULL) |
{ |
{ |
|
free((*s_etat_processus).instruction_courante); |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
Line 305 sequenceur(struct_processus *s_etat_proc
|
Line 316 sequenceur(struct_processus *s_etat_proc
|
|
|
if ((message = messages(s_etat_processus)) == NULL) |
if ((message = messages(s_etat_processus)) == NULL) |
{ |
{ |
|
free((*s_etat_processus).instruction_courante); |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
Line 321 sequenceur(struct_processus *s_etat_proc
|
Line 333 sequenceur(struct_processus *s_etat_proc
|
} |
} |
else |
else |
{ |
{ |
tampon_retour = (*(*s_etat_processus) |
position_courante = |
.l_base_pile_systeme).retour_definition; |
(*s_etat_processus).position_courante; |
|
empilement_pile_systeme(s_etat_processus); |
|
|
|
if ((*s_etat_processus).erreur_systeme != d_es) |
|
{ |
|
return(d_erreur); |
|
} |
|
|
(*(*s_etat_processus).l_base_pile_systeme) |
(*(*s_etat_processus).l_base_pile_systeme) |
.retour_definition = 'Y'; |
.retour_definition = 'Y'; |
|
|
Line 343 sequenceur(struct_processus *s_etat_proc
|
Line 362 sequenceur(struct_processus *s_etat_proc
|
printf("+++Error : Too few arguments\n"); |
printf("+++Error : Too few arguments\n"); |
} |
} |
|
|
(*(*s_etat_processus).l_base_pile_systeme) |
depilement_pile_systeme(s_etat_processus); |
.retour_definition = tampon_retour; |
|
|
if ((*s_etat_processus).erreur_systeme != d_es) |
|
{ |
|
return(d_erreur); |
|
} |
|
|
fflush(stdout); |
fflush(stdout); |
} |
} |
else if (evaluation(s_etat_processus, s_objet, 'I') == |
else if (evaluation(s_etat_processus, s_objet, 'I') == |
d_erreur) |
d_erreur) |
{ |
{ |
(*(*s_etat_processus).l_base_pile_systeme) |
|
.retour_definition = tampon_retour; |
|
|
|
if ((*s_etat_processus).erreur_systeme != d_es) |
if ((*s_etat_processus).erreur_systeme != d_es) |
{ |
{ |
if (test_cfsf(s_etat_processus, 51) == d_faux) |
if (test_cfsf(s_etat_processus, 51) == d_faux) |
Line 364 sequenceur(struct_processus *s_etat_proc
|
Line 384 sequenceur(struct_processus *s_etat_proc
|
if ((message = messages(s_etat_processus)) |
if ((message = messages(s_etat_processus)) |
== NULL) |
== NULL) |
{ |
{ |
|
free((*s_etat_processus) |
|
.instruction_courante); |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
printf("%s [%d]\n", message, (int) getpid()); |
printf("%s [%d]\n", message, (int) getpid()); |
free(message); |
|
|
|
|
free(message); |
|
free((*s_etat_processus).instruction_courante); |
return(d_erreur); |
return(d_erreur); |
} |
} |
else if ((*s_etat_processus) |
else if ((*s_etat_processus) |
Line 387 sequenceur(struct_processus *s_etat_proc
|
Line 410 sequenceur(struct_processus *s_etat_proc
|
if ((message = messages(s_etat_processus)) |
if ((message = messages(s_etat_processus)) |
== NULL) |
== NULL) |
{ |
{ |
|
free((*s_etat_processus) |
|
.instruction_courante); |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
Line 434 sequenceur(struct_processus *s_etat_proc
|
Line 459 sequenceur(struct_processus *s_etat_proc
|
liberation(s_etat_processus, s_objet); |
liberation(s_etat_processus, s_objet); |
} |
} |
|
|
(*(*s_etat_processus).l_base_pile_systeme) |
(*s_etat_processus).position_courante = |
.retour_definition = tampon_retour; |
position_courante; |
} |
} |
} |
} |
else if ((*s_etat_processus).invalidation_message_erreur |
else if ((*s_etat_processus).invalidation_message_erreur |
Line 452 sequenceur(struct_processus *s_etat_proc
|
Line 477 sequenceur(struct_processus *s_etat_proc
|
|
|
if ((message = messages(s_etat_processus)) == NULL) |
if ((message = messages(s_etat_processus)) == NULL) |
{ |
{ |
|
free((*s_etat_processus).instruction_courante); |
free(ligne); |
free(ligne); |
return(d_erreur); |
return(d_erreur); |
} |
} |
Line 547 sequenceur(struct_processus *s_etat_proc
|
Line 573 sequenceur(struct_processus *s_etat_proc
|
d_vrai) && ((*s_etat_processus) |
d_vrai) && ((*s_etat_processus) |
.autorisation_evaluation_nom == 'Y')) |
.autorisation_evaluation_nom == 'Y')) |
{ |
{ |
if (((*s_etat_processus).s_liste_variables |
if ((*(*s_etat_processus).pointeur_variable_courante) |
[(*s_etat_processus) |
.objet == NULL) |
.position_variable_courante]).objet == NULL) |
|
{ |
{ |
|
|
/* |
/* |
Line 564 sequenceur(struct_processus *s_etat_proc
|
Line 589 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(), |
(int) getpid(), (*s_etat_processus) |
(*s_etat_processus) |
|
.instruction_courante, |
.instruction_courante, |
(*((*s_etat_processus).s_liste_variables |
(*(*(*s_etat_processus) |
[(*s_etat_processus) |
.pointeur_variable_courante).objet) |
.position_variable_courante]).objet) |
|
.type); |
.type); |
} |
} |
else |
else |
{ |
{ |
printf("[%d] Pushing %s as %d type shared " |
printf("[%d] Pushing %s as %d type shared " |
"variable \n", (int) getpid(), |
"variable\n", (int) getpid(), |
(*s_etat_processus) |
(*s_etat_processus) |
.instruction_courante, |
.instruction_courante, |
(*((*s_etat_processus).s_liste_variables |
(*(*(*s_etat_processus) |
[(*s_etat_processus) |
.pointeur_variable_courante).objet) |
.position_variable_courante]).objet) |
|
.type); |
.type); |
} |
} |
|
|
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_liste_variables |
(*(*s_etat_processus) |
[(*s_etat_processus) |
.pointeur_variable_courante).nom, |
.position_variable_courante]).nom, |
(*(*s_etat_processus) |
((*s_etat_processus).s_liste_variables |
.pointeur_variable_courante).variable_partagee, |
[(*s_etat_processus) |
'P') != NULL) |
.position_variable_courante]) |
|
.variable_partagee, 'P') == d_vrai) |
|
{ |
{ |
// 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 622 sequenceur(struct_processus *s_etat_proc
|
Line 631 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 664 sequenceur(struct_processus *s_etat_proc
|
Line 660 sequenceur(struct_processus *s_etat_proc
|
-------------------------------------------------------------------------------- |
-------------------------------------------------------------------------------- |
*/ |
*/ |
|
|
else if ((*((*s_etat_processus).s_liste_variables |
else if ((*(*(*s_etat_processus).pointeur_variable_courante) |
[(*s_etat_processus).position_variable_courante]) |
|
.objet).type == ADR) |
.objet).type == ADR) |
{ |
{ |
|
|
Line 733 sequenceur(struct_processus *s_etat_proc
|
Line 728 sequenceur(struct_processus *s_etat_proc
|
.niveau_courant; |
.niveau_courant; |
|
|
(*s_etat_processus).position_courante = |
(*s_etat_processus).position_courante = |
(*((unsigned long *) |
(*((integer8 *) |
((*((*s_etat_processus).s_liste_variables |
((*(*(*s_etat_processus) |
[(*s_etat_processus) |
.pointeur_variable_courante) |
.position_variable_courante] |
.objet).objet))); |
.objet)).objet))); |
|
|
|
drapeau_appel_definition = d_vrai; |
drapeau_appel_definition = d_vrai; |
} |
} |
Line 750 sequenceur(struct_processus *s_etat_proc
|
Line 744 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) |
.instruction_courante, |
.instruction_courante, |
(*((*s_etat_processus).s_liste_variables |
(*(*(*s_etat_processus) |
[(*s_etat_processus) |
.pointeur_variable_courante).objet) |
.position_variable_courante]).objet) |
|
.type); |
.type); |
} |
} |
else |
else |
Line 766 sequenceur(struct_processus *s_etat_proc
|
Line 759 sequenceur(struct_processus *s_etat_proc
|
"\n", (int) getpid(), |
"\n", (int) getpid(), |
(*s_etat_processus) |
(*s_etat_processus) |
.instruction_courante, |
.instruction_courante, |
(*((*s_etat_processus).s_liste_variables |
(*(*(*s_etat_processus) |
[(*s_etat_processus) |
.pointeur_variable_courante).objet) |
.position_variable_courante]).objet) |
|
.type); |
.type); |
} |
} |
|
|
Line 776 sequenceur(struct_processus *s_etat_proc
|
Line 768 sequenceur(struct_processus *s_etat_proc
|
} |
} |
|
|
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[(*s_etat_processus) |
.pointeur_variable_courante).objet, 'P')) |
.position_variable_courante]).objet, 'P')) |
|
== NULL) |
== NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
Line 786 sequenceur(struct_processus *s_etat_proc
|
Line 777 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 812 sequenceur(struct_processus *s_etat_proc
|
Line 803 sequenceur(struct_processus *s_etat_proc
|
{ |
{ |
if ((*s_etat_processus).l_base_pile == NULL) |
if ((*s_etat_processus).l_base_pile == NULL) |
{ |
{ |
(*s_etat_processus).erreur_execution = |
if ((*s_etat_processus).erreur_execution != |
d_ex_manque_argument; |
d_ex_nom_implicite) |
|
{ |
|
(*s_etat_processus).erreur_execution = |
|
d_ex_manque_argument; |
|
} |
} |
} |
else if ((*(*(*s_etat_processus).l_base_pile).donnee) |
else if ((*(*(*s_etat_processus).l_base_pile).donnee) |
.type == NOM) |
.type == NOM) |
Line 848 sequenceur(struct_processus *s_etat_proc
|
Line 843 sequenceur(struct_processus *s_etat_proc
|
&((*s_etat_processus).l_base_pile), |
&((*s_etat_processus).l_base_pile), |
&s_objet_evaluation) == d_erreur) |
&s_objet_evaluation) == d_erreur) |
{ |
{ |
|
free((*s_etat_processus).instruction_courante); |
(*s_etat_processus).erreur_execution = |
(*s_etat_processus).erreur_execution = |
d_ex_manque_argument; |
d_ex_manque_argument; |
return(d_erreur); |
return(d_erreur); |
Line 856 sequenceur(struct_processus *s_etat_proc
|
Line 852 sequenceur(struct_processus *s_etat_proc
|
if (evaluation(s_etat_processus, s_objet_evaluation, |
if (evaluation(s_etat_processus, s_objet_evaluation, |
'N') == d_erreur) |
'N') == d_erreur) |
{ |
{ |
|
free((*s_etat_processus).instruction_courante); |
liberation(s_etat_processus, s_objet_evaluation); |
liberation(s_etat_processus, s_objet_evaluation); |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
liberation(s_etat_processus, s_objet_evaluation); |
liberation(s_etat_processus, s_objet_evaluation); |
} |
} |
|
|
|
// Le séquenceur est appelé depuis la routine de |
|
// recherche de type |
|
|
|
else if ((*s_etat_processus).recherche_type == 'Y') |
|
{ |
|
if ((*s_etat_processus).erreur_execution != d_ex) |
|
{ |
|
free((*s_etat_processus).instruction_courante); |
|
return(d_erreur); |
|
} |
|
} |
} |
} |
} |
} |
else if (((*s_etat_processus).test_instruction == 'Y') && |
else if (((*s_etat_processus).test_instruction == 'Y') && |
Line 949 sequenceur(struct_processus *s_etat_proc
|
Line 958 sequenceur(struct_processus *s_etat_proc
|
free(instruction_majuscule); |
free(instruction_majuscule); |
} |
} |
|
|
erreur |= (((*s_etat_processus).erreur_execution != d_ex) |
erreur = (logical1) (erreur | (((*s_etat_processus) |
? d_erreur : d_absence_erreur); |
.erreur_execution != d_ex) ? d_erreur : d_absence_erreur)); |
} |
} |
else |
else |
{ |
{ |
Line 969 sequenceur(struct_processus *s_etat_proc
|
Line 978 sequenceur(struct_processus *s_etat_proc
|
|
|
fflush(stdout); |
fflush(stdout); |
|
|
|
free((*s_etat_processus).instruction_courante); |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
Line 1050 sequenceur(struct_processus *s_etat_proc
|
Line 1060 sequenceur(struct_processus *s_etat_proc
|
|
|
if ((message = messages(s_etat_processus)) == NULL) |
if ((message = messages(s_etat_processus)) == NULL) |
{ |
{ |
|
free((*s_etat_processus).instruction_courante); |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
Line 1061 sequenceur(struct_processus *s_etat_proc
|
Line 1072 sequenceur(struct_processus *s_etat_proc
|
(*s_etat_processus).exception = d_ep; |
(*s_etat_processus).exception = d_ep; |
erreur = d_absence_erreur; |
erreur = d_absence_erreur; |
|
|
(*s_etat_processus).position_courante -= |
(*s_etat_processus).position_courante -= (integer8) |
strlen((*s_etat_processus).instruction_courante); |
strlen((*s_etat_processus).instruction_courante); |
} |
} |
|
|
Line 1136 sequenceur(struct_processus *s_etat_proc
|
Line 1147 sequenceur(struct_processus *s_etat_proc
|
|
|
if (erreur == d_erreur) |
if (erreur == d_erreur) |
{ |
{ |
|
free((*s_etat_processus).instruction_courante); |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
if (recherche_variable(s_etat_processus, |
if (recherche_variable(s_etat_processus, |
(*s_etat_processus).instruction_courante) == d_vrai) |
(*s_etat_processus).instruction_courante) == d_vrai) |
{ |
{ |
if (((*s_etat_processus).s_liste_variables |
if ((*(*s_etat_processus).pointeur_variable_courante) |
[(*s_etat_processus) |
.objet == NULL) |
.position_variable_courante]).objet == NULL) |
|
{ |
{ |
// Variable partagée |
// Variable partagée |
} |
} |
else if ((*((*s_etat_processus).s_liste_variables |
else if ((*(*(*s_etat_processus) |
[(*s_etat_processus) |
.pointeur_variable_courante).objet).type == ADR) |
.position_variable_courante]).objet).type == |
|
ADR) |
|
{ |
{ |
empilement_pile_systeme(s_etat_processus); |
empilement_pile_systeme(s_etat_processus); |
|
|
if ((*s_etat_processus).erreur_systeme != d_es) |
if ((*s_etat_processus).erreur_systeme != d_es) |
{ |
{ |
|
free((*s_etat_processus).instruction_courante); |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
Line 1172 sequenceur(struct_processus *s_etat_proc
|
Line 1182 sequenceur(struct_processus *s_etat_proc
|
.niveau_courant; |
.niveau_courant; |
|
|
(*s_etat_processus).position_courante = |
(*s_etat_processus).position_courante = |
(*((unsigned long *) |
(*((integer8 *) |
((*((*s_etat_processus).s_liste_variables |
((*(*(*s_etat_processus) |
[(*s_etat_processus) |
.pointeur_variable_courante) |
.position_variable_courante] |
.objet).objet))); |
.objet)).objet))); |
|
|
|
(*s_etat_processus) |
(*s_etat_processus) |
.autorisation_empilement_programme = 'N'; |
.autorisation_empilement_programme = 'N'; |
Line 1190 sequenceur(struct_processus *s_etat_proc
|
Line 1199 sequenceur(struct_processus *s_etat_proc
|
|
|
if (instruction_majuscule == NULL) |
if (instruction_majuscule == NULL) |
{ |
{ |
|
free((*s_etat_processus).instruction_courante); |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
Line 1203 sequenceur(struct_processus *s_etat_proc
|
Line 1213 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 1212 sequenceur(struct_processus *s_etat_proc
|
Line 1226 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 1244 sequenceur(struct_processus *s_etat_proc
|
Line 1273 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 1286 sequenceur(struct_processus *s_etat_proc
|
Line 1395 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 1382 sequenceur(struct_processus *s_etat_proc
|
Line 1493 sequenceur(struct_processus *s_etat_proc
|
|
|
if ((*s_etat_processus).var_volatile_processus_pere == 0) |
if ((*s_etat_processus).var_volatile_processus_pere == 0) |
{ |
{ |
kill((*s_etat_processus).pid_processus_pere, SIGALRM); |
envoi_signal_processus((*s_etat_processus).pid_processus_pere, |
|
rpl_sigalrm); |
} |
} |
else |
else |
{ |
{ |