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.192 and 1.211

version 1.192, 2017/06/28 09:20:37	version 1.211, 2024/01/17 16:57:17
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.27	RPL/2 (R) version 4.1.36
Copyright (C) 1989-2017 Dr. BERTRAND Joël	Copyright (C) 1989-2024 Dr. BERTRAND Joël

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

Line 70 thread_surveillance_signaux(void *argume	Line 70 thread_surveillance_signaux(void *argume
// nécessaires dans la queue des signaux et incrémentent le sémaphore.	// nécessaires dans la queue des signaux et incrémentent le sémaphore.
// Le sémaphore est décrémenté lorsque le signal est effectivement traité.	// Le sémaphore est décrémenté lorsque le signal est effectivement traité.

int ios;
int nombre_signaux_envoyes;	int nombre_signaux_envoyes;

struct_processus *s_etat_processus;	struct_processus *s_etat_processus;
Line 93 thread_surveillance_signaux(void *argume	Line 92 thread_surveillance_signaux(void *argume

if (sem_wait(semaphore_signalisation) == 0)	if (sem_wait(semaphore_signalisation) == 0)
{	{
while((ios = sem_wait(semaphore_arret_signalisation)) != 0)	while(sem_wait(semaphore_arret_signalisation) != 0)
{	{
if (errno != EINTR)	if (errno != EINTR)
{	{
Line 117 thread_surveillance_signaux(void *argume	Line 116 thread_surveillance_signaux(void *argume
// affectée au processus courant pour vérifier s'il y a quelque	// affectée au processus courant pour vérifier s'il y a quelque
// chose à traiter.	// chose à traiter.

while((ios = sem_wait(semaphore_queue_signaux)) != 0)	while(sem_wait(semaphore_queue_signaux) != 0)
{	{
if (errno != EINTR)	if (errno != EINTR)
{	{
Line 217 modification_pid_thread_pere(struct_proc	Line 216 modification_pid_thread_pere(struct_proc
void	void
insertion_thread(struct_processus *s_etat_processus, logical1 thread_principal)	insertion_thread(struct_processus *s_etat_processus, logical1 thread_principal)
{	{
	int ios;

	struct timespec attente;

volatile struct_liste_chainee_volatile *l_nouvel_objet;	volatile struct_liste_chainee_volatile *l_nouvel_objet;

if ((l_nouvel_objet = malloc(sizeof(struct_liste_chainee_volatile)))	if ((l_nouvel_objet = malloc(sizeof(struct_liste_chainee_volatile)))
Line 239 insertion_thread(struct_processus *s_eta	Line 242 insertion_thread(struct_processus *s_eta
(((struct_thread ) (*l_nouvel_objet).donnee)).s_etat_processus =	(((struct_thread ) (*l_nouvel_objet).donnee)).s_etat_processus =
s_etat_processus;	s_etat_processus;

if (pthread_mutex_lock(&mutex_liste_threads) != 0)	attente.tv_sec = 0;
	attente.tv_nsec = GRANULARITE_us * 1000;

	while((ios = pthread_mutex_trylock(&mutex_liste_threads)) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	if (ios != EBUSY)
return;	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}

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

	nanosleep(&attente, NULL);
	INCR_GRANULARITE(attente.tv_nsec);

	while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
	{
	if (errno != EINTR)
	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}
	}
}	}

(*l_nouvel_objet).suivant = liste_threads;	(*l_nouvel_objet).suivant = liste_threads;
Line 270 insertion_thread_surveillance(struct_pro	Line 297 insertion_thread_surveillance(struct_pro
return;	return;
}	}

if (pthread_mutex_lock(&mutex_liste_threads) != 0)	if (pthread_mutex_lock(&mutex_liste_threads_surveillance) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
Line 285 insertion_thread_surveillance(struct_pro	Line 312 insertion_thread_surveillance(struct_pro

liste_threads_surveillance = l_nouvel_objet;	liste_threads_surveillance = l_nouvel_objet;

if (pthread_mutex_unlock(&mutex_liste_threads) != 0)	if (pthread_mutex_unlock(&mutex_liste_threads_surveillance) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
Line 297 insertion_thread_surveillance(struct_pro	Line 324 insertion_thread_surveillance(struct_pro
void	void
retrait_thread(struct_processus *s_etat_processus)	retrait_thread(struct_processus *s_etat_processus)
{	{
	int ios;

	struct timespec attente;

volatile struct_liste_chainee_volatile *l_element_precedent;	volatile struct_liste_chainee_volatile *l_element_precedent;
volatile struct_liste_chainee_volatile *l_element_courant;	volatile struct_liste_chainee_volatile *l_element_courant;

if (pthread_mutex_lock(&mutex_liste_threads) != 0)	attente.tv_sec = 0;
	attente.tv_nsec = GRANULARITE_us * 1000;

	while((ios = pthread_mutex_trylock(&mutex_liste_threads)) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	if (ios != EBUSY)
return;	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}

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

	nanosleep(&attente, NULL);
	INCR_GRANULARITE(attente.tv_nsec);

	while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
	{
	if (errno != EINTR)
	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}
	}
}	}

l_element_precedent = NULL;	l_element_precedent = NULL;
Line 380 retrait_thread_surveillance(struct_proce	Line 435 retrait_thread_surveillance(struct_proce
volatile struct_liste_chainee_volatile *l_element_precedent;	volatile struct_liste_chainee_volatile *l_element_precedent;
volatile struct_liste_chainee_volatile *l_element_courant;	volatile struct_liste_chainee_volatile *l_element_courant;

if (pthread_mutex_lock(&mutex_liste_threads) != 0)	if (pthread_mutex_lock(&mutex_liste_threads_surveillance) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
Line 402 retrait_thread_surveillance(struct_proce	Line 457 retrait_thread_surveillance(struct_proce

if (l_element_courant == NULL)	if (l_element_courant == NULL)
{	{
pthread_mutex_unlock(&mutex_liste_threads);	pthread_mutex_unlock(&mutex_liste_threads_surveillance);
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
}	}
Line 419 retrait_thread_surveillance(struct_proce	Line 474 retrait_thread_surveillance(struct_proce
if (pthread_mutex_lock(&((*s_argument_thread).mutex_nombre_references))	if (pthread_mutex_lock(&((*s_argument_thread).mutex_nombre_references))
!= 0)	!= 0)
{	{
pthread_mutex_unlock(&mutex_liste_threads);	pthread_mutex_unlock(&mutex_liste_threads_surveillance);
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
}	}
Line 435 retrait_thread_surveillance(struct_proce	Line 490 retrait_thread_surveillance(struct_proce
if (pthread_mutex_unlock(&((*s_argument_thread)	if (pthread_mutex_unlock(&((*s_argument_thread)
.mutex_nombre_references)) != 0)	.mutex_nombre_references)) != 0)
{	{
pthread_mutex_unlock(&mutex_liste_threads);	pthread_mutex_unlock(&mutex_liste_threads_surveillance);
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
}	}
Line 449 retrait_thread_surveillance(struct_proce	Line 504 retrait_thread_surveillance(struct_proce
if (pthread_mutex_unlock(&((*s_argument_thread)	if (pthread_mutex_unlock(&((*s_argument_thread)
.mutex_nombre_references)) != 0)	.mutex_nombre_references)) != 0)
{	{
pthread_mutex_unlock(&mutex_liste_threads);	pthread_mutex_unlock(&mutex_liste_threads_surveillance);
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
}	}
}	}

if (pthread_mutex_unlock(&mutex_liste_threads) != 0)	if (pthread_mutex_unlock(&mutex_liste_threads_surveillance) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
Line 468 retrait_thread_surveillance(struct_proce	Line 523 retrait_thread_surveillance(struct_proce
void	void
verrouillage_threads_concurrents(struct_processus *s_etat_processus)	verrouillage_threads_concurrents(struct_processus *s_etat_processus)
{	{
	int ios;

	struct timespec attente;

volatile struct_liste_chainee_volatile *l_element_courant;	volatile struct_liste_chainee_volatile *l_element_courant;

if (pthread_mutex_lock(&mutex_liste_threads) != 0)	attente.tv_sec = 0;
	attente.tv_nsec = GRANULARITE_us * 1000;

	while((ios = pthread_mutex_trylock(&mutex_liste_threads)) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	if (ios != EBUSY)
return;	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}

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

	nanosleep(&attente, NULL);
	INCR_GRANULARITE(attente.tv_nsec);

	while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
	{
	if (errno != EINTR)
	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}
	}
}	}

l_element_courant = liste_threads;	l_element_courant = liste_threads;
Line 492 verrouillage_threads_concurrents(struct_	Line 575 verrouillage_threads_concurrents(struct_
.donnee)).s_etat_processus).semaphore_fork) == -1)	.donnee)).s_etat_processus).semaphore_fork) == -1)
# endif	# endif
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	if (errno != EINTR)
return;	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}
}	}
}	}

Line 1294 liberation_threads(struct_processus *s_e	Line 1380 liberation_threads(struct_processus *s_e

liste_threads = NULL;	liste_threads = NULL;

	if (pthread_mutex_unlock(&mutex_liste_threads) == -1)
	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}

	if (pthread_mutex_lock(&mutex_liste_threads_surveillance) == -1)
	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}

l_element_courant = liste_threads_surveillance;	l_element_courant = liste_threads_surveillance;

while(l_element_courant != NULL)	while(l_element_courant != NULL)
Line 1305 liberation_threads(struct_processus *s_e	Line 1403 liberation_threads(struct_processus *s_e
!= 0)	!= 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
pthread_mutex_unlock(&mutex_liste_threads);	pthread_mutex_unlock(&mutex_liste_threads_surveillance);
return;	return;
}	}

Line 1328 liberation_threads(struct_processus *s_e	Line 1426 liberation_threads(struct_processus *s_e
.mutex_nombre_references)) != 0)	.mutex_nombre_references)) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
pthread_mutex_unlock(&mutex_liste_threads);	pthread_mutex_unlock(&mutex_liste_threads_surveillance);
return;	return;
}	}

Line 1352 liberation_threads(struct_processus *s_e	Line 1450 liberation_threads(struct_processus *s_e
.mutex_nombre_references)) != 0)	.mutex_nombre_references)) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
pthread_mutex_unlock(&mutex_liste_threads);	pthread_mutex_unlock(&mutex_liste_threads_surveillance);
return;	return;
}	}
}	}
Line 1364 liberation_threads(struct_processus *s_e	Line 1462 liberation_threads(struct_processus *s_e

liste_threads_surveillance = NULL;	liste_threads_surveillance = NULL;

if (pthread_mutex_unlock(&mutex_liste_threads) != 0)	if (pthread_mutex_unlock(&mutex_liste_threads_surveillance) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
Line 1472 recherche_thread_principal(pid_t pid)	Line 1570 recherche_thread_principal(pid_t pid)
static inline void	static inline void
verrouillage_gestionnaire_signaux(struct_processus *s_etat_processus)	verrouillage_gestionnaire_signaux(struct_processus *s_etat_processus)
{	{
	return;

# ifndef SEMAPHORES_NOMMES	# ifndef SEMAPHORES_NOMMES
if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)	if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
# else	# else
Line 1488 verrouillage_gestionnaire_signaux(struct	Line 1588 verrouillage_gestionnaire_signaux(struct
static inline void	static inline void
deverrouillage_gestionnaire_signaux(struct_processus *s_etat_processus)	deverrouillage_gestionnaire_signaux(struct_processus *s_etat_processus)
{	{
	return;

# ifndef SEMAPHORES_NOMMES	# ifndef SEMAPHORES_NOMMES
while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)	while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
# else	# else
Line 1902 inline static void	Line 2004 inline static void
signal_int(struct_processus *s_etat_processus, pid_t pid)	signal_int(struct_processus *s_etat_processus, pid_t pid)
{	{
struct_processus *s_thread_principal;	struct_processus *s_thread_principal;
volatile sig_atomic_t exclusion = 0;	pthread_mutex_t exclusion = PTHREAD_MUTEX_INITIALIZER;

verrouillage_gestionnaire_signaux(s_etat_processus);	verrouillage_gestionnaire_signaux(s_etat_processus);

Line 1924 signal_int(struct_processus *s_etat_proc	Line 2026 signal_int(struct_processus *s_etat_proc
{	{
(*s_etat_processus).var_volatile_traitement_sigint = -1;	(*s_etat_processus).var_volatile_traitement_sigint = -1;

while(exclusion == 1);	pthread_mutex_lock(&exclusion);
exclusion = 1;

if ((*s_etat_processus).var_volatile_requete_arret == -1)	if ((*s_etat_processus).var_volatile_requete_arret == -1)
{	{
deverrouillage_gestionnaire_signaux(s_etat_processus);	deverrouillage_gestionnaire_signaux(s_etat_processus);
exclusion = 0;	pthread_mutex_unlock(&exclusion);
return;	return;
}	}

Line 1948 signal_int(struct_processus *s_etat_proc	Line 2049 signal_int(struct_processus *s_etat_proc
(*s_etat_processus).var_volatile_requete_arret = -1;	(*s_etat_processus).var_volatile_requete_arret = -1;
(*s_etat_processus).var_volatile_alarme = -1;	(*s_etat_processus).var_volatile_alarme = -1;

exclusion = 0;	pthread_mutex_unlock(&exclusion);
}	}
}	}
else	else
Line 2489 scrutation_interruptions(struct_processu	Line 2590 scrutation_interruptions(struct_processu
// Il y a un signal en attente dans le segment partagé. On le	// Il y a un signal en attente dans le segment partagé. On le
// traite.	// traite.

	if (pthread_mutex_lock(&mutex_liste_threads) != 0)
	{
	return;
	}

envoi_interruptions(s_etat_processus,	envoi_interruptions(s_etat_processus,
(s_queue_signaux).queue[(s_queue_signaux)	(s_queue_signaux).queue[(s_queue_signaux)
.pointeur_lecture].signal, (*s_queue_signaux).queue	.pointeur_lecture].signal, (*s_queue_signaux).queue
Line 2507 scrutation_interruptions(struct_processu	Line 2613 scrutation_interruptions(struct_processu
}	}
# endif	# endif

	if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
	{
	return;
	}

while(sem_wait(semaphore_signalisation) != 0)	while(sem_wait(semaphore_signalisation) != 0)
{	{
if (errno != EINTR)	if (errno != EINTR)
Line 3103 envoi_signal_processus(pid_t pid, enum s	Line 3214 envoi_signal_processus(pid_t pid, enum s
}	}

int	int
envoi_signal_thread(pthread_t tid, enum signaux_rpl signal)	envoi_signal_thread(struct_processus *s_contexte,
	pthread_t tid, enum signaux_rpl signal)
{	{
// Un signal est envoyé d'un thread à un autre thread du même processus.	// Un signal est envoyé d'un thread à un autre thread du même processus.

	int ios;

	struct timespec attente;

volatile struct_liste_chainee_volatile *l_element_courant;	volatile struct_liste_chainee_volatile *l_element_courant;

struct_processus *s_etat_processus;	struct_processus *s_etat_processus;

if (pthread_mutex_lock(&mutex_liste_threads) != 0)	if (s_contexte != NULL)
{	{
return(1);	attente.tv_sec = 0;
	attente.tv_nsec = GRANULARITE_us * 1000;

	while((ios = pthread_mutex_trylock(&mutex_liste_threads)) != 0)
	{
	if (ios != EBUSY)
	{
	return(1);
	}

	if (sem_post(&((*s_contexte).semaphore_fork)) != 0)
	{
	return(1);
	}

	nanosleep(&attente, NULL);
	INCR_GRANULARITE(attente.tv_nsec);

	while(sem_wait(&((*s_contexte).semaphore_fork)) != 0)
	{
	if (errno != EINTR)
	{
	return(1);
	}
	}
	}
	}
	else
	{
	if (pthread_mutex_lock(&mutex_liste_threads) != 0)
	{
	return(1);
	}
}	}

l_element_courant = liste_threads;	l_element_courant = liste_threads;
Line 3181 envoi_signal_contexte(struct_processus *	Line 3329 envoi_signal_contexte(struct_processus *
(*s_etat_processus_a_signaler).pointeur_signal_ecriture =	(*s_etat_processus_a_signaler).pointeur_signal_ecriture =
((*s_etat_processus_a_signaler).pointeur_signal_ecriture + 1)	((*s_etat_processus_a_signaler).pointeur_signal_ecriture + 1)
% LONGUEUR_QUEUE_SIGNAUX;	% LONGUEUR_QUEUE_SIGNAUX;
	pthread_kill((*s_etat_processus_a_signaler).tid, SIGUSR2);
pthread_mutex_unlock(&((*s_etat_processus_a_signaler).mutex_signaux));	pthread_mutex_unlock(&((*s_etat_processus_a_signaler).mutex_signaux));

if (sem_post(semaphore_signalisation) != 0)	if (sem_post(semaphore_signalisation) != 0)
Line 3212 creation_queue_signaux(struct_processus	Line 3361 creation_queue_signaux(struct_processus

unsigned char *nom;	unsigned char *nom;

if (lancement_thread_signaux(s_etat_processus) == d_erreur)
{
(*s_etat_processus).erreur_systeme = d_es_processus;
return;
}

racine_segment = (*s_etat_processus).chemin_fichiers_temporaires;	racine_segment = (*s_etat_processus).chemin_fichiers_temporaires;

# ifndef IPCS_SYSV // POSIX	# ifndef IPCS_SYSV // POSIX
Line 3413 creation_queue_signaux(struct_processus	Line 3556 creation_queue_signaux(struct_processus

sys_free(nom);	sys_free(nom);

sem_init(&((*s_queue_signaux).semaphore), 1, 1);	if (sem_init(&((*s_queue_signaux).semaphore), 1, 1) != 0)
sem_init(&((*s_queue_signaux).signalisation), 1, 0);	{
sem_init(&((*s_queue_signaux).arret_signalisation), 1, 1);	(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
	return;
	}

	if (sem_init(&((*s_queue_signaux).signalisation), 1, 0) != 0)
	{
	(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
	return;
	}

	if (sem_init(&((*s_queue_signaux).arret_signalisation), 1, 1) != 0)
	{
	(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
	return;
	}

(*s_queue_signaux).pointeur_lecture = 0;	(*s_queue_signaux).pointeur_lecture = 0;
(*s_queue_signaux).pointeur_ecriture = 0;	(*s_queue_signaux).pointeur_ecriture = 0;
Line 3423 creation_queue_signaux(struct_processus	Line 3580 creation_queue_signaux(struct_processus
# endif	# endif
# endif	# endif

	(*s_queue_signaux).controle = getpid();

	if (lancement_thread_signaux(s_etat_processus) == d_erreur)
	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}

// Lancement du thread de récupération des signaux.	// Lancement du thread de récupération des signaux.

if (pthread_attr_init(&attributs) != 0)	if (pthread_attr_init(&attributs) != 0)
Line 3438 creation_queue_signaux(struct_processus	Line 3603 creation_queue_signaux(struct_processus
return;	return;
}	}

(*s_queue_signaux).controle = getpid();

if (pthread_create(&((*s_queue_signaux).thread_signaux), &attributs,	if (pthread_create(&((*s_queue_signaux).thread_signaux), &attributs,
thread_surveillance_signaux, s_etat_processus) != 0)	thread_surveillance_signaux, s_etat_processus) != 0)
{	{
Line 3460 creation_queue_signaux(struct_processus	Line 3623 creation_queue_signaux(struct_processus
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
}	}
# endif	# endif

return;	return;
}	}
Line 3565 destruction_queue_signaux(struct_process	Line 3728 destruction_queue_signaux(struct_process
return;	return;
}	}

	arret_thread_signaux(s_etat_processus);

# ifdef IPCS_SYSV // SystemV	# ifdef IPCS_SYSV // SystemV
# ifndef OS2	# ifndef OS2
// Il faut commencer par éliminer le sémaphore.	// Il faut commencer par éliminer le sémaphore.
Line 3663 destruction_queue_signaux(struct_process	Line 3828 destruction_queue_signaux(struct_process
sys_free(nom);	sys_free(nom);
# endif	# endif

arret_thread_signaux(s_etat_processus);
return;	return;
}	}

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.192
changed lines
	Added in v.1.211