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

Diff for /rpl/src/rpl.c between versions 1.82 and 1.83

version 1.82, 2011/09/10 20:45:06 version 1.83, 2011/09/14 14:34:28
Line 189  rplinit(int argc, char *argv[], unsigned Line 189  rplinit(int argc, char *argv[], unsigned
     (*s_etat_processus).erreur_systeme = d_es;      (*s_etat_processus).erreur_systeme = d_es;
     (*s_etat_processus).erreur_execution = d_ex;      (*s_etat_processus).erreur_execution = d_ex;
     (*s_etat_processus).compteur_violation_d_acces = 0;      (*s_etat_processus).compteur_violation_d_acces = 0;
       (*s_etat_processus).tid_courant = pthread_self();
   
     (*s_etat_processus).rpl_home = rpl_home;      (*s_etat_processus).rpl_home = rpl_home;
   
Line 244  rplinit(int argc, char *argv[], unsigned Line 245  rplinit(int argc, char *argv[], unsigned
             recherche_chemin_fichiers_temporaires(s_etat_processus);              recherche_chemin_fichiers_temporaires(s_etat_processus);
   
 #   ifdef IPCS_SYSV  #   ifdef IPCS_SYSV
 #   ifndef OS2  #       ifndef OS2
     chemin_semaphores_SysV = (*s_etat_processus).chemin_fichiers_temporaires;              chemin_semaphores_SysV =
 #   endif                      (*s_etat_processus).chemin_fichiers_temporaires;
 #   endif  #       endif
   
 #   ifdef _BROKEN_SIGINFO  
     creation_fifos_signaux(s_etat_processus);  
 #   ifdef return  
 #       undef return  
 #   endif  
 #   define return destruction_fifos_signaux(s_etat_processus); return  
 #   endif  #   endif
   
     insertion_thread(s_etat_processus, d_vrai);      insertion_thread(s_etat_processus, d_vrai);
       creation_queue_signaux(s_etat_processus);
   
 #   ifndef OS2  #   ifndef OS2
     localisation_courante(s_etat_processus);      localisation_courante(s_etat_processus);
Line 417  rplinit(int argc, char *argv[], unsigned Line 412  rplinit(int argc, char *argv[], unsigned
     }      }
 #   endif  #   endif
   
 #   ifndef _BROKEN_SIGINFO  
     action.sa_sigaction = interruption1;  
 #   else  
     action.sa_handler = interruption1;      action.sa_handler = interruption1;
 #   endif      action.sa_flags = SA_ONSTACK;
     action.sa_flags = SA_ONSTACK | SA_SIGINFO;  
   
     if (sigaction(SIGINT, &action, NULL) != 0)      if (sigaction(SIGINT, &action, NULL) != 0)
     {      {
Line 498  rplinit(int argc, char *argv[], unsigned Line 489  rplinit(int argc, char *argv[], unsigned
         return(EXIT_FAILURE);          return(EXIT_FAILURE);
     }      }
   
 #   ifndef _BROKEN_SIGINFO  
     action.sa_sigaction = interruption2;  
 #   else  
     action.sa_handler = interruption2;      action.sa_handler = interruption2;
 #   endif      action.sa_flags = SA_NODEFER | SA_ONSTACK;
     action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;  
   
     if (sigaction(SIGTSTP, &action, NULL) != 0)      if (sigaction(SIGTSTP, &action, NULL) != 0)
     {      {
Line 540  rplinit(int argc, char *argv[], unsigned Line 527  rplinit(int argc, char *argv[], unsigned
         return(EXIT_FAILURE);          return(EXIT_FAILURE);
     }      }
   
 #   ifndef _BROKEN_SIGINFO  
     action.sa_sigaction = interruption4;  
 #   else  
     action.sa_handler = interruption4;  
 #   endif  
     // SIGCONT ne doit pas pouvoir être appelé depuis son gestionnaire.  
     action.sa_flags = SA_ONSTACK | SA_SIGINFO;  
   
     if (sigaction(SIGSTART, &action, NULL) != 0)  
     {  
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
     signal_test = SIGTEST;  
     kill(getpid(), SIGSTART);  
   
     if (signal_test != SIGSTART)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
     if (sigaction(SIGCONT, &action, NULL) != 0)  
     {  
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
     signal_test = SIGTEST;  
     kill(getpid(), SIGCONT);  
   
     if (signal_test != SIGCONT)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
 #   ifndef _BROKEN_SIGINFO  
     action.sa_sigaction = interruption5;  
 #   else  
     action.sa_handler = interruption5;      action.sa_handler = interruption5;
 #   endif      action.sa_flags = SA_NODEFER | SA_ONSTACK;
     action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;  
   
     if (sigaction(SIGFSTOP, &action, NULL) != 0)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
     signal_test = SIGTEST;  
     kill(getpid(), SIGFSTOP);  
   
     if (signal_test != SIGFSTOP)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
 #   ifndef _BROKEN_SIGINFO  
     action.sa_sigaction = interruption11;  
 #   else  
     action.sa_handler = interruption11;  
 #   endif  
     action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;  
   
     if (sigaction(SIGFABORT, &action, NULL) != 0)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
     signal_test = SIGTEST;  
     kill(getpid(), SIGFABORT);  
   
     if (signal_test != SIGFABORT)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
 #   ifndef _BROKEN_SIGINFO  
     action.sa_sigaction = interruption8;  
 #   else  
     action.sa_handler = interruption8;  
 #   endif  
     action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;  
   
     if (sigaction(SIGURG, &action, NULL) != 0)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
     signal_test = SIGTEST;  
     kill(getpid(), SIGURG);  
   
     if (signal_test != SIGURG)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
 #   ifndef _BROKEN_SIGINFO  
     action.sa_sigaction = interruption7;  
 #   else  
     action.sa_handler = interruption7;  
 #   endif  
     action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;  
   
     if (sigaction(SIGPIPE, &action, NULL) != 0)      if (sigaction(SIGPIPE, &action, NULL) != 0)
     {      {
Line 794  rplinit(int argc, char *argv[], unsigned Line 567  rplinit(int argc, char *argv[], unsigned
         return(EXIT_FAILURE);          return(EXIT_FAILURE);
     }      }
   
 #   ifndef _BROKEN_SIGINFO  
     action.sa_sigaction = interruption6;  
 #   else  
     action.sa_handler = interruption6;  
 #   endif  
     action.sa_flags = SA_ONSTACK | SA_SIGINFO | SA_NODEFER;  
   
     if (sigaction(SIGINJECT, &action, NULL) != 0)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
     signal_test = SIGTEST;  
     kill(getpid(), SIGINJECT);  
   
     if (signal_test != SIGINJECT)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
 #   ifndef _BROKEN_SIGINFO  
     action.sa_sigaction = interruption9;  
 #   else  
     action.sa_handler = interruption9;  
 #   endif  
     action.sa_flags = SA_ONSTACK | SA_SIGINFO | SA_NODEFER;  
   
     if (sigaction(SIGABORT, &action, NULL) != 0)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
     signal_test = SIGTEST;  
     kill(getpid(), SIGABORT);  
   
     if (signal_test != SIGABORT)  
     {  
         erreur = d_es_signal;  
   
         if ((*s_etat_processus).langue == 'F')  
         {  
             printf("+++Système : Initialisation des signaux POSIX "  
                     "impossible\n");  
         }  
         else  
         {  
             printf("+++System : Initialization of POSIX signals failed\n");  
         }  
   
         return(EXIT_FAILURE);  
     }  
   
 #   ifndef _BROKEN_SIGINFO  
     action.sa_sigaction = interruption1;  
 #   else  
     action.sa_handler = interruption1;      action.sa_handler = interruption1;
 #   endif      action.sa_flags = SA_NODEFER | SA_ONSTACK;
     action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;  
   
     if (sigaction(SIGALRM, &action, NULL) != 0)      if (sigaction(SIGALRM, &action, NULL) != 0)
     {      {
Line 1815  rplinit(int argc, char *argv[], unsigned Line 1496  rplinit(int argc, char *argv[], unsigned
   
         if (debug == d_faux)          if (debug == d_faux)
         {          {
 #           ifndef _BROKEN_SIGINFO  
             action.sa_sigaction = interruption3;  
 #           else  
             action.sa_handler = interruption3;              action.sa_handler = interruption3;
 #           endif              action.sa_flags = SA_NODEFER | SA_ONSTACK;
             action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;  
   
             if (sigaction(SIGSEGV, &action, NULL) != 0)              if (sigaction(SIGSEGV, &action, NULL) != 0)
             {              {
Line 1857  rplinit(int argc, char *argv[], unsigned Line 1534  rplinit(int argc, char *argv[], unsigned
   
         if (option_n == d_vrai)          if (option_n == d_vrai)
         {          {
 #           ifndef _BROKEN_SIGINFO              action.sa_handler = interruption4;
             action.sa_sigaction = interruption10;              action.sa_flags = SA_ONSTACK;
 #           else  
             action.sa_handler = interruption10;  
 #           endif  
             action.sa_flags = SA_ONSTACK | SA_SIGINFO;  
   
             if (sigaction(SIGHUP, &action, NULL) != 0)              if (sigaction(SIGHUP, &action, NULL) != 0)
             {              {
Line 2256  rplinit(int argc, char *argv[], unsigned Line 1929  rplinit(int argc, char *argv[], unsigned
             (*s_etat_processus).var_volatile_recursivite = 0;              (*s_etat_processus).var_volatile_recursivite = 0;
             (*s_etat_processus).var_volatile_exception_gsl = 0;              (*s_etat_processus).var_volatile_exception_gsl = 0;
             (*s_etat_processus).arret_depuis_abort = 0;              (*s_etat_processus).arret_depuis_abort = 0;
             (*s_etat_processus).signal_a_traiter = d_faux;              (*s_etat_processus).pointeur_signal_lecture = 0;
               (*s_etat_processus).pointeur_signal_ecriture = 0;
   
             initialisation_allocateur(s_etat_processus);              initialisation_allocateur(s_etat_processus);
             initialisation_drapeaux(s_etat_processus);              initialisation_drapeaux(s_etat_processus);
Line 3005  rplinit(int argc, char *argv[], unsigned Line 2679  rplinit(int argc, char *argv[], unsigned
                             lancement_daemon(s_etat_processus);                              lancement_daemon(s_etat_processus);
                         }                          }
   
   // A FIXER
   // création signaux
                         if (option_p == d_faux)                          if (option_p == d_faux)
                         {                          {
                             if (setjmp(contexte_initial) == 0)                              if (setjmp(contexte_initial) == 0)
Line 3047  rplinit(int argc, char *argv[], unsigned Line 2723  rplinit(int argc, char *argv[], unsigned
                                 }                                  }
                             }                              }
                         }                          }
   // A FIXER
   // destruction signaux
                     }                      }
   
                     liberation(s_etat_processus, (*s_etat_processus).at_exit);                      liberation(s_etat_processus, (*s_etat_processus).at_exit);
Line 3161  rplinit(int argc, char *argv[], unsigned Line 2839  rplinit(int argc, char *argv[], unsigned
                         {                          {
                             if ((*s_etat_processus).var_volatile_alarme != 0)                              if ((*s_etat_processus).var_volatile_alarme != 0)
                             {                              {
                                 kill((*(*((struct_processus_fils *)                                  envoi_signal_processus(
                                           (*(*((struct_processus_fils *)
                                         (*(*((struct_liste_chainee *)                                          (*(*((struct_liste_chainee *)
                                         l_element_courant)).donnee).objet))                                          l_element_courant)).donnee).objet))
                                         .thread).pid, SIGURG);                                          .thread).pid, rpl_sigurg);
                             }                              }
                             else                              else
                             {                              {
                                 if ((*s_etat_processus).arret_depuis_abort                                  if ((*s_etat_processus).arret_depuis_abort
                                         == -1)                                          == -1)
                                 {                                  {
                                     kill((*(*((struct_processus_fils *)                                      envoi_signal_processus(
                                               (*(*((struct_processus_fils *)
                                             (*(*((struct_liste_chainee *)                                              (*(*((struct_liste_chainee *)
                                             l_element_courant)).donnee).objet))                                              l_element_courant)).donnee).objet))
                                             .thread).pid, SIGFABORT);                                              .thread).pid, rpl_sigabort);
                                 }                                  }
                                 else                                  else
                                 {                                  {
                                     kill((*(*((struct_processus_fils *)                                      envoi_signal_processus(
                                               (*(*((struct_processus_fils *)
                                             (*(*((struct_liste_chainee *)                                              (*(*((struct_liste_chainee *)
                                             l_element_courant)).donnee).objet))                                              l_element_courant)).donnee).objet))
                                             .thread).pid, SIGFSTOP);                                              .thread).pid, rpl_sigstop);
                                 }                                  }
                             }                              }
                         }                          }
Line 3200  rplinit(int argc, char *argv[], unsigned Line 2881  rplinit(int argc, char *argv[], unsigned
                                 if ((*s_etat_processus).var_volatile_alarme                                  if ((*s_etat_processus).var_volatile_alarme
                                         != 0)                                          != 0)
                                 {                                  {
                                     pthread_kill((*(*((struct_processus_fils *)                                      envoi_signal_thread(
                                               (*(*((struct_processus_fils *)
                                             (*(*((struct_liste_chainee *)                                              (*(*((struct_liste_chainee *)
                                             l_element_courant)).donnee).objet))                                              l_element_courant)).donnee).objet))
                                             .thread).tid, SIGURG);                                              .thread).tid, rpl_sigurg);
                                 }                                  }
                                 else                                  else
                                 {                                  {
                                     if ((*s_etat_processus).arret_depuis_abort                                      if ((*s_etat_processus).arret_depuis_abort
                                             == -1)                                              == -1)
                                     {                                      {
                                         pthread_kill(                                          envoi_signal_thread(
                                                 (*(*((struct_processus_fils *)                                                  (*(*((struct_processus_fils *)
                                                 (*(*((struct_liste_chainee *)                                                  (*(*((struct_liste_chainee *)
                                                 l_element_courant)).donnee)                                                  l_element_courant)).donnee)
                                                 .objet)).thread).tid,                                                  .objet)).thread).tid,
                                                 SIGFABORT);                                                  rpl_sigabort);
                                     }                                      }
                                     else                                      else
                                     {                                      {
                                         pthread_kill(                                          envoi_signal_thread(
                                                 (*(*((struct_processus_fils *)                                                  (*(*((struct_processus_fils *)
                                                 (*(*((struct_liste_chainee *)                                                  (*(*((struct_liste_chainee *)
                                                 l_element_courant)).donnee)                                                  l_element_courant)).donnee)
                                                 .objet)).thread).tid,                                                  .objet)).thread).tid,
                                                 SIGFSTOP);                                                  rpl_sigstop);
                                     }                                      }
                                 }                                  }
                             }                              }
Line 3874  rplinit(int argc, char *argv[], unsigned Line 3556  rplinit(int argc, char *argv[], unsigned
             sem_gestionnaires_signaux_atomique);              sem_gestionnaires_signaux_atomique);
 #   endif  #   endif
   
 #   ifdef _BROKEN_SIGINFO      destruction_queue_signaux(s_etat_processus);
     destruction_fifos_signaux(s_etat_processus);  
 #   undef return  
 #   endif  
   
     liberation_contexte_cas(s_etat_processus);      liberation_contexte_cas(s_etat_processus);
   
     free((*s_etat_processus).chemin_fichiers_temporaires);      free((*s_etat_processus).chemin_fichiers_temporaires);
Removed from v.1.82  
changed lines
  Added in v.1.83

CVSweb interface <joel.bertrand@systella.fr>