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.66 and 1.90

version 1.66, 2011/09/14 14:34:28	version 1.90, 2012/12/17 21:22:43
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.3	RPL/2 (R) version 4.1.11
Copyright (C) 1989-2011 Dr. BERTRAND Joël	Copyright (C) 1989-2012 Dr. BERTRAND Joël

This file is part of RPL/2.	This file is part of RPL/2.

Line 112 initialisation_allocateur(struct_process	Line 112 initialisation_allocateur(struct_process
(*s_etat_processus).pointeur_maillons = 0;	(*s_etat_processus).pointeur_maillons = 0;

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

return;	return;
}	}
Line 544 allocation(struct_processus *s_etat_proc	Line 546 allocation(struct_processus *s_etat_proc
return(NULL);	return(NULL);
}	}

	(((struct_mutex ) (*s_objet).objet)).tid = pthread_self();
break;	break;
}	}

Line 1103 liberation(struct_processus *s_etat_proc	Line 1106 liberation(struct_processus *s_etat_proc
return;	return;
}	}

	if (pthread_mutex_trylock(&((((struct_mutex )
	(*s_objet).objet)).mutex)) == 0)
	{
	// On a pu verrouiller le mutex. Il faut donc spécifier le tid.
	(((struct_mutex ) (*s_objet).objet)).tid = pthread_self();
	}

	if (pthread_equal(pthread_self(),
	(((struct_mutex ) (*s_objet).objet)).tid) != 0)
	{
	pthread_mutex_unlock(&((((struct_mutex )
	(*s_objet).objet)).mutex));
	}
	else
	{
	(*s_etat_processus).erreur_systeme =
	d_es_mutex_acquis_autre_thread;
	return;
	}

	pthread_mutex_destroy(&((((struct_mutex )
	(*s_objet).objet)).mutex));
free((struct_mutex ) (s_objet).objet);	free((struct_mutex ) (s_objet).objet);
break;	break;
}	}
Line 2216 copie_objet(struct_processus *s_etat_pro	Line 2241 copie_objet(struct_processus *s_etat_pro

case MTX :	case MTX :
{	{
if (type != 'O')	// La duplication d'un mutex renvoie le même objet.
{	incrementation_atomique(s_objet);
incrementation_atomique(s_objet);	return(s_objet);
return(s_objet);
}

if ((s_nouvel_objet = allocation(s_etat_processus, MTX)) == NULL)
{
return(NULL);
}

(((struct_mutex ) ((*s_nouvel_objet).objet))).mutex =
(((struct_mutex ) ((*s_objet).objet))).mutex;
break;
}	}

case NOM :	case NOM :
Line 2271 copie_objet(struct_processus *s_etat_pro	Line 2285 copie_objet(struct_processus *s_etat_pro
return(s_objet);	return(s_objet);
}	}

	// Un objet de type NON est un objet encapsulé dans une
	// structure de type struct_objet. Elle peut très bien contenir
	// une donnée, mais c'est à l'utilisateur de la libérer
	// explicitement avec un free().

if ((s_nouvel_objet = allocation(s_etat_processus, NON)) == NULL)	if ((s_nouvel_objet = allocation(s_etat_processus, NON)) == NULL)
{	{
return(NULL);	return(NULL);
}	}

(*s_nouvel_objet).objet = NULL;	(s_nouvel_objet).objet = (s_objet).objet;
break;	break;
}	}

Line 2484 copie_objet(struct_processus *s_etat_pro	Line 2503 copie_objet(struct_processus *s_etat_pro
return(NULL);	return(NULL);
}	}

	(((struct_semaphore ) (*s_nouvel_objet).objet)).semaphore =
	(((struct_semaphore ) (*s_objet).objet)).semaphore;
