rpl/src/instructions_d5.c - diff

Return to instructions_d5.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/instructions_d5.c between versions 1.11 and 1.53

version 1.11, 2010/04/21 13:45:46	version 1.53, 2011/06/20 17:54:16
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.0.15	RPL/2 (R) version 4.1.0.prerelease.1
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 20	Line 20
*/	*/


#include "rpl.conv.h"	#include "rpl-conv.h"


/*	/*
Line 838 instruction_detach(struct_processus *s_e	Line 838 instruction_detach(struct_processus *s_e
ssize_t longueur_ecriture;	ssize_t longueur_ecriture;

struct_descripteur_thread *s_argument_thread;	struct_descripteur_thread *s_argument_thread;
	struct_descripteur_thread *s_argument_thread2;

struct_liste_chainee *l_element_courant;	struct_liste_chainee *l_element_courant;
struct_liste_chainee *l_element_precedent;	struct_liste_chainee *l_element_precedent;
Line 930 instruction_detach(struct_processus *s_e	Line 931 instruction_detach(struct_processus *s_e
if (recherche_variable(s_etat_processus, (((struct_nom )	if (recherche_variable(s_etat_processus, (((struct_nom )
(*s_objet).objet)).nom) == d_vrai)	(*s_objet).objet)).nom) == d_vrai)
{	{
if ((*s_etat_processus).s_liste_variables	if (((s_etat_processus).pointeur_variable_courante).objet
[(*s_etat_processus).position_variable_courante].objet
== NULL)	== NULL)
{	{
if (pthread_mutex_lock(&(((s_etat_processus)	if (pthread_mutex_lock(&(((s_etat_processus)
Line 942 instruction_detach(struct_processus *s_e	Line 942 instruction_detach(struct_processus *s_e
}	}

if (recherche_variable_partagee(s_etat_processus,	if (recherche_variable_partagee(s_etat_processus,
(*s_etat_processus).s_liste_variables	((s_etat_processus).pointeur_variable_courante).nom,
[(*s_etat_processus).position_variable_courante].nom,	((s_etat_processus).pointeur_variable_courante)
(*s_etat_processus).s_liste_variables	.variable_partagee, ((s_etat_processus)
[(*s_etat_processus).position_variable_courante]	.pointeur_variable_courante).origine) == d_faux)
.variable_partagee, (*s_etat_processus)
.s_liste_variables[(*s_etat_processus)
.position_variable_courante].origine) == d_faux)
{	{
if (pthread_mutex_unlock(&(((s_etat_processus)	if (pthread_mutex_unlock(&(((s_etat_processus)
.s_liste_variables_partagees).mutex)) != 0)	.s_liste_variables_partagees).mutex)) != 0)
Line 1016 instruction_detach(struct_processus *s_e	Line 1013 instruction_detach(struct_processus *s_e
}	}
else	else
{	{
if ((((s_etat_processus).s_liste_variables	if (((((*s_etat_processus).pointeur_variable_courante).objet)
[(*s_etat_processus).position_variable_courante].objet)	.type != RPN) && ((((*s_etat_processus)
.type != RPN) && (((s_etat_processus)	.pointeur_variable_courante).objet).type != ADR))
.s_liste_variables[(*s_etat_processus)
.position_variable_courante].objet).type != ADR))
{	{
liberation(s_etat_processus, s_objet);	liberation(s_etat_processus, s_objet);

Line 1062 instruction_detach(struct_processus *s_e	Line 1057 instruction_detach(struct_processus *s_e
return;	return;
}	}

	if (sigaddset(&set, SIGFABORT) != 0)
	{
	(*s_etat_processus).erreur_systeme = d_es_processus;
	return;
	}

if (sigaddset(&set, SIGURG) != 0)	if (sigaddset(&set, SIGURG) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
Line 1165 instruction_detach(struct_processus *s_e	Line 1166 instruction_detach(struct_processus *s_e
pthread_mutex_init(&((*s_argument_thread).mutex), &attributs_mutex);	pthread_mutex_init(&((*s_argument_thread).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_RECURSIVE);
	pthread_mutex_init(&((*s_argument_thread).mutex_nombre_references),
	&attributs_mutex);
	pthread_mutexattr_destroy(&attributs_mutex);

if ((*s_argument_thread).pid > 0)	if ((*s_argument_thread).pid > 0)
{	{
/*	/*
Line 1176 instruction_detach(struct_processus *s_e	Line 1183 instruction_detach(struct_processus *s_e
liberation(s_etat_processus, s_copie);	liberation(s_etat_processus, s_copie);
}	}

if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)	liberation(s_etat_processus, s_objet);

	if ((s_objet = allocation(s_etat_processus, PRC)) == NULL)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
return;	return;
}	}

if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)	(((struct_processus_fils ) (*s_objet).objet)).thread =
	s_argument_thread;
	((((struct_processus_fils ) (s_objet).objet)).thread)
	.nombre_objets_dans_pipe = 0;
	((((struct_processus_fils ) (s_objet).objet)).thread)
	.nombre_interruptions_dans_pipe = 0;
	((((struct_processus_fils ) (s_objet).objet)).thread)
	.nombre_references = 1;

	/*
	* On copie l'objet plutôt que le pointeur car cet objet peut être
	* accédé depuis deux threads distincts et aboutir à un blocage lors
	* d'une copie.
	*/

	if ((s_objet_systeme = copie_objet(s_etat_processus, s_objet, 'O'))
	== NULL)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
