version 1.211, 2013/03/20 17:11:45
|
version 1.231, 2013/09/26 14:46:15
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.13 |
RPL/2 (R) version 4.1.16 |
Copyright (C) 1989-2013 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 18
|
Line 18
|
along with RPL/2. If not, write to info@cecill.info. |
along with RPL/2. If not, write to info@cecill.info. |
================================================================================ |
================================================================================ |
*/ |
*/ |
|
#define DEBUG_ERREURS |
|
|
#ifndef INCLUSION_RPL |
#ifndef INCLUSION_RPL |
#define INCLUSION_RPL |
#define INCLUSION_RPL |
Line 73
|
Line 73
|
#include <errno.h> |
#include <errno.h> |
#include <stdarg.h> |
#include <stdarg.h> |
#include <poll.h> |
#include <poll.h> |
|
#include <signal.h> |
|
|
#ifndef RPLARGS |
#ifndef RPLARGS |
# include <sys/mman.h> |
# include <sys/mman.h> |
Line 154
|
Line 155
|
# endif |
# endif |
|
|
# include <setjmp.h> |
# include <setjmp.h> |
# include <signal.h> |
|
# include <termios.h> |
# include <termios.h> |
# include <time.h> |
# include <time.h> |
# include <unistd.h> |
# include <unistd.h> |
Line 164
|
Line 164
|
# include "readline.h" |
# include "readline.h" |
# include "termcap.h" |
# include "termcap.h" |
# include "iconv.h" |
# include "iconv.h" |
|
# include "zlib.h" |
|
|
# include "openssl/evp.h" |
# include "openssl/evp.h" |
# ifndef OPENSSL_NO_MD2 |
# ifndef OPENSSL_NO_MD2 |
Line 317 typedef struct queue_signaux
|
Line 318 typedef struct queue_signaux
|
# ifndef SEMAPHORES_NOMMES |
# ifndef SEMAPHORES_NOMMES |
sem_t semaphore; |
sem_t semaphore; |
sem_t signalisation; |
sem_t signalisation; |
|
sem_t arret_signalisation; |
# endif |
# endif |
# else |
# else |
sem_t semaphore; |
sem_t semaphore; |
sem_t signalisation; |
sem_t signalisation; |
|
sem_t arret_signalisation; |
# endif |
# endif |
|
|
volatile int pointeur_lecture; |
volatile int pointeur_lecture; |
Line 341 __EXTERN__ int f_queue_signaux;
|
Line 344 __EXTERN__ int f_queue_signaux;
|
# ifdef SEMAPHORES_NOMMES |
# ifdef SEMAPHORES_NOMMES |
__EXTERN__ sem_t *semaphore_queue_signaux; |
__EXTERN__ sem_t *semaphore_queue_signaux; |
__EXTERN__ sem_t *semaphore_signalisation; |
__EXTERN__ sem_t *semaphore_signalisation; |
|
__EXTERN__ sem_t *semaphore_arret_signalisation; |
# endif |
# endif |
#endif |
#endif |
|
|
Line 478 union semun
|
Line 482 union semun
|
|
|
__EXTERN__ pthread_mutex_t mutex_liste_threads |
__EXTERN__ pthread_mutex_t mutex_liste_threads |
__STATIC_MUTEX_INITIALIZATION__; |
__STATIC_MUTEX_INITIALIZATION__; |
__EXTERN__ pthread_mutex_t mutex_gestionnaires_signaux_atomique |
|
__STATIC_MUTEX_INITIALIZATION__; |
|
__EXTERN__ pthread_mutex_t mutex_creation_variable_partagee |
__EXTERN__ pthread_mutex_t mutex_creation_variable_partagee |
__STATIC_MUTEX_INITIALIZATION__; |
__STATIC_MUTEX_INITIALIZATION__; |
__EXTERN__ pthread_mutex_t mutex_sections_critiques; |
__EXTERN__ pthread_mutex_t mutex_sections_critiques; |
Line 491 union semun
|
Line 493 union semun
|
#endif |
#endif |
|
|
#ifdef SEMAPHORES_NOMMES |
#ifdef SEMAPHORES_NOMMES |
#define SEM_FORK 0 |
#define SEM_FORK 0 |
#define SEM_QUEUE 1 |
#define SEM_QUEUE 1 |
#define SEM_SIGNAUX 2 |
#define SEM_SIGNAUX 2 |
#define SEM_SIGNALISATION 3 |
#define SEM_SIGNALISATION 3 |
|
#define SEM_ARRET_SIGNALISATION 4 |
sem_t *sem_init2(unsigned int valeur, pid_t pid, int ordre); |
sem_t *sem_init2(unsigned int valeur, pid_t pid, int ordre); |
sem_t *sem_init3(unsigned int valeur, pid_t pid, pthread_t tid, int ordre); |
sem_t *sem_init3(unsigned int valeur, pid_t pid, pthread_t tid, int ordre); |
int sem_destroy2(sem_t *semaphore_p, pid_t pid, int ordre); |
int sem_destroy2(sem_t *semaphore_p, pid_t pid, int ordre); |
Line 1127 typedef struct objet
|
Line 1130 typedef struct objet
|
#ifndef RPLARGS |
#ifndef RPLARGS |
typedef struct fichier |
typedef struct fichier |
{ |
{ |
unsigned long descripteur; |
int descripteur; |
|
|
unsigned char acces; /* S/D/I */ |
unsigned char acces; /* S/D/I */ |
unsigned char binaire; /* Y/N/F */ |
unsigned char binaire; /* Y/N/F */ |
Line 1220 typedef struct bibliotheque
|
Line 1223 typedef struct bibliotheque
|
#ifndef RPLARGS |
#ifndef RPLARGS |
typedef struct descripteur_fichier |
typedef struct descripteur_fichier |
{ |
{ |
unsigned long identifiant; |
int identifiant; |
|
|
unsigned char effacement; |
unsigned char effacement; |
unsigned char type; // C (file *) ou S (sqlite *) |
unsigned char type; // C (file *) ou S (sqlite *) |
Line 1459 typedef struct descripteur_thread
|
Line 1462 typedef struct descripteur_thread
|
int pipe_injections[2]; |
int pipe_injections[2]; |
int pipe_nombre_injections[2]; |
int pipe_nombre_injections[2]; |
int pipe_interruptions[2]; |
int pipe_interruptions[2]; |
int pipe_nombre_objets_attente[2]; |
// pipe_nombre_elements_attente == 0 => initialisation ou terminaison |
int pipe_nombre_interruptions_attente[2]; |
// pipe_nombre_elements_attente == 1 => objet en attente |
|
// pipe_nombre_elements_attente == 2 => interruption en attente |
|
int pipe_nombre_elements_attente[2]; |
int pipe_acquittement[2]; |
int pipe_acquittement[2]; |
|
|
volatile integer8 nombre_objets_dans_pipe; |
volatile integer8 nombre_objets_dans_pipe; |
Line 1806 typedef struct arbre_variables_partagees
|
Line 1811 typedef struct arbre_variables_partagees
|
do { \ |
do { \ |
pthread_mutexattr_t attributs_mutex; \ |
pthread_mutexattr_t attributs_mutex; \ |
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_RECURSIVE); \ |
pthread_mutex_init(&(mutex), &attributs_mutex); \ |
pthread_mutex_init(&(mutex), &attributs_mutex); \ |
pthread_mutexattr_destroy(&attributs_mutex); \ |
pthread_mutexattr_destroy(&attributs_mutex); \ |
} while(0) |
} while(0) |
Line 1823 typedef struct tableau_variables
|
Line 1828 typedef struct tableau_variables
|
|
|
logical1 variable_verrouillee; |
logical1 variable_verrouillee; |
logical1 variable_masquee; |
logical1 variable_masquee; |
|
pthread_mutex_t *mutex; |
union_position_variable variable_statique; |
union_position_variable variable_statique; |
union_position_variable variable_partagee; |
union_position_variable variable_partagee; |
} struct_tableau_variables; |
} struct_tableau_variables; |
Line 1943 typedef struct processus
|
Line 1949 typedef struct processus
|
int pipe_injections; |
int pipe_injections; |
int pipe_nombre_injections; |
int pipe_nombre_injections; |
int pipe_interruptions; |
int pipe_interruptions; |
int pipe_nombre_objets_attente; |
int pipe_nombre_elements_attente; |
int pipe_nombre_interruptions_attente; |
|
int nombre_objets_envoyes_non_lus; |
int nombre_objets_envoyes_non_lus; |
int nombre_objets_injectes; |
int nombre_objets_injectes; |
|
|
Line 2180 typedef struct processus
|
Line 2185 typedef struct processus
|
/* Traitement des erreurs */ |
/* Traitement des erreurs */ |
|
|
int erreur_compilation; |
int erreur_compilation; |
int erreur_execution; |
volatile int erreur_execution; |
int erreur_systeme; |
volatile int erreur_systeme; |
|
|
struct_objet *s_objet_errone; |
struct_objet *s_objet_errone; |
struct_objet *s_objet_erreur; |
struct_objet *s_objet_erreur; |
Line 2302 typedef struct processus
|
Line 2307 typedef struct processus
|
struct_liste_profilage2 *pile_profilage_fonctions; |
struct_liste_profilage2 *pile_profilage_fonctions; |
struct timeval horodatage_profilage; |
struct timeval horodatage_profilage; |
|
|
// Mutex spécifique au processus et donnant accès à la pile des processus |
|
pthread_mutex_t mutex; |
|
pthread_mutex_t mutex_allocation; |
pthread_mutex_t mutex_allocation; |
|
pthread_mutex_t mutex_interruptions; |
|
pthread_mutex_t mutex_pile_processus; |
|
pthread_mutex_t mutex_signaux; |
|
|
// Mutex autorisant les fork() |
// Mutex autorisant les fork() |
sem_t __PTR__ semaphore_fork; |
sem_t __PTR__ semaphore_fork; |
Line 2315 typedef struct processus
|
Line 2321 typedef struct processus
|
pthread_mutex_t protection_liste_mutexes; |
pthread_mutex_t protection_liste_mutexes; |
unsigned int sections_critiques; |
unsigned int sections_critiques; |
|
|
/* Drapeau nécessaire à RESTART */ |
/* Variable d'initialisation pour SCHED */ |
|
|
|
logical1 initialisation_scheduler; |
|
|
|
/* Drapeau nécessaire à RESTART */ |
|
|
volatile logical1 requete_redemarrage; |
volatile logical1 requete_redemarrage; |
|
|
Line 2482 void instruction_col_fleche(struct_proce
|
Line 2492 void instruction_col_fleche(struct_proce
|
void instruction_col_moins(struct_processus *s_etat_processus); |
void instruction_col_moins(struct_processus *s_etat_processus); |
void instruction_col_plus(struct_processus *s_etat_processus); |
void instruction_col_plus(struct_processus *s_etat_processus); |
void instruction_comb(struct_processus *s_etat_processus); |
void instruction_comb(struct_processus *s_etat_processus); |
|
void instruction_compress(struct_processus *s_etat_processus); |
void instruction_con(struct_processus *s_etat_processus); |
void instruction_con(struct_processus *s_etat_processus); |
void instruction_cond(struct_processus *s_etat_processus); |
void instruction_cond(struct_processus *s_etat_processus); |
void instruction_cont(struct_processus *s_etat_processus); |
void instruction_cont(struct_processus *s_etat_processus); |
Line 2789 void instruction_return(struct_processus
|
Line 2800 void instruction_return(struct_processus
|
void instruction_revlist(struct_processus *s_etat_processus); |
void instruction_revlist(struct_processus *s_etat_processus); |
void instruction_rewind(struct_processus *s_etat_processus); |
void instruction_rewind(struct_processus *s_etat_processus); |
void instruction_rfuse(struct_processus *s_etat_processus); |
void instruction_rfuse(struct_processus *s_etat_processus); |
|
void instruction_rgdl(struct_processus *s_etat_processus); |
|
void instruction_rgdr(struct_processus *s_etat_processus); |
void instruction_rl(struct_processus *s_etat_processus); |
void instruction_rl(struct_processus *s_etat_processus); |
void instruction_rlb(struct_processus *s_etat_processus); |
void instruction_rlb(struct_processus *s_etat_processus); |
void instruction_rnd(struct_processus *s_etat_processus); |
void instruction_rnd(struct_processus *s_etat_processus); |
Line 2908 void instruction_t_vers_l(struct_process
|
Line 2921 void instruction_t_vers_l(struct_process
|
|
|
void instruction_ucase(struct_processus *s_etat_processus); |
void instruction_ucase(struct_processus *s_etat_processus); |
void instruction_uchol(struct_processus *s_etat_processus); |
void instruction_uchol(struct_processus *s_etat_processus); |
|
void instruction_uncompress(struct_processus *s_etat_processus); |
void instruction_unlock(struct_processus *s_etat_processus); |
void instruction_unlock(struct_processus *s_etat_processus); |
void instruction_unprotect(struct_processus *s_etat_processus); |
void instruction_unprotect(struct_processus *s_etat_processus); |
void instruction_until(struct_processus *s_etat_processus); |
void instruction_until(struct_processus *s_etat_processus); |