rpl/src/rpl.c - diff

Return to rpl.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/rpl.c between versions 1.84 and 1.94

version 1.84, 2011/09/14 17:56:00	version 1.94, 2011/09/21 09:09:01
Line 23	Line 23
#define MAIN_RPL	#define MAIN_RPL
#include "rpl-conv.h"	#include "rpl-conv.h"

#ifdef IPCS_SYSV
#ifndef OS2
unsigned char *chemin_semaphores_SysV;
#endif
#endif


/*	/*
================================================================================	================================================================================
Line 42 rplinit(int argc, char *argv[], unsigned	Line 36 rplinit(int argc, char *argv[], unsigned
# include "copyright-conv.h"	# include "copyright-conv.h"
# include "licence-conv.h"	# include "licence-conv.h"

	char pile_signaux[SIGSTKSZ];

file *f_source;	file *f_source;

int erreur_historique;	int erreur_historique;
Line 105 rplinit(int argc, char *argv[], unsigned	Line 101 rplinit(int argc, char *argv[], unsigned
volatile unsigned char traitement_fichier_temporaire;	volatile unsigned char traitement_fichier_temporaire;

errno = 0;	errno = 0;
	s_queue_signaux = NULL;
	routine_recursive = 0;
pid_processus_pere = getpid();	pid_processus_pere = getpid();

# ifdef DEBUG_MEMOIRE	# ifdef DEBUG_MEMOIRE
Line 114 rplinit(int argc, char *argv[], unsigned	Line 112 rplinit(int argc, char *argv[], unsigned
setvbuf(stdout, NULL, _IOLBF, 0);	setvbuf(stdout, NULL, _IOLBF, 0);
setvbuf(stderr, NULL, _IOLBF, 0);	setvbuf(stderr, NULL, _IOLBF, 0);

// mutex_liste_thread est dévérouillé par défaut.
// mutex_gestionnaires_signaux et mutex_gestionnaires_signaux_atomique
// sont verrouillés par défaut.

pthread_mutex_lock(&mutex_gestionnaires_signaux_atomique);

# ifndef SEMAPHORES_NOMMES	# ifndef SEMAPHORES_NOMMES
sem_init(&semaphore_gestionnaires_signaux, 0, 0);	sem_init(&semaphore_gestionnaires_signaux, 0, 0);
# else	# else
semaphore_gestionnaires_signaux = sem_init2(0, sem_gestionnaires_signaux);	semaphore_gestionnaires_signaux = sem_init2(0, getpid(), SEM_SIGNAUX);

if (semaphore_gestionnaires_signaux == SEM_FAILED)	if (semaphore_gestionnaires_signaux == SEM_FAILED)
{	{
Line 187 rplinit(int argc, char *argv[], unsigned	Line 179 rplinit(int argc, char *argv[], unsigned
(*s_etat_processus).exception = d_ep;	(*s_etat_processus).exception = d_ep;
(*s_etat_processus).erreur_systeme = d_es;	(*s_etat_processus).erreur_systeme = d_es;
(*s_etat_processus).erreur_execution = d_ex;	(*s_etat_processus).erreur_execution = d_ex;
(*s_etat_processus).compteur_violation_d_acces = 0;

(*s_etat_processus).rpl_home = rpl_home;	(*s_etat_processus).rpl_home = rpl_home;

Line 202 rplinit(int argc, char *argv[], unsigned	Line 193 rplinit(int argc, char *argv[], unsigned
&attributs_mutex);	&attributs_mutex);
pthread_mutexattr_destroy(&attributs_mutex);	pthread_mutexattr_destroy(&attributs_mutex);

pthread_mutexattr_init(&attributs_mutex);	# ifndef SEMAPHORES_NOMMES
pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);	sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
pthread_mutex_init(&((*s_etat_processus).mutex_fork),	# else
&attributs_mutex);	if (((*s_etat_processus).semaphore_fork = sem_init3(0, getpid(),
pthread_mutexattr_destroy(&attributs_mutex);	pthread_self(), SEM_FORK)) == SEM_FAILED)
pthread_mutex_lock(&((*s_etat_processus).mutex_fork));	{
	if ((*s_etat_processus).langue == 'F')
	{
	uprintf("+++Système : Mémoire insuffisante\n");
	}
	else
	{
	uprintf("+++System : Not enough memory\n");
	}

	return(EXIT_FAILURE);
	}
	# endif

pthread_mutexattr_init(&attributs_mutex);	pthread_mutexattr_init(&attributs_mutex);
pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
Line 230 rplinit(int argc, char *argv[], unsigned	Line 233 rplinit(int argc, char *argv[], unsigned
(*s_etat_processus).chemin_fichiers_temporaires =	(*s_etat_processus).chemin_fichiers_temporaires =
recherche_chemin_fichiers_temporaires(s_etat_processus);	recherche_chemin_fichiers_temporaires(s_etat_processus);

# ifdef IPCS_SYSV
# ifndef OS2
chemin_semaphores_SysV =
(*s_etat_processus).chemin_fichiers_temporaires;
# endif
# endif

insertion_thread(s_etat_processus, d_vrai);	insertion_thread(s_etat_processus, d_vrai);
creation_queue_signaux(s_etat_processus);	creation_queue_signaux(s_etat_processus);

Line 320 rplinit(int argc, char *argv[], unsigned	Line 316 rplinit(int argc, char *argv[], unsigned
home = "";	home = "";
}	}

// Initialisation d'une pile de signal pour récupérer les	# ifdef HAVE_STACK_OVERFLOW_RECOVERY
// débordement de pile	if (stackoverflow_install_handler(interruption_depassement_pile,
	pile_signaux, sizeof(pile_signaux)) != 0)
# if !defined(Cygwin) && !defined(OpenBSD)
if (((*s_etat_processus).pile_signal.ss_sp =
malloc((*s_etat_processus).pile_signal.ss_size =
SIGSTKSZ)) == NULL)
{
erreur = d_es_allocation_memoire;

if ((*s_etat_processus).langue == 'F')
{	{
printf("+++Système : Mémoire insuffisante\n");	erreur = d_es_signal;
}
else
{
printf("+++System : Not enough memory\n");
}

return(EXIT_FAILURE);
}

(*s_etat_processus).pile_signal.ss_flags = 0;

if (sigaltstack(&((*s_etat_processus).pile_signal), NULL) != 0)	if ((*s_etat_processus).langue == 'F')
{	{
erreur = d_es_signal;	printf("+++Système : Initialisation de la pile alternative "
	"impossible\n");
	}
	else
	{
	printf("+++System : Initialization of alternate "
	"stack failed\n");
	}

	return(EXIT_FAILURE);
	}
	# else
if ((*s_etat_processus).langue == 'F')	if ((*s_etat_processus).langue == 'F')
{	{
printf("+++Système : Initialisation de la pile spécifique de signal"	printf("+++Attention : Le système ne supporte pas de pile "
" impossible\n");	"alternative\n");
}	}
else	else
{	{
printf("+++System : Initialization of signal stack failed\n");	printf("+++Warning : Operating system does not support alternate "
	"stack\n");
}	}

return(EXIT_FAILURE);
}
# endif	# endif

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

if (sigaction(SIGINT, &action, NULL) != 0)	if (sigaction(SIGINT, &action, NULL) != 0)
{	{
Line 440 rplinit(int argc, char *argv[], unsigned	Line 426 rplinit(int argc, char *argv[], unsigned
}	}

action.sa_handler = interruption2;	action.sa_handler = interruption2;
action.sa_flags = SA_NODEFER \| SA_ONSTACK;	action.sa_flags = 0;

if (sigaction(SIGTSTP, &action, NULL) != 0)	if (sigaction(SIGTSTP, &action, NULL) != 0)
{	{
Line 478 rplinit(int argc, char *argv[], unsigned	Line 464 rplinit(int argc, char *argv[], unsigned
}	}

action.sa_handler = interruption5;	action.sa_handler = interruption5;
action.sa_flags = SA_NODEFER \| SA_ONSTACK;	action.sa_flags = 0;

if (sigaction(SIGPIPE, &action, NULL) != 0)	if (sigaction(SIGPIPE, &action, NULL) != 0)
{	{
Line 518 rplinit(int argc, char *argv[], unsigned	Line 504 rplinit(int argc, char *argv[], unsigned
}	}

action.sa_handler = interruption1;	action.sa_handler = interruption1;
action.sa_flags = SA_NODEFER \| SA_ONSTACK;	action.sa_flags = 0;

if (sigaction(SIGALRM, &action, NULL) != 0)	if (sigaction(SIGUSR1, &action, NULL) != 0)
{	{
erreur = d_es_signal;	erreur = d_es_signal;

Line 538 rplinit(int argc, char *argv[], unsigned	Line 524 rplinit(int argc, char *argv[], unsigned
}	}

signal_test = SIGTEST;	signal_test = SIGTEST;
kill(getpid(), SIGALRM);	kill(getpid(), SIGUSR1);

if (signal_test != SIGALRM)	if (signal_test != SIGUSR1)
{	{
erreur = d_es_signal;	erreur = d_es_signal;

Line 605 rplinit(int argc, char *argv[], unsigned	Line 591 rplinit(int argc, char *argv[], unsigned
option_t = d_faux;	option_t = d_faux;
option_v = d_faux;	option_v = d_faux;

	// Lorsque le programme est appelé depuis un shebang, argv[0] contient
	// le chemin du programme et argv[1] tous les arguments.
	// argv[2] contient quant à lui le nom du script RPL/2.
	//
	// Exemple :
	// argv[0] : /usr/local/bin/rpl
	// argv[1] : -csdp -t 800
	// argv[2] : ./on_exit.rpl

while((--argc) > 0)	while((--argc) > 0)
{	{
if ((*(++argv))[0] == '-')	if ((*(++argv))[0] == '-')
Line 1400 rplinit(int argc, char *argv[], unsigned	Line 1395 rplinit(int argc, char *argv[], unsigned
break;	break;
}	}

	case '-':
	case ' ':
	{
	break;
	}

default :	default :
{	{
if ((*s_etat_processus).langue == 'F')	if ((*s_etat_processus).langue == 'F')
Line 1444 rplinit(int argc, char *argv[], unsigned	Line 1445 rplinit(int argc, char *argv[], unsigned
}	}
}	}

	/*
	* Dans le cas où le programme est appelé avec l'option -d,
	* on ne récupère par les signaux de violation d'accès. On
	* tente simplement la récupération des dépassements de pile.
	*/