strcpy((((struct_semaphore ) (*s_nouvel_objet).objet)).nom,	strcpy((((struct_semaphore ) (*s_nouvel_objet).objet)).nom,
(((struct_semaphore ) (*s_objet).objet)).nom);	(((struct_semaphore ) (*s_objet).objet)).nom);
break;	break;
Line 2801 copie_etat_processus(struct_processus *s	Line 2822 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	(*s_nouvel_etat_processus).sections_critiques = 0;
if (((*s_nouvel_etat_processus).semaphore_fork = sem_init2(0, sem_fork))
== SEM_FAILED)	// Les sémaphores sont initialisés dans le nouveau thread. Il
{	// s'agit d'une limitation de l'implantation de l'émulation
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;	// de sem_init().
return(NULL);
}
# endif

initialisation_contexte_cas(s_etat_processus);	initialisation_contexte_cas(s_etat_processus);

Line 2827 copie_etat_processus(struct_processus *s	Line 2845 copie_etat_processus(struct_processus *s
(*s_nouvel_etat_processus).processus_detache = d_faux;	(*s_nouvel_etat_processus).processus_detache = d_faux;
(*s_nouvel_etat_processus).evaluation_forcee = 'N';	(*s_nouvel_etat_processus).evaluation_forcee = 'N';

(*s_nouvel_etat_processus).compteur_violation_d_acces = 0;

(*s_nouvel_etat_processus).nombre_objets_envoyes_non_lus = 0;	(*s_nouvel_etat_processus).nombre_objets_envoyes_non_lus = 0;
(*s_nouvel_etat_processus).nombre_objets_injectes = 0;	(*s_nouvel_etat_processus).nombre_objets_injectes = 0;
(*s_nouvel_etat_processus).presence_fusible = d_faux;	(*s_nouvel_etat_processus).presence_fusible = d_faux;
Line 3098 copie_etat_processus(struct_processus *s	Line 3114 copie_etat_processus(struct_processus *s
* Copie de la table des variables	* Copie de la table des variables
*/	*/

	(*s_nouvel_etat_processus).l_liste_variables_statiques = NULL;
copie_arbre_variables(s_etat_processus, s_nouvel_etat_processus);	copie_arbre_variables(s_etat_processus, s_nouvel_etat_processus);

if ((*s_nouvel_etat_processus).erreur_systeme != d_es)	if ((*s_nouvel_etat_processus).erreur_systeme != d_es)
Line 3105 copie_etat_processus(struct_processus *s	Line 3122 copie_etat_processus(struct_processus *s
return(NULL);	return(NULL);
}	}

/*	((s_nouvel_etat_processus).l_liste_variables_partagees) =
* Copie de la table des variables statiques	((s_etat_processus).l_liste_variables_partagees);
*/	((s_nouvel_etat_processus).s_arbre_variables_partagees) =
	((s_etat_processus).s_arbre_variables_partagees);
if (((*s_nouvel_etat_processus).s_liste_variables_statiques =
malloc((s_etat_processus).nombre_variables_statiques_allouees
sizeof(struct_variable_statique))) == 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_statiques; i++)
{
if (((*s_nouvel_etat_processus).s_liste_variables_statiques[i].nom =
malloc((strlen((*s_etat_processus).s_liste_variables_statiques
[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_statiques[i].nom,
(*s_etat_processus).s_liste_variables_statiques[i].nom);

(*s_nouvel_etat_processus).s_liste_variables_statiques[i].origine =
(*s_etat_processus).s_liste_variables_statiques[i].origine;
(*s_nouvel_etat_processus).s_liste_variables_statiques[i].niveau =
(*s_etat_processus).s_liste_variables_statiques[i].niveau;
(*s_nouvel_etat_processus).s_liste_variables_statiques[i]
.variable_statique = (*s_etat_processus)
.s_liste_variables_statiques[i].variable_statique;

if (((*s_nouvel_etat_processus).s_liste_variables_statiques[i].objet =
copie_objet(s_etat_processus, (*s_etat_processus)
.s_liste_variables_statiques[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);
}
}

/*	/*
* Copie de la pile opérationnelle	* Copie de la pile opérationnelle
Line 3939 debug_fork()	Line 3901 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)
{	{
liberation_queue_signaux(s_etat_processus);	liberation_queue_signaux(s_etat_processus);

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.66
changed lines
	Added in v.1.90