rpl/src/gestion_interruptions.c - diff

Return to gestion_interruptions.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/gestion_interruptions.c between versions 1.1.1.1 and 1.70

version 1.1.1.1, 2010/01/26 15:22:45	version 1.70, 2020/01/10 11:15:42
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.0.9	RPL/2 (R) version 4.1.32
Copyright (C) 1989-2010 Dr. BERTRAND Joël	Copyright (C) 1989-2020 Dr. BERTRAND Joël

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

Line 20	Line 20
*/	*/


#include "rpl.conv.h"	#include "rpl-conv.h"


/*	/*
Line 39 void	Line 39 void
affectation_interruptions_logicielles(struct_processus *s_etat_processus)	affectation_interruptions_logicielles(struct_processus *s_etat_processus)
{	{
int interruption;	int interruption;
	int ios;

sig_atomic_t registre;	sig_atomic_t registre;

volatile struct_liste_chainee *l_element_courant;	volatile struct_liste_chainee *l_element_courant;
	struct_liste_chainee *l_element;

struct_objet *s_objet_processus;	struct_objet *s_objet_processus;

if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
{
(*s_etat_processus).erreur_systeme = d_es_processus;
return;
}

if ((*s_etat_processus).var_volatile_requete_arret == -1)	if ((*s_etat_processus).var_volatile_requete_arret == -1)
{	{
// Si une requête d'arrêt est reçue par le processus durant la	// Si une requête d'arrêt est reçue par le processus durant la
Line 59 affectation_interruptions_logicielles(st	Line 55 affectation_interruptions_logicielles(st
// processus peut déjà être libérée par le thread de surveillance.	// processus peut déjà être libérée par le thread de surveillance.

(*s_etat_processus).nombre_interruptions_non_affectees = 0;	(*s_etat_processus).nombre_interruptions_non_affectees = 0;
	return;
	}

if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)	if ((ios = pthread_mutex_trylock(&((*s_etat_processus)
	.mutex_pile_processus))) != 0)
	{
	if (ios != EBUSY)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;
}	}

return;	return;
Line 83 affectation_interruptions_logicielles(st	Line 83 affectation_interruptions_logicielles(st

if (((l_element_courant).donnee).type != PRC)	if (((l_element_courant).donnee).type != PRC)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));

(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
Line 92 affectation_interruptions_logicielles(st	Line 92 affectation_interruptions_logicielles(st
if (pthread_mutex_lock(&(((((struct_processus_fils *)	if (pthread_mutex_lock(&(((((struct_processus_fils *)
((l_element_courant).donnee).objet)).thread).mutex)) != 0)	((l_element_courant).donnee).objet)).thread).mutex)) != 0)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));

(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
Line 124 affectation_interruptions_logicielles(st	Line 124 affectation_interruptions_logicielles(st
if ((interruption < 1) \|\| (interruption >	if ((interruption < 1) \|\| (interruption >
d_NOMBRE_INTERRUPTIONS))	d_NOMBRE_INTERRUPTIONS))
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));
pthread_mutex_unlock(&(((((struct_processus_fils *)	pthread_mutex_unlock(&(((((struct_processus_fils *)
((l_element_courant).donnee).objet)).thread)	((l_element_courant).donnee).objet)).thread)
.mutex));	.mutex));
	pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus));

(*s_etat_processus).erreur_systeme =	(*s_etat_processus).erreur_systeme =
d_es_interruption_invalide;	d_es_interruption_invalide;
Line 145 affectation_interruptions_logicielles(st	Line 146 affectation_interruptions_logicielles(st
if ((s_objet_processus = copie_objet(s_etat_processus,	if ((s_objet_processus = copie_objet(s_etat_processus,
(*l_element_courant).donnee, 'P')) == NULL)	(*l_element_courant).donnee, 'P')) == NULL)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));
pthread_mutex_unlock(&(((((struct_processus_fils *)	pthread_mutex_unlock(&(((((struct_processus_fils *)
((l_element_courant).donnee).objet)).thread)	((l_element_courant).donnee).objet)).thread)
.mutex));	.mutex));
	pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus));

(*s_etat_processus).erreur_systeme =	(*s_etat_processus).erreur_systeme =
d_es_allocation_memoire;	d_es_allocation_memoire;
return;	return;
}	}

	// Pile LIFO

if (empilement(s_etat_processus, &((*s_etat_processus)	if (empilement(s_etat_processus, &((*s_etat_processus)
.pile_origine_interruptions[interruption - 1]),	.pile_origine_interruptions[interruption - 1]),
s_objet_processus) == d_erreur)	s_objet_processus) == d_erreur)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));
pthread_mutex_unlock(&(((((struct_processus_fils *)	pthread_mutex_unlock(&(((((struct_processus_fils *)
((l_element_courant).donnee).objet)).thread)	((l_element_courant).donnee).objet)).thread)
.mutex));	.mutex));

	if (pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus)) != 0)
	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}

return;	return;
}	}

(*s_etat_processus).queue_interruptions[interruption - 1]++;	(*s_etat_processus).queue_interruptions[interruption - 1]++;
(*s_etat_processus).nombre_interruptions_en_queue++;	(*s_etat_processus).nombre_interruptions_en_queue++;

	// Transformation en FIFO

	if ((*s_etat_processus).queue_interruptions
	[interruption - 1] > 1)
	{
	l_element = (*s_etat_processus)
	.pile_origine_interruptions[interruption - 1];

	while((*l_element).suivant != NULL)
	{
	l_element = (*l_element).suivant;
	}

	(l_element).suivant = (s_etat_processus)
	.pile_origine_interruptions[interruption - 1];
	(*s_etat_processus).pile_origine_interruptions
	[interruption - 1] =
	((l_element).suivant).suivant;
	((l_element).suivant).suivant = NULL;
	}

if ((*s_etat_processus).debug == d_vrai)	if ((*s_etat_processus).debug == d_vrai)
if (((*s_etat_processus).type_debug &	if (((*s_etat_processus).type_debug &
d_traitement_interruption) != 0)	d_traitement_interruption) != 0)
Line 229 affectation_interruptions_logicielles(st	Line 261 affectation_interruptions_logicielles(st
}	}
else	else
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));
pthread_mutex_unlock(&(((((struct_processus_fils *)	pthread_mutex_unlock(&(((((struct_processus_fils *)
((l_element_courant).donnee).objet)).thread).mutex));	((l_element_courant).donnee).objet)).thread).mutex));
	pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus));

if (registre == 0)	if (registre == 0)
{	{
Line 253 affectation_interruptions_logicielles(st	Line 286 affectation_interruptions_logicielles(st
if (pthread_mutex_unlock(&(((((struct_processus_fils *)	if (pthread_mutex_unlock(&(((((struct_processus_fils *)
((l_element_courant).donnee).objet)).thread).mutex)) != 0)	((l_element_courant).donnee).objet)).thread).mutex)) != 0)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));

(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
}	}
Line 262 affectation_interruptions_logicielles(st	Line 293 affectation_interruptions_logicielles(st
l_element_courant = (*l_element_courant).suivant;	l_element_courant = (*l_element_courant).suivant;
}	}

if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.1.1.1
changed lines
	Added in v.1.70