[BACK]Return to interruptions.c CVS log [TXT] [DIR] Up to [local] / rpl / src

Diff for /rpl/src/interruptions.c between versions 1.35 and 1.157

version 1.35, 2010/08/25 09:06:49 version 1.157, 2015/02/19 11:01:28
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.0.18    RPL/2 (R) version 4.1.21
   Copyright (C) 1989-2010 Dr. BERTRAND Joël    Copyright (C) 1989-2015 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
   
Line 52  typedef struct liste_chainee_volatile Line 52  typedef struct liste_chainee_volatile
     volatile void                           *donnee;      volatile void                           *donnee;
 } struct_liste_chainee_volatile;  } struct_liste_chainee_volatile;
   
   
 static volatile struct_liste_chainee_volatile   *liste_threads  static volatile struct_liste_chainee_volatile   *liste_threads
         = NULL;          = NULL;
 static volatile struct_liste_chainee_volatile   *liste_threads_surveillance  static volatile struct_liste_chainee_volatile   *liste_threads_surveillance
         = NULL;          = NULL;
   static volatile int                             code_erreur_gsl = 0;
   
   unsigned char                                   *racine_segment;
   
   static void *
   thread_surveillance_signaux(void *argument)
   {
       // Cette fonction est lancée dans un thread créé par processus pour
       // gérer le cas des appels système qui seraient bloqués lors de l'arrivée du
       // signal SIGALRM. Les processus externes n'envoient plus un signal au
       // processus ou au thread à signaler mais positionnent les informations
       // nécessaires dans la queue des signaux et incrémentent le sémaphore.
       // Le sémaphore est décrémenté lorsque le signal est effectivement traité.
   
       int                                     nombre_signaux_envoyes;
   
       struct_processus                        *s_etat_processus;
   
       struct timespec                         attente;
   
       volatile struct_liste_chainee_volatile  *l_element_courant;
   
       sigset_t                                set;
   
       sigfillset(&set);
       pthread_sigmask(SIG_BLOCK, &set, NULL);
   
       s_etat_processus = (struct_processus *) argument;
   
       for(;;)
       {
           attente.tv_sec = 0;
           attente.tv_nsec = GRANULARITE_us * 1000;
   
           if (sem_wait(semaphore_signalisation) == 0)
           {
               if (sem_wait(semaphore_arret_signalisation) != 0)
               {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
               }
   
               if ((*s_queue_signaux).requete_arret == d_vrai)
               {
                   sem_post(semaphore_arret_signalisation);
                   sem_post(semaphore_signalisation);
   
                   break;
               }
   
               sem_post(semaphore_arret_signalisation);
               sem_post(semaphore_signalisation);
   
               nombre_signaux_envoyes = 0;
               sched_yield();
   
               // Dans un premier temps, on verrouille la queue des signaux
               // affectée au processus courant pour vérifier s'il y a quelque
               // chose à traiter.
   
               sem_wait(semaphore_queue_signaux);
   
               if ((*s_queue_signaux).pointeur_lecture !=
                       (*s_queue_signaux).pointeur_ecriture)
               {
                   // Attention : raise() envoit le signal au thread appelant !
                   // kill() l'envoie au processus appelant, donc dans notre
                   // cas à un thread aléatoire du processus, ce qui nous
                   // convient tout à fait puisqu'il s'agit de débloquer les
                   // appels système lents.
   
                   nombre_signaux_envoyes++;
                   kill(getpid(), SIGALRM);
               }
   
               sem_post(semaphore_queue_signaux);
   
               // Dans un second temps, on balaye toutes les queues de signaux
               // des threads du processus courant.
   
               // Attention : l'ordre de verrouillage des mutexes est important
               // pour éviter les conditions bloquantes !
   
               pthread_mutex_lock(&mutex_liste_threads);
   
               l_element_courant = liste_threads;
   
               while(l_element_courant != NULL)
               {
                   if ((*((struct_thread *) (*l_element_courant).donnee)).pid
                           == getpid())
                   {
                       pthread_mutex_lock(&((*(*((struct_thread *)
                               (*l_element_courant).donnee)).s_etat_processus)
                               .mutex_signaux));
   
                       if ((*(*((struct_thread *) (*l_element_courant).donnee))
                               .s_etat_processus).pointeur_signal_ecriture !=
                               (*(*((struct_thread *) (*l_element_courant)
                               .donnee)).s_etat_processus)
                               .pointeur_signal_lecture)
                       {
                           nombre_signaux_envoyes++;
                           pthread_kill((*((struct_thread *)
                                   (*l_element_courant).donnee)).tid, SIGALRM);
                       }
   
                       pthread_mutex_unlock(&((*(*((struct_thread *)
                               (*l_element_courant).donnee)).s_etat_processus)
                               .mutex_signaux));
                   }
   
                   l_element_courant = (*l_element_courant).suivant;
               }
   
               pthread_mutex_unlock(&mutex_liste_threads);
   
               // Nanosleep
   
               if (nombre_signaux_envoyes > 0)
               {
                   nanosleep(&attente, NULL);
               }
           }
           else
           {
               if (errno != EINTR)
               {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
               }
           }
       }
   
       pthread_exit(NULL);
   }
   
 void  void
 modification_pid_thread_pere(struct_processus *s_etat_processus)  modification_pid_thread_pere(struct_processus *s_etat_processus)
Line 74  modification_pid_thread_pere(struct_proc Line 207  modification_pid_thread_pere(struct_proc
 void  void
 insertion_thread(struct_processus *s_etat_processus, logical1 thread_principal)  insertion_thread(struct_processus *s_etat_processus, logical1 thread_principal)
 {  {
     sigset_t                                    oldset;  
     sigset_t                                    set;  
   
     volatile struct_liste_chainee_volatile      *l_nouvel_objet;      volatile struct_liste_chainee_volatile      *l_nouvel_objet;
   
     sigfillset(&set);  
     pthread_sigmask(SIG_BLOCK, &set, &oldset);  
   
     if ((l_nouvel_objet = malloc(sizeof(struct_liste_chainee_volatile)))      if ((l_nouvel_objet = malloc(sizeof(struct_liste_chainee_volatile)))
             == NULL)              == NULL)
     {      {
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         sigpending(&set);  
   
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
         return;          return;
     }      }
   
     if (((*l_nouvel_objet).donnee = malloc(sizeof(struct_thread))) == NULL)      if (((*l_nouvel_objet).donnee = malloc(sizeof(struct_thread))) == NULL)
     {      {
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         sigpending(&set);  
   
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
         return;          return;
     }      }
Line 108  insertion_thread(struct_processus *s_eta Line 229  insertion_thread(struct_processus *s_eta
     (*((struct_thread *) (*l_nouvel_objet).donnee)).s_etat_processus =      (*((struct_thread *) (*l_nouvel_objet).donnee)).s_etat_processus =
             s_etat_processus;              s_etat_processus;
   
 #   ifndef SEMAPHORES_NOMMES      if (pthread_mutex_lock(&mutex_liste_threads) != 0)
     while(sem_wait(&semaphore_liste_threads) == -1)  
 #   else  
     while(sem_wait(semaphore_liste_threads) == -1)  
 #   endif  
     {      {
         if (errno != EINTR)          (*s_etat_processus).erreur_systeme = d_es_processus;
         {          return;
             pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
             sigpending(&set);  
   
             (*s_etat_processus).erreur_systeme = d_es_processus;  
             return;  
         }  
     }      }
   
     (*l_nouvel_objet).suivant = liste_threads;      (*l_nouvel_objet).suivant = liste_threads;
     liste_threads = l_nouvel_objet;      liste_threads = l_nouvel_objet;
   
 #   ifndef SEMAPHORES_NOMMES      if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
     if (sem_post(&semaphore_liste_threads) != 0)  
 #   else  
     if (sem_post(semaphore_liste_threads) != 0)  
 #   endif  
     {      {
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         sigpending(&set);  
   
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
     }      }
   
     pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
     sigpending(&set);  
     return;      return;
 }  }
   
Line 149  void Line 251  void
 insertion_thread_surveillance(struct_processus *s_etat_processus,  insertion_thread_surveillance(struct_processus *s_etat_processus,
         struct_descripteur_thread *s_argument_thread)          struct_descripteur_thread *s_argument_thread)
 {  {
     sigset_t                                    oldset;  
     sigset_t                                    set;  
   
     volatile struct_liste_chainee_volatile      *l_nouvel_objet;      volatile struct_liste_chainee_volatile      *l_nouvel_objet;
   
     sigfillset(&set);  
     pthread_sigmask(SIG_BLOCK, &set, &oldset);  
   
     if ((l_nouvel_objet = malloc(sizeof(struct_liste_chainee_volatile)))      if ((l_nouvel_objet = malloc(sizeof(struct_liste_chainee_volatile)))
             == NULL)              == NULL)
     {      {
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         sigpending(&set);  
   
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
         return;          return;
     }      }
   
 #   ifndef SEMAPHORES_NOMMES      if (pthread_mutex_lock(&mutex_liste_threads) != 0)
     while(sem_wait(&semaphore_liste_threads) == -1)  
 #   else  
     while(sem_wait(semaphore_liste_threads) == -1)  
 #   endif  
     {      {
         if (errno != EINTR)          (*s_etat_processus).erreur_systeme = d_es_processus;
         {          return;
             pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
             sigpending(&set);  
   
             (*s_etat_processus).erreur_systeme = d_es_processus;  
             return;  
         }  
     }      }
   
     pthread_mutex_lock(&((*s_argument_thread).mutex));      pthread_mutex_lock(&((*s_argument_thread).mutex_nombre_references));
     (*s_argument_thread).nombre_references++;      (*s_argument_thread).nombre_references++;
     pthread_mutex_unlock(&((*s_argument_thread).mutex));      pthread_mutex_unlock(&((*s_argument_thread).mutex_nombre_references));
   
     (*l_nouvel_objet).suivant = liste_threads_surveillance;      (*l_nouvel_objet).suivant = liste_threads_surveillance;
     (*l_nouvel_objet).donnee = (void *) s_argument_thread;      (*l_nouvel_objet).donnee = (void *) s_argument_thread;
   
     liste_threads_surveillance = l_nouvel_objet;      liste_threads_surveillance = l_nouvel_objet;
   
 #   ifndef SEMAPHORES_NOMMES      if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
     if (sem_post(&semaphore_liste_threads) != 0)  
 #   else  
     if (sem_post(semaphore_liste_threads) != 0)  
 #   endif  
     {      {
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         sigpending(&set);  
   
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
     }      }
   
     pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
     sigpending(&set);  
     return;      return;
 }  }
   
 void  void
 retrait_thread(struct_processus *s_etat_processus)  retrait_thread(struct_processus *s_etat_processus)
 {  {
     sigset_t                                oldset;  
     sigset_t                                set;  
   
     volatile struct_liste_chainee_volatile  *l_element_precedent;      volatile struct_liste_chainee_volatile  *l_element_precedent;
     volatile struct_liste_chainee_volatile  *l_element_courant;      volatile struct_liste_chainee_volatile  *l_element_courant;
   
     sigfillset(&set);      if (pthread_mutex_lock(&mutex_liste_threads) != 0)
     pthread_sigmask(SIG_BLOCK, &set, &oldset);  
   
 #   ifndef SEMAPHORES_NOMMES  
     while(sem_wait(&semaphore_liste_threads) == -1)  
 #   else  
     while(sem_wait(semaphore_liste_threads) == -1)  
 #   endif  
     {      {
         if (errno != EINTR)          (*s_etat_processus).erreur_systeme = d_es_processus;
         {          return;
             pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
             sigpending(&set);  
   
             (*s_etat_processus).erreur_systeme = d_es_processus;  
             return;  
         }  
     }      }
   
     l_element_precedent = NULL;      l_element_precedent = NULL;
Line 256  retrait_thread(struct_processus *s_etat_ Line 314  retrait_thread(struct_processus *s_etat_
   
     if (l_element_courant == NULL)      if (l_element_courant == NULL)
     {      {
 #       ifndef SEMAPHORES_NOMMES          pthread_mutex_unlock(&mutex_liste_threads);
         sem_post(&semaphore_liste_threads);  
 #       else  
         sem_post(semaphore_liste_threads);  
 #       endif  
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         sigpending(&set);  
   
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
     }      }
Line 277  retrait_thread(struct_processus *s_etat_ Line 328  retrait_thread(struct_processus *s_etat_
         (*l_element_precedent).suivant = (*l_element_courant).suivant;          (*l_element_precedent).suivant = (*l_element_courant).suivant;
     }      }
   
     if (pthread_setspecific(semaphore_fork_processus_courant, NULL) != 0)      if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
     {      {
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
   
 #       ifndef SEMAPHORES_NOMMES  
         sem_post(&semaphore_liste_threads);  
 #       else  
         sem_post(semaphore_liste_threads);  
 #       endif  
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         sigpending(&set);  
         return;          return;
     }      }
   
 #   ifndef SEMAPHORES_NOMMES      // Le thread ne peut plus traiter de signaux explicites. Il convient
     if (sem_post(&semaphore_liste_threads) != 0)      // alors de corriger le sémaphore pour annuler les signaux en attente.
 #   else  
     if (sem_post(semaphore_liste_threads) != 0)      while((*(*((struct_thread *) (*l_element_courant).donnee)).s_etat_processus)
 #   endif              .pointeur_signal_ecriture != (*(*((struct_thread *)
               (*l_element_courant).donnee)).s_etat_processus)
               .pointeur_signal_lecture)
     {      {
         (*s_etat_processus).erreur_systeme = d_es_processus;          while(sem_wait(semaphore_signalisation) != 0)
           {
               if (errno != EINTR)
               {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
                   return;
               }
           }
   
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);          (*(*((struct_thread *) (*l_element_courant).donnee)).s_etat_processus)
         sigpending(&set);                  .pointeur_signal_lecture = ((*(*((struct_thread *)
         return;                  (*l_element_courant).donnee)).s_etat_processus)
                   .pointeur_signal_lecture + 1) % LONGUEUR_QUEUE_SIGNAUX;
     }      }
   
     free((void *) (*l_element_courant).donnee);      free((void *) (*l_element_courant).donnee);
     free((struct_liste_chainee_volatile *) l_element_courant);      free((struct_liste_chainee_volatile *) l_element_courant);
   
     pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
     sigpending(&set);  
     return;      return;
 }  }
   
Line 316  void Line 367  void
 retrait_thread_surveillance(struct_processus *s_etat_processus,  retrait_thread_surveillance(struct_processus *s_etat_processus,
         struct_descripteur_thread *s_argument_thread)          struct_descripteur_thread *s_argument_thread)
 {  {
     sigset_t                                set;  
     sigset_t                                oldset;  
   
     volatile struct_liste_chainee_volatile  *l_element_precedent;      volatile struct_liste_chainee_volatile  *l_element_precedent;
     volatile struct_liste_chainee_volatile  *l_element_courant;      volatile struct_liste_chainee_volatile  *l_element_courant;
   
     sigfillset(&set);      if (pthread_mutex_lock(&mutex_liste_threads) != 0)
     pthread_sigmask(SIG_BLOCK, &set, &oldset);  
   
 #   ifndef SEMAPHORES_NOMMES  
     while(sem_wait(&semaphore_liste_threads) == -1)  
 #   else  
     while(sem_wait(semaphore_liste_threads) == -1)  
 #   endif  
     {      {
         if (errno != EINTR)          (*s_etat_processus).erreur_systeme = d_es_processus;
         {          return;
             pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
             sigpending(&set);  
   
             (*s_etat_processus).erreur_systeme = d_es_processus;  
             return;  
         }  
     }      }
   
     l_element_precedent = NULL;      l_element_precedent = NULL;
Line 357  retrait_thread_surveillance(struct_proce Line 392  retrait_thread_surveillance(struct_proce
   
     if (l_element_courant == NULL)      if (l_element_courant == NULL)
     {      {
 #       ifndef SEMAPHORES_NOMMES          pthread_mutex_unlock(&mutex_liste_threads);
         sem_post(&semaphore_liste_threads);  
 #       else  
         sem_post(semaphore_liste_threads);  
 #       endif  
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         sigpending(&set);  
   
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
     }      }
Line 378  retrait_thread_surveillance(struct_proce Line 406  retrait_thread_surveillance(struct_proce
         (*l_element_precedent).suivant = (*l_element_courant).suivant;          (*l_element_precedent).suivant = (*l_element_courant).suivant;
     }      }
   
     if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0)      if (pthread_mutex_lock(&((*s_argument_thread).mutex_nombre_references))
               != 0)
     {      {
 #       ifndef SEMAPHORES_NOMMES          pthread_mutex_unlock(&mutex_liste_threads);
         sem_post(&semaphore_liste_threads);  
 #       else  
         sem_post(semaphore_liste_threads);  
 #       endif  
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         sigpending(&set);  
   
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
     }      }
Line 400  retrait_thread_surveillance(struct_proce Line 422  retrait_thread_surveillance(struct_proce
   
     if ((*s_argument_thread).nombre_references == 0)      if ((*s_argument_thread).nombre_references == 0)
     {      {
         if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)          if (pthread_mutex_unlock(&((*s_argument_thread)
                   .mutex_nombre_references)) != 0)
         {          {
 #           ifndef SEMAPHORES_NOMMES              pthread_mutex_unlock(&mutex_liste_threads);
             sem_post(&semaphore_liste_threads);  
 #           else  
             sem_post(semaphore_liste_threads);  
 #           endif  
             pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
             sigpending(&set);  
   
             (*s_etat_processus).erreur_systeme = d_es_processus;              (*s_etat_processus).erreur_systeme = d_es_processus;
             return;              return;
         }          }
   
         pthread_mutex_destroy(&((*s_argument_thread).mutex));          pthread_mutex_destroy(&((*s_argument_thread).mutex));
           pthread_mutex_destroy(&((*s_argument_thread).mutex_nombre_references));
         free(s_argument_thread);          free(s_argument_thread);
     }      }
     else      else
     {      {
         if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)          if (pthread_mutex_unlock(&((*s_argument_thread)
                   .mutex_nombre_references)) != 0)
         {          {
 #           ifndef SEMAPHORES_NOMMES              pthread_mutex_unlock(&mutex_liste_threads);
             sem_post(&semaphore_liste_threads);  
 #           else  
             sem_post(semaphore_liste_threads);  
 #           endif  
             pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
             sigpending(&set);  
   
             (*s_etat_processus).erreur_systeme = d_es_processus;              (*s_etat_processus).erreur_systeme = d_es_processus;
             return;              return;
         }          }
     }      }
   
 #   ifndef SEMAPHORES_NOMMES      if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
     if (sem_post(&semaphore_liste_threads) != 0)  
 #   else  
     if (sem_post(semaphore_liste_threads) != 0)  
 #   endif  
     {      {
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         sigpending(&set);  
   
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
     }      }
   
     free((struct_liste_chainee_volatile *) l_element_courant);      free((struct_liste_chainee_volatile *) l_element_courant);
   
     pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
     sigpending(&set);  
   
     return;      return;
 }  }
   
Line 460  verrouillage_threads_concurrents(struct_ Line 460  verrouillage_threads_concurrents(struct_
 {  {
     volatile struct_liste_chainee_volatile  *l_element_courant;      volatile struct_liste_chainee_volatile  *l_element_courant;
   
 #   ifndef SEMAPHORES_NOMMES      if (pthread_mutex_lock(&mutex_liste_threads) != 0)
     while(sem_wait(&semaphore_liste_threads) == -1)  
 #   else  
     while(sem_wait(semaphore_liste_threads) == -1)  
 #   endif  
     {      {
         if (errno != EINTR)          (*s_etat_processus).erreur_systeme = d_es_processus;
         {          return;
             (*s_etat_processus).erreur_systeme = d_es_processus;  
             return;  
         }  
     }      }
   
     l_element_courant = liste_threads;      l_element_courant = liste_threads;
Line 482  verrouillage_threads_concurrents(struct_ Line 475  verrouillage_threads_concurrents(struct_
                 (*l_element_courant).donnee)).tid, pthread_self()) == 0))                  (*l_element_courant).donnee)).tid, pthread_self()) == 0))
         {          {
 #           ifndef SEMAPHORES_NOMMES  #           ifndef SEMAPHORES_NOMMES
             while(sem_wait(&((*(*((struct_thread *) (*l_element_courant)                  while(sem_wait(&((*(*((struct_thread *) (*l_element_courant)
                     .donnee)).s_etat_processus).semaphore_fork)) == -1)                          .donnee)).s_etat_processus).semaphore_fork)) == -1)
 #           else  #           else
             while(sem_wait((*(*((struct_thread *) (*l_element_courant)                  while(sem_wait((*(*((struct_thread *) (*l_element_courant)
                     .donnee)).s_etat_processus).semaphore_fork) == -1)                          .donnee)).s_etat_processus).semaphore_fork) == -1)
 #           endif  #           endif
             {              {
                 if (errno != EINTR)                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 {                  return;
                     (*s_etat_processus).erreur_systeme = d_es_processus;  
                     return;  
                 }  
             }              }
         }          }
   
