Diff for /rpl/src/gestion_threads.c between versions 1.2 and 1.12

version 1.2, 2010/01/27 22:22:11 version 1.12, 2010/04/28 07:05:38
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.0.10    RPL/2 (R) version 4.0.15
   Copyright (C) 1989-2010 Dr. BERTRAND Joël    Copyright (C) 1989-2010 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
Line 78  lancement_thread(void *argument) Line 78  lancement_thread(void *argument)
     (*s_argument_thread).thread_actif = d_vrai;      (*s_argument_thread).thread_actif = d_vrai;
     s_etat_processus = (*s_argument_thread).s_nouvel_etat_processus;      s_etat_processus = (*s_argument_thread).s_nouvel_etat_processus;
   
   #   ifndef SEMAPHORES_NOMMES
     if (pthread_setspecific(semaphore_fork_processus_courant,      if (pthread_setspecific(semaphore_fork_processus_courant,
             &((*s_etat_processus).semaphore_fork)) != 0)              &((*s_etat_processus).semaphore_fork)) != 0)
   #   else
       if (pthread_setspecific(semaphore_fork_processus_courant,
               (*s_etat_processus).semaphore_fork) != 0)
   #   endif
     {      {
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
   
Line 256  lancement_thread(void *argument) Line 261  lancement_thread(void *argument)
                         d_ex_erreur_evaluation;                          d_ex_erreur_evaluation;
             }              }
         }          }
           else
           {
               if ((*s_etat_processus).at_exit != NULL)
               {
                   if (evaluation(s_etat_processus, (*s_etat_processus).at_exit,
                           'E') == d_erreur)
                   {
                       if (((*s_etat_processus).erreur_execution == d_ex) &&
                               ((*s_etat_processus).erreur_systeme == d_es))
                       {
                           (*s_etat_processus).erreur_execution =
                                   d_ex_erreur_evaluation;
                       }
                   }
               }
           }
   
         if ((*s_argument_thread).destruction_objet == d_vrai)          if ((*s_argument_thread).destruction_objet == d_vrai)
         {          {
Line 402  lancement_thread(void *argument) Line 423  lancement_thread(void *argument)
                 .donnee)).pid == getpid())                  .donnee)).pid == getpid())
         {          {
             fclose((*((struct_descripteur_fichier *)              fclose((*((struct_descripteur_fichier *)
                     (*l_element_courant).donnee)).descripteur);                      (*l_element_courant).donnee)).descripteur_c);
   
               if ((*((struct_descripteur_fichier *)
                       (*l_element_courant).donnee)).type != 'C')
               {
                   sqlite3_close((*((struct_descripteur_fichier *)
                           (*l_element_courant).donnee)).descripteur_sqlite);
               }
   
             if ((*((struct_descripteur_fichier *) (*l_element_courant)              if ((*((struct_descripteur_fichier *) (*l_element_courant)
                     .donnee)).effacement == 'Y')                      .donnee)).effacement == 'Y')
Line 979  lancement_thread(void *argument) Line 1007  lancement_thread(void *argument)
     }      }
   
     liberation(s_etat_processus, (*s_argument_thread).argument);      liberation(s_etat_processus, (*s_argument_thread).argument);
       liberation(s_etat_processus, (*s_etat_processus).at_exit);
   
     for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++)      for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++)
     {      {

Removed from v.1.2  
changed lines
  Added in v.1.12


CVSweb interface <joel.bertrand@systella.fr>