Diff for /rpl/src/gestion_objets.c between versions 1.79 and 1.96

version 1.79, 2012/03/01 10:14:04 version 1.96, 2013/03/10 17:01:05
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.7    RPL/2 (R) version 4.1.13
   Copyright (C) 1989-2012 Dr. BERTRAND Joël    Copyright (C) 1989-2013 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 348  allocation(struct_processus *s_etat_proc Line 357  allocation(struct_processus *s_etat_proc
             {              {
                 if (((*s_objet).objet = malloc(sizeof(unsigned long))) == NULL)                  if (((*s_objet).objet = malloc(sizeof(unsigned long))) == 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 384  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 412  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 426  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 430  allocation(struct_processus *s_etat_proc Line 446  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 471  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 498  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 523  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 548  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 566  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 586  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 607  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 626  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 646  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 659  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 671  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 684  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 703  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 726  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 750  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 774  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 2283  copie_objet(struct_processus *s_etat_pro Line 2327  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 2817  copie_etat_processus(struct_processus *s Line 2866  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);
       (*s_nouvel_etat_processus).sections_critiques = 0;
   
     // 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 3106  copie_etat_processus(struct_processus *s Line 3156  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 3164  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

Removed from v.1.79  
changed lines
  Added in v.1.96


CVSweb interface <joel.bertrand@systella.fr>