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.125 and 1.136

version 1.125, 2012/12/13 16:59:43	version 1.136, 2013/03/21 11:30:31
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.11	RPL/2 (R) version 4.1.13
Copyright (C) 1989-2012 Dr. BERTRAND Joël	Copyright (C) 1989-2013 Dr. BERTRAND Joël

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

Line 51 rplinit(int argc, char argv[], char en	Line 51 rplinit(int argc, char argv[], char en
int erreur_historique;	int erreur_historique;
int option_P;	int option_P;

	integer8 i;

logical1 core;	logical1 core;
logical1 debug;	logical1 debug;
logical1 erreur_fichier;	logical1 erreur_fichier;
Line 80 rplinit(int argc, char argv[], char en	Line 82 rplinit(int argc, char argv[], char en

struct_processus *s_etat_processus;	struct_processus *s_etat_processus;

	struct_liste_variables_partagees *l_element_partage_courant;
	struct_liste_variables_partagees *l_element_partage_suivant;

struct_liste_variables_statiques *l_element_statique_courant;	struct_liste_variables_statiques *l_element_statique_courant;
struct_liste_variables_statiques *l_element_statique_suivant;	struct_liste_variables_statiques *l_element_statique_suivant;

	struct_arbre_variables_partagees *s_arbre_variables_partagees;
	struct_liste_variables_partagees *l_liste_variables_partagees;

struct sigaction action;	struct sigaction action;
struct sigaction registre;	struct sigaction registre;

Line 100 rplinit(int argc, char argv[], char en	Line 108 rplinit(int argc, char argv[], char en
unsigned char *ptr;	unsigned char *ptr;
unsigned char *tampon;	unsigned char *tampon;

unsigned long i;
unsigned long unite_fichier;	unsigned long unite_fichier;

void *l_element_courant;	void *l_element_courant;
Line 213 rplinit(int argc, char argv[], char en	Line 220 rplinit(int argc, char argv[], char en
return(EXIT_FAILURE);	return(EXIT_FAILURE);
}	}

if ((arg_exec = malloc((argc + 1) * sizeof(char *))) == NULL)	if ((arg_exec = malloc((((size_t) argc) + 1) * sizeof(char *))) == NULL)
{	{
# ifndef SEMAPHORES_NOMMES	# ifndef SEMAPHORES_NOMMES
sem_post(&semaphore_gestionnaires_signaux);	sem_post(&semaphore_gestionnaires_signaux);
Line 235 rplinit(int argc, char argv[], char en	Line 242 rplinit(int argc, char argv[], char en
return(EXIT_FAILURE);	return(EXIT_FAILURE);
}	}

for(i = 0; i < (unsigned long) argc; i++)	for(i = 0; i < argc; i++)
{	{
arg_exec[i] = argv[i];	arg_exec[i] = argv[i];
}	}
Line 267 rplinit(int argc, char argv[], char en	Line 274 rplinit(int argc, char argv[], char en
pthread_mutex_init(&mutex_sections_critiques, &attributs_mutex);	pthread_mutex_init(&mutex_sections_critiques, &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(&mutex_liste_variables_partagees, &attributs_mutex);
	pthread_mutexattr_destroy(&attributs_mutex);

# ifndef SEMAPHORES_NOMMES	# ifndef SEMAPHORES_NOMMES
sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);	sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
# else	# else
Line 424 rplinit(int argc, char argv[], char en	Line 436 rplinit(int argc, char argv[], char en

if ((*s_etat_processus).langue == 'F')	if ((*s_etat_processus).langue == 'F')
{	{
printf("+++Copyright (C) 1989 à 2011, 2012 BERTRAND Joël\n");	printf("+++Copyright (C) 1989 à 2012, 2013 BERTRAND Joël\n");
}	}
else	else
{	{
printf("+++Copyright (C) 1989 to 2011, 2012 BERTRAND Joel\n");	printf("+++Copyright (C) 1989 to 2012, 2013 BERTRAND Joel\n");
}	}

if (getenv("HOME") != NULL)	if (getenv("HOME") != NULL)
Line 582 rplinit(int argc, char argv[], char en	Line 594 rplinit(int argc, char argv[], char en
}	}

signal_test = SIGTEST;	signal_test = SIGTEST;
kill(getpid(), SIGINT);	raise(SIGINT);

attente.tv_sec = 0;	attente.tv_sec = 0;
attente.tv_nsec = 1000000;	attente.tv_nsec = 1000000;
Line 669 rplinit(int argc, char argv[], char en	Line 681 rplinit(int argc, char argv[], char en
}	}

signal_test = SIGTEST;	signal_test = SIGTEST;
kill(getpid(), SIGTERM);	raise(SIGTERM);

attente.tv_sec = 0;	attente.tv_sec = 0;
attente.tv_nsec = 1000000;	attente.tv_nsec = 1000000;
Line 756 rplinit(int argc, char argv[], char en	Line 768 rplinit(int argc, char argv[], char en
}	}

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

attente.tv_sec = 0;	attente.tv_sec = 0;
attente.tv_nsec = 1000000;	attente.tv_nsec = 1000000;
Line 844 rplinit(int argc, char argv[], char en	Line 856 rplinit(int argc, char argv[], char en
}	}

signal_test = SIGTEST;	signal_test = SIGTEST;
kill(getpid(), SIGTSTP);	raise(SIGTSTP);

attente.tv_sec = 0;	attente.tv_sec = 0;
attente.tv_nsec = 1000000;	attente.tv_nsec = 1000000;
Line 934 rplinit(int argc, char argv[], char en	Line 946 rplinit(int argc, char argv[], char en
}	}

signal_test = SIGTEST;	signal_test = SIGTEST;
kill(getpid(), SIGPIPE);	raise(SIGPIPE);

attente.tv_sec = 0;	attente.tv_sec = 0;
attente.tv_nsec = 1000000;	attente.tv_nsec = 1000000;
Line 1024 rplinit(int argc, char argv[], char en	Line 1036 rplinit(int argc, char argv[], char en
}	}

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

attente.tv_sec = 0;	attente.tv_sec = 0;
attente.tv_nsec = 1000000;	attente.tv_nsec = 1000000;
Line 2242 rplinit(int argc, char argv[], char en	Line 2254 rplinit(int argc, char argv[], char en
}	}

(*s_etat_processus).longueur_definitions_chainees =	(*s_etat_processus).longueur_definitions_chainees =
strlen((*s_etat_processus)	(integer8) strlen((*s_etat_processus)
.definitions_chainees);	.definitions_chainees);

break;	break;
Line 2789 rplinit(int argc, char argv[], char en	Line 2801 rplinit(int argc, char argv[], char en
}	}

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

attente.tv_sec = 0;	attente.tv_sec = 0;
attente.tv_nsec = 1000000;	attente.tv_nsec = 1000000;
Line 2889 rplinit(int argc, char argv[], char en	Line 2901 rplinit(int argc, char argv[], char en
}	}

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

attente.tv_sec = 0;	attente.tv_sec = 0;
attente.tv_nsec = 1000000;	attente.tv_nsec = 1000000;
Line 3425 rplinit(int argc, char argv[], char en	Line 3437 rplinit(int argc, char argv[], char en

(*s_etat_processus).s_arbre_variables = NULL;	(*s_etat_processus).s_arbre_variables = NULL;
(*s_etat_processus).l_liste_variables_par_niveau = NULL;	(*s_etat_processus).l_liste_variables_par_niveau = NULL;
	(*s_etat_processus).l_liste_variables_statiques = NULL;
(*s_etat_processus).gel_liste_variables = d_faux;	(*s_etat_processus).gel_liste_variables = d_faux;
	s_arbre_variables_partagees = NULL;
	l_liste_variables_partagees = NULL;
	(*s_etat_processus).s_arbre_variables_partagees =
	&s_arbre_variables_partagees;
	(*s_etat_processus).l_liste_variables_partagees =
	&l_liste_variables_partagees;
(*s_etat_processus).pointeur_variable_courante = NULL;	(*s_etat_processus).pointeur_variable_courante = NULL;
(*s_etat_processus).pointeur_variable_statique_courante = NULL;	(*s_etat_processus).pointeur_variable_statique_courante = NULL;
(*s_etat_processus).l_liste_variables_statiques = NULL;	(*s_etat_processus).pointeur_variable_partagee_courante = NULL;
(*s_etat_processus).niveau_courant = 0;	(*s_etat_processus).niveau_courant = 0;
(*s_etat_processus).niveau_initial = 0;	(*s_etat_processus).niveau_initial = 0;
(*s_etat_processus).creation_variables_statiques = d_faux;	(*s_etat_processus).creation_variables_statiques = d_faux;
Line 5362 rplinit(int argc, char argv[], char en	Line 5381 rplinit(int argc, char argv[], char en
l_element_courant = (void *)	l_element_courant = (void *)
(*s_etat_processus).l_base_pile_processus;	(*s_etat_processus).l_base_pile_processus;

for(i = 0; i < (unsigned long)	for(i = 0; i < ((((struct_processus_fils *)
((((struct_processus_fils *)
((((struct_liste_chainee *)	((((struct_liste_chainee *)
l_element_courant)).donnee).objet)).thread)	l_element_courant)).donnee).objet)).thread)
.nombre_objets_dans_pipe; i++)	.nombre_objets_dans_pipe; i++)
Line 5662 rplinit(int argc, char argv[], char en	Line 5680 rplinit(int argc, char argv[], char en
*/	*/

liberation_arbre_variables_partagees(s_etat_processus,	liberation_arbre_variables_partagees(s_etat_processus,
(*s_etat_processus).s_arbre_variables, d_vrai);	((s_etat_processus).s_arbre_variables_partagees));
liberation_arbre_variables(s_etat_processus,	liberation_arbre_variables(s_etat_processus,
(*s_etat_processus).s_arbre_variables, d_vrai);	(*s_etat_processus).s_arbre_variables, d_vrai);
free((*s_etat_processus).pointeurs_caracteres_variables);	free((*s_etat_processus).pointeurs_caracteres_variables);
Line 5678 rplinit(int argc, char argv[], char en	Line 5696 rplinit(int argc, char argv[], char en
l_element_statique_courant = l_element_statique_suivant;	l_element_statique_courant = l_element_statique_suivant;
}	}

	l_element_partage_courant = ((s_etat_processus)
	.l_liste_variables_partagees);

	while(l_element_partage_courant != NULL)
	{
	l_element_partage_suivant =
	(*l_element_partage_courant).suivant;
	free(l_element_partage_courant);
	l_element_partage_courant = l_element_partage_suivant;
	}

/*	/*
* Si resultats est non nul, rplinit a été appelé	* Si resultats est non nul, rplinit a été appelé
* depuis rpl() [librpl] et non main().	* depuis rpl() [librpl] et non main().
Line 5692 rplinit(int argc, char argv[], char en	Line 5721 rplinit(int argc, char argv[], char en
{	{
free((*resultats));	free((*resultats));

if (((resultats) = malloc(((s_etat_processus)	if (((*resultats) = malloc(((size_t)
.hauteur_pile_operationnelle + 1)	((*s_etat_processus)
	.hauteur_pile_operationnelle + 1))
* sizeof(unsigned char **))) != NULL)	* sizeof(unsigned char **))) != NULL)
{	{
(resultats)[(s_etat_processus)	(resultats)[(s_etat_processus)
Line 6015 rplinit(int argc, char argv[], char en	Line 6045 rplinit(int argc, char argv[], char en
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_destroy(&mutex_sections_critiques);	pthread_mutex_destroy(&mutex_sections_critiques);
	pthread_mutex_destroy(&mutex_liste_variables_partagees);

# ifndef SEMAPHORES_NOMMES	# ifndef SEMAPHORES_NOMMES
sem_post(&((*s_etat_processus).semaphore_fork));	sem_post(&((*s_etat_processus).semaphore_fork));

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.125
changed lines
	Added in v.1.136