Diff for /rpl/src/gestion_objets.c between versions 1.76 and 1.133

version 1.76, 2011/11/26 13:05:03 version 1.133, 2017/06/30 13:11:26
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.5    RPL/2 (R) version 4.1.27
   Copyright (C) 1989-2011 Dr. BERTRAND Joël    Copyright (C) 1989-2017 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
   
Line 112  initialisation_allocateur(struct_process Line 112  initialisation_allocateur(struct_process
     (*s_etat_processus).pointeur_maillons = 0;      (*s_etat_processus).pointeur_maillons = 0;
   
     (*s_etat_processus).pointeur_variables_noeud = 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_feuille = 0;
     (*s_etat_processus).pointeur_variables_variable = 0;      (*s_etat_processus).pointeur_variables_variable = 0;
     (*s_etat_processus).pointeur_variables_tableau_noeuds = 0;      (*s_etat_processus).pointeur_variables_tableau_noeuds = 0;
       (*s_etat_processus).pointeur_variables_tableau_noeuds_partages = 0;
   
     return;      return;
 }  }
Line 150  liberation_allocateur(struct_processus * Line 152  liberation_allocateur(struct_processus *
   
     for(i = 0; i < (*s_etat_processus).pointeur_variables_noeud;      for(i = 0; i < (*s_etat_processus).pointeur_variables_noeud;
             free((*s_etat_processus).variables_noeud[i++]));              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;      for(i = 0; i < (*s_etat_processus).pointeur_variables_feuille;
             free((*s_etat_processus).variables_feuille[i++]));              free((*s_etat_processus).variables_feuille[i++]));
     for(i = 0; i < (*s_etat_processus).pointeur_variables_variable;      for(i = 0; i < (*s_etat_processus).pointeur_variables_variable;
             free((*s_etat_processus).variables_variable[i++]));              free((*s_etat_processus).variables_variable[i++]));
     for(i = 0; i < (*s_etat_processus).pointeur_variables_tableau_noeuds;      for(i = 0; i < (*s_etat_processus).pointeur_variables_tableau_noeuds;
             free((*s_etat_processus).variables_tableau_noeuds[i++]));              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;
Line 238  allocation_maillon(struct_processus *s_e Line 245  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 311  allocation(struct_processus *s_etat_proc Line 319  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 334  allocation(struct_processus *s_etat_proc Line 343  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 346  allocation(struct_processus *s_etat_proc Line 357  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 373  allocation(struct_processus *s_etat_proc Line 386  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 399  allocation(struct_processus *s_etat_proc Line 414  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 411  allocation(struct_processus *s_etat_proc Line 428  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 418  allocation(struct_processus *s_etat_proc Line 436  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 430  allocation(struct_processus *s_etat_proc Line 454  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 453  allocation(struct_processus *s_etat_proc Line 479  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 478  allocation(struct_processus *s_etat_proc Line 506  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 501  allocation(struct_processus *s_etat_proc Line 531  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 524  allocation(struct_processus *s_etat_proc Line 556  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 540  allocation(struct_processus *s_etat_proc Line 574  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);
             }              }
Line 559  allocation(struct_processus *s_etat_proc Line 594  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 578  allocation(struct_processus *s_etat_proc Line 615  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 596  allocation(struct_processus *s_etat_proc Line 634  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 614  allocation(struct_processus *s_etat_proc Line 654  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 626  allocation(struct_processus *s_etat_proc Line 667  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 637  allocation(struct_processus *s_etat_proc Line 679  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 649  allocation(struct_processus *s_etat_proc Line 692  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 667  allocation(struct_processus *s_etat_proc Line 711  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 688  allocation(struct_processus *s_etat_proc Line 734  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 710  allocation(struct_processus *s_etat_proc Line 758  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 732  allocation(struct_processus *s_etat_proc Line 782  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 776  liberation(struct_processus *s_etat_proc Line 828  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 815  liberation(struct_processus *s_etat_proc Line 869  liberation(struct_processus *s_etat_proc
             }              }
             else              else
             {              {
                 free((unsigned long *) ((*s_objet).objet));                  free((*s_objet).objet);
             }              }
   
             break;              break;
Line 882  liberation(struct_processus *s_etat_proc Line 936  liberation(struct_processus *s_etat_proc
                 return;                  return;
             }              }
   
             free((unsigned char *) ((*s_objet).objet));              free((unsigned char *) (*s_objet).objet);
             break;              break;
         }          }
   
Line 1350  liberation(struct_processus *s_etat_proc Line 1404  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 1449  liberation(struct_processus *s_etat_proc Line 1503  liberation(struct_processus *s_etat_proc
             break;              break;
         }          }
   
           case EXT:
           {
               if (decrementation_atomique(s_objet) > 0)
               {
                   return;
               }
   
               // Appel de la fonction de duplication associée ŕ l'objet
               // externe. Le descripteur de bibliothčque est directement
               // associé ŕ la structure objet.
   
               if ((__type_drop = dlsym((*s_objet).descripteur_bibliotheque,
                       "__type_drop")) == NULL)
               {
                   // La fonction de duplication 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;
           }
   
         default :          default :
         {          {
             if (pthread_mutex_unlock(&((*s_objet).mutex)) != 0)              if (pthread_mutex_unlock(&((*s_objet).mutex)) != 0)
Line 1545  copie_objet(struct_processus *s_etat_pro Line 1630  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 1597  copie_objet(struct_processus *s_etat_pro Line 1683  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 1663  copie_objet(struct_processus *s_etat_pro Line 1749  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 1715  copie_objet(struct_processus *s_etat_pro Line 1801  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 1809  copie_objet(struct_processus *s_etat_pro Line 1895  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 2016  copie_objet(struct_processus *s_etat_pro Line 2102  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 2051  copie_objet(struct_processus *s_etat_pro Line 2137  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 2075  copie_objet(struct_processus *s_etat_pro Line 2160  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 2118  copie_objet(struct_processus *s_etat_pro Line 2203  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 2142  copie_objet(struct_processus *s_etat_pro Line 2227  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 2185  copie_objet(struct_processus *s_etat_pro Line 2270  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 2209  copie_objet(struct_processus *s_etat_pro Line 2293  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 2283  copie_objet(struct_processus *s_etat_pro Line 2367  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;
         }          }
   
Line 2387  copie_objet(struct_processus *s_etat_pro Line 2476  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 2576  copie_objet(struct_processus *s_etat_pro Line 2677  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 2637  copie_objet(struct_processus *s_etat_pro Line 2739  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 2680  copie_objet(struct_processus *s_etat_pro Line 2782  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 2723  copie_objet(struct_processus *s_etat_pro Line 2825  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 2752  copie_objet(struct_processus *s_etat_pro Line 2854  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.
   
               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;
           }
   
         default :          default :
         {          {
             return(NULL);              return(NULL);
Line 2787  copie_etat_processus(struct_processus *s Line 2921  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);
     }      }
   
     (*s_nouvel_etat_processus) = (*s_etat_processus);      (*s_nouvel_etat_processus) = (*s_etat_processus);
   
     // On réinitialise l'allocateur.      // 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 2815  copie_etat_processus(struct_processus *s Line 2970  copie_etat_processus(struct_processus *s
      * n'ont aucune raison de changer.       * n'ont aucune raison de changer.
      */       */
   
     pthread_mutexattr_init(&attributs_mutex);      (*s_nouvel_etat_processus).sections_critiques = 0;
     pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);      (*s_nouvel_etat_processus).initialisation_scheduler = d_faux;
   
     // Les sémaphores sont initialisés dans le nouveau thread. Il      // Les sémaphores sont initialisés dans le nouveau thread. Il
     // s'agit d'une limitation de l'implantation de l'émulation      // s'agit d'une limitation de l'implantation de l'émulation
Line 2883  copie_etat_processus(struct_processus *s Line 3038  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 2899  copie_etat_processus(struct_processus *s Line 3054  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 2919  copie_etat_processus(struct_processus *s Line 3075  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 2940  copie_etat_processus(struct_processus *s Line 3097  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 2960  copie_etat_processus(struct_processus *s Line 3118  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 2984  copie_etat_processus(struct_processus *s Line 3144  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 3008  copie_etat_processus(struct_processus *s Line 3170  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 3032  copie_etat_processus(struct_processus *s Line 3195  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 3056  copie_etat_processus(struct_processus *s Line 3220  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 3080  copie_etat_processus(struct_processus *s Line 3245  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 3106  copie_etat_processus(struct_processus *s Line 3272  copie_etat_processus(struct_processus *s
      * Copie de la table des variables       * Copie de la table des variables
      */       */
   
       (*s_nouvel_etat_processus).l_liste_variables_statiques = NULL;
     copie_arbre_variables(s_etat_processus, s_nouvel_etat_processus);      copie_arbre_variables(s_etat_processus, s_nouvel_etat_processus);
   
     if ((*s_nouvel_etat_processus).erreur_systeme != d_es)      if ((*s_nouvel_etat_processus).erreur_systeme != d_es)
Line 3113  copie_etat_processus(struct_processus *s Line 3280  copie_etat_processus(struct_processus *s
         return(NULL);          return(NULL);
     }      }
   
     /*      (*(*s_nouvel_etat_processus).l_liste_variables_partagees) =
      * Copie de la table des variables statiques              (*(*s_etat_processus).l_liste_variables_partagees);
      */      (*(*s_nouvel_etat_processus).s_arbre_variables_partagees) =
               (*(*s_etat_processus).s_arbre_variables_partagees);
     if (((*s_nouvel_etat_processus).s_liste_variables_statiques =  
             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);  
     }  
   
     for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++)  
     {  
         if (((*s_nouvel_etat_processus).s_liste_variables_statiques[i].nom =  
                 malloc((strlen((*s_etat_processus).s_liste_variables_statiques  
                 [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 3183  copie_etat_processus(struct_processus *s Line 3295  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 3198  copie_etat_processus(struct_processus *s Line 3312  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 3234  copie_etat_processus(struct_processus *s Line 3349  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 3256  copie_etat_processus(struct_processus *s Line 3372  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 3288  copie_etat_processus(struct_processus *s Line 3405  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 3303  copie_etat_processus(struct_processus *s Line 3422  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 3334  copie_etat_processus(struct_processus *s Line 3454  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 3349  copie_etat_processus(struct_processus *s Line 3471  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 3385  copie_etat_processus(struct_processus *s Line 3508  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 3400  copie_etat_processus(struct_processus *s Line 3525  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 3431  copie_etat_processus(struct_processus *s Line 3557  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 3443  copie_etat_processus(struct_processus *s Line 3571  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 3459  copie_etat_processus(struct_processus *s Line 3587  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 3493  copie_etat_processus(struct_processus *s Line 3623  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 3503  copie_etat_processus(struct_processus *s Line 3634  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 3514  copie_etat_processus(struct_processus *s Line 3646  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 3538  copie_etat_processus(struct_processus *s Line 3670  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);

Removed from v.1.76  
changed lines
  Added in v.1.133


CVSweb interface <joel.bertrand@systella.fr>