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

Diff for /rpl/src/gestion_objets.c between versions 1.1 and 1.14

version 1.1, 2010/01/26 15:22:44 version 1.14, 2010/04/28 06:41:06
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.0.9    RPL/2 (R) version 4.0.15
   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 25 Line 25
   
 /*  /*
 ================================================================================  ================================================================================
   Routine de gestion du nombre d'occurrences comme grandeur atomique    Routines de gestion du nombre d'occurrences comme grandeur atomique
 ================================================================================  ================================================================================
   entrées : structure sur l'état du processus et objet à afficher    entrées : structure sur l'état du processus et objet à afficher
 --------------------------------------------------------------------------------  --------------------------------------------------------------------------------
Line 403  allocation(struct_processus *s_etat_proc Line 403  allocation(struct_processus *s_etat_proc
                 }                  }
             }              }
   
               (*((struct_fonction *) (*s_objet).objet)).fonction = NULL;
             (*((struct_fonction *) (*s_objet).objet)).prediction_saut = NULL;              (*((struct_fonction *) (*s_objet).objet)).prediction_saut = NULL;
               (*((struct_fonction *) (*s_objet).objet)).prediction_execution
                       = d_faux;
             break;              break;
         }          }
   
Line 2718  copie_etat_processus(struct_processus *s Line 2721  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 2730  copie_etat_processus(struct_processus *s Line 2742  copie_etat_processus(struct_processus *s
     (*s_nouvel_etat_processus).expression_courante = NULL;      (*s_nouvel_etat_processus).expression_courante = NULL;
     (*s_nouvel_etat_processus).objet_courant = NULL;      (*s_nouvel_etat_processus).objet_courant = NULL;
     (*s_nouvel_etat_processus).processus_detache = d_faux;      (*s_nouvel_etat_processus).processus_detache = d_faux;
       (*s_nouvel_etat_processus).evaluation_forcee = 'N';
   
     (*s_nouvel_etat_processus).nombre_objets_envoyes_non_lus = 0;      (*s_nouvel_etat_processus).nombre_objets_envoyes_non_lus = 0;
     (*s_nouvel_etat_processus).nombre_objets_injectes = 0;      (*s_nouvel_etat_processus).nombre_objets_injectes = 0;
Line 2749  copie_etat_processus(struct_processus *s Line 2762  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 3028  copie_etat_processus(struct_processus *s Line 3043  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 3493  copie_etat_processus(struct_processus *s Line 3510  copie_etat_processus(struct_processus *s
 #undef return  #undef return
 }  }
   
   
   /*
   ================================================================================
     Routines de debug
   ================================================================================
     entrées :
   --------------------------------------------------------------------------------
     sorties :
   --------------------------------------------------------------------------------
     effets de bord : néant
   ================================================================================
   */
   
   #ifdef DEBUG_MEMOIRE
   
   #undef malloc
   #undef realloc
   #undef free
   
   #ifdef return
   #   undef return
   #endif
   
   #undef fprintf
   
   #define return(a) { if (a == NULL) \
           { BACKTRACE(20); fprintf(stderr, ">>> MEDITATION %d\n", __LINE__); } \
           return(a); } while(0)
   
   typedef struct memoire
   {
       void                *pointeur;
       unsigned char       *fonction;
       unsigned char       *argument;
       unsigned long       ligne;
       size_t              taille;
       unsigned long long  ordre;
       struct memoire      *suivant;
   } struct_memoire;
   
   static struct_memoire       *debug = NULL;
   static unsigned long long   ordre = 0;
   static pthread_mutex_t      mutex_allocation = PTHREAD_MUTEX_INITIALIZER;
   
   #define check(a, b) ((strcmp(#a, fonction) == 0) && (ligne == b))
   
   void *
   debug_memoire_ajout(size_t taille, const unsigned char *fonction,
           unsigned long ligne, const unsigned char *argument)
   {
       struct_memoire  *ancienne_base;
   
       pthread_mutex_lock(&mutex_allocation);
   
       ancienne_base = debug;
   
       if ((debug = malloc(sizeof(struct_memoire))) == NULL)
       {
           pthread_mutex_unlock(&mutex_allocation);
           return(NULL);
       }
   
       if (((*debug).pointeur = malloc(taille)) == NULL)
       {
           pthread_mutex_unlock(&mutex_allocation);
           return(NULL);
       }
   
       (*debug).suivant = ancienne_base;
       (*debug).ligne = ligne;
       (*debug).taille = taille;
       (*debug).ordre = ordre;
   
       pthread_mutex_unlock(&mutex_allocation);
   
       if (((*debug).fonction = malloc((strlen(fonction) + 1) *
               sizeof(unsigned char))) == NULL)
       {
           return(NULL);
       }
   
       if (((*debug).argument = malloc((strlen(argument) + 1) *
               sizeof(unsigned char))) == NULL)
       {
           return(NULL);
       }
   
       strcpy((*debug).fonction, fonction);
       strcpy((*debug).argument, argument);
   
       ordre++;
   
       return((*debug).pointeur);
   }
   
   void *
   debug_memoire_modification(void *pointeur, size_t taille,
           const unsigned char *fonction, unsigned long ligne,
           const unsigned char *argument)
   {
       struct_memoire  *element_courant;
   
       if (pointeur != NULL)
       {
           if (taille == 0)
           {
               // Revient à free()
               debug_memoire_retrait(pointeur);
               return(NULL);
           }
           else
           {
               // Réallocation réelle
   
               pthread_mutex_lock(&mutex_allocation);
   
               element_courant = debug;
   
               while(element_courant != NULL)
               {
                   if ((*element_courant).pointeur == pointeur)
                   {
                       break;
                   }
   
                   element_courant = (*element_courant).suivant;
               }
   
               if (element_courant == NULL)
               {
                   pthread_mutex_unlock(&mutex_allocation);
                   return(NULL);
               }
   
               pthread_mutex_unlock(&mutex_allocation);
   
               if (((*element_courant).pointeur = realloc(pointeur, taille))
                       == NULL)
               {
                   return(NULL);
               }
   
               (*element_courant).ligne = ligne;
               (*element_courant).taille = taille;
               free((*element_courant).fonction);
               free((*element_courant).argument);
   
               if (((*element_courant).fonction = malloc((strlen(fonction) + 1) *
                       sizeof(unsigned char))) == NULL)
               {
                   return(NULL);
               }
   
               if (((*element_courant).argument = malloc((strlen(argument) + 1) *
                       sizeof(unsigned char))) == NULL)
               {
                   return(NULL);
               }
   
               strcpy((*element_courant).fonction, fonction);
               strcpy((*element_courant).argument, argument);
   
               return((*element_courant).pointeur);
           }
       }
       else
       {
           // Revient à malloc()
           pointeur = debug_memoire_ajout(taille, fonction, ligne, argument);
           return(pointeur);
       }
   }
   
   void
   debug_memoire_retrait(void *pointeur)
   {
       struct_memoire  *element_courant;
       struct_memoire  *element_precedent;
   
       pthread_mutex_lock(&mutex_allocation);
   
       element_courant = debug;
       element_precedent = NULL;
   
       while(element_courant != NULL)
       {
           if ((*element_courant).pointeur == pointeur)
           {
               if (element_precedent == NULL)
               {
                   debug = (*debug).suivant;
               }
               else
               {
                   (*element_precedent).suivant = (*element_courant).suivant;
               }
   
               free((*element_courant).fonction);
               free((*element_courant).argument);
               free(element_courant);
   
               break;
           }
   
           element_precedent = element_courant;
           element_courant = (*element_courant).suivant;
       }
   
       pthread_mutex_unlock(&mutex_allocation);
   
       free(pointeur);
   
       return;
   }
   
   void
   debug_memoire_verification(struct_processus *s_etat_processus)
   {
       integer8        i;
   
       struct_memoire  *element_courant;
       struct_memoire  *element_suivant;
   
       fprintf(stderr, "[%d-%llu] MEMORY LEAK\n",
               getpid(), (unsigned long long) pthread_self());
   
       pthread_mutex_lock(&mutex_allocation);
   
       element_courant = debug;
       i = 1;
   
       while(element_courant != NULL)
       {
           fprintf(stderr, "[%d-%llu] MEDITATION %lld (%llu)\n", getpid(),
                   (unsigned long long) pthread_self(), i,
                   (*element_courant).ordre);
           fprintf(stderr, "[%d-%llu] P: %p, F: %s(), L: %lu, S: %d\n",
                   getpid(), (unsigned long long) pthread_self(),
                   (*element_courant).pointeur,
                   (*element_courant).fonction, (*element_courant).ligne,
                   (int) (*element_courant).taille);
           fprintf(stderr, "[%d-%llu] A: %s\n", getpid(),
                   (unsigned long long) pthread_self(),
                   (*element_courant).argument);
   
           switch(i)
           {
               // Affichage des méditations
               case 1:
               {
                   break;
               }
           }
   
           i++;
   
           element_suivant = (*element_courant).suivant;
           free((*element_courant).fonction);
           free((*element_courant).argument);
           free(element_courant);
           element_courant = element_suivant;
       }
   
       pthread_mutex_unlock(&mutex_allocation);
   
       fprintf(stderr, "[%d-%llu] END OF LIST\n", getpid(),
               (unsigned long long) pthread_self());
   
       return;
   }
   
   #endif
   
 // vim: ts=4  // vim: ts=4
Removed from v.1.1  
changed lines
  Added in v.1.14

CVSweb interface <joel.bertrand@systella.fr>