rpl/src/sequenceur.c - diff

Return to sequenceur.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/sequenceur.c between versions 1.80 and 1.111

version 1.80, 2014/04/25 07:37:35	version 1.111, 2022/09/07 13:40:42
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.18	RPL/2 (R) version 4.1.34
Copyright (C) 1989-2014 Dr. BERTRAND Joël	Copyright (C) 1989-2021 Dr. BERTRAND Joël

This file is part of RPL/2.	This file is part of RPL/2.

Line 134 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 162 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 197 sequenceur(struct_processus *s_etat_proc	Line 205 sequenceur(struct_processus *s_etat_proc
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 216 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 226 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 265 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 295 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 539 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 583 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] Évaluation 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 (recherche_variable_partagee(s_etat_processus,	fflush(stdout);
((s_etat_processus)	}
.pointeur_variable_courante).nom,
((s_etat_processus)
.pointeur_variable_courante).variable_partagee,
'P') != NULL)
{
// 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)
Line 651 sequenceur(struct_processus *s_etat_proc	Line 673 sequenceur(struct_processus *s_etat_proc
else	else
{	{
// La variable n'existe plus.	// La variable n'existe plus.
	if ((*s_etat_processus).debug == d_vrai)
	if (((*s_etat_processus).type_debug &
	d_debug_variables) != 0)
	{
	if ((*s_etat_processus).langue == 'F')
	{
	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);
	}

	fflush(stdout);
	}
}	}
}	}

Line 716 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 797 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)
{	{
if ((*s_etat_processus).erreur_execution !=	if (((*s_etat_processus).erreur_execution !=
d_ex_nom_implicite)	d_ex_nom_implicite) &&
	((*s_etat_processus).erreur_execution !=
	d_ex_syntaxe))
{	{
(*s_etat_processus).erreur_execution =	(*s_etat_processus).erreur_execution =
d_ex_manque_argument;	d_ex_manque_argument;
Line 884 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 905 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 1195 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 1383 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 1494 sequenceur(struct_processus *s_etat_proc	Line 1547 sequenceur(struct_processus *s_etat_proc
if ((*s_etat_processus).var_volatile_processus_pere == 0)	if ((*s_etat_processus).var_volatile_processus_pere == 0)
{	{
envoi_signal_processus((*s_etat_processus).pid_processus_pere,	envoi_signal_processus((*s_etat_processus).pid_processus_pere,
rpl_sigalrm);	rpl_sigalrm, d_faux);
}	}
else	else
{	{

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.80
changed lines
	Added in v.1.111