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.34 and 1.54

version 1.34, 2010/08/06 15:32:58	version 1.54, 2011/06/22 13:26:58
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.0.18	RPL/2 (R) version 4.1.0.prerelease.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 57 decrementation_atomique(struct_objet *s_	Line 57 decrementation_atomique(struct_objet *s_
return((*s_objet).nombre_occurrences);	return((*s_objet).nombre_occurrences);
}	}

inline void	void
initialisation_objet(struct_objet *s_objet)	initialisation_objet(struct_objet *s_objet)
{	{
pthread_mutexattr_t attributs_mutex;	pthread_mutexattr_t attributs_mutex;
Line 111 initialisation_allocateur(struct_process	Line 111 initialisation_allocateur(struct_process
(*s_etat_processus).pointeur_vec = 0;	(*s_etat_processus).pointeur_vec = 0;
(*s_etat_processus).pointeur_maillons = 0;	(*s_etat_processus).pointeur_maillons = 0;

	(*s_etat_processus).pointeur_variables_noeud = 0;
	(*s_etat_processus).pointeur_variables_feuille = 0;
	(*s_etat_processus).pointeur_variables_variable = 0;
	(*s_etat_processus).pointeur_variables_tableau_noeuds = 0;

return;	return;
}	}

Line 143 liberation_allocateur(struct_processus *	Line 148 liberation_allocateur(struct_processus *
for(i = 0; i < (*s_etat_processus).pointeur_maillons;	for(i = 0; i < (*s_etat_processus).pointeur_maillons;
free((*s_etat_processus).maillons[i++]));	free((*s_etat_processus).maillons[i++]));

	for(i = 0; i < (*s_etat_processus).pointeur_variables_noeud;
	free((*s_etat_processus).variables_noeud[i++]));
	for(i = 0; i < (*s_etat_processus).pointeur_variables_feuille;
	free((*s_etat_processus).variables_feuille[i++]));
	for(i = 0; i < (*s_etat_processus).pointeur_variables_variable;
	free((*s_etat_processus).variables_variable[i++]));
	for(i = 0; i < (*s_etat_processus).pointeur_variables_tableau_noeuds;
	free((*s_etat_processus).variables_tableau_noeuds[i++]));

{	{
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 234 allocation_maillon(struct_processus *s_e	Line 248 allocation_maillon(struct_processus *s_e

/*	/*
================================================================================	================================================================================
Routine d'allocation d'un maillon d'un objet (liste, expression...)	Routine de libération d'un maillon d'un objet (liste, expression...)
================================================================================	================================================================================
Entrées : structure sur l'état du processus et objet à afficher	Entrées : structure sur l'état du processus et objet à afficher
--------------------------------------------------------------------------------	--------------------------------------------------------------------------------
Line 758 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 1127 liberation(struct_processus *s_etat_proc	Line 1144 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)) != 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 1155 liberation(struct_processus *s_etat_proc	Line 1178 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)) != 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 *)
(*s_objet).objet)).thread).mutex));	(*s_objet).objet)).thread).mutex));
	pthread_mutex_destroy(&(((((struct_processus_fils *)
	(*s_objet).objet)).thread).mutex_nombre_references));
free((((struct_processus_fils ) (*s_objet).objet)).thread);	free((((struct_processus_fils ) (*s_objet).objet)).thread);

}	}

if (decrementation_atomique(s_objet) > 0)	if (decrementation_atomique(s_objet) > 0)
Line 1497 struct_objet *	Line 1527 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 2267 copie_objet(struct_processus *s_etat_pro	Line 2300 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)) != 0)	(*s_objet).objet)).thread).mutex_nombre_references)) != 0)
{	{
	pthread_sigmask(SIG_SETMASK, &oldset, NULL);
	sigpending(&set);

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

Line 2277 copie_objet(struct_processus *s_etat_pro	Line 2316 copie_objet(struct_processus *s_etat_pro
.nombre_references++;	.nombre_references++;

if (pthread_mutex_unlock(&(((((struct_processus_fils *)	if (pthread_mutex_unlock(&(((((struct_processus_fils *)
(*s_objet).objet)).thread).mutex)) != 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 2295 copie_objet(struct_processus *s_etat_pro	Line 2340 copie_objet(struct_processus *s_etat_pro

(((struct_processus_fils ) (*s_nouvel_objet).objet)) =	(((struct_processus_fils ) (*s_nouvel_objet).objet)) =
(((struct_processus_fils ) (*s_objet).objet));	(((struct_processus_fils ) (*s_objet).objet));

break;	break;
}	}

Line 2799 copie_etat_processus(struct_processus *s	Line 2843 copie_etat_processus(struct_processus *s
# endif	# 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).fichiers_graphiques = NULL;	(*s_nouvel_etat_processus).fichiers_graphiques = NULL;
(*s_nouvel_etat_processus).entree_standard = NULL;	(*s_nouvel_etat_processus).entree_standard = NULL;
(*s_nouvel_etat_processus).s_marques = NULL;	(*s_nouvel_etat_processus).s_marques = NULL;
Line 2842 copie_etat_processus(struct_processus *s	Line 2887 copie_etat_processus(struct_processus *s

if ((*s_nouvel_etat_processus).generateur_aleatoire != NULL)	if ((*s_nouvel_etat_processus).generateur_aleatoire != NULL)
{	{
(*s_nouvel_etat_processus).generateur_aleatoire = NULL;	if (((*s_nouvel_etat_processus).generateur_aleatoire =
}	gsl_rng_clone((*s_etat_processus).generateur_aleatoire))
	== NULL)
	{
	(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
	return(NULL);
	}

(*s_nouvel_etat_processus).type_generateur_aleatoire = NULL;	gsl_rng_set((*s_nouvel_etat_processus).generateur_aleatoire,
	gsl_rng_get((*s_etat_processus).generateur_aleatoire));
	}

// Copie de la localisation	// Copie de la localisation

Line 3072 copie_etat_processus(struct_processus *s	Line 3124 copie_etat_processus(struct_processus *s
* Copie de la table des variables	* Copie de la table des variables
*/	*/

if (((*s_nouvel_etat_processus).s_liste_variables =	copie_arbre_variables(s_etat_processus, s_nouvel_etat_processus);
malloc((s_etat_processus).nombre_variables_allouees
sizeof(struct_variable))) == NULL)
{
if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
{
(*s_etat_processus).erreur_systeme = d_es_processus;
return(NULL);
}

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

for(i = 0; i < (*s_etat_processus).nombre_variables; i++)	if ((*s_nouvel_etat_processus).erreur_systeme != d_es)
{	{
if (((*s_nouvel_etat_processus).s_liste_variables[i].nom =	return(NULL);
malloc((strlen((*s_etat_processus).s_liste_variables[i].nom)
+ 1) * sizeof(unsigned char))) == NULL)
{
if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
{
(*s_etat_processus).erreur_systeme = d_es_processus;
return(NULL);
}

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

strcpy((*s_nouvel_etat_processus).s_liste_variables[i].nom,
(*s_etat_processus).s_liste_variables[i].nom);

(*s_nouvel_etat_processus).s_liste_variables[i].origine =
(*s_etat_processus).s_liste_variables[i].origine;
(*s_nouvel_etat_processus).s_liste_variables[i].niveau =
(*s_etat_processus).s_liste_variables[i].niveau;
(*s_nouvel_etat_processus).s_liste_variables[i].variable_statique =
(*s_etat_processus).s_liste_variables[i].variable_statique;
(*s_nouvel_etat_processus).s_liste_variables[i].variable_partagee =
(*s_etat_processus).s_liste_variables[i].variable_partagee;
(*s_nouvel_etat_processus).s_liste_variables[i].variable_verrouillee =
(*s_etat_processus).s_liste_variables[i].variable_verrouillee;

// Les définitions sont partagées entre tous les threads.

if ((*s_etat_processus).s_liste_variables[i].niveau == 0)
{
(*s_nouvel_etat_processus).s_liste_variables[i].objet =
(*s_etat_processus).s_liste_variables[i].objet;
}
else
{
if (((*s_nouvel_etat_processus).s_liste_variables[i].objet =
copie_objet(s_etat_processus,
(*s_etat_processus).s_liste_variables[i]
.objet, 'P')) == NULL)
{
if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
{
(*s_etat_processus).erreur_systeme = d_es_processus;
return(NULL);
}

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

/*	/*
Line 3973 debug_fork()	Line 3962 debug_fork()
pthread_mutex_lock(&mutex_allocation);	pthread_mutex_lock(&mutex_allocation);
pid = fork();	pid = fork();

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

if (pid == 0)	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.34
changed lines
	Added in v.1.54