Diff for /rpl/src/instructions_s9.c between versions 1.38 and 1.53

version 1.38, 2011/09/14 17:55:59 version 1.53, 2012/10/07 08:18:36
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.3    RPL/2 (R) version 4.1.11
   Copyright (C) 1989-2011 Dr. BERTRAND Joël    Copyright (C) 1989-2012 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
   
Line 760  instruction_save(struct_processus *s_eta Line 760  instruction_save(struct_processus *s_eta
          * Aucune variable n'est accessible (ni locale, ni globale).           * Aucune variable n'est accessible (ni locale, ni globale).
          */           */
   
           if (((*s_etat_processus).autorisation_nom_implicite == 'N') &&
                   ((*((struct_nom *) (*s_objet_1).objet)).symbole == d_faux))
           {
               liberation(s_etat_processus, s_objet_1);
               liberation(s_etat_processus, s_objet_2);
   
               (*s_etat_processus).erreur_systeme = d_es;
               (*s_etat_processus).erreur_execution =
                       d_ex_creation_variable_globale;
               return;
           }
   
         if ((s_variable.nom = malloc((strlen((*((struct_nom *)          if ((s_variable.nom = malloc((strlen((*((struct_nom *)
                 (*s_objet_1).objet)).nom) + 1) * sizeof(unsigned char)))                  (*s_objet_1).objet)).nom) + 1) * sizeof(unsigned char)))
                 == NULL)                  == NULL)
Line 854  instruction_suspend(struct_processus *s_ Line 866  instruction_suspend(struct_processus *s_
         }          }
     }      }
   
     if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 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;          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
Line 873  instruction_suspend(struct_processus *s_ Line 889  instruction_suspend(struct_processus *s_
         INCR_GRANULARITE(attente.tv_nsec);          INCR_GRANULARITE(attente.tv_nsec);
     }      }
   
     if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #   ifndef SEMAPHORES_NOMMES
           while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #   else
           while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #   endif
     {      {
         (*s_etat_processus).erreur_systeme = d_es_processus;          if (errno != EINTR)
         return;          {
               (*s_etat_processus).erreur_systeme = d_es_processus;
               return;
           }
     }      }
   
     if ((*s_etat_processus).profilage == d_vrai)      if ((*s_etat_processus).profilage == d_vrai)
