version 1.35, 2011/06/21 15:26:35
|
version 1.107, 2019/02/11 09:45:53
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.0.prerelease.2 |
RPL/2 (R) version 4.1.31 |
Copyright (C) 1989-2011 Dr. BERTRAND Joël |
Copyright (C) 1989-2019 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 136 sequenceur(struct_processus *s_etat_proc
|
Line 134 sequenceur(struct_processus *s_etat_proc
|
*/ |
*/ |
|
|
action.sa_handler = SIG_IGN; |
action.sa_handler = SIG_IGN; |
action.sa_flags = SA_NODEFER | SA_ONSTACK; |
action.sa_flags = 0; |
|
|
(*s_etat_processus).execution_pas_suivant = d_faux; |
(*s_etat_processus).execution_pas_suivant = d_faux; |
(*s_etat_processus).traitement_instruction_halt = d_vrai; |
(*s_etat_processus).traitement_instruction_halt = d_vrai; |
Line 164 sequenceur(struct_processus *s_etat_proc
|
Line 162 sequenceur(struct_processus *s_etat_proc
|
fflush(stdout); |
fflush(stdout); |
} |
} |
|
|
|
if (pthread_mutex_lock(&mutex_sigaction) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return(d_erreur); |
|
} |
|
|
if (sigaction(SIGINT, &action, &action_defaut) != 0) |
if (sigaction(SIGINT, &action, &action_defaut) != 0) |
{ |
{ |
|
pthread_mutex_unlock(&mutex_sigaction); |
(*s_etat_processus).erreur_systeme = d_es_signal; |
(*s_etat_processus).erreur_systeme = d_es_signal; |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
if (sigaction(SIGTSTP, &action, &action_defaut2) != 0) |
if (sigaction(SIGTSTP, &action, &action_defaut2) != 0) |
{ |
{ |
|
pthread_mutex_unlock(&mutex_sigaction); |
(*s_etat_processus).erreur_systeme = d_es_signal; |
(*s_etat_processus).erreur_systeme = d_es_signal; |
return(d_erreur); |
return(d_erreur); |
} |
} |
Line 182 sequenceur(struct_processus *s_etat_proc
|
Line 188 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); |
|
|
if ((*s_etat_processus).var_volatile_requete_arret != 0) |
|
{ |
|
(*s_etat_processus).requete_arret = 'Y'; |
|
break; |
|
} |
|
|
|
if (ligne != NULL) |
if (ligne != NULL) |
{ |
{ |
if ((t_ligne = transliteration(s_etat_processus, ligne, |
if ((t_ligne = transliteration(s_etat_processus, ligne, |
(*s_etat_processus).localisation, d_locale)) |
(*s_etat_processus).localisation, d_locale)) |
== NULL) |
== NULL) |
{ |
{ |
|
pthread_mutex_unlock(&mutex_sigaction); |
free((*s_etat_processus).instruction_courante); |
free((*s_etat_processus).instruction_courante); |
return(d_erreur); |
return(d_erreur); |
} |
} |
Line 206 sequenceur(struct_processus *s_etat_proc
|
Line 219 sequenceur(struct_processus *s_etat_proc
|
free(ligne); |
free(ligne); |
ligne = t_ligne; |
ligne = t_ligne; |
|
|
if ((ligne = compactage(ligne)) == NULL) |
if ((ligne = compactage(s_etat_processus, ligne)) == NULL) |
{ |
{ |
|
pthread_mutex_unlock(&mutex_sigaction); |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
d_es_allocation_memoire; |
d_es_allocation_memoire; |
return(d_erreur); |
return(d_erreur); |
Line 216 sequenceur(struct_processus *s_etat_proc
|
Line 230 sequenceur(struct_processus *s_etat_proc
|
|
|
if (sigaction(SIGINT, &action_defaut, NULL) != 0) |
if (sigaction(SIGINT, &action_defaut, NULL) != 0) |
{ |
{ |
|
pthread_mutex_unlock(&mutex_sigaction); |
(*s_etat_processus).erreur_systeme = d_es_signal; |
(*s_etat_processus).erreur_systeme = d_es_signal; |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
if (sigaction(SIGTSTP, &action_defaut2, NULL) != 0) |
if (sigaction(SIGTSTP, &action_defaut2, NULL) != 0) |
{ |
{ |
|
pthread_mutex_unlock(&mutex_sigaction); |
(*s_etat_processus).erreur_systeme = d_es_signal; |
(*s_etat_processus).erreur_systeme = d_es_signal; |
return(d_erreur); |
return(d_erreur); |
} |
} |
|
|
|
if (pthread_mutex_unlock(&mutex_sigaction) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return(d_erreur); |
|
} |
|
|
if (ligne == NULL) |
if (ligne == NULL) |
{ |
{ |
if ((ligne = (unsigned char *) malloc(6 * |
if ((ligne = (unsigned char *) malloc(6 * |
Line 255 sequenceur(struct_processus *s_etat_proc
|
Line 277 sequenceur(struct_processus *s_etat_proc
|
sprintf(ligne, "dup"); |
sprintf(ligne, "dup"); |
} |
} |
|
|
|
if ((*s_etat_processus).var_volatile_requete_arret != 0) |
|
{ |
|
free(ligne); |
|
(*s_etat_processus).requete_arret = 'Y'; |
|
break; |
|
} |
|
|
add_history(ligne); |
add_history(ligne); |
stifle_history(ds_longueur_historique); |
stifle_history(ds_longueur_historique); |
|
|
Line 285 sequenceur(struct_processus *s_etat_proc
|
Line 314 sequenceur(struct_processus *s_etat_proc
|
tampon = (*s_etat_processus).instruction_courante; |
tampon = (*s_etat_processus).instruction_courante; |
(*s_etat_processus).instruction_courante = ligne; |
(*s_etat_processus).instruction_courante = ligne; |
|
|
|
(*s_etat_processus).type_en_cours = NON; |
recherche_type(s_etat_processus); |
recherche_type(s_etat_processus); |
|
|
(*s_etat_processus).instruction_courante = tampon; |
(*s_etat_processus).instruction_courante = tampon; |
Line 323 sequenceur(struct_processus *s_etat_proc
|
Line 353 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 345 sequenceur(struct_processus *s_etat_proc
|
Line 382 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 441 sequenceur(struct_processus *s_etat_proc
|
Line 479 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 521 sequenceur(struct_processus *s_etat_proc
|
Line 559 sequenceur(struct_processus *s_etat_proc
|
-------------------------------------------------------------------------------- |
-------------------------------------------------------------------------------- |
*/ |
*/ |
|
|
|
(*s_etat_processus).instruction_sensible = 'N'; |
|
|
analyse(s_etat_processus, NULL); |
analyse(s_etat_processus, NULL); |
|
|
if ((*s_etat_processus).traitement_cycle_exit != 'N') |
if ((*s_etat_processus).traitement_cycle_exit != 'N') |
Line 565 sequenceur(struct_processus *s_etat_proc
|
Line 605 sequenceur(struct_processus *s_etat_proc
|
-------------------------------------------------------------------------------- |
-------------------------------------------------------------------------------- |
*/ |
*/ |
|
|
if ((*s_etat_processus).debug == d_vrai) |
if (recherche_variable_partagee(s_etat_processus, |
if (((*s_etat_processus).type_debug & |
(*(*s_etat_processus) |
d_debug_variables) != 0) |
.pointeur_variable_courante).nom, |
|
(*(*s_etat_processus) |
|
.pointeur_variable_courante).variable_partagee, |
|
'P') != NULL) |
{ |
{ |
if ((*s_etat_processus).langue == 'F') |
// La variable existe. |
|
|
|
if ((*s_etat_processus).debug == d_vrai) |
|
if (((*s_etat_processus).type_debug & |
|
d_debug_variables) != 0) |
{ |
{ |
printf("[%d] Empilement de la variable " |
if ((*s_etat_processus).langue == 'F') |
|
{ |
|
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, |
(*(*(*s_etat_processus) |
(*(*(*s_etat_processus) |
.pointeur_variable_courante).objet) |
.pointeur_variable_partagee_courante) |
.type); |
.objet).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_etat_processus) |
.pointeur_variable_courante).objet) |
.pointeur_variable_partagee_courante) |
.type); |
.objet).type); |
} |
} |
|
|
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, |
fflush(stdout); |
(*(*s_etat_processus) |
} |
.pointeur_variable_courante).nom, |
|
(*(*s_etat_processus) |
|
.pointeur_variable_courante).variable_partagee, |
|
'P') == d_vrai) |
|
{ |
|
// 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 624 sequenceur(struct_processus *s_etat_proc
|
Line 653 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. |
|
if ((*s_etat_processus).debug == d_vrai) |
(*s_etat_processus).erreur_systeme = d_es; |
if (((*s_etat_processus).type_debug & |
|
d_debug_variables) != 0) |
if (pthread_mutex_unlock(&((*(*s_etat_processus) |
|
.s_liste_variables_partagees).mutex)) |
|
!= 0) |
|
{ |
{ |
(*s_etat_processus).erreur_systeme = |
if ((*s_etat_processus).langue == 'F') |
d_es_processus; |
{ |
return(d_erreur); |
printf("[%d] Tentative d'accès à la " |
} |
"variable partagée non définie %s\n", |
|
(int) getpid(), (*s_etat_processus) |
|
.instruction_courante); |
|
} |
|
else |
|
{ |
|
printf("[%d] Trying to access to undefined " |
|
"shared variable %s\n", |
|
(int) getpid(), |
|
(*s_etat_processus) |
|
.instruction_courante); |
|
} |
|
|
recherche_type(s_etat_processus); |
fflush(stdout); |
|
} |
} |
} |
} |
} |
|
|
Line 722 sequenceur(struct_processus *s_etat_proc
|
Line 760 sequenceur(struct_processus *s_etat_proc
|
} |
} |
} |
} |
|
|
|
(*s_etat_processus).debug_programme = d_faux; |
|
|
(*(*s_etat_processus).l_base_pile_systeme) |
(*(*s_etat_processus).l_base_pile_systeme) |
.adresse_retour = (*s_etat_processus) |
.adresse_retour = (*s_etat_processus) |
.position_courante; |
.position_courante; |
Line 734 sequenceur(struct_processus *s_etat_proc
|
Line 774 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_etat_processus) |
.pointeur_variable_courante) |
.pointeur_variable_courante) |
.objet).objet))); |
.objet).objet))); |
Line 750 sequenceur(struct_processus *s_etat_proc
|
Line 790 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 783 sequenceur(struct_processus *s_etat_proc
|
Line 823 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 803 sequenceur(struct_processus *s_etat_proc
|
Line 843 sequenceur(struct_processus *s_etat_proc
|
*/ |
*/ |
|
|
(*s_etat_processus).erreur_systeme = d_es; |
(*s_etat_processus).erreur_systeme = d_es; |
|
(*s_etat_processus).type_en_cours = NON; |
recherche_type(s_etat_processus); |
recherche_type(s_etat_processus); |
|
|
if ((*s_etat_processus).autorisation_nom_implicite == 'N') |
if ((*s_etat_processus).autorisation_nom_implicite == 'N') |
{ |
{ |
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_syntaxe)) |
|
{ |
|
(*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 886 sequenceur(struct_processus *s_etat_proc
|
Line 933 sequenceur(struct_processus *s_etat_proc
|
*/ |
*/ |
|
|
if ((instruction_majuscule = conversion_majuscule( |
if ((instruction_majuscule = conversion_majuscule( |
(*s_etat_processus).instruction_courante)) == NULL) |
s_etat_processus, (*s_etat_processus) |
|
.instruction_courante)) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
d_es_allocation_memoire; |
d_es_allocation_memoire; |
Line 907 sequenceur(struct_processus *s_etat_proc
|
Line 955 sequenceur(struct_processus *s_etat_proc
|
(*((struct_fonction *) (*s_objet).objet)) |
(*((struct_fonction *) (*s_objet).objet)) |
.nombre_arguments = 0; |
.nombre_arguments = 0; |
|
|
if ((*s_etat_processus).instruction_intrinseque == 'Y') |
if (((*s_etat_processus).instruction_intrinseque == 'Y') && |
|
((*s_etat_processus).instruction_sensible == 'N')) |
{ |
{ |
if (((*((struct_fonction *) (*s_objet).objet)) |
if (((*((struct_fonction *) (*s_objet).objet)) |
.nom_fonction = conversion_majuscule( |
.nom_fonction = conversion_majuscule( |
(*s_etat_processus).instruction_courante)) |
s_etat_processus, (*s_etat_processus) |
== NULL) |
.instruction_courante)) == NULL) |
{ |
{ |
(*s_etat_processus).erreur_systeme = |
(*s_etat_processus).erreur_systeme = |
d_es_allocation_memoire; |
d_es_allocation_memoire; |
Line 960 sequenceur(struct_processus *s_etat_proc
|
Line 1009 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 1074 sequenceur(struct_processus *s_etat_proc
|
Line 1123 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 1184 sequenceur(struct_processus *s_etat_proc
|
Line 1233 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_etat_processus) |
.pointeur_variable_courante) |
.pointeur_variable_courante) |
.objet).objet))); |
.objet).objet))); |
Line 1197 sequenceur(struct_processus *s_etat_proc
|
Line 1246 sequenceur(struct_processus *s_etat_proc
|
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es; |
(*s_etat_processus).erreur_systeme = d_es; |
instruction_majuscule = conversion_majuscule( |
instruction_majuscule = conversion_majuscule( |
(*s_etat_processus).instruction_courante); |
s_etat_processus, (*s_etat_processus) |
|
.instruction_courante); |
|
|
if (instruction_majuscule == NULL) |
if (instruction_majuscule == NULL) |
{ |
{ |
Line 1215 sequenceur(struct_processus *s_etat_proc
|
Line 1265 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 1224 sequenceur(struct_processus *s_etat_proc
|
Line 1278 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 1256 sequenceur(struct_processus *s_etat_proc
|
Line 1325 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 1435 sequenceur(struct_processus *s_etat_proc
|
} |
} |
|
|
instruction_majuscule = conversion_majuscule( |
instruction_majuscule = conversion_majuscule( |
|
s_etat_processus, |
(*s_etat_processus).instruction_courante); |
(*s_etat_processus).instruction_courante); |
|
|
if (instruction_majuscule == NULL) |
if (instruction_majuscule == NULL) |
Line 1298 sequenceur(struct_processus *s_etat_proc
|
Line 1448 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 1394 sequenceur(struct_processus *s_etat_proc
|
Line 1546 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, d_faux); |
} |
} |
else |
else |
{ |
{ |