Diff for /rpl/src/gestion_objets.c between versions 1.8 and 1.30

version 1.8, 2010/03/09 10:18:44 version 1.30, 2010/06/28 14:30:33
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.0.13    RPL/2 (R) version 4.0.17
   Copyright (C) 1989-2010 Dr. BERTRAND Joël    Copyright (C) 1989-2010 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
Line 266  liberation_maillon(struct_processus *s_e Line 266  liberation_maillon(struct_processus *s_e
 ================================================================================  ================================================================================
   Routine d'allocation d'une structure *s_objet    Routine d'allocation d'une structure *s_objet
 ================================================================================  ================================================================================
   Entrées : structure sur l'état du processus et objet à afficher    Entrées : structure sur l'état du processus et objet à allouer
 --------------------------------------------------------------------------------  --------------------------------------------------------------------------------
   Sorties : chaine de caractères    Sorties : chaine de caractères
 --------------------------------------------------------------------------------  --------------------------------------------------------------------------------
Line 279  allocation(struct_processus *s_etat_proc Line 279  allocation(struct_processus *s_etat_proc
 {  {
     struct_objet            *s_objet;      struct_objet            *s_objet;
   
       if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation)) != 0)
       {
           (*s_etat_processus).erreur_systeme = d_es_processus;
           return(NULL);
       }
   
     if ((*s_etat_processus).pile_objets == NULL)      if ((*s_etat_processus).pile_objets == NULL)
     {      {
           if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation)) != 0)
           {
               (*s_etat_processus).erreur_systeme = d_es_processus;
               return(NULL);
           }
   
         // Il n'existe aucune structure struct_objet disponible dans le cache.          // Il n'existe aucune structure struct_objet disponible dans le cache.
   
         if ((s_objet = malloc(sizeof(struct_objet))) == NULL)          if ((s_objet = malloc(sizeof(struct_objet))) == NULL)
Line 299  allocation(struct_processus *s_etat_proc Line 311  allocation(struct_processus *s_etat_proc
         (*s_etat_processus).taille_pile_objets--;          (*s_etat_processus).taille_pile_objets--;
   
         (*s_objet).nombre_occurrences = 1;          (*s_objet).nombre_occurrences = 1;
   
           if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation)) != 0)
           {
               (*s_etat_processus).erreur_systeme = d_es_processus;
               return(NULL);
           }
     }      }
   
     (*s_objet).type = type;      (*s_objet).type = type;
