--- rpl/src/interruptions.c 2010/08/23 08:04:40 1.34 +++ rpl/src/interruptions.c 2010/09/02 07:51:48 1.39 @@ -1,6 +1,6 @@ /* ================================================================================ - RPL/2 (R) version 4.0.18 + RPL/2 (R) version 4.0.19 Copyright (C) 1989-2010 Dr. BERTRAND Joël This file is part of RPL/2. @@ -1724,507 +1724,6 @@ deverrouillage_gestionnaire_signaux() return; } -#ifdef _BROKEN_SIGINFO - -#define longueur_queue 256 -#define nombre_queues 13 - -static int *fifos; -static int segment; -static sem_t *semaphores[nombre_queues]; -static sem_t *semaphore_global; - -#ifdef IPCS_SYSV -static unsigned char *chemin = NULL; -#endif - -unsigned char * -nom_segment(unsigned char *chemin, pid_t pid) -{ - unsigned char *fichier; - -# ifdef IPCS_SYSV - if ((fichier = malloc((strlen(chemin) + 1 + 256 + 1) * - sizeof(unsigned char))) == NULL) - { - return(NULL); - } - - sprintf(fichier, "%s/RPL-SIGQUEUES-%d", chemin, (int) pid); -# else - if ((fichier = malloc((1 + 256 + 1) * - sizeof(unsigned char))) == NULL) - { - return(NULL); - } - - sprintf(fichier, "/RPL-SIGQUEUES-%d", (int) pid); -# endif - - return(fichier); -} - -unsigned char * -nom_semaphore(pid_t pid, int queue) -{ - unsigned char *fichier; - - if ((fichier = malloc((256 + 1) * sizeof(unsigned char))) == NULL) - { - return(NULL); - } - - sprintf(fichier, "/RPL-SIGESMAPHORES-%d-%d", (int) pid, queue); - - return(fichier); -} - -inline int -queue_de_signal(int signal) -{ - switch(signal) - { - case SIGINT: - return(0); - case SIGTSTP: - return(1); - case SIGCONT: - return(2); - case SIGURG: - return(3); - case SIGPIPE: - return(4); - case SIGALRM: - return(5); - case SIGFSTOP: - return(6); - case SIGSTART: - return(7); - case SIGINJECT: - return(8); - case SIGABORT: - return(9); - case SIGFABORT: - return(10); - case SIGSEGV: - return(11); - case SIGBUS: - return(12); - } - - return(-1); -} - -void -creation_fifos_signaux(struct_processus *s_etat_processus) -{ - /* - * Signaux utilisés - * SIGINT, SIGTSTP, SIGCONT, SIGURG, SIGPIPE, SIGALRM, SIGFSTOP, - * SIGSTART, SIGINJECT, SIGABORT, SIGFABORT - */ - -# ifndef IPCS_SYSV // POSIX -# else // SystemV - - file *desc; - - int i; - - key_t clef; - - unsigned char *nom; - - // Création d'un segment de données associé au PID du processus courant - - chemin = (*s_etat_processus).chemin_fichiers_temporaires; - - if ((nom = nom_segment((*s_etat_processus).chemin_fichiers_temporaires, - getpid())) == NULL) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - if ((desc = fopen(nom, "w")) == NULL) - { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return; - } - - fclose(desc); - - if ((clef = ftok(nom, 1)) == -1) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - free(nom); - - if ((segment = shmget(clef, - nombre_queues * (longueur_queue + 4) * sizeof(int), - IPC_CREAT | IPC_EXCL | S_IRUSR | S_IWUSR)) == -1) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - fifos = shmat(segment, NULL, 0); - - if (((void *) fifos) == ((void *) -1)) - { - if (shmctl(segment, IPC_RMID, 0) == -1) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - -# endif - - /* - * Structure d'une queue - * 0 : pointeur en lecture sur le premier emplacement libre (int) - * 1 : pointeur en écriture sur le premier emplacement à lire (int) - * 2 : longueur de la queue (int) - * 3 : éléments restants (int) - * 4 à 4 + (2) : queue (int) - */ - - for(i = 0; i < nombre_queues; i++) - { - fifos[(i * (longueur_queue + 4))] = 0; - fifos[(i * (longueur_queue + 4)) + 1] = 0; - fifos[(i * (longueur_queue + 4)) + 2] = longueur_queue; - fifos[(i * (longueur_queue + 4)) + 3] = longueur_queue; - } - - // Création des sémaphores : un sémaphore par signal et par queue - // plus un sémaphore global pour tous les threads. - - for(i = 0; i < nombre_queues; i++) - { - if ((nom = nom_semaphore(getpid(), i)) == NULL) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - // Le sémaphore est créé en écrasant si nécessaire un sémaphore - // préexistant. Comme le nom du sémaphore contient l'identifiant du - // processus, il est anormal d'avoir un sémaphore de même nom - // préexistant. - - if ((semaphores[i] = sem_open(nom, O_CREAT, S_IRUSR | S_IWUSR, - 1)) == SEM_FAILED) - { - (*s_etat_processus).erreur_systeme = d_es_semaphore; - return; - } - - free(nom); - } - - - if ((nom = nom_semaphore(getpid(), nombre_queues)) == NULL) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - if ((semaphore_global = sem_open(nom, O_CREAT, S_IRUSR | S_IWUSR, - 1)) == SEM_FAILED) - { - (*s_etat_processus).erreur_systeme = d_es_semaphore; - return; - } - - free(nom); - - return; -} - -void -liberation_fifos_signaux(struct_processus *s_etat_processus) -{ - int i; - - if (shmdt(fifos) == -1) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - for(i = 0; i < nombre_queues; i++) - { - if (sem_close(semaphores[i]) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_semaphore; - return; - } - } - - if (sem_close(semaphore_global) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_semaphore; - return; - } - - return; -} - -void -destruction_fifos_signaux(struct_processus *s_etat_processus) -{ - int i; - - unsigned char *nom; - - if (shmdt(fifos) == -1) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - if (shmctl(segment, IPC_RMID, 0) == -1) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - if ((nom = nom_segment((*s_etat_processus).chemin_fichiers_temporaires, - getpid())) == NULL) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - unlink(nom); - free(nom); - - for(i = 0; i < nombre_queues; i++) - { - if ((nom = nom_semaphore(getpid(), i)) == NULL) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - if (sem_unlink(nom) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_semaphore; - return; - } - - free(nom); - } - - if ((nom = nom_semaphore(getpid(), nombre_queues)) == NULL) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } - - if (sem_unlink(nom) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_semaphore; - return; - } - - free(nom); - - return; -} - -int -queue_in(pid_t pid, int signal) -{ -#undef printf -// Transformer ce truc en POSIX ! On ne fait du SysV que si on n'a pas le choix - -# ifndef IPCS_SYSV -# else // Traitement à l'aide d'IPCS SystemV - - int *base; - int *buffer; - int *projection_fifos; - int queue; - int identifiant; - - key_t clef; - - sem_t *semaphore; - - struct stat s_stat; - - unsigned char *nom; - - queue = queue_de_signal(signal); - - // Ouverture des projections - - if ((nom = nom_segment(chemin, pid)) == NULL) - { - return(-1); - } - - // Dans le cas de SIGSTART, premier signal envoyé à un processus fils, - // il convient d'attendre que le fichier support soit effectivement - // accessible. Dans tous les autres cas, ce fichier doit exister. S'il - // n'existe plus, le processus associé n'existe plus. - - if (signal == SIGSTART) - { - // On attend que le fichier sois présent - - while(stat(nom, &s_stat) != 0); - } - - if ((clef = ftok(nom, 1)) == -1) - { - return(-1); - } - - free(nom); - - if (signal == SIGSTART) - { - while((identifiant = shmget(clef, - nombre_queues * (longueur_queue + 4) * sizeof(int), - S_IRUSR | S_IWUSR)) == -1); - } - else - { - if ((identifiant = shmget(clef, - nombre_queues * (longueur_queue + 4) * sizeof(int), - S_IRUSR | S_IWUSR)) == -1) - { - return(-1); - } - } - - projection_fifos = shmat(identifiant, NULL, 0); - - if (((void *) projection_fifos) == ((void *) -1)) - { - return(-1); - } - - if ((nom = nom_semaphore(pid, queue)) == NULL) - { - shmdt(projection_fifos); - return(-1); - } - - while((semaphore = sem_open(nom, 0)) == SEM_FAILED); - - if (sem_wait(semaphore) != 0) - { - shmdt(projection_fifos); - return(-1); - } - - // Il ne faut pas empiler plusieurs SIGSTART car SIGSTART peut provenir - // de l'instruction SWI. Plusieurs threads peuvent interrompre de façon - // asynchrone le processus père durant une phase de signaux masqués. - - base = &(projection_fifos[(longueur_queue + 4) * queue]); - buffer = &(base[4]); - - // base[3] contient le nombre d'éléments restants - - if (base[3] <= 0) - { - sem_post(semaphore); - sem_close(semaphore); - shmdt(projection_fifos); - return(-1); - } - - base[3]--; - - // base[1] contient le prochain élément à écrire - buffer[base[1]++] = (int) pid; - base[1] %= base[2]; - - if (sem_post(semaphore) != 0) - { - shmdt(projection_fifos); - sem_close(semaphore); - return(-1); - } - - sem_close(semaphore); - - // Fermeture des projections - shmdt(projection_fifos); - -# endif - - return(0); -} - -pid_t -origine_signal(int signal) -{ - int *base; - int *buffer; - int pid; - int queue; - - queue = queue_de_signal(signal); - - BUG(queue == -1, uprintf("[%d] Unknown signal %d in this context\n", - (int) getpid(), signal)); - - if (sem_wait(semaphores[queue]) != 0) - { - return(-1); - } - - // Le signal SIGCONT peut être envoyé de façon totalement asynchrone. - // Il peut y avoir plus de signaux envoyés que d'interruptions traitées. - // Il convient donc de rectifier la queue lors du traitement de - // l'interruption correspondante. Le gestionnaire étant installé sans - // l'option NODEFER, la queue reste cohérente. - - if (signal == SIGCONT) - { - base = &(fifos[(longueur_queue + 4) * queue]); - buffer = &(base[4]); - base[0] = (base[1] - 1) % base[2]; - pid = buffer[base[0]++]; - base[3] = base[2]; - } - else - { - base = &(fifos[(longueur_queue + 4) * queue]); - buffer = &(base[4]); - pid = buffer[base[0]++]; - base[0] %= base[2]; - base[3]++; - } - - if (base[3] > base[2]) - { - sem_post(semaphores[queue]); - return(-1); - } - - if (sem_post(semaphores[queue]) != 0) - { - return(-1); - } - - return((pid_t) pid); -} - -#endif - void interruption1(SIGHANDLER_ARGS) { @@ -2251,7 +1750,14 @@ interruption1(SIGHANDLER_ARGS) pid = origine_signal(signal); } # else - pid = (*siginfo).si_pid; + if (siginfo != NULL) + { + pid = (*siginfo).si_pid; + } + else + { + pid = getpid(); + } # endif switch(signal) @@ -2398,7 +1904,14 @@ interruption2(SIGHANDLER_ARGS) # ifdef _BROKEN_SIGINFO pid = origine_signal(signal); # else - pid = (*siginfo).si_pid; + if (siginfo != NULL) + { + pid = (*siginfo).si_pid; + } + else + { + pid = getpid(); + } # endif # ifndef _BROKEN_SIGINFO @@ -2950,115 +2463,4 @@ traitement_exceptions_gsl(const char *re return; } -#ifdef _BROKEN_SIGINFO - -#undef kill -#undef pthread_kill - -int -kill_broken_siginfo(pid_t pid, int signal) -{ - int ios; - - sem_t *semaphore; - - unsigned char *nom; - - /* - * Lorsqu'on veut interrompre le processus pid, on ouvre le segment - * correspondant au processus en question et ou ajoute le pid dans la - * queue. - * - * Le sémaphore global à tous les threads d'un même processus sert - * à garantir que les signaux seront traités dans l'ordre de ce qui est - * effectivement mis dans la queue. - */ - - // Sémaphore acquis - - if ((nom = nom_semaphore(getpid(), nombre_queues)) == NULL) - { - return(-1); - } - - if ((semaphore = sem_open(nom, 0)) == SEM_FAILED) - { - free(nom); - return(-1); - } - - free(nom); - - if (sem_wait(semaphore) == -1) - { - return(-1); - } - - if ((signal != 0) && (signal != SIGINT)) - { - if (queue_in(pid, signal) != 0) - { - sem_post(semaphore); - sem_close(semaphore); - return(-1); - } - } - - ios = kill(pid, signal); - - // Sémaphore relâché - - sem_post(semaphore); - sem_close(semaphore); - - return(ios); -} - -int -pthread_kill_broken_siginfo(pthread_t tid, int signal) -{ - int ios; - - sem_t *semaphore; - - unsigned char *nom; - - if ((nom = nom_semaphore(getpid(), nombre_queues)) == NULL) - { - return(-1); - } - - if ((semaphore = sem_open(nom, 0)) == SEM_FAILED) - { - free(nom); - return(-1); - } - - free(nom); - - if (sem_wait(semaphore) == -1) - { - return(-1); - } - - if ((signal != 0) && (signal != SIGINT)) - { - if (queue_in(getpid(), signal) != 0) - { - sem_post(semaphore); - sem_close(semaphore); - return(-1); - } - } - - ios = pthread_kill(tid, signal); - - sem_post(semaphore); - sem_close(semaphore); - - return(ios); -} - -#endif - // vim: ts=4