Diff for /rpl/src/rpl.c between versions 1.116 and 1.121

version 1.116, 2012/08/22 10:47:18 version 1.121, 2012/10/07 08:18:36
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.10    RPL/2 (R) version 4.1.11
   Copyright (C) 1989-2012 Dr. BERTRAND Joël    Copyright (C) 1989-2012 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
Line 80  rplinit(int argc, char *argv[], char *en Line 80  rplinit(int argc, char *argv[], char *en
   
     struct_processus                    *s_etat_processus;      struct_processus                    *s_etat_processus;
   
       struct_liste_variables_statiques    *l_element_statique_courant;
       struct_liste_variables_statiques    *l_element_statique_suivant;
   
     struct_table_variables_partagees    s_variables_partagees;      struct_table_variables_partagees    s_variables_partagees;
   
     struct sigaction                    action;      struct sigaction                    action;
Line 251  rplinit(int argc, char *argv[], char *en Line 254  rplinit(int argc, char *argv[], char *en
             &attributs_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_RECURSIVE);
       pthread_mutex_init(&mutex_sections_critiques, &attributs_mutex);
       pthread_mutexattr_destroy(&attributs_mutex);
   
 #   ifndef SEMAPHORES_NOMMES  #   ifndef SEMAPHORES_NOMMES
         sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);          sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
 #   else  #   else
Line 1928  rplinit(int argc, char *argv[], char *en Line 1936  rplinit(int argc, char *argv[], char *en
             gettimeofday(&((*s_etat_processus).horodatage_profilage), NULL);              gettimeofday(&((*s_etat_processus).horodatage_profilage), NULL);
   
             (*s_etat_processus).liste_mutexes = NULL;              (*s_etat_processus).liste_mutexes = NULL;
               (*s_etat_processus).sections_critiques = 0;
   
             (*s_etat_processus).test_instruction = 'N';              (*s_etat_processus).test_instruction = 'N';
             (*s_etat_processus).nombre_arguments = 0;              (*s_etat_processus).nombre_arguments = 0;
Line 1963  rplinit(int argc, char *argv[], char *en Line 1972  rplinit(int argc, char *argv[], char *en
             (*s_etat_processus).l_liste_variables_par_niveau = NULL;              (*s_etat_processus).l_liste_variables_par_niveau = NULL;
             (*s_etat_processus).gel_liste_variables = d_faux;              (*s_etat_processus).gel_liste_variables = d_faux;
             (*s_etat_processus).pointeur_variable_courante = NULL;              (*s_etat_processus).pointeur_variable_courante = NULL;
             (*s_etat_processus).s_liste_variables_statiques = NULL;              (*s_etat_processus).pointeur_variable_statique_courante = NULL;
             (*s_etat_processus).nombre_variables_statiques = 0;              (*s_etat_processus).l_liste_variables_statiques = NULL;
             (*s_etat_processus).nombre_variables_statiques_allouees = 0;  
             (*s_etat_processus).niveau_courant = 0;              (*s_etat_processus).niveau_courant = 0;
             (*s_etat_processus).niveau_initial = 0;              (*s_etat_processus).niveau_initial = 0;
             (*s_etat_processus).creation_variables_statiques = d_faux;              (*s_etat_processus).creation_variables_statiques = d_faux;
             (*s_etat_processus).creation_variables_partagees = d_faux;              (*s_etat_processus).creation_variables_partagees = d_faux;
             (*s_etat_processus).position_variable_statique_courante = 0;  
   
             (*s_etat_processus).s_bibliotheques = NULL;              (*s_etat_processus).s_bibliotheques = NULL;
             (*s_etat_processus).s_instructions_externes = NULL;              (*s_etat_processus).s_instructions_externes = NULL;
Line 2910  rplinit(int argc, char *argv[], char *en Line 2917  rplinit(int argc, char *argv[], char *en
                         }                          }
                     }                      }
   
                       for(i = 0; i < (*s_etat_processus).sections_critiques; i++)
                       {
                           pthread_mutex_unlock(&mutex_sections_critiques);
                       }
   
                     liberation(s_etat_processus, (*s_etat_processus).at_exit);                      liberation(s_etat_processus, (*s_etat_processus).at_exit);
                     liberation(s_etat_processus, (*s_etat_processus).at_poke);                      liberation(s_etat_processus, (*s_etat_processus).at_poke);
   
Line 3336  rplinit(int argc, char *argv[], char *en Line 3348  rplinit(int argc, char *argv[], char *en
                             (*s_etat_processus).s_arbre_variables, d_vrai);                              (*s_etat_processus).s_arbre_variables, d_vrai);
                     free((*s_etat_processus).pointeurs_caracteres_variables);                      free((*s_etat_processus).pointeurs_caracteres_variables);
   
                     for(i = 0; i < (*s_etat_processus)                      l_element_statique_courant = (*s_etat_processus)
                             .nombre_variables_statiques; i++)                              .l_liste_variables_statiques;
   
                       while(l_element_statique_courant != NULL)
                     {                      {
                         liberation(s_etat_processus, (*s_etat_processus)                          l_element_statique_suivant =
                                 .s_liste_variables_statiques[i].objet);                              (*l_element_statique_courant).suivant;
                         free((*s_etat_processus)                          free(l_element_statique_courant);
                                 .s_liste_variables_statiques[i].nom);                          l_element_statique_courant = l_element_statique_suivant;
                     }                      }
   
                     free((*s_etat_processus).s_liste_variables_statiques);  
   
                     for(i = 0; i < (*((*s_etat_processus)                      for(i = 0; i < (*((*s_etat_processus)
                             .s_liste_variables_partagees)).nombre_variables;                              .s_liste_variables_partagees)).nombre_variables;
                             i++)                              i++)
Line 3703  rplinit(int argc, char *argv[], char *en Line 3715  rplinit(int argc, char *argv[], char *en
   
     pthread_mutex_destroy(&((*s_etat_processus).mutex));      pthread_mutex_destroy(&((*s_etat_processus).mutex));
     pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));      pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
       pthread_mutex_destroy(&mutex_sections_critiques);
   
 #   ifndef SEMAPHORES_NOMMES  #   ifndef SEMAPHORES_NOMMES
     sem_post(&((*s_etat_processus).semaphore_fork));      sem_post(&((*s_etat_processus).semaphore_fork));
Line 3715  rplinit(int argc, char *argv[], char *en Line 3728  rplinit(int argc, char *argv[], char *en
   
     free((*s_etat_processus).localisation);      free((*s_etat_processus).localisation);
   
     pthread_mutex_destroy(&mutex_liste_threads);  
     pthread_mutex_destroy(&mutex_gestionnaires_signaux_atomique);  
   
 #   ifndef SEMAPHORES_NOMMES  #   ifndef SEMAPHORES_NOMMES
     sem_post(&semaphore_gestionnaires_signaux);      sem_post(&semaphore_gestionnaires_signaux);
     sem_destroy(&semaphore_gestionnaires_signaux);      sem_destroy(&semaphore_gestionnaires_signaux);

Removed from v.1.116  
changed lines
  Added in v.1.121


CVSweb interface <joel.bertrand@systella.fr>