return;	return;
}	}

Line 1250 instruction_detach(struct_processus *s_e	Line 1275 instruction_detach(struct_processus *s_e
return;	return;
}	}

	# ifndef OS2
	# ifndef Cygwin
if (pthread_attr_setschedpolicy(&attributs, SCHED_OTHER) != 0)	if (pthread_attr_setschedpolicy(&attributs, SCHED_OTHER) != 0)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
Line 1268 instruction_detach(struct_processus *s_e	Line 1295 instruction_detach(struct_processus *s_e
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
}	}
	# endif
	# endif

(*s_argument_thread).s_etat_processus = s_etat_processus;	(*s_argument_thread).s_etat_processus = s_etat_processus;

Line 1290 instruction_detach(struct_processus *s_e	Line 1319 instruction_detach(struct_processus *s_e
* Processus fils	* Processus fils
*/	*/

	# ifdef _BROKEN_SIGINFO
	liberation_fifos_signaux(s_etat_processus);
	creation_fifos_signaux(s_etat_processus);
	# endif

	if ((*s_etat_processus).debug == d_vrai)
	if (((*s_etat_processus).type_debug &
	d_debug_processus) != 0)
	{
	if ((*s_etat_processus).langue == 'F')
	{
	printf("[%d] Lancement du processus fils %d de %d\n",
	(int) getpid(), (int) getpid(), (int) ppid);
	}
	else
	{
	printf("[%d] Start child process %d from %d\n", (int) getpid(),
	(int) getpid(), (int) ppid);
	}

	fflush(stdout);
	}

# ifndef SEMAPHORES_NOMMES	# ifndef SEMAPHORES_NOMMES
sem_post(&semaphore_gestionnaires_signaux);	sem_post(&semaphore_gestionnaires_signaux);
sem_destroy(&semaphore_gestionnaires_signaux);	sem_destroy(&semaphore_gestionnaires_signaux);
Line 1383 instruction_detach(struct_processus *s_e	Line 1435 instruction_detach(struct_processus *s_e
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
}	}

	if ((*s_etat_processus).debug == d_vrai)
	if (((*s_etat_processus).type_debug &
	d_debug_processus) != 0)
	{
	if ((*s_etat_processus).langue == 'F')
	{
	printf("[%d] Libération des objets du processus père\n",
	(int) getpid());
	}
	else
	{
	printf("[%d] Freeing parent process memory\n", getpid());
	}

	fflush(stdout);
	}

l_element_courant = (*s_etat_processus).liste_mutexes;	l_element_courant = (*s_etat_processus).liste_mutexes;
while(l_element_courant != NULL)	while(l_element_courant != NULL)
{	{
Line 1444 instruction_detach(struct_processus *s_e	Line 1513 instruction_detach(struct_processus *s_e
}	}
}	}

	# ifdef _BROKEN_SIGINFO
	destruction_fifos_signaux(s_etat_processus);
	# endif

	BUG(1, uprintf("Process management error line %d\n", __LINE__));
exit(EXIT_FAILURE);	exit(EXIT_FAILURE);
}	}

