Diff for /rpl/src/gestion_objets.c between versions 1.38 and 1.148

version 1.38, 2010/08/26 19:07:36 version 1.148, 2020/01/10 11:15:42
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.0.19    RPL/2 (R) version 4.1.32
   Copyright (C) 1989-2010 Dr. BERTRAND Joël    Copyright (C) 1989-2020 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
   
Line 57  decrementation_atomique(struct_objet *s_ Line 57  decrementation_atomique(struct_objet *s_
     return((*s_objet).nombre_occurrences);      return((*s_objet).nombre_occurrences);
 }  }
   
 inline void  void
 initialisation_objet(struct_objet *s_objet)  initialisation_objet(struct_objet *s_objet)
 {  {
     pthread_mutexattr_t     attributs_mutex;      pthread_mutexattr_t     attributs_mutex;
Line 106  initialisation_allocateur(struct_process Line 106  initialisation_allocateur(struct_process
     (*s_etat_processus).pointeur_int = 0;      (*s_etat_processus).pointeur_int = 0;
     (*s_etat_processus).pointeur_mat = 0;      (*s_etat_processus).pointeur_mat = 0;
     (*s_etat_processus).pointeur_nom = 0;      (*s_etat_processus).pointeur_nom = 0;
       (*s_etat_processus).pointeur_rec = 0;
     (*s_etat_processus).pointeur_rel = 0;      (*s_etat_processus).pointeur_rel = 0;
     (*s_etat_processus).pointeur_tab = 0;      (*s_etat_processus).pointeur_tab = 0;
     (*s_etat_processus).pointeur_vec = 0;      (*s_etat_processus).pointeur_vec = 0;
     (*s_etat_processus).pointeur_maillons = 0;      (*s_etat_processus).pointeur_maillons = 0;
   
       (*s_etat_processus).pointeur_variables_noeud = 0;
       (*s_etat_processus).pointeur_variables_partagees_noeud = 0;
       (*s_etat_processus).pointeur_variables_feuille = 0;
       (*s_etat_processus).pointeur_variables_variable = 0;
       (*s_etat_processus).pointeur_variables_tableau_noeuds = 0;
       (*s_etat_processus).pointeur_variables_tableau_noeuds_partages = 0;
   
     return;      return;
 }  }
   
Line 134  liberation_allocateur(struct_processus * Line 142  liberation_allocateur(struct_processus *
             free((*s_etat_processus).objets_mat[i++]));              free((*s_etat_processus).objets_mat[i++]));
     for(i = 0; i < (*s_etat_processus).pointeur_nom;      for(i = 0; i < (*s_etat_processus).pointeur_nom;
             free((*s_etat_processus).objets_nom[i++]));              free((*s_etat_processus).objets_nom[i++]));
       for(i = 0; i < (*s_etat_processus).pointeur_rec;
               free((*s_etat_processus).objets_rec[i++]));
     for(i = 0; i < (*s_etat_processus).pointeur_rel;      for(i = 0; i < (*s_etat_processus).pointeur_rel;
             free((*s_etat_processus).objets_rel[i++]));              free((*s_etat_processus).objets_rel[i++]));
     for(i = 0; i < (*s_etat_processus).pointeur_tab;      for(i = 0; i < (*s_etat_processus).pointeur_tab;
Line 143  liberation_allocateur(struct_processus * Line 153  liberation_allocateur(struct_processus *
     for(i = 0; i < (*s_etat_processus).pointeur_maillons;      for(i = 0; i < (*s_etat_processus).pointeur_maillons;
             free((*s_etat_processus).maillons[i++]));              free((*s_etat_processus).maillons[i++]));
   
       for(i = 0; i < (*s_etat_processus).pointeur_variables_noeud;
               free((*s_etat_processus).variables_noeud[i++]));
       for(i = 0; i < (*s_etat_processus).pointeur_variables_partagees_noeud;
               free((*s_etat_processus).variables_partagees_noeud[i++]));
       for(i = 0; i < (*s_etat_processus).pointeur_variables_feuille;
               free((*s_etat_processus).variables_feuille[i++]));
       for(i = 0; i < (*s_etat_processus).pointeur_variables_variable;
               free((*s_etat_processus).variables_variable[i++]));
       for(i = 0; i < (*s_etat_processus).pointeur_variables_tableau_noeuds;
               free((*s_etat_processus).variables_tableau_noeuds[i++]));
       for(i = 0; i < (*s_etat_processus)
               .pointeur_variables_tableau_noeuds_partages;
               free((*s_etat_processus).variables_tableau_noeuds_partages[i++]));
   
     {      {
         struct_liste_chainee        *l_element_courant;          struct_liste_chainee        *l_element_courant;
         struct_liste_chainee        *l_element_suivant;          struct_liste_chainee        *l_element_suivant;
Line 224  allocation_maillon(struct_processus *s_e Line 248  allocation_maillon(struct_processus *s_e
     {      {
         if ((s_maillon = malloc(sizeof(struct_liste_chainee))) == NULL)          if ((s_maillon = malloc(sizeof(struct_liste_chainee))) == NULL)
         {          {
               (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return(NULL);              return(NULL);
         }          }
     }      }
Line 234  allocation_maillon(struct_processus *s_e Line 259  allocation_maillon(struct_processus *s_e
   
 /*  /*
 ================================================================================  ================================================================================
   Routine d'allocation d'un maillon d'un objet (liste, expression...)    Routine de libération d'un maillon d'un objet (liste, expression...)
 ================================================================================  ================================================================================
   Entrées : structure sur l'état du processus et objet à afficher    Entrées : structure sur l'état du processus et objet à afficher
 --------------------------------------------------------------------------------  --------------------------------------------------------------------------------
Line 274  liberation_maillon(struct_processus *s_e Line 299  liberation_maillon(struct_processus *s_e
 ================================================================================  ================================================================================
 */  */
   
 void *  struct_objet *
 allocation(struct_processus *s_etat_processus, enum t_type type)  allocation(struct_processus *s_etat_processus, enum t_type type)
 {  {
     struct_objet            *s_objet;      struct_objet            *s_objet;
Line 297  allocation(struct_processus *s_etat_proc Line 322  allocation(struct_processus *s_etat_proc
   
         if ((s_objet = malloc(sizeof(struct_objet))) == NULL)          if ((s_objet = malloc(sizeof(struct_objet))) == NULL)
         {          {
               (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return(NULL);              return(NULL);
         }          }
   
Line 320  allocation(struct_processus *s_etat_proc Line 346  allocation(struct_processus *s_etat_proc
     }      }
   
     (*s_objet).type = type;      (*s_objet).type = type;
       (*s_objet).extension_type = 0;
       (*s_objet).descripteur_bibliotheque = NULL;
   
     switch(type)      switch(type)
     {      {
Line 332  allocation(struct_processus *s_etat_proc Line 360  allocation(struct_processus *s_etat_proc
             }              }
             else              else
             {              {
                 if (((*s_objet).objet = malloc(sizeof(unsigned long))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(integer8))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 359  allocation(struct_processus *s_etat_proc Line 389  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(logical8))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(logical8))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 385  allocation(struct_processus *s_etat_proc Line 417  allocation(struct_processus *s_etat_proc
                 if (((*s_objet).objet = malloc(sizeof(struct_complexe16)))                  if (((*s_objet).objet = malloc(sizeof(struct_complexe16)))
                         == NULL)                          == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 397  allocation(struct_processus *s_etat_proc Line 431  allocation(struct_processus *s_etat_proc
         {          {
             if (((*s_objet).objet = malloc(sizeof(struct_fichier))) == NULL)              if (((*s_objet).objet = malloc(sizeof(struct_fichier))) == NULL)
             {              {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 free(s_objet);                  free(s_objet);
                 return(NULL);                  return(NULL);
             }              }
Line 404  allocation(struct_processus *s_etat_proc Line 439  allocation(struct_processus *s_etat_proc
             break;              break;
         }          }
   
           case EXT :
           {
               // Aucune allocation
               break;
           }
   
         case FCT :          case FCT :
         {          {
             if ((*s_etat_processus).pointeur_fct > 0)              if ((*s_etat_processus).pointeur_fct > 0)
Line 416  allocation(struct_processus *s_etat_proc Line 457  allocation(struct_processus *s_etat_proc
                 if (((*s_objet).objet = malloc(sizeof(struct_fonction)))                  if (((*s_objet).objet = malloc(sizeof(struct_fonction)))
                         == NULL)                          == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 439  allocation(struct_processus *s_etat_proc Line 482  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(integer8))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(integer8))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 464  allocation(struct_processus *s_etat_proc Line 509  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 487  allocation(struct_processus *s_etat_proc Line 534  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 510  allocation(struct_processus *s_etat_proc Line 559  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 526  allocation(struct_processus *s_etat_proc Line 577  allocation(struct_processus *s_etat_proc
         {          {
             if (((*s_objet).objet = malloc(sizeof(struct_mutex))) == NULL)              if (((*s_objet).objet = malloc(sizeof(struct_mutex))) == NULL)
             {              {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 free(s_objet);                  free(s_objet);
                 return(NULL);                  return(NULL);
             }              }
   
               (*((struct_mutex *) (*s_objet).objet)).tid = pthread_self();
             break;              break;
         }          }
   
Line 544  allocation(struct_processus *s_etat_proc Line 597  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(struct_nom))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(struct_nom))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 563  allocation(struct_processus *s_etat_proc Line 618  allocation(struct_processus *s_etat_proc
             if (((*s_objet).objet = malloc(sizeof(struct_processus_fils)))              if (((*s_objet).objet = malloc(sizeof(struct_processus_fils)))
                     == NULL)                      == NULL)
             {              {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 free(s_objet);                  free(s_objet);
                 return(NULL);                  return(NULL);
             }              }
Line 570  allocation(struct_processus *s_etat_proc Line 626  allocation(struct_processus *s_etat_proc
             break;              break;
         }          }
   
           case REC :
           {
               if ((*s_etat_processus).pointeur_rec > 0)
               {
                   (*s_objet).objet = (*s_etat_processus).objets_rec
                           [--(*s_etat_processus).pointeur_rec];
               }
               else
               {
                   if (((*s_objet).objet = malloc(sizeof(struct_record)))
                           == NULL)
                   {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                       free(s_objet);
                       return(NULL);
                   }
               }
   
               break;
           }
   
         case REL :          case REL :
         {          {
             if ((*s_etat_processus).pointeur_rel > 0)              if ((*s_etat_processus).pointeur_rel > 0)
Line 581  allocation(struct_processus *s_etat_proc Line 659  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(real8))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(real8))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 599  allocation(struct_processus *s_etat_proc Line 679  allocation(struct_processus *s_etat_proc
         {          {
             if (((*s_objet).objet = malloc(sizeof(struct_socket))) == NULL)              if (((*s_objet).objet = malloc(sizeof(struct_socket))) == NULL)
             {              {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 free(s_objet);                  free(s_objet);
                 return(NULL);                  return(NULL);
             }              }
Line 611  allocation(struct_processus *s_etat_proc Line 692  allocation(struct_processus *s_etat_proc
             if (((*s_objet).objet = malloc(sizeof(struct_bibliotheque)))              if (((*s_objet).objet = malloc(sizeof(struct_bibliotheque)))
                     == NULL)                      == NULL)
             {              {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 free(s_objet);                  free(s_objet);
                 return(NULL);                  return(NULL);
             }              }
Line 622  allocation(struct_processus *s_etat_proc Line 704  allocation(struct_processus *s_etat_proc
         {          {
             if (((*s_objet).objet = malloc(sizeof(struct_semaphore))) == NULL)              if (((*s_objet).objet = malloc(sizeof(struct_semaphore))) == NULL)
             {              {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 free(s_objet);                  free(s_objet);
                 return(NULL);                  return(NULL);
             }              }
Line 634  allocation(struct_processus *s_etat_proc Line 717  allocation(struct_processus *s_etat_proc
             if (((*s_objet).objet = malloc(sizeof(struct_connecteur_sql)))              if (((*s_objet).objet = malloc(sizeof(struct_connecteur_sql)))
                     == NULL)                      == NULL)
             {              {
                   (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 free(s_objet);                  free(s_objet);
                 return(NULL);                  return(NULL);
             }              }
Line 652  allocation(struct_processus *s_etat_proc Line 736  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(struct_tableau))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(struct_tableau))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 673  allocation(struct_processus *s_etat_proc Line 759  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 695  allocation(struct_processus *s_etat_proc Line 783  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 717  allocation(struct_processus *s_etat_proc Line 807  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL)
                 {                  {
                       (*s_etat_processus).erreur_systeme =
                               d_es_allocation_memoire;
                     free(s_objet);                      free(s_objet);
                     return(NULL);                      return(NULL);
                 }                  }
Line 761  liberation(struct_processus *s_etat_proc Line 853  liberation(struct_processus *s_etat_proc
     struct_liste_chainee                *l_element_courant;      struct_liste_chainee                *l_element_courant;
     struct_liste_chainee                *l_element_suivant;      struct_liste_chainee                *l_element_suivant;
   
     unsigned long                       i;      integer8                            i;
       integer8                            (*__type_drop)(struct_processus *,
                                                   void **);
   
     if (s_objet == NULL)      if (s_objet == NULL)
     {      {
Line 800  liberation(struct_processus *s_etat_proc Line 894  liberation(struct_processus *s_etat_proc
             }              }
             else              else
             {              {
                 free((unsigned long *) ((*s_objet).objet));                  free((*s_objet).objet);
             }              }
   
             break;              break;
Line 867  liberation(struct_processus *s_etat_proc Line 961  liberation(struct_processus *s_etat_proc
                 return;                  return;
             }              }
   
             free((unsigned char *) ((*s_objet).objet));              free((unsigned char *) (*s_objet).objet);
             break;              break;
         }          }
   
Line 1089  liberation(struct_processus *s_etat_proc Line 1183  liberation(struct_processus *s_etat_proc
                 return;                  return;
             }              }
   
               if (pthread_mutex_trylock(&((*((struct_mutex *)
                       (*s_objet).objet)).mutex)) == 0)
               {
                   // On a pu verrouiller le mutex. Il faut donc spécifier le tid.
                   (*((struct_mutex *) (*s_objet).objet)).tid = pthread_self();
               }
   
               if (pthread_equal(pthread_self(),
                       (*((struct_mutex *) (*s_objet).objet)).tid) != 0)
               {
                   pthread_mutex_unlock(&((*((struct_mutex *)
                           (*s_objet).objet)).mutex));
               }
               else
               {
                   (*s_etat_processus).erreur_systeme =
                           d_es_mutex_acquis_autre_thread;
                   return;
               }
   
               pthread_mutex_destroy(&((*((struct_mutex *)
                       (*s_objet).objet)).mutex));
             free((struct_mutex *) (*s_objet).objet);              free((struct_mutex *) (*s_objet).objet);
             break;              break;
         }          }
Line 1128  liberation(struct_processus *s_etat_proc Line 1244  liberation(struct_processus *s_etat_proc
         case PRC :          case PRC :
         {          {
             if (pthread_mutex_lock(&((*(*((struct_processus_fils *)              if (pthread_mutex_lock(&((*(*((struct_processus_fils *)
                     (*s_objet).objet)).thread).mutex)) != 0)                      (*s_objet).objet)).thread).mutex_nombre_references)) != 0)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return;                  return;
Line 1155  liberation(struct_processus *s_etat_proc Line 1271  liberation(struct_processus *s_etat_proc
             }              }
   
             if (pthread_mutex_unlock(&((*(*((struct_processus_fils *)              if (pthread_mutex_unlock(&((*(*((struct_processus_fils *)
                     (*s_objet).objet)).thread).mutex)) != 0)                      (*s_objet).objet)).thread).mutex_nombre_references)) != 0)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return;                  return;
Line 1165  liberation(struct_processus *s_etat_proc Line 1281  liberation(struct_processus *s_etat_proc
             {              {
                 pthread_mutex_destroy(&((*(*((struct_processus_fils *)                  pthread_mutex_destroy(&((*(*((struct_processus_fils *)
                         (*s_objet).objet)).thread).mutex));                          (*s_objet).objet)).thread).mutex));
                   pthread_mutex_destroy(&((*(*((struct_processus_fils *)
                           (*s_objet).objet)).thread).mutex_nombre_references));
                 free((*((struct_processus_fils *) (*s_objet).objet)).thread);                  free((*((struct_processus_fils *) (*s_objet).objet)).thread);
   
             }              }
   
             if (decrementation_atomique(s_objet) > 0)              if (decrementation_atomique(s_objet) > 0)
Line 1181  liberation(struct_processus *s_etat_proc Line 1298  liberation(struct_processus *s_etat_proc
             break;              break;
         }          }
   
           case REC :
           {
               liberation(s_etat_processus,
                       (*((struct_record *) (*s_objet).objet)).noms);
               liberation(s_etat_processus,
                       (*((struct_record *) (*s_objet).objet)).donnees);
   
               if (decrementation_atomique(s_objet) > 0)
               {
                   return;
               }
   
               if ((*s_etat_processus).pointeur_rec < TAILLE_CACHE)
               {
                   (*s_etat_processus).objets_rec
                           [(*s_etat_processus).pointeur_rec++] = (*s_objet).objet;
               }
               else
               {
                   free((struct_record *) ((*s_objet).objet));
               }
   
               break;
           }
   
         case REL :          case REL :
         {          {
             if (decrementation_atomique(s_objet) > 0)              if (decrementation_atomique(s_objet) > 0)
Line 1312  liberation(struct_processus *s_etat_proc Line 1454  liberation(struct_processus *s_etat_proc
                             .nombre_occurrences <= 1,                              .nombre_occurrences <= 1,
                             pthread_mutex_unlock(&((*s_objet).mutex)),                              pthread_mutex_unlock(&((*s_objet).mutex)),
                             printf("(*((*((struct_tableau *) (*s_objet).objet))"                              printf("(*((*((struct_tableau *) (*s_objet).objet))"
                             ".element[%lu])).nombre_occurrences=%ld\n", i,                              ".element[%lld])).nombre_occurrences=%ld\n", i,
                             (*((*((struct_tableau *) (*s_objet).objet))                              (*((*((struct_tableau *) (*s_objet).objet))
                             .elements[i])).nombre_occurrences));                              .elements[i])).nombre_occurrences));
                     liberation(s_etat_processus, (*((struct_tableau *)                      liberation(s_etat_processus, (*((struct_tableau *)
Line 1411  liberation(struct_processus *s_etat_proc Line 1553  liberation(struct_processus *s_etat_proc
             break;              break;
         }          }
   
           case EXT:
           {
               if (decrementation_atomique(s_objet) > 0)
               {
                   return;
               }
   
               // Appel de la fonction de liberation associée à l'objet
               // externe. Le descripteur de bibliothèque est directement
               // associé à la structure objet.
   
               l_element_courant = (*s_etat_processus).s_bibliotheques;
   
               while(l_element_courant != NULL)
               {
                   if ((*((struct_bibliotheque *) (*l_element_courant).donnee))
                           .descripteur == (*s_objet).descripteur_bibliotheque)
                   {
                       if ((__type_drop = dlsym((*s_objet)
                               .descripteur_bibliotheque, "__type_drop")) == NULL)
                       {
                           // La fonction de libération n'existe pas dans la
                           // bibliothèque.
   
                           (*s_etat_processus).erreur_execution =
                                   d_ex_type_externe_drop;
                       }
                       else
                       {
                           if (__type_drop(s_etat_processus, (void **) &s_objet)
                                   == 0)
                           {
                               (*s_etat_processus).erreur_execution =
                                       d_ex_type_externe_drop;
                           }
                       }
   
                       break;
                   }
   
                   l_element_courant = (*l_element_courant).suivant;
               }
   
               if (l_element_courant == NULL)
               {
                   (*s_etat_processus).erreur_execution = d_ex_type_externe_drop;
               }
   
               break;
           }
   
         default :          default :
         {          {
             if (pthread_mutex_unlock(&((*s_objet).mutex)) != 0)              if (pthread_mutex_unlock(&((*s_objet).mutex)) != 0)
Line 1507  copie_objet(struct_processus *s_etat_pro Line 1700  copie_objet(struct_processus *s_etat_pro
     struct_objet                *s_nouvel_objet;      struct_objet                *s_nouvel_objet;
     struct_objet                *s_objet_tampon;      struct_objet                *s_objet_tampon;
   
     unsigned long               i;      integer8                    i;
     unsigned long               j;      integer8                    j;
       integer8                    (*__type_dup)(struct_processus *, void **);
   
     if (pthread_mutex_lock(&((*s_objet).mutex)) != 0)      if (pthread_mutex_lock(&((*s_objet).mutex)) != 0)
     {      {
Line 1559  copie_objet(struct_processus *s_etat_pro Line 1753  copie_objet(struct_processus *s_etat_pro
                 return(NULL);                  return(NULL);
             }              }
   
             (*((unsigned long *) ((*s_nouvel_objet).objet))) =              (*((integer8 *) ((*s_nouvel_objet).objet))) =
                     (*((unsigned long *) ((*s_objet).objet)));                      (*((integer8 *) ((*s_objet).objet)));
             break;              break;
         }          }
   
Line 1625  copie_objet(struct_processus *s_etat_pro Line 1819  copie_objet(struct_processus *s_etat_pro
                             (*l_element_courant_lecture).suivant;                              (*l_element_courant_lecture).suivant;
                 }                  }
   
                 (*s_nouvel_objet).objet = (void *) ((struct_liste_chainee *)                  (*s_nouvel_objet).objet = ((struct_liste_chainee *)
                         l_element_base);                          l_element_base);
             }              }
             else // type == 'P'              else // type == 'P'
Line 1677  copie_objet(struct_processus *s_etat_pro Line 1871  copie_objet(struct_processus *s_etat_pro
                 return(NULL);                  return(NULL);
             }              }
   
             (*s_nouvel_objet).objet = (void *) ((unsigned char *)              (*s_nouvel_objet).objet = ((unsigned char *)
                     malloc((strlen((unsigned char *) ((*s_objet).objet)) + 1)                      malloc((strlen((unsigned char *) ((*s_objet).objet)) + 1)
                     * sizeof(unsigned char)));                      * sizeof(unsigned char)));
   
Line 1771  copie_objet(struct_processus *s_etat_pro Line 1965  copie_objet(struct_processus *s_etat_pro
                             (*l_element_courant_lecture).suivant;                              (*l_element_courant_lecture).suivant;
                 }                  }
   
                 (*s_nouvel_objet).objet = (void *) ((struct_liste_chainee *)                  (*s_nouvel_objet).objet = ((struct_liste_chainee *)
                         l_element_base);                          l_element_base);
             }              }
             else // type == 'P'              else // type == 'P'
Line 1978  copie_objet(struct_processus *s_etat_pro Line 2172  copie_objet(struct_processus *s_etat_pro
                             (*l_element_courant_lecture).suivant;                              (*l_element_courant_lecture).suivant;
                 }                  }
   
                 (*s_nouvel_objet).objet = (void *) ((struct_liste_chainee *)                  (*s_nouvel_objet).objet = ((struct_liste_chainee *)
                         l_element_base);                          l_element_base);
             }              }
             else              else
Line 2013  copie_objet(struct_processus *s_etat_pro Line 2207  copie_objet(struct_processus *s_etat_pro
             }              }
   
             (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau =              (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau =
                     (void **) ((integer8 **) malloc(                      malloc(((size_t) ((*((struct_matrice *)
                     ((*((struct_matrice *) ((*s_objet).objet))).nombre_lignes)                      ((*s_objet).objet))).nombre_lignes)) * sizeof(integer8 *));
                     * sizeof(integer8 *)));  
   
             if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau              if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau
                     == NULL)                      == NULL)
Line 2037  copie_objet(struct_processus *s_etat_pro Line 2230  copie_objet(struct_processus *s_etat_pro
             {              {
                 if ((((integer8 **) ((*((struct_matrice *)                  if ((((integer8 **) ((*((struct_matrice *)
                         ((*s_nouvel_objet).objet))).tableau))[i] =                          ((*s_nouvel_objet).objet))).tableau))[i] =
                         (void *) ((integer8 *) malloc(                          ((integer8 *) malloc(((size_t)
                         ((*((struct_matrice *) ((*s_objet).objet)))                          ((*((struct_matrice *) ((*s_objet).objet)))
                         .nombre_colonnes) * sizeof(integer8)))) == NULL)                          .nombre_colonnes)) * sizeof(integer8)))) == NULL)
                 {                  {
                     for(j = 0; j < i; j++)                      for(j = 0; j < i; j++)
                     {                      {
Line 2080  copie_objet(struct_processus *s_etat_pro Line 2273  copie_objet(struct_processus *s_etat_pro
             }              }
   
             (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau =              (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau =
                     (void **) ((struct_complexe16 **) malloc(                      malloc(((size_t) ((*((struct_matrice *)
                     ((*((struct_matrice *) ((*s_objet).objet))).nombre_lignes)                      ((*s_objet).objet))).nombre_lignes))
                     * sizeof(struct_complexe16 *)));                      * sizeof(struct_complexe16 *));
   
             if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau              if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau
                     == NULL)                      == NULL)
Line 2104  copie_objet(struct_processus *s_etat_pro Line 2297  copie_objet(struct_processus *s_etat_pro
             {              {
                 if ((((struct_complexe16 **) ((*((struct_matrice *)                  if ((((struct_complexe16 **) ((*((struct_matrice *)
                         ((*s_nouvel_objet).objet))).tableau))[i] =                          ((*s_nouvel_objet).objet))).tableau))[i] =
                         (void *) ((struct_complexe16 *) malloc(                          ((struct_complexe16 *) malloc(((size_t)
                         ((*((struct_matrice *) ((*s_objet).objet)))                          ((*((struct_matrice *) ((*s_objet).objet)))
                         .nombre_colonnes) * sizeof(struct_complexe16))))                          .nombre_colonnes)) * sizeof(struct_complexe16))))
                         == NULL)                          == NULL)
                 {                  {
                     for(j = 0; j < i; j++)                      for(j = 0; j < i; j++)
Line 2147  copie_objet(struct_processus *s_etat_pro Line 2340  copie_objet(struct_processus *s_etat_pro
             }              }
   
             (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau =               (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau = 
                     (void **) ((real8 **) malloc(                      malloc(((size_t) ((*((struct_matrice *)
                     ((*((struct_matrice *) ((*s_objet).objet))).nombre_lignes)                      ((*s_objet).objet))).nombre_lignes)) * sizeof(real8 *));
                     * sizeof(real8 *)));  
   
             if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau              if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau
                     == NULL)                      == NULL)
Line 2171  copie_objet(struct_processus *s_etat_pro Line 2363  copie_objet(struct_processus *s_etat_pro
             {              {
                 if ((((real8 **) ((*((struct_matrice *)                  if ((((real8 **) ((*((struct_matrice *)
                         ((*s_nouvel_objet).objet))).tableau))[i] =                          ((*s_nouvel_objet).objet))).tableau))[i] =
                         (void *) ((real8 *) malloc(                          ((real8 *) malloc(((size_t)
                         ((*((struct_matrice *) ((*s_objet).objet)))                          ((*((struct_matrice *) ((*s_objet).objet)))
                         .nombre_colonnes) * sizeof(real8)))) == NULL)                          .nombre_colonnes)) * sizeof(real8)))) == NULL)
                 {                  {
                     for(j = 0; j < i; j++)                      for(j = 0; j < i; j++)
                     {                      {
Line 2201  copie_objet(struct_processus *s_etat_pro Line 2393  copie_objet(struct_processus *s_etat_pro
   
         case MTX :          case MTX :
         {          {
             if (type != 'O')              // La duplication d'un mutex renvoie le même objet.
             {              incrementation_atomique(s_objet);
                 incrementation_atomique(s_objet);              return(s_objet);
                 return(s_objet);  
             }  
   
             if ((s_nouvel_objet = allocation(s_etat_processus, MTX)) == NULL)  
             {  
                 return(NULL);  
             }  
   
             (*((struct_mutex *) ((*s_nouvel_objet).objet))).mutex =  
                     (*((struct_mutex *) ((*s_objet).objet))).mutex;  
             break;  
         }          }
   
         case NOM :          case NOM :
Line 2256  copie_objet(struct_processus *s_etat_pro Line 2437  copie_objet(struct_processus *s_etat_pro
                 return(s_objet);                  return(s_objet);
             }              }
   
               // Un objet de type NON est un objet encapsulé dans une
               // structure de type struct_objet. Elle peut très bien contenir
               // une donnée, mais c'est à l'utilisateur de la libérer
               // explicitement avec un free().
   
             if ((s_nouvel_objet = allocation(s_etat_processus, NON)) == NULL)              if ((s_nouvel_objet = allocation(s_etat_processus, NON)) == NULL)
             {              {
                 return(NULL);                  return(NULL);
             }              }
   
             (*s_nouvel_objet).objet = NULL;              (*s_nouvel_objet).objet = (*s_objet).objet;
             break;              break;
         }          }
   
         case PRC :          case PRC :
         {          {
             if (pthread_mutex_lock(&((*(*((struct_processus_fils *)              if (pthread_mutex_lock(&((*(*((struct_processus_fils *)
                     (*s_objet).objet)).thread).mutex)) != 0)                      (*s_objet).objet)).thread).mutex_nombre_references)) != 0)
             {              {
                 return(NULL);                  return(NULL);
             }              }
Line 2277  copie_objet(struct_processus *s_etat_pro Line 2463  copie_objet(struct_processus *s_etat_pro
                     .nombre_references++;                      .nombre_references++;
   
             if (pthread_mutex_unlock(&((*(*((struct_processus_fils *)              if (pthread_mutex_unlock(&((*(*((struct_processus_fils *)
                     (*s_objet).objet)).thread).mutex)) != 0)                      (*s_objet).objet)).thread).mutex_nombre_references)) != 0)
             {              {
                 return(NULL);                  return(NULL);
             }              }
Line 2295  copie_objet(struct_processus *s_etat_pro Line 2481  copie_objet(struct_processus *s_etat_pro
   
             (*((struct_processus_fils *) (*s_nouvel_objet).objet)) =              (*((struct_processus_fils *) (*s_nouvel_objet).objet)) =
                     (*((struct_processus_fils *) (*s_objet).objet));                      (*((struct_processus_fils *) (*s_objet).objet));
               break;
           }
   
           case REC :
           {
               if (type != 'P')
               {
                   if ((s_nouvel_objet = allocation(s_etat_processus, REC))
                           == NULL)
                   {
                       return(NULL);
                   }
   
                   if (((*((struct_record *) (*s_nouvel_objet).objet)).noms =
                           copie_objet(s_etat_processus, (*((struct_record *)
                           (*s_objet).objet)).noms, 'P')) == NULL)
                   {
                       return(NULL);
                   }
   
                   if (((*((struct_record *) (*s_nouvel_objet).objet)).donnees =
                           copie_objet(s_etat_processus, (*((struct_record *)
                           (*s_objet).objet)).donnees, type)) == NULL)
                   {
                       return(NULL);
                   }
               }
               else
               {
                   incrementation_atomique(s_objet);
                   (*((struct_record *) (*s_objet).objet)).noms =
                           copie_objet(s_etat_processus, (*((struct_record *)
                           (*s_objet).objet)).noms, 'P');
                   (*((struct_record *) (*s_objet).objet)).donnees =
                           copie_objet(s_etat_processus, (*((struct_record *)
                           (*s_objet).objet)).donnees, 'P');
   
                   return(s_objet);
               }
   
             break;              break;
         }          }
Line 2361  copie_objet(struct_processus *s_etat_pro Line 2586  copie_objet(struct_processus *s_etat_pro
                     (*((struct_socket *) ((*s_objet).objet))).pid;                      (*((struct_socket *) ((*s_objet).objet))).pid;
             (*((struct_socket *) ((*s_nouvel_objet).objet))).tid =              (*((struct_socket *) ((*s_nouvel_objet).objet))).tid =
                     (*((struct_socket *) ((*s_objet).objet))).tid;                      (*((struct_socket *) ((*s_objet).objet))).tid;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).options =
                       (*((struct_socket *) ((*s_objet).objet))).options;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).priorite =
                       (*((struct_socket *) ((*s_objet).objet))).priorite;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).buffer_reception =
                       (*((struct_socket *) ((*s_objet).objet))).buffer_reception;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).buffer_emission =
                       (*((struct_socket *) ((*s_objet).objet))).buffer_emission;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).timeout_reception =
                       (*((struct_socket *) ((*s_objet).objet))).timeout_reception;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).timeout_emission =
                       (*((struct_socket *) ((*s_objet).objet))).timeout_emission;
   
             if (((*((struct_socket *) ((*s_nouvel_objet).objet))).format =              if (((*((struct_socket *) ((*s_nouvel_objet).objet))).format =
                     copie_objet(s_etat_processus, (*((struct_socket *)                      copie_objet(s_etat_processus, (*((struct_socket *)
Line 2470  copie_objet(struct_processus *s_etat_pro Line 2707  copie_objet(struct_processus *s_etat_pro
                 return(NULL);                  return(NULL);
             }              }
   
               (*((struct_semaphore *) (*s_nouvel_objet).objet)).semaphore =
                       (*((struct_semaphore *) (*s_objet).objet)).semaphore;
             strcpy((*((struct_semaphore *) (*s_nouvel_objet).objet)).nom,              strcpy((*((struct_semaphore *) (*s_nouvel_objet).objet)).nom,
                     (*((struct_semaphore *) (*s_objet).objet)).nom);                      (*((struct_semaphore *) (*s_objet).objet)).nom);
             break;              break;
Line 2548  copie_objet(struct_processus *s_etat_pro Line 2787  copie_objet(struct_processus *s_etat_pro
                         (*s_objet).objet)).nombre_elements;                          (*s_objet).objet)).nombre_elements;
   
                 if (((*((struct_tableau *) (*s_nouvel_objet).objet)).elements =                  if (((*((struct_tableau *) (*s_nouvel_objet).objet)).elements =
                         malloc((*((struct_tableau *) (*s_objet).objet))                          malloc(((size_t) (*((struct_tableau *)
                         .nombre_elements * sizeof(struct_objet *))) == NULL)                          (*s_objet).objet)).nombre_elements)
                           * sizeof(struct_objet *))) == NULL)
                 {                  {
                     return(NULL);                      return(NULL);
                 }                  }
Line 2609  copie_objet(struct_processus *s_etat_pro Line 2849  copie_objet(struct_processus *s_etat_pro
             }              }
   
             (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau =               (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau = 
                     (void *) ((integer8 *) malloc(                      ((integer8 *) malloc(((size_t)
                     ((*((struct_vecteur *) ((*s_objet).objet))).taille)                      ((*((struct_vecteur *) ((*s_objet).objet))).taille))
                     * sizeof(integer8)));                      * sizeof(integer8)));
   
             if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau              if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau
Line 2652  copie_objet(struct_processus *s_etat_pro Line 2892  copie_objet(struct_processus *s_etat_pro
             }              }
   
             (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau =               (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau = 
                     (void *) ((struct_complexe16 *) malloc(                      ((struct_complexe16 *) malloc(((size_t)
                     ((*((struct_vecteur *) ((*s_objet).objet))).taille)                      ((*((struct_vecteur *) ((*s_objet).objet))).taille))
                     * sizeof(struct_complexe16)));                      * sizeof(struct_complexe16)));
   
             if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau              if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau
Line 2695  copie_objet(struct_processus *s_etat_pro Line 2935  copie_objet(struct_processus *s_etat_pro
             }              }
   
             (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau =               (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau = 
                     (void *) ((real8 *) malloc(                      ((real8 *) malloc(((size_t)
                     ((*((struct_vecteur *) ((*s_objet).objet))).taille)                      ((*((struct_vecteur *) ((*s_objet).objet))).taille))
                     * sizeof(real8)));                      * sizeof(real8)));
   
             if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau              if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau
Line 2724  copie_objet(struct_processus *s_etat_pro Line 2964  copie_objet(struct_processus *s_etat_pro
             break;              break;
         }          }
   
           case EXT:
           {
               if (type != 'O')
               {
                   incrementation_atomique(s_objet);
                   return(s_objet);
               }
   
               // Appel de la fonction de duplication associée à l'objet
               // externe. Le descripteur de bibliothèque est directement
               // associé à la structure objet.
   
               l_element_courant = (*s_etat_processus).s_bibliotheques;
   
               while(l_element_courant != NULL)
               {
                   if ((*((struct_bibliotheque *) (*l_element_courant).donnee))
                           .descripteur == (*s_objet).descripteur_bibliotheque)
                   {
                       if ((__type_dup = dlsym((*s_objet).descripteur_bibliotheque,
                               "__type_dup")) == NULL)
                       {
                           // La fonction de duplication n'existe pas dans la
                           // bibliothèque.
   
                           (*s_etat_processus).erreur_execution =
                                   d_ex_type_externe_dup;
                           return(NULL);
                       }
   
                       s_nouvel_objet = s_objet;
   
                       if (__type_dup(s_etat_processus, (void **) &s_nouvel_objet)
                               == 0)
                       {
                           return(NULL);
                       }
   
                       break;
                   }
   
                   l_element_courant = (*l_element_courant).suivant;
               }
   
               if (l_element_courant == NULL)
               {
                   (*s_etat_processus).erreur_execution = d_ex_type_externe_dup;
                   return(NULL);
               }
   
               break;
           }
   
         default :          default :
         {          {
             return(NULL);              return(NULL);
Line 2759  copie_etat_processus(struct_processus *s Line 3052  copie_etat_processus(struct_processus *s
   
     struct_processus                *s_nouvel_etat_processus;      struct_processus                *s_nouvel_etat_processus;
   
     unsigned long                   i;      integer8                        i;
   
     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(NULL);          return(NULL);
     }      }
   
     if ((s_nouvel_etat_processus = malloc(sizeof(struct_processus))) == NULL)      if ((s_nouvel_etat_processus = sys_malloc(sizeof(struct_processus)))
               == NULL)
     {      {
           if (pthread_mutex_unlock(&((*s_etat_processus)
                   .mutex_pile_processus)) != 0)
           {
               (*s_etat_processus).erreur_systeme = d_es_processus;
               return(NULL);
           }
   
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
         return(NULL);          return(NULL);
     }      }
   
   
       if (pthread_mutex_lock(&((*s_etat_processus).mutex_interruptions)) != 0)
       {
           (*s_etat_processus).erreur_systeme = d_es_processus;
           return(NULL);
       }
   
       if (pthread_mutex_lock(&((*s_etat_processus).mutex_signaux)) != 0)
       {
           (*s_etat_processus).erreur_systeme = d_es_processus;
           return(NULL);
       }
   
     (*s_nouvel_etat_processus) = (*s_etat_processus);      (*s_nouvel_etat_processus) = (*s_etat_processus);
   
     // On réinitialise l'allocateur.      if (pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux)) != 0)
       {
           (*s_etat_processus).erreur_systeme = d_es_processus;
           return(NULL);
       }
   
       if (pthread_mutex_unlock(&((*s_etat_processus).mutex_interruptions)) != 0)
       {
           (*s_etat_processus).erreur_systeme = d_es_processus;
           return(NULL);
       }
   
       // On réinitialise les allocateurs.
   
       pthread_mutexattr_init(&attributs_mutex);
       pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
       pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_allocation_buffer),
               &attributs_mutex);
       pthread_mutexattr_destroy(&attributs_mutex);
   
       pthread_mutexattr_init(&attributs_mutex);
       pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
       pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_allocation),
               &attributs_mutex);
       pthread_mutexattr_destroy(&attributs_mutex);
   
     initialisation_allocateur(s_nouvel_etat_processus);      initialisation_allocateur(s_nouvel_etat_processus);
       initialisation_allocateur_buffer(s_nouvel_etat_processus);
   
     /*      /*
      * (*s_etat_processus).definition_chainee,       * (*s_etat_processus).definition_chainee,
Line 2787  copie_etat_processus(struct_processus *s Line 3126  copie_etat_processus(struct_processus *s
      * n'ont aucune raison de changer.       * n'ont aucune raison de changer.
      */       */
   
 #   ifndef SEMAPHORES_NOMMES      (*s_nouvel_etat_processus).sections_critiques = 0;
     sem_init(&((*s_nouvel_etat_processus).semaphore_fork), 0, 0);      (*s_nouvel_etat_processus).initialisation_scheduler = d_faux;
 #   else  
     if (((*s_nouvel_etat_processus).semaphore_fork = sem_init2(0, sem_fork))      // Les sémaphores sont initialisés dans le nouveau thread. Il
             == SEM_FAILED)      // s'agit d'une limitation de l'implantation de l'émulation
     {      // de sem_init().
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
         return(NULL);      initialisation_contexte_cas(s_etat_processus);
     }  
 #   endif  
   
     (*s_nouvel_etat_processus).var_volatile_processus_pere = 0;      (*s_nouvel_etat_processus).var_volatile_processus_pere = 0;
       (*s_nouvel_etat_processus).var_volatile_processus_racine = 0;
     (*s_nouvel_etat_processus).fichiers_graphiques = NULL;      (*s_nouvel_etat_processus).fichiers_graphiques = NULL;
     (*s_nouvel_etat_processus).entree_standard = NULL;      (*s_nouvel_etat_processus).entree_standard = NULL;
     (*s_nouvel_etat_processus).s_marques = NULL;      (*s_nouvel_etat_processus).s_marques = NULL;
Line 2856  copie_etat_processus(struct_processus *s Line 3194  copie_etat_processus(struct_processus *s
   
     // Copie de la localisation      // Copie de la localisation
   
     if (((*s_nouvel_etat_processus).localisation = malloc((strlen(      if (((*s_nouvel_etat_processus).localisation = rpl_malloc(
             (*s_etat_processus).localisation) + 1) * sizeof(unsigned char)))              s_nouvel_etat_processus, (strlen((*s_etat_processus).localisation)
             == NULL)              + 1) * sizeof(unsigned char))) == NULL)
     {      {
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
         return(NULL);          return(NULL);
Line 2872  copie_etat_processus(struct_processus *s Line 3210  copie_etat_processus(struct_processus *s
         if (((*s_nouvel_etat_processus).indep = copie_objet(s_etat_processus,          if (((*s_nouvel_etat_processus).indep = copie_objet(s_etat_processus,
                 (*s_etat_processus).indep, 'P')) == NULL)                  (*s_etat_processus).indep, 'P')) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 2892  copie_etat_processus(struct_processus *s Line 3231  copie_etat_processus(struct_processus *s
         if (((*s_nouvel_etat_processus).depend = copie_objet(s_etat_processus,           if (((*s_nouvel_etat_processus).depend = copie_objet(s_etat_processus, 
                 (*s_etat_processus).depend, 'P')) == NULL)                  (*s_etat_processus).depend, 'P')) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 2913  copie_etat_processus(struct_processus *s Line 3253  copie_etat_processus(struct_processus *s
                 copie_objet(s_etat_processus, (*s_etat_processus)                  copie_objet(s_etat_processus, (*s_etat_processus)
                 .parametres_courbes_de_niveau, 'P')) == NULL)                  .parametres_courbes_de_niveau, 'P')) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 2933  copie_etat_processus(struct_processus *s Line 3274  copie_etat_processus(struct_processus *s
     if (((*s_etat_processus).instruction_courante != NULL) &&      if (((*s_etat_processus).instruction_courante != NULL) &&
             (*s_etat_processus).evaluation_expression_compilee == 'N')              (*s_etat_processus).evaluation_expression_compilee == 'N')
     {      {
         if (((*s_nouvel_etat_processus).instruction_courante = malloc((strlen(          if (((*s_nouvel_etat_processus).instruction_courante = rpl_malloc(
                   s_nouvel_etat_processus, (strlen(
                 (*s_etat_processus).instruction_courante) + 1) *                  (*s_etat_processus).instruction_courante) + 1) *
                 sizeof(unsigned char))) == NULL)                  sizeof(unsigned char))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 2957  copie_etat_processus(struct_processus *s Line 3300  copie_etat_processus(struct_processus *s
   
     if ((*s_etat_processus).label_x != NULL)      if ((*s_etat_processus).label_x != NULL)
     {      {
         if (((*s_nouvel_etat_processus).label_x = malloc((strlen(          if (((*s_nouvel_etat_processus).label_x = rpl_malloc(
                   s_nouvel_etat_processus, (strlen(
                 (*s_etat_processus).label_x) + 1) *                  (*s_etat_processus).label_x) + 1) *
                 sizeof(unsigned char))) == NULL)                  sizeof(unsigned char))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 2981  copie_etat_processus(struct_processus *s Line 3326  copie_etat_processus(struct_processus *s
   
     if ((*s_etat_processus).label_y != NULL)      if ((*s_etat_processus).label_y != NULL)
     {      {
         if (((*s_nouvel_etat_processus).label_y = malloc((strlen(          if (((*s_nouvel_etat_processus).label_y = rpl_malloc(
                 (*s_etat_processus).label_y) + 1) *                  s_nouvel_etat_processus, (strlen((*s_etat_processus).label_y)
                 sizeof(unsigned char))) == NULL)                  + 1) * sizeof(unsigned char))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3005  copie_etat_processus(struct_processus *s Line 3351  copie_etat_processus(struct_processus *s
   
     if ((*s_etat_processus).label_z != NULL)      if ((*s_etat_processus).label_z != NULL)
     {      {
         if (((*s_nouvel_etat_processus).label_z = malloc((strlen(          if (((*s_nouvel_etat_processus).label_z = rpl_malloc(
                 (*s_etat_processus).label_z) + 1) *                  s_nouvel_etat_processus, (strlen((*s_etat_processus).label_z)
                 sizeof(unsigned char))) == NULL)                  + 1) * sizeof(unsigned char))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3029  copie_etat_processus(struct_processus *s Line 3376  copie_etat_processus(struct_processus *s
   
     if ((*s_etat_processus).titre != NULL)      if ((*s_etat_processus).titre != NULL)
     {      {
         if (((*s_nouvel_etat_processus).titre = malloc((strlen(          if (((*s_nouvel_etat_processus).titre = rpl_malloc(
                 (*s_etat_processus).titre) + 1) *                  s_nouvel_etat_processus, (strlen((*s_etat_processus).titre) + 1)
                 sizeof(unsigned char))) == NULL)                  * sizeof(unsigned char))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3053  copie_etat_processus(struct_processus *s Line 3401  copie_etat_processus(struct_processus *s
   
     if ((*s_etat_processus).legende != NULL)      if ((*s_etat_processus).legende != NULL)
     {      {
         if (((*s_nouvel_etat_processus).legende = malloc((strlen(          if (((*s_nouvel_etat_processus).legende = rpl_malloc(
                 (*s_etat_processus).legende) + 1) *                  s_nouvel_etat_processus, (strlen((*s_etat_processus).legende)
                 sizeof(unsigned char))) == NULL)                  + 1) * sizeof(unsigned char))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3079  copie_etat_processus(struct_processus *s Line 3428  copie_etat_processus(struct_processus *s
      * Copie de la table des variables       * Copie de la table des variables
      */       */
   
     if (((*s_nouvel_etat_processus).s_liste_variables =      (*s_nouvel_etat_processus).l_liste_variables_statiques = NULL;
             malloc((*s_etat_processus).nombre_variables_allouees *      copie_arbre_variables(s_etat_processus, s_nouvel_etat_processus);
             sizeof(struct_variable))) == NULL)  
     {  
         if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)  
         {  
             (*s_etat_processus).erreur_systeme = d_es_processus;  
             return(NULL);  
         }  
   
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
         return(NULL);  
     }  
   
     for(i = 0; i < (*s_etat_processus).nombre_variables; i++)  
     {  
         if (((*s_nouvel_etat_processus).s_liste_variables[i].nom =  
                 malloc((strlen((*s_etat_processus).s_liste_variables[i].nom)  
                 + 1) * sizeof(unsigned char))) == NULL)  
         {  
             if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)  
             {  
                 (*s_etat_processus).erreur_systeme = d_es_processus;  
                 return(NULL);  
             }  
   
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
             return(NULL);  
         }  
   
         strcpy((*s_nouvel_etat_processus).s_liste_variables[i].nom,  
                 (*s_etat_processus).s_liste_variables[i].nom);  
   
         (*s_nouvel_etat_processus).s_liste_variables[i].origine =  
                 (*s_etat_processus).s_liste_variables[i].origine;  
         (*s_nouvel_etat_processus).s_liste_variables[i].niveau =  
                 (*s_etat_processus).s_liste_variables[i].niveau;  
         (*s_nouvel_etat_processus).s_liste_variables[i].variable_statique =  
                 (*s_etat_processus).s_liste_variables[i].variable_statique;  
         (*s_nouvel_etat_processus).s_liste_variables[i].variable_partagee =  
                 (*s_etat_processus).s_liste_variables[i].variable_partagee;  
         (*s_nouvel_etat_processus).s_liste_variables[i].variable_verrouillee =  
                 (*s_etat_processus).s_liste_variables[i].variable_verrouillee;  
   
         // Les définitions sont partagées entre tous les threads.  
   
         if ((*s_etat_processus).s_liste_variables[i].niveau == 0)  
         {  
             (*s_nouvel_etat_processus).s_liste_variables[i].objet =  
                     (*s_etat_processus).s_liste_variables[i].objet;  
         }  
         else  
         {  
             if (((*s_nouvel_etat_processus).s_liste_variables[i].objet =  
                     copie_objet(s_etat_processus,  
                     (*s_etat_processus).s_liste_variables[i]  
                     .objet, 'P')) == NULL)  
             {  
                 if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)  
                 {  
                     (*s_etat_processus).erreur_systeme = d_es_processus;  
                     return(NULL);  
                 }  
   
                 (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
                 return(NULL);  
             }  
         }  
     }  
   
     /*  
      * Copie de la table des variables statiques  
      */  
   
     if (((*s_nouvel_etat_processus).s_liste_variables_statiques =      if ((*s_nouvel_etat_processus).erreur_systeme != d_es)
             malloc((*s_etat_processus).nombre_variables_statiques_allouees *  
             sizeof(struct_variable_statique))) == NULL)  
     {      {
         if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)  
         {  
             (*s_etat_processus).erreur_systeme = d_es_processus;  
             return(NULL);  
         }  
   
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
         return(NULL);          return(NULL);
     }      }
   
     for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++)      (*(*s_nouvel_etat_processus).l_liste_variables_partagees) =
     {              (*(*s_etat_processus).l_liste_variables_partagees);
         if (((*s_nouvel_etat_processus).s_liste_variables_statiques[i].nom =      (*(*s_nouvel_etat_processus).s_arbre_variables_partagees) =
                 malloc((strlen((*s_etat_processus).s_liste_variables_statiques              (*(*s_etat_processus).s_arbre_variables_partagees);
                 [i].nom) + 1) * sizeof(unsigned char))) == NULL)  
         {  
             if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)  
             {  
                 (*s_etat_processus).erreur_systeme = d_es_processus;  
                 return(NULL);  
             }  
   
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
             return(NULL);  
         }  
   
         strcpy((*s_nouvel_etat_processus).s_liste_variables_statiques[i].nom,  
                 (*s_etat_processus).s_liste_variables_statiques[i].nom);  
   
         (*s_nouvel_etat_processus).s_liste_variables_statiques[i].origine =  
                 (*s_etat_processus).s_liste_variables_statiques[i].origine;  
         (*s_nouvel_etat_processus).s_liste_variables_statiques[i].niveau =  
                 (*s_etat_processus).s_liste_variables_statiques[i].niveau;  
         (*s_nouvel_etat_processus).s_liste_variables_statiques[i]  
                 .variable_statique = (*s_etat_processus)  
                 .s_liste_variables_statiques[i].variable_statique;  
   
         if (((*s_nouvel_etat_processus).s_liste_variables_statiques[i].objet =  
                 copie_objet(s_etat_processus, (*s_etat_processus)  
                 .s_liste_variables_statiques[i].objet, 'P')) == NULL)  
         {  
             if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)  
             {  
                 (*s_etat_processus).erreur_systeme = d_es_processus;  
                 return(NULL);  
             }  
   
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;  
             return(NULL);  
         }  
     }  
   
     /*      /*
      * Copie de la pile opérationnelle       * Copie de la pile opérationnelle
Line 3219  copie_etat_processus(struct_processus *s Line 3451  copie_etat_processus(struct_processus *s
   
     while(l_element_lecture != NULL)      while(l_element_lecture != NULL)
     {      {
         if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)          if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
                   sizeof(struct_liste_chainee))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3234  copie_etat_processus(struct_processus *s Line 3468  copie_etat_processus(struct_processus *s
         if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,          if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
                 (*l_element_lecture).donnee, 'P')) == NULL)                  (*l_element_lecture).donnee, 'P')) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3270  copie_etat_processus(struct_processus *s Line 3505  copie_etat_processus(struct_processus *s
   
     if ((*s_nouvel_etat_processus).erreur_systeme != d_es)      if ((*s_nouvel_etat_processus).erreur_systeme != d_es)
     {      {
         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(NULL);              return(NULL);
Line 3292  copie_etat_processus(struct_processus *s Line 3528  copie_etat_processus(struct_processus *s
   
     if ((*s_nouvel_etat_processus).erreur_systeme != d_es)      if ((*s_nouvel_etat_processus).erreur_systeme != d_es)
     {      {
         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(NULL);              return(NULL);
Line 3316  copie_etat_processus(struct_processus *s Line 3553  copie_etat_processus(struct_processus *s
      * Copie des différents contextes       * Copie des différents contextes
      */       */
   
       (*s_nouvel_etat_processus).pointeur_signal_lecture = d_faux;
       (*s_nouvel_etat_processus).pointeur_signal_ecriture = d_faux;
   
     (*s_nouvel_etat_processus).l_base_pile_contextes = NULL;      (*s_nouvel_etat_processus).l_base_pile_contextes = NULL;
     l_element_lecture = (*s_etat_processus).l_base_pile_contextes;      l_element_lecture = (*s_etat_processus).l_base_pile_contextes;
   
     while(l_element_lecture != NULL)      while(l_element_lecture != NULL)
     {      {
         if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)          if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
                   sizeof(struct_liste_chainee))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3336  copie_etat_processus(struct_processus *s Line 3578  copie_etat_processus(struct_processus *s
         if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,          if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
                 (*l_element_lecture).donnee, 'P')) == NULL)                  (*l_element_lecture).donnee, 'P')) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3367  copie_etat_processus(struct_processus *s Line 3610  copie_etat_processus(struct_processus *s
   
     while(l_element_lecture != NULL)      while(l_element_lecture != NULL)
     {      {
         if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)          if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
                   sizeof(struct_liste_chainee))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3382  copie_etat_processus(struct_processus *s Line 3627  copie_etat_processus(struct_processus *s
         if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,          if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
                 (*l_element_lecture).donnee, 'P')) == NULL)                  (*l_element_lecture).donnee, 'P')) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3418  copie_etat_processus(struct_processus *s Line 3664  copie_etat_processus(struct_processus *s
   
     while(l_element_lecture != NULL)      while(l_element_lecture != NULL)
     {      {
         if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)          if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
                   sizeof(struct_liste_chainee))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3433  copie_etat_processus(struct_processus *s Line 3681  copie_etat_processus(struct_processus *s
         if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,          if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
                 (*l_element_lecture).donnee, 'P')) == NULL)                  (*l_element_lecture).donnee, 'P')) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3464  copie_etat_processus(struct_processus *s Line 3713  copie_etat_processus(struct_processus *s
   
     while(l_element_lecture != NULL)      while(l_element_lecture != NULL)
     {      {
         if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)          if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
                   sizeof(struct_liste_chainee))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3476  copie_etat_processus(struct_processus *s Line 3727  copie_etat_processus(struct_processus *s
             return(NULL);              return(NULL);
         }          }
   
         if (((*l_element_suivant).donnee = malloc(sizeof(struct_bibliotheque)))          if (((*l_element_suivant).donnee = rpl_malloc(s_nouvel_etat_processus,
                 == NULL)                  sizeof(struct_bibliotheque))) == NULL)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return(NULL);              return(NULL);
Line 3492  copie_etat_processus(struct_processus *s Line 3743  copie_etat_processus(struct_processus *s
                 = (*((struct_bibliotheque *) (*l_element_lecture).donnee)).tid;                  = (*((struct_bibliotheque *) (*l_element_lecture).donnee)).tid;
   
         if (((*((struct_bibliotheque *) (*l_element_suivant).donnee)).nom =          if (((*((struct_bibliotheque *) (*l_element_suivant).donnee)).nom =
                 malloc((strlen((*((struct_bibliotheque *) (*l_element_lecture)                  rpl_malloc(s_nouvel_etat_processus,
                   (strlen((*((struct_bibliotheque *) (*l_element_lecture)
                 .donnee)).nom) + 1) * sizeof(unsigned char))) == NULL)                  .donnee)).nom) + 1) * sizeof(unsigned char))) == NULL)
         {          {
             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(NULL);                  return(NULL);
Line 3526  copie_etat_processus(struct_processus *s Line 3779  copie_etat_processus(struct_processus *s
     if ((*s_etat_processus).nombre_instructions_externes != 0)      if ((*s_etat_processus).nombre_instructions_externes != 0)
     {      {
         if (((*s_nouvel_etat_processus).s_instructions_externes =          if (((*s_nouvel_etat_processus).s_instructions_externes =
                 malloc((*s_etat_processus).nombre_instructions_externes *                  rpl_malloc(s_nouvel_etat_processus, ((size_t)
                   (*s_etat_processus).nombre_instructions_externes) *
                 sizeof(struct_instruction_externe))) == NULL)                  sizeof(struct_instruction_externe))) == NULL)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_processus;              (*s_etat_processus).erreur_systeme = d_es_processus;
Line 3536  copie_etat_processus(struct_processus *s Line 3790  copie_etat_processus(struct_processus *s
         for(i = 0; i < (*s_etat_processus).nombre_instructions_externes; i++)          for(i = 0; i < (*s_etat_processus).nombre_instructions_externes; i++)
         {          {
             if (((*s_nouvel_etat_processus).s_instructions_externes[i].nom =              if (((*s_nouvel_etat_processus).s_instructions_externes[i].nom =
                     malloc((strlen((*s_etat_processus).s_instructions_externes                      rpl_malloc(s_nouvel_etat_processus,
                       (strlen((*s_etat_processus).s_instructions_externes
                     [i].nom) + 1) * sizeof(unsigned char))) == NULL)                      [i].nom) + 1) * sizeof(unsigned char))) == NULL)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  (*s_etat_processus).erreur_systeme = d_es_processus;
Line 3547  copie_etat_processus(struct_processus *s Line 3802  copie_etat_processus(struct_processus *s
                     (*s_etat_processus).s_instructions_externes[i].nom);                      (*s_etat_processus).s_instructions_externes[i].nom);
   
             if (((*s_nouvel_etat_processus).s_instructions_externes[i]              if (((*s_nouvel_etat_processus).s_instructions_externes[i]
                     .nom_bibliotheque = malloc((strlen((*s_etat_processus)                      .nom_bibliotheque = rpl_malloc(s_nouvel_etat_processus,
                     .s_instructions_externes[i].nom_bibliotheque) + 1) *                      (strlen((*s_etat_processus).s_instructions_externes[i]
                     sizeof(unsigned char))) == NULL)                      .nom_bibliotheque) + 1) * sizeof(unsigned char))) == NULL)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return(NULL);                  return(NULL);
Line 3571  copie_etat_processus(struct_processus *s Line 3826  copie_etat_processus(struct_processus *s
   
     pthread_mutexattr_init(&attributs_mutex);      pthread_mutexattr_init(&attributs_mutex);
     pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);      pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
     pthread_mutex_init(&((*s_nouvel_etat_processus).mutex), &attributs_mutex);      pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_pile_processus),
               &attributs_mutex);
     pthread_mutexattr_destroy(&attributs_mutex);      pthread_mutexattr_destroy(&attributs_mutex);
   
     pthread_mutexattr_init(&attributs_mutex);      pthread_mutexattr_init(&attributs_mutex);
     pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);      pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
     pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_allocation),      pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_interruptions),
               &attributs_mutex);
       pthread_mutexattr_destroy(&attributs_mutex);
   
       pthread_mutexattr_init(&attributs_mutex);
       pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
       pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_signaux),
               &attributs_mutex);
       pthread_mutexattr_destroy(&attributs_mutex);
   
       pthread_mutexattr_init(&attributs_mutex);
       pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
       pthread_mutex_init(&((*s_nouvel_etat_processus).protection_liste_mutexes),
             &attributs_mutex);              &attributs_mutex);
     pthread_mutexattr_destroy(&attributs_mutex);      pthread_mutexattr_destroy(&attributs_mutex);
   
     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(NULL);          return(NULL);
Line 3698  debug_memoire_ajout(size_t taille, const Line 3966  debug_memoire_ajout(size_t taille, const
             sizeof(unsigned char))) == NULL)              sizeof(unsigned char))) == NULL)
     {      {
         pthread_mutex_unlock(&mutex_allocation);          pthread_mutex_unlock(&mutex_allocation);
   
           uprintf("[%d-%llu] ILLEGAL POINTER (malloc) $%016X\n",
                   getpid(), (unsigned long long) pthread_self(), NULL);
   #       ifdef __BACKTRACE
               BACKTRACE(PROFONDEUR_PILE);
   #       endif
   
         return(NULL);          return(NULL);
     }      }
   
Line 3758  debug_memoire_modification(void *pointeu Line 4033  debug_memoire_modification(void *pointeu
             {              {
                 pthread_mutex_unlock(&mutex_allocation);                  pthread_mutex_unlock(&mutex_allocation);
   
                 uprintf("[%d-%llu] ILLEGAL POINTER (realloc)\n",                  uprintf("[%d-%llu] ILLEGAL POINTER (realloc) $%016X\n",
                         getpid(), (unsigned long long) pthread_self());                          getpid(), (unsigned long long) pthread_self(),
                           pointeur);
 #               ifdef __BACKTRACE  #               ifdef __BACKTRACE
                     BACKTRACE(PROFONDEUR_PILE);                      BACKTRACE(PROFONDEUR_PILE);
 #               endif  #               endif
Line 3855  debug_memoire_retrait(void *pointeur) Line 4131  debug_memoire_retrait(void *pointeur)
   
     if (element_courant == NULL)      if (element_courant == NULL)
     {      {
         uprintf("[%d-%llu] ILLEGAL POINTER (free)\n",          uprintf("[%d-%llu] ILLEGAL POINTER (free) $%016X\n",
                 getpid(), (unsigned long long) pthread_self());                  getpid(), (unsigned long long) pthread_self(), pointeur);
 #       ifdef __BACKTRACE  #       ifdef __BACKTRACE
             BACKTRACE(PROFONDEUR_PILE);              BACKTRACE(PROFONDEUR_PILE);
 #       endif  #       endif
Line 3973  debug_memoire_verification() Line 4249  debug_memoire_verification()
 }  }
   
 pid_t  pid_t
 debug_fork()  debug_fork(struct_processus *s_etat_processus)
 {  {
     pid_t   pid;      pid_t   pid;
   
     pthread_mutex_lock(&mutex_allocation);      pthread_mutex_lock(&mutex_allocation);
     pid = fork();      pid = fork();
   
 #   ifdef OS2  
     if (pid == 0)  
     {  
         sem_init(&semaphore_liste_threads, 0, 1);  
         sem_init(&semaphore_gestionnaires_signaux, 0, 0);  
         sem_init(&semaphore_gestionnaires_signaux_atomique, 0, 1);  
         sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);  
     }  
 #   endif  
   
     if (pid == 0)      if (pid == 0)
     {      {
 #       ifdef _BROKEN_SIGINFO          liberation_queue_signaux(s_etat_processus);
         liberation_fifos_signaux(s_etat_processus);          creation_queue_signaux(s_etat_processus);
         creation_fifos_signaux(s_etat_processus);  
 #       endif  
   
         pthread_mutex_destroy(&mutex_allocation);          pthread_mutex_destroy(&mutex_allocation);
         debug_memoire_initialisation();          debug_memoire_initialisation();

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


CVSweb interface <joel.bertrand@systella.fr>