Line 1235  instruction_swi(struct_processus *s_etat Line 1258  instruction_swi(struct_processus *s_etat
             attente.tv_sec = 0;              attente.tv_sec = 0;
             attente.tv_nsec = GRANULARITE_us * 1000;              attente.tv_nsec = GRANULARITE_us * 1000;
   
             if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 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;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return;                  return;
Line 1245  instruction_swi(struct_processus *s_etat Line 1272  instruction_swi(struct_processus *s_etat
                     (*s_etat_processus).pipe_nombre_objets_attente,                      (*s_etat_processus).pipe_nombre_objets_attente,
                     &pid, sizeof(pid))) != sizeof(pid))                      &pid, sizeof(pid))) != sizeof(pid))
             {              {
                 if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #               ifndef SEMAPHORES_NOMMES
                       while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #               else
                       while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #               endif
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_processus;                      if (errno != EINTR)
                     return;                      {
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
                 }                  }
   
                 if (longueur_ecriture == -1)                  if (longueur_ecriture == -1)
Line 1273  instruction_swi(struct_processus *s_etat Line 1307  instruction_swi(struct_processus *s_etat
                 nanosleep(&attente, NULL);                  nanosleep(&attente, NULL);
                 INCR_GRANULARITE(attente.tv_nsec);                  INCR_GRANULARITE(attente.tv_nsec);
   
                 if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))  #               ifndef SEMAPHORES_NOMMES
                         != 0)                      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;                      (*s_etat_processus).erreur_systeme = d_es_processus;
                     return;                      return;
                 }                  }
             }              }
   
             if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)              scrutation_interruptions(s_etat_processus);
   
   #           ifndef SEMAPHORES_NOMMES
                   while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #           else
                   while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #           endif
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  if (errno != EINTR)
                 return;                  {
                       (*s_etat_processus).erreur_systeme = d_es_processus;
                       return;
                   }
             }              }
         }          }
         else          else
         {          {
             tid = -1;              tid = (pthread_t) -1;
   
             attente.tv_sec = 0;              attente.tv_sec = 0;
             attente.tv_nsec = GRANULARITE_us * 1000;              attente.tv_nsec = GRANULARITE_us * 1000;
   
             if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 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;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return;                  return;
Line 1304  instruction_swi(struct_processus *s_etat Line 1354  instruction_swi(struct_processus *s_etat
                     (*s_etat_processus).pipe_nombre_objets_attente,                      (*s_etat_processus).pipe_nombre_objets_attente,
                     &tid, sizeof(tid))) != sizeof(tid))                      &tid, sizeof(tid))) != sizeof(tid))
             {              {
                 if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #               ifndef SEMAPHORES_NOMMES
                       while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #               else
                       while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #               endif
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_processus;                      if (errno != EINTR)
                     return;                      {
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
                 }                  }
   
                 if (longueur_ecriture == -1)                  if (longueur_ecriture == -1)
Line 1332  instruction_swi(struct_processus *s_etat Line 1389  instruction_swi(struct_processus *s_etat
                 nanosleep(&attente, NULL);                  nanosleep(&attente, NULL);
                 INCR_GRANULARITE(attente.tv_nsec);                  INCR_GRANULARITE(attente.tv_nsec);
   
                 if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))  #               ifndef SEMAPHORES_NOMMES
                         != 0)                      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;                      (*s_etat_processus).erreur_systeme = d_es_processus;
                     return;                      return;
                 }                  }
             }              }
   
             if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)              scrutation_interruptions(s_etat_processus);
   
   #           ifndef SEMAPHORES_NOMMES
                   while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #           else
                   while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #           endif
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  if (errno != EINTR)
                 return;                  {
                       (*s_etat_processus).erreur_systeme = d_es_processus;
                       return;
                   }
             }              }
         }          }
   
Line 1352  instruction_swi(struct_processus *s_etat Line 1421  instruction_swi(struct_processus *s_etat
         attente.tv_sec = 0;          attente.tv_sec = 0;
         attente.tv_nsec = GRANULARITE_us * 1000;          attente.tv_nsec = GRANULARITE_us * 1000;
   
         if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 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;              (*s_etat_processus).erreur_systeme = d_es_processus;
             return;              return;
Line 1363  instruction_swi(struct_processus *s_etat Line 1436  instruction_swi(struct_processus *s_etat
                 &interruption_reduite, sizeof(interruption_reduite)))                  &interruption_reduite, sizeof(interruption_reduite)))
                 != sizeof(interruption_reduite))                  != sizeof(interruption_reduite))
         {          {
             if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #           ifndef SEMAPHORES_NOMMES
                   while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #           else
                   while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #           endif
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  if (errno != EINTR)
                 return;                  {
                       (*s_etat_processus).erreur_systeme = d_es_processus;
                       return;
                   }
             }              }
   
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
Line 1391  instruction_swi(struct_processus *s_etat Line 1471  instruction_swi(struct_processus *s_etat
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
   
             if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 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;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return;                  return;
             }              }
   
               scrutation_interruptions(s_etat_processus);
         }          }
   
         if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #       ifndef SEMAPHORES_NOMMES
               while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #       else
               while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #       endif
         {          {
             (*s_etat_processus).erreur_systeme = d_es_processus;              if (errno != EINTR)
             return;              {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
                   return;
               }
         }          }
   
         if ((*s_etat_processus).processus_detache == d_vrai)          if ((*s_etat_processus).processus_detache == d_vrai)