if (debug == d_faux)	if (debug == d_faux)
{	{

	# ifdef HAVE_SIGSEGV_RECOVERY
	if (sigsegv_install_handler(interruption_violation_access) != 0)
	{
	erreur = d_es_signal;

	if ((*s_etat_processus).langue == 'F')
	{
	printf("+++Système : Initialisation de la pile alternative "
	"impossible\n");
	}
	else
	{
	printf("+++System : Initialization of alternate "
	"stack failed\n");
	}

	return(EXIT_FAILURE);
	}
	# else
action.sa_handler = interruption3;	action.sa_handler = interruption3;
action.sa_flags = SA_NODEFER \| SA_ONSTACK;	action.sa_flags = 0;

if (sigaction(SIGSEGV, &action, NULL) != 0)	if (sigaction(SIGSEGV, &action, NULL) != 0)
{	{
Line 1465 rplinit(int argc, char *argv[], unsigned	Line 1492 rplinit(int argc, char *argv[], unsigned
return(EXIT_FAILURE);	return(EXIT_FAILURE);
}	}

	signal_test = SIGTEST;
	kill(getpid(), SIGSEGV);

	if (signal_test != SIGSEGV)
	{
	erreur = d_es_signal;

	if ((*s_etat_processus).langue == 'F')
	{
	printf("+++Système : Initialisation des signaux POSIX "
	"impossible\n");
	}
	else
	{
	printf("+++System : Initialization of POSIX signals "
	"failed\n");
	}

	return(EXIT_FAILURE);
	}
	# endif

if (sigaction(SIGBUS, &action, NULL) != 0)	if (sigaction(SIGBUS, &action, NULL) != 0)
{	{
if ((*s_etat_processus).langue == 'F')	if ((*s_etat_processus).langue == 'F')
Line 1480 rplinit(int argc, char *argv[], unsigned	Line 1529 rplinit(int argc, char *argv[], unsigned

return(EXIT_FAILURE);	return(EXIT_FAILURE);
}	}

	signal_test = SIGTEST;
	kill(getpid(), SIGBUS);

	if (signal_test != SIGBUS)
	{
	erreur = d_es_signal;

	if ((*s_etat_processus).langue == 'F')
	{
	printf("+++Système : Initialisation des signaux POSIX "
	"impossible\n");
	}
	else
	{
	printf("+++System : Initialization of POSIX signals "
	"failed\n");
	}

	return(EXIT_FAILURE);
	}

}	}

if (option_n == d_vrai)	if (option_n == d_vrai)
{	{
action.sa_handler = interruption4;	action.sa_handler = interruption4;
action.sa_flags = SA_ONSTACK;	action.sa_flags = 0;

if (sigaction(SIGHUP, &action, NULL) != 0)	if (sigaction(SIGHUP, &action, NULL) != 0)
{	{
Line 2629 rplinit(int argc, char *argv[], unsigned	Line 2700 rplinit(int argc, char *argv[], unsigned
lancement_daemon(s_etat_processus);	lancement_daemon(s_etat_processus);
}	}

// A FIXER
// création signaux
if (option_p == d_faux)	if (option_p == d_faux)
{	{
if (setjmp(contexte_initial) == 0)	if (setjmp(contexte_initial) == 0)
Line 2673 rplinit(int argc, char *argv[], unsigned	Line 2742 rplinit(int argc, char *argv[], unsigned
}	}
}	}
}	}
// A FIXER
// destruction signaux
}	}

liberation(s_etat_processus, (*s_etat_processus).at_exit);	liberation(s_etat_processus, (*s_etat_processus).at_exit);
Line 2909 rplinit(int argc, char *argv[], unsigned	Line 2976 rplinit(int argc, char *argv[], unsigned
.thread).nombre_objets_dans_pipe--;	.thread).nombre_objets_dans_pipe--;

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

if (sigaction(SIGPIPE, &action, &registre)	if (sigaction(SIGPIPE, &action, &registre)
!= 0)	!= 0)
Line 2955 rplinit(int argc, char *argv[], unsigned	Line 3022 rplinit(int argc, char *argv[], unsigned
}	}

nanosleep(&attente, NULL);	nanosleep(&attente, NULL);
	scrutation_interruptions(s_etat_processus);
pthread_mutex_lock(&((*s_etat_processus).mutex));	pthread_mutex_lock(&((*s_etat_processus).mutex));
}	}

Line 3480 rplinit(int argc, char *argv[], unsigned	Line 3548 rplinit(int argc, char *argv[], unsigned
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).mutex_allocation));

pthread_mutex_unlock(&((*s_etat_processus).mutex_fork));	# ifndef SEMAPHORES_NOMMES
pthread_mutex_destroy(&((*s_etat_processus).mutex_fork));	sem_post(&((*s_etat_processus).semaphore_fork));
	sem_destroy(&((*s_etat_processus).semaphore_fork));
	# else
	sem_post((*s_etat_processus).semaphore_fork);
	sem_destroy3((*s_etat_processus).semaphore_fork, getpid(), pthread_self(),
	SEM_FORK);
	# endif

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

Line 3493 rplinit(int argc, char *argv[], unsigned	Line 3567 rplinit(int argc, char *argv[], unsigned
sem_destroy(&semaphore_gestionnaires_signaux);	sem_destroy(&semaphore_gestionnaires_signaux);
# else	# else
sem_post(semaphore_gestionnaires_signaux);	sem_post(semaphore_gestionnaires_signaux);
sem_destroy2(semaphore_gestionnaires_signaux, sem_gestionnaires_signaux);	sem_destroy2(semaphore_gestionnaires_signaux, getpid(), SEM_SIGNAUX);
# endif	# endif

destruction_queue_signaux(s_etat_processus);	destruction_queue_signaux(s_etat_processus);
Line 3507 rplinit(int argc, char *argv[], unsigned	Line 3581 rplinit(int argc, char *argv[], unsigned
analyse_post_mortem();	analyse_post_mortem();
# endif	# endif

	# ifdef HAVE_STACK_OVERFLOW_RECOVERY
	stackoverflow_deinstall_handler();
	# endif

	# ifdef HAVE_SIGSEGV_RECOVERY
	if (debug == d_faux)
	{
	sigsegv_deinstall_handler();
	}
	# endif

return((erreur == d_absence_erreur) ? EXIT_SUCCESS : EXIT_FAILURE);	return((erreur == d_absence_erreur) ? EXIT_SUCCESS : EXIT_FAILURE);
}	}

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.84
changed lines
	Added in v.1.94