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

Diff for /rpl/src/instructions_p7.c between versions 1.37 and 1.86

version 1.37, 2011/09/20 09:51:42 version 1.86, 2022/09/07 13:40:38
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.3    RPL/2 (R) version 4.1.34
   Copyright (C) 1989-2011 Dr. BERTRAND Joël    Copyright (C) 1989-2021 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
   
Line 718  instruction_poke(struct_processus *s_eta Line 718  instruction_poke(struct_processus *s_eta
             return;              return;
         }          }
   
         if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)          if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus))
                   != 0)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_processus;              (*s_etat_processus).erreur_systeme = d_es_processus;
             return;              return;
Line 749  instruction_poke(struct_processus *s_eta Line 750  instruction_poke(struct_processus *s_eta
                     // figure !                      // figure !
   
                     action.sa_handler = SIG_IGN;                      action.sa_handler = SIG_IGN;
                     action.sa_flags = SA_ONSTACK;                      action.sa_flags = 0;
   
   #                   ifndef SEMAPHORES_NOMMES
                           if (sem_post(&((*s_etat_processus).semaphore_fork))
                                   != 0)
   #                   else
                           if (sem_post((*s_etat_processus).semaphore_fork) != 0)
   #                   endif
                       {
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
   
                       if (pthread_mutex_lock(&mutex_sigaction) != 0)
                       {
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
   
                     if (sigaction(SIGPIPE, &action, &registre) != 0)                      if (sigaction(SIGPIPE, &action, &registre) != 0)
                     {                      {
                         pthread_mutex_unlock(&((*s_etat_processus).mutex));                          pthread_mutex_unlock(&mutex_sigaction);
                           pthread_mutex_unlock(&((*s_etat_processus)
                                   .mutex_pile_processus));
   
                         (*s_etat_processus).erreur_systeme = d_es_signal;                          (*s_etat_processus).erreur_systeme = d_es_signal;
                         return;                          return;
Line 765  instruction_poke(struct_processus *s_eta Line 785  instruction_poke(struct_processus *s_eta
   
                     if (envoi_signal_processus((*(*((struct_processus_fils *)                      if (envoi_signal_processus((*(*((struct_processus_fils *)
                             (*(*l_element_courant).donnee).objet))                              (*(*l_element_courant).donnee).objet))
                             .thread).pid, rpl_siginject) != 0)                              .thread).pid, rpl_siginject, d_faux) != 0)
                     {                      {
                         // Le processus fils peut s'être terminé.                          // Le processus fils peut s'être terminé.
                         break;                          break;
Line 783  instruction_poke(struct_processus *s_eta Line 803  instruction_poke(struct_processus *s_eta
   
                         if ((*s_etat_processus).erreur_systeme != d_es)                          if ((*s_etat_processus).erreur_systeme != d_es)
                         {                          {
                             pthread_mutex_unlock(&((*s_etat_processus).mutex));                              pthread_mutex_unlock(&mutex_sigaction);
                               pthread_mutex_unlock(&((*s_etat_processus)
                                       .mutex_pile_processus));
                             return;                              return;
                         }                          }
                     }                      }
   
                     if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)  
                     {  
                         (*s_etat_processus).erreur_systeme = d_es_processus;  
                         return;  
                     }  
   
                     while((longueur_ecriture = write_atomic(s_etat_processus,                      while((longueur_ecriture = write_atomic(s_etat_processus,
                             (*(*((struct_processus_fils *)                              (*(*((struct_processus_fils *)
                             (*(*l_element_courant).donnee).objet)).thread)                              (*(*l_element_courant).donnee).objet)).thread)
                             .pipe_nombre_injections[1], "-",                              .pipe_nombre_injections[1], "-",
                             sizeof(unsigned char))) != sizeof(unsigned char))                              sizeof(unsigned char))) != sizeof(unsigned char))
                     {                      {
                         while(sem_wait(  
                                 &((*s_etat_processus).semaphore_fork)) != 0)  
                         {  
                             if (errno != EINTR)  
                             {  
                                 (*s_etat_processus).erreur_systeme =  
                                         d_es_processus;  
                                 return;  
                             }  
                         }  
   
                         if (longueur_ecriture == -1)                          if (longueur_ecriture == -1)
                         {                          {
                             pthread_mutex_unlock(&((*s_etat_processus).mutex));                              pthread_mutex_unlock(&mutex_sigaction);
                               pthread_mutex_unlock(&((*s_etat_processus)
                                       .mutex_pile_processus));
   
                             liberation(s_etat_processus, s_objet_argument_1);                              liberation(s_etat_processus, s_objet_argument_1);
                             liberation(s_etat_processus, s_objet_argument_2);                              liberation(s_etat_processus, s_objet_argument_2);
Line 840  instruction_poke(struct_processus *s_eta Line 847  instruction_poke(struct_processus *s_eta
   
                             if (sigaction(SIGPIPE, &registre, NULL) != 0)                              if (sigaction(SIGPIPE, &registre, NULL) != 0)
                             {                              {
                                   pthread_mutex_unlock(&mutex_sigaction);
                                 (*s_etat_processus).erreur_systeme =                                  (*s_etat_processus).erreur_systeme =
                                         d_es_signal;                                          d_es_signal;
                                 return;                                  return;
Line 847  instruction_poke(struct_processus *s_eta Line 855  instruction_poke(struct_processus *s_eta
   
                             return;                              return;
                         }                          }
   
                         if (sem_post(  
                                 &((*s_etat_processus).semaphore_fork)) != 0)  
                         {  
                             (*s_etat_processus).erreur_systeme = d_es_processus;  
                             return;  
                         }  
                     }                      }
   
                     if (ecriture_pipe(s_etat_processus,                      if (ecriture_pipe(s_etat_processus,
Line 870  instruction_poke(struct_processus *s_eta Line 871  instruction_poke(struct_processus *s_eta
                         }                          }
                     }                      }
   
                     while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)  
                     {  
                         if (errno != EINTR)  
                         {  
                             (*s_etat_processus).erreur_systeme = d_es_processus;  
                             return;  
                         }  
                     }  
   
                     if (registre_stop == 0)                      if (registre_stop == 0)
                     {                      {
                         if ((*s_etat_processus)                          if ((*s_etat_processus)
Line 899  instruction_poke(struct_processus *s_eta Line 891  instruction_poke(struct_processus *s_eta
   
                     if (sigaction(SIGPIPE, &registre, NULL) != 0)                      if (sigaction(SIGPIPE, &registre, NULL) != 0)
                     {                      {
                         pthread_mutex_unlock(&((*s_etat_processus).mutex));                          pthread_mutex_unlock(&mutex_sigaction);
                           pthread_mutex_unlock(&((*s_etat_processus)
                                   .mutex_pile_processus));
   
                         (*s_etat_processus).erreur_systeme = d_es_signal;                          (*s_etat_processus).erreur_systeme = d_es_signal;
                         return;                          return;
                     }                      }
   
                       if (pthread_mutex_unlock(&mutex_sigaction) != 0)
                       {
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
   
   #                   ifndef SEMAPHORES_NOMMES
                           while(sem_wait(&((*s_etat_processus).semaphore_fork))
                                   != 0)
   #                   else
                           while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #                   endif
                       {
                           if (errno != EINTR)
                           {
                               (*s_etat_processus).erreur_systeme = d_es_processus;
                               return;
                           }
                       }
   
                     break;                      break;
                 }                  }
             }              }
Line 931  instruction_poke(struct_processus *s_eta Line 945  instruction_poke(struct_processus *s_eta
                     // de lecteur et on peut se prendre un SIGPIPE dans la                      // de lecteur et on peut se prendre un SIGPIPE dans la
                     // figure !                      // figure !
   
   #                   ifndef SEMAPHORES_NOMMES
                           if (sem_post(&((*s_etat_processus).semaphore_fork))
                                   != 0)
   #                   else
                           if (sem_post((*s_etat_processus).semaphore_fork) != 0)
   #                   endif
                       {
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
   
                       if (pthread_mutex_lock(&mutex_sigaction) != 0)
                       {
   #                       ifndef SEMAPHORES_NOMMES
                               while(sem_wait(&((*s_etat_processus)
                                       .semaphore_fork)) != 0)
   #                       else
                               while(sem_wait((*s_etat_processus)
                                       .semaphore_fork) != 0)
   #                       endif
                           {
                               if (errno != EINTR)
                               {
                                   (*s_etat_processus).erreur_systeme =
                                           d_es_processus;
                                   return;
                               }
                           }
   
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
   
                     action.sa_handler = SIG_IGN;                      action.sa_handler = SIG_IGN;
                     action.sa_flags = SA_ONSTACK;                      action.sa_flags = 0;
   
                     if (sigaction(SIGPIPE, &action, &registre) != 0)                      if (sigaction(SIGPIPE, &action, &registre) != 0)
                     {                      {
                         pthread_mutex_unlock(&((*s_etat_processus).mutex));  #                       ifndef SEMAPHORES_NOMMES
                               while(sem_wait(&((*s_etat_processus)
                                       .semaphore_fork)) != 0)
   #                       else
                               while(sem_wait((*s_etat_processus)
                                       .semaphore_fork) != 0)
   #                       endif
                           {
                               if (errno != EINTR)
                               {
                                   (*s_etat_processus).erreur_systeme =
                                           d_es_processus;
                                   return;
                               }
                           }
   
                           pthread_mutex_unlock(&mutex_sigaction);
                           pthread_mutex_unlock(&((*s_etat_processus)
                                   .mutex_pile_processus));
   
                         (*s_etat_processus).erreur_systeme = d_es_signal;                          (*s_etat_processus).erreur_systeme = d_es_signal;
                         return;                          return;
Line 950  instruction_poke(struct_processus *s_eta Line 1015  instruction_poke(struct_processus *s_eta
                             (*(*l_element_courant).donnee).objet)).thread)                              (*(*l_element_courant).donnee).objet)).thread)
                             .mutex)) != 0)                              .mutex)) != 0)
                     {                      {
   #                       ifndef SEMAPHORES_NOMMES
                               while(sem_wait(&((*s_etat_processus)
                                       .semaphore_fork)) != 0)
   #                       else
                               while(sem_wait((*s_etat_processus)
                                       .semaphore_fork) != 0)
   #                       endif
                           {
                               if (errno != EINTR)
                               {
                                   (*s_etat_processus).erreur_systeme =
                                           d_es_processus;
                                   return;
                               }
                           }
   
                           pthread_mutex_unlock(&mutex_sigaction);
                         (*s_etat_processus).erreur_systeme = d_es_processus;                          (*s_etat_processus).erreur_systeme = d_es_processus;
                         return;                          return;
                     }                      }
Line 958  instruction_poke(struct_processus *s_eta Line 1040  instruction_poke(struct_processus *s_eta
                             (*(*l_element_courant).donnee).objet)).thread)                              (*(*l_element_courant).donnee).objet)).thread)
                             .thread_actif == d_vrai)                              .thread_actif == d_vrai)
                     {                      {
                         if (envoi_signal_thread((*(*((struct_processus_fils *)                          if (envoi_signal_thread(NULL,
                                   (*(*((struct_processus_fils *)
                                 (*(*l_element_courant).donnee).objet)).thread)                                  (*(*l_element_courant).donnee).objet)).thread)
                                 .tid, rpl_siginject) != 0)                                  .tid, rpl_siginject) != 0)
                         {                          {
Line 969  instruction_poke(struct_processus *s_eta Line 1052  instruction_poke(struct_processus *s_eta
                                     (*(*l_element_courant).donnee).objet))                                      (*(*l_element_courant).donnee).objet))
                                     .thread).mutex)) != 0)                                      .thread).mutex)) != 0)
                             {                              {
   #                               ifndef SEMAPHORES_NOMMES
                                       while(sem_wait(&((*s_etat_processus)
                                               .semaphore_fork)) != 0)
   #                               else
                                       while(sem_wait((*s_etat_processus)
                                               .semaphore_fork) != 0)
   #                               endif
                                   {
                                       if (errno != EINTR)
                                       {
                                           (*s_etat_processus).erreur_systeme =
                                                   d_es_processus;
                                           return;
                                       }
                                   }
   
                                   pthread_mutex_unlock(&mutex_sigaction);
                                 (*s_etat_processus).erreur_systeme =                                  (*s_etat_processus).erreur_systeme =
                                         d_es_processus;                                          d_es_processus;
                                 return;                                  return;
Line 984  instruction_poke(struct_processus *s_eta Line 1084  instruction_poke(struct_processus *s_eta
                                 (*(*l_element_courant).donnee).objet))                                  (*(*l_element_courant).donnee).objet))
                                 .thread).mutex)) != 0)                                  .thread).mutex)) != 0)
                         {                          {
   #                           ifndef SEMAPHORES_NOMMES
                                   while(sem_wait(&((*s_etat_processus)
                                           .semaphore_fork)) != 0)
   #                           else
                                   while(sem_wait((*s_etat_processus)
                                           .semaphore_fork) != 0)
   #                           endif
                               {
                                   if (errno != EINTR)
                                   {
                                       (*s_etat_processus).erreur_systeme =
                                               d_es_processus;
                                       return;
                                   }
                               }
   
                               pthread_mutex_unlock(&mutex_sigaction);
                             (*s_etat_processus).erreur_systeme = d_es_processus;                              (*s_etat_processus).erreur_systeme = d_es_processus;
                             return;                              return;
                         }                          }
