rpl/src/instructions_p7.c - diff

Return to instructions_p7.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/instructions_p7.c between versions 1.48 and 1.79

version 1.48, 2012/12/13 16:59:42	version 1.79, 2019/02/09 13:36:40
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.11	RPL/2 (R) version 4.1.31
Copyright (C) 1989-2012 Dr. BERTRAND Joël	Copyright (C) 1989-2019 Dr. BERTRAND Joël

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

Line 718 instruction_poke(struct_processus *s_eta	Line 718 instruction_poke(struct_processus *s_eta
return;	return;
}	}

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;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
Line 749 instruction_poke(struct_processus *s_eta	Line 750 instruction_poke(struct_processus *s_eta
// figure !	// figure !

action.sa_handler = SIG_IGN;	action.sa_handler = SIG_IGN;
action.sa_flags = SA_ONSTACK;	action.sa_flags = 0;

if (sigaction(SIGPIPE, &action, &registre) != 0)	if (sigaction(SIGPIPE, &action, &registre) != 0)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus));

(*s_etat_processus).erreur_systeme = d_es_signal;	(*s_etat_processus).erreur_systeme = d_es_signal;
return;	return;
Line 765 instruction_poke(struct_processus *s_eta	Line 767 instruction_poke(struct_processus *s_eta

if (envoi_signal_processus(((((struct_processus_fils *)	if (envoi_signal_processus(((((struct_processus_fils *)
((l_element_courant).donnee).objet))	((l_element_courant).donnee).objet))
.thread).pid, rpl_siginject) != 0)	.thread).pid, rpl_siginject, d_faux) != 0)
{	{
// Le processus fils peut s'être terminé.	// Le processus fils peut s'être terminé.
break;	break;
Line 783 instruction_poke(struct_processus *s_eta	Line 785 instruction_poke(struct_processus *s_eta

if ((*s_etat_processus).erreur_systeme != d_es)	if ((*s_etat_processus).erreur_systeme != d_es)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus));
return;	return;
}	}
}	}
Line 823 instruction_poke(struct_processus *s_eta	Line 826 instruction_poke(struct_processus *s_eta

if (longueur_ecriture == -1)	if (longueur_ecriture == -1)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus));

liberation(s_etat_processus, s_objet_argument_1);	liberation(s_etat_processus, s_objet_argument_1);
liberation(s_etat_processus, s_objet_argument_2);	liberation(s_etat_processus, s_objet_argument_2);
Line 919 instruction_poke(struct_processus *s_eta	Line 923 instruction_poke(struct_processus *s_eta

if (sigaction(SIGPIPE, &registre, NULL) != 0)	if (sigaction(SIGPIPE, &registre, NULL) != 0)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus));

(*s_etat_processus).erreur_systeme = d_es_signal;	(*s_etat_processus).erreur_systeme = d_es_signal;
return;	return;
Line 952 instruction_poke(struct_processus *s_eta	Line 957 instruction_poke(struct_processus *s_eta
// figure !	// figure !

action.sa_handler = SIG_IGN;	action.sa_handler = SIG_IGN;
action.sa_flags = SA_ONSTACK;	action.sa_flags = 0;

if (sigaction(SIGPIPE, &action, &registre) != 0)	if (sigaction(SIGPIPE, &action, &registre) != 0)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus));

(*s_etat_processus).erreur_systeme = d_es_signal;	(*s_etat_processus).erreur_systeme = d_es_signal;
return;	return;
Line 978 instruction_poke(struct_processus *s_eta	Line 984 instruction_poke(struct_processus *s_eta
((l_element_courant).donnee).objet)).thread)	((l_element_courant).donnee).objet)).thread)
.thread_actif == d_vrai)	.thread_actif == d_vrai)
{	{
if (envoi_signal_thread(((((struct_processus_fils *)	if (envoi_signal_thread(s_etat_processus,
	((((struct_processus_fils *)
((l_element_courant).donnee).objet)).thread)	((l_element_courant).donnee).objet)).thread)
.tid, rpl_siginject) != 0)	.tid, rpl_siginject) != 0)
{	{
Line 1031 instruction_poke(struct_processus *s_eta	Line 1038 instruction_poke(struct_processus *s_eta

if ((*s_etat_processus).erreur_systeme != d_es)	if ((*s_etat_processus).erreur_systeme != d_es)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus));
return;	return;
}	}
}	}
Line 1072 instruction_poke(struct_processus *s_eta	Line 1080 instruction_poke(struct_processus *s_eta

if (longueur_ecriture == -1)	if (longueur_ecriture == -1)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus));

liberation(s_etat_processus, s_objet_argument_1);	liberation(s_etat_processus, s_objet_argument_1);
liberation(s_etat_processus, s_objet_argument_2);	liberation(s_etat_processus, s_objet_argument_2);
Line 1169 instruction_poke(struct_processus *s_eta	Line 1178 instruction_poke(struct_processus *s_eta

if (sigaction(SIGPIPE, &registre, NULL) != 0)	if (sigaction(SIGPIPE, &registre, NULL) != 0)
{	{
pthread_mutex_unlock(&((*s_etat_processus).mutex));	pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus));

(*s_etat_processus).erreur_systeme = d_es_signal;	(*s_etat_processus).erreur_systeme = d_es_signal;
return;	return;
Line 1182 instruction_poke(struct_processus *s_eta	Line 1192 instruction_poke(struct_processus *s_eta
l_element_courant = (*l_element_courant).suivant;	l_element_courant = (*l_element_courant).suivant;
}	}

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;	(*s_etat_processus).erreur_systeme = d_es_processus;
return;	return;
Line 1288 instruction_private(struct_processus *s_	Line 1299 instruction_private(struct_processus *s_
(s_objet).objet)).nom), ((*s_etat_processus)	(s_objet).objet)).nom), ((*s_etat_processus)
.pointeur_variable_courante).variable_partagee,	.pointeur_variable_courante).variable_partagee,
((s_etat_processus).pointeur_variable_courante).origine)	((s_etat_processus).pointeur_variable_courante).origine)
== d_faux)	== NULL)
{	{
liberation(s_etat_processus, s_objet);	liberation(s_etat_processus, s_objet);

Line 1350 instruction_private(struct_processus *s_	Line 1361 instruction_private(struct_processus *s_
(s_objet).objet)).nom), ((*s_etat_processus)	(s_objet).objet)).nom), ((*s_etat_processus)
.pointeur_variable_courante).variable_partagee,	.pointeur_variable_courante).variable_partagee,
((s_etat_processus).pointeur_variable_courante).origine)	((s_etat_processus).pointeur_variable_courante).origine)
== d_faux)	== NULL)
{	{
liberation(s_etat_processus, s_objet);	liberation(s_etat_processus, s_objet);

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.48
changed lines
	Added in v.1.79