Line 877  liberation(struct_processus *s_etat_proc Line 895  liberation(struct_processus *s_etat_proc
         {          {
             if (decrementation_atomique(s_objet) > 0)              if (decrementation_atomique(s_objet) > 0)
             {              {
                   BUG((*(*((struct_fichier *) (*s_objet).objet)).format)
                           .nombre_occurrences <= 1,
                           pthread_mutex_unlock(&((*s_objet).mutex)),
                           printf("(*(*((struct_fichier *) (*s_objet).objet))"
                           ".format).nombre_occurrences=%ld\n",
                           (*(*((struct_fichier *) (*s_objet).objet)).format)
                           .nombre_occurrences));
   
                   liberation(s_etat_processus,
                           (*((struct_fichier *) (*s_objet).objet)).format);
                 return;                  return;
             }              }
   
             liberation(s_etat_processus,              liberation(s_etat_processus,
                     (*((struct_fichier *) (*s_objet).objet)).format);                      (*((struct_fichier *) (*s_objet).objet)).format);
   
             free((unsigned char *) (*((struct_fichier *)              free((unsigned char *) (*((struct_fichier *)
                     (*s_objet).objet)).nom);                      (*s_objet).objet)).nom);
             free((struct_fichier *) ((*s_objet).objet));              free((struct_fichier *) ((*s_objet).objet));
Line 1095  liberation(struct_processus *s_etat_proc Line 1122  liberation(struct_processus *s_etat_proc
                 return;                  return;
             }              }
   
             free(s_objet);  
             break;              break;
         }          }
   
Line 1112  liberation(struct_processus *s_etat_proc Line 1138  liberation(struct_processus *s_etat_proc
                     .nombre_references--;                      .nombre_references--;
   
             BUG((*(*((struct_processus_fils *) (*s_objet).objet)).thread)              BUG((*(*((struct_processus_fils *) (*s_objet).objet)).thread)
                     .nombre_references < 0, printf("(*(*((struct_processus_fils"                      .nombre_references < 0, uprintf(
                       "(*(*((struct_processus_fils"
                     " *) (*s_objet).objet)).thread).nombre_references = %d\n",                      " *) (*s_objet).objet)).thread).nombre_references = %d\n",
                     (int) (*(*((struct_processus_fils *) (*s_objet).objet))                      (int) (*(*((struct_processus_fils *) (*s_objet).objet))
                     .thread).nombre_references));                      .thread).nombre_references));
Line 1139  liberation(struct_processus *s_etat_proc Line 1166  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));
                 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)
             {              {
                   BUG(drapeau == d_vrai, uprintf("(*(*((struct_processus_fils"
                           " *) (*s_objet).objet)).thread).nombre_references "
                           "= 0 with nombre_occurrences > 0\n"));
                 return;                  return;
             }              }
   
Line 1208  liberation(struct_processus *s_etat_proc Line 1239  liberation(struct_processus *s_etat_proc
         {          {
             if (decrementation_atomique(s_objet) > 0)              if (decrementation_atomique(s_objet) > 0)
             {              {
                   BUG((*(*((struct_socket *) (*s_objet).objet)).format)
                           .nombre_occurrences <= 1,
                           pthread_mutex_unlock(&((*s_objet).mutex)),
                           printf("(*(*((struct_socket *) (*s_objet).objet))"
                           ".format).nombre_occurrences=%ld\n",
                           (*(*((struct_socket *) (*s_objet).objet)).format)
                           .nombre_occurrences));
   
                   liberation(s_etat_processus, (*((struct_socket *)
                           (*s_objet).objet)).format);
                 return;                  return;
             }              }
   
             liberation(s_etat_processus, (*((struct_socket *)              liberation(s_etat_processus, (*((struct_socket *)
                     (*s_objet).objet)).format);                      (*s_objet).objet)).format);
   
             free((unsigned char *) (*((struct_socket *) (*s_objet).objet))              free((unsigned char *) (*((struct_socket *) (*s_objet).objet))
                     .adresse);                      .adresse);
             free((unsigned char *) (*((struct_socket *) (*s_objet).objet))              free((unsigned char *) (*((struct_socket *) (*s_objet).objet))
Line 1396  liberation(struct_processus *s_etat_proc Line 1438  liberation(struct_processus *s_etat_proc
         return;          return;
     }      }
   
     if (s_etat_processus != NULL)      if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation)) != 0)
     {      {
         if ((*s_etat_processus).taille_pile_objets < TAILLE_CACHE)          (*s_etat_processus).erreur_systeme = d_es_processus;
         {          return;
             (*s_objet).objet = (*s_etat_processus).pile_objets;      }
             (*s_etat_processus).pile_objets = s_objet;  
             (*s_etat_processus).taille_pile_objets++;  
         }  
         else  
         {  
             if (pthread_mutex_destroy(&((*s_objet).mutex)) != 0)  
             {  
                 (*s_etat_processus).erreur_systeme = d_es_processus;  
                 return;  
             }  
   
             free(s_objet);      if ((*s_etat_processus).taille_pile_objets < TAILLE_CACHE)
         }      {
           (*s_objet).objet = (*s_etat_processus).pile_objets;
           (*s_etat_processus).pile_objets = s_objet;
           (*s_etat_processus).taille_pile_objets++;
     }      }
     else      else
     {      {
           if (pthread_mutex_destroy(&((*s_objet).mutex)) != 0)
           {
               pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation));
               (*s_etat_processus).erreur_systeme = d_es_processus;
               return;
           }
   
         free(s_objet);          free(s_objet);
     }      }
   
       if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation)) != 0)
       {
           (*s_etat_processus).erreur_systeme = d_es_processus;
           return;
       }
   
     return;      return;
 }  }
   