Line 995  instruction_poke(struct_processus *s_eta Line 1112  instruction_poke(struct_processus *s_eta
                             (*(*l_element_courant).donnee).objet)).thread)                              (*(*l_element_courant).donnee).objet)).thread)
                             .mutex)) != 0)                              .mutex)) != 0)
                     {                      {
   #                       ifndef SEMAPHORES_NOMMES
                               while(sem_wait(&((*s_etat_processus)
                                       .semaphore_fork)) != 0)
   #                       else
                               while(sem_wait((*s_etat_processus)
                                       .semaphore_fork) != 0)
   #                       endif
                           {
                               if (errno != EINTR)
                               {
                                   (*s_etat_processus).erreur_systeme =
                                           d_es_processus;
                                   return;
                               }
                           }
   
                           pthread_mutex_unlock(&mutex_sigaction);
                         (*s_etat_processus).erreur_systeme = d_es_processus;                          (*s_etat_processus).erreur_systeme = d_es_processus;
                         return;                          return;
                     }                      }
Line 1011  instruction_poke(struct_processus *s_eta Line 1145  instruction_poke(struct_processus *s_eta
   
                         if ((*s_etat_processus).erreur_systeme != d_es)                          if ((*s_etat_processus).erreur_systeme != d_es)
                         {                          {
                             pthread_mutex_unlock(&((*s_etat_processus).mutex));  #                           ifndef SEMAPHORES_NOMMES
                                   while(sem_wait(&((*s_etat_processus)
                                           .semaphore_fork)) != 0)
   #                           else
                                   while(sem_wait((*s_etat_processus)
                                           .semaphore_fork) != 0)
   #                           endif
                               {
                                   if (errno != EINTR)
                                   {
                                       (*s_etat_processus).erreur_systeme =
                                               d_es_processus;
                                       return;
                                   }
                               }
   
                               pthread_mutex_unlock(&mutex_sigaction);
                               pthread_mutex_unlock(&((*s_etat_processus)
                                       .mutex_pile_processus));
                             return;                              return;
                         }                          }
                     }                      }
   
                     if (sem_post(  
                             &((*s_etat_processus).semaphore_fork)) != 0)  
                     {  
                         (*s_etat_processus).erreur_systeme = d_es_processus;  
                         return;  
                     }  
   
                     while((longueur_ecriture = write_atomic(s_etat_processus,                      while((longueur_ecriture = write_atomic(s_etat_processus,
                             (*(*((struct_processus_fils *)                              (*(*((struct_processus_fils *)
                             (*(*l_element_courant).donnee).objet)).thread)                              (*(*l_element_courant).donnee).objet)).thread)
                             .pipe_nombre_injections[1], "-",                              .pipe_nombre_injections[1], "-",
                             sizeof(unsigned char))) != sizeof(unsigned char))                              sizeof(unsigned char))) != sizeof(unsigned char))
                     {                      {
                         while(sem_wait(  
                                 &((*s_etat_processus).semaphore_fork)) != 0)  
                         {  
                             if (errno != EINTR)  
                             {  
                                 (*s_etat_processus).erreur_systeme =  
                                         d_es_processus;  
                                 return;  
                             }  
                         }  
   
                         if (longueur_ecriture == -1)                          if (longueur_ecriture == -1)
                         {                          {
                             pthread_mutex_unlock(&((*s_etat_processus).mutex));                              pthread_mutex_unlock(&((*s_etat_processus)
                                       .mutex_pile_processus));
   
                             liberation(s_etat_processus, s_objet_argument_1);                              liberation(s_etat_processus, s_objet_argument_1);
                             liberation(s_etat_processus, s_objet_argument_2);                              liberation(s_etat_processus, s_objet_argument_2);
Line 1069  instruction_poke(struct_processus *s_eta Line 1204  instruction_poke(struct_processus *s_eta
   
                             if (sigaction(SIGPIPE, &registre, NULL) != 0)                              if (sigaction(SIGPIPE, &registre, NULL) != 0)
                             {                              {
   #                               ifndef SEMAPHORES_NOMMES
                                       while(sem_wait(&((*s_etat_processus)
                                               .semaphore_fork)) != 0)
   #                               else
                                       while(sem_wait((*s_etat_processus)
                                               .semaphore_fork) != 0)
   #                               endif
                                   {
                                       if (errno != EINTR)
                                       {
                                           (*s_etat_processus).erreur_systeme =
                                                   d_es_processus;
                                           return;
                                       }
                                   }
   
                                   pthread_mutex_unlock(&mutex_sigaction);
                                 (*s_etat_processus).erreur_systeme =                                  (*s_etat_processus).erreur_systeme =
                                         d_es_signal;                                          d_es_signal;
                                 return;                                  return;
                             }                              }
   
                             return;  #                           ifndef SEMAPHORES_NOMMES
                         }                                  while(sem_wait(&((*s_etat_processus)
                                           .semaphore_fork)) != 0)
   #                           else
                                   while(sem_wait((*s_etat_processus)
                                           .semaphore_fork) != 0)
   #                           endif
                               {
                                   if (errno != EINTR)
                                   {
                                       (*s_etat_processus).erreur_systeme =
                                               d_es_processus;
                                       return;
                                   }
                               }
   
                         if (sem_post(                              pthread_mutex_unlock(&mutex_sigaction);
                                 &((*s_etat_processus).semaphore_fork)) != 0)  
                         {  
                             (*s_etat_processus).erreur_systeme = d_es_processus;  
                             return;                              return;
                         }                          }
                     }                      }
Line 1099  instruction_poke(struct_processus *s_eta Line 1261  instruction_poke(struct_processus *s_eta
                         }                          }
                     }                      }
   
                     while(sem_wait(  
                             &((*s_etat_processus).semaphore_fork)) != 0)  
                     {  
                         if (errno != EINTR)  
                         {  
                             (*s_etat_processus).erreur_systeme = d_es_processus;  
                             return;  
                         }  
                     }  
   
                     if (registre_stop == 0)                      if (registre_stop == 0)
                     {                      {
                         if ((*s_etat_processus)                          if ((*s_etat_processus)
Line 1129  instruction_poke(struct_processus *s_eta Line 1281  instruction_poke(struct_processus *s_eta
   
                     if (sigaction(SIGPIPE, &registre, NULL) != 0)                      if (sigaction(SIGPIPE, &registre, NULL) != 0)
                     {                      {
                         pthread_mutex_unlock(&((*s_etat_processus).mutex));  #                       ifndef SEMAPHORES_NOMMES
                               while(sem_wait(&((*s_etat_processus)
                                       .semaphore_fork)) != 0)
   #                       else
                               while(sem_wait((*s_etat_processus)
                                       .semaphore_fork) != 0)
   #                       endif
                           {
                               if (errno != EINTR)
                               {
                                   (*s_etat_processus).erreur_systeme =
                                           d_es_processus;
                                   return;
                               }
                           }
   
                           pthread_mutex_unlock(&mutex_sigaction);
                           pthread_mutex_unlock(&((*s_etat_processus)
                                   .mutex_pile_processus));
   
                         (*s_etat_processus).erreur_systeme = d_es_signal;                          (*s_etat_processus).erreur_systeme = d_es_signal;
                         return;                          return;
                     }                      }
   
                       if (pthread_mutex_unlock(&mutex_sigaction) != 0)
                       {
   #                       ifndef SEMAPHORES_NOMMES
                               while(sem_wait(&((*s_etat_processus)
                                       .semaphore_fork)) != 0)
   #                       else
                               while(sem_wait((*s_etat_processus)
                                       .semaphore_fork) != 0)
   #                       endif
                           {
                               if (errno != EINTR)
                               {
                                   (*s_etat_processus).erreur_systeme =
                                           d_es_processus;
                                   return;
                               }
                           }
   
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
   
   #                   ifndef SEMAPHORES_NOMMES
                           while(sem_wait(&((*s_etat_processus).semaphore_fork))
                                   != 0)
   #                   else
                           while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #                   endif
                       {
                           if (errno != EINTR)
                           {
                               (*s_etat_processus).erreur_systeme = d_es_processus;
                               return;
                           }
                       }
   
                     break;                      break;
                 }                  }
             }              }
Line 1142  instruction_poke(struct_processus *s_eta Line 1348  instruction_poke(struct_processus *s_eta
             l_element_courant = (*l_element_courant).suivant;              l_element_courant = (*l_element_courant).suivant;
         }          }
   
         if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)          if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus))
                   != 0)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_processus;              (*s_etat_processus).erreur_systeme = d_es_processus;
             return;              return;
