rpl/src/interruptions.c - diff

Return to interruptions.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/interruptions.c between versions 1.44 and 1.63

version 1.44, 2010/12/10 16:08:27	version 1.63, 2011/09/03 10:31:50
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.0.20	RPL/2 (R) version 4.1.3
Copyright (C) 1989-2010 Dr. BERTRAND Joël	Copyright (C) 1989-2011 Dr. BERTRAND Joël

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

Line 803 liberation_threads(struct_processus *s_e	Line 803 liberation_threads(struct_processus *s_e
}	}
}	}

for(i = 0; i < (*s_etat_processus).nombre_variables; i++)	liberation_arbre_variables(s_etat_processus,
{	(*s_etat_processus).s_arbre_variables, d_faux);
pthread_mutex_trylock(&(((s_etat_processus)
.s_liste_variables[i].objet).mutex));
pthread_mutex_unlock(&(((s_etat_processus)
.s_liste_variables[i].objet).mutex));

// Les variables de niveau 0 sont des définitions qui
// ne sont pas copiées entre threads.
if ((*s_etat_processus).s_liste_variables[i].niveau > 0)
{
liberation(s_etat_processus,
(*s_etat_processus).s_liste_variables[i].objet);
}

free((*s_etat_processus).s_liste_variables[i].nom);
}

free((*s_etat_processus).s_liste_variables);

