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.23 and 1.29

version 1.23, 2010/06/04 07:48:19	version 1.29, 2010/06/24 10:10:41
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.0.16	RPL/2 (R) version 4.0.17
Copyright (C) 1989-2010 Dr. BERTRAND Joël	Copyright (C) 1989-2010 Dr. BERTRAND Joël

This file is part of RPL/2.	This file is part of RPL/2.
Line 266 liberation_maillon(struct_processus *s_e	Line 266 liberation_maillon(struct_processus *s_e
================================================================================	================================================================================
Routine d'allocation d'une structure *s_objet	Routine d'allocation d'une structure *s_objet
================================================================================	================================================================================
Entrées : structure sur l'état du processus et objet à afficher	Entrées : structure sur l'état du processus et objet à allouer
--------------------------------------------------------------------------------	--------------------------------------------------------------------------------
Sorties : chaine de caractères	Sorties : chaine de caractères
--------------------------------------------------------------------------------	--------------------------------------------------------------------------------
Line 279 allocation(struct_processus *s_etat_proc	Line 279 allocation(struct_processus *s_etat_proc
{	{
struct_objet *s_objet;	struct_objet *s_objet;

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

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

// Il n'existe aucune structure struct_objet disponible dans le cache.	// Il n'existe aucune structure struct_objet disponible dans le cache.

if ((s_objet = malloc(sizeof(struct_objet))) == NULL)	if ((s_objet = malloc(sizeof(struct_objet))) == NULL)
Line 299 allocation(struct_processus *s_etat_proc	Line 311 allocation(struct_processus *s_etat_proc
(*s_etat_processus).taille_pile_objets--;	(*s_etat_processus).taille_pile_objets--;

(*s_objet).nombre_occurrences = 1;	(*s_objet).nombre_occurrences = 1;

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

(*s_objet).type = type;	(*s_objet).type = type;
Line 1104 liberation(struct_processus *s_etat_proc	Line 1122 liberation(struct_processus *s_etat_proc
return;	return;
}	}

free(s_objet);
break;	break;
}	}

Line 1121 liberation(struct_processus *s_etat_proc	Line 1138 liberation(struct_processus *s_etat_proc
.nombre_references--;	.nombre_references--;

BUG(((((struct_processus_fils ) (s_objet).objet)).thread)	BUG(((((struct_processus_fils ) (s_objet).objet)).thread)
.nombre_references < 0, printf("((((struct_processus_fils"	.nombre_references < 0, uprintf(
	"((((struct_processus_fils"
" ) (s_objet).objet)).thread).nombre_references = %d\n",	" ) (s_objet).objet)).thread).nombre_references = %d\n",
(int) ((((struct_processus_fils ) (s_objet).objet))	(int) ((((struct_processus_fils ) (s_objet).objet))
.thread).nombre_references));	.thread).nombre_references));

printf("liberation : %d\n", ((((struct_processus_fils ) (s_objet).objet)).thread).nombre_references);
if (((((struct_processus_fils ) (s_objet).objet)).thread)	if (((((struct_processus_fils ) (s_objet).objet)).thread)
.nombre_references == 0)	.nombre_references == 0)
{	{
Line 1149 printf("liberation : %d\n", ((((struct	Line 1166 printf("liberation : %d\n", ((((struct
pthread_mutex_destroy(&(((((struct_processus_fils *)	pthread_mutex_destroy(&(((((struct_processus_fils *)
(*s_objet).objet)).thread).mutex));	(*s_objet).objet)).thread).mutex));
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)
{	{
	BUG(drapeau == d_vrai, uprintf("((((struct_processus_fils"
	" ) (s_objet).objet)).thread).nombre_references "
	"= 0 with nombre_occurrences > 0\n"));
return;	return;
}	}

Line 1417 printf("liberation : %d\n", ((((struct	Line 1438 printf("liberation : %d\n", ((((struct
return;	return;
}	}

if (s_etat_processus != NULL)	if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation)) != 0)
{	{
if ((*s_etat_processus).taille_pile_objets < TAILLE_CACHE)	(*s_etat_processus).erreur_systeme = d_es_processus;
{	return;
(s_objet).objet = (s_etat_processus).pile_objets;	}
(*s_etat_processus).pile_objets = s_objet;
(*s_etat_processus).taille_pile_objets++;
}
else
{
if (pthread_mutex_destroy(&((*s_objet).mutex)) != 0)
{
(*s_etat_processus).erreur_systeme = d_es_processus;
return;
}

free(s_objet);	if ((*s_etat_processus).taille_pile_objets < TAILLE_CACHE)
}	{
	(s_objet).objet = (s_etat_processus).pile_objets;
	(*s_etat_processus).pile_objets = s_objet;
	(*s_etat_processus).taille_pile_objets++;
}	}
else	else
{	{
	if (pthread_mutex_destroy(&((*s_objet).mutex)) != 0)
	{
	pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation));
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}

free(s_objet);	free(s_objet);
}	}

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

return;	return;
}	}

Line 2248 copie_objet(struct_processus *s_etat_pro	Line 2275 copie_objet(struct_processus *s_etat_pro

((((struct_processus_fils ) (s_objet).objet)).thread)	((((struct_processus_fils ) (s_objet).objet)).thread)
.nombre_references++;	.nombre_references++;
printf("<2> +1 %d\n", ((((struct_processus_fils ) (s_objet).objet)).thread).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)) != 0)
Line 2269 printf("<2> +1 %d\n", ((((struct_proce	Line 2295 printf("<2> +1 %d\n", ((((struct_proce

(((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 3538 copie_etat_processus(struct_processus *s	Line 3565 copie_etat_processus(struct_processus *s
pthread_mutex_init(&((*s_nouvel_etat_processus).mutex), &attributs_mutex);	pthread_mutex_init(&((*s_nouvel_etat_processus).mutex), &attributs_mutex);
pthread_mutexattr_destroy(&attributs_mutex);	pthread_mutexattr_destroy(&attributs_mutex);

	pthread_mutexattr_init(&attributs_mutex);
	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
	pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_allocation),
	&attributs_mutex);
	pthread_mutexattr_destroy(&attributs_mutex);

if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)	if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
Line 3716 debug_memoire_modification(void *pointeu	Line 3749 debug_memoire_modification(void *pointeu
{	{
pthread_mutex_unlock(&mutex_allocation);	pthread_mutex_unlock(&mutex_allocation);

uprintf("[%d-%llu] ILLEGAL POINTER\n",	uprintf("[%d-%llu] ILLEGAL POINTER (realloc)\n",
getpid(), (unsigned long long) pthread_self());	getpid(), (unsigned long long) pthread_self());
# ifdef __BACKTRACE	# ifdef __BACKTRACE
BACKTRACE(PROFONDEUR_PILE);	BACKTRACE(PROFONDEUR_PILE);
Line 3813 debug_memoire_retrait(void *pointeur)	Line 3846 debug_memoire_retrait(void *pointeur)

if (element_courant == NULL)	if (element_courant == NULL)
{	{
uprintf("[%d-%llu] ILLEGAL POINTER\n",	uprintf("[%d-%llu] ILLEGAL POINTER (free)\n",
getpid(), (unsigned long long) pthread_self());	getpid(), (unsigned long long) pthread_self());
# ifdef __BACKTRACE	# ifdef __BACKTRACE
BACKTRACE(PROFONDEUR_PILE);	BACKTRACE(PROFONDEUR_PILE);

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.23
changed lines
	Added in v.1.29