Line 1411  instruction_swi(struct_processus *s_etat Line 1504  instruction_swi(struct_processus *s_etat
             attente.tv_sec = 0;              attente.tv_sec = 0;
             attente.tv_nsec = GRANULARITE_us * 1000;              attente.tv_nsec = GRANULARITE_us * 1000;
   
             if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 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;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return;                  return;
Line 1421  instruction_swi(struct_processus *s_etat Line 1518  instruction_swi(struct_processus *s_etat
                     (*s_etat_processus).pipe_nombre_interruptions_attente,                      (*s_etat_processus).pipe_nombre_interruptions_attente,
                     &pid, sizeof(pid))) != sizeof(pid))                      &pid, sizeof(pid))) != sizeof(pid))
             {              {
                 if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #               ifndef SEMAPHORES_NOMMES
                       while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #               else
                       while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #               endif
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_processus;                      if (errno != EINTR)
                     return;                      {
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
                 }                  }
   
                 if (longueur_ecriture == -1)                  if (longueur_ecriture == -1)
Line 1449  instruction_swi(struct_processus *s_etat Line 1553  instruction_swi(struct_processus *s_etat
                 nanosleep(&attente, NULL);                  nanosleep(&attente, NULL);
                 INCR_GRANULARITE(attente.tv_nsec);                  INCR_GRANULARITE(attente.tv_nsec);
   
                 if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))  #               ifndef SEMAPHORES_NOMMES
                         != 0)                      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;                      (*s_etat_processus).erreur_systeme = d_es_processus;
                     return;                      return;
                 }                  }
   
                   scrutation_interruptions(s_etat_processus);
             }              }
   
             pid = getpid();              pid = getpid();
Line 1466  instruction_swi(struct_processus *s_etat Line 1575  instruction_swi(struct_processus *s_etat
                     (*s_etat_processus).pipe_nombre_interruptions_attente,                      (*s_etat_processus).pipe_nombre_interruptions_attente,
                     &pid, sizeof(pid))) != sizeof(pid))                      &pid, sizeof(pid))) != sizeof(pid))
             {              {
                 if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #               ifndef SEMAPHORES_NOMMES
                       while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #               else
                       while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #               endif
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_processus;                      if (errno != EINTR)
                     return;                      {
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
                 }                  }
   
                 if (longueur_ecriture == -1)                  if (longueur_ecriture == -1)
Line 1494  instruction_swi(struct_processus *s_etat Line 1610  instruction_swi(struct_processus *s_etat
                 nanosleep(&attente, NULL);                  nanosleep(&attente, NULL);
                 INCR_GRANULARITE(attente.tv_nsec);                  INCR_GRANULARITE(attente.tv_nsec);
   
                 if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))  #               ifndef SEMAPHORES_NOMMES
                         != 0)                      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;                      (*s_etat_processus).erreur_systeme = d_es_processus;
                     return;                      return;
                 }                  }
             }              }
   
             if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #           ifndef SEMAPHORES_NOMMES
                   while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #           else
                   while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #           endif
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  if (errno != EINTR)
                 return;                  {
                       (*s_etat_processus).erreur_systeme = d_es_processus;
                       return;
                   }
             }              }
         }          }
         else          else
         {          {
             tid = -3;              tid = (pthread_t) -3;
   
             if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 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;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return;                  return;
Line 1522  instruction_swi(struct_processus *s_etat Line 1652  instruction_swi(struct_processus *s_etat
                     (*s_etat_processus).pipe_nombre_interruptions_attente,                      (*s_etat_processus).pipe_nombre_interruptions_attente,
                     &tid, sizeof(tid))) != sizeof(tid))                      &tid, sizeof(tid))) != sizeof(tid))
             {              {
                 if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #               ifndef SEMAPHORES_NOMMES
                       while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #               else
                       while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #               endif
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_processus;                      if (errno != EINTR)
                     return;                      {
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
                 }                  }
   
                 if (longueur_ecriture == -1)                  if (longueur_ecriture == -1)
Line 1550  instruction_swi(struct_processus *s_etat Line 1687  instruction_swi(struct_processus *s_etat
                 nanosleep(&attente, NULL);                  nanosleep(&attente, NULL);
                 INCR_GRANULARITE(attente.tv_nsec);                  INCR_GRANULARITE(attente.tv_nsec);
   
                 if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))  #               ifndef SEMAPHORES_NOMMES
                         != 0)                      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;                      (*s_etat_processus).erreur_systeme = d_es_processus;
                     return;                      return;
                 }                  }
   
                   scrutation_interruptions(s_etat_processus);
             }              }
   
             tid = pthread_self();              tid = pthread_self();