Line 1244  instruction_private(struct_processus *s_ Line 1451  instruction_private(struct_processus *s_
             return;              return;
         }          }
   
         if (pthread_mutex_lock(&((*(*s_etat_processus)  
                 .s_liste_variables_partagees).mutex)) != 0)  
         {  
             (*s_etat_processus).erreur_systeme = d_es_processus;  
             return;  
         }  
   
         if (recherche_variable_partagee(s_etat_processus, ((*((struct_nom *)          if (recherche_variable_partagee(s_etat_processus, ((*((struct_nom *)
                 (*s_objet).objet)).nom), (*(*s_etat_processus)                  (*s_objet).objet)).nom), (*(*s_etat_processus)
                 .pointeur_variable_courante).variable_partagee,                  .pointeur_variable_courante).variable_partagee,
                 (*(*s_etat_processus).pointeur_variable_courante).origine)                  (*(*s_etat_processus).pointeur_variable_courante).origine)
                 == d_faux)                  == NULL)
         {          {
             if (pthread_mutex_unlock(&((*(*s_etat_processus)  
                     .s_liste_variables_partagees).mutex)) != 0)  
             {  
                 (*s_etat_processus).erreur_systeme = d_es_processus;  
                 return;  
             }  
   
             liberation(s_etat_processus, s_objet);              liberation(s_etat_processus, s_objet);
   
             (*s_etat_processus).erreur_systeme = d_es;              (*s_etat_processus).erreur_systeme = d_es;
Line 1271  instruction_private(struct_processus *s_ Line 1464  instruction_private(struct_processus *s_
         }          }
   
         (*(*s_etat_processus).pointeur_variable_courante).objet =          (*(*s_etat_processus).pointeur_variable_courante).objet =
                 (*(*s_etat_processus).s_liste_variables_partagees).table                  (*(*s_etat_processus).pointeur_variable_partagee_courante)
                 [(*(*s_etat_processus).s_liste_variables_partagees)                  .objet;
                 .position_variable].objet;          (*(*s_etat_processus).pointeur_variable_partagee_courante).objet = NULL;
         (*(*s_etat_processus).s_liste_variables_partagees).table  
                 [(*(*s_etat_processus).s_liste_variables_partagees)  
                 .position_variable].objet = NULL;  
   
         if (retrait_variable_partagee(s_etat_processus,          if (retrait_variable_partagee(s_etat_processus,
                 (*((struct_nom *) (*s_objet).objet)).nom,                  (*((struct_nom *) (*s_objet).objet)).nom,
                 (*(*s_etat_processus).pointeur_variable_courante)                  (*(*s_etat_processus).pointeur_variable_courante)
                 .variable_partagee) == d_erreur)                  .variable_partagee) == d_erreur)
         {          {
             if (pthread_mutex_unlock(&((*(*s_etat_processus)  
                     .s_liste_variables_partagees).mutex)) != 0)  
             {  
                 (*s_etat_processus).erreur_systeme = d_es_processus;  
                 return;  
             }  
   
             liberation(s_etat_processus, s_objet);              liberation(s_etat_processus, s_objet);
             return;              return;
         }          }
Line 1304  instruction_private(struct_processus *s_ Line 1487  instruction_private(struct_processus *s_
             (*(*s_etat_processus).pointeur_variable_courante)              (*(*s_etat_processus).pointeur_variable_courante)
                     .variable_partagee.pointeur = NULL;                      .variable_partagee.pointeur = NULL;
         }          }
   
         if (pthread_mutex_unlock(&((*(*s_etat_processus)  
                 .s_liste_variables_partagees).mutex)) != 0)  
         {  
             (*s_etat_processus).erreur_systeme = d_es_processus;  
             return;  
         }  
     }      }
     else if ((*s_objet).type == LST)      else if ((*s_objet).type == LST)
     {      {
Line 1337  instruction_private(struct_processus *s_ Line 1513  instruction_private(struct_processus *s_
                 return;                  return;
             }              }
   
             if (pthread_mutex_lock(&((*(*s_etat_processus)  
                     .s_liste_variables_partagees).mutex)) != 0)  
             {  
                 (*s_etat_processus).erreur_systeme = d_es_processus;  
                 return;  
             }  
   
             if (recherche_variable_partagee(s_etat_processus, ((*((struct_nom *)              if (recherche_variable_partagee(s_etat_processus, ((*((struct_nom *)
                     (*s_objet).objet)).nom), (*(*s_etat_processus)                      (*s_objet).objet)).nom), (*(*s_etat_processus)
                     .pointeur_variable_courante).variable_partagee,                      .pointeur_variable_courante).variable_partagee,
                     (*(*s_etat_processus).pointeur_variable_courante).origine)                      (*(*s_etat_processus).pointeur_variable_courante).origine)
                     == d_faux)                      == NULL)
             {              {
                 if (pthread_mutex_unlock(&((*(*s_etat_processus)  
                         .s_liste_variables_partagees).mutex)) != 0)  
                 {  
                     (*s_etat_processus).erreur_systeme = d_es_processus;  
                     return;  
                 }  
   
                 liberation(s_etat_processus, s_objet);                  liberation(s_etat_processus, s_objet);
   
                 (*s_etat_processus).erreur_systeme = d_es;                  (*s_etat_processus).erreur_systeme = d_es;
Line 1366  instruction_private(struct_processus *s_ Line 1528  instruction_private(struct_processus *s_
             }              }
   
             (*(*s_etat_processus).pointeur_variable_courante).objet =              (*(*s_etat_processus).pointeur_variable_courante).objet =
                     (*(*s_etat_processus).s_liste_variables_partagees).table                      (*(*s_etat_processus).pointeur_variable_partagee_courante)
                     [(*(*s_etat_processus).s_liste_variables_partagees)                      .objet;
                     .position_variable].objet;              (*(*s_etat_processus).pointeur_variable_partagee_courante).objet
             (*(*s_etat_processus).s_liste_variables_partagees).table                      = NULL;
                     [(*(*s_etat_processus).s_liste_variables_partagees)  
                     .position_variable].objet = NULL;  
   
             if ((*(*s_etat_processus).pointeur_variable_courante).origine              if ((*(*s_etat_processus).pointeur_variable_courante).origine
                     == 'P')                      == 'P')
Line 1390  instruction_private(struct_processus *s_ Line 1550  instruction_private(struct_processus *s_
                     (*(*s_etat_processus).pointeur_variable_courante)                      (*(*s_etat_processus).pointeur_variable_courante)
                     .variable_statique) == d_erreur)                      .variable_statique) == d_erreur)
             {              {
                 if (pthread_mutex_unlock(&((*(*s_etat_processus)  
                         .s_liste_variables_partagees).mutex)) != 0)  
                 {  
                     (*s_etat_processus).erreur_systeme = d_es_processus;  
                     return;  
                 }  
   
                 liberation(s_etat_processus, s_objet);                  liberation(s_etat_processus, s_objet);
                 return;                  return;
             }              }
   
             if (pthread_mutex_unlock(&((*(*s_etat_processus)  
                     .s_liste_variables_partagees).mutex)) != 0)  
             {  
                 (*s_etat_processus).erreur_systeme = d_es_processus;  
                 return;  
             }  
   
             l_element_courant = (*l_element_courant).suivant;              l_element_courant = (*l_element_courant).suivant;
         }          }
     }      }
Removed from v.1.37  
changed lines
  Added in v.1.86

CVSweb interface <joel.bertrand@systella.fr>