rpl/src/gestion_objets.c - diff

Return to gestion_objets.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/gestion_objets.c between versions 1.55 and 1.72

version 1.55, 2011/06/24 15:59:06	version 1.72, 2011/09/21 09:09:22
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.0.prerelease.3	RPL/2 (R) version 4.1.3
Copyright (C) 1989-2011 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 772 liberation(struct_processus *s_etat_proc	Line 772 liberation(struct_processus *s_etat_proc
{	{
logical1 drapeau;	logical1 drapeau;

sigset_t oldset;
sigset_t set;

struct_liste_chainee *l_element_courant;	struct_liste_chainee *l_element_courant;
struct_liste_chainee *l_element_suivant;	struct_liste_chainee *l_element_suivant;

Line 1144 liberation(struct_processus *s_etat_proc	Line 1141 liberation(struct_processus *s_etat_proc

case PRC :	case PRC :
{	{
sigfillset(&set);
pthread_sigmask(SIG_BLOCK, &set, &oldset);

if (pthread_mutex_lock(&(((((struct_processus_fils *)	if (pthread_mutex_lock(&(((((struct_processus_fils *)
(*s_objet).objet)).thread).mutex_nombre_references)) != 0)	(*s_objet).objet)).thread).mutex_nombre_references)) != 0)
{	{
pthread_sigmask(SIG_SETMASK, &oldset, NULL);
sigpending(&set);

(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
}	}
Line 1180 liberation(struct_processus *s_etat_proc	Line 1171 liberation(struct_processus *s_etat_proc
if (pthread_mutex_unlock(&(((((struct_processus_fils *)	if (pthread_mutex_unlock(&(((((struct_processus_fils *)
(*s_objet).objet)).thread).mutex_nombre_references)) != 0)	(*s_objet).objet)).thread).mutex_nombre_references)) != 0)
{	{
pthread_sigmask(SIG_SETMASK, &oldset, NULL);
sigpending(&set);

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

pthread_sigmask(SIG_SETMASK, &oldset, NULL);
sigpending(&set);

if (drapeau == d_vrai)	if (drapeau == d_vrai)
{	{
pthread_mutex_destroy(&(((((struct_processus_fils *)	pthread_mutex_destroy(&(((((struct_processus_fils *)
Line 1527 struct_objet *	Line 1512 struct_objet *
copie_objet(struct_processus *s_etat_processus,	copie_objet(struct_processus *s_etat_processus,
struct_objet *s_objet, unsigned char type)	struct_objet *s_objet, unsigned char type)
{	{
sigset_t oldset;
sigset_t set;

struct_liste_chainee *l_element_base;	struct_liste_chainee *l_element_base;
struct_liste_chainee *l_element_courant;	struct_liste_chainee *l_element_courant;
struct_liste_chainee *l_element_courant_ecriture;	struct_liste_chainee *l_element_courant_ecriture;
Line 2300 copie_objet(struct_processus *s_etat_pro	Line 2282 copie_objet(struct_processus *s_etat_pro

case PRC :	case PRC :
{	{
sigfillset(&set);
pthread_sigmask(SIG_BLOCK, &set, &oldset);

if (pthread_mutex_lock(&(((((struct_processus_fils *)	if (pthread_mutex_lock(&(((((struct_processus_fils *)
(*s_objet).objet)).thread).mutex_nombre_references)) != 0)	(*s_objet).objet)).thread).mutex_nombre_references)) != 0)
{	{
pthread_sigmask(SIG_SETMASK, &oldset, NULL);
sigpending(&set);

return(NULL);	return(NULL);
}	}

Line 2318 copie_objet(struct_processus *s_etat_pro	Line 2294 copie_objet(struct_processus *s_etat_pro
if (pthread_mutex_unlock(&(((((struct_processus_fils *)	if (pthread_mutex_unlock(&(((((struct_processus_fils *)
(*s_objet).objet)).thread).mutex_nombre_references)) != 0)	(*s_objet).objet)).thread).mutex_nombre_references)) != 0)
{	{
pthread_sigmask(SIG_SETMASK, &oldset, NULL);
sigpending(&set);

return(NULL);	return(NULL);
}	}

pthread_sigmask(SIG_SETMASK, &oldset, NULL);
sigpending(&set);

if (type != 'O')	if (type != 'O')
{	{
incrementation_atomique(s_objet);	incrementation_atomique(s_objet);
Line 2831 copie_etat_processus(struct_processus *s	Line 2801 copie_etat_processus(struct_processus *s
* n'ont aucune raison de changer.	* n'ont aucune raison de changer.
*/	*/

# ifndef SEMAPHORES_NOMMES	pthread_mutexattr_init(&attributs_mutex);
sem_init(&((*s_nouvel_etat_processus).semaphore_fork), 0, 0);	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
# else
if (((*s_nouvel_etat_processus).semaphore_fork = sem_init2(0, sem_fork))	// Les sémaphores sont initialisés dans le nouveau thread. Il
== SEM_FAILED)	// s'agit d'une limitation de l'implantation de l'émulation
{	// de sem_init().
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
return(NULL);	initialisation_contexte_cas(s_etat_processus);
}
# endif

(*s_nouvel_etat_processus).var_volatile_processus_pere = 0;	(*s_nouvel_etat_processus).var_volatile_processus_pere = 0;
(*s_nouvel_etat_processus).var_volatile_processus_racine = 0;	(*s_nouvel_etat_processus).var_volatile_processus_racine = 0;
Line 3298 copie_etat_processus(struct_processus *s	Line 3266 copie_etat_processus(struct_processus *s
* Copie des différents contextes	* Copie des différents contextes
*/	*/

	(*s_nouvel_etat_processus).pointeur_signal_lecture = d_faux;
	(*s_nouvel_etat_processus).pointeur_signal_ecriture = d_faux;

(*s_nouvel_etat_processus).l_base_pile_contextes = NULL;	(*s_nouvel_etat_processus).l_base_pile_contextes = NULL;
l_element_lecture = (*s_etat_processus).l_base_pile_contextes;	l_element_lecture = (*s_etat_processus).l_base_pile_contextes;

Line 3962 debug_fork()	Line 3933 debug_fork()
pthread_mutex_lock(&mutex_allocation);	pthread_mutex_lock(&mutex_allocation);
pid = fork();	pid = fork();

# ifdef OS2
if (pid == 0)	if (pid == 0)
{	{
sem_init(&semaphore_liste_threads, 0, 1);	liberation_queue_signaux(s_etat_processus);
sem_init(&semaphore_gestionnaires_signaux, 0, 0);	creation_queue_signaux(s_etat_processus);
sem_init(&semaphore_gestionnaires_signaux_atomique, 0, 1);
sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
}
# endif

if (pid == 0)
{
# ifdef _BROKEN_SIGINFO
liberation_fifos_signaux(s_etat_processus);
creation_fifos_signaux(s_etat_processus);
# endif

pthread_mutex_destroy(&mutex_allocation);	pthread_mutex_destroy(&mutex_allocation);
debug_memoire_initialisation();	debug_memoire_initialisation();

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.55
changed lines
	Added in v.1.72