Line 1567  instruction_swi(struct_processus *s_etat Line 1709  instruction_swi(struct_processus *s_etat
                     (*s_etat_processus).pipe_nombre_interruptions_attente,                      (*s_etat_processus).pipe_nombre_interruptions_attente,
                     &tid, sizeof(tid))) != sizeof(tid))                      &tid, sizeof(tid))) != sizeof(tid))
             {              {
                 if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #               ifndef SEMAPHORES_NOMMES
                       while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #               else
                       while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #               endif
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_processus;                      if (errno != EINTR)
                     return;                      {
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
                 }                  }
   
                 if (longueur_ecriture == -1)                  if (longueur_ecriture == -1)
Line 1596  instruction_swi(struct_processus *s_etat Line 1745  instruction_swi(struct_processus *s_etat
                 nanosleep(&attente, NULL);                  nanosleep(&attente, NULL);
                 INCR_GRANULARITE(attente.tv_nsec);                  INCR_GRANULARITE(attente.tv_nsec);
   
                 if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork))  #               ifndef SEMAPHORES_NOMMES
                         != 0)                      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;                      (*s_etat_processus).erreur_systeme = d_es_processus;
                     return;                      return;
                 }                  }
   
                   scrutation_interruptions(s_etat_processus);
             }              }
   
             if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #           ifndef SEMAPHORES_NOMMES
                   while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #           else
                   while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #           endif
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  if (errno != EINTR)
                 return;                  {
                       (*s_etat_processus).erreur_systeme = d_es_processus;
                       return;
                   }
             }              }
         }          }
   
         attente.tv_sec = 0;          attente.tv_sec = 0;
         attente.tv_nsec = GRANULARITE_us * 1000;          attente.tv_nsec = GRANULARITE_us * 1000;
   
         if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 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;              (*s_etat_processus).erreur_systeme = d_es_processus;
             return;              return;
Line 1624  instruction_swi(struct_processus *s_etat Line 1789  instruction_swi(struct_processus *s_etat
                 (*s_etat_processus).pipe_acquittement,                  (*s_etat_processus).pipe_acquittement,
                 &tampon, sizeof(unsigned char)) != sizeof(unsigned char))                  &tampon, sizeof(unsigned char)) != sizeof(unsigned char))
         {          {
             if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #           ifndef SEMAPHORES_NOMMES
                   while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #           else
                   while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #           endif
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  if (errno != EINTR)
                 return;                  {
                       (*s_etat_processus).erreur_systeme = d_es_processus;
                       return;
                   }
             }              }
   
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
   
             if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 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;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return;                  return;
             }              }
   
               scrutation_interruptions(s_etat_processus);
         }          }
   
         if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)  #       ifndef SEMAPHORES_NOMMES
               while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #       else
               while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #       endif
         {          {
             (*s_etat_processus).erreur_systeme = d_es_processus;              if (errno != EINTR)
             return;              {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
                   return;
               }
         }          }
   
         if (registre == 0)          if (registre == 0)

Removed from v.1.38  
changed lines
  Added in v.1.53


CVSweb interface <joel.bertrand@systella.fr>