--- rpl/src/rpl.h 2011/09/07 18:53:53 1.116 +++ rpl/src/rpl.h 2011/09/20 14:36:30 1.130 @@ -99,11 +99,7 @@ # endif # include - -# ifdef _BROKEN_SIGINFO -# include -# include -# endif +# include # ifndef IPCS_SYSV # include @@ -126,16 +122,20 @@ ULONG *nopened; ULONG allocated; } sem_t; -# else +# else // IPCS_SYSV typedef struct { int sem; + int alloue; unsigned char *path; pid_t pid; + pthread_t tid; } sem_t; # endif -# define SEM_FAILED NULL +# ifndef SEM_FAILED +# define SEM_FAILED NULL +# endif sem_t *sem_open_SysV(const char *nom, int oflag, ...); int sem_init_SysV(sem_t *sem, int shared, unsigned int value); @@ -213,30 +213,68 @@ ================================================================================ */ -#ifdef _BROKEN_SIGINFO -# define SIGHANDLER_ARGS int signal -# ifdef SA_SIGINFO -# undef SA_SIGINFO -# endif -# define SA_SIGINFO 0 +enum signaux_rpl +{ + rpl_signull = 0, + rpl_sigint, + rpl_sigterm, + rpl_sigstart, // Signal envoyé par un père pour lancer son fils. + rpl_sigcont, // Signal de redémarrage d'un processus arrêté par + // SUSPEND + rpl_sigstop, // Signal d'arrêt envoyé par l'instruction STOP ou + // FUSE. (FSTOP) + rpl_sigabort, // Signal envoyé par l'instruction ABORT (à regrouper + // avec FABORT) + rpl_sigurg, // Signal d'arrêt urgent + rpl_siginject, // Signal indiquant la présence d'une donnée à lire + // envoyée depuis le père + rpl_sigalrm, // Signal d'alarme (erreur système) depuis un fils + rpl_sighup, + rpl_sigtstp, + rpl_sigexcept, + rpl_sigmax +}; -# ifndef __BROKEN_SIGINFO_ROUTINES__ +#define LONGUEUR_QUEUE_SIGNAUX 1024 -// pthread_kill() est une macro sous OS/2. -# ifdef pthread_kill -# undef pthread_kill -# endif +// Une structure s_queue_signaux est créée par processus (et non par thread). +// Elle est projetée dans un segment de mémoire partagée pour qu'elle soit +// accessible à la fois du père et des fils. -# define kill(a, b) kill_broken_siginfo(a, b) -# define pthread_kill(a, b) pthread_kill_broken_siginfo(a, b) +typedef struct queue_signaux +{ +# ifndef IPCS_SYSV +# ifndef SEMAPHORES_NOMMES + sem_t semaphore; +# endif +# else + sem_t semaphore; # endif - int kill_broken_siginfo(pid_t pid, int signal); - int pthread_kill_broken_siginfo(pthread_t tid, int signal); - pid_t origine_signal(int signal); - int queue_in(pid_t pid, int signal); -#else -# define SIGHANDLER_ARGS int signal, siginfo_t *siginfo, void *context + volatile int pointeur_lecture; + volatile int pointeur_ecriture; + + volatile struct + { + pid_t pid; + enum signaux_rpl signal; + } queue[LONGUEUR_QUEUE_SIGNAUX]; +} struct_queue_signaux; + +#ifndef RPLARGS +# ifndef MAIN_RPL + extern struct_queue_signaux *s_queue_signaux; + extern int f_queue_signaux; +# ifdef SEMAPHORES_NOMMES + extern sem_t *semaphore_queue_signaux; +# endif +# else + struct_queue_signaux *s_queue_signaux; + int f_queue_signaux; +# ifdef SEMAPHORES_NOMMES + sem_t *semaphore_queue_signaux; +# endif +# endif #endif #ifdef OpenBSD @@ -297,25 +335,7 @@ union semun // SIGPIPE // SIGALRM -// Arrêt par STOP -# define SIGFSTOP SIGUSR1 -// Démarrage d'un processus fils -# define SIGSTART SIGUSR2 -// Injection de données -# define SIGINJECT SIGQUIT -// Arrêt général -# ifndef OpenBSD -// La libpthread d'OpenBSD utilise SIGPROF -# define SIGABORT SIGPROF -# else -# define SIGABORT SIGTHR -# endif -// Arrêt d'un processus fils depuis autre chose que STOP -# if defined(Darwin) || defined(OpenBSD) -# define SIGFABORT SIGINFO -# else -# define SIGFABORT SIGPOLL -# endif +# define SIGTEST SIGUSR1 // Nombre d'interruptions disponibles # define d_NOMBRE_INTERRUPTIONS 64 @@ -383,97 +403,66 @@ typedef unsigned char t_8_bits; # endif # ifndef MAIN_RPL -# ifdef _BROKEN_SIGINFO - extern int *fifos_signaux; -# endif - extern jmp_buf contexte; extern jmp_buf contexte_initial; extern jmp_buf contexte_processus; extern jmp_buf contexte_thread; -# ifdef SEMAPHORES_NOMMES - extern pthread_mutex_t mutex_sem; -# endif + extern int signal_test; - extern pthread_key_t semaphore_fork_processus_courant; + extern pid_t pid_processus_pere; - extern sem_t # ifdef SEMAPHORES_NOMMES - * + extern pthread_mutex_t mutex_sem; # endif - semaphore_liste_threads; - extern sem_t -# ifdef SEMAPHORES_NOMMES - * -# endif - semaphore_gestionnaires_signaux; + extern pthread_mutex_t mutex_liste_threads; + extern pthread_mutex_t mutex_gestionnaires_signaux_atomique; extern sem_t # ifdef SEMAPHORES_NOMMES - * -# endif - semaphore_gestionnaires_signaux_atomique; - -# ifdef SEMAPHORES_NOMMES - // 0 -> liste_threads - // 1 -> gestionnaire_signaux - // 2 -> gestionnaire_signaux_atomique - // 3 -> &((*s_etat_processus).semaphore_fork) - extern unsigned char noms_semaphores[4][LONGUEUR_NOM_SEMAPHORE]; - extern sem_t *semaphores_nommes[4]; + * # endif + semaphore_gestionnaires_signaux; # else -# ifdef _BROKEN_SIGINFO - int *fifos_signaux; -# endif - jmp_buf contexte; jmp_buf contexte_initial; jmp_buf contexte_processus; jmp_buf contexte_thread; -# ifdef SEMAPHORES_NOMMES - pthread_mutex_t mutex_sem = PTHREAD_MUTEX_INITIALIZER; -# endif + int signal_test; - pthread_key_t semaphore_fork_processus_courant; + pid_t pid_processus_pere; - sem_t # ifdef SEMAPHORES_NOMMES - * + pthread_mutex_t mutex_sem = PTHREAD_MUTEX_INITIALIZER; # endif - semaphore_liste_threads; + pthread_mutex_t mutex_liste_threads = + PTHREAD_MUTEX_INITIALIZER; + pthread_mutex_t mutex_gestionnaires_signaux = + PTHREAD_MUTEX_INITIALIZER; + pthread_mutex_t mutex_gestionnaires_signaux_atomique = + PTHREAD_MUTEX_INITIALIZER; sem_t # ifdef SEMAPHORES_NOMMES - * + * # endif semaphore_gestionnaires_signaux; - - sem_t -# ifdef SEMAPHORES_NOMMES - * -# endif - semaphore_gestionnaires_signaux_atomique; - -# ifdef SEMAPHORES_NOMMES - unsigned char noms_semaphores[4][LONGUEUR_NOM_SEMAPHORE]; - sem_t *semaphores_nommes[4]; -# endif # endif #endif #ifdef SEMAPHORES_NOMMES -enum t_semaphore { sem_liste_threads = 0, - sem_gestionnaires_signaux = 1, - sem_gestionnaires_signaux_atomique = 2, - sem_fork = 3 }; - -sem_t *sem_init2(unsigned int valeur, enum t_semaphore semaphore); -int sem_destroy2(sem_t *semaphore_p, enum t_semaphore semaphore); +sem_t *sem_init2(unsigned int valeur, pid_t pid); +sem_t *sem_init3(unsigned int valeur, pid_t pid, pthread_t tid); +int sem_destroy2(sem_t *semaphore_p, pid_t pid); +int sem_destroy3(sem_t *semaphore_p, pid_t pid, pthread_t tid); int sem_getvalue2(sem_t *semaphore, int *valeur); +sem_t *sem_open2(pid_t pid); + +// Le mutex est là uniquement pour pouvoir émuler le comportement +// de sem_getvalue() sur un système comme MacOS X qui ne possède pas +// cette fonction. #define sem_getvalue(semaphore, value) sem_getvalue2(semaphore, value) #define sem_post(semaphore) \ @@ -505,10 +494,6 @@ int sem_getvalue2(sem_t *semaphore, int #define ufprintf(flux, ...) transliterated_fprintf(NULL, \ flux, __VA_ARGS__) -// Tous les messages pour DISP, INPUT et les E/S par readline sont sur stderr. -// Cela évite aux messages envoyés par les gestionnaires de signaux d'être -// indéfiniment bloqués. - #ifdef SunOS # define fopen(...) ({ FILE *desc; \ while((desc = fopen(__VA_ARGS__)) == NULL) \ @@ -1392,9 +1377,6 @@ typedef struct descripteur_thread logical1 processus_detache; logical1 destruction_objet; - sigset_t oldset; - sigset_t set; - volatile signed long nombre_references; } struct_descripteur_thread; @@ -1849,6 +1831,12 @@ typedef struct processus # define RTLD_LOCAL 0 # endif + volatile int pointeur_signal_ecriture; + volatile int pointeur_signal_lecture; + volatile enum signaux_rpl signaux_en_queue[LONGUEUR_QUEUE_SIGNAUX]; + volatile logical1 demarrage_fils; + volatile logical1 redemarrage_processus; + /* Contextes */ struct_liste_chainee *l_base_pile_contextes; @@ -2190,12 +2178,12 @@ typedef struct processus pthread_mutex_t mutex; pthread_mutex_t mutex_allocation; - // Sémaphore autorisant les fork() + // Mutex autorisant les fork() sem_t # ifdef SEMAPHORES_NOMMES - * + * # endif - semaphore_fork; + semaphore_fork; /* Mutexes */ @@ -2910,17 +2898,11 @@ void integrale_romberg(struct_processus real8 a, real8 b, real8 precision); void interface_cas(struct_processus *s_etat_processus, enum t_rplcas_commandes commande); -void interruption1(SIGHANDLER_ARGS); -void interruption2(SIGHANDLER_ARGS); -void interruption3(SIGHANDLER_ARGS); -void interruption4(SIGHANDLER_ARGS); -void interruption5(SIGHANDLER_ARGS); -void interruption6(SIGHANDLER_ARGS); -void interruption7(SIGHANDLER_ARGS); -void interruption8(SIGHANDLER_ARGS); -void interruption9(SIGHANDLER_ARGS); -void interruption10(SIGHANDLER_ARGS); -void interruption11(SIGHANDLER_ARGS); +void interruption1(int signal); +void interruption2(int signal); +void interruption3(int signal); +void interruption4(int signal); +void interruption5(int signal); void inversion_matrice(struct_processus *s_etat_processus, struct_matrice *s_matrice); void lancement_daemon(struct_processus *s_etat_processus); @@ -2955,6 +2937,7 @@ void retrait_thread_surveillance(struct_ struct_descripteur_thread *s_argument_thread); void rplcore(struct_processus *s_etat_processus); void scrutation_injection(struct_processus *s_etat_processus); +void scrutation_interruptions(struct_processus *s_etat_processus); void sf(struct_processus *s_etat_processus, unsigned char indice_drapeau); void *surveillance_processus(void *argument); void swap(void *variable_1, void *variable_2, unsigned long taille_octets); @@ -2982,12 +2965,20 @@ void valeurs_singulieres(struct_processu void verrouillage_threads_concurrents(struct_processus *s_etat_processus); #endif +/* +-------------------------------------------------------------------------------- + Fonctions de gestion des signaux +-------------------------------------------------------------------------------- +*/ + #ifndef RPLARGS -#ifdef _BROKEN_SIGINFO -void creation_fifos_signaux(struct_processus *s_etat_processus); -void destruction_fifos_signaux(struct_processus *s_etat_processus); -void liberation_fifos_signaux(struct_processus *s_etat_processus); -#endif +void creation_queue_signaux(struct_processus *s_etat_processus); +void liberation_queue_signaux(struct_processus *s_etat_processus); +void destruction_queue_signaux(struct_processus *s_etat_processus); +int envoi_signal_contexte(struct_processus *s_etat_processus, + enum signaux_rpl signal); +int envoi_signal_processus(pid_t pid, enum signaux_rpl signal); +int envoi_signal_thread(pthread_t tid, enum signaux_rpl signal); #endif /*