for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++)	for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++)
{	{
Line 1335 liberation_threads(struct_processus *s_e	Line 1318 liberation_threads(struct_processus *s_e
sem_destroy2((*s_etat_processus).semaphore_fork, sem_fork);	sem_destroy2((*s_etat_processus).semaphore_fork, sem_fork);
# endif	# endif

	liberation_contexte_cas(s_etat_processus);
free(s_etat_processus);	free(s_etat_processus);

s_etat_processus = candidat;	s_etat_processus = candidat;
Line 2007 interruption2(SIGHANDLER_ARGS)	Line 1991 interruption2(SIGHANDLER_ARGS)
void	void
interruption3(SIGHANDLER_ARGS)	interruption3(SIGHANDLER_ARGS)
{	{
pid_t pid;	pthread_t thread;

struct_processus *s_etat_processus;	struct_processus *s_etat_processus;

static int compteur = 0;

verrouillage_gestionnaire_signaux();	verrouillage_gestionnaire_signaux();

# ifdef _BROKEN_SIGINFO
pid = origine_signal(signal);
# else
pid = (*siginfo).si_pid;
# endif

if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
{	{
deverrouillage_gestionnaire_signaux();	deverrouillage_gestionnaire_signaux();
Line 2045 interruption3(SIGHANDLER_ARGS)	Line 2021 interruption3(SIGHANDLER_ARGS)
// Segfault dans une routine interne	// Segfault dans une routine interne
if (strncmp(getenv("LANG"), "fr", 2) == 0)	if (strncmp(getenv("LANG"), "fr", 2) == 0)
{	{
printf("+++Système : Violation d'accès (dépassement de pile)\n");	printf("+++Système : Violation d'accès\n");
}	}
else	else
{	{
printf("+++System : Access violation (stack overflow)\n");	printf("+++System : Access violation\n");
}	}

fflush(stdout);	fflush(stdout);

compteur++;	(*s_etat_processus).compteur_violation_d_acces++;

if (compteur > 1)	if ((*s_etat_processus).compteur_violation_d_acces > 1)
{	{
	// On vient de récupérer plus d'une erreur de segmentation
	// dans le même processus ou le même thread. L'erreur n'est pas
	// récupérable et on sort autoritairement du programme. Il peut
	// rester des processus orphelins en attente !

	if (strncmp(getenv("LANG"), "fr", 2) == 0)
	{
	printf("+++Système : Violation d'accès\n");
	}
	else
	{
	printf("+++System : Access violation\n");
	}

	fflush(stdout);

deverrouillage_gestionnaire_signaux();	deverrouillage_gestionnaire_signaux();
exit(EXIT_FAILURE);	exit(EXIT_FAILURE);
}	}
else	else
{	{
	// Première erreur de segmentation. On essaie de terminer
	// proprement le thread ou le processus. Le signal ne peut être
	// envoyé que depuis le même processus.

	if (recherche_thread_principal(getpid(), &thread) == d_vrai)
	{
	if (pthread_equal(thread, pthread_self()) != 0)
	{
	deverrouillage_gestionnaire_signaux();

	if ((*s_etat_processus).pid_processus_pere != getpid())
	{
	// On est dans le thread principal d'un processus.

	longjmp(contexte_processus, -1);
	}
	else
	{
	// On est dans le thread principal du processus
	// père.

	longjmp(contexte_initial, -1);
	}
	}
	else
	{
	// On est dans un thread fils d'un thread principal.

	deverrouillage_gestionnaire_signaux();
	longjmp(contexte_thread, -1);
	}
	}

	// Là, on ramasse les miettes puisque le thread n'existe plus
	// dans la base (corruption de la mémoire).

deverrouillage_gestionnaire_signaux();	deverrouillage_gestionnaire_signaux();
longjmp(contexte_initial, -1);	longjmp(contexte_initial, -1);
}	}
Line 2075 interruption3(SIGHANDLER_ARGS)	Line 2103 interruption3(SIGHANDLER_ARGS)
void	void
interruption4(SIGHANDLER_ARGS)	interruption4(SIGHANDLER_ARGS)
{	{
pid_t pid;

struct_processus *s_etat_processus;	struct_processus *s_etat_processus;

verrouillage_gestionnaire_signaux();	verrouillage_gestionnaire_signaux();

# ifdef _BROKEN_SIGINFO
pid = origine_signal(signal);
# else
pid = (*siginfo).si_pid;
# endif

if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
{	{
deverrouillage_gestionnaire_signaux();	deverrouillage_gestionnaire_signaux();
Line 2183 interruption5(SIGHANDLER_ARGS)	Line 2203 interruption5(SIGHANDLER_ARGS)
void	void
interruption6(SIGHANDLER_ARGS)	interruption6(SIGHANDLER_ARGS)
{	{
pid_t pid;

struct_processus *s_etat_processus;	struct_processus *s_etat_processus;

verrouillage_gestionnaire_signaux();	verrouillage_gestionnaire_signaux();

# ifdef _BROKEN_SIGINFO
pid = origine_signal(signal);
# else
pid = (*siginfo).si_pid;
# endif

if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
{	{
deverrouillage_gestionnaire_signaux();	deverrouillage_gestionnaire_signaux();
Line 2215 interruption6(SIGHANDLER_ARGS)	Line 2227 interruption6(SIGHANDLER_ARGS)
void	void
interruption7(SIGHANDLER_ARGS)	interruption7(SIGHANDLER_ARGS)
{	{
pid_t pid;

struct_processus *s_etat_processus;	struct_processus *s_etat_processus;

verrouillage_gestionnaire_signaux();	verrouillage_gestionnaire_signaux();

# ifdef _BROKEN_SIGINFO
pid = origine_signal(signal);
# else
pid = (*siginfo).si_pid;
# endif

if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
{	{
deverrouillage_gestionnaire_signaux();	deverrouillage_gestionnaire_signaux();
Line 2302 interruption8(SIGHANDLER_ARGS)	Line 2306 interruption8(SIGHANDLER_ARGS)
void	void
interruption9(SIGHANDLER_ARGS)	interruption9(SIGHANDLER_ARGS)
{	{
pid_t pid;

struct_processus *s_etat_processus;	struct_processus *s_etat_processus;

verrouillage_gestionnaire_signaux();	verrouillage_gestionnaire_signaux();

# ifdef _BROKEN_SIGINFO
pid = origine_signal(signal);
# else
pid = (*siginfo).si_pid;
# endif

if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
{	{
deverrouillage_gestionnaire_signaux();	deverrouillage_gestionnaire_signaux();
Line 2347 interruption10(SIGHANDLER_ARGS)	Line 2343 interruption10(SIGHANDLER_ARGS)
{	{
file *fichier;	file *fichier;

pid_t pid;

struct_processus *s_etat_processus;	struct_processus *s_etat_processus;

unsigned char nom[8 + 64 + 1];	unsigned char nom[8 + 64 + 1];

verrouillage_gestionnaire_signaux();	verrouillage_gestionnaire_signaux();

# ifdef _BROKEN_SIGINFO
pid = origine_signal(signal);
# else
pid = (*siginfo).si_pid;
# endif

if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)	if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
{	{
deverrouillage_gestionnaire_signaux();	deverrouillage_gestionnaire_signaux();

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.44
changed lines
	Added in v.1.63