--- rpl/src/gestion_objets.c	2013/03/21 12:07:38	1.98
+++ rpl/src/gestion_objets.c	2015/12/13 22:55:24	1.126
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.1.13
-  Copyright (C) 1989-2013 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.24
+  Copyright (C) 1989-2015 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -926,7 +926,7 @@ liberation(struct_processus *s_etat_proc
 				return;
 			}
 
-			free((unsigned char *) ((*s_objet).objet));
+			free((unsigned char *) (*s_objet).objet);
 			break;
 		}
 
@@ -1394,7 +1394,7 @@ liberation(struct_processus *s_etat_proc
 							.nombre_occurrences <= 1,
 							pthread_mutex_unlock(&((*s_objet).mutex)),
 							printf("(*((*((struct_tableau *) (*s_objet).objet))"
-							".element[%lu])).nombre_occurrences=%ld\n", i,
+							".element[%lld])).nombre_occurrences=%ld\n", i,
 							(*((*((struct_tableau *) (*s_objet).objet))
 							.elements[i])).nombre_occurrences));
 					liberation(s_etat_processus, (*((struct_tableau *)
@@ -2434,6 +2434,18 @@ copie_objet(struct_processus *s_etat_pro
 					(*((struct_socket *) ((*s_objet).objet))).pid;
 			(*((struct_socket *) ((*s_nouvel_objet).objet))).tid =
 					(*((struct_socket *) ((*s_objet).objet))).tid;
+			(*((struct_socket *) ((*s_nouvel_objet).objet))).options =
+					(*((struct_socket *) ((*s_objet).objet))).options;
+			(*((struct_socket *) ((*s_nouvel_objet).objet))).priorite =
+					(*((struct_socket *) ((*s_objet).objet))).priorite;
+			(*((struct_socket *) ((*s_nouvel_objet).objet))).buffer_reception =
+					(*((struct_socket *) ((*s_objet).objet))).buffer_reception;
+			(*((struct_socket *) ((*s_nouvel_objet).objet))).buffer_emission =
+					(*((struct_socket *) ((*s_objet).objet))).buffer_emission;
+			(*((struct_socket *) ((*s_nouvel_objet).objet))).timeout_reception =
+					(*((struct_socket *) ((*s_objet).objet))).timeout_reception;
+			(*((struct_socket *) ((*s_nouvel_objet).objet))).timeout_emission =
+					(*((struct_socket *) ((*s_objet).objet))).timeout_emission;
 
 			if (((*((struct_socket *) ((*s_nouvel_objet).objet))).format =
 					copie_objet(s_etat_processus, (*((struct_socket *)
@@ -2837,23 +2849,44 @@ copie_etat_processus(struct_processus *s
 
 	integer8						i;
 
-	if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
+	if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return(NULL);
 	}
 
-	if ((s_nouvel_etat_processus = malloc(sizeof(struct_processus))) == NULL)
+	if ((s_nouvel_etat_processus = sys_malloc(sizeof(struct_processus)))
+			== NULL)
 	{
+		if (pthread_mutex_unlock(&((*s_etat_processus)
+				.mutex_pile_processus)) != 0)
+		{
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return(NULL);
+		}
+
 		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 		return(NULL);
 	}
 
 	(*s_nouvel_etat_processus) = (*s_etat_processus);
 
-	// On réinitialise l'allocateur.
+	// On réinitialise les allocateurs.
+
+	pthread_mutexattr_init(&attributs_mutex);
+	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
+	pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_allocation_buffer),
+			&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);
 
 	initialisation_allocateur(s_nouvel_etat_processus);
+	initialisation_allocateur_buffer(s_nouvel_etat_processus);
 
 	/*
 	 * (*s_etat_processus).definition_chainee,
@@ -2863,9 +2896,8 @@ copie_etat_processus(struct_processus *s
 	 * n'ont aucune raison de changer.
 	 */
 
-	pthread_mutexattr_init(&attributs_mutex);
-	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
 	(*s_nouvel_etat_processus).sections_critiques = 0;
+	(*s_nouvel_etat_processus).initialisation_scheduler = d_faux;
 
 	// Les sémaphores sont initialisés dans le nouveau thread. Il
 	// s'agit d'une limitation de l'implantation de l'émulation
@@ -2932,9 +2964,9 @@ copie_etat_processus(struct_processus *s
 
 	// Copie de la localisation
 
-	if (((*s_nouvel_etat_processus).localisation = malloc((strlen(
-			(*s_etat_processus).localisation) + 1) * sizeof(unsigned char)))
-			== NULL)
+	if (((*s_nouvel_etat_processus).localisation = rpl_malloc(
+			s_nouvel_etat_processus, (strlen((*s_etat_processus).localisation)
+			+ 1) * sizeof(unsigned char))) == NULL)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 		return(NULL);
@@ -2948,7 +2980,8 @@ copie_etat_processus(struct_processus *s
 		if (((*s_nouvel_etat_processus).indep = copie_objet(s_etat_processus,
 				(*s_etat_processus).indep, 'P')) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -2968,7 +3001,8 @@ copie_etat_processus(struct_processus *s
 		if (((*s_nouvel_etat_processus).depend = copie_objet(s_etat_processus, 
 				(*s_etat_processus).depend, 'P')) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -2989,7 +3023,8 @@ copie_etat_processus(struct_processus *s
 				copie_objet(s_etat_processus, (*s_etat_processus)
 				.parametres_courbes_de_niveau, 'P')) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3009,11 +3044,13 @@ copie_etat_processus(struct_processus *s
 	if (((*s_etat_processus).instruction_courante != NULL) &&
 			(*s_etat_processus).evaluation_expression_compilee == 'N')
 	{
-		if (((*s_nouvel_etat_processus).instruction_courante = malloc((strlen(
+		if (((*s_nouvel_etat_processus).instruction_courante = rpl_malloc(
+				s_nouvel_etat_processus, (strlen(
 				(*s_etat_processus).instruction_courante) + 1) *
 				sizeof(unsigned char))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3033,11 +3070,13 @@ copie_etat_processus(struct_processus *s
 
 	if ((*s_etat_processus).label_x != NULL)
 	{
-		if (((*s_nouvel_etat_processus).label_x = malloc((strlen(
+		if (((*s_nouvel_etat_processus).label_x = rpl_malloc(
+				s_nouvel_etat_processus, (strlen(
 				(*s_etat_processus).label_x) + 1) *
 				sizeof(unsigned char))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3057,11 +3096,12 @@ copie_etat_processus(struct_processus *s
 
 	if ((*s_etat_processus).label_y != NULL)
 	{
-		if (((*s_nouvel_etat_processus).label_y = malloc((strlen(
-				(*s_etat_processus).label_y) + 1) *
-				sizeof(unsigned char))) == NULL)
+		if (((*s_nouvel_etat_processus).label_y = rpl_malloc(
+				s_nouvel_etat_processus, (strlen((*s_etat_processus).label_y)
+				+ 1) * sizeof(unsigned char))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3081,11 +3121,12 @@ copie_etat_processus(struct_processus *s
 
 	if ((*s_etat_processus).label_z != NULL)
 	{
-		if (((*s_nouvel_etat_processus).label_z = malloc((strlen(
-				(*s_etat_processus).label_z) + 1) *
-				sizeof(unsigned char))) == NULL)
+		if (((*s_nouvel_etat_processus).label_z = rpl_malloc(
+				s_nouvel_etat_processus, (strlen((*s_etat_processus).label_z)
+				+ 1) * sizeof(unsigned char))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3105,11 +3146,12 @@ copie_etat_processus(struct_processus *s
 
 	if ((*s_etat_processus).titre != NULL)
 	{
-		if (((*s_nouvel_etat_processus).titre = malloc((strlen(
-				(*s_etat_processus).titre) + 1) *
-				sizeof(unsigned char))) == NULL)
+		if (((*s_nouvel_etat_processus).titre = rpl_malloc(
+				s_nouvel_etat_processus, (strlen((*s_etat_processus).titre) + 1)
+				* sizeof(unsigned char))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3129,11 +3171,12 @@ copie_etat_processus(struct_processus *s
 
 	if ((*s_etat_processus).legende != NULL)
 	{
-		if (((*s_nouvel_etat_processus).legende = malloc((strlen(
-				(*s_etat_processus).legende) + 1) *
-				sizeof(unsigned char))) == NULL)
+		if (((*s_nouvel_etat_processus).legende = rpl_malloc(
+				s_nouvel_etat_processus, (strlen((*s_etat_processus).legende)
+				+ 1) * sizeof(unsigned char))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3178,9 +3221,11 @@ copie_etat_processus(struct_processus *s
 
 	while(l_element_lecture != NULL)
 	{
-		if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)
+		if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
+				sizeof(struct_liste_chainee))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3193,7 +3238,8 @@ copie_etat_processus(struct_processus *s
 		if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
 				(*l_element_lecture).donnee, 'P')) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3229,7 +3275,8 @@ copie_etat_processus(struct_processus *s
 
 	if ((*s_nouvel_etat_processus).erreur_systeme != d_es)
 	{
-		if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus))
+				!= 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return(NULL);
@@ -3251,7 +3298,8 @@ copie_etat_processus(struct_processus *s
 
 	if ((*s_nouvel_etat_processus).erreur_systeme != d_es)
 	{
-		if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus))
+				!= 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return(NULL);
@@ -3283,9 +3331,11 @@ copie_etat_processus(struct_processus *s
 
 	while(l_element_lecture != NULL)
 	{
-		if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)
+		if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
+				sizeof(struct_liste_chainee))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3298,7 +3348,8 @@ copie_etat_processus(struct_processus *s
 		if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
 				(*l_element_lecture).donnee, 'P')) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3329,9 +3380,11 @@ copie_etat_processus(struct_processus *s
 
 	while(l_element_lecture != NULL)
 	{
-		if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)
+		if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
+				sizeof(struct_liste_chainee))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3344,7 +3397,8 @@ copie_etat_processus(struct_processus *s
 		if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
 				(*l_element_lecture).donnee, 'P')) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3380,9 +3434,11 @@ copie_etat_processus(struct_processus *s
 
 	while(l_element_lecture != NULL)
 	{
-		if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)
+		if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
+				sizeof(struct_liste_chainee))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3395,7 +3451,8 @@ copie_etat_processus(struct_processus *s
 		if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
 				(*l_element_lecture).donnee, 'P')) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3426,9 +3483,11 @@ copie_etat_processus(struct_processus *s
 
 	while(l_element_lecture != NULL)
 	{
-		if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)
+		if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
+				sizeof(struct_liste_chainee))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3438,8 +3497,8 @@ copie_etat_processus(struct_processus *s
 			return(NULL);
 		}
 
-		if (((*l_element_suivant).donnee = malloc(sizeof(struct_bibliotheque)))
-				== NULL)
+		if (((*l_element_suivant).donnee = rpl_malloc(s_nouvel_etat_processus,
+				sizeof(struct_bibliotheque))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 			return(NULL);
@@ -3454,10 +3513,12 @@ copie_etat_processus(struct_processus *s
 				= (*((struct_bibliotheque *) (*l_element_lecture).donnee)).tid;
 
 		if (((*((struct_bibliotheque *) (*l_element_suivant).donnee)).nom =
-				malloc((strlen((*((struct_bibliotheque *) (*l_element_lecture)
+				rpl_malloc(s_nouvel_etat_processus,
+				(strlen((*((struct_bibliotheque *) (*l_element_lecture)
 				.donnee)).nom) + 1) * sizeof(unsigned char))) == NULL)
 		{
-			if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus)
+					.mutex_pile_processus)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3488,8 +3549,8 @@ copie_etat_processus(struct_processus *s
 	if ((*s_etat_processus).nombre_instructions_externes != 0)
 	{
 		if (((*s_nouvel_etat_processus).s_instructions_externes =
-				malloc(((size_t) (*s_etat_processus)
-				.nombre_instructions_externes) *
+				rpl_malloc(s_nouvel_etat_processus, ((size_t)
+				(*s_etat_processus).nombre_instructions_externes) *
 				sizeof(struct_instruction_externe))) == NULL)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -3499,7 +3560,8 @@ copie_etat_processus(struct_processus *s
 		for(i = 0; i < (*s_etat_processus).nombre_instructions_externes; i++)
 		{
 			if (((*s_nouvel_etat_processus).s_instructions_externes[i].nom =
-					malloc((strlen((*s_etat_processus).s_instructions_externes
+					rpl_malloc(s_nouvel_etat_processus,
+					(strlen((*s_etat_processus).s_instructions_externes
 					[i].nom) + 1) * sizeof(unsigned char))) == NULL)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
@@ -3510,9 +3572,9 @@ copie_etat_processus(struct_processus *s
 					(*s_etat_processus).s_instructions_externes[i].nom);
 
 			if (((*s_nouvel_etat_processus).s_instructions_externes[i]
-					.nom_bibliotheque = malloc((strlen((*s_etat_processus)
-					.s_instructions_externes[i].nom_bibliotheque) + 1) *
-					sizeof(unsigned char))) == NULL)
+					.nom_bibliotheque = rpl_malloc(s_nouvel_etat_processus,
+					(strlen((*s_etat_processus).s_instructions_externes[i]
+					.nom_bibliotheque) + 1) * sizeof(unsigned char))) == NULL)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return(NULL);
@@ -3534,16 +3596,29 @@ copie_etat_processus(struct_processus *s
 
 	pthread_mutexattr_init(&attributs_mutex);
 	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
-	pthread_mutex_init(&((*s_nouvel_etat_processus).mutex), &attributs_mutex);
+	pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_pile_processus),
+			&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),
+	pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_interruptions),
+			&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_signaux),
+			&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).protection_liste_mutexes),
 			&attributs_mutex);
 	pthread_mutexattr_destroy(&attributs_mutex);
 
-	if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
+	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_processus;
 		return(NULL);