Line 1749  copie_objet(struct_processus *s_etat_pro Line 1797  copie_objet(struct_processus *s_etat_pro
             if (type == 'P')              if (type == 'P')
             {              {
                 incrementation_atomique(s_objet);                  incrementation_atomique(s_objet);
   
                   if (((*((struct_fichier *) ((*s_objet).objet))).format =
                           copie_objet(s_etat_processus, (*((struct_fichier *)
                           ((*s_objet).objet))).format, 'P')) == NULL)
                   {
                       return(NULL);
                   }
   
                 return(s_objet);                  return(s_objet);
             }              }
   
Line 2239  copie_objet(struct_processus *s_etat_pro Line 2295  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;              break;
         }          }
   
Line 2265  copie_objet(struct_processus *s_etat_pro Line 2322  copie_objet(struct_processus *s_etat_pro
             if (type == 'P')              if (type == 'P')
             {              {
                 incrementation_atomique(s_objet);                  incrementation_atomique(s_objet);
   
                   if (((*((struct_socket *) ((*s_objet).objet)))
                           .format = copie_objet(s_etat_processus,
                           (*((struct_socket *) ((*s_objet).objet))).format, 'P'))
                           == NULL)
                   {
                       return(NULL);
                   }
   
                 return(s_objet);                  return(s_objet);
             }              }
   
Line 2721  copie_etat_processus(struct_processus *s Line 2787  copie_etat_processus(struct_processus *s
      * n'ont aucune raison de changer.       * n'ont aucune raison de changer.
      */       */
   
   #   ifndef SEMAPHORES_NOMMES
     sem_init(&((*s_nouvel_etat_processus).semaphore_fork), 0, 0);      sem_init(&((*s_nouvel_etat_processus).semaphore_fork), 0, 0);
   #   else
       if (((*s_nouvel_etat_processus).semaphore_fork = sem_init2(0, sem_fork))
               == SEM_FAILED)
       {
           (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
           return(NULL);
       }
   #   endif
   
     (*s_nouvel_etat_processus).var_volatile_processus_pere = 0;      (*s_nouvel_etat_processus).var_volatile_processus_pere = 0;
     (*s_nouvel_etat_processus).fichiers_graphiques = NULL;      (*s_nouvel_etat_processus).fichiers_graphiques = NULL;
Line 2753  copie_etat_processus(struct_processus *s Line 2828  copie_etat_processus(struct_processus *s
     (*s_nouvel_etat_processus).nombre_interruptions_en_queue = 0;      (*s_nouvel_etat_processus).nombre_interruptions_en_queue = 0;
     (*s_nouvel_etat_processus).nombre_interruptions_non_affectees = 0;      (*s_nouvel_etat_processus).nombre_interruptions_non_affectees = 0;
   
       (*s_nouvel_etat_processus).at_exit = NULL;
   
     for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++)      for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++)
     {      {
         (*s_nouvel_etat_processus).corps_interruptions[i] = NULL;          (*s_nouvel_etat_processus).corps_interruptions[i] = NULL;
Line 3032  copie_etat_processus(struct_processus *s Line 3109  copie_etat_processus(struct_processus *s
                 (*s_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_nouvel_etat_processus).s_liste_variables[i].variable_statique =
                 (*s_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_nouvel_etat_processus).s_liste_variables[i].variable_verrouillee =
                 (*s_etat_processus).s_liste_variables[i].variable_verrouillee;                  (*s_etat_processus).s_liste_variables[i].variable_verrouillee;
   
Line 3486  copie_etat_processus(struct_processus *s Line 3565  copie_etat_processus(struct_processus *s
     pthread_mutex_init(&((*s_nouvel_etat_processus).mutex), &attributs_mutex);      pthread_mutex_init(&((*s_nouvel_etat_processus).mutex), &attributs_mutex);
     pthread_mutexattr_destroy(&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);
   
     if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)      if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
     {      {
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
Line 3515  copie_etat_processus(struct_processus *s Line 3600  copie_etat_processus(struct_processus *s
 #undef malloc  #undef malloc
 #undef realloc  #undef realloc
 #undef free  #undef free
   #undef fork
   
 #ifdef return  #ifdef return
 #   undef return  #   undef return
 #endif  #endif
   
 #undef fprintf  #ifdef __BACKTRACE
   #define PROFONDEUR_PILE 64
 #define return(a) { if (a == NULL) \  #define return(a) { if (a == NULL) \
         { BACKTRACE(20); fprintf(stderr, ">>> MEDITATION %d\n", __LINE__); } \          { BACKTRACE(PROFONDEUR_PILE); \
           fprintf(stderr, ">>> MEDITATION %d\n", __LINE__); } \
         return(a); } while(0)          return(a); } while(0)
   #endif
   
   #undef fprintf
   #define check(a, b) ((strcmp(#a, fonction) == 0) && (ligne == b))
   #undef CORE_DUMP
   
 typedef struct memoire  typedef struct memoire
 {  {
Line 3534  typedef struct memoire Line 3626  typedef struct memoire
     unsigned long       ligne;      unsigned long       ligne;
     size_t              taille;      size_t              taille;
     unsigned long long  ordre;      unsigned long long  ordre;
   #   ifdef __BACKTRACE
       void                *pile[PROFONDEUR_PILE];
       int                 profondeur;
   #   endif
     struct memoire      *suivant;      struct memoire      *suivant;
 } struct_memoire;  } struct_memoire;
   
 static struct_memoire       *debug = NULL;  static struct_memoire       *debug = NULL;
 static unsigned long long   ordre = 0;  static unsigned long long   ordre = 0;
 static pthread_mutex_t      mutex_allocation = PTHREAD_MUTEX_INITIALIZER;  static pthread_mutex_t      mutex_allocation;
   
 #define check(a, b) ((strcmp(#a, fonction) == 0) && (ligne == b))  void
   debug_memoire_initialisation()
   {
       pthread_mutexattr_t         attributs_mutex;
   
       pthread_mutexattr_init(&attributs_mutex);
       pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
       pthread_mutex_init(&mutex_allocation, &attributs_mutex);
       pthread_mutexattr_destroy(&attributs_mutex);
   
       return;
   }
   
 void *  void *
 debug_memoire_ajout(size_t taille, const unsigned char *fonction,  debug_memoire_ajout(size_t taille, const unsigned char *fonction,
Line 3549  debug_memoire_ajout(size_t taille, const Line 3656  debug_memoire_ajout(size_t taille, const
 {  {
     struct_memoire  *ancienne_base;      struct_memoire  *ancienne_base;
   
       void            *pointeur;
   
     pthread_mutex_lock(&mutex_allocation);      pthread_mutex_lock(&mutex_allocation);
   
     ancienne_base = debug;      ancienne_base = debug;
Line 3570  debug_memoire_ajout(size_t taille, const Line 3679  debug_memoire_ajout(size_t taille, const
     (*debug).taille = taille;      (*debug).taille = taille;
     (*debug).ordre = ordre;      (*debug).ordre = ordre;
   
     pthread_mutex_unlock(&mutex_allocation);      pointeur = (*debug).pointeur;
   
   #   ifdef __BACKTRACE
       (*debug).profondeur = backtrace((*debug).pile, PROFONDEUR_PILE);
   #   endif
   
     if (((*debug).fonction = malloc((strlen(fonction) + 1) *      if (((*debug).fonction = malloc((strlen(fonction) + 1) *
             sizeof(unsigned char))) == NULL)              sizeof(unsigned char))) == NULL)
     {      {
           pthread_mutex_unlock(&mutex_allocation);
         return(NULL);          return(NULL);
     }      }
   
     if (((*debug).argument = malloc((strlen(argument) + 1) *      if (((*debug).argument = malloc((strlen(argument) + 1) *
             sizeof(unsigned char))) == NULL)              sizeof(unsigned char))) == NULL)
     {      {
           pthread_mutex_unlock(&mutex_allocation);
         return(NULL);          return(NULL);
     }      }
   
     strcpy((*debug).fonction, fonction);      strcpy((*debug).fonction, fonction);
     strcpy((*debug).argument, argument);      strcpy((*debug).argument, argument);
   
       memset((*debug).pointeur, 0, (*debug).taille);
   
       pthread_mutex_unlock(&mutex_allocation);
     ordre++;      ordre++;
   
     return((*debug).pointeur);      return(pointeur);
 }  }
   
 void *  void *
Line 3603  debug_memoire_modification(void *pointeu Line 3721  debug_memoire_modification(void *pointeu
     {      {
         if (taille == 0)          if (taille == 0)
         {          {
             // Revient à free()              // Revient à free(). Il n'y a pas de parenthèses car on ne veut
               // pas utiliser la macro return().
   
             debug_memoire_retrait(pointeur);              debug_memoire_retrait(pointeur);
             return(NULL);              return NULL ;
         }          }
         else          else
         {          {
Line 3628  debug_memoire_modification(void *pointeu Line 3748  debug_memoire_modification(void *pointeu
             if (element_courant == NULL)              if (element_courant == NULL)
             {              {
                 pthread_mutex_unlock(&mutex_allocation);                  pthread_mutex_unlock(&mutex_allocation);
                 return(NULL);  
             }  
   
             pthread_mutex_unlock(&mutex_allocation);                  uprintf("[%d-%llu] ILLEGAL POINTER (realloc)\n",
                           getpid(), (unsigned long long) pthread_self());
   #               ifdef __BACKTRACE
                       BACKTRACE(PROFONDEUR_PILE);
   #               endif
   
             if (((*element_courant).pointeur = realloc(pointeur, taille))                  return(realloc(pointeur, taille));
                     == NULL)  
             {  
                 return(NULL);  
             }              }
               else
               {
                   if (((*element_courant).pointeur = realloc(pointeur, taille))
                           == NULL)
                   {
                       pthread_mutex_unlock(&mutex_allocation);
                       return(NULL);
                   }
   
             (*element_courant).ligne = ligne;                  (*element_courant).ligne = ligne;
             (*element_courant).taille = taille;                  (*element_courant).taille = taille;
             free((*element_courant).fonction);                  free((*element_courant).fonction);
             free((*element_courant).argument);                  free((*element_courant).argument);
   
             if (((*element_courant).fonction = malloc((strlen(fonction) + 1) *                  if (((*element_courant).fonction = malloc((strlen(fonction)
                     sizeof(unsigned char))) == NULL)                          + 1) * sizeof(unsigned char))) == NULL)
             {                  {
                 return(NULL);                      pthread_mutex_unlock(&mutex_allocation);
             }                      return(NULL);
                   }
   
             if (((*element_courant).argument = malloc((strlen(argument) + 1) *                  if (((*element_courant).argument = malloc((strlen(argument)
                     sizeof(unsigned char))) == NULL)                          + 1) * sizeof(unsigned char))) == NULL)
             {                  {
                 return(NULL);                      pthread_mutex_unlock(&mutex_allocation);
             }                      return(NULL);
                   }
   
                   strcpy((*element_courant).fonction, fonction);
                   strcpy((*element_courant).argument, argument);
   
             strcpy((*element_courant).fonction, fonction);                  pthread_mutex_unlock(&mutex_allocation);
             strcpy((*element_courant).argument, argument);  
   
             return((*element_courant).pointeur);                  return((*element_courant).pointeur);
               }
         }          }
     }      }
     else      else
Line 3694  debug_memoire_retrait(void *pointeur) Line 3826  debug_memoire_retrait(void *pointeur)
                 (*element_precedent).suivant = (*element_courant).suivant;                  (*element_precedent).suivant = (*element_courant).suivant;
             }              }
   
               if (pointeur != NULL)
               {
                   memset(pointeur, 0, (*element_courant).taille);
               }
   
             free((*element_courant).fonction);              free((*element_courant).fonction);
             free((*element_courant).argument);              free((*element_courant).argument);
             free(element_courant);              free(element_courant);
Line 3707  debug_memoire_retrait(void *pointeur) Line 3844  debug_memoire_retrait(void *pointeur)
   
     pthread_mutex_unlock(&mutex_allocation);      pthread_mutex_unlock(&mutex_allocation);
   
     free(pointeur);      if (element_courant == NULL)
       {
           uprintf("[%d-%llu] ILLEGAL POINTER (free)\n",
                   getpid(), (unsigned long long) pthread_self());
   #       ifdef __BACKTRACE
               BACKTRACE(PROFONDEUR_PILE);
   #       endif
       }
   
       free(pointeur);
     return;      return;
 }  }
   
 void  void
 debug_memoire_verification(struct_processus *s_etat_processus)  debug_memoire_verification()
 {  {
   #   ifdef __BACKTRACE
       char            **appels;
   
       int             j;
   #   endif
   
     integer8        i;      integer8        i;
   
     struct_memoire  *element_courant;      struct_memoire  *element_courant;
     struct_memoire  *element_suivant;      struct_memoire  *element_suivant;
   
     fprintf(stderr, "[%d-%llu] MEMORY LEAK\n",      fprintf(stderr, "[%d-%llu] LIST OF MEMORY LEAKS\n",
             getpid(), (unsigned long long) pthread_self());              getpid(), (unsigned long long) pthread_self());
   
     pthread_mutex_lock(&mutex_allocation);      pthread_mutex_lock(&mutex_allocation);
Line 3742  debug_memoire_verification(struct_proces Line 3893  debug_memoire_verification(struct_proces
                 (unsigned long long) pthread_self(),                  (unsigned long long) pthread_self(),
                 (*element_courant).argument);                  (*element_courant).argument);
   
         switch(i)          if (strstr((*element_courant).argument, "sizeof(unsigned char)")
                   != NULL)
           {
               fprintf(stderr, "[%d-%llu] ", getpid(),
                       (unsigned long long) pthread_self());
               fprintf(stderr, "O: %s\n", (unsigned char *)
                       (*element_courant).pointeur);
           }
           else if (strcmp((*element_courant).argument, "sizeof(struct_objet)")
                   == 0)
           {
               fprintf(stderr, "[%d-%llu] ", getpid(),
                       (unsigned long long) pthread_self());
               fprintf(stderr, "O: %d\n", (*((struct_objet *)
                       (*element_courant).pointeur)).type);
           }
           else if (strcmp((*element_courant).argument,
                   "sizeof(struct_liste_chainee)") == 0)
           {
               fprintf(stderr, "[%d-%llu] ", getpid(),
                       (unsigned long long) pthread_self());
               fprintf(stderr, "O: data=%p next=%p\n", (*((struct_liste_chainee *)
                       (*element_courant).pointeur)).donnee,
                       (*((struct_liste_chainee *) (*element_courant).pointeur))
                       .suivant);
           }
   
   #       ifdef __BACKTRACE
           appels = backtrace_symbols((*element_courant).pile,
                   (*element_courant).profondeur);
   
           fprintf(stderr, "[%d-%llu] BACKTRACE\n",
                   getpid(), (unsigned long long) pthread_self());
   
           if (appels != NULL)
         {          {
             // Affichage des méditations              for(j = 0; j < (*element_courant).profondeur; j++)
             case 1:  
             {              {
                 break;                  fprintf(stderr, "[%d-%llu] %s\n", getpid(),
                           (unsigned long long) pthread_self(), appels[j]);
             }              }
   
               free(appels);
         }          }
   #       endif
   
           fprintf(stderr, "\n");
   
         i++;          i++;
   
         element_suivant = (*element_courant).suivant;          element_suivant = (*element_courant).suivant;
   
   #       ifndef CORE_DUMP
         free((*element_courant).fonction);          free((*element_courant).fonction);
         free((*element_courant).argument);          free((*element_courant).argument);
         free(element_courant);          free(element_courant);
   #       endif
   
         element_courant = element_suivant;          element_courant = element_suivant;
     }      }
   
     pthread_mutex_unlock(&mutex_allocation);      pthread_mutex_unlock(&mutex_allocation);
       pthread_mutex_destroy(&mutex_allocation);
   
     fprintf(stderr, "[%d-%llu] END OF LIST\n", getpid(),      fprintf(stderr, "[%d-%llu] END OF LIST\n", getpid(),
             (unsigned long long) pthread_self());              (unsigned long long) pthread_self());
   
     return;      return;
 }  }
   
   pid_t
   debug_fork()
   {
       pid_t   pid;
   
       pthread_mutex_lock(&mutex_allocation);
       pid = fork();
   
       if (pid == 0)
       {
           pthread_mutex_destroy(&mutex_allocation);
           debug_memoire_initialisation();
       }
       else
       {
           pthread_mutex_unlock(&mutex_allocation);
       }
   
       // Pas de parenthèses pour ne pas remplacer return par sa macro.
       return pid;
   }
   
   void
   analyse_post_mortem()
   {
   #   ifdef CORE_DUMP
       BUG(debug != NULL, uprintf("[%d-%llu] CREATE CORE DUMP FILE FOR "
               "POST MORTEM ANALYZE\n", getpid(),
               (unsigned long long) pthread_self()));
   #   endif
   
       return;
   }
   
 #endif  #endif
   

Removed from v.1.8  
changed lines
  Added in v.1.30


CVSweb interface <joel.bertrand@systella.fr>