Line 517  deverrouillage_threads_concurrents(struc Line 507  deverrouillage_threads_concurrents(struc
                 (*l_element_courant).donnee)).tid, pthread_self()) == 0))                  (*l_element_courant).donnee)).tid, pthread_self()) == 0))
         {          {
 #           ifndef SEMAPHORES_NOMMES  #           ifndef SEMAPHORES_NOMMES
             if (sem_post(&((*(*((struct_thread *)                  if (sem_post(&((*(*((struct_thread *)
                     (*l_element_courant).donnee)).s_etat_processus)                          (*l_element_courant).donnee)).s_etat_processus)
                     .semaphore_fork)) != 0)                          .semaphore_fork)) != 0)
 #           else  #           else
             if (sem_post((*(*((struct_thread *)                  if (sem_post((*(*((struct_thread *)
                     (*l_element_courant).donnee)).s_etat_processus)                          (*l_element_courant).donnee)).s_etat_processus)
                     .semaphore_fork) != 0)                          .semaphore_fork) != 0)
 #           endif  #           endif
             {              {
 #               ifndef SEMAPHORES_NOMMES                  if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
                 if (sem_post(&semaphore_liste_threads) != 0)  
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_processus;                      (*s_etat_processus).erreur_systeme = d_es_processus;
                     return;                      return;
                 }                  }
 #               else  
                 if (sem_post(semaphore_liste_threads) != 0)  
                 {  
                     (*s_etat_processus).erreur_systeme = d_es_processus;  
                     return;  
                 }  
 #               endif  
   
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return;                  return;
Line 548  deverrouillage_threads_concurrents(struc Line 530  deverrouillage_threads_concurrents(struc
         l_element_courant = (*l_element_courant).suivant;          l_element_courant = (*l_element_courant).suivant;
     }      }
   
 #   ifndef SEMAPHORES_NOMMES      if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
     if (sem_post(&semaphore_liste_threads) != 0)  
 #   else  
     if (sem_post(semaphore_liste_threads) != 0)  
 #   endif  
     {      {
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
Line 566  liberation_threads(struct_processus *s_e Line 544  liberation_threads(struct_processus *s_e
 {  {
     logical1                                    suppression_variables_partagees;      logical1                                    suppression_variables_partagees;
   
     sigset_t                                    oldset;  
     sigset_t                                    set;  
   
     struct_descripteur_thread                   *s_argument_thread;      struct_descripteur_thread                   *s_argument_thread;
   
     struct_processus                            *candidat;      struct_processus                            *candidat;
   
     unsigned long                               i;      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_suivant;
   
       integer8                                    i;
   
     void                                        *element_candidat;      void                                        *element_candidat;
     void                                        *element_courant;      void                                        *element_courant;
Line 582  liberation_threads(struct_processus *s_e Line 563  liberation_threads(struct_processus *s_e
     volatile struct_liste_chainee_volatile      *l_element_courant;      volatile struct_liste_chainee_volatile      *l_element_courant;
     volatile struct_liste_chainee_volatile      *l_element_suivant;      volatile struct_liste_chainee_volatile      *l_element_suivant;
   
     sigfillset(&set);      if (pthread_mutex_lock(&mutex_liste_threads) == -1)
     pthread_sigmask(SIG_BLOCK, &set, &oldset);  
   
 #   ifndef SEMAPHORES_NOMMES  
     while(sem_wait(&semaphore_liste_threads) == -1)  
 #   else  
     while(sem_wait(semaphore_liste_threads) == -1)  
 #   endif  
     {      {
         if (errno != EINTR)          (*s_etat_processus).erreur_systeme = d_es_processus;
         {          return;
             pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
             (*s_etat_processus).erreur_systeme = d_es_processus;  
             return;  
         }  
     }      }
   
     l_element_courant = liste_threads;      l_element_courant = liste_threads;
Line 627  liberation_threads(struct_processus *s_e Line 597  liberation_threads(struct_processus *s_e
             close((*s_etat_processus).pipe_injections);              close((*s_etat_processus).pipe_injections);
             close((*s_etat_processus).pipe_nombre_injections);              close((*s_etat_processus).pipe_nombre_injections);
             close((*s_etat_processus).pipe_interruptions);              close((*s_etat_processus).pipe_interruptions);
             close((*s_etat_processus).pipe_nombre_objets_attente);              close((*s_etat_processus).pipe_nombre_elements_attente);
             close((*s_etat_processus).pipe_nombre_interruptions_attente);  
   
             liberation(s_etat_processus, (*s_etat_processus).at_exit);              liberation(s_etat_processus, (*s_etat_processus).at_exit);
   
Line 676  liberation_threads(struct_processus *s_e Line 645  liberation_threads(struct_processus *s_e
                 s_argument_thread = (struct_descripteur_thread *)                  s_argument_thread = (struct_descripteur_thread *)
                         (*((struct_liste_chainee *) element_courant)).donnee;                          (*((struct_liste_chainee *) element_courant)).donnee;
   
                 if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0)                  if (pthread_mutex_lock(&((*s_argument_thread)
                           .mutex_nombre_references)) != 0)
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_processus;                      (*s_etat_processus).erreur_systeme = d_es_processus;
                     sem_post(&semaphore_liste_threads);                      pthread_mutex_unlock(&mutex_liste_threads);
                     return;                      return;
                 }                  }
   
Line 695  liberation_threads(struct_processus *s_e Line 665  liberation_threads(struct_processus *s_e
                     close((*s_argument_thread).pipe_acquittement[1]);                      close((*s_argument_thread).pipe_acquittement[1]);
                     close((*s_argument_thread).pipe_injections[1]);                      close((*s_argument_thread).pipe_injections[1]);
                     close((*s_argument_thread).pipe_nombre_injections[1]);                      close((*s_argument_thread).pipe_nombre_injections[1]);
                     close((*s_argument_thread).pipe_nombre_objets_attente[0]);                      close((*s_argument_thread).pipe_nombre_elements_attente[0]);
                     close((*s_argument_thread).pipe_interruptions[0]);                      close((*s_argument_thread).pipe_interruptions[0]);
                     close((*s_argument_thread)  
                             .pipe_nombre_interruptions_attente[0]);  
   
                     if (pthread_mutex_unlock(&((*s_argument_thread).mutex))                      if (pthread_mutex_unlock(&((*s_argument_thread)
                             != 0)                              .mutex_nombre_references)) != 0)
                     {                      {
                         (*s_etat_processus).erreur_systeme = d_es_processus;                          (*s_etat_processus).erreur_systeme = d_es_processus;
                         sem_post(&semaphore_liste_threads);                          pthread_mutex_unlock(&mutex_liste_threads);
                         return;                          return;
                     }                      }
   
                     pthread_mutex_destroy(&((*s_argument_thread).mutex));                      pthread_mutex_destroy(&((*s_argument_thread).mutex));
                       pthread_mutex_destroy(&((*s_argument_thread)
                               .mutex_nombre_references));
   
                     if ((*s_argument_thread).processus_detache == d_faux)                      if ((*s_argument_thread).processus_detache == d_faux)
                     {                      {
Line 723  liberation_threads(struct_processus *s_e Line 693  liberation_threads(struct_processus *s_e
                 }                  }
                 else                  else
                 {                  {
                     if (pthread_mutex_unlock(&((*s_argument_thread).mutex))                      if (pthread_mutex_unlock(&((*s_argument_thread)
                             != 0)                              .mutex_nombre_references)) != 0)
                     {                      {
                         (*s_etat_processus).erreur_systeme = d_es_processus;                          (*s_etat_processus).erreur_systeme = d_es_processus;
                         sem_post(&semaphore_liste_threads);                          pthread_mutex_unlock(&mutex_liste_threads);
                         return;                          return;
                     }                      }
                 }                  }
Line 796  liberation_threads(struct_processus *s_e Line 766  liberation_threads(struct_processus *s_e
                 }                  }
             }              }
   
             for(i = 0; i < (*s_etat_processus).nombre_variables; i++)              // ne peut être effacé qu'une seule fois
             {  
                 pthread_mutex_trylock(&((*(*s_etat_processus)  
                         .s_liste_variables[i].objet).mutex));  
                 pthread_mutex_unlock(&((*(*s_etat_processus)  
                         .s_liste_variables[i].objet).mutex));  
   
                 // Les variables de niveau 0 sont des définitions qui  
                 // ne sont pas copiées entre threads.  
                 if ((*s_etat_processus).s_liste_variables[i].niveau > 0)  
                 {  
                     liberation(s_etat_processus,  
                             (*s_etat_processus).s_liste_variables[i].objet);  
                 }  
   
                 free((*s_etat_processus).s_liste_variables[i].nom);  
             }  
   
             free((*s_etat_processus).s_liste_variables);  
   
             for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++)  
             {  
                 pthread_mutex_trylock(&((*(*s_etat_processus)  
                         .s_liste_variables_statiques[i].objet).mutex));  
                 pthread_mutex_unlock(&((*(*s_etat_processus)  
                         .s_liste_variables_statiques[i].objet).mutex));  
   
                 liberation(s_etat_processus, (*s_etat_processus)  
                         .s_liste_variables_statiques[i].objet);  
                 free((*s_etat_processus).s_liste_variables_statiques[i].nom);  
             }  
   
             free((*s_etat_processus).s_liste_variables_statiques);  
   
             // Ne peut être effacé qu'une seule fois  
             if (suppression_variables_partagees == d_faux)              if (suppression_variables_partagees == d_faux)
             {              {
                 suppression_variables_partagees = d_vrai;                  suppression_variables_partagees = d_vrai;
   
                 for(i = 0; i < (*(*s_etat_processus)                  liberation_arbre_variables_partagees(s_etat_processus,
                         .s_liste_variables_partagees).nombre_variables; i++)                          (*(*s_etat_processus).s_arbre_variables_partagees));
                 {  
                     pthread_mutex_trylock(&((*(*(*s_etat_processus)  
                             .s_liste_variables_partagees).table[i].objet)  
                             .mutex));  
                     pthread_mutex_unlock(&((*(*(*s_etat_processus)  
                             .s_liste_variables_partagees).table[i].objet)  
                             .mutex));  
   
                     liberation(s_etat_processus, (*(*s_etat_processus)                  l_element_partage_courant = (*(*s_etat_processus)
                             .s_liste_variables_partagees).table[i].objet);                          .l_liste_variables_partagees);
                     free((*(*s_etat_processus).s_liste_variables_partagees)  
                             .table[i].nom);  
                 }  
   
                 if ((*(*s_etat_processus).s_liste_variables_partagees).table                  while(l_element_partage_courant != NULL)
                         != NULL)  
                 {                  {
                     free((struct_variable_partagee *) (*(*s_etat_processus)                      l_element_partage_suivant =
                             .s_liste_variables_partagees).table);                              (*l_element_partage_courant).suivant;
                       free(l_element_partage_courant);
                       l_element_partage_courant = l_element_partage_suivant;
                 }                  }
               }
   
               liberation_arbre_variables(s_etat_processus,
                       (*s_etat_processus).s_arbre_variables, d_faux);
   
                 pthread_mutex_trylock(&((*(*s_etat_processus)              l_element_statique_courant = (*s_etat_processus)
                         .s_liste_variables_partagees).mutex));                      .l_liste_variables_statiques;
                 pthread_mutex_unlock(&((*(*s_etat_processus)  
                         .s_liste_variables_partagees).mutex));              while(l_element_statique_courant != NULL)
               {
                   l_element_statique_suivant =
                       (*l_element_statique_courant).suivant;
                   free(l_element_statique_courant);
                   l_element_statique_courant = l_element_statique_suivant;
             }              }
   
             element_courant = (*s_etat_processus).l_base_pile;              element_courant = (*s_etat_processus).l_base_pile;
Line 1321  liberation_threads(struct_processus *s_e Line 1257  liberation_threads(struct_processus *s_e
             liberation_allocateur(s_etat_processus);              liberation_allocateur(s_etat_processus);
   
 #           ifndef SEMAPHORES_NOMMES  #           ifndef SEMAPHORES_NOMMES
             sem_post(&((*s_etat_processus).semaphore_fork));                  sem_post(&((*s_etat_processus).semaphore_fork));
             sem_destroy(&((*s_etat_processus).semaphore_fork));                  sem_destroy(&((*s_etat_processus).semaphore_fork));
 #           else  #           else
             sem_post((*s_etat_processus).semaphore_fork);                  sem_post((*s_etat_processus).semaphore_fork);
             sem_destroy2((*s_etat_processus).semaphore_fork, sem_fork);                  sem_close((*s_etat_processus).semaphore_fork);
 #           endif  #           endif
   
             free(s_etat_processus);              liberation_contexte_cas(s_etat_processus);
               liberation_allocateur_buffer(s_etat_processus);
               sys_free(s_etat_processus);
   
             s_etat_processus = candidat;              s_etat_processus = candidat;
         }          }
Line 1350  liberation_threads(struct_processus *s_e Line 1288  liberation_threads(struct_processus *s_e
         s_argument_thread = (struct_descripteur_thread *)          s_argument_thread = (struct_descripteur_thread *)
                 (*l_element_courant).donnee;                  (*l_element_courant).donnee;
   
         if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0)          if (pthread_mutex_lock(&((*s_argument_thread).mutex_nombre_references))
                   != 0)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_processus;              (*s_etat_processus).erreur_systeme = d_es_processus;
             sem_post(&semaphore_liste_threads);              pthread_mutex_unlock(&mutex_liste_threads);
             return;              return;
         }          }
   
Line 1369  liberation_threads(struct_processus *s_e Line 1308  liberation_threads(struct_processus *s_e
             close((*s_argument_thread).pipe_acquittement[1]);              close((*s_argument_thread).pipe_acquittement[1]);
             close((*s_argument_thread).pipe_injections[1]);              close((*s_argument_thread).pipe_injections[1]);
             close((*s_argument_thread).pipe_nombre_injections[1]);              close((*s_argument_thread).pipe_nombre_injections[1]);
             close((*s_argument_thread).pipe_nombre_objets_attente[0]);              close((*s_argument_thread).pipe_nombre_elements_attente[0]);
             close((*s_argument_thread).pipe_interruptions[0]);              close((*s_argument_thread).pipe_interruptions[0]);
             close((*s_argument_thread).pipe_nombre_interruptions_attente[0]);  
   
             if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)              if (pthread_mutex_unlock(&((*s_argument_thread)
                       .mutex_nombre_references)) != 0)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 sem_post(&semaphore_liste_threads);                  pthread_mutex_unlock(&mutex_liste_threads);
                 return;                  return;
             }              }
   
             pthread_mutex_destroy(&((*s_argument_thread).mutex));              pthread_mutex_destroy(&((*s_argument_thread).mutex));
               pthread_mutex_destroy(&((*s_argument_thread)
                       .mutex_nombre_references));
   
             if ((*s_argument_thread).processus_detache == d_faux)              if ((*s_argument_thread).processus_detache == d_faux)
             {              {
Line 1394  liberation_threads(struct_processus *s_e Line 1335  liberation_threads(struct_processus *s_e
         }          }
         else          else
         {          {
             if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)              if (pthread_mutex_unlock(&((*s_argument_thread)
                       .mutex_nombre_references)) != 0)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 sem_post(&semaphore_liste_threads);                  pthread_mutex_unlock(&mutex_liste_threads);
                 return;                  return;
             }              }
         }          }
Line 1409  liberation_threads(struct_processus *s_e Line 1351  liberation_threads(struct_processus *s_e
   
     liste_threads_surveillance = NULL;      liste_threads_surveillance = NULL;
   
 #   ifndef SEMAPHORES_NOMMES      if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
     if (sem_post(&semaphore_liste_threads) != 0)  
 #   else  
     if (sem_post(semaphore_liste_threads) != 0)  
 #   endif  
     {      {
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
     }      }
   
     pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
     sigpending(&set);  
     return;      return;
 }  }
   
Line 1432  recherche_thread(pid_t pid, pthread_t ti Line 1367  recherche_thread(pid_t pid, pthread_t ti
   
     struct_processus                            *s_etat_processus;      struct_processus                            *s_etat_processus;
   
       if (pthread_mutex_lock(&mutex_liste_threads) != 0)
       {
           return(NULL);
       }
   
     l_element_courant = liste_threads;      l_element_courant = liste_threads;
   
     while(l_element_courant != NULL)      while(l_element_courant != NULL)
Line 1452  recherche_thread(pid_t pid, pthread_t ti Line 1392  recherche_thread(pid_t pid, pthread_t ti
          * Le processus n'existe plus. On ne distribue aucun signal.           * Le processus n'existe plus. On ne distribue aucun signal.
          */           */
   
           pthread_mutex_unlock(&mutex_liste_threads);
         return(NULL);          return(NULL);
     }      }
   
     s_etat_processus = (*((struct_thread *)      s_etat_processus = (*((struct_thread *)
             (*l_element_courant).donnee)).s_etat_processus;              (*l_element_courant).donnee)).s_etat_processus;
   
       if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
       {
           return(NULL);
       }
   
     return(s_etat_processus);      return(s_etat_processus);
 }  }
   
 static logical1  static struct_processus *
 recherche_thread_principal(pid_t pid, pthread_t *thread)  recherche_thread_principal(pid_t pid)
 {  {
     volatile struct_liste_chainee_volatile      *l_element_courant;      volatile struct_liste_chainee_volatile      *l_element_courant;
   
Line 1486  recherche_thread_principal(pid_t pid, pt Line 1432  recherche_thread_principal(pid_t pid, pt
          * Le processus n'existe plus. On ne distribue aucun signal.           * Le processus n'existe plus. On ne distribue aucun signal.
          */           */
   
         return(d_faux);          return(NULL);
     }      }
   
     (*thread) = (*((struct_thread *) (*l_element_courant).donnee)).tid;      return((*((struct_thread *) (*l_element_courant).donnee))
               .s_etat_processus);
     return(d_vrai);  
 }  }
   
   
Line 1512  recherche_thread_principal(pid_t pid, pt Line 1457  recherche_thread_principal(pid_t pid, pt
 // les sémaphores sont déjà bloqués par un gestionnaire de signal.  // les sémaphores sont déjà bloqués par un gestionnaire de signal.
   
 static inline void  static inline void
 verrouillage_gestionnaire_signaux()  verrouillage_gestionnaire_signaux(struct_processus *s_etat_processus)
 {  {
     int         semaphore;  #   ifndef SEMAPHORES_NOMMES
       if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
     sigset_t    oldset;  #   else
     sigset_t    set;      if (sem_post((*s_etat_processus).semaphore_fork) != 0)
   #   endif
     sem_t       *sem;  
   
     if ((sem = pthread_getspecific(semaphore_fork_processus_courant))  
             != NULL)  
     {      {
         if (sem_post(sem) != 0)          BUG(1, uprintf("Lock error !\n"));
         {          return;
             BUG(1, uprintf("Lock error !\n"));  
             return;  
         }  
     }      }
   
     // Il faut respecteur l'atomicité des deux opérations suivantes !      return;
   }
     sigfillset(&set);  
     pthread_sigmask(SIG_BLOCK, &set, &oldset);  
   
   static inline void
   deverrouillage_gestionnaire_signaux(struct_processus *s_etat_processus)
   {
 #   ifndef SEMAPHORES_NOMMES  #   ifndef SEMAPHORES_NOMMES
     while(sem_wait(&semaphore_gestionnaires_signaux_atomique) == -1)      while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 #   else  #   else
     while(sem_wait(semaphore_gestionnaires_signaux_atomique) == -1)      while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
 #   endif  #   endif
     {      {
         if (errno != EINTR)          if (errno != EINTR)
         {          {
             pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
             BUG(1, uprintf("Unlock error !\n"));              BUG(1, uprintf("Unlock error !\n"));
             return;              return;
         }          }
     }      }
   
 #   ifndef SEMAPHORES_NOMMES      return;
     if (sem_post(&semaphore_gestionnaires_signaux) == -1)  }
 #   else  
     if (sem_post(semaphore_gestionnaires_signaux) == -1)  /*
 #   endif  ================================================================================
     Fonctions de gestion des signaux dans les threads.
   
     Lorsqu'un processus reçoit un signal, il appelle le gestionnaire de signal
     associé qui ne fait qu'envoyer au travers de write() le signal
     reçus dans un pipe. Un second thread est bloqué sur ce pipe et
     effectue le traitement adéquat pour le signal donné.
   ================================================================================
   */
   
   #define test_signal(signal) \
       if (signal_test == SIGTEST) { signal_test = signal; return; }
   
   static int          pipe_signaux;
   
   logical1
   lancement_thread_signaux(struct_processus *s_etat_processus)
   {
       pthread_attr_t                  attributs;
   
       void                            *argument;
   
       if (pipe((*s_etat_processus).pipe_signaux) != 0)
     {      {
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);          (*s_etat_processus).erreur_systeme = d_es_processus;
         BUG(1, uprintf("Lock error !\n"));          return(d_erreur);
         return;  
     }      }
   
 #   ifndef SEMAPHORES_NOMMES      pipe_signaux = (*s_etat_processus).pipe_signaux[1];
     if (sem_getvalue(&semaphore_gestionnaires_signaux, &semaphore) != 0)  
 #   else      if (pthread_attr_init(&attributs) != 0)
     if (sem_getvalue(semaphore_gestionnaires_signaux, &semaphore) != 0)  
 #   endif  
     {      {
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);          (*s_etat_processus).erreur_systeme = d_es_processus;
         BUG(1, uprintf("Lock error !\n"));          return(d_erreur);
         return;  
     }      }
   
 #   ifndef SEMAPHORES_NOMMES      if (pthread_attr_setdetachstate(&attributs, PTHREAD_CREATE_JOINABLE) != 0)
     if (sem_post(&semaphore_gestionnaires_signaux_atomique) != 0)  
 #   else  
     if (sem_post(semaphore_gestionnaires_signaux_atomique) != 0)  
 #   endif  
     {      {
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);          (*s_etat_processus).erreur_systeme = d_es_processus;
         BUG(1, uprintf("Unlock error !\n"));          return(d_erreur);
         return;  
     }      }
   
     if (semaphore == 1)      argument = (*s_etat_processus).pipe_signaux;
   
       if (pthread_create(&((*s_etat_processus).thread_signaux), &attributs,
               thread_signaux, argument) != 0)
     {      {
         // Le semaphore ne peut être pris par le thread qui a appelé          (*s_etat_processus).erreur_systeme = d_es_processus;
         // le gestionnaire de signal car le signal est bloqué par ce thread          return(d_erreur);
         // dans les zones critiques. Ce sémaphore ne peut donc être bloqué que      }
         // par un thread concurrent. On essaye donc de le bloquer jusqu'à  
         // ce que ce soit possible.  
   
 #       ifndef SEMAPHORES_NOMMES      return(d_absence_erreur);
         while(sem_trywait(&semaphore_liste_threads) == -1)  }
 #       else  
         while(sem_trywait(semaphore_liste_threads) == -1)  
 #       endif  
         {  
             if ((errno != EINTR) && (errno != EAGAIN))  
             {  
                 pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
   
                 while(sem_wait(sem) == -1)  logical1
                 {  arret_thread_signaux(struct_processus *s_etat_processus)
                     if (errno != EINTR)  {
                     {      unsigned char       signal;
                         BUG(1, uprintf("Lock error !\n"));      ssize_t             n;
                         return;  
                     }  
                 }  
   
                 BUG(1, uprintf("Lock error !\n"));      signal = (unsigned char ) (rpl_sigmax & 0xFF);
                 return;  
             }  
   
             sched_yield();      do
       {
           n = write((*s_etat_processus).pipe_signaux[1], &signal, sizeof(signal));
   
           if (n < 0)
           {
               return(d_erreur);
         }          }
     }      } while(n != 1);
   
     pthread_sigmask(SIG_SETMASK, &oldset, NULL);      pthread_join((*s_etat_processus).thread_signaux, NULL);
     sigpending(&set);  
   
     return;      close((*s_etat_processus).pipe_signaux[0]);
       close((*s_etat_processus).pipe_signaux[1]);
   
       return(d_absence_erreur);
 }  }
   
 static inline void  void *
 deverrouillage_gestionnaire_signaux()  thread_signaux(void *argument)
 {  {
     int         semaphore;      int                     *pipe;
   
     sem_t       *sem;      sigset_t                masque;
   
     sigset_t    oldset;      struct pollfd           fds;
     sigset_t    set;  
   
     // Il faut respecteur l'atomicité des deux opérations suivantes !      unsigned char           signal;
   
     sigfillset(&set);      pipe = (int *) argument;
     pthread_sigmask(SIG_BLOCK, &set, &oldset);      fds.fd = pipe[0];
       fds.events = POLLIN;
 #   ifndef SEMAPHORES_NOMMES      fds.revents = 0;
     while(sem_wait(&semaphore_gestionnaires_signaux_atomique) == -1)  
 #   else  
     while(sem_wait(semaphore_gestionnaires_signaux_atomique) == -1)  
 #   endif  
     {  
         if (errno != EINTR)  
         {  
             pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
             BUG(1, uprintf("Unlock error !\n"));  
             return;  
         }  
     }  
   
 #   ifndef SEMAPHORES_NOMMES      sigfillset(&masque);
     if (sem_getvalue(&semaphore_gestionnaires_signaux, &semaphore) != 0)      pthread_sigmask(SIG_BLOCK, &masque, NULL);
 #   else  
     if (sem_getvalue(semaphore_gestionnaires_signaux, &semaphore) != 0)  
 #   endif  
     {  
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         BUG(1, uprintf("Unlock error !\n"));  
         return;  
     }  
   
 #   ifndef SEMAPHORES_NOMMES      do
     while(sem_wait(&semaphore_gestionnaires_signaux) == -1)  
 #   else  
     while(sem_wait(semaphore_gestionnaires_signaux) == -1)  
 #   endif  
     {      {
         if (errno != EINTR)          if (poll(&fds, 1, -1) == -1)
         {          {
             pthread_sigmask(SIG_SETMASK, &oldset, NULL);              pthread_exit(NULL);
             BUG(1, uprintf("Unlock error !\n"));  
             return;  
         }          }
     }  
   
 #   ifndef SEMAPHORES_NOMMES  #   pragma GCC diagnostic push
     if (sem_post(&semaphore_gestionnaires_signaux_atomique) != 0)  #   pragma GCC diagnostic ignored "-Wunused-result"
 #   else  
     if (sem_post(semaphore_gestionnaires_signaux_atomique) != 0)  
 #   endif  
     {  
         pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
         BUG(1, uprintf("Unlock error !\n"));  
         return;  
     }  
   
     if ((sem = pthread_getspecific(semaphore_fork_processus_courant))          read(fds.fd, &signal, 1);
             != NULL)  
     {  
         while(sem_wait(sem) == -1)  
         {  
             if (errno != EINTR)  
             {  
                 pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
                 BUG(1, uprintf("Unlock error !\n"));  
                 return;  
             }  
         }  
     }  
   
     if (semaphore == 1)  #   pragma GCC diagnostic pop
     {  
 #       ifndef SEMAPHORES_NOMMES  
         if (sem_post(&semaphore_liste_threads) != 0)  
 #       else  
         if (sem_post(semaphore_liste_threads) != 0)  
 #       endif  
         {  
             pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
   
             BUG(1, uprintf("Unlock error !\n"));          if (signal != (0xFF & rpl_sigmax))
             return;          {
               envoi_signal_processus(getpid(), signal);
               // Un signal SIGALRM est envoyé par le thread de surveillance
               // des signaux jusqu'à ce que les signaux soient tous traités.
         }          }
     }      } while(signal != (0xFF & rpl_sigmax));
   
     pthread_sigmask(SIG_SETMASK, &oldset, NULL);  
     sigpending(&set);  
   
     return;      pthread_exit(NULL);
 }  }
   
 #ifdef _BROKEN_SIGINFO  // Récupération des signaux
   // - SIGINT  (arrêt au clavier)
   // - SIGTERM (signal d'arrêt en provenance du système)
   
 #define longueur_queue  256  void
 #define nombre_queues   13  interruption1(int signal)
   {
 static int              *fifos;      unsigned char       signal_tronque;
 static int              markov;  
 static int              segment;  
 static sem_t            *semaphores[nombre_queues];  
 static sem_t            *semaphore_global;  
   
 #ifdef IPCS_SYSV      test_signal(signal);
 static unsigned char    *chemin = NULL;  
 #endif  
   
 unsigned char *  #   pragma GCC diagnostic push
 nom_segment(unsigned char *chemin, pid_t pid)  #   pragma GCC diagnostic ignored "-Wunused-result"
 {  
     unsigned char               *fichier;  
   
 #   ifdef IPCS_SYSV      switch(signal)
     if ((fichier = malloc((strlen(chemin) + 1 + 256 + 1) *  
             sizeof(unsigned char))) == NULL)  
     {      {
         return(NULL);          case SIGINT:
     }              signal_tronque = (unsigned char) (rpl_sigint & 0xFF);
               write(pipe_signaux, &signal_tronque, sizeof(signal_tronque));
               break;
   
     sprintf(fichier, "%s/RPL-SIGQUEUES-%d", chemin, (int) pid);          case SIGTERM:
 #   else              signal_tronque = (unsigned char) (rpl_sigterm & 0xFF);
     if ((fichier = malloc((1 + 256 + 1) *              write(pipe_signaux, &signal_tronque, sizeof(signal_tronque));
             sizeof(unsigned char))) == NULL)              break;
     {  
         return(NULL);          case SIGUSR1:
               signal_tronque = (unsigned char) (rpl_sigalrm & 0xFF);
               write(pipe_signaux, &signal_tronque, sizeof(signal_tronque));
               break;
   
           default:
               // SIGALRM
               break;
     }      }
   
     sprintf(fichier, "/RPL-SIGQUEUES-%d", (int) pid);  #   pragma GCC diagnostic pop
 #   endif  
   
     return(fichier);      return;
 }  }
   
 unsigned char *  // Récupération des signaux
 nom_semaphore(pid_t pid, int queue)  // - SIGFSTP
   //
   // ATTENTION :
   // Le signal SIGFSTP provient de la mort du processus de contrôle.
   // Sous certains systèmes (Linux...), la mort du terminal de contrôle
   // se traduit par l'envoi d'un SIGHUP au processus. Sur d'autres
   // (SunOS), le processus reçoit un SIGFSTP avec une structure siginfo
   // non initialisée (pointeur NULL) issue de TERMIO.
   
   void
   interruption2(int signal)
 {  {
     unsigned char               *fichier;      unsigned char       signal_tronque;
   
     if ((fichier = malloc((256 + 1) * sizeof(unsigned char))) == NULL)      test_signal(signal);
     {  
         return(NULL);  
     }  
   
     sprintf(fichier, "/RPL-SIGESMAPHORES-%d-%d", (int) pid, queue);      signal_tronque = (unsigned char) (rpl_sigtstp & 0xFF);
   
     return(fichier);  #   pragma GCC diagnostic push
 }  #   pragma GCC diagnostic ignored "-Wunused-result"
   
 inline int      write(pipe_signaux, &signal_tronque, sizeof(signal_tronque));
 queue_de_signal(int signal)  
 {  #   pragma GCC diagnostic pop
     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);      return;
 }  }
   
 void  void
 creation_fifos_signaux(struct_processus *s_etat_processus)  interruption3(int signal)
 {  {
     /*      // Si on passe par ici, c'est qu'il est impossible de récupérer
      * Signaux utilisés      // l'erreur d'accès à la mémoire. On sort donc du programme quitte à
      * SIGINT, SIGTSTP, SIGCONT, SIGURG, SIGPIPE, SIGALRM, SIGFSTOP,      // ce qu'il reste des processus orphelins.
      * SIGSTART, SIGINJECT, SIGABORT, SIGFABORT  
      */  
   
     int                             i;  
   
     unsigned char                   *nom;      unsigned char       message_1[] = "+++System : Uncaught access violation\n"
                                   "+++System : Aborting !\n";
       unsigned char       message_2[] = "+++System : Stack overflow\n"
                                   "+++System : Aborting !\n";
   
 #   ifndef IPCS_SYSV // POSIX      test_signal(signal);
   
     if ((nom = nom_segment((*s_etat_processus).chemin_fichiers_temporaires,      if (pid_processus_pere == getpid())
             getpid())) == NULL)  
     {      {
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          kill(pid_processus_pere, SIGUSR1);
         return;  
     }      }
   
     if ((segment = shm_open(nom, O_RDWR | O_CREAT | O_EXCL,  #   pragma GCC diagnostic push
             S_IRUSR | S_IWUSR)) == -1)  #   pragma GCC diagnostic ignored "-Wunused-result"
   
       if (signal != SIGUSR2)
     {      {
         free(nom);          write(STDERR_FILENO, message_1, strlen(message_1));
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
         return;  
     }      }
       else
     if (ftruncate(segment, nombre_queues * ((2 * longueur_queue) + 4) *  
             sizeof(int)) == -1)  
     {      {
         free(nom);          write(STDERR_FILENO, message_2, strlen(message_2));
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
         return;  
     }      }
   
     fifos = mmap(NULL, nombre_queues * ((2 * longueur_queue) + 4) * sizeof(int),  #   pragma GCC diagnostic pop
             PROT_READ | PROT_WRITE, MAP_SHARED, segment, 0);  
     close(segment);  
   
     if (((void *) fifos) == ((void *) -1))      _exit(EXIT_FAILURE);
     {  }
         if (shm_unlink(nom) == -1)  
         {  
             free(nom);  
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
             return;  
         }  
   
         free(nom);  // Récupération des signaux
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  // - SIGHUP
         return;  
     }  
   
     free(nom);  void
   interruption4(int signal)
   {
       unsigned char       signal_tronque;
   
 #   else // SystemV      test_signal(signal);
   
     file                            *desc;      signal_tronque = (unsigned char) (rpl_sighup & 0xFF);
   
     key_t                           clef;  #   pragma GCC diagnostic push
   #   pragma GCC diagnostic ignored "-Wunused-result"
   
     // Création d'un segment de données associé au PID du processus courant      write(pipe_signaux, &signal_tronque, sizeof(signal_tronque));
   
     chemin = (*s_etat_processus).chemin_fichiers_temporaires;  #   pragma GCC diagnostic pop
   
     if ((nom = nom_segment((*s_etat_processus).chemin_fichiers_temporaires,      return;
             getpid())) == NULL)  }
     {  
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
         return;  
     }  
   
     if ((desc = fopen(nom, "w")) == NULL)  // Récupération des signaux
     {  // - SIGPIPE
         (*s_etat_processus).erreur_systeme = d_es_erreur_fichier;  
         return;  
     }  
   
     fclose(desc);  void
   interruption5(int signal)
   {
       unsigned char       message[] = "+++System : SIGPIPE\n"
                                   "+++System : Aborting !\n";
       unsigned char       signal_tronque;
   
     if ((clef = ftok(nom, 1)) == -1)      test_signal(signal);
     {  
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
         return;  
     }  
   
     free(nom);  #   pragma GCC diagnostic push
   #   pragma GCC diagnostic ignored "-Wunused-result"
   
     if ((segment = shmget(clef,      if (pid_processus_pere == getpid())
             nombre_queues * ((2 * longueur_queue) + 4) * sizeof(int),  
             IPC_CREAT | IPC_EXCL | S_IRUSR | S_IWUSR)) == -1)  
     {      {
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          signal_tronque = (unsigned char) (rpl_sigalrm & 0xFF);
         return;          write(pipe_signaux, &signal_tronque, sizeof(signal_tronque));
     }      }
   
     fifos = shmat(segment, NULL, 0);      write(STDERR_FILENO, message, strlen(message));
   
     if (((void *) fifos) == ((void *) -1))  #   pragma GCC diagnostic pop
     {  
         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;
         return;  }
     }  
   
 #   endif  
   
     /*  inline static void
      * Structure d'une queue  signal_alrm(struct_processus *s_etat_processus, pid_t pid)
      * 0 : pointeur en lecture sur le premier emplacement libre (int)  {
      * 1 : pointeur en écriture sur le premier emplacement à lire (int)      struct_processus        *s_thread_principal;
      * 2 : longueur de la queue (int)  
      * 3 : éléments restants (int)  
      * 4 à 4 + (2) : queue (int)  
      * 4 + (2) + 1 ) 4 + 2 * (2) : horodatage en centième de secondes.  
      */  
   
     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      verrouillage_gestionnaire_signaux(s_etat_processus);
     // plus un sémaphore global pour tous les threads.  
   
     for(i = 0; i < nombre_queues; i++)      if (pid == getpid())
     {      {
         if ((nom = nom_semaphore(getpid(), i)) == NULL)          // Si pid est égal à getpid(), le signal à traiter est issu
           // du même processus que celui qui va le traiter, mais d'un thread
           // différent.
   
           if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              printf("[%d] RPL/SIGALRM (thread %llu)\n", (int) getpid(),
             return;                      (unsigned long long) pthread_self());
               fflush(stdout);
         }          }
   
         // Le sémaphore est créé en écrasant si nécessaire un sémaphore          if ((*s_etat_processus).pid_processus_pere != getpid())
         // 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;              // On n'est pas dans le processus père, on remonte le signal.
             return;              envoi_signal_processus((*s_etat_processus).pid_processus_pere,
                       rpl_sigalrm);
           }
           else
           {
               // On est dans le processus père, on effectue un arrêt d'urgence.
               (*s_etat_processus).var_volatile_alarme = -1;
               (*s_etat_processus).var_volatile_requete_arret = -1;
         }          }
   
         free(nom);  
     }      }
       else
   
     if ((nom = nom_semaphore(getpid(), nombre_queues)) == NULL)  
     {      {
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          // Le signal est issu d'un processus différent. On recherche le
         return;          // thread principal pour remonter le signal.
     }  
   
     if ((semaphore_global = sem_open(nom, O_CREAT, S_IRUSR | S_IWUSR,          if ((s_thread_principal = recherche_thread_principal(getpid()))
             1)) == SEM_FAILED)                  != NULL)
     {          {
         (*s_etat_processus).erreur_systeme = d_es_semaphore;              envoi_signal_contexte(s_thread_principal, rpl_sigalrm);
         return;          }
     }      }
   
     free(nom);      deverrouillage_gestionnaire_signaux(s_etat_processus);
   
     markov = 0;  
   
     return;      return;
 }  }
   
 void  inline static void
 liberation_fifos_signaux(struct_processus *s_etat_processus)  signal_term(struct_processus *s_etat_processus, pid_t pid)
 {  {
     int                 i;      struct_processus        *s_thread_principal;
       pthread_mutex_t         exclusion = PTHREAD_MUTEX_INITIALIZER;
   
 #   ifdef IPCS_SYSV // SystemV      verrouillage_gestionnaire_signaux(s_etat_processus);
   
     if (shmdt(fifos) == -1)      if (pid == getpid())
     {      {
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
         return;          {
     }              printf("[%d] RPL/SIGTERM (thread %llu)\n", (int) getpid(),
                       (unsigned long long) pthread_self());
               fflush(stdout);
           }
   
 #   else // POSIX          if ((*s_etat_processus).pid_processus_pere != getpid())
           {
               envoi_signal_processus((*s_etat_processus).pid_processus_pere,
                       rpl_sigterm);
           }
           else
           {
               (*s_etat_processus).var_volatile_traitement_sigint = -1;
   
     if (munmap(fifos, nombre_queues * ((2 * longueur_queue) + 4) * sizeof(int))              pthread_mutex_lock(&exclusion);
             != 0)  
     {  
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
         return;  
     }  
   
 #   endif              if ((*s_etat_processus).var_volatile_requete_arret == -1)
               {
                   deverrouillage_gestionnaire_signaux(s_etat_processus);
                   pthread_mutex_unlock(&exclusion);
                   return;
               }
   
     for(i = 0; i < nombre_queues; i++)              (*s_etat_processus).var_volatile_requete_arret = -1;
     {              (*s_etat_processus).var_volatile_alarme = -1;
         if (sem_close(semaphores[i]) != 0)  
         {              pthread_mutex_unlock(&exclusion);
             (*s_etat_processus).erreur_systeme = d_es_semaphore;  
             return;  
         }          }
     }      }
       else
     if (sem_close(semaphore_global) != 0)  
     {      {
         (*s_etat_processus).erreur_systeme = d_es_semaphore;          if ((s_thread_principal = recherche_thread_principal(getpid()))
         return;                  != NULL)
           {
               envoi_signal_contexte(s_thread_principal, rpl_sigterm);
           }
     }      }
   
       deverrouillage_gestionnaire_signaux(s_etat_processus);
     return;      return;
 }  }
   
 void  inline static void
 destruction_fifos_signaux(struct_processus *s_etat_processus)  signal_int(struct_processus *s_etat_processus, pid_t pid)
 {  {
     int                 i;      struct_processus        *s_thread_principal;
       volatile sig_atomic_t   exclusion = 0;
     unsigned char       *nom;  
   
 #   ifdef IPCS_SYSV // SystemV      verrouillage_gestionnaire_signaux(s_etat_processus);
   
     if (shmdt(fifos) == -1)      if (pid == getpid())
     {      {
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
         return;          {
     }              printf("[%d] RPL/SIGINT (thread %llu)\n", (int) getpid(),
                       (unsigned long long) pthread_self());
               fflush(stdout);
           }
   
     if (shmctl(segment, IPC_RMID, 0) == -1)          if ((*s_etat_processus).pid_processus_pere != getpid())
     {          {
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              envoi_signal_processus((*s_etat_processus).pid_processus_pere,
         return;                      rpl_sigint);
     }          }
           else
           {
               (*s_etat_processus).var_volatile_traitement_sigint = -1;
   
     if ((nom = nom_segment((*s_etat_processus).chemin_fichiers_temporaires,              while(exclusion == 1);
             getpid())) == NULL)              exclusion = 1;
     {  
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
         return;  
     }  
   
     unlink(nom);              if ((*s_etat_processus).var_volatile_requete_arret == -1)
     free(nom);              {
                   deverrouillage_gestionnaire_signaux(s_etat_processus);
                   exclusion = 0;
                   return;
               }
   
 #   else // POSIX              if ((*s_etat_processus).langue == 'F')
               {
                   printf("+++Interruption\n");
               }
               else
               {
                   printf("+++Interrupt\n");
               }
   
     if (munmap(fifos, nombre_queues * ((2 * longueur_queue) + 4) * sizeof(int))              fflush(stdout);
             != 0)  
     {  
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
         return;  
     }  
   
     if ((nom = nom_segment(NULL, getpid())) == NULL)              (*s_etat_processus).var_volatile_requete_arret = -1;
     {              (*s_etat_processus).var_volatile_alarme = -1;
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
         return;  
     }  
   
     if (shm_unlink(nom) != 0)              exclusion = 0;
           }
       }
       else
     {      {
         free(nom);          if ((s_thread_principal = recherche_thread_principal(getpid()))
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;                  != NULL)
         return;          {
               envoi_signal_contexte(s_thread_principal, rpl_sigint);
           }
     }      }
   
     free(nom);      deverrouillage_gestionnaire_signaux(s_etat_processus);
       return;
   }
   
 #   endif  static inline void
   signal_tstp(struct_processus *s_etat_processus, pid_t pid)
   {
       struct_processus        *s_thread_principal;
   
       verrouillage_gestionnaire_signaux(s_etat_processus);
   
     for(i = 0; i < nombre_queues; i++)      if (pid == getpid())
     {      {
         if ((nom = nom_semaphore(getpid(), i)) == NULL)          /*
            *  0 => fonctionnement normal
            * -1 => requête
            *  1 => requête acceptée en attente de traitement
            */
   
           if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              printf("[%d] RPL/SIGTSTP (thread %llu)\n", (int) getpid(),
             return;                      (unsigned long long) pthread_self());
               fflush(stdout);
         }          }
   
         if (sem_unlink(nom) != 0)          if ((*s_etat_processus).var_volatile_processus_pere == 0)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_semaphore;              envoi_signal_processus((*s_etat_processus).pid_processus_pere,
             return;                      rpl_sigtstp);
           }
           else
           {
               (*s_etat_processus).var_volatile_requete_arret2 = -1;
         }          }
   
         free(nom);  
     }      }
       else
     if ((nom = nom_semaphore(getpid(), nombre_queues)) == NULL)  
     {      {
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          // Envoi d'un signal au thread maître du groupe.
         return;  
           if ((s_thread_principal = recherche_thread_principal(getpid()))
                   != NULL)
           {
               envoi_signal_contexte(s_thread_principal, rpl_sigtstp);
           }
     }      }
   
     if (sem_unlink(nom) != 0)      deverrouillage_gestionnaire_signaux(s_etat_processus);
       return;
   }
   
   static void
   sortie_interruption_depassement_pile(void *arg1, void *arg2, void *arg3)
   {
       switch((*((volatile int *) arg1)))
     {      {
         (*s_etat_processus).erreur_systeme = d_es_semaphore;          case 1:
         return;              longjmp(contexte_ecriture, -1);
     }              break;
   
     free(nom);          case 2:
               longjmp(contexte_impression, -1);
               break;
       }
   
     return;      return;
 }  }
   
 inline int  void
 horodatage()  interruption_depassement_pile(int urgence, stackoverflow_context_t scp)
 {  {
     int             ts;      if ((urgence == 0) && (routine_recursive != 0))
       {
     struct timeval  tv;          // On peut tenter de récupérer le dépassement de pile. Si la variable
           // 'routine_recursive' est non nulle, on récupère l'erreur.
   
     gettimeofday(&tv, NULL);          sigsegv_leave_handler(sortie_interruption_depassement_pile,
     ts = (int) ((tv.tv_sec * 100) + (tv.tv_usec / 10000));                  (void *) &routine_recursive, NULL, NULL);
       }
   
     return(ts);      // Ici, la panique est totale et il vaut mieux quitter l'application.
       interruption3(SIGUSR2);
       return;
 }  }
   
 int  int
 queue_in(pid_t pid, int signal)  interruption_violation_access(void *adresse_fautive, int gravite)
 {  {
     int             queue;      unsigned char       message[] = "+++System : Trying to catch access "
     int             *base;                                  "violation\n";
     int             *buffer;  
     int             horodatage_initial;  
     int             identifiant;  
     int             *projection_fifos;  
   
     sem_t           *semaphore;      static int          compteur_erreur = 0;
   
     queue = queue_de_signal(signal);      if ((gravite == 0) && (routine_recursive != 0))
       {
           // Il peut s'agir d'un dépassement de pile.
   
     unsigned char   *nom;          sigsegv_leave_handler(sortie_interruption_depassement_pile,
                   (void *) &routine_recursive, NULL, NULL);
       }
   
 #   ifndef IPCS_SYSV      // On est dans une bonne vieille violation d'accès. On essaie
       // de fermer au mieux l'application.
   
     // Ouverture des projections      compteur_erreur++;
   
     if ((nom = nom_segment(NULL, pid)) == NULL)      if (compteur_erreur >= 2)
     {      {
         return(-1);          // Erreurs multiples, on arrête l'application.
           interruption3(SIGSEGV);
           return(0);
     }      }
   
     // Dans le cas de SIGSTART, premier signal envoyé à un processus fils,  #   pragma GCC diagnostic push
     // il convient d'attendre que le fichier support soit effectivement  #   pragma GCC diagnostic ignored "-Wunused-result"
     // accessible. Dans tous les autres cas, ce fichier doit exister. S'il  
     // n'existe plus, le processus associé n'existe plus.  
   
     if (signal == SIGSTART)      write(STDERR_FILENO, message, strlen(message));
     {  
         horodatage_initial = horodatage();  
   
         while((identifiant = shm_open(nom, O_RDWR, S_IRUSR | S_IWUSR)) == -1)  #   pragma GCC diagnostic pop
         {  
             if (abs(horodatage_initial - horodatage()) > 500)      if (pid_processus_pere == getpid())
             {      {
                 return(-1);          longjmp(contexte_initial, -1);
             }          return(1);
         }  
     }      }
     else      else
     {      {
         if ((identifiant = shm_open(nom, O_RDWR, S_IRUSR | S_IWUSR)) == -1)          longjmp(contexte_processus, -1);
         {          return(1);
             return(-1);  
         }  
     }      }
   
     projection_fifos = mmap(NULL, nombre_queues * ((2 * longueur_queue) + 4)      // On renvoie 0 parce qu'on décline toute responsabilité quant à la
             * sizeof(int), PROT_READ | PROT_WRITE, MAP_SHARED, identifiant, 0);      // suite des événements...
     close(identifiant);      return(0);
   }
   
   // Traitement de rpl_sigstart
   
     if (((void *) projection_fifos) == ((void *) -1))  static inline void
   signal_start(struct_processus *s_etat_processus, pid_t pid)
   {
       struct_processus        *s_thread_principal;
   
       verrouillage_gestionnaire_signaux(s_etat_processus);
   
       if (pid == getpid())
     {      {
         return(-1);          (*s_etat_processus).demarrage_fils = d_vrai;
       }
       else
       {
           // Envoi d'un signal au thread maître du groupe.
   
           if ((s_thread_principal = recherche_thread_principal(getpid()))
                   != NULL)
           {
               envoi_signal_contexte(s_thread_principal, rpl_sigstart);
           }
     }      }
   
 #   else // Traitement à l'aide d'IPCS SystemV      deverrouillage_gestionnaire_signaux(s_etat_processus);
       return;
   }
   
     key_t           clef;  // Traitement de rpl_sigcont
   
     struct stat     s_stat;  static inline void
   signal_cont(struct_processus *s_etat_processus, pid_t pid)
   {
       struct_processus        *s_thread_principal;
   
     // Ouverture des projections      verrouillage_gestionnaire_signaux(s_etat_processus);
   
     if ((nom = nom_segment(chemin, pid)) == NULL)      if (pid == getpid())
     {      {
         return(-1);          (*s_etat_processus).redemarrage_processus = d_vrai;
     }      }
       else
     // 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          // Envoi d'un signal au thread maître du groupe.
   
         horodatage_initial = horodatage();  
   
         while(stat(nom, &s_stat) != 0)          if ((s_thread_principal = recherche_thread_principal(getpid()))
                   != NULL)
         {          {
             if (abs(horodatage_initial - horodatage()) > 500)              envoi_signal_contexte(s_thread_principal, rpl_sigcont);
             {  
                 return(-1);  
             }  
         }          }
     }      }
   
     if ((clef = ftok(nom, 1)) == -1)      deverrouillage_gestionnaire_signaux(s_etat_processus);
     {      return;
         return(-1);  }
     }  
   
     free(nom);  // Traitement de rpl_sigstop
   
     if (signal == SIGSTART)  static inline void
   signal_stop(struct_processus *s_etat_processus, pid_t pid)
   {
       struct_processus        *s_thread_principal;
   
       verrouillage_gestionnaire_signaux(s_etat_processus);
   
       if (pid == getpid())
     {      {
         while((identifiant = shmget(clef,          if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
                 nombre_queues * ((2 * longueur_queue) + 4) * sizeof(int),          {
                 S_IRUSR | S_IWUSR)) == -1);              printf("[%d] RPL/SIGSTOP (thread %llu)\n", (int) getpid(),
                       (unsigned long long) pthread_self());
               fflush(stdout);
           }
   
           /*
            * var_globale_traitement_retarde_stop :
            *  0 -> traitement immédiat
            *  1 -> traitement retardé (aucun signal reçu)
            * -1 -> traitement retardé (un ou plusieurs signaux stop reçus)
            */
   
           if ((*s_etat_processus).var_volatile_traitement_retarde_stop == 0)
           {
               (*s_etat_processus).var_volatile_requete_arret = -1;
           }
           else
           {
               (*s_etat_processus).var_volatile_traitement_retarde_stop = -1;
           }
     }      }
     else      else
     {      {
         if ((identifiant = shmget(clef,          // Envoi d'un signal au thread maître du groupe.
                 nombre_queues * ((2 * longueur_queue) + 4) * sizeof(int),  
                 S_IRUSR | S_IWUSR)) == -1)          if ((s_thread_principal = recherche_thread_principal(getpid()))
                   != NULL)
         {          {
             return(-1);              envoi_signal_contexte(s_thread_principal, rpl_sigstop);
         }          }
     }      }
   
     projection_fifos = shmat(identifiant, NULL, 0);      deverrouillage_gestionnaire_signaux(s_etat_processus);
       return;
   }
   
   // Traitement de rpl_siginject
   
   static inline void
   signal_inject(struct_processus *s_etat_processus, pid_t pid)
   {
       verrouillage_gestionnaire_signaux(s_etat_processus);
   
     if (((void *) projection_fifos) == ((void *) -1))      if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
     {      {
         return(-1);          deverrouillage_gestionnaire_signaux(s_etat_processus);
           return;
     }      }
   
 #   endif      if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
   
     if ((nom = nom_semaphore(pid, queue)) == NULL)  
     {      {
 #       ifdef IPCS_SYSV          printf("[%d] RPL/SIGINJECT (thread %llu)\n", (int) getpid(),
         shmdt(projection_fifos);                  (unsigned long long) pthread_self());
 #       else          fflush(stdout);
         munmap(projection_fifos, nombre_queues * ((2 * longueur_queue) + 4)  
                 * sizeof(int));  
 #       endif  
         return(-1);  
     }      }
   
     while((semaphore = sem_open(nom, 0)) == SEM_FAILED);      deverrouillage_gestionnaire_signaux(s_etat_processus);
     free(nom);      return;
   }
   
   
   static inline void
   signal_urg(struct_processus *s_etat_processus, pid_t pid)
   {
       struct_processus        *s_thread_principal;
   
       verrouillage_gestionnaire_signaux(s_etat_processus);
   
     while(sem_wait(semaphore) != 0)      if (pid == getpid())
     {      {
         if (errno != EINTR)          if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
         {          {
 #           ifdef IPCS_SYSV              printf("[%d] RPL/SIGURG (thread %llu)\n", (int) getpid(),
             shmdt(projection_fifos);                      (unsigned long long) pthread_self());
 #           else              fflush(stdout);
             munmap(projection_fifos, nombre_queues * ((2 * longueur_queue) + 4)  
                     * sizeof(int));  
 #           endif  
             return(-1);  
         }          }
   
           (*s_etat_processus).var_volatile_alarme = -1;
           (*s_etat_processus).var_volatile_requete_arret = -1;
     }      }
       else
       {
           // Envoi d'un signal au thread maître du groupe.
   
     base = &(projection_fifos[(longueur_queue + 4) * queue]);          if ((s_thread_principal = recherche_thread_principal(getpid()))
     buffer = &(base[4]);                  != NULL)
           {
               envoi_signal_contexte(s_thread_principal, rpl_sigurg);
           }
       }
   
     // base[3] contient le nombre d'éléments restants      deverrouillage_gestionnaire_signaux(s_etat_processus);
       return;
   }
   
     if (base[3] <= 0)  // Traitement de rpl_sigabort
     {  
         sem_post(semaphore);  
         sem_close(semaphore);  
 #       ifdef IPCS_SYSV  
         shmdt(projection_fifos);  
 #       else  
         munmap(projection_fifos, nombre_queues * ((2 * longueur_queue) + 4)  
                 * sizeof(int));  
 #       endif  
         return(-1);  
     }  
   
     base[3]--;  static inline void
   signal_abort(struct_processus *s_etat_processus, pid_t pid)
   {
       struct_processus        *s_thread_principal;
   
     // base[1] contient le prochain élément à écrire      verrouillage_gestionnaire_signaux(s_etat_processus);
   
     buffer[base[1] + (nombre_queues * base[2])] = horodatage();      if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
     buffer[base[1]++] = (int) pid;      {
     base[1] %= base[2];          deverrouillage_gestionnaire_signaux(s_etat_processus);
           return;
       }
   
     if (sem_post(semaphore) != 0)      if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
     {      {
 #       ifdef IPCS_SYSV          printf("[%d] RPL/SIGABORT (thread %llu)\n", (int) getpid(),
         shmdt(projection_fifos);                  (unsigned long long) pthread_self());
 #       else          fflush(stdout);
         munmap(projection_fifos, nombre_queues * ((2 * longueur_queue) + 4)  
                 * sizeof(int));  
 #       endif  
         sem_close(semaphore);  
         return(-1);  
     }      }
   
     sem_close(semaphore);      if (pid == getpid())
       {
           (*s_etat_processus).arret_depuis_abort = -1;
   
     // Fermeture des projections          /*
 #   ifdef IPCS_SYSV           * var_globale_traitement_retarde_stop :
     shmdt(projection_fifos);           *  0 -> traitement immédiat
 #   else           *  1 -> traitement retardé (aucun signal reçu)
     munmap(projection_fifos, nombre_queues * ((2 * longueur_queue) + 4)           * -1 -> traitement retardé (un ou plusieurs signaux stop reçus)
             * sizeof(int));           */
 #   endif  
   
     return(0);          if ((*s_etat_processus).var_volatile_traitement_retarde_stop == 0)
 }          {
               (*s_etat_processus).var_volatile_requete_arret = -1;
           }
           else
           {
               (*s_etat_processus).var_volatile_traitement_retarde_stop = -1;
           }
       }
       else
       {
           (*s_etat_processus).arret_depuis_abort = -1;
   
 inline int          // Envoi d'un signal au thread maître du groupe.
 chaine_markov(int markov, int delta)  
 {  
     double      memoire = 0.9;  
     int         valeur;  
   
     valeur = (int) ((memoire * markov) + ((1 - memoire) * delta));          if ((s_thread_principal = recherche_thread_principal(getpid()))
     valeur = (valeur < 10) ? 10 : valeur;                  != NULL)
           {
               envoi_signal_contexte(s_thread_principal, rpl_sigabort);
           }
       }
   
     return(valeur);      deverrouillage_gestionnaire_signaux(s_etat_processus);
       return;
 }  }
   
 pid_t  
 origine_signal(int signal)  
 {  
     logical1        drapeau;  
   
     int             *base;  static inline void
     int             *buffer;  signal_hup(struct_processus *s_etat_processus, pid_t pid)
     int             delta;  {
     int             pid;      file                    *fichier;
     int             queue;  
   
     queue = queue_de_signal(signal);      unsigned char           nom[8 + 64 + 1];
   
     BUG(queue == -1, uprintf("[%d] Unknown signal %d in this context\n",      verrouillage_gestionnaire_signaux(s_etat_processus);
             (int) getpid(), signal));  
   
     while(sem_wait(semaphores[queue]) != 0)      if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
     {      {
         if (errno != EINTR)          deverrouillage_gestionnaire_signaux(s_etat_processus);
         {          return;
             return(-1);  
         }  
     }      }
   
     // On retire les interruptions anciennes qui ont été ratées sauf s'il      snprintf(nom, 8 + 64 + 1, "rpl-out-%llu-%llu",
     // s'agit de la dernière dans la queue.              (unsigned long long) getpid(),
               (unsigned long long) pthread_self());
   
     base = &(fifos[(longueur_queue + 4) * queue]);  #   pragma GCC diagnostic push
     buffer = &(base[4]);  #   pragma GCC diagnostic ignored "-Wunused-result"
   
     if (base[3] == (base[2] - 1))      if ((fichier = fopen(nom, "w+")) != NULL)
     {      {
         delta = abs(horodatage() -          fclose(fichier);
                  buffer[base[0] + (nombre_queues * base[2])]);  
         // Une seule interruption dans la queue.  
         pid = buffer[base[0]++];  
         base[0] %= base[2];  
         base[3]++;  
   
         markov = chaine_markov(markov, delta);          freopen(nom, "w", stdout);
           freopen(nom, "w", stderr);
     }      }
     else if (base[3] >= base[2])  
     {  
         // Aucune interruption n'est dans la queue.  
         // On a retiré trop d'interruptions de la queue.  
   
         // (base[3] - base[2]) + 1 : nombre d'interruptions manquantes      freopen("/dev/null", "r", stdin);
         // base[0] - 1             : dernière interruption lue  
         pid = buffer[((((base[0] + base[2] - 1) % base[2])  #   pragma GCC diagnostic pop
                 - ((base[3] - base[2]) + 1)) + base[2]) % base[2]];  
     }      if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
     else  
     {      {
         // Plusieurs interruptions à distribuer.          printf("[%d] RPL/SIGHUP (thread %llu)\n", (int) getpid(),
         drapeau = d_vrai;                  (unsigned long long) pthread_self());
           fflush(stdout);
       }
   
         do      deverrouillage_gestionnaire_signaux(s_etat_processus);
         {      return;
             delta = abs(horodatage() -  }
                      buffer[base[0] + (nombre_queues * base[2])]);  
             pid = buffer[base[0]++];  
             base[0] %= base[2];  
             base[3]++;  
   
             if ((delta > (2 * markov)) && (base[3] < base[2]))  void
             {  traitement_exceptions_gsl(const char *reason, const char *file,
                 drapeau = d_vrai;          int line, int gsl_errno)
             }  {
             else      code_erreur_gsl = gsl_errno;
             {      envoi_signal_processus(getpid(), rpl_sigexcept);
                 drapeau = d_faux;      return;
             }  }
         } while(drapeau == d_vrai);  
   
         markov = chaine_markov(markov, delta);  static inline void
     }  signal_except(struct_processus *s_etat_processus, pid_t pid)
   {
       verrouillage_gestionnaire_signaux(s_etat_processus);
   
     if (sem_post(semaphores[queue]) != 0)      if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)
     {      {
         return(-1);          deverrouillage_gestionnaire_signaux(s_etat_processus);
           return;
     }      }
   
     return((pid_t) pid);      (*s_etat_processus).var_volatile_exception_gsl = code_erreur_gsl;
 }      deverrouillage_gestionnaire_signaux(s_etat_processus);
   
 #endif      return;
   }
   
 void  static inline void
 interruption1(SIGHANDLER_ARGS)  envoi_interruptions(struct_processus *s_etat_processus, enum signaux_rpl signal,
           pid_t pid_source)
 {  {
     pid_t                   pid;      switch(signal)
       {
           case rpl_signull:
               break;
   
     pthread_t               thread;          case rpl_sigint:
               signal_int(s_etat_processus, pid_source);
               break;
   
     struct_processus        *s_etat_processus;          case rpl_sigterm:
               signal_term(s_etat_processus, pid_source);
               break;
   
     volatile sig_atomic_t   exclusion = 0;          case rpl_sigstart:
               signal_start(s_etat_processus, pid_source);
               break;
   
     verrouillage_gestionnaire_signaux();          case rpl_sigcont:
               signal_cont(s_etat_processus, pid_source);
               break;
   
 #   ifdef _BROKEN_SIGINFO          case rpl_sigstop:
     if (signal == SIGINT)              signal_stop(s_etat_processus, pid_source);
     {              break;
         // Si l'interruption provient du clavier, il n'y a pas eu d'appel  
         // à queue_in().  
   
         pid = getpid();          case rpl_sigabort:
     }              signal_abort(s_etat_processus, pid_source);
     else              break;
     {  
         pid = origine_signal(signal);  
     }  
 #   else  
     pid = (*siginfo).si_pid;  
 #   endif  
   
     switch(signal)          case rpl_sigurg:
     {              signal_urg(s_etat_processus, pid_source);
         case SIGALRM :              break;
         {  
             if (pid == getpid())  
             {  
                 if ((s_etat_processus = recherche_thread(getpid(),  
                         pthread_self())) == NULL)  
                 {  
                     deverrouillage_gestionnaire_signaux();  
                      return;  
                 }  
   
                 if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)          case rpl_siginject:
                 {              signal_inject(s_etat_processus, pid_source);
                     printf("[%d] SIGALRM (thread %llu)\n", (int) getpid(),              break;
                             (unsigned long long) pthread_self());  
                     fflush(stdout);  
                 }  
   
                 if ((*s_etat_processus).pid_processus_pere != getpid())          case rpl_sigalrm:
                 {              signal_alrm(s_etat_processus, pid_source);
                     kill((*s_etat_processus).pid_processus_pere, signal);              break;
                 }  
                 else          case rpl_sighup:
                 {              signal_hup(s_etat_processus, pid_source);
                     (*s_etat_processus).var_volatile_alarme = -1;              break;
                     (*s_etat_processus).var_volatile_requete_arret = -1;  
                 }          case rpl_sigtstp:
               signal_tstp(s_etat_processus, pid_source);
               break;
   
           case rpl_sigexcept:
               signal_except(s_etat_processus, pid_source);
               break;
   
           default:
               if ((*s_etat_processus).langue == 'F')
               {
                   printf("+++System : Signal inconnu (%d) !\n", signal);
             }              }
             else              else
             {              {
                 if (recherche_thread_principal(getpid(), &thread) == d_vrai)                  printf("+++System : Spurious signal (%d) !\n", signal);
                 {  
                     pthread_kill(thread, signal);  
                 }  
             }              }
   
             break;              break;
         }      }
   
         case SIGINT :      return;
         {  }
             /*  
              * Une vieille spécification POSIX permet au pointeur siginfo  void
              * d'être nul dans le cas d'un ^C envoyé depuis le clavier.  scrutation_interruptions(struct_processus *s_etat_processus)
              * Solaris suit en particulier cette spécification.  {
              */      // Interruptions qui arrivent sur le processus depuis un
       // processus externe.
   
 #           ifndef _BROKEN_SIGINFO      // Les pointeurs de lecture pointent sur les prochains éléments
             if (siginfo == NULL)      // à lire. Les pointeurs d'écriture pointent sur les prochains éléments à
       // écrire.
   
       if (sem_trywait(semaphore_queue_signaux) == 0)
       {
           while((*s_queue_signaux).pointeur_lecture !=
                   (*s_queue_signaux).pointeur_ecriture)
           {
               // Il y a un signal en attente dans le segment partagé. On le
               // traite.
   
               envoi_interruptions(s_etat_processus,
                       (*s_queue_signaux).queue[(*s_queue_signaux)
                       .pointeur_lecture].signal, (*s_queue_signaux).queue
                       [(*s_queue_signaux).pointeur_lecture].pid);
               (*s_queue_signaux).pointeur_lecture =
                       ((*s_queue_signaux).pointeur_lecture + 1)
                       % LONGUEUR_QUEUE_SIGNAUX;
   
   #           ifndef IPCS_SYSV
               if (msync(s_queue_signaux, sizeof(s_queue_signaux),
                       MS_ASYNC | MS_INVALIDATE) != 0)
             {              {
                 kill(getpid(), signal);                  (*s_etat_processus).erreur_systeme = d_es_processus;
                   return;
             }              }
             else  
 #           endif  #           endif
             if (pid == getpid())  
               while(sem_wait(semaphore_signalisation) != 0)
             {              {
                 if ((s_etat_processus = recherche_thread(getpid(),                  if (errno != EINTR)
                         pthread_self())) == NULL)  
                 {                  {
                     deverrouillage_gestionnaire_signaux();                      (*s_etat_processus).erreur_systeme = d_es_processus;
                     return;                      return;
                 }                  }
               }
           }
   
                 if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)          sem_post(semaphore_queue_signaux);
                 {      }
                     printf("[%d] SIGINT (thread %llu)\n", (int) getpid(),  
                             (unsigned long long) pthread_self());  
                     fflush(stdout);  
                 }  
   
                 if ((*s_etat_processus).pid_processus_pere != getpid())  
                 {  
                     kill((*s_etat_processus).pid_processus_pere, signal);  
                 }  
                 else  
                 {  
                     (*s_etat_processus).var_volatile_traitement_sigint = -1;  
   
                     while(exclusion == 1);  
                     exclusion = 1;  
   
                     if ((*s_etat_processus).var_volatile_requete_arret == -1)  
                     {  
                         deverrouillage_gestionnaire_signaux();  
                         exclusion = 0;  
                         return;  
                     }  
   
                     if (strncmp(getenv("LANG"), "fr", 2) == 0)      // Interruptions qui arrivent depuis le groupe courant de threads.
                     {  
                         printf("+++Interruption\n");  
                     }  
                     else  
                     {  
                         printf("+++Interrupt\n");  
                     }  
   
                     fflush(stdout);      if (pthread_mutex_trylock(&((*s_etat_processus).mutex_signaux)) == 0)
       {
           while((*s_etat_processus).pointeur_signal_lecture !=
                   (*s_etat_processus).pointeur_signal_ecriture)
           {
               // Il y a un signal dans la queue du thread courant. On le traite.
   
                     (*s_etat_processus).var_volatile_requete_arret = -1;              envoi_interruptions(s_etat_processus,
                     (*s_etat_processus).var_volatile_alarme = -1;                      (*s_etat_processus).signaux_en_queue
                       [(*s_etat_processus).pointeur_signal_lecture],
                       getpid());
               (*s_etat_processus).pointeur_signal_lecture =
                       ((*s_etat_processus).pointeur_signal_lecture + 1)
                       % LONGUEUR_QUEUE_SIGNAUX;
   
                     exclusion = 0;              while(sem_wait(semaphore_signalisation) != 0)
                 }  
             }  
             else  
             {              {
                 if (recherche_thread_principal(getpid(), &thread) == d_vrai)                  if (errno != EINTR)
                 {                  {
                     pthread_kill(thread, signal);                      (*s_etat_processus).erreur_systeme = d_es_processus;
                       return;
                 }                  }
             }              }
   
             break;  
         }          }
   
         default :          pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux));
         {  
             BUG(1, uprintf("[%d] Unknown signal %d in this context\n",  
                     (int) getpid(), signal));  
             break;  
         }  
     }      }
   
     deverrouillage_gestionnaire_signaux();  
     return;      return;
 }  }
   
 void  
 interruption2(SIGHANDLER_ARGS)  
 {  
     pid_t                   pid;  
   
     pthread_t               thread;  
   
     struct_processus        *s_etat_processus;  
   
     verrouillage_gestionnaire_signaux();  /*
   ================================================================================
     Fonction renvoyant le nom du segment de mémoire partagée en fonction
     du pid du processus.
   ================================================================================
     Entrée : Chemin absolue servant de racine, pid du processus
   --------------------------------------------------------------------------------
     Sortie : NULL ou nom du segment
   --------------------------------------------------------------------------------
     Effet de bord : Néant
   ================================================================================
   */
   
 #   ifdef _BROKEN_SIGINFO  static unsigned char *
     pid = origine_signal(signal);  nom_segment(unsigned char *chemin, pid_t pid)
 #   else  {
     pid = (*siginfo).si_pid;      unsigned char               *fichier;
 #   endif  
   
 #   ifndef _BROKEN_SIGINFO  #   ifdef IPCS_SYSV // !POSIX
     if (siginfo == NULL)  #       ifndef OS2 // !OS2
     {  
         /*  
          * Le signal SIGFSTP provient de la mort du processus de contrôle.  
          * Sous certains systèmes (Linux...), la mort du terminal de contrôle  
          * se traduit par l'envoi d'un SIGHUP au processus. Sur d'autres  
          * (SunOS), le processus reçoit un SIGFSTP avec une structure siginfo  
          * non initialisée (pointeur NULL) issue de TERMIO.  
          */  
   
         if (recherche_thread_principal(getpid(), &thread) == d_vrai)              if ((fichier = sys_malloc((strlen(chemin) + 1 + 256 + 1) *
         {                      sizeof(unsigned char))) == NULL)
             pthread_kill(thread, SIGHUP);              {
             deverrouillage_gestionnaire_signaux();                  return(NULL);
             return;              }
         }  
     }  
     else  
 #   endif  
     if (pid == getpid())  
     {  
         if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))  
                 == NULL)  
         {  
             deverrouillage_gestionnaire_signaux();  
             return;  
         }  
   
         /*              sprintf(fichier, "%s/RPL-SIGQUEUES-%d", chemin, (int) pid);
          *  0 => fonctionnement normal  #       else // OS2
          * -1 => requête              if ((fichier = sys_malloc((10 + 256 + 1) * sizeof(unsigned char)))
          *  1 => requête acceptée en attente de traitement                      == NULL)
          */              {
                   return(NULL);
               }
   
         if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)              sprintf(fichier, "\\SHAREMEM\\RPL-SIGQUEUES-%d", (int) pid);
         {  #       endif // OS2
             printf("[%d] SIGTSTP (thread %llu)\n", (int) getpid(),  #   else // POSIX
                     (unsigned long long) pthread_self());  
             fflush(stdout);  
         }  
   
         if ((*s_etat_processus).var_volatile_processus_pere == 0)          if ((fichier = sys_malloc((1 + 256 + 1) *
                   sizeof(unsigned char))) == NULL)
         {          {
             kill((*s_etat_processus).pid_processus_pere, signal);              return(NULL);
         }  
         else  
         {  
             (*s_etat_processus).var_volatile_requete_arret2 = -1;  
         }          }
     }  
     else  
     {  
         // Envoi d'un signal au thread maître du groupe.  
   
         if (recherche_thread_principal(getpid(), &thread) == d_vrai)          sprintf(fichier, "/RPL-SIGQUEUES-%d", (int) pid);
         {  #   endif
             pthread_kill(thread, SIGTSTP);  
             deverrouillage_gestionnaire_signaux();  
             return;  
         }  
     }  
   
     deverrouillage_gestionnaire_signaux();      return(fichier);
     return;  
 }  }
   
 void  
 interruption3(SIGHANDLER_ARGS)  
 {  
     pid_t                   pid;  
   
     struct_processus        *s_etat_processus;  
   
     static int              compteur = 0;  /*
   ================================================================================
     Fonctions d'envoi d'un signal à un thread ou à un processus.
   ================================================================================
     Entrée : processus et signal
   --------------------------------------------------------------------------------
     Sortie : erreur
   --------------------------------------------------------------------------------
     Effet de bord : Néant
   ================================================================================
   */
   
     verrouillage_gestionnaire_signaux();  int
   envoi_signal_processus(pid_t pid, enum signaux_rpl signal)
   {
   #   ifndef OS2
           int                         segment;
   #   endif
   
 #   ifdef _BROKEN_SIGINFO  #   ifndef IPCS_SYSV
     pid = origine_signal(signal);          sem_t                       *semaphore;
           sem_t                       *signalisation;
 #   else  #   else
     pid = (*siginfo).si_pid;          sem_t                       *semaphore;
           sem_t                       *signalisation;
   #       ifndef OS2
               int                     desc;
               key_t                   clef;
   #       endif
 #   endif  #   endif
   
     if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)      struct_queue_signaux            *queue;
     {  
         deverrouillage_gestionnaire_signaux();  
         return;  
     }  
   
     if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)      unsigned char                   *nom;
     {  
         printf("[%d] SIGSEGV (thread %llu)\n", (int) getpid(),  
                 (unsigned long long) pthread_self());  
         fflush(stdout);  
     }  
   
     if ((*s_etat_processus).var_volatile_recursivite == -1)      // Il s'agit d'ouvrir le segment de mémoire partagée, de le projeter en
     {      // mémoire puis d'y inscrire le signal à traiter.
         // Segfault dans un appel de fonction récursive  
         deverrouillage_gestionnaire_signaux();      if (pid == getpid())
         longjmp(contexte, -1);  
     }  
     else  
     {      {
         // Segfault dans une routine interne          // Le signal est envoyé au même processus.
         if (strncmp(getenv("LANG"), "fr", 2) == 0)  
           if (s_queue_signaux == NULL)
         {          {
             printf("+++Système : Violation d'accès (dépassement de pile)\n");              return(1);
         }          }
         else  
           while(sem_wait(semaphore_queue_signaux) != 0)
         {          {
             printf("+++System : Access violation (stack overflow)\n");              if (errno != EINTR)
               {
                   return(1);
               }
         }          }
   
         fflush(stdout);          (*s_queue_signaux).queue[(*s_queue_signaux).pointeur_ecriture]
                   .pid = pid;
           (*s_queue_signaux).queue[(*s_queue_signaux).pointeur_ecriture]
                   .signal = signal;
   
         compteur++;          (*s_queue_signaux).pointeur_ecriture =
                   ((*s_queue_signaux).pointeur_ecriture + 1)
                   % LONGUEUR_QUEUE_SIGNAUX;
   
         if (compteur > 1)  #       ifndef IPCS_SYSV
           if (msync(s_queue_signaux, sizeof(s_queue_signaux),
                   MS_ASYNC | MS_INVALIDATE) != 0)
         {          {
             deverrouillage_gestionnaire_signaux();              return(1);
             exit(EXIT_FAILURE);  
         }          }
         else  #       endif
   
           if (sem_post(semaphore_queue_signaux) != 0)
         {          {
             deverrouillage_gestionnaire_signaux();              return(1);
             longjmp(contexte_initial, -1);  
         }          }
     }  
   
     deverrouillage_gestionnaire_signaux();          if (sem_post(semaphore_signalisation) != 0)
     return;          {
 }              return(1);
           }
       }
       else
       {
           // Le signal est envoyé depuis un processus distinct.
   
 void  #       ifdef IPCS_SYSV
 interruption4(SIGHANDLER_ARGS)              if ((nom = nom_segment(racine_segment, pid)) == NULL)
 {              {
     pid_t                   pid;                  return(1);
               }
   
     struct_processus        *s_etat_processus;  #           ifndef OS2 // SysV
                   if ((desc = open(nom, O_RDWR)) == -1)
                   {
                       sys_free(nom);
                       return(1);
                   }
   
     verrouillage_gestionnaire_signaux();                  close(desc);
   
 #   ifdef _BROKEN_SIGINFO                  if ((clef = ftok(nom, 1)) == -1)
     pid = origine_signal(signal);                  {
 #   else                      sys_free(nom);
     pid = (*siginfo).si_pid;                      return(1);
 #   endif                  }
   
     if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)                  sys_free(nom);
     {  
         deverrouillage_gestionnaire_signaux();  
         return;  
     }  
   
     /*                  if ((segment = shmget(clef, sizeof(struct_queue_signaux), 0))
      * Démarrage d'un processus fils ou gestion de SIGCONT (SUSPEND)                          == -1)
      */                  {
                       return(1);
                   }
   
     if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)                  queue = shmat(segment, NULL, 0);
     {  #           else // OS/2
         printf("[%d] SIGSTART/SIGCONT (thread %llu)\n", (int) getpid(),                  if (DosGetNamedSharedMem((PVOID) &queue, nom,
                 (unsigned long long) pthread_self());                          PAG_WRITE | PAG_READ) != 0)
         fflush(stdout);                  {
     }                      sys_free(nom);
                       return(1);
                   }
   
     deverrouillage_gestionnaire_signaux();                  sys_free(nom);
     return;  #           endif
 }  #       else // POSIX
               if ((nom = nom_segment(racine_segment, pid)) == NULL)
               {
                   return(1);
               }
   
 void              if ((segment = shm_open(nom, O_RDWR, 0)) == -1)
 interruption5(SIGHANDLER_ARGS)              {
 {                  sys_free(nom);
     pid_t                   pid;                  return(1);
               }
   
     pthread_t               thread;              sys_free(nom);
   
     struct_processus        *s_etat_processus;              if ((queue = mmap(NULL, sizeof(struct_queue_signaux),
                       PROT_READ | PROT_WRITE, MAP_SHARED, segment, 0)) ==
                       MAP_FAILED)
               {
                   close(segment);
                   return(1);
               }
   #       endif
   
     verrouillage_gestionnaire_signaux();          // À ce moment, le segment de mémoire partagée est projeté
           // dans l'espace du processus.
   
 #   ifdef _BROKEN_SIGINFO          if ((semaphore = sem_open2(pid, SEM_QUEUE)) == SEM_FAILED)
     pid = origine_signal(signal);          {
 #   else              return(1);
     pid = (*siginfo).si_pid;          }
 #   endif  
   
     if (pid == getpid())          if ((signalisation = sem_open2(pid, SEM_SIGNALISATION))
     {                  == SEM_FAILED)
         if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))  
                 == NULL)  
         {          {
             deverrouillage_gestionnaire_signaux();              return(1);
             return;  
         }          }
   
         if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)          while(sem_wait(semaphore) != 0)
         {          {
             printf("[%d] SIGFSTOP (thread %llu)\n", (int) getpid(),              if (errno != EINTR)
                     (unsigned long long) pthread_self());              {
             fflush(stdout);                  sem_close(semaphore);
                   sem_close(signalisation);
                   return(1);
               }
         }          }
   
         /*          (*queue).queue[(*queue).pointeur_ecriture].pid = getpid();
          * var_globale_traitement_retarde_stop :          (*queue).queue[(*queue).pointeur_ecriture].signal = signal;
          *  0 -> traitement immédiat  
          *  1 -> traitement retardé (aucun signal reçu)  
          * -1 -> traitement retardé (un ou plusieurs signaux stop reçus)  
          */  
   
         if ((*s_etat_processus).var_volatile_traitement_retarde_stop == 0)          (*queue).pointeur_ecriture = ((*queue).pointeur_ecriture + 1)
                   % LONGUEUR_QUEUE_SIGNAUX;
   
   #       ifndef IPCS_SYSV
           if (msync(queue, sizeof(queue), MS_ASYNC | MS_INVALIDATE) != 0)
         {          {
             (*s_etat_processus).var_volatile_requete_arret = -1;              sem_close(semaphore);
               sem_close(signalisation);
               return(1);
         }          }
         else  #       endif
   
           if (sem_post(semaphore) != 0)
         {          {
             (*s_etat_processus).var_volatile_traitement_retarde_stop = -1;              sem_close(semaphore);
               sem_close(signalisation);
               return(1);
         }          }
     }  
     else          if (sem_close(semaphore) != 0)
     {  
         if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))  
                 == NULL)  
         {          {
             deverrouillage_gestionnaire_signaux();              return(1);
             return;  
         }          }
   
         // Envoi d'un signal au thread maître du groupe.          if (sem_post(signalisation) != 0)
           {
               sem_close(signalisation);
               return(1);
           }
   
         if (recherche_thread_principal(getpid(), &thread) == d_vrai)          if (sem_close(signalisation) != 0)
         {          {
             pthread_kill(thread, signal);              return(1);
             deverrouillage_gestionnaire_signaux();  
             return;  
         }          }
   
   #       ifndef IPCS_SYSV // POSIX
               if (munmap(queue, sizeof(struct_queue_signaux)) != 0)
               {
                   close(segment);
                   return(1);
               }
   #       else // IPCS_SYSV
   #           ifndef OS2 // SysV
                   if (shmdt(queue) != 0)
                   {
                       return(1);
                   }
   #           else // OS/2
                   // Pendant de DosGetNamedSHaredMem()
   #           endif
   #       endif
     }      }
   
     deverrouillage_gestionnaire_signaux();      return(0);
     return;  
 }  }
   
 void  int
 interruption6(SIGHANDLER_ARGS)  envoi_signal_thread(pthread_t tid, enum signaux_rpl signal)
 {  {
     pid_t                   pid;      // Un signal est envoyé d'un thread à un autre thread du même processus.
   
     struct_processus        *s_etat_processus;  
   
     verrouillage_gestionnaire_signaux();      volatile struct_liste_chainee_volatile  *l_element_courant;
   
 #   ifdef _BROKEN_SIGINFO      struct_processus                        *s_etat_processus;
     pid = origine_signal(signal);  
 #   else  
     pid = (*siginfo).si_pid;  
 #   endif  
   
     if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)      if (pthread_mutex_lock(&mutex_liste_threads) != 0)
     {      {
         deverrouillage_gestionnaire_signaux();          return(1);
         return;  
     }      }
   
     if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)      l_element_courant = liste_threads;
   
       while(l_element_courant != NULL)
     {      {
         printf("[%d] SIGINJECT/SIGQUIT (thread %llu)\n", (int) getpid(),          if (((*((struct_thread *) (*l_element_courant).donnee)).pid
                 (unsigned long long) pthread_self());                  == getpid()) && (pthread_equal((*((struct_thread *)
         fflush(stdout);                  (*l_element_courant).donnee)).tid, tid) != 0))
           {
               break;
           }
   
           l_element_courant = (*l_element_courant).suivant;
     }      }
   
     deverrouillage_gestionnaire_signaux();      if (l_element_courant == NULL)
     return;      {
 }          pthread_mutex_unlock(&mutex_liste_threads);
           return(1);
       }
   
 void      s_etat_processus = (*((struct_thread *) (*l_element_courant).donnee))
 interruption7(SIGHANDLER_ARGS)              .s_etat_processus;
 {  
     pid_t                   pid;  
   
     struct_processus        *s_etat_processus;      if (pthread_mutex_lock(&((*s_etat_processus).mutex_signaux)) != 0)
       {
           pthread_mutex_unlock(&mutex_liste_threads);
           return(1);
       }
   
     verrouillage_gestionnaire_signaux();      (*s_etat_processus).signaux_en_queue
               [(*s_etat_processus).pointeur_signal_ecriture] = signal;
       (*s_etat_processus).pointeur_signal_ecriture =
               ((*s_etat_processus).pointeur_signal_ecriture + 1)
               % LONGUEUR_QUEUE_SIGNAUX;
   
 #   ifdef _BROKEN_SIGINFO      if (pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux)) != 0)
     pid = origine_signal(signal);      {
 #   else          pthread_mutex_unlock(&mutex_liste_threads);
     pid = (*siginfo).si_pid;          return(1);
 #   endif      }
   
     if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)      if (pthread_mutex_unlock(&mutex_liste_threads) != 0)
     {      {
         deverrouillage_gestionnaire_signaux();          return(1);
         return;  
     }      }
   
     if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)      if (sem_post(semaphore_signalisation) != 0)
     {      {
         printf("[%d] SIGPIPE (thread %llu)\n", (int) getpid(),          return(1);
                 (unsigned long long) pthread_self());  
         fflush(stdout);  
     }      }
   
     (*s_etat_processus).var_volatile_requete_arret = -1;      return(0);
     deverrouillage_gestionnaire_signaux();  }
   
     BUG(1, printf("[%d] SIGPIPE\n", (int) getpid()));  int
     return;  envoi_signal_contexte(struct_processus *s_etat_processus_a_signaler,
           enum signaux_rpl signal)
   {
       pthread_mutex_lock(&((*s_etat_processus_a_signaler).mutex_signaux));
       (*s_etat_processus_a_signaler).signaux_en_queue
               [(*s_etat_processus_a_signaler).pointeur_signal_ecriture] =
               signal;
       (*s_etat_processus_a_signaler).pointeur_signal_ecriture =
               ((*s_etat_processus_a_signaler).pointeur_signal_ecriture + 1)
               % LONGUEUR_QUEUE_SIGNAUX;
       pthread_mutex_unlock(&((*s_etat_processus_a_signaler).mutex_signaux));
   
       if (sem_post(semaphore_signalisation) != 0)
       {
           return(1);
       }
   
       return(0);
 }  }
   
   
   /*
   ================================================================================
     Fonction créant un segment de mémoire partagée destiné à contenir
     la queue des signaux.
   ================================================================================
     Entrée : structure de description du processus
   --------------------------------------------------------------------------------
     Sortie : Néant
   --------------------------------------------------------------------------------
     Effet de bord : Néant
   ================================================================================
   */
   
 void  void
 interruption8(SIGHANDLER_ARGS)  creation_queue_signaux(struct_processus *s_etat_processus)
 {  {
     pid_t                   pid;      pthread_attr_t                  attributs;
   
     pthread_t               thread;      unsigned char                   *nom;
   
     struct_processus        *s_etat_processus;      racine_segment = (*s_etat_processus).chemin_fichiers_temporaires;
   
     verrouillage_gestionnaire_signaux();  #   ifndef IPCS_SYSV // POSIX
           if ((nom = nom_segment((*s_etat_processus).chemin_fichiers_temporaires,
                   getpid())) == NULL)
           {
               (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
               return;
           }
   
 #   ifdef _BROKEN_SIGINFO          if ((f_queue_signaux = shm_open(nom, O_RDWR | O_CREAT | O_EXCL,
     pid = origine_signal(signal);                  S_IRUSR | S_IWUSR)) == -1)
 #   else          {
     pid = (*siginfo).si_pid;              sys_free(nom);
 #   endif              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
               return;
           }
   
     if (pid == getpid())          if (ftruncate(f_queue_signaux, sizeof(struct_queue_signaux)) == -1)
     {  
         if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))  
                 == NULL)  
         {          {
             deverrouillage_gestionnaire_signaux();              sys_free(nom);
               (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return;              return;
         }          }
   
         if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)          s_queue_signaux = mmap(NULL, sizeof(struct_queue_signaux),
                   PROT_READ | PROT_WRITE, MAP_SHARED, f_queue_signaux, 0);
   
           if (((void *) s_queue_signaux) == ((void *) -1))
         {          {
             printf("[%d] SIGURG (thread %llu)\n", (int) getpid(),              if (shm_unlink(nom) == -1)
                     (unsigned long long) pthread_self());              {
             fflush(stdout);                  sys_free(nom);
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                   return;
               }
   
               sys_free(nom);
               (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
               return;
         }          }
   
         (*s_etat_processus).var_volatile_alarme = -1;          sys_free(nom);
         (*s_etat_processus).var_volatile_requete_arret = -1;  
     }  
     else  
     {  
         // Envoi d'un signal au thread maître du groupe.  
   
         if (recherche_thread_principal(getpid(), &thread) == d_vrai)          if ((semaphore_queue_signaux = sem_init2(1, getpid(), SEM_QUEUE))
                   == SEM_FAILED)
         {          {
             pthread_kill(thread, SIGURG);              (*s_etat_processus).erreur_systeme = d_es_processus;
             deverrouillage_gestionnaire_signaux();  
             return;              return;
         }          }
     }  
   
     deverrouillage_gestionnaire_signaux();          if ((semaphore_signalisation = sem_init2(0, getpid(),
     return;                  SEM_SIGNALISATION)) == SEM_FAILED)
 }          {
               (*s_etat_processus).erreur_systeme = d_es_processus;
               return;
           }
   
 void          if ((semaphore_arret_signalisation = sem_init2(1, getpid(),
 interruption9(SIGHANDLER_ARGS)                  SEM_ARRET_SIGNALISATION)) == SEM_FAILED)
 {          {
     pid_t                   pid;              (*s_etat_processus).erreur_systeme = d_es_processus;
               return;
           }
   
     struct_processus        *s_etat_processus;          (*s_queue_signaux).pointeur_lecture = 0;
           (*s_queue_signaux).pointeur_ecriture = 0;
   
     verrouillage_gestionnaire_signaux();          (*s_queue_signaux).requete_arret = d_faux;
   
 #   ifdef _BROKEN_SIGINFO          if (msync(s_queue_signaux, sizeof(struct_queue_signaux), MS_SYNC))
     pid = origine_signal(signal);          {
 #   else              (*s_etat_processus).erreur_systeme = d_es_processus;
     pid = (*siginfo).si_pid;              return;
           }
   #   else // IPCS_SYSV
   #       ifndef OS2
               int                             segment;
               int                             support;
   
               key_t                           clef;
   
               // Création d'un segment de données associé au PID du processus
               // courant
   
               if ((nom = nom_segment((*s_etat_processus)
                       .chemin_fichiers_temporaires, getpid())) == NULL)
               {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                   return;
               }
   
               if ((support = open(nom, O_RDWR | O_CREAT | O_EXCL,
                       S_IRUSR | S_IWUSR)) == -1)
               {
                   (*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
                   return;
               }
   
               if ((clef = ftok(nom, 1)) == -1)
               {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                   return;
               }
   
               close(support);
               sys_free(nom);
   
               if ((segment = shmget(clef, sizeof(struct_queue_signaux),
                       IPC_CREAT | IPC_EXCL | S_IRUSR | S_IWUSR)) == -1)
               {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                   return;
               }
   
               s_queue_signaux = shmat(segment, NULL, 0);
               f_queue_signaux = segment;
   
               if (((void *) s_queue_signaux) == ((void *) -1))
               {
                   if (shmctl(f_queue_signaux, IPC_RMID, 0) == -1)
                   {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                       return;
                   }
   
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                   return;
               }
   
               if ((semaphore_queue_signaux = sem_init2(1, getpid(), SEM_QUEUE))
                       == SEM_FAILED)
               {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
                   return;
               }
   
               if ((semaphore_signalisation = sem_init2(0, getpid(),
                       SEM_SIGNALISATION)) == SEM_FAILED)
               {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
                   return;
               }
   
               if ((semaphore_arret_signalisation = sem_init2(1, getpid(),
                       SEM_ARRET_SIGNALISATION)) == SEM_FAILED)
               {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
                   return;
               }
   
               (*s_queue_signaux).pointeur_lecture = 0;
               (*s_queue_signaux).pointeur_ecriture = 0;
               (*s_queue_signaux).requete_arret = d_faux;
   #       else // OS/2
               if ((nom = nom_segment(NULL, getpid())) == NULL)
               {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                   return;
               }
   
               if (DosAllocSharedMem((PVOID) &s_queue_signaux, nom,
                       sizeof(struct_queue_signaux),
                       PAG_WRITE | PAG_READ | PAG_COMMIT) != 0)
               {
                   sys_free(nom);
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                   return;
               }
   
               sys_free(nom);
   
               sem_init(&((*s_queue_signaux).semaphore), 1, 1);
               sem_init(&((*s_queue_signaux).signalisation), 1, 0);
               sem_init(&((*s_queue_signaux).arret_signalisation), 1, 1);
   
               (*s_queue_signaux).pointeur_lecture = 0;
               (*s_queue_signaux).pointeur_ecriture = 0;
               (*s_queue_signaux).requete_arret = d_faux;
   #       endif
 #   endif  #   endif
   
     if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)      // Lancement du thread de récupération des signaux.
   
       if (pthread_attr_init(&attributs) != 0)
     {      {
         deverrouillage_gestionnaire_signaux();          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
     }      }
   
     if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)      if (pthread_attr_setdetachstate(&attributs,
               PTHREAD_CREATE_JOINABLE) != 0)
     {      {
         printf("[%d] SIGABORT/SIGPROF (thread %llu)\n", (int) getpid(),          (*s_etat_processus).erreur_systeme = d_es_processus;
                 (unsigned long long) pthread_self());          return;
         fflush(stdout);  
     }      }
   
 #   ifdef _BROKEN_SIGINFO  #   ifdef SCHED_OTHER
     if (queue_in(getpid(), signal) != 0)      if (pthread_attr_setschedpolicy(&attributs, SCHED_OTHER) != 0)
     {      {
           (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
     }      }
   
     deverrouillage_gestionnaire_signaux();  
     interruption11(signal);  
 #   else  
     deverrouillage_gestionnaire_signaux();  
     interruption11(signal, siginfo, context);  
 #   endif  #   endif
     return;  
 }  
   
 void  
 interruption10(SIGHANDLER_ARGS)  
 {  
     file                    *fichier;  
   
     pid_t                   pid;  #   ifdef PTHREAD_EXPLICIT_SCHED
       if (pthread_attr_setinheritsched(&attributs, PTHREAD_EXPLICIT_SCHED) != 0)
     struct_processus        *s_etat_processus;      {
           (*s_etat_processus).erreur_systeme = d_es_processus;
     unsigned char           nom[8 + 64 + 1];          return;
       }
     verrouillage_gestionnaire_signaux();  
   
 #   ifdef _BROKEN_SIGINFO  
     pid = origine_signal(signal);  
 #   else  
     pid = (*siginfo).si_pid;  
 #   endif  #   endif
   
     if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)  #   ifdef PTHREAD_SCOPE_SYSTEM
       if (pthread_attr_setscope(&attributs, PTHREAD_SCOPE_SYSTEM) != 0)
     {      {
         deverrouillage_gestionnaire_signaux();          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
     }      }
   #   endif
   
     snprintf(nom, 8 + 64 + 1, "rpl-out-%lu-%lu", (unsigned long) getpid(),      if (pthread_attr_destroy(&attributs) != 0)
             (unsigned long) pthread_self());  
   
     if ((fichier = fopen(nom, "w+")) != NULL)  
     {      {
         fclose(fichier);          (*s_etat_processus).erreur_systeme = d_es_processus;
           return;
         freopen(nom, "w", stdout);  
         freopen(nom, "w", stderr);  
     }      }
   
     freopen("/dev/null", "r", stdin);      if (pthread_create(&((*s_queue_signaux).thread_signaux), &attributs,
               thread_surveillance_signaux, s_etat_processus) != 0)
     if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)  
     {      {
         printf("[%d] SIGHUP (thread %llu)\n", (int) getpid(),          (*s_etat_processus).erreur_systeme = d_es_processus;
                 (unsigned long long) pthread_self());          return;
         fflush(stdout);  
     }      }
   
     deverrouillage_gestionnaire_signaux();  
     return;      return;
 }  }
   
 void  
 interruption11(SIGHANDLER_ARGS)  
 {  
     pid_t                   pid;  
   
     pthread_t               thread;  
   
     struct_processus        *s_etat_processus;  /*
   ================================================================================
     Fonction libérant le segment de mémoire partagée destiné à contenir
     la queue des signaux.
   ================================================================================
     Entrée : structure de description du processus
   --------------------------------------------------------------------------------
     Sortie : Néant
   --------------------------------------------------------------------------------
     Effet de bord : Néant
   ================================================================================
   */
   
     verrouillage_gestionnaire_signaux();  void
   liberation_queue_signaux(struct_processus *s_etat_processus)
   {
       sem_wait(semaphore_arret_signalisation);
       (*s_queue_signaux).requete_arret = d_vrai;
   
 #   ifdef _BROKEN_SIGINFO  #   ifndef IPCS_SYSV
     pid = origine_signal(signal);      msync(s_queue_signaux, sizeof(s_queue_signaux), MS_ASYNC | MS_INVALIDATE);
 #   else  
     pid = (*siginfo).si_pid;  
 #   endif  #   endif
   
     if (pid == getpid())      sem_post(semaphore_arret_signalisation);
     {  
         if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))  
                 == NULL)  
         {  
             deverrouillage_gestionnaire_signaux();  
             return;  
         }  
   
         (*s_etat_processus).arret_depuis_abort = -1;      // Incrémenter le sémaphore pour être sûr de le débloquer.
   
         if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)      sem_post(semaphore_signalisation);
         {      pthread_join((*s_queue_signaux).thread_signaux, NULL);
             printf("[%d] SIGFABORT (thread %llu)\n", (int) getpid(),  
                     (unsigned long long) pthread_self());  
             fflush(stdout);  
         }  
   
         /*  #   ifdef IPCS_SYSV // SystemV
          * var_globale_traitement_retarde_stop :  #       ifndef OS2
          *  0 -> traitement immédiat              if (shmdt(s_queue_signaux) == -1)
          *  1 -> traitement retardé (aucun signal reçu)              {
          * -1 -> traitement retardé (un ou plusieurs signaux stop reçus)                  (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
          */                  return;
               }
   #       else // OS/2
   #       endif
   #   else // POSIX
           sem_close(semaphore_queue_signaux);
           sem_close(semaphore_signalisation);
           sem_close(semaphore_arret_signalisation);
   
         if ((*s_etat_processus).var_volatile_traitement_retarde_stop == 0)          if (munmap(s_queue_signaux, sizeof(struct_queue_signaux)) != 0)
         {          {
             (*s_etat_processus).var_volatile_requete_arret = -1;              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
         }  
         else  
         {  
             (*s_etat_processus).var_volatile_traitement_retarde_stop = -1;  
         }  
     }  
     else  
     {  
         if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))  
                 == NULL)  
         {  
             deverrouillage_gestionnaire_signaux();  
             return;              return;
         }          }
   
         (*s_etat_processus).arret_depuis_abort = -1;          close(f_queue_signaux);
   #   endif
         // Envoi d'un signal au thread maître du groupe.  
   
         if (recherche_thread_principal(getpid(), &thread) == d_vrai)  
         {  
             pthread_kill(thread, signal);  
             deverrouillage_gestionnaire_signaux();  
             return;  
         }  
     }  
   
     deverrouillage_gestionnaire_signaux();  
     return;      return;
 }  }
   
 void  
 traitement_exceptions_gsl(const char *reason, const char *file,  
         int line, int gsl_errno)  
 {  
     struct_processus        *s_etat_processus;  
   
     verrouillage_gestionnaire_signaux();  
   
     if ((s_etat_processus = recherche_thread(getpid(), pthread_self())) == NULL)  /*
     {  ================================================================================
         deverrouillage_gestionnaire_signaux();    Fonction détruisant le segment de mémoire partagée destiné à contenir
         return;    la queue des signaux.
     }  ================================================================================
     Entrée : structure de description du processus
   --------------------------------------------------------------------------------
     Sortie : Néant
   --------------------------------------------------------------------------------
     Effet de bord : Néant
   ================================================================================
   */
   
     (*s_etat_processus).var_volatile_exception_gsl = gsl_errno;  void
     deverrouillage_gestionnaire_signaux();  destruction_queue_signaux(struct_processus *s_etat_processus)
     return;  {
 }  #   ifndef OS2
           unsigned char       *nom;
   #   endif
   
 #ifdef _BROKEN_SIGINFO      sem_wait(semaphore_arret_signalisation);
   
 #undef kill      (*s_queue_signaux).requete_arret = d_vrai;
 #undef pthread_kill  
   
 int  #   ifndef IPCS_SYSV
 kill_broken_siginfo(pid_t pid, int signal)      msync(s_queue_signaux, sizeof(s_queue_signaux), MS_ASYNC | MS_INVALIDATE);
 {  #   endif
     int                 ios;  
   
     sem_t               *semaphore;      sem_post(semaphore_arret_signalisation);
   
     unsigned char       *nom;      // Incrémenter le sémaphore pour être sûr de le débloquer.
   
     /*      sem_post(semaphore_signalisation);
      * Lorsqu'on veut interrompre le processus pid, on ouvre le segment      pthread_join((*s_queue_signaux).thread_signaux, NULL);
      * 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  #   ifdef IPCS_SYSV // SystemV
   #       ifndef OS2
               // Il faut commencer par éliminer le sémaphore.
   
     if ((nom = nom_semaphore(getpid(), nombre_queues)) == NULL)              if (semctl((*semaphore_queue_signaux).sem, 0, IPC_RMID) == -1)
     {              {
         return(-1);                  (*s_etat_processus).erreur_systeme = d_es_processus;
     }                  return;
               }
   
     while((semaphore = sem_open(nom, 0)) == SEM_FAILED);              unlink((*semaphore_queue_signaux).path);
     free(nom);              sys_free((*semaphore_queue_signaux).path);
   
     while(sem_wait(semaphore) != 0)              if (semctl((*semaphore_signalisation).sem, 0, IPC_RMID) == -1)
     {              {
         if (errno != EINTR)                  (*s_etat_processus).erreur_systeme = d_es_processus;
         {                  return;
             return(-1);              }
         }  
     }  
   
     if ((signal != 0) && (signal != SIGINT))              unlink((*semaphore_signalisation).path);
     {              sys_free((*semaphore_signalisation).path);
         if (queue_in(pid, signal) != 0)  
         {  
             sem_post(semaphore);  
             sem_close(semaphore);  
             return(-1);  
         }  
     }  
   
     ios = kill(pid, signal);              if (semctl((*semaphore_arret_signalisation).sem, 0, IPC_RMID) == -1)
               {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
                   return;
               }
   
     // Sémaphore relâché              unlink((*semaphore_arret_signalisation).path);
               sys_free((*semaphore_arret_signalisation).path);
   
     sem_post(semaphore);              if (shmdt(s_queue_signaux) == -1)
     sem_close(semaphore);              {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                   return;
               }
   
     return(ios);              if (shmctl(f_queue_signaux, IPC_RMID, 0) == -1)
 }              {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                   return;
               }
   
 int              if ((nom = nom_segment((*s_etat_processus)
 pthread_kill_broken_siginfo(pthread_t tid, int signal)                      .chemin_fichiers_temporaires, getpid())) == NULL)
 {              {
     int                 ios;                  (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                   return;
               }
   
     sem_t               *semaphore;              unlink(nom);
               sys_free(nom);
   #       else
               sem_close(&((*s_queue_signaux).semaphore));
               sem_destroy(&((*s_queue_signaux).semaphore));
   
     unsigned char       *nom;              sem_close(&((*s_queue_signaux).signalisation));
               sem_destroy(&((*s_queue_signaux).signalisation));
   
     if ((nom = nom_semaphore(getpid(), nombre_queues)) == NULL)              sem_close(&((*s_queue_signaux).arret_signalisation));
     {              sem_destroy(&((*s_queue_signaux).arret_signalisation));
         return(-1);  
     }  
   
     while((semaphore = sem_open(nom, 0)) == SEM_FAILED);              if (DosFreeMem(s_queue_signaux) != 0)
     free(nom);              {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                   return;
               }
   #       endif
   #   else // POSIX
           sem_destroy2(semaphore_queue_signaux, getpid(), SEM_QUEUE);
           sem_destroy2(semaphore_signalisation, getpid(), SEM_SIGNALISATION);
           sem_destroy2(semaphore_arret_signalisation, getpid(),
                   SEM_ARRET_SIGNALISATION);
   
     while(sem_wait(semaphore) != 0)          if (munmap(s_queue_signaux, sizeof(struct_queue_signaux)) != 0)
     {  
         if (errno != EINTR)  
         {          {
             return(-1);              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
               return;
         }          }
     }  
   
     if ((signal != 0) && (signal != SIGINT))          if ((nom = nom_segment(NULL, getpid())) == NULL)
     {  
         if (queue_in(getpid(), signal) != 0)  
         {          {
             sem_post(semaphore);              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             sem_close(semaphore);              return;
             return(-1);  
         }          }
     }  
   
     ios = pthread_kill(tid, signal);          close(f_queue_signaux);
   
     sem_post(semaphore);          if (shm_unlink(nom) != 0)
     sem_close(semaphore);          {
               sys_free(nom);
               (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
               return;
           }
   
     return(ios);          sys_free(nom);
 }  #   endif
   
 #endif      return;
   }
   
 // vim: ts=4  // vim: ts=4
Removed from v.1.35  
changed lines
  Added in v.1.157

CVSweb interface <joel.bertrand@systella.fr>