Line 1473 instruction_detach(struct_processus *s_e	Line 1547 instruction_detach(struct_processus *s_e
}	}
}	}

	# ifdef _BROKEN_SIGINFO
	destruction_fifos_signaux(s_etat_processus);
	# endif

	BUG(1, uprintf("Process management error line %d\n", __LINE__));
exit(EXIT_FAILURE);	exit(EXIT_FAILURE);
}	}

	pthread_mutex_trylock(&((*s_etat_processus).protection_liste_mutexes));

if (pthread_mutex_unlock(&((*s_etat_processus)	if (pthread_mutex_unlock(&((*s_etat_processus)
.protection_liste_mutexes)) != 0)	.protection_liste_mutexes)) != 0)
{	{
Line 1503 instruction_detach(struct_processus *s_e	Line 1584 instruction_detach(struct_processus *s_e
}	}
}	}

	# ifdef _BROKEN_SIGINFO
	destruction_fifos_signaux(s_etat_processus);
	# endif

	BUG(1, uprintf("Process management error line %d\n", __LINE__));
exit(EXIT_FAILURE);	exit(EXIT_FAILURE);
}	}

Line 1513 instruction_detach(struct_processus *s_e	Line 1599 instruction_detach(struct_processus *s_e
}	}

(*s_etat_processus).var_volatile_processus_pere = 0;	(*s_etat_processus).var_volatile_processus_pere = 0;
	(*s_etat_processus).var_volatile_processus_racine = 0;

// On réinitialise toutes les interruptions.	// On réinitialise toutes les interruptions.

