rpl/src/gestion_processus.c - diff

Return to gestion_processus.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/gestion_processus.c between versions 1.75 and 1.106

version 1.75, 2014/07/17 08:07:18	version 1.106, 2025/04/15 10:17:51
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.19	RPL/2 (R) version 4.1.36
Copyright (C) 1989-2014 Dr. BERTRAND Joël	Copyright (C) 1989-2025 Dr. BERTRAND Joël

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

Line 83 surveillance_processus(void *argument)	Line 83 surveillance_processus(void *argument)
BUG(1, uprintf("General mutex error!\n"));	BUG(1, uprintf("General mutex error!\n"));
}	}

insertion_thread_surveillance(s_etat_processus, s_argument_thread);	nombre_threads_surveillance_processus++;

if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0)	if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0)
{	{
Line 91 surveillance_processus(void *argument)	Line 91 surveillance_processus(void *argument)
BUG(1, uprintf("General mutex error!\n"));	BUG(1, uprintf("General mutex error!\n"));
}	}

	insertion_thread_surveillance(s_etat_processus, s_argument_thread);

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

Line 362 surveillance_processus(void *argument)	Line 364 surveillance_processus(void *argument)
}	}
}	}

envoi_signal_thread((*s_argument_thread).thread_pere,	envoi_signal_thread(NULL,
	(*s_argument_thread).thread_pere,
rpl_siginject);	rpl_siginject);
break;	break;
}	}
Line 389 surveillance_processus(void *argument)	Line 392 surveillance_processus(void *argument)
}	}
else	else
{	{
perror("read");
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
}	}

Line 630 surveillance_processus(void *argument)	Line 632 surveillance_processus(void *argument)
d_es_processus;	d_es_processus;
}	}

envoi_signal_thread((*s_argument_thread).thread_pere,	envoi_signal_thread(NULL,
	(*s_argument_thread).thread_pere,
rpl_siginject);	rpl_siginject);

if (pthread_mutex_lock(&((*s_etat_processus)	if (pthread_mutex_lock(&((*s_etat_processus)
Line 1426 surveillance_processus(void *argument)	Line 1429 surveillance_processus(void *argument)
fflush(stdout);	fflush(stdout);
}	}

	if (pthread_mutex_unlock(&((*s_etat_processus)
	.mutex_pile_processus)) != 0)
	{
	(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;
	}

retrait_thread_surveillance(s_etat_processus, s_argument_thread);	retrait_thread_surveillance(s_etat_processus, s_argument_thread);

	if (pthread_mutex_lock(&((*s_etat_processus)
	.mutex_pile_processus)) != 0)
	{
	(*s_etat_processus).erreur_systeme_processus_fils = d_es_processus;
	}

	nombre_threads_surveillance_processus--;

if (pthread_mutex_unlock(&((*s_etat_processus)	if (pthread_mutex_unlock(&((*s_etat_processus)
.mutex_pile_processus)) != 0)	.mutex_pile_processus)) != 0)
{	{
Line 1436 surveillance_processus(void *argument)	Line 1453 surveillance_processus(void *argument)
}	}

pthread_exit(NULL);	pthread_exit(NULL);
return(NULL);
}	}


Line 2997 lecture_pipe(struct_processus *s_etat_pr	Line 3013 lecture_pipe(struct_processus *s_etat_pr
void	void
scrutation_injection(struct_processus *s_etat_processus)	scrutation_injection(struct_processus *s_etat_processus)
{	{
fd_set ensemble_descripteurs;

logical1 drapeau_erreur;	logical1 drapeau_erreur;
logical1 registre_arret_si_exception;	logical1 registre_arret_si_exception;

# ifdef PSELECT	struct pollfd fds;
struct timespec timeout;
# else
struct timeval timeout;
# endif

unsigned char tampon;	unsigned char tampon;
unsigned char tampon_profilage[20];	unsigned char tampon_profilage[20];

// Si on est dans le processus père, il n'y a rien à surveiller.

scrutation_interruptions(s_etat_processus);	scrutation_interruptions(s_etat_processus);

	// Si on est dans le processus père, il n'y a rien à surveiller.

if ((*s_etat_processus).var_volatile_processus_racine == 0)	if ((*s_etat_processus).var_volatile_processus_racine == 0)
{	{
FD_ZERO(&ensemble_descripteurs);	fds.fd = (*s_etat_processus).pipe_nombre_injections;
FD_SET((*s_etat_processus).pipe_nombre_injections,	fds.events = POLLIN;
&ensemble_descripteurs);	fds.revents = 0;

# ifdef PSELECT	if (poll(&fds, 1, 0) > 0)
timeout.tv_sec = 0;
timeout.tv_nsec = 0;

if (pselect((*s_etat_processus).pipe_nombre_injections + 1,
&ensemble_descripteurs, NULL, NULL, &timeout, NULL) > 0)
# else
timeout.tv_sec = 0;
timeout.tv_usec = 0;

if (select((*s_etat_processus).pipe_nombre_injections + 1,
&ensemble_descripteurs, NULL, NULL, &timeout) > 0)
# endif
{	{
if (read_atomic(s_etat_processus,	if (read_atomic(s_etat_processus,
(*s_etat_processus).pipe_nombre_injections,	(*s_etat_processus).pipe_nombre_injections,
Line 3190 scrutation_injection(struct_processus *s	Line 3188 scrutation_injection(struct_processus *s
}	}
}	}
}	}

}	}

return;	return;

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.75
changed lines
	Added in v.1.106