Diff for /rpl/src/gestion_threads.c between versions 1.73 and 1.78

version 1.73, 2013/02/27 17:11:40 version 1.78, 2013/04/01 15:29:34
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.13    RPL/2 (R) version 4.1.14
   Copyright (C) 1989-2013 Dr. BERTRAND Joël    Copyright (C) 1989-2013 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
Line 69  lancement_thread(void *argument) Line 69  lancement_thread(void *argument)
   
     unsigned int                        erreur;      unsigned int                        erreur;
   
     unsigned long                       i;      integer8                            i;
   
     attente.tv_sec = 0;      attente.tv_sec = 0;
     attente.tv_nsec = GRANULARITE_us * 1000;      attente.tv_nsec = GRANULARITE_us * 1000;
Line 89  lancement_thread(void *argument) Line 89  lancement_thread(void *argument)
 #   endif  #   endif
   
     (*s_argument_thread).tid = pthread_self();      (*s_argument_thread).tid = pthread_self();
     (*s_argument_thread).thread_actif = d_vrai;  
   
     insertion_thread(s_etat_processus, d_faux);      insertion_thread(s_etat_processus, d_faux);
       (*s_argument_thread).thread_actif = d_vrai;
   
     // Envoi d'une donnée pour signaler le démarrage du thread au thread      // Envoi d'une donnée pour signaler le démarrage du thread au thread
     // de surveillance.      // de surveillance.
Line 189  lancement_thread(void *argument) Line 188  lancement_thread(void *argument)
             }              }
             else              else
             {              {
                 if (((*s_etat_processus).var_volatile_alarme == 0)                  if (((*s_etat_processus).arret_depuis_abort == 0)
                         && ((*s_etat_processus).arret_depuis_abort == 0)  
                         && ((*s_etat_processus).at_exit != NULL))                          && ((*s_etat_processus).at_exit != NULL))
                 {                  {
                     (*s_etat_processus).var_volatile_requete_arret = 0;                      (*s_etat_processus).var_volatile_requete_arret = 0;
                     (*s_etat_processus).var_volatile_traitement_retarde_stop =                      (*s_etat_processus).var_volatile_alarme = 0;
                             -1;                      (*s_etat_processus).var_volatile_traitement_sigint = 0;
   
                       if ((*s_etat_processus).profilage == d_vrai)
                       {
                           profilage(s_etat_processus, "ATEXIT");
                       }
   
                     if (evaluation(s_etat_processus,                      if (evaluation(s_etat_processus,
                             (*s_etat_processus).at_exit, 'E') == d_erreur)                              (*s_etat_processus).at_exit, 'E') == d_erreur)
Line 207  lancement_thread(void *argument) Line 210  lancement_thread(void *argument)
                                     d_ex_erreur_evaluation;                                      d_ex_erreur_evaluation;
                         }                          }
                     }                      }
   
                       if ((*s_etat_processus).profilage == d_vrai)
                       {
                           profilage(s_etat_processus, NULL);
                       }
                 }                  }
             }              }
         }          }
Line 578  lancement_thread(void *argument) Line 586  lancement_thread(void *argument)
                 .var_volatile_traitement_retarde_stop;                  .var_volatile_traitement_retarde_stop;
         (*s_etat_processus).var_volatile_traitement_retarde_stop = 1;          (*s_etat_processus).var_volatile_traitement_retarde_stop = 1;
   
         for(i = 0; i < (unsigned long) (*(*((struct_processus_fils *)          for(i = 0; i < (*(*((struct_processus_fils *)
                 (*(*l_element_courant).donnee).objet)).thread)                  (*(*l_element_courant).donnee).objet)).thread)
                 .nombre_objets_dans_pipe; i++)                  .nombre_objets_dans_pipe; i++)
         {          {

Removed from v.1.73  
changed lines
  Added in v.1.78


CVSweb interface <joel.bertrand@systella.fr>