Line 1522 instruction_detach(struct_processus *s_e	Line 1609 instruction_detach(struct_processus *s_e
(*s_etat_processus).nombre_interruptions_non_affectees = 0;	(*s_etat_processus).nombre_interruptions_non_affectees = 0;
(*s_etat_processus).processus_detache = d_vrai;	(*s_etat_processus).processus_detache = d_vrai;

	liberation(s_etat_processus, (*s_etat_processus).at_exit);
	(*s_etat_processus).at_exit = NULL;
	liberation(s_etat_processus, (*s_etat_processus).at_poke);
	(*s_etat_processus).at_poke = NULL;
	(*s_etat_processus).traitement_at_poke = 'N';

for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++)	for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++)
{	{
liberation(s_etat_processus,	liberation(s_etat_processus,
Line 1545 instruction_detach(struct_processus *s_e	Line 1638 instruction_detach(struct_processus *s_e
(*s_etat_processus).pile_origine_interruptions[i] = NULL;	(*s_etat_processus).pile_origine_interruptions[i] = NULL;
}	}

if ((*s_etat_processus).debug == d_vrai)
if (((*s_etat_processus).type_debug &
d_debug_processus) != 0)
{
if ((*s_etat_processus).langue == 'F')
{
printf("[%d] Lancement du processus fils %d de %d\n",
(int) getpid(), (int) getpid(), (int) ppid);
}
else
{
printf("[%d] Start child process %d from %d\n", (int) getpid(),
(int) getpid(), (int) ppid);
}

fflush(stdout);
}

/*	/*
* On bloque l'exécution du processus fils jusqu'à ce que	* On bloque l'exécution du processus fils jusqu'à ce que
* le père ait renseigné correctement la pile des processus.	* le père ait renseigné correctement la pile des processus.
Line 1632 instruction_detach(struct_processus *s_e	Line 1707 instruction_detach(struct_processus *s_e
}	}

/*	/*
* Initialisation de la pile des processus	* Initialisation de la pile des processus. Cette pile est effacée
	* par liberation_threads().
*/	*/

	if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
	{
	(*s_etat_processus).erreur_systeme = d_es;

	pid_final = -2;

	while((longueur_ecriture = write_atomic(s_etat_processus,
	(*s_argument_thread).pipe_nombre_interruptions_attente[1],
	&pid_final, sizeof(pid_final))) != sizeof(pid_final))
	{
	if (longueur_ecriture == -1)
	{
	break;
	}
	}

	while((longueur_ecriture = write_atomic(s_etat_processus,
	(*s_argument_thread).pipe_nombre_objets_attente[1],
	&pid_final, sizeof(pid_final))) != sizeof(pid_final))
	{
	if (longueur_ecriture == -1)
	{
	break;
	}
	}

	# ifdef _BROKEN_SIGINFO
	destruction_fifos_signaux(s_etat_processus);
	# endif

	BUG(1, uprintf("Process management error line %d\n", __LINE__));
	exit(EXIT_FAILURE);
	}

	l_element_courant = (struct_liste_chainee *)
	(*s_etat_processus).l_base_pile_processus;

	while(l_element_courant != NULL)
	{
	s_argument_thread2 = (struct_descripteur_thread *)
	(((struct_processus_fils ) ((l_element_courant).donnee)
	.objet)).thread;

	(*s_argument_thread2).nombre_references--;

	BUG((*s_argument_thread2).nombre_references < 0,
	# ifdef _BROKEN_SIGINFO
	destruction_fifos_signaux(s_etat_processus),
	# endif
	printf("(*s_argument_thread2).nombre_references = %d\n",
	(int) (*s_argument_thread2).nombre_references));

	if ((*s_argument_thread2).nombre_references == 0)
	{
	close((*s_argument_thread2).pipe_objets[0]);
	close((*s_argument_thread2).pipe_acquittement[1]);
	close((*s_argument_thread2).pipe_injections[1]);
	close((*s_argument_thread2).pipe_nombre_injections[1]);
	close((*s_argument_thread2).pipe_nombre_objets_attente[0]);
	close((*s_argument_thread2).pipe_interruptions[0]);
	close((*s_argument_thread2)
	.pipe_nombre_interruptions_attente[0]);

	pthread_mutex_destroy(&((*s_argument_thread2).mutex));

	if ((*s_argument_thread2).processus_detache == d_faux)
	{
	if ((*s_argument_thread2).destruction_objet == d_vrai)
	{
	liberation(s_etat_processus,
	(*s_argument_thread2).argument);
	}
	}

	free(s_argument_thread2);
	free(((l_element_courant).donnee).objet);
	free((*l_element_courant).donnee);
	}

	l_element_suivant = (*l_element_courant).suivant;
	free((struct_liste_chainee *) l_element_courant);
	l_element_courant = l_element_suivant;
	}

(*s_etat_processus).l_base_pile_processus = NULL;	(*s_etat_processus).l_base_pile_processus = NULL;
// Les données associées sont déjà effacées par liberation_thread().
	if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
	{
	(*s_etat_processus).erreur_systeme = d_es;

	pid_final = -2;

	while((longueur_ecriture = write_atomic(s_etat_processus,
	(*s_argument_thread).pipe_nombre_interruptions_attente[1],
	&pid_final, sizeof(pid_final))) != sizeof(pid_final))
	{
	if (longueur_ecriture == -1)
	{
	break;
	}
	}

	while((longueur_ecriture = write_atomic(s_etat_processus,
	(*s_argument_thread).pipe_nombre_objets_attente[1],
	&pid_final, sizeof(pid_final))) != sizeof(pid_final))
	{
	if (longueur_ecriture == -1)
	{
	break;
	}
	}

	# ifdef _BROKEN_SIGINFO
	destruction_fifos_signaux(s_etat_processus);
	# endif

	BUG(1, uprintf("Process management error line %d\n", __LINE__));
	exit(EXIT_FAILURE);
	}

/*	/*
* Initialisation de la pile système	* Initialisation de la pile système
Line 1698 instruction_detach(struct_processus *s_e	Line 1891 instruction_detach(struct_processus *s_e
}	}
}	}

	# ifdef _BROKEN_SIGINFO
	destruction_fifos_signaux(s_etat_processus);
	# endif

	BUG(1, uprintf("Process management error line %d\n", __LINE__));
exit(EXIT_FAILURE);	exit(EXIT_FAILURE);
}	}

Line 1749 instruction_detach(struct_processus *s_e	Line 1947 instruction_detach(struct_processus *s_e
}	}
}	}

	# ifdef _BROKEN_SIGINFO
	destruction_fifos_signaux(s_etat_processus);
	# endif

	BUG(1, uprintf("Process management error line %d\n", __LINE__));
exit(EXIT_FAILURE);	exit(EXIT_FAILURE);
}	}

Line 1821 instruction_detach(struct_processus *s_e	Line 2024 instruction_detach(struct_processus *s_e
* Destruction des piles de connecteurs SQL	* Destruction des piles de connecteurs SQL
*/	*/

	/*
	================================================================================
	À noter : on ne ferme pas la connexion car la conséquence immédiate est
	une destruction de l'objet pour le processus père.
	================================================================================
	*/

l_element_courant = (*s_etat_processus).s_connecteurs_sql;	l_element_courant = (*s_etat_processus).s_connecteurs_sql;

while(l_element_courant != NULL)	while(l_element_courant != NULL)
{	{
l_element_suivant = (*l_element_courant).suivant;	l_element_suivant = (*l_element_courant).suivant;

sqlclose((*l_element_courant).donnee);	// sqlclose((*l_element_courant).donnee);
liberation(s_etat_processus, (*l_element_courant).donnee);	liberation(s_etat_processus, (*l_element_courant).donnee);
l_element_courant = l_element_suivant;	l_element_courant = l_element_suivant;
}	}

	(*s_etat_processus).s_connecteurs_sql = NULL;

/*	/*
* On ne détruit pas les sockets car il faut utiliser DETACH	* On ne détruit pas les sockets car il faut utiliser DETACH
* pour traiter plusieurs connexions simultanées sur les sockets	* pour traiter plusieurs connexions simultanées sur les sockets
Line 1846 instruction_detach(struct_processus *s_e	Line 2058 instruction_detach(struct_processus *s_e

sigpending(&set);	sigpending(&set);

	if ((*s_etat_processus).debug == d_vrai)
	{
	if (((*s_etat_processus).type_debug & d_debug_processus)
	!= 0)
	{
	if ((*s_etat_processus).langue == 'F')
	{
	printf("[%d] Évaluation de l'objet détaché\n", getpid());
	}
	else
	{
	printf("[%d] Évaluation of detached object\n", getpid());
	}
	}
	}

if ((*s_etat_processus).erreur_systeme == d_es)	if ((*s_etat_processus).erreur_systeme == d_es)
{	{
if (variable_partagee == d_faux)	if (variable_partagee == d_faux)
Line 1859 instruction_detach(struct_processus *s_e	Line 2087 instruction_detach(struct_processus *s_e
d_ex_erreur_evaluation;	d_ex_erreur_evaluation;
}	}
}	}
	else
	{
	if (((*s_etat_processus).var_volatile_alarme == 0)
	&& ((*s_etat_processus).arret_depuis_abort == 0)
	&& ((*s_etat_processus).at_exit != NULL))
	{
	(*s_etat_processus).var_volatile_requete_arret = 0;

	if (evaluation(s_etat_processus,
	(*s_etat_processus).at_exit, 'E') == d_erreur)
	{
	(*s_etat_processus).erreur_execution =
	d_ex_erreur_evaluation;
	}
	}
	}
}	}
else	else
{	{
Line 1871 instruction_detach(struct_processus *s_e	Line 2115 instruction_detach(struct_processus *s_e
d_ex_erreur_evaluation;	d_ex_erreur_evaluation;
}	}
}	}
	else
	{
	if ((*s_etat_processus).at_exit != NULL)
	{
	(*s_etat_processus).var_volatile_requete_arret = 0;

	if (evaluation(s_etat_processus,
	(*s_etat_processus).at_exit, 'E') == d_erreur)
	{
	(*s_etat_processus).erreur_execution =
	d_ex_erreur_evaluation;
	}
	}
	}

liberation(s_etat_processus, s_copie);	liberation(s_etat_processus, s_copie);
}	}
}	}

	liberation(s_etat_processus, (*s_etat_processus).at_exit);
	liberation(s_etat_processus, (*s_etat_processus).at_poke);

l_element_courant = (*s_etat_processus).liste_mutexes;	l_element_courant = (*s_etat_processus).liste_mutexes;
while(l_element_courant != NULL)	while(l_element_courant != NULL)
{	{
Line 2102 instruction_detach(struct_processus *s_e	Line 2363 instruction_detach(struct_processus *s_e
}	}
else	else
{	{
kill(((((struct_processus_fils *)	if ((*s_etat_processus).arret_depuis_abort == -1)
((l_element_courant).donnee).objet)).thread).pid,	{
SIGFSTOP);	kill(((((struct_processus_fils *)
	((l_element_courant).donnee).objet)).thread)
	.pid, SIGFABORT);
	}
	else
	{
	kill(((((struct_processus_fils *)
	((l_element_courant).donnee).objet)).thread)
	.pid, SIGFSTOP);
	}
}	}
}	}
else	else
Line 2151 instruction_detach(struct_processus *s_e	Line 2421 instruction_detach(struct_processus *s_e
}	}
else	else
{	{
pthread_kill(((((struct_processus_fils *)	if ((*s_etat_processus).arret_depuis_abort == -1)
((l_element_courant).donnee).objet)).thread)	{
.tid, SIGFSTOP);	pthread_kill(((((struct_processus_fils *)
	((l_element_courant).donnee).objet))
	.thread).tid, SIGFABORT);
	}
	else
	{
	pthread_kill(((((struct_processus_fils *)
	((l_element_courant).donnee).objet))
	.thread).tid, SIGFSTOP);
	}
}	}
}	}

Line 2181 instruction_detach(struct_processus *s_e	Line 2460 instruction_detach(struct_processus *s_e
l_element_courant = (struct_liste_chainee *)	l_element_courant = (struct_liste_chainee *)
(*s_etat_processus).l_base_pile_processus;	(*s_etat_processus).l_base_pile_processus;

if ((*s_etat_processus).nombre_interruptions_non_affectees != 0)
{
affectation_interruptions_logicielles(s_etat_processus);
}

registre_stop = (*s_etat_processus)	registre_stop = (*s_etat_processus)
.var_volatile_traitement_retarde_stop;	.var_volatile_traitement_retarde_stop;
(*s_etat_processus).var_volatile_traitement_retarde_stop = 1;	(*s_etat_processus).var_volatile_traitement_retarde_stop = 1;
Line 2225 instruction_detach(struct_processus *s_e	Line 2499 instruction_detach(struct_processus *s_e
registre_stop;	registre_stop;
}	}

	# ifdef _BROKEN_SIGINFO
	destruction_fifos_signaux(s_etat_processus);
	# endif

(*s_etat_processus).erreur_systeme = d_es_signal;	(*s_etat_processus).erreur_systeme = d_es_signal;
exit(EXIT_FAILURE);	exit(EXIT_FAILURE);
}	}
Line 2259 instruction_detach(struct_processus *s_e	Line 2537 instruction_detach(struct_processus *s_e

if (sigaction(SIGPIPE, &registre, NULL) != 0)	if (sigaction(SIGPIPE, &registre, NULL) != 0)
{	{
	# ifdef _BROKEN_SIGINFO
	destruction_fifos_signaux(s_etat_processus);
	# endif

pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus).mutex));

(*s_etat_processus).erreur_systeme = d_es_signal;	(*s_etat_processus).erreur_systeme = d_es_signal;
Line 2268 instruction_detach(struct_processus *s_e	Line 2550 instruction_detach(struct_processus *s_e
}	}

pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus).mutex));

	if ((*s_etat_processus).nombre_interruptions_non_affectees != 0)
	{
	affectation_interruptions_logicielles(s_etat_processus);
	}

nanosleep(&attente, NULL);	nanosleep(&attente, NULL);
pthread_mutex_lock(&((*s_etat_processus).mutex));	pthread_mutex_lock(&((*s_etat_processus).mutex));
}	}
Line 2394 instruction_detach(struct_processus *s_e	Line 2682 instruction_detach(struct_processus *s_e
(*s_etat_processus).instruction_derniere_erreur = NULL;	(*s_etat_processus).instruction_derniere_erreur = NULL;
}	}

for(i = 0; i < (*s_etat_processus).nombre_variables; i++)	liberation_arbre_variables(s_etat_processus,
{	(*s_etat_processus).s_arbre_variables, d_vrai);
liberation(s_etat_processus,	free((*s_etat_processus).pointeurs_caracteres_variables);
(*s_etat_processus).s_liste_variables[i].objet);
free((*s_etat_processus).s_liste_variables[i].nom);
}

free((*s_etat_processus).s_liste_variables);

for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++)	for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++)
{	{
Line 2569 instruction_detach(struct_processus *s_e	Line 2852 instruction_detach(struct_processus *s_e

liberation(s_etat_processus, s_objet);	liberation(s_etat_processus, s_objet);

# ifndef Cygwin
free((*s_etat_processus).pile_signal.ss_sp);
# endif

free((*s_etat_processus).definitions_chainees);	free((*s_etat_processus).definitions_chainees);
free((*s_etat_processus).nom_fichier_historique);	free((*s_etat_processus).nom_fichier_historique);

Line 2612 instruction_detach(struct_processus *s_e	Line 2891 instruction_detach(struct_processus *s_e
retrait_thread(s_etat_processus);	retrait_thread(s_etat_processus);

pthread_mutex_destroy(&((*s_etat_processus).mutex));	pthread_mutex_destroy(&((*s_etat_processus).mutex));
	pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
pthread_mutex_destroy(&((*s_etat_processus).protection_liste_mutexes));	pthread_mutex_destroy(&((*s_etat_processus).protection_liste_mutexes));

pthread_key_delete(semaphore_fork_processus_courant);	pthread_key_delete(semaphore_fork_processus_courant);
Line 2625 instruction_detach(struct_processus *s_e	Line 2905 instruction_detach(struct_processus *s_e
# endif	# endif

free((*s_etat_processus).localisation);	free((*s_etat_processus).localisation);
free(s_etat_processus);
free(s_argument_thread);	free(s_argument_thread);

# ifndef SEMAPHORES_NOMMES	# ifndef SEMAPHORES_NOMMES
Line 2644 instruction_detach(struct_processus *s_e	Line 2923 instruction_detach(struct_processus *s_e

clear_history();	clear_history();

	# ifdef _BROKEN_SIGINFO
	destruction_fifos_signaux(s_etat_processus);
	# endif

	free(s_etat_processus);

# ifdef DEBUG_MEMOIRE	# ifdef DEBUG_MEMOIRE
debug_memoire_verification(s_etat_processus);	debug_memoire_verification();
	analyse_post_mortem();
# endif	# endif

exit(EXIT_SUCCESS);	exit(EXIT_SUCCESS);
Line 2656 instruction_detach(struct_processus *s_e	Line 2942 instruction_detach(struct_processus *s_e
return;	return;
}	}

liberation(s_etat_processus, s_objet);

if ((s_objet = allocation(s_etat_processus, PRC)) == NULL)
{
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
return;
}

(((struct_processus_fils ) (*s_objet).objet)).thread = s_argument_thread;
((((struct_processus_fils ) (s_objet).objet)).thread)
.nombre_objets_dans_pipe = 0;
((((struct_processus_fils ) (s_objet).objet)).thread)
.nombre_interruptions_dans_pipe = 0;
((((struct_processus_fils ) (s_objet).objet)).thread)
.nombre_references = 1;

/*
* On copie l'objet plutôt que le pointeur car cet objet peut être
* accédé depuis deux threads distincts et aboutir à un blocage lors d'une
* copie.
*/

if ((s_objet_systeme = copie_objet(s_etat_processus, s_objet, 'O')) == NULL)
{
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
return;
}

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

// Si le pid existe déjà dans la pile des processus, il s'agit forcement	// Si le pid existe déjà dans la pile des processus, il s'agit forcement
// d'un processus moribond. On attend donc qu'il soit effectivement	// d'un processus moribond. On attend donc qu'il soit effectivement
// libéré.	// libéré.
Line 2754 instruction_detach(struct_processus *s_e	Line 3006 instruction_detach(struct_processus *s_e

// Être sûr que le processus fils soit déjà présent...	// Être sûr que le processus fils soit déjà présent...

	attente.tv_sec = 0;
	attente.tv_nsec = GRANULARITE_us * 1000;

while(kill((*s_argument_thread).pid, 0) != 0)	while(kill((*s_argument_thread).pid, 0) != 0)
{	{
//if ((errno != ESRCH) && (errno != EAGAIN))	//if ((errno != ESRCH) && (errno != EAGAIN))
Line 2765 instruction_detach(struct_processus *s_e	Line 3020 instruction_detach(struct_processus *s_e
}	}

nanosleep(&attente, NULL);	nanosleep(&attente, NULL);
	INCR_GRANULARITE(attente.tv_nsec);
}	}

// Le fils peut être présent sans être en attente du signal de départ.	// Le fils peut être présent sans être en attente du signal de départ.

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.11
changed lines
	Added in v.1.53