--- rpl/src/allocateur.c	2015/01/27 15:41:25	1.4
+++ rpl/src/allocateur.c	2015/02/01 09:47:18	1.6
@@ -186,20 +186,20 @@ initialisation_allocateur_buffer(struct_
 		{
 			longueur_tailles++;
 		}
+	}
 
-		if (((*s_etat_processus).cache_buffer = sys_malloc(((size_t)
-				longueur_tailles) * sizeof(unsigned char **))) == NULL)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
-			return;
-		}
+	if (((*s_etat_processus).cache_buffer = sys_malloc(((size_t)
+			longueur_tailles) * sizeof(unsigned char **))) == NULL)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
+		return;
+	}
 
-		if (((*s_etat_processus).pointeur_cache_buffer = sys_malloc(((size_t)
-				longueur_tailles) * sizeof(int))) == NULL)
-		{
-			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
-			return;
-		}
+	if (((*s_etat_processus).pointeur_cache_buffer = sys_malloc(((size_t)
+			longueur_tailles) * sizeof(int))) == NULL)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
+		return;
 	}
 
 	for(i = 0; i < longueur_tailles; i++)
@@ -238,6 +238,8 @@ liberation_allocateur_buffer(struct_proc
 	int							i;
 	int							j;
 
+uprintf("Libération de l'allocateur des buffers\n");
+BACKTRACE(10);
 	for(i = 0; i < longueur_tailles; i++)
 	{
 		for(j = 0; j < (*s_etat_processus).pointeur_cache_buffer[i]; j++)
@@ -256,6 +258,7 @@ liberation_allocateur_buffer(struct_proc
 		sys_free((*s_etat_processus).enveloppes_buffers[i]);
 	}
 
+uprintf("Fin de la libération de l'allocateur des buffers\n");
 	return;
 }
 
@@ -405,13 +408,29 @@ rpl_malloc(struct_processus *s_etat_proc
 
 	void						*pointeur;
 
+	if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation_buffer)) != 0)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return(NULL);
+	}
+
 	if ((s_buffer = allocation_buffer(s_etat_processus, s)) == NULL)
 	{
+		pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation_buffer));
+
 		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 		return(NULL);
 	}
 
 	pointeur = (*s_buffer).buffer + sizeof(struct_buffer *);
+
+	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation_buffer))
+			!= 0)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return(NULL);
+	}
+
 	return(pointeur);
 }
 
@@ -440,8 +459,21 @@ rpl_realloc(struct_processus *s_etat_pro
 
 	void						*pointeur;
 
+	if (ptr == NULL)
+	{
+		return(rpl_malloc(s_etat_processus, s));
+	}
+
+	if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation_buffer)) != 0)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return(NULL);
+	}
+
 	if ((s_nouveau_buffer = allocation_buffer(s_etat_processus, s)) == NULL)
 	{
+		pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation_buffer));
+
 		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 		return(NULL);
 	}
@@ -458,6 +490,13 @@ rpl_realloc(struct_processus *s_etat_pro
 	liberation_buffer(s_etat_processus, s_ancien_buffer);
 	pointeur = (*s_nouveau_buffer).buffer + sizeof(struct_buffer *);
 
+	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation_buffer))
+		   	!= 0)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return(NULL);
+	}
+
 	return(pointeur);
 }
 
@@ -485,7 +524,22 @@ rpl_free(struct_processus *s_etat_proces
 	}
 
 	s_buffer = (*((struct_buffer **) (ptr - sizeof(struct_buffer *))));
+
+	if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation_buffer)) != 0)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return;
+	}
+
 	liberation_buffer(s_etat_processus, s_buffer);
+
+	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation_buffer))
+			!= 0)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_processus;
+		return;
+	}